--- rpl/src/interruptions.c	2013/05/22 13:40:12	1.129
+++ rpl/src/interruptions.c	2013/05/23 09:20:08	1.130
@@ -99,11 +99,22 @@ thread_surveillance_signaux(void *argume
 		if (sem_wait(semaphore_signalisation) == 0)
 #		endif
 		{
+#			if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV)
+			if (sem_wait(&(*s_queue_signaux).arret_signalisation) != 0)
+#			else
+			if (sem_wait(semaphore_arret_signalisation) != 0)
+#			endif
+			{
+				(*s_etat_processus).erreur_systeme = d_es_processus;
+			}
+
 			if ((*s_queue_signaux).requete_arret == d_vrai)
 			{
 #				if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV)
+				sem_post(&(*s_queue_signaux).arret_signalisation);
 				sem_post(&(*s_queue_signaux).signalisation);
 #				else
+				sem_post(semaphore_arret_signalisation);
 				sem_post(semaphore_signalisation);
 #				endif
 
@@ -111,8 +122,10 @@ thread_surveillance_signaux(void *argume
 			}
 
 #			if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV)
+			sem_post(&(*s_queue_signaux).arret_signalisation);
 			sem_post(&(*s_queue_signaux).signalisation);
 #			else
+			sem_post(semaphore_arret_signalisation);
 			sem_post(semaphore_signalisation);
 #			endif
 
@@ -3123,6 +3136,7 @@ creation_queue_signaux(struct_processus
 #		ifndef SEMAPHORES_NOMMES
 			sem_init(&((*s_queue_signaux).semaphore), 1, 1);
 			sem_init(&((*s_queue_signaux).signalisation), 1, 0);
+			sem_init(&((*s_queue_signaux).arret_signalisation), 1, 1);
 #		else
 			if ((semaphore_queue_signaux = sem_init2(1, getpid(), SEM_QUEUE))
 					== SEM_FAILED)
@@ -3131,16 +3145,24 @@ creation_queue_signaux(struct_processus
 				return;
 			}
 
-			if ((semaphore_signalisation = sem_init2(1, getpid(),
+			if ((semaphore_signalisation = sem_init2(0, getpid(),
 					SEM_SIGNALISATION)) == SEM_FAILED)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return;
 			}
+
+			if ((semaphore_arret_signalisation = sem_init2(1, getpid(),
+					SEM_ARRET_SIGNALISATION)) == SEM_FAILED)
+			{
+				(*s_etat_processus).erreur_systeme = d_es_processus;
+				return;
+			}
 #		endif
 
 		(*s_queue_signaux).pointeur_lecture = 0;
 		(*s_queue_signaux).pointeur_ecriture = 0;
+
 		(*s_queue_signaux).requete_arret = d_faux;
 
 		if (msync(s_queue_signaux, sizeof(struct_queue_signaux), 0))
@@ -3206,6 +3228,8 @@ creation_queue_signaux(struct_processus
 
 			sem_init(&((*s_queue_signaux).semaphore), 1, 1);
 			sem_init(&((*s_queue_signaux).signalisation), 1, 0);
+			sem_init(&((*s_queue_signaux).arret_signalisation), 1, 1);
+
 			(*s_queue_signaux).pointeur_lecture = 0;
 			(*s_queue_signaux).pointeur_ecriture = 0;
 			(*s_queue_signaux).requete_arret = d_faux;
@@ -3229,6 +3253,8 @@ creation_queue_signaux(struct_processus
 
 			sem_init(&((*s_queue_signaux).semaphore), 1, 1);
 			sem_init(&((*s_queue_signaux).signalisation), 1, 0);
+			sem_init(&((*s_queue_signaux).arret_signalisation), 1, 1);
+
 			(*s_queue_signaux).pointeur_lecture = 0;
 			(*s_queue_signaux).pointeur_ecriture = 0;
 			(*s_queue_signaux).requete_arret = d_faux;
@@ -3307,11 +3333,23 @@ creation_queue_signaux(struct_processus
 void
 liberation_queue_signaux(struct_processus *s_etat_processus)
 {
-	// 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).arret_signalisation));
+#	else
+	sem_wait(semaphore_arret_signalisation);
+#	endif
 
 	(*s_queue_signaux).requete_arret = d_vrai;
 
 #	if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV)
+	sem_post(&((*s_queue_signaux).arret_signalisation));
+#	else
+	sem_post(semaphore_arret_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);
@@ -3334,6 +3372,7 @@ liberation_queue_signaux(struct_processu
 #		else
 			sem_close(semaphore_queue_signaux);
 			sem_close(semaphore_signalisation);
+			sem_close(semaphore_arret_signalisation);
 #		endif
 
 		if (munmap(s_queue_signaux, sizeof(struct_queue_signaux)) != 0)
@@ -3370,17 +3409,17 @@ destruction_queue_signaux(struct_process
 #	endif
 
 #	if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV)
-	sem_wait(&((*s_queue_signaux).signalisation));
+	sem_wait(&((*s_queue_signaux).arret_signalisation));
 #	else
-	sem_wait(semaphore_signalisation);
+	sem_wait(semaphore_arret_signalisation);
 #	endif
 
 	(*s_queue_signaux).requete_arret = d_vrai;
 
 #	if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV)
-	sem_post(&((*s_queue_signaux).signalisation));
+	sem_post(&((*s_queue_signaux).arret_signalisation));
 #	else
-	sem_post(semaphore_signalisation);
+	sem_post(semaphore_arret_signalisation);
 #	endif
 
 	// Incrémenter le sémaphore pour être sûr de le débloquer.
@@ -3415,6 +3454,16 @@ destruction_queue_signaux(struct_process
 			unlink((*s_queue_signaux).signalisation.path);
 			free((*s_queue_signaux).signalisation.path);
 
+			if (semctl((*s_queue_signaux).arret_signalisation.sem, 0, IPC_RMID)
+					== -1)
+			{
+				(*s_etat_processus).erreur_systeme = d_es_processus;
+				return;
+			}
+
+			unlink((*s_queue_signaux).arret_signalisation.path);
+			free((*s_queue_signaux).arret_signalisation.path);
+
 			if (shmdt(s_queue_signaux) == -1)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
@@ -3443,6 +3492,9 @@ destruction_queue_signaux(struct_process
 			sem_close(&((*s_queue_signaux).signalisation));
 			sem_destroy(&((*s_queue_signaux).signalisation));
 
+			sem_close(&((*s_queue_signaux).arret_signalisation));
+			sem_destroy(&((*s_queue_signaux).arret_signalisation));
+
 			if (DosFreeMem(s_queue_signaux) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
@@ -3453,12 +3505,17 @@ destruction_queue_signaux(struct_process
 #		ifndef SEMAPHORES_NOMMES
 			sem_destroy(&((*s_queue_signaux).semaphore));
 			sem_destroy(&((*s_queue_signaux).signalisation));
+			sem_destroy(&((*s_queue_signaux).arret_signalisation));
 #		else
 			sem_close(semaphore_queue_signaux);
 			sem_destroy2(semaphore_queue_signaux, getpid(), SEM_QUEUE);
 
 			sem_close(semaphore_signalisation);
 			sem_destroy2(semaphore_signalisation, getpid(), SEM_SIGNALISATION);
+
+			sem_close(semaphore_arret_signalisation);
+			sem_destroy2(semaphore_arret_signalisation, getpid(),
+					SEM_ARRET_SIGNALISATION);
 #		endif
 
 		if (munmap(s_queue_signaux, sizeof(struct_queue_signaux)) != 0)