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.14 and 1.17

version 1.14, 2010/06/04 07:48:19	version 1.17, 2010/06/17 11:00:23
Line 53 surveillance_processus(void *argument)	Line 53 surveillance_processus(void *argument)

pid_t pid;	pid_t pid;
pid_t pid_candidat;	pid_t pid_candidat;
	pid_t pid_erreur;

pthread_t tid_candidat;	pthread_t tid_candidat;

Line 71 surveillance_processus(void *argument)	Line 72 surveillance_processus(void *argument)

unsigned char caractere;	unsigned char caractere;

unsigned int tampon_erreur;	unsigned int tampon_erreur_execution;
	unsigned int tampon_erreur_systeme;

sigemptyset(&masque);	sigemptyset(&masque);
sigaddset(&masque, SIGINJECT);	sigaddset(&masque, SIGINJECT);
Line 85 surveillance_processus(void *argument)	Line 87 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)
	{
	(*s_etat_processus).erreur_systeme = d_es_processus;
	BUG(1, uprintf("General mutex error!\n"));
	}

insertion_thread_surveillance(s_etat_processus, s_argument_thread);	insertion_thread_surveillance(s_etat_processus, s_argument_thread);

	if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
	{
	(*s_etat_processus).erreur_systeme = d_es_processus;
	BUG(1, uprintf("General mutex error!\n"));
	}

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

Line 1429 surveillance_processus(void *argument)	Line 1444 surveillance_processus(void *argument)
attente.tv_nsec = GRANULARITE_us * 1000;	attente.tv_nsec = GRANULARITE_us * 1000;

