--- rpl/src/instructions_s10.c	2011/03/06 16:44:13	1.29
+++ rpl/src/instructions_s10.c	2012/04/12 09:56:40	1.56
@@ -1,7 +1,7 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.0.21
-  Copyright (C) 1989-2011 Dr. BERTRAND Joël
+  RPL/2 (R) version 4.1.7
+  Copyright (C) 1989-2012 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
 
@@ -45,12 +45,8 @@ instruction_spawn(struct_processus *s_et
 
 	pthread_mutexattr_t			attributs_mutex;
 
-	pthread_t					thread_id;
 	pthread_t					thread_surveillance;
 
-	sigset_t					oldset;
-	sigset_t					set;
-
 	struct_descripteur_thread	*s_argument_thread;
 
 	struct_liste_chainee		*l_element_courant;
@@ -132,9 +128,7 @@ instruction_spawn(struct_processus *s_et
 		if (recherche_variable(s_etat_processus, (*((struct_nom *)
 				(*s_objet).objet)).nom) == d_vrai)
 		{
-			if ((*s_etat_processus).s_liste_variables
-					[(*s_etat_processus).position_variable_courante].objet
-					== NULL)
+			if ((*(*s_etat_processus).pointeur_variable_courante).objet == NULL)
 			{
 				if (pthread_mutex_lock(&((*(*s_etat_processus)
 						.s_liste_variables_partagees).mutex)) != 0)
@@ -144,13 +138,10 @@ instruction_spawn(struct_processus *s_et
 				}
 
 				if (recherche_variable_partagee(s_etat_processus,
-						(*s_etat_processus).s_liste_variables
-						[(*s_etat_processus).position_variable_courante].nom,
-						(*s_etat_processus).s_liste_variables
-						[(*s_etat_processus).position_variable_courante]
-						.variable_partagee, (*s_etat_processus)
-						.s_liste_variables[(*s_etat_processus)
-						.position_variable_courante].origine) == d_faux)
+						(*(*s_etat_processus).pointeur_variable_courante).nom,
+						(*(*s_etat_processus).pointeur_variable_courante)
+						.variable_partagee, (*(*s_etat_processus)
+						.pointeur_variable_courante).origine) == d_faux)
 				{
 					if (pthread_mutex_unlock(&((*(*s_etat_processus)
 							.s_liste_variables_partagees).mutex)) != 0)
@@ -219,11 +210,9 @@ instruction_spawn(struct_processus *s_et
 			}
 			else
 			{
-				if (((*(*s_etat_processus).s_liste_variables
-						[(*s_etat_processus).position_variable_courante].objet)
-						.type != RPN) && ((*(*s_etat_processus)
-						.s_liste_variables[(*s_etat_processus)
-						.position_variable_courante].objet).type != ADR))
+				if (((*(*(*s_etat_processus).pointeur_variable_courante).objet)
+						.type != RPN) && ((*(*(*s_etat_processus)
+						.pointeur_variable_courante).objet).type != ADR))
 				{
 					liberation(s_etat_processus, s_objet);
 
@@ -243,46 +232,6 @@ instruction_spawn(struct_processus *s_et
 		}
 	}
 
-	if (sigemptyset(&set) != 0)
-	{
-		(*s_etat_processus).erreur_systeme = d_es_processus;
-		return;
-	}
-
-	if (sigaddset(&set, SIGSTART) != 0)
-	{
-		(*s_etat_processus).erreur_systeme = d_es_processus;
-		return;
-	}
-
-	/*
-	 * Le signal SIGFSTOP doit être traité !
-	 */
-
-	if (sigaddset(&set, SIGFSTOP) != 0)
-	{
-		(*s_etat_processus).erreur_systeme = d_es_processus;
-		return;
-	}
-
-	if (sigaddset(&set, SIGFABORT) != 0)
-	{
-		(*s_etat_processus).erreur_systeme = d_es_processus;
-		return;
-	}
-
-	if (sigaddset(&set, SIGURG) != 0)
-	{
-		(*s_etat_processus).erreur_systeme = d_es_processus;
-		return;
-	}
-
-	if (pthread_sigmask(SIG_BLOCK, &set, &oldset) != 0)
-	{
-		(*s_etat_processus).erreur_systeme = d_es_processus;
-		return;
-	}
-
 	if ((s_argument_thread = malloc(sizeof(struct_descripteur_thread))) == NULL)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_processus;
@@ -403,19 +352,23 @@ instruction_spawn(struct_processus *s_et
 		return;
 	}
 
-#	ifndef OS2
+#	ifdef SCHED_OTHER
 	if (pthread_attr_setschedpolicy(&attributs, SCHED_OTHER) != 0)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_processus;
 		return;
 	}
+#	endif
 
+#	ifdef PTHREAD_EXPLICIT_SCHED
 	if (pthread_attr_setinheritsched(&attributs, PTHREAD_EXPLICIT_SCHED) != 0)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_processus;
 		return;
 	}
+#	endif
 
+#	ifdef PTHREAD_SCOPE_SYSTEM
 	if (pthread_attr_setscope(&attributs, PTHREAD_SCOPE_SYSTEM) != 0)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_processus;
@@ -445,12 +398,6 @@ instruction_spawn(struct_processus *s_et
 
 	// Lancement du thread fils
 
-	if (pthread_mutex_lock(&((*s_nouvel_etat_processus).mutex)) != 0)
-	{
-		(*s_etat_processus).erreur_systeme = d_es_processus;
-		return;
-	}
-
 	(*s_argument_thread).s_nouvel_etat_processus = s_nouvel_etat_processus;
 	(*s_argument_thread).s_etat_processus = s_etat_processus;
 
@@ -465,12 +412,10 @@ instruction_spawn(struct_processus *s_et
 		(*s_argument_thread).destruction_objet = d_faux;
 	}
 
-	(*s_argument_thread).set = set;
-	(*s_argument_thread).oldset = oldset;
 	(*s_argument_thread).thread_actif = d_faux;
 
-	if (pthread_create(&thread_id, &attributs, lancement_thread,
-			s_argument_thread) != 0)
+	if (pthread_create(&(*s_nouvel_etat_processus).tid,
+			&attributs, lancement_thread, s_argument_thread) != 0)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_processus;
 		return;
@@ -481,6 +426,7 @@ instruction_spawn(struct_processus *s_et
 
 	while((*s_argument_thread).thread_actif == d_faux)
 	{
+		scrutation_interruptions(s_etat_processus);
 		nanosleep(&attente, NULL);
 		INCR_GRANULARITE(attente.tv_nsec);
 	}
@@ -504,20 +450,24 @@ instruction_spawn(struct_processus *s_et
 		return;
 	}
 
-#	ifndef OS2
+#	ifdef SCHED_OTHER
 	if (pthread_attr_setschedpolicy(&attributs, SCHED_OTHER) != 0)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_processus;
 		return;
 	}
+#	endif
 
+#	ifdef PTHREAD_EXPLICIT_SCHED
 	if (pthread_attr_setinheritsched(&attributs,
 			PTHREAD_EXPLICIT_SCHED) != 0)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_processus;
 		return;
 	}
+#	endif
 
+#	ifdef PTHREAD_SCOPE_SYSTEM
 	if (pthread_attr_setscope(&attributs, PTHREAD_SCOPE_SYSTEM) != 0)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_processus;
@@ -525,14 +475,6 @@ instruction_spawn(struct_processus *s_et
 	}
 #	endif
 
-	// Attente de l'affectation de la grandeur processus.tid par le thread fils.
-
-	if (pthread_mutex_lock(&((*s_nouvel_etat_processus).mutex)) != 0)
-	{
-		(*s_etat_processus).erreur_systeme = d_es_processus;
-		return;
-	}
-
 	/*
 	 * On copie l'objet plutôt que le pointeur car cet objet peut être
 	 * accédé depuis deux threads distincts et aboutir à un blocage lors d'une
@@ -548,6 +490,7 @@ instruction_spawn(struct_processus *s_et
 
 	if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0)
 	{
+		pthread_mutex_unlock(&((*s_nouvel_etat_processus).mutex));
 		(*s_etat_processus).erreur_systeme = d_es_processus;
 		return;
 	}
@@ -609,6 +552,7 @@ instruction_spawn(struct_processus *s_et
 				}
 			}
 
+			scrutation_interruptions(s_etat_processus);
 			l_element_courant = (*l_element_courant).suivant;
 		}
 	} while(drapeau == d_vrai);
@@ -618,7 +562,6 @@ instruction_spawn(struct_processus *s_et
 			.l_base_pile_processus), s_objet_systeme) == d_erreur)
 	{
 		pthread_mutex_unlock(&((*s_etat_processus).mutex));
-		pthread_mutex_unlock(&((*s_nouvel_etat_processus).mutex));
 		return;
 	}
 
@@ -631,13 +574,11 @@ instruction_spawn(struct_processus *s_et
 	if (empilement(s_etat_processus, &((*s_etat_processus).l_base_pile),
 			s_objet_resultat) == d_erreur)
 	{
-		pthread_mutex_unlock(&((*s_nouvel_etat_processus).mutex));
 		return;
 	}
 
 	if (pthread_mutex_lock(&(*s_argument_thread).mutex) != 0)
 	{
-		pthread_mutex_unlock(&((*s_nouvel_etat_processus).mutex));
 		(*s_etat_processus).erreur_systeme = d_es_processus;
 		return;
 	}
@@ -647,7 +588,6 @@ instruction_spawn(struct_processus *s_et
 		// Le thread n'existe plus.
 
 		pthread_join((*s_argument_thread).tid, NULL);
-		pthread_mutex_unlock(&((*s_nouvel_etat_processus).mutex));
 		pthread_mutex_unlock(&(*s_argument_thread).mutex);
 		(*s_etat_processus).erreur_systeme = d_es_processus;
 		return;
@@ -655,13 +595,6 @@ instruction_spawn(struct_processus *s_et
 
 	if (pthread_mutex_unlock(&(*s_argument_thread).mutex) != 0)
 	{
-		pthread_mutex_unlock(&((*s_nouvel_etat_processus).mutex));
-		(*s_etat_processus).erreur_systeme = d_es_processus;
-		return;
-	}
-
-	if (pthread_mutex_unlock(&((*s_nouvel_etat_processus).mutex)) != 0)
-	{
 		(*s_etat_processus).erreur_systeme = d_es_processus;
 		return;
 	}
@@ -683,20 +616,12 @@ instruction_spawn(struct_processus *s_et
 
 	// Le fils peut être présent sans être en attente du signal de départ.
 
-	if (pthread_kill((*s_argument_thread).tid, SIGSTART) != 0)
-	{
-		(*s_etat_processus).erreur_systeme = d_es_processus;
-		return;
-	}
-
-	if (pthread_sigmask(SIG_SETMASK, &oldset, NULL) != 0)
+	if (envoi_signal_thread((*s_argument_thread).tid, rpl_sigstart) != 0)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_processus;
 		return;
 	}
 
-	sigpending(&set);
-
 	return;
 }
 
@@ -781,10 +706,18 @@ instruction_sqlconnect(struct_processus
 		if ((s_objet_resultat = parametres_sql(s_etat_processus,
 				s_objet_argument)) == NULL)
 		{
+			liberation(s_etat_processus, s_objet_resultat);
 			liberation(s_etat_processus, s_objet_argument);
 			return;
 		}
 
+		if ((*s_etat_processus).erreur_execution ==
+				d_ex_instruction_indisponible)
+		{
+			liberation(s_etat_processus, s_objet_resultat);
+			return;
+		}
+
 		if ((s_objet_systeme = copie_objet(s_etat_processus, s_objet_resultat,
 				'O')) == NULL)
 		{
@@ -1184,24 +1117,26 @@ instruction_smphrdecr(struct_processus *
 		}
 
 #		ifndef SEMAPHORES_NOMMES
-		if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
-		{
-			(*s_etat_processus).erreur_systeme = d_es_processus;
-			return;
-		}
+			if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
 #		else
-		if (sem_post((*s_etat_processus).semaphore_fork) != 0)
+			if (sem_post((*s_etat_processus).semaphore_fork) != 0)
+#		endif
 		{
 			(*s_etat_processus).erreur_systeme = d_es_processus;
 			return;
 		}
-#		endif
 
 		while(sem_wait((*((struct_semaphore *) (*s_objet_argument).objet))
 				.semaphore) == -1)
 		{
 			if (errno != EINTR)
 			{
+#				ifndef SEMAPHORES_NOMMES
+					sem_post(&((*s_etat_processus).semaphore_fork));
+#				else
+					sem_post((*s_etat_processus).semaphore_fork);
+#				endif
+
 				(*s_etat_processus).erreur_execution = d_ex_semaphore;
 
 				if ((*s_etat_processus).profilage == d_vrai)
@@ -1215,9 +1150,9 @@ instruction_smphrdecr(struct_processus *
 		}
 
 #		ifndef SEMAPHORES_NOMMES
-		while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
+			while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
 #		else
-		while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
+			while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
 #		endif
 		{
 			if (errno != EINTR)
@@ -1338,18 +1273,19 @@ instruction_smphrtrydecr(struct_processu
 		}
 
 #		ifndef SEMAPHORES_NOMMES
-		if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
-		{
-			(*s_etat_processus).erreur_systeme = d_es_processus;
-			return;
-		}
+			if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
 #		else
-		if (sem_post((*s_etat_processus).semaphore_fork) != 0)
+			if (sem_post((*s_etat_processus).semaphore_fork) != 0)
+#		endif
 		{
+			if ((*s_etat_processus).profilage == d_vrai)
+			{
+				profilage(s_etat_processus, NULL);
+			}
+
 			(*s_etat_processus).erreur_systeme = d_es_processus;
 			return;
 		}
-#		endif
 
 		(*((integer8 *) (*s_objet_resultat).objet)) = 0;
 
@@ -1390,9 +1326,9 @@ instruction_smphrtrydecr(struct_processu
 		}
 
 #		ifndef SEMAPHORES_NOMMES
-		while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
+			while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
 #		else
-		while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
+			while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
 #		endif
 		{
 			if (errno != EINTR)