X-Git-Url: https://git.llucax.com/z.facultad/75.06/emufs.git/blobdiff_plain/74c6776ce0ae5ea218cf0363af040bf260b2c72b..e5f006cdf069c341253488880979653d7826af7f:/emufs/tipo1.c diff --git a/emufs/tipo1.c b/emufs/tipo1.c index fb21da5..313cf5c 100644 --- a/emufs/tipo1.c +++ b/emufs/tipo1.c @@ -98,6 +98,7 @@ int emufs_tipo1_inicializar(EMUFS* efs) efs->leer_registro_raw = emufs_tipo1_leer_registro_raw; efs->leer_estadisticas = emufs_tipo1_leer_estadisticas; efs->compactar = emufs_tipo1_compactar; + efs->modificar_registro = emufs_tipo1_modificar_registro; efs->tam_reg = 0; return EMUFS_OK; } @@ -120,6 +121,8 @@ int emufs_tipo4_inicializar(EMUFS* efs) efs->leer_registro_raw = emufs_tipo1_leer_registro_raw; efs->leer_estadisticas = emufs_tipo1_leer_estadisticas; efs->compactar = emufs_tipo1_compactar; + efs->modificar_registro= emufs_tipo1_modificar_registro_plus; + efs->obtener_claver_raw= emufs_tipo1_obtener_claves_raw; efs->tam_reg = 0; return EMUFS_OK; } @@ -135,7 +138,7 @@ void* emufs_tipo1_leer_registro(EMUFS* efs, CLAVE clave, EMUFS_TIPO1_REG_HEADER curr_reg_header; /* cabecera del registro a leer */ INDICE_DATO dato; - if (efs->indices != NULL) { + if ((efs->indices != NULL) && (*err != 1)) { /* TODO : Verificar donde esta el indice primario */ dato = efs->indices->existe_entrada(efs->indices, clave); block_id = dato.bloque; @@ -143,6 +146,7 @@ void* emufs_tipo1_leer_registro(EMUFS* efs, CLAVE clave, } else { reg_id = clave.i_clave; block_id = emufs_idx_buscar_registro(efs, reg_id); + if (*err == 1) *err = 0; /*hack!*/ } if (block_id == EMUFS_NOT_FOUND) { PERR("Registro no encontrado"); @@ -207,6 +211,7 @@ void* emufs_tipo1_leer_registro(EMUFS* efs, CLAVE clave, } while (offset < efs->tam_bloque); /* registro está en el bloque */ free(block); + PERR("REGISTRO LEIDO; RETORNANDO"); return registro; } @@ -720,7 +725,9 @@ EMUFS_BLOCK_ID emufs_tipo1_grabar_bloque_fsc(EMUFS *efs, void *block, EMUFS_REG_ID emufs_tipo1_modificar_registro(EMUFS* efs, CLAVE k, void *data, EMUFS_REG_SIZE size, int* err, INDICE_DATO dato) { + PERR("Tipo1 Modificar Borrando"); emufs_tipo1_borrar_registro(efs, k, dato); + PERR("Tipo1 Modificar Agregando de nuevo"); return emufs_tipo1_grabar_registro(efs, data, size, err); } @@ -992,7 +999,7 @@ int emufs_tipo1_eliminar_ordenado(EMUFS *emu, CLAVE clave, INDICE_DATO dato) { char *bloque, *aux; INDEX_DAT query; - int result, iter, cant_reg, leidos; + int result, iter, cant_reg; EMUFS_REG_SIZE tam_reg; CLAVE clave_ajena, ancla; int err = 0; @@ -1123,3 +1130,43 @@ EMUFS_REG_ID emufs_tipo1_modificar_registro_plus(EMUFS *emu, CLAVE k, void *ptr emufs_tipo1_eliminar_ordenado(emu, k, dato); return emufs_tipo1_insertar_ordenado(emu, ptr, size, err); } + +B_PLUS_KEYBUCKET *emufs_tipo1_obtener_claves_raw(EMUFS *emu, int num_bloque) +{ + B_PLUS_KEYBUCKET *keys; + char *bloque, *aux;; + int err = 0, cant_reg, i; + EMUFS_REG_SIZE tam_reg; + + keys = (B_PLUS_KEYBUCKET*)malloc(sizeof(B_PLUS_KEYBUCKET)); + if (keys == NULL){ + PERR("NO SE PUDO CREAR EL BUCKET"); + return NULL; + } + /*leo el bloque*/ + bloque = emufs_tipo1_leer_bloque(emu, num_bloque, &err); + if ( bloque == NULL ){ + PERR("NO SE PUDO LEER EL BLOQUE"); + return NULL; + } + aux = bloque; + /*leo la cantidad de registros*/ + memcpy(&cant_reg, bloque+emu->tam_bloque-sizeof(int), sizeof(int)); + /*ya se cuanto guardarle al vector*/ + keys->claves = (CLAVE*)malloc(cant_reg*sizeof(CLAVE)); + if (keys->claves == NULL){ + PERR("NO SE PUDO CREAR EL ARRAY DE CLAVES"); + free(bloque); + free(keys); + return NULL; + } + keys->cant_keys = cant_reg; + keys->current_key = 0; + for (i=0; iclaves[i] = emufs_indice_generar_clave(emu->indices, bloque+sizeof(EMUFS_TIPO1_REG_HEADER)); + bloque += tam_reg+sizeof(EMUFS_TIPO1_REG_HEADER); + } + free(aux); + return keys; +}