--- rpl/src/rpl.h	2016/03/01 22:12:36	1.283
+++ rpl/src/rpl.h	2017/07/30 22:00:22	1.312
@@ -1,7 +1,7 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.1.25
-  Copyright (C) 1989-2016 Dr. BERTRAND Joël
+  RPL/2 (R) version 4.1.27
+  Copyright (C) 1989-2017 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
 
@@ -64,6 +64,16 @@
 #	define SA_ONSTACK	0
 #endif
 
+#ifdef BROKEN_SIGSEGV
+#	undef HAVE_STACK_OVERFLOW_RECOVERY
+#	undef HAVE_SIGSEGV_RECOVERY
+#endif
+
+#define DEBUG_TRACE		uprintf("[%d/%X] %s(%d)\n", \
+		getpid(), pthread_self(), __FILE__, __LINE__);
+#define TEST_ABSENCE_FICHIER(nom) \
+		{ int ios; struct stat *buf; ios = stat(nom, buf); \
+			if (ios == 0) BUG(1, uprintf("File %s found!\n", nom)); }
 
 /*
 ================================================================================
@@ -210,7 +220,11 @@
 #	endif
 
 #	include "sqlite3.h"
-#	include "sigsegv.h"
+
+#	ifndef BROKEN_SIGSEGV
+#		include "sigsegv.h"
+#	endif
+
 #	ifdef OS2
 		// Bug de libsigsegv
 #		undef HAVE_STACK_OVERFLOW_RECOVERY
@@ -267,6 +281,7 @@
 #	define __STATIC_MUTEX_INITIALIZATION__
 #endif
 
+
 /*
 ================================================================================
   Bugs spécifiques
@@ -523,6 +538,7 @@ union semun
 	__EXTERN__ pthread_mutex_t		mutex_sem __STATIC_MUTEX_INITIALIZATION__;
 
 	__EXTERN__ volatile int			routine_recursive;
+	__EXTERN__ volatile int			nombre_thread_surveillance_processus;
 
 #	define SEM_FORK					0
 #	define SEM_QUEUE				1
@@ -590,26 +606,6 @@ union semun
 #	define fflush(flux) fflush((flux == stdout) ? stderr : flux)
 #endif
 
-// Ajout d'un timeout sur les fonctions pipe() pour éviter une erreur
-// système dans le cas où l'on a atteint le nombre maximale de fichiers
-// ouverts.
-
-#define pipe(descripteurs) \
-	({ \
-		struct timespec temporisation; \
-		int erreur, nombre_echecs; \
-		nombre_echecs = 0; \
-		do \
-		{ \
-			if ((erreur = pipe(descripteurs)) == 0) break; \
-			nombre_echecs++; \
-			temporisation.tv_sec = 0; \
-			temporisation.tv_nsec = ((long) 1000000000) * rand(); \
-			nanosleep(&temporisation, NULL); \
-		} while(nombre_echecs < 100); \
-		erreur; \
-	 })
-
 // Redéfinition de abs pour un fonctionnement en entier de type long long int
 
 #ifdef __GNUC__
@@ -632,9 +628,9 @@ union semun
 	} while(0)
 
 #ifdef __GLIBC__
-#include <execinfo.h>
-#define __BACKTRACE
-#define BACKTRACE(n) \
+#	include <execinfo.h>
+#	define __BACKTRACE
+#	define BACKTRACE(n) \
 	do \
 	{ \
 		void    		*buffer[n]; \
@@ -659,7 +655,7 @@ union semun
 		pthread_mutex_unlock(&mutex); \
 	} while(0)
 #else
-#define BACKTRACE(n) NOTICE("BACKTRACE only defined in glibc")
+#	define BACKTRACE(n) NOTICE("BACKTRACE only defined in glibc")
 #endif
 
 #ifdef __BACKTRACE
@@ -705,18 +701,18 @@ pid_t debug_fork();
 #endif
 
 #ifdef DEBUG_RETURN
-#define return uprintf("[%d] Return from <%s()> at line #%d " \
+#	define return uprintf("[%d] Return from <%s()> at line #%d " \
 		"(%s [%d])\n", (int) getpid(), __FUNCTION__, \
 		__LINE__, strerror(errno), errno); fflush(stdout); errno = 0; return
 #endif
 
 #ifdef DEBUG_MUTEX
-#define pthread_mutex_lock(mutex) uprintf("[%d-%llu] Mutex %s (%p) " \
+#	define pthread_mutex_lock(mutex) uprintf("[%d-%llu] Mutex %s (%p) " \
 		"locking at %s() " \
 		"line #%d\n", (int) getpid(), (unsigned long long) pthread_self(), \
 		#mutex, mutex, __FUNCTION__, __LINE__), fflush(stdout), \
 		pthread_mutex_lock(mutex)
-#define pthread_mutex_unlock(mutex) uprintf("[%d-%llu] Mutex %s (%p) " \
+#	define pthread_mutex_unlock(mutex) uprintf("[%d-%llu] Mutex %s (%p) " \
 		"unlocking at " \
 		"%s() line #%d\n", (int) getpid(), (unsigned long long) \
 		pthread_self(), #mutex, mutex, __FUNCTION__, __LINE__), \
@@ -810,16 +806,48 @@ pid_t debug_fork();
 #		else
 #			define __erreur_(i)	i
 #		endif
-#		define __erreur(i)	({ if (strstr(__FUNCTION__, "recherche_variable") \
-				== NULL) ufprintf(stderr, \
-				"ERROR %d AT %s() FROM %s LINE %d\n", \
-				i, __FUNCTION__, __FILE__, __LINE__); i; })
+#		define __erreur(i)	({ int ios; ios = errno; \
+				if (strstr(__FUNCTION__, "recherche_variable") \
+				== NULL) { if(ios != 0) \
+				ufprintf(stderr, "LAST ERROR: %s\n", strerror(ios)); \
+				ufprintf(stderr, "ERROR %d AT %s() FROM %s LINE %d\n", \
+				i, __FUNCTION__, __FILE__, __LINE__); BACKTRACE(16); } i; })
 #	endif
 #else
 #	define __erreur(i)	i
 #	define __erreur_(i)	i
 #endif
 
+#ifdef DEBUG_FICHIERS
+#	define open(a, ...) \
+		({ ufprintf(stderr, "[%d] OPEN %s AT %s() FROM %s LINE %d\n", \
+		getpid(), a, \
+		__FUNCTION__, __FILE__, __LINE__); open(a, __VA_ARGS__); })
+#	define pipe(a) \
+		({ ufprintf(stderr, "[%d] PIPE %s AT %s() FROM %s LINE %d\n", \
+		getpid(), a, \
+		__FUNCTION__, __FILE__, __LINE__); pipe(a); })
+#	define shm_open(a, ...) \
+		({ ufprintf(stderr, "[%d] SHM_OPEN %s AT %s() FROM %s LINE %d\n", \
+		getpid(), a, \
+		__FUNCTION__, __FILE__, __LINE__); shm_open(a, __VA_ARGS__); })
+#	define shm_unlink(a) \
+		({ ufprintf(stderr, "[%d] SHM_UNLINK %s AT %s() FROM %s LINE %d\n", \
+		getpid(), a, \
+		__FUNCTION__, __FILE__, __LINE__); shm_unlink(a); })
+#	define sem_open(a, ...) \
+		({ ufprintf(stderr, "[%d] SEM_OPEN %s AT %s() FROM %s LINE %d\n", \
+		getpid(), a, \
+		__FUNCTION__, __FILE__, __LINE__); sem_open(a, __VA_ARGS__); })
+#	define sem_unlink(a) \
+		({ ufprintf(stderr, "[%d] SEM_UNLINK %s AT %s() FROM %s LINE %d\n", \
+		getpid(), a, \
+		__FUNCTION__, __FILE__, __LINE__); sem_unlink(a); })
+#	define close(a) \
+		({ ufprintf(stderr, "[%d] CLOSE %s AT %s() FROM %s LINE %d\n", \
+		getpid(), a, \
+		__FUNCTION__, __FILE__, __LINE__); close(a); })
+#endif
 
 // -1 : erreur provoquée par une bibliothèque externe
 #ifndef RPLARGS
@@ -986,6 +1014,8 @@ pid_t debug_fork();
 #	define d_ex_chiffrement_indisponible		__erreur(90)
 #	define d_ex_longueur_clef_chiffrement		__erreur(91)
 #	define d_ex_taille_message					__erreur(92)
+#	define d_ex_type_externe_dup				__erreur(93)
+#	define d_ex_type_externe_drop				__erreur(94)
 #endif
 
 
@@ -1014,6 +1044,7 @@ pid_t debug_fork();
 #define BIN	__RPL_BIN
 #define CHN	__RPL_CHN
 #define CPL	__RPL_CPL
+#define EXT	__RPL_EXT
 #define FCH	__RPL_FCH
 #define FCT	__RPL_FCT
 #define INT	__RPL_INT
@@ -1039,7 +1070,7 @@ pid_t debug_fork();
 
 enum t_rplcas_commandes		{ RPLCAS_INTEGRATION = 0, RPLCAS_LIMITE };
 
-enum t_type		{ ADR = 0, ALG, BIN, CHN, CPL, FCH, FCT, INT, LST,
+enum t_type		{ ADR = 0, ALG, BIN, CHN, CPL, EXT, FCH, FCT, INT, LST,
 				MCX, MIN, MRL, MTX, NOM, NON, PRC, REC, REL, RPN, SCK,
 				SLB, SPH, SQL, TBL, VCX, VIN, VRL };
 
@@ -1063,6 +1094,8 @@ enum t_type		{ ADR = 0, ALG, BIN, CHN, C
 			Sans objet.
 			Type C/Fortran : complex16
 
+	EXT : type géré dans une bibliothèque externe.
+
 	FCH : descripteur de fichier (struct_fichier *).
 
 	FCT : déclaration d'une fonction et de son nombre d'arguments
@@ -1128,6 +1161,8 @@ enum t_type		{ ADR = 0, ALG, BIN, CHN, C
 typedef struct objet
 {
 	enum t_type			type;
+	integer8			extension_type;
+	void				*descripteur_bibliotheque;
 
 	volatile long		nombre_occurrences;
 
@@ -2449,8 +2484,8 @@ typedef struct processus
 			variables_tableau_noeuds_partages)
 
 	CACHE2(struct_buffer, enveloppes_buffers)
-	unsigned char		***cache_buffer;
-	int					*pointeur_cache_buffer;
+	unsigned char				***cache_buffer;
+	int							*pointeur_cache_buffer;
 } struct_processus;
 #endif
 
@@ -3130,7 +3165,10 @@ void interruption3(int signal);
 void interruption4(int signal);
 void interruption5(int signal);
 void interruption6(int signal);
-void interruption_depassement_pile(int urgence, stackoverflow_context_t scp);
+#ifdef HAVE_SIGSEGV_RECOVERY
+	void interruption_depassement_pile(int urgence,
+			stackoverflow_context_t scp);
+#endif
 void inversion_matrice(struct_processus *s_etat_processus,
 		struct_matrice *s_matrice);
 void lancement_daemon(struct_processus *s_etat_processus);
@@ -3214,7 +3252,8 @@ void liberation_queue_signaux(struct_pro
 void destruction_queue_signaux(struct_processus *s_etat_processus);
 int envoi_signal_contexte(struct_processus *s_etat_processus,
 		enum signaux_rpl signal);
-int envoi_signal_processus(pid_t pid, enum signaux_rpl signal);
+int envoi_signal_processus(pid_t pid, enum signaux_rpl signal,
+		logical1 test_ouverture);
 int envoi_signal_thread(pthread_t tid, enum signaux_rpl signal);
 #endif
 
@@ -3408,7 +3447,8 @@ logical1 retrait_variable_statique(struc
 logical1 retrait_variables_statiques_locales(
 		struct_processus *s_etat_processus);
 logical1 sequenceur(struct_processus *s_etat_processus);
-logical1 sequenceur_optimise(struct_processus *s_etat_processus);
+logical1 sequenceur_optimise(struct_processus *s_etat_processus,
+		struct_liste_chainee *l_bibliotheques);
 #endif
 
 /*