--- rpl/src/gestion_threads.c 2019/02/07 21:44:14 1.111 +++ rpl/src/gestion_threads.c 2019/02/09 13:36:37 1.112 @@ -78,15 +78,12 @@ lancement_thread(void *argument) # ifndef SEMAPHORES_NOMMES sem_init(&((*s_etat_processus).semaphore_fork), 0, 0); -uprintf("[%d-%llu] Semaphore fork %p (gestion_threads.c)\n", (int) getpid(), - (unsigned long long) pthread_self(), - &((*s_etat_processus).semaphore_fork)); # else if (((*s_etat_processus).semaphore_fork = sem_init3(0, getpid(), pthread_self(), SEM_FORK)) == SEM_FAILED) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; - return(NULL); + pthread_exit(NULL); } # endif @@ -96,7 +93,7 @@ uprintf("[%d-%llu] Semaphore fork %p (ge if (pthread_mutex_lock(&((*s_argument_thread).mutex)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; - return(NULL); + pthread_exit(NULL); } (*s_argument_thread).thread_actif = d_vrai; @@ -104,7 +101,7 @@ uprintf("[%d-%llu] Semaphore fork %p (ge if (pthread_mutex_unlock(&((*s_argument_thread).mutex)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; - return(NULL); + pthread_exit(NULL); } // Envoi d'une donnée pour signaler le démarrage du thread au thread @@ -153,7 +150,22 @@ uprintf("[%d-%llu] Semaphore fork %p (ge break; } + if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + pthread_exit(NULL); + } + nanosleep(&attente, NULL); + + while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0) + { + if (errno != EINTR) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + pthread_exit(NULL); + } + } } if ((*s_etat_processus).debug == d_vrai) @@ -477,7 +489,8 @@ uprintf("[%d-%llu] Semaphore fork %p (ge (*(*l_element_courant).donnee).objet)).thread) .thread_actif == d_vrai) { - envoi_signal_thread((*(*((struct_processus_fils *) + envoi_signal_thread(NULL, + (*(*((struct_processus_fils *) (*(*l_element_courant).donnee).objet)).thread).tid, rpl_sigurg); } @@ -522,13 +535,15 @@ uprintf("[%d-%llu] Semaphore fork %p (ge { if ((*s_etat_processus).arret_depuis_abort == -1) { - envoi_signal_thread((*(*((struct_processus_fils *) + envoi_signal_thread(NULL, + (*(*((struct_processus_fils *) (*(*l_element_courant).donnee).objet)).thread) .tid, rpl_sigabort); } else { - envoi_signal_thread((*(*((struct_processus_fils *) + envoi_signal_thread(NULL, + (*(*((struct_processus_fils *) (*(*l_element_courant).donnee).objet)).thread) .tid, rpl_sigstop); } @@ -590,7 +605,7 @@ uprintf("[%d-%llu] Semaphore fork %p (ge .donnee).objet)).thread).nombre_objets_dans_pipe--; action.sa_handler = SIG_IGN; - action.sa_flags = SA_ONSTACK; + action.sa_flags = 0; if (sigaction(SIGPIPE, &action, ®istre) != 0) {