--- rpl/src/interruptions.c 2013/05/22 09:25:47 1.127 +++ 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) @@ -161,12 +166,13 @@ thread_surveillance_signaux(void *argume { 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) + (*(*((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); + pthread_kill((*((struct_thread *) + (*l_element_courant).donnee)).tid, SIGALRM); } } @@ -174,6 +180,7 @@ thread_surveillance_signaux(void *argume } pthread_mutex_unlock(&mutex_liste_threads); + pthread_mutex_unlock(&mutex_interruptions); // Nanosleep @@ -2954,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); @@ -2988,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 =