--- rpl/src/interruptions.c	2013/05/21 13:30:56	1.126
+++ rpl/src/interruptions.c	2013/05/22 13:40:12	1.129
@@ -99,17 +99,23 @@ thread_surveillance_signaux(void *argume
 		if (sem_wait(semaphore_signalisation) == 0)
 #		endif
 		{
+			if ((*s_queue_signaux).requete_arret == d_vrai)
+			{
+#				if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV)
+				sem_post(&(*s_queue_signaux).signalisation);
+#				else
+				sem_post(semaphore_signalisation);
+#				endif
+
+				break;
+			}
+
 #			if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV)
 			sem_post(&(*s_queue_signaux).signalisation);
 #			else
 			sem_post(semaphore_signalisation);
 #			endif
 
-			if ((*s_queue_signaux).requete_arret == d_vrai)
-			{
-				break;
-			}
-
 			nombre_signaux_envoyes = 0;
 			sched_yield();
 
@@ -145,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)
@@ -155,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);
 					}
 				}
 
@@ -168,6 +180,7 @@ thread_surveillance_signaux(void *argume
 			}
 
 			pthread_mutex_unlock(&mutex_liste_threads);
+			pthread_mutex_unlock(&mutex_interruptions);
 
 			// Nanosleep
 
@@ -2948,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);
@@ -2982,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 =
@@ -3356,12 +3369,24 @@ destruction_queue_signaux(struct_process
 		unsigned char		*nom;
 #	endif
 
-	// Incrémenter le sémaphore pour être sûr de le débloquer.
+#	if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV)
+	sem_wait(&((*s_queue_signaux).signalisation));
+#	else
+	sem_wait(semaphore_signalisation);
+#	endif
 
 	(*s_queue_signaux).requete_arret = d_vrai;
 
 #	if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV)
 	sem_post(&((*s_queue_signaux).signalisation));
+#	else
+	sem_post(semaphore_signalisation);
+#	endif
+
+	// Incrémenter le sémaphore pour être sûr de le débloquer.
+
+#	if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV)
+	sem_post(&((*s_queue_signaux).signalisation));
 #	else
 	sem_post(semaphore_signalisation);
 #	endif