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