--- rpl/src/instructions_s1.c 2019/02/07 21:44:15 1.99 +++ rpl/src/instructions_s1.c 2019/05/16 09:15:08 1.106 @@ -3372,6 +3372,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,9 +3460,6 @@ instruction_syseval(struct_processus *s_ int pipes_sortie[2]; int status; - integer8 longueur_ecriture; - integer8 longueur_traitee; - logical1 drapeau_fin; logical1 presence_stdin; @@ -3394,6 +3468,10 @@ instruction_syseval(struct_processus *s_ 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; @@ -3406,7 +3484,8 @@ instruction_syseval(struct_processus *s_ struct sigaction action_courante; struct sigaction action_passee; - unsigned char *ligne; + struct timespec attente; + unsigned char *ptr; unsigned char *ptr2; unsigned char registre_autorisation_empilement_programme; @@ -3417,6 +3496,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 +3731,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 +3751,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 +3849,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 +3869,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 +3878,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 +3887,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 +3924,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 : erreurinterne 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 +3982,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; - } - } + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } - if (longueur_ecriture == -1) - { - (*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 - 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; - } - } + arguments_stdin.s_etat_processus = s_etat_processus; + arguments_stdin.fd_stdin = l_element_stdin; + arguments_stdin.pipe_entree = pipes_entree[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; - } - } - - 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; @@ -4030,13 +4078,39 @@ instruction_syseval(struct_processus *s_ } # 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 +4260,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),