--- rpl/src/instructions_d5.c 2010/04/28 11:05:45 1.16 +++ rpl/src/instructions_d5.c 2010/06/02 10:28:45 1.24 @@ -1,6 +1,6 @@ /* ================================================================================ - RPL/2 (R) version 4.0.15 + RPL/2 (R) version 4.0.16 Copyright (C) 1989-2010 Dr. BERTRAND Joël This file is part of RPL/2. @@ -1062,6 +1062,12 @@ instruction_detach(struct_processus *s_e return; } + if (sigaddset(&set, SIGFABORT) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + if (sigaddset(&set, SIGURG) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; @@ -1638,8 +1644,29 @@ instruction_detach(struct_processus *s_e * Initialisation de la pile des processus */ + l_element_courant = (struct_liste_chainee *) + (*s_etat_processus).l_base_pile_processus; + + while(l_element_courant != NULL) + { + l_element_suivant = (*l_element_courant).suivant; + + if ((*((*(struct_processus_fils *) (*(*l_element_courant).donnee) + .objet)).thread).processus_detache == d_faux) + { + liberation(s_etat_processus, (*((*(struct_processus_fils *) + (*(*l_element_courant).donnee).objet)).thread) + .argument); + } + + free((*(*l_element_courant).donnee).objet); + free((*l_element_courant).donnee); + free(l_element_courant); + + l_element_courant = l_element_suivant; + } + (*s_etat_processus).l_base_pile_processus = NULL; - // Les données associées sont déjà effacées par liberation_thread(). /* * Initialisation de la pile système @@ -1824,17 +1851,26 @@ instruction_detach(struct_processus *s_e * Destruction des piles de connecteurs SQL */ +/* +================================================================================ + À noter : on ne ferme pas la connexion car la conséquence immédiate est + une destruction de l'objet pour le processus père. +================================================================================ +*/ + l_element_courant = (*s_etat_processus).s_connecteurs_sql; while(l_element_courant != NULL) { l_element_suivant = (*l_element_courant).suivant; - sqlclose((*l_element_courant).donnee); +// sqlclose((*l_element_courant).donnee); liberation(s_etat_processus, (*l_element_courant).donnee); 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 @@ -2234,11 +2270,6 @@ instruction_detach(struct_processus *s_e l_element_courant = (struct_liste_chainee *) (*s_etat_processus).l_base_pile_processus; - if ((*s_etat_processus).nombre_interruptions_non_affectees != 0) - { - affectation_interruptions_logicielles(s_etat_processus); - } - registre_stop = (*s_etat_processus) .var_volatile_traitement_retarde_stop; (*s_etat_processus).var_volatile_traitement_retarde_stop = 1; @@ -2321,6 +2352,12 @@ instruction_detach(struct_processus *s_e } pthread_mutex_unlock(&((*s_etat_processus).mutex)); + + if ((*s_etat_processus).nombre_interruptions_non_affectees != 0) + { + affectation_interruptions_logicielles(s_etat_processus); + } + nanosleep(&attente, NULL); pthread_mutex_lock(&((*s_etat_processus).mutex)); } @@ -2623,6 +2660,8 @@ instruction_detach(struct_processus *s_e liberation(s_etat_processus, s_objet); # ifndef Cygwin + (*s_etat_processus).pile_signal.ss_flags = SS_DISABLE; + sigaltstack(&((*s_etat_processus).pile_signal), NULL); free((*s_etat_processus).pile_signal.ss_sp); # endif @@ -2678,7 +2717,6 @@ instruction_detach(struct_processus *s_e # endif free((*s_etat_processus).localisation); - free(s_etat_processus); free(s_argument_thread); # ifndef SEMAPHORES_NOMMES @@ -2697,8 +2735,11 @@ instruction_detach(struct_processus *s_e clear_history(); + free(s_etat_processus); + # ifdef DEBUG_MEMOIRE - debug_memoire_verification(s_etat_processus); + debug_memoire_verification(); + analyse_post_mortem(); # endif exit(EXIT_SUCCESS);