--- rpl/src/interruptions.c	2019/02/09 13:36:42	1.201
+++ rpl/src/interruptions.c	2022/09/07 13:40:41	1.208
@@ -1,7 +1,7 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.1.31
-  Copyright (C) 1989-2019 Dr. BERTRAND Joël
+  RPL/2 (R) version 4.1.34
+  Copyright (C) 1989-2021 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
 
@@ -70,7 +70,6 @@ thread_surveillance_signaux(void *argume
 	// nécessaires dans la queue des signaux et incrémentent le sémaphore.
 	// Le sémaphore est décrémenté lorsque le signal est effectivement traité.
 
-	int										ios;
 	int										nombre_signaux_envoyes;
 
 	struct_processus						*s_etat_processus;
@@ -93,7 +92,7 @@ thread_surveillance_signaux(void *argume
 
 		if (sem_wait(semaphore_signalisation) == 0)
 		{
-			while((ios = sem_wait(semaphore_arret_signalisation)) != 0)
+			while(sem_wait(semaphore_arret_signalisation) != 0)
 			{
 				if (errno != EINTR)
 				{
@@ -117,7 +116,7 @@ thread_surveillance_signaux(void *argume
 			// affectée au processus courant pour vérifier s'il y a quelque
 			// chose à traiter.
 
-			while((ios = sem_wait(semaphore_queue_signaux)) != 0)
+			while(sem_wait(semaphore_queue_signaux) != 0)
 			{
 				if (errno != EINTR)
 				{
@@ -298,7 +297,7 @@ insertion_thread_surveillance(struct_pro
 		return;
 	}
 
-	if (pthread_mutex_lock(&mutex_liste_threads) != 0)
+	if (pthread_mutex_lock(&mutex_liste_threads_surveillance) != 0)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_processus;
 		return;
@@ -313,7 +312,7 @@ insertion_thread_surveillance(struct_pro
 
 	liste_threads_surveillance = l_nouvel_objet;
 
-	if (pthread_mutex_unlock(&mutex_liste_threads) != 0)
+	if (pthread_mutex_unlock(&mutex_liste_threads_surveillance) != 0)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_processus;
 		return;
@@ -436,7 +435,7 @@ retrait_thread_surveillance(struct_proce
 	volatile struct_liste_chainee_volatile	*l_element_precedent;
 	volatile struct_liste_chainee_volatile	*l_element_courant;
 
-	if (pthread_mutex_lock(&mutex_liste_threads) != 0)
+	if (pthread_mutex_lock(&mutex_liste_threads_surveillance) != 0)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_processus;
 		return;
@@ -458,7 +457,7 @@ retrait_thread_surveillance(struct_proce
 
 	if (l_element_courant == NULL)
 	{
-		pthread_mutex_unlock(&mutex_liste_threads);
+		pthread_mutex_unlock(&mutex_liste_threads_surveillance);
 		(*s_etat_processus).erreur_systeme = d_es_processus;
 		return;
 	}
@@ -475,7 +474,7 @@ retrait_thread_surveillance(struct_proce
 	if (pthread_mutex_lock(&((*s_argument_thread).mutex_nombre_references))
 			!= 0)
 	{
-		pthread_mutex_unlock(&mutex_liste_threads);
+		pthread_mutex_unlock(&mutex_liste_threads_surveillance);
 		(*s_etat_processus).erreur_systeme = d_es_processus;
 		return;
 	}
@@ -491,7 +490,7 @@ retrait_thread_surveillance(struct_proce
 		if (pthread_mutex_unlock(&((*s_argument_thread)
 				.mutex_nombre_references)) != 0)
 		{
-			pthread_mutex_unlock(&mutex_liste_threads);
+			pthread_mutex_unlock(&mutex_liste_threads_surveillance);
 			(*s_etat_processus).erreur_systeme = d_es_processus;
 			return;
 		}
@@ -505,13 +504,13 @@ retrait_thread_surveillance(struct_proce
 		if (pthread_mutex_unlock(&((*s_argument_thread)
 				.mutex_nombre_references)) != 0)
 		{
-			pthread_mutex_unlock(&mutex_liste_threads);
+			pthread_mutex_unlock(&mutex_liste_threads_surveillance);
 			(*s_etat_processus).erreur_systeme = d_es_processus;
 			return;
 		}
 	}
 
-	if (pthread_mutex_unlock(&mutex_liste_threads) != 0)
+	if (pthread_mutex_unlock(&mutex_liste_threads_surveillance) != 0)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_processus;
 		return;
@@ -1381,6 +1380,18 @@ liberation_threads(struct_processus *s_e
 
 	liste_threads = NULL;
 
+	if (pthread_mutex_unlock(&mutex_liste_threads) == -1)
+	{
+		(*s_etat_processus).erreur_systeme = d_es_processus;
+		return;
+	}
+
+	if (pthread_mutex_lock(&mutex_liste_threads_surveillance) == -1)
+	{
+		(*s_etat_processus).erreur_systeme = d_es_processus;
+		return;
+	}
+
 	l_element_courant = liste_threads_surveillance;
 
 	while(l_element_courant != NULL)
@@ -1392,7 +1403,7 @@ liberation_threads(struct_processus *s_e
 				!= 0)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_processus;
-			pthread_mutex_unlock(&mutex_liste_threads);
+			pthread_mutex_unlock(&mutex_liste_threads_surveillance);
 			return;
 		}
 
@@ -1415,7 +1426,7 @@ liberation_threads(struct_processus *s_e
 					.mutex_nombre_references)) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
-				pthread_mutex_unlock(&mutex_liste_threads);
+				pthread_mutex_unlock(&mutex_liste_threads_surveillance);
 				return;
 			}
 
@@ -1439,7 +1450,7 @@ liberation_threads(struct_processus *s_e
 					.mutex_nombre_references)) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
-				pthread_mutex_unlock(&mutex_liste_threads);
+				pthread_mutex_unlock(&mutex_liste_threads_surveillance);
 				return;
 			}
 		}
@@ -1451,7 +1462,7 @@ liberation_threads(struct_processus *s_e
 
 	liste_threads_surveillance = NULL;
 
-	if (pthread_mutex_unlock(&mutex_liste_threads) != 0)
+	if (pthread_mutex_unlock(&mutex_liste_threads_surveillance) != 0)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_processus;
 		return;
@@ -1559,6 +1570,8 @@ recherche_thread_principal(pid_t pid)
 static inline void
 verrouillage_gestionnaire_signaux(struct_processus *s_etat_processus)
 {
+	return;
+
 #	ifndef SEMAPHORES_NOMMES
 	if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
 #	else
@@ -1575,6 +1588,8 @@ verrouillage_gestionnaire_signaux(struct
 static inline void
 deverrouillage_gestionnaire_signaux(struct_processus *s_etat_processus)
 {
+	return;
+
 #	ifndef SEMAPHORES_NOMMES
 	while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
 #	else
@@ -2575,6 +2590,11 @@ scrutation_interruptions(struct_processu
 			// Il y a un signal en attente dans le segment partagé. On le
 			// traite.
 
+			if (pthread_mutex_lock(&mutex_liste_threads) != 0)
+			{
+				return;
+			}
+
 			envoi_interruptions(s_etat_processus,
 					(*s_queue_signaux).queue[(*s_queue_signaux)
 					.pointeur_lecture].signal, (*s_queue_signaux).queue
@@ -2593,6 +2613,11 @@ scrutation_interruptions(struct_processu
 			}
 #			endif
 
+			if (pthread_mutex_unlock(&mutex_liste_threads) != 0)
+			{
+				return;
+			}
+
 			while(sem_wait(semaphore_signalisation) != 0)
 			{
 				if (errno != EINTR)
@@ -3304,6 +3329,7 @@ envoi_signal_contexte(struct_processus *
 	(*s_etat_processus_a_signaler).pointeur_signal_ecriture =
 			((*s_etat_processus_a_signaler).pointeur_signal_ecriture + 1)
 			% LONGUEUR_QUEUE_SIGNAUX;
+	pthread_kill((*s_etat_processus_a_signaler).tid, SIGUSR2);
 	pthread_mutex_unlock(&((*s_etat_processus_a_signaler).mutex_signaux));
 
 	if (sem_post(semaphore_signalisation) != 0)
@@ -3530,9 +3556,23 @@ creation_queue_signaux(struct_processus
 
 			sys_free(nom);
 
-			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);
+			if (sem_init(&((*s_queue_signaux).semaphore), 1, 1) != 0)
+			{
+				(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
+				return;
+			}
+
+			if (sem_init(&((*s_queue_signaux).signalisation), 1, 0) != 0)
+			{
+				(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
+				return;
+			}
+
+			if (sem_init(&((*s_queue_signaux).arret_signalisation), 1, 1) != 0)
+			{
+				(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
+				return;
+			}
 
 			(*s_queue_signaux).pointeur_lecture = 0;
 			(*s_queue_signaux).pointeur_ecriture = 0;