X-Git-Url: https://git.llucax.com/z.facultad/75.06/emufs.git/blobdiff_plain/32feb1e82b00d6c1ad3f5aa6884d003a665ea975..eb9e911d67728e6729bff9ea6d05ac3a9c6c8d00:/emufs/tipo1.c diff --git a/emufs/tipo1.c b/emufs/tipo1.c index 8cd7e2c..4c68ce4 100644 --- a/emufs/tipo1.c +++ b/emufs/tipo1.c @@ -44,26 +44,33 @@ #include #include -/*------------------ Funciones privadas ----------------------*/ +/*------------------ Declaraciones privadas ----------------------*/ -int emufs_tipo1_header_jump(FILE*); +/** Cabecera de un registro de un archivo tipo1. */ +typedef struct { + EMUFS_REG_ID id; /**< Identificador del registro. */ + EMUFS_REG_SIZE size; /**< Tamaño del registro. */ +} EMUFS_TIPO1_REG_HEADER; -size_t emufs_tipo1_header_size(void); +static size_t emufs_tipo1_header_size(void); -int emufs_tipo1_block_jump(EMUFS*, FILE*, EMUFS_BLOCK_ID); +static int emufs_tipo1_header_jump(FILE*); -void emufs_tipo1_escribir_reg_en_memoria(char* dst, EMUFS_REG_ID reg_id, - EMUFS_REG_SIZE reg_size, char* reg); +static int emufs_tipo1_block_jump(EMUFS*, FILE*, EMUFS_BLOCK_ID); + +static void emufs_tipo1_escribir_reg_en_memoria(char*, EMUFS_TIPO1_REG_HEADER, + char*); /*------------------ Funciones públicas ----------------------*/ int emufs_tipo1_inicializar(EMUFS* efs) { /* Asigna punteros a funciones. */ - 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->leer_bloque = emufs_tipo1_leer_bloque; + efs->grabar_registro = emufs_tipo1_grabar_registro; + efs->borrar_registro = emufs_tipo1_borrar_registro; + efs->leer_registro = emufs_tipo1_leer_registro; + efs->leer_registro_raw = emufs_tipo1_leer_registro_raw; return 0; } @@ -75,8 +82,7 @@ void* emufs_tipo1_leer_registro(EMUFS* efs, EMUFS_REG_ID reg_id, 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 */ + EMUFS_TIPO1_REG_HEADER curr_reg_header; /* cabecera del registro a leer */ block_id = emufs_idx_buscar_registro(efs, reg_id); if (block_id == EMUFS_NOT_FOUND) { @@ -94,14 +100,11 @@ void* emufs_tipo1_leer_registro(EMUFS* efs, EMUFS_REG_ID reg_id, /* 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 == reg_id) { - registro = (char*) malloc(curr_reg_size); + /* Copio la cabecera del registro actual. */ + memcpy(&curr_reg_header, block + offset, sizeof(EMUFS_TIPO1_REG_HEADER)); + offset += sizeof(EMUFS_TIPO1_REG_HEADER); + if (curr_reg_header.id == reg_id) { + registro = (char*) malloc(curr_reg_header.size); if (registro == NULL) { /* TODO Manejo de errores */ free(block); @@ -109,12 +112,12 @@ void* emufs_tipo1_leer_registro(EMUFS* efs, EMUFS_REG_ID reg_id, *err = 2; /* EMUFS_ERROR_OUT_OF_MEMORY */ return NULL; } - memcpy(registro, block + offset, curr_reg_size); - *reg_size = curr_reg_size; + memcpy(registro, block + offset, curr_reg_header.size); + *reg_size = curr_reg_header.size; break; } /* Desplazo el offset */ - offset += curr_reg_size; + offset += curr_reg_header.size; } while (offset < block_size); free(block); @@ -159,17 +162,20 @@ void* emufs_tipo1_leer_bloque(EMUFS* efs, EMUFS_BLOCK_ID block_id, int *err) EMUFS_REG_ID emufs_tipo1_grabar_registro(EMUFS* efs, void* reg, EMUFS_REG_SIZE reg_size, int* err) { - EMUFS_REG_ID reg_id; - EMUFS_FREE fs; - EMUFS_BLOCK_ID block_id; - char name_f[255]; - char* block; - - strcpy(name_f,efs->nombre); - strcat(name_f,".dat"); - + EMUFS_TIPO1_REG_HEADER reg_header; + EMUFS_FREE fs; + EMUFS_BLOCK_ID block_id; + char name_f[255]; + char* block; + + strcpy(name_f, efs->nombre); + strcat(name_f, ".dat"); + + /* pongo tamaño del registro en la cabecera. */ + reg_header.size = reg_size; /* 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_TIPO1_REG_HEADER), &fs); /* si no hay bloques con suficiente espacio creo un bloque nuevo */ if (block_id == EMUFS_NOT_FOUND) { /* crear un nuevo bloque en memoria */ @@ -180,10 +186,11 @@ EMUFS_REG_ID emufs_tipo1_grabar_registro(EMUFS* efs, void* reg, *err = 2; /* EMUFS_ERROR_OUT_OF_MEMORY */ return EMUFS_NOT_FOUND; } - /* graba el registro al principio del bloque */ - reg_id = emufs_idx_get_new_id(efs, err); + memset(block, 0, efs->tam_bloque); /* inicializa bloque */ + reg_header.id = emufs_idx_get_new_id(efs, err); /* graba registro en bloque */ - emufs_tipo1_escribir_reg_en_memoria(block, reg_id, reg_size, reg); + /* TODO if (reg_size > efs->tam_bloque) */ + emufs_tipo1_escribir_reg_en_memoria(block, reg_header, reg); /* graba el bloque en el archivo */ block_id = emufs_tipo1_grabar_bloque(efs, block, block_id, err); if (*err) { @@ -194,7 +201,7 @@ EMUFS_REG_ID emufs_tipo1_grabar_registro(EMUFS* efs, void* reg, free(block); /* grabo el nuevo registro en el archivo de espacios libres */ *err = emufs_fsc_agregar(efs, block_id, efs->tam_bloque - reg_size - - sizeof(EMUFS_REG_ID) - sizeof(EMUFS_REG_SIZE)); + - sizeof(EMUFS_TIPO1_REG_HEADER)); if (*err) { PERR("No se pudo agregar fsc"); return EMUFS_NOT_FOUND; @@ -210,10 +217,10 @@ 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_idx_get_new_id(efs, err); + reg_header.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); + reg_header, reg); /* graba el bloque en el archivo */ block_id = emufs_tipo1_grabar_bloque(efs, block, block_id, err); if (*err) { @@ -224,7 +231,7 @@ EMUFS_REG_ID emufs_tipo1_grabar_registro(EMUFS* efs, void* reg, free(block); /* actualizo el archivo de espacios libres */ *err = emufs_fsc_actualizar(efs, block_id, fs - reg_size - - sizeof(EMUFS_REG_ID) - sizeof(EMUFS_REG_SIZE)); + - sizeof(EMUFS_TIPO1_REG_HEADER)); if (*err) { PERR("No se pudo actualizar fsc"); return EMUFS_NOT_FOUND; @@ -232,13 +239,13 @@ 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_header.id, block_id); if (*err){ PERR("No se pudo agregar idx"); return EMUFS_NOT_FOUND; } - return reg_id; + return reg_header.id; } /*Graba un bloque en el archivo*/ @@ -302,15 +309,19 @@ 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 */ } +size_t emufs_tipo1_header_size(void) +{ + return sizeof(EMUFS_Tipo) + sizeof(EMUFS_BLOCK_SIZE); +} + 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 */ } @@ -326,22 +337,56 @@ int emufs_tipo1_block_jump(EMUFS* efs, FILE* fp, EMUFS_BLOCK_ID block_count) return 0; /* EMUFS_OK */ } -size_t emufs_tipo1_header_size(void) +void emufs_tipo1_escribir_reg_en_memoria(char* dst, EMUFS_TIPO1_REG_HEADER header, + char* reg) { + /* grabo cabecera del registro en el bloque */ + memcpy(dst, &header, sizeof(EMUFS_TIPO1_REG_HEADER)); + /* incremento puntero de escritura */ + dst += sizeof(EMUFS_TIPO1_REG_HEADER); + /* grabo el registro en el bloque */ + memcpy(dst, reg, header.size); +} + +EMUFS_REG_ID emufs_tipo1_modificar_registro(EMUFS *emu, EMUFS_REG_ID id, + void *data, EMUFS_REG_SIZE size, int *error) { - return sizeof(EMUFS_TYPE) + /* Cabecera de tipo de archivo */ - sizeof(EMUFS_BLOCK_SIZE); /* Cabecera de tamaño del bloque */ + emufs_tipo1_borrar_registro(emu, id); + return emufs_tipo1_grabar_registro(emu, data, size, error); } -void emufs_tipo1_escribir_reg_en_memoria(char* dst, EMUFS_REG_ID reg_id, - EMUFS_REG_SIZE reg_size, char* reg) { - /* grabo el id en el bloque */ - memcpy(dst, ®_id, sizeof(EMUFS_REG_ID)); - /* incremento puntero de escritura */ - dst += sizeof(EMUFS_REG_ID); - /* grabo el tamaño del registro en el bloque */ - memcpy(dst, ®_size, sizeof(EMUFS_REG_SIZE)); - /* incremento puntero de escritura */ - dst += sizeof(EMUFS_REG_SIZE); - /* grabo el registro en el bloque */ - memcpy(dst, reg, reg_size); +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_TIPO1_REG_HEADER curr_reg_header; /* cabecera del registro a leer */ + 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 la cabecera del registro. */ + memcpy(&curr_reg_header, block + offset, sizeof(EMUFS_TIPO1_REG_HEADER)); + offset += sizeof(EMUFS_TIPO1_REG_HEADER); + if (curr_reg_header.id == id) { + *pos = offset - sizeof(EMUFS_TIPO1_REG_HEADER); + break; + } + /* Desplazo el offset */ + offset += curr_reg_header.size; + } while (offset < block_size); + + (*size) = block_size; + return block; } +