while(read_atomic(s_etat_processus, (*s_argument_thread).pipe_erreurs[0],	while(read_atomic(s_etat_processus, (*s_argument_thread).pipe_erreurs[0],
&((*s_etat_processus).erreur_execution_processus_fils),	&tampon_erreur_execution,
sizeof((*s_etat_processus).erreur_execution_processus_fils)) !=	sizeof((*s_etat_processus).erreur_execution_processus_fils)) !=
sizeof((*s_etat_processus).erreur_execution_processus_fils))	sizeof((*s_etat_processus).erreur_execution_processus_fils))
{	{
Line 1441 surveillance_processus(void *argument)	Line 1456 surveillance_processus(void *argument)
attente.tv_nsec = GRANULARITE_us * 1000;	attente.tv_nsec = GRANULARITE_us * 1000;

while(read_atomic(s_etat_processus, (*s_argument_thread).pipe_erreurs[0],	while(read_atomic(s_etat_processus, (*s_argument_thread).pipe_erreurs[0],
&tampon_erreur,	&tampon_erreur_systeme,
sizeof((*s_etat_processus).erreur_systeme_processus_fils)) !=	sizeof((*s_etat_processus).erreur_systeme_processus_fils)) !=
sizeof((*s_etat_processus).erreur_systeme_processus_fils))	sizeof((*s_etat_processus).erreur_systeme_processus_fils))
{	{
Line 1449 surveillance_processus(void *argument)	Line 1464 surveillance_processus(void *argument)
INCR_GRANULARITE(attente.tv_nsec);	INCR_GRANULARITE(attente.tv_nsec);
}	}

(*s_etat_processus).erreur_systeme_processus_fils = tampon_erreur;

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

while(read_atomic(s_etat_processus, (*s_argument_thread).pipe_erreurs[0],	while(read_atomic(s_etat_processus, (*s_argument_thread).pipe_erreurs[0],
&((*s_etat_processus).pid_erreur_processus_fils),	&pid_erreur,
sizeof((*s_etat_processus).pid_erreur_processus_fils)) !=	sizeof((*s_etat_processus).pid_erreur_processus_fils)) !=
sizeof((*s_etat_processus).pid_erreur_processus_fils))	sizeof((*s_etat_processus).pid_erreur_processus_fils))
{	{
Line 1464 surveillance_processus(void *argument)	Line 1477 surveillance_processus(void *argument)
}	}

/*	/*
* Si une erreur est d�clar�e dans le processus fils, le message
* d'erreur a d�j� �t� affich�.
*/

if (((*s_etat_processus).erreur_systeme_processus_fils != d_es) \|\|
((*s_etat_processus).erreur_execution_processus_fils != d_ex))
{
(*s_etat_processus).erreur_processus_fils = d_vrai;
(*s_etat_processus).invalidation_message_erreur = d_vrai;
}

/*
* Retrait du processus de la pile des processus	* Retrait du processus de la pile des processus
*/	*/

Line 1490 surveillance_processus(void *argument)	Line 1491 surveillance_processus(void *argument)
}	}
else	else
{	{
	(*s_etat_processus).erreur_execution_processus_fils =
	tampon_erreur_execution;
	(*s_etat_processus).erreur_systeme_processus_fils =
	tampon_erreur_systeme;
	(*s_etat_processus).pid_erreur_processus_fils = pid_erreur;

	/*
	* Si une erreur est d�clar�e dans le processus fils, le message
	* d'erreur a d�j� �t� affich�.
	*/

	if (((*s_etat_processus).erreur_systeme_processus_fils != d_es) \|\|
	((*s_etat_processus).erreur_execution_processus_fils != d_ex))
	{
	(*s_etat_processus).erreur_processus_fils = d_vrai;
	(*s_etat_processus).invalidation_message_erreur = d_vrai;
	}

do	do
{	{
drapeau_fin = d_faux;	drapeau_fin = d_faux;
Line 1754 surveillance_processus(void *argument)	Line 1773 surveillance_processus(void *argument)
(*s_etat_processus).l_base_pile_processus =	(*s_etat_processus).l_base_pile_processus =
(*l_element_courant).suivant;	(*l_element_courant).suivant;

	((((struct_processus_fils ) ((*l_element_courant)
	.donnee).objet)).thread).nombre_references--;

	// Cette r�f�rence ne peut �tre nulle car l'objet est encore
	// r�f�renc� par la liste des threads de surveillance.

	BUG(((((struct_processus_fils ) ((*l_element_courant)
	.donnee).objet)).thread).nombre_references <= 0,
	uprintf("((((struct_processus_fils *) "
	"((l_element_courant).donnee).objet)).thread)"
	".nombre_references = %d\n",
	((((struct_processus_fils *)
	((l_element_courant).donnee).objet)).thread)
	.nombre_references));

free(((l_element_courant).donnee).objet);	free(((l_element_courant).donnee).objet);
free((*l_element_courant).donnee);	free((*l_element_courant).donnee);
free(l_element_courant);	free(l_element_courant);
Line 1766 surveillance_processus(void *argument)	Line 1800 surveillance_processus(void *argument)
(*l_element_precedent).suivant =	(*l_element_precedent).suivant =
(*l_element_courant).suivant;	(*l_element_courant).suivant;

	((((struct_processus_fils ) ((*l_element_courant)
	.donnee).objet)).thread).nombre_references--;

	// Cette r�f�rence ne peut �tre nulle car l'objet est encore
	// r�f�renc� par la liste des threads de surveillance.

	BUG(((((struct_processus_fils ) ((*l_element_courant)
	.donnee).objet)).thread).nombre_references <= 0,
	uprintf("((((struct_processus_fils *) "
	"((l_element_courant).donnee).objet)).thread)"
	".nombre_references = %d\n",
	((((struct_processus_fils *)
	((l_element_courant).donnee).objet)).thread)
	.nombre_references));

free(((l_element_courant).donnee).objet);	free(((l_element_courant).donnee).objet);
free((*l_element_courant).donnee);	free((*l_element_courant).donnee);
free(l_element_courant);	free(l_element_courant);

CVSweb interface <joel.bertrand@systella.fr>

Removed from v.1.14
changed lines
	Added in v.1.17