X-Git-Url: https://git.llucax.com/z.facultad/75.06/emufs.git/blobdiff_plain/9be3cef1df309cc384c37af980d379d465ab25e9..8567a7085f7e311712244a69a1d1a45737a9ae32:/emufs/tipo3.c diff --git a/emufs/tipo3.c b/emufs/tipo3.c index a1d0f19..10d6f33 100644 --- a/emufs/tipo3.c +++ b/emufs/tipo3.c @@ -42,23 +42,32 @@ #include #include -/** Leo un registro del archivo, devuelve cero si no lo encuentra.**/ -void* emufs_tipo3_leer_registro(EMUFS *emu, EMUFS_REG_ID ID, +/** Leo un registro del archivo, devuelve NULL si no lo encuentra.**/ +void* emufs_tipo3_leer_registro(EMUFS *emu, CLAVE clave, EMUFS_REG_SIZE* reg_size, int* err) { + INDICE_DATO dato; char* bloque; char* registro; /* registro a leer */ EMUFS_BLOCK_ID block; - EMUFS_REG_ID ID_aux; + EMUFS_REG_ID ID_aux, ID; EMUFS_BLOCK_SIZE iterador = 0; int cant_bloques = 0, resto, i, copiado=0; - + cant_bloques = (emu->tam_reg / (emu->tam_bloque-sizeof(EMUFS_REG_ID))) + 1; if ( emu->tam_reg+sizeof(EMUFS_REG_ID) == emu->tam_bloque ) cant_bloques = 1; /*si existe, lo busco en el archivo de bloques*/ - block = emufs_idx_buscar_registro(emu,ID); /*me devuelve el nro de bloque al que pertenece el registro*/ + if (emu->indices != NULL) { + /* TODO : Verificar donde esta el indice primario */ + dato = emu->indices->existe_entrada(emu->indices, clave); + block = dato.bloque; + ID = dato.id; + } else { + /* TODO ID de donde lo puedo sacar :-) , lo cargo en CLAVE ? */ + block = emufs_idx_buscar_registro(emu,ID); /*me devuelve el nro de bloque al que pertenece el registro*/ + } if ( block == EMUFS_NOT_FOUND ){ PERR("No se encontro el bloque"); *err = -1; @@ -149,6 +158,7 @@ void* emufs_tipo3_leer_bloque(EMUFS *emu, EMUFS_BLOCK_ID ID, int* err) EMUFS_REG_ID emufs_tipo3_grabar_registro(EMUFS *emu, void *ptr, EMUFS_REG_SIZE tam, int* err) { + INDICE_DATO idx_data; EMUFS_REG_ID ID_aux; EMUFS_FREE fs, new_fs; EMUFS_BLOCK_ID num_bloque; @@ -156,7 +166,7 @@ EMUFS_REG_ID emufs_tipo3_grabar_registro(EMUFS *emu, void *ptr, EMUFS_REG_SIZE t FILE *file; char name_f[255]; char* bloque = NULL; - int cant_bloques, resto, i=0, lugar; + int cant_bloques, resto, i=0; strcpy(name_f,emu->nombre); strcat(name_f,".dat"); @@ -213,6 +223,9 @@ EMUFS_REG_ID emufs_tipo3_grabar_registro(EMUFS *emu, void *ptr, EMUFS_REG_SIZE t free(bloque); return -1; } + idx_data.id = ID_aux; + idx_data.bloque = num_bloque; + emufs_indice_agregar(emu->indices, ptr, idx_data); } /* grabo el nuevo registro en el archivo de espacios libres */ @@ -289,6 +302,9 @@ EMUFS_REG_ID emufs_tipo3_grabar_registro(EMUFS *emu, void *ptr, EMUFS_REG_SIZE t if (bloque) free(bloque); return -1; } + idx_data.id = ID_aux; + idx_data.bloque = num_bloque; + emufs_indice_agregar(emu->indices, ptr, idx_data); } } } @@ -316,13 +332,14 @@ int emufs_tipo3_grabar_bloque(EMUFS *emu, void *ptr, EMUFS_BLOCK_ID num) } /*borra un registro de un bloque y acomoda los registros que quedan*/ -int emufs_tipo3_borrar_registro(EMUFS *emu, EMUFS_REG_ID ID) +int emufs_tipo3_borrar_registro(EMUFS *emu, CLAVE k) { EMUFS_BLOCK_SIZE num_bloque; EMUFS_BLOCK_SIZE ptr_elim; EMUFS_BLOCK_SIZE ptr_mov; - EMUFS_REG_ID ID_aux; - EMUFS_FREE fs, new_fs; + EMUFS_REG_ID ID_aux, ID; + EMUFS_FREE fs; + INDICE_DATO dato; char *bloque; int err = 0, i, cant_bloques; @@ -330,14 +347,21 @@ int emufs_tipo3_borrar_registro(EMUFS *emu, EMUFS_REG_ID ID) cant_bloques = emu->tam_reg/(emu->tam_bloque-sizeof(EMUFS_REG_ID))+1; if ( emu->tam_reg+sizeof(EMUFS_REG_ID) == emu->tam_bloque ) cant_bloques = 1; - - num_bloque = emufs_idx_buscar_registro(emu, ID); + + PERR("Buscando datos del registro en el indice"); + dato = emu->indices->existe_entrada(emu->indices, k); + num_bloque = dato.bloque; /*emufs_idx_buscar_registro(emu, ID);*/ + ID = dato.id; + if (!(bloque = emufs_tipo3_leer_bloque(emu, num_bloque, &err))) { /* TODO Manejo de errores */ PERR("no se pudo leer el bloque"); return -1; } + PERR("Borrando clave"); + /* TODO Borrar en todos los indices!! */ + emu->indices->borrar_entrada(emu->indices, k); /*apunto al registro que voy a eliminar*/ ptr_elim = 0; while ( ptr_elim < emu->tam_bloque ){ @@ -450,7 +474,7 @@ EMUFS_Estadisticas emufs_tipo3_leer_estadisticas(EMUFS *emu) EMUFS_REG_ID emufs_tipo3_modificar_registro(EMUFS *emu, EMUFS_REG_ID id, void *data, EMUFS_REG_SIZE size, int *error) { - emufs_tipo3_borrar_registro(emu, id); + /*emufs_tipo3_borrar_registro(emu, id);*/ return emufs_tipo3_grabar_registro(emu, data, size, error); } @@ -494,6 +518,8 @@ void* emufs_tipo3_leer_registro_raw(EMUFS *emu, EMUFS_REG_ID ID, EMUFS_REG_SIZE void emufs_tipo3_compactar(EMUFS *emu) { +/* TODO ARREGLAR */ +#ifdef PEPITO_EL_GALAN EMUFS_REG_ID *tmp, max_id; EMUFS_BLOCK_ID block_id; EMUFS_REG_SIZE size; @@ -528,6 +554,7 @@ void emufs_tipo3_compactar(EMUFS *emu) if(emu->tam_bloque-sizeof(EMUFS_REG_ID) < emu->tam_reg) block_id = block_id/2; if (emufs_fsc_truncate(emu, block_id)!= 0) PERR("NO TURNQUE EL FSC"); +#endif } void emufs_tipo3_leer_bloque_raw(EMUFS *efs, EMUFS_BLOCK_ID id, char **actual, char **anterior, char **siguiente, @@ -547,3 +574,36 @@ void emufs_tipo3_leer_bloque_raw(EMUFS *efs, EMUFS_BLOCK_ID id, char **actual, c } (*size1) = (*size2) = (*size3) = efs->tam_bloque; } + +CLAVE obtener_clave(void *ptr, INDICE indice) +{ + CLAVE clave; + + switch ( indice->tipo_dato ){ + case IDX_FLOAT: + memcpy(&clave, ptr+indice->offset, sizeof(float)); + break; + case IDX_INT: + memcpy(&clave, ptr+indice->offset, sizeof(int)); + } + return clave; +} + +int emufs_tipo3_insertar_ordenado(EMUFS *emu, void *ptr, CLAVE clave, int offset, EMUFS_BLOCK_ID num_bloque, int *err) +{ + /*FILE *f; + char f_name[255];*/ + char *bloque; + CLAVE clave_ant; + + + bloque = emufs_tipo3_leer_bloque(emu, num_bloque, err); + if (err){ + PERR("NO SE PUDO LEER EL BLQUE"); + return -1; + } + + + + return 0; +}