rpl/src/gestion_processus.c - diff

Return to gestion_processus.c CVS log

Up to [local] / rpl / src

Diff for /rpl/src/gestion_processus.c between versions 1.66 and 1.100

version 1.66, 2013/05/21 12:10:11	version 1.100, 2020/01/10 11:15:43
Line 1	Line 1
/*	/*
================================================================================	================================================================================
RPL/2 (R) version 4.1.14	RPL/2 (R) version 4.1.32
Copyright (C) 1989-2013 Dr. BERTRAND Joël	Copyright (C) 1989-2020 Dr. BERTRAND Joël

This file is part of RPL/2.	This file is part of RPL/2.

Line 77 surveillance_processus(void *argument)	Line 77 surveillance_processus(void *argument)
s_argument_thread = argument;	s_argument_thread = argument;
s_etat_processus = (*s_argument_thread).s_etat_processus;	s_etat_processus = (*s_argument_thread).s_etat_processus;

if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0)	if (pthread_mutex_lock(&((*s_etat_processus).mutex_pile_processus)) != 0)
{	{
(*s_etat_processus).erreur_systeme = d_es_processus;	(*s_etat_processus).erreur_systeme = d_es_processus;
BUG(1, uprintf("General mutex error!\n"));	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)) != 0)	if (pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)) != 0)
{	{
(*s_etat_processus).erreur_systeme = d_es_processus;	(*s_etat_processus).erreur_systeme = d_es_processus;
BUG(1, uprintf("General mutex error!\n"));	BUG(1, uprintf("General mutex error!\n"));
}	}

	insertion_thread_surveillance(s_etat_processus, s_argument_thread);

attente.tv_sec = 0;	attente.tv_sec = 0;
attente.tv_nsec = GRANULARITE_us * 1000;	attente.tv_nsec = GRANULARITE_us * 1000;

Line 176 surveillance_processus(void *argument)	Line 178 surveillance_processus(void *argument)
// Un objet supplémentaire est dans le pipe correspondant	// Un objet supplémentaire est dans le pipe correspondant
// au processus surveillé par ce thread.	// au processus surveillé par ce thread.

if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0)	if (pthread_mutex_lock(&((*s_etat_processus)
	.mutex_pile_processus)) != 0)
{	{
(*s_etat_processus).erreur_systeme_processus_fils =	(*s_etat_processus).erreur_systeme_processus_fils =
d_es_processus;	d_es_processus;
Line 274 surveillance_processus(void *argument)	Line 277 surveillance_processus(void *argument)
((((struct_processus_fils *)	((((struct_processus_fils *)
((l_element_courant).donnee).objet))	((l_element_courant).donnee).objet))
.thread).nombre_interruptions_dans_pipe++;	.thread).nombre_interruptions_dans_pipe++;

	if (pthread_mutex_lock(&((*s_etat_processus)
	.mutex_interruptions)) != 0)
	{
	(*s_etat_processus).erreur_systeme =
	d_es_processus;
	}

(*s_etat_processus)	(*s_etat_processus)
.nombre_interruptions_non_affectees++;	.nombre_interruptions_non_affectees++;

	if (pthread_mutex_unlock(&((*s_etat_processus)
	.mutex_interruptions)) != 0)
	{
	(*s_etat_processus).erreur_systeme =
	d_es_processus;
	}
}	}

if (pthread_mutex_unlock(	if (pthread_mutex_unlock(
Line 346 surveillance_processus(void *argument)	Line 364 surveillance_processus(void *argument)
}	}
}	}

envoi_signal_thread((*s_argument_thread).thread_pere,	envoi_signal_thread(NULL,
	(*s_argument_thread).thread_pere,
rpl_siginject);	rpl_siginject);
break;	break;
}	}
Line 364 surveillance_processus(void *argument)	Line 383 surveillance_processus(void *argument)
}	}
}	}

if (pthread_mutex_unlock(&((*s_etat_processus).mutex))	if (pthread_mutex_unlock(&((*s_etat_processus)
!= 0)	.mutex_pile_processus)) != 0)
{	{
(*s_etat_processus).erreur_systeme_processus_fils =	(*s_etat_processus).erreur_systeme_processus_fils =
d_es_processus;	d_es_processus;
Line 373 surveillance_processus(void *argument)	Line 392 surveillance_processus(void *argument)
}	}
else	else
{	{
perror("read");
(*s_etat_processus).erreur_systeme = d_es_processus;	(*s_etat_processus).erreur_systeme = d_es_processus;
}	}

Line 415 surveillance_processus(void *argument)	Line 433 surveillance_processus(void *argument)
// Un objet supplémentaire est dans le pipe correspondant	// Un objet supplémentaire est dans le pipe correspondant
// au processus surveillé par ce thread.	// au processus surveillé par ce thread.

if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0)	if (pthread_mutex_lock(&((*s_etat_processus)
	.mutex_pile_processus)) != 0)
{	{
(*s_etat_processus).erreur_systeme_processus_fils =	(*s_etat_processus).erreur_systeme_processus_fils =
d_es_processus;	d_es_processus;
Line 430 surveillance_processus(void *argument)	Line 449 surveillance_processus(void *argument)
((l_element_courant).donnee).objet))	((l_element_courant).donnee).objet))
.thread).processus_detache == d_vrai)	.thread).processus_detache == d_vrai)
{	{
l_element_courant = (*l_element_courant)	l_element_courant = (*l_element_courant).suivant;
.suivant;
continue;	continue;
}	}

Line 516 surveillance_processus(void *argument)	Line 534 surveillance_processus(void *argument)
((((struct_processus_fils *)	((((struct_processus_fils *)
((l_element_courant).donnee).objet))	((l_element_courant).donnee).objet))
.thread).nombre_interruptions_dans_pipe++;	.thread).nombre_interruptions_dans_pipe++;

	if (pthread_mutex_lock(&((*s_etat_processus)
	.mutex_interruptions)) != 0)
	{
	(*s_etat_processus).erreur_systeme =
	d_es_processus;
	}

(*s_etat_processus)	(*s_etat_processus)
.nombre_interruptions_non_affectees++;	.nombre_interruptions_non_affectees++;

	if (pthread_mutex_unlock(&((*s_etat_processus)
	.mutex_interruptions)) != 0)
	{
	(*s_etat_processus).erreur_systeme =
	d_es_processus;
	}
}	}

if (pthread_mutex_unlock(	if (pthread_mutex_unlock(
Line 592 surveillance_processus(void *argument)	Line 625 surveillance_processus(void *argument)
}	}
}	}

envoi_signal_thread((*s_argument_thread).thread_pere,	if (pthread_mutex_unlock(&((*s_etat_processus)
	.mutex_pile_processus)) != 0)
	{
	(*s_etat_processus).erreur_systeme_processus_fils =
	d_es_processus;
	}

	envoi_signal_thread(NULL,
	(*s_argument_thread).thread_pere,
rpl_siginject);	rpl_siginject);

	if (pthread_mutex_lock(&((*s_etat_processus)
	.mutex_pile_processus)) != 0)
	{
	(*s_etat_processus).erreur_systeme_processus_fils =
	d_es_processus;
	}

break;	break;
}	}

Line 610 surveillance_processus(void *argument)	Line 659 surveillance_processus(void *argument)
}	}
}	}

if (pthread_mutex_unlock(&((*s_etat_processus).mutex))	if (pthread_mutex_unlock(&((*s_etat_processus)
!= 0)	.mutex_pile_processus)) != 0)
{	{
(*s_etat_processus).erreur_systeme_processus_fils =	(*s_etat_processus).erreur_systeme_processus_fils =
d_es_processus;	d_es_processus;
Line 654 surveillance_processus(void *argument)	Line 703 surveillance_processus(void *argument)
* reste plus rien dans les tuyaux...	* reste plus rien dans les tuyaux...
*/	*/

