--- rpl/src/instructions_d5.c 2015/10/26 15:14:19 1.136 +++ rpl/src/instructions_d5.c 2016/07/20 16:24:29 1.152 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.1.23 - Copyright (C) 1989-2015 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. @@ -1094,6 +1094,8 @@ instruction_detach(struct_processus *s_e 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; @@ -1107,9 +1109,7 @@ 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) @@ -1118,6 +1118,13 @@ instruction_detach(struct_processus *s_e 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; @@ -1281,15 +1288,15 @@ instruction_detach(struct_processus *s_e * Processus fils */ + // EPERM 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_mutex_destroy(&mutex_liste_threads); - pthread_mutexattr_init(&attributs_mutex); pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_RECURSIVE); pthread_mutex_init(&mutex_liste_threads, &attributs_mutex); @@ -1298,12 +1305,8 @@ instruction_detach(struct_processus *s_e 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; - } - routine_recursive = 0; + nombre_thread_surveillance_processus = 0; (*s_etat_processus).pointeur_signal_lecture = 0; (*s_etat_processus).pointeur_signal_ecriture = 0; @@ -2190,14 +2193,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_elements_attente[1]); - close((*s_argument_thread).pipe_objets[1]); - close((*s_argument_thread).pipe_injections[0]); - close((*s_argument_thread).pipe_nombre_injections[0]); - close((*s_argument_thread).pipe_acquittement[0]); - l_element_courant = (*s_etat_processus).s_fichiers; while(l_element_courant != NULL) @@ -2277,7 +2272,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 { @@ -2285,13 +2280,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); } } } @@ -2760,8 +2755,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,16 +2806,20 @@ 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(); retrait_thread(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(&mutex_sections_critiques); + liberation_contexte_cas(s_etat_processus); + destruction_queue_signaux(s_etat_processus); # ifndef SEMAPHORES_NOMMES sem_post(&((*s_etat_processus).semaphore_fork)); @@ -2833,17 +2830,33 @@ instruction_detach(struct_processus *s_e pthread_self(), SEM_FORK); # endif + 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); - clear_history(); - - destruction_queue_signaux(s_etat_processus); - liberation_contexte_cas(s_etat_processus); - arret_thread_signaux(s_etat_processus); liberation_allocateur(s_etat_processus); liberation_allocateur_buffer(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); + pthread_mutex_destroy(&mutex_liste_variables_partagees); + pthread_mutex_destroy(&mutex_liste_threads); + sys_free(s_etat_processus); # ifdef DEBUG_MEMOIRE @@ -2944,7 +2957,8 @@ 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_pile_processus));