--- rpl/src/instructions_d5.c	2010/06/02 10:28:45	1.24
+++ rpl/src/instructions_d5.c	2012/12/18 13:19:36	1.99
@@ -1,7 +1,7 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.0.16
-  Copyright (C) 1989-2010 Dr. BERTRAND Joël
+  RPL/2 (R) version 4.1.12
+  Copyright (C) 1989-2012 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
 
@@ -20,7 +20,7 @@
 */
 
 
-#include "rpl.conv.h"
+#include "rpl-conv.h"
 
 
 /*
@@ -814,50 +814,54 @@ instruction_der(struct_processus *s_etat
 void
 instruction_detach(struct_processus *s_etat_processus)
 {
-	int							status;
+	int									pipe_initialisation_segment_signaux[2];
 
-	logical1					drapeau;
-	logical1					variable_partagee;
+	logical1							drapeau;
 
-	pid_t						ppid;
-	pid_t						pid_final;
+	pid_t								ppid;
+	pid_t								pid_final;
 
-	pthread_attr_t				attributs;
+	pthread_attr_t						attributs;
 
-	pthread_mutexattr_t			attributs_mutex;
+	pthread_mutexattr_t					attributs_mutex;
 
-	pthread_t					thread_surveillance;
+	pthread_t							thread_surveillance;
 
-	sig_atomic_t				registre_stop;
+	sig_atomic_t						registre_stop;
 
-	sigset_t					oldset;
-	sigset_t					oldset2;
-	sigset_t					set;
-	sigset_t					set2;
+	ssize_t								longueur_ecriture;
 
-	ssize_t						longueur_ecriture;
+	struct_descripteur_thread			*s_argument_thread;
+	struct_descripteur_thread			*s_argument_thread2;
 
-	struct_descripteur_thread	*s_argument_thread;
+	struct_liste_chainee				*l_element_courant;
+	struct_liste_chainee				*l_element_precedent;
+	struct_liste_chainee				*l_element_suivant;
 
-	struct_liste_chainee		*l_element_courant;
-	struct_liste_chainee		*l_element_precedent;
-	struct_liste_chainee		*l_element_suivant;
+	struct_liste_variables_partagees	*l_element_partage_courant;
+	struct_liste_variables_partagees	*l_element_partage_suivant;
 
-	struct_objet				*s_copie;
-	struct_objet				*s_objet;
-	struct_objet				*s_objet_systeme;
-	struct_objet				*s_objet_temporaire;
+	struct_liste_variables_statiques	*l_element_statique_courant;
+	struct_liste_variables_statiques	*l_element_statique_suivant;
 
-	struct sigaction			action;
-	struct sigaction			registre;
+	struct_objet						*s_copie;
+	struct_objet						*s_objet;
+	struct_objet						*s_objet_systeme;
+	struct_objet						*s_objet_temporaire;
 
-	struct timespec				attente;
+	struct sigaction					action;
+	struct sigaction					registre;
 
-	unsigned char				*message;
+	struct timespec						attente;
 
-	unsigned int				erreur;
+	unsigned char						caractere;
+	unsigned char						*message;
 
-	unsigned long				i;
+	unsigned int						erreur;
+
+	unsigned long						i;
+
+	volatile logical1					variable_partagee;
 
 	(*s_etat_processus).erreur_execution = d_ex;
 
@@ -930,33 +934,15 @@ instruction_detach(struct_processus *s_e
 		if (recherche_variable(s_etat_processus, (*((struct_nom *)
 				(*s_objet).objet)).nom) == d_vrai)
 		{
-			if ((*s_etat_processus).s_liste_variables
-					[(*s_etat_processus).position_variable_courante].objet
+			if ((*(*s_etat_processus).pointeur_variable_courante).objet
 					== NULL)
 			{
-				if (pthread_mutex_lock(&((*(*s_etat_processus)
-						.s_liste_variables_partagees).mutex)) != 0)
-				{
-					(*s_etat_processus).erreur_systeme = d_es_processus;
-					return;
-				}
-
 				if (recherche_variable_partagee(s_etat_processus,
-						(*s_etat_processus).s_liste_variables
-						[(*s_etat_processus).position_variable_courante].nom,
-						(*s_etat_processus).s_liste_variables
-						[(*s_etat_processus).position_variable_courante]
-						.variable_partagee, (*s_etat_processus)
-						.s_liste_variables[(*s_etat_processus)
-						.position_variable_courante].origine) == d_faux)
+						(*(*s_etat_processus).pointeur_variable_courante).nom,
+						(*(*s_etat_processus).pointeur_variable_courante)
+						.variable_partagee, (*(*s_etat_processus)
+						.pointeur_variable_courante).origine) == NULL)
 				{
-					if (pthread_mutex_unlock(&((*(*s_etat_processus)
-							.s_liste_variables_partagees).mutex)) != 0)
-					{
-						(*s_etat_processus).erreur_systeme = d_es_processus;
-						return;
-					}
-
 					liberation(s_etat_processus, s_objet);
 
 					(*s_etat_processus).erreur_systeme = d_es;
@@ -965,16 +951,14 @@ instruction_detach(struct_processus *s_e
 					return;
 				}
 
-				if (((*(*(*s_etat_processus).s_liste_variables_partagees)
-						.table[(*(*s_etat_processus)
-						.s_liste_variables_partagees).position_variable].objet)
-						.type != RPN) && ((*(*(*s_etat_processus)
-						.s_liste_variables_partagees).table
-						[(*(*s_etat_processus).s_liste_variables_partagees)
-						.position_variable].objet).type != ADR))
+				if (((*(*(*s_etat_processus)
+						.pointeur_variable_partagee_courante).objet).type
+						== RPN) && ((*(*(*s_etat_processus)
+						.pointeur_variable_partagee_courante).objet).type
+						== ADR))
 				{
 					if (pthread_mutex_unlock(&((*(*s_etat_processus)
-							.s_liste_variables_partagees).mutex)) != 0)
+							.pointeur_variable_partagee_courante).mutex)) != 0)
 					{
 						(*s_etat_processus).erreur_systeme = d_es_processus;
 						return;
@@ -988,12 +972,12 @@ instruction_detach(struct_processus *s_e
 				}
 
 				if ((s_copie = copie_objet(s_etat_processus,
-						(*(*s_etat_processus).s_liste_variables_partagees).table
-						[(*(*s_etat_processus).s_liste_variables_partagees)
-						.position_variable].objet, 'P')) == NULL)
+						(*(*s_etat_processus)
+						.pointeur_variable_partagee_courante).objet, 'P'))
+						== NULL)
 				{
 					if (pthread_mutex_unlock(&((*(*s_etat_processus)
-							.s_liste_variables_partagees).mutex)) != 0)
+							.pointeur_variable_partagee_courante).mutex)) != 0)
 					{
 						(*s_etat_processus).erreur_systeme = d_es_processus;
 						return;
@@ -1008,7 +992,7 @@ instruction_detach(struct_processus *s_e
 				variable_partagee = d_vrai;
 
 				if (pthread_mutex_unlock(&((*(*s_etat_processus)
-						.s_liste_variables_partagees).mutex)) != 0)
+						.pointeur_variable_partagee_courante).mutex)) != 0)
 				{
 					(*s_etat_processus).erreur_systeme = d_es_processus;
 					return;
@@ -1016,11 +1000,9 @@ instruction_detach(struct_processus *s_e
 			}
 			else
 			{
-				if (((*(*s_etat_processus).s_liste_variables
-						[(*s_etat_processus).position_variable_courante].objet)
-						.type != RPN) && ((*(*s_etat_processus)
-						.s_liste_variables[(*s_etat_processus)
-						.position_variable_courante].objet).type != ADR))
+				if (((*(*(*s_etat_processus).pointeur_variable_courante).objet)
+						.type != RPN) && ((*(*(*s_etat_processus)
+						.pointeur_variable_courante).objet).type != ADR))
 				{
 					liberation(s_etat_processus, s_objet);
 
@@ -1040,46 +1022,6 @@ instruction_detach(struct_processus *s_e
 		}
 	}
 
-	if (sigemptyset(&set) != 0)
-	{
-		(*s_etat_processus).erreur_systeme = d_es_processus;
-		return;
-	}
-
-	if (sigaddset(&set, SIGSTART) != 0)
-	{
-		(*s_etat_processus).erreur_systeme = d_es_processus;
-		return;
-	}
-
-	/*
-	 * Le signal SIGFSTOP doit être traité !
-	 */
-
-	if (sigaddset(&set, SIGFSTOP) != 0)
-	{
-		(*s_etat_processus).erreur_systeme = d_es_processus;
-		return;
-	}
-
-	if (sigaddset(&set, SIGFABORT) != 0)
-	{
-		(*s_etat_processus).erreur_systeme = d_es_processus;
-		return;
-	}
-
-	if (sigaddset(&set, SIGURG) != 0)
-	{
-		(*s_etat_processus).erreur_systeme = d_es_processus;
-		return;
-	}
-
-	if (pthread_sigmask(SIG_BLOCK, &set, &oldset) != 0)
-	{
-		(*s_etat_processus).erreur_systeme = d_es_processus;
-		return;
-	}
-
 	if ((s_argument_thread = malloc(sizeof(struct_descripteur_thread))) == NULL)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_processus;
