--- rpl/src/instructions_c4.c 2010/01/26 15:22:45 1.1 +++ rpl/src/instructions_c4.c 2016/03/23 21:51:14 1.68 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.0.9 - Copyright (C) 1989-2010 Dr. BERTRAND Joël + RPL/2 (R) version 4.1.25 + Copyright (C) 1989-2016 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" /* @@ -39,16 +39,13 @@ void instruction_cov(struct_processus *s_etat_processus) { - integer8 nombre_colonnes; - logical1 erreur; - logical1 presence_variable; - - long i; struct_objet *s_objet_statistique; struct_objet *s_objet_resultat; + integer8 nombre_colonnes; + (*s_etat_processus).erreur_execution = d_ex; if ((*s_etat_processus).affichage_arguments == 'Y') @@ -86,7 +83,7 @@ instruction_cov(struct_processus *s_etat * Recherche d'une variable globale référencée par SIGMA */ - if (recherche_variable(s_etat_processus, ds_sdat) == d_faux) + if (recherche_variable_globale(s_etat_processus, ds_sdat) == d_faux) { /* * Aucune variable SIGMA @@ -98,64 +95,21 @@ instruction_cov(struct_processus *s_etat } else { - /* - * Il existe une variable locale SIGMA. Reste à vérifier l'existence - * d'une variable SIGMA globale... - */ - - i = (*s_etat_processus).position_variable_courante; - presence_variable = d_faux; - - while(i >= 0) + if (((*(*(*s_etat_processus).pointeur_variable_courante).objet) + .type != MIN) && ((*(*(*s_etat_processus) + .pointeur_variable_courante).objet).type != MRL)) { - if ((strcmp((*s_etat_processus).s_liste_variables[i].nom, - ds_sdat) == 0) && ((*s_etat_processus) - .s_liste_variables[i].niveau == 1)) - { - presence_variable = d_vrai; - break; - } - - i--; - } - - if (presence_variable == d_faux) - { - (*s_etat_processus).erreur_execution = d_ex_absence_observations; + (*s_etat_processus).erreur_execution = + d_ex_matrice_statistique_invalide; return; } - else - { - (*s_etat_processus).position_variable_courante = i; - if ((*s_etat_processus).s_liste_variables - [(*s_etat_processus).position_variable_courante].objet - == NULL) - { - (*s_etat_processus).erreur_execution = d_ex_variable_partagee; - return; - } - - if (((*((*s_etat_processus).s_liste_variables - [(*s_etat_processus).position_variable_courante].objet)) - .type != MIN) && ((*((*s_etat_processus) - .s_liste_variables[(*s_etat_processus) - .position_variable_courante].objet)).type != MRL)) - { - (*s_etat_processus).erreur_execution = - d_ex_matrice_statistique_invalide; - return; - } - - nombre_colonnes = (*((struct_matrice *) (*((*s_etat_processus) - .s_liste_variables[(*s_etat_processus) - .position_variable_courante].objet)).objet)) - .nombre_colonnes; - } + nombre_colonnes = (*((struct_matrice *) (*(*(*s_etat_processus) + .pointeur_variable_courante).objet).objet)).nombre_colonnes; } - s_objet_statistique = ((*s_etat_processus).s_liste_variables - [(*s_etat_processus).position_variable_courante]).objet; + s_objet_statistique = (*(*s_etat_processus).pointeur_variable_courante) + .objet; if (((*s_objet_statistique).type == MIN) || ((*s_objet_statistique).type == MRL)) @@ -221,14 +175,11 @@ void instruction_corr(struct_processus *s_etat_processus) { logical1 erreur; - logical1 presence_variable; - - long i; struct_objet *s_objet_statistique; struct_objet *s_objet_resultat; - unsigned long nombre_colonnes; + integer8 nombre_colonnes; (*s_etat_processus).erreur_execution = d_ex; @@ -267,7 +218,7 @@ instruction_corr(struct_processus *s_eta * Recherche d'une variable globale référencée par SIGMA */ - if (recherche_variable(s_etat_processus, ds_sdat) == d_faux) + if (recherche_variable_globale(s_etat_processus, ds_sdat) == d_faux) { /* * Aucune variable SIGMA @@ -279,64 +230,22 @@ instruction_corr(struct_processus *s_eta } else { - /* - * Il existe une variable locale SIGMA. Reste à vérifier l'existence - * d'une variable SIGMA globale... - */ - - i = (*s_etat_processus).position_variable_courante; - presence_variable = d_faux; - - while(i >= 0) + if (((*(*(*s_etat_processus).pointeur_variable_courante).objet) + .type != MIN) && ((*(*(*s_etat_processus) + .pointeur_variable_courante).objet).type != MRL)) { - if ((strcmp((*s_etat_processus).s_liste_variables[i].nom, - ds_sdat) == 0) && ((*s_etat_processus) - .s_liste_variables[i].niveau == 1)) - { - presence_variable = d_vrai; - break; - } - - i--; - } - - if (presence_variable == d_faux) - { - (*s_etat_processus).erreur_execution = d_ex_absence_observations; + (*s_etat_processus).erreur_execution = + d_ex_matrice_statistique_invalide; return; } - else - { - (*s_etat_processus).position_variable_courante = i; - - if ((*s_etat_processus).s_liste_variables - [(*s_etat_processus).position_variable_courante].objet - == NULL) - { - (*s_etat_processus).erreur_execution = d_ex_variable_partagee; - return; - } - - if (((*((*s_etat_processus).s_liste_variables - [(*s_etat_processus).position_variable_courante].objet)) - .type != MIN) && ((*((*s_etat_processus) - .s_liste_variables[(*s_etat_processus) - .position_variable_courante].objet)).type != MRL)) - { - (*s_etat_processus).erreur_execution = - d_ex_matrice_statistique_invalide; - return; - } - nombre_colonnes = (*((struct_matrice *) (*((*s_etat_processus) - .s_liste_variables[(*s_etat_processus) - .position_variable_courante].objet)).objet)) - .nombre_colonnes; - } + nombre_colonnes = (*((struct_matrice *) (*(*(*s_etat_processus) + .pointeur_variable_courante).objet).objet)) + .nombre_colonnes; } - s_objet_statistique = ((*s_etat_processus).s_liste_variables - [(*s_etat_processus).position_variable_courante]).objet; + s_objet_statistique = (*(*s_etat_processus).pointeur_variable_courante) + .objet; if (((*s_objet_statistique).type == MIN) || ((*s_objet_statistique).type == MRL)) @@ -402,7 +311,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; @@ -463,7 +372,7 @@ instruction_convert(struct_processus *s_ logical1 last_valide; - long longueur_chaine; + size_t longueur_chaine; logical1 presence_resultat; @@ -472,6 +381,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 +453,75 @@ 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(s_etat_processus, &executable_candidat, + "%s/bin/rplconvert", d_exec_path) < 0) + { + (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; + return; + } + + if (controle_integrite(s_etat_processus, executable_candidat, + "rplconvert") != 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)); + + 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(s_etat_processus, &executable_candidat, + "%s/bin/rplconvert", (*s_etat_processus).rpl_home) < 0) + { + (*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 (controle_integrite(s_etat_processus, executable_candidat, + "rplconvert") != d_vrai) + { + (*s_etat_processus).erreur_systeme = d_es_somme_controle; + return; + } + + free(executable_candidat); + } if ((pipe = popen(commande, "r")) == NULL) { @@ -585,6 +549,7 @@ instruction_convert(struct_processus *s_ (*s_etat_processus).instruction_courante; (*s_etat_processus).instruction_courante = ligne; + (*s_etat_processus).type_en_cours = NON; recherche_type(s_etat_processus); (*s_etat_processus).instruction_courante = @@ -684,12 +649,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 +736,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 +756,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 +778,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 +965,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 +1011,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); @@ -1063,10 +1086,9 @@ instruction_cswp(struct_processus *s_eta struct_objet *s_objet_argument_2; struct_objet *s_objet_argument_3; - signed long colonne_1; - signed long colonne_2; - - unsigned long i; + integer8 colonne_1; + integer8 colonne_2; + integer8 i; (*s_etat_processus).erreur_execution = d_ex; @@ -1138,11 +1160,11 @@ instruction_cswp(struct_processus *s_eta if ((*s_objet_argument_3).type == MIN) { - if ((colonne_1 < 0) || (colonne_1 > ((signed long) + if ((colonne_1 < 0) || (colonne_1 > (*((struct_matrice *) (*s_objet_argument_3).objet)) - .nombre_colonnes) - 1) || (colonne_2 < 0) || (colonne_2 > - ((signed long) (*((struct_matrice *) - (*s_objet_argument_3).objet)).nombre_colonnes) - 1)) + .nombre_colonnes - 1) || (colonne_2 < 0) || (colonne_2 > + (*((struct_matrice *) + (*s_objet_argument_3).objet)).nombre_colonnes - 1)) { liberation(s_etat_processus, s_objet_argument_1); liberation(s_etat_processus, s_objet_argument_2); @@ -1175,11 +1197,11 @@ instruction_cswp(struct_processus *s_eta } else if ((*s_objet_argument_3).type == MRL) { - if ((colonne_1 < 0) || (colonne_1 > ((signed long) + if ((colonne_1 < 0) || (colonne_1 > (*((struct_matrice *) (*s_objet_argument_3).objet)) - .nombre_colonnes) - 1) || (colonne_2 < 0) || (colonne_2 > - ((signed long) (*((struct_matrice *) - (*s_objet_argument_3).objet)).nombre_colonnes) - 1)) + .nombre_colonnes - 1) || (colonne_2 < 0) || (colonne_2 > + (*((struct_matrice *) + (*s_objet_argument_3).objet)).nombre_colonnes - 1)) { liberation(s_etat_processus, s_objet_argument_1); liberation(s_etat_processus, s_objet_argument_2); @@ -1212,11 +1234,11 @@ instruction_cswp(struct_processus *s_eta } else if ((*s_objet_argument_3).type == MCX) { - if ((colonne_1 < 0) || (colonne_1 > ((signed long) + if ((colonne_1 < 0) || (colonne_1 > (*((struct_matrice *) (*s_objet_argument_3).objet)) - .nombre_colonnes) - 1) || (colonne_2 < 0) || (colonne_2 > - ((signed long) (*((struct_matrice *) - (*s_objet_argument_3).objet)).nombre_colonnes) - 1)) + .nombre_colonnes - 1) || (colonne_2 < 0) || (colonne_2 > + (*((struct_matrice *) + (*s_objet_argument_3).objet)).nombre_colonnes - 1)) { liberation(s_etat_processus, s_objet_argument_1); liberation(s_etat_processus, s_objet_argument_2);