--- rpl/src/instructions_s8.c	2011/06/20 17:54:20	1.24
+++ rpl/src/instructions_s8.c	2011/09/20 08:56:24	1.36
@@ -1,6 +1,6 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.1.0.prerelease.1
+  RPL/2 (R) version 4.1.3
   Copyright (C) 1989-2011 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
@@ -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)
 		{
 			(*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 (sem_wait(&((*s_etat_processus).semaphore_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 (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)
-			{
-				(*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 (sem_wait(&((*s_etat_processus).semaphore_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
 			{
 				(*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 (sem_wait(&((*s_etat_processus).semaphore_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)
-		{
-			(*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(sem_wait(&((*s_etat_processus).semaphore_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)
-			{
-				(*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 (sem_wait(&((*s_etat_processus).semaphore_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)
-			{
-				(*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 (sem_post(&((*s_etat_processus).semaphore_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)
-	{
-		(*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 (sem_wait(&((*s_etat_processus).semaphore_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
 		{
 			(*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 (sem_wait(&((*s_etat_processus).semaphore_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
 		{
 			(*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 (sem_post(&((*s_etat_processus).semaphore_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)
-			{
-				(*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 (sem_wait(&((*s_etat_processus).semaphore_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
 		{
 			(*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 (sem_wait(&((*s_etat_processus).semaphore_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
 			{
 				(*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 (sem_wait(&((*s_etat_processus).semaphore_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)
 	{
 		(*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 (sem_wait(&((*s_etat_processus).semaphore_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 (sem_wait(&((*s_etat_processus).semaphore_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)
@@ -1470,11 +1303,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')
@@ -1520,8 +1348,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
 		{
@@ -1581,8 +1409,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 *)