@@ -1134,6 +1076,12 @@ instruction_detach(struct_processus *s_e
 		return;
 	}
 
+	if (pipe(pipe_initialisation_segment_signaux) != 0)
+	{
+		(*s_etat_processus).erreur_systeme = d_es_processus;
+		return;
+	}
+
 	ppid = getpid();
 
 	/*
@@ -1153,16 +1101,10 @@ instruction_detach(struct_processus *s_e
 	 * de mémoire, ni libération, ni copie d'objet concurrent au fork().
 	 */
 
-	sigfillset(&set2);
-	pthread_sigmask(SIG_BLOCK, &set2, &oldset2);
-
 	verrouillage_threads_concurrents(s_etat_processus);
 	(*s_argument_thread).pid = fork();
 	deverrouillage_threads_concurrents(s_etat_processus);
 
-	pthread_sigmask(SIG_SETMASK, &oldset2, NULL);
-	sigpending(&set2);
-
 	(*s_argument_thread).thread_pere = pthread_self();
 	(*s_argument_thread).processus_detache = d_vrai;
 
@@ -1171,6 +1113,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 +1130,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,24 +1222,30 @@ instruction_detach(struct_processus *s_e
 			return;
 		}
 
+#		ifdef SCHED_OTHER
 		if (pthread_attr_setschedpolicy(&attributs, SCHED_OTHER) != 0)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_processus;
 			return;
 		}
