--- rpl/src/instructions_s10.c 2013/02/27 17:11:44 1.69 +++ rpl/src/instructions_s10.c 2013/05/30 09:41:41 1.79 @@ -1,6 +1,6 @@ /* ================================================================================ - RPL/2 (R) version 4.1.13 + RPL/2 (R) version 4.1.14 Copyright (C) 1989-2013 Dr. BERTRAND Joël This file is part of RPL/2. @@ -233,7 +233,7 @@ instruction_spawn(struct_processus *s_et return; } - if (pipe((*s_argument_thread).pipe_nombre_interruptions_attente) != 0) + if (pipe((*s_argument_thread).pipe_nombre_elements_attente) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; @@ -251,12 +251,6 @@ instruction_spawn(struct_processus *s_et return; } - if (pipe((*s_argument_thread).pipe_nombre_objets_attente) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; - } - if (pipe((*s_argument_thread).pipe_injections) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; @@ -293,12 +287,10 @@ instruction_spawn(struct_processus *s_et (*s_nouvel_etat_processus).pipe_donnees = (*s_argument_thread).pipe_objets[1]; - (*s_nouvel_etat_processus).pipe_nombre_objets_attente = - (*s_argument_thread).pipe_nombre_objets_attente[1]; + (*s_nouvel_etat_processus).pipe_nombre_elements_attente = + (*s_argument_thread).pipe_nombre_elements_attente[1]; (*s_nouvel_etat_processus).pipe_interruptions = (*s_argument_thread).pipe_interruptions[1]; - (*s_nouvel_etat_processus).pipe_nombre_interruptions_attente = - (*s_argument_thread).pipe_nombre_interruptions_attente[1]; (*s_nouvel_etat_processus).pipe_injections = (*s_argument_thread).pipe_injections[0]; (*s_nouvel_etat_processus).pipe_nombre_injections = @@ -407,13 +399,39 @@ instruction_spawn(struct_processus *s_et attente.tv_sec = 0; attente.tv_nsec = GRANULARITE_us * 1000; + if (pthread_mutex_lock(&((*s_argument_thread).mutex)) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + while((*s_argument_thread).thread_actif == d_faux) { scrutation_interruptions(s_etat_processus); + + if (pthread_mutex_unlock(&((*s_argument_thread).mutex)) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + nanosleep(&attente, NULL); + + if (pthread_mutex_lock(&((*s_argument_thread).mutex)) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + INCR_GRANULARITE(attente.tv_nsec); } + if (pthread_mutex_unlock(&((*s_argument_thread).mutex)) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + if (pthread_attr_destroy(&attributs) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; @@ -471,9 +489,8 @@ instruction_spawn(struct_processus *s_et return; } - if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_lock(&((*s_etat_processus).mutex_pile_processus)) != 0) { - pthread_mutex_unlock(&((*s_nouvel_etat_processus).mutex)); (*s_etat_processus).erreur_systeme = d_es_processus; return; } @@ -502,29 +519,49 @@ instruction_spawn(struct_processus *s_et (*(*l_element_courant).donnee).objet)).thread) .tid, (*s_argument_thread).tid) != 0) { - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + scrutation_injection(s_etat_processus); + + if (pthread_mutex_lock(&((*s_etat_processus) + .mutex_interruptions)) != 0) { + pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)); (*s_etat_processus).erreur_systeme = d_es_processus; return; } - scrutation_injection(s_etat_processus); - if ((*s_etat_processus).nombre_interruptions_non_affectees != 0) { affectation_interruptions_logicielles(s_etat_processus); } + if (pthread_mutex_unlock(&((*s_etat_processus) + .mutex_interruptions)) != 0) + { + pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)); + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + if ((*s_etat_processus).nombre_interruptions_en_queue != 0) { traitement_interruptions_logicielles(s_etat_processus); } + if (pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + nanosleep(&attente, NULL); INCR_GRANULARITE(attente.tv_nsec); - if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_lock(&((*s_etat_processus) + .mutex_pile_processus)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; @@ -544,11 +581,11 @@ instruction_spawn(struct_processus *s_et (struct_liste_chainee **) &((*s_etat_processus) .l_base_pile_processus), s_objet_systeme) == d_erreur) { - pthread_mutex_unlock(&((*s_etat_processus).mutex)); + pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)); return; } - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; @@ -1276,7 +1313,8 @@ instruction_smphrtrydecr(struct_processu return; } - horodatage.tv_sec += (*((integer8 *) (*s_objet_argument_1).objet)); + horodatage.tv_sec += (time_t) (*((integer8 *) + (*s_objet_argument_1).objet)); } else { @@ -1290,7 +1328,7 @@ instruction_smphrtrydecr(struct_processu } partie_entiere = floor((*((real8 *) (*s_objet_argument_1).objet))); - horodatage.tv_sec += partie_entiere; + horodatage.tv_sec += (time_t) partie_entiere; horodatage.tv_usec += ((suseconds_t) ((*((real8 *) (*s_objet_argument_1).objet)) - partie_entiere)) * 1000000; @@ -1647,8 +1685,8 @@ instruction_svd(struct_processus *s_etat struct_vecteur s_vecteur; - unsigned long i; - unsigned long j; + integer8 i; + integer8 j; (*s_etat_processus).erreur_execution = d_ex; @@ -1740,8 +1778,8 @@ instruction_svd(struct_processus *s_etat .nombre_lignes; if (((*((struct_matrice *) (*s_objet_resultat_2).objet)).tableau = - malloc((*((struct_matrice *) (*s_objet_resultat_2).objet)) - .nombre_lignes * sizeof(real8 *))) == NULL) + malloc(((size_t) (*((struct_matrice *) (*s_objet_resultat_2) + .objet)).nombre_lignes) * sizeof(real8 *))) == NULL) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; return; @@ -1751,9 +1789,9 @@ instruction_svd(struct_processus *s_etat .nombre_lignes; i++) { if ((((real8 **) (*((struct_matrice *) (*s_objet_resultat_2) - .objet)).tableau)[i] = malloc((*((struct_matrice *) - (*s_objet_resultat_2).objet)).nombre_colonnes * - sizeof(real8 *))) == NULL) + .objet)).tableau)[i] = malloc(((size_t) + (*((struct_matrice *) (*s_objet_resultat_2).objet)) + .nombre_colonnes) * sizeof(real8 *))) == NULL) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; return; @@ -1840,8 +1878,8 @@ instruction_svd(struct_processus *s_etat .nombre_lignes; if (((*((struct_matrice *) (*s_objet_resultat_2).objet)).tableau = - malloc((*((struct_matrice *) (*s_objet_resultat_2).objet)) - .nombre_lignes * sizeof(real8 *))) == NULL) + malloc(((size_t) (*((struct_matrice *) (*s_objet_resultat_2) + .objet)).nombre_lignes) * sizeof(real8 *))) == NULL) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; return; @@ -1851,9 +1889,9 @@ instruction_svd(struct_processus *s_etat .nombre_lignes; i++) { if ((((real8 **) (*((struct_matrice *) (*s_objet_resultat_2) - .objet)).tableau)[i] = malloc((*((struct_matrice *) - (*s_objet_resultat_2).objet)).nombre_colonnes * - sizeof(real8 *))) == NULL) + .objet)).tableau)[i] = malloc(((size_t) + (*((struct_matrice *) (*s_objet_resultat_2).objet)) + .nombre_colonnes) * sizeof(real8 *))) == NULL) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; return;