version 1.104, 2013/03/21 16:31:58
|
version 1.108, 2013/05/21 12:10:12
|
Line 1
|
Line 1
|
/* |
/* |
================================================================================ |
================================================================================ |
RPL/2 (R) version 4.1.13 |
RPL/2 (R) version 4.1.14 |
Copyright (C) 1989-2013 Dr. BERTRAND Joël |
Copyright (C) 1989-2013 Dr. BERTRAND Joël |
|
|
This file is part of RPL/2. |
This file is part of RPL/2. |
Line 819 instruction_detach(struct_processus *s_e
|
Line 819 instruction_detach(struct_processus *s_e
|
logical1 drapeau; |
logical1 drapeau; |
|
|
pid_t ppid; |
pid_t ppid; |
pid_t pid_final; |
|
|
|
pthread_attr_t attributs; |
pthread_attr_t attributs; |
|
|
Line 1040 instruction_detach(struct_processus *s_e
|
Line 1039 instruction_detach(struct_processus *s_e
|
return; |
return; |
} |
} |
|
|
if (pipe((*s_argument_thread).pipe_nombre_interruptions_attente) != 0) |
if (pipe((*s_argument_thread).pipe_nombre_elements_attente) != 0) |
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es_processus; |
(*s_etat_processus).erreur_systeme = d_es_processus; |
return; |
return; |
Line 1058 instruction_detach(struct_processus *s_e
|
Line 1057 instruction_detach(struct_processus *s_e
|
return; |
return; |
} |
} |
|
|
if (pipe((*s_argument_thread).pipe_nombre_objets_attente) != 0) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
|
|
|
if (pipe((*s_argument_thread).pipe_injections) != 0) |
if (pipe((*s_argument_thread).pipe_injections) != 0) |
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es_processus; |
(*s_etat_processus).erreur_systeme = d_es_processus; |
Line 1172 instruction_detach(struct_processus *s_e
|
Line 1165 instruction_detach(struct_processus *s_e
|
return; |
return; |
} |
} |
|
|
if (close((*s_argument_thread).pipe_nombre_interruptions_attente[1]) |
if (close((*s_argument_thread).pipe_nombre_elements_attente[1]) |
!= 0) |
!= 0) |
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es_processus; |
(*s_etat_processus).erreur_systeme = d_es_processus; |
Line 1185 instruction_detach(struct_processus *s_e
|
Line 1178 instruction_detach(struct_processus *s_e
|
return; |
return; |
} |
} |
|
|
if (close((*s_argument_thread).pipe_nombre_objets_attente[1]) != 0) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
|
|
|
if (close((*s_argument_thread).pipe_injections[0]) != 0) |
if (close((*s_argument_thread).pipe_injections[0]) != 0) |
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es_processus; |
(*s_etat_processus).erreur_systeme = d_es_processus; |
Line 1317 instruction_detach(struct_processus *s_e
|
Line 1304 instruction_detach(struct_processus *s_e
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
(*s_etat_processus).erreur_systeme = d_es_processus; |
} |
} |
else if (close((*s_argument_thread) |
else if (close((*s_argument_thread) |
.pipe_nombre_interruptions_attente[0]) != 0) |
.pipe_nombre_elements_attente[0]) != 0) |
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es_processus; |
(*s_etat_processus).erreur_systeme = d_es_processus; |
} |
} |
Line 1325 instruction_detach(struct_processus *s_e
|
Line 1312 instruction_detach(struct_processus *s_e
|
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es_processus; |
(*s_etat_processus).erreur_systeme = d_es_processus; |
} |
} |
else if (close((*s_argument_thread).pipe_nombre_objets_attente[0]) != 0) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
} |
|
else if (close((*s_argument_thread).pipe_injections[1]) != 0) |
else if (close((*s_argument_thread).pipe_injections[1]) != 0) |
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es_processus; |
(*s_etat_processus).erreur_systeme = d_es_processus; |
Line 1376 instruction_detach(struct_processus *s_e
|
Line 1359 instruction_detach(struct_processus *s_e
|
// Envoi d'une donnée pour signaler le démarrage du processus au thread |
// Envoi d'une donnée pour signaler le démarrage du processus au thread |
// de surveillance. |
// de surveillance. |
|
|
|
caractere = 0; |
|
|
if (write_atomic(s_etat_processus, |
if (write_atomic(s_etat_processus, |
(*s_argument_thread).pipe_nombre_objets_attente[1], |
(*s_argument_thread).pipe_nombre_elements_attente[1], |
"-", sizeof(unsigned char)) != sizeof(unsigned char)) |
&caractere, sizeof(caractere)) != sizeof(caractere)) |
{ |
{ |
pthread_mutex_unlock(&((*s_etat_processus).mutex)); |
pthread_mutex_unlock(&((*s_etat_processus).mutex)); |
(*s_etat_processus).erreur_systeme = d_es_processus; |
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
|
pid_final = -2; |
|
|
|
while((longueur_ecriture = write_atomic(s_etat_processus, |
while((longueur_ecriture = write_atomic(s_etat_processus, |
(*s_argument_thread).pipe_nombre_interruptions_attente[1], |
(*s_argument_thread).pipe_nombre_elements_attente[1], |
&pid_final, sizeof(pid_final))) != sizeof(pid_final)) |
&caractere, sizeof(caractere))) != sizeof(caractere)) |
{ |
|
if (longueur_ecriture == -1) |
|
{ |
|
break; |
|
} |
|
} |
|
|
|
while((longueur_ecriture = write_atomic(s_etat_processus, |
|
(*s_argument_thread).pipe_nombre_objets_attente[1], |
|
&pid_final, sizeof(pid_final))) != sizeof(pid_final)) |
|
{ |
{ |
if (longueur_ecriture == -1) |
if (longueur_ecriture == -1) |
{ |
{ |
Line 1414 instruction_detach(struct_processus *s_e
|
Line 1387 instruction_detach(struct_processus *s_e
|
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es_processus; |
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
|
pid_final = -2; |
|
|
|
while((longueur_ecriture = write_atomic(s_etat_processus, |
while((longueur_ecriture = write_atomic(s_etat_processus, |
(*s_argument_thread).pipe_nombre_interruptions_attente[1], |
(*s_argument_thread).pipe_nombre_elements_attente[1], |
&pid_final, sizeof(pid_final))) != sizeof(pid_final)) |
&caractere, sizeof(caractere))) != sizeof(caractere)) |
{ |
|
if (longueur_ecriture == -1) |
|
{ |
|
break; |
|
} |
|
} |
|
|
|
while((longueur_ecriture = write_atomic(s_etat_processus, |
|
(*s_argument_thread).pipe_nombre_objets_attente[1], |
|
&pid_final, sizeof(pid_final))) != sizeof(pid_final)) |
|
{ |
{ |
if (longueur_ecriture == -1) |
if (longueur_ecriture == -1) |
{ |
{ |
Line 1450 instruction_detach(struct_processus *s_e
|
Line 1411 instruction_detach(struct_processus *s_e
|
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es_processus; |
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
|
pid_final = -2; |
caractere = 0; |
|
|
while((longueur_ecriture = write_atomic(s_etat_processus, |
while((longueur_ecriture = write_atomic(s_etat_processus, |
(*s_argument_thread).pipe_nombre_interruptions_attente[1], |
(*s_argument_thread).pipe_nombre_elements_attente[1], |
&pid_final, sizeof(pid_final))) != sizeof(pid_final)) |
&caractere, sizeof(caractere))) != sizeof(caractere)) |
{ |
|
if (longueur_ecriture == -1) |
|
{ |
|
break; |
|
} |
|
} |
|
|
|
while((longueur_ecriture = write_atomic(s_etat_processus, |
|
(*s_argument_thread).pipe_nombre_objets_attente[1], |
|
&pid_final, sizeof(pid_final))) != sizeof(pid_final)) |
|
{ |
{ |
if (longueur_ecriture == -1) |
if (longueur_ecriture == -1) |
{ |
{ |
Line 1484 instruction_detach(struct_processus *s_e
|
Line 1435 instruction_detach(struct_processus *s_e
|
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es_processus; |
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
|
pid_final = -2; |
caractere = 0; |
|
|
while((longueur_ecriture = write_atomic(s_etat_processus, |
|
(*s_argument_thread).pipe_nombre_interruptions_attente[1], |
|
&pid_final, sizeof(pid_final))) != sizeof(pid_final)) |
|
{ |
|
if (longueur_ecriture == -1) |
|
{ |
|
break; |
|
} |
|
} |
|
|
|
while((longueur_ecriture = write_atomic(s_etat_processus, |
while((longueur_ecriture = write_atomic(s_etat_processus, |
(*s_argument_thread).pipe_nombre_objets_attente[1], |
(*s_argument_thread).pipe_nombre_elements_attente[1], |
&pid_final, sizeof(pid_final))) != sizeof(pid_final)) |
&caractere, sizeof(caractere))) != sizeof(caractere)) |
{ |
{ |
if (longueur_ecriture == -1) |
if (longueur_ecriture == -1) |
{ |
{ |
Line 1583 instruction_detach(struct_processus *s_e
|
Line 1524 instruction_detach(struct_processus *s_e
|
(*s_etat_processus).presence_pipes = d_vrai; |
(*s_etat_processus).presence_pipes = d_vrai; |
(*s_etat_processus).debug_programme = d_faux; |
(*s_etat_processus).debug_programme = d_faux; |
(*s_etat_processus).pipe_donnees = (*s_argument_thread).pipe_objets[1]; |
(*s_etat_processus).pipe_donnees = (*s_argument_thread).pipe_objets[1]; |
(*s_etat_processus).pipe_nombre_objets_attente = (*s_argument_thread) |
(*s_etat_processus).pipe_nombre_elements_attente = (*s_argument_thread) |
.pipe_nombre_objets_attente[1]; |
.pipe_nombre_elements_attente[1]; |
(*s_etat_processus).pipe_interruptions = (*s_argument_thread) |
(*s_etat_processus).pipe_interruptions = (*s_argument_thread) |
.pipe_interruptions[1]; |
.pipe_interruptions[1]; |
(*s_etat_processus).pipe_nombre_interruptions_attente = |
|
(*s_argument_thread).pipe_nombre_interruptions_attente[1]; |
|
(*s_etat_processus).pipe_injections = |
(*s_etat_processus).pipe_injections = |
(*s_argument_thread).pipe_injections[0]; |
(*s_argument_thread).pipe_injections[0]; |
(*s_etat_processus).pipe_nombre_injections = |
(*s_etat_processus).pipe_nombre_injections = |
Line 1632 instruction_detach(struct_processus *s_e
|
Line 1571 instruction_detach(struct_processus *s_e
|
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es; |
(*s_etat_processus).erreur_systeme = d_es; |
|
|
pid_final = -2; |
caractere = 0; |
|
|
while((longueur_ecriture = write_atomic(s_etat_processus, |
while((longueur_ecriture = write_atomic(s_etat_processus, |
(*s_argument_thread).pipe_nombre_interruptions_attente[1], |
(*s_argument_thread).pipe_nombre_elements_attente[1], |
&pid_final, sizeof(pid_final))) != sizeof(pid_final)) |
&caractere, sizeof(caractere))) != sizeof(caractere)) |
{ |
|
if (longueur_ecriture == -1) |
|
{ |
|
break; |
|
} |
|
} |
|
|
|
while((longueur_ecriture = write_atomic(s_etat_processus, |
|
(*s_argument_thread).pipe_nombre_objets_attente[1], |
|
&pid_final, sizeof(pid_final))) != sizeof(pid_final)) |
|
{ |
{ |
if (longueur_ecriture == -1) |
if (longueur_ecriture == -1) |
{ |
{ |
Line 1681 instruction_detach(struct_processus *s_e
|
Line 1610 instruction_detach(struct_processus *s_e
|
close((*s_argument_thread2).pipe_acquittement[1]); |
close((*s_argument_thread2).pipe_acquittement[1]); |
close((*s_argument_thread2).pipe_injections[1]); |
close((*s_argument_thread2).pipe_injections[1]); |
close((*s_argument_thread2).pipe_nombre_injections[1]); |
close((*s_argument_thread2).pipe_nombre_injections[1]); |
close((*s_argument_thread2).pipe_nombre_objets_attente[0]); |
close((*s_argument_thread2).pipe_nombre_elements_attente[0]); |
close((*s_argument_thread2).pipe_interruptions[0]); |
close((*s_argument_thread2).pipe_interruptions[0]); |
close((*s_argument_thread2) |
|
.pipe_nombre_interruptions_attente[0]); |
|
|
|
pthread_mutex_destroy(&((*s_argument_thread2).mutex)); |
pthread_mutex_destroy(&((*s_argument_thread2).mutex)); |
|
|
Line 1713 instruction_detach(struct_processus *s_e
|
Line 1640 instruction_detach(struct_processus *s_e
|
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es; |
(*s_etat_processus).erreur_systeme = d_es; |
|
|
pid_final = -2; |
caractere = 0; |
|
|
while((longueur_ecriture = write_atomic(s_etat_processus, |
while((longueur_ecriture = write_atomic(s_etat_processus, |
(*s_argument_thread).pipe_nombre_interruptions_attente[1], |
(*s_argument_thread).pipe_nombre_elements_attente[1], |
&pid_final, sizeof(pid_final))) != sizeof(pid_final)) |
&caractere, sizeof(caractere))) != sizeof(caractere)) |
{ |
|
if (longueur_ecriture == -1) |
|
{ |
|
break; |
|
} |
|
} |
|
|
|
while((longueur_ecriture = write_atomic(s_etat_processus, |
|
(*s_argument_thread).pipe_nombre_objets_attente[1], |
|
&pid_final, sizeof(pid_final))) != sizeof(pid_final)) |
|
{ |
{ |
if (longueur_ecriture == -1) |
if (longueur_ecriture == -1) |
{ |
{ |
Line 1778 instruction_detach(struct_processus *s_e
|
Line 1695 instruction_detach(struct_processus *s_e
|
|
|
if ((*s_etat_processus).erreur_systeme != d_es) |
if ((*s_etat_processus).erreur_systeme != d_es) |
{ |
{ |
pid_final = -2; |
caractere = 0; |
|
|
while((longueur_ecriture = write_atomic(s_etat_processus, |
|
(*s_argument_thread).pipe_nombre_interruptions_attente[1], |
|
&pid_final, sizeof(pid_final))) != sizeof(pid_final)) |
|
{ |
|
if (longueur_ecriture == -1) |
|
{ |
|
break; |
|
} |
|
} |
|
|
|
while((longueur_ecriture = write_atomic(s_etat_processus, |
while((longueur_ecriture = write_atomic(s_etat_processus, |
(*s_argument_thread).pipe_nombre_objets_attente[1], |
(*s_argument_thread).pipe_nombre_elements_attente[1], |
&pid_final, sizeof(pid_final))) != sizeof(pid_final)) |
&caractere, sizeof(caractere))) != sizeof(caractere)) |
{ |
{ |
if (longueur_ecriture == -1) |
if (longueur_ecriture == -1) |
{ |
{ |
Line 1831 instruction_detach(struct_processus *s_e
|
Line 1738 instruction_detach(struct_processus *s_e
|
|
|
if ((*s_etat_processus).erreur_systeme != d_es) |
if ((*s_etat_processus).erreur_systeme != d_es) |
{ |
{ |
pid_final = -2; |
caractere = 0; |
|
|
while((longueur_ecriture = write_atomic(s_etat_processus, |
|
(*s_argument_thread).pipe_nombre_interruptions_attente[1], |
|
&pid_final, sizeof(pid_final))) != sizeof(pid_final)) |
|
{ |
|
if (longueur_ecriture == -1) |
|
{ |
|
break; |
|
} |
|
} |
|
|
|
while((longueur_ecriture = write_atomic(s_etat_processus, |
while((longueur_ecriture = write_atomic(s_etat_processus, |
(*s_argument_thread).pipe_nombre_objets_attente[1], |
(*s_argument_thread).pipe_nombre_elements_attente[1], |
&pid_final, sizeof(pid_final))) != sizeof(pid_final)) |
&caractere, sizeof(caractere))) != sizeof(caractere)) |
{ |
{ |
if (longueur_ecriture == -1) |
if (longueur_ecriture == -1) |
{ |
{ |
Line 1999 instruction_detach(struct_processus *s_e
|
Line 1896 instruction_detach(struct_processus *s_e
|
} |
} |
else |
else |
{ |
{ |
if (((*s_etat_processus).var_volatile_alarme == 0) |
if (((*s_etat_processus).arret_depuis_abort == 0) |
&& ((*s_etat_processus).arret_depuis_abort == 0) |
|
&& ((*s_etat_processus).at_exit != NULL)) |
&& ((*s_etat_processus).at_exit != NULL)) |
{ |
{ |
(*s_etat_processus).var_volatile_requete_arret = 0; |
(*s_etat_processus).var_volatile_requete_arret = 0; |
|
(*s_etat_processus).var_volatile_alarme = 0; |
|
(*s_etat_processus).var_volatile_traitement_sigint |
|
= 0; |
|
|
|
if ((*s_etat_processus).profilage == d_vrai) |
|
{ |
|
profilage(s_etat_processus, "ATEXIT"); |
|
} |
|
|
if (evaluation(s_etat_processus, |
if (evaluation(s_etat_processus, |
(*s_etat_processus).at_exit, 'E') == |
(*s_etat_processus).at_exit, 'E') == |
Line 2012 instruction_detach(struct_processus *s_e
|
Line 1916 instruction_detach(struct_processus *s_e
|
(*s_etat_processus).erreur_execution = |
(*s_etat_processus).erreur_execution = |
d_ex_erreur_evaluation; |
d_ex_erreur_evaluation; |
} |
} |
|
|
|
if ((*s_etat_processus).profilage == d_vrai) |
|
{ |
|
profilage(s_etat_processus, NULL); |
|
} |
} |
} |
} |
} |
} |
} |
Line 2028 instruction_detach(struct_processus *s_e
|
Line 1937 instruction_detach(struct_processus *s_e
|
} |
} |
else |
else |
{ |
{ |
if (((*s_etat_processus).var_volatile_alarme == 0) |
if (((*s_etat_processus).arret_depuis_abort == 0) |
&& ((*s_etat_processus).arret_depuis_abort == 0) |
|
&& ((*s_etat_processus).at_exit != NULL)) |
&& ((*s_etat_processus).at_exit != NULL)) |
{ |
{ |
(*s_etat_processus).var_volatile_requete_arret = 0; |
(*s_etat_processus).var_volatile_requete_arret = 0; |
|
(*s_etat_processus).var_volatile_alarme = 0; |
|
(*s_etat_processus).var_volatile_traitement_sigint |
|
= 0; |
|
|
|
if ((*s_etat_processus).profilage == d_vrai) |
|
{ |
|
profilage(s_etat_processus, "ATEXIT"); |
|
} |
|
|
if (evaluation(s_etat_processus, |
if (evaluation(s_etat_processus, |
(*s_etat_processus).at_exit, 'E') == |
(*s_etat_processus).at_exit, 'E') == |
Line 2041 instruction_detach(struct_processus *s_e
|
Line 1957 instruction_detach(struct_processus *s_e
|
(*s_etat_processus).erreur_execution = |
(*s_etat_processus).erreur_execution = |
d_ex_erreur_evaluation; |
d_ex_erreur_evaluation; |
} |
} |
|
|
|
if ((*s_etat_processus).profilage == d_vrai) |
|
{ |
|
profilage(s_etat_processus, NULL); |
|
} |
} |
} |
} |
} |
|
|
Line 2073 instruction_detach(struct_processus *s_e
|
Line 1994 instruction_detach(struct_processus *s_e
|
pthread_cancel((*s_etat_processus).thread_fusible); |
pthread_cancel((*s_etat_processus).thread_fusible); |
} |
} |
|
|
pid_final = -2; |
caractere = 0; |
|
|
while((longueur_ecriture = write_atomic(s_etat_processus, |
|
(*s_argument_thread).pipe_nombre_interruptions_attente[1], |
|
&pid_final, sizeof(pid_final))) != sizeof(pid_final)) |
|
{ |
|
if (longueur_ecriture == -1) |
|
{ |
|
break; |
|
} |
|
} |
|
|
|
while((longueur_ecriture = write_atomic(s_etat_processus, |
while((longueur_ecriture = write_atomic(s_etat_processus, |
(*s_argument_thread).pipe_nombre_objets_attente[1], |
(*s_argument_thread).pipe_nombre_elements_attente[1], |
&pid_final, sizeof(pid_final))) != sizeof(pid_final)) |
&caractere, sizeof(caractere))) != sizeof(caractere)) |
{ |
{ |
if (longueur_ecriture == -1) |
if (longueur_ecriture == -1) |
{ |
{ |
Line 2116 instruction_detach(struct_processus *s_e
|
Line 2027 instruction_detach(struct_processus *s_e
|
{ |
{ |
while((longueur_ecriture = write_atomic(s_etat_processus, |
while((longueur_ecriture = write_atomic(s_etat_processus, |
(*s_argument_thread).pipe_erreurs[1], |
(*s_argument_thread).pipe_erreurs[1], |
&((*s_etat_processus).erreur_execution), |
(int *) &((*s_etat_processus).erreur_execution), |
sizeof((*s_etat_processus).erreur_execution))) != |
sizeof((*s_etat_processus).erreur_execution))) != |
sizeof((*s_etat_processus).erreur_execution)) |
sizeof((*s_etat_processus).erreur_execution)) |
{ |
{ |
Line 2148 instruction_detach(struct_processus *s_e
|
Line 2059 instruction_detach(struct_processus *s_e
|
{ |
{ |
while((longueur_ecriture = write_atomic(s_etat_processus, |
while((longueur_ecriture = write_atomic(s_etat_processus, |
(*s_argument_thread).pipe_erreurs[1], |
(*s_argument_thread).pipe_erreurs[1], |
&((*s_etat_processus).erreur_systeme), |
(int *) &((*s_etat_processus).erreur_systeme), |
sizeof((*s_etat_processus).erreur_systeme))) != |
sizeof((*s_etat_processus).erreur_systeme))) != |
sizeof((*s_etat_processus).erreur_systeme)) |
sizeof((*s_etat_processus).erreur_systeme)) |
{ |
{ |
Line 2188 instruction_detach(struct_processus *s_e
|
Line 2099 instruction_detach(struct_processus *s_e
|
|
|
close((*s_argument_thread).pipe_erreurs[1]); |
close((*s_argument_thread).pipe_erreurs[1]); |
close((*s_argument_thread).pipe_interruptions[1]); |
close((*s_argument_thread).pipe_interruptions[1]); |
close((*s_argument_thread).pipe_nombre_interruptions_attente[1]); |
close((*s_argument_thread).pipe_nombre_elements_attente[1]); |
close((*s_argument_thread).pipe_objets[1]); |
close((*s_argument_thread).pipe_objets[1]); |
close((*s_argument_thread).pipe_nombre_objets_attente[1]); |
|
close((*s_argument_thread).pipe_injections[0]); |
close((*s_argument_thread).pipe_injections[0]); |
close((*s_argument_thread).pipe_nombre_injections[0]); |
close((*s_argument_thread).pipe_nombre_injections[0]); |
close((*s_argument_thread).pipe_acquittement[0]); |
close((*s_argument_thread).pipe_acquittement[0]); |