--- rpl/src/instructions_s10.c 2011/09/14 17:55:59 1.44 +++ rpl/src/instructions_s10.c 2011/09/20 14:36:29 1.48 @@ -397,12 +397,6 @@ instruction_spawn(struct_processus *s_et // Lancement du thread fils - if (pthread_mutex_lock(&((*s_nouvel_etat_processus).mutex)) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; - } - (*s_argument_thread).s_nouvel_etat_processus = s_nouvel_etat_processus; (*s_argument_thread).s_etat_processus = s_etat_processus; @@ -431,6 +425,7 @@ instruction_spawn(struct_processus *s_et while((*s_argument_thread).thread_actif == d_faux) { + scrutation_interruptions(s_etat_processus); nanosleep(&attente, NULL); INCR_GRANULARITE(attente.tv_nsec); } @@ -477,14 +472,6 @@ instruction_spawn(struct_processus *s_et # endif # endif - // Attente de l'affectation de la grandeur processus.tid par le thread fils. - - if (pthread_mutex_lock(&((*s_nouvel_etat_processus).mutex)) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; - } - /* * On copie l'objet plutôt que le pointeur car cet objet peut être * accédé depuis deux threads distincts et aboutir à un blocage lors d'une @@ -500,6 +487,7 @@ instruction_spawn(struct_processus *s_et if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0) { + pthread_mutex_unlock(&((*s_nouvel_etat_processus).mutex)); (*s_etat_processus).erreur_systeme = d_es_processus; return; } @@ -561,6 +549,7 @@ instruction_spawn(struct_processus *s_et } } + scrutation_interruptions(s_etat_processus); l_element_courant = (*l_element_courant).suivant; } } while(drapeau == d_vrai); @@ -570,7 +559,6 @@ instruction_spawn(struct_processus *s_et .l_base_pile_processus), s_objet_systeme) == d_erreur) { pthread_mutex_unlock(&((*s_etat_processus).mutex)); - pthread_mutex_unlock(&((*s_nouvel_etat_processus).mutex)); return; } @@ -583,13 +571,11 @@ instruction_spawn(struct_processus *s_et if (empilement(s_etat_processus, &((*s_etat_processus).l_base_pile), s_objet_resultat) == d_erreur) { - pthread_mutex_unlock(&((*s_nouvel_etat_processus).mutex)); return; } if (pthread_mutex_lock(&(*s_argument_thread).mutex) != 0) { - pthread_mutex_unlock(&((*s_nouvel_etat_processus).mutex)); (*s_etat_processus).erreur_systeme = d_es_processus; return; } @@ -599,7 +585,6 @@ instruction_spawn(struct_processus *s_et // Le thread n'existe plus. pthread_join((*s_argument_thread).tid, NULL); - pthread_mutex_unlock(&((*s_nouvel_etat_processus).mutex)); pthread_mutex_unlock(&(*s_argument_thread).mutex); (*s_etat_processus).erreur_systeme = d_es_processus; return; @@ -607,13 +592,6 @@ instruction_spawn(struct_processus *s_et if (pthread_mutex_unlock(&(*s_argument_thread).mutex) != 0) { - pthread_mutex_unlock(&((*s_nouvel_etat_processus).mutex)); - (*s_etat_processus).erreur_systeme = d_es_processus; - return; - } - - if (pthread_mutex_unlock(&((*s_nouvel_etat_processus).mutex)) != 0) - { (*s_etat_processus).erreur_systeme = d_es_processus; return; } @@ -1127,7 +1105,11 @@ instruction_smphrdecr(struct_processus * } } - if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 0) +# ifndef SEMAPHORES_NOMMES + if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0) +# else + if (sem_post((*s_etat_processus).semaphore_fork) != 0) +# endif { (*s_etat_processus).erreur_systeme = d_es_processus; return; @@ -1138,7 +1120,12 @@ instruction_smphrdecr(struct_processus * { if (errno != EINTR) { - pthread_mutex_lock(&((*s_etat_processus).mutex_fork)); +# ifndef SEMAPHORES_NOMMES + sem_post(&((*s_etat_processus).semaphore_fork)); +# else + sem_post((*s_etat_processus).semaphore_fork); +# endif + (*s_etat_processus).erreur_execution = d_ex_semaphore; if ((*s_etat_processus).profilage == d_vrai) @@ -1151,15 +1138,22 @@ instruction_smphrdecr(struct_processus * } } - if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0) +# ifndef SEMAPHORES_NOMMES + while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0) +# else + while(sem_wait((*s_etat_processus).semaphore_fork) != 0) +# endif { - if ((*s_etat_processus).profilage == d_vrai) + if (errno != EINTR) { - profilage(s_etat_processus, NULL); - } + if ((*s_etat_processus).profilage == d_vrai) + { + profilage(s_etat_processus, NULL); + } - (*s_etat_processus).erreur_systeme = d_es_processus; - return; + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } } if ((*s_etat_processus).profilage == d_vrai) @@ -1267,7 +1261,11 @@ instruction_smphrtrydecr(struct_processu } } - if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 0) +# ifndef SEMAPHORES_NOMMES + if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0) +# else + if (sem_post((*s_etat_processus).semaphore_fork) != 0) +# endif { if ((*s_etat_processus).profilage == d_vrai) { @@ -1316,15 +1314,22 @@ instruction_smphrtrydecr(struct_processu } } - if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0) +# ifndef SEMAPHORES_NOMMES + while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0) +# else + while(sem_wait((*s_etat_processus).semaphore_fork) != 0) +# endif { - if ((*s_etat_processus).profilage == d_vrai) + if (errno != EINTR) { - profilage(s_etat_processus, NULL); - } + if ((*s_etat_processus).profilage == d_vrai) + { + profilage(s_etat_processus, NULL); + } - (*s_etat_processus).erreur_systeme = d_es_processus; - return; + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } } if ((*s_etat_processus).profilage == d_vrai)