+#		endif
 
+#		ifdef PTHREAD_EXPLICIT_SCHED
 		if (pthread_attr_setinheritsched(&attributs,
 				PTHREAD_EXPLICIT_SCHED) != 0)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_processus;
 			return;
 		}
+#		endif
 
+#		ifdef PTHREAD_SCOPE_SYSTEM
 		if (pthread_attr_setscope(&attributs, PTHREAD_SCOPE_SYSTEM) != 0)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_processus;
 			return;
 		}
+#		endif
 
 		(*s_argument_thread).s_etat_processus = s_etat_processus;
 
@@ -1296,63 +1268,44 @@ instruction_detach(struct_processus *s_e
 		 * Processus fils
 		 */
 
-#		ifndef SEMAPHORES_NOMMES
-		sem_post(&semaphore_gestionnaires_signaux);
-		sem_destroy(&semaphore_gestionnaires_signaux);
-		sem_init(&semaphore_gestionnaires_signaux, 0, 0);
-#		else
-		sem_post(semaphore_gestionnaires_signaux);
-		sem_destroy2(semaphore_gestionnaires_signaux,
-				sem_gestionnaires_signaux);
-
-		if ((semaphore_gestionnaires_signaux = sem_init2(0,
-				sem_gestionnaires_signaux)) == SEM_FAILED)
+		if (lancement_thread_signaux(s_etat_processus) != d_absence_erreur)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_processus;
 		}
-#		endif
-
-#		ifndef SEMAPHORES_NOMMES
-		sem_post(&semaphore_liste_threads);
-		sem_destroy(&semaphore_liste_threads);
-		sem_init(&semaphore_liste_threads, 0, 1);
-#		else
-		sem_post(semaphore_liste_threads);
-		sem_destroy2(semaphore_liste_threads, sem_liste_threads);
 
-		if ((semaphore_liste_threads = sem_init2(1,
-				sem_liste_threads)) == SEM_FAILED)
-		{
-			(*s_etat_processus).erreur_systeme = d_es_processus;
-		}
-#		endif
+		liberation_queue_signaux(s_etat_processus);
+		creation_queue_signaux(s_etat_processus);
+		routine_recursive = 0;
 
-#		ifndef SEMAPHORES_NOMMES
-		sem_destroy(&semaphore_gestionnaires_signaux_atomique);
-		sem_init(&semaphore_gestionnaires_signaux_atomique, 0, 1);
-		sem_trywait(&((*s_etat_processus).semaphore_fork));
-#		else
-		sem_destroy2(semaphore_gestionnaires_signaux_atomique,
-				sem_gestionnaires_signaux_atomique);
+		(*s_etat_processus).pointeur_signal_lecture = 0;
+		(*s_etat_processus).pointeur_signal_ecriture = 0;
 
-		if ((semaphore_gestionnaires_signaux_atomique = sem_init2(1,
-				sem_gestionnaires_signaux_atomique)) == SEM_FAILED)
+		if (write_atomic(s_etat_processus,
+				pipe_initialisation_segment_signaux[1],
+				"-", sizeof(unsigned char)) != sizeof(unsigned char))
 		{
 			(*s_etat_processus).erreur_systeme = d_es_processus;
 		}
 
-		sem_trywait((*s_etat_processus).semaphore_fork);
-#		endif
+		close(pipe_initialisation_segment_signaux[0]);
+		close(pipe_initialisation_segment_signaux[1]);
 
