X-Git-Url: https://git.llucax.com/z.facultad/75.06/emufs.git/blobdiff_plain/63f9cc2172df9d346457685096b4de200c084e9e..ec7edba15ba5510149162d9998bc1b7146ca249d:/emufs/emufs.c?ds=inline diff --git a/emufs/emufs.c b/emufs/emufs.c index ad14955..0586999 100644 --- a/emufs/emufs.c +++ b/emufs/emufs.c @@ -47,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) @@ -82,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; @@ -103,6 +114,16 @@ EMUFS *emufs_crear(const char *filename, EMUFS_Tipo tipo, EMUFS_BLOCK_SIZE tam_b 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); strcat(name, ".dat"); @@ -349,6 +370,7 @@ int emufs_agregar_indice(EMUFS *emu, char *nombre, INDICE_FUNCION funcion, INDIC /* 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) { @@ -359,6 +381,7 @@ int emufs_agregar_indice(EMUFS *emu, char *nombre, INDICE_FUNCION funcion, INDIC error = 2; break; } + tmp = tmp->sig; } if (tmp != NULL) { @@ -368,17 +391,21 @@ int emufs_agregar_indice(EMUFS *emu, char *nombre, INDICE_FUNCION funcion, INDIC break; case 2: PERR("EMUFS ya tiene indice primario!!"); - break; - default: - PERR("Error no esperado!!"); } return 0; } /* Creo el nuevo indice */ + PERR("Creando indice\n"); tmp = emufs_indice_crear(emu, nombre, funcion, tipo, tipo_dato, offset, tam_bloque); - if (tmp == NULL) return 0; + /* 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; @@ -389,12 +416,15 @@ int emufs_agregar_indice(EMUFS *emu, char *nombre, INDICE_FUNCION funcion, INDIC return 1; } -INDICE_DATO *emufs_buscar_registros(EMUFS *emu, char *indice, CLAVE clave, int *cant) +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) { @@ -403,6 +433,45 @@ INDICE_DATO *emufs_buscar_registros(EMUFS *emu, char *indice, CLAVE clave, int * return NULL; } - return tmp->buscar_entradas(tmp, clave, cant); + 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); + return 1; }