--- rpl/src/rpl.c	2011/12/16 13:46:56	1.106
+++ rpl/src/rpl.c	2012/10/07 08:18:36	1.121
@@ -1,7 +1,7 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.1.5
-  Copyright (C) 1989-2011 Dr. BERTRAND Joël
+  RPL/2 (R) version 4.1.11
+  Copyright (C) 1989-2012 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
 
@@ -80,6 +80,9 @@ rplinit(int argc, char *argv[], char *en
 
 	struct_processus					*s_etat_processus;
 
+	struct_liste_variables_statiques	*l_element_statique_courant;
+	struct_liste_variables_statiques	*l_element_statique_suivant;
+
 	struct_table_variables_partagees	s_variables_partagees;
 
 	struct sigaction					action;
@@ -251,6 +254,11 @@ rplinit(int argc, char *argv[], char *en
 			&attributs_mutex);
 	pthread_mutexattr_destroy(&attributs_mutex);
 
+	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);
+
 #	ifndef SEMAPHORES_NOMMES
 		sem_init(&((*s_etat_processus).semaphore_fork), 0, 0);
 #	else
@@ -345,11 +353,11 @@ rplinit(int argc, char *argv[], char *en
 
 	if ((*s_etat_processus).langue == 'F')
 	{
-		printf("+++Copyright (C) 1989 à 2010, 2011 BERTRAND Joël\n");
+		printf("+++Copyright (C) 1989 à 2011, 2012 BERTRAND Joël\n");
 	}
 	else
 	{
-		printf("+++Copyright (C) 1989 to 2010, 2011 BERTRAND Joel\n");
+		printf("+++Copyright (C) 1989 to 2011, 2012 BERTRAND Joel\n");
 	}
 
 	if (getenv("HOME") != NULL)
@@ -429,6 +437,14 @@ rplinit(int argc, char *argv[], char *en
 	signal_test = SIGTEST;
 	kill(getpid(), SIGINT);
 
+	attente.tv_sec = 0;
+	attente.tv_nsec = 1000000;
+
+	for(i = 0; (i < 1000) && (signal_test == SIGTEST); i++)
+	{
+		nanosleep(&attente, NULL);
+	}
+
 	if (signal_test != SIGINT)
 	{
 		erreur = d_es_signal;
@@ -466,6 +482,14 @@ rplinit(int argc, char *argv[], char *en
 	signal_test = SIGTEST;
 	kill(getpid(), SIGTERM);
 
+	attente.tv_sec = 0;
+	attente.tv_nsec = 1000000;
+
+	for(i = 0; (i < 1000) && (signal_test == SIGTEST); i++)
+	{
+		nanosleep(&attente, NULL);
+	}
+
 	if (signal_test != SIGTERM)
 	{
 		erreur = d_es_signal;
@@ -503,6 +527,14 @@ rplinit(int argc, char *argv[], char *en
 	signal_test = SIGTEST;
 	kill(getpid(), SIGALRM);
 
+	attente.tv_sec = 0;
+	attente.tv_nsec = 1000000;
+
+	for(i = 0; (i < 1000) && (signal_test == SIGTEST); i++)
+	{
+		nanosleep(&attente, NULL);
+	}
+
 	if (signal_test != SIGALRM)
 	{
 		erreur = d_es_signal;
@@ -541,6 +573,14 @@ rplinit(int argc, char *argv[], char *en
 	signal_test = SIGTEST;
 	kill(getpid(), SIGTSTP);
 
+	attente.tv_sec = 0;
+	attente.tv_nsec = 1000000;
+
+	for(i = 0; (i < 1000) && (signal_test == SIGTEST); i++)
+	{
+		nanosleep(&attente, NULL);
+	}
+
 	if (signal_test != SIGTSTP)
 	{
 		erreur = d_es_signal;
@@ -581,6 +621,14 @@ rplinit(int argc, char *argv[], char *en
 	signal_test = SIGTEST;
 	kill(getpid(), SIGPIPE);
 
+	attente.tv_sec = 0;
+	attente.tv_nsec = 1000000;
+
+	for(i = 0; (i < 1000) && (signal_test == SIGTEST); i++)
+	{
+		nanosleep(&attente, NULL);
+	}
+
 	if (signal_test != SIGPIPE)
 	{
 		erreur = d_es_signal;
@@ -621,6 +669,14 @@ rplinit(int argc, char *argv[], char *en
 	signal_test = SIGTEST;
 	kill(getpid(), SIGUSR1);
 
+	attente.tv_sec = 0;
+	attente.tv_nsec = 1000000;
+
+	for(i = 0; (i < 1000) && (signal_test == SIGTEST); i++)
+	{
+		nanosleep(&attente, NULL);
+	}
+
 	if (signal_test != SIGUSR1)
 	{
 		erreur = d_es_signal;
@@ -1590,6 +1646,14 @@ rplinit(int argc, char *argv[], char *en
 			signal_test = SIGTEST;
 			kill(getpid(), SIGSEGV);
 
+			attente.tv_sec = 0;
+			attente.tv_nsec = 1000000;
+
+			for(i = 0; (i < 1000) && (signal_test == SIGTEST); i++)
+			{
+				nanosleep(&attente, NULL);
+			}
+
 			if (signal_test != SIGSEGV)
 			{
 				erreur = d_es_signal;
@@ -1609,6 +1673,9 @@ rplinit(int argc, char *argv[], char *en
 			}
 #	endif
 
+			action.sa_handler = interruption3;
+			action.sa_flags = 0;
+
 			if (sigaction(SIGBUS, &action, NULL) != 0)
 			{
 				if ((*s_etat_processus).langue == 'F')
@@ -1628,6 +1695,14 @@ rplinit(int argc, char *argv[], char *en
 			signal_test = SIGTEST;
 			kill(getpid(), SIGBUS);
 
+			attente.tv_sec = 0;
+			attente.tv_nsec = 1000000;
+
+			for(i = 0; (i < 1000) && (signal_test == SIGTEST); i++)
+			{
+				nanosleep(&attente, NULL);
+			}
+
 			if (signal_test != SIGBUS)
 			{
 				erreur = d_es_signal;
@@ -1861,6 +1936,7 @@ rplinit(int argc, char *argv[], char *en
 			gettimeofday(&((*s_etat_processus).horodatage_profilage), NULL);
 
 			(*s_etat_processus).liste_mutexes = NULL;
+			(*s_etat_processus).sections_critiques = 0;
 
 			(*s_etat_processus).test_instruction = 'N';
 			(*s_etat_processus).nombre_arguments = 0;
@@ -1896,14 +1972,12 @@ rplinit(int argc, char *argv[], char *en
 			(*s_etat_processus).l_liste_variables_par_niveau = NULL;
 			(*s_etat_processus).gel_liste_variables = d_faux;
 			(*s_etat_processus).pointeur_variable_courante = NULL;
-			(*s_etat_processus).s_liste_variables_statiques = NULL;
-			(*s_etat_processus).nombre_variables_statiques = 0;
-			(*s_etat_processus).nombre_variables_statiques_allouees = 0;
+			(*s_etat_processus).pointeur_variable_statique_courante = NULL;
+			(*s_etat_processus).l_liste_variables_statiques = NULL;
 			(*s_etat_processus).niveau_courant = 0;
 			(*s_etat_processus).niveau_initial = 0;
 			(*s_etat_processus).creation_variables_statiques = d_faux;
 			(*s_etat_processus).creation_variables_partagees = d_faux;
-			(*s_etat_processus).position_variable_statique_courante = 0;
 
 			(*s_etat_processus).s_bibliotheques = NULL;
 			(*s_etat_processus).s_instructions_externes = NULL;
@@ -2032,7 +2106,7 @@ rplinit(int argc, char *argv[], char *en
 			(*s_etat_processus).arbre_instructions = NULL;
 
 			(*s_etat_processus).tid_processus_pere = pthread_self();
-			(*s_etat_processus).tid= pthread_self();
+			(*s_etat_processus).tid = pthread_self();
 			(*s_etat_processus).pid_processus_pere = getpid();
 			(*s_etat_processus).processus_detache = d_vrai;
 			(*s_etat_processus).var_volatile_processus_pere = -1;
@@ -2129,12 +2203,10 @@ rplinit(int argc, char *argv[], char *en
 				(*((*s_etat_processus).l_base_pile_systeme))
 						.retour_definition = 'Y';
 
-				(*s_etat_processus).indep = (struct_objet *) malloc(
-						sizeof(struct_objet));
-				(*s_etat_processus).depend = (struct_objet *) malloc(
-						sizeof(struct_objet));
+				(*s_etat_processus).indep = allocation(s_etat_processus, NON);
+				(*s_etat_processus).depend = allocation(s_etat_processus, NON);
 				(*s_etat_processus).parametres_courbes_de_niveau =
-						(struct_objet *) malloc(sizeof(struct_objet));
+						allocation(s_etat_processus, NON);
 
 				if (((*s_etat_processus).indep != NULL) &&
 						((*s_etat_processus).depend != NULL) &&
@@ -2544,6 +2616,11 @@ rplinit(int argc, char *argv[], char *en
 							home, ds_fichier_historique);
 
 					using_history();
+
+					// Pour pouvoir utiliser le keymap avant le premier
+					// appel à readline().
+					rl_initialize();
+
 					erreur_historique = read_history(
 							(*s_etat_processus).nom_fichier_historique);
 
@@ -2840,6 +2917,11 @@ rplinit(int argc, char *argv[], char *en
 						}
 					}
 
+					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);
 
@@ -3266,17 +3348,17 @@ rplinit(int argc, char *argv[], char *en
 							(*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++)
+					l_element_statique_courant = (*s_etat_processus)
+							.l_liste_variables_statiques;
+
+					while(l_element_statique_courant != NULL)
 					{
-						liberation(s_etat_processus, (*s_etat_processus)
-								.s_liste_variables_statiques[i].objet);
-						free((*s_etat_processus)
-								.s_liste_variables_statiques[i].nom);
+						l_element_statique_suivant =
+							(*l_element_statique_courant).suivant;
+						free(l_element_statique_courant);
+						l_element_statique_courant = l_element_statique_suivant;
 					}
 
-					free((*s_etat_processus).s_liste_variables_statiques);
-
 					for(i = 0; i < (*((*s_etat_processus)
 							.s_liste_variables_partagees)).nombre_variables;
 							i++)
@@ -3633,6 +3715,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);
 
 #	ifndef SEMAPHORES_NOMMES
 	sem_post(&((*s_etat_processus).semaphore_fork));
@@ -3645,9 +3728,6 @@ rplinit(int argc, char *argv[], char *en
 
 	free((*s_etat_processus).localisation);
 
-	pthread_mutex_destroy(&mutex_liste_threads);
-	pthread_mutex_destroy(&mutex_gestionnaires_signaux_atomique);
-
 #	ifndef SEMAPHORES_NOMMES
 	sem_post(&semaphore_gestionnaires_signaux);
 	sem_destroy(&semaphore_gestionnaires_signaux);