--- rpl/src/instructions_s1.c	2019/02/28 12:40:38	1.105
+++ rpl/src/instructions_s1.c	2019/07/16 08:31:22	1.109
@@ -19,7 +19,7 @@
 ================================================================================
 */
 
-
+#define DEBUG_ERREURS
 #include "rpl-conv.h"
 
 
@@ -3372,7 +3372,7 @@ instruction_sto(struct_processus *s_etat
 ================================================================================
 */
 
-struct
+static struct
 {
 	struct_processus		*s_etat_processus;
 	struct_liste_chainee	*fd_stdin;
@@ -3454,12 +3454,16 @@ instruction_syseval(struct_processus *s_
 {
 	char						**arguments;
 
+	int							etape;
 	int							ios;
 	int							pipes_entree[2];
 	int							pipes_erreur[2];
 	int							pipes_sortie[2];
+	int							registre_ios;
 	int							status;
 
+	file						*fpipe;
+
 	logical1					drapeau_fin;
 	logical1					presence_stdin;
 
@@ -3486,6 +3490,9 @@ instruction_syseval(struct_processus *s_
 
 	struct timespec				attente;
 
+	struct timeval				horodatage_final;
+	struct timeval				horodatage_initial;
+
 	unsigned char				*ptr;
 	unsigned char				*ptr2;
 	unsigned char				registre_autorisation_empilement_programme;
@@ -3926,7 +3933,7 @@ instruction_syseval(struct_processus *s_
 
 			if ((*s_etat_processus).langue == 'F')
 			{
-				printf("+++Système : erreurinterne dans SYSEVAL [%d]\n",
+				printf("+++Système : erreur interne dans SYSEVAL [%d]\n",
 						(int) getpid());
 			}
 			else
@@ -4039,10 +4046,11 @@ instruction_syseval(struct_processus *s_
 				return;
 			}
 
-			while((ios = (int) read_atomic(s_etat_processus,
+			while((ios = (int) read_atomic_signal(s_etat_processus,
 					pipes_sortie[0], &(tampon[pointeur]),
-					(size_t) longueur_lecture)) > 0)
+					(size_t) longueur_lecture)) >= 0)
 			{
+uprintf("lecture\n");
 #				ifndef SEMAPHORES_NOMMES
 					while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
 #				else
@@ -4075,6 +4083,54 @@ 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);
+
+					if ((*s_etat_processus).var_volatile_alarme == -1)
+					{
+						kill(pid, SIGKILL);
+					}
+					else
+					{
+						kill(pid, SIGTERM);
+					}
+
+					if ((fpipe = fdopen(pipes_sortie[0], "r")) == NULL)
+					{
+						(*s_etat_processus).erreur_systeme =
+								d_es_erreur_fichier;
+						return;
+					}
+
+					etape = 1;
+					registre_ios = ios;
+
+					while((ios = getc(fpipe)) != EOF)
+					{
+						if (etape == 1)
+						{
+							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)
+							{
+								etape = 2;
+								kill(pid, SIGKILL);
+								gettimeofday(&horodatage_initial, NULL);
+							}
+						}
+					}
+
+					ios = registre_ios;
+					break;
+				}
 			}
 
 #			ifndef SEMAPHORES_NOMMES