X-Git-Url: https://git.llucax.com/z.facultad/75.06/emufs.git/blobdiff_plain/5a67fdb396639987febb90770180252ce1e9ba6e..ddc964cd151aae4713a5d2d658da986df7cd3441:/emufs/tipo1.c diff --git a/emufs/tipo1.c b/emufs/tipo1.c index a4f9de7..fa1c012 100644 --- a/emufs/tipo1.c +++ b/emufs/tipo1.c @@ -99,16 +99,26 @@ int emufs_tipo1_inicializar(EMUFS* efs) return EMUFS_OK; } -void* emufs_tipo1_leer_registro(EMUFS* efs, EMUFS_REG_ID reg_id, +void* emufs_tipo1_leer_registro(EMUFS* efs, CLAVE clave, EMUFS_REG_SIZE* reg_size, int *err) { char* block; /* bloque leido (en donde está el registro a leer) */ char* registro; /* registro a leer */ EMUFS_BLOCK_ID block_id; /* id del bloque en donde esta el registro a leer */ EMUFS_BLOCK_SIZE offset; /* offset del bloque leído */ + EMUFS_REG_ID reg_id; EMUFS_TIPO1_REG_HEADER curr_reg_header; /* cabecera del registro a leer */ - - block_id = emufs_idx_buscar_registro(efs, reg_id); + INDICE_DATO dato; + + if (efs->indices != NULL) { + /* TODO : Verificar donde esta el indice primario */ + dato = efs->indices->existe_entrada(efs->indices, clave); + block_id = dato.bloque; + reg_id = dato.id; + } else { + reg_id = clave.i_clave; + block_id = emufs_idx_buscar_registro(efs, reg_id); + } if (block_id == EMUFS_NOT_FOUND) { PERR("Registro no encontrado"); *err = EMUFS_NOT_FOUND; @@ -240,10 +250,12 @@ void* emufs_tipo1_leer_bloque(EMUFS* efs, EMUFS_BLOCK_ID block_id, int* err) if (block == NULL) { PERR("No hay memoria"); *err = EMUFS_ERROR_OUT_OF_MEMORY; + fclose(file); return NULL; } if (fread(block, efs->tam_bloque, 1, file) != 1) { free(block); + fclose(file); PERR("Error al leer bloque"); *err = EMUFS_ERROR_FILE_READ; return NULL; @@ -266,6 +278,7 @@ EMUFS_REG_ID emufs_tipo1_grabar_registro(EMUFS* efs, void* reg, EMUFS_BLOCK_ID curr_block_id; /* tamaño de la porción de registro que se guarda */ EMUFS_REG_SIZE chunk_size = 0; + INDICE_DATO idx_data; /* obtengo identificador que corresponderá al registro */ header.id = emufs_idx_get_new_id(efs, err); @@ -346,23 +359,38 @@ EMUFS_REG_ID emufs_tipo1_grabar_registro(EMUFS* efs, void* reg, PERR("No se pudo agregar idx"); return EMUFS_NOT_FOUND; } + idx_data.id = header.id; + idx_data.bloque = block_id; + emufs_indice_agregar(efs->indices, reg, idx_data); return header.id; } -int emufs_tipo1_borrar_registro(EMUFS* efs, EMUFS_REG_ID reg_id) +int emufs_tipo1_borrar_registro(EMUFS* efs, CLAVE k) { char* block; /* bloque leido (en donde está el registro a leer) */ EMUFS_BLOCK_ID block_id; /* id del bloque en donde esta el registro a leer */ EMUFS_BLOCK_SIZE offset; /* offset del bloque leído */ EMUFS_TIPO1_REG_HEADER curr_reg_header; /* cabecera del registro a leer */ + EMUFS_REG_ID reg_id; + INDICE_DATO dato; int err = 0; /* para almacenar código de error */ - block_id = emufs_idx_buscar_registro(efs, reg_id); - if (block_id == EMUFS_NOT_FOUND) { - PERR("Registro no encontrado"); - return EMUFS_NOT_FOUND; + if (efs->indices != NULL) { + dato = efs->indices->existe_entrada(efs->indices, k); + block_id = dato.bloque; /*emufs_idx_buscar_registro(emu, ID);*/ + reg_id = dato.id; + } else { + reg_id = k.i_clave; + block_id = emufs_idx_buscar_registro(efs, reg_id); + if (block_id == EMUFS_NOT_FOUND) { + PERR("Registro no encontrado"); + return EMUFS_NOT_FOUND; + } } + + if (reg_id == -1) return EMUFS_NOT_FOUND; + if (!(block = (char*) emufs_tipo1_leer_bloque(efs, block_id, &err))) { PERR("no se pudo reservar memoria"); return err; @@ -379,12 +407,14 @@ int emufs_tipo1_borrar_registro(EMUFS* efs, EMUFS_REG_ID reg_id) /* tamaño máximo ultilizable para datos en un bloque */ EMUFS_BLOCK_SIZE block_space = efs->tam_bloque - sizeof(EMUFS_TIPO1_REG_HEADER); - EMUFS_FREE fs; /* cantidad de espacio libre en el bloque */ + /* cantidad de espacio libre original del ultimo bloque */ + EMUFS_FREE orig_fs; while (1) { + EMUFS_FREE fs; /* cantidad de espacio libre en el bloque */ + orig_fs = emufs_fsc_get_fs(efs, curr_block_id); /* actualizo archivo de espacio libre por bloque */ - fs = emufs_fsc_get_fs(efs, curr_block_id) - + MIN(curr_reg_header.size, block_space) + fs = orig_fs + MIN(curr_reg_header.size, block_space) + sizeof(EMUFS_TIPO1_REG_HEADER); if ((err = emufs_fsc_actualizar(efs, curr_block_id, fs))) { PERR("no se pudo actualizar .fsc"); @@ -428,11 +458,14 @@ int emufs_tipo1_borrar_registro(EMUFS* efs, EMUFS_REG_ID reg_id) /* si es necesario desplazar */ if (offset < offset_reg_end) { /* muevo la porción de bloque a izquierda */ + /* XXX Este memcpy() puede copiar regiones de memoria que + * se superponen, si copia de principio a fin y byte a byte + * no debería haber problema */ memcpy(block + offset, block + offset_reg_end, efs->tam_bloque - offset_reg_end); /* rellena el espacio libre con ceros para la GUI */ - /* FIXME memset(block + offset_reg_end, 0, - efs->tam_bloque - offset_reg_end);*/ + memset(block + efs->tam_bloque - offset_reg_end - orig_fs + offset, + 0, offset_reg_end + orig_fs - offset); } } /* guardo el bloque en disco (actualizando espacio libre) */ @@ -510,6 +543,7 @@ EMUFS_Estadisticas emufs_tipo1_leer_estadisticas(EMUFS* efs) void emufs_tipo1_compactar(EMUFS* efs) { +#ifdef ARREGLAR EMUFS_BLOCK_SIZE block_space /* tamaño para datos de un bloque */ = efs->tam_bloque - sizeof(EMUFS_TIPO1_REG_HEADER); EMUFS_REG_ID total_ids; /* cantidad total de registros en el array */ @@ -573,6 +607,7 @@ void emufs_tipo1_compactar(EMUFS* efs) emufs_fsc_truncate(efs, block_id); } } +#endif } EMUFS_BLOCK_ID emufs_tipo1_grabar_bloque_fsc(EMUFS *efs, void *block, @@ -659,10 +694,10 @@ EMUFS_BLOCK_ID emufs_tipo1_grabar_bloque_fsc(EMUFS *efs, void *block, return block_id; } -EMUFS_REG_ID emufs_tipo1_modificar_registro(EMUFS* efs, EMUFS_REG_ID id, +EMUFS_REG_ID emufs_tipo1_modificar_registro(EMUFS* efs, CLAVE k, void *data, EMUFS_REG_SIZE size, int* err) { - emufs_tipo1_borrar_registro(efs, id); + emufs_tipo1_borrar_registro(efs, k); return emufs_tipo1_grabar_registro(efs, data, size, err); }