--- rpl/src/rpl.c	2013/03/21 11:30:31	1.136
+++ rpl/src/rpl.c	2013/08/27 13:48:05	1.148
@@ -1,6 +1,6 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.1.13
+  RPL/2 (R) version 4.1.15
   Copyright (C) 1989-2013 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
@@ -260,7 +260,20 @@ rplinit(int argc, char *argv[], char *en
 
 	pthread_mutexattr_init(&attributs_mutex);
 	pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL);
-	pthread_mutex_init(&((*s_etat_processus).mutex), &attributs_mutex);
+	pthread_mutex_init(&((*s_etat_processus).mutex_pile_processus),
+			&attributs_mutex);
+	pthread_mutexattr_destroy(&attributs_mutex);
+
+	pthread_mutexattr_init(&attributs_mutex);
+	pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL);
+	pthread_mutex_init(&((*s_etat_processus).mutex_interruptions),
+			&attributs_mutex);
+	pthread_mutexattr_destroy(&attributs_mutex);
+
+	pthread_mutexattr_init(&attributs_mutex);
+	pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL);
+	pthread_mutex_init(&((*s_etat_processus).mutex_signaux),
+			&attributs_mutex);
 	pthread_mutexattr_destroy(&attributs_mutex);
 
 	pthread_mutexattr_init(&attributs_mutex);
@@ -357,26 +370,26 @@ rplinit(int argc, char *argv[], char *en
 	}
 	else
 	{
-#		ifndef SEMAPHORES_NOMMES
-			sem_post(&((*s_etat_processus).semaphore_fork));
-			sem_post(&semaphore_gestionnaires_signaux);
-			sem_destroy(&semaphore_gestionnaires_signaux);
-			sem_destroy(&((*s_etat_processus).semaphore_fork));
-#		else
-			sem_post((*s_etat_processus).semaphore_fork);
-			sem_post(semaphore_gestionnaires_signaux);
-			sem_destroy2(semaphore_gestionnaires_signaux, getpid(),
-					SEM_SIGNAUX);
-			sem_destroy3((*s_etat_processus).semphore_fork, getpid(),
-					pthread_self(), SEM_FORK);
-#		endif
-
-		liberation_contexte_cas(s_etat_processus);
-		liberation_queue_signaux(s_etat_processus);
-
 		if (((*s_etat_processus).localisation = malloc((strlen(d_locale)
 				+ 1) * sizeof(unsigned char))) == NULL)
 		{
+#			ifndef SEMAPHORES_NOMMES
+				sem_post(&((*s_etat_processus).semaphore_fork));
+				sem_post(&semaphore_gestionnaires_signaux);
+				sem_destroy(&semaphore_gestionnaires_signaux);
+				sem_destroy(&((*s_etat_processus).semaphore_fork));
+#			else
+				sem_post((*s_etat_processus).semaphore_fork);
+				sem_post(semaphore_gestionnaires_signaux);
+				sem_destroy2(semaphore_gestionnaires_signaux, getpid(),
+						SEM_SIGNAUX);
+				sem_destroy3((*s_etat_processus).semphore_fork, getpid(),
+						pthread_self(), SEM_FORK);
+#			endif
+
+			liberation_contexte_cas(s_etat_processus);
+			liberation_queue_signaux(s_etat_processus);
+
 			if ((*s_etat_processus).langue == 'F')
 			{
 				uprintf("+++Système : Mémoire insuffisante\n");
@@ -3404,6 +3417,7 @@ rplinit(int argc, char *argv[], char *en
 
 			(*s_etat_processus).liste_mutexes = NULL;
 			(*s_etat_processus).sections_critiques = 0;
+			(*s_etat_processus).initialisation_scheduler = d_faux;
 
 			(*s_etat_processus).test_instruction = 'N';
 			(*s_etat_processus).nombre_arguments = 0;
@@ -4483,7 +4497,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)
 						{
@@ -4905,6 +4919,8 @@ rplinit(int argc, char *argv[], char *en
 							return(EXIT_FAILURE);
 						}
 
+						empilement_pile_systeme(s_etat_processus);
+
 						if (evaluation(s_etat_processus, s_objet, 'E')
 								== d_erreur)
 						{
@@ -5139,15 +5155,95 @@ 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;
+
+										if ((*s_etat_processus).profilage ==
+												d_vrai)
+										{
+											profilage(s_etat_processus,
+													"ATEXIT");
+										}
+
 										erreur = evaluation(s_etat_processus,
 												(*s_etat_processus).at_exit,
 												'E');
+
+										if ((*s_etat_processus).profilage ==
+												d_vrai)
+										{
+											profilage(s_etat_processus, NULL);
+										}
+
+										if (((*s_etat_processus)
+												.erreur_execution != d_ex) ||
+												((*s_etat_processus).exception
+												!= d_ep) || ((*s_etat_processus)
+												.erreur_systeme != d_es))
+										{
+											printf("%s [%d]\n", message =
+													messages(s_etat_processus),
+													(int) getpid());
+											free(message);
+
+											if (test_cfsf(s_etat_processus, 51)
+													== d_faux)
+											{
+												printf("%s", ds_beep);
+											}
+
+											if ((*s_etat_processus).core ==
+													d_vrai)
+											{
+												printf("\n");
+
+												if ((*s_etat_processus).langue
+														== 'F')
+												{
+													printf("+++Information : Gé"
+															"nération du fichie"
+															"r rpl-core "
+															"[%d]\n", (int)
+															getpid());
+												}
+												else
+												{
+													printf("+++Information : Wr"
+															"iting rpl-core fil"
+															"e [%d]\n",
+															(int) getpid());
+												}
+
+												rplcore(s_etat_processus);
+
+												if ((*s_etat_processus).langue
+														== 'F')
+												{
+													printf("+++Information : Pr"
+															"ocessus tracé [%d]"
+															"\n",
+															(int) getpid());
+												}
+												else
+												{
+													printf("+++Information : Do"
+															"ne [%d]\n", (int)
+															getpid());
+												}
+
+												printf("\n");
+												fflush(stdout);
+											}
+										}
 									}
 								}
 							}
@@ -5160,15 +5256,95 @@ 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;
+
+										if ((*s_etat_processus).profilage ==
+												d_vrai)
+										{
+											profilage(s_etat_processus,
+													"ATEXIT");
+										}
+
 										erreur = evaluation(s_etat_processus,
 												(*s_etat_processus).at_exit,
 												'E');
+
+										if ((*s_etat_processus).profilage ==
+												d_vrai)
+										{
+											profilage(s_etat_processus, NULL);
+										}
+
+										if (((*s_etat_processus)
+												.erreur_execution != d_ex) ||
+												((*s_etat_processus).exception
+												!= d_ep) || ((*s_etat_processus)
+												.erreur_systeme != d_es))
+										{
+											printf("%s [%d]\n", message =
+													messages(s_etat_processus),
+													(int) getpid());
+											free(message);
+
+											if (test_cfsf(s_etat_processus, 51)
+													== d_faux)
+											{
+												printf("%s", ds_beep);
+											}
+
+											if ((*s_etat_processus).core ==
+													d_vrai)
+											{
+												printf("\n");
+
+												if ((*s_etat_processus).langue
+														== 'F')
+												{
+													printf("+++Information : Gé"
+															"nération du fichie"
+															"r rpl-core "
+															"[%d]\n", (int)
+															getpid());
+												}
+												else
+												{
+													printf("+++Information : Wr"
+															"iting rpl-core fil"
+															"e [%d]\n",
+															(int) getpid());
+												}
+
+												rplcore(s_etat_processus);
+
+												if ((*s_etat_processus).langue
+														== 'F')
+												{
+													printf("+++Information : Pr"
+															"ocessus tracé [%d]"
+															"\n",
+															(int) getpid());
+												}
+												else
+												{
+													printf("+++Information : Do"
+															"ne [%d]\n", (int)
+															getpid());
+												}
+
+												printf("\n");
+												fflush(stdout);
+											}
+										}
 									}
 								}
 							}
