--- rpl/src/rpl.h	2011/09/14 14:34:28	1.120
+++ rpl/src/rpl.h	2011/09/26 15:57:17	1.133
@@ -1,6 +1,6 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.1.3
+  RPL/2 (R) version 4.1.4
   Copyright (C) 1989-2011 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
@@ -122,16 +122,20 @@
 				ULONG	*nopened;
 				ULONG	allocated;
 			} sem_t;
-#		else
+#		else // IPCS_SYSV
 			typedef struct
 		   	{
 				int				sem;
+				int				alloue;
 				unsigned char	*path;
 				pid_t			pid;
+				pthread_t		tid;
 			} sem_t;
 #		endif
 
-#		define SEM_FAILED	NULL
+#		ifndef SEM_FAILED
+#			define SEM_FAILED	NULL
+#		endif
 
 		sem_t *sem_open_SysV(const char *nom, int oflag, ...);
 		int sem_init_SysV(sem_t *sem, int shared, unsigned int value);
@@ -158,6 +162,7 @@
 
 #	include "openssl/evp.h"
 #	include "sqlite3.h"
+#	include "sigsegv.h"
 
 #	define HAVE_INLINE
 #	define GSL_RANGE_CHECK_OFF
@@ -211,7 +216,7 @@
 
 enum signaux_rpl
 {
-	rpl_null = 0,
+	rpl_signull = 0,
 	rpl_sigint,
 	rpl_sigterm,
 	rpl_sigstart,		// Signal envoyé par un père pour lancer son fils.
@@ -227,6 +232,7 @@ enum signaux_rpl
 	rpl_sigalrm,		// Signal d'alarme (erreur système) depuis un fils
 	rpl_sighup,
 	rpl_sigtstp,
+	rpl_sigexcept,
 	rpl_sigmax
 };
 
@@ -236,9 +242,16 @@ enum signaux_rpl
 // Elle est projetée dans un segment de mémoire partagée pour qu'elle soit
 // accessible à la fois du père et des fils.
 
+#ifndef RPLARGS
 typedef struct queue_signaux
 {
-	pthread_mutex_t				mutex;
+#	ifndef IPCS_SYSV
+#		ifndef SEMAPHORES_NOMMES
+			sem_t				semaphore;
+#		endif
+#	else
+		sem_t					semaphore;
+#	endif
 
 	volatile int				pointeur_lecture;
 	volatile int				pointeur_ecriture;
@@ -250,11 +263,18 @@ typedef struct queue_signaux
 	}							queue[LONGUEUR_QUEUE_SIGNAUX];
 } struct_queue_signaux;
 
-#ifndef RPLARGS
 #	ifndef MAIN_RPL
 		extern struct_queue_signaux			*s_queue_signaux;
+		extern int							f_queue_signaux;
+#		ifdef SEMAPHORES_NOMMES
+			extern sem_t					*semaphore_queue_signaux;
+#		endif
 #	else
 		struct_queue_signaux				*s_queue_signaux;
+		int									f_queue_signaux;
+#		ifdef SEMAPHORES_NOMMES
+			sem_t							*semaphore_queue_signaux;
+#		endif
 #	endif
 #endif
 
@@ -280,6 +300,13 @@ union semun
 };
 #endif
 
