--- rpl/src/instructions_s8.c	2011/09/14 14:34:28	1.33
+++ rpl/src/instructions_s8.c	2011/09/15 17:51:43	1.35
@@ -247,35 +247,20 @@ instruction_send(struct_processus *s_eta
 		attente.tv_sec = 0;
 		attente.tv_nsec = GRANULARITE_us * 1000;
 
-#		ifndef SEMAPHORES_NOMMES
-		if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
+		if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 0)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_processus;
 			return;
 		}
-#		else
-		if (sem_post((*s_etat_processus).semaphore_fork) != 0)
-		{
-			(*s_etat_processus).erreur_systeme = d_es_processus;
-			return;
-		}
-#		endif
 
 		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)) == -1)
-#			else
-			while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
-#			endif
+			if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)
 			{
-				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)
@@ -292,19 +277,14 @@ instruction_send(struct_processus *s_eta
 			nanosleep(&attente, NULL);
 			INCR_GRANULARITE(attente.tv_nsec);
 
-#			ifndef SEMAPHORES_NOMMES
-			if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
+			if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork))
+					!= 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return;
 			}
-#			else
-			if (sem_post((*s_etat_processus).semaphore_fork) != 0)
-			{
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
-			}
-#			endif
+
+			scrutation_interruptions(s_etat_processus);
 		}
 
 		pid = getpid();
@@ -316,17 +296,10 @@ instruction_send(struct_processus *s_eta
 				(*s_etat_processus).pipe_nombre_objets_attente,
 				&pid, sizeof(pid))) != sizeof(pid))
 		{
-#			ifndef SEMAPHORES_NOMMES
-			while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
-#			else
-			while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
-#			endif
+			if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)
 			{
-				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)
@@ -343,28 +316,19 @@ instruction_send(struct_processus *s_eta
 			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
+			if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 0)
 			{
 				(*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)) == -1)
-#		else
-		while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
-#		endif
+		if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)
 		{
-			if (errno != EINTR)
-			{
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
-			}
+			(*s_etat_processus).erreur_systeme = d_es_processus;
+			return;
 		}
 	}
 	else
@@ -384,35 +348,20 @@ instruction_send(struct_processus *s_eta
 		attente.tv_sec = 0;
 		attente.tv_nsec = GRANULARITE_us * 1000;
 
-#		ifndef SEMAPHORES_NOMMES
-		if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
-		{
-			(*s_etat_processus).erreur_systeme = d_es_processus;
-			return;
-		}
-#		else
-		if (sem_post((*s_etat_processus).semaphore_fork) != 0)
+		if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 0)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_processus;
 			return;
 		}
-#		endif
 
 		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)) == -1)
-#			else
-			while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
-#			endif
+			while(pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)
 			{
-				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)
@@ -429,19 +378,13 @@ instruction_send(struct_processus *s_eta
 			nanosleep(&attente, NULL);
 			INCR_GRANULARITE(attente.tv_nsec);
 
-#			ifndef SEMAPHORES_NOMMES
-			if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
-			{
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
-			}
-#			else
-			if (sem_post((*s_etat_processus).semaphore_fork) != 0)
+			if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return;
 			}
-#			endif
+
+			scrutation_interruptions(s_etat_processus);
 		}
 
 		tid = pthread_self();
@@ -453,17 +396,10 @@ instruction_send(struct_processus *s_eta
 				(*s_etat_processus).pipe_nombre_objets_attente,
 				&tid, sizeof(tid))) != sizeof(tid))
 		{
-#			ifndef SEMAPHORES_NOMMES
-			while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
-#			else
-			while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
-#			endif
+			if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)
 			{
-				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)
@@ -480,32 +416,19 @@ instruction_send(struct_processus *s_eta
 			nanosleep(&attente, NULL);
 			INCR_GRANULARITE(attente.tv_nsec);
 
-#			ifndef SEMAPHORES_NOMMES
-			if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
-			{
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
-			}
-#			else
-			if (sem_post((*s_etat_processus).semaphore_fork) != 0)
+			if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return;
 			}
-#			endif
+
+			scrutation_interruptions(s_etat_processus);
 		}
 
-#		ifndef SEMAPHORES_NOMMES
-		while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
-#		else
-		while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
-#		endif
+		if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)
 		{
-			if (errno != EINTR)
-			{
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
-			}
+			(*s_etat_processus).erreur_systeme = d_es_processus;
+			return;
 		}
 	}
 
