--- rpl/src/transliteration.c 2010/09/07 12:54:03 1.22 +++ rpl/src/transliteration.c 2011/09/20 09:51:43 1.43 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.0.19 - Copyright (C) 1989-2010 Dr. BERTRAND Joël + RPL/2 (R) version 4.1.3 + Copyright (C) 1989-2011 Dr. BERTRAND Joël This file is part of RPL/2. @@ -105,7 +105,8 @@ reencodage(struct_processus *s_etat_proc chaine_sortie[0] = d_code_fin_chaine; - if ((buffer_sortie = malloc((d_LONGUEUR + 1) * sizeof(char))) == NULL) + if ((buffer_sortie = malloc((d_LONGUEUR + 1) * sizeof(unsigned char))) + == NULL) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; return(NULL); @@ -131,7 +132,7 @@ reencodage(struct_processus *s_etat_proc } } - tampon = (unsigned char *) chaine_sortie; + tampon = chaine_sortie; (*pointeur) = d_code_fin_chaine; if ((chaine_sortie = malloc((strlen(tampon) + strlen(buffer_sortie) + 1) @@ -158,8 +159,8 @@ reencodage(struct_processus *s_etat_proc ================================================================================ Entrées : -------------------------------------------------------------------------------- + Sorties : -------------------------------------------------------------------------------- - iorties : Effets de bord : néant ================================================================================ */ @@ -175,16 +176,11 @@ localisation_courante(struct_processus * int pipes_sortie[2]; int status; - logical1 drapeau_fin; - long i; long nombre_arguments; pid_t pid; - sigset_t oldset; - sigset_t set; - struct sigaction action_passee; unsigned char *tampon; @@ -216,7 +212,6 @@ localisation_courante(struct_processus * arguments[2] = NULL; nombre_arguments = 2; - drapeau_fin = d_faux; if (pipe(pipes_entree) != 0) { @@ -236,16 +231,10 @@ localisation_courante(struct_processus * return; } - sigfillset(&set); - pthread_sigmask(SIG_BLOCK, &set, &oldset); - verrouillage_threads_concurrents(s_etat_processus); pid = fork(); deverrouillage_threads_concurrents(s_etat_processus); - pthread_sigmask(SIG_SETMASK, &oldset, NULL); - sigpending(&set); - if (pid < 0) { if (close(pipes_entree[0]) != 0) @@ -407,11 +396,7 @@ localisation_courante(struct_processus * * Récupération de la valeur de retour du processus détaché */ -# 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; @@ -419,11 +404,7 @@ localisation_courante(struct_processus * if (waitpid(pid, &status, 0) == -1) { -# ifndef SEMAPHORES_NOMMES - if (sem_wait(&((*s_etat_processus).semaphore_fork)) == -1) -# else - if (sem_wait((*s_etat_processus).semaphore_fork) == -1) -# endif + while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0) { if (errno != EINTR) { @@ -436,11 +417,7 @@ localisation_courante(struct_processus * return; } -# ifndef SEMAPHORES_NOMMES - if (sem_wait(&((*s_etat_processus).semaphore_fork)) == -1) -# else - if (sem_wait((*s_etat_processus).semaphore_fork) == -1) -# endif + while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0) { if (errno != EINTR) { @@ -463,11 +440,7 @@ localisation_courante(struct_processus * tampon[0] = d_code_fin_chaine; -# 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; @@ -477,11 +450,7 @@ localisation_courante(struct_processus * pipes_sortie[0], &(tampon[pointeur]), longueur_lecture)) > 0) { -# ifndef SEMAPHORES_NOMMES - while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1) -# else - while(sem_wait((*s_etat_processus).semaphore_fork) == -1) -# endif + while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0) { if (errno != EINTR) { @@ -503,22 +472,14 @@ localisation_courante(struct_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; } } -# ifndef SEMAPHORES_NOMMES - while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1) -# else - while(sem_wait((*s_etat_processus).semaphore_fork) == -1) -# endif + while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0) { if (errno != EINTR) { @@ -584,11 +545,7 @@ localisation_courante(struct_processus * free(arguments); -# 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; @@ -610,11 +567,7 @@ localisation_courante(struct_processus * strcpy((*s_etat_processus).localisation, d_locale); } -# ifndef SEMAPHORES_NOMMES - while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1) -# else - while(sem_wait((*s_etat_processus).semaphore_fork) == -1) -# endif + while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0) { if (errno != EINTR) { @@ -686,50 +639,53 @@ transliterated_fprintf(struct_processus } # ifdef OS2 - i = 0; - ptr_l = tampon2; - - while((*ptr_l) != d_code_fin_chaine) + if ((flux == stdin) || (flux == stdout)) { - if ((*ptr_l) == '\n') - { - i++; - } + i = 0; + ptr_l = tampon2; - ptr_l++; - } - - if ((tampon3 = malloc((strlen(tampon2) + i + 1) * sizeof(unsigned char))) - == NULL) - { - (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; - return(NULL); - } - - ptr_e = tampon3; - ptr_l = tampon2; + while((*ptr_l) != d_code_fin_chaine) + { + if ((*ptr_l) == '\n') + { + i++; + } - while((*ptr_l) != d_code_fin_chaine) - { - (*ptr_e) = (*ptr_l); + ptr_l++; + } - if ((*ptr_l) == '\n') + if ((tampon3 = malloc((strlen(tampon2) + i + 1) * + sizeof(unsigned char))) == NULL) { - (*(++ptr_e)) = '\r'; - ptr_e++; - ptr_l++; + (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; + return(NULL); } - else + + ptr_e = tampon3; + ptr_l = tampon2; + + while((*ptr_l) != d_code_fin_chaine) { - ptr_e++; - ptr_l++; + (*ptr_e) = (*ptr_l); + + if ((*ptr_l) == '\n') + { + (*(++ptr_e)) = '\r'; + ptr_e++; + ptr_l++; + } + else + { + ptr_e++; + ptr_l++; + } } - } - (*ptr_e) = d_code_fin_chaine; + (*ptr_e) = d_code_fin_chaine; - free(tampon2); - tampon2 = tampon3; + free(tampon2); + tampon2 = tampon3; + } # endif # ifdef SunOS