-#		ifndef SEMAPHORES_NOMMES
-		if (pthread_setspecific(semaphore_fork_processus_courant,
-				&((*s_etat_processus).semaphore_fork)) != 0)
-#		else
-		if (pthread_setspecific(semaphore_fork_processus_courant,
-				(*s_etat_processus).semaphore_fork) != 0)
-#		endif
+		if ((*s_etat_processus).debug == d_vrai)
+			if (((*s_etat_processus).type_debug &
+					d_debug_processus) != 0)
 		{
-			(*s_etat_processus).erreur_systeme = d_es_processus;
+			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);
 		}
 
 		if (close((*s_argument_thread).pipe_erreurs[0]) != 0)
@@ -1389,16 +1342,26 @@ 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)
 		{
-			pthread_mutex_trylock(&((*((struct_mutex *) (*(*l_element_courant)
-					.donnee).objet)).mutex));
-			pthread_mutex_unlock(&((*((struct_mutex *) (*(*l_element_courant)
-					.donnee).objet)).mutex));
-			pthread_mutex_destroy(&((*((struct_mutex *) (*(*l_element_courant)
-					.donnee).objet)).mutex));
-
 			liberation(s_etat_processus, (*l_element_courant).donnee);
 			l_element_suivant = (*l_element_courant).suivant;
 			free(l_element_courant);
@@ -1408,14 +1371,6 @@ instruction_detach(struct_processus *s_e
 		(*s_etat_processus).liste_mutexes = NULL;
 
 		liberation_threads(s_etat_processus);
-
-		(*(*s_etat_processus).s_liste_variables_partagees)
-				.table = NULL;
-		(*(*s_etat_processus).s_liste_variables_partagees)
-				.nombre_variables = 0;
-		(*(*s_etat_processus).s_liste_variables_partagees)
-				.nombre_variables_allouees = 0;
-
 		insertion_thread(s_etat_processus, d_vrai);
 
 		// Envoi d'une donnée pour signaler le démarrage du processus au thread
@@ -1450,9 +1405,47 @@ instruction_detach(struct_processus *s_e
 				}
 			}
 
+			destruction_queue_signaux(s_etat_processus);
+			BUG(1, uprintf("Process management error line %d\n", __LINE__));
+			exit(EXIT_FAILURE);
+		}
+
+		if (pthread_mutex_destroy(&mutex_sections_critiques) != 0)
+		{
+			(*s_etat_processus).erreur_systeme = d_es_processus;
+
+			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;
+				}
+			}
+
+			destruction_queue_signaux(s_etat_processus);
+			BUG(1, uprintf("Process management error line %d\n", __LINE__));
 			exit(EXIT_FAILURE);
 		}
 
+		pthread_mutexattr_init(&attributs_mutex);
+		pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_RECURSIVE);
+		pthread_mutex_init(&mutex_sections_critiques, &attributs_mutex);
+		pthread_mutexattr_destroy(&attributs_mutex);
+
 		if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_processus;
@@ -1479,9 +1472,13 @@ instruction_detach(struct_processus *s_e
 				}
 			}
 
+			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)
 		{
@@ -1509,6 +1506,8 @@ instruction_detach(struct_processus *s_e
 				}
 			}
 
+			destruction_queue_signaux(s_etat_processus);
+			BUG(1, uprintf("Process management error line %d\n", __LINE__));
 			exit(EXIT_FAILURE);
 		}
 
