--- rpl/src/interruptions.c 2015/10/23 09:58:50 1.162 +++ rpl/src/interruptions.c 2015/10/26 15:14:19 1.163 @@ -2494,32 +2494,44 @@ scrutation_interruptions(struct_processu // Interruptions qui arrivent depuis le groupe courant de threads. - if (pthread_mutex_trylock(&((*s_etat_processus).mutex_signaux)) == 0) + if (pthread_mutex_trylock(&mutex_liste_threads) == 0) { - while((*s_etat_processus).pointeur_signal_lecture != - (*s_etat_processus).pointeur_signal_ecriture) + if (pthread_mutex_trylock(&((*s_etat_processus).mutex_signaux)) == 0) { - // Il y a un signal dans la queue du thread courant. On le traite. + 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. - envoi_interruptions(s_etat_processus, - (*s_etat_processus).signaux_en_queue - [(*s_etat_processus).pointeur_signal_lecture], - getpid()); - (*s_etat_processus).pointeur_signal_lecture = - ((*s_etat_processus).pointeur_signal_lecture + 1) - % LONGUEUR_QUEUE_SIGNAUX; + envoi_interruptions(s_etat_processus, + (*s_etat_processus).signaux_en_queue + [(*s_etat_processus).pointeur_signal_lecture], + getpid()); + (*s_etat_processus).pointeur_signal_lecture = + ((*s_etat_processus).pointeur_signal_lecture + 1) + % LONGUEUR_QUEUE_SIGNAUX; - while(sem_wait(semaphore_signalisation) != 0) - { - if (errno != EINTR) + while(sem_wait(semaphore_signalisation) != 0) { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; + if (errno != EINTR) + { + if (pthread_mutex_unlock(&mutex_liste_threads) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } } } + + pthread_mutex_unlock(&((*s_etat_processus).mutex_signaux)); } - pthread_mutex_unlock(&((*s_etat_processus).mutex_signaux)); + pthread_mutex_unlock(&mutex_liste_threads); } return;