--- rpl/src/instructions_d5.c	2010/05/06 15:02:43	1.18
+++ rpl/src/instructions_d5.c	2011/04/21 16:00:56	1.51
@@ -1,7 +1,7 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.0.15
-  Copyright (C) 1989-2010 Dr. BERTRAND Joël
+  RPL/2 (R) version 4.1.0.prerelease.0
+  Copyright (C) 1989-2011 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
 
@@ -20,7 +20,7 @@
 */
 
 
-#include "rpl.conv.h"
+#include "rpl-conv.h"
 
 
 /*
@@ -838,6 +838,7 @@ instruction_detach(struct_processus *s_e
 	ssize_t						longueur_ecriture;
 
 	struct_descripteur_thread	*s_argument_thread;
+	struct_descripteur_thread	*s_argument_thread2;
 
 	struct_liste_chainee		*l_element_courant;
 	struct_liste_chainee		*l_element_precedent;
@@ -1171,6 +1172,12 @@ instruction_detach(struct_processus *s_e
 	pthread_mutex_init(&((*s_argument_thread).mutex), &attributs_mutex);
 	pthread_mutexattr_destroy(&attributs_mutex);
 
+	pthread_mutexattr_init(&attributs_mutex);
+	pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_RECURSIVE);
+	pthread_mutex_init(&((*s_argument_thread).mutex_nombre_references),
+			&attributs_mutex);
+	pthread_mutexattr_destroy(&attributs_mutex);
+
 	if ((*s_argument_thread).pid > 0)
 	{
 		/*
@@ -1182,15 +1189,33 @@ instruction_detach(struct_processus *s_e
 			liberation(s_etat_processus, s_copie);
 		}
 
-		if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
+		liberation(s_etat_processus, s_objet);
+
+		if ((s_objet = allocation(s_etat_processus, PRC)) == NULL)
 		{
-			(*s_etat_processus).erreur_systeme = d_es_processus;
+			(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
 			return;
 		}
 
-		if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
+		(*((struct_processus_fils *) (*s_objet).objet)).thread =
+				s_argument_thread;
+		(*(*((struct_processus_fils *) (*s_objet).objet)).thread)
+				.nombre_objets_dans_pipe = 0;
+		(*(*((struct_processus_fils *) (*s_objet).objet)).thread)
+				.nombre_interruptions_dans_pipe = 0;
+		(*(*((struct_processus_fils *) (*s_objet).objet)).thread)
+				.nombre_references = 1;
+
+		/*
+		 * On copie l'objet plutôt que le pointeur car cet objet peut être
+		 * accédé depuis deux threads distincts et aboutir à un blocage lors
+		 * d'une copie.
+		 */
+
+		if ((s_objet_systeme = copie_objet(s_etat_processus, s_objet, 'O'))
+				== NULL)
 		{
-			(*s_etat_processus).erreur_systeme = d_es_processus;
+			(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
 			return;
 		}
 
@@ -1256,6 +1281,8 @@ instruction_detach(struct_processus *s_e
 			return;
 		}
 
+#		ifndef OS2
+#		ifndef Cygwin
 		if (pthread_attr_setschedpolicy(&attributs, SCHED_OTHER) != 0)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_processus;
@@ -1274,6 +1301,8 @@ instruction_detach(struct_processus *s_e
 			(*s_etat_processus).erreur_systeme = d_es_processus;
 			return;
 		}
+#		endif
+#		endif
 
 		(*s_argument_thread).s_etat_processus = s_etat_processus;
 
@@ -1296,6 +1325,29 @@ instruction_detach(struct_processus *s_e
 		 * Processus fils
 		 */
 
+#		ifdef _BROKEN_SIGINFO
+		liberation_fifos_signaux(s_etat_processus);
+		creation_fifos_signaux(s_etat_processus);
+#		endif
+
+		if ((*s_etat_processus).debug == d_vrai)
+			if (((*s_etat_processus).type_debug &
+					d_debug_processus) != 0)
+		{
+			if ((*s_etat_processus).langue == 'F')
+			{
+				printf("[%d] Lancement du processus fils %d de %d\n",
+						(int) getpid(), (int) getpid(), (int) ppid);
+			}
+			else
+			{
+				printf("[%d] Start child process %d from %d\n", (int) getpid(),
+						(int) getpid(), (int) ppid);
+			}
+
+			fflush(stdout);
+		}
+
 #		ifndef SEMAPHORES_NOMMES
 		sem_post(&semaphore_gestionnaires_signaux);
 		sem_destroy(&semaphore_gestionnaires_signaux);
@@ -1389,6 +1441,23 @@ instruction_detach(struct_processus *s_e
 			(*s_etat_processus).erreur_systeme = d_es_processus;
 		}
 
+		if ((*s_etat_processus).debug == d_vrai)
+			if (((*s_etat_processus).type_debug &
+					d_debug_processus) != 0)
+		{
+			if ((*s_etat_processus).langue == 'F')
+			{
+				printf("[%d] Libération des objets du processus père\n",
+						(int) getpid());
+			}
+			else
+			{
+				printf("[%d] Freeing parent process memory\n", getpid());
+			}
+
+			fflush(stdout);
+		}
+
 		l_element_courant = (*s_etat_processus).liste_mutexes;
 		while(l_element_courant != NULL)
 		{
@@ -1450,6 +1519,11 @@ instruction_detach(struct_processus *s_e
 				}
 			}
 
+#			ifdef _BROKEN_SIGINFO
+			destruction_fifos_signaux(s_etat_processus);
+#			endif
+
+			BUG(1, uprintf("Process management error line %d\n", __LINE__));
 			exit(EXIT_FAILURE);
 		}
 
@@ -1479,9 +1553,16 @@ instruction_detach(struct_processus *s_e
 				}
 			}
 