@@ -1519,6 +1518,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 +1530,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 +1557,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.
@@ -1580,21 +1565,18 @@ instruction_detach(struct_processus *s_e
 		 * renseignée.
 		 */
 
-		if (sigpending(&set) != 0)
-		{
-			(*s_etat_processus).erreur_systeme = d_es_processus;
-		}
-		else if (sigismember(&set, SIGSTART) == 0)
+		// Attente de la réception du signal rpl_sigstart.
+
+		for((*s_etat_processus).demarrage_fils = d_faux;;)
 		{
-			while(sigismember(&set, SIGSTART) == 0)
-			{
-				if (sigpending(&set) != 0)
-				{
-					(*s_etat_processus).erreur_systeme = d_es_processus;
-				}
+			scrutation_interruptions(s_etat_processus);
 
-				nanosleep(&attente, NULL);
+			if ((*s_etat_processus).demarrage_fils == d_vrai)
+			{
+				break;
 			}
+
+			nanosleep(&attente, NULL);
 		}
 
 		(*s_etat_processus).niveau_initial = (*s_etat_processus).niveau_courant;
@@ -1619,6 +1601,7 @@ instruction_detach(struct_processus *s_e
 		(*s_etat_processus).presence_fusible = d_faux;
 		(*s_etat_processus).thread_fusible = 0;
 		(*s_etat_processus).pid_erreur_processus_fils = getpid();
+		(*s_etat_processus).sections_critiques = 0;
 
 		if ((*s_etat_processus).profilage == d_vrai)
 		{
@@ -1641,33 +1624,122 @@ 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;
+				}
+			}
+
+			destruction_queue_signaux(s_etat_processus);
+			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)
 		{
-			l_element_suivant = (*l_element_courant).suivant;
+			s_argument_thread2 = (struct_descripteur_thread *)
+					(*((struct_processus_fils *) (*(*l_element_courant).donnee)
+					  .objet)).thread;
 
-			if ((*((*(struct_processus_fils *) (*(*l_element_courant).donnee)
-					.objet)).thread).processus_detache == d_faux)
+			(*s_argument_thread2).nombre_references--;
+
+			BUG((*s_argument_thread2).nombre_references < 0,
+					destruction_queue_signaux(s_etat_processus),
+					printf("(*s_argument_thread2).nombre_references = %d\n",
+					(int) (*s_argument_thread2).nombre_references));
+
+			if ((*s_argument_thread2).nombre_references == 0)
 			{
-				liberation(s_etat_processus, (*((*(struct_processus_fils *)
-						(*(*l_element_courant).donnee).objet)).thread)
-						.argument);
-			}
+				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]);
 
-			free((*(*l_element_courant).donnee).objet);
-			free((*l_element_courant).donnee);
-			free(l_element_courant);
+				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;
 
+		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;
+				}
+			}
+
+			destruction_queue_signaux(s_etat_processus);
+			BUG(1, uprintf("Process management error line %d\n", __LINE__));
+			exit(EXIT_FAILURE);
+		}
+
 		/*
 		 * Initialisation de la pile système
 		 */
@@ -1728,6 +1800,8 @@ instruction_detach(struct_processus *s_e
 				}
 			}
 
+			destruction_queue_signaux(s_etat_processus);
+			BUG(1, uprintf("Process management error line %d\n", __LINE__));
 			exit(EXIT_FAILURE);
 		}
 
@@ -1779,6 +1853,8 @@ instruction_detach(struct_processus *s_e
 				}
 			}
 
+			destruction_queue_signaux(s_etat_processus);
+			BUG(1, uprintf("Process management error line %d\n", __LINE__));
 			exit(EXIT_FAILURE);
 		}
 
@@ -1878,85 +1954,114 @@ instruction_detach(struct_processus *s_e
 
 		(*s_etat_processus).s_fichiers = NULL;
 
-		if (pthread_sigmask(SIG_SETMASK, &oldset, NULL) != 0)
+		if ((*s_etat_processus).debug == d_vrai)
 		{
-			(*s_etat_processus).erreur_systeme = d_es_processus;
+			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());
+				}
+			}
 		}
 
