version 1.67, 2013/05/28 22:09:55
|
version 1.80, 2015/09/18 13:41:10
|
Line 1
|
Line 1
|
/* |
/* |
================================================================================ |
================================================================================ |
RPL/2 (R) version 4.1.14 |
RPL/2 (R) version 4.1.23 |
Copyright (C) 1989-2013 Dr. BERTRAND Joël |
Copyright (C) 1989-2015 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")); |
Line 85 surveillance_processus(void *argument)
|
Line 85 surveillance_processus(void *argument)
|
|
|
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) |
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")); |
Line 176 surveillance_processus(void *argument)
|
Line 176 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 379 surveillance_processus(void *argument)
|
Line 380 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 430 surveillance_processus(void *argument)
|
Line 431 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 621 surveillance_processus(void *argument)
|
Line 623 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 631 surveillance_processus(void *argument)
|
Line 633 surveillance_processus(void *argument)
|
envoi_signal_thread((*s_argument_thread).thread_pere, |
envoi_signal_thread((*s_argument_thread).thread_pere, |
rpl_siginject); |
rpl_siginject); |
|
|
if (pthread_mutex_lock(&((*s_etat_processus).mutex)) |
if (pthread_mutex_lock(&((*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 656 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 698 surveillance_processus(void *argument)
|
Line 700 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 989 surveillance_processus(void *argument)
|
Line 991 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 1083 surveillance_processus(void *argument)
|
Line 1086 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 1294 surveillance_processus(void *argument)
|
Line 1297 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 1304 surveillance_processus(void *argument)
|
Line 1308 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 1423 surveillance_processus(void *argument)
|
Line 1428 surveillance_processus(void *argument)
|
|
|
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_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; |
} |
} |