version 1.14, 2010/06/04 07:48:19
|
version 1.16, 2010/06/09 12:19:13
|
Line 85 surveillance_processus(void *argument)
|
Line 85 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 1754 surveillance_processus(void *argument)
|
Line 1768 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 1795 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); |