--- rpl/src/instructions_d5.c 2013/03/27 09:14:51 1.106 +++ rpl/src/instructions_d5.c 2016/03/17 16:31:58 1.146 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.1.13 - Copyright (C) 1989-2013 Dr. BERTRAND Joël + RPL/2 (R) version 4.1.25 + Copyright (C) 1989-2016 Dr. BERTRAND Joël This file is part of RPL/2. @@ -767,6 +767,7 @@ instruction_der(struct_processus *s_etat if ((s_objet_simplifie = simplification(s_etat_processus, s_objet_resultat)) == NULL) { + liberation(s_etat_processus, s_objet_resultat); return; } @@ -819,7 +820,6 @@ instruction_detach(struct_processus *s_e logical1 drapeau; pid_t ppid; - pid_t pid_final; pthread_attr_t attributs; @@ -1040,7 +1040,7 @@ instruction_detach(struct_processus *s_e 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; return; @@ -1058,12 +1058,6 @@ instruction_detach(struct_processus *s_e 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) { (*s_etat_processus).erreur_systeme = d_es_processus; @@ -1088,7 +1082,21 @@ instruction_detach(struct_processus *s_e * Le mutex suivant permet de copier un contexte propre. */ - 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; + return; + } + + if (pthread_mutex_lock(&mutex_liste_variables_partagees) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + + verrouillage_threads_concurrents(s_etat_processus); + + if (pthread_mutex_lock(&((*s_etat_processus).mutex_allocation_buffer)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; @@ -1101,9 +1109,21 @@ instruction_detach(struct_processus *s_e * de mémoire, ni libération, ni copie d'objet concurrent au fork(). */ - verrouillage_threads_concurrents(s_etat_processus); (*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).processus_detache = d_vrai; @@ -1125,6 +1145,12 @@ instruction_detach(struct_processus *s_e * 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) { liberation(s_etat_processus, s_copie); @@ -1172,7 +1198,7 @@ instruction_detach(struct_processus *s_e return; } - if (close((*s_argument_thread).pipe_nombre_interruptions_attente[1]) + if (close((*s_argument_thread).pipe_nombre_elements_attente[1]) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; @@ -1185,12 +1211,6 @@ instruction_detach(struct_processus *s_e 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) { (*s_etat_processus).erreur_systeme = d_es_processus; @@ -1268,13 +1288,27 @@ instruction_detach(struct_processus *s_e * Processus fils */ + pthread_mutex_destroy(&mutex_liste_variables_partagees); + pthread_mutex_destroy(&mutex_liste_threads); + + 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); + + liberation_queue_signaux(s_etat_processus); + creation_queue_signaux(s_etat_processus); + if (lancement_thread_signaux(s_etat_processus) != d_absence_erreur) { (*s_etat_processus).erreur_systeme = d_es_processus; } - liberation_queue_signaux(s_etat_processus); - creation_queue_signaux(s_etat_processus); routine_recursive = 0; (*s_etat_processus).pointeur_signal_lecture = 0; @@ -1317,7 +1351,7 @@ instruction_detach(struct_processus *s_e (*s_etat_processus).erreur_systeme = d_es_processus; } 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; } @@ -1325,10 +1359,6 @@ instruction_detach(struct_processus *s_e { (*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) { (*s_etat_processus).erreur_systeme = d_es_processus; @@ -1376,28 +1406,18 @@ instruction_detach(struct_processus *s_e // Envoi d'une donnée pour signaler le démarrage du processus au thread // de surveillance. + caractere = 0; + if (write_atomic(s_etat_processus, - (*s_argument_thread).pipe_nombre_objets_attente[1], - "-", sizeof(unsigned char)) != sizeof(unsigned char)) + (*s_argument_thread).pipe_nombre_elements_attente[1], + &caractere, sizeof(caractere)) != sizeof(caractere)) { - pthread_mutex_unlock(&((*s_etat_processus).mutex)); + pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)); (*s_etat_processus).erreur_systeme = d_es_processus; - pid_final = -2; - - 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, - (*s_argument_thread).pipe_nombre_objets_attente[1], - &pid_final, sizeof(pid_final))) != sizeof(pid_final)) + (*s_argument_thread).pipe_nombre_elements_attente[1], + &caractere, sizeof(caractere))) != sizeof(caractere)) { if (longueur_ecriture == -1) { @@ -1414,21 +1434,9 @@ instruction_detach(struct_processus *s_e { (*s_etat_processus).erreur_systeme = d_es_processus; - pid_final = -2; - 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, - (*s_argument_thread).pipe_nombre_objets_attente[1], - &pid_final, sizeof(pid_final))) != sizeof(pid_final)) + (*s_argument_thread).pipe_nombre_elements_attente[1], + &caractere, sizeof(caractere))) != sizeof(caractere)) { if (longueur_ecriture == -1) { @@ -1446,15 +1454,16 @@ instruction_detach(struct_processus *s_e pthread_mutex_init(&mutex_sections_critiques, &attributs_mutex); pthread_mutexattr_destroy(&attributs_mutex); - 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; - 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)) + (*s_argument_thread).pipe_nombre_elements_attente[1], + &caractere, sizeof(caractere))) != sizeof(caractere)) { if (longueur_ecriture == -1) { @@ -1462,9 +1471,23 @@ instruction_detach(struct_processus *s_e } } + 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_objets_attente[1], - &pid_final, sizeof(pid_final))) != sizeof(pid_final)) + (*s_argument_thread).pipe_nombre_elements_attente[1], + &caractere, sizeof(caractere))) != sizeof(caractere)) { if (longueur_ecriture == -1) { @@ -1477,18 +1500,18 @@ instruction_detach(struct_processus *s_e exit(EXIT_FAILURE); } - pthread_mutex_trylock(&((*s_etat_processus).protection_liste_mutexes)); + pthread_mutex_trylock(&((*s_etat_processus).mutex_interruptions)); - if (pthread_mutex_unlock(&((*s_etat_processus) - .protection_liste_mutexes)) != 0) + if (pthread_mutex_unlock(&((*s_etat_processus).mutex_interruptions)) + != 0) { (*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)) + (*s_argument_thread).pipe_nombre_elements_attente[1], + &caractere, sizeof(caractere))) != sizeof(caractere)) { if (longueur_ecriture == -1) { @@ -1496,9 +1519,23 @@ instruction_detach(struct_processus *s_e } } + 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_objets_attente[1], - &pid_final, sizeof(pid_final))) != sizeof(pid_final)) + (*s_argument_thread).pipe_nombre_elements_attente[1], + &caractere, sizeof(caractere))) != sizeof(caractere)) { if (longueur_ecriture == -1) { @@ -1583,12 +1620,10 @@ instruction_detach(struct_processus *s_e (*s_etat_processus).presence_pipes = d_vrai; (*s_etat_processus).debug_programme = d_faux; (*s_etat_processus).pipe_donnees = (*s_argument_thread).pipe_objets[1]; - (*s_etat_processus).pipe_nombre_objets_attente = (*s_argument_thread) - .pipe_nombre_objets_attente[1]; + (*s_etat_processus).pipe_nombre_elements_attente = (*s_argument_thread) + .pipe_nombre_elements_attente[1]; (*s_etat_processus).pipe_interruptions = (*s_argument_thread) .pipe_interruptions[1]; - (*s_etat_processus).pipe_nombre_interruptions_attente = - (*s_argument_thread).pipe_nombre_interruptions_attente[1]; (*s_etat_processus).pipe_injections = (*s_argument_thread).pipe_injections[0]; (*s_etat_processus).pipe_nombre_injections = @@ -1602,6 +1637,7 @@ instruction_detach(struct_processus *s_e (*s_etat_processus).thread_fusible = 0; (*s_etat_processus).pid_erreur_processus_fils = getpid(); (*s_etat_processus).sections_critiques = 0; + (*s_etat_processus).initialisation_scheduler = d_faux; if ((*s_etat_processus).profilage == d_vrai) { @@ -1628,25 +1664,16 @@ instruction_detach(struct_processus *s_e * par liberation_threads(). */ - 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; - pid_final = -2; - - 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; - } - } + caractere = 0; while((longueur_ecriture = write_atomic(s_etat_processus, - (*s_argument_thread).pipe_nombre_objets_attente[1], - &pid_final, sizeof(pid_final))) != sizeof(pid_final)) + (*s_argument_thread).pipe_nombre_elements_attente[1], + &caractere, sizeof(caractere))) != sizeof(caractere)) { if (longueur_ecriture == -1) { @@ -1681,10 +1708,8 @@ instruction_detach(struct_processus *s_e close((*s_argument_thread2).pipe_acquittement[1]); close((*s_argument_thread2).pipe_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_nombre_interruptions_attente[0]); pthread_mutex_destroy(&((*s_argument_thread2).mutex)); @@ -1709,25 +1734,16 @@ instruction_detach(struct_processus *s_e (*s_etat_processus).l_base_pile_processus = NULL; - 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; - 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, - (*s_argument_thread).pipe_nombre_objets_attente[1], - &pid_final, sizeof(pid_final))) != sizeof(pid_final)) + (*s_argument_thread).pipe_nombre_elements_attente[1], + &caractere, sizeof(caractere))) != sizeof(caractere)) { if (longueur_ecriture == -1) { @@ -1778,21 +1794,11 @@ instruction_detach(struct_processus *s_e if ((*s_etat_processus).erreur_systeme != d_es) { - pid_final = -2; - - 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; - } - } + caractere = 0; while((longueur_ecriture = write_atomic(s_etat_processus, - (*s_argument_thread).pipe_nombre_objets_attente[1], - &pid_final, sizeof(pid_final))) != sizeof(pid_final)) + (*s_argument_thread).pipe_nombre_elements_attente[1], + &caractere, sizeof(caractere))) != sizeof(caractere)) { if (longueur_ecriture == -1) { @@ -1831,21 +1837,11 @@ instruction_detach(struct_processus *s_e 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, - (*s_argument_thread).pipe_nombre_objets_attente[1], - &pid_final, sizeof(pid_final))) != sizeof(pid_final)) + (*s_argument_thread).pipe_nombre_elements_attente[1], + &caractere, sizeof(caractere))) != sizeof(caractere)) { if (longueur_ecriture == -1) { @@ -2097,21 +2093,11 @@ instruction_detach(struct_processus *s_e pthread_cancel((*s_etat_processus).thread_fusible); } - pid_final = -2; - - 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; - } - } + caractere = 0; while((longueur_ecriture = write_atomic(s_etat_processus, - (*s_argument_thread).pipe_nombre_objets_attente[1], - &pid_final, sizeof(pid_final))) != sizeof(pid_final)) + (*s_argument_thread).pipe_nombre_elements_attente[1], + &caractere, sizeof(caractere))) != sizeof(caractere)) { if (longueur_ecriture == -1) { @@ -2140,7 +2126,7 @@ instruction_detach(struct_processus *s_e { while((longueur_ecriture = write_atomic(s_etat_processus, (*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)) { @@ -2172,7 +2158,7 @@ instruction_detach(struct_processus *s_e { while((longueur_ecriture = write_atomic(s_etat_processus, (*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)) { @@ -2210,15 +2196,6 @@ 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_interruptions_attente[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_nombre_injections[0]); - close((*s_argument_thread).pipe_acquittement[0]); - l_element_courant = (*s_etat_processus).s_fichiers; while(l_element_courant != NULL) @@ -2256,7 +2233,7 @@ instruction_detach(struct_processus *s_e l_element_courant = l_element_suivant; } - pthread_mutex_lock(&((*s_etat_processus).mutex)); + pthread_mutex_lock(&((*s_etat_processus).mutex_pile_processus)); l_element_courant = (struct_liste_chainee *) (*s_etat_processus).l_base_pile_processus; @@ -2298,7 +2275,7 @@ instruction_detach(struct_processus *s_e { envoi_signal_processus((*(*((struct_processus_fils *) (*(*l_element_courant).donnee).objet)).thread).pid, - rpl_sigurg); + rpl_sigurg, d_faux); } else { @@ -2306,13 +2283,13 @@ instruction_detach(struct_processus *s_e { envoi_signal_processus((*(*((struct_processus_fils *) (*(*l_element_courant).donnee).objet)).thread) - .pid, rpl_sigabort); + .pid, rpl_sigabort, d_faux); } else { envoi_signal_processus((*(*((struct_processus_fils *) (*(*l_element_courant).donnee).objet)).thread) - .pid, rpl_sigstop); + .pid, rpl_sigstop, d_faux); } } } @@ -2419,7 +2396,8 @@ instruction_detach(struct_processus *s_e if (sigaction(SIGPIPE, &action, ®istre) != 0) { - pthread_mutex_unlock(&((*s_etat_processus).mutex)); + pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)); if (registre_stop == 0) { @@ -2473,27 +2451,49 @@ instruction_detach(struct_processus *s_e { destruction_queue_signaux(s_etat_processus); - pthread_mutex_unlock(&((*s_etat_processus).mutex)); + pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)); (*s_etat_processus).erreur_systeme = d_es_signal; exit(EXIT_FAILURE); } } } - pthread_mutex_unlock(&((*s_etat_processus).mutex)); + if (pthread_mutex_lock(&((*s_etat_processus).mutex_interruptions)) + != 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); + } if ((*s_etat_processus).nombre_interruptions_non_affectees != 0) { affectation_interruptions_logicielles(s_etat_processus); } + if (pthread_mutex_unlock(&((*s_etat_processus) + .mutex_interruptions)) != 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); + } + + pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)); nanosleep(&attente, NULL); - pthread_mutex_lock(&((*s_etat_processus).mutex)); + pthread_mutex_lock(&((*s_etat_processus).mutex_pile_processus)); scrutation_interruptions(s_etat_processus); } - pthread_mutex_unlock(&((*s_etat_processus).mutex)); + pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)); l_element_courant = (*s_etat_processus).s_sockets; @@ -2758,8 +2758,6 @@ instruction_detach(struct_processus *s_e l_element_courant = l_element_suivant; } - free((*s_etat_processus).chemin_fichiers_temporaires); - if ((*s_etat_processus).debug == d_vrai) if (((*s_etat_processus).type_debug & d_debug_processus) != 0) @@ -2813,13 +2811,15 @@ instruction_detach(struct_processus *s_e closelog(); - liberation_allocateur(s_etat_processus); - retrait_thread(s_etat_processus); + 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]); - pthread_mutex_destroy(&((*s_etat_processus).mutex)); - pthread_mutex_destroy(&((*s_etat_processus).mutex_allocation)); - pthread_mutex_destroy(&((*s_etat_processus).protection_liste_mutexes)); - pthread_mutex_destroy(&mutex_sections_critiques); + retrait_thread(s_etat_processus); # ifndef SEMAPHORES_NOMMES sem_post(&((*s_etat_processus).semaphore_fork)); @@ -2830,15 +2830,27 @@ instruction_detach(struct_processus *s_e pthread_self(), SEM_FORK); # endif + clear_history(); + + liberation_contexte_cas(s_etat_processus); + destruction_queue_signaux(s_etat_processus); + free((*s_etat_processus).localisation); + free((*s_etat_processus).chemin_fichiers_temporaires); free(s_argument_thread); - clear_history(); + liberation_allocateur(s_etat_processus); + liberation_allocateur_buffer(s_etat_processus); - destruction_queue_signaux(s_etat_processus); - liberation_contexte_cas(s_etat_processus); - arret_thread_signaux(s_etat_processus); - free(s_etat_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_interruptions)); + pthread_mutex_destroy(&((*s_etat_processus).mutex_signaux)); + pthread_mutex_destroy(&((*s_etat_processus).protection_liste_mutexes)); + pthread_mutex_destroy(&((*s_etat_processus).mutex_allocation_buffer)); + pthread_mutex_destroy(&mutex_sections_critiques); + + sys_free(s_etat_processus); # ifdef DEBUG_MEMOIRE debug_memoire_verification(); @@ -2876,7 +2888,8 @@ instruction_detach(struct_processus *s_e (*(*l_element_courant).donnee).objet)).thread).pid == (*s_argument_thread).pid) { - 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; return; @@ -2885,7 +2898,8 @@ instruction_detach(struct_processus *s_e nanosleep(&attente, NULL); 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 = d_es_processus; return; @@ -2905,14 +2919,14 @@ instruction_detach(struct_processus *s_e (struct_liste_chainee **) &((*s_etat_processus) .l_base_pile_processus), s_objet_systeme) == d_erreur) { - pthread_mutex_unlock(&((*s_etat_processus).mutex)); + pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)); return; } if (empilement(s_etat_processus, &((*s_etat_processus).l_base_pile), s_objet) == d_erreur) { - pthread_mutex_unlock(&((*s_etat_processus).mutex)); + pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)); return; } @@ -2936,14 +2950,15 @@ instruction_detach(struct_processus *s_e // 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; - pthread_mutex_unlock(&((*s_etat_processus).mutex)); + pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)); return; } - 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; return;