--- rpl/src/interruptions.c	2011/11/18 09:51:33	1.85
+++ rpl/src/interruptions.c	2012/05/16 14:45:25	1.95
@@ -1,7 +1,7 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.1.4
-  Copyright (C) 1989-2011 Dr. BERTRAND Joël
+  RPL/2 (R) version 4.1.8
+  Copyright (C) 1989-2012 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
 
@@ -64,6 +64,28 @@ unsigned char									*racine_segment;
 static pthread_mutex_t							mutex_interruptions
 		= PTHREAD_MUTEX_INITIALIZER;
 
+void *
+thread_surveillance_signaux(void *argument)
+{
+	// Chaque kill() ou pthread_kill() incrémente le sémaphore. Lorsque le
+	// sémaphore est déverrouillé, on part dans un timeout.
+	// while(sem_wait())
+	// {
+	// 	nanosleep();
+	// 	if (errno == EINTR)
+	// 	{
+	// 		continue;
+	//	}
+	//
+	// 	if (sem_trywait() != 0)
+	// 	{
+	// 	  sem_post()
+	// 	  kill()
+	// 	}
+	// }
+	pthread_exit(NULL);
+}
+
 void
 modification_pid_thread_pere(struct_processus *s_etat_processus)
 {
@@ -1760,8 +1782,6 @@ interruption3(int signal)
 	// l'erreur d'accès à la mémoire. On sort donc du programme quitte à
 	// ce qu'il reste des processus orphelins.
 
-	int					ios;
-
 	unsigned char		message_1[] = "+++System : Uncaught access violation\n"
 								"+++System : Aborting !\n";
 	unsigned char		message_2[] = "+++System : Stack overflow\n"
@@ -1774,14 +1794,13 @@ interruption3(int signal)
 		kill(pid_processus_pere, SIGUSR1);
 	}
 
-
 	if (signal != SIGUSR2)
 	{
-		ios = write(STDERR_FILENO, message_1, strlen(message_1));
+		write(STDERR_FILENO, message_1, strlen(message_1));
 	}
 	else
 	{
-		ios = write(STDERR_FILENO, message_2, strlen(message_2));
+		write(STDERR_FILENO, message_2, strlen(message_2));
 	}
 
 	_exit(EXIT_FAILURE);
@@ -1831,7 +1850,6 @@ interruption_violation_access(void *adre
 								"violation\n";
 
 	static int			compteur_erreur = 0;
-	int					ios;
 
 	if ((gravite == 0) && (routine_recursive != 0))
 	{
@@ -1853,7 +1871,7 @@ interruption_violation_access(void *adre
 		return(0);
 	}
 
-	ios = write(STDERR_FILENO, message, strlen(message));
+	write(STDERR_FILENO, message, strlen(message));
 
 	if (pid_processus_pere == getpid())
 	{
@@ -1938,13 +1956,6 @@ signal_stop(struct_processus *s_etat_pro
 
 	if (pid == getpid())
 	{
-		if ((s_etat_processus = recherche_thread(getpid(), pthread_self()))
-				== NULL)
-		{
-			deverrouillage_gestionnaire_signaux(s_etat_processus);
-			return;
-		}
-
 		if (((*s_etat_processus).type_debug & d_debug_signaux) != 0)
 		{
 			printf("[%d] RPL/SIGSTOP (thread %llu)\n", (int) getpid(),
@@ -2013,8 +2024,6 @@ signal_inject(struct_processus *s_etat_p
 void
 interruption5(int signal)
 {
-	int					ios;
-
 	unsigned char		message[] = "+++System : SIGPIPE\n"
 								"+++System : Aborting !\n";
 
@@ -2025,7 +2034,7 @@ interruption5(int signal)
 		envoi_signal_processus(pid_processus_pere, rpl_sigalrm);
 	}
 
-	ios = write(STDERR_FILENO, message, strlen(message));
+	write(STDERR_FILENO, message, strlen(message));
 	return;
 }
 
@@ -2038,13 +2047,6 @@ signal_urg(struct_processus *s_etat_proc
 
 	if (pid == getpid())
 	{
-		if ((s_etat_processus = recherche_thread(getpid(), pthread_self()))
-				== NULL)
-		{
-			deverrouillage_gestionnaire_signaux(s_etat_processus);
-			return;
-		}
-
 		if (((*s_etat_processus).type_debug & d_debug_signaux) != 0)
 		{
 			printf("[%d] RPL/SIGURG (thread %llu)\n", (int) getpid(),
@@ -2094,13 +2096,6 @@ signal_abort(struct_processus *s_etat_pr
 
 	if (pid == getpid())
 	{
-		if ((s_etat_processus = recherche_thread(getpid(), pthread_self()))
-				== NULL)
-		{
-			deverrouillage_gestionnaire_signaux(s_etat_processus);
-			return;
-		}
-
 		(*s_etat_processus).arret_depuis_abort = -1;
 
 		/*
@@ -2169,11 +2164,11 @@ signal_hup(struct_processus *s_etat_proc
 	{
 		fclose(fichier);
 
-		stdout = freopen(nom, "w", stdout);
-		stderr = freopen(nom, "w", stderr);
+		freopen(nom, "w", stdout);
+		freopen(nom, "w", stderr);
 	}
 
-	stdin = freopen("/dev/null", "r", stdin);
+	freopen("/dev/null", "r", stdin);
 
 	if (((*s_etat_processus).type_debug & d_debug_signaux) != 0)
 	{
@@ -2301,7 +2296,7 @@ scrutation_interruptions(struct_processu
 		if (sem_trywait(semaphore_queue_signaux) == 0)
 #	endif
 	{
-		if ((*s_queue_signaux).pointeur_lecture !=
+		while((*s_queue_signaux).pointeur_lecture !=
 				(*s_queue_signaux).pointeur_ecriture)
 		{
 			// Il y a un signal en attente dans le segment partagé. On le
@@ -2327,7 +2322,7 @@ scrutation_interruptions(struct_processu
 
 	if (pthread_mutex_trylock(&mutex_interruptions) == 0)
 	{
-		if ((*s_etat_processus).pointeur_signal_lecture !=
+		while((*s_etat_processus).pointeur_signal_lecture !=
 				(*s_etat_processus).pointeur_signal_ecriture)
 		{
 			// Il y a un signal dans la queue du thread courant. On le traite.
@@ -2626,6 +2621,8 @@ envoi_signal_processus(pid_t pid, enum s
 #		endif
 	}
 
+	kill(pid, SIGALRM);
+
 	return(0);
 }
 
@@ -2689,6 +2686,8 @@ envoi_signal_thread(pthread_t tid, enum
 		return(1);
 	}
 
+	pthread_kill(tid, SIGALRM);
+
 	return(0);
 }
 
@@ -2705,6 +2704,8 @@ envoi_signal_contexte(struct_processus *
 			% LONGUEUR_QUEUE_SIGNAUX;
 	pthread_mutex_unlock(&mutex_interruptions);
 
+	pthread_kill((*s_etat_processus_a_signaler).tid, SIGALRM);
+
 	return(0);
 }