--- rpl/src/rpl.c	2010/05/19 09:22:34	1.25
+++ rpl/src/rpl.c	2010/09/02 07:51:48	1.48
@@ -1,6 +1,6 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.0.15
+  RPL/2 (R) version 4.0.19
   Copyright (C) 1989-2010 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
@@ -21,7 +21,13 @@
 
 
 #define  MAIN_RPL
-#include "rpl.conv.h"
+#include "rpl-conv.h"
+
+#ifdef SEMAPHORES_SYSV
+#ifndef OS2
+	unsigned char		*chemin_semaphores_SysV;
+#endif
+#endif
 
 
 /*
@@ -33,8 +39,8 @@
 int
 rplinit(int argc, char *argv[], unsigned char ***resultats, char *rpl_home)
 {
-#	include								"copyright.conv.h"
-#	include								"licence.conv.h"
+#	include								"copyright-conv.h"
+#	include								"licence-conv.h"
 
 	file								*f_source;
 
@@ -99,6 +105,12 @@ rplinit(int argc, char *argv[], unsigned
 	volatile int						erreur;
 	volatile unsigned char				traitement_fichier_temporaire;
 
+	errno = 0;
+
+#	ifdef DEBUG_MEMOIRE
+	debug_memoire_initialisation();
+#	endif
+
 	setvbuf(stdout, NULL, _IOLBF, 0);
 	setvbuf(stderr, NULL, _IOLBF, 0);
 
@@ -177,13 +189,17 @@ rplinit(int argc, char *argv[], unsigned
 
 	(*s_etat_processus).rpl_home = rpl_home;
 
-	insertion_thread(s_etat_processus, d_vrai);
-
 	pthread_mutexattr_init(&attributs_mutex);
 	pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL);
 	pthread_mutex_init(&((*s_etat_processus).mutex), &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_allocation),
+			&attributs_mutex);
+	pthread_mutexattr_destroy(&attributs_mutex);
+
 #	ifndef SEMAPHORES_NOMMES
 	sem_init(&((*s_etat_processus).semaphore_fork), 0, 0);
 #	else
@@ -221,7 +237,49 @@ rplinit(int argc, char *argv[], unsigned
 			.mutex), &attributs_mutex);
 	pthread_mutexattr_destroy(&attributs_mutex);
 
+	(*s_etat_processus).chemin_fichiers_temporaires =
+			recherche_chemin_fichiers_temporaires(s_etat_processus);
+
+#	ifdef SEMAPHORES_SYSV
+#	ifndef OS2
+	chemin_semaphores_SysV = (*s_etat_processus).chemin_fichiers_temporaires;
+#	endif
+#	endif
+
+#	ifdef _BROKEN_SIGINFO
+	creation_fifos_signaux(s_etat_processus);
+#	ifdef return
+#		undef return
+#	endif
+#	define return destruction_fifos_signaux(s_etat_processus); return
+#	endif
+
+	insertion_thread(s_etat_processus, d_vrai);
+
+#	ifndef OS2
 	localisation_courante(s_etat_processus);
+#	else
+	if ((*s_etat_processus).erreur_systeme != d_es)
+	{
+		if (((*s_etat_processus).localisation = malloc((strlen(d_locale) + 1) *
+				sizeof(unsigned char))) == NULL)
+		{
+			if ((*s_etat_processus).langue == 'F')
+			{
+				uprintf("+++Système : Mémoire insuffisante\n");
+			}
+			else
+			{
+				uprintf("+++System : Not enough memory\n");
+			}
+
+			return(EXIT_FAILURE);
+		}
+
+		strcpy((*s_etat_processus).localisation, d_locale);
+	}
+#	endif
+
 	(*s_etat_processus).erreur_systeme = d_es;
 
 	if ((*s_etat_processus).localisation == NULL)
@@ -317,7 +375,7 @@ rplinit(int argc, char *argv[], unsigned
 	// Initialisation d'une pile de signal pour récupérer les
 	// débordement de pile
 
-#	ifndef Cygwin
+#	if !defined(Cygwin) && !defined(OpenBSD)
 	if (((*s_etat_processus).pile_signal.ss_sp =
 			malloc((*s_etat_processus).pile_signal.ss_size =
 			SIGSTKSZ)) == NULL)
@@ -356,8 +414,12 @@ rplinit(int argc, char *argv[], unsigned
 	}
 #	endif
 
+#	ifndef _BROKEN_SIGINFO
 	action.sa_sigaction = interruption1;
-	action.sa_flags = SA_ONSTACK | SA_SIGINFO;
+#	else
+	action.sa_handler = interruption1;
+#	endif
+	action.sa_flags = SA_ONSTACK | SA_SIGINFO | SA_NODEFER;
 
 	if (sigaction(SIGINT, &action, NULL) != 0)
 	{
@@ -376,7 +438,11 @@ rplinit(int argc, char *argv[], unsigned
 		return(EXIT_FAILURE);
 	}
 
+#	ifndef _BROKEN_SIGINFO
 	action.sa_sigaction = interruption2;
+#	else
+	action.sa_handler = interruption2;
+#	endif
 	action.sa_flags = SA_NODEFER | SA_ONSTACK | SA_SIGINFO;
 
 	if (sigaction(SIGTSTP, &action, NULL) != 0)
@@ -394,8 +460,12 @@ rplinit(int argc, char *argv[], unsigned
 		return(EXIT_FAILURE);
 	}
 
+#	ifndef _BROKEN_SIGINFO
 	action.sa_sigaction = interruption4;
-	action.sa_flags = SA_ONSTACK | SA_SIGINFO;
+#	else
+	action.sa_handler = interruption4;
+#	endif
+	action.sa_flags = SA_ONSTACK | SA_SIGINFO | SA_NODEFER;
 
 	if (sigaction(SIGSTART, &action, NULL) != 0)
 	{
@@ -427,7 +497,11 @@ rplinit(int argc, char *argv[], unsigned
 		return(EXIT_FAILURE);
 	}
 
+#	ifndef _BROKEN_SIGINFO
 	action.sa_sigaction = interruption5;
+#	else
+	action.sa_handler = interruption5;
+#	endif
 	action.sa_flags = SA_NODEFER | SA_ONSTACK | SA_SIGINFO;
 
 	if (sigaction(SIGFSTOP, &action, NULL) != 0)
@@ -447,7 +521,11 @@ rplinit(int argc, char *argv[], unsigned
 		return(EXIT_FAILURE);
 	}
 
+#	ifndef _BROKEN_SIGINFO
 	action.sa_sigaction = interruption11;
+#	else
+	action.sa_handler = interruption11;
+#	endif
 	action.sa_flags = SA_NODEFER | SA_ONSTACK | SA_SIGINFO;
 
 	if (sigaction(SIGFABORT, &action, NULL) != 0)
@@ -467,7 +545,11 @@ rplinit(int argc, char *argv[], unsigned
 		return(EXIT_FAILURE);
 	}
 
+#	ifndef _BROKEN_SIGINFO
 	action.sa_sigaction = interruption8;
+#	else
+	action.sa_handler = interruption8;
+#	endif
 	action.sa_flags = SA_NODEFER | SA_ONSTACK | SA_SIGINFO;
 
 	if (sigaction(SIGURG, &action, NULL) != 0)
@@ -487,7 +569,11 @@ rplinit(int argc, char *argv[], unsigned
 		return(EXIT_FAILURE);
 	}
 
+#	ifndef _BROKEN_SIGINFO
 	action.sa_sigaction = interruption7;
+#	else
+	action.sa_handler = interruption7;
+#	endif
 	action.sa_flags = SA_NODEFER | SA_ONSTACK | SA_SIGINFO;
 
 	if (sigaction(SIGPIPE, &action, NULL) != 0)
@@ -507,8 +593,12 @@ rplinit(int argc, char *argv[], unsigned
 		return(EXIT_FAILURE);
 	}
 
+#	ifndef _BROKEN_SIGINFO
 	action.sa_sigaction = interruption6;
-	action.sa_flags = SA_ONSTACK | SA_SIGINFO;
+#	else
+	action.sa_handler = interruption6;
+#	endif
+	action.sa_flags = SA_ONSTACK | SA_SIGINFO | SA_NODEFER;
 
 	if (sigaction(SIGINJECT, &action, NULL) != 0)
 	{
@@ -527,8 +617,12 @@ rplinit(int argc, char *argv[], unsigned
 		return(EXIT_FAILURE);
 	}
 
+#	ifndef _BROKEN_SIGINFO
 	action.sa_sigaction = interruption9;
-	action.sa_flags = SA_ONSTACK | SA_SIGINFO;
+#	else
+	action.sa_handler = interruption9;
+#	endif
+	action.sa_flags = SA_ONSTACK | SA_SIGINFO | SA_NODEFER;
 
 	if (sigaction(SIGABORT, &action, NULL) != 0)
 	{
@@ -547,7 +641,11 @@ rplinit(int argc, char *argv[], unsigned
 		return(EXIT_FAILURE);
 	}
 
+#	ifndef _BROKEN_SIGINFO
 	action.sa_sigaction = interruption1;
+#	else
+	action.sa_handler = interruption1;
+#	endif
 	action.sa_flags = SA_NODEFER | SA_ONSTACK | SA_SIGINFO;
 
 	if (sigaction(SIGALRM, &action, NULL) != 0)
@@ -567,12 +665,13 @@ rplinit(int argc, char *argv[], unsigned
 		return(EXIT_FAILURE);
 	}
 
+#	ifndef _BROKEN_SIGINFO
 	action.sa_sigaction = interruption3;
+#	else
+	action.sa_handler = interruption3;
+#	endif
 	action.sa_flags = SA_NODEFER | SA_ONSTACK | SA_SIGINFO;
 
-	(*s_etat_processus).chemin_fichiers_temporaires =
-			recherche_chemin_fichiers_temporaires(s_etat_processus);
-
 	erreur = d_absence_erreur;
 	core = d_faux;
 	mode_interactif = d_faux;
@@ -1495,8 +1594,12 @@ rplinit(int argc, char *argv[], unsigned
 
 		if (option_n == d_vrai)
 		{
+#			ifndef _BROKEN_SIGINFO
 			action.sa_sigaction = interruption10;
-			action.sa_flags = SA_ONSTACK | SA_SIGINFO;
+#			else
+			action.sa_handler = interruption10;
+#			endif
+			action.sa_flags = SA_ONSTACK | SA_SIGINFO | SA_NODEFER;
 
 			if (sigaction(SIGHUP, &action, NULL) != 0)
 			{
@@ -1861,6 +1964,8 @@ rplinit(int argc, char *argv[], unsigned
 			}
 
 			(*s_etat_processus).at_exit = NULL;
+			(*s_etat_processus).at_poke = NULL;
+			(*s_etat_processus).traitement_at_poke = 'N';
 
 			(*s_etat_processus).pointeurs_caracteres = NULL;
 			(*s_etat_processus).arbre_instructions = NULL;
@@ -1869,6 +1974,7 @@ rplinit(int argc, char *argv[], unsigned
 			(*s_etat_processus).pid_processus_pere = getpid();
 			(*s_etat_processus).processus_detache = d_vrai;
 			(*s_etat_processus).var_volatile_processus_pere = -1;
+			(*s_etat_processus).var_volatile_processus_racine = -1;
 			(*s_etat_processus).var_volatile_traitement_retarde_stop = 0;
 			(*s_etat_processus).var_volatile_alarme = 0;
 			(*s_etat_processus).var_volatile_requete_arret = 0;
@@ -1897,7 +2003,7 @@ rplinit(int argc, char *argv[], unsigned
 			}
 
 			if (((*s_etat_processus).instruction_derniere_erreur =
-					malloc(2 * sizeof(unsigned char))) == NULL)
+					malloc(sizeof(unsigned char))) == NULL)
 			{
 				erreur = d_es_allocation_memoire;
 
@@ -1948,7 +2054,7 @@ rplinit(int argc, char *argv[], unsigned
 
 			free((*s_etat_processus).instruction_courante);
 
-			if ((*s_etat_processus).erreur_systeme == d_es_allocation_memoire)
+			if ((*s_etat_processus).erreur_systeme != d_es)
 			{
 				erreur = d_es_allocation_memoire;
 			}
@@ -2653,11 +2759,11 @@ rplinit(int argc, char *argv[], unsigned
 										(*s_etat_processus).at_exit, 'E');
 							}
 						}
-
-						liberation(s_etat_processus,
-								(*s_etat_processus).at_exit);
 					}
 
+					liberation(s_etat_processus, (*s_etat_processus).at_exit);
+					liberation(s_etat_processus, (*s_etat_processus).at_poke);
+
 					if ((*s_etat_processus).generateur_aleatoire != NULL)
 					{
 						liberation_generateur_aleatoire(s_etat_processus);
@@ -3399,8 +3505,6 @@ rplinit(int argc, char *argv[], unsigned
 						l_element_courant = l_element_suivant;
 					}
 
-					free((*s_etat_processus).chemin_fichiers_temporaires);
-
 					l_element_courant = (*s_etat_processus).s_marques;
 					while(l_element_courant != NULL)
 					{
@@ -3452,7 +3556,7 @@ rplinit(int argc, char *argv[], unsigned
 		}
 	}
 
-#	ifndef Cygwin
+#	if !defined(Cygwin) && !defined(OpenBSD)
 	(*s_etat_processus).pile_signal.ss_flags = SS_DISABLE;
 	sigaltstack(&((*s_etat_processus).pile_signal), NULL);
 	free((*s_etat_processus).pile_signal.ss_sp);
@@ -3467,6 +3571,8 @@ rplinit(int argc, char *argv[], unsigned
 	retrait_thread(s_etat_processus);
 
 	pthread_mutex_destroy(&((*s_etat_processus).mutex));
+	pthread_mutex_destroy(&((*s_etat_processus).mutex_allocation));
+
 #	ifndef SEMAPHORES_NOMMES
 	sem_post(&((*s_etat_processus).semaphore_fork));
 	sem_destroy(&((*s_etat_processus).semaphore_fork));
@@ -3493,6 +3599,12 @@ rplinit(int argc, char *argv[], unsigned
 			sem_gestionnaires_signaux_atomique);
 #	endif
 
+#	ifdef _BROKEN_SIGINFO
+	destruction_fifos_signaux(s_etat_processus);
+#	undef return
+#	endif
+
+	free((*s_etat_processus).chemin_fichiers_temporaires);
 	free(s_etat_processus);
 
 #	ifdef DEBUG_MEMOIRE