--- rpl/src/interruptions.c 2011/12/16 13:46:56 1.89 +++ rpl/src/interruptions.c 2012/05/16 14:45:25 1.95 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.1.5 - Copyright (C) 1989-2011 Dr. BERTRAND Joël + RPL/2 (R) version 4.1.8 + Copyright (C) 1989-2012 Dr. BERTRAND Joël This file is part of RPL/2. @@ -64,6 +64,28 @@ unsigned char *racine_segment; static pthread_mutex_t mutex_interruptions = PTHREAD_MUTEX_INITIALIZER; +void * +thread_surveillance_signaux(void *argument) +{ + // Chaque kill() ou pthread_kill() incrémente le sémaphore. Lorsque le + // sémaphore est déverrouillé, on part dans un timeout. + // while(sem_wait()) + // { + // nanosleep(); + // if (errno == EINTR) + // { + // continue; + // } + // + // if (sem_trywait() != 0) + // { + // sem_post() + // kill() + // } + // } + pthread_exit(NULL); +} + void modification_pid_thread_pere(struct_processus *s_etat_processus) { @@ -2274,7 +2296,7 @@ scrutation_interruptions(struct_processu if (sem_trywait(semaphore_queue_signaux) == 0) # endif { - if ((*s_queue_signaux).pointeur_lecture != + while((*s_queue_signaux).pointeur_lecture != (*s_queue_signaux).pointeur_ecriture) { // Il y a un signal en attente dans le segment partagé. On le @@ -2300,7 +2322,7 @@ scrutation_interruptions(struct_processu if (pthread_mutex_trylock(&mutex_interruptions) == 0) { - if ((*s_etat_processus).pointeur_signal_lecture != + while((*s_etat_processus).pointeur_signal_lecture != (*s_etat_processus).pointeur_signal_ecriture) { // Il y a un signal dans la queue du thread courant. On le traite.