--- rpl/src/rpl.c	2012/12/14 14:19:50	1.126
+++ rpl/src/rpl.c	2013/03/26 09:04:33	1.138
@@ -1,7 +1,7 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.1.11
-  Copyright (C) 1989-2012 Dr. BERTRAND Joël
+  RPL/2 (R) version 4.1.13
+  Copyright (C) 1989-2013 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
 
@@ -51,6 +51,8 @@ rplinit(int argc, char *argv[], char *en
 	int									erreur_historique;
 	int									option_P;
 
+	integer8							i;
+
 	logical1							core;
 	logical1							debug;
 	logical1							erreur_fichier;
@@ -80,9 +82,15 @@ rplinit(int argc, char *argv[], char *en
 
 	struct_processus					*s_etat_processus;
 
+	struct_liste_variables_partagees	*l_element_partage_courant;
+	struct_liste_variables_partagees	*l_element_partage_suivant;
+
 	struct_liste_variables_statiques	*l_element_statique_courant;
 	struct_liste_variables_statiques	*l_element_statique_suivant;
 
+	struct_arbre_variables_partagees	*s_arbre_variables_partagees;
+	struct_liste_variables_partagees	*l_liste_variables_partagees;
+
 	struct sigaction					action;
 	struct sigaction					registre;
 
@@ -100,7 +108,6 @@ rplinit(int argc, char *argv[], char *en
 	unsigned char						*ptr;
 	unsigned char						*tampon;
 
-	unsigned long						i;
 	unsigned long						unite_fichier;
 
 	void								*l_element_courant;
@@ -213,7 +220,7 @@ rplinit(int argc, char *argv[], char *en
 		return(EXIT_FAILURE);
 	}
 
-	if ((arg_exec = malloc((argc + 1) * sizeof(char *))) == NULL)
+	if ((arg_exec = malloc((((size_t) argc) + 1) * sizeof(char *))) == NULL)
 	{
 #		ifndef SEMAPHORES_NOMMES
 		sem_post(&semaphore_gestionnaires_signaux);
@@ -235,7 +242,7 @@ rplinit(int argc, char *argv[], char *en
 		return(EXIT_FAILURE);
 	}
 
-	for(i = 0; i < (unsigned long) argc; i++)
+	for(i = 0; i < argc; i++)
 	{
 		arg_exec[i] = argv[i];
 	}
@@ -267,6 +274,11 @@ rplinit(int argc, char *argv[], char *en
 	pthread_mutex_init(&mutex_sections_critiques, &attributs_mutex);
 	pthread_mutexattr_destroy(&attributs_mutex);
 
+	pthread_mutexattr_init(&attributs_mutex);
+	pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_RECURSIVE);
+	pthread_mutex_init(&mutex_liste_variables_partagees, &attributs_mutex);
+	pthread_mutexattr_destroy(&attributs_mutex);
+
 #	ifndef SEMAPHORES_NOMMES
 		sem_init(&((*s_etat_processus).semaphore_fork), 0, 0);
 #	else
@@ -424,11 +436,11 @@ rplinit(int argc, char *argv[], char *en
 
 	if ((*s_etat_processus).langue == 'F')
 	{
-		printf("+++Copyright (C) 1989 à 2011, 2012 BERTRAND Joël\n");
+		printf("+++Copyright (C) 1989 à 2012, 2013 BERTRAND Joël\n");
 	}
 	else
 	{
-		printf("+++Copyright (C) 1989 to 2011, 2012 BERTRAND Joel\n");
+		printf("+++Copyright (C) 1989 to 2012, 2013 BERTRAND Joel\n");
 	}
 
 	if (getenv("HOME") != NULL)
@@ -582,7 +594,7 @@ rplinit(int argc, char *argv[], char *en
 	}
 
 	signal_test = SIGTEST;
-	kill(getpid(), SIGINT);
+	raise(SIGINT);
 
 	attente.tv_sec = 0;
 	attente.tv_nsec = 1000000;
@@ -669,7 +681,7 @@ rplinit(int argc, char *argv[], char *en
 	}
 
 	signal_test = SIGTEST;
-	kill(getpid(), SIGTERM);
+	raise(SIGTERM);
 
 	attente.tv_sec = 0;
 	attente.tv_nsec = 1000000;
@@ -756,7 +768,7 @@ rplinit(int argc, char *argv[], char *en
 	}
 
 	signal_test = SIGTEST;
-	kill(getpid(), SIGALRM);
+	raise(SIGALRM);
 
 	attente.tv_sec = 0;
 	attente.tv_nsec = 1000000;
@@ -844,7 +856,7 @@ rplinit(int argc, char *argv[], char *en
 	}
 
 	signal_test = SIGTEST;
-	kill(getpid(), SIGTSTP);
+	raise(SIGTSTP);
 
 	attente.tv_sec = 0;
 	attente.tv_nsec = 1000000;
@@ -934,7 +946,7 @@ rplinit(int argc, char *argv[], char *en
 	}
 
 	signal_test = SIGTEST;
-	kill(getpid(), SIGPIPE);
+	raise(SIGPIPE);
 
 	attente.tv_sec = 0;
 	attente.tv_nsec = 1000000;
@@ -1024,7 +1036,7 @@ rplinit(int argc, char *argv[], char *en
 	}
 
 	signal_test = SIGTEST;
-	kill(getpid(), SIGUSR1);
+	raise(SIGUSR1);
 
 	attente.tv_sec = 0;
 	attente.tv_nsec = 1000000;
@@ -2242,7 +2254,7 @@ rplinit(int argc, char *argv[], char *en
 							}
 
 							(*s_etat_processus).longueur_definitions_chainees =
-									strlen((*s_etat_processus)
+									(integer8) strlen((*s_etat_processus)
 									.definitions_chainees);
 
 							break;
@@ -2789,7 +2801,7 @@ rplinit(int argc, char *argv[], char *en
 			}
 
 			signal_test = SIGTEST;
-			kill(getpid(), SIGSEGV);
+			raise(SIGSEGV);
 
 			attente.tv_sec = 0;
 			attente.tv_nsec = 1000000;
@@ -2889,7 +2901,7 @@ rplinit(int argc, char *argv[], char *en
 			}
 
 			signal_test = SIGTEST;
-			kill(getpid(), SIGBUS);
+			raise(SIGBUS);
 
 			attente.tv_sec = 0;
 			attente.tv_nsec = 1000000;
@@ -3425,10 +3437,17 @@ rplinit(int argc, char *argv[], char *en
 
 			(*s_etat_processus).s_arbre_variables = NULL;
 			(*s_etat_processus).l_liste_variables_par_niveau = NULL;
+			(*s_etat_processus).l_liste_variables_statiques = NULL;
 			(*s_etat_processus).gel_liste_variables = d_faux;
+			s_arbre_variables_partagees = NULL;
+			l_liste_variables_partagees = NULL;
+			(*s_etat_processus).s_arbre_variables_partagees =
+					&s_arbre_variables_partagees;
+			(*s_etat_processus).l_liste_variables_partagees =
+					&l_liste_variables_partagees;
 			(*s_etat_processus).pointeur_variable_courante = NULL;
 			(*s_etat_processus).pointeur_variable_statique_courante = NULL;
-			(*s_etat_processus).l_liste_variables_statiques = NULL;
+			(*s_etat_processus).pointeur_variable_partagee_courante = NULL;
 			(*s_etat_processus).niveau_courant = 0;
 			(*s_etat_processus).niveau_initial = 0;
 			(*s_etat_processus).creation_variables_statiques = d_faux;
@@ -4464,7 +4483,7 @@ rplinit(int argc, char *argv[], char *en
 					{
 						(*s_etat_processus).erreur_systeme = d_es;
 						encart(s_etat_processus,
-								(unsigned long) (5 * 1000000));
+								(integer8) (5 * 1000000));
 
 						if ((*s_etat_processus).erreur_systeme != d_es)
 						{
@@ -5120,12 +5139,18 @@ rplinit(int argc, char *argv[], char *en
 
 								if (erreur == d_absence_erreur)
 								{
-									if (((*s_etat_processus).var_volatile_alarme
-											== 0) && ((*s_etat_processus)
+									if (((*s_etat_processus)
 											.arret_depuis_abort == 0) &&
 											((*s_etat_processus).at_exit
 											!= NULL))
 									{
+										// Permet de traiter ATEXIT
+										// même après réception d'un SIGINT.
+										(*s_etat_processus)
+												.var_volatile_alarme = 0;
+										(*s_etat_processus)
+												.var_volatile_requete_arret = 0;
+
 										erreur = evaluation(s_etat_processus,
 												(*s_etat_processus).at_exit,
 												'E');
@@ -5141,12 +5166,18 @@ rplinit(int argc, char *argv[], char *en
 
 								if (erreur == d_absence_erreur)
 								{
-									if (((*s_etat_processus).var_volatile_alarme
-											== 0) && ((*s_etat_processus)
+									if (((*s_etat_processus)
 											.arret_depuis_abort == 0) &&
 											((*s_etat_processus).at_exit
 											!= NULL))
 									{
+										// Permet de traiter ATEXIT
+										// même après réception d'un SIGINT.
+										(*s_etat_processus)
+												.var_volatile_alarme = 0;
+										(*s_etat_processus)
+												.var_volatile_requete_arret = 0;
+
 										erreur = evaluation(s_etat_processus,
 												(*s_etat_processus).at_exit,
 												'E');
@@ -5362,8 +5393,7 @@ rplinit(int argc, char *argv[], char *en
 						l_element_courant = (void *)
 								(*s_etat_processus).l_base_pile_processus;
 
-						for(i = 0; i < (unsigned long)
-								(*(*((struct_processus_fils *)
+						for(i = 0; i < (*(*((struct_processus_fils *)
 								(*(*((struct_liste_chainee *)
 								l_element_courant)).donnee).objet)).thread)
 								.nombre_objets_dans_pipe; i++)
@@ -5662,7 +5692,7 @@ rplinit(int argc, char *argv[], char *en
 					 */
 
 					liberation_arbre_variables_partagees(s_etat_processus,
-							(*s_etat_processus).s_arbre_variables);
+							(*(*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);
@@ -5678,6 +5708,17 @@ rplinit(int argc, char *argv[], char *en
 						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;
+					}
+
 					/*
 					 * Si resultats est non nul, rplinit a été appelé
 					 * depuis rpl() [librpl] et non main().
@@ -5692,8 +5733,9 @@ rplinit(int argc, char *argv[], char *en
 						{
 							free((*resultats));
 
-							if (((*resultats) = malloc(((*s_etat_processus)
-									.hauteur_pile_operationnelle + 1)
+							if (((*resultats) = malloc(((size_t)
+									((*s_etat_processus)
+									.hauteur_pile_operationnelle + 1))
 									* sizeof(unsigned char **))) != NULL)
 							{
 								(*resultats)[(*s_etat_processus)
@@ -6015,6 +6057,7 @@ rplinit(int argc, char *argv[], char *en
 	pthread_mutex_destroy(&((*s_etat_processus).mutex));
 	pthread_mutex_destroy(&((*s_etat_processus).mutex_allocation));
 	pthread_mutex_destroy(&mutex_sections_critiques);
+	pthread_mutex_destroy(&mutex_liste_variables_partagees);
 
 #	ifndef SEMAPHORES_NOMMES
 	sem_post(&((*s_etat_processus).semaphore_fork));