version 1.14, 2010/06/04 07:48:19
|
version 1.19, 2010/06/19 15:54:51
|
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 1753 surveillance_processus(void *argument)
|
Line 1772 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; |
|
|
free((*(*l_element_courant).donnee).objet); |
|
free((*l_element_courant).donnee); |
|
free(l_element_courant); |
|
|
|
l_element_courant = (struct_liste_chainee *) |
|
(*s_etat_processus).l_base_pile_processus; |
|
} |
} |
else |
else |
{ |
{ |
(*l_element_precedent).suivant = |
(*l_element_precedent).suivant = |
(*l_element_courant).suivant; |
(*l_element_courant).suivant; |
|
|
free((*(*l_element_courant).donnee).objet); |
|
free((*l_element_courant).donnee); |
|
free(l_element_courant); |
|
} |
} |
|
|
|
liberation(s_etat_processus, (*l_element_courant).donnee); |
|
free(l_element_courant); |
|
|
break; |
break; |
} |
} |
else |
else |