--- rpl/src/gestion_threads.c 2010/08/06 15:26:45 1.26 +++ rpl/src/gestion_threads.c 2011/09/20 15:45:53 1.54 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.0.18 - Copyright (C) 1989-2010 Dr. BERTRAND Joël + RPL/2 (R) version 4.1.3 + Copyright (C) 1989-2011 Dr. BERTRAND Joël This file is part of RPL/2. @@ -46,8 +46,6 @@ lancement_thread(void *argument) sig_atomic_t registre_stop; - sigset_t set; - ssize_t longueur_ecriture; struct_descripteur_thread *s_argument_thread; @@ -78,82 +76,6 @@ lancement_thread(void *argument) (*s_argument_thread).tid = pthread_self(); (*s_argument_thread).thread_actif = d_vrai; -# ifndef SEMAPHORES_NOMMES - if (pthread_setspecific(semaphore_fork_processus_courant, - &((*s_etat_processus).semaphore_fork)) != 0) -# else - if (pthread_setspecific(semaphore_fork_processus_courant, - (*s_etat_processus).semaphore_fork) != 0) -# endif - { - (*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)) - { - if (longueur_ecriture == -1) - { - break; - } - } - - pthread_exit(NULL); - } - - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - - 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; - } - } - - pthread_exit(NULL); - } - insertion_thread(s_etat_processus, d_faux); // Envoi d'une donnée pour signaler le démarrage du thread au thread @@ -163,7 +85,6 @@ lancement_thread(void *argument) (*s_argument_thread).pipe_nombre_objets_attente[1], "-", sizeof(unsigned char)) != sizeof(unsigned char)) { - pthread_mutex_unlock(&((*s_etat_processus).mutex)); (*s_etat_processus).erreur_systeme = d_es_processus; pthread_mutex_lock(&((*s_argument_thread).mutex)); @@ -202,23 +123,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) @@ -238,46 +154,43 @@ 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).var_volatile_alarme == 0) - && ((*s_etat_processus).arret_depuis_abort == 0) - && ((*s_etat_processus).at_exit != NULL)) + else { - (*s_etat_processus).var_volatile_requete_arret = 0; - (*s_etat_processus).var_volatile_traitement_retarde_stop = -1; + 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; + (*s_etat_processus).var_volatile_traitement_retarde_stop = + -1; - 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)) + if (evaluation(s_etat_processus, + (*s_etat_processus).at_exit, '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; + } } } } @@ -488,20 +401,23 @@ 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 { if ((*s_etat_processus).arret_depuis_abort == -1) { - kill((*(*((struct_processus_fils *) (*(*l_element_courant) - .donnee).objet)).thread).pid, SIGFABORT); + envoi_signal_processus((*(*((struct_processus_fils *) + (*(*l_element_courant) + .donnee).objet)).thread).pid, rpl_sigabort); } else { - kill((*(*((struct_processus_fils *) (*(*l_element_courant) - .donnee).objet)).thread).pid, SIGFSTOP); + envoi_signal_processus((*(*((struct_processus_fils *) + (*(*l_element_courant) + .donnee).objet)).thread).pid, rpl_sigstop); } } } @@ -551,9 +467,9 @@ 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 *) @@ -594,15 +510,15 @@ lancement_thread(void *argument) { if ((*s_etat_processus).arret_depuis_abort == -1) { - pthread_kill((*(*((struct_processus_fils *) + envoi_signal_thread((*(*((struct_processus_fils *) (*(*l_element_courant).donnee).objet)).thread) - .tid, SIGFABORT); + .tid, rpl_sigabort); } else { - pthread_kill((*(*((struct_processus_fils *) + envoi_signal_thread((*(*((struct_processus_fils *) (*(*l_element_courant).donnee).objet)).thread) - .tid, SIGFSTOP); + .tid, rpl_sigstop); } } @@ -882,21 +798,8 @@ 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. - - 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); + liberation_arbre_variables(s_etat_processus, + (*s_etat_processus).s_arbre_variables, d_faux); for(i = 0; i < (*s_etat_processus).nombre_variables_statiques; i++) { @@ -1081,6 +984,13 @@ lancement_thread(void *argument) pthread_mutex_destroy(&((*s_etat_processus).mutex)); pthread_mutex_destroy(&((*s_etat_processus).mutex_allocation)); +# ifndef SEMAPHORES_NOMMES + sem_destroy(&((*s_etat_processus).semaphore_fork)); +# else + sem_destroy2((*s_etat_processus).semaphore_fork, getpid(), SEM_FORK); +# endif + + liberation_contexte_cas(s_etat_processus); free((*s_etat_processus).localisation); free(s_etat_processus);