--- rpl/src/gestion_threads.c 2010/01/27 22:22:11 1.2 +++ rpl/src/gestion_threads.c 2013/06/21 14:15:52 1.84 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.0.10 - Copyright (C) 1989-2010 Dr. BERTRAND Joël + RPL/2 (R) version 4.1.15 + Copyright (C) 1989-2013 Dr. BERTRAND Joël This file is part of RPL/2. @@ -20,7 +20,7 @@ */ -#include "rpl.conv.h" +#include "rpl-conv.h" /* @@ -38,127 +38,81 @@ void * lancement_thread(void *argument) { - int status; + int status; - pid_t ppid; + pid_t ppid; - pthread_t tid_final; + sig_atomic_t registre_stop; - sig_atomic_t registre_stop; + ssize_t longueur_ecriture; - sigset_t set; + struct_descripteur_thread *s_argument_thread; - ssize_t longueur_ecriture; + struct_liste_chainee *l_element_courant; + struct_liste_chainee *l_element_suivant; - struct_descripteur_thread *s_argument_thread; + struct_liste_variables_statiques *l_element_statique_courant; + struct_liste_variables_statiques *l_element_statique_suivant; - struct_liste_chainee *l_element_courant; - struct_liste_chainee *l_element_suivant; + struct_objet *s_objet_temporaire; - struct_objet *s_objet_temporaire; + struct_processus *s_etat_processus; - struct_processus *s_etat_processus; + struct sigaction action; + struct sigaction registre; - struct sigaction action; - struct sigaction registre; + struct timespec attente; - struct timespec attente; + unsigned char caractere; + unsigned char *message; - unsigned char *message; + unsigned int erreur; - unsigned int erreur; - - unsigned long i; + integer8 i; attente.tv_sec = 0; attente.tv_nsec = GRANULARITE_us * 1000; s_argument_thread = (struct_descripteur_thread *) argument; - (*s_argument_thread).tid = pthread_self(); - (*s_argument_thread).thread_actif = d_vrai; s_etat_processus = (*s_argument_thread).s_nouvel_etat_processus; - if (pthread_setspecific(semaphore_fork_processus_courant, - &((*s_etat_processus).semaphore_fork)) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - - pthread_mutex_unlock(&((*s_etat_processus).mutex)); - - pthread_mutex_lock(&((*s_argument_thread).mutex)); - pthread_mutex_unlock(&((*s_argument_thread).mutex)); - - (*s_argument_thread).thread_actif = d_faux; - - tid_final = -2; - - while((longueur_ecriture = write_atomic(s_etat_processus, - (*s_argument_thread).pipe_nombre_interruptions_attente[1], - &tid_final, sizeof(tid_final))) != sizeof(tid_final)) - { - if (longueur_ecriture == -1) - { - break; - } - } - - while((longueur_ecriture = write_atomic(s_etat_processus, - (*s_argument_thread).pipe_nombre_objets_attente[1], - &tid_final, sizeof(tid_final))) != sizeof(tid_final)) +# ifndef SEMAPHORES_NOMMES + sem_init(&((*s_etat_processus).semaphore_fork), 0, 0); +# else + if (((*s_etat_processus).semaphore_fork = sem_init3(0, getpid(), + pthread_self(), SEM_FORK)) == SEM_FAILED) { - if (longueur_ecriture == -1) - { - break; - } + (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; + return(NULL); } +# endif - pthread_exit(NULL); - } + (*s_argument_thread).tid = pthread_self(); + insertion_thread(s_etat_processus, d_faux); - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_lock(&((*s_argument_thread).mutex)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; + return(NULL); + } - pthread_mutex_lock(&((*s_argument_thread).mutex)); - pthread_mutex_unlock(&((*s_argument_thread).mutex)); - - (*s_argument_thread).thread_actif = d_faux; - - tid_final = -2; - - while((longueur_ecriture = write_atomic(s_etat_processus, - (*s_argument_thread).pipe_nombre_interruptions_attente[1], - &tid_final, sizeof(tid_final))) != sizeof(tid_final)) - { - if (longueur_ecriture == -1) - { - break; - } - } - - while((longueur_ecriture = write_atomic(s_etat_processus, - (*s_argument_thread).pipe_nombre_objets_attente[1], - &tid_final, sizeof(tid_final))) != sizeof(tid_final)) - { - if (longueur_ecriture == -1) - { - break; - } - } + (*s_argument_thread).thread_actif = d_vrai; - pthread_exit(NULL); + if (pthread_mutex_unlock(&((*s_argument_thread).mutex)) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return(NULL); } - insertion_thread(s_etat_processus, d_faux); - // Envoi d'une donnée pour signaler le démarrage du thread 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; pthread_mutex_lock(&((*s_argument_thread).mutex)); @@ -166,21 +120,9 @@ lancement_thread(void *argument) (*s_argument_thread).thread_actif = d_faux; - tid_final = -2; - while((longueur_ecriture = write_atomic(s_etat_processus, - (*s_argument_thread).pipe_nombre_interruptions_attente[1], - &tid_final, sizeof(tid_final))) != sizeof(tid_final)) - { - if (longueur_ecriture == -1) - { - break; - } - } - - while((longueur_ecriture = write_atomic(s_etat_processus, - (*s_argument_thread).pipe_nombre_objets_attente[1], - &tid_final, sizeof(tid_final))) != sizeof(tid_final)) + (*s_argument_thread).pipe_nombre_elements_attente[1], + &caractere, sizeof(caractere))) != sizeof(caractere)) { if (longueur_ecriture == -1) { @@ -197,23 +139,18 @@ lancement_thread(void *argument) (*s_etat_processus).instruction_courante = NULL; } - set = (*s_argument_thread).set; + // Attente de la réception du signal rpl_sigstart. - if (sigpending(&set) != 0) + for((*s_etat_processus).demarrage_fils = d_faux;;) { - (*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; - } + scrutation_interruptions(s_etat_processus); - nanosleep(&attente, NULL); + if ((*s_etat_processus).demarrage_fils == d_vrai) + { + break; } + + nanosleep(&attente, NULL); } if ((*s_etat_processus).debug == d_vrai) @@ -233,27 +170,54 @@ lancement_thread(void *argument) fflush(stdout); } - if (pthread_sigmask(SIG_SETMASK, &((*s_argument_thread).oldset), NULL) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - } - - sigpending(&set); - (*s_etat_processus).pid_erreur_processus_fils = getpid(); // Évaluation de l'objet if ((*s_etat_processus).erreur_systeme == d_es) { - if (evaluation(s_etat_processus, (*s_argument_thread).argument, 'E') - == d_erreur) + if (setjmp(contexte_thread) == 0) { - if (((*s_etat_processus).erreur_execution == d_ex) && - ((*s_etat_processus).erreur_systeme == d_es)) + if (evaluation(s_etat_processus, (*s_argument_thread).argument, 'E') + == d_erreur) { - (*s_etat_processus).erreur_execution = - d_ex_erreur_evaluation; + if (((*s_etat_processus).erreur_execution == d_ex) && + ((*s_etat_processus).erreur_systeme == d_es)) + { + (*s_etat_processus).erreur_execution = + d_ex_erreur_evaluation; + } + } + else + { + 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') == d_erreur) + { + if (((*s_etat_processus).erreur_execution == d_ex) && + ((*s_etat_processus).erreur_systeme == d_es)) + { + (*s_etat_processus).erreur_execution = + d_ex_erreur_evaluation; + } + } + + if ((*s_etat_processus).profilage == d_vrai) + { + profilage(s_etat_processus, NULL); + } + } } } @@ -268,21 +232,11 @@ lancement_thread(void *argument) pthread_cancel((*s_etat_processus).thread_fusible); } - tid_final = -2; + caractere = 0; while((longueur_ecriture = write_atomic(s_etat_processus, - (*s_argument_thread).pipe_nombre_interruptions_attente[1], - &tid_final, sizeof(tid_final))) != sizeof(tid_final)) - { - if (longueur_ecriture == -1) - { - break; - } - } - - while((longueur_ecriture = write_atomic(s_etat_processus, - (*s_argument_thread).pipe_nombre_objets_attente[1], - &tid_final, sizeof(tid_final))) != sizeof(tid_final)) + (*s_argument_thread).pipe_nombre_elements_attente[1], + &caractere, sizeof(caractere))) != sizeof(caractere)) { if (longueur_ecriture == -1) { @@ -311,7 +265,7 @@ lancement_thread(void *argument) { 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)) { @@ -343,7 +297,7 @@ lancement_thread(void *argument) { 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)) { @@ -385,9 +339,8 @@ lancement_thread(void *argument) 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_nombre_elements_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]); @@ -402,7 +355,14 @@ lancement_thread(void *argument) .donnee)).pid == getpid()) { fclose((*((struct_descripteur_fichier *) - (*l_element_courant).donnee)).descripteur); + (*l_element_courant).donnee)).descripteur_c); + + if ((*((struct_descripteur_fichier *) + (*l_element_courant).donnee)).type != 'C') + { + sqlite3_close((*((struct_descripteur_fichier *) + (*l_element_courant).donnee)).descripteur_sqlite); + } if ((*((struct_descripteur_fichier *) (*l_element_courant) .donnee)).effacement == 'Y') @@ -420,7 +380,7 @@ lancement_thread(void *argument) 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; @@ -455,13 +415,24 @@ lancement_thread(void *argument) if ((*s_etat_processus).var_volatile_alarme != 0) { - kill((*(*((struct_processus_fils *) (*(*l_element_courant) - .donnee).objet)).thread).pid, SIGURG); + envoi_signal_processus((*(*((struct_processus_fils *) + (*(*l_element_courant) + .donnee).objet)).thread).pid, rpl_sigurg); } else { - kill((*(*((struct_processus_fils *) (*(*l_element_courant) - .donnee).objet)).thread).pid, SIGFSTOP); + if ((*s_etat_processus).arret_depuis_abort == -1) + { + envoi_signal_processus((*(*((struct_processus_fils *) + (*(*l_element_courant) + .donnee).objet)).thread).pid, rpl_sigabort); + } + else + { + envoi_signal_processus((*(*((struct_processus_fils *) + (*(*l_element_courant) + .donnee).objet)).thread).pid, rpl_sigstop); + } } } else @@ -495,7 +466,8 @@ lancement_thread(void *argument) (*(*l_element_courant).donnee).objet)).thread).mutex)) != 0) { - pthread_mutex_unlock(&((*s_etat_processus).mutex)); + pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)); (*s_etat_processus).erreur_systeme = d_es_processus; pthread_mutex_lock(&((*s_argument_thread).mutex)); @@ -510,16 +482,17 @@ lancement_thread(void *argument) (*(*l_element_courant).donnee).objet)).thread) .thread_actif == d_vrai) { - pthread_kill((*(*((struct_processus_fils *) + envoi_signal_thread((*(*((struct_processus_fils *) (*(*l_element_courant).donnee).objet)).thread).tid, - SIGURG); + rpl_sigurg); } if (pthread_mutex_unlock(&((*(*((struct_processus_fils *) (*(*l_element_courant).donnee).objet)).thread) .mutex)) != 0) { - pthread_mutex_unlock(&((*s_etat_processus).mutex)); + pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)); (*s_etat_processus).erreur_systeme = d_es_processus; pthread_mutex_lock(&((*s_argument_thread).mutex)); @@ -536,7 +509,8 @@ lancement_thread(void *argument) (*(*l_element_courant).donnee).objet)).thread).mutex)) != 0) { - pthread_mutex_unlock(&((*s_etat_processus).mutex)); + pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)); (*s_etat_processus).erreur_systeme = d_es_processus; pthread_mutex_lock(&((*s_argument_thread).mutex)); @@ -551,16 +525,26 @@ lancement_thread(void *argument) (*(*l_element_courant).donnee).objet)).thread) .thread_actif == d_vrai) { - pthread_kill((*(*((struct_processus_fils *) - (*(*l_element_courant).donnee).objet)).thread).tid, - SIGFSTOP); + if ((*s_etat_processus).arret_depuis_abort == -1) + { + envoi_signal_thread((*(*((struct_processus_fils *) + (*(*l_element_courant).donnee).objet)).thread) + .tid, rpl_sigabort); + } + else + { + envoi_signal_thread((*(*((struct_processus_fils *) + (*(*l_element_courant).donnee).objet)).thread) + .tid, rpl_sigstop); + } } if (pthread_mutex_unlock(&((*(*((struct_processus_fils *) (*(*l_element_courant).donnee).objet)).thread).mutex)) != 0) { - pthread_mutex_unlock(&((*s_etat_processus).mutex)); + pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)); (*s_etat_processus).erreur_systeme = d_es_processus; pthread_mutex_lock(&((*s_argument_thread).mutex)); @@ -593,16 +577,11 @@ lancement_thread(void *argument) 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; - 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++) { @@ -620,7 +599,8 @@ lancement_thread(void *argument) 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) { @@ -671,7 +651,8 @@ lancement_thread(void *argument) if (sigaction(SIGPIPE, ®istre, NULL) != 0) { - pthread_mutex_unlock(&((*s_etat_processus).mutex)); + pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)); (*s_etat_processus).erreur_systeme = d_es_signal; exit(EXIT_FAILURE); @@ -689,12 +670,34 @@ lancement_thread(void *argument) } } - pthread_mutex_unlock(&((*s_etat_processus).mutex)); + if (pthread_mutex_lock(&((*s_etat_processus).mutex_interruptions)) != 0) + { + 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) + { + 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)); } - pthread_mutex_unlock(&((*s_etat_processus).mutex)); + pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)); l_element_courant = (*s_etat_processus).s_sockets; @@ -831,31 +834,19 @@ lancement_thread(void *argument) (*s_etat_processus).instruction_derniere_erreur = NULL; } - for(i = 0; i < (*s_etat_processus).nombre_variables; i++) - { - // Les définitions ne sont pas libérées parce qu'elles sont partagées - // avec le thread père. + liberation_arbre_variables(s_etat_processus, + (*s_etat_processus).s_arbre_variables, d_faux); - if ((*s_etat_processus).s_liste_variables[i].niveau != 0) - { - liberation(s_etat_processus, - (*s_etat_processus).s_liste_variables[i].objet); - } - - free((*s_etat_processus).s_liste_variables[i].nom); - } - - free((*s_etat_processus).s_liste_variables); + l_element_statique_courant = (*s_etat_processus) + .l_liste_variables_statiques; - for(i = 0; i < (*s_etat_processus).nombre_variables_statiques; i++) + while(l_element_statique_courant != NULL) { - liberation(s_etat_processus, - (*s_etat_processus).s_liste_variables_statiques[i].objet); - free((*s_etat_processus).s_liste_variables_statiques[i].nom); + l_element_statique_suivant = (*l_element_statique_courant).suivant; + free(l_element_statique_courant); + l_element_statique_courant = l_element_statique_suivant; } - free((*s_etat_processus).s_liste_variables_statiques); - l_element_courant = (*s_etat_processus).l_base_pile; while(l_element_courant != NULL) { @@ -979,6 +970,8 @@ lancement_thread(void *argument) } liberation(s_etat_processus, (*s_argument_thread).argument); + liberation(s_etat_processus, (*s_etat_processus).at_exit); + liberation(s_etat_processus, (*s_etat_processus).at_poke); for(i = 0; i < d_NOMBRE_INTERRUPTIONS; i++) { @@ -1025,16 +1018,28 @@ lancement_thread(void *argument) liberation_allocateur(s_etat_processus); retrait_thread(s_etat_processus); - pthread_mutex_destroy(&((*s_etat_processus).mutex)); + 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)); + +# ifndef SEMAPHORES_NOMMES + sem_destroy(&((*s_etat_processus).semaphore_fork)); +# else + sem_destroy3((*s_etat_processus).semaphore_fork, getpid(), + pthread_self(), SEM_FORK); +# endif + liberation_contexte_cas(s_etat_processus); free((*s_etat_processus).localisation); free(s_etat_processus); pthread_mutex_lock(&((*s_argument_thread).mutex)); + (*s_argument_thread).thread_actif = d_faux; pthread_mutex_unlock(&((*s_argument_thread).mutex)); - (*s_argument_thread).thread_actif = d_faux; pthread_exit(NULL); + return(NULL); } // vim: ts=4