X-Git-Url: https://git.llucax.com/z.facultad/75.06/emufs.git/blobdiff_plain/9becab83c083dd57876b1d29ec4bc73cbda912ac..673b6744b98968c1a0fd6856b5a9dcd636c06b7c:/emufs/emufs.c?ds=sidebyside diff --git a/emufs/emufs.c b/emufs/emufs.c index ebd4337..445f278 100644 --- a/emufs/emufs.c +++ b/emufs/emufs.c @@ -39,6 +39,7 @@ */ #include "emufs.h" +#include "common.h" #include "tipo1.h" #include "tipo2.h" #include "tipo3.h" @@ -46,6 +47,17 @@ #include "fsc.h" #include "idx.h" +typedef struct _data_indices_ { + char nombre[50]; + INDICE_FUNCION funcion; + INDICE_TIPO tipo; + INDICE_TIPO_DATO tipo_dato; + unsigned int offset; + unsigned int tam_bloque; +} t_Indice; + +int guardar_indice(EMUFS *emu, char *nombre, INDICE_FUNCION funcion, INDICE_TIPO tipo, INDICE_TIPO_DATO tipo_dato, unsigned int offset, unsigned int tam_bloque); + char *str_dup(const char *s); char *str_dup(const char *s) @@ -81,7 +93,7 @@ int emufs_crear_archivo_auxiliar(const char* name, const char* ext) EMUFS *emufs_crear(const char *filename, EMUFS_Tipo tipo, EMUFS_BLOCK_SIZE tam_bloque, EMUFS_REG_SIZE tam_reg) { - char name[255]; + char name[255], otroname[255]; FILE *fp; EMUFS *efs; int err = 0; @@ -100,6 +112,17 @@ EMUFS *emufs_crear(const char *filename, EMUFS_Tipo tipo, EMUFS_BLOCK_SIZE tam_b efs->tam_bloque = tam_bloque; efs->tam_reg = tam_reg; efs->nombre = str_dup(filename); + efs->indices = NULL; + + sprintf(otroname, "%s.info", efs->nombre); + fp = fopen(otroname, "w"); + if (fp == NULL) { + PERR("CARAJO!, NO PUEDO CREAR INFO"); + } else { + err = 0; + fwrite(&err, 1, sizeof(int), fp); + fclose(fp); + } /* Abre archivo de datos. */ strcpy(name, filename); @@ -118,6 +141,7 @@ EMUFS *emufs_crear(const char *filename, EMUFS_Tipo tipo, EMUFS_BLOCK_SIZE tam_b /* Crea archivo de índice. */ if (emufs_idx_crear(efs)) { /* TODO ERROR */ + fclose(fp); free(efs->nombre); free(efs); return NULL; @@ -126,6 +150,7 @@ EMUFS *emufs_crear(const char *filename, EMUFS_Tipo tipo, EMUFS_BLOCK_SIZE tam_b /* Crea archivo de control de espacio libre. */ if (emufs_fsc_crear(efs)) { /* TODO ERROR */ + fclose(fp); free(efs->nombre); free(efs); return NULL; @@ -134,6 +159,7 @@ EMUFS *emufs_crear(const char *filename, EMUFS_Tipo tipo, EMUFS_BLOCK_SIZE tam_b /* Crea archivo de identificadores borrados (recuperables). */ if (emufs_did_crear(efs)) { /* TODO ERROR */ + fclose(fp); free(efs->nombre); free(efs); return NULL; @@ -145,7 +171,9 @@ EMUFS *emufs_crear(const char *filename, EMUFS_Tipo tipo, EMUFS_BLOCK_SIZE tam_b case T1: /* Asigna punteros a funciones. */ if ((err = emufs_tipo1_inicializar(efs))) { + /* TODO ERROR */ PERR("No se pudo inicializar el EMUFS de tipo1"); + fclose(fp); free(efs->nombre); free(efs); return NULL; @@ -163,19 +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; + 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); @@ -251,6 +307,7 @@ EMUFS *emufs_abrir(const char *filename) 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; break; } @@ -260,7 +317,18 @@ EMUFS *emufs_abrir(const char *filename) int emufs_destruir(EMUFS *e) { + INDICE *del, *cur; + if (e == NULL) return 1; + + /* libero indices */ + cur = e->indices; + while (cur) { + del = cur; + cur = cur->sig; + emufs_indice_destruir(e, cur); + } + free(e->nombre); free(e); return 0; @@ -304,3 +372,215 @@ int ver_archivo_FS(EMUFS *emu) return 0; } + +int debug_ver_estadisticas(EMUFS* efs) +{ + EMUFS_Estadisticas s = efs->leer_estadisticas(efs); + + printf("ESTADISTICAS:\n"); + printf("=============\n"); + printf("Tamaño del archivo: %lu bytes\n", s.tam_archivo); + printf("Tamaño de datos (incluye espacio libre): %lu bytes (%.2f %%)\n", + s.tam_archivo - s.tam_info_control_dat, + (s.tam_archivo - s.tam_info_control_dat) * 100.0 + / (float) s.tam_archivo); + printf("Tamaño de info de control total: %lu bytes (%.2f %%)\n", + s.tam_info_control_dat + s.tam_archivos_aux, + (s.tam_info_control_dat + s.tam_archivos_aux) * 100.0 + / (float) s.tam_archivo); + printf("Tamaño de los archivos auxiliares: %lu bytes\n", + s.tam_archivos_aux); + printf("Tamaño de la información de control en el .dat: %lu bytes\n", + s.tam_info_control_dat); + printf("Total de espacio libre: %lu bytes\n", s.total_fs); + printf("Máximo espacio libre en bloque: %lu bytes\n", s.max_fs); + printf("Mínimo espacio libre en bloque: %lu bytes\n", s.min_fs); + printf("Media del espacio libre por bloque: %lu bytes\n", s.media_fs); + printf("Cantidad de registros: %lu\n", s.cant_registros); + printf("Cantidad de bloques: %lu\n", s.cant_bloques); + 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 str_offset) +{ + INDICE *tmp; + int error=0; + + /* Verifico que no existe un indice con el mismo nombre */ + /* y que no exista un indice primario */ + PERR("Agregando indice"); + tmp = emu->indices; + while (tmp) { + if (strcmp(tmp->nombre, nombre)==0) { + error = 1; + break; + } + if ((funcion == IND_PRIMARIO) && (tmp->funcion == funcion)) { + error = 2; + break; + } + tmp = tmp->sig; + } + + if (tmp != NULL) { + switch (error) { + case 1: + PERR("Ya existe un indice con el mismo nombre!"); + break; + case 2: + PERR("EMUFS ya tiene indice primario!!"); + } + return 0; + } + + /* Creo el nuevo indice */ + PERR("Creando indice\n"); + 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); + + if (tmp == NULL) { + PERR("NO SE PUDO CREAR INDICE!!!"); + return 0; + } + + if (emu->indices==NULL) + emu->indices = tmp; + else { + tmp->sig = emu->indices; + emu->indices = tmp; + } + return 1; +} + +INDICE_DATO *emufs_buscar_registros(EMUFS *emu, char *indice, char *data, int *cant) +{ + CLAVE k; + INDICE *tmp; + + tmp = emu->indices; + while (tmp) { + if (strcmp(tmp->nombre, indice) == 0) break; + tmp = tmp->sig; + } + + if (tmp == NULL) { + PERR("NO EXISTE EL INDICE"); + cant = 0; + return NULL; + } + + PERR("GENERANDO CLAVE") + PERR(data); + k = emufs_indice_generar_clave_desde_valor(tmp, data); + PERR("DONE"); + return tmp->buscar_entradas(tmp, k, cant); +} + +int guardar_indice(EMUFS *emu, char *nombre, INDICE_FUNCION funcion, INDICE_TIPO tipo, INDICE_TIPO_DATO tipo_dato, unsigned int offset, unsigned int tam_bloque) +{ + char filename[100]; + FILE *fp; + int cant; /* cantidad de indices hasta el momento */ + t_Indice *indices; + + sprintf(filename, "%s.info", emu->nombre); + fp = fopen(filename, "r+"); + PERR("Abri info"); + PERR(filename); + if (fp == NULL) { + PERR("No se pudo"); + return 0; + } + + fread(&cant, 1, sizeof(int), fp); + indices = malloc((cant+1)*sizeof(t_Indice)); + fread(indices, cant, sizeof(t_Indice), fp); + memset(indices[cant].nombre, 0, 50); + strcpy(indices[cant].nombre, nombre); + indices[cant].funcion = funcion; + indices[cant].tipo = tipo; + indices[cant].tipo_dato = tipo_dato; + indices[cant].offset = offset; + indices[cant].tam_bloque = tam_bloque; + + fseek(fp, SEEK_SET, 0); + cant++; + fwrite(&cant, 1, sizeof(int), fp); + fwrite(indices, cant, sizeof(t_Indice), fp); + fclose(fp); + free(indices); + return 1; +} + +/*crea un bloque y devuelve en numero del mismo*/ +EMUFS_BLOCK_ID emufs_create_new_block(EMUFS *emu) +{ + FILE *fp; + char name[255]; + char *dummy; + EMUFS_BLOCK_ID num; + + /* obtengo nombre del archivo */ + strcpy(name, emu->nombre); + strcat(name,".dat"); + + if ( (fp=fopen(name,"a+")) == NULL ){ + PERR("NO SE PUDO ABRIR EL ARCHIVO"); + return -1; + } + + dummy = (char*)malloc(emu->tam_bloque); + memset(dummy, 0, emu->tam_bloque); + fwrite(dummy, emu->tam_bloque, 1, fp); + switch(emu->tipo){ + case T1: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE))/emu->tam_bloque; + break; + case T3: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE)-sizeof(EMUFS_REG_SIZE))/emu->tam_bloque; + } + fclose(fp); + free(dummy); + return num-1; +} + +/*devuelve un numero de bloque siguiente al ultimo*/ +EMUFS_BLOCK_ID emufs_get_new_block_number(EMUFS *emu) +{ + FILE *fp; + char name[255]; + EMUFS_BLOCK_ID num=0; + + /* obtengo nombre del archivo */ + strcpy(name, emu->nombre); + strcat(name,".dat"); + if ( (fp=fopen(name,"r")) == NULL ){ + PERR("NO SE PUDO ABRIR EL ARCHIVO"); + return -1; + } + if ( fseek(fp, 0, SEEK_END)!=0 ){ + PERR("NO PUDE HACER EL SEEK"); + return -1; + } + 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; + 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; + } + fclose(fp); + return num; +} + +INDICE *emufs_buscar_indice_por_nombre(EMUFS *emu, const char *nombre) +{ + INDICE *tmp; + + tmp = emu->indices; + while (tmp) { + if (strcmp(tmp->nombre, nombre) == 0) break; + tmp = tmp->sig; + } + return tmp; +}