if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0)	if (pthread_mutex_lock(&((*s_etat_processus).mutex_pile_processus)) != 0)
{	{
(*s_etat_processus).erreur_systeme_processus_fils =	(*s_etat_processus).erreur_systeme_processus_fils =
d_es_processus;	d_es_processus;
Line 790 surveillance_processus(void *argument)	Line 839 surveillance_processus(void *argument)
((l_element_courant).donnee).objet))	((l_element_courant).donnee).objet))
.thread)	.thread)
.nombre_interruptions_dans_pipe++;	.nombre_interruptions_dans_pipe++;

	if (pthread_mutex_lock(&((*s_etat_processus)
	.mutex_interruptions)) != 0)
	{
	(*s_etat_processus).erreur_systeme =
	d_es_processus;
	}

(*s_etat_processus)	(*s_etat_processus)
.nombre_interruptions_non_affectees++;	.nombre_interruptions_non_affectees++;

	if (pthread_mutex_unlock(&((*s_etat_processus)
	.mutex_interruptions)) != 0)
	{
	(*s_etat_processus).erreur_systeme =
	d_es_processus;
	}
}	}

if (pthread_mutex_unlock(	if (pthread_mutex_unlock(
Line 893 surveillance_processus(void *argument)	Line 957 surveillance_processus(void *argument)
((l_element_courant).donnee).objet))	((l_element_courant).donnee).objet))
.thread)	.thread)
.nombre_interruptions_dans_pipe++;	.nombre_interruptions_dans_pipe++;

	if (pthread_mutex_lock(&((*s_etat_processus)
	.mutex_interruptions)) != 0)
	{
	(*s_etat_processus).erreur_systeme =
	d_es_processus;
	}

(*s_etat_processus)	(*s_etat_processus)
.nombre_interruptions_non_affectees++;	.nombre_interruptions_non_affectees++;

	if (pthread_mutex_unlock(&((*s_etat_processus)
	.mutex_interruptions)) != 0)
	{
	(*s_etat_processus).erreur_systeme =
	d_es_processus;
	}
}	}