+#ifndef RTLD_LOCAL
+#	define RTLD_LOCAL		0
+#endif
+
+#ifndef SIGSTKSZ
+#	define SIGSTKSZ			65536
+#endif
 
 /*
 ================================================================================
@@ -384,7 +411,8 @@ typedef unsigned char			t_8_bits;
 #	endif
 
 #	ifndef MAIN_RPL
-		extern jmp_buf				contexte;
+		extern jmp_buf				contexte_ecriture;
+		extern jmp_buf				contexte_impression;
 		extern jmp_buf				contexte_initial;
 		extern jmp_buf				contexte_processus;
 		extern jmp_buf				contexte_thread;
@@ -397,36 +425,19 @@ typedef unsigned char			t_8_bits;
 		extern pthread_mutex_t		mutex_sem;
 #		endif
 
-		extern pthread_key_t		semaphore_fork_processus_courant;
-
-		extern sem_t
-#		ifdef SEMAPHORES_NOMMES
-		*
-#		endif
-									semaphore_liste_threads;
+		extern pthread_mutex_t		mutex_liste_threads;
+		extern pthread_mutex_t		mutex_gestionnaires_signaux_atomique;
 
 		extern sem_t
 #		ifdef SEMAPHORES_NOMMES
-		*
+			*
 #		endif
 									semaphore_gestionnaires_signaux;
 
-		extern sem_t
-#		ifdef SEMAPHORES_NOMMES
-		*
-#		endif
-									semaphore_gestionnaires_signaux_atomique;
-
-#		ifdef SEMAPHORES_NOMMES
-		// 0 -> liste_threads
-		// 1 -> gestionnaire_signaux
-		// 2 -> gestionnaire_signaux_atomique
-		// 3 -> &((*s_etat_processus).semaphore_fork)
-			extern unsigned char	noms_semaphores[4][LONGUEUR_NOM_SEMAPHORE];
-			extern sem_t			*semaphores_nommes[4];
-#		endif
+		extern volatile int			routine_recursive;
 #	else
-		jmp_buf						contexte;
+		jmp_buf						contexte_ecriture;
+		jmp_buf						contexte_impression;
 		jmp_buf						contexte_initial;
 		jmp_buf						contexte_processus;
 		jmp_buf						contexte_thread;
@@ -439,42 +450,36 @@ typedef unsigned char			t_8_bits;
 		pthread_mutex_t				mutex_sem = PTHREAD_MUTEX_INITIALIZER;
 #		endif
 
-		pthread_key_t				semaphore_fork_processus_courant;
-
-		sem_t
-#		ifdef SEMAPHORES_NOMMES
-		*
-#		endif
-									semaphore_liste_threads;
-
+		pthread_mutex_t				mutex_liste_threads =
+											PTHREAD_MUTEX_INITIALIZER;
+		pthread_mutex_t				mutex_gestionnaires_signaux =
+											PTHREAD_MUTEX_INITIALIZER;
+		pthread_mutex_t				mutex_gestionnaires_signaux_atomique =
+											PTHREAD_MUTEX_INITIALIZER;
 		sem_t
 #		ifdef SEMAPHORES_NOMMES
-		*
+			*
 #		endif
 									semaphore_gestionnaires_signaux;
 
-		sem_t
-#		ifdef SEMAPHORES_NOMMES
-		*
-#		endif
-									semaphore_gestionnaires_signaux_atomique;
-
-#		ifdef SEMAPHORES_NOMMES
-			unsigned char			noms_semaphores[4][LONGUEUR_NOM_SEMAPHORE];
-			sem_t					*semaphores_nommes[4];
-#		endif
+		volatile int				routine_recursive;
 #	endif
 #endif
 
 #ifdef SEMAPHORES_NOMMES
-enum t_semaphore	{ sem_liste_threads = 0,
-		sem_gestionnaires_signaux = 1,
-		sem_gestionnaires_signaux_atomique = 2,
-		sem_fork = 3 };
-
-sem_t *sem_init2(unsigned int valeur, enum t_semaphore semaphore);
-int sem_destroy2(sem_t *semaphore_p, enum t_semaphore semaphore);
+#define SEM_FORK			0
+#define	SEM_QUEUE			1
+#define	SEM_SIGNAUX			2
+sem_t *sem_init2(unsigned int valeur, pid_t pid, int ordre);
+sem_t *sem_init3(unsigned int valeur, pid_t pid, pthread_t tid, int ordre);
+int sem_destroy2(sem_t *semaphore_p, pid_t pid, int ordre);
+int sem_destroy3(sem_t *semaphore_p, pid_t pid, pthread_t tid, int ordre);
 int sem_getvalue2(sem_t *semaphore, int *valeur);
+sem_t *sem_open2(pid_t pid, int ordre);
+
+// Le mutex est là uniquement pour pouvoir émuler le comportement
+// de sem_getvalue() sur un système comme MacOS X qui ne possède pas
+// cette fonction.
 
 #define sem_getvalue(semaphore, value) sem_getvalue2(semaphore, value)
 #define sem_post(semaphore) \
@@ -506,10 +511,6 @@ int sem_getvalue2(sem_t *semaphore, int
 #define ufprintf(flux, ...) transliterated_fprintf(NULL, \
 			flux, __VA_ARGS__)
 
-// Tous les messages pour DISP, INPUT et les E/S par readline sont sur stderr.
-// Cela évite aux messages envoyés par les gestionnaires de signaux d'être
-// indéfiniment bloqués.
-
 #ifdef SunOS
 #	define fopen(...) ({ FILE *desc; \
 	        while((desc = fopen(__VA_ARGS__)) == NULL) \
@@ -1833,20 +1834,6 @@ typedef struct processus
 	pthread_t					thread_fusible;
 	pthread_t					thread_surveille_par_fusible;
 
-#	if !defined(Cygwin)
-#		if !(OpenBSD)
-			stack_t				pile_signal;
-#		else
-#			ifdef SA_ONSTACK
-#				undef SA_ONSTACK
-#			endif
-#			define SA_ONSTACK	0
-#		endif
-#	else
-#		define SA_ONSTACK		0
-#		define RTLD_LOCAL		0
-#	endif
-
 	volatile int				pointeur_signal_ecriture;
 	volatile int				pointeur_signal_lecture;
 	volatile enum signaux_rpl	signaux_en_queue[LONGUEUR_QUEUE_SIGNAUX];
@@ -2067,7 +2054,6 @@ typedef struct processus
 
 /* Traitement des erreurs								*/
 
