--- rpl/src/instructions_d4.c 2010/03/06 18:29:07 1.5 +++ rpl/src/instructions_d4.c 2011/11/26 10:01:28 1.34 @@ -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.5 + Copyright (C) 1989-2011 Dr. BERTRAND Joël This file is part of RPL/2. @@ -20,7 +20,7 @@ */ -#include "rpl.conv.h" +#include "rpl-conv.h" /* @@ -38,19 +38,30 @@ void instruction_delete(struct_processus *s_etat_processus) { + const char *queue; + file *fichier; + integer8 lecture_i64; + logical1 erreur; logical1 existence; logical1 ouverture; + sqlite3_stmt *ppStmt; + + struct_descripteur_fichier *descripteur; + struct_objet *s_objet_argument; + struct_objet *s_objet_indice; struct flock lock; struct stat requete; + unsigned char *commande; unsigned char *nom; + unsigned char *utf8; unsigned long unite; @@ -62,15 +73,17 @@ instruction_delete(struct_processus *s_e if ((*s_etat_processus).langue == 'F') { - printf("(effacement d'un fichier)\n\n"); + printf("(effacement d'un fichier ou d'un enregistrement)\n\n"); } else { - printf("(delete a file)\n\n"); + printf("(delete file or record)\n\n"); } - printf(" 1: %s\n", d_CHN); + printf(" 1: %s\n\n", d_CHN); + printf(" 2: %s, %s\n", d_CHN, d_INT); + printf(" 1: %s\n", d_FCH); return; } else if ((*s_etat_processus).test_instruction == 'Y') @@ -81,10 +94,26 @@ instruction_delete(struct_processus *s_e if (test_cfsf(s_etat_processus, 31) == d_vrai) { - if (empilement_pile_last(s_etat_processus, 1) == d_erreur) + if ((*s_etat_processus).l_base_pile == NULL) { + (*s_etat_processus).erreur_execution = d_ex_manque_argument; return; } + + if ((*(*(*s_etat_processus).l_base_pile).donnee).type == FCH) + { + if (empilement_pile_last(s_etat_processus, 2) == d_erreur) + { + return; + } + } + else + { + if (empilement_pile_last(s_etat_processus, 1) == d_erreur) + { + return; + } + } } if (depilement(s_etat_processus, &((*s_etat_processus).l_base_pile), @@ -200,6 +229,341 @@ instruction_delete(struct_processus *s_e free(nom); } + else if ((*s_objet_argument).type == FCH) + { + if ((descripteur = descripteur_fichier(s_etat_processus, + (struct_fichier *) (*s_objet_argument).objet)) == NULL) + { + return; + } + + /* + * Vérification des verrous + */ + + lock.l_type = F_RDLCK; + lock.l_whence = SEEK_SET; + lock.l_start = 0; + lock.l_len = 0; + lock.l_pid = getpid(); + + if (fcntl(fileno((*descripteur).descripteur_c), F_GETLK, &lock) + == -1) + { + liberation(s_etat_processus, s_objet_argument); + + (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; + return; + } + + if (lock.l_type != F_UNLCK) + { + liberation(s_etat_processus, s_objet_argument); + + (*s_etat_processus).erreur_execution = + d_ex_fichier_verrouille; + return; + } + + if ((*((struct_fichier *) (*s_objet_argument).objet)) + .protection == 'R') + { + liberation(s_etat_processus, s_objet_argument); + + (*s_etat_processus).erreur_execution = d_ex_erreur_acces_fichier; + return; + } + + if ((*((struct_fichier *) (*s_objet_argument).objet)).binaire == 'N') + { + if ((*((struct_fichier *) (*s_objet_argument).objet)).acces + == 'S') + { + liberation(s_etat_processus, s_objet_argument); + + (*s_etat_processus).erreur_execution = d_ex_erreur_type_fichier; + return; + } + else if ((*((struct_fichier *) (*s_objet_argument).objet)).acces + == 'D') + { + BUG(((*descripteur).type == 'C'), uprintf("Bad filtype !\n")); + + if (depilement(s_etat_processus, &((*s_etat_processus) + .l_base_pile), &s_objet_indice) == d_erreur) + { + (*s_etat_processus).erreur_execution = d_ex_manque_argument; + return; + } + + if ((*s_objet_indice).type != INT) + { + liberation(s_etat_processus, s_objet_argument); + liberation(s_etat_processus, s_objet_indice); + + (*s_etat_processus).erreur_execution = + d_ex_erreur_type_argument; + return; + } + + if (alsprintf(&commande, "select count(*) from data where " + "id = %lld", (*((integer8 *) (*s_objet_indice).objet))) + < 0) + { + (*s_etat_processus).erreur_systeme = + d_es_allocation_memoire; + return; + } + + if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite, + commande, strlen(commande), &ppStmt, &queue) + != SQLITE_OK) + { + (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; + return; + } + + if (sqlite3_step(ppStmt) != SQLITE_ROW) + { + (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; + return; + } + + lecture_i64 = sqlite3_column_int64(ppStmt, 0); + + if (sqlite3_step(ppStmt) != SQLITE_DONE) + { + (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; + return; + } + + if (sqlite3_finalize(ppStmt) != SQLITE_OK) + { + (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; + return; + } + + free(commande); + + if (lecture_i64 == 0) + { + liberation(s_etat_processus, s_objet_argument); + liberation(s_etat_processus, s_objet_indice); + + (*s_etat_processus).erreur_execution = + d_ex_enregistrement_inexistant; + return; + } + + if (alsprintf(&commande, "delete from data where id = %lld", + (*((integer8 *) (*s_objet_indice).objet))) < 0) + { + (*s_etat_processus).erreur_systeme = + d_es_allocation_memoire; + return; + } + + if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite, + commande, strlen(commande), &ppStmt, &queue) + != SQLITE_OK) + { + (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; + return; + } + + if (sqlite3_step(ppStmt) != SQLITE_DONE) + { + (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; + return; + } + + if (sqlite3_finalize(ppStmt) != SQLITE_OK) + { + (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; + return; + } + + free(commande); + liberation(s_etat_processus, s_objet_indice); + } + else + { + BUG(((*descripteur).type == 'C'), uprintf("Bad filtype !\n")); + + if (depilement(s_etat_processus, &((*s_etat_processus) + .l_base_pile), &s_objet_indice) == d_erreur) + { + (*s_etat_processus).erreur_execution = d_ex_manque_argument; + return; + } + + if ((*s_objet_indice).type != CHN) + { + liberation(s_etat_processus, s_objet_argument); + liberation(s_etat_processus, s_objet_indice); + + (*s_etat_processus).erreur_execution = + d_ex_erreur_type_argument; + return; + } + + // Récupération de l'identifiant de la clef + + if ((utf8 = transliteration(s_etat_processus, + (unsigned char *) (*s_objet_indice).objet, d_locale, + "UTF-8")) == NULL) + { + liberation(s_etat_processus, s_objet_argument); + liberation(s_etat_processus, s_objet_indice); + + return; + } + + if (alsprintf(&commande, "select id from key where key = " + "'{ \"%s\" }'", utf8) < 0) + { + (*s_etat_processus).erreur_systeme = + d_es_allocation_memoire; + return; + } + + free(utf8); + + if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite, + commande, strlen(commande), &ppStmt, &queue) + != SQLITE_OK) + { + (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; + return; + } + + switch(sqlite3_step(ppStmt)) + { + case SQLITE_ROW: + { + // Correspondance + break; + } + + case SQLITE_DONE: + { + // Aucune correspondance + if (sqlite3_finalize(ppStmt) != SQLITE_OK) + { + (*s_etat_processus).erreur_systeme = + d_es_erreur_fichier; + return; + } + + free(commande); + + liberation(s_etat_processus, s_objet_argument); + liberation(s_etat_processus, s_objet_indice); + + (*s_etat_processus).erreur_execution = + d_ex_enregistrement_inexistant; + return; + } + + default: + { + (*s_etat_processus).erreur_systeme = + d_es_erreur_fichier; + return; + } + } + + if (sqlite3_column_type(ppStmt, 0) != SQLITE_INTEGER) + { + (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; + return; + } + + lecture_i64 = sqlite3_column_int64(ppStmt, 0); + + if (sqlite3_step(ppStmt) != SQLITE_DONE) + { + (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; + return; + } + + if (sqlite3_finalize(ppStmt) != SQLITE_OK) + { + (*s_etat_processus).erreur_systeme = + d_es_erreur_fichier; + return; + } + + free(commande); + + if (alsprintf(&commande, "delete from data where key_id = %lld", + lecture_i64) < 0) + { + (*s_etat_processus).erreur_systeme = + d_es_allocation_memoire; + return; + } + + if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite, + commande, strlen(commande), &ppStmt, &queue) + != SQLITE_OK) + { + (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; + return; + } + + if (sqlite3_step(ppStmt) != SQLITE_DONE) + { + (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; + return; + } + + if (sqlite3_finalize(ppStmt) != SQLITE_OK) + { + (*s_etat_processus).erreur_systeme = + d_es_erreur_fichier; + return; + } + + free(commande); + + if (alsprintf(&commande, "delete from key where id = %lld", + lecture_i64) < 0) + { + (*s_etat_processus).erreur_systeme = + d_es_allocation_memoire; + return; + } + + if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite, + commande, strlen(commande), &ppStmt, &queue) + != SQLITE_OK) + { + (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; + return; + } + + if (sqlite3_step(ppStmt) != SQLITE_DONE) + { + (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; + return; + } + + if (sqlite3_finalize(ppStmt) != SQLITE_OK) + { + (*s_etat_processus).erreur_systeme = + d_es_erreur_fichier; + return; + } + + free(commande); + liberation(s_etat_processus, s_objet_indice); + } + } + else // Fichiers non formatés + { + } + } else { liberation(s_etat_processus, s_objet_argument); @@ -302,11 +666,8 @@ instruction_drws(struct_processus *s_eta int dimensions; - logical1 presence_variable; logical1 matrice_entiere; - long i; - struct_objet *s_objet_statistique; unsigned char *nom_fichier; @@ -353,46 +714,24 @@ instruction_drws(struct_processus *s_eta * Vérification de la présence de la matrice statistique */ - if (recherche_variable(s_etat_processus, ds_sdat) == d_faux) + if (recherche_variable_globale(s_etat_processus, ds_sdat) == d_faux) { /* * Aucune variable ds_sdat n'existe. */ - (*s_etat_processus).erreur_execution = d_ex_absence_observations; - (*s_etat_processus).erreur_systeme = d_es; - - return; - } - - i = (*s_etat_processus).position_variable_courante; - presence_variable = d_faux; - - while(i >= 0) - { - if ((strcmp((*s_etat_processus).s_liste_variables[i].nom, - ds_sdat) == 0) && ((*s_etat_processus) - .s_liste_variables[i].niveau == 1)) + if ((*s_etat_processus).erreur_execution == d_ex) { - presence_variable = d_vrai; - break; + (*s_etat_processus).erreur_execution = d_ex_absence_observations; } - i--; - } + (*s_etat_processus).erreur_systeme = d_es; - if (presence_variable == d_faux) - { - (*s_etat_processus).erreur_execution = d_ex_absence_observations; return; } - if ((s_objet_statistique = (*s_etat_processus).s_liste_variables[i].objet) - == NULL) - { - (*s_etat_processus).erreur_execution = d_ex_variable_partagee; - return; - } + s_objet_statistique = (*(*s_etat_processus).pointeur_variable_courante) + .objet; if ((*s_objet_statistique).type == MIN) { @@ -719,8 +1058,7 @@ instruction_decr(struct_processus *s_eta liberation(s_etat_processus, s_objet_argument); - if ((*s_etat_processus).s_liste_variables - [(*s_etat_processus).position_variable_courante] + if ((*(*s_etat_processus).pointeur_variable_courante) .variable_verrouillee == d_vrai) { (*s_etat_processus).erreur_execution = @@ -728,8 +1066,7 @@ instruction_decr(struct_processus *s_eta return; } - if ((*s_etat_processus).s_liste_variables - [(*s_etat_processus).position_variable_courante].objet + if ((*(*s_etat_processus).pointeur_variable_courante).objet == NULL) { if (pthread_mutex_lock(&((*(*s_etat_processus) @@ -740,13 +1077,10 @@ instruction_decr(struct_processus *s_eta } if (recherche_variable_partagee(s_etat_processus, - (*s_etat_processus).s_liste_variables - [(*s_etat_processus).position_variable_courante].nom, - (*s_etat_processus).s_liste_variables - [(*s_etat_processus).position_variable_courante] - .variable_partagee, (*s_etat_processus).s_liste_variables - [(*s_etat_processus).position_variable_courante] - .origine) == d_faux) + (*(*s_etat_processus).pointeur_variable_courante).nom, + (*(*s_etat_processus).pointeur_variable_courante) + .variable_partagee, (*(*s_etat_processus) + .pointeur_variable_courante).origine) == d_faux) { (*s_etat_processus).erreur_systeme = d_es; (*s_etat_processus).erreur_execution = @@ -763,8 +1097,8 @@ instruction_decr(struct_processus *s_eta } else { - s_objet_argument = (*s_etat_processus).s_liste_variables - [(*s_etat_processus).position_variable_courante].objet; + s_objet_argument = (*(*s_etat_processus).pointeur_variable_courante) + .objet; variable_partagee = d_faux; } @@ -789,8 +1123,7 @@ instruction_decr(struct_processus *s_eta if (variable_partagee == d_vrai) { - (*s_etat_processus).s_liste_variables[(*s_etat_processus) - .position_variable_courante].objet = NULL; + (*(*s_etat_processus).pointeur_variable_courante).objet = NULL; (*(*s_etat_processus) .s_liste_variables_partagees).table [(*(*s_etat_processus).s_liste_variables_partagees) @@ -798,8 +1131,8 @@ instruction_decr(struct_processus *s_eta } else { - (*s_etat_processus).s_liste_variables[(*s_etat_processus) - .position_variable_courante].objet = s_copie_argument; + (*(*s_etat_processus).pointeur_variable_courante).objet = + s_copie_argument; } if ((*s_copie_argument).type == INT)