--- rpl/src/instructions_d5.c	2012/01/05 10:19:01	1.85
+++ rpl/src/instructions_d5.c	2013/02/26 19:56:14	1.101
@@ -1,7 +1,7 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.1.5
-  Copyright (C) 1989-2012 Dr. BERTRAND Joël
+  RPL/2 (R) version 4.1.12
+  Copyright (C) 1989-2013 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
 
@@ -814,48 +814,54 @@ instruction_der(struct_processus *s_etat
 void
 instruction_detach(struct_processus *s_etat_processus)
 {
-	int							pipe_initialisation_segment_signaux[2];
+	int									pipe_initialisation_segment_signaux[2];
 
-	logical1					drapeau;
+	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;
 
-	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_descripteur_thread			*s_argument_thread2;
 
-	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_objet				*s_copie;
-	struct_objet				*s_objet;
-	struct_objet				*s_objet_systeme;
-	struct_objet				*s_objet_temporaire;
+	struct_liste_variables_partagees	*l_element_partage_courant;
+	struct_liste_variables_partagees	*l_element_partage_suivant;
 
-	struct sigaction			action;
-	struct sigaction			registre;
+	struct_liste_variables_statiques	*l_element_statique_courant;
+	struct_liste_variables_statiques	*l_element_statique_suivant;
 
-	struct timespec				attente;
+	struct_objet						*s_copie;
+	struct_objet						*s_objet;
+	struct_objet						*s_objet_systeme;
+	struct_objet						*s_objet_temporaire;
 
-	unsigned char				caractere;
-	unsigned char				*message;
+	struct sigaction					action;
+	struct sigaction					registre;
 
-	unsigned int				erreur;
+	struct timespec						attente;
 
-	unsigned long				i;
+	unsigned char						caractere;
+	unsigned char						*message;
+
+	unsigned int						erreur;
+
+	unsigned long						i;
 
-	volatile logical1			variable_partagee;
+	volatile logical1					variable_partagee;
 
 	(*s_etat_processus).erreur_execution = d_ex;
 
@@ -931,26 +937,12 @@ instruction_detach(struct_processus *s_e
 			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).pointeur_variable_courante).nom,
 						(*(*s_etat_processus).pointeur_variable_courante)
 						.variable_partagee, (*(*s_etat_processus)
-						.pointeur_variable_courante).origine) == d_faux)
+						.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;
@@ -959,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;
@@ -982,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;
@@ -1002,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;
@@ -1278,6 +1268,11 @@ instruction_detach(struct_processus *s_e
 		 * Processus fils
 		 */
 
+		if (lancement_thread_signaux(s_etat_processus) != d_absence_erreur)
+		{
+			(*s_etat_processus).erreur_systeme = d_es_processus;
+		}
+
 		liberation_queue_signaux(s_etat_processus);
 		creation_queue_signaux(s_etat_processus);
 		routine_recursive = 0;
@@ -1376,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
@@ -1423,6 +1410,42 @@ instruction_detach(struct_processus *s_e
 			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;
@@ -1578,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)
 		{
@@ -2027,6 +2051,11 @@ instruction_detach(struct_processus *s_e
 			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);
 
@@ -2538,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);
@@ -2562,39 +2611,12 @@ instruction_detach(struct_processus *s_e
 			(*s_etat_processus).instruction_derniere_erreur = NULL;
 		}
 
+		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);
 
-		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));
-
 		l_element_courant = (*s_etat_processus).l_base_pile;
 		while(l_element_courant != NULL)
 		{
@@ -2773,6 +2795,7 @@ instruction_detach(struct_processus *s_e
 		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_mutex_destroy(&mutex_sections_critiques);
 
 #		ifndef SEMAPHORES_NOMMES
 		sem_post(&((*s_etat_processus).semaphore_fork));
@@ -2790,6 +2813,7 @@ instruction_detach(struct_processus *s_e
 
 		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