--- rpl/src/instructions_s8.c	2010/01/26 15:22:45	1.1.1.1
+++ rpl/src/instructions_s8.c	2011/11/26 10:01:31	1.41
@@ -1,7 +1,7 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.0.9
-  Copyright (C) 1989-2010 Dr. BERTRAND Joël
+  RPL/2 (R) version 4.1.5
+  Copyright (C) 1989-2011 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
 
@@ -20,7 +20,7 @@
 */
 
 
-#include "rpl.conv.h"
+#include "rpl-conv.h"
 
 
 /*
@@ -247,7 +247,11 @@ instruction_send(struct_processus *s_eta
 		attente.tv_sec = 0;
 		attente.tv_nsec = GRANULARITE_us * 1000;
 
-		if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
+#		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;
@@ -257,7 +261,11 @@ instruction_send(struct_processus *s_eta
 				(*s_etat_processus).pipe_nombre_objets_attente,
 				&pid, sizeof(pid))) != sizeof(pid))
 		{
-			while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
+#			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)
 				{
@@ -280,11 +288,17 @@ instruction_send(struct_processus *s_eta
 			nanosleep(&attente, NULL);
 			INCR_GRANULARITE(attente.tv_nsec);
 
-			if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
+#			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();
@@ -296,7 +310,11 @@ instruction_send(struct_processus *s_eta
 				(*s_etat_processus).pipe_nombre_objets_attente,
 				&pid, sizeof(pid))) != sizeof(pid))
 		{
-			while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
+#			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)
 				{
@@ -319,14 +337,24 @@ instruction_send(struct_processus *s_eta
 			nanosleep(&attente, NULL);
 			INCR_GRANULARITE(attente.tv_nsec);
 
-			if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
+#			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);
 		}
 
-		while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
+#		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)
 			{
@@ -352,7 +380,11 @@ instruction_send(struct_processus *s_eta
 		attente.tv_sec = 0;
 		attente.tv_nsec = GRANULARITE_us * 1000;
 
-		if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
+#		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;
@@ -362,13 +394,14 @@ instruction_send(struct_processus *s_eta
 				(*s_etat_processus).pipe_nombre_objets_attente,
 				&tid, sizeof(tid))) != sizeof(tid))
 		{
-			while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
+#			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;
-				}
+				(*s_etat_processus).erreur_systeme = d_es_processus;
+				return;
 			}
 
 			if (longueur_ecriture == -1)
@@ -385,11 +418,17 @@ instruction_send(struct_processus *s_eta
 			nanosleep(&attente, NULL);
 			INCR_GRANULARITE(attente.tv_nsec);
 
-			if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
+#			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();
@@ -401,7 +440,11 @@ instruction_send(struct_processus *s_eta
 				(*s_etat_processus).pipe_nombre_objets_attente,
 				&tid, sizeof(tid))) != sizeof(tid))
 		{
-			while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
+#			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)
 				{
@@ -424,20 +467,27 @@ instruction_send(struct_processus *s_eta
 			nanosleep(&attente, NULL);
 			INCR_GRANULARITE(attente.tv_nsec);
 
-			if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
+#			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);
 		}
 
-		while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
+#		ifndef SEMAPHORES_NOMMES
+			if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
+#		else
+			if (sem_post((*s_etat_processus).semaphore_fork) != 0)
+#		endif
 		{
-			if (errno != EINTR)
-			{
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
-			}
+			(*s_etat_processus).erreur_systeme = d_es_processus;
+			return;
 		}
 	}
 
@@ -446,7 +496,11 @@ instruction_send(struct_processus *s_eta
 	attente.tv_sec = 0;
 	attente.tv_nsec = GRANULARITE_us * 1000;
 
-	if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
+#	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;
@@ -455,7 +509,11 @@ instruction_send(struct_processus *s_eta
 	while(read_atomic(s_etat_processus, (*s_etat_processus).pipe_acquittement,
 			&tampon, sizeof(unsigned char)) != sizeof(unsigned char))
 	{
-		while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
+#		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)
 			{
@@ -467,14 +525,24 @@ instruction_send(struct_processus *s_eta
 		nanosleep(&attente, NULL);
 		INCR_GRANULARITE(attente.tv_nsec);
 
-		if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
+#		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);
 	}
 
-	while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
+#	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)
 		{
@@ -493,7 +561,11 @@ instruction_send(struct_processus *s_eta
 		attente.tv_sec = 0;
 		attente.tv_nsec = GRANULARITE_us * 1000;
 
-		if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
+#		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;
@@ -503,13 +575,14 @@ instruction_send(struct_processus *s_eta
 				(*s_etat_processus).pipe_nombre_interruptions_attente,
 				&pid, sizeof(pid))) != sizeof(pid))
 		{
-			while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
+#			ifndef SEMAPHORES_NOMMES
+				if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
+#			else
+				if (sem_post((*s_etat_processus).semaphore_fork) != 0)
+#			endif
 			{
-				if (errno != EINTR)
-				{
-					(*s_etat_processus).erreur_systeme = d_es_processus;
-					return;
-				}
+				(*s_etat_processus).erreur_systeme = d_es_processus;
+				return;
 			}
 
 			if (longueur_ecriture == -1)
@@ -526,14 +599,22 @@ instruction_send(struct_processus *s_eta
 			nanosleep(&attente, NULL);
 			INCR_GRANULARITE(attente.tv_nsec);
 
-			if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
+#			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(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
+#		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)
 			{
@@ -541,6 +622,8 @@ instruction_send(struct_processus *s_eta
 				return;
 			}
 		}
+
+		scrutation_interruptions(s_etat_processus);
 	}
 	else
 	{
@@ -549,7 +632,11 @@ instruction_send(struct_processus *s_eta
 		attente.tv_sec = 0;
 		attente.tv_nsec = GRANULARITE_us * 1000;
 
-		if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
+#		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;
@@ -559,7 +646,11 @@ instruction_send(struct_processus *s_eta
 				(*s_etat_processus).pipe_nombre_interruptions_attente,
 				&tid, sizeof(tid))) != sizeof(tid))
 		{
-			while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
+#			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)
 				{
@@ -582,14 +673,24 @@ instruction_send(struct_processus *s_eta
 			nanosleep(&attente, NULL);
 			INCR_GRANULARITE(attente.tv_nsec);
 
-			if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
+#			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);
 		}
 
-		while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
+#		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)
 			{
@@ -601,7 +702,11 @@ instruction_send(struct_processus *s_eta
 
 	// ecriture_pipe() ne peut être interrompu par un signal.
 
-	if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
+#	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;
@@ -610,7 +715,11 @@ instruction_send(struct_processus *s_eta
 	if (ecriture_pipe(s_etat_processus, (*s_etat_processus).pipe_donnees,
 			s_objet) == d_erreur)
 	{
-		while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
+#		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)
 			{
@@ -628,7 +737,11 @@ instruction_send(struct_processus *s_eta
 		return;
 	}
 
-	while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
+#	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)
 		{
@@ -674,25 +787,17 @@ instruction_sqlquery(struct_processus *s
 {
 #	define							d_LONGUEUR	1024
 
+#	if defined(MYSQL_SUPPORT) || defined(POSTGRESQL_SUPPORT)
 	logical1						connexion_permanente;
-	logical1						presence_resultat;
+#	endif
 
 	struct_objet					*s_copie_1;
 	struct_objet					*s_objet_1;
 	struct_objet					*s_copie_2;
 	struct_objet					*s_objet_2;
-	struct_objet					*s_objet_resultat;
-
-	struct_liste_chainee			*l_element_courant;
-	struct_liste_chainee			*l_element_courant_ligne;
 
 	unsigned char					*tampon;
 
-	unsigned int					i;
-	unsigned int					j;
-	unsigned int					nombre_colonnes;
-	unsigned int					nombre_lignes;
-
 	(*s_etat_processus).erreur_execution = d_ex;
 
 	if ((*s_etat_processus).affichage_arguments == 'Y')
@@ -767,7 +872,9 @@ instruction_sqlquery(struct_processus *s
 
 	if ((*s_objet_1).type == LST)
 	{
+#	if defined(MYSQL_SUPPORT) || defined(POSTGRESQL_SUPPORT)
 		connexion_permanente = d_faux;
+#	endif
 
 		s_copie_1 = s_objet_1;
 
@@ -797,7 +904,9 @@ instruction_sqlquery(struct_processus *s
 			}
 		}
 
+#	if defined(MYSQL_SUPPORT) || defined(POSTGRESQL_SUPPORT)
 		connexion_permanente = d_vrai;
+#	endif
 	}
 
 	if (((*s_objet_1).type == SQL) && ((*s_objet_2).type == CHN))
@@ -839,8 +948,18 @@ instruction_sqlquery(struct_processus *s
 		{
 #			ifdef MYSQL_SUPPORT
 
-			MYSQL_RES		*resultat_mysql;
-			MYSQL_ROW		ligne;
+			unsigned int				i;
+			unsigned int				nombre_colonnes;
+
+			logical1					presence_resultat;
+
+			MYSQL_RES					*resultat_mysql;
+			MYSQL_ROW					ligne;
+
+			struct_objet				*s_objet_resultat;
+
+			struct_liste_chainee		*l_element_courant;
+			struct_liste_chainee		*l_element_courant_ligne;
 
 			if (mysql_real_query((*((struct_connecteur_sql *) (*s_objet_1)
 					.objet)).descripteur.mysql, (unsigned char *) (*s_objet_2)
@@ -1042,7 +1161,19 @@ instruction_sqlquery(struct_processus *s
 		{
 #			ifdef POSTGRESQL_SUPPORT
 
-			PGresult		*resultat_postgresql;
+			unsigned int				i;
+			unsigned int				j;
+			unsigned int				nombre_colonnes;
+			unsigned int				nombre_lignes;
+
+			logical1					presence_resultat;
+
+			PGresult					*resultat_postgresql;
+
+			struct_objet				*s_objet_resultat;
+
+			struct_liste_chainee		*l_element_courant;
+			struct_liste_chainee		*l_element_courant_ligne;
 
 			if (PQstatus((*((struct_connecteur_sql *) (*s_objet_1).objet))
 					.descripteur.postgresql) != CONNECTION_OK)
@@ -1330,11 +1461,6 @@ instruction_stop(struct_processus *s_eta
 
 	struct_objet				*s_objet;
 
-	struct timespec				attente;
-
-	attente.tv_sec = 0;
-	attente.tv_nsec = GRANULARITE_us * 1000;
-
 	(*s_etat_processus).erreur_execution = d_ex;
 
 	if ((*s_etat_processus).affichage_arguments == 'Y')
@@ -1380,8 +1506,8 @@ instruction_stop(struct_processus *s_eta
 		if ((*(*((struct_processus_fils *) (*s_objet).objet)).thread)
 				.processus_detache == d_vrai)
 		{
-			kill((*(*((struct_processus_fils *) (*s_objet).objet)).thread).pid,
-					SIGFSTOP);
+			envoi_signal_processus((*(*((struct_processus_fils *)
+					(*s_objet).objet)).thread).pid, rpl_sigstop);
 		}
 		else
 		{
@@ -1400,7 +1526,7 @@ instruction_stop(struct_processus *s_eta
 						.donnee).objet)).thread).processus_detache == d_faux)
 				{
 					if ((pthread_equal((*(*((struct_processus_fils *)
-							(*(*l_element_courant).donnee).objet)).thread).pid,
+							(*(*l_element_courant).donnee).objet)).thread).tid,
 							(*(*((struct_processus_fils *)
 							(*s_objet).objet)).thread).tid) != 0) &&
 							((*(*((struct_processus_fils *)
@@ -1441,8 +1567,8 @@ instruction_stop(struct_processus *s_eta
 					if ((*(*((struct_processus_fils *)
 							(*s_objet).objet)).thread).thread_actif == d_vrai)
 					{
-						pthread_kill((*(*((struct_processus_fils *)
-								(*s_objet).objet)).thread).tid, SIGFSTOP);
+						envoi_signal_thread((*(*((struct_processus_fils *)
+								(*s_objet).objet)).thread).tid, rpl_sigstop);
 					}
 
 					if (pthread_mutex_unlock(&((*(*((struct_processus_fils *)