--- rpl/src/instructions_s10.c 2019/02/03 14:40:56 1.102 +++ rpl/src/instructions_s10.c 2019/02/09 13:36:41 1.103 @@ -38,6 +38,8 @@ void instruction_spawn(struct_processus *s_etat_processus) { + int ios; + logical1 drapeau; logical1 variable_partagee; @@ -415,8 +417,31 @@ instruction_spawn(struct_processus *s_et return; } +# 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; + } + nanosleep(&attente, NULL); +# ifndef SEMAPHORES_NOMMES + while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0) +# else + while(sem_wait((*s_etat_processus).semaphore_fork) != 0) +# endif + { + if (errno != EINTR) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + } + if (pthread_mutex_lock(&((*s_argument_thread).mutex)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; @@ -489,10 +514,34 @@ instruction_spawn(struct_processus *s_et return; } - if (pthread_mutex_lock(&((*s_etat_processus).mutex_pile_processus)) != 0) + attente.tv_sec = 0; + attente.tv_nsec = GRANULARITE_us * 1000; + + while((ios = pthread_mutex_trylock(&((*s_etat_processus) + .mutex_pile_processus))) != 0) { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; + if (ios != EBUSY) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + } + + if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + + nanosleep(&attente, NULL); + INCR_GRANULARITE(attente.tv_nsec); + + while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0) + { + if (errno != EINTR) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + } } // Si le tid existe déjà  dans la pile des processus, il s'agit forcement @@ -636,7 +685,8 @@ instruction_spawn(struct_processus *s_et // Le fils peut être présent sans être en attente du signal de départ. - if (envoi_signal_thread((*s_argument_thread).tid, rpl_sigstart) != 0) + if (envoi_signal_thread(s_etat_processus, + (*s_argument_thread).tid, rpl_sigstart) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return;