version 1.112, 2013/05/30 09:41:41
|
version 1.180, 2024/01/09 07:33:50
|
Line 1
|
Line 1
|
/* |
/* |
================================================================================ |
================================================================================ |
RPL/2 (R) version 4.1.14 |
RPL/2 (R) version 4.1.35 |
Copyright (C) 1989-2013 Dr. BERTRAND Joël |
Copyright (C) 1989-2024 Dr. BERTRAND Joël |
|
|
This file is part of RPL/2. |
This file is part of RPL/2. |
|
|
Line 767 instruction_der(struct_processus *s_etat
|
Line 767 instruction_der(struct_processus *s_etat
|
if ((s_objet_simplifie = simplification(s_etat_processus, |
if ((s_objet_simplifie = simplification(s_etat_processus, |
s_objet_resultat)) == NULL) |
s_objet_resultat)) == NULL) |
{ |
{ |
|
liberation(s_etat_processus, s_objet_resultat); |
return; |
return; |
} |
} |
|
|
Line 1087 instruction_detach(struct_processus *s_e
|
Line 1088 instruction_detach(struct_processus *s_e
|
return; |
return; |
} |
} |
|
|
|
verrouillage_threads_concurrents(s_etat_processus); |
|
|
|
if (pthread_mutex_lock(&mutex_liste_variables_partagees) != 0) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
|
|
|
if (pthread_mutex_lock(&((*s_etat_processus).mutex_allocation_buffer)) != 0) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
|
|
fflush(NULL); |
fflush(NULL); |
|
|
/* |
/* |
Line 1094 instruction_detach(struct_processus *s_e
|
Line 1109 instruction_detach(struct_processus *s_e
|
* de mémoire, ni libération, ni copie d'objet concurrent au fork(). |
* de mémoire, ni libération, ni copie d'objet concurrent au fork(). |
*/ |
*/ |
|
|
verrouillage_threads_concurrents(s_etat_processus); |
|
(*s_argument_thread).pid = fork(); |
(*s_argument_thread).pid = fork(); |
deverrouillage_threads_concurrents(s_etat_processus); |
|
|
if (pthread_mutex_unlock(&((*s_etat_processus).mutex_allocation_buffer)) |
|
!= 0) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
|
|
|
if ((*s_argument_thread).pid > 0) |
|
{ |
|
// On ne déverrouille les threads concurrents que dans le processus |
|
// père. Dans le fils, les valeurs sont non initialisées. |
|
deverrouillage_threads_concurrents(s_etat_processus); |
|
} |
|
|
(*s_argument_thread).thread_pere = pthread_self(); |
(*s_argument_thread).thread_pere = pthread_self(); |
(*s_argument_thread).processus_detache = d_vrai; |
(*s_argument_thread).processus_detache = d_vrai; |
Line 1118 instruction_detach(struct_processus *s_e
|
Line 1145 instruction_detach(struct_processus *s_e
|
* Processus père |
* Processus père |
*/ |
*/ |
|
|
|
if (pthread_mutex_unlock(&mutex_liste_variables_partagees) != 0) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
|
|
if (variable_partagee == d_vrai) |
if (variable_partagee == d_vrai) |
{ |
{ |
liberation(s_etat_processus, s_copie); |
liberation(s_etat_processus, s_copie); |
Line 1255 instruction_detach(struct_processus *s_e
|
Line 1288 instruction_detach(struct_processus *s_e
|
* Processus fils |
* Processus fils |
*/ |
*/ |
|
|
if (lancement_thread_signaux(s_etat_processus) != d_absence_erreur) |
// EPERM |
{ |
#if 0 |
(*s_etat_processus).erreur_systeme = d_es_processus; |
pthread_mutex_destroy(&mutex_liste_variables_partagees); |
} |
pthread_mutex_destroy(&mutex_liste_threads); |
|
pthread_mutex_destroy(&((*s_etat_processus).mutex_pile_processus); |
|
pthread_mutex_destroy(&((*s_etat_processus).mutex_allocation)); |
|
#endif |
|
pthread_mutexattr_init(&attributs_mutex); |
|
pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_RECURSIVE); |
|
pthread_mutex_init(&mutex_liste_variables_partagees, &attributs_mutex); |
|
pthread_mutexattr_destroy(&attributs_mutex); |
|
|
|
pthread_mutexattr_init(&attributs_mutex); |
|
pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_RECURSIVE); |
|
pthread_mutex_init(&mutex_liste_threads, &attributs_mutex); |
|
pthread_mutexattr_destroy(&attributs_mutex); |
|
|
|
pthread_mutexattr_init(&attributs_mutex); |
|
pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_RECURSIVE); |
|
pthread_mutex_init(&mutex_liste_threads_surveillance, &attributs_mutex); |
|
pthread_mutexattr_destroy(&attributs_mutex); |
|
|
|
pthread_mutexattr_init(&attributs_mutex); |
|
pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_RECURSIVE); |
|
pthread_mutex_init(&mutex_sigaction, &attributs_mutex); |
|
pthread_mutexattr_destroy(&attributs_mutex); |
|
|
|
pthread_mutexattr_init(&attributs_mutex); |
|
pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL); |
|
pthread_mutex_init(&((*s_etat_processus).mutex_pile_processus), |
|
&attributs_mutex); |
|
pthread_mutexattr_destroy(&attributs_mutex); |
|
|
|
pthread_mutexattr_init(&attributs_mutex); |
|
pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL); |
|
pthread_mutex_init(&((*s_etat_processus).mutex_allocation), |
|
&attributs_mutex); |
|
pthread_mutexattr_destroy(&attributs_mutex); |
|
|
liberation_queue_signaux(s_etat_processus); |
liberation_queue_signaux(s_etat_processus); |
creation_queue_signaux(s_etat_processus); |
creation_queue_signaux(s_etat_processus); |
|
|
routine_recursive = 0; |
routine_recursive = 0; |
|
nombre_threads_surveillance_processus = 0; |
|
|
(*s_etat_processus).pointeur_signal_lecture = 0; |
(*s_etat_processus).pointeur_signal_lecture = 0; |
(*s_etat_processus).pointeur_signal_ecriture = 0; |
(*s_etat_processus).pointeur_signal_ecriture = 0; |
Line 1365 instruction_detach(struct_processus *s_e
|
Line 1434 instruction_detach(struct_processus *s_e
|
(*s_argument_thread).pipe_nombre_elements_attente[1], |
(*s_argument_thread).pipe_nombre_elements_attente[1], |
&caractere, sizeof(caractere)) != sizeof(caractere)) |
&caractere, sizeof(caractere)) != sizeof(caractere)) |
{ |
{ |
pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)); |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
|
while((longueur_ecriture = write_atomic(s_etat_processus, |
while((longueur_ecriture = write_atomic(s_etat_processus, |
Line 1407 instruction_detach(struct_processus *s_e
|
Line 1475 instruction_detach(struct_processus *s_e
|
pthread_mutex_init(&mutex_sections_critiques, &attributs_mutex); |
pthread_mutex_init(&mutex_sections_critiques, &attributs_mutex); |
pthread_mutexattr_destroy(&attributs_mutex); |
pthread_mutexattr_destroy(&attributs_mutex); |
|
|
if (pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)) |
|
!= 0) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
|
|
caractere = 0; |
|
|
|
while((longueur_ecriture = write_atomic(s_etat_processus, |
|
(*s_argument_thread).pipe_nombre_elements_attente[1], |
|
&caractere, sizeof(caractere))) != sizeof(caractere)) |
|
{ |
|
if (longueur_ecriture == -1) |
|
{ |
|
break; |
|
} |
|
} |
|
|
|
destruction_queue_signaux(s_etat_processus); |
|
BUG(1, uprintf("Process management error line %d\n", __LINE__)); |
|
exit(EXIT_FAILURE); |
|
} |
|
|
|
pthread_mutex_trylock(&((*s_etat_processus).protection_liste_mutexes)); |
|
|
|
if (pthread_mutex_unlock(&((*s_etat_processus) |
|
.protection_liste_mutexes)) != 0) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
|
|
caractere = 0; |
|
|
|
while((longueur_ecriture = write_atomic(s_etat_processus, |
|
(*s_argument_thread).pipe_nombre_elements_attente[1], |
|
&caractere, sizeof(caractere))) != sizeof(caractere)) |
|
{ |
|
if (longueur_ecriture == -1) |
|
{ |
|
break; |
|
} |
|
} |
|
|
|
destruction_queue_signaux(s_etat_processus); |
|
BUG(1, uprintf("Process management error line %d\n", __LINE__)); |
|
exit(EXIT_FAILURE); |
|
} |
|
|
|
pthread_mutex_trylock(&((*s_etat_processus).mutex_interruptions)); |
|
|
|
if (pthread_mutex_unlock(&((*s_etat_processus).mutex_interruptions)) |
|
!= 0) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
|
|
caractere = 0; |
|
|
|
while((longueur_ecriture = write_atomic(s_etat_processus, |
|
(*s_argument_thread).pipe_nombre_elements_attente[1], |
|
&caractere, sizeof(caractere))) != sizeof(caractere)) |
|
{ |
|
if (longueur_ecriture == -1) |
|
{ |
|
break; |
|
} |
|
} |
|
|
|
destruction_queue_signaux(s_etat_processus); |
|
BUG(1, uprintf("Process management error line %d\n", __LINE__)); |
|
exit(EXIT_FAILURE); |
|
} |
|
|
|
pthread_mutex_trylock(&((*s_etat_processus).mutex_signaux)); |
|
|
|
if (pthread_mutex_unlock(&((*s_etat_processus).mutex_signaux)) |
|
!= 0) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
|
|
caractere = 0; |
|
|
|
while((longueur_ecriture = write_atomic(s_etat_processus, |
|
(*s_argument_thread).pipe_nombre_elements_attente[1], |
|
&caractere, sizeof(caractere))) != sizeof(caractere)) |
|
{ |
|
if (longueur_ecriture == -1) |
|
{ |
|
break; |
|
} |
|
} |
|
|
|
destruction_queue_signaux(s_etat_processus); |
|
BUG(1, uprintf("Process management error line %d\n", __LINE__)); |
|
exit(EXIT_FAILURE); |
|
} |
|
|
|
if ((*s_etat_processus).evaluation_expression_compilee == 'N') |
if ((*s_etat_processus).evaluation_expression_compilee == 'N') |
{ |
{ |
free((*s_etat_processus).instruction_courante); |
free((*s_etat_processus).instruction_courante); |
Line 1557 instruction_detach(struct_processus *s_e
|
Line 1531 instruction_detach(struct_processus *s_e
|
|
|
// Attente de la réception du signal rpl_sigstart. |
// Attente de la réception du signal rpl_sigstart. |
|
|
for((*s_etat_processus).demarrage_fils = d_faux;;) |
for((*s_etat_processus).demarrage_fils = d_faux; |
|
(*s_etat_processus).demarrage_fils != d_vrai; |
|
nanosleep(&attente, NULL)) |
{ |
{ |
scrutation_interruptions(s_etat_processus); |
scrutation_interruptions(s_etat_processus); |
|
|
if ((*s_etat_processus).demarrage_fils == d_vrai) |
|
{ |
|
break; |
|
} |
|
|
|
nanosleep(&attente, NULL); |
|
} |
} |
|
|
(*s_etat_processus).niveau_initial = (*s_etat_processus).niveau_courant; |
(*s_etat_processus).niveau_initial = (*s_etat_processus).niveau_courant; |
Line 1854 instruction_detach(struct_processus *s_e
|
Line 1823 instruction_detach(struct_processus *s_e
|
{ |
{ |
l_element_suivant = (*l_element_courant).suivant; |
l_element_suivant = (*l_element_courant).suivant; |
|
|
|
// On ne détruit pas le descripteur sous prétexte |
|
// d'avoir le fichier ou la socket fermée dans le processus père |
|
|
|
/* |
fclose((*((struct_descripteur_fichier *) |
fclose((*((struct_descripteur_fichier *) |
(*l_element_courant).donnee)).descripteur_c); |
(*l_element_courant).donnee)).descripteur_c); |
|
|
Line 1863 instruction_detach(struct_processus *s_e
|
Line 1836 instruction_detach(struct_processus *s_e
|
sqlite3_close((*((struct_descripteur_fichier *) |
sqlite3_close((*((struct_descripteur_fichier *) |
(*l_element_courant).donnee)).descripteur_sqlite); |
(*l_element_courant).donnee)).descripteur_sqlite); |
} |
} |
|
*/ |
|
|
free((*((struct_descripteur_fichier *) (*l_element_courant) |
free((*((struct_descripteur_fichier *) (*l_element_courant) |
.donnee)).nom); |
.donnee)).nom); |
Line 1872 instruction_detach(struct_processus *s_e
|
Line 1846 instruction_detach(struct_processus *s_e
|
l_element_courant = l_element_suivant; |
l_element_courant = l_element_suivant; |
} |
} |
|
|
|
(*s_etat_processus).s_fichiers = NULL; |
|
|
/* |
/* |
* Destruction des piles de connecteurs SQL |
* Destruction des piles de connecteurs SQL |
*/ |
*/ |
Line 1894 instruction_detach(struct_processus *s_e
|
Line 1870 instruction_detach(struct_processus *s_e
|
l_element_courant = l_element_suivant; |
l_element_courant = l_element_suivant; |
} |
} |
|
|
(*s_etat_processus).s_connecteurs_sql = NULL; |
|
|
|
/* |
/* |
* On ne détruit pas les sockets car il faut utiliser DETACH |
* On ne détruit pas les sockets car il faut utiliser DETACH |
* pour traiter plusieurs connexions simultanées sur les sockets |
* pour traiter plusieurs connexions simultanées sur les sockets |
*/ |
*/ |
|
|
(*s_etat_processus).s_fichiers = NULL; |
(*s_etat_processus).s_connecteurs_sql = NULL; |
|
|
if ((*s_etat_processus).debug == d_vrai) |
if ((*s_etat_processus).debug == d_vrai) |
{ |
{ |
Line 2149 instruction_detach(struct_processus *s_e
|
Line 2123 instruction_detach(struct_processus *s_e
|
} |
} |
} |
} |
|
|
close((*s_argument_thread).pipe_erreurs[1]); |
|
close((*s_argument_thread).pipe_interruptions[1]); |
|
close((*s_argument_thread).pipe_nombre_elements_attente[1]); |
|
close((*s_argument_thread).pipe_objets[1]); |
|
close((*s_argument_thread).pipe_injections[0]); |
|
close((*s_argument_thread).pipe_nombre_injections[0]); |
|
close((*s_argument_thread).pipe_acquittement[0]); |
|
|
|
l_element_courant = (*s_etat_processus).s_fichiers; |
l_element_courant = (*s_etat_processus).s_fichiers; |
|
|
while(l_element_courant != NULL) |
while(l_element_courant != NULL) |
Line 2236 instruction_detach(struct_processus *s_e
|
Line 2202 instruction_detach(struct_processus *s_e
|
{ |
{ |
envoi_signal_processus((*(*((struct_processus_fils *) |
envoi_signal_processus((*(*((struct_processus_fils *) |
(*(*l_element_courant).donnee).objet)).thread).pid, |
(*(*l_element_courant).donnee).objet)).thread).pid, |
rpl_sigurg); |
rpl_sigurg, d_faux); |
} |
} |
else |
else |
{ |
{ |
Line 2244 instruction_detach(struct_processus *s_e
|
Line 2210 instruction_detach(struct_processus *s_e
|
{ |
{ |
envoi_signal_processus((*(*((struct_processus_fils *) |
envoi_signal_processus((*(*((struct_processus_fils *) |
(*(*l_element_courant).donnee).objet)).thread) |
(*(*l_element_courant).donnee).objet)).thread) |
.pid, rpl_sigabort); |
.pid, rpl_sigabort, d_faux); |
} |
} |
else |
else |
{ |
{ |
envoi_signal_processus((*(*((struct_processus_fils *) |
envoi_signal_processus((*(*((struct_processus_fils *) |
(*(*l_element_courant).donnee).objet)).thread) |
(*(*l_element_courant).donnee).objet)).thread) |
.pid, rpl_sigstop); |
.pid, rpl_sigstop, d_faux); |
} |
} |
} |
} |
} |
} |
Line 2292 instruction_detach(struct_processus *s_e
|
Line 2258 instruction_detach(struct_processus *s_e
|
{ |
{ |
if ((*s_etat_processus).var_volatile_alarme != 0) |
if ((*s_etat_processus).var_volatile_alarme != 0) |
{ |
{ |
envoi_signal_thread((*(*((struct_processus_fils *) |
envoi_signal_thread(s_etat_processus, |
|
(*(*((struct_processus_fils *) |
(*(*l_element_courant).donnee).objet)).thread) |
(*(*l_element_courant).donnee).objet)).thread) |
.tid, rpl_sigurg); |
.tid, rpl_sigurg); |
} |
} |
Line 2300 instruction_detach(struct_processus *s_e
|
Line 2267 instruction_detach(struct_processus *s_e
|
{ |
{ |
if ((*s_etat_processus).arret_depuis_abort == -1) |
if ((*s_etat_processus).arret_depuis_abort == -1) |
{ |
{ |
envoi_signal_thread((*(*((struct_processus_fils *) |
envoi_signal_thread(s_etat_processus, |
|
(*(*((struct_processus_fils *) |
(*(*l_element_courant).donnee).objet)) |
(*(*l_element_courant).donnee).objet)) |
.thread).tid, rpl_sigabort); |
.thread).tid, rpl_sigabort); |
} |
} |
else |
else |
{ |
{ |
envoi_signal_thread((*(*((struct_processus_fils *) |
envoi_signal_thread(s_etat_processus, |
|
(*(*((struct_processus_fils *) |
(*(*l_element_courant).donnee).objet)) |
(*(*l_element_courant).donnee).objet)) |
.thread).tid, rpl_sigstop); |
.thread).tid, rpl_sigstop); |
} |
} |
Line 2352 instruction_detach(struct_processus *s_e
|
Line 2321 instruction_detach(struct_processus *s_e
|
(*(*((struct_processus_fils *) (*(*l_element_courant) |
(*(*((struct_processus_fils *) (*(*l_element_courant) |
.donnee).objet)).thread).nombre_objets_dans_pipe--; |
.donnee).objet)).thread).nombre_objets_dans_pipe--; |
|
|
|
if (pthread_mutex_lock(&mutex_sigaction) != 0) |
|
{ |
|
destruction_queue_signaux(s_etat_processus); |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
exit(EXIT_FAILURE); |
|
} |
|
|
action.sa_handler = SIG_IGN; |
action.sa_handler = SIG_IGN; |
action.sa_flags = SA_ONSTACK; |
action.sa_flags = 0; |
|
|
if (sigaction(SIGPIPE, &action, ®istre) != 0) |
if (sigaction(SIGPIPE, &action, ®istre) != 0) |
{ |
{ |
pthread_mutex_unlock(&((*s_etat_processus) |
pthread_mutex_unlock(&((*s_etat_processus) |
.mutex_pile_processus)); |
.mutex_pile_processus)); |
|
pthread_mutex_unlock(&mutex_sigaction); |
|
|
if (registre_stop == 0) |
if (registre_stop == 0) |
{ |
{ |
Line 2412 instruction_detach(struct_processus *s_e
|
Line 2389 instruction_detach(struct_processus *s_e
|
{ |
{ |
destruction_queue_signaux(s_etat_processus); |
destruction_queue_signaux(s_etat_processus); |
|
|
|
pthread_mutex_unlock(&mutex_sigaction); |
pthread_mutex_unlock(&((*s_etat_processus) |
pthread_mutex_unlock(&((*s_etat_processus) |
.mutex_pile_processus)); |
.mutex_pile_processus)); |
(*s_etat_processus).erreur_systeme = d_es_signal; |
(*s_etat_processus).erreur_systeme = d_es_signal; |
exit(EXIT_FAILURE); |
exit(EXIT_FAILURE); |
} |
} |
|
|
|
if (pthread_mutex_unlock(&mutex_sigaction) != 0) |
|
{ |
|
destruction_queue_signaux(s_etat_processus); |
|
pthread_mutex_unlock(&((*s_etat_processus) |
|
.mutex_pile_processus)); |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
exit(EXIT_FAILURE); |
|
} |
} |
} |
} |
} |
|
|
Line 2462 instruction_detach(struct_processus *s_e
|
Line 2449 instruction_detach(struct_processus *s_e
|
{ |
{ |
l_element_suivant = (*l_element_courant).suivant; |
l_element_suivant = (*l_element_courant).suivant; |
|
|
if ((*((struct_socket *) (*(*l_element_courant).donnee) |
|
.objet)).socket_connectee == d_vrai) |
|
{ |
|
shutdown((*((struct_socket *) (*(*l_element_courant).donnee) |
|
.objet)).socket, SHUT_RDWR); |
|
} |
|
|
|
close((*((struct_socket *) (*(*l_element_courant).donnee) |
|
.objet)).socket); |
|
|
|
if (((*((struct_socket *) (*(*l_element_courant).donnee).objet)) |
if (((*((struct_socket *) (*(*l_element_courant).donnee).objet)) |
.pid == getpid()) && (pthread_equal((*((struct_socket *) |
.pid == getpid()) && (pthread_equal((*((struct_socket *) |
(*(*l_element_courant).donnee).objet)).tid, pthread_self()) |
(*(*l_element_courant).donnee).objet)).tid, pthread_self()) |
!= 0)) |
!= 0)) |
{ |
{ |
|
if ((*((struct_socket *) (*(*l_element_courant).donnee) |
|
.objet)).socket_connectee == d_vrai) |
|
{ |
|
shutdown((*((struct_socket *) (*(*l_element_courant).donnee) |
|
.objet)).socket, SHUT_RDWR); |
|
} |
|
|
|
close((*((struct_socket *) (*(*l_element_courant).donnee) |
|
.objet)).socket); |
|
|
if ((*((struct_socket *) (*(*l_element_courant).donnee).objet)) |
if ((*((struct_socket *) (*(*l_element_courant).donnee).objet)) |
.effacement == 'Y') |
.effacement == 'Y') |
{ |
{ |
Line 2719 instruction_detach(struct_processus *s_e
|
Line 2706 instruction_detach(struct_processus *s_e
|
l_element_courant = l_element_suivant; |
l_element_courant = l_element_suivant; |
} |
} |
|
|
free((*s_etat_processus).chemin_fichiers_temporaires); |
|
|
|
if ((*s_etat_processus).debug == d_vrai) |
if ((*s_etat_processus).debug == d_vrai) |
if (((*s_etat_processus).type_debug & |
if (((*s_etat_processus).type_debug & |
d_debug_processus) != 0) |
d_debug_processus) != 0) |
Line 2772 instruction_detach(struct_processus *s_e
|
Line 2757 instruction_detach(struct_processus *s_e
|
liberation_profil(s_etat_processus); |
liberation_profil(s_etat_processus); |
} |
} |
|
|
|
attente.tv_sec = 0; |
|
attente.tv_nsec = GRANULARITE_us * 1000; |
|
|
|
pthread_mutex_lock(&((*s_etat_processus).mutex_pile_processus)); |
|
|
|
while(nombre_threads_surveillance_processus != 0) |
|
{ |
|
pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)); |
|
nanosleep(&attente, NULL); |
|
INCR_GRANULARITE(attente.tv_nsec); |
|
pthread_mutex_lock(&((*s_etat_processus).mutex_pile_processus)); |
|
} |
|
|
|
pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)); |
|
|
closelog(); |
closelog(); |
|
|
liberation_allocateur(s_etat_processus); |
|
retrait_thread(s_etat_processus); |
retrait_thread(s_etat_processus); |
|
liberation_contexte_cas(s_etat_processus); |
|
|
|
clear_history(); |
|
|
|
close((*s_argument_thread).pipe_erreurs[1]); |
|
close((*s_argument_thread).pipe_interruptions[1]); |
|
close((*s_argument_thread).pipe_nombre_elements_attente[1]); |
|
close((*s_argument_thread).pipe_objets[1]); |
|
close((*s_argument_thread).pipe_injections[0]); |
|
close((*s_argument_thread).pipe_nombre_injections[0]); |
|
close((*s_argument_thread).pipe_acquittement[0]); |
|
|
|
free((*s_etat_processus).localisation); |
|
free((*s_etat_processus).chemin_fichiers_temporaires); |
|
free(s_argument_thread); |
|
|
|
liberation_allocateur(s_etat_processus); |
|
liberation_allocateur_buffer(s_etat_processus); |
|
|
|
// Permet d'attendre la libération du mutex de la part |
|
// de surveillance_processus(). |
|
|
|
attente.tv_sec = 0; |
|
attente.tv_nsec = GRANULARITE_us * 1000; |
|
|
|
while(pthread_mutex_trylock(&((*s_etat_processus).mutex_pile_processus)) |
|
== EBUSY) |
|
{ |
|
nanosleep(&attente, NULL); |
|
INCR_GRANULARITE(attente.tv_nsec); |
|
} |
|
|
|
pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)); |
|
|
|
// Libération des mutexes. |
|
|
pthread_mutex_destroy(&((*s_etat_processus).mutex_pile_processus)); |
pthread_mutex_destroy(&((*s_etat_processus).mutex_pile_processus)); |
pthread_mutex_destroy(&((*s_etat_processus).mutex_allocation)); |
pthread_mutex_destroy(&((*s_etat_processus).mutex_allocation)); |
pthread_mutex_destroy(&((*s_etat_processus).mutex_interruptions)); |
pthread_mutex_destroy(&((*s_etat_processus).mutex_interruptions)); |
pthread_mutex_destroy(&((*s_etat_processus).mutex_signaux)); |
pthread_mutex_destroy(&((*s_etat_processus).mutex_signaux)); |
pthread_mutex_destroy(&((*s_etat_processus).protection_liste_mutexes)); |
pthread_mutex_destroy(&((*s_etat_processus).protection_liste_mutexes)); |
|
pthread_mutex_destroy(&((*s_etat_processus).mutex_allocation_buffer)); |
pthread_mutex_destroy(&mutex_sections_critiques); |
pthread_mutex_destroy(&mutex_sections_critiques); |
|
pthread_mutex_destroy(&mutex_liste_variables_partagees); |
|
|
|
destruction_queue_signaux(s_etat_processus); |
|
pthread_mutex_destroy(&mutex_liste_threads); |
|
pthread_mutex_destroy(&mutex_liste_threads_surveillance); |
|
|
# ifndef SEMAPHORES_NOMMES |
# ifndef SEMAPHORES_NOMMES |
sem_post(&((*s_etat_processus).semaphore_fork)); |
sem_post(&((*s_etat_processus).semaphore_fork)); |
Line 2793 instruction_detach(struct_processus *s_e
|
Line 2833 instruction_detach(struct_processus *s_e
|
pthread_self(), SEM_FORK); |
pthread_self(), SEM_FORK); |
# endif |
# endif |
|
|
free((*s_etat_processus).localisation); |
sys_free(s_etat_processus); |
free(s_argument_thread); |
|
|
|
clear_history(); |
|
|
|
destruction_queue_signaux(s_etat_processus); |
|
liberation_contexte_cas(s_etat_processus); |
|
arret_thread_signaux(s_etat_processus); |
|
free(s_etat_processus); |
|
|
|
# ifdef DEBUG_MEMOIRE |
# ifdef DEBUG_MEMOIRE |
debug_memoire_verification(); |
debug_memoire_verification(); |
analyse_post_mortem(); |
analyse_post_mortem(); |
# endif |
# endif |
|
|
|
pthread_mutex_destroy(&mutex_sigaction); |
exit(EXIT_SUCCESS); |
exit(EXIT_SUCCESS); |
} |
} |
else |
else |
{ |
{ |
|
deverrouillage_threads_concurrents(s_etat_processus); |
(*s_etat_processus).erreur_systeme = d_es_processus; |
(*s_etat_processus).erreur_systeme = d_es_processus; |
return; |
return; |
} |
} |
Line 2901 instruction_detach(struct_processus *s_e
|
Line 2935 instruction_detach(struct_processus *s_e
|
|
|
// Le fils peut être présent sans être en attente du signal de départ. |
// Le fils peut être présent sans être en attente du signal de départ. |
|
|
if (envoi_signal_processus((*s_argument_thread).pid, rpl_sigstart) != 0) |
if (envoi_signal_processus((*s_argument_thread).pid, rpl_sigstart, |
|
d_vrai) != 0) |
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es_processus; |
(*s_etat_processus).erreur_systeme = d_es_processus; |
pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)); |
pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)); |