--- rpl/src/instructions_c4.c 2010/01/26 15:22:45 1.1.1.1 +++ rpl/src/instructions_c4.c 2010/08/26 19:07:37 1.16 @@ -1,6 +1,6 @@ /* ================================================================================ - RPL/2 (R) version 4.0.9 + RPL/2 (R) version 4.0.19 Copyright (C) 1989-2010 Dr. BERTRAND Joël This file is part of RPL/2. @@ -20,8 +20,8 @@ */ -#include "rpl.conv.h" -#include "convert.conv.h" +#include "rpl-conv.h" +#include "convert-conv.h" /* @@ -402,7 +402,7 @@ instruction_corr(struct_processus *s_eta void instruction_copyright(struct_processus *s_etat_processus) { -# include "copyright.conv.h" +# include "copyright-conv.h" (*s_etat_processus).erreur_execution = d_ex; @@ -472,6 +472,7 @@ instruction_convert(struct_processus *s_ struct_objet *s_objet_argument_3; unsigned char *commande; + unsigned char *executable_candidat; unsigned char ligne[1024 + 1]; unsigned char *tampon_instruction; @@ -543,21 +544,89 @@ instruction_convert(struct_processus *s_ (((*s_objet_argument_3).type == INT) || ((*s_objet_argument_3).type == REL))) { - longueur_chaine = strlen(ds_rplconvert_commande) - 9 - + strlen((unsigned char *) (*s_objet_argument_1).objet) - + strlen((unsigned char *) (*s_objet_argument_2).objet) - + (2 * strlen(d_exec_path)); - - if ((commande = malloc((longueur_chaine + 1) * sizeof(unsigned char))) - == NULL) + if ((*s_etat_processus).rpl_home == NULL) { - (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; - return; + longueur_chaine = strlen(ds_rplconvert_commande) - 9 + + strlen((unsigned char *) (*s_objet_argument_1).objet) + + strlen((unsigned char *) (*s_objet_argument_2).objet) + + (2 * strlen(d_exec_path)); + + if ((commande = malloc((longueur_chaine + 1) * + sizeof(unsigned char))) == NULL) + { + (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; + return; + } + + sprintf(commande, ds_rplconvert_commande, d_exec_path, d_exec_path, + (unsigned char *) (*s_objet_argument_2).objet, + (unsigned char *) (*s_objet_argument_1).objet); + + if (alsprintf(&executable_candidat, "%s/bin/rplconvert", + d_exec_path) < 0) + { + (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; + return; + } + + if (controle(s_etat_processus, executable_candidat, "md5", + rplconvert_md5) != d_vrai) + { + (*s_etat_processus).erreur_systeme = d_es_somme_controle; + return; + } + + if (controle(s_etat_processus, executable_candidat, "sha1", + rplconvert_sha1) != d_vrai) + { + (*s_etat_processus).erreur_systeme = d_es_somme_controle; + return; + } + + free(executable_candidat); } + else + { + longueur_chaine = strlen(ds_rplconvert_commande) - 9 + + strlen((unsigned char *) (*s_objet_argument_1).objet) + + strlen((unsigned char *) (*s_objet_argument_2).objet) + + (2 * strlen((*s_etat_processus).rpl_home)); - sprintf(commande, ds_rplconvert_commande, d_exec_path, d_exec_path, - (unsigned char *) (*s_objet_argument_2).objet, - (unsigned char *) (*s_objet_argument_1).objet); + if ((commande = malloc((longueur_chaine + 1) * + sizeof(unsigned char))) == NULL) + { + (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; + return; + } + + sprintf(commande, ds_rplconvert_commande, + (*s_etat_processus).rpl_home, (*s_etat_processus).rpl_home, + (unsigned char *) (*s_objet_argument_2).objet, + (unsigned char *) (*s_objet_argument_1).objet); + + if (alsprintf(&executable_candidat, "%s/bin/rplconvert", + (*s_etat_processus).rpl_home) < 0) + { + (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; + return; + } + + if (controle(s_etat_processus, executable_candidat, "md5", + rplconvert_md5) != d_vrai) + { + (*s_etat_processus).erreur_systeme = d_es_somme_controle; + return; + } + + if (controle(s_etat_processus, executable_candidat, "sha1", + rplconvert_sha1) != d_vrai) + { + (*s_etat_processus).erreur_systeme = d_es_somme_controle; + return; + } + + free(executable_candidat); + } if ((pipe = popen(commande, "r")) == NULL) { @@ -684,12 +753,16 @@ instruction_convert(struct_processus *s_ void instruction_close(struct_processus *s_etat_processus) { - file *descripteur; + const char *queue; int socket; logical1 socket_connectee; + sqlite3_stmt *ppStmt; + + struct_descripteur_fichier *descripteur; + struct_liste_chainee *l_element_courant; struct_liste_chainee *l_element_precedent; @@ -767,8 +840,8 @@ instruction_close(struct_processus *s_et (*((struct_descripteur_fichier *) (*l_element_courant) .donnee)).tid) != 0)) { - descripteur = (*((struct_descripteur_fichier *) - (*l_element_courant).donnee)).descripteur; + descripteur = (struct_descripteur_fichier *) + (*l_element_courant).donnee; if (l_element_precedent == NULL) { @@ -787,7 +860,6 @@ instruction_close(struct_processus *s_et free((*((struct_descripteur_fichier *) (*l_element_courant).donnee)).nom); - free((*l_element_courant).donnee); free(l_element_courant); break; @@ -810,14 +882,57 @@ instruction_close(struct_processus *s_et * Fermeture du fichier */ - if (fclose(descripteur) != 0) + if (fclose((*descripteur).descripteur_c) != 0) { + free(descripteur); liberation(s_etat_processus, s_objet_argument); (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; return; } + if ((*descripteur).type != 'C') + { + if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite, + "vacuum", 7, &ppStmt, &queue) != SQLITE_OK) + { + free(descripteur); + liberation(s_etat_processus, s_objet_argument); + + (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; + return; + } + + if (sqlite3_step(ppStmt) != SQLITE_DONE) + { + free(descripteur); + liberation(s_etat_processus, s_objet_argument); + + (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; + return; + } + + if (sqlite3_finalize(ppStmt) != SQLITE_OK) + { + free(descripteur); + liberation(s_etat_processus, s_objet_argument); + + (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; + return; + } + + if (sqlite3_close((*descripteur).descripteur_sqlite) != SQLITE_OK) + { + free(descripteur); + liberation(s_etat_processus, s_objet_argument); + + (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; + return; + } + + free(descripteur); + } + if ((*((struct_fichier *) (*s_objet_argument).objet)).ouverture == 'S') { if (destruction_fichier((*((struct_fichier *) @@ -954,6 +1069,8 @@ instruction_create(struct_processus *s_e struct_objet *s_objet_argument; + unsigned char *nom; + unsigned long unite; (*s_etat_processus).erreur_execution = d_ex; @@ -998,28 +1115,38 @@ instruction_create(struct_processus *s_e if ((*s_objet_argument).type == CHN) { - erreur = caracteristiques_fichier(s_etat_processus, (unsigned char *) - (*s_objet_argument).objet, &existence, &ouverture, &unite); + if ((nom = transliteration(s_etat_processus, (unsigned char *) + (*s_objet_argument).objet, d_locale, "UTF-8")) == NULL) + { + liberation(s_etat_processus, s_objet_argument); + return; + } + + erreur = caracteristiques_fichier(s_etat_processus, nom, + &existence, &ouverture, &unite); if ((erreur != d_absence_erreur) || (existence == d_vrai)) { liberation(s_etat_processus, s_objet_argument); + free(nom); (*s_etat_processus).erreur_execution = d_ex_erreur_acces_fichier; return; } - if ((fichier = fopen((unsigned char *) (*s_objet_argument).objet, "w")) - == NULL) + if ((fichier = fopen(nom, "w")) == NULL) { liberation(s_etat_processus, s_objet_argument); + free(nom); (*s_etat_processus).erreur_execution = d_ex_erreur_acces_fichier; return; } + free(nom); + if (fclose(fichier) != 0) { liberation(s_etat_processus, s_objet_argument);