-	unsigned int				compteur_violation_d_acces;
 	unsigned int				erreur_compilation;
 	unsigned int				erreur_execution;
 	unsigned int				erreur_systeme;
@@ -2179,7 +2165,6 @@ typedef struct processus
 
 	pid_t						pid_processus_pere;
 	pthread_t					tid_processus_pere;
-	pthread_t					tid_courant;
 
 	logical1					processus_detache;
 
@@ -2195,12 +2180,12 @@ typedef struct processus
 	pthread_mutex_t				mutex;
 	pthread_mutex_t				mutex_allocation;
 
-	// Sémaphore autorisant les fork()
+	// Mutex autorisant les fork()
 	sem_t
 #	ifdef SEMAPHORES_NOMMES
-	*
+		*
 #	endif
-								semaphore_fork;
+		 						semaphore_fork;
 
 /* Mutexes											*/
 
@@ -2920,6 +2905,7 @@ void interruption2(int signal);
 void interruption3(int signal);
 void interruption4(int signal);
 void interruption5(int signal);
+void interruption_depassement_pile(int urgence, stackoverflow_context_t scp);
 void inversion_matrice(struct_processus *s_etat_processus,
 		struct_matrice *s_matrice);
 void lancement_daemon(struct_processus *s_etat_processus);
@@ -2953,7 +2939,11 @@ void retrait_thread(struct_processus *s_
 void retrait_thread_surveillance(struct_processus *s_etat_processus,
 		struct_descripteur_thread *s_argument_thread);
 void rplcore(struct_processus *s_etat_processus);
+#endif
+
 void scrutation_injection(struct_processus *s_etat_processus);
+
+#ifndef RPLARGS
 void scrutation_interruptions(struct_processus *s_etat_processus);
 void sf(struct_processus *s_etat_processus, unsigned char indice_drapeau);
 void *surveillance_processus(void *argument);
@@ -3208,11 +3198,14 @@ ssize_t write_atomic(struct_processus *s
 */
 
 int alsprintf(unsigned char **strp, const char *fmt, ...);
+int interruption_violation_access(void *adresse_fautive, int gravite);
+#ifndef RPLARGS
 int liste_variables(struct_processus *s_etat_processus,
 		struct_tableau_variables *tableau, int position,
 		struct_arbre_variables *l_element_courant);
 int nombre_variables(struct_processus *s_etat_processus,
 		struct_arbre_variables *l_element_courant);
+#endif
 int tex_fprintf(struct_processus *s_etat_processus,
 		file *flux, const char *format, ...);
 int transliterated_fprintf(struct_processus *s_etat_processus, file *flux,
@@ -3294,8 +3287,8 @@ struct_descripteur_fichier *descripteur_
 struct_objet *copie_objet(struct_processus *s_etat_processus,
 		struct_objet *s_objet, unsigned char type);
 
-#ifndef RPLARGS
 struct_objet *allocation(struct_processus *s_etat_processus, enum t_type type);
+#ifndef RPLARGS
 struct_objet *formateur_date(struct_processus *s_etat_processus,
 		struct timeval *temps);
 struct_objet *lecture_pipe(struct_processus *s_etat_processus, int pipe);