--- rpl/src/instructions_s1.c 2019/02/17 08:59:39 1.103 +++ rpl/src/instructions_s1.c 2020/11/01 08:51:41 1.116 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.1.31 - Copyright (C) 1989-2019 Dr. BERTRAND Joël + RPL/2 (R) version 4.1.32 + Copyright (C) 1989-2020 Dr. BERTRAND Joël This file is part of RPL/2. @@ -20,6 +20,7 @@ */ +#define DEBUG_ERREURS #include "rpl-conv.h" @@ -3372,10 +3373,10 @@ instruction_sto(struct_processus *s_etat ================================================================================ */ -struct +static struct { struct_processus *s_etat_processus; - struct_liste_chainee *stdin; + struct_liste_chainee *fd_stdin; int pipe_entree; volatile int erreur; } arguments_stdin; @@ -3395,7 +3396,7 @@ thread_stdin(void *argument) ptr = argument; - l_element_courant = (*ptr).stdin; + l_element_courant = (*ptr).fd_stdin; s_etat_processus = (*ptr).s_etat_processus; (*ptr).erreur = d_es; @@ -3460,8 +3461,11 @@ instruction_syseval(struct_processus *s_ int pipes_sortie[2]; int status; + file *fpipe; + logical1 drapeau_fin; logical1 presence_stdin; + logical1 processus_tue; long i; long nombre_arguments; @@ -3481,11 +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; struct timespec attente; + struct timeval horodatage_final; + struct timeval horodatage_initial; + unsigned char *ptr; unsigned char *ptr2; unsigned char registre_autorisation_empilement_programme; @@ -3796,6 +3805,7 @@ instruction_syseval(struct_processus *s_ (*s_etat_processus).erreur_systeme = d_es_signal; return; } +instruction_clmf(s_etat_processus); verrouillage_threads_concurrents(s_etat_processus); @@ -3849,19 +3859,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) @@ -3869,7 +3879,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__); } } @@ -3878,7 +3888,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__); } } @@ -3887,18 +3897,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 @@ -3927,6 +3934,17 @@ 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 @@ -3991,7 +4009,7 @@ instruction_syseval(struct_processus *s_ } arguments_stdin.s_etat_processus = s_etat_processus; - arguments_stdin.stdin = l_element_stdin; + arguments_stdin.fd_stdin = l_element_stdin; arguments_stdin.pipe_entree = pipes_entree[1]; if (pthread_create(&thread_stdin_tid, &attributs, thread_stdin, @@ -4031,10 +4049,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 @@ -4067,6 +4097,63 @@ 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