--- rpl/src/instructions_d5.c 2015/02/16 19:49:38 1.127 +++ rpl/src/instructions_d5.c 2016/09/27 15:29:35 1.155 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.1.20 - Copyright (C) 1989-2015 Dr. BERTRAND Joël + RPL/2 (R) version 4.1.26 + Copyright (C) 1989-2016 Dr. BERTRAND Joël This file is part of RPL/2. @@ -815,6 +815,10 @@ instruction_der(struct_processus *s_etat void instruction_detach(struct_processus *s_etat_processus) { +#ifndef EXPERIMENTAL_CODE + printf("DETACH currently broken is replaced by SPAWN...\n"); + instruction_spawn(s_etat_processus); +#else int pipe_initialisation_segment_signaux[2]; logical1 drapeau; @@ -1088,6 +1092,14 @@ instruction_detach(struct_processus *s_e return; } + if (pthread_mutex_lock(&mutex_liste_variables_partagees) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + 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; @@ -1101,9 +1113,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) @@ -1112,6 +1122,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; @@ -1132,6 +1149,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); @@ -1269,14 +1292,43 @@ instruction_detach(struct_processus *s_e * Processus fils */ - if (lancement_thread_signaux(s_etat_processus) != d_absence_erreur) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - } + // 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); + +#if 0 liberation_queue_signaux(s_etat_processus); +#endif 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; @@ -1288,6 +1340,7 @@ instruction_detach(struct_processus *s_e (*s_etat_processus).erreur_systeme = d_es_processus; } +#if 0 close(pipe_initialisation_segment_signaux[0]); close(pipe_initialisation_segment_signaux[1]); @@ -1364,10 +1417,13 @@ instruction_detach(struct_processus *s_e free(l_element_courant); l_element_courant = l_element_suivant; } +#endif (*s_etat_processus).liste_mutexes = NULL; +#if 0 liberation_threads(s_etat_processus); +#endif insertion_thread(s_etat_processus, d_vrai); // Envoi d'une donnée pour signaler le démarrage du processus au thread @@ -1397,6 +1453,7 @@ instruction_detach(struct_processus *s_e exit(EXIT_FAILURE); } +#if 0 if (pthread_mutex_destroy(&mutex_sections_critiques) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; @@ -1415,6 +1472,7 @@ instruction_detach(struct_processus *s_e BUG(1, uprintf("Process management error line %d\n", __LINE__)); exit(EXIT_FAILURE); } +#endif pthread_mutexattr_init(&attributs_mutex); pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_RECURSIVE); @@ -1517,10 +1575,13 @@ instruction_detach(struct_processus *s_e if ((*s_etat_processus).evaluation_expression_compilee == 'N') { +#if 0 free((*s_etat_processus).instruction_courante); +#endif (*s_etat_processus).instruction_courante = NULL; } +#if 0 (*s_etat_processus).var_volatile_processus_pere = 0; (*s_etat_processus).var_volatile_processus_racine = 0; @@ -1537,16 +1598,20 @@ instruction_detach(struct_processus *s_e liberation(s_etat_processus, (*s_etat_processus).at_poke); (*s_etat_processus).at_poke = NULL; (*s_etat_processus).traitement_at_poke = 'N'; +#endif for(i = 0; i < d_NOMBRE_INTERRUPTIONS; i++) { +#if 0 liberation(s_etat_processus, (*s_etat_processus).corps_interruptions[i]); +#endif (*s_etat_processus).corps_interruptions[i] = NULL; (*s_etat_processus).masque_interruptions[i] = 'N'; (*s_etat_processus).queue_interruptions[i] = 0; +#if 0 l_element_courant = (*s_etat_processus) .pile_origine_interruptions[i]; @@ -1557,6 +1622,7 @@ instruction_detach(struct_processus *s_e free(l_element_courant); l_element_courant = l_element_suivant; } +#endif (*s_etat_processus).pile_origine_interruptions[i] = NULL; } @@ -1571,18 +1637,14 @@ instruction_detach(struct_processus *s_e // Attente de la réception du signal rpl_sigstart. - for((*s_etat_processus).demarrage_fils = d_faux;;) + for((*s_etat_processus).demarrage_fils = d_faux; + (*s_etat_processus).demarrage_fils != d_vrai; + nanosleep(&attente, NULL)) { scrutation_interruptions(s_etat_processus); - - if ((*s_etat_processus).demarrage_fils == d_vrai) - { - break; - } - - nanosleep(&attente, NULL); } +#if 0 (*s_etat_processus).niveau_initial = (*s_etat_processus).niveau_courant; (*s_etat_processus).presence_pipes = d_vrai; (*s_etat_processus).debug_programme = d_faux; @@ -1605,18 +1667,23 @@ instruction_detach(struct_processus *s_e (*s_etat_processus).pid_erreur_processus_fils = getpid(); (*s_etat_processus).sections_critiques = 0; (*s_etat_processus).initialisation_scheduler = d_faux; +#endif +#if 0 if ((*s_etat_processus).profilage == d_vrai) { liberation_profil(s_etat_processus); } +#endif (*s_etat_processus).pile_profilage = NULL; +#if 0 if ((*s_etat_processus).generateur_aleatoire != NULL) { liberation_generateur_aleatoire(s_etat_processus); } +#endif (*s_etat_processus).generateur_aleatoire = NULL; @@ -1669,6 +1736,7 @@ instruction_detach(struct_processus *s_e printf("(*s_argument_thread2).nombre_references = %d\n", (int) (*s_argument_thread2).nombre_references)); +#if 0 if ((*s_argument_thread2).nombre_references == 0) { close((*s_argument_thread2).pipe_objets[0]); @@ -1693,6 +1761,7 @@ instruction_detach(struct_processus *s_e free((*(*l_element_courant).donnee).objet); free((*l_element_courant).donnee); } +#endif l_element_suivant = (*l_element_courant).suivant; free((struct_liste_chainee *) l_element_courant); @@ -1727,6 +1796,7 @@ instruction_detach(struct_processus *s_e * Initialisation de la pile système */ +#if 0 l_element_courant = (struct_liste_chainee *) (*s_etat_processus).l_base_pile_systeme; while(l_element_courant != NULL) @@ -1753,10 +1823,12 @@ instruction_detach(struct_processus *s_e l_element_courant = l_element_suivant; } +#endif (*s_etat_processus).l_base_pile_systeme = NULL; (*s_etat_processus).hauteur_pile_systeme = 0; +#if 0 empilement_pile_systeme(s_etat_processus); if ((*s_etat_processus).erreur_systeme != d_es) @@ -1779,7 +1851,9 @@ instruction_detach(struct_processus *s_e } (*(*s_etat_processus).l_base_pile_systeme).retour_definition = 'Y'; +#endif +#if 0 l_element_courant = (struct_liste_chainee *) (*s_etat_processus).s_marques; @@ -1792,6 +1866,7 @@ instruction_detach(struct_processus *s_e free((struct_marque *) l_element_courant); l_element_courant = l_element_suivant; } +#endif (*s_etat_processus).s_marques = NULL; @@ -1800,6 +1875,7 @@ instruction_detach(struct_processus *s_e * les variables dans le cas d'un programme compilé. */ +#if 0 empilement_pile_systeme(s_etat_processus); if ((*s_etat_processus).erreur_systeme != d_es) @@ -1822,11 +1898,13 @@ instruction_detach(struct_processus *s_e } (*(*s_etat_processus).l_base_pile_systeme).retour_definition = 'Y'; +#endif /* * Destruction des sorties graphiques et PostScript */ +#if 0 while((*s_etat_processus).fichiers_graphiques != NULL) { free((*(*s_etat_processus).fichiers_graphiques).nom); @@ -1848,6 +1926,7 @@ instruction_detach(struct_processus *s_e pclose((*s_etat_processus).entree_standard); (*s_etat_processus).entree_standard = NULL; } +#endif (*s_etat_processus).requete_nouveau_plan = d_vrai; (*s_etat_processus).mise_a_jour_trace_requise = d_faux; @@ -1862,6 +1941,7 @@ instruction_detach(struct_processus *s_e * Destruction des piles de fichiers */ +#if 0 l_element_courant = (*s_etat_processus).s_fichiers; while(l_element_courant != NULL) @@ -1886,6 +1966,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 */ @@ -1908,14 +1990,13 @@ 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; + (*s_etat_processus).s_connecteurs_sql = NULL; +#endif if ((*s_etat_processus).debug == d_vrai) { @@ -1933,6 +2014,7 @@ instruction_detach(struct_processus *s_e } } +#if 0 if ((*s_etat_processus).erreur_systeme == d_es) { // Évite le warning variable s_copie might be clobbered by @@ -2037,7 +2119,9 @@ instruction_detach(struct_processus *s_e free(s); } +#endif +#if 0 for(i = 0; i < (*s_etat_processus).sections_critiques; i++) { pthread_mutex_unlock(&mutex_sections_critiques); @@ -2059,6 +2143,7 @@ instruction_detach(struct_processus *s_e { pthread_cancel((*s_etat_processus).thread_fusible); } +#endif caractere = 0; @@ -2163,14 +2248,7 @@ 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]); - +#if 0 l_element_courant = (*s_etat_processus).s_fichiers; while(l_element_courant != NULL) @@ -2250,7 +2328,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 { @@ -2258,13 +2336,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); } } } @@ -2733,8 +2811,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) @@ -2786,16 +2862,23 @@ instruction_detach(struct_processus *s_e liberation_profil(s_etat_processus); } +#endif + attente.tv_sec = 0; + attente.tv_nsec = GRANULARITE_us * 1000; + + while(nombre_thread_surveillance_processus != 0) + { + nanosleep(&attente, NULL); + INCR_GRANULARITE(attente.tv_nsec); + } + +#if 0 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); +#endif + destruction_queue_signaux(s_etat_processus); # ifndef SEMAPHORES_NOMMES sem_post(&((*s_etat_processus).semaphore_fork)); @@ -2806,23 +2889,41 @@ instruction_detach(struct_processus *s_e pthread_self(), SEM_FORK); # endif +#if 0 + 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 debug_memoire_verification(); analyse_post_mortem(); # endif +#endif exit(EXIT_SUCCESS); } @@ -2917,7 +3018,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)); @@ -2931,6 +3033,7 @@ instruction_detach(struct_processus *s_e } return; +#endif } // vim: ts=4