+#			ifdef _BROKEN_SIGINFO
+			destruction_fifos_signaux(s_etat_processus);
+#			endif
+
+			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)
 		{
@@ -1509,6 +1590,11 @@ instruction_detach(struct_processus *s_e
 				}
 			}
 
+#			ifdef _BROKEN_SIGINFO
+			destruction_fifos_signaux(s_etat_processus);
+#			endif
+
+			BUG(1, uprintf("Process management error line %d\n", __LINE__));
 			exit(EXIT_FAILURE);
 		}
 
@@ -1519,6 +1605,7 @@ instruction_detach(struct_processus *s_e
 		}
 
 		(*s_etat_processus).var_volatile_processus_pere = 0;
+		(*s_etat_processus).var_volatile_processus_racine = 0;
 
 		// On réinitialise toutes les interruptions.
 
@@ -1530,6 +1617,9 @@ instruction_detach(struct_processus *s_e
 
 		liberation(s_etat_processus, (*s_etat_processus).at_exit);
 		(*s_etat_processus).at_exit = NULL;
+		liberation(s_etat_processus, (*s_etat_processus).at_poke);
+		(*s_etat_processus).at_poke = NULL;
+		(*s_etat_processus).traitement_at_poke = 'N';
 
 		for(i = 0; i < d_NOMBRE_INTERRUPTIONS; i++)
 		{
@@ -1554,24 +1644,6 @@ instruction_detach(struct_processus *s_e
 			(*s_etat_processus).pile_origine_interruptions[i] = NULL;
 		}
 
-		if ((*s_etat_processus).debug == d_vrai)
-			if (((*s_etat_processus).type_debug &
-					d_debug_processus) != 0)
-		{
-			if ((*s_etat_processus).langue == 'F')
-			{
-				printf("[%d] Lancement du processus fils %d de %d\n",
-						(int) getpid(), (int) getpid(), (int) ppid);
-			}
-			else
-			{
-				printf("[%d] Start child process %d from %d\n", (int) getpid(),
-						(int) getpid(), (int) ppid);
-			}
-
-			fflush(stdout);
-		}
-
 		/*
 		 * On bloque l'exécution du processus fils jusqu'à ce que
 		 * le père ait renseigné correctement la pile des processus.
@@ -1641,11 +1713,129 @@ instruction_detach(struct_processus *s_e
 		}
 
 		/*
-		 * Initialisation de la pile des processus
+		 * Initialisation de la pile des processus. Cette pile est effacée
+		 * par liberation_threads().
 		 */
 
+		if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0)
+		{
+			(*s_etat_processus).erreur_systeme = d_es;
+
+			pid_final = -2;
+
+			while((longueur_ecriture = write_atomic(s_etat_processus,
+					(*s_argument_thread).pipe_nombre_interruptions_attente[1],
+					&pid_final, sizeof(pid_final))) != sizeof(pid_final))
+			{
+				if (longueur_ecriture == -1)
+				{
+					break;
+				}
+			}
+
+			while((longueur_ecriture = write_atomic(s_etat_processus,
+					(*s_argument_thread).pipe_nombre_objets_attente[1],
+					&pid_final, sizeof(pid_final))) != sizeof(pid_final))
+			{
+				if (longueur_ecriture == -1)
+				{
+					break;
+				}
+			}
+
+#			ifdef _BROKEN_SIGINFO
+			destruction_fifos_signaux(s_etat_processus);
+#			endif
+
+			BUG(1, uprintf("Process management error line %d\n", __LINE__));
+			exit(EXIT_FAILURE);
+		}
+
+		l_element_courant = (struct_liste_chainee *)
+				(*s_etat_processus).l_base_pile_processus;
+
+		while(l_element_courant != NULL)
+		{
+			s_argument_thread2 = (struct_descripteur_thread *)
+					(*((struct_processus_fils *) (*(*l_element_courant).donnee)
+					  .objet)).thread;
+
+			(*s_argument_thread2).nombre_references--;
+
+			BUG((*s_argument_thread2).nombre_references < 0,
+#					ifdef _BROKEN_SIGINFO
+					destruction_fifos_signaux(s_etat_processus),
+#					endif
+					printf("(*s_argument_thread2).nombre_references = %d\n",
+					(int) (*s_argument_thread2).nombre_references));
+
+			if ((*s_argument_thread2).nombre_references == 0)
+			{
+				close((*s_argument_thread2).pipe_objets[0]);
+				close((*s_argument_thread2).pipe_acquittement[1]);
+				close((*s_argument_thread2).pipe_injections[1]);
+				close((*s_argument_thread2).pipe_nombre_injections[1]);
+				close((*s_argument_thread2).pipe_nombre_objets_attente[0]);
+				close((*s_argument_thread2).pipe_interruptions[0]);
+				close((*s_argument_thread2)
+						.pipe_nombre_interruptions_attente[0]);
+
+				pthread_mutex_destroy(&((*s_argument_thread2).mutex));
+
+				if ((*s_argument_thread2).processus_detache == d_faux)
+				{
+					if ((*s_argument_thread2).destruction_objet == d_vrai)
+					{
+						liberation(s_etat_processus,
+								(*s_argument_thread2).argument);
+					}
+				}
+
+				free(s_argument_thread2);
+				free((*(*l_element_courant).donnee).objet);
+				free((*l_element_courant).donnee);
+			}
+
+			l_element_suivant = (*l_element_courant).suivant;
+			free((struct_liste_chainee *) l_element_courant);
+			l_element_courant = l_element_suivant;
+		}
+
 		(*s_etat_processus).l_base_pile_processus = NULL;
-		// Les données associées sont déjà effacées par liberation_thread().
+
+		if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
+		{
+			(*s_etat_processus).erreur_systeme = d_es;
+
+			pid_final = -2;
+
+			while((longueur_ecriture = write_atomic(s_etat_processus,
+					(*s_argument_thread).pipe_nombre_interruptions_attente[1],
+					&pid_final, sizeof(pid_final))) != sizeof(pid_final))
+			{
+				if (longueur_ecriture == -1)
+				{
+					break;
+				}
+			}
+
+			while((longueur_ecriture = write_atomic(s_etat_processus,
+					(*s_argument_thread).pipe_nombre_objets_attente[1],
+					&pid_final, sizeof(pid_final))) != sizeof(pid_final))
+			{
+				if (longueur_ecriture == -1)
+				{
+					break;
+				}
+			}
+
+#			ifdef _BROKEN_SIGINFO
+			destruction_fifos_signaux(s_etat_processus);
+#			endif
+
+			BUG(1, uprintf("Process management error line %d\n", __LINE__));
+			exit(EXIT_FAILURE);
+		}
 
 		/*
 		 * Initialisation de la pile système
@@ -1707,6 +1897,11 @@ instruction_detach(struct_processus *s_e
 				}
 			}
 
+#			ifdef _BROKEN_SIGINFO
+			destruction_fifos_signaux(s_etat_processus);
+#			endif
+
+			BUG(1, uprintf("Process management error line %d\n", __LINE__));
 			exit(EXIT_FAILURE);
 		}
 
@@ -1758,6 +1953,11 @@ instruction_detach(struct_processus *s_e
 				}
 			}
 
+#			ifdef _BROKEN_SIGINFO
+			destruction_fifos_signaux(s_etat_processus);
+#			endif
+
+			BUG(1, uprintf("Process management error line %d\n", __LINE__));
 			exit(EXIT_FAILURE);
 		}
 
@@ -1835,6 +2035,7 @@ instruction_detach(struct_processus *s_e
   À noter : on ne ferme pas la connexion car la conséquence immédiate est
   une destruction de l'objet pour le processus père.
 ================================================================================
+*/
 
 		l_element_courant = (*s_etat_processus).s_connecteurs_sql;
 
@@ -1842,11 +2043,10 @@ instruction_detach(struct_processus *s_e
 		{
 			l_element_suivant = (*l_element_courant).suivant;
 
-			sqlclose((*l_element_courant).donnee);
+//			sqlclose((*l_element_courant).donnee);
 			liberation(s_etat_processus, (*l_element_courant).donnee);
 			l_element_courant = l_element_suivant;
 		}
-*/
 
 		(*s_etat_processus).s_connecteurs_sql = NULL;
 
@@ -1864,6 +2064,22 @@ instruction_detach(struct_processus *s_e
 
 		sigpending(&set);
 
+		if ((*s_etat_processus).debug == d_vrai)
+		{
+			if (((*s_etat_processus).type_debug & d_debug_processus)
+					!= 0)
+			{
+				if ((*s_etat_processus).langue == 'F')
+				{
+					printf("[%d] Évaluation de l'objet détaché\n", getpid());
+				}
+				else
+				{
+					printf("[%d] Évaluation of detached object\n", getpid());
+				}
+			}
+		}
+
 		if ((*s_etat_processus).erreur_systeme == d_es)
 		{
 			if (variable_partagee == d_faux)
@@ -1925,6 +2141,7 @@ instruction_detach(struct_processus *s_e
 		}
 
 		liberation(s_etat_processus, (*s_etat_processus).at_exit);
+		liberation(s_etat_processus, (*s_etat_processus).at_poke);
 
 		l_element_courant = (*s_etat_processus).liste_mutexes;
 		while(l_element_courant != NULL)
@@ -2288,6 +2505,10 @@ instruction_detach(struct_processus *s_e
 									registre_stop;
 						}
 
+#						ifdef _BROKEN_SIGINFO
+						destruction_fifos_signaux(s_etat_processus);
+#						endif
+
 						(*s_etat_processus).erreur_systeme = d_es_signal;
 						exit(EXIT_FAILURE);
 					}
@@ -2322,6 +2543,10 @@ instruction_detach(struct_processus *s_e
 
 					if (sigaction(SIGPIPE, &registre, NULL) != 0)
 					{
+#						ifdef _BROKEN_SIGINFO
+						destruction_fifos_signaux(s_etat_processus);
+#						endif
+
 						pthread_mutex_unlock(&((*s_etat_processus).mutex));
 
 						(*s_etat_processus).erreur_systeme = d_es_signal;
@@ -2638,10 +2863,6 @@ instruction_detach(struct_processus *s_e
 
 		liberation(s_etat_processus, s_objet);
 
-#		ifndef Cygwin
-		free((*s_etat_processus).pile_signal.ss_sp);
-#		endif
-
 		free((*s_etat_processus).definitions_chainees);
 		free((*s_etat_processus).nom_fichier_historique);
 
@@ -2681,6 +2902,7 @@ instruction_detach(struct_processus *s_e
 		retrait_thread(s_etat_processus);
 
 		pthread_mutex_destroy(&((*s_etat_processus).mutex));
+		pthread_mutex_destroy(&((*s_etat_processus).mutex_allocation));
 		pthread_mutex_destroy(&((*s_etat_processus).protection_liste_mutexes));
 
 		pthread_key_delete(semaphore_fork_processus_courant);
@@ -2694,7 +2916,6 @@ instruction_detach(struct_processus *s_e
 #		endif
 
 		free((*s_etat_processus).localisation);
-		free(s_etat_processus);
 		free(s_argument_thread);
 
 #		ifndef SEMAPHORES_NOMMES
@@ -2713,8 +2934,15 @@ instruction_detach(struct_processus *s_e
 
 		clear_history();
 
+#		ifdef _BROKEN_SIGINFO
+		destruction_fifos_signaux(s_etat_processus);
+#		endif
+
+		free(s_etat_processus);
+
 #		ifdef DEBUG_MEMOIRE
-		debug_memoire_verification(s_etat_processus);
+		debug_memoire_verification();
+		analyse_post_mortem();
 #		endif
 
 		exit(EXIT_SUCCESS);
@@ -2725,40 +2953,6 @@ instruction_detach(struct_processus *s_e
 		return;
 	}
 
-	liberation(s_etat_processus, s_objet);
-
-	if ((s_objet = allocation(s_etat_processus, PRC)) == NULL)
-	{
-		(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
-		return;
-	}
-
-	(*((struct_processus_fils *) (*s_objet).objet)).thread = s_argument_thread;
-	(*(*((struct_processus_fils *) (*s_objet).objet)).thread)
-			.nombre_objets_dans_pipe = 0;
-	(*(*((struct_processus_fils *) (*s_objet).objet)).thread)
-			.nombre_interruptions_dans_pipe = 0;
-	(*(*((struct_processus_fils *) (*s_objet).objet)).thread)
-			.nombre_references = 1;
-
-	/*
-	 * On copie l'objet plutôt que le pointeur car cet objet peut être
-	 * accédé depuis deux threads distincts et aboutir à un blocage lors d'une
-	 * copie.
-	 */
-
-	if ((s_objet_systeme = copie_objet(s_etat_processus, s_objet, 'O')) == NULL)
-	{
-		(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
-		return;
-	}
-
-	if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0)
-	{
-		(*s_etat_processus).erreur_systeme = d_es_processus;
-		return;
-	}
-
 	// Si le pid existe déjà dans la pile des processus, il s'agit forcement
 	// d'un processus moribond. On attend donc qu'il soit effectivement
 	// libéré.
@@ -2823,6 +3017,9 @@ instruction_detach(struct_processus *s_e
 
 	// Être sûr que le processus fils soit déjà présent...
 
+	attente.tv_sec = 0;
+	attente.tv_nsec = GRANULARITE_us * 1000;
+
 	while(kill((*s_argument_thread).pid, 0) != 0)
 	{
 		//if ((errno != ESRCH) && (errno != EAGAIN))
@@ -2834,6 +3031,7 @@ instruction_detach(struct_processus *s_e
 		}
 
 		nanosleep(&attente, NULL);
+		INCR_GRANULARITE(attente.tv_nsec);
 	}
 
 	// Le fils peut être présent sans être en attente du signal de départ.