--- rpl/src/instructions_d5.c	2016/04/06 21:14:56	1.151
+++ rpl/src/instructions_d5.c	2017/08/03 15:13:04	1.159
@@ -1,7 +1,7 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.1.25
-  Copyright (C) 1989-2016 Dr. BERTRAND Joël
+  RPL/2 (R) version 4.1.27
+  Copyright (C) 1989-2017 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
 
@@ -1088,14 +1088,14 @@ instruction_detach(struct_processus *s_e
 		return;
 	}
 
+	verrouillage_threads_concurrents(s_etat_processus);
+
 	if (pthread_mutex_lock(&mutex_liste_variables_partagees) != 0)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_processus;
 		return;
 	}
 
-	verrouillage_threads_concurrents(s_etat_processus);
-
 	if (pthread_mutex_lock(&((*s_etat_processus).mutex_allocation_buffer)) != 0)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_processus;
@@ -1289,9 +1289,12 @@ instruction_detach(struct_processus *s_e
 		 */
 
 		// EPERM
+#if 0
 		pthread_mutex_destroy(&mutex_liste_variables_partagees);
 		pthread_mutex_destroy(&mutex_liste_threads);
-
+		pthread_mutex_destroy(&((*s_etat_processus).mutex_pile_processus);
+		pthread_mutex_destroy(&((*s_etat_processus).mutex_allocation));
+#endif
 		pthread_mutexattr_init(&attributs_mutex);
 		pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_RECURSIVE);
 		pthread_mutex_init(&mutex_liste_variables_partagees, &attributs_mutex);
@@ -1302,6 +1305,18 @@ instruction_detach(struct_processus *s_e
 		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_NORMAL);
+		pthread_mutex_init(&((*s_etat_processus).mutex_pile_processus),
+				&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_allocation),
+				&attributs_mutex);
+		pthread_mutexattr_destroy(&attributs_mutex);
+
 		liberation_queue_signaux(s_etat_processus);
 		creation_queue_signaux(s_etat_processus);
 