-		sigpending(&set);
-
 		if ((*s_etat_processus).erreur_systeme == d_es)
 		{
-			if (variable_partagee == d_faux)
+			// Évite le warning variable s_copie might be clobbered by
+			// longjmp or vfork
+			struct_objet **s;
+
+			if ((s = malloc(sizeof(struct_objet *))) == NULL)
 			{
-				if (evaluation(s_etat_processus, s_objet, 'E') == d_erreur)
-				{
-					if (((*s_etat_processus).erreur_execution == d_ex) &&
-							((*s_etat_processus).erreur_systeme == d_es))
-					{
-						(*s_etat_processus).erreur_execution =
-								d_ex_erreur_evaluation;
-					}
-				}
-				else
+				(*s_etat_processus).erreur_execution = d_es_allocation_memoire;
+				return;
+			}
+
+			(*s) = s_copie;
+
+			if (setjmp(contexte_processus) == 0)
+			{
+				if (variable_partagee == d_faux)
 				{
-					if (((*s_etat_processus).var_volatile_alarme == 0)
-							&& ((*s_etat_processus).arret_depuis_abort == 0)
-							&& ((*s_etat_processus).at_exit != NULL))
+					if (evaluation(s_etat_processus, s_objet, 'E') == d_erreur)
 					{
-						(*s_etat_processus).var_volatile_requete_arret = 0;
-
-						if (evaluation(s_etat_processus,
-								(*s_etat_processus).at_exit, 'E') == d_erreur)
+						if (((*s_etat_processus).erreur_execution == d_ex) &&
+								((*s_etat_processus).erreur_systeme == d_es))
 						{
 							(*s_etat_processus).erreur_execution =
 									d_ex_erreur_evaluation;
 						}
 					}
-				}
-			}
-			else
-			{
-				if (evaluation(s_etat_processus, s_copie, 'E') == d_erreur)
-				{
-					if (((*s_etat_processus).erreur_execution == d_ex) &&
-							((*s_etat_processus).erreur_systeme == d_es))
+					else
 					{
-						(*s_etat_processus).erreur_execution =
-								d_ex_erreur_evaluation;
+						if (((*s_etat_processus).var_volatile_alarme == 0)
+								&& ((*s_etat_processus).arret_depuis_abort == 0)
+								&& ((*s_etat_processus).at_exit != NULL))
+						{
+							(*s_etat_processus).var_volatile_requete_arret = 0;
+
+							if (evaluation(s_etat_processus,
+									(*s_etat_processus).at_exit, 'E') ==
+									d_erreur)
+							{
+								(*s_etat_processus).erreur_execution =
+										d_ex_erreur_evaluation;
+							}
+						}
 					}
 				}
 				else
 				{
-					if ((*s_etat_processus).at_exit != NULL)
+					if (evaluation(s_etat_processus, (*s), 'E') == d_erreur)
 					{
-						(*s_etat_processus).var_volatile_requete_arret = 0;
-
-						if (evaluation(s_etat_processus,
-								(*s_etat_processus).at_exit, 'E') == d_erreur)
+						if (((*s_etat_processus).erreur_execution == d_ex) &&
+								((*s_etat_processus).erreur_systeme == d_es))
 						{
 							(*s_etat_processus).erreur_execution =
 									d_ex_erreur_evaluation;
 						}
 					}
-				}
+					else
+					{
+						if (((*s_etat_processus).var_volatile_alarme == 0)
+								&& ((*s_etat_processus).arret_depuis_abort == 0)
+								&& ((*s_etat_processus).at_exit != NULL))
+						{
+							(*s_etat_processus).var_volatile_requete_arret = 0;
+
+							if (evaluation(s_etat_processus,
+									(*s_etat_processus).at_exit, 'E') ==
+									d_erreur)
+							{
+								(*s_etat_processus).erreur_execution =
+										d_ex_erreur_evaluation;
+							}
+						}
+					}
 
-				liberation(s_etat_processus, s_copie);
+					liberation(s_etat_processus, (*s));
+				}
 			}
