--- rpl/src/interruptions.c	2013/04/01 15:29:38	1.124
+++ rpl/src/interruptions.c	2013/05/22 12:05:42	1.128
@@ -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();
 
@@ -153,14 +159,27 @@ thread_surveillance_signaux(void *argume
 				if ((*((struct_thread *) (*l_element_courant).donnee)).pid
 						== getpid())
 				{
-					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)
+					if (pthread_mutex_lock(&mutex_interruptions) != 0)
+					{
+						(*s_etat_processus).erreur_systeme = d_es_processus;
+					}
+					else
 					{
-						nombre_signaux_envoyes++;
-						pthread_kill((*((struct_thread *) (*l_element_courant)
-								.donnee)).tid, SIGALRM);
+						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;
+						}
 					}
 				}
 
@@ -598,8 +617,7 @@ liberation_threads(struct_processus *s_e
 			close((*s_etat_processus).pipe_injections);
 			close((*s_etat_processus).pipe_nombre_injections);
 			close((*s_etat_processus).pipe_interruptions);
-			close((*s_etat_processus).pipe_nombre_objets_attente);
-			close((*s_etat_processus).pipe_nombre_interruptions_attente);
+			close((*s_etat_processus).pipe_nombre_elements_attente);
 
 			liberation(s_etat_processus, (*s_etat_processus).at_exit);
 
@@ -667,10 +685,8 @@ liberation_threads(struct_processus *s_e
 					close((*s_argument_thread).pipe_acquittement[1]);
 					close((*s_argument_thread).pipe_injections[1]);
 					close((*s_argument_thread).pipe_nombre_injections[1]);
-					close((*s_argument_thread).pipe_nombre_objets_attente[0]);
+					close((*s_argument_thread).pipe_nombre_elements_attente[0]);
 					close((*s_argument_thread).pipe_interruptions[0]);
-					close((*s_argument_thread)
-							.pipe_nombre_interruptions_attente[0]);
 
 					if (pthread_mutex_unlock(&((*s_argument_thread)
 							.mutex_nombre_references)) != 0)
@@ -1311,9 +1327,8 @@ liberation_threads(struct_processus *s_e
 			close((*s_argument_thread).pipe_acquittement[1]);
 			close((*s_argument_thread).pipe_injections[1]);
 			close((*s_argument_thread).pipe_nombre_injections[1]);
-			close((*s_argument_thread).pipe_nombre_objets_attente[0]);
+			close((*s_argument_thread).pipe_nombre_elements_attente[0]);
 			close((*s_argument_thread).pipe_interruptions[0]);
-			close((*s_argument_thread).pipe_nombre_interruptions_attente[0]);
 
 			if (pthread_mutex_unlock(&((*s_argument_thread)
 					.mutex_nombre_references)) != 0)
@@ -3321,8 +3336,7 @@ liberation_queue_signaux(struct_processu
 #		endif
 #	else // POSIX
 #		ifndef SEMAPHORES_NOMMES
-			sem_close(&((*s_queue_signaux).semaphore));
-			sem_close(&((*s_queue_signaux).signalisation));
+			// Rien à faire, les sémaphores sont anonymes.
 #		else
 			sem_close(semaphore_queue_signaux);
 			sem_close(semaphore_signalisation);
@@ -3361,7 +3375,11 @@ 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;
 
@@ -3371,6 +3389,14 @@ destruction_queue_signaux(struct_process
 	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
+
 	pthread_join((*s_queue_signaux).thread_signaux, NULL);
 
 #	ifdef IPCS_SYSV // SystemV
@@ -3431,10 +3457,7 @@ destruction_queue_signaux(struct_process
 #		endif
 #	else // POSIX
 #		ifndef SEMAPHORES_NOMMES
-			sem_close(&((*s_queue_signaux).semaphore));
 			sem_destroy(&((*s_queue_signaux).semaphore));
-
-			sem_close(&((*s_queue_signaux).signalisation));
 			sem_destroy(&((*s_queue_signaux).signalisation));
 #		else
 			sem_close(semaphore_queue_signaux);