--- rpl/src/gestion_fichiers.c 2010/03/06 18:29:06 1.6 +++ rpl/src/gestion_fichiers.c 2014/07/17 08:07:18 1.59 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.0.12 - Copyright (C) 1989-2010 Dr. BERTRAND Joël + RPL/2 (R) version 4.1.19 + Copyright (C) 1989-2014 Dr. BERTRAND Joël This file is part of RPL/2. @@ -20,7 +20,7 @@ */ -#include "rpl.conv.h" +#include "rpl-conv.h" /* @@ -77,8 +77,8 @@ creation_nom_fichier(struct_processus *s do { - sprintf(tampon, "RPL2-%lu-%lu-%lu", (unsigned long) getpid(), - (unsigned long) pthread_self(), ordre); + sprintf(tampon, "RPL-%llu-%llu-%lu", (unsigned long long) getpid(), + (unsigned long long) pthread_self(), ordre); if (chemin == NULL) { @@ -222,14 +222,14 @@ recherche_chemin_fichiers_temporaires(st { if (chemins[i][0] == '$') { - candidat = getenv("RPL_TMP_PATH"); + candidat = getenv(chemins[i] + 1); if (candidat != NULL) { if ((nom_candidat = creation_nom_fichier(s_etat_processus, candidat)) == NULL) { - return NULL; + return(NULL); } if ((fichier = fopen(nom_candidat, "w+")) != NULL) @@ -245,7 +245,7 @@ recherche_chemin_fichiers_temporaires(st } else { - return NULL; + return(NULL); } } else @@ -259,7 +259,7 @@ recherche_chemin_fichiers_temporaires(st if ((nom_candidat = creation_nom_fichier(s_etat_processus, chemins[i])) == NULL) { - return NULL; + return(NULL); } if ((fichier = fopen(nom_candidat, "w+")) != NULL) @@ -275,7 +275,7 @@ recherche_chemin_fichiers_temporaires(st } else { - return NULL; + return(NULL); } } else @@ -287,7 +287,7 @@ recherche_chemin_fichiers_temporaires(st i++; } - return chemin; + return(chemin); } @@ -348,6 +348,53 @@ caracteristiques_fichier(struct_processu l_element_courant = (*l_element_courant).suivant; } } + else if (errno == EACCES) + { + // Le répertoire n'est pas accessible en écriture. On tente + // l'ouverture du fichier. + + if ((descripteur = open(nom, O_RDONLY, S_IRUSR | S_IWUSR)) == -1) + { + // Le fichier n'existe pas. + close(descripteur); + erreur = d_absence_erreur; + } + else + { + erreur = d_absence_erreur; + (*existence) = d_vrai; + + // On chercher à savoir si le fichier est ouvert. + // S'il est ouvert, on renvoie son unité de rattachement. + + l_element_courant = (*s_etat_processus).s_fichiers; + + while(l_element_courant != NULL) + { + if (strcmp((*((struct_descripteur_fichier *) + (*l_element_courant).donnee)).nom, nom) == 0) + { + if (((*((struct_descripteur_fichier *) + (*l_element_courant).donnee)).pid == getpid()) + && (pthread_equal( + (*((struct_descripteur_fichier *) + (*l_element_courant).donnee)).tid, + pthread_self()) != 0)) + { + (*ouverture) = d_vrai; + + (*unite) = (unsigned long) + fileno((*((struct_descripteur_fichier *) + (*l_element_courant).donnee)) + .descripteur_c); + break; + } + } + + l_element_courant = (*l_element_courant).suivant; + } + } + } else { erreur = d_erreur; @@ -391,17 +438,19 @@ 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; - if (sqlite3_prepare_v2(sqlite, commande1, strlen(commande1), &ppStmt, + unsigned char *commande; + + if (sqlite3_prepare_v2(sqlite, commande1, (int) strlen(commande1), &ppStmt, &queue) != SQLITE_OK) { (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; @@ -422,24 +471,35 @@ initialisation_controle(struct_processus if (fichier_indexe == d_vrai) { - if (sqlite3_prepare_v2(sqlite, commande2, strlen(commande2), &ppStmt, - &queue) != SQLITE_OK) + 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, (int) 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 +507,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, " - "lock text)"; + "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, " - "lock blob)"; + "data blob, sequence integer)"; const char commande20[] = "create table key(id integer primary key asc, key blob)"; const char commande3[] = @@ -467,7 +527,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); @@ -475,8 +535,8 @@ initialisation_fichier_acces_indexe(stru if (binaire == d_faux) { - if (sqlite3_prepare_v2(sqlite, commande1, strlen(commande1), &ppStmt, - &queue) != SQLITE_OK) + if (sqlite3_prepare_v2(sqlite, commande1, (int) strlen(commande1), + &ppStmt, &queue) != SQLITE_OK) { (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; return(d_erreur); @@ -494,8 +554,8 @@ initialisation_fichier_acces_indexe(stru return(d_erreur); } - if (sqlite3_prepare_v2(sqlite, commande10, strlen(commande10), &ppStmt, - &queue) != SQLITE_OK) + if (sqlite3_prepare_v2(sqlite, commande10, (int) strlen(commande10), + &ppStmt, &queue) != SQLITE_OK) { (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; return(d_erreur); @@ -515,8 +575,8 @@ initialisation_fichier_acces_indexe(stru } else { - if (sqlite3_prepare_v2(sqlite, commande2, strlen(commande2), &ppStmt, - &queue) != SQLITE_OK) + if (sqlite3_prepare_v2(sqlite, commande2, (int) strlen(commande2), + &ppStmt, &queue) != SQLITE_OK) { (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; return(d_erreur); @@ -534,8 +594,8 @@ initialisation_fichier_acces_indexe(stru return(d_erreur); } - if (sqlite3_prepare_v2(sqlite, commande20, strlen(commande20), &ppStmt, - &queue) != SQLITE_OK) + if (sqlite3_prepare_v2(sqlite, commande20, (int) strlen(commande20), + &ppStmt, &queue) != SQLITE_OK) { (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; return(d_erreur); @@ -554,7 +614,7 @@ initialisation_fichier_acces_indexe(stru } } - if (sqlite3_prepare_v2(sqlite, commande3, strlen(commande3), &ppStmt, + if (sqlite3_prepare_v2(sqlite, commande3, (int) strlen(commande3), &ppStmt, &queue) != SQLITE_OK) { (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; @@ -573,7 +633,7 @@ initialisation_fichier_acces_indexe(stru return(d_erreur); } - if (sqlite3_prepare_v2(sqlite, commande4, strlen(commande4), &ppStmt, + if (sqlite3_prepare_v2(sqlite, commande4, (int) strlen(commande4), &ppStmt, &queue) != SQLITE_OK) { (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; @@ -600,16 +660,16 @@ initialisation_fichier_acces_direct(stru sqlite3 *sqlite, logical1 binaire) { const char commande1[] = - "create table data(id integer primary key asc, lock text)"; + "create table data(id integer primary key asc, data text)"; const char commande2[] = - "create table data(id integer primary key asc, lock blob)"; + "create table data(id integer primary key asc, data blob)"; const char commande3[] = "create index data_idx on data(id)"; const char *queue; 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); @@ -617,8 +677,8 @@ initialisation_fichier_acces_direct(stru if (binaire == d_faux) { - if (sqlite3_prepare_v2(sqlite, commande1, strlen(commande1), &ppStmt, - &queue) != SQLITE_OK) + if (sqlite3_prepare_v2(sqlite, commande1, (int) strlen(commande1), + &ppStmt, &queue) != SQLITE_OK) { (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; return(d_erreur); @@ -638,8 +698,8 @@ initialisation_fichier_acces_direct(stru } else { - if (sqlite3_prepare_v2(sqlite, commande2, strlen(commande2), &ppStmt, - &queue) != SQLITE_OK) + if (sqlite3_prepare_v2(sqlite, commande2, (int) strlen(commande2), + &ppStmt, &queue) != SQLITE_OK) { (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; return(d_erreur); @@ -658,7 +718,7 @@ initialisation_fichier_acces_direct(stru } } - if (sqlite3_prepare_v2(sqlite, commande3, strlen(commande3), &ppStmt, + if (sqlite3_prepare_v2(sqlite, commande3, (int) strlen(commande3), &ppStmt, &queue) != SQLITE_OK) { (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; @@ -680,97 +740,4 @@ initialisation_fichier_acces_direct(stru return(d_absence_erreur); } -unsigned char * -verrouillage_fichier_sqlite(struct_processus *s_etat_processus, - sqlite3 *sqlite, unsigned char *operation) -{ - const char commande1[] = - "select lock from control where id = 1"; - const char commande2[] = - "update control set lock = '%s'"; - const char *queue; - - const unsigned char *resultat; - - sqlite3_stmt *ppStmt; - - unsigned char *verrou; - - resultat = NULL; - - if (operation == NULL) - { - // Lecture du verrou - - if (sqlite3_prepare_v2(sqlite, commande1, strlen(commande1), &ppStmt, - &queue) != SQLITE_OK) - { - (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; - return(NULL); - } - - if (sqlite3_step(ppStmt) != SQLITE_ROW) - { - (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; - return(NULL); - } - - if (sqlite3_column_type(ppStmt, 0) != SQLITE_TEXT) - { - (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; - return(NULL); - } - - resultat = sqlite3_column_text(ppStmt, 0); - - if ((verrou = malloc((strlen(resultat) + 1) * sizeof(unsigned char))) - == NULL) - { - return(NULL); - } - - strcpy(verrou, resultat); - - if (sqlite3_finalize(ppStmt) != SQLITE_OK) - { - (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; - return(NULL); - } - } - else - { - // Positionnement d'un verrou - - if (alsprintf(&verrou, commande2, operation) < 0) - { - (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; - return(NULL); - } - - if (sqlite3_prepare_v2(sqlite, verrou, strlen(verrou), &ppStmt, - &queue) != SQLITE_OK) - { - (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; - return(NULL); - } - - if (sqlite3_step(ppStmt) != SQLITE_DONE) - { - (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; - return(NULL); - } - - if (sqlite3_finalize(ppStmt) != SQLITE_OK) - { - (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; - return(NULL); - } - - free(verrou); - verrou = NULL; - } - - return(verrou); -} - // vim: ts=4