--- rpl/src/interruptions.c	2012/05/17 17:06:18	1.96
+++ rpl/src/interruptions.c	2012/05/18 09:30:31	1.97
@@ -99,7 +99,14 @@ thread_surveillance_signaux(void *argume
 				break;
 			}
 
+#			ifndef SEMAPHORES_NOMMES
+			sem_post(&(*s_queue_signaux).signalisation);
+#			else
+			sem_post(semaphore_signalisation);
+#			endif
+
 			nombre_signaux_envoyes = 0;
+			sched_yield();
 
 			// Dans un premier temps, on verrouille la queue des signaux
 			// affectée au processus courant pour vérifier s'il y a quelque
@@ -310,6 +317,26 @@ retrait_thread(struct_processus *s_etat_
 		return;
 	}
 
+	// Le thread ne peut plus traiter de signaux explicites. Il convient
+	// alors de corriger le sémaphore pour annuler les signaux en attente.
+
+	while((*(*((struct_thread *) (*l_element_courant).donnee)).s_etat_processus)
+			.pointeur_signal_ecriture != (*(*((struct_thread *)
+			(*l_element_courant).donnee)).s_etat_processus)
+			.pointeur_signal_lecture)
+	{
+#		ifndef SEMAPHORES_NOMMES
+		sem_wait(&((*s_queue_signaux).signalisation));
+#		else
+		sem_wait(semaphore_signalisation);
+#		endif
+
+		(*(*((struct_thread *) (*l_element_courant).donnee)).s_etat_processus)
+				.pointeur_signal_lecture = ((*(*((struct_thread *)
+				(*l_element_courant).donnee)).s_etat_processus)
+				.pointeur_signal_lecture + 1) % LONGUEUR_QUEUE_SIGNAUX;
+	}
+
 	free((void *) (*l_element_courant).donnee);
 	free((struct_liste_chainee_volatile *) l_element_courant);
 
@@ -1674,7 +1701,7 @@ inline static void
 signal_term(struct_processus *s_etat_processus, pid_t pid)
 {
 	struct_processus		*s_thread_principal;
-	volatile sig_atomic_t	exclusion = 0;
+	pthread_mutex_t			exclusion = PTHREAD_MUTEX_INITIALIZER;
 
 	verrouillage_gestionnaire_signaux(s_etat_processus);
 
@@ -1696,20 +1723,19 @@ signal_term(struct_processus *s_etat_pro
 		{
 			(*s_etat_processus).var_volatile_traitement_sigint = -1;
 
-			while(exclusion == 1);
-			exclusion = 1;
+			pthread_mutex_lock(&exclusion);
 
 			if ((*s_etat_processus).var_volatile_requete_arret == -1)
 			{
 				deverrouillage_gestionnaire_signaux(s_etat_processus);
-				exclusion = 0;
+				pthread_mutex_unlock(&exclusion);
 				return;
 			}
 
 			(*s_etat_processus).var_volatile_requete_arret = -1;
 			(*s_etat_processus).var_volatile_alarme = -1;
 
-			exclusion = 0;
+			pthread_mutex_unlock(&exclusion);
 		}
 	}
 	else
@@ -2509,6 +2535,7 @@ envoi_signal_processus(pid_t pid, enum s
 #	ifndef IPCS_SYSV
 #		ifdef SEMAPHORES_NOMMES
 			sem_t					*semaphore;
+			sem_t					*signalisation;
 #		endif
 #	else
 #		ifndef OS2
@@ -2562,6 +2589,15 @@ envoi_signal_processus(pid_t pid, enum s
 		{
 			return(1);
 		}
+
+#		ifndef SEMAPHORES_NOMMES
+			if (sem_post(&((*s_queue_signaux).signalisation)) != 0)
+#		else
+			if (sem_post(semaphore_signalisation) != 0)
+#		endif
+		{
+			return(1);
+		}
 	}
 	else
 	{
@@ -2648,11 +2684,18 @@ envoi_signal_processus(pid_t pid, enum s
 					return(1);
 				}
 
+				if ((signalisation = sem_open2(pid, SEM_SIGNALISATION))
+						== SEM_FAILED)
+				{
+					return(1);
+				}
+
 				while(sem_wait(semaphore) != 0)
 				{
 					if (errno != EINTR)
 					{
 						sem_close(semaphore);
+						sem_close(signalisation);
 						return(1);
 					}
 				}
@@ -2679,10 +2722,16 @@ envoi_signal_processus(pid_t pid, enum s
 				{
 					return(1);
 				}
+
+				if (sem_post(&((*queue).signalisation)) != 0)
+				{
+					return(1);
+				}
 #			else
 				if (sem_post(semaphore) != 0)
 				{
 					sem_close(semaphore);
+					sem_close(signalisation);
 					return(1);
 				}
 
@@ -2690,6 +2739,18 @@ envoi_signal_processus(pid_t pid, enum s
 				{
 					return(1);
 				}
+
+				if (sem_post(signalisation) != 0)
+				{
+					sem_close(signalisation);
+					return(1);
+				}
+
+				if (sem_close(signalisation) != 0)
+				{
+					return(1);
+				}
+
 #			endif
 
 			if (munmap(queue, sizeof(struct_queue_signaux)) != 0)
@@ -2703,6 +2764,11 @@ envoi_signal_processus(pid_t pid, enum s
 				return(1);
 			}
 
+			if (sem_post(&((*queue).signalisation)) != 0)
+			{
+				return(1);
+			}
+
 #			ifndef OS2 // SysV
 				if (shmdt(queue) != 0)
 				{
@@ -2714,8 +2780,6 @@ envoi_signal_processus(pid_t pid, enum s
 #		endif
 	}
 
-	kill(pid, SIGALRM);
-
 	return(0);
 }
 
@@ -2779,7 +2843,17 @@ envoi_signal_thread(pthread_t tid, enum
 		return(1);
 	}
 
-	pthread_kill(tid, SIGALRM);
+#	ifndef SEMAPHORES_NOMMES
+	if (sem_post(&((*s_queue_signaux).signalisation)) != 0)
+	{
+		return(1);
+	}
+#	else
+	if (sem_post(semaphore_signalisation) != 0)
+	{
+		return(1);
+	}
+#	endif
 
 	return(0);
 }
@@ -2797,7 +2871,17 @@ envoi_signal_contexte(struct_processus *
 			% LONGUEUR_QUEUE_SIGNAUX;
 	pthread_mutex_unlock(&mutex_interruptions);
 
-	pthread_kill((*s_etat_processus_a_signaler).tid, SIGALRM);
+#	ifndef SEMAPHORES_NOMMES
+	if (sem_post(&((*s_queue_signaux).signalisation)) != 0)
+	{
+		return(1);
+	}
+#	else
+	if (sem_post(semaphore_signalisation) != 0)
+	{
+		return(1);
+	}
+#	endif
 
 	return(0);
 }