--- rpl/src/instructions_d5.c	2017/08/03 17:03:39	1.160
+++ rpl/src/instructions_d5.c	2023/11/22 10:55:15	1.178
@@ -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.35
+  Copyright (C) 1989-2023 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
 
@@ -1306,6 +1306,16 @@ instruction_detach(struct_processus *s_e
 		pthread_mutexattr_destroy(&attributs_mutex);
 
 		pthread_mutexattr_init(&attributs_mutex);
+		pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_RECURSIVE);
+		pthread_mutex_init(&mutex_liste_threads_surveillance, &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);
+
+		pthread_mutexattr_init(&attributs_mutex);
 		pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL);
 		pthread_mutex_init(&((*s_etat_processus).mutex_pile_processus),
 				&attributs_mutex);
@@ -1321,7 +1331,7 @@ instruction_detach(struct_processus *s_e
 		creation_queue_signaux(s_etat_processus);
 
 		routine_recursive = 0;
-		nombre_thread_surveillance_processus = 0;
+		nombre_threads_surveillance_processus = 0;
 
 		(*s_etat_processus).pointeur_signal_lecture = 0;
 		(*s_etat_processus).pointeur_signal_ecriture = 0;
@@ -1333,7 +1343,6 @@ instruction_detach(struct_processus *s_e
 			(*s_etat_processus).erreur_systeme = d_es_processus;
 		}
 
-		close(pipe_initialisation_segment_signaux[0]);
 		close(pipe_initialisation_segment_signaux[1]);
 
 		if ((*s_etat_processus).debug == d_vrai)
@@ -1813,6 +1822,10 @@ instruction_detach(struct_processus *s_e
 		{
 			l_element_suivant = (*l_element_courant).suivant;
 
+			// On ne détruit pas le descripteur sous prétexte
+			// d'avoir le fichier ou la socket fermée dans le processus père
+
+			/*
 			fclose((*((struct_descripteur_fichier *)
 					(*l_element_courant).donnee)).descripteur_c);
 
@@ -1822,6 +1835,7 @@ instruction_detach(struct_processus *s_e
 				sqlite3_close((*((struct_descripteur_fichier *)
 						(*l_element_courant).donnee)).descripteur_sqlite);
 			}
+			*/
 
 			free((*((struct_descripteur_fichier *) (*l_element_courant)
 					.donnee)).nom);
@@ -2243,7 +2257,8 @@ instruction_detach(struct_processus *s_e
 				{
 					if ((*s_etat_processus).var_volatile_alarme != 0)
 					{
-						envoi_signal_thread((*(*((struct_processus_fils *)
+						envoi_signal_thread(s_etat_processus,
+								(*(*((struct_processus_fils *)
 								(*(*l_element_courant).donnee).objet)).thread)
 								.tid, rpl_sigurg);
 					}
@@ -2251,13 +2266,15 @@ instruction_detach(struct_processus *s_e
 					{
 						if ((*s_etat_processus).arret_depuis_abort == -1)
 						{
-							envoi_signal_thread((*(*((struct_processus_fils *)
+							envoi_signal_thread(s_etat_processus,
+									(*(*((struct_processus_fils *)
 									(*(*l_element_courant).donnee).objet))
 									.thread).tid, rpl_sigabort);
 						}
 						else
 						{
-							envoi_signal_thread((*(*((struct_processus_fils *)
+							envoi_signal_thread(s_etat_processus,
+									(*(*((struct_processus_fils *)
 									(*(*l_element_courant).donnee).objet))
 									.thread).tid, rpl_sigstop);
 						}
@@ -2303,13 +2320,21 @@ instruction_detach(struct_processus *s_e
 					(*(*((struct_processus_fils *) (*(*l_element_courant)
 							.donnee).objet)).thread).nombre_objets_dans_pipe--;
 
+					if (pthread_mutex_lock(&mutex_sigaction) != 0)
+					{
+						destruction_queue_signaux(s_etat_processus);
+						(*s_etat_processus).erreur_systeme = d_es_processus;
+						exit(EXIT_FAILURE);
+					}
+
 					action.sa_handler = SIG_IGN;
-					action.sa_flags = SA_ONSTACK;
+					action.sa_flags = 0;
 
 					if (sigaction(SIGPIPE, &action, &registre) != 0)
 					{
 						pthread_mutex_unlock(&((*s_etat_processus)
 								.mutex_pile_processus));
+						pthread_mutex_unlock(&mutex_sigaction);
 
 						if (registre_stop == 0)
 						{
@@ -2363,11 +2388,21 @@ instruction_detach(struct_processus *s_e
 					{
 						destruction_queue_signaux(s_etat_processus);
 
+						pthread_mutex_unlock(&mutex_sigaction);
 						pthread_mutex_unlock(&((*s_etat_processus)
 								.mutex_pile_processus));
 						(*s_etat_processus).erreur_systeme = d_es_signal;
 						exit(EXIT_FAILURE);
 					}
+
+					if (pthread_mutex_unlock(&mutex_sigaction) != 0)
+					{
+						destruction_queue_signaux(s_etat_processus);
+						pthread_mutex_unlock(&((*s_etat_processus)
+								.mutex_pile_processus));
+						(*s_etat_processus).erreur_systeme = d_es_processus;
+						exit(EXIT_FAILURE);
+					}
 				}
 			}
 
@@ -2413,21 +2448,21 @@ instruction_detach(struct_processus *s_e
 		{
 			l_element_suivant = (*l_element_courant).suivant;
 
-			if ((*((struct_socket *) (*(*l_element_courant).donnee)
-					.objet)).socket_connectee == d_vrai)
-			{
-				shutdown((*((struct_socket *) (*(*l_element_courant).donnee)
-						.objet)).socket, SHUT_RDWR);
-			}
-
-			close((*((struct_socket *) (*(*l_element_courant).donnee)
-					.objet)).socket);
-
 			if (((*((struct_socket *) (*(*l_element_courant).donnee).objet))
 					.pid == getpid()) && (pthread_equal((*((struct_socket *)
 					(*(*l_element_courant).donnee).objet)).tid, pthread_self())
 					!= 0))
 			{
+				if ((*((struct_socket *) (*(*l_element_courant).donnee)
+						.objet)).socket_connectee == d_vrai)
+				{
+					shutdown((*((struct_socket *) (*(*l_element_courant).donnee)
+							.objet)).socket, SHUT_RDWR);
+				}
+
+				close((*((struct_socket *) (*(*l_element_courant).donnee)
+						.objet)).socket);
+
 				if ((*((struct_socket *) (*(*l_element_courant).donnee).objet))
 						.effacement == 'Y')
 				{
@@ -2724,12 +2759,18 @@ instruction_detach(struct_processus *s_e
 		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));
+
 		closelog();
 
 		retrait_thread(s_etat_processus);
@@ -2780,6 +2821,7 @@ instruction_detach(struct_processus *s_e
 
 		destruction_queue_signaux(s_etat_processus);
 		pthread_mutex_destroy(&mutex_liste_threads);
+		pthread_mutex_destroy(&mutex_liste_threads_surveillance);
 
 #		ifndef SEMAPHORES_NOMMES
 		sem_post(&((*s_etat_processus).semaphore_fork));
@@ -2797,10 +2839,12 @@ instruction_detach(struct_processus *s_e
 		analyse_post_mortem();
 #		endif
 
+		pthread_mutex_destroy(&mutex_sigaction);
 		exit(EXIT_SUCCESS);
 	}
 	else
 	{
+		deverrouillage_threads_concurrents(s_etat_processus);
 		(*s_etat_processus).erreur_systeme = d_es_processus;
 		return;
 	}
@@ -2886,7 +2930,6 @@ instruction_detach(struct_processus *s_e
 	}
 
 	close(pipe_initialisation_segment_signaux[0]);
-	close(pipe_initialisation_segment_signaux[1]);
 
 	// Le fils peut être présent sans être en attente du signal de départ.