--- rpl/src/interruptions.c 2011/11/30 12:15:18 1.88 +++ 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. @@ -2599,6 +2621,8 @@ envoi_signal_processus(pid_t pid, enum s # endif } + kill(pid, SIGALRM); + return(0); } @@ -2662,6 +2686,8 @@ envoi_signal_thread(pthread_t tid, enum return(1); } + pthread_kill(tid, SIGALRM); + return(0); } @@ -2678,6 +2704,8 @@ envoi_signal_contexte(struct_processus * % LONGUEUR_QUEUE_SIGNAUX; pthread_mutex_unlock(&mutex_interruptions); + pthread_kill((*s_etat_processus_a_signaler).tid, SIGALRM); + return(0); }