--- rpl/src/instructions_c4.c 2010/03/05 11:20:08 1.6 +++ rpl/src/instructions_c4.c 2010/03/06 18:29:07 1.7 @@ -753,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; @@ -836,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) { @@ -856,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; @@ -879,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 *) @@ -1023,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; @@ -1067,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);