--- rpl/src/instructions_s8.c	2012/12/21 12:09:50	1.54
+++ rpl/src/instructions_s8.c	2015/09/18 13:41:18	1.71
@@ -1,7 +1,7 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.1.12
-  Copyright (C) 1989-2012 Dr. BERTRAND Joël
+  RPL/2 (R) version 4.1.23
+  Copyright (C) 1989-2015 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
 
@@ -102,7 +102,7 @@ instruction_splash(struct_processus *s_e
 			return;
 		}
 
-		encart(s_etat_processus, (unsigned long) (attente * 1E6));
+		encart(s_etat_processus, (integer8) (attente * 1E6));
 	}
 	else
 	{
@@ -133,10 +133,6 @@ instruction_splash(struct_processus *s_e
 void
 instruction_send(struct_processus *s_etat_processus)
 {
-	pid_t						pid;
-
-	pthread_t					tid;
-
 	sig_atomic_t				registre;
 
 	ssize_t						longueur_ecriture;
@@ -145,6 +141,7 @@ instruction_send(struct_processus *s_eta
 
 	struct timespec				attente;
 
+	unsigned char				caractere;
 	unsigned char				tampon;
 
 	(*s_etat_processus).erreur_execution = d_ex;
@@ -242,11 +239,6 @@ instruction_send(struct_processus *s_eta
 			}
 		}
 
-		pid = -3;
-
-		attente.tv_sec = 0;
-		attente.tv_nsec = GRANULARITE_us * 1000;
-
 #		ifndef SEMAPHORES_NOMMES
 			if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
 #		else
@@ -257,58 +249,14 @@ instruction_send(struct_processus *s_eta
 			return;
 		}
 
-		while((longueur_ecriture = write_atomic(s_etat_processus,
-				(*s_etat_processus).pipe_nombre_objets_attente,
-				&pid, sizeof(pid))) != sizeof(pid))
-		{
-#			ifndef SEMAPHORES_NOMMES
-				while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
-#			else
-				while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
-#			endif
-			{
-				if (errno != EINTR)
-				{
-					(*s_etat_processus).erreur_systeme = d_es_processus;
-					return;
-				}
-			}
-
-			if (longueur_ecriture == -1)
-			{
-				if ((*s_etat_processus).profilage == d_vrai)
-				{
-					profilage(s_etat_processus, NULL);
-				}
-
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
-			}
-
-			nanosleep(&attente, NULL);
-			INCR_GRANULARITE(attente.tv_nsec);
-
-#			ifndef SEMAPHORES_NOMMES
-				if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
-#			else
-				if (sem_post((*s_etat_processus).semaphore_fork) != 0)
-#			endif
-			{
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
-			}
-
-			scrutation_interruptions(s_etat_processus);
-		}
-
-		pid = getpid();
+		caractere = 1;
 
 		attente.tv_sec = 0;
 		attente.tv_nsec = GRANULARITE_us * 1000;
 
 		while((longueur_ecriture = write_atomic(s_etat_processus,
-				(*s_etat_processus).pipe_nombre_objets_attente,
-				&pid, sizeof(pid))) != sizeof(pid))
+				(*s_etat_processus).pipe_nombre_elements_attente,
+				&caractere, sizeof(caractere))) != sizeof(caractere))
 		{
 #			ifndef SEMAPHORES_NOMMES
 				while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
@@ -375,8 +323,6 @@ instruction_send(struct_processus *s_eta
 			}
 		}
 
-		tid = (pthread_t) -3;
-
 		attente.tv_sec = 0;
 		attente.tv_nsec = GRANULARITE_us * 1000;
 
@@ -390,55 +336,14 @@ instruction_send(struct_processus *s_eta
 			return;
 		}
 
