--- rpl/src/instructions_s10.c	2011/09/14 17:55:59	1.44
+++ rpl/src/instructions_s10.c	2012/04/13 14:12:59	1.57
@@ -1,7 +1,7 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.1.3
-  Copyright (C) 1989-2011 Dr. BERTRAND Joël
+  RPL/2 (R) version 4.1.8
+  Copyright (C) 1989-2012 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
 
@@ -45,7 +45,6 @@ instruction_spawn(struct_processus *s_et
 
 	pthread_mutexattr_t			attributs_mutex;
 
-	pthread_t					thread_id;
 	pthread_t					thread_surveillance;
 
 	struct_descripteur_thread	*s_argument_thread;
@@ -353,27 +352,29 @@ instruction_spawn(struct_processus *s_et
 		return;
 	}
 
-#	ifndef OS2
-#	ifndef Cygwin
+#	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;
 		return;
 	}
 #	endif
-#	endif
 
 	/*
 	 * Création de l'objet à retourner
@@ -397,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;
 
@@ -419,8 +414,8 @@ instruction_spawn(struct_processus *s_et
 
 	(*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;
@@ -431,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);
 	}
@@ -454,36 +450,30 @@ instruction_spawn(struct_processus *s_et
 		return;
 	}
 
-#	ifndef OS2
-#	ifndef Cygwin
+#	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;
 		return;
 	}
 #	endif
-#	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
@@ -500,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;
 	}
@@ -561,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);
@@ -570,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;
 	}
 
@@ -583,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;
 	}
@@ -599,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;
@@ -607,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;
 	}
@@ -725,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)
 		{
@@ -1127,7 +1116,11 @@ instruction_smphrdecr(struct_processus *
 			}
 		}
 
-		if (pthread_mutex_unlock(&((*s_etat_processus).mutex_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;
@@ -1138,7 +1131,12 @@ instruction_smphrdecr(struct_processus *
 		{
 			if (errno != EINTR)
 			{
-				pthread_mutex_lock(&((*s_etat_processus).mutex_fork));
+#				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)
@@ -1151,15 +1149,22 @@ instruction_smphrdecr(struct_processus *
 			}
 		}
 
-		if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)
+#		ifndef SEMAPHORES_NOMMES
+			while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
+#		else
+			while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
+#		endif
 		{
-			if ((*s_etat_processus).profilage == d_vrai)
+			if (errno != EINTR)
 			{
-				profilage(s_etat_processus, NULL);
-			}
+				if ((*s_etat_processus).profilage == d_vrai)
+				{
+					profilage(s_etat_processus, NULL);
+				}
 
-			(*s_etat_processus).erreur_systeme = d_es_processus;
-			return;
+				(*s_etat_processus).erreur_systeme = d_es_processus;
+				return;
+			}
 		}
 
 		if ((*s_etat_processus).profilage == d_vrai)
@@ -1267,7 +1272,11 @@ instruction_smphrtrydecr(struct_processu
 			}
 		}
 
-		if (pthread_mutex_unlock(&((*s_etat_processus).mutex_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
 		{
 			if ((*s_etat_processus).profilage == d_vrai)
 			{
@@ -1316,15 +1325,22 @@ instruction_smphrtrydecr(struct_processu
 			}
 		}
 
-		if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)
+#		ifndef SEMAPHORES_NOMMES
+			while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
+#		else
+			while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
+#		endif
 		{
-			if ((*s_etat_processus).profilage == d_vrai)
+			if (errno != EINTR)
 			{
-				profilage(s_etat_processus, NULL);
-			}
+				if ((*s_etat_processus).profilage == d_vrai)
+				{
+					profilage(s_etat_processus, NULL);
+				}
 
-			(*s_etat_processus).erreur_systeme = d_es_processus;
-			return;
+				(*s_etat_processus).erreur_systeme = d_es_processus;
+				return;
+			}
 		}
 
 		if ((*s_etat_processus).profilage == d_vrai)