--- rpl/src/rpl.c	2017/07/12 15:42:43	1.196
+++ rpl/src/rpl.c	2019/02/17 16:08:41	1.211
@@ -1,7 +1,7 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.1.27
-  Copyright (C) 1989-2017 Dr. BERTRAND Joël
+  RPL/2 (R) version 4.1.31
+  Copyright (C) 1989-2019 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
 
@@ -127,7 +127,7 @@ rplinit(int argc, char *argv[], char *en
 	errno = 0;
 	s_queue_signaux = NULL;
 	routine_recursive = 0;
-	nombre_thread_surveillance_processus = 0;
+	nombre_threads_surveillance_processus = 0;
 	pid_processus_pere = getpid();
 
 #	ifdef DEBUG_PROC
@@ -313,6 +313,11 @@ rplinit(int argc, char *argv[], char *en
 	pthread_mutex_init(&mutex_liste_threads, &attributs_mutex);
 	pthread_mutexattr_destroy(&attributs_mutex);
 
+	pthread_mutexattr_init(&attributs_mutex);
+	pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_RECURSIVE);
+	pthread_mutex_init(&mutex_sigaction, &attributs_mutex);
+	pthread_mutexattr_destroy(&attributs_mutex);
+
 #	ifndef SEMAPHORES_NOMMES
 		sem_init(&((*s_etat_processus).semaphore_fork), 0, 0);
 #	else
@@ -449,11 +454,11 @@ rplinit(int argc, char *argv[], char *en
 
 		if ((*s_etat_processus).langue == 'F')
 		{
-			printf("+++Copyright (C) 1989 à 2016, 2017 BERTRAND Joël\n");
+			printf("+++Copyright (C) 1989 à 2018, 2019 BERTRAND Joël\n");
 		}
 		else
 		{
-			printf("+++Copyright (C) 1989 to 2016, 2017 BERTRAND Joel\n");
+			printf("+++Copyright (C) 1989 to 2018, 2019 BERTRAND Joel\n");
 		}
 	}
 
@@ -5433,7 +5438,7 @@ rplinit(int argc, char *argv[], char *en
 								if ((*s_etat_processus).var_volatile_alarme
 										!= 0)
 								{
-									envoi_signal_thread(
+									envoi_signal_thread(s_etat_processus,
 											(*(*((struct_processus_fils *)
 											(*(*((struct_liste_chainee *)
 											l_element_courant)).donnee).objet))
@@ -5444,7 +5449,7 @@ rplinit(int argc, char *argv[], char *en
 									if ((*s_etat_processus).arret_depuis_abort
 											== -1)
 									{
-										envoi_signal_thread(
+										envoi_signal_thread(s_etat_processus,
 												(*(*((struct_processus_fils *)
 												(*(*((struct_liste_chainee *)
 												l_element_courant)).donnee)
@@ -5453,7 +5458,7 @@ rplinit(int argc, char *argv[], char *en
 									}
 									else
 									{
-										envoi_signal_thread(
+										envoi_signal_thread(s_etat_processus,
 												(*(*((struct_processus_fils *)
 												(*(*((struct_liste_chainee *)
 												l_element_courant)).donnee)
@@ -5900,41 +5905,6 @@ rplinit(int argc, char *argv[], char *en
 						l_element_courant = l_element_suivant;
 					}
 
-					for(i = 0; i < (*s_etat_processus)
-							.nombre_instructions_externes; i++)
-					{
-						free((*s_etat_processus).s_instructions_externes[i]
-								.nom);
-						free((*s_etat_processus).s_instructions_externes[i]
-								.nom_bibliotheque);
-					}
-
-					if ((*s_etat_processus).nombre_instructions_externes != 0)
-					{
-						free((*s_etat_processus).s_instructions_externes);
-					}
-
-					l_element_courant = (void *) (*s_etat_processus)
-							.s_bibliotheques;
-					
-					while(l_element_courant != NULL)
-					{
-						l_element_suivant = (*((struct_liste_chainee *)
-								l_element_courant)).suivant;
-
-						free((*((struct_bibliotheque *)
-								(*((struct_liste_chainee *)
-								l_element_courant)).donnee)).nom);
-						dlclose((*((struct_bibliotheque *)
-								(*((struct_liste_chainee *)
-								l_element_courant)).donnee)).descripteur);
-						free((*((struct_liste_chainee *) l_element_courant))
-								.donnee);
-						free(l_element_courant);
-
-						l_element_courant = l_element_suivant;
-					}
-
 					l_element_courant = (void *) (*s_etat_processus)
 							.l_base_pile_last;
 					while(l_element_courant != NULL)
@@ -5950,6 +5920,14 @@ rplinit(int argc, char *argv[], char *en
 						l_element_courant = l_element_suivant;
 					}
 
+					while((*s_etat_processus).s_bibliotheques != NULL)
+					{
+						retrait_bibliotheque(s_etat_processus,
+								(struct_bibliotheque *)
+								(*((struct_liste_chainee *)
+								(*s_etat_processus).s_bibliotheques)).donnee);
+					}
+
 					l_element_courant = (void *) (*s_etat_processus)
 							.l_base_pile_systeme;
 					while(l_element_courant != NULL)
@@ -6137,19 +6115,41 @@ rplinit(int argc, char *argv[], char *en
 	attente.tv_sec = 0;
 	attente.tv_nsec = GRANULARITE_us * 1000;
 
-	while(nombre_thread_surveillance_processus != 0)
+	pthread_mutex_lock(&((*s_etat_processus).mutex_pile_processus));
+
+	while(nombre_threads_surveillance_processus != 0)
+	{
+		pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus));
+		nanosleep(&attente, NULL);
+		INCR_GRANULARITE(attente.tv_nsec);
+		pthread_mutex_lock(&((*s_etat_processus).mutex_pile_processus));
+	}
+
+	pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus));
+
+	attente.tv_sec = 0;
+	attente.tv_nsec = GRANULARITE_us * 1000;
+
+	while(pthread_mutex_trylock(&((*s_etat_processus).mutex_pile_processus))
+			== EBUSY)
 	{
 		nanosleep(&attente, NULL);
 		INCR_GRANULARITE(attente.tv_nsec);
 	}
 
+	pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus));
 	pthread_mutex_destroy(&((*s_etat_processus).mutex_pile_processus));
 	pthread_mutex_destroy(&((*s_etat_processus).mutex_allocation));
 	pthread_mutex_destroy(&((*s_etat_processus).mutex_interruptions));
-	pthread_mutex_destroy(&((*s_etat_processus).mutex_signaux));
 	pthread_mutex_destroy(&mutex_sections_critiques);
 	pthread_mutex_destroy(&mutex_liste_variables_partagees);
 
+	free((*s_etat_processus).localisation);
+
+	destruction_queue_signaux(s_etat_processus);
+	pthread_mutex_destroy(&((*s_etat_processus).mutex_signaux));
+	liberation_contexte_cas(s_etat_processus);
+
 #	ifndef SEMAPHORES_NOMMES
 	sem_post(&((*s_etat_processus).semaphore_fork));
 	sem_destroy(&((*s_etat_processus).semaphore_fork));
@@ -6159,11 +6159,6 @@ rplinit(int argc, char *argv[], char *en
 			SEM_FORK);
 #	endif
 
-	free((*s_etat_processus).localisation);
-
-	destruction_queue_signaux(s_etat_processus);
-	liberation_contexte_cas(s_etat_processus);
-
 	free((*s_etat_processus).chemin_fichiers_temporaires);
 
 	if ((*s_etat_processus).requete_redemarrage == d_vrai)
@@ -6180,6 +6175,8 @@ rplinit(int argc, char *argv[], char *en
 
 	liberation_allocateur_buffer(s_etat_processus);
 	pthread_mutex_destroy(&((*s_etat_processus).mutex_allocation_buffer));
+	pthread_mutex_destroy(&mutex_liste_threads);
+	pthread_mutex_destroy(&mutex_sigaction);
 
 	sys_free(s_etat_processus);
 	sys_free(arg_exec);