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                         if ((err = emufs_tipo3_inicializar(efs))) {
 195                                 /* TODO ERROR */
 196                                 PERR("No se pudo inicializar el EMUFS de tipo3");
 197                                 fclose(fp);
 198                                 free(efs->nombre);
 199                                 free(efs);
 200                                 return NULL;
 201                         }
 202                         /* Guarda cabeceras propias. */
 203                         fwrite(&tam_bloque, sizeof(EMUFS_BLOCK_SIZE), 1, fp);
 204                         fwrite(&tam_reg, sizeof(EMUFS_REG_SIZE), 1, fp);
 205                         break;
 206
 207                 case T4:
 208                         /* Asigna punteros a funciones. */
 209                         if ((err = emufs_tipo4_inicializar(efs))) {
 210                                 /* TODO ERROR */
 211                                 PERR("No se pudo inicializar el EMUFS de tipo4");
 212                                 fclose(fp);
 213                                 free(efs->nombre);
 214                                 free(efs);
 215                                 return NULL;
 216                         }
 217                         /* Guarda cabeceras propias. */
 218                         fwrite(&tam_bloque, sizeof(EMUFS_BLOCK_SIZE), 1, fp);
 219                         break;
 220
 221                 case T5:
 222                         /* Asigna punteros a funciones. */
 223                         if ((err = emufs_tipo5_inicializar(efs))) {
 224                                 /* TODO ERROR */
 225                                 PERR("No se pudo inicializar el EMUFS de tipo5");
 226                                 fclose(fp);
 227                                 free(efs->nombre);
 228                                 free(efs);
 229                                 return NULL;
 230                         }
 231                         /* Guarda cabeceras propias. */
 232                         fwrite(&tam_bloque, sizeof(EMUFS_BLOCK_SIZE), 1, fp);
 233                         fwrite(&tam_reg, sizeof(EMUFS_REG_SIZE), 1, fp);
 234                         break;
 235         }
 236
 237         fclose(fp);
 238         return efs;
 239 }
 240
 241 EMUFS *emufs_abrir(const char *filename)
 242 {
 243         EMUFS *efs;
 244         char name[255];
 245         char tipo;
 246         FILE *fp;
 247         int err = 0;
 248
 249         strcpy(name, filename);
 250         strcat(name, ".dat");
 251
 252         /* Trato de determinar el tipo de archivo */
 253         fp = fopen(name, "r");
 254         if (fp == NULL) return NULL;
 255         fread(&tipo, sizeof(EMUFS_Tipo), 1, fp);
 256
 257         /* Si no es un tipo conocido, sale. */
 258         if ((tipo != T1) && (tipo != T2) && (tipo != T3)) {
 259                 fclose(fp);
 260                 return NULL;
 261         }
 262
 263         /* Inicializa parámetros comunes. */
 264         efs = (EMUFS*) malloc(sizeof(EMUFS));
 265         if (efs == NULL) {
 266                 fclose(fp);
 267                 return NULL;
 268         }
 269         efs->tipo = tipo;
 270         efs->nombre = str_dup(filename);
 271
 272         switch (tipo) {
 273                 case T1:
 274                         /* Lee cabeceras propias. */
 275                         if (!fread(&(efs->tam_bloque), sizeof(EMUFS_BLOCK_SIZE), 1, fp)) {
 276                                 free(efs->nombre);
 277                                 free(efs);
 278                                 fclose(fp);
 279                                 return NULL;
 280                         }
 281                         /* Asigna punteros a funciones. */
 282                         if ((err = emufs_tipo1_inicializar(efs))) {
 283                                 PERR("No se pudo inicializar el EMUFS de tipo1");
 284                                 fclose(fp);
 285                                 return NULL;
 286                         }
 287                         break;
 288                 case T2:
 289                         /* Asigna punteros a funciones. */
 290                         emufs_tipo2_inicializar(efs);
 291                         break;
 292                 case T3:
 293                         if ((!fread(&(efs->tam_bloque), sizeof(EMUFS_BLOCK_SIZE), 1, fp)) ||
 294                            (!fread(&(efs->tam_reg), sizeof(EMUFS_REG_SIZE), 1, fp)))
 295                                 {
 296                                 free(efs->nombre);
 297                                 free(efs);
 298                                 fclose(fp);
 299                                 return NULL;
 300                         }
 301                         /* Asigna punteros a funciones. */
 302                         efs->leer_bloque = emufs_tipo3_leer_bloque;
 303                         efs->leer_registro_raw = emufs_tipo3_leer_registro_raw;
 304                         efs->leer_registro = emufs_tipo3_leer_registro;
 305                         efs->grabar_registro = emufs_tipo3_grabar_registro;
 306                         efs->borrar_registro = emufs_tipo3_borrar_registro;
 307                         efs->leer_estadisticas = emufs_tipo3_leer_estadisticas;
 308                         efs->modificar_registro = emufs_tipo3_modificar_registro;
 309                         efs->compactar = emufs_tipo3_compactar;
 310                         efs->leer_bloque_raw = emufs_tipo3_leer_bloque_raw;
 311                         break;
 312         }
 313
 314         fclose(fp);
 315         return efs;
 316 }
 317
 318 int emufs_destruir(EMUFS *e)
 319 {
 320         INDICE *del, *cur;
 321
 322         if (e == NULL) return 1;
 323
 324         /* libero indices */
 325         cur = e->indices;
 326         while (cur) {
 327                 del = cur;
 328                 cur = cur->sig;
 329                 emufs_indice_destruir(e, cur);
 330         }
 331
 332         free(e->nombre);
 333         free(e);
 334         return 0;
 335 }
 336
 337 int ver_archivo_FS(EMUFS *emu)
 338 {
 339         FILE *f_block_free;
 340         EMUFS_FSC reg;
 341         char name_f_block_free[255];
 342
 343         strcpy(name_f_block_free,emu->nombre);
 344         strcat(name_f_block_free,".fsc");
 345
 346         if ( (f_block_free = fopen(name_f_block_free,"r"))==NULL ){
 347                 fprintf(stderr, "no pude abrir el archivo %s\n",name_f_block_free);
 348                 return -1;
 349         }
 350         fprintf(stderr,"BOQUES Y ESPACIO LIBRE\n");
 351         fread(&reg,sizeof(reg),1,f_block_free);
 352         while ( !feof(f_block_free) ){
 353                 fprintf(stderr, "Bloque = %li   Espacio libre = %li\n",reg.marker, reg.freespace);
 354                 fread(&reg,sizeof(reg),1,f_block_free);
 355         }
 356
 357         fclose(f_block_free);
 358
 359         /* Imprimo la lista de bloques/registros */
 360         fprintf(stderr, "BLOQUES Y REGISTROS\n");
 361         strcpy(name_f_block_free,emu->nombre);
 362         strcat(name_f_block_free,".idx");
 363         f_block_free = fopen(name_f_block_free, "r");
 364         {
 365                 EMUFS_IDX r;
 366                 while (!feof(f_block_free)) {
 367                         if (fread(&r, sizeof(EMUFS_IDX), 1, f_block_free) != 1) continue;
 368                         fprintf(stderr, "ID %li en bloque %li\n", r.id_reg, r.location);
 369                 }
 370         }
 371         fclose(f_block_free);
 372
 373         return 0;
 374 }
 375
 376 int debug_ver_estadisticas(EMUFS* efs)
 377 {
 378         EMUFS_Estadisticas s = efs->leer_estadisticas(efs);
 379
 380         printf("ESTADISTICAS:\n");
 381         printf("=============\n");
 382         printf("Tamaño del archivo: %lu bytes\n", s.tam_archivo);
 383         printf("Tamaño de datos (incluye espacio libre): %lu bytes (%.2f %%)\n",
 384                         s.tam_archivo - s.tam_info_control_dat,
 385                         (s.tam_archivo - s.tam_info_control_dat) * 100.0
 386                                 / (float) s.tam_archivo);
 387         printf("Tamaño de info de control total: %lu bytes (%.2f %%)\n",
 388                         s.tam_info_control_dat + s.tam_archivos_aux,
 389                         (s.tam_info_control_dat + s.tam_archivos_aux) * 100.0
 390                                 / (float) s.tam_archivo);
 391         printf("Tamaño de los archivos auxiliares: %lu bytes\n",
 392                         s.tam_archivos_aux);
 393         printf("Tamaño de la información de control en el .dat: %lu bytes\n",
 394                         s.tam_info_control_dat);
 395         printf("Total de espacio libre: %lu bytes\n", s.total_fs);
 396         printf("Máximo espacio libre en bloque: %lu bytes\n", s.max_fs);
 397         printf("Mínimo espacio libre en bloque: %lu bytes\n", s.min_fs);
 398         printf("Media del espacio libre por bloque: %lu bytes\n", s.media_fs);
 399         printf("Cantidad de registros: %lu\n", s.cant_registros);
 400         printf("Cantidad de bloques: %lu\n", s.cant_bloques);
 401         return 0;
 402 }
 403
 404 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, int str_offset)
 405 {
 406         INDICE *tmp;
 407         int error=0;
 408
 409         /* Verifico que no existe un indice con el mismo nombre */
 410         /* y que no exista un indice primario */
 411         PERR("Agregando indice");
 412         tmp = emu->indices;
 413         while (tmp) {
 414                 if (strcmp(tmp->nombre, nombre)==0) {
 415                         error = 1;
 416                         break;
 417                 }
 418                 if ((funcion == IND_PRIMARIO) && (tmp->funcion == funcion)) {
 419                         error = 2;
 420                         break;
 421                 }
 422                 tmp = tmp->sig;
 423         }
 424
 425         if (tmp != NULL) {
 426                 switch (error) {
 427                         case 1:
 428                                 PERR("Ya existe un indice con el mismo nombre!");
 429                         break;
 430                         case 2:
 431                                 PERR("EMUFS ya tiene indice primario!!");
 432                 }
 433                 return 0;
 434         }
 435
 436         /* Creo el nuevo indice */
 437         PERR("Creando indice\n");
 438         tmp = emufs_indice_crear(emu, nombre, funcion, tipo, tipo_dato, offset, tam_bloque, str_offset);
 439
 440         /* Guardo la info del indice para poder abrir despues el archivo */
 441         guardar_indice(emu, nombre, funcion, tipo, tipo_dato, offset, tam_bloque);
 442
 443         if (tmp == NULL) {
 444                 PERR("NO SE PUDO CREAR INDICE!!!");
 445                 return 0;
 446         }
 447
 448         if (emu->indices==NULL)
 449                 emu->indices = tmp;
 450         else {
 451                 tmp->sig = emu->indices;
 452                 emu->indices = tmp;
 453         }
 454         return 1;
 455 }
 456
 457 INDICE_DATO *emufs_buscar_registros(EMUFS *emu, char *indice, char *data, int *cant)
 458 {
 459         CLAVE k;
 460         INDICE *tmp;
 461
 462         tmp = emu->indices;
 463         while (tmp) {
 464                 if (strcmp(tmp->nombre, indice) == 0) break;
 465                 tmp = tmp->sig;
 466         }
 467
 468         if (tmp == NULL) {
 469                 PERR("NO EXISTE EL INDICE");
 470                 cant = 0;
 471                 return NULL;
 472         }
 473
 474         PERR("GENERANDO CLAVE")
 475         PERR(data);
 476         k = emufs_indice_generar_clave_desde_valor(tmp, data);
 477         PERR("DONE");
 478         return tmp->buscar_entradas(tmp, k, cant);
 479 }
 480
 481 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)
 482 {
 483         char filename[100];
 484         FILE *fp;
 485         int cant; /* cantidad de indices hasta el momento */
 486         t_Indice *indices;
 487
 488         sprintf(filename, "%s.info", emu->nombre);
 489         fp = fopen(filename, "r+");
 490         PERR("Abri info");
 491         PERR(filename);
 492         if (fp == NULL) {
 493                 PERR("No se pudo");
 494                 return 0;
 495         }
 496
 497         fread(&cant, 1, sizeof(int), fp);
 498         indices = malloc((cant+1)*sizeof(t_Indice));
 499         fread(indices, cant, sizeof(t_Indice), fp);
 500         memset(indices[cant].nombre, 0, 50);
 501         strcpy(indices[cant].nombre, nombre);
 502         indices[cant].funcion = funcion;
 503         indices[cant].tipo = tipo;
 504         indices[cant].tipo_dato = tipo_dato;
 505         indices[cant].offset = offset;
 506         indices[cant].tam_bloque = tam_bloque;
 507
 508         fseek(fp, SEEK_SET, 0);
 509         cant++;
 510         fwrite(&cant, 1, sizeof(int), fp);
 511         fwrite(indices, cant, sizeof(t_Indice), fp);
 512         fclose(fp);
 513         free(indices);
 514         return 1;
 515 }
 516
 517 /*crea un bloque y devuelve en numero del mismo*/
 518 EMUFS_BLOCK_ID emufs_create_new_block(EMUFS *emu)
 519 {
 520         FILE *fp;
 521         char name[255];
 522         char *dummy;
 523         EMUFS_BLOCK_ID num;
 524
 525         /* obtengo nombre del archivo */
 526         strcpy(name, emu->nombre);
 527         strcat(name,".dat");
 528
 529         if ( (fp=fopen(name,"a+")) == NULL ){
 530                 PERR("NO SE PUDO ABRIR EL ARCHIVO");
 531                 return -1;
 532         }
 533
 534         dummy = (char*)malloc(emu->tam_bloque);
 535         memset(dummy, 0, emu->tam_bloque);
 536         fwrite(dummy, emu->tam_bloque, 1, fp);
 537         switch(emu->tipo){
 538                 case T1: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE))/emu->tam_bloque;
 539                         break;
 540                 case T3: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE)-sizeof(EMUFS_REG_SIZE))/emu->tam_bloque;
 541         }
 542         fclose(fp);
 543         free(dummy);
 544         return num-1;
 545 }
 546
 547 /*devuelve un numero de bloque siguiente al ultimo*/
 548 EMUFS_BLOCK_ID emufs_get_new_block_number(EMUFS *emu)
 549 {
 550         FILE *fp;
 551         char name[255];
 552         EMUFS_BLOCK_ID num=0;
 553
 554         /* obtengo nombre del archivo */
 555         strcpy(name, emu->nombre);
 556         strcat(name,".dat");
 557         if ( (fp=fopen(name,"r")) == NULL ){
 558                 PERR("NO SE PUDO ABRIR EL ARCHIVO");
 559                 return -1;
 560         }
 561         if ( fseek(fp, 0, SEEK_END)!=0 ){
 562                 PERR("NO PUDE HACER EL SEEK");
 563                 return -1;
 564         }
 565         switch(emu->tipo){
 566                 case T1: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE))/emu->tam_bloque;
 567                         if (ftell(fp) ==  sizeof(EMUFS_Tipo)+sizeof(EMUFS_BLOCK_SIZE)) num = 0;
 568                         break;
 569                 case T3: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE)-sizeof(EMUFS_REG_SIZE))/emu->tam_bloque;
 570                         if (ftell(fp) ==  sizeof(EMUFS_Tipo)+sizeof(EMUFS_BLOCK_SIZE)+sizeof(EMUFS_REG_SIZE)) num = 0;
 571         }
 572         fclose(fp);
 573         return num;
 574 }
 575
 576 INDICE *emufs_buscar_indice_por_nombre(EMUFS *emu, const char *nombre)
 577 {
 578         INDICE *tmp;
 579
 580         tmp = emu->indices;
 581         while (tmp) {
 582                 if (strcmp(tmp->nombre, nombre) == 0) break;
 583                 tmp = tmp->sig;
 584         }
 585         return tmp;
 586 }