--- rpl/src/interruptions.c 2013/05/22 12:05:42 1.128 +++ rpl/src/interruptions.c 2013/05/22 13:40:12 1.129 @@ -151,7 +151,12 @@ thread_surveillance_signaux(void *argume // Dans un second temps, on balaye toutes les queues de signaux // des threads du processus courant. + // Attention : l'ordre de verrouillage des mutexes est important + // pour éviter les conditions bloquantes ! + + pthread_mutex_lock(&mutex_interruptions); pthread_mutex_lock(&mutex_liste_threads); + l_element_courant = liste_threads; while(l_element_courant != NULL) @@ -159,27 +164,15 @@ thread_surveillance_signaux(void *argume if ((*((struct_thread *) (*l_element_courant).donnee)).pid == getpid()) { - if (pthread_mutex_lock(&mutex_interruptions) != 0) + if ((*(*((struct_thread *) (*l_element_courant).donnee)) + .s_etat_processus).pointeur_signal_ecriture != + (*(*((struct_thread *) (*l_element_courant) + .donnee)).s_etat_processus) + .pointeur_signal_lecture) { - (*s_etat_processus).erreur_systeme = d_es_processus; - } - else - { - if ((*(*((struct_thread *) (*l_element_courant).donnee)) - .s_etat_processus).pointeur_signal_ecriture != - (*(*((struct_thread *) (*l_element_courant) - .donnee)).s_etat_processus) - .pointeur_signal_lecture) - { - nombre_signaux_envoyes++; - pthread_kill((*((struct_thread *) - (*l_element_courant).donnee)).tid, SIGALRM); - } - - if (pthread_mutex_unlock(&mutex_interruptions) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - } + nombre_signaux_envoyes++; + pthread_kill((*((struct_thread *) + (*l_element_courant).donnee)).tid, SIGALRM); } } @@ -187,6 +180,7 @@ thread_surveillance_signaux(void *argume } pthread_mutex_unlock(&mutex_liste_threads); + pthread_mutex_unlock(&mutex_interruptions); // Nanosleep @@ -2967,12 +2961,6 @@ envoi_signal_thread(pthread_t tid, enum struct_processus *s_etat_processus; - if (pthread_mutex_lock(&mutex_interruptions) != 0) - { - pthread_mutex_unlock(&mutex_liste_threads); - return(1); - } - if (pthread_mutex_lock(&mutex_liste_threads) != 0) { return(1); @@ -3001,6 +2989,12 @@ envoi_signal_thread(pthread_t tid, enum s_etat_processus = (*((struct_thread *) (*l_element_courant).donnee)) .s_etat_processus; + if (pthread_mutex_lock(&mutex_interruptions) != 0) + { + pthread_mutex_unlock(&mutex_liste_threads); + return(1); + } + (*s_etat_processus).signaux_en_queue [(*s_etat_processus).pointeur_signal_ecriture] = signal; (*s_etat_processus).pointeur_signal_ecriture =