X-Git-Url: https://git.llucax.com/z.facultad/75.06/emufs.git/blobdiff_plain/cfcbab8ec369453b7809f2d2954b15d1bb5fcfdd..3fedb806fdecbcb4508773321011e96ab27903e9:/emufs/tipo1.c diff --git a/emufs/tipo1.c b/emufs/tipo1.c index a75967e..769d7b2 100644 --- a/emufs/tipo1.c +++ b/emufs/tipo1.c @@ -44,8 +44,6 @@ #include #include -#define PERR(msg) printf("%s:%d> %s.\n",__FILE__, __LINE__, msg); - /*------------------ Funciones privadas ----------------------*/ int emufs_tipo1_header_jump(FILE*); @@ -65,7 +63,8 @@ int emufs_tipo1_inicializar(EMUFS* efs) efs->leer_bloque = emufs_tipo1_leer_bloque; efs->leer_registro = emufs_tipo1_leer_registro; efs->grabar_registro = emufs_tipo1_grabar_registro; - /*efs->borrar_registro = emufs_tipo1_borrar_registro;*/ + efs->borrar_registro = emufs_tipo1_borrar_registro; + efs->leer_registro_raw = emufs_tipo1_leer_registro_raw; return 0; } @@ -167,15 +166,17 @@ EMUFS_REG_ID emufs_tipo1_grabar_registro(EMUFS* efs, void* reg, char name_f[255]; char* block; - strcpy(name_f,efs->nombre); - strcat(name_f,".dat"); + strcpy(name_f, efs->nombre); + strcat(name_f, ".dat"); /* me devuelve el ID del bloque donde quepa un registro y el espacio libre en "fs"*/ - block_id = emufs_fsc_buscar_lugar(efs, reg_size, &fs); + block_id = emufs_fsc_buscar_lugar(efs, reg_size + sizeof(EMUFS_REG_ID) + + sizeof(EMUFS_REG_SIZE), &fs); /* si no hay bloques con suficiente espacio creo un bloque nuevo */ if (block_id == EMUFS_NOT_FOUND) { /* crear un nuevo bloque en memoria */ block = (char*) malloc(efs->tam_bloque); + memset(block, 0, efs->tam_bloque); if (block == NULL) { /* TODO Manejo de errores */ PERR("No hay memoria"); @@ -183,7 +184,7 @@ EMUFS_REG_ID emufs_tipo1_grabar_registro(EMUFS* efs, void* reg, return EMUFS_NOT_FOUND; } /* graba el registro al principio del bloque */ - reg_id = emufs_tipo1_get_id(efs); + reg_id = emufs_idx_get_new_id(efs, err); /* graba registro en bloque */ emufs_tipo1_escribir_reg_en_memoria(block, reg_id, reg_size, reg); /* graba el bloque en el archivo */ @@ -212,7 +213,7 @@ EMUFS_REG_ID emufs_tipo1_grabar_registro(EMUFS* efs, void* reg, } /* inserta el registro en el bloque */ /* tengo que buscar un ID válido para el nuevo registro */ - reg_id = emufs_tipo1_get_id(efs); + reg_id = emufs_idx_get_new_id(efs, err); /* graba registro en bloque */ emufs_tipo1_escribir_reg_en_memoria(block + efs->tam_bloque - fs, reg_id, reg_size, reg); @@ -234,7 +235,7 @@ EMUFS_REG_ID emufs_tipo1_grabar_registro(EMUFS* efs, void* reg, } /* actualizo el indice de bloques y registros */ - *err = emufs_idx_agregar(efs, block_id, reg_id); + *err = emufs_idx_agregar(efs, reg_id, block_id); if (*err){ PERR("No se pudo agregar idx"); return EMUFS_NOT_FOUND; @@ -298,27 +299,20 @@ EMUFS_BLOCK_ID emufs_tipo1_grabar_bloque(EMUFS *efs, void *block, return block_id; } -/*Busco en el archivo de Id`s un Id valido para un nuevo registro*/ -EMUFS_REG_ID emufs_tipo1_get_id(EMUFS *emu) -{ - return -1; /* FIXME Error */ -} - /*borra un registro de un bloque y acomoda los registros que quedan*/ int emufs_tipo1_buscar_registro(EMUFS *emu, EMUFS_REG_ID id_reg) { return -1; /* FIXME Error */ } -int emufs_tipo1_borrar_registro(EMUFS *emu, EMUFS_REG_ID id_reg, - EMUFS_REG_SIZE tam_reg) +int emufs_tipo1_borrar_registro(EMUFS *emu, EMUFS_REG_ID id_reg) { return -1; /* FIXME Error */ } int emufs_tipo1_header_jump(FILE* fp) { - if (fseek(fp, 0l, SEEK_END)) { + if (fseek(fp, emufs_tipo1_header_size(), SEEK_CUR)) { PERR("No se pudo hacer fseek()"); return 8; /* EMUFS_ERROR_SEEK_FILE */ } @@ -336,7 +330,7 @@ int emufs_tipo1_block_jump(EMUFS* efs, FILE* fp, EMUFS_BLOCK_ID block_count) size_t emufs_tipo1_header_size(void) { - return sizeof(EMUFS_TYPE) + /* Cabecera de tipo de archivo */ + return sizeof(EMUFS_Tipo) + /* Cabecera de tipo de archivo */ sizeof(EMUFS_BLOCK_SIZE); /* Cabecera de tamaño del bloque */ } @@ -353,3 +347,49 @@ void emufs_tipo1_escribir_reg_en_memoria(char* dst, EMUFS_REG_ID reg_id, /* grabo el registro en el bloque */ memcpy(dst, reg, reg_size); } + +EMUFS_REG_ID emufs_tipo1_modificar_registro(EMUFS *emu, EMUFS_REG_ID id, void *data, EMUFS_REG_SIZE size, int *error) +{ + emufs_tipo1_borrar_registro(emu, id); + return emufs_tipo1_grabar_registro(emu, data, size, error); +} + +void* emufs_tipo1_leer_registro_raw(EMUFS *efs, EMUFS_REG_ID id, EMUFS_REG_SIZE *size, int *pos) +{ + 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_BLOCK_SIZE block_size; /* tamaño del bloque leído */ + EMUFS_REG_SIZE curr_reg_size; /* tamaño del registro leído secuencialmente */ + EMUFS_REG_ID curr_reg_id; /* id del registro leído secuencialmente */ + int err; + + block_id = emufs_idx_buscar_registro(efs, id); + if (block_id == EMUFS_NOT_FOUND) { + return NULL; + } + if (!(block = (char*) emufs_tipo1_leer_bloque(efs, block_id, &err))) { + return NULL; + } + + /* Busco secuencialmente en el bloque el registro a leer */ + offset = 0; + do { + /* Copio el id del registro de la cabecera. */ + memcpy(&curr_reg_id, block + offset, sizeof(EMUFS_REG_ID)); + offset += sizeof(EMUFS_REG_ID); + /* Copio el tamaño del registro de la cabecera. */ + memcpy(&curr_reg_size, block + offset, sizeof(EMUFS_REG_SIZE)); + offset += sizeof(EMUFS_REG_SIZE); + if (curr_reg_id == id) { + *pos = offset-sizeof(EMUFS_REG_ID)-sizeof(EMUFS_REG_SIZE); + break; + } + /* Desplazo el offset */ + offset += curr_reg_size; + } while (offset < block_size); + + (*size) = efs->tam_bloque; + return block; +} +