--- rpl/src/instructions_d5.c 2012/10/14 21:37:10 1.96 +++ rpl/src/instructions_d5.c 2015/01/30 07:53:15 1.124 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.1.11 - Copyright (C) 1989-2012 Dr. BERTRAND Joël + RPL/2 (R) version 4.1.20 + Copyright (C) 1989-2015 Dr. BERTRAND Joël This file is part of RPL/2. @@ -40,12 +40,13 @@ instruction_dft(struct_processus *s_etat { integer4 erreur; integer4 inverse; + integer4 longueur_dft; integer4 nombre_colonnes; integer4 nombre_lignes; logical1 presence_longueur_dft; - long longueur_dft_signee; + integer8 longueur_dft_signee; struct_complexe16 *matrice_f77; @@ -53,10 +54,9 @@ instruction_dft(struct_processus *s_etat struct_objet *s_objet_longueur_dft; struct_objet *s_objet_resultat; - unsigned long i; - unsigned long j; - unsigned long k; - unsigned long longueur_dft; + integer8 i; + integer8 j; + integer8 k; (*s_etat_processus).erreur_execution = d_ex; @@ -135,7 +135,7 @@ instruction_dft(struct_processus *s_etat return; } - longueur_dft = longueur_dft_signee; + longueur_dft = (integer4) longueur_dft_signee; } else { @@ -170,11 +170,11 @@ instruction_dft(struct_processus *s_etat { if (presence_longueur_dft == d_faux) { - longueur_dft = (*((struct_vecteur *) + longueur_dft = (integer4) (*((struct_vecteur *) (*s_objet_argument).objet)).taille; } - if ((matrice_f77 = malloc(longueur_dft * + if ((matrice_f77 = malloc(((size_t) longueur_dft) * sizeof(struct_complexe16))) == NULL) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; @@ -260,13 +260,13 @@ instruction_dft(struct_processus *s_etat { if (presence_longueur_dft == d_faux) { - longueur_dft = (*((struct_matrice *) + longueur_dft = (integer4) (*((struct_matrice *) (*s_objet_argument).objet)).nombre_colonnes; } - if ((matrice_f77 = malloc(longueur_dft * + if ((matrice_f77 = malloc(((size_t) longueur_dft) * ((size_t) (*((struct_matrice *) (*s_objet_argument).objet)) - .nombre_lignes * sizeof(struct_complexe16))) == NULL) + .nombre_lignes) * sizeof(struct_complexe16))) == NULL) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; return; @@ -342,8 +342,8 @@ instruction_dft(struct_processus *s_etat } } - nombre_lignes = (*((struct_matrice *) (*s_objet_argument).objet)) - .nombre_lignes; + nombre_lignes = (integer4) (*((struct_matrice *) (*s_objet_argument) + .objet)).nombre_lignes; nombre_colonnes = longueur_dft; inverse = 0; @@ -371,8 +371,8 @@ instruction_dft(struct_processus *s_etat longueur_dft; if (((*((struct_matrice *) (*s_objet_resultat).objet)).tableau = - malloc((*((struct_matrice *) (*s_objet_resultat).objet)) - .nombre_lignes * sizeof(struct_complexe16 *))) == NULL) + malloc(((size_t) (*((struct_matrice *) (*s_objet_resultat) + .objet)).nombre_lignes) * sizeof(struct_complexe16 *))) == NULL) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; return; @@ -383,8 +383,8 @@ instruction_dft(struct_processus *s_etat { if ((((struct_complexe16 **) (*((struct_matrice *) (*s_objet_resultat).objet)).tableau)[i] = - malloc((*((struct_matrice *) - (*s_objet_resultat).objet)).nombre_colonnes * + malloc(((size_t) (*((struct_matrice *) + (*s_objet_resultat).objet)).nombre_colonnes) * sizeof(struct_complexe16))) == NULL) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; @@ -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; @@ -838,6 +838,9 @@ instruction_detach(struct_processus *s_e struct_liste_chainee *l_element_precedent; struct_liste_chainee *l_element_suivant; + struct_liste_variables_partagees *l_element_partage_courant; + struct_liste_variables_partagees *l_element_partage_suivant; + struct_liste_variables_statiques *l_element_statique_courant; struct_liste_variables_statiques *l_element_statique_suivant; @@ -856,7 +859,7 @@ instruction_detach(struct_processus *s_e unsigned int erreur; - unsigned long i; + integer8 i; volatile logical1 variable_partagee; @@ -934,26 +937,12 @@ instruction_detach(struct_processus *s_e if ((*(*s_etat_processus).pointeur_variable_courante).objet == NULL) { - if (pthread_mutex_lock(&((*(*s_etat_processus) - .s_liste_variables_partagees).mutex)) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; - } - if (recherche_variable_partagee(s_etat_processus, (*(*s_etat_processus).pointeur_variable_courante).nom, (*(*s_etat_processus).pointeur_variable_courante) .variable_partagee, (*(*s_etat_processus) - .pointeur_variable_courante).origine) == d_faux) + .pointeur_variable_courante).origine) == NULL) { - if (pthread_mutex_unlock(&((*(*s_etat_processus) - .s_liste_variables_partagees).mutex)) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; - } - liberation(s_etat_processus, s_objet); (*s_etat_processus).erreur_systeme = d_es; @@ -962,16 +951,14 @@ instruction_detach(struct_processus *s_e return; } - if (((*(*(*s_etat_processus).s_liste_variables_partagees) - .table[(*(*s_etat_processus) - .s_liste_variables_partagees).position_variable].objet) - .type != RPN) && ((*(*(*s_etat_processus) - .s_liste_variables_partagees).table - [(*(*s_etat_processus).s_liste_variables_partagees) - .position_variable].objet).type != ADR)) + if (((*(*(*s_etat_processus) + .pointeur_variable_partagee_courante).objet).type + == RPN) && ((*(*(*s_etat_processus) + .pointeur_variable_partagee_courante).objet).type + == ADR)) { if (pthread_mutex_unlock(&((*(*s_etat_processus) - .s_liste_variables_partagees).mutex)) != 0) + .pointeur_variable_partagee_courante).mutex)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; @@ -985,12 +972,12 @@ instruction_detach(struct_processus *s_e } if ((s_copie = copie_objet(s_etat_processus, - (*(*s_etat_processus).s_liste_variables_partagees).table - [(*(*s_etat_processus).s_liste_variables_partagees) - .position_variable].objet, 'P')) == NULL) + (*(*s_etat_processus) + .pointeur_variable_partagee_courante).objet, 'P')) + == NULL) { if (pthread_mutex_unlock(&((*(*s_etat_processus) - .s_liste_variables_partagees).mutex)) != 0) + .pointeur_variable_partagee_courante).mutex)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; @@ -1005,7 +992,7 @@ instruction_detach(struct_processus *s_e variable_partagee = d_vrai; if (pthread_mutex_unlock(&((*(*s_etat_processus) - .s_liste_variables_partagees).mutex)) != 0) + .pointeur_variable_partagee_courante).mutex)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; @@ -1053,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; @@ -1071,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; @@ -1101,7 +1082,7 @@ 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; @@ -1185,7 +1166,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; @@ -1198,12 +1179,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; @@ -1330,7 +1305,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; } @@ -1338,10 +1313,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; @@ -1384,41 +1355,23 @@ instruction_detach(struct_processus *s_e (*s_etat_processus).liste_mutexes = NULL; liberation_threads(s_etat_processus); - - (*(*s_etat_processus).s_liste_variables_partagees) - .table = NULL; - (*(*s_etat_processus).s_liste_variables_partagees) - .nombre_variables = 0; - (*(*s_etat_processus).s_liste_variables_partagees) - .nombre_variables_allouees = 0; - insertion_thread(s_etat_processus, d_vrai); // 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) { @@ -1435,21 +1388,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) { @@ -1467,15 +1408,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) { @@ -1483,9 +1425,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) { @@ -1498,18 +1454,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) { @@ -1517,9 +1473,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) { @@ -1604,12 +1574,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 = @@ -1623,6 +1591,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) { @@ -1649,25 +1618,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; + 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) { @@ -1702,10 +1662,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)); @@ -1730,25 +1688,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; - - 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) { @@ -1799,21 +1748,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) { @@ -1852,21 +1791,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) { @@ -2020,11 +1949,18 @@ instruction_detach(struct_processus *s_e } else { - if (((*s_etat_processus).var_volatile_alarme == 0) - && ((*s_etat_processus).arret_depuis_abort == 0) + if (((*s_etat_processus).arret_depuis_abort == 0) && ((*s_etat_processus).at_exit != NULL)) { (*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, (*s_etat_processus).at_exit, 'E') == @@ -2033,6 +1969,11 @@ instruction_detach(struct_processus *s_e (*s_etat_processus).erreur_execution = d_ex_erreur_evaluation; } + + if ((*s_etat_processus).profilage == d_vrai) + { + profilage(s_etat_processus, NULL); + } } } } @@ -2049,11 +1990,18 @@ instruction_detach(struct_processus *s_e } else { - if (((*s_etat_processus).var_volatile_alarme == 0) - && ((*s_etat_processus).arret_depuis_abort == 0) + if (((*s_etat_processus).arret_depuis_abort == 0) && ((*s_etat_processus).at_exit != NULL)) { (*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, (*s_etat_processus).at_exit, 'E') == @@ -2062,6 +2010,11 @@ instruction_detach(struct_processus *s_e (*s_etat_processus).erreur_execution = d_ex_erreur_evaluation; } + + if ((*s_etat_processus).profilage == d_vrai) + { + profilage(s_etat_processus, NULL); + } } } @@ -2094,21 +2047,11 @@ instruction_detach(struct_processus *s_e 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, - (*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) { @@ -2137,7 +2080,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)) { @@ -2169,7 +2112,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)) { @@ -2209,9 +2152,8 @@ 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_nombre_elements_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]); @@ -2253,7 +2195,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; @@ -2398,7 +2340,7 @@ instruction_detach(struct_processus *s_e .var_volatile_traitement_retarde_stop; (*s_etat_processus).var_volatile_traitement_retarde_stop = 1; - for(i = 0; i < (unsigned long) (*(*((struct_processus_fils *) + for(i = 0; i < (*(*((struct_processus_fils *) (*(*l_element_courant) .donnee).objet)).thread).nombre_objets_dans_pipe; i++) { @@ -2416,7 +2358,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) { @@ -2470,27 +2413,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; @@ -2598,6 +2563,16 @@ instruction_detach(struct_processus *s_e l_element_statique_courant = l_element_statique_suivant; } + l_element_partage_courant = (*(*s_etat_processus) + .l_liste_variables_partagees); + + while(l_element_partage_courant != NULL) + { + l_element_partage_suivant = (*l_element_partage_courant).suivant; + free(l_element_partage_courant); + l_element_partage_courant = l_element_partage_suivant; + } + if ((*s_etat_processus).entree_standard != NULL) { pclose((*s_etat_processus).entree_standard); @@ -2622,30 +2597,12 @@ instruction_detach(struct_processus *s_e (*s_etat_processus).instruction_derniere_erreur = NULL; } + liberation_arbre_variables_partagees(s_etat_processus, + (*(*s_etat_processus).s_arbre_variables_partagees)); liberation_arbre_variables(s_etat_processus, (*s_etat_processus).s_arbre_variables, d_vrai); free((*s_etat_processus).pointeurs_caracteres_variables); - for(i = 0; i < (*(*s_etat_processus).s_liste_variables_partagees) - .nombre_variables; i++) - { - liberation(s_etat_processus, - (*(*s_etat_processus).s_liste_variables_partagees) - .table[i].objet); - free((*(*s_etat_processus).s_liste_variables_partagees) - .table[i].nom); - } - - if ((*(*s_etat_processus).s_liste_variables_partagees).table - != NULL) - { - free((struct_variable_partagee *) - (*(*s_etat_processus).s_liste_variables_partagees).table); - } - - pthread_mutex_destroy(&((*(*s_etat_processus) - .s_liste_variables_partagees).mutex)); - l_element_courant = (*s_etat_processus).l_base_pile; while(l_element_courant != NULL) { @@ -2821,8 +2778,11 @@ instruction_detach(struct_processus *s_e liberation_allocateur(s_etat_processus); retrait_thread(s_etat_processus); - pthread_mutex_destroy(&((*s_etat_processus).mutex)); + 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_buffer)); + 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(&mutex_sections_critiques); @@ -2843,7 +2803,8 @@ instruction_detach(struct_processus *s_e destruction_queue_signaux(s_etat_processus); liberation_contexte_cas(s_etat_processus); arret_thread_signaux(s_etat_processus); - free(s_etat_processus); + liberation_allocateur_buffer(s_etat_processus); + sys_free(s_etat_processus); # ifdef DEBUG_MEMOIRE debug_memoire_verification(); @@ -2881,7 +2842,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; @@ -2890,7 +2852,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; @@ -2910,14 +2873,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; } @@ -2944,11 +2907,11 @@ instruction_detach(struct_processus *s_e if (envoi_signal_processus((*s_argument_thread).pid, rpl_sigstart) != 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;