--- rpl/src/instructions_w1.c 2012/06/21 16:07:25 1.63 +++ rpl/src/instructions_w1.c 2012/06/22 10:12:19 1.64 @@ -391,8 +391,10 @@ instruction_write(struct_processus *s_et integer8 id; integer8 ordre; + logical1 format_degenere; logical1 mise_a_jour; + long longueur; long longueur_effective; long recursivite; @@ -428,7 +430,7 @@ instruction_write(struct_processus *s_et unsigned char *chaine_utf8; unsigned char *clef_utf8; unsigned char *commande; - unsigned char retour; + unsigned char *format_chaine; unsigned long i; @@ -1350,46 +1352,145 @@ instruction_write(struct_processus *s_et return; } - if ((*((*((struct_liste_chainee *) (*s_objet_argument_2).objet)) - .donnee)).type != CHN) + l_element_courant = (*s_objet_argument_2).objet; + l_element_courant_format = (struct_liste_chainee *) + (*(*((struct_fichier *) (*s_objet_argument_1).objet)) + .format).objet; + + while((l_element_courant != NULL) && + (l_element_courant_format != NULL)) { - liberation(s_etat_processus, s_objet_argument_2); - liberation(s_etat_processus, s_objet_argument_1); + if ((*(*l_element_courant).donnee).type != CHN) + { + liberation(s_etat_processus, s_objet_argument_2); + liberation(s_etat_processus, s_objet_argument_1); - (*s_etat_processus).erreur_execution = - d_ex_erreur_type_argument; - return; - } + (*s_etat_processus).erreur_execution = + d_ex_erreur_type_argument; + return; + } - if ((chaine = formateur_flux(s_etat_processus, (unsigned char *) - (*((*((struct_liste_chainee *) (*s_objet_argument_2) - .objet)).donnee)).objet, &longueur_effective)) == NULL) - { - (*s_etat_processus).erreur_systeme = - d_es_allocation_memoire; - return; - } + if ((*(*l_element_courant_format).donnee).type != CHN) + { + liberation(s_etat_processus, s_objet_argument_2); + liberation(s_etat_processus, s_objet_argument_1); - if (fwrite(chaine, sizeof(unsigned char), longueur_effective, - (*descripteur).descripteur_c) != - (size_t) longueur_effective) - { - (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; - return; - } + (*s_etat_processus).erreur_execution = + d_ex_erreur_type_argument; + return; + } - free(chaine); + if ((format_chaine = conversion_majuscule((unsigned char *) + (*(*l_element_courant_format).donnee).objet)) + == NULL) + { + (*s_etat_processus).erreur_systeme = + d_es_allocation_memoire; + return; + } + + if (strncmp("LENGTH*(", format_chaine, 8) != 0) + { + free(format_chaine); + + liberation(s_etat_processus, s_objet_argument_2); + liberation(s_etat_processus, s_objet_argument_1); + + (*s_etat_processus).erreur_execution = + d_ex_erreur_format_fichier; + return; + } + + longueur = strlen(format_chaine); + + if (format_chaine[longueur] != ')') + { + free(format_chaine); - // Le fichier de type FLOW est à accès séquentiel. Il - // convient d'ajouter un retour à la ligne pour l'opération - // de lecture. + liberation(s_etat_processus, s_objet_argument_2); + liberation(s_etat_processus, s_objet_argument_1); + + (*s_etat_processus).erreur_execution = + d_ex_erreur_format_fichier; + return; + } + + format_chaine[longueur] = d_code_fin_chaine; + + if (format_chaine[8] == '*') + { + format_degenere = d_vrai; + } + else + { + // Détermination de la longueur + format_degenere = d_faux; + + if (sscanf(&(format_chaine[8]), "%ld", &longueur) != 1) + { + free(format_chaine); + + liberation(s_etat_processus, s_objet_argument_2); + liberation(s_etat_processus, s_objet_argument_1); - retour = d_code_retour_chariot; + (*s_etat_processus).erreur_execution = + d_ex_erreur_format_fichier; + return; + } + } + + free(format_chaine); - if (fwrite(&retour, sizeof(unsigned char), 1, - (*descripteur).descripteur_c) != 1) + if ((chaine = formateur_flux(s_etat_processus, + (unsigned char *) (*(*l_element_courant).donnee) + .objet, &longueur_effective)) == NULL) + { + (*s_etat_processus).erreur_systeme = + d_es_allocation_memoire; + return; + } + + if ((format_degenere == d_vrai) || + (longueur_effective < longueur)) + { + if (fwrite(chaine, sizeof(unsigned char), + longueur_effective, + (*descripteur).descripteur_c) != + (size_t) longueur_effective) + { + (*s_etat_processus).erreur_systeme = + d_es_erreur_fichier; + return; + } + } + else + { + if (fwrite(chaine, sizeof(unsigned char), + longueur_effective, + (*descripteur).descripteur_c) != + (size_t) longueur) + { + (*s_etat_processus).erreur_systeme = + d_es_erreur_fichier; + return; + } + } + + free(chaine); + + l_element_courant = (*l_element_courant).suivant; + l_element_courant_format = (*l_element_courant_format) + .suivant; + } + + if ((l_element_courant_format != NULL) || + (l_element_courant != NULL)) { - (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; + liberation(s_etat_processus, s_objet_argument_2); + liberation(s_etat_processus, s_objet_argument_1); + + (*s_etat_processus).erreur_execution = + d_ex_erreur_format_fichier; return; } }