--- rpl/src/instructions_s1.c 2019/06/17 13:27:35 1.108 +++ rpl/src/instructions_s1.c 2019/07/19 06:53:29 1.112 @@ -19,7 +19,7 @@ ================================================================================ */ - +#define DEBUG_ERREURS #include "rpl-conv.h" @@ -3484,6 +3484,8 @@ 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; @@ -3875,7 +3877,7 @@ instruction_syseval(struct_processus *s_ if (dup2(pipes_entree[0], STDIN_FILENO) == -1) { (*s_etat_processus).erreur_systeme = d_es_processus; - printf("%d\n",__LINE__); + printf("%d\n",__LINE__); } } @@ -3884,7 +3886,7 @@ instruction_syseval(struct_processus *s_ if (dup2(pipes_sortie[1], STDOUT_FILENO) == -1) { (*s_etat_processus).erreur_systeme = d_es_processus; - printf("%d\n",__LINE__); + printf("%d\n",__LINE__); } } @@ -3893,7 +3895,7 @@ instruction_syseval(struct_processus *s_ if (dup2(pipes_sortie[1], STDERR_FILENO) == -1) { (*s_etat_processus).erreur_systeme = d_es_processus; - printf("%d\n",__LINE__); + printf("%d\n",__LINE__); } } @@ -3932,7 +3934,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 @@ -4047,8 +4049,18 @@ instruction_syseval(struct_processus *s_ 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 @@ -4103,9 +4115,26 @@ instruction_syseval(struct_processus *s_ } etape = 1; + attente.tv_sec = 0; + attente.tv_nsec = GRANULARITE_us * 1000; - while((ios = getc(fpipe)) != EOF) + fds.fd = pipes_sortie[0]; + fds.events = POLLIN; + + while(feof(fpipe) != 0) { + 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); + } + if (etape == 1) { gettimeofday(&horodatage_final, NULL); @@ -4125,7 +4154,6 @@ instruction_syseval(struct_processus *s_ } } - fclose(fpipe); break; } }