--- rpl/src/instructions_d5.c 2011/09/10 20:45:06 1.66 +++ rpl/src/instructions_d5.c 2018/05/30 09:27:34 1.162 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.1.3 - Copyright (C) 1989-2011 Dr. BERTRAND Joël + RPL/2 (R) version 4.1.29 + Copyright (C) 1989-2018 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; } @@ -814,49 +815,53 @@ instruction_der(struct_processus *s_etat void instruction_detach(struct_processus *s_etat_processus) { - logical1 drapeau; - logical1 variable_partagee; + int pipe_initialisation_segment_signaux[2]; - pid_t ppid; - pid_t pid_final; + logical1 drapeau; - pthread_attr_t attributs; + pid_t ppid; - pthread_mutexattr_t attributs_mutex; + pthread_attr_t attributs; - pthread_t thread_surveillance; + pthread_mutexattr_t attributs_mutex; - sig_atomic_t registre_stop; + pthread_t thread_surveillance; - sigset_t oldset; - sigset_t oldset2; - sigset_t set; - sigset_t set2; + sig_atomic_t registre_stop; - ssize_t longueur_ecriture; + ssize_t longueur_ecriture; - struct_descripteur_thread *s_argument_thread; - struct_descripteur_thread *s_argument_thread2; + struct_descripteur_thread *s_argument_thread; + struct_descripteur_thread *s_argument_thread2; - struct_liste_chainee *l_element_courant; - struct_liste_chainee *l_element_precedent; - struct_liste_chainee *l_element_suivant; + struct_liste_chainee *l_element_courant; + 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; - struct_objet *s_copie; - struct_objet *s_objet; - struct_objet *s_objet_systeme; - struct_objet *s_objet_temporaire; + struct_objet *s_copie; + struct_objet *s_objet; + struct_objet *s_objet_systeme; + struct_objet *s_objet_temporaire; - struct sigaction action; - struct sigaction registre; + struct sigaction action; + struct sigaction registre; - struct timespec attente; + struct timespec attente; - unsigned char *message; + unsigned char caractere; + unsigned char *message; - unsigned int erreur; + unsigned int erreur; - unsigned long i; + integer8 i; + + volatile logical1 variable_partagee; (*s_etat_processus).erreur_execution = d_ex; @@ -932,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; @@ -960,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; @@ -983,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; @@ -1003,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; @@ -1033,107 +1022,81 @@ instruction_detach(struct_processus *s_e } } - if (sigemptyset(&set) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; - } - - if (sigaddset(&set, SIGSTART) != 0) + if ((s_argument_thread = malloc(sizeof(struct_descripteur_thread))) == NULL) { (*s_etat_processus).erreur_systeme = d_es_processus; return; } - /* - * Le signal SIGFSTOP doit être traité ! - */ - - if (sigaddset(&set, SIGFSTOP) != 0) + if (pipe((*s_argument_thread).pipe_erreurs) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; } - if (sigaddset(&set, SIGFABORT) != 0) + if (pipe((*s_argument_thread).pipe_interruptions) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; } - if (sigaddset(&set, SIGURG) != 0) + if (pipe((*s_argument_thread).pipe_nombre_elements_attente) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; } - if (pthread_sigmask(SIG_BLOCK, &set, &oldset) != 0) + if (pipe((*s_argument_thread).pipe_objets) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; } - if ((s_argument_thread = malloc(sizeof(struct_descripteur_thread))) == NULL) + if (pipe((*s_argument_thread).pipe_acquittement) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; } - if (pipe((*s_argument_thread).pipe_erreurs) != 0) + if (pipe((*s_argument_thread).pipe_injections) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; } - if (pipe((*s_argument_thread).pipe_interruptions) != 0) + if (pipe((*s_argument_thread).pipe_nombre_injections) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; } - if (pipe((*s_argument_thread).pipe_nombre_interruptions_attente) != 0) + if (pipe(pipe_initialisation_segment_signaux) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; } - if (pipe((*s_argument_thread).pipe_objets) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; - } + ppid = getpid(); - if (pipe((*s_argument_thread).pipe_acquittement) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; - } + /* + * Le mutex suivant permet de copier un contexte propre. + */ - if (pipe((*s_argument_thread).pipe_nombre_objets_attente) != 0) + if (pthread_mutex_lock(&((*s_etat_processus).mutex_pile_processus)) != 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; - return; - } + verrouillage_threads_concurrents(s_etat_processus); - if (pipe((*s_argument_thread).pipe_nombre_injections) != 0) + if (pthread_mutex_lock(&mutex_liste_variables_partagees) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; } - ppid = getpid(); - - /* - * 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_allocation_buffer)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; @@ -1146,15 +1109,21 @@ instruction_detach(struct_processus *s_e * de mémoire, ni libération, ni copie d'objet concurrent au fork(). */ - sigfillset(&set2); - pthread_sigmask(SIG_BLOCK, &set2, &oldset2); - - verrouillage_threads_concurrents(s_etat_processus); (*s_argument_thread).pid = fork(); - deverrouillage_threads_concurrents(s_etat_processus); - pthread_sigmask(SIG_SETMASK, &oldset2, NULL); - sigpending(&set2); + 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; @@ -1176,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); @@ -1223,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; @@ -1236,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; @@ -1273,28 +1242,30 @@ instruction_detach(struct_processus *s_e return; } -# ifndef OS2 -# ifndef Cygwin +# ifdef SCHED_OTHER if (pthread_attr_setschedpolicy(&attributs, SCHED_OTHER) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; } +# endif +# ifdef PTHREAD_EXPLICIT_SCHED if (pthread_attr_setinheritsched(&attributs, PTHREAD_EXPLICIT_SCHED) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; } +# endif +# ifdef PTHREAD_SCOPE_SYSTEM if (pthread_attr_setscope(&attributs, PTHREAD_SCOPE_SYSTEM) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; } # endif -# endif (*s_argument_thread).s_etat_processus = s_etat_processus; @@ -1317,12 +1288,53 @@ instruction_detach(struct_processus *s_e * Processus fils */ -# ifdef _BROKEN_SIGINFO - liberation_fifos_signaux(s_etat_processus); - creation_fifos_signaux(s_etat_processus); -# endif + // EPERM +#if 0 + 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_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); - (*s_etat_processus).signal_a_traiter = d_faux; + liberation_queue_signaux(s_etat_processus); + creation_queue_signaux(s_etat_processus); + + routine_recursive = 0; + nombre_thread_surveillance_processus = 0; + + (*s_etat_processus).pointeur_signal_lecture = 0; + (*s_etat_processus).pointeur_signal_ecriture = 0; + + if (write_atomic(s_etat_processus, + pipe_initialisation_segment_signaux[1], + "-", sizeof(unsigned char)) != sizeof(unsigned char)) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + } + + close(pipe_initialisation_segment_signaux[0]); + close(pipe_initialisation_segment_signaux[1]); if ((*s_etat_processus).debug == d_vrai) if (((*s_etat_processus).type_debug & @@ -1342,65 +1354,6 @@ instruction_detach(struct_processus *s_e fflush(stdout); } -# ifndef SEMAPHORES_NOMMES - sem_post(&semaphore_gestionnaires_signaux); - sem_destroy(&semaphore_gestionnaires_signaux); - sem_init(&semaphore_gestionnaires_signaux, 0, 0); -# else - sem_post(semaphore_gestionnaires_signaux); - sem_destroy2(semaphore_gestionnaires_signaux, - sem_gestionnaires_signaux); - - if ((semaphore_gestionnaires_signaux = sem_init2(0, - sem_gestionnaires_signaux)) == SEM_FAILED) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - } -# endif - -# ifndef SEMAPHORES_NOMMES - sem_post(&semaphore_liste_threads); - sem_destroy(&semaphore_liste_threads); - sem_init(&semaphore_liste_threads, 0, 1); -# else - sem_post(semaphore_liste_threads); - sem_destroy2(semaphore_liste_threads, sem_liste_threads); - - if ((semaphore_liste_threads = sem_init2(1, - sem_liste_threads)) == SEM_FAILED) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - } -# endif - -# ifndef SEMAPHORES_NOMMES - sem_destroy(&semaphore_gestionnaires_signaux_atomique); - sem_init(&semaphore_gestionnaires_signaux_atomique, 0, 1); - sem_trywait(&((*s_etat_processus).semaphore_fork)); -# else - sem_destroy2(semaphore_gestionnaires_signaux_atomique, - sem_gestionnaires_signaux_atomique); - - if ((semaphore_gestionnaires_signaux_atomique = sem_init2(1, - sem_gestionnaires_signaux_atomique)) == SEM_FAILED) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - } - - sem_trywait((*s_etat_processus).semaphore_fork); -# endif - -# ifndef SEMAPHORES_NOMMES - if (pthread_setspecific(semaphore_fork_processus_courant, - &((*s_etat_processus).semaphore_fork)) != 0) -# else - if (pthread_setspecific(semaphore_fork_processus_courant, - (*s_etat_processus).semaphore_fork) != 0) -# endif - { - (*s_etat_processus).erreur_systeme = d_es_processus; - } - if (close((*s_argument_thread).pipe_erreurs[0]) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; @@ -1410,7 +1363,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; } @@ -1418,10 +1371,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; @@ -1455,13 +1404,6 @@ instruction_detach(struct_processus *s_e l_element_courant = (*s_etat_processus).liste_mutexes; while(l_element_courant != NULL) { - pthread_mutex_trylock(&((*((struct_mutex *) (*(*l_element_courant) - .donnee).objet)).mutex)); - pthread_mutex_unlock(&((*((struct_mutex *) (*(*l_element_courant) - .donnee).objet)).mutex)); - pthread_mutex_destroy(&((*((struct_mutex *) (*(*l_element_courant) - .donnee).objet)).mutex)); - liberation(s_etat_processus, (*l_element_courant).donnee); l_element_suivant = (*l_element_courant).suivant; free(l_element_courant); @@ -1471,31 +1413,22 @@ 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)); (*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)) + (*s_argument_thread).pipe_nombre_elements_attente[1], + &caractere, sizeof(caractere))) != sizeof(caractere)) { if (longueur_ecriture == -1) { @@ -1503,33 +1436,18 @@ instruction_detach(struct_processus *s_e } } - 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) - { - break; - } - } - -# ifdef _BROKEN_SIGINFO - destruction_fifos_signaux(s_etat_processus); -# endif - + destruction_queue_signaux(s_etat_processus); BUG(1, uprintf("Process management error line %d\n", __LINE__)); exit(EXIT_FAILURE); } - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_destroy(&mutex_sections_critiques) != 0) { (*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)) + (*s_argument_thread).pipe_nombre_elements_attente[1], + &caractere, sizeof(caractere))) != sizeof(caractere)) { if (longueur_ecriture == -1) { @@ -1537,60 +1455,15 @@ instruction_detach(struct_processus *s_e } } - 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) - { - break; - } - } - -# ifdef _BROKEN_SIGINFO - destruction_fifos_signaux(s_etat_processus); -# endif - + 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; - - 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)) - { - if (longueur_ecriture == -1) - { - break; - } - } - -# ifdef _BROKEN_SIGINFO - destruction_fifos_signaux(s_etat_processus); -# endif - - BUG(1, uprintf("Process management error line %d\n", __LINE__)); - exit(EXIT_FAILURE); - } + pthread_mutexattr_init(&attributs_mutex); + pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_RECURSIVE); + pthread_mutex_init(&mutex_sections_critiques, &attributs_mutex); + pthread_mutexattr_destroy(&attributs_mutex); if ((*s_etat_processus).evaluation_expression_compilee == 'N') { @@ -1646,33 +1519,23 @@ instruction_detach(struct_processus *s_e * renseignée. */ - if (sigpending(&set) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - } - else if (sigismember(&set, SIGSTART) == 0) - { - while(sigismember(&set, SIGSTART) == 0) - { - if (sigpending(&set) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - } + // Attente de la réception du signal rpl_sigstart. - nanosleep(&attente, NULL); - } + for((*s_etat_processus).demarrage_fils = d_faux; + (*s_etat_processus).demarrage_fils != d_vrai; + nanosleep(&attente, NULL)) + { + scrutation_interruptions(s_etat_processus); } (*s_etat_processus).niveau_initial = (*s_etat_processus).niveau_courant; (*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 = @@ -1685,6 +1548,8 @@ instruction_detach(struct_processus *s_e (*s_etat_processus).presence_fusible = d_faux; (*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) { @@ -1711,25 +1576,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) { @@ -1737,10 +1593,7 @@ instruction_detach(struct_processus *s_e } } -# ifdef _BROKEN_SIGINFO - destruction_fifos_signaux(s_etat_processus); -# endif - + destruction_queue_signaux(s_etat_processus); BUG(1, uprintf("Process management error line %d\n", __LINE__)); exit(EXIT_FAILURE); } @@ -1757,9 +1610,7 @@ instruction_detach(struct_processus *s_e (*s_argument_thread2).nombre_references--; BUG((*s_argument_thread2).nombre_references < 0, -# ifdef _BROKEN_SIGINFO - destruction_fifos_signaux(s_etat_processus), -# endif + destruction_queue_signaux(s_etat_processus), printf("(*s_argument_thread2).nombre_references = %d\n", (int) (*s_argument_thread2).nombre_references)); @@ -1769,10 +1620,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)); @@ -1797,15 +1646,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)) + (*s_argument_thread).pipe_nombre_elements_attente[1], + &caractere, sizeof(caractere))) != sizeof(caractere)) { if (longueur_ecriture == -1) { @@ -1813,20 +1663,7 @@ instruction_detach(struct_processus *s_e } } - 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) - { - break; - } - } - -# ifdef _BROKEN_SIGINFO - destruction_fifos_signaux(s_etat_processus); -# endif - + destruction_queue_signaux(s_etat_processus); BUG(1, uprintf("Process management error line %d\n", __LINE__)); exit(EXIT_FAILURE); } @@ -1869,21 +1706,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) { @@ -1891,10 +1718,7 @@ instruction_detach(struct_processus *s_e } } -# ifdef _BROKEN_SIGINFO - destruction_fifos_signaux(s_etat_processus); -# endif - + destruction_queue_signaux(s_etat_processus); BUG(1, uprintf("Process management error line %d\n", __LINE__)); exit(EXIT_FAILURE); } @@ -1925,11 +1749,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)) + (*s_argument_thread).pipe_nombre_elements_attente[1], + &caractere, sizeof(caractere))) != sizeof(caractere)) { if (longueur_ecriture == -1) { @@ -1937,20 +1761,7 @@ instruction_detach(struct_processus *s_e } } - 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) - { - break; - } - } - -# ifdef _BROKEN_SIGINFO - destruction_fifos_signaux(s_etat_processus); -# endif - + destruction_queue_signaux(s_etat_processus); BUG(1, uprintf("Process management error line %d\n", __LINE__)); exit(EXIT_FAILURE); } @@ -2020,6 +1831,8 @@ instruction_detach(struct_processus *s_e l_element_courant = l_element_suivant; } + (*s_etat_processus).s_fichiers = NULL; + /* * Destruction des piles de connecteurs SQL */ @@ -2042,21 +1855,12 @@ instruction_detach(struct_processus *s_e 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 * pour traiter plusieurs connexions simultanées sur les sockets */ - (*s_etat_processus).s_fichiers = NULL; - - if (pthread_sigmask(SIG_SETMASK, &oldset, NULL) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - } - - sigpending(&set); + (*s_etat_processus).s_connecteurs_sql = NULL; if ((*s_etat_processus).debug == d_vrai) { @@ -2076,6 +1880,18 @@ instruction_detach(struct_processus *s_e if ((*s_etat_processus).erreur_systeme == d_es) { + // Évite le warning variable s_copie might be clobbered by + // longjmp or vfork + struct_objet **s; + + if ((s = malloc(sizeof(struct_objet *))) == NULL) + { + (*s_etat_processus).erreur_execution = d_es_allocation_memoire; + return; + } + + (*s) = s_copie; + if (setjmp(contexte_processus) == 0) { if (variable_partagee == d_faux) @@ -2091,11 +1907,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') == @@ -2104,12 +1927,17 @@ 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); + } } } } else { - if (evaluation(s_etat_processus, s_copie, 'E') == d_erreur) + if (evaluation(s_etat_processus, (*s), 'E') == d_erreur) { if (((*s_etat_processus).erreur_execution == d_ex) && ((*s_etat_processus).erreur_systeme == d_es)) @@ -2120,9 +1948,18 @@ instruction_detach(struct_processus *s_e } else { - if ((*s_etat_processus).at_exit != NULL) + 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') == @@ -2131,12 +1968,24 @@ 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); + } } } - liberation(s_etat_processus, s_copie); + liberation(s_etat_processus, (*s)); } } + + free(s); + } + + for(i = 0; i < (*s_etat_processus).sections_critiques; i++) + { + pthread_mutex_unlock(&mutex_sections_critiques); } liberation(s_etat_processus, (*s_etat_processus).at_exit); @@ -2145,13 +1994,6 @@ instruction_detach(struct_processus *s_e l_element_courant = (*s_etat_processus).liste_mutexes; while(l_element_courant != NULL) { - pthread_mutex_trylock(&((*((struct_mutex *) - (*(*l_element_courant).donnee).objet)).mutex)); - pthread_mutex_unlock(&((*((struct_mutex *) - (*(*l_element_courant).donnee).objet)).mutex)); - pthread_mutex_destroy(&((*((struct_mutex *) - (*(*l_element_courant).donnee).objet)).mutex)); - liberation(s_etat_processus, (*l_element_courant).donnee); l_element_suivant = (*l_element_courant).suivant; free(l_element_courant); @@ -2163,21 +2005,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) { @@ -2206,7 +2038,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)) { @@ -2238,7 +2070,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)) { @@ -2276,15 +2108,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) @@ -2322,7 +2145,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; @@ -2362,23 +2185,23 @@ instruction_detach(struct_processus *s_e if ((*s_etat_processus).var_volatile_alarme != 0) { - kill((*(*((struct_processus_fils *) + envoi_signal_processus((*(*((struct_processus_fils *) (*(*l_element_courant).donnee).objet)).thread).pid, - SIGURG); + rpl_sigurg, d_faux); } else { if ((*s_etat_processus).arret_depuis_abort == -1) { - kill((*(*((struct_processus_fils *) + envoi_signal_processus((*(*((struct_processus_fils *) (*(*l_element_courant).donnee).objet)).thread) - .pid, SIGFABORT); + .pid, rpl_sigabort, d_faux); } else { - kill((*(*((struct_processus_fils *) + envoi_signal_processus((*(*((struct_processus_fils *) (*(*l_element_courant).donnee).objet)).thread) - .pid, SIGFSTOP); + .pid, rpl_sigstop, d_faux); } } } @@ -2420,23 +2243,23 @@ instruction_detach(struct_processus *s_e { if ((*s_etat_processus).var_volatile_alarme != 0) { - pthread_kill((*(*((struct_processus_fils *) + envoi_signal_thread((*(*((struct_processus_fils *) (*(*l_element_courant).donnee).objet)).thread) - .tid, SIGURG); + .tid, rpl_sigurg); } else { if ((*s_etat_processus).arret_depuis_abort == -1) { - pthread_kill((*(*((struct_processus_fils *) + envoi_signal_thread((*(*((struct_processus_fils *) (*(*l_element_courant).donnee).objet)) - .thread).tid, SIGFABORT); + .thread).tid, rpl_sigabort); } else { - pthread_kill((*(*((struct_processus_fils *) + envoi_signal_thread((*(*((struct_processus_fils *) (*(*l_element_courant).donnee).objet)) - .thread).tid, SIGFSTOP); + .thread).tid, rpl_sigstop); } } } @@ -2467,7 +2290,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++) { @@ -2485,7 +2308,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) { @@ -2502,10 +2326,7 @@ instruction_detach(struct_processus *s_e registre_stop; } -# ifdef _BROKEN_SIGINFO - destruction_fifos_signaux(s_etat_processus); -# endif - + destruction_queue_signaux(s_etat_processus); (*s_etat_processus).erreur_systeme = d_es_signal; exit(EXIT_FAILURE); } @@ -2540,30 +2361,51 @@ instruction_detach(struct_processus *s_e if (sigaction(SIGPIPE, ®istre, NULL) != 0) { -# ifdef _BROKEN_SIGINFO - destruction_fifos_signaux(s_etat_processus); -# endif - - pthread_mutex_unlock(&((*s_etat_processus).mutex)); + destruction_queue_signaux(s_etat_processus); + 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; @@ -2661,6 +2503,26 @@ instruction_detach(struct_processus *s_e (*s_etat_processus).arbre_instructions); free((*s_etat_processus).pointeurs_caracteres); + l_element_statique_courant = (*s_etat_processus) + .l_liste_variables_statiques; + + while(l_element_statique_courant != NULL) + { + l_element_statique_suivant = (*l_element_statique_courant).suivant; + free(l_element_statique_courant); + 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); @@ -2685,39 +2547,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).nombre_variables_statiques; i++) - { - liberation(s_etat_processus, - (*s_etat_processus).s_liste_variables_statiques[i].objet); - free((*s_etat_processus).s_liste_variables_statiques[i].nom); - } - - free((*s_etat_processus).s_liste_variables_statiques); - - 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) { @@ -2835,8 +2670,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) @@ -2888,50 +2721,76 @@ instruction_detach(struct_processus *s_e liberation_profil(s_etat_processus); } + attente.tv_sec = 0; + attente.tv_nsec = GRANULARITE_us * 1000; + + while(nombre_thread_surveillance_processus != 0) + { + nanosleep(&attente, NULL); + INCR_GRANULARITE(attente.tv_nsec); + } + closelog(); - liberation_allocateur(s_etat_processus); retrait_thread(s_etat_processus); + liberation_contexte_cas(s_etat_processus); - pthread_mutex_destroy(&((*s_etat_processus).mutex)); + 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_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); + pthread_mutex_destroy(&mutex_liste_variables_partagees); - pthread_key_delete(semaphore_fork_processus_courant); + destruction_queue_signaux(s_etat_processus); + pthread_mutex_destroy(&mutex_liste_threads); # ifndef SEMAPHORES_NOMMES sem_post(&((*s_etat_processus).semaphore_fork)); sem_destroy(&((*s_etat_processus).semaphore_fork)); # else sem_post((*s_etat_processus).semaphore_fork); - sem_destroy2((*s_etat_processus).semaphore_fork, sem_fork); -# endif - - free((*s_etat_processus).localisation); - free(s_argument_thread); - -# ifndef SEMAPHORES_NOMMES - sem_destroy(&semaphore_liste_threads); - sem_post(&semaphore_gestionnaires_signaux); - sem_destroy(&semaphore_gestionnaires_signaux); - sem_destroy(&semaphore_gestionnaires_signaux_atomique); -# else - sem_destroy2(semaphore_liste_threads, sem_liste_threads); - sem_post(semaphore_gestionnaires_signaux); - sem_destroy2(semaphore_gestionnaires_signaux, - sem_gestionnaires_signaux); - sem_destroy2(semaphore_gestionnaires_signaux_atomique, - sem_gestionnaires_signaux_atomique); + sem_destroy3((*s_etat_processus).semaphore_fork, getpid(), + pthread_self(), SEM_FORK); # endif - clear_history(); - -# ifdef _BROKEN_SIGINFO - destruction_fifos_signaux(s_etat_processus); -# endif - - liberation_contexte_cas(s_etat_processus); - free(s_etat_processus); + sys_free(s_etat_processus); # ifdef DEBUG_MEMOIRE debug_memoire_verification(); @@ -2969,7 +2828,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; @@ -2978,7 +2838,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; @@ -2989,6 +2850,7 @@ instruction_detach(struct_processus *s_e } } + scrutation_interruptions(s_etat_processus); l_element_courant = (*l_element_courant).suivant; } } while(drapeau == d_vrai); @@ -2997,55 +2859,46 @@ 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; } - // Être sûr que le processus fils soit déjà présent... + // On attend une donnée fictive pour être sûr que le segment de mémoire + // partagée destiné à la gestion des signaux est bien initialisé. attente.tv_sec = 0; attente.tv_nsec = GRANULARITE_us * 1000; - while(kill((*s_argument_thread).pid, 0) != 0) + while(read_atomic(s_etat_processus, + pipe_initialisation_segment_signaux[0], + &caractere, sizeof(caractere)) == 0) { - //if ((errno != ESRCH) && (errno != EAGAIN)) - if (errno != ESRCH) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - pthread_mutex_unlock(&((*s_etat_processus).mutex)); - return; - } - + scrutation_interruptions(s_etat_processus); nanosleep(&attente, NULL); INCR_GRANULARITE(attente.tv_nsec); } - // Le fils peut être présent sans être en attente du signal de départ. + close(pipe_initialisation_segment_signaux[0]); + close(pipe_initialisation_segment_signaux[1]); - if (kill((*s_argument_thread).pid, SIGSTART) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - pthread_mutex_unlock(&((*s_etat_processus).mutex)); - return; - } + // Le fils peut être présent sans être en attente du signal de départ. - if (pthread_sigmask(SIG_SETMASK, &oldset, NULL) != 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; } - sigpending(&set); - - 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;