if (pthread_mutex_unlock(	if (pthread_mutex_unlock(
Line 915 surveillance_processus(void *argument)	Line 994 surveillance_processus(void *argument)
}	}
}	}

if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)	if (pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus))
	!= 0)
{	{
(*s_etat_processus).erreur_systeme_processus_fils =	(*s_etat_processus).erreur_systeme_processus_fils =
d_es_processus;	d_es_processus;
Line 1009 surveillance_processus(void *argument)	Line 1089 surveillance_processus(void *argument)
(*s_etat_processus).erreur_systeme_processus_fils = d_es_processus;	(*s_etat_processus).erreur_systeme_processus_fils = d_es_processus;
}	}

if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0)	if (pthread_mutex_lock(&((*s_etat_processus).mutex_pile_processus)) != 0)
{	{
(*s_etat_processus).erreur_systeme_processus_fils = d_es_processus;	(*s_etat_processus).erreur_systeme_processus_fils = d_es_processus;
}	}
Line 1220 surveillance_processus(void *argument)	Line 1300 surveillance_processus(void *argument)
}	}
else	else
{	{
if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)	if (pthread_mutex_unlock(&((*s_etat_processus)
	.mutex_pile_processus)) != 0)
{	{
(*s_etat_processus).erreur_systeme_processus_fils =	(*s_etat_processus).erreur_systeme_processus_fils =
d_es_processus;	d_es_processus;
Line 1230 surveillance_processus(void *argument)	Line 1311 surveillance_processus(void *argument)
nanosleep(&attente, NULL);	nanosleep(&attente, NULL);
INCR_GRANULARITE(attente.tv_nsec);	INCR_GRANULARITE(attente.tv_nsec);

if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0)	if (pthread_mutex_lock(&((*s_etat_processus)
	.mutex_pile_processus)) != 0)
{	{
(*s_etat_processus).erreur_systeme_processus_fils =	(*s_etat_processus).erreur_systeme_processus_fils =
d_es_processus;	d_es_processus;
Line 1347 surveillance_processus(void *argument)	Line 1429 surveillance_processus(void *argument)
fflush(stdout);	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);	retrait_thread_surveillance(s_etat_processus, s_argument_thread);

if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)	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)
{	{
(*s_etat_processus).erreur_systeme_processus_fils = d_es_processus;	(*s_etat_processus).erreur_systeme_processus_fils = d_es_processus;
}	}
}	}

pthread_exit(NULL);	pthread_exit(NULL);
return(NULL);
}	}


Line 2917 lecture_pipe(struct_processus *s_etat_pr	Line 3013 lecture_pipe(struct_processus *s_etat_pr
void	void
scrutation_injection(struct_processus *s_etat_processus)	scrutation_injection(struct_processus *s_etat_processus)
{	{
fd_set ensemble_descripteurs;

logical1 drapeau_erreur;	logical1 drapeau_erreur;
logical1 registre_arret_si_exception;	logical1 registre_arret_si_exception;

# ifdef PSELECT	struct pollfd fds;
struct timespec timeout;
# else
struct timeval timeout;
# endif

unsigned char tampon;	unsigned char tampon;
unsigned char tampon_profilage[20];	unsigned char tampon_profilage[20];

// Si on est dans le processus père, il n'y a rien à surveiller.

scrutation_interruptions(s_etat_processus);	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)	if ((*s_etat_processus).var_volatile_processus_racine == 0)
{	{
FD_ZERO(&ensemble_descripteurs);	fds.fd = (*s_etat_processus).pipe_nombre_injections;
FD_SET((*s_etat_processus).pipe_nombre_injections,	fds.events = POLLIN;
&ensemble_descripteurs);	fds.revents = 0;

# ifdef PSELECT	if (poll(&fds, 1, 0) > 0)
timeout.tv_sec = 0;
timeout.tv_nsec = 0;

if (pselect((*s_etat_processus).pipe_nombre_injections + 1,
&ensemble_descripteurs, NULL, NULL, &timeout, NULL) > 0)
# else
timeout.tv_sec = 0;
timeout.tv_usec = 0;

if (select((*s_etat_processus).pipe_nombre_injections + 1,
&ensemble_descripteurs, NULL, NULL, &timeout) > 0)
# endif
{	{
if (read_atomic(s_etat_processus,	if (read_atomic(s_etat_processus,
(*s_etat_processus).pipe_nombre_injections,	(*s_etat_processus).pipe_nombre_injections,
Line 3110 scrutation_injection(struct_processus *s	Line 3188 scrutation_injection(struct_processus *s
}	}
}	}
}	}

}	}

return;	return;

CVSweb interface <joel.bertrand@systella.fr>

Removed from v.1.66
changed lines
	Added in v.1.100