--- rpl/src/interruptions.c	2015/02/19 11:01:28	1.157
+++ rpl/src/interruptions.c	2016/03/09 17:49:12	1.166
@@ -1,7 +1,7 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.1.21
-  Copyright (C) 1989-2015 Dr. BERTRAND Joël
+  RPL/2 (R) version 4.1.25
+  Copyright (C) 1989-2016 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
 
@@ -109,7 +109,6 @@ thread_surveillance_signaux(void *argume
 			sem_post(semaphore_signalisation);
 
 			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
@@ -128,6 +127,7 @@ thread_surveillance_signaux(void *argume
 
 				nombre_signaux_envoyes++;
 				kill(getpid(), SIGALRM);
+				sched_yield();
 			}
 
 			sem_post(semaphore_queue_signaux);
@@ -160,6 +160,7 @@ thread_surveillance_signaux(void *argume
 						nombre_signaux_envoyes++;
 						pthread_kill((*((struct_thread *)
 								(*l_element_courant).donnee)).tid, SIGALRM);
+						sched_yield();
 					}
 
 					pthread_mutex_unlock(&((*(*((struct_thread *)
@@ -766,13 +767,14 @@ liberation_threads(struct_processus *s_e
 				}
 			}
 
-			// ne peut être effacé qu'une seule fois
+			// Ne peut être effacé qu'une seule fois
 			if (suppression_variables_partagees == d_faux)
 			{
 				suppression_variables_partagees = d_vrai;
 
 				liberation_arbre_variables_partagees(s_etat_processus,
 						(*(*s_etat_processus).s_arbre_variables_partagees));
+				(*(*s_etat_processus).s_arbre_variables_partagees) = NULL;
 
 				l_element_partage_courant = (*(*s_etat_processus)
 						.l_liste_variables_partagees);
@@ -784,6 +786,8 @@ liberation_threads(struct_processus *s_e
 					free(l_element_partage_courant);
 					l_element_partage_courant = l_element_partage_suivant;
 				}
+
+				(*(*s_etat_processus).l_liste_variables_partagees) = NULL;
 			}
 
 			liberation_arbre_variables(s_etat_processus,
@@ -2491,32 +2495,44 @@ scrutation_interruptions(struct_processu
 
 	// Interruptions qui arrivent depuis le groupe courant de threads.
 
-	if (pthread_mutex_trylock(&((*s_etat_processus).mutex_signaux)) == 0)
+	if (pthread_mutex_trylock(&mutex_liste_threads) == 0)
 	{
-		while((*s_etat_processus).pointeur_signal_lecture !=
-				(*s_etat_processus).pointeur_signal_ecriture)
+		if (pthread_mutex_trylock(&((*s_etat_processus).mutex_signaux)) == 0)
 		{
-			// Il y a un signal dans la queue du thread courant. On le traite.
+			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.
 
-			envoi_interruptions(s_etat_processus,
-					(*s_etat_processus).signaux_en_queue
-					[(*s_etat_processus).pointeur_signal_lecture],
-					getpid());
-			(*s_etat_processus).pointeur_signal_lecture =
-					((*s_etat_processus).pointeur_signal_lecture + 1)
-					% LONGUEUR_QUEUE_SIGNAUX;
+				envoi_interruptions(s_etat_processus,
+						(*s_etat_processus).signaux_en_queue
+						[(*s_etat_processus).pointeur_signal_lecture],
+						getpid());
+				(*s_etat_processus).pointeur_signal_lecture =
+						((*s_etat_processus).pointeur_signal_lecture + 1)
+						% LONGUEUR_QUEUE_SIGNAUX;
 
-			while(sem_wait(semaphore_signalisation) != 0)
-			{
-				if (errno != EINTR)
+				while(sem_wait(semaphore_signalisation) != 0)
 				{
-					(*s_etat_processus).erreur_systeme = d_es_processus;
-					return;
+					if (errno != EINTR)
+					{
+						if (pthread_mutex_unlock(&mutex_liste_threads) != 0)
+						{
+							(*s_etat_processus).erreur_systeme = d_es_processus;
+							return;
+						}
+
+						(*s_etat_processus).erreur_systeme = d_es_processus;
+						return;
+					}
 				}
 			}
+
+			pthread_mutex_unlock(&((*s_etat_processus).mutex_signaux));
 		}
 
-		pthread_mutex_unlock(&((*s_etat_processus).mutex_signaux));
+		pthread_mutex_unlock(&mutex_liste_threads);
 	}
 
 	return;
@@ -2643,6 +2659,7 @@ envoi_signal_processus(pid_t pid, enum s
 		if (msync(s_queue_signaux, sizeof(s_queue_signaux),
 				MS_ASYNC | MS_INVALIDATE) != 0)
 		{
+			sem_post(semaphore_queue_signaux);
 			return(1);
 		}
 #		endif
@@ -2987,7 +3004,8 @@ creation_queue_signaux(struct_processus
 
 		(*s_queue_signaux).requete_arret = d_faux;
 
-		if (msync(s_queue_signaux, sizeof(struct_queue_signaux), MS_SYNC))
+		if (msync(s_queue_signaux, sizeof(struct_queue_signaux),
+				MS_ASYNC | MS_INVALIDATE) != 0)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_processus;
 			return;
@@ -3152,6 +3170,17 @@ creation_queue_signaux(struct_processus
 		return;
 	}
 
+	(*s_queue_signaux).controle = getpid();
+
+#	ifndef IPCS_SYSV
+	if (msync(s_queue_signaux, sizeof(s_queue_signaux),
+			MS_ASYNC | MS_INVALIDATE) != 0)
+	{
+		(*s_etat_processus).erreur_systeme = d_es_processus;
+		return;
+	}
+#			endif
+
 	return;
 }
 
@@ -3184,7 +3213,11 @@ liberation_queue_signaux(struct_processu
 	// Incrémenter le sémaphore pour être sûr de le débloquer.
 
 	sem_post(semaphore_signalisation);
-	pthread_join((*s_queue_signaux).thread_signaux, NULL);
+
+	if (getpid() == (*s_queue_signaux).controle)
+	{
+		pthread_join((*s_queue_signaux).thread_signaux, NULL);
+	}
 
 #	ifdef IPCS_SYSV // SystemV
 #		ifndef OS2