+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, str_offset);
+
+ if (tmp == NULL) {
+ PERR("NO SE PUDO CREAR INDICE!!!");
+ return 0;
+ }
+
+ tmp->sig = NULL;
+ 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, int str_offset)
+{
+ 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;
+ indices[cant].str_offset = str_offset;
+
+ 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;
+}
+
+int cargar_indices(EMUFS *emu)
+{
+ char filename[100];
+ FILE *fp;
+ int cant, i; /* 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;
+ }
+
+ emu->indices = NULL;
+ fread(&cant, 1, sizeof(int), fp);
+ if (cant == 0) {
+ PERR("NO HAY INDICES EN ESTE ARCHIVO");
+ return 1;
+ }
+ indices = malloc(cant*sizeof(t_Indice));
+ fread(indices, cant, sizeof(t_Indice), fp);
+ fclose(fp);
+
+ /* Leo */
+ for(i=0; i<cant; i++) {
+ INDICE *tmp;
+ tmp = emufs_indice_abrir(emu,
+ indices[i].nombre,
+ indices[i].funcion,
+ indices[i].tipo,
+ indices[i].tipo_dato,
+ indices[i].offset,
+ indices[i].tam_bloque,
+ indices[i].str_offset
+ );
+ PERR(indices[i].nombre);
+ if (emu->indices==NULL)
+ emu->indices = tmp;
+ else {
+ tmp->sig = emu->indices;
+ emu->indices = tmp;
+ }
+ }
+
+ 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 T4: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE))/emu->tam_bloque;
+ break;
+ case T5: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE)-sizeof(EMUFS_REG_SIZE))/emu->tam_bloque;
+ break;
+ default: num = 0;
+ }
+ 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 T4: 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 T5: 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;
+ break;
+ default: 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;
+}
projects / z.facultad / 75.06 / emufs.git / blobdiff