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;
}
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;
}
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;
} 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");
} while (offset < efs->tam_bloque); /* registro está en el bloque */
free(block);
+ PERR("REGISTRO LEIDO; RETORNANDO");
return registro;
}
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);
}
{
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;
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; i<cant_reg; i++){
+ memcpy(&tam_reg, bloque+sizeof(EMUFS_REG_ID), sizeof(EMUFS_REG_SIZE));
+ keys->claves[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;
+}