@@ -1409,7 +1424,6 @@ instruction_detach(struct_processus *s_e
 				(*s_argument_thread).pipe_nombre_elements_attente[1],
 				&caractere, sizeof(caractere)) != sizeof(caractere))
 		{
-			pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus));
 			(*s_etat_processus).erreur_systeme = d_es_processus;
 
 			while((longueur_ecriture = write_atomic(s_etat_processus,
@@ -1451,100 +1465,6 @@ instruction_detach(struct_processus *s_e
 		pthread_mutex_init(&mutex_sections_critiques, &attributs_mutex);
 		pthread_mutexattr_destroy(&attributs_mutex);
 
-		if (pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus))
-				!= 0)
-		{
-			(*s_etat_processus).erreur_systeme = d_es_processus;
-
-			caractere = 0;
-
-			while((longueur_ecriture = write_atomic(s_etat_processus,
-					(*s_argument_thread).pipe_nombre_elements_attente[1],
-					&caractere, sizeof(caractere))) != sizeof(caractere))
-			{
-				if (longueur_ecriture == -1)
-				{
-					break;
-				}
-			}
-
-			destruction_queue_signaux(s_etat_processus);
-			BUG(1, uprintf("Process management error line %d\n", __LINE__));
-			exit(EXIT_FAILURE);
-		}
-
-		pthread_mutex_trylock(&((*s_etat_processus).protection_liste_mutexes));
-
-		if (pthread_mutex_unlock(&((*s_etat_processus)
-				.protection_liste_mutexes)) != 0)
-		{
-			(*s_etat_processus).erreur_systeme = d_es_processus;
-
-			caractere = 0;
-
-			while((longueur_ecriture = write_atomic(s_etat_processus,
-					(*s_argument_thread).pipe_nombre_elements_attente[1],
-					&caractere, sizeof(caractere))) != sizeof(caractere))
-			{
-				if (longueur_ecriture == -1)
-				{
-					break;
-				}
-			}
-
-			destruction_queue_signaux(s_etat_processus);
-			BUG(1, uprintf("Process management error line %d\n", __LINE__));
-			exit(EXIT_FAILURE);
-		}
-
-		pthread_mutex_trylock(&((*s_etat_processus).mutex_interruptions));
-
-		if (pthread_mutex_unlock(&((*s_etat_processus).mutex_interruptions))
-				!= 0)
-		{
-			(*s_etat_processus).erreur_systeme = d_es_processus;
-
-			caractere = 0;
-
-			while((longueur_ecriture = write_atomic(s_etat_processus,
-					(*s_argument_thread).pipe_nombre_elements_attente[1],
-					&caractere, sizeof(caractere))) != sizeof(caractere))
-			{
-				if (longueur_ecriture == -1)
-				{
-					break;
-				}
-			}
-
-			destruction_queue_signaux(s_etat_processus);
-			BUG(1, uprintf("Process management error line %d\n", __LINE__));
-			exit(EXIT_FAILURE);
-		}
-
-		pthread_mutex_trylock(&((*s_etat_processus).mutex_signaux));
-
-		if (pthread_mutex_unlock(&((*s_etat_processus).mutex_signaux))
-				!= 0)
-		{
-			(*s_etat_processus).erreur_systeme = d_es_processus;
-
-			caractere = 0;
-
-			while((longueur_ecriture = write_atomic(s_etat_processus,
-					(*s_argument_thread).pipe_nombre_elements_attente[1],
-					&caractere, sizeof(caractere))) != sizeof(caractere))
-			{
-				if (longueur_ecriture == -1)
-				{
-					break;
-				}
-			}
-
-			destruction_queue_signaux(s_etat_processus);
-			BUG(1, uprintf("Process management error line %d\n", __LINE__));
-			exit(EXIT_FAILURE);
-		}
-
 		if ((*s_etat_processus).evaluation_expression_compilee == 'N')
 		{
 			free((*s_etat_processus).instruction_courante);
@@ -1601,16 +1521,11 @@ instruction_detach(struct_processus *s_e
 
 		// Attente de la réception du signal rpl_sigstart.
 
-		for((*s_etat_processus).demarrage_fils = d_faux;;)
+		for((*s_etat_processus).demarrage_fils = d_faux;
+				(*s_etat_processus).demarrage_fils != d_vrai;
+				nanosleep(&attente, NULL))
 		{
 			scrutation_interruptions(s_etat_processus);
-
-			if ((*s_etat_processus).demarrage_fils == d_vrai)
-			{
-				break;
-			}
-
-			nanosleep(&attente, NULL);
 		}
 
 		(*s_etat_processus).niveau_initial = (*s_etat_processus).niveau_courant;
@@ -1916,6 +1831,8 @@ instruction_detach(struct_processus *s_e
 			l_element_courant = l_element_suivant;
 		}
 
+		(*s_etat_processus).s_fichiers = NULL;
+
 		/*
 		 * Destruction des piles de connecteurs SQL
 		 */
@@ -1938,14 +1855,12 @@ instruction_detach(struct_processus *s_e
 			l_element_courant = l_element_suivant;
 		}
 
-		(*s_etat_processus).s_connecteurs_sql = NULL;
-
 		/*
 		 * On ne détruit pas les sockets car il faut utiliser DETACH
 		 * pour traiter plusieurs connexions simultanées sur les sockets
 		 */
 
-		(*s_etat_processus).s_fichiers = NULL;
+		(*s_etat_processus).s_connecteurs_sql = NULL;
 
 		if ((*s_etat_processus).debug == d_vrai)
 		{
@@ -2819,16 +2734,6 @@ instruction_detach(struct_processus *s_e
 
 		retrait_thread(s_etat_processus);
 		liberation_contexte_cas(s_etat_processus);
-		destruction_queue_signaux(s_etat_processus);
-
-#		ifndef SEMAPHORES_NOMMES
-		sem_post(&((*s_etat_processus).semaphore_fork));
-		sem_destroy(&((*s_etat_processus).semaphore_fork));
-#		else
-		sem_post((*s_etat_processus).semaphore_fork);
-		sem_destroy3((*s_etat_processus).semaphore_fork, getpid(),
-				pthread_self(), SEM_FORK);
-#		endif
 
 		clear_history();
 
@@ -2847,6 +2752,23 @@ instruction_detach(struct_processus *s_e
 		liberation_allocateur(s_etat_processus);
 		liberation_allocateur_buffer(s_etat_processus);
 
+		// Permet d'attendre la libération du mutex de la part
+		// de surveillance_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));
+
+		// Libération des mutexes.
+
 		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));
@@ -2855,8 +2777,19 @@ instruction_detach(struct_processus *s_e
 		pthread_mutex_destroy(&((*s_etat_processus).mutex_allocation_buffer));
 		pthread_mutex_destroy(&mutex_sections_critiques);
 		pthread_mutex_destroy(&mutex_liste_variables_partagees);
+
+		destruction_queue_signaux(s_etat_processus);
 		pthread_mutex_destroy(&mutex_liste_threads);
 
+#		ifndef SEMAPHORES_NOMMES
+		sem_post(&((*s_etat_processus).semaphore_fork));
+		sem_destroy(&((*s_etat_processus).semaphore_fork));
+#		else
+		sem_post((*s_etat_processus).semaphore_fork);
+		sem_destroy3((*s_etat_processus).semaphore_fork, getpid(),
+				pthread_self(), SEM_FORK);
+#		endif
+
 		sys_free(s_etat_processus);
 
 #		ifdef DEBUG_MEMOIRE
@@ -2972,6 +2905,7 @@ instruction_detach(struct_processus *s_e
 	}
 
 	return;
+#endif
 }
 
 // vim: ts=4