+
+			free(s);
+		}
+
+		for(i = 0; i < (*s_etat_processus).sections_critiques; i++)
+		{
+			pthread_mutex_unlock(&mutex_sections_critiques);
 		}
 
 		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)
 		{
-			pthread_mutex_trylock(&((*((struct_mutex *)
-					(*(*l_element_courant).donnee).objet)).mutex));
-			pthread_mutex_unlock(&((*((struct_mutex *)
-					(*(*l_element_courant).donnee).objet)).mutex));
-			pthread_mutex_destroy(&((*((struct_mutex *)
-					(*(*l_element_courant).donnee).objet)).mutex));
-
 			liberation(s_etat_processus, (*l_element_courant).donnee);
 			l_element_suivant = (*l_element_courant).suivant;
 			free(l_element_courant);
@@ -2167,23 +2272,23 @@ instruction_detach(struct_processus *s_e
 
 				if ((*s_etat_processus).var_volatile_alarme != 0)
 				{
-					kill((*(*((struct_processus_fils *)
+					envoi_signal_processus((*(*((struct_processus_fils *)
 							(*(*l_element_courant).donnee).objet)).thread).pid,
-							SIGURG);
+							rpl_sigurg);
 				}
 				else
 				{
 					if ((*s_etat_processus).arret_depuis_abort == -1)
 					{
-						kill((*(*((struct_processus_fils *)
+						envoi_signal_processus((*(*((struct_processus_fils *)
 								(*(*l_element_courant).donnee).objet)).thread)
-								.pid, SIGFABORT);
+								.pid, rpl_sigabort);
 					}
 					else
 					{
-						kill((*(*((struct_processus_fils *)
+						envoi_signal_processus((*(*((struct_processus_fils *)
 								(*(*l_element_courant).donnee).objet)).thread)
-								.pid, SIGFSTOP);
+								.pid, rpl_sigstop);
 					}
 				}
 			}
@@ -2225,23 +2330,23 @@ instruction_detach(struct_processus *s_e
 				{
 					if ((*s_etat_processus).var_volatile_alarme != 0)
 					{
-						pthread_kill((*(*((struct_processus_fils *)
+						envoi_signal_thread((*(*((struct_processus_fils *)
 								(*(*l_element_courant).donnee).objet)).thread)
-								.tid, SIGURG);
+								.tid, rpl_sigurg);
 					}
 					else
 					{
 						if ((*s_etat_processus).arret_depuis_abort == -1)
 						{
-							pthread_kill((*(*((struct_processus_fils *)
+							envoi_signal_thread((*(*((struct_processus_fils *)
 									(*(*l_element_courant).donnee).objet))
-									.thread).tid, SIGFABORT);
+									.thread).tid, rpl_sigabort);
 						}
 						else
 						{
-							pthread_kill((*(*((struct_processus_fils *)
+							envoi_signal_thread((*(*((struct_processus_fils *)
 									(*(*l_element_courant).donnee).objet))
-									.thread).tid, SIGFSTOP);
+									.thread).tid, rpl_sigstop);
 						}
 					}
 				}
@@ -2265,8 +2370,6 @@ instruction_detach(struct_processus *s_e
 
 		while((*s_etat_processus).l_base_pile_processus != NULL)
 		{
-			status = 0;
-
 			l_element_courant = (struct_liste_chainee *)
 					(*s_etat_processus).l_base_pile_processus;
 
@@ -2309,6 +2412,7 @@ instruction_detach(struct_processus *s_e
 									registre_stop;
 						}
 
+						destruction_queue_signaux(s_etat_processus);
 						(*s_etat_processus).erreur_systeme = d_es_signal;
 						exit(EXIT_FAILURE);
 					}
@@ -2343,8 +2447,9 @@ instruction_detach(struct_processus *s_e
 
 					if (sigaction(SIGPIPE, &registre, NULL) != 0)
 					{
-						pthread_mutex_unlock(&((*s_etat_processus).mutex));
+						destruction_queue_signaux(s_etat_processus);
 
+						pthread_mutex_unlock(&((*s_etat_processus).mutex));
 						(*s_etat_processus).erreur_systeme = d_es_signal;
 						exit(EXIT_FAILURE);
 					}
@@ -2360,6 +2465,8 @@ instruction_detach(struct_processus *s_e
 
 			nanosleep(&attente, NULL);
 			pthread_mutex_lock(&((*s_etat_processus).mutex));
+
+			scrutation_interruptions(s_etat_processus);
 		}
 
 		pthread_mutex_unlock(&((*s_etat_processus).mutex));
@@ -2460,6 +2567,26 @@ instruction_detach(struct_processus *s_e
 				(*s_etat_processus).arbre_instructions);
 		free((*s_etat_processus).pointeurs_caracteres);
 
+		l_element_statique_courant = (*s_etat_processus)
+				.l_liste_variables_statiques;
+
+		while(l_element_statique_courant != NULL)
+		{
+			l_element_statique_suivant = (*l_element_statique_courant).suivant;
+			free(l_element_statique_courant);
+			l_element_statique_courant = l_element_statique_suivant;
+		}
+
+		l_element_partage_courant = (*(*s_etat_processus)
+				.l_liste_variables_partagees);
+
+		while(l_element_partage_courant != NULL)
+		{
+			l_element_partage_suivant = (*l_element_partage_courant).suivant;
+			free(l_element_partage_courant);
+			l_element_partage_courant = l_element_partage_suivant;
+		}
+
 		if ((*s_etat_processus).entree_standard != NULL)
 		{
 			pclose((*s_etat_processus).entree_standard);
@@ -2484,43 +2611,11 @@ instruction_detach(struct_processus *s_e
 			(*s_etat_processus).instruction_derniere_erreur = NULL;
 		}
 
-		for(i = 0; i < (*s_etat_processus).nombre_variables; i++)
-		{
-			liberation(s_etat_processus,
-					(*s_etat_processus).s_liste_variables[i].objet);
-			free((*s_etat_processus).s_liste_variables[i].nom);
-		}
-
-		free((*s_etat_processus).s_liste_variables);
-
-		for(i = 0; i < (*s_etat_processus).nombre_variables_statiques; i++)
-		{
-			liberation(s_etat_processus,
-					(*s_etat_processus).s_liste_variables_statiques[i].objet);
-			free((*s_etat_processus).s_liste_variables_statiques[i].nom);
-		}
-
-		free((*s_etat_processus).s_liste_variables_statiques);
-
-		for(i = 0; i < (*(*s_etat_processus).s_liste_variables_partagees)
-				.nombre_variables; i++)
-		{
-			liberation(s_etat_processus,
-					(*(*s_etat_processus).s_liste_variables_partagees)
-					.table[i].objet);
-			free((*(*s_etat_processus).s_liste_variables_partagees)
-					.table[i].nom);
-		}
-
-		if ((*(*s_etat_processus).s_liste_variables_partagees).table
-				!= NULL)
-		{
-			free((struct_variable_partagee *)
-					(*(*s_etat_processus).s_liste_variables_partagees).table);
-		}
-
-		pthread_mutex_destroy(&((*(*s_etat_processus)
-				.s_liste_variables_partagees).mutex));
+		liberation_arbre_variables_partagees(s_etat_processus,
+				(*(*s_etat_processus).s_arbre_variables_partagees));
+		liberation_arbre_variables(s_etat_processus,
+				(*s_etat_processus).s_arbre_variables, d_vrai);
+		free((*s_etat_processus).pointeurs_caracteres_variables);
 
 		l_element_courant = (*s_etat_processus).l_base_pile;
 		while(l_element_courant != NULL)
@@ -2659,12 +2754,6 @@ instruction_detach(struct_processus *s_e
 
 		liberation(s_etat_processus, s_objet);
 
-#		ifndef Cygwin
-		(*s_etat_processus).pile_signal.ss_flags = SS_DISABLE;
-		sigaltstack(&((*s_etat_processus).pile_signal), NULL);
-		free((*s_etat_processus).pile_signal.ss_sp);
-#		endif
-
 		free((*s_etat_processus).definitions_chainees);
 		free((*s_etat_processus).nom_fichier_historique);
 
@@ -2704,37 +2793,27 @@ 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);
+		pthread_mutex_destroy(&mutex_sections_critiques);
 
 #		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_destroy2((*s_etat_processus).semaphore_fork, sem_fork);
+		sem_destroy3((*s_etat_processus).semaphore_fork, getpid(),
+				pthread_self(), SEM_FORK);
 #		endif
 
 		free((*s_etat_processus).localisation);
 		free(s_argument_thread);
 
-#		ifndef SEMAPHORES_NOMMES
-		sem_destroy(&semaphore_liste_threads);
-		sem_post(&semaphore_gestionnaires_signaux);
-		sem_destroy(&semaphore_gestionnaires_signaux);
-		sem_destroy(&semaphore_gestionnaires_signaux_atomique);
-#		else
-		sem_destroy2(semaphore_liste_threads, sem_liste_threads);
-		sem_post(semaphore_gestionnaires_signaux);
-		sem_destroy2(semaphore_gestionnaires_signaux,
-				sem_gestionnaires_signaux);
-		sem_destroy2(semaphore_gestionnaires_signaux_atomique,
-				sem_gestionnaires_signaux_atomique);
-#		endif
-
 		clear_history();
 
+		destruction_queue_signaux(s_etat_processus);
+		liberation_contexte_cas(s_etat_processus);
+		arret_thread_signaux(s_etat_processus);
 		free(s_etat_processus);
 
 #		ifdef DEBUG_MEMOIRE
@@ -2750,40 +2829,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é.
@@ -2827,6 +2872,7 @@ instruction_detach(struct_processus *s_e
 				}
 			}
 
+			scrutation_interruptions(s_etat_processus);
 			l_element_courant = (*l_element_courant).suivant;
 		}
 	} while(drapeau == d_vrai);
@@ -2846,39 +2892,33 @@ instruction_detach(struct_processus *s_e
 		return;
 	}
 
-	// Être sûr que le processus fils soit déjà présent...
+	// On attend une donnée fictive pour être sûr que le segment de mémoire
+	// partagée destiné à la gestion des signaux est bien initialisé.
 
-	while(kill((*s_argument_thread).pid, 0) != 0)
-	{
-		//if ((errno != ESRCH) && (errno != EAGAIN))
-		if (errno != ESRCH)
-		{
-			(*s_etat_processus).erreur_systeme = d_es_processus;
-			pthread_mutex_unlock(&((*s_etat_processus).mutex));
-			return;
-		}
+	attente.tv_sec = 0;
+	attente.tv_nsec = GRANULARITE_us * 1000;
 
+	while(read_atomic(s_etat_processus,
+			pipe_initialisation_segment_signaux[0],
+			&caractere, sizeof(caractere)) == 0)
+	{
+		scrutation_interruptions(s_etat_processus);
 		nanosleep(&attente, NULL);
+		INCR_GRANULARITE(attente.tv_nsec);
 	}
 
-	// Le fils peut être présent sans être en attente du signal de départ.
+	close(pipe_initialisation_segment_signaux[0]);
+	close(pipe_initialisation_segment_signaux[1]);
 
-	if (kill((*s_argument_thread).pid, SIGSTART) != 0)
-	{
-		(*s_etat_processus).erreur_systeme = d_es_processus;
-		pthread_mutex_unlock(&((*s_etat_processus).mutex));
-		return;
-	}
+	// Le fils peut être présent sans être en attente du signal de départ.
 
-	if (pthread_sigmask(SIG_SETMASK, &oldset, NULL) != 0)
+	if (envoi_signal_processus((*s_argument_thread).pid, rpl_sigstart) != 0)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_processus;
 		pthread_mutex_unlock(&((*s_etat_processus).mutex));
 		return;
 	}
 
-	sigpending(&set);
-
 	if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_processus;