--- rpl/src/gestion_threads.c 2011/09/03 10:31:50 1.49 +++ rpl/src/gestion_threads.c 2011/09/14 14:34:28 1.50 @@ -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; @@ -75,6 +73,7 @@ lancement_thread(void *argument) s_argument_thread = (struct_descripteur_thread *) argument; s_etat_processus = (*s_argument_thread).s_nouvel_etat_processus; + (*s_etat_processus).tid_courant = pthread_self(); (*s_argument_thread).tid = pthread_self(); (*s_argument_thread).thread_actif = d_vrai; @@ -202,23 +201,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) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - } - else if (sigismember(&set, SIGSTART) == 0) + for((*s_etat_processus).demarrage_fils = d_faux;;) { - 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,13 +232,6 @@ 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 @@ -492,20 +479,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); } } } @@ -555,9 +545,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 *) @@ -598,15 +588,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); } }