--- rpl/src/instructions_s8.c 2013/04/01 15:29:38 1.58 +++ rpl/src/instructions_s8.c 2013/05/21 12:10:12 1.59 @@ -133,10 +133,6 @@ instruction_splash(struct_processus *s_e void instruction_send(struct_processus *s_etat_processus) { - pid_t pid; - - pthread_t tid; - sig_atomic_t registre; ssize_t longueur_ecriture; @@ -145,6 +141,7 @@ instruction_send(struct_processus *s_eta struct timespec attente; + unsigned char caractere; unsigned char tampon; (*s_etat_processus).erreur_execution = d_ex; @@ -242,11 +239,6 @@ instruction_send(struct_processus *s_eta } } - pid = -3; - - attente.tv_sec = 0; - attente.tv_nsec = GRANULARITE_us * 1000; - # ifndef SEMAPHORES_NOMMES if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0) # else @@ -257,58 +249,14 @@ instruction_send(struct_processus *s_eta return; } - while((longueur_ecriture = write_atomic(s_etat_processus, - (*s_etat_processus).pipe_nombre_objets_attente, - &pid, sizeof(pid))) != sizeof(pid)) - { -# 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) - { - if ((*s_etat_processus).profilage == d_vrai) - { - profilage(s_etat_processus, NULL); - } - - (*s_etat_processus).erreur_systeme = d_es_processus; - return; - } - - nanosleep(&attente, NULL); - INCR_GRANULARITE(attente.tv_nsec); - -# 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; - } - - scrutation_interruptions(s_etat_processus); - } - - pid = getpid(); + caractere = 1; attente.tv_sec = 0; attente.tv_nsec = GRANULARITE_us * 1000; while((longueur_ecriture = write_atomic(s_etat_processus, - (*s_etat_processus).pipe_nombre_objets_attente, - &pid, sizeof(pid))) != sizeof(pid)) + (*s_etat_processus).pipe_nombre_elements_attente, + &caractere, sizeof(caractere))) != sizeof(caractere)) { # ifndef SEMAPHORES_NOMMES while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0) @@ -375,8 +323,6 @@ instruction_send(struct_processus *s_eta } } - tid = (pthread_t) -3; - attente.tv_sec = 0; attente.tv_nsec = GRANULARITE_us * 1000; @@ -390,55 +336,14 @@ instruction_send(struct_processus *s_eta return; } - while((longueur_ecriture = write_atomic(s_etat_processus, - (*s_etat_processus).pipe_nombre_objets_attente, - &tid, sizeof(tid))) != sizeof(tid)) - { -# 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) - { - if ((*s_etat_processus).profilage == d_vrai) - { - profilage(s_etat_processus, NULL); - } - - (*s_etat_processus).erreur_systeme = d_es_processus; - return; - } - - nanosleep(&attente, NULL); - INCR_GRANULARITE(attente.tv_nsec); - -# 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; - } - - scrutation_interruptions(s_etat_processus); - } - - tid = pthread_self(); + caractere = 1; attente.tv_sec = 0; attente.tv_nsec = GRANULARITE_us * 1000; while((longueur_ecriture = write_atomic(s_etat_processus, - (*s_etat_processus).pipe_nombre_objets_attente, - &tid, sizeof(tid))) != sizeof(tid)) + (*s_etat_processus).pipe_nombre_elements_attente, + &caractere, sizeof(caractere))) != sizeof(caractere)) { # ifndef SEMAPHORES_NOMMES while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0) @@ -551,155 +456,6 @@ instruction_send(struct_processus *s_eta } } - // Envoi d'un PID invalide (-1) pour ne pas bloquer le thread - // de surveillance. - - if ((*s_etat_processus).processus_detache == d_vrai) - { - pid = -1; - - attente.tv_sec = 0; - attente.tv_nsec = GRANULARITE_us * 1000; - -# 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((longueur_ecriture = write_atomic(s_etat_processus, - (*s_etat_processus).pipe_nombre_interruptions_attente, - &pid, sizeof(pid))) != sizeof(pid)) - { -# 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 (longueur_ecriture == -1) - { - if ((*s_etat_processus).profilage == d_vrai) - { - profilage(s_etat_processus, NULL); - } - - (*s_etat_processus).erreur_systeme = d_es_processus; - return; - } - - nanosleep(&attente, NULL); - INCR_GRANULARITE(attente.tv_nsec); - -# 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; - } - } - -# 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; - } - } - - scrutation_interruptions(s_etat_processus); - } - else - { - tid = (pthread_t) -1; - - attente.tv_sec = 0; - attente.tv_nsec = GRANULARITE_us * 1000; - -# 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((longueur_ecriture = write_atomic(s_etat_processus, - (*s_etat_processus).pipe_nombre_interruptions_attente, - &tid, sizeof(tid))) != sizeof(tid)) - { -# 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) - { - if ((*s_etat_processus).profilage == d_vrai) - { - profilage(s_etat_processus, NULL); - } - - (*s_etat_processus).erreur_systeme = d_es_processus; - return; - } - - nanosleep(&attente, NULL); - INCR_GRANULARITE(attente.tv_nsec); - -# 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; - } - - scrutation_interruptions(s_etat_processus); - } - -# 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; - } - } - } - // ecriture_pipe() ne peut être interrompu par un signal. # ifndef SEMAPHORES_NOMMES