@@ -514,61 +437,37 @@ instruction_send(struct_processus *s_eta
 	attente.tv_sec = 0;
 	attente.tv_nsec = GRANULARITE_us * 1000;
 
-#	ifndef SEMAPHORES_NOMMES
-	if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
-	{
-		(*s_etat_processus).erreur_systeme = d_es_processus;
-		return;
-	}
-#	else
-	if (sem_post((*s_etat_processus).semaphore_fork) != 0)
+	if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 0)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_processus;
 		return;
 	}
-#	endif
 
 	while(read_atomic(s_etat_processus, (*s_etat_processus).pipe_acquittement,
 			&tampon, sizeof(unsigned char)) != sizeof(unsigned char))
 	{
-#		ifndef SEMAPHORES_NOMMES
-		while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
-#		else
-		while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
-#		endif
+		if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)
 		{
-			if (errno != EINTR)
-			{
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
-			}
+			(*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
+		if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 0)
 		{
 			(*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)) == -1)
-#	else
-	while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
-#	endif
+	if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)
 	{
-		if (errno != EINTR)
-		{
-			(*s_etat_processus).erreur_systeme = d_es_processus;
-			return;
-		}
+		(*s_etat_processus).erreur_systeme = d_es_processus;
+		return;
 	}
 
 	// Envoi d'un PID invalide (-1) pour ne pas bloquer le thread
@@ -581,11 +480,7 @@ instruction_send(struct_processus *s_eta
 		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
+		if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 0)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_processus;
 			return;
@@ -595,17 +490,10 @@ instruction_send(struct_processus *s_eta
 				(*s_etat_processus).pipe_nombre_interruptions_attente,
 				&pid, sizeof(pid))) != sizeof(pid))
 		{
-#			ifndef SEMAPHORES_NOMMES
-			while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
-#			else
-			while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
-#			endif
+			if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)
 			{
-				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)
@@ -622,33 +510,20 @@ instruction_send(struct_processus *s_eta
 			nanosleep(&attente, NULL);
 			INCR_GRANULARITE(attente.tv_nsec);
 
-#			ifndef SEMAPHORES_NOMMES
-			if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
-			{
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
-			}
-#			else
-			if (sem_post((*s_etat_processus).semaphore_fork) != 0)
+			if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return;
 			}
-#			endif
 		}
 
-#		ifndef SEMAPHORES_NOMMES
-		while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
-#		else
-		while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
-#		endif
+		if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)
 		{
-			if (errno != EINTR)
-			{
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
-			}
+			(*s_etat_processus).erreur_systeme = d_es_processus;
+			return;
 		}
+
+		scrutation_interruptions(s_etat_processus);
 	}
 	else
 	{
@@ -657,11 +532,7 @@ instruction_send(struct_processus *s_eta
 		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
+		if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 0)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_processus;
 			return;
@@ -671,17 +542,10 @@ instruction_send(struct_processus *s_eta
 				(*s_etat_processus).pipe_nombre_interruptions_attente,
 				&tid, sizeof(tid))) != sizeof(tid))
 		{
-#			ifndef SEMAPHORES_NOMMES
-			while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
-#			else
-			while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
-#			endif
+			if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)
 			{
-				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)
@@ -698,61 +562,37 @@ instruction_send(struct_processus *s_eta
 			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
+			if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 0)
 			{
 				(*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)) == -1)
-#		else
-		while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
-#		endif
+		if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)
 		{
-			if (errno != EINTR)
-			{
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
-			}
+			(*s_etat_processus).erreur_systeme = d_es_processus;
+			return;
 		}
 	}
 
 	// ecriture_pipe() ne peut être interrompu par un signal.
 
-#	ifndef SEMAPHORES_NOMMES
-	if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
+	if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 0)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_processus;
 		return;
 	}
-#	else
-	if (sem_post((*s_etat_processus).semaphore_fork) != 0)
-	{
-		(*s_etat_processus).erreur_systeme = d_es_processus;
-		return;
-	}
-#	endif
 
 	if (ecriture_pipe(s_etat_processus, (*s_etat_processus).pipe_donnees,
 			s_objet) == d_erreur)
 	{
-#		ifndef SEMAPHORES_NOMMES
-		while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
-#		else
-		while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
-#		endif
+		if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)
 		{
-			if (errno != EINTR)
-			{
-				(*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)
@@ -764,17 +604,10 @@ instruction_send(struct_processus *s_eta
 		return;
 	}
 
-#	ifndef SEMAPHORES_NOMMES
-	while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
-#	else
-	while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
-#	endif
+	if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)
 	{
-		if (errno != EINTR)
-		{
-			(*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)