X-Git-Url: https://git.llucax.com/z.facultad/75.06/emufs.git/blobdiff_plain/d718803ef7f9e17b2fb893ea9c7c2905a1591cf2..008189ea62c4d3800769f00a304f95cc454102b3:/emufs/emufs.c?ds=inline diff --git a/emufs/emufs.c b/emufs/emufs.c index fc4165d..e789fa7 100644 --- a/emufs/emufs.c +++ b/emufs/emufs.c @@ -99,7 +99,7 @@ EMUFS *emufs_crear(const char *filename, EMUFS_Tipo tipo, EMUFS_BLOCK_SIZE tam_b int err = 0; /* Si no es un tipo conocido, sale. */ - if ((tipo != T1) && (tipo != T2) && (tipo != T3)) { + if ((tipo != T1) && (tipo != T2) && (tipo != T3) && (tipo != T4) && (tipo != T5)) { return NULL; } @@ -191,20 +191,47 @@ EMUFS *emufs_crear(const char *filename, EMUFS_Tipo tipo, EMUFS_BLOCK_SIZE tam_b case T3: /* Asigna punteros a funciones. */ - efs->leer_bloque = emufs_tipo3_leer_bloque; - efs->leer_registro = emufs_tipo3_leer_registro; - efs->leer_registro_raw = emufs_tipo3_leer_registro_raw; - efs->grabar_registro = emufs_tipo3_grabar_registro; - efs->borrar_registro = emufs_tipo3_borrar_registro; - efs->leer_estadisticas = emufs_tipo3_leer_estadisticas; - efs->modificar_registro = emufs_tipo3_modificar_registro; - efs->compactar = emufs_tipo3_compactar; - efs->leer_bloque_raw = emufs_tipo3_leer_bloque_raw; + if ((err = emufs_tipo3_inicializar(efs))) { + /* TODO ERROR */ + PERR("No se pudo inicializar el EMUFS de tipo3"); + fclose(fp); + free(efs->nombre); + free(efs); + return NULL; + } /* Guarda cabeceras propias. */ fwrite(&tam_bloque, sizeof(EMUFS_BLOCK_SIZE), 1, fp); fwrite(&tam_reg, sizeof(EMUFS_REG_SIZE), 1, fp); break; - + + case T4: + /* Asigna punteros a funciones. */ + if ((err = emufs_tipo4_inicializar(efs))) { + /* TODO ERROR */ + PERR("No se pudo inicializar el EMUFS de tipo4"); + fclose(fp); + free(efs->nombre); + free(efs); + return NULL; + } + /* Guarda cabeceras propias. */ + fwrite(&tam_bloque, sizeof(EMUFS_BLOCK_SIZE), 1, fp); + break; + + case T5: + /* Asigna punteros a funciones. */ + if ((err = emufs_tipo5_inicializar(efs))) { + /* TODO ERROR */ + PERR("No se pudo inicializar el EMUFS de tipo5"); + fclose(fp); + free(efs->nombre); + free(efs); + return NULL; + } + /* Guarda cabeceras propias. */ + fwrite(&tam_bloque, sizeof(EMUFS_BLOCK_SIZE), 1, fp); + fwrite(&tam_reg, sizeof(EMUFS_REG_SIZE), 1, fp); + break; } fclose(fp); @@ -272,17 +299,32 @@ EMUFS *emufs_abrir(const char *filename) return NULL; } /* Asigna punteros a funciones. */ - efs->leer_bloque = emufs_tipo3_leer_bloque; - efs->leer_registro_raw = emufs_tipo3_leer_registro_raw; - efs->leer_registro = emufs_tipo3_leer_registro; - efs->grabar_registro = emufs_tipo3_grabar_registro; - efs->borrar_registro = emufs_tipo3_borrar_registro; - efs->leer_estadisticas = emufs_tipo3_leer_estadisticas; - efs->modificar_registro = emufs_tipo3_modificar_registro; - efs->compactar = emufs_tipo3_compactar; - efs->leer_bloque_raw = emufs_tipo3_leer_bloque_raw; + emufs_tipo3_inicializar(efs); break; - } + + case T4: + /* Lee cabeceras propias. */ + if (!fread(&(efs->tam_bloque), sizeof(EMUFS_BLOCK_SIZE), 1, fp)) { + free(efs->nombre); + free(efs); + fclose(fp); + return NULL; + } + emufs_tipo4_inicializar(efs); + break; + + case T5: + if ((!fread(&(efs->tam_bloque), sizeof(EMUFS_BLOCK_SIZE), 1, fp)) || + (!fread(&(efs->tam_reg), sizeof(EMUFS_REG_SIZE), 1, fp))) + { + free(efs->nombre); + free(efs); + fclose(fp); + return NULL; + } + /* Asigna punteros a funciones. */ + emufs_tipo5_inicializar(efs); + } fclose(fp); return efs; @@ -374,7 +416,7 @@ int debug_ver_estadisticas(EMUFS* efs) return 0; } -int emufs_agregar_indice(EMUFS *emu, char *nombre, INDICE_FUNCION funcion, INDICE_TIPO tipo, INDICE_TIPO_DATO tipo_dato, unsigned int offset, unsigned int tam_bloque) +int emufs_agregar_indice(EMUFS *emu, char *nombre, INDICE_FUNCION funcion, INDICE_TIPO tipo, INDICE_TIPO_DATO tipo_dato, unsigned int offset, unsigned int tam_bloque, int str_offset) { INDICE *tmp; int error=0; @@ -383,6 +425,7 @@ int emufs_agregar_indice(EMUFS *emu, char *nombre, INDICE_FUNCION funcion, INDIC /* y que no exista un indice primario */ PERR("Agregando indice"); tmp = emu->indices; + PERR("IGUALE"); while (tmp) { if (strcmp(tmp->nombre, nombre)==0) { error = 1; @@ -408,7 +451,7 @@ int emufs_agregar_indice(EMUFS *emu, char *nombre, INDICE_FUNCION funcion, INDIC /* Creo el nuevo indice */ PERR("Creando indice\n"); - tmp = emufs_indice_crear(emu, nombre, funcion, tipo, tipo_dato, offset, tam_bloque); + tmp = emufs_indice_crear(emu, nombre, funcion, tipo, tipo_dato, offset, tam_bloque, str_offset); /* Guardo la info del indice para poder abrir despues el archivo */ guardar_indice(emu, nombre, funcion, tipo, tipo_dato, offset, tam_bloque); @@ -507,10 +550,6 @@ EMUFS_BLOCK_ID emufs_create_new_block(EMUFS *emu) dummy = (char*)malloc(emu->tam_bloque); memset(dummy, 0, emu->tam_bloque); fwrite(dummy, emu->tam_bloque, 1, fp); -<<<<<<< .mine - fprintf(stderr, "new_block ftell = %ld\n", ftell(fp)); -======= ->>>>>>> .r552 switch(emu->tipo){ case T1: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE))/emu->tam_bloque; break; @@ -518,7 +557,7 @@ EMUFS_BLOCK_ID emufs_create_new_block(EMUFS *emu) } fclose(fp); free(dummy); - return num; + return num-1; } /*devuelve un numero de bloque siguiente al ultimo*/ @@ -542,7 +581,6 @@ EMUFS_BLOCK_ID emufs_get_new_block_number(EMUFS *emu) switch(emu->tipo){ case T1: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE))/emu->tam_bloque; if (ftell(fp) == sizeof(EMUFS_Tipo)+sizeof(EMUFS_BLOCK_SIZE)) num = 0; - PERR("PASE"); break; case T3: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE)-sizeof(EMUFS_REG_SIZE))/emu->tam_bloque; if (ftell(fp) == sizeof(EMUFS_Tipo)+sizeof(EMUFS_BLOCK_SIZE)+sizeof(EMUFS_REG_SIZE)) num = 0;