--- rpl/src/gestion_threads.c 2010/04/28 09:38:27 1.13 +++ rpl/src/gestion_threads.c 2010/06/19 15:54:51 1.21 @@ -1,6 +1,6 @@ /* ================================================================================ - RPL/2 (R) version 4.0.15 + RPL/2 (R) version 4.0.16 Copyright (C) 1989-2010 Dr. BERTRAND Joël This file is part of RPL/2. @@ -74,9 +74,9 @@ lancement_thread(void *argument) attente.tv_nsec = GRANULARITE_us * 1000; s_argument_thread = (struct_descripteur_thread *) argument; + s_etat_processus = (*s_argument_thread).s_nouvel_etat_processus; (*s_argument_thread).tid = pthread_self(); (*s_argument_thread).thread_actif = d_vrai; - s_etat_processus = (*s_argument_thread).s_nouvel_etat_processus; # ifndef SEMAPHORES_NOMMES if (pthread_setspecific(semaphore_fork_processus_courant, @@ -263,10 +263,11 @@ lancement_thread(void *argument) } 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; - (*s_etat_processus).var_volatile_traitement_retarde_stop = -1; if (evaluation(s_etat_processus, (*s_etat_processus).at_exit, 'E') == d_erreur) @@ -491,8 +492,16 @@ lancement_thread(void *argument) } else { - kill((*(*((struct_processus_fils *) (*(*l_element_courant) - .donnee).objet)).thread).pid, SIGFSTOP); + if ((*s_etat_processus).arret_depuis_abort == -1) + { + kill((*(*((struct_processus_fils *) (*(*l_element_courant) + .donnee).objet)).thread).pid, SIGFABORT); + } + else + { + kill((*(*((struct_processus_fils *) (*(*l_element_courant) + .donnee).objet)).thread).pid, SIGFSTOP); + } } } else @@ -582,9 +591,18 @@ 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) + { + pthread_kill((*(*((struct_processus_fils *) + (*(*l_element_courant).donnee).objet)).thread) + .tid, SIGFABORT); + } + else + { + pthread_kill((*(*((struct_processus_fils *) + (*(*l_element_courant).donnee).objet)).thread) + .tid, SIGFSTOP); + } } if (pthread_mutex_unlock(&((*(*((struct_processus_fils *) @@ -624,11 +642,6 @@ 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; @@ -721,6 +734,12 @@ lancement_thread(void *argument) } pthread_mutex_unlock(&((*s_etat_processus).mutex)); + + if ((*s_etat_processus).nombre_interruptions_non_affectees != 0) + { + affectation_interruptions_logicielles(s_etat_processus); + } + nanosleep(&attente, NULL); pthread_mutex_lock(&((*s_etat_processus).mutex)); } @@ -1058,6 +1077,7 @@ lancement_thread(void *argument) retrait_thread(s_etat_processus); pthread_mutex_destroy(&((*s_etat_processus).mutex)); + pthread_mutex_destroy(&((*s_etat_processus).mutex_allocation)); free((*s_etat_processus).localisation); free(s_etat_processus);