--- rpl/src/instructions_s1.c	2019/02/07 21:44:15	1.99
+++ rpl/src/instructions_s1.c	2019/10/31 15:40:19	1.114
@@ -1,6 +1,6 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.1.31
+  RPL/2 (R) version 4.1.32
   Copyright (C) 1989-2019 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
@@ -20,6 +20,7 @@
 */
 
 
+#define DEBUG_ERREURS
 #include "rpl-conv.h"
 
 
@@ -3372,6 +3373,83 @@ instruction_sto(struct_processus *s_etat
 ================================================================================
 */
 
+static struct
+{
+	struct_processus		*s_etat_processus;
+	struct_liste_chainee	*fd_stdin;
+	int						pipe_entree;
+	volatile int			erreur;
+} arguments_stdin;
+
+static void *
+thread_stdin(void *argument)
+{
+	integer8				longueur_ecriture;
+
+	typeof(arguments_stdin)	*ptr;
+
+	struct_liste_chainee	*l_element_courant;
+
+	struct_processus		*s_etat_processus;
+
+	unsigned char			*ligne;
+
+	ptr = argument;
+
+	l_element_courant = (*ptr).fd_stdin;
+	s_etat_processus = (*ptr).s_etat_processus;
+	(*ptr).erreur = d_es;
+
+	while(l_element_courant != NULL)
+	{
+		if ((ligne = formateur_flux(s_etat_processus,
+				(unsigned char *) (*(*l_element_courant).donnee).objet,
+				&longueur_ecriture)) == NULL)
+		{
+			(*ptr).erreur = d_es_allocation_memoire;
+			close((*ptr).pipe_entree);
+			pthread_exit(NULL);
+		}
+
+		while(write_atomic(s_etat_processus, (*ptr).pipe_entree, ligne,
+				(size_t) longueur_ecriture) != longueur_ecriture)
+		{
+			if (longueur_ecriture == -1)
+			{
+				(*ptr).erreur = d_es_processus;
+				close((*ptr).pipe_entree);
+				pthread_exit(NULL);
+			}
+		}
+
+		free(ligne);
+
+		while(write_atomic(s_etat_processus, (*ptr).pipe_entree, "\n", 1)
+				!= 1)
+		{
+			if (longueur_ecriture == -1)
+			{
+				(*ptr).erreur = d_es_processus;
+				close((*ptr).pipe_entree);
+				pthread_exit(NULL);
+			}
+		}
+
+		l_element_courant = (*l_element_courant).suivant;
+	}
+
+	if (close((*ptr).pipe_entree) != 0)
+	{
+		(*ptr).erreur = d_es_processus;
+	}
+	else
+	{
+		(*ptr).erreur = d_es;
+	}
+
+	pthread_exit(NULL);
+}
+
 void
 instruction_syseval(struct_processus *s_etat_processus)
 {
@@ -3383,17 +3461,21 @@ instruction_syseval(struct_processus *s_
 	int							pipes_sortie[2];
 	int							status;
 
-	integer8					longueur_ecriture;
-	integer8					longueur_traitee;
+	file						*fpipe;
 
 	logical1					drapeau_fin;
 	logical1					presence_stdin;
+	logical1					processus_tue;
 
 	long						i;
 	long						nombre_arguments;
 
 	pid_t						pid;
 
+	pthread_attr_t				attributs;
+
+	pthread_t					thread_stdin_tid;
+
 	struct_liste_chainee		*l_element_courant;
 	struct_liste_chainee		*l_element_precedent;
 	struct_liste_chainee		*l_element_stdin;
@@ -3403,10 +3485,16 @@ instruction_syseval(struct_processus *s_
 	struct_objet				*s_objet_resultat;
 	struct_objet				*s_objet_temporaire;
 
+	struct pollfd				fds;
+
 	struct sigaction			action_courante;
 	struct sigaction			action_passee;
 
-	unsigned char				*ligne;
+	struct timespec				attente;
+
+	struct timeval				horodatage_final;
+	struct timeval				horodatage_initial;
+
 	unsigned char				*ptr;
 	unsigned char				*ptr2;
 	unsigned char				registre_autorisation_empilement_programme;
@@ -3417,6 +3505,7 @@ instruction_syseval(struct_processus *s_
 	integer8					longueur_lecture;
 	integer8					longueur_lue;
 	integer8					longueur_tampon;
+	integer8					longueur_traitee;
 	integer8					nombre_lignes;
 	integer8					pointeur;
 	integer8					registre_position_courante;
@@ -3651,23 +3740,6 @@ instruction_syseval(struct_processus *s_
 			l_element_courant = (*l_element_courant).suivant;
 		}
 
-		action_courante.sa_handler = SIG_IGN;
-		action_courante.sa_flags = SA_NODEFER | SA_ONSTACK;
-
-		if (sigaction(SIGINT, &action_courante, &action_passee) != 0)
-		{
-			for(i = 0; i < nombre_arguments; i++)
-			{
-				depilement(s_etat_processus, &((*s_etat_processus).l_base_pile),
-						&s_objet_temporaire);
-				liberation(s_etat_processus, s_objet_temporaire);
-			}
-
-			free(arguments);
-			(*s_etat_processus).erreur_systeme = d_es_signal;
-			return;
-		}
-
 		if (pipe(pipes_entree) != 0)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_processus;
@@ -3688,6 +3760,52 @@ instruction_syseval(struct_processus *s_
 
 		fflush(NULL);
 
+		attente.tv_sec = 0;
+		attente.tv_nsec = GRANULARITE_us * 1000;
+
+		while(pthread_mutex_trylock(&mutex_sigaction) != 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;
+			}
+
+			nanosleep(&attente, NULL);
+			INCR_GRANULARITE(attente.tv_nsec);
+
+#			ifndef SEMAPHORES_NOMMES
+				while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
+#			else
+				while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
+#			endif
+			{
+				(*s_etat_processus).erreur_systeme = d_es_processus;
+				return;
+			}
+		}
+
+		action_courante.sa_handler = SIG_IGN;
+		action_courante.sa_flags = 0;
+
+		if (sigaction(SIGINT, &action_courante, &action_passee) != 0)
+		{
+			for(i = 0; i < nombre_arguments; i++)
+			{
+				depilement(s_etat_processus, &((*s_etat_processus).l_base_pile),
+						&s_objet_temporaire);
+				liberation(s_etat_processus, s_objet_temporaire);
+			}
+
+			free(arguments);
+			(*s_etat_processus).erreur_systeme = d_es_signal;
+			return;
+		}
+
 		verrouillage_threads_concurrents(s_etat_processus);
 
 		pid = fork();
@@ -3740,19 +3858,19 @@ instruction_syseval(struct_processus *s_
 			if (close(pipes_entree[1]) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
+				printf("%d\n",__LINE__);
 			}
 
 			if (close(pipes_sortie[0]) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
+				printf("%d\n",__LINE__);
 			}
 
 			if (close(pipes_erreur[0]) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
+				printf("%d\n",__LINE__);
 			}
 
 			if (pipes_entree[0] != STDIN_FILENO)
@@ -3760,7 +3878,7 @@ instruction_syseval(struct_processus *s_
 				if (dup2(pipes_entree[0], STDIN_FILENO) == -1)
 				{
 					(*s_etat_processus).erreur_systeme = d_es_processus;
-					return;
+					printf("%d\n",__LINE__);
 				}
 			}
 
@@ -3769,7 +3887,7 @@ instruction_syseval(struct_processus *s_
 				if (dup2(pipes_sortie[1], STDOUT_FILENO) == -1)
 				{
 					(*s_etat_processus).erreur_systeme = d_es_processus;
-					return;
+					printf("%d\n",__LINE__);
 				}
 			}
 
@@ -3778,18 +3896,15 @@ instruction_syseval(struct_processus *s_
 				if (dup2(pipes_sortie[1], STDERR_FILENO) == -1)
 				{
 					(*s_etat_processus).erreur_systeme = d_es_processus;
-					return;
+					printf("%d\n",__LINE__);
 				}
 			}
 
-			if (nombre_arguments != 0)
+			if ((nombre_arguments != 0) && ((*s_etat_processus).erreur_systeme
+					== d_es))
 			{
 				execvp(arguments[0], arguments);
 			}
-			else
-			{
-				exit(EXIT_SUCCESS);
-			}
 
 			/*
 			 * L'appel système execvp() a généré une erreur et n'a pu exécuter
@@ -3818,10 +3933,42 @@ instruction_syseval(struct_processus *s_
 			write_atomic(s_etat_processus, pipes_erreur[1], " ", 1);
 			close(pipes_erreur[1]);
 
+			if ((*s_etat_processus).langue == 'F')
+			{
+				printf("+++Système : erreur interne dans SYSEVAL [%d]\n",
+						(int) getpid());
+			}
+			else
+			{
+				printf("+++System : SYSEVAL internal error [%d]\n",
+						(int) getpid());
+			}
+
 			exit(EXIT_SUCCESS);
 		}
 		else
 		{
+			if (sigaction(SIGINT, &action_passee, NULL) != 0)
+			{
+				for(i = 0; i < nombre_arguments; i++)
+				{
+					depilement(s_etat_processus,
+							&((*s_etat_processus).l_base_pile),
+							&s_objet_temporaire);
+					liberation(s_etat_processus, s_objet_temporaire);
+				}
+
+				free(arguments);
+				(*s_etat_processus).erreur_systeme = d_es_signal;
+				return;
+			}
+
+			if (pthread_mutex_unlock(&mutex_sigaction) != 0)
+			{
+				(*s_etat_processus).erreur_systeme = d_es_processus;
+				return;
+			}
+
 			deverrouillage_threads_concurrents(s_etat_processus);
 
 			if (close(pipes_entree[0]) != 0)
@@ -3844,128 +3991,38 @@ instruction_syseval(struct_processus *s_
 
 			if (presence_stdin == d_vrai)
 			{
-				l_element_courant = l_element_stdin;
+				// L'écriture sur stdin est dans un thread séparé pour
+				// ne pas bloquer.
 
-				while(l_element_courant != NULL)
+				if (pthread_attr_init(&attributs) != 0)
 				{
-					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)
-#					else
-						if (sem_post((*s_etat_processus).semaphore_fork) != 0)
-#					endif
-					{
-						(*s_etat_processus).erreur_systeme = d_es_processus;
-						return;
-					}
-
-					while(write_atomic(s_etat_processus,
-							pipes_entree[1], ligne,
-							(size_t) longueur_ecriture) != longueur_ecriture)
-					{
-#						ifndef SEMAPHORES_NOMMES
-							while(sem_wait(&((*s_etat_processus)
-									.semaphore_fork)) != 0)
-#						else
-							while(sem_wait((*s_etat_processus)
-									.semaphore_fork) != 0)
-#						endif
-						{
-							(*s_etat_processus).erreur_systeme =
-									d_es_processus;
-							return;
-						}
-
-						if (longueur_ecriture == -1)
-						{
-							(*s_etat_processus).erreur_systeme = d_es_processus;
-							return;
-						}
-
-#						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;
-						}
-					}
-
-					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)) != 0)
-#						else
-							while(sem_wait((*s_etat_processus)
-									.semaphore_fork) != 0)
-#						endif
-						{
-							if (errno != EINTR)
-							{
-								(*s_etat_processus).erreur_systeme =
-										d_es_processus;
-								return;
-							}
-						}
-
-						if (longueur_ecriture == -1)
-						{
-							(*s_etat_processus).erreur_systeme = d_es_processus;
-							return;
-						}
+					(*s_etat_processus).erreur_systeme = d_es_processus;
+					return;
+				}
 
-#						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;
-						}
-					}
+				if (pthread_attr_setdetachstate(&attributs, 
+						PTHREAD_CREATE_JOINABLE) != 0)
+				{
+					(*s_etat_processus).erreur_systeme = d_es_processus;
+					return;
+				}
 
-#					ifndef SEMAPHORES_NOMMES
-						while(sem_wait(&((*s_etat_processus).semaphore_fork))
-								!= 0)
-#					else
-						while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
-#					endif
-					{
-						if (errno != EINTR)
-						{
-							(*s_etat_processus).erreur_systeme = d_es_processus;
-							return;
-						}
-					}
+				arguments_stdin.s_etat_processus = s_etat_processus;
+				arguments_stdin.fd_stdin = l_element_stdin;
+				arguments_stdin.pipe_entree = pipes_entree[1];
 
-					l_element_courant = (*l_element_courant).suivant;
+				if (pthread_create(&thread_stdin_tid, &attributs, thread_stdin,
+						&arguments_stdin) != 0)
+				{
+					(*s_etat_processus).erreur_systeme = d_es_processus;
+					return;
 				}
-			}
 
-			if (close(pipes_entree[1]) != 0)
-			{
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
+				if (pthread_attr_destroy(&attributs) != 0)
+				{
+					(*s_etat_processus).erreur_systeme = d_es_processus;
+					return;
+				}
 			}
 
 			longueur_lecture = 65536;
@@ -3991,10 +4048,22 @@ instruction_syseval(struct_processus *s_
 				return;
 			}
 
-			while((ios = (int) read_atomic(s_etat_processus,
+			processus_tue = d_faux;
+
+			while((ios = (int) read_atomic_signal(s_etat_processus,
 					pipes_sortie[0], &(tampon[pointeur]),
-					(size_t) longueur_lecture)) > 0)
+					(size_t) longueur_lecture)) >= 0)
 			{
+				if ((ios == 0) && ((*s_etat_processus)
+						.var_volatile_requete_arret == 0))
+				{
+					// Correspond à un buffer vide en l'absence
+					// d'interruption. On ne boucle pas, il n'y a rien à
+					// lire.
+
+					break;
+				}
+
 #				ifndef SEMAPHORES_NOMMES
 					while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
 #				else
@@ -4027,16 +4096,99 @@ instruction_syseval(struct_processus *s_
 					(*s_etat_processus).erreur_systeme = d_es_processus;
 					return;
 				}
+
+				if ((*s_etat_processus).var_volatile_requete_arret == -1)
+				{
+					gettimeofday(&horodatage_initial, NULL);
+					kill(pid, SIGTERM);
+
+					if ((fpipe = fdopen(pipes_sortie[0], "r")) == NULL)
+					{
+						(*s_etat_processus).erreur_systeme =
+								d_es_erreur_fichier;
+						return;
+					}
+
+					attente.tv_sec = 0;
+					attente.tv_nsec = GRANULARITE_us * 1000;
+
+					if (kill(pid, 0) == 0)
+					{
+						while(feof(fpipe) == 0)
+						{
+							fds.fd = pipes_sortie[0];
+							fds.events = POLLIN;
+
+							if (poll(&fds, 1, 0) > 0)
+							{
+								getc(fpipe);
+								attente.tv_sec = 0;
+								attente.tv_nsec = GRANULARITE_us * 1000;
+							}
+							else
+							{
+								nanosleep(&attente, NULL);
+								INCR_GRANULARITE(attente.tv_nsec);
+							}
+
+							gettimeofday(&horodatage_final, NULL);
+
+							// Si au bout de 10 secondes après le premier
+							// signal, il reste des données à lire, le processus
+							// est sans doute encore actif. On envoie donc
+							// un signal 9.
+
+							if ((horodatage_final.tv_sec -
+									horodatage_initial.tv_sec) > 10)
+							{
+								kill(pid, SIGKILL);
+								gettimeofday(&horodatage_initial, NULL);
+								processus_tue = d_vrai;
+							}
+						}
+					}
+				}
+
+				if (processus_tue == d_vrai)
+				{
+					break;
+				}
 			}
 
 #			ifndef SEMAPHORES_NOMMES
-				if (sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
+				while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
 #			else
-				if (sem_wait((*s_etat_processus).semaphore_fork) != 0)
+				while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
 #			endif
 			{
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
+				if (errno != EINTR)
+				{
+					(*s_etat_processus).erreur_systeme = d_es_processus;
+					return;
+				}
+			}
+
+			if (presence_stdin == d_vrai)
+			{
+				if (pthread_join(thread_stdin_tid, NULL) != 0)
+				{
+					(*s_etat_processus).erreur_systeme = d_es_processus;
+					return;
+				}
+
+				if (arguments_stdin.erreur != d_es)
+				{
+					(*s_etat_processus).erreur_systeme = arguments_stdin.erreur;
+					return;
+				}
+			}
+			else
+			{
+				if (close(pipes_entree[1]) != 0)
+				{
+					(*s_etat_processus).erreur_systeme = d_es_processus;
+					return;
+				}
 			}
 
 			do
@@ -4186,20 +4338,6 @@ instruction_syseval(struct_processus *s_
 			free(tampon);
 		}
 
-		if (sigaction(SIGINT, &action_passee, NULL) != 0)
-		{
-			for(i = 0; i < nombre_arguments; i++)
-			{
-				depilement(s_etat_processus, &((*s_etat_processus).l_base_pile),
-						&s_objet_temporaire);
-				liberation(s_etat_processus, s_objet_temporaire);
-			}
-
-			free(arguments);
-			(*s_etat_processus).erreur_systeme = d_es_signal;
-			return;
-		}
-
 		for(i = 0; i < nombre_arguments; i++)
 		{
 			depilement(s_etat_processus, &((*s_etat_processus).l_base_pile),