]> git.llucax.com Git - z.facultad/75.06/emufs.git/blob - emufs/emufs.c
Piloteado de mini bug que pudiera existir en insertar ordenado, siempre se devuelve...
[z.facultad/75.06/emufs.git] / emufs / emufs.c
1 /* vim: set noexpandtab tabstop=4 shiftwidth=4:
2  *----------------------------------------------------------------------------
3  *                                  emufs
4  *----------------------------------------------------------------------------
5  * This file is part of emufs.
6  *
7  * emufs is free software; you can redistribute it and/or modify it under the
8  * terms of the GNU General Public License as published by the Free Software
9  * Foundation; either version 2 of the License, or (at your option) any later
10  * version.
11  *
12  * emufs is distributed in the hope that it will be useful, but WITHOUT ANY
13  * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
14  * FOR A PARTICULAR PURPOSE. See the GNU General Public License for more
15  * details.
16  *
17  * You should have received a copy of the GNU General Public License along
18  * with emufs; if not, write to the Free Software Foundation, Inc., 59 Temple
19  * Place, Suite 330, Boston, MA  02111-1307  USA
20  *----------------------------------------------------------------------------
21  * Creado:  mié mar 31 17:26:46 ART 2004
22  * Autores: Nicolás Dimov <sagardua@uolsinectis.com.ar>
23  *          Ricardo Markiewicz <rmarkie@fi.uba.ar>
24  *          Leandro Lucarella <llucare@fi.uba.ar>
25  *----------------------------------------------------------------------------
26  *
27  * $Id$
28  *
29  */
30
31 /** \file
32  *
33  * Estructura general de un archivo <em>abstracto</em> de emufs.
34  * 
35  * Implementación de la estructura abstracta que representa cualquiera de los
36  * tipos de archivo implementados. Se incluyen funciones tipo <em>factory</em>
37  * para crear un archivo, abrirlo y destruirlo.
38  *
39  */
40
41 #include "emufs.h"
42 #include "common.h"
43 #include "tipo1.h"
44 #include "tipo2.h"
45 #include "tipo3.h"
46 #include "did.h"
47 #include "fsc.h"
48 #include "idx.h"
49
50 typedef struct _data_indices_ {
51         char nombre[50];
52         INDICE_FUNCION funcion;
53         INDICE_TIPO tipo;
54         INDICE_TIPO_DATO tipo_dato;
55         unsigned int offset;
56         unsigned int tam_bloque;
57         int str_offset;
58 } t_Indice;
59
60 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);
61 int cargar_indices(EMUFS *emu);
62
63 char *str_dup(const char *s);
64
65 char *str_dup(const char *s)
66 {
67         char *tmp;
68         if (s == NULL) return NULL;
69         tmp = (char *)malloc(sizeof(char)*(strlen(s)+1));
70         strcpy(tmp, s);
71         return tmp;
72 }
73
74 int emufs_crear_archivo_auxiliar(const char* name, const char* ext)
75 {
76         FILE* f;
77         char* filename;
78
79         filename = (char*) malloc(sizeof(char) * (strlen(name) + strlen(ext) + 1));
80         if (filename == NULL) {
81                 /* TODO Manejo de errores */
82                 return -1;
83         }
84         strcpy(filename, name);
85         strcat(filename, ext);
86         f = fopen(filename, "w");
87         free(filename);
88         if (f == NULL) {
89                 /* TODO Manejo de errores */
90                 return -1;
91         }
92         fclose(f);
93         return 0;
94 }
95
96 EMUFS *emufs_crear(const char *filename, EMUFS_Tipo tipo, EMUFS_BLOCK_SIZE tam_bloque, EMUFS_REG_SIZE tam_reg)
97 {
98         char name[255], otroname[255];
99         FILE *fp;
100         EMUFS *efs;
101         int err = 0;
102
103         /* Si no es un tipo conocido, sale. */
104         if ((tipo != T1) && (tipo != T2) && (tipo != T3) && (tipo != T4) && (tipo != T5)) {
105                 return NULL;
106         }
107
108         /* Inicializa parámetros comunes. */
109         efs = (EMUFS*) malloc(sizeof(EMUFS));
110         if (efs == NULL) {
111                 return NULL;
112         }
113         efs->tipo = tipo;
114         efs->tam_bloque = tam_bloque;
115         efs->tam_reg = tam_reg;
116         efs->nombre = str_dup(filename);
117         efs->indices = NULL;
118
119         sprintf(otroname, "%s.info", efs->nombre);
120         fp = fopen(otroname, "w");
121         if (fp == NULL) {
122                 PERR("CARAJO!, NO PUEDO CREAR INFO");
123         } else {
124                 err = 0;
125                 fwrite(&err, 1, sizeof(int), fp);
126                 fclose(fp);
127         }
128
129         /* Abre archivo de datos. */
130         strcpy(name, filename);
131         strcat(name, ".dat");
132         fp = fopen(name, "w");
133         if (fp == NULL) {
134                 /* TODO ERROR */
135                 free(efs->nombre);
136                 free(efs);
137                 return NULL;
138         }
139
140         /* Guarda cabecera común. */
141         fwrite(&tipo, sizeof(EMUFS_Tipo), 1, fp);
142
143         /* Crea archivo de índice. */
144         if (emufs_idx_crear(efs)) {
145                 /* TODO ERROR */
146                 fclose(fp);
147                 free(efs->nombre);
148                 free(efs);
149                 return NULL;
150         }
151
152         /* Crea archivo de control de espacio libre. */
153         if (emufs_fsc_crear(efs)) {
154                 /* TODO ERROR */
155                 fclose(fp);
156                 free(efs->nombre);
157                 free(efs);
158                 return NULL;
159         }
160
161         /* Crea archivo de identificadores borrados (recuperables). */
162         if (emufs_did_crear(efs)) {
163                 /* TODO ERROR */
164                 fclose(fp);
165                 free(efs->nombre);
166                 free(efs);
167                 return NULL;
168         }
169
170         /* Termina de realizar el trabajo según el tipo de archivo. */
171         switch (tipo) {
172
173                 case T1:
174                         /* Asigna punteros a funciones. */
175                         if ((err = emufs_tipo1_inicializar(efs))) {
176                                 /* TODO ERROR */
177                                 PERR("No se pudo inicializar el EMUFS de tipo1");
178                                 fclose(fp);
179                                 free(efs->nombre);
180                                 free(efs);
181                                 return NULL;
182                         }
183
184                         /* Guarda cabeceras propias. */
185                         fwrite(&tam_bloque, sizeof(EMUFS_BLOCK_SIZE), 1, fp);
186
187                         break;
188
189                 case T2:
190                         /* Asigna punteros a funciones. */
191                         emufs_tipo2_inicializar(efs);
192                         break;
193
194                 case T3:
195                         /* Asigna punteros a funciones. */
196                         if ((err = emufs_tipo3_inicializar(efs))) {
197                                 /* TODO ERROR */
198                                 PERR("No se pudo inicializar el EMUFS de tipo3");
199                                 fclose(fp);
200                                 free(efs->nombre);
201                                 free(efs);
202                                 return NULL;
203                         }
204                         /* Guarda cabeceras propias. */
205                         fwrite(&tam_bloque, sizeof(EMUFS_BLOCK_SIZE), 1, fp);
206                         fwrite(&tam_reg, sizeof(EMUFS_REG_SIZE), 1, fp);                        
207                         break;
208                 
209                 case T4:
210                         /* Asigna punteros a funciones. */
211                         if ((err = emufs_tipo4_inicializar(efs))) {
212                                 /* TODO ERROR */
213                                 PERR("No se pudo inicializar el EMUFS de tipo4");
214                                 fclose(fp);
215                                 free(efs->nombre);
216                                 free(efs);
217                                 return NULL;
218                         }
219                         /* Guarda cabeceras propias. */
220                         fwrite(&tam_bloque, sizeof(EMUFS_BLOCK_SIZE), 1, fp);
221                         break;
222                 
223                 case T5:
224                         /* Asigna punteros a funciones. */
225                         if ((err = emufs_tipo5_inicializar(efs))) {
226                                 /* TODO ERROR */
227                                 PERR("No se pudo inicializar el EMUFS de tipo5");
228                                 fclose(fp);
229                                 free(efs->nombre);
230                                 free(efs);
231                                 return NULL;
232                         }
233                         /* Guarda cabeceras propias. */                 
234                         fwrite(&tam_bloque, sizeof(EMUFS_BLOCK_SIZE), 1, fp);
235                         fwrite(&tam_reg, sizeof(EMUFS_REG_SIZE), 1, fp);                        
236                         break;
237         }
238
239         fclose(fp);
240         return efs;
241 }
242
243 EMUFS *emufs_abrir(const char *filename)
244 {
245         EMUFS *efs;
246         char name[255];
247         char tipo;
248         FILE *fp;
249         int err = 0;
250
251         strcpy(name, filename);
252         strcat(name, ".dat");
253
254         /* Trato de determinar el tipo de archivo */
255         fp = fopen(name, "r");
256         if (fp == NULL) return NULL;
257         fread(&tipo, sizeof(EMUFS_Tipo), 1, fp);
258
259         /* Si no es un tipo conocido, sale. */
260         if ((tipo != T1) && (tipo != T2) && (tipo != T3)) {
261                 fclose(fp);
262                 return NULL;
263         }
264         
265         /* Inicializa parámetros comunes. */
266         efs = (EMUFS*) malloc(sizeof(EMUFS));
267         if (efs == NULL) {
268                 fclose(fp);
269                 return NULL;
270         }
271         efs->tipo = tipo;
272         efs->nombre = str_dup(filename);
273         
274         switch (tipo) {
275                 case T1:
276                         /* Lee cabeceras propias. */
277                         if (!fread(&(efs->tam_bloque), sizeof(EMUFS_BLOCK_SIZE), 1, fp)) {
278                                 free(efs->nombre);
279                                 free(efs);
280                                 fclose(fp);
281                                 return NULL;
282                         }
283                         /* Asigna punteros a funciones. */
284                         if ((err = emufs_tipo1_inicializar(efs))) {
285                                 PERR("No se pudo inicializar el EMUFS de tipo1");
286                                 fclose(fp);
287                                 return NULL;
288                         }
289                         break;
290                 case T2:
291                         /* Asigna punteros a funciones. */
292                         emufs_tipo2_inicializar(efs);                   
293                         break;
294                 case T3:
295                         if ((!fread(&(efs->tam_bloque), sizeof(EMUFS_BLOCK_SIZE), 1, fp)) ||
296                            (!fread(&(efs->tam_reg), sizeof(EMUFS_REG_SIZE), 1, fp)))
297                                 {
298                                 free(efs->nombre);
299                                 free(efs);
300                                 fclose(fp);
301                                 return NULL;
302                         }                       
303                         /* Asigna punteros a funciones. */                      
304                         emufs_tipo3_inicializar(efs);
305                         break;
306         
307                 case T4:
308                         /* Lee cabeceras propias. */
309                         if (!fread(&(efs->tam_bloque), sizeof(EMUFS_BLOCK_SIZE), 1, fp)) {
310                                 free(efs->nombre);
311                                 free(efs);
312                                 fclose(fp);
313                                 return NULL;
314                         }
315                         emufs_tipo4_inicializar(efs);
316                         break;
317
318                 case T5:
319                         if ((!fread(&(efs->tam_bloque), sizeof(EMUFS_BLOCK_SIZE), 1, fp)) ||
320                            (!fread(&(efs->tam_reg), sizeof(EMUFS_REG_SIZE), 1, fp)))
321                                 {
322                                 free(efs->nombre);
323                                 free(efs);
324                                 fclose(fp);
325                                 return NULL;
326                         }                       
327                         /* Asigna punteros a funciones. */
328                         emufs_tipo5_inicializar(efs);
329         }       
330
331         /* finalmente cargo la data de los indices */
332         cargar_indices(efs);
333         fclose(fp);
334         return efs;
335 }
336
337 int emufs_destruir(EMUFS *e)
338 {
339         INDICE *del, *cur;
340
341         if (e == NULL) return 1;
342
343         /* libero indices */
344         cur = e->indices;
345         while (cur) {
346                 del = cur;
347                 fprintf(stderr, "INDICE A ELIMINAR = %s\n", del->nombre);
348                 cur = cur->sig;
349                 emufs_indice_destruir(e, del);
350         }
351
352         free(e->nombre);
353         free(e);
354         return 0;
355 }
356
357 int ver_archivo_FS(EMUFS *emu)
358 {
359         FILE *f_block_free;
360         EMUFS_FSC reg;
361         char name_f_block_free[255];
362         
363         strcpy(name_f_block_free,emu->nombre);
364         strcat(name_f_block_free,".fsc");
365
366         if ( (f_block_free = fopen(name_f_block_free,"r"))==NULL ){
367                 fprintf(stderr, "no pude abrir el archivo %s\n",name_f_block_free);
368                 return -1;
369         }
370         fprintf(stderr,"BOQUES Y ESPACIO LIBRE\n");
371         fread(&reg,sizeof(reg),1,f_block_free);
372         while ( !feof(f_block_free) ){
373                 fprintf(stderr, "Bloque = %li   Espacio libre = %li\n",reg.marker, reg.freespace);
374                 fread(&reg,sizeof(reg),1,f_block_free);
375         }
376         
377         fclose(f_block_free);
378
379         /* Imprimo la lista de bloques/registros */
380         fprintf(stderr, "BLOQUES Y REGISTROS\n");
381         strcpy(name_f_block_free,emu->nombre);
382         strcat(name_f_block_free,".idx");
383         f_block_free = fopen(name_f_block_free, "r");
384         {
385                 EMUFS_IDX r;
386                 while (!feof(f_block_free)) {
387                         if (fread(&r, sizeof(EMUFS_IDX), 1, f_block_free) != 1) continue;
388                         fprintf(stderr, "ID %li en bloque %li\n", r.id_reg, r.location);
389                 }
390         }
391         fclose(f_block_free);
392         
393         return 0;
394 }
395
396 int debug_ver_estadisticas(EMUFS* efs)
397 {
398         EMUFS_Estadisticas s = efs->leer_estadisticas(efs);
399
400         printf("ESTADISTICAS:\n");
401         printf("=============\n");
402         printf("Tamaño del archivo: %lu bytes\n", s.tam_archivo);
403         printf("Tamaño de datos (incluye espacio libre): %lu bytes (%.2f %%)\n",
404                         s.tam_archivo - s.tam_info_control_dat,
405                         (s.tam_archivo - s.tam_info_control_dat) * 100.0
406                                 / (float) s.tam_archivo);
407         printf("Tamaño de info de control total: %lu bytes (%.2f %%)\n",
408                         s.tam_info_control_dat + s.tam_archivos_aux,
409                         (s.tam_info_control_dat + s.tam_archivos_aux) * 100.0
410                                 / (float) s.tam_archivo);
411         printf("Tamaño de los archivos auxiliares: %lu bytes\n",
412                         s.tam_archivos_aux);
413         printf("Tamaño de la información de control en el .dat: %lu bytes\n",
414                         s.tam_info_control_dat);
415         printf("Total de espacio libre: %lu bytes\n", s.total_fs);
416         printf("Máximo espacio libre en bloque: %lu bytes\n", s.max_fs);
417         printf("Mínimo espacio libre en bloque: %lu bytes\n", s.min_fs);
418         printf("Media del espacio libre por bloque: %lu bytes\n", s.media_fs);
419         printf("Cantidad de registros: %lu\n", s.cant_registros);
420         printf("Cantidad de bloques: %lu\n", s.cant_bloques);
421         return 0;
422 }
423
424 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)
425 {
426         INDICE *tmp;
427         int error=0;
428
429         /* Verifico que no existe un indice con el mismo nombre */
430         /* y que no exista un indice primario */
431         PERR("Agregando indice");
432         tmp = emu->indices;
433         while (tmp) {
434                 if (strcmp(tmp->nombre, nombre)==0) {
435                         error = 1;
436                         break;
437                 }
438                 if ((funcion == IND_PRIMARIO) && (tmp->funcion == funcion)) {
439                         error = 2;
440                         break;
441                 }
442                 tmp = tmp->sig;
443         }
444
445         if (tmp != NULL) {
446                 switch (error) {
447                         case 1:
448                                 PERR("Ya existe un indice con el mismo nombre!");
449                         break;
450                         case 2:
451                                 PERR("EMUFS ya tiene indice primario!!");
452                 }
453                 return 0;
454         }
455
456         /* Creo el nuevo indice */
457         PERR("Creando indice\n");
458         tmp = emufs_indice_crear(emu, nombre, funcion, tipo, tipo_dato, offset, tam_bloque, str_offset);
459
460         /* Guardo la info del indice para poder abrir despues el archivo */
461         guardar_indice(emu, nombre, funcion, tipo, tipo_dato, offset, tam_bloque, str_offset);
462
463         if (tmp == NULL) {
464                 PERR("NO SE PUDO CREAR INDICE!!!");
465                 return 0;
466         }
467
468         tmp->sig = NULL;
469         if (emu->indices==NULL)
470                 emu->indices = tmp;
471         else {
472                 tmp->sig = emu->indices;
473                 emu->indices = tmp;
474         }
475         return 1;
476 }
477
478 INDICE_DATO *emufs_buscar_registros(EMUFS *emu, char *indice, char *data, int *cant)
479 {
480         CLAVE k;
481         INDICE *tmp;
482
483         tmp = emu->indices;
484         while (tmp) {
485                 if (strcmp(tmp->nombre, indice) == 0) break;
486                 tmp = tmp->sig;
487         }
488
489         if (tmp == NULL) {
490                 PERR("NO EXISTE EL INDICE");
491                 cant = 0;
492                 return NULL;
493         }
494
495         PERR("GENERANDO CLAVE")
496         PERR(data);
497         k = emufs_indice_generar_clave_desde_valor(tmp, data);
498         PERR("DONE");
499         return tmp->buscar_entradas(tmp, k, cant);
500 }
501
502 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)
503 {
504         char filename[100];
505         FILE *fp;
506         int cant; /* cantidad de indices hasta el momento */
507         t_Indice *indices;
508
509         sprintf(filename, "%s.info", emu->nombre);
510         fp = fopen(filename, "r+");
511         PERR("Abri info");
512         PERR(filename);
513         if (fp == NULL) {
514                 PERR("No se pudo");
515                 return 0;
516         }
517
518         fread(&cant, 1, sizeof(int), fp);
519         indices = malloc((cant+1)*sizeof(t_Indice));
520         fread(indices, cant, sizeof(t_Indice), fp);
521         memset(indices[cant].nombre, 0, 50); 
522         strcpy(indices[cant].nombre, nombre);
523         indices[cant].funcion = funcion;
524         indices[cant].tipo = tipo;
525         indices[cant].tipo_dato = tipo_dato;
526         indices[cant].offset = offset;
527         indices[cant].tam_bloque = tam_bloque;
528         indices[cant].str_offset = str_offset;
529
530         fseek(fp, SEEK_SET, 0);
531         cant++;
532         fwrite(&cant, 1, sizeof(int), fp);
533         fwrite(indices, cant, sizeof(t_Indice), fp);
534         fclose(fp);
535         free(indices);
536         return 1;
537 }
538
539 int cargar_indices(EMUFS *emu)
540 {
541         char filename[100];
542         FILE *fp;
543         int cant, i; /* cantidad de indices hasta el momento */
544         t_Indice *indices;
545
546         sprintf(filename, "%s.info", emu->nombre);
547         fp = fopen(filename, "r");
548         PERR("Abri info");
549         PERR(filename);
550         if (fp == NULL) {
551                 PERR("No se pudo");
552                 return 0;
553         }
554
555         emu->indices = NULL;
556         fread(&cant, 1, sizeof(int), fp);
557         if (cant == 0) {
558                 PERR("NO HAY INDICES EN ESTE ARCHIVO");
559                 return 1;
560         }
561         indices = malloc(cant*sizeof(t_Indice));
562         fread(indices, cant, sizeof(t_Indice), fp);
563         fclose(fp);
564         
565         /* Leo  */
566         for(i=0; i<cant; i++) {
567                 INDICE *tmp;
568                 tmp = emufs_indice_abrir(emu,
569                                 indices[i].nombre,
570                                 indices[i].funcion,
571                                 indices[i].tipo,
572                                 indices[i].tipo_dato,
573                                 indices[i].offset,
574                                 indices[i].tam_bloque,
575                                 indices[i].str_offset
576                         );
577                 PERR(indices[i].nombre);
578                 if (emu->indices==NULL)
579                         emu->indices = tmp;
580                 else {
581                         tmp->sig = emu->indices;
582                         emu->indices = tmp;
583                 }
584         }
585         
586         free(indices);
587         return 1;
588 }
589
590 /*crea un bloque y devuelve en numero del mismo*/
591 EMUFS_BLOCK_ID emufs_create_new_block(EMUFS *emu)
592 {
593         FILE *fp;
594         char name[255];
595         char *dummy;
596         EMUFS_BLOCK_ID num;
597         
598         /* obtengo nombre del archivo */
599         strcpy(name, emu->nombre);
600         strcat(name,".dat");
601         
602         if ( (fp=fopen(name,"a+")) == NULL ){
603                 PERR("NO SE PUDO ABRIR EL ARCHIVO");
604                 return -1;
605         }
606
607         dummy = (char*)malloc(emu->tam_bloque);
608         memset(dummy, 0, emu->tam_bloque);
609         fwrite(dummy, emu->tam_bloque, 1, fp);
610         switch(emu->tipo){
611                 case T4: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE))/emu->tam_bloque;
612                         break;
613                 case T5: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE)-sizeof(EMUFS_REG_SIZE))/emu->tam_bloque;
614                         break;
615                 default: num = 0;               
616         }
617         fclose(fp);
618         free(dummy);
619         return num-1;
620 }
621
622 /*devuelve un numero de bloque siguiente al ultimo*/
623 EMUFS_BLOCK_ID emufs_get_new_block_number(EMUFS *emu)
624 {
625         FILE *fp;
626         char name[255];
627         EMUFS_BLOCK_ID num=0;
628         
629         /* obtengo nombre del archivo */
630         strcpy(name, emu->nombre);
631         strcat(name,".dat");
632         if ( (fp=fopen(name,"r")) == NULL ){
633                 PERR("NO SE PUDO ABRIR EL ARCHIVO");
634                 return -1;
635         }
636         if ( fseek(fp, 0, SEEK_END)!=0 ){
637                 PERR("NO PUDE HACER EL SEEK");
638                 return -1;
639         }
640         switch(emu->tipo){
641                 case T4: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE))/emu->tam_bloque;
642                         if (ftell(fp) ==  sizeof(EMUFS_Tipo)+sizeof(EMUFS_BLOCK_SIZE)) num = 0;
643                         break;
644                 case T5: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE)-sizeof(EMUFS_REG_SIZE))/emu->tam_bloque;
645                         if (ftell(fp) ==  sizeof(EMUFS_Tipo)+sizeof(EMUFS_BLOCK_SIZE)+sizeof(EMUFS_REG_SIZE)) num = 0;
646                         break;
647                 default: num = 0;
648         }
649         fclose(fp);
650         return num;
651 }
652
653 INDICE *emufs_buscar_indice_por_nombre(EMUFS *emu, const char *nombre)
654 {
655         INDICE *tmp;
656
657         tmp = emu->indices;
658         while (tmp) {
659                 if (strcmp(tmp->nombre, nombre) == 0) break;
660                 tmp = tmp->sig;
661         }
662         return tmp;
663 }