--- rpl/src/instructions_s10.c	2011/06/20 17:54:19	1.34
+++ rpl/src/instructions_s10.c	2011/09/26 15:57:15	1.49
@@ -1,6 +1,6 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.1.0.prerelease.1
+  RPL/2 (R) version 4.1.4
   Copyright (C) 1989-2011 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
@@ -48,9 +48,6 @@ instruction_spawn(struct_processus *s_et
 	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;
@@ -236,46 +233,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;
@@ -440,12 +397,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;
 
@@ -460,8 +411,6 @@ 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,
@@ -476,6 +425,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);
 	}
@@ -522,14 +472,6 @@ instruction_spawn(struct_processus *s_et
 #	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
 	 * accédé depuis deux threads distincts et aboutir à un blocage lors d'une
@@ -545,6 +487,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;
 	}
@@ -606,6 +549,7 @@ instruction_spawn(struct_processus *s_et
 				}
 			}
 
+			scrutation_interruptions(s_etat_processus);
 			l_element_courant = (*l_element_courant).suivant;
 		}
 	} while(drapeau == d_vrai);
@@ -615,7 +559,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;
 	}
 
@@ -628,13 +571,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;
 	}
@@ -644,7 +585,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;
@@ -652,13 +592,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;
 	}
@@ -680,20 +613,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)
+	if (envoi_signal_thread((*s_argument_thread).tid, rpl_sigstart) != 0)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_processus;
 		return;
 	}
 
-	if (pthread_sigmask(SIG_SETMASK, &oldset, NULL) != 0)
-	{
-		(*s_etat_processus).erreur_systeme = d_es_processus;
-		return;
-	}
-
-	sigpending(&set);
-
 	return;
 }
 
@@ -1181,24 +1106,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)
@@ -1212,9 +1139,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)
@@ -1335,18 +1262,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;
 
@@ -1387,9 +1315,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)