rpl/src/gestion_threads.c - diff

Return to gestion_threads.c CVS log

Up to [local] / rpl / src

Diff for /rpl/src/gestion_threads.c between versions 1.111 and 1.112

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, &registre) != 0)	if (sigaction(SIGPIPE, &action, &registre) != 0)
{	{

CVSweb interface <joel.bertrand@systella.fr>

Removed from v.1.111
changed lines
	Added in v.1.112