@@ -5209,7 +5385,8 @@ rplinit(int argc, char *argv[], char *en
 						pthread_cancel((*s_etat_processus).thread_fusible);
 					}
 
-					pthread_mutex_lock(&((*s_etat_processus).mutex));
+					pthread_mutex_lock(&((*s_etat_processus)
+							.mutex_pile_processus));
 
 					l_element_courant = (void *) (*s_etat_processus)
 							.l_base_pile_processus;
@@ -5445,8 +5622,8 @@ rplinit(int argc, char *argv[], char *en
 										}
 #									endif
 
-									pthread_mutex_unlock(
-											&((*s_etat_processus).mutex));
+									pthread_mutex_unlock(&((*s_etat_processus)
+											.mutex_pile_processus));
 									return(EXIT_FAILURE);
 								}
 
@@ -5508,14 +5685,15 @@ rplinit(int argc, char *argv[], char *en
 										}
 #									endif
 
-									pthread_mutex_unlock(
-											&((*s_etat_processus).mutex));
+									pthread_mutex_unlock(&((*s_etat_processus)
+											.mutex_pile_processus));
 									return(EXIT_FAILURE);
 								}
 							}
 						}
 
-						pthread_mutex_unlock(&((*s_etat_processus).mutex));
+						pthread_mutex_lock(&((*s_etat_processus)
+								.mutex_interruptions));
 
 						if ((*s_etat_processus)
 								.nombre_interruptions_non_affectees != 0)
@@ -5524,12 +5702,18 @@ rplinit(int argc, char *argv[], char *en
 									s_etat_processus);
 						}
 
+						pthread_mutex_unlock(&((*s_etat_processus)
+								.mutex_interruptions));
+						pthread_mutex_unlock(&((*s_etat_processus)
+								.mutex_pile_processus));
 						nanosleep(&attente, NULL);
 						scrutation_interruptions(s_etat_processus);
-						pthread_mutex_lock(&((*s_etat_processus).mutex));
+						pthread_mutex_lock(&((*s_etat_processus)
+								.mutex_pile_processus));
 					}
 
-					pthread_mutex_unlock(&((*s_etat_processus).mutex));
+					pthread_mutex_unlock(&((*s_etat_processus)
+							.mutex_pile_processus));
 
 					erreur_historique = write_history(
 							(*s_etat_processus).nom_fichier_historique);
@@ -6042,8 +6226,10 @@ rplinit(int argc, char *argv[], char *en
 
 	retrait_thread(s_etat_processus);
 
-	pthread_mutex_destroy(&((*s_etat_processus).mutex));
+	pthread_mutex_destroy(&((*s_etat_processus).mutex_pile_processus));
 	pthread_mutex_destroy(&((*s_etat_processus).mutex_allocation));
+	pthread_mutex_destroy(&((*s_etat_processus).mutex_interruptions));
+	pthread_mutex_destroy(&((*s_etat_processus).mutex_signaux));
 	pthread_mutex_destroy(&mutex_sections_critiques);
 	pthread_mutex_destroy(&mutex_liste_variables_partagees);