--- rpl/src/gestion_processus.c 2016/03/22 17:12:14 1.84 +++ rpl/src/gestion_processus.c 2020/01/10 11:15:43 1.100 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.1.25 - Copyright (C) 1989-2016 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. @@ -73,7 +73,6 @@ surveillance_processus(void *argument) sigfillset(&set); pthread_sigmask(SIG_BLOCK, &set, NULL); - nombre_thread_surveillance_processus++; s_argument_thread = argument; s_etat_processus = (*s_argument_thread).s_etat_processus; @@ -84,7 +83,7 @@ surveillance_processus(void *argument) BUG(1, uprintf("General mutex error!\n")); } - insertion_thread_surveillance(s_etat_processus, s_argument_thread); + nombre_threads_surveillance_processus++; if (pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)) != 0) { @@ -92,6 +91,8 @@ surveillance_processus(void *argument) BUG(1, uprintf("General mutex error!\n")); } + insertion_thread_surveillance(s_etat_processus, s_argument_thread); + attente.tv_sec = 0; attente.tv_nsec = GRANULARITE_us * 1000; @@ -363,7 +364,8 @@ surveillance_processus(void *argument) } } - envoi_signal_thread((*s_argument_thread).thread_pere, + envoi_signal_thread(NULL, + (*s_argument_thread).thread_pere, rpl_siginject); break; } @@ -390,7 +392,6 @@ surveillance_processus(void *argument) } else { - perror("read"); (*s_etat_processus).erreur_systeme = d_es_processus; } @@ -631,7 +632,8 @@ surveillance_processus(void *argument) d_es_processus; } - envoi_signal_thread((*s_argument_thread).thread_pere, + envoi_signal_thread(NULL, + (*s_argument_thread).thread_pere, rpl_siginject); if (pthread_mutex_lock(&((*s_etat_processus) @@ -1427,8 +1429,22 @@ surveillance_processus(void *argument) fflush(stdout); } + if (pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)) != 0) + { + (*s_etat_processus).erreur_systeme_processus_fils = d_es_processus; + } + retrait_thread_surveillance(s_etat_processus, s_argument_thread); + if (pthread_mutex_lock(&((*s_etat_processus) + .mutex_pile_processus)) != 0) + { + (*s_etat_processus).erreur_systeme_processus_fils = d_es_processus; + } + + nombre_threads_surveillance_processus--; + if (pthread_mutex_unlock(&((*s_etat_processus) .mutex_pile_processus)) != 0) { @@ -1436,7 +1452,6 @@ surveillance_processus(void *argument) } } - nombre_thread_surveillance_processus--; pthread_exit(NULL); } @@ -3006,10 +3021,10 @@ scrutation_injection(struct_processus *s unsigned char tampon; unsigned char tampon_profilage[20]; - // Si on est dans le processus père, il n'y a rien à surveiller. - scrutation_interruptions(s_etat_processus); + // Si on est dans le processus père, il n'y a rien à surveiller. + if ((*s_etat_processus).var_volatile_processus_racine == 0) { fds.fd = (*s_etat_processus).pipe_nombre_injections; @@ -3173,7 +3188,6 @@ scrutation_injection(struct_processus *s } } } - } return;