--- rpl/src/instructions_s1.c	2011/06/20 17:54:19	1.28
+++ rpl/src/instructions_s1.c	2012/06/12 11:44:34	1.49
@@ -1,7 +1,7 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.1.0.prerelease.1
-  Copyright (C) 1989-2011 Dr. BERTRAND Joël
+  RPL/2 (R) version 4.1.9
+  Copyright (C) 1989-2012 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
 
@@ -3403,9 +3403,6 @@ instruction_syseval(struct_processus *s_
 
 	pid_t						pid;
 
-	sigset_t					oldset;
-	sigset_t					set;
-
 	ssize_t						longueur_ecriture;
 
 	struct_liste_chainee		*l_element_courant;
@@ -3420,6 +3417,7 @@ instruction_syseval(struct_processus *s_
 	struct sigaction			action_courante;
 	struct sigaction			action_passee;
 
+	unsigned char				*ligne;
 	unsigned char				*ptr;
 	unsigned char				*ptr2;
 	unsigned char				registre_autorisation_empilement_programme;
@@ -3702,16 +3700,10 @@ instruction_syseval(struct_processus *s_
 
 		fflush(NULL);
 
-		sigfillset(&set);
-		pthread_sigmask(SIG_BLOCK, &set, &oldset);
-
 		verrouillage_threads_concurrents(s_etat_processus);
 		pid = fork();
 		deverrouillage_threads_concurrents(s_etat_processus);
 
-		pthread_sigmask(SIG_SETMASK, &oldset, NULL);
-		sigpending(&set);
-
 		if (pid < 0)
 		{
 			if (close(pipes_entree[0]) != 0)
@@ -3864,13 +3856,20 @@ instruction_syseval(struct_processus *s_
 
 				while(l_element_courant != NULL)
 				{
-					longueur_ecriture = strlen((unsigned char *)
-							(*(*l_element_courant).donnee).objet);
+					if ((ligne = formateur_flux(s_etat_processus,
+							(unsigned char *) (*(*l_element_courant).donnee)
+							.objet, &longueur_ecriture)) == NULL)
+					{
+						(*s_etat_processus).erreur_systeme =
+								d_es_allocation_memoire;
+						return;
+					}
 
 #					ifndef SEMAPHORES_NOMMES
-					if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
+						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;
@@ -3878,24 +3877,20 @@ instruction_syseval(struct_processus *s_
 					}
 
 					while(write_atomic(s_etat_processus,
-							pipes_entree[1], (unsigned char *)
-							(*(*l_element_courant).donnee).objet,
+							pipes_entree[1], ligne,
 							longueur_ecriture) != longueur_ecriture)
 					{
 #						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)
-							{
-								(*s_etat_processus).erreur_systeme =
-										d_es_processus;
-								return;
-							}
+							(*s_etat_processus).erreur_systeme =
+									d_es_processus;
+							return;
 						}
 
 						if (longueur_ecriture == -1)
@@ -3905,11 +3900,11 @@ instruction_syseval(struct_processus *s_
 						}
 
 #						ifndef SEMAPHORES_NOMMES
-						if (sem_post(&((*s_etat_processus)
-								.semaphore_fork)) != 0)
+							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;
@@ -3917,15 +3912,17 @@ instruction_syseval(struct_processus *s_
 						}
 					}
 
+					free(ligne);
+
 					while(write_atomic(s_etat_processus,
 							pipes_entree[1], "\n", 1) != 1)
 					{
 #						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)
@@ -3943,11 +3940,11 @@ instruction_syseval(struct_processus *s_
 						}
 
 #						ifndef SEMAPHORES_NOMMES
-						if (sem_post(&((*s_etat_processus)
-								.semaphore_fork)) != 0)
+							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;
@@ -3956,9 +3953,10 @@ instruction_syseval(struct_processus *s_
 					}
 
 #					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)
@@ -3990,9 +3988,9 @@ instruction_syseval(struct_processus *s_
 				 */
 
 #				ifndef SEMAPHORES_NOMMES
-				if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
+					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;
@@ -4002,16 +4000,14 @@ instruction_syseval(struct_processus *s_
 				if (waitpid(pid, &status, 0) == -1)
 				{
 #					ifndef SEMAPHORES_NOMMES
-					if (sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
+						if (sem_post(&((*s_etat_processus).semaphore_fork))
+								!= 0)
 #					else
-					if (sem_wait((*s_etat_processus).semaphore_fork) == -1)
+						if (sem_post((*s_etat_processus).semaphore_fork) != 0)
 #					endif
 					{
-						if (errno != EINTR)
-						{
-							(*s_etat_processus).erreur_systeme = d_es_processus;
-							return;
-						}
+						(*s_etat_processus).erreur_systeme = d_es_processus;
+						return;
 					}
 
 					(*s_etat_processus).erreur_systeme = d_es_processus;
@@ -4019,9 +4015,9 @@ instruction_syseval(struct_processus *s_
 				}
 
 #				ifndef SEMAPHORES_NOMMES
-				if (sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
+					while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
 #				else
-				if (sem_wait((*s_etat_processus).semaphore_fork) == -1)
+					while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
 #				endif
 				{
 					if (errno != EINTR)
@@ -4043,35 +4039,30 @@ instruction_syseval(struct_processus *s_
 				return;
 			}
 
+			tampon[0] = d_code_fin_chaine;
+
 #			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((ios = read_atomic(s_etat_processus,
 					pipes_sortie[0], &(tampon[pointeur]),
 					longueur_lecture)) > 0)
 			{
 #				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)
-					{
-						(*s_etat_processus).erreur_systeme = d_es_processus;
-						return;
-					}
+					(*s_etat_processus).erreur_systeme = d_es_processus;
+					return;
 				}
 
 				tampon[pointeur + ios] = d_code_fin_chaine;
@@ -4088,9 +4079,9 @@ instruction_syseval(struct_processus *s_
 				}
 
 #				ifndef SEMAPHORES_NOMMES
-				if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
+					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;
@@ -4099,9 +4090,9 @@ instruction_syseval(struct_processus *s_
 			}
 
 #			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)
@@ -4135,7 +4126,15 @@ instruction_syseval(struct_processus *s_
 			 * Transformation de la chaîne en liste
 			 */
 
-			longueur_tampon = strlen(tampon);
+			if ((ligne = analyse_flux(s_etat_processus, tampon,
+					&longueur_tampon)) == NULL)
+			{
+				(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
+				return;
+			}
+
+			free(tampon);
+			tampon = ligne;
 
 			for(i = 0, ptr = tampon, nombre_lignes = 0;
 					i < (long) longueur_tampon; i++, ptr++)
@@ -4251,9 +4250,9 @@ instruction_syseval(struct_processus *s_
 		}
  
 #		ifndef SEMAPHORES_NOMMES
-		if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
+			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;
@@ -4272,9 +4271,9 @@ instruction_syseval(struct_processus *s_
 				== d_erreur)
 		{
 #			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)
@@ -4295,9 +4294,9 @@ instruction_syseval(struct_processus *s_
 		}
 
 #		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)