--- rpl/src/instructions_s10.c 2018/05/30 09:27:37 1.99 +++ rpl/src/instructions_s10.c 2020/01/10 11:15:48 1.105 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.1.29 - Copyright (C) 1989-2018 Dr. BERTRAND Joël + RPL/2 (R) version 4.1.32 + Copyright (C) 1989-2020 Dr. BERTRAND Joël This file is part of RPL/2. @@ -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;