--- rpl/src/instructions_d5.c 2011/09/15 17:51:43 1.69 +++ rpl/src/instructions_d5.c 2012/10/07 08:18:35 1.95 @@ -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.11 + Copyright (C) 1989-2012 Dr. BERTRAND Joël This file is part of RPL/2. @@ -814,47 +814,51 @@ instruction_der(struct_processus *s_etat void instruction_detach(struct_processus *s_etat_processus) { - int pipe_initialisation_segment_signaux[2]; + int pipe_initialisation_segment_signaux[2]; - logical1 drapeau; - logical1 variable_partagee; + logical1 drapeau; - pid_t ppid; - pid_t pid_final; + pid_t ppid; + pid_t pid_final; - pthread_attr_t attributs; + pthread_attr_t attributs; - pthread_mutexattr_t attributs_mutex; + pthread_mutexattr_t attributs_mutex; - pthread_t thread_surveillance; + pthread_t thread_surveillance; - sig_atomic_t registre_stop; + 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_objet *s_copie; - struct_objet *s_objet; - struct_objet *s_objet_systeme; - struct_objet *s_objet_temporaire; + struct_liste_variables_statiques *l_element_statique_courant; + struct_liste_variables_statiques *l_element_statique_suivant; - struct sigaction action; - struct sigaction registre; + struct_objet *s_copie; + struct_objet *s_objet; + struct_objet *s_objet_systeme; + struct_objet *s_objet_temporaire; - struct timespec attente; + struct sigaction action; + struct sigaction registre; - unsigned char caractere; - unsigned char *message; + struct timespec attente; - unsigned int erreur; + unsigned char caractere; + unsigned char *message; - unsigned long i; + unsigned int erreur; + + unsigned long i; + + volatile logical1 variable_partagee; (*s_etat_processus).erreur_execution = d_ex; @@ -1231,28 +1235,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; @@ -1277,6 +1283,7 @@ instruction_detach(struct_processus *s_e liberation_queue_signaux(s_etat_processus); creation_queue_signaux(s_etat_processus); + routine_recursive = 0; (*s_etat_processus).pointeur_signal_lecture = 0; (*s_etat_processus).pointeur_signal_ecriture = 0; @@ -1363,13 +1370,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); @@ -1426,6 +1426,42 @@ instruction_detach(struct_processus *s_e exit(EXIT_FAILURE); } + 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)) + { + 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; + } + } + + destruction_queue_signaux(s_etat_processus); + 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 (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; @@ -1581,6 +1617,7 @@ 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; if ((*s_etat_processus).profilage == d_vrai) { @@ -1951,6 +1988,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) @@ -1984,7 +2033,7 @@ instruction_detach(struct_processus *s_e } 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)) @@ -1995,7 +2044,9 @@ instruction_detach(struct_processus *s_e } else { - if ((*s_etat_processus).at_exit != NULL) + if (((*s_etat_processus).var_volatile_alarme == 0) + && ((*s_etat_processus).arret_depuis_abort == 0) + && ((*s_etat_processus).at_exit != NULL)) { (*s_etat_processus).var_volatile_requete_arret = 0; @@ -2009,9 +2060,16 @@ instruction_detach(struct_processus *s_e } } - 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); @@ -2020,13 +2078,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); @@ -2532,6 +2583,16 @@ 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; + } + if ((*s_etat_processus).entree_standard != NULL) { pclose((*s_etat_processus).entree_standard); @@ -2560,15 +2621,6 @@ instruction_detach(struct_processus *s_e (*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++) { @@ -2767,9 +2819,16 @@ instruction_detach(struct_processus *s_e 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); - pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)); - pthread_mutex_destroy(&((*s_etat_processus).mutex_fork)); +# 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_destroy3((*s_etat_processus).semaphore_fork, getpid(), + pthread_self(), SEM_FORK); +# endif free((*s_etat_processus).localisation); free(s_argument_thread); @@ -2874,25 +2933,6 @@ instruction_detach(struct_processus *s_e close(pipe_initialisation_segment_signaux[0]); close(pipe_initialisation_segment_signaux[1]); - // Être sûr que le processus fils soit déjà présent... - - attente.tv_sec = 0; - attente.tv_nsec = GRANULARITE_us * 1000; - - while(envoi_signal_processus((*s_argument_thread).pid, rpl_signull) != 0) - { - if (errno != ENOENT) - { - (*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. if (envoi_signal_processus((*s_argument_thread).pid, rpl_sigstart) != 0)