emufs/emufs.c

   1 /* vim: set noexpandtab tabstop=4 shiftwidth=4:
   2  *----------------------------------------------------------------------------
   3  *                                  emufs
   4  *----------------------------------------------------------------------------
   5  * This file is part of emufs.
   6  *
   7  * emufs is free software; you can redistribute it and/or modify it under the
   8  * terms of the GNU General Public License as published by the Free Software
   9  * Foundation; either version 2 of the License, or (at your option) any later
  10  * version.
  11  *
  12  * emufs is distributed in the hope that it will be useful, but WITHOUT ANY
  13  * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
  14  * FOR A PARTICULAR PURPOSE. See the GNU General Public License for more
  15  * details.
  16  *
  17  * You should have received a copy of the GNU General Public License along
  18  * with emufs; if not, write to the Free Software Foundation, Inc., 59 Temple
  19  * Place, Suite 330, Boston, MA  02111-1307  USA
  20  *----------------------------------------------------------------------------
  21  * Creado:  mié mar 31 17:26:46 ART 2004
  22  * Autores: Nicolás Dimov <sagardua@uolsinectis.com.ar>
  23  *          Ricardo Markiewicz <rmarkie@fi.uba.ar>
  24  *          Leandro Lucarella <llucare@fi.uba.ar>
  25  *----------------------------------------------------------------------------
  26  *
  27  * $Id$
  28  *
  29  */
  30
  31 /** \file
  32  *
  33  * Estructura general de un archivo <em>abstracto</em> de emufs.
  34  *
  35  * Implementación de la estructura abstracta que representa cualquiera de los
  36  * tipos de archivo implementados. Se incluyen funciones tipo <em>factory</em>
  37  * para crear un archivo, abrirlo y destruirlo.
  38  *
  39  */
  40
  41 #include "emufs.h"
  42 #include "common.h"
  43 #include "tipo1.h"
  44 #include "tipo2.h"
  45 #include "tipo3.h"
  46 #include "did.h"
  47 #include "fsc.h"
  48 #include "idx.h"
  49
  50 typedef struct _data_indices_ {
  51         char nombre[50];
  52         INDICE_FUNCION funcion;
  53         INDICE_TIPO tipo;
  54         INDICE_TIPO_DATO tipo_dato;
  55         unsigned int offset;
  56         unsigned int tam_bloque;
  57 } t_Indice;
  58
  59 int guardar_indice(EMUFS *emu, char *nombre, INDICE_FUNCION funcion, INDICE_TIPO tipo, INDICE_TIPO_DATO tipo_dato,  unsigned int offset, unsigned int tam_bloque);
  60
  61 char *str_dup(const char *s);
  62
  63 char *str_dup(const char *s)
  64 {
  65         char *tmp;
  66         if (s == NULL) return NULL;
  67         tmp = (char *)malloc(sizeof(char)*(strlen(s)+1));
  68         strcpy(tmp, s);
  69         return tmp;
  70 }
  71
  72 int emufs_crear_archivo_auxiliar(const char* name, const char* ext)
  73 {
  74         FILE* f;
  75         char* filename;
  76
  77         filename = (char*) malloc(sizeof(char) * (strlen(name) + strlen(ext) + 1));
  78         if (filename == NULL) {
  79                 /* TODO Manejo de errores */
  80                 return -1;
  81         }
  82         strcpy(filename, name);
  83         strcat(filename, ext);
  84         f = fopen(filename, "w");
  85         free(filename);
  86         if (f == NULL) {
  87                 /* TODO Manejo de errores */
  88                 return -1;
  89         }
  90         fclose(f);
  91         return 0;
  92 }
  93
  94 EMUFS *emufs_crear(const char *filename, EMUFS_Tipo tipo, EMUFS_BLOCK_SIZE tam_bloque, EMUFS_REG_SIZE tam_reg)
  95 {
  96         char name[255], otroname[255];
  97         FILE *fp;
  98         EMUFS *efs;
  99         int err = 0;
 100
 101         /* Si no es un tipo conocido, sale. */
 102         if ((tipo != T1) && (tipo != T2) && (tipo != T3)) {
 103                 return NULL;
 104         }
 105
 106         /* Inicializa parámetros comunes. */
 107         efs = (EMUFS*) malloc(sizeof(EMUFS));
 108         if (efs == NULL) {
 109                 return NULL;
 110         }
 111         efs->tipo = tipo;
 112         efs->tam_bloque = tam_bloque;
 113         efs->tam_reg = tam_reg;
 114         efs->nombre = str_dup(filename);
 115         efs->indices = NULL;
 116
 117         sprintf(otroname, "%s.info", efs->nombre);
 118         fp = fopen(otroname, "w");
 119         if (fp == NULL) {
 120                 PERR("CARAJO!, NO PUEDO CREAR INFO");
 121         } else {
 122                 err = 0;
 123                 fwrite(&err, 1, sizeof(int), fp);
 124                 fclose(fp);
 125         }
 126
 127         /* Abre archivo de datos. */
 128         strcpy(name, filename);
 129         strcat(name, ".dat");
 130         fp = fopen(name, "w");
 131         if (fp == NULL) {
 132                 /* TODO ERROR */
 133                 free(efs->nombre);
 134                 free(efs);
 135                 return NULL;
 136         }
 137
 138         /* Guarda cabecera común. */
 139         fwrite(&tipo, sizeof(EMUFS_Tipo), 1, fp);
 140
 141         /* Crea archivo de índice. */
 142         if (emufs_idx_crear(efs)) {
 143                 /* TODO ERROR */
 144                 fclose(fp);
 145                 free(efs->nombre);
 146                 free(efs);
 147                 return NULL;
 148         }
 149
 150         /* Crea archivo de control de espacio libre. */
 151         if (emufs_fsc_crear(efs)) {
 152                 /* TODO ERROR */
 153                 fclose(fp);
 154                 free(efs->nombre);
 155                 free(efs);
 156                 return NULL;
 157         }
 158
 159         /* Crea archivo de identificadores borrados (recuperables). */
 160         if (emufs_did_crear(efs)) {
 161                 /* TODO ERROR */
 162                 fclose(fp);
 163                 free(efs->nombre);
 164                 free(efs);
 165                 return NULL;
 166         }
 167
 168         /* Termina de realizar el trabajo según el tipo de archivo. */
 169         switch (tipo) {
 170
 171                 case T1:
 172                         /* Asigna punteros a funciones. */
 173                         if ((err = emufs_tipo1_inicializar(efs))) {
 174                                 /* TODO ERROR */
 175                                 PERR("No se pudo inicializar el EMUFS de tipo1");
 176                                 fclose(fp);
 177                                 free(efs->nombre);
 178                                 free(efs);
 179                                 return NULL;
 180                         }
 181
 182                         /* Guarda cabeceras propias. */
 183                         fwrite(&tam_bloque, sizeof(EMUFS_BLOCK_SIZE), 1, fp);
 184
 185                         break;
 186
 187                 case T2:
 188                         /* Asigna punteros a funciones. */
 189                         emufs_tipo2_inicializar(efs);
 190                         break;
 191
 192                 case T3:
 193                         /* Asigna punteros a funciones. */
 194                         efs->leer_bloque = emufs_tipo3_leer_bloque;
 195                         efs->leer_registro = emufs_tipo3_leer_registro;
 196                         efs->leer_registro_raw = emufs_tipo3_leer_registro_raw;
 197                         efs->grabar_registro = emufs_tipo3_grabar_registro;
 198                         efs->borrar_registro = emufs_tipo3_borrar_registro;
 199                         efs->leer_estadisticas = emufs_tipo3_leer_estadisticas;
 200                         efs->modificar_registro = emufs_tipo3_modificar_registro;
 201                         efs->compactar = emufs_tipo3_compactar;
 202                         efs->leer_bloque_raw = emufs_tipo3_leer_bloque_raw;
 203                         /* Guarda cabeceras propias. */
 204                         fwrite(&tam_bloque, sizeof(EMUFS_BLOCK_SIZE), 1, fp);
 205                         fwrite(&tam_reg, sizeof(EMUFS_REG_SIZE), 1, fp);
 206                         break;
 207
 208         }
 209
 210         fclose(fp);
 211         return efs;
 212 }
 213
 214 EMUFS *emufs_abrir(const char *filename)
 215 {
 216         EMUFS *efs;
 217         char name[255];
 218         char tipo;
 219         FILE *fp;
 220         int err = 0;
 221
 222         strcpy(name, filename);
 223         strcat(name, ".dat");
 224
 225         /* Trato de determinar el tipo de archivo */
 226         fp = fopen(name, "r");
 227         if (fp == NULL) return NULL;
 228         fread(&tipo, sizeof(EMUFS_Tipo), 1, fp);
 229
 230         /* Si no es un tipo conocido, sale. */
 231         if ((tipo != T1) && (tipo != T2) && (tipo != T3)) {
 232                 fclose(fp);
 233                 return NULL;
 234         }
 235
 236         /* Inicializa parámetros comunes. */
 237         efs = (EMUFS*) malloc(sizeof(EMUFS));
 238         if (efs == NULL) {
 239                 fclose(fp);
 240                 return NULL;
 241         }
 242         efs->tipo = tipo;
 243         efs->nombre = str_dup(filename);
 244
 245         switch (tipo) {
 246                 case T1:
 247                         /* Lee cabeceras propias. */
 248                         if (!fread(&(efs->tam_bloque), sizeof(EMUFS_BLOCK_SIZE), 1, fp)) {
 249                                 free(efs->nombre);
 250                                 free(efs);
 251                                 fclose(fp);
 252                                 return NULL;
 253                         }
 254                         /* Asigna punteros a funciones. */
 255                         if ((err = emufs_tipo1_inicializar(efs))) {
 256                                 PERR("No se pudo inicializar el EMUFS de tipo1");
 257                                 fclose(fp);
 258                                 return NULL;
 259                         }
 260                         break;
 261                 case T2:
 262                         /* Asigna punteros a funciones. */
 263                         emufs_tipo2_inicializar(efs);
 264                         break;
 265                 case T3:
 266                         if ((!fread(&(efs->tam_bloque), sizeof(EMUFS_BLOCK_SIZE), 1, fp)) ||
 267                            (!fread(&(efs->tam_reg), sizeof(EMUFS_REG_SIZE), 1, fp)))
 268                                 {
 269                                 free(efs->nombre);
 270                                 free(efs);
 271                                 fclose(fp);
 272                                 return NULL;
 273                         }
 274                         /* Asigna punteros a funciones. */
 275                         efs->leer_bloque = emufs_tipo3_leer_bloque;
 276                         efs->leer_registro_raw = emufs_tipo3_leer_registro_raw;
 277                         efs->leer_registro = emufs_tipo3_leer_registro;
 278                         efs->grabar_registro = emufs_tipo3_grabar_registro;
 279                         efs->borrar_registro = emufs_tipo3_borrar_registro;
 280                         efs->leer_estadisticas = emufs_tipo3_leer_estadisticas;
 281                         efs->modificar_registro = emufs_tipo3_modificar_registro;
 282                         efs->compactar = emufs_tipo3_compactar;
 283                         efs->leer_bloque_raw = emufs_tipo3_leer_bloque_raw;
 284                         break;
 285         }
 286
 287         fclose(fp);
 288         return efs;
 289 }
 290
 291 int emufs_destruir(EMUFS *e)
 292 {
 293         if (e == NULL) return 1;
 294         free(e->nombre);
 295         free(e);
 296         return 0;
 297 }
 298
 299 int ver_archivo_FS(EMUFS *emu)
 300 {
 301         FILE *f_block_free;
 302         EMUFS_FSC reg;
 303         char name_f_block_free[255];
 304
 305         strcpy(name_f_block_free,emu->nombre);
 306         strcat(name_f_block_free,".fsc");
 307
 308         if ( (f_block_free = fopen(name_f_block_free,"r"))==NULL ){
 309                 fprintf(stderr, "no pude abrir el archivo %s\n",name_f_block_free);
 310                 return -1;
 311         }
 312         fprintf(stderr,"BOQUES Y ESPACIO LIBRE\n");
 313         fread(&reg,sizeof(reg),1,f_block_free);
 314         while ( !feof(f_block_free) ){
 315                 fprintf(stderr, "Bloque = %li   Espacio libre = %li\n",reg.marker, reg.freespace);
 316                 fread(&reg,sizeof(reg),1,f_block_free);
 317         }
 318
 319         fclose(f_block_free);
 320
 321         /* Imprimo la lista de bloques/registros */
 322         fprintf(stderr, "BLOQUES Y REGISTROS\n");
 323         strcpy(name_f_block_free,emu->nombre);
 324         strcat(name_f_block_free,".idx");
 325         f_block_free = fopen(name_f_block_free, "r");
 326         {
 327                 EMUFS_IDX r;
 328                 while (!feof(f_block_free)) {
 329                         if (fread(&r, sizeof(EMUFS_IDX), 1, f_block_free) != 1) continue;
 330                         fprintf(stderr, "ID %li en bloque %li\n", r.id_reg, r.location);
 331                 }
 332         }
 333         fclose(f_block_free);
 334
 335         return 0;
 336 }
 337
 338 int debug_ver_estadisticas(EMUFS* efs)
 339 {
 340         EMUFS_Estadisticas s = efs->leer_estadisticas(efs);
 341
 342         printf("ESTADISTICAS:\n");
 343         printf("=============\n");
 344         printf("Tamaño del archivo: %lu bytes\n", s.tam_archivo);
 345         printf("Tamaño de datos (incluye espacio libre): %lu bytes (%.2f %%)\n",
 346                         s.tam_archivo - s.tam_info_control_dat,
 347                         (s.tam_archivo - s.tam_info_control_dat) * 100.0
 348                                 / (float) s.tam_archivo);
 349         printf("Tamaño de info de control total: %lu bytes (%.2f %%)\n",
 350                         s.tam_info_control_dat + s.tam_archivos_aux,
 351                         (s.tam_info_control_dat + s.tam_archivos_aux) * 100.0
 352                                 / (float) s.tam_archivo);
 353         printf("Tamaño de los archivos auxiliares: %lu bytes\n",
 354                         s.tam_archivos_aux);
 355         printf("Tamaño de la información de control en el .dat: %lu bytes\n",
 356                         s.tam_info_control_dat);
 357         printf("Total de espacio libre: %lu bytes\n", s.total_fs);
 358         printf("Máximo espacio libre en bloque: %lu bytes\n", s.max_fs);
 359         printf("Mínimo espacio libre en bloque: %lu bytes\n", s.min_fs);
 360         printf("Media del espacio libre por bloque: %lu bytes\n", s.media_fs);
 361         printf("Cantidad de registros: %lu\n", s.cant_registros);
 362         printf("Cantidad de bloques: %lu\n", s.cant_bloques);
 363         return 0;
 364 }
 365
 366 int emufs_agregar_indice(EMUFS *emu, char *nombre, INDICE_FUNCION funcion, INDICE_TIPO tipo, INDICE_TIPO_DATO tipo_dato,  unsigned int offset, unsigned int tam_bloque)
 367 {
 368         INDICE *tmp;
 369         int error=0;
 370
 371         /* Verifico que no existe un indice con el mismo nombre */
 372         /* y que no exista un indice primario */
 373         PERR("Agregando indice");
 374         tmp = emu->indices;
 375         while (tmp) {
 376                 if (strcmp(tmp->nombre, nombre)==0) {
 377                         error = 1;
 378                         break;
 379                 }
 380                 if ((funcion == IND_PRIMARIO) && (tmp->funcion == funcion)) {
 381                         error = 2;
 382                         break;
 383                 }
 384                 tmp = tmp->sig;
 385         }
 386
 387         if (tmp != NULL) {
 388                 switch (error) {
 389                         case 1:
 390                                 PERR("Ya existe un indice con el mismo nombre!");
 391                         break;
 392                         case 2:
 393                                 PERR("EMUFS ya tiene indice primario!!");
 394                 }
 395                 return 0;
 396         }
 397
 398         /* Creo el nuevo indice */
 399         PERR("Creando indice\n");
 400         tmp = emufs_indice_crear(emu, nombre, funcion, tipo, tipo_dato, offset, tam_bloque);
 401
 402         /* Guardo la info del indice para poder abrir despues el archivo */
 403         guardar_indice(emu, nombre, funcion, tipo, tipo_dato, offset, tam_bloque);
 404
 405         if (tmp == NULL) {
 406                 PERR("NO SE PUDO CREAR INDICE!!!");
 407                 return 0;
 408         }
 409
 410         if (emu->indices==NULL)
 411                 emu->indices = tmp;
 412         else {
 413                 tmp->sig = emu->indices;
 414                 emu->indices = tmp;
 415         }
 416         return 1;
 417 }
 418
 419 INDICE_DATO *emufs_buscar_registros(EMUFS *emu, char *indice, char *data, int *cant)
 420 {
 421         CLAVE k;
 422         INDICE *tmp;
 423
 424         tmp = emu->indices;
 425         while (tmp) {
 426                 if (strcmp(tmp->nombre, indice) == 0) break;
 427                 tmp = tmp->sig;
 428         }
 429
 430         if (tmp == NULL) {
 431                 PERR("NO EXISTE EL INDICE");
 432                 cant = 0;
 433                 return NULL;
 434         }
 435
 436         PERR("GENERANDO CLAVE")
 437         PERR(data);
 438         k = emufs_indice_generar_clave_desde_valor(tmp, data);
 439         PERR("DONE");
 440         return tmp->buscar_entradas(tmp, k, cant);
 441 }
 442
 443 int guardar_indice(EMUFS *emu, char *nombre, INDICE_FUNCION funcion, INDICE_TIPO tipo, INDICE_TIPO_DATO tipo_dato,  unsigned int offset, unsigned int tam_bloque)
 444 {
 445         char filename[100];
 446         FILE *fp;
 447         int cant; /* cantidad de indices hasta el momento */
 448         t_Indice *indices;
 449
 450         sprintf(filename, "%s.info", emu->nombre);
 451         fp = fopen(filename, "r+");
 452         PERR("Abri info");
 453         PERR(filename);
 454         if (fp == NULL) {
 455                 PERR("No se pudo");
 456                 return 0;
 457         }
 458
 459         fread(&cant, 1, sizeof(int), fp);
 460         indices = malloc((cant+1)*sizeof(t_Indice));
 461         fread(indices, cant, sizeof(t_Indice), fp);
 462         memset(indices[cant].nombre, 0, 50);
 463         strcpy(indices[cant].nombre, nombre);
 464         indices[cant].funcion = funcion;
 465         indices[cant].tipo = tipo;
 466         indices[cant].tipo_dato = tipo_dato;
 467         indices[cant].offset = offset;
 468         indices[cant].tam_bloque = tam_bloque;
 469
 470         fseek(fp, SEEK_SET, 0);
 471         cant++;
 472         fwrite(&cant, 1, sizeof(int), fp);
 473         fwrite(indices, cant, sizeof(t_Indice), fp);
 474         fclose(fp);
 475         return 1;
 476 }
 477
 478 /*crea un bloque y devuelve en numero del mismo*/
 479 EMUFS_BLOCK_ID emufs_create_new_block(EMUFS *emu)
 480 {
 481         FILE *fp;
 482         char name[255];
 483         char *dummy;
 484         EMUFS_BLOCK_ID num;
 485
 486         /* obtengo nombre del archivo */
 487         strcpy(name, emu->nombre);
 488         strcat(name,".dat");
 489
 490         if ( (fp=fopen(name,"a+")) == NULL ){
 491                 PERR("NO SE PUDO ABRIR EL ARCHIVO");
 492                 return -1;
 493         }
 494
 495         dummy = (char*)malloc(emu->tam_bloque);
 496         memset(dummy, 0, emu->tam_bloque);
 497         fwrite(dummy, emu->tam_bloque, 1, fp);
 498         printf("new_block ftell = %d\n", ftell(fp));
 499         switch(emu->tipo){
 500                 case T1: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE))/emu->tam_bloque;
 501                         break;
 502                 case T3: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE)-sizeof(EMUFS_REG_SIZE))/emu->tam_bloque;
 503         }
 504         fclose(fp);
 505         free(dummy);
 506         return num-1;
 507 }
 508
 509 /*devuelve un numero de bloque siguiente al ultimo*/
 510 EMUFS_BLOCK_ID emufs_get_new_block_number(EMUFS *emu)
 511 {
 512         FILE *fp;
 513         char name[255];
 514         EMUFS_BLOCK_ID num=0;
 515
 516         /* obtengo nombre del archivo */
 517         strcpy(name, emu->nombre);
 518         strcat(name,".dat");
 519         if ( (fp=fopen(name,"r")) == NULL ){
 520                 PERR("NO SE PUDO ABRIR EL ARCHIVO");
 521                 return -1;
 522         }
 523         if ( fseek(fp, 0, SEEK_END)!=0 ){
 524                 PERR("NO PUDE HACER EL SEEK");
 525                 return -1;
 526         }
 527         switch(emu->tipo){
 528                 case T1: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE))/emu->tam_bloque;
 529                         if (ftell(fp) ==  sizeof(EMUFS_Tipo)+sizeof(EMUFS_BLOCK_SIZE)) num = 0;
 530                                 PERR("PASE");
 531                         break;
 532                 case T3: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE)-sizeof(EMUFS_REG_SIZE))/emu->tam_bloque;
 533                         if (ftell(fp) ==  sizeof(EMUFS_Tipo)+sizeof(EMUFS_BLOCK_SIZE)+sizeof(EMUFS_REG_SIZE)) num = 0;
 534         }
 535         fclose(fp);
 536         return num;
 537 }
 538
 539 INDICE *emufs_buscar_indice_por_nombre(EMUFS *emu, const char *nombre)
 540 {
 541         INDICE *tmp;
 542
 543         tmp = emu->indices;
 544         while (tmp) {
 545                 if (strcmp(tmp->nombre, nombre) == 0) break;
 546                 tmp = tmp->sig;
 547         }
 548         return tmp;
 549 }