--- rpl/src/gestion_fichiers.c 2010/03/07 17:03:29 1.7 +++ rpl/src/gestion_fichiers.c 2010/08/26 19:07:36 1.19 @@ -1,6 +1,6 @@ /* ================================================================================ - RPL/2 (R) version 4.0.12 + RPL/2 (R) version 4.0.19 Copyright (C) 1989-2010 Dr. BERTRAND Joël This file is part of RPL/2. @@ -20,7 +20,7 @@ */ -#include "rpl.conv.h" +#include "rpl-conv.h" /* @@ -77,7 +77,7 @@ creation_nom_fichier(struct_processus *s do { - sprintf(tampon, "RPL2-%lu-%lu-%lu", (unsigned long) getpid(), + sprintf(tampon, "RPL-%lu-%lu-%lu", (unsigned long) getpid(), (unsigned long) pthread_self(), ordre); if (chemin == NULL) @@ -391,16 +391,18 @@ caracteristiques_fichier(struct_processu static logical1 initialisation_controle(struct_processus *s_etat_processus, sqlite3 *sqlite, - logical1 fichier_indexe) + integer8 position_clef, logical1 fichier_indexe) { const char commande1[] = - "create table control(id integer primary key asc, lock text)"; + "create table control(id integer primary key asc, key integer)"; const char commande2[] = - "insert into control (id, lock) values (2, '0')"; + "insert into control (id, key) values (1, %lld)"; const char *queue; sqlite3_stmt *ppStmt; + unsigned char *commande; + if (sqlite3_prepare_v2(sqlite, commande1, strlen(commande1), &ppStmt, &queue) != SQLITE_OK) { @@ -422,24 +424,35 @@ initialisation_controle(struct_processus if (fichier_indexe == d_vrai) { - if (sqlite3_prepare_v2(sqlite, commande2, strlen(commande2), &ppStmt, + if (alsprintf(&commande, commande2, position_clef) < 0) + { + (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; + return(d_erreur); + } + + if (sqlite3_prepare_v2(sqlite, commande, strlen(commande), &ppStmt, &queue) != SQLITE_OK) { + free(commande); (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; return(d_erreur); } if (sqlite3_step(ppStmt) != SQLITE_DONE) { + free(commande); (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; return(d_erreur); } if (sqlite3_finalize(ppStmt) != SQLITE_OK) { + free(commande); (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; return(d_erreur); } + + free(commande); } return(d_absence_erreur); @@ -447,16 +460,16 @@ initialisation_controle(struct_processus logical1 initialisation_fichier_acces_indexe(struct_processus *s_etat_processus, - sqlite3 *sqlite, logical1 binaire) + sqlite3 *sqlite, integer8 position_clef, logical1 binaire) { const char commande1[] = "create table data(id integer primary key asc, key_id integer, " - "data text, order integer)"; + "data text, sequence integer)"; const char commande10[] = "create table key(id integer primary key asc, key text)"; const char commande2[] = "create table data(id integer primary key asc, key_id integer, " - "data blob, order integer)"; + "data blob, sequence integer)"; const char commande20[] = "create table key(id integer primary key asc, key blob)"; const char commande3[] = @@ -467,7 +480,7 @@ initialisation_fichier_acces_indexe(stru sqlite3_stmt *ppStmt; - if (initialisation_controle(s_etat_processus, sqlite, d_vrai) + if (initialisation_controle(s_etat_processus, sqlite, position_clef, d_vrai) != d_absence_erreur) { return(d_erreur); @@ -609,7 +622,7 @@ initialisation_fichier_acces_direct(stru sqlite3_stmt *ppStmt; - if (initialisation_controle(s_etat_processus, sqlite, d_faux) + if (initialisation_controle(s_etat_processus, sqlite, (integer8) 0, d_faux) != d_absence_erreur) { return(d_erreur);