-		while((longueur_ecriture = write_atomic(s_etat_processus,
-				(*s_etat_processus).pipe_nombre_objets_attente,
-				&tid, sizeof(tid))) != sizeof(tid))
-		{
-#			ifndef SEMAPHORES_NOMMES
-				while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
-#			else
-				while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
-#			endif
-			{
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
-			}
-
-			if (longueur_ecriture == -1)
-			{
-				if ((*s_etat_processus).profilage == d_vrai)
-				{
-					profilage(s_etat_processus, NULL);
-				}
-
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
-			}
-
-			nanosleep(&attente, NULL);
-			INCR_GRANULARITE(attente.tv_nsec);
-
-#			ifndef SEMAPHORES_NOMMES
-				if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
-#			else
-				if (sem_post((*s_etat_processus).semaphore_fork) != 0)
-#			endif
-			{
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
-			}
-
-			scrutation_interruptions(s_etat_processus);
-		}
-
-		tid = pthread_self();
+		caractere = 1;
 
 		attente.tv_sec = 0;
 		attente.tv_nsec = GRANULARITE_us * 1000;
 
 		while((longueur_ecriture = write_atomic(s_etat_processus,
-				(*s_etat_processus).pipe_nombre_objets_attente,
-				&tid, sizeof(tid))) != sizeof(tid))
+				(*s_etat_processus).pipe_nombre_elements_attente,
+				&caractere, sizeof(caractere))) != sizeof(caractere))
 		{
 #			ifndef SEMAPHORES_NOMMES
 				while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
@@ -551,155 +456,6 @@ instruction_send(struct_processus *s_eta
 		}
 	}
 
-	// Envoi d'un PID invalide (-1) pour ne pas bloquer le thread
-	// de surveillance.
-
-	if ((*s_etat_processus).processus_detache == d_vrai)
-	{
-		pid = -1;
-
-		attente.tv_sec = 0;
-		attente.tv_nsec = GRANULARITE_us * 1000;
-
-#		ifndef SEMAPHORES_NOMMES
-			if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
-#		else
-			if (sem_post((*s_etat_processus).semaphore_fork) != 0)
-#		endif
-		{
-			(*s_etat_processus).erreur_systeme = d_es_processus;
-			return;
-		}
-
-		while((longueur_ecriture = write_atomic(s_etat_processus,
-				(*s_etat_processus).pipe_nombre_interruptions_attente,
-				&pid, sizeof(pid))) != sizeof(pid))
-		{
-#			ifndef SEMAPHORES_NOMMES
-				if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
-#			else
-				if (sem_post((*s_etat_processus).semaphore_fork) != 0)
-#			endif
-			{
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
-			}
-
-			if (longueur_ecriture == -1)
-			{
-				if ((*s_etat_processus).profilage == d_vrai)
-				{
-					profilage(s_etat_processus, NULL);
-				}
-
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
-			}
-
-			nanosleep(&attente, NULL);
-			INCR_GRANULARITE(attente.tv_nsec);
-
-#			ifndef SEMAPHORES_NOMMES
-				if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
-#			else
-				if (sem_post((*s_etat_processus).semaphore_fork) != 0)
-#			endif
-			{
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
-			}
-		}
-
-#		ifndef SEMAPHORES_NOMMES
-			while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
-#		else
-			while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
-#		endif
-		{
-			if (errno != EINTR)
-			{
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
-			}
-		}
-
-		scrutation_interruptions(s_etat_processus);
-	}
-	else
-	{
-		tid = (pthread_t) -1;
-
-		attente.tv_sec = 0;
-		attente.tv_nsec = GRANULARITE_us * 1000;
-
-#		ifndef SEMAPHORES_NOMMES
-			if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
-#		else
-			if (sem_post((*s_etat_processus).semaphore_fork) != 0)
-#		endif
-		{
-			(*s_etat_processus).erreur_systeme = d_es_processus;
-			return;
-		}
-
-		while((longueur_ecriture = write_atomic(s_etat_processus,
-				(*s_etat_processus).pipe_nombre_interruptions_attente,
-				&tid, sizeof(tid))) != sizeof(tid))
-		{
-#			ifndef SEMAPHORES_NOMMES
-				while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
-#			else
-				while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
-#			endif
-			{
-				if (errno != EINTR)
-				{
-					(*s_etat_processus).erreur_systeme = d_es_processus;
-					return;
-				}
-			}
-
-			if (longueur_ecriture == -1)
-			{
-				if ((*s_etat_processus).profilage == d_vrai)
-				{
-					profilage(s_etat_processus, NULL);
-				}
-
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
-			}
-
-			nanosleep(&attente, NULL);
-			INCR_GRANULARITE(attente.tv_nsec);
-
-#			ifndef SEMAPHORES_NOMMES
-				if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
-#			else
-				if (sem_post((*s_etat_processus).semaphore_fork) != 0)
-#			endif
-			{
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
-			}
-
-			scrutation_interruptions(s_etat_processus);
-		}
-
-#		ifndef SEMAPHORES_NOMMES
-			while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
-#		else
-			while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
-#		endif
-		{
-			if (errno != EINTR)
-			{
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
-			}
-		}
-	}
-
 	// ecriture_pipe() ne peut être interrompu par un signal.
 
 #	ifndef SEMAPHORES_NOMMES
@@ -1165,10 +921,10 @@ instruction_sqlquery(struct_processus *s
 		{
 #			ifdef POSTGRESQL_SUPPORT
 
-			unsigned int				i;
-			unsigned int				j;
-			unsigned int				nombre_colonnes;
-			unsigned int				nombre_lignes;
+			int							i;
+			int							j;
+			int							nombre_colonnes;
+			int							nombre_lignes;
 
 			logical1					presence_resultat;
 
@@ -1343,8 +1099,8 @@ instruction_sqlquery(struct_processus *s
 							else
 							{
 								if (((*(*l_element_courant_ligne).donnee).objet
-										= malloc((PQgetlength(
-										resultat_postgresql, i, j) + 1) *
+										= malloc(((size_t) (PQgetlength(
+										resultat_postgresql, i, j) + 1)) *
 										sizeof(unsigned char))) == NULL)
 								{
 									(*s_etat_processus).erreur_systeme =
@@ -1427,7 +1183,9 @@ instruction_sqlquery(struct_processus *s
 			const char					*queue;
 			const unsigned char			*resultat;
 
+			int							i;
 			int							ios;
+			int							nombre_colonnes;
 
 			logical1					presence_resultat;
 
@@ -1440,13 +1198,10 @@ instruction_sqlquery(struct_processus *s
 
 			struct timespec				attente;
 
-			unsigned int				i;
-			unsigned int				nombre_colonnes;
-
 			if (sqlite3_prepare_v2((*((struct_connecteur_sql *)
 					(*s_objet_1).objet)).descripteur.sqlite,
 					(unsigned char *) (*s_objet_2).objet,
-					strlen((unsigned char *) (*s_objet_2).objet),
+					(int) strlen((unsigned char *) (*s_objet_2).objet),
 					&ppStmt, &queue) != SQLITE_OK)
 			{
 				if (connexion_permanente == d_faux)
@@ -1765,7 +1520,8 @@ instruction_stop(struct_processus *s_eta
 		}
 		else
 		{
-			if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0)
+			if (pthread_mutex_lock(&((*s_etat_processus).mutex_pile_processus))
+					!= 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return;
@@ -1807,8 +1563,8 @@ instruction_stop(struct_processus *s_eta
 					if (pthread_mutex_lock(&((*(*((struct_processus_fils *)
 							(*s_objet).objet)).thread).mutex)) != 0)
 					{
-						if (pthread_mutex_unlock(&((*s_etat_processus).mutex))
-								!= 0)
+						if (pthread_mutex_unlock(&((*s_etat_processus)
+								.mutex_pile_processus)) != 0)
 						{
 							(*s_etat_processus).erreur_systeme = d_es_processus;
 							return;
@@ -1828,8 +1584,8 @@ instruction_stop(struct_processus *s_eta
 					if (pthread_mutex_unlock(&((*(*((struct_processus_fils *)
 							(*s_objet).objet)).thread).mutex)) != 0)
 					{
-						if (pthread_mutex_unlock(&((*s_etat_processus).mutex))
-								!= 0)
+						if (pthread_mutex_unlock(&((*s_etat_processus)
+								.mutex_pile_processus)) != 0)
 						{
 							(*s_etat_processus).erreur_systeme = d_es_processus;
 							return;
@@ -1841,7 +1597,8 @@ instruction_stop(struct_processus *s_eta
 				}
 			}
 
-			if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
+			if (pthread_mutex_unlock(&((*s_etat_processus)
+					.mutex_pile_processus)) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return;