emufs/tipo1.c

   1 /* vim: set noexpandtab tabstop=4 shiftwidth=4 wrap:
   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:  vie abr  9 16:47:32 ART 2004
  22  * Autores: Leandro Lucarella <llucare@fi.uba.ar>
  23  *----------------------------------------------------------------------------
  24  *
  25  * $Id$
  26  *
  27  */
  28
  29 /** \file
  30  *
  31  * Archivo con bloque de longitud parametrizada, registro de longitud variable.
  32  *
  33  * Implementación del archivo con bloques de longitud parametrizada y registros
  34  * de longitud variable.
  35  *
  36  */
  37
  38 #include "tipo1.h"
  39 #include "idx.h"
  40 #include "fsc.h"
  41 #include "did.h"
  42 #include "common.h"
  43 #include "error.h"
  44 #include <unistd.h>
  45 #include <stdio.h>
  46 #include <math.h>
  47 #include <stdlib.h>
  48 #include <string.h>
  49
  50 #ifndef MIN
  51 #       define MIN(x, y) (((x) > (y)) ? (y) : (x))
  52 #endif
  53
  54 /*------------------ Declaraciones privadas ----------------------*/
  55
  56 /** Cabecera de un registro de un archivo tipo1. */
  57 typedef struct {
  58         EMUFS_REG_ID   id;   /**< Identificador del registro. */
  59         EMUFS_REG_SIZE size; /**< Tamaño del registro. */
  60 } EMUFS_TIPO1_REG_HEADER;
  61
  62 static size_t emufs_tipo1_header_size(void);
  63
  64 static int emufs_tipo1_header_jump(FILE*);
  65
  66 static int emufs_tipo1_block_jump(EMUFS*, FILE*, EMUFS_BLOCK_ID);
  67
  68 static void emufs_tipo1_escribir_reg_chunk_en_memoria(char* dst,
  69                 EMUFS_TIPO1_REG_HEADER header, char* reg, EMUFS_REG_SIZE reg_size);
  70
  71 /** Lee el bloque \param num_bloque y lo almacena en \c ptr. */
  72 static void* emufs_tipo1_leer_bloque(EMUFS*, EMUFS_BLOCK_ID, int*);
  73
  74 /** Graba un bloque en el archivo y actualiza .fsc, si se solicita. */
  75 static EMUFS_BLOCK_ID emufs_tipo1_grabar_bloque_fsc(EMUFS*, void*,
  76                 EMUFS_BLOCK_ID, EMUFS_FREE, int*);
  77
  78
  79 CLAVE grabar_ordenado_en_bloque(EMUFS *emu, void *ptr, EMUFS_REG_SIZE size,
  80                 EMUFS_FREE fs, void *bloque, int num_bloque, int *err);
  81
  82 /*------------------ Funciones públicas ----------------------*/
  83
  84 int emufs_tipo1_inicializar(EMUFS* efs)
  85 {
  86         /* como mínimo el tamaño de bloque debe ser 2 veces el tamaño de la cabecera
  87          * (una relación 1/2 entre datos e info de control ya es lo suficientemente
  88          * mala */
  89         if (efs->tam_bloque < (sizeof(EMUFS_TIPO1_REG_HEADER) * 2)) {
  90                 PERR("bloque demasiado chico");
  91                 return EMUFS_ERROR_BLOCK_TOO_SMALL;
  92         }
  93         /* Asigna punteros a funciones. */
  94         efs->leer_bloque       = emufs_tipo1_leer_bloque;
  95         efs->leer_bloque_raw   = emufs_tipo1_leer_bloque_raw;
  96         efs->grabar_registro   = emufs_tipo1_grabar_registro;
  97         efs->borrar_registro   = emufs_tipo1_borrar_registro;
  98         efs->leer_registro     = emufs_tipo1_leer_registro;
  99         efs->leer_registro_raw = emufs_tipo1_leer_registro_raw;
 100         efs->leer_estadisticas = emufs_tipo1_leer_estadisticas;
 101         efs->compactar         = emufs_tipo1_compactar;
 102         efs->tam_reg = 0;
 103         return EMUFS_OK;
 104 }
 105
 106 void* emufs_tipo1_leer_registro(EMUFS* efs, CLAVE clave,
 107                 EMUFS_REG_SIZE* reg_size, int *err)
 108 {
 109         char* block; /* bloque leido (en donde está el registro a leer) */
 110         char* registro; /* registro a leer */
 111         EMUFS_BLOCK_ID block_id; /* id del bloque en donde esta el registro a leer */
 112         EMUFS_BLOCK_SIZE offset; /* offset del bloque leído */
 113         EMUFS_REG_ID reg_id;
 114         EMUFS_TIPO1_REG_HEADER curr_reg_header; /* cabecera del registro a leer */
 115         INDICE_DATO dato;
 116
 117         if (efs->indices != NULL) {
 118                 /* TODO : Verificar donde esta el indice primario */
 119                 dato = efs->indices->existe_entrada(efs->indices, clave);
 120                 block_id = dato.bloque;
 121                 reg_id = dato.id;
 122         } else {
 123                 reg_id = clave.i_clave;
 124                 block_id = emufs_idx_buscar_registro(efs, reg_id);
 125         }
 126         if (block_id == EMUFS_NOT_FOUND) {
 127                 PERR("Registro no encontrado");
 128                 *err = EMUFS_NOT_FOUND;
 129                 return NULL;
 130         }
 131         if (!(block = (char*) emufs_tipo1_leer_bloque(efs, block_id, err))) {
 132                 PERR("no se pudo reservar memoria");
 133                 *err = EMUFS_ERROR_OUT_OF_MEMORY;
 134                 return NULL;
 135         }
 136
 137         /* Busco secuencialmente en el bloque el registro a leer */
 138         offset = 0;
 139         do {
 140                 /* Copio la cabecera del registro actual. */
 141                 memcpy(&curr_reg_header, block + offset, sizeof(EMUFS_TIPO1_REG_HEADER));
 142                 offset += sizeof(EMUFS_TIPO1_REG_HEADER);
 143                 if (curr_reg_header.id == reg_id) {
 144                         /* tamaño máximo ultilizable para datos en un bloque */
 145                         EMUFS_BLOCK_SIZE block_space
 146                                         = efs->tam_bloque - sizeof(EMUFS_TIPO1_REG_HEADER);
 147                         /* tamaño de la porción de registro que se guarda */
 148                         EMUFS_REG_SIZE chunk_size = 0;
 149                         /* puntero a la porción actual del registro */
 150                         char* chunk_ptr;
 151
 152                         *reg_size = curr_reg_header.size;
 153                         registro = chunk_ptr = (char*) malloc(*reg_size);
 154                         if (registro == NULL) {
 155                                 free(block);
 156                                 PERR("No hay memoria");
 157                                 *err = EMUFS_ERROR_OUT_OF_MEMORY;
 158                                 return NULL;
 159                         }
 160                         while (1) {
 161                                 chunk_ptr += chunk_size; /* Avanzo para guardar prox chunk */
 162                                 curr_reg_header.size -= chunk_size; /* Resto lo que ya guardé */
 163                                 chunk_size = MIN(curr_reg_header.size, block_space);
 164                                 /* copio porción de registro en el buffer */
 165                                 memcpy(chunk_ptr, block + offset, chunk_size);
 166                                  /* falta leer un bloque */
 167                                 if (curr_reg_header.size > block_space) {
 168                                         free(block);
 169                                         if (!(block = (char*) emufs_tipo1_leer_bloque(efs,
 170                                                                         ++block_id, err))) {
 171                                                 free(registro);
 172                                                 PERR("no se pudo reservar memoria");
 173                                                 *err = EMUFS_ERROR_OUT_OF_MEMORY;
 174                                                 return NULL;
 175                                         }
 176                                 } else { /* se terminó de leer */
 177                                         break;
 178                                 }
 179                         }
 180                         break;
 181                 }
 182                 /* Desplazo el offset */
 183                 offset += curr_reg_header.size;
 184
 185         /* esto no debería ser nunca false porque sé positivamente que el */
 186         } while (offset < efs->tam_bloque); /* registro está en el bloque */
 187
 188         free(block);
 189         return registro;
 190 }
 191
 192 void* emufs_tipo1_leer_registro_raw(EMUFS *efs, EMUFS_REG_ID id, EMUFS_REG_SIZE *size, int *pos)
 193 {
 194         char* block; /* bloque leido (en donde está el registro a leer) */
 195         EMUFS_BLOCK_ID block_id; /* bloque en donde esta el registro a leer */
 196         EMUFS_BLOCK_SIZE offset; /* offset del bloque leído */
 197         EMUFS_TIPO1_REG_HEADER curr_reg_header; /* cabecera del registro a leer */
 198         int err = 0;
 199
 200         block_id = emufs_idx_buscar_registro(efs, id);
 201         if (block_id == EMUFS_NOT_FOUND) {
 202                 PERR("Registro no encontrado");
 203                 *pos = 0;
 204                 *size = 0;
 205                 return NULL;
 206         }
 207         if (!(block = (char*) emufs_tipo1_leer_bloque(efs, block_id, &err))) {
 208                 PERR("no se pudo reservar memoria");
 209                 *pos = 0;
 210                 *size = 0;
 211                 return NULL;
 212         }
 213
 214         /* busco secuencialmente en el bloque el registro a leer */
 215         offset = 0;
 216         do {
 217                 /* copio la cabecera del registro actual. */
 218                 memcpy(&curr_reg_header, block + offset,
 219                                 sizeof(EMUFS_TIPO1_REG_HEADER));
 220                 offset += sizeof(EMUFS_TIPO1_REG_HEADER);
 221                 if (curr_reg_header.id == id) {
 222                         /* posición del comienzo del registro, incluye cabecera */
 223                         *pos = offset - sizeof(EMUFS_TIPO1_REG_HEADER);
 224                         *size = efs->tam_bloque; /* tamaño del bloque leido */
 225                         return block; /* devuelvo el puntero al bloque */
 226                 }
 227                 /* Desplazo el offset */
 228                 offset += curr_reg_header.size;
 229         } while (offset < efs->tam_bloque);
 230
 231         /* no se encontró el registro, no debería pasar nunca */
 232         PERR("No se encontró el registro en el bloque indicado por el .idx");
 233         free(block);
 234         return NULL;
 235 }
 236
 237 void* emufs_tipo1_leer_bloque(EMUFS* efs, EMUFS_BLOCK_ID block_id, int* err)
 238 {
 239         FILE* file;
 240         char* block; /* bloque leido (en donde está el registro a leer) */
 241         char  name_f[255];
 242
 243         strcpy(name_f,efs->nombre);
 244         strcat(name_f,".dat");
 245
 246         if ((file = fopen(name_f, "r")) == NULL) {
 247                 PERR("No se puede abrir archivo");
 248                 *err = EMUFS_ERROR_CANT_OPEN_FILE;
 249                 return NULL;
 250         }
 251         emufs_tipo1_header_jump(file); /* salta cabeceras */
 252         emufs_tipo1_block_jump(efs, file, block_id); /* salta bloques */
 253         block = (char*) malloc(efs->tam_bloque);
 254         if (block == NULL) {
 255                 PERR("No hay memoria");
 256                 *err = EMUFS_ERROR_OUT_OF_MEMORY;
 257                 fclose(file);
 258                 return NULL;
 259         }
 260         if (fread(block, efs->tam_bloque, 1, file) != 1) {
 261                 free(block);
 262                 fclose(file);
 263                 PERR("Error al leer bloque");
 264                 *err = EMUFS_ERROR_FILE_READ;
 265                 return NULL;
 266         }
 267         fclose(file);
 268         return block;
 269 }
 270
 271 EMUFS_REG_ID emufs_tipo1_grabar_registro(EMUFS* efs, void* reg,
 272                 EMUFS_REG_SIZE reg_size, int* err)
 273 {
 274         EMUFS_TIPO1_REG_HEADER header; /* cabecera del registro a leer */
 275         EMUFS_FREE fs; /* espacio libre en el bloque */
 276         EMUFS_BLOCK_ID block_id; /* identificador del 1er bloque */
 277         char* block; /* buffer del bloque a guardar en disco */
 278         char* chunk_ptr = reg; /* puntero a la poción del registro */
 279         EMUFS_BLOCK_SIZE block_space /* tamaño máximo para datos en un bloque */
 280                 = efs->tam_bloque - sizeof(EMUFS_TIPO1_REG_HEADER);
 281         /* identificador del bloque que se guarda */
 282         EMUFS_BLOCK_ID curr_block_id;
 283         /* tamaño de la porción de registro que se guarda */
 284         EMUFS_REG_SIZE chunk_size = 0;
 285         INDICE_DATO idx_data;
 286
 287         /* obtengo identificador que corresponderá al registro */
 288         header.id = emufs_idx_get_new_id(efs, err);
 289         if (*err) {
 290                 PERR("no se pudo obtener un id para el registro nuevo");
 291                 return EMUFS_NOT_FOUND;
 292         }
 293         header.size = reg_size; /* tamaño del registro */
 294
 295         /* busco lugar para el registro en un bloque existente */
 296         block_id = emufs_fsc_buscar_n_lugares(efs,
 297                         /* cantidad de bloques que necesita el registro */
 298                         (EMUFS_BLOCK_SIZE) ceil(header.size / (double) block_space),
 299                         /* cabecera + si es un registro multibloque, tomo el bloque */
 300                         sizeof(EMUFS_TIPO1_REG_HEADER) + MIN(header.size, block_space),
 301                         &fs, err);
 302         /* si no hay bloques con suficiente espacio creo un bloque nuevo */
 303         if (block_id == EMUFS_NOT_FOUND) {
 304                 /* crear un nuevo bloque en memoria */
 305                 block = (char*) malloc(efs->tam_bloque);
 306                 if (block == NULL) {
 307                         PERR("No hay memoria");
 308                         *err = EMUFS_ERROR_OUT_OF_MEMORY;
 309                         return EMUFS_NOT_FOUND;
 310                 }
 311                 memset(block, 0, efs->tam_bloque); /* inicializa bloque */
 312                 curr_block_id = EMUFS_NOT_FOUND; /* pongo de bloque actual el final */
 313         /* si hay bloques con suficiente espacio, levanto el primero */
 314         } else {
 315                 /* cargo el bloque en block_id */
 316                 if (!(block = (char*) emufs_tipo1_leer_bloque(efs, block_id, err))) {
 317                         PERR("no se pudo leer el bloque");
 318                         return EMUFS_NOT_FOUND;
 319                 }
 320                 curr_block_id = block_id; /* pongo de bloque actual el primero */
 321         }
 322
 323         do {
 324                 EMUFS_BLOCK_ID new_block_id; /* identificador del bloque nuevo */
 325                 chunk_ptr += chunk_size; /* Avanzo para guardar prox chunk */
 326                 header.size -= chunk_size; /* Resto lo que ya guardé */
 327                 chunk_size = MIN(header.size, block_space);
 328
 329                 /* graba porción del registro en bloque */ /* destino: fin de bloque */
 330                 emufs_tipo1_escribir_reg_chunk_en_memoria(block + efs->tam_bloque - fs,
 331                                 header, chunk_ptr, chunk_size);
 332                 /* rellena el espacio libre con ceros para la GUI */
 333                 memset(block + efs->tam_bloque - fs + chunk_size
 334                                 + sizeof(EMUFS_TIPO1_REG_HEADER), 0,
 335                                 fs - chunk_size - sizeof(EMUFS_TIPO1_REG_HEADER));
 336                 /* graba el bloque en el archivo */
 337                 new_block_id = emufs_tipo1_grabar_bloque_fsc(efs, block, curr_block_id,
 338                                 fs - sizeof(EMUFS_TIPO1_REG_HEADER) - chunk_size, err);
 339                 if (*err) {
 340                         PERR("error al grabar bloque");
 341                         free(block);
 342                         return EMUFS_NOT_FOUND;
 343                 }
 344                 /* si es el primer id de bloque obtenido, lo guardo para
 345                  * agregarlo después al archivo de índices. */
 346                 if (block_id == EMUFS_NOT_FOUND) {
 347                         block_id = new_block_id;
 348                 }
 349                 /* si no estoy por fuera del archivo, incremento el nro. de bloque */
 350                 if (curr_block_id != EMUFS_NOT_FOUND) {
 351                         ++curr_block_id;
 352                 }
 353
 354         /* mientras que el chunk no entre en un bloque */
 355         } while (header.size > block_space);
 356
 357         /* libera el bloque */
 358         free(block);
 359
 360         /* actualizo el indice de bloques y registros */
 361         *err = emufs_idx_agregar(efs, header.id, block_id);
 362         if (*err) {
 363                 PERR("No se pudo agregar idx");
 364                 return EMUFS_NOT_FOUND;
 365         }
 366         idx_data.id = header.id;
 367         idx_data.bloque = block_id;
 368         emufs_indice_agregar(efs->indices, reg, idx_data);
 369
 370         return header.id;
 371 }
 372
 373 int emufs_tipo1_borrar_registro(EMUFS* efs, CLAVE k)
 374 {
 375         char* block; /* bloque leido (en donde está el registro a leer) */
 376         EMUFS_BLOCK_ID block_id; /* id del bloque en donde esta el registro a leer */
 377         EMUFS_BLOCK_SIZE offset; /* offset del bloque leído */
 378         EMUFS_TIPO1_REG_HEADER curr_reg_header; /* cabecera del registro a leer */
 379         EMUFS_REG_ID reg_id;
 380         INDICE_DATO dato;
 381         int err = 0; /* para almacenar código de error */
 382
 383         if (efs->indices != NULL) {
 384                 dato = efs->indices->existe_entrada(efs->indices, k);
 385                 block_id = dato.bloque; /*emufs_idx_buscar_registro(emu, ID);*/
 386                 reg_id = dato.id;
 387         } else {
 388                 reg_id = k.i_clave;
 389                 block_id = emufs_idx_buscar_registro(efs, reg_id);
 390                 if (block_id == EMUFS_NOT_FOUND) {
 391                         PERR("Registro no encontrado");
 392                         return EMUFS_NOT_FOUND;
 393                 }
 394         }
 395
 396         if (reg_id == -1) return EMUFS_NOT_FOUND;
 397
 398         if (!(block = (char*) emufs_tipo1_leer_bloque(efs, block_id, &err))) {
 399                 PERR("no se pudo reservar memoria");
 400                 return err;
 401         }
 402
 403         /* Busco secuencialmente en el bloque el registro a leer */
 404         offset = 0;
 405         do {
 406                 /* Copio la cabecera del registro actual. */
 407                 memcpy(&curr_reg_header, block + offset, sizeof(EMUFS_TIPO1_REG_HEADER));
 408                 if (curr_reg_header.id == reg_id) {
 409                         /* identificador del bloque actual */
 410                         EMUFS_BLOCK_ID curr_block_id = block_id;
 411                         /* tamaño máximo ultilizable para datos en un bloque */
 412                         EMUFS_BLOCK_SIZE block_space
 413                                         = efs->tam_bloque - sizeof(EMUFS_TIPO1_REG_HEADER);
 414                         /* cantidad de espacio libre original del ultimo bloque */
 415                         EMUFS_FREE orig_fs;
 416
 417                         while (1) {
 418                                 EMUFS_FREE fs; /* cantidad de espacio libre en el bloque */
 419                                 orig_fs = emufs_fsc_get_fs(efs, curr_block_id);
 420                                 /* actualizo archivo de espacio libre por bloque */
 421                                 fs = orig_fs + MIN(curr_reg_header.size, block_space)
 422                                         + sizeof(EMUFS_TIPO1_REG_HEADER);
 423                                 if ((err = emufs_fsc_actualizar(efs, curr_block_id, fs))) {
 424                                         PERR("no se pudo actualizar .fsc");
 425                                         free(block);
 426                                         return err;
 427                                 }
 428                                 /* falta liberar un bloque (o porción) */
 429                                 if (curr_reg_header.size > block_space) {
 430                                         free(block);
 431                                         if (!(block = (char*) emufs_tipo1_leer_bloque(efs,
 432                                                                         ++curr_block_id, &err))) {
 433                                                 PERR("no se pudo leer el bloque");
 434                                                 return err;
 435                                         }
 436                                         /* copio la cabecera del primer registro (si ocupa más de un
 437                                          * registro está en bloques contiguos) */
 438                                         memcpy(&curr_reg_header, block,
 439                                                         sizeof(EMUFS_TIPO1_REG_HEADER));
 440                                 } else { /* se terminó de leer */
 441                                         break;
 442                                 }
 443                         }
 444
 445                         /* actualizo archivo de identificadores de registros borrados */
 446                         if ((err = emufs_did_agregar(efs, reg_id))) {
 447                                 PERR("no se pudo actualizar .did");
 448                                 free(block);
 449                                 return err;
 450                         }
 451                         /*actualizo archivo .idx*/
 452                         if ((err = emufs_idx_borrar(efs, reg_id))) {
 453                                 PERR("no se pudo actualizar .did");
 454                                 free(block);
 455                                 return err;
 456                         }
 457
 458                         /* desplazo registros a izquierda */
 459                         {   /* offset del fin del registro a borrar */
 460                                 EMUFS_BLOCK_SIZE offset_reg_end = offset
 461                                         + sizeof(EMUFS_TIPO1_REG_HEADER) + curr_reg_header.size;
 462                                 /* si es necesario desplazar */
 463                                 if (offset < offset_reg_end) {
 464                                         /* muevo la porción de bloque a izquierda */
 465                                         /* XXX Este memcpy() puede copiar regiones de memoria que
 466                                          * se superponen, si copia de principio a fin y byte a byte
 467                                          * no debería haber problema */
 468                                         memcpy(block + offset, block + offset_reg_end,
 469                                                 efs->tam_bloque - offset_reg_end);
 470                                         /* rellena el espacio libre con ceros para la GUI */
 471                                         memset(block + efs->tam_bloque - offset_reg_end - orig_fs + offset,
 472                                                         0, offset_reg_end + orig_fs - offset);
 473                                 }
 474                         }
 475                         /* guardo el bloque en disco (actualizando espacio libre) */
 476                         emufs_tipo1_grabar_bloque_fsc(efs, block, curr_block_id,
 477                                         EMUFS_NOT_FOUND, &err);
 478                         if (err) {
 479                                 PERR("no se pudo grabar bloque en disco");
 480                                 free(block);
 481                                 return err;
 482                         }
 483
 484                         break; /* salgo del loop, ya terminé lo que tenía que hacer */
 485                 }
 486                 /* desplazo el offset */
 487                 offset += sizeof(EMUFS_TIPO1_REG_HEADER) + curr_reg_header.size;
 488
 489         /* esto no debería ser nunca false porque sé positivamente que el */
 490         } while (offset < efs->tam_bloque); /* registro está en el bloque */
 491
 492         free(block);
 493         return EMUFS_OK;
 494 }
 495
 496 /* \bug Si hay registros multibloque, no se calcula bien el
 497  *         stats.tam_info_control_dat.
 498  */
 499 EMUFS_Estadisticas emufs_tipo1_leer_estadisticas(EMUFS* efs)
 500 {
 501         int err = 0;
 502         EMUFS_Estadisticas stats;
 503         memset(&stats, 0, sizeof(EMUFS_Estadisticas));
 504
 505         { /* obtengo tamaño del archivo en bytes */
 506                 char name_f[255];
 507                 strcpy(name_f, efs->nombre);
 508                 strcat(name_f, ".dat");
 509                 stats.tam_archivo = emufs_common_get_file_size(name_f, &err);
 510                 if (err) {
 511                         PERR("no se pudo obtener el tamaño del archivo");
 512                         return stats;
 513                 }
 514         }
 515
 516         /* obtengo cantidad de bloques en el archivo */
 517         stats.cant_bloques = (stats.tam_archivo - emufs_tipo1_header_size())
 518                         / efs->tam_bloque;
 519
 520         /* obtengo la cantidad de registros en el archivo */
 521         {
 522                 EMUFS_REG_ID *tmp = emufs_idx_get(efs, &stats.cant_registros);
 523                 if (tmp) free(tmp); /* libera memoria innecesaria */
 524         }
 525
 526         /* obtengo información de control que guarda el archivo .dat */
 527         stats.tam_info_control_dat = emufs_tipo1_header_size() /* cabecera del archivo */
 528                         /* mas las cabeceras de todos los registros */
 529                         + stats.cant_registros * sizeof(EMUFS_TIPO1_REG_HEADER);
 530
 531         /* obtengo las estadísticas del archivo de espacio libre por bloque */
 532         stats.total_fs = emufs_fsc_get_total_fs(efs);
 533         stats.media_fs = emufs_fsc_get_media_fs(efs);
 534         emufs_fsc_get_max_min_fs(efs, &stats.min_fs, &stats.max_fs);
 535
 536         /* obtengo informacion de control guardada por los archivos auxiliares */
 537         stats.tam_archivos_aux = emufs_idx_get_file_size(efs, &err)
 538                 + emufs_fsc_get_file_size(efs, &err)
 539                 + emufs_did_get_file_size(efs, &err);
 540         if (err) {
 541                 PERR("error al obtener tamaño de alguno de los archivos auxiliares");
 542                 return stats;
 543         }
 544
 545         return stats;
 546 }
 547
 548 void emufs_tipo1_compactar(EMUFS* efs)
 549 {
 550 #ifdef ARREGLAR
 551         EMUFS_BLOCK_SIZE block_space /* tamaño para datos de un bloque */
 552                 = efs->tam_bloque - sizeof(EMUFS_TIPO1_REG_HEADER);
 553         EMUFS_REG_ID total_ids; /* cantidad total de registros en el array */
 554         /* array con los identificadores de los registros */
 555         EMUFS_REG_ID* reg_ids = emufs_idx_get(efs, &total_ids);
 556         int i; /* índice de elemento actual del array */
 557
 558         /* recorro cada registro válido del archivo */
 559         for (i = 0; i < total_ids; ++i) {
 560                 EMUFS_TIPO1_REG_HEADER header; /* cabecera del registro a leer */
 561                 char* reg; /* buffer para el registro a mover */
 562                 int err = 0; /* para almacenar código de error */
 563                 /* bloque al que pertenece el registro */
 564                 EMUFS_BLOCK_ID block_id = emufs_idx_buscar_registro(efs, reg_ids[i]);
 565
 566                 /* obtengo identificador del registro actual */
 567                 header.id = reg_ids[i];
 568                 /* si el registro está borrado, continúo con el próximo */
 569                 if (block_id == EMUFS_NOT_FOUND) {
 570                         continue;
 571                 }
 572                 /* leo el registro */
 573                 reg = (char*) efs->leer_registro(efs, header.id, &header.size, &err);
 574                 if (err) {
 575                         PERR("error al leer registro");
 576                         return;
 577                 }
 578                 /* borro el registro */
 579                 if ((err = efs->borrar_registro(efs, header.id))) {
 580                         PERR("error al borrar registro");
 581                         free(reg);
 582                         return;
 583                 }
 584                 /* lo inserto en la nueva posición */
 585                 emufs_tipo1_grabar_registro(efs, reg, header.size, &err);
 586                 if (err) {
 587                         PERR("error al grabar registro");
 588                         free(reg);
 589                         return;
 590                 }
 591                 free(reg);
 592         }
 593         free(reg_ids); /* libero lista de ids */
 594
 595         /* truncamos el archivo si hay bloques libres al final */
 596         {
 597                 EMUFS_FREE fs; /* espacio libre en el bloque */
 598                 /* busco si hay algún bloque completo libre */
 599                 EMUFS_BLOCK_ID block_id = emufs_fsc_buscar_lugar(efs, block_space, &fs);
 600                 /* si hay, el resto del archivo tiene que estar vacío */
 601                 if (block_id != EMUFS_NOT_FOUND) {
 602                         long size = emufs_tipo1_header_size() /* cabecera del archivo */
 603                                 + block_id * efs->tam_bloque; /* mas los bloques compactos */
 604                         char filename[255];
 605
 606                         /* trunca archivo de datos */
 607                         strcpy(filename, efs->nombre);
 608                         strcat(filename, ".dat");
 609                         truncate(filename, size);
 610                         /* trunca archivo de de espacio libre */
 611                         emufs_fsc_truncate(efs, block_id);
 612                 }
 613         }
 614 #endif
 615 }
 616
 617 EMUFS_BLOCK_ID emufs_tipo1_grabar_bloque_fsc(EMUFS *efs, void *block,
 618                 EMUFS_BLOCK_ID block_id, EMUFS_FREE fs, int* err)
 619 {
 620         FILE* file;
 621         char name_f[255];
 622         EMUFS_BLOCK_SIZE num_blocks;
 623
 624         /* obtengo nombre del archivo */
 625         strcpy(name_f, efs->nombre);
 626         strcat(name_f,".dat");
 627
 628         /* obtengo cantidad de bloques */
 629         num_blocks =
 630                 (emufs_common_get_file_size(name_f, err) - emufs_tipo1_header_size())
 631                 / efs->tam_bloque;
 632         if (*err) {
 633                 PERR("Error al obtener tamaño del archivo.");
 634                 return EMUFS_NOT_FOUND;
 635         }
 636
 637         /* abre archivo */
 638         strcpy(name_f,efs->nombre);
 639         strcat(name_f,".dat");
 640         if ((file = fopen(name_f, "r+b")) == NULL) {
 641                 PERR("Error al abrir archivo");
 642                 *err = EMUFS_ERROR_CANT_OPEN_FILE;
 643                 return EMUFS_NOT_FOUND;
 644         }
 645         /* Si es NOT_FOUND o mayor a la cantidad de bloques presentes,
 646          * tengo que agregar un bloque al final del archivo */
 647         if ((block_id == EMUFS_NOT_FOUND) || (block_id >= num_blocks)) {
 648                 /* me paro al final del archivo */
 649                 if (fseek(file, 0l, SEEK_END)) {
 650                         PERR("No se pudo hacer fseek()");
 651                         fclose(file);
 652                         *err = EMUFS_ERROR_SEEK_FILE;
 653                         return EMUFS_NOT_FOUND;
 654                 }
 655                 /* Obtengo ID del bloque nuevo */
 656                 block_id = (ftell(file) - emufs_tipo1_header_size()) / efs->tam_bloque;
 657                 /* si me lo solicitan, actualizo el .fsc */
 658                 if (fs != EMUFS_NOT_FOUND) {
 659                         *err = emufs_fsc_agregar(efs, block_id, fs);
 660                         if (*err) {
 661                                 PERR("No se pudo agregar al .fsc");
 662                                 fclose(file);
 663                                 return EMUFS_NOT_FOUND;
 664                         }
 665                 }
 666         /* Si es un ID válido, salto hasta ese bloque. */
 667         } else {
 668                 /* Salta el header del archivo */
 669                 if ((*err = emufs_tipo1_header_jump(file))) {
 670                         PERR("no se pudo saltar la cabecera del archivo");
 671                         fclose(file);
 672                         return EMUFS_NOT_FOUND;
 673                 }
 674                 /* Salta bloques */
 675                 if ((*err = emufs_tipo1_block_jump(efs, file, block_id))) {
 676                         PERR("no se pudo saltar la cabecera del bloque");
 677                         fclose(file);
 678                         return EMUFS_NOT_FOUND;
 679                 }
 680                 /* si me lo solicitan, actualizo el .fsc */
 681                 if (fs != EMUFS_NOT_FOUND) {
 682                         if ((*err = emufs_fsc_actualizar(efs, block_id, fs))) {
 683                                 PERR("no se pudo actualizar .fsc");
 684                                 fclose(file);
 685                                 return EMUFS_NOT_FOUND;
 686                         }
 687                 }
 688         }
 689         /* Grabo el bloque */
 690         if (fwrite(block, efs->tam_bloque, 1, file) != 1) {
 691                 PERR("No se pudo escribir el archivo");
 692                 fclose(file);
 693                 *err = EMUFS_ERROR_WRITE_FILE;
 694                 return EMUFS_NOT_FOUND;
 695         }
 696
 697         fclose(file);
 698         return block_id;
 699 }
 700
 701 EMUFS_REG_ID emufs_tipo1_modificar_registro(EMUFS* efs, CLAVE k,
 702                 void *data, EMUFS_REG_SIZE size, int* err)
 703 {
 704         emufs_tipo1_borrar_registro(efs, k);
 705         return emufs_tipo1_grabar_registro(efs, data, size, err);
 706 }
 707
 708 size_t emufs_tipo1_header_size(void)
 709 {
 710         return sizeof(EMUFS_Tipo) + sizeof(EMUFS_BLOCK_SIZE);
 711 }
 712
 713 int emufs_tipo1_header_jump(FILE* fp)
 714 {
 715         if (fseek(fp, emufs_tipo1_header_size(), SEEK_CUR)) {
 716                 PERR("No se pudo hacer fseek()");
 717                 return EMUFS_ERROR_SEEK_FILE;
 718         }
 719         return EMUFS_OK;
 720 }
 721
 722 int emufs_tipo1_block_jump(EMUFS* efs, FILE* fp, EMUFS_BLOCK_ID block_count)
 723 {
 724         if (fseek(fp, block_count * efs->tam_bloque, SEEK_CUR)) {
 725                 PERR("No se pudo hacer fseek()");
 726                 return EMUFS_ERROR_SEEK_FILE;
 727         }
 728         return EMUFS_OK;
 729 }
 730
 731 /*crea un bloque y devuelve en numero del mismo*/
 732 EMUFS_BLOCK_ID create_new_block(EMUFS *emu)
 733 {
 734         FILE *fp;
 735         char name[255];
 736         char *dummy;
 737         EMUFS_BLOCK_ID num;
 738
 739         /* obtengo nombre del archivo */
 740         strcpy(name, emu->nombre);
 741         strcat(name,".dat");
 742
 743         if ( (fp=fopen(name,"a+")) == NULL ){
 744                 PERR("NO SE PUDO ABRIR EL ARCHIVO");
 745                 return -1;
 746         }
 747
 748         dummy = (char*)malloc(emu->tam_bloque);
 749         memset(dummy, 0, emu->tam_bloque);
 750         fwrite(dummy, emu->tam_bloque, 1, fp);
 751
 752         num = (ftell(fp)-emufs_tipo1_header_size())/emu->tam_bloque;
 753         fclose(fp);
 754         free(dummy);
 755         return num;
 756 }
 757
 758 /*devuelve un numero de bloque siguiente al ultimo*/
 759 EMUFS_BLOCK_ID get_new_block_number(EMUFS *emu)
 760 {
 761         FILE *fp;
 762         char name[255];
 763         EMUFS_BLOCK_ID num;
 764
 765         /* obtengo nombre del archivo */
 766         strcpy(name, emu->nombre);
 767         strcat(name,".dat");
 768
 769         if ( (fp=fopen(name,"a+")) == NULL ){
 770                 PERR("NO SE PUDO ABRIR EL ARCHIVO");
 771                 return -1;
 772         }
 773         num = (ftell(fp)-emufs_tipo1_header_size())/emu->tam_bloque;
 774         fclose(fp);
 775         return num+1;
 776 }
 777
 778 void emufs_tipo1_escribir_reg_chunk_en_memoria(char* dst,
 779                 EMUFS_TIPO1_REG_HEADER header, char* reg, EMUFS_REG_SIZE reg_size)
 780 {
 781         /* grabo cabecera del registro en el bloque */
 782         memcpy(dst, &header, sizeof(EMUFS_TIPO1_REG_HEADER));
 783         /* incremento puntero de escritura */
 784         dst += sizeof(EMUFS_TIPO1_REG_HEADER);
 785         /* grabo el registro en el bloque */
 786         memcpy(dst, reg, reg_size);
 787 }
 788
 789 void emufs_tipo1_leer_bloque_raw(EMUFS *efs, EMUFS_BLOCK_ID id, char **actual, char **anterior, char **siguiente, EMUFS_BLOCK_SIZE *size1, EMUFS_BLOCK_SIZE *size2, EMUFS_BLOCK_SIZE *size3)
 790 {
 791         int err = 0;
 792         (*actual) = emufs_tipo1_leer_bloque(efs, id, &err);
 793         (*anterior) = emufs_tipo1_leer_bloque(efs, id-1, &err);
 794         (*siguiente) = emufs_tipo1_leer_bloque(efs, id+1, &err);
 795         (*size1) = (*size2) = (*size3) = efs->tam_bloque;
 796 }
 797
 798 int emufs_tipo1_insertar_ordenado(EMUFS *emu, void *ptr, EMUFS_REG_SIZE size, int *err)
 799 {
 800         CLAVE clave;
 801         EMUFS_BLOCK_ID num_bloque = get_new_block_number(emu);
 802         EMUFS_TIPO1_REG_HEADER header;
 803         EMUFS_REG_SIZE tam_reg, move_size;
 804         INDEX_DAT query;
 805         EMUFS_FREE fs;
 806         char *bloque, *aux, *new_bloque;
 807         int cant_reg, i, result;
 808
 809         /*le asigno un posible numero de bloque para el caso en que no encuentre donde meterlo*/
 810         query.num_bloque = num_bloque;
 811         /*saco la clave del stream*/
 812         query.clave = emufs_indice_generar_clave(emu->indices, ptr);
 813         /*mando a buscar en el arbol el bloque correspondiente a esa clave*/
 814         /*en query->num_bloque tengo el bloque donde debo meter el registro*/
 815         /*debo insertar el reg en el bloque en forma ordenada*/
 816         /*si es el menor de todos tengo que cambiar el ancla en el arbol*/
 817         /*si no entra, tengo que insertar una nueva clave en el arbol y separar los registros en 2 bloques*/
 818         /* emufs_b_plus_get_bloque retorna asi
 819         -1 = Nuevo bloque, retorno idem num_bloque que ingreso
 820         0 = Sin problemas, retorno bloque donde insertar
 821         1 = Error de lectura en algun nodo, abortar operacion en funcion invocante.
 822         */
 823         result = emufs_b_plus_get_bloque(emu->indices, &query);
 824         if (result == 1){
 825                 PERR("SE PRODUJO UN ERROR EN EL ARBOL.. ABORTANDO");
 826                 return -1;
 827         }
 828         if ( result == -1 ){
 829                 /*creo un bloque nuevo*/
 830                 bloque = (char*) malloc(emu->tam_bloque);
 831                 if (bloque == NULL){
 832                         PERR("NO SE PUDO CREAR EL BLOQUE");
 833                         return -1;
 834                 }
 835                 header.id = emufs_idx_get_new_id(emu, err);
 836                 header.size = size;
 837                 cant_reg = 1;
 838                 /*pongo la cabecera en el registro*/
 839                 memcpy(bloque, &header, sizeof(EMUFS_TIPO1_REG_HEADER));
 840                 /*inserto el footer en el bloque*/
 841                 memcpy(bloque+emu->tam_bloque-sizeof(int), &cant_reg, sizeof(int));
 842                 /*inserto el registro en el bloqude*/
 843                 if ( size <= emu->tam_bloque-sizeof(EMUFS_TIPO1_REG_HEADER)-sizeof(int) )
 844                         memcpy(bloque+sizeof(EMUFS_TIPO1_REG_HEADER), ptr, size);
 845                 else {
 846                         PERR("NO ENTRA EL REGISTRO EN EL BLOQUE!!!!!");
 847                         free(bloque);
 848                         return -1;
 849                 }
 850                 /*hago lugar en el archivo para grabar*/
 851                 if ( num_bloque != create_new_block(emu) )      PERR("NUMEROS DE NUEVO BLOQUE DISTINTOS");
 852                 /*grabo el bloque en el archivo*/ /* OJO CON LO DE FS = 0 */
 853                 emufs_tipo1_grabar_bloque_fsc(emu, bloque, query.num_bloque, EMUFS_NOT_FOUND, err);
 854                 /*agrego la clave al arbol*/
 855                 emufs_b_plus_insertar(emu->indices, &query);
 856                 free(bloque);
 857                 return 0;
 858         } else { /*tengo que meter el registro en el bloque que me dijo el arbol*/
 859                 /*leo el bloque correspondiente*/
 860                 bloque = emufs_tipo1_leer_bloque(emu, num_bloque, err);
 861                 /*me fijo cuantos registros hay en el */
 862                 memcpy(&cant_reg, bloque+emu->tam_bloque-sizeof(int), sizeof(int));
 863                 /*me fijo si entra en nuevo reg en el bloque */
 864                 fs = emu->tam_bloque;
 865                 aux = bloque;
 866                 for (i=0; i<cant_reg; i++){
 867                         memcpy(&tam_reg, aux+sizeof(EMUFS_REG_ID), sizeof(EMUFS_REG_SIZE));
 868                         aux += sizeof(EMUFS_TIPO1_REG_HEADER)+tam_reg;
 869                         fs -= (tam_reg+sizeof(EMUFS_TIPO1_REG_HEADER));
 870                 } /*aca deberia estar apuntando al final de los registros. espacio libre*/
 871                 fs -= sizeof(int); /*footer*/
 872                 if ( fs >= size+sizeof(EMUFS_TIPO1_REG_HEADER) ){ /* puedo meter el registro en este bloque*/
 873                         grabar_ordenado_en_bloque(emu, ptr, size, bloque, query.num_bloque, fs, err);
 874                         /*en teoria el nuevo registro no debe cambiar el ancla, por lo cual no actualizo el arbol*/
 875                         return 0;
 876                 /*aca va lo que saque*/
 877                 } else { /* el registro no entra en el bloque, hay que crear uno nuevo y desparramar */
 878                         new_bloque = (char*)malloc(emu->tam_bloque);
 879                         move_size=0;
 880                         for(i=0; i<cant_reg/2; i++){ /*copio mitad aca y mitad en el nuevo*/
 881                                 /*avanzo*/
 882                                 memcpy(&tam_reg, aux+sizeof(EMUFS_REG_ID), sizeof(EMUFS_REG_SIZE));
 883                                 aux += sizeof(EMUFS_TIPO1_REG_HEADER)+tam_reg;
 884                                 move_size += sizeof(EMUFS_TIPO1_REG_HEADER)+tam_reg;
 885                         }
 886                         /*copio el resto del bloque al nuevo bloque*/
 887                         memcpy(new_bloque, aux, emu->tam_bloque-move_size);
 888                         /*borro lo que sobra en el bloque original, guardando el footer*/
 889                         memset(aux, 0, emu->tam_bloque - move_size - sizeof(int));
 890                         /*actualizo la cant de registros (footer)*/
 891                         memcpy(bloque+emu->tam_bloque-sizeof(int), i, sizeof(int));
 892                         /*grabo el bloque original*/
 893                         emufs_tipo1_grabar_bloque_fsc(emu, bloque, num_bloque, EMUFS_NOT_FOUND, err);
 894                         /*actualizo el footer del nuevo bloque*/
 895                         memcpy(new_bloque+emu->tam_bloque, cant_reg-i, sizeof(int));
 896                         /*genero un nuevo espacio para un bloque en el archivo y lo cargo en query
 897                           la clave ya estaba en query desde antes*/
 898                         query.num_bloque = create_new_block(emu);
 899                         /*inserto el nuevo registro en el nuevo bloque y obtengo la clave del menor*/
 900                         clave = grabar_ordenado_en_bloque(emu,ptr,size,new_bloque,query.num_bloque, emu->tam_bloque-move_size,err);
 901                         /*actualizo el arbol con la nueva clave*/
 902                         emufs_b_plus_insertar(emu->indices, &query);
 903                         free(new_bloque);
 904                         free(bloque);
 905                         return 0;
 906                 }
 907         }
 908         return 0;
 909 }
 910
 911 /*inserta un registro ordenado en un bloque y devuelve la menor de las claves*/
 912 CLAVE grabar_ordenado_en_bloque(EMUFS *emu, void *ptr, EMUFS_REG_SIZE size, void *bloque, int num_bloque, EMUFS_FREE fs, int *err)
 913 {
 914         char *aux, *new_bloque;
 915         int cant_reg, tam_reg, i, j;
 916         EMUFS_TIPO1_REG_HEADER header;
 917         CLAVE clave, clave_ajena;
 918
 919         /*saco la cant de registros del bloque*/
 920         memcpy(&cant_reg, bloque+emu->tam_bloque-sizeof(int), sizeof(int));
 921         /*obtengo la clave del nuevo registro*/
 922         clave = emufs_indice_generar_clave(emu->indices, ptr);
 923         /*cargo el header*/
 924         header.id = emufs_idx_get_new_id(emu, err);
 925         header.size = size;
 926         cant_reg++; /*voy a poner un reg mas*/
 927         new_bloque = (char*)malloc(emu->tam_bloque);
 928         aux = new_bloque;
 929         for (i=0; i<cant_reg+1; i++){
 930                 bloque += sizeof(EMUFS_TIPO1_REG_HEADER); /*salteo el encabezado del registro*/
 931                 if ( emu->tam_bloque-fs < sizeof(EMUFS_TIPO1_REG_HEADER)+emu->indices->offset ){
 932                         PERR("ESTOY LEYENDO FUERA DEL BLOQUE!!!");
 933                         free(new_bloque);
 934                         *err = -1;
 935                         return clave;
 936                 }
 937                 clave_ajena = emufs_indice_generar_clave(emu->indices, bloque); /*leo la clave*/
 938                 bloque -= sizeof(EMUFS_TIPO1_REG_HEADER); /*vuelvo al principio*/
 939                 if (  i<cant_reg && emufs_indice_es_menor(emu->indices, clave_ajena, clave) ){
 940                         memcpy(&tam_reg, bloque+sizeof(EMUFS_REG_ID), sizeof(EMUFS_REG_SIZE));
 941                         /*copio el reg al bloque nuevo*/
 942                         memcpy(new_bloque, bloque, sizeof(EMUFS_TIPO1_REG_HEADER)+tam_reg);
 943                         bloque += sizeof(EMUFS_TIPO1_REG_HEADER)+ tam_reg; /*paso al proximo*/
 944                         new_bloque += sizeof(EMUFS_TIPO1_REG_HEADER)+ tam_reg; /*dejo preparado*/
 945                         continue;
 946                 } else {
 947                         /*meto el registro que me mandan*/
 948                         memcpy(new_bloque, &header, sizeof(EMUFS_TIPO1_REG_HEADER));
 949                         memcpy(new_bloque+sizeof(EMUFS_TIPO1_REG_HEADER), ptr, size);
 950                         new_bloque += sizeof(EMUFS_TIPO1_REG_HEADER)+size;
 951                         /*tengo que copiar los que faltan*/
 952                         j = i;
 953                         while ( j < cant_reg ){
 954                                 memcpy(&tam_reg, bloque+sizeof(EMUFS_REG_ID), sizeof(EMUFS_REG_SIZE));
 955                                 memcpy(new_bloque, bloque, sizeof(EMUFS_TIPO1_REG_HEADER)+tam_reg);
 956                                 bloque += sizeof(EMUFS_TIPO1_REG_HEADER)+tam_reg;
 957                                 new_bloque += sizeof(EMUFS_TIPO1_REG_HEADER)+tam_reg;
 958                                 j++;
 959                         }
 960                 break; /*corto el for porque ya inserte todos*/
 961                 }
 962         }
 963         /*grabo el bloque en el archivo*/
 964         new_bloque = aux; /*apunto al principio del bloque*/
 965         emufs_tipo1_grabar_bloque_fsc(emu, new_bloque, num_bloque, EMUFS_NOT_FOUND, err);
 966         clave = emufs_indice_generar_clave(emu->indices, new_bloque+sizeof(EMUFS_TIPO1_REG_HEADER));
 967         free(new_bloque);
 968         return clave;
 969 }