]> git.llucax.com Git - z.facultad/75.06/emufs.git/blob - emufs/emufs.c
un poco mas de B+
[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) && (tipo != T4) && (tipo != T5)) {
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                                 PERR("ERROR Tipo1 no se pudo leer cabecera");
279                                 free(efs->nombre);
280                                 free(efs);
281                                 fclose(fp);
282                                 return NULL;
283                         }
284                         /* Asigna punteros a funciones. */
285                         if ((err = emufs_tipo1_inicializar(efs))) {
286                                 PERR("No se pudo inicializar el EMUFS de tipo1");
287                                 fclose(fp);
288                                 return NULL;
289                         }
290                         break;
291                 case T2:
292                         /* Asigna punteros a funciones. */
293                         emufs_tipo2_inicializar(efs);                   
294                         break;
295                 case T3:
296                         if ((!fread(&(efs->tam_bloque), sizeof(EMUFS_BLOCK_SIZE), 1, fp)) ||
297                            (!fread(&(efs->tam_reg), sizeof(EMUFS_REG_SIZE), 1, fp)))
298                                 {
299                                 PERR("ERROR Tipo3 no se pudo leer header");
300                                 free(efs->nombre);
301                                 free(efs);
302                                 fclose(fp);
303                                 return NULL;
304                         }                       
305                         /* Asigna punteros a funciones. */                      
306                         emufs_tipo3_inicializar(efs);
307                         break;
308         
309                 case T4:
310                         /* Lee cabeceras propias. */
311                         if (!fread(&(efs->tam_bloque), sizeof(EMUFS_BLOCK_SIZE), 1, fp)) {
312                                 free(efs->nombre);
313                                 free(efs);
314                                 fclose(fp);
315                                 return NULL;
316                         }
317                         emufs_tipo4_inicializar(efs);
318                         break;
319
320                 case T5:
321                         if ((!fread(&(efs->tam_bloque), sizeof(EMUFS_BLOCK_SIZE), 1, fp)) ||
322                            (!fread(&(efs->tam_reg), sizeof(EMUFS_REG_SIZE), 1, fp)))
323                                 {
324                                 free(efs->nombre);
325                                 free(efs);
326                                 fclose(fp);
327                                 return NULL;
328                         }                       
329                         /* Asigna punteros a funciones. */
330                         emufs_tipo5_inicializar(efs);
331                 default:
332                         PERR("EMUFS TIPO NO SOPORTADO");
333         }       
334
335         /* finalmente cargo la data de los indices */
336         cargar_indices(efs);
337         fclose(fp);
338         return efs;
339 }
340
341 int emufs_destruir(EMUFS *e)
342 {
343         INDICE *del, *cur;
344
345         if (e == NULL) return 1;
346
347         /* libero indices */
348         cur = e->indices;
349         while (cur) {
350                 del = cur;
351                 cur = cur->sig;
352                 emufs_indice_destruir(e, del);
353         }
354
355         free(e->nombre);
356         free(e);
357         return 0;
358 }
359
360 int ver_archivo_FS(EMUFS *emu)
361 {
362         FILE *f_block_free;
363         EMUFS_FSC reg;
364         char name_f_block_free[255];
365         
366         strcpy(name_f_block_free,emu->nombre);
367         strcat(name_f_block_free,".fsc");
368
369         if ( (f_block_free = fopen(name_f_block_free,"r"))==NULL ){
370                 fprintf(stderr, "no pude abrir el archivo %s\n",name_f_block_free);
371                 return -1;
372         }
373         fprintf(stderr,"BOQUES Y ESPACIO LIBRE\n");
374         fread(&reg,sizeof(reg),1,f_block_free);
375         while ( !feof(f_block_free) ){
376                 fprintf(stderr, "Bloque = %li   Espacio libre = %li\n",reg.marker, reg.freespace);
377                 fread(&reg,sizeof(reg),1,f_block_free);
378         }
379         
380         fclose(f_block_free);
381
382         /* Imprimo la lista de bloques/registros */
383         fprintf(stderr, "BLOQUES Y REGISTROS\n");
384         strcpy(name_f_block_free,emu->nombre);
385         strcat(name_f_block_free,".idx");
386         f_block_free = fopen(name_f_block_free, "r");
387         {
388                 EMUFS_IDX r;
389                 while (!feof(f_block_free)) {
390                         if (fread(&r, sizeof(EMUFS_IDX), 1, f_block_free) != 1) continue;
391                         fprintf(stderr, "ID %li en bloque %li\n", r.id_reg, r.location);
392                 }
393         }
394         fclose(f_block_free);
395         
396         return 0;
397 }
398
399 int debug_ver_estadisticas(EMUFS* efs)
400 {
401         EMUFS_Estadisticas s = efs->leer_estadisticas(efs);
402
403         printf("ESTADISTICAS:\n");
404         printf("=============\n");
405         printf("Tamaño del archivo: %lu bytes\n", s.tam_archivo);
406         printf("Tamaño de datos (incluye espacio libre): %lu bytes (%.2f %%)\n",
407                         s.tam_archivo - s.tam_info_control_dat,
408                         (s.tam_archivo - s.tam_info_control_dat) * 100.0
409                                 / (float) s.tam_archivo);
410         printf("Tamaño de info de control total: %lu bytes (%.2f %%)\n",
411                         s.tam_info_control_dat + s.tam_archivos_aux,
412                         (s.tam_info_control_dat + s.tam_archivos_aux) * 100.0
413                                 / (float) s.tam_archivo);
414         printf("Tamaño de los archivos auxiliares: %lu bytes\n",
415                         s.tam_archivos_aux);
416         printf("Tamaño de la información de control en el .dat: %lu bytes\n",
417                         s.tam_info_control_dat);
418         printf("Total de espacio libre: %lu bytes\n", s.total_fs);
419         printf("Máximo espacio libre en bloque: %lu bytes\n", s.max_fs);
420         printf("Mínimo espacio libre en bloque: %lu bytes\n", s.min_fs);
421         printf("Media del espacio libre por bloque: %lu bytes\n", s.media_fs);
422         printf("Cantidad de registros: %lu\n", s.cant_registros);
423         printf("Cantidad de bloques: %lu\n", s.cant_bloques);
424         return 0;
425 }
426
427 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)
428 {
429         INDICE *tmp;
430         int error=0;
431
432         /* Verifico que no existe un indice con el mismo nombre */
433         /* y que no exista un indice primario */
434         PERR("Agregando indice");
435         tmp = emu->indices;
436         while (tmp) {
437                 if (strcmp(tmp->nombre, nombre)==0) {
438                         error = 1;
439                         break;
440                 }
441                 if ((funcion == IND_PRIMARIO) && (tmp->funcion == funcion)) {
442                         error = 2;
443                         break;
444                 }
445                 tmp = tmp->sig;
446         }
447
448         if (tmp != NULL) {
449                 switch (error) {
450                         case 1:
451                                 PERR("Ya existe un indice con el mismo nombre!");
452                         break;
453                         case 2:
454                                 PERR("EMUFS ya tiene indice primario!!");
455                 }
456                 return 0;
457         }
458
459         /* Creo el nuevo indice */
460         PERR("Creando indice\n");
461         tmp = emufs_indice_crear(emu, nombre, funcion, tipo, tipo_dato, offset, tam_bloque, str_offset);
462
463         /* Guardo la info del indice para poder abrir despues el archivo */
464         guardar_indice(emu, nombre, funcion, tipo, tipo_dato, offset, tam_bloque, str_offset);
465
466         if (tmp == NULL) {
467                 PERR("NO SE PUDO CREAR INDICE!!!");
468                 return 0;
469         }
470
471         tmp->sig = NULL;
472         if (emu->indices==NULL)
473                 emu->indices = tmp;
474         else {
475                 tmp->sig = emu->indices;
476                 emu->indices = tmp;
477         }
478         return 1;
479 }
480
481 INDICE_DATO *emufs_buscar_registros(EMUFS *emu, char *indice, char *data, int *cant)
482 {
483         CLAVE k;
484         INDICE *tmp;
485
486         tmp = emu->indices;
487         while (tmp) {
488                 if (strcmp(tmp->nombre, indice) == 0) break;
489                 tmp = tmp->sig;
490         }
491
492         if (tmp == NULL) {
493                 PERR("NO EXISTE EL INDICE");
494                 cant = 0;
495                 return NULL;
496         }
497
498         PERR("GENERANDO CLAVE")
499         PERR(data);
500         k = emufs_indice_generar_clave_desde_valor(tmp, data);
501         PERR("DONE");
502         return tmp->buscar_entradas(tmp, k, cant);
503 }
504
505 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)
506 {
507         char filename[100];
508         FILE *fp;
509         int cant; /* cantidad de indices hasta el momento */
510         t_Indice *indices;
511
512         sprintf(filename, "%s.info", emu->nombre);
513         fp = fopen(filename, "r+");
514         PERR("Abri info");
515         PERR(filename);
516         if (fp == NULL) {
517                 PERR("No se pudo");
518                 return 0;
519         }
520
521         fread(&cant, 1, sizeof(int), fp);
522         indices = malloc((cant+1)*sizeof(t_Indice));
523         fread(indices, cant, sizeof(t_Indice), fp);
524         memset(indices[cant].nombre, 0, 50); 
525         strcpy(indices[cant].nombre, nombre);
526         indices[cant].funcion = funcion;
527         indices[cant].tipo = tipo;
528         indices[cant].tipo_dato = tipo_dato;
529         indices[cant].offset = offset;
530         indices[cant].tam_bloque = tam_bloque;
531         indices[cant].str_offset = str_offset;
532
533         fseek(fp, SEEK_SET, 0);
534         cant++;
535         fwrite(&cant, 1, sizeof(int), fp);
536         fwrite(indices, cant, sizeof(t_Indice), fp);
537         fclose(fp);
538         free(indices);
539         return 1;
540 }
541
542 int cargar_indices(EMUFS *emu)
543 {
544         char filename[100];
545         FILE *fp;
546         int cant, i; /* cantidad de indices hasta el momento */
547         t_Indice *indices;
548
549         sprintf(filename, "%s.info", emu->nombre);
550         fp = fopen(filename, "r");
551         PERR("Abri info");
552         PERR(filename);
553         if (fp == NULL) {
554                 PERR("No se pudo");
555                 return 0;
556         }
557
558         emu->indices = NULL;
559         fread(&cant, 1, sizeof(int), fp);
560         if (cant == 0) {
561                 PERR("NO HAY INDICES EN ESTE ARCHIVO");
562                 return 1;
563         }
564         indices = malloc(cant*sizeof(t_Indice));
565         fread(indices, cant, sizeof(t_Indice), fp);
566         fclose(fp);
567         
568         /* Leo  */
569         for(i=0; i<cant; i++) {
570                 INDICE *tmp;
571                 tmp = emufs_indice_abrir(emu,
572                                 indices[i].nombre,
573                                 indices[i].funcion,
574                                 indices[i].tipo,
575                                 indices[i].tipo_dato,
576                                 indices[i].offset,
577                                 indices[i].tam_bloque,
578                                 indices[i].str_offset
579                         );
580                 PERR(indices[i].nombre);
581                 if (emu->indices==NULL)
582                         emu->indices = tmp;
583                 else {
584                         tmp->sig = emu->indices;
585                         emu->indices = tmp;
586                 }
587         }
588         
589         free(indices);
590         return 1;
591 }
592
593 /*crea un bloque y devuelve en numero del mismo*/
594 EMUFS_BLOCK_ID emufs_create_new_block(EMUFS *emu)
595 {
596         FILE *fp;
597         char name[255];
598         char *dummy;
599         EMUFS_BLOCK_ID num;
600         
601         /* obtengo nombre del archivo */
602         strcpy(name, emu->nombre);
603         strcat(name,".dat");
604         
605         if ( (fp=fopen(name,"a+")) == NULL ){
606                 PERR("NO SE PUDO ABRIR EL ARCHIVO");
607                 return -1;
608         }
609
610         dummy = (char*)malloc(emu->tam_bloque);
611         memset(dummy, 0, emu->tam_bloque);
612         fwrite(dummy, emu->tam_bloque, 1, fp);
613         switch(emu->tipo){
614                 case T4: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE))/emu->tam_bloque;
615                         break;
616                 case T5: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE)-sizeof(EMUFS_REG_SIZE))/emu->tam_bloque;
617                         break;
618                 default: num = 0;               
619         }
620         fclose(fp);
621         free(dummy);
622         return num-1;
623 }
624
625 /*devuelve un numero de bloque siguiente al ultimo*/
626 EMUFS_BLOCK_ID emufs_get_new_block_number(EMUFS *emu)
627 {
628         FILE *fp;
629         char name[255];
630         EMUFS_BLOCK_ID num=0;
631         
632         /* obtengo nombre del archivo */
633         strcpy(name, emu->nombre);
634         strcat(name,".dat");
635         if ( (fp=fopen(name,"r")) == NULL ){
636                 PERR("NO SE PUDO ABRIR EL ARCHIVO");
637                 return -1;
638         }
639         if ( fseek(fp, 0, SEEK_END)!=0 ){
640                 PERR("NO PUDE HACER EL SEEK");
641                 return -1;
642         }
643         switch(emu->tipo){
644                 case T4: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE))/emu->tam_bloque;
645                         if (ftell(fp) ==  sizeof(EMUFS_Tipo)+sizeof(EMUFS_BLOCK_SIZE)) num = 0;
646                         break;
647                 case T5: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE)-sizeof(EMUFS_REG_SIZE))/emu->tam_bloque;
648                         if (ftell(fp) ==  sizeof(EMUFS_Tipo)+sizeof(EMUFS_BLOCK_SIZE)+sizeof(EMUFS_REG_SIZE)) num = 0;
649                         break;
650                 default: num = 0;
651         }
652         fclose(fp);
653         return num;
654 }
655
656 INDICE *emufs_buscar_indice_por_nombre(EMUFS *emu, const char *nombre)
657 {
658         INDICE *tmp;
659
660         tmp = emu->indices;
661         while (tmp) {
662                 if (strcmp(tmp->nombre, nombre) == 0) break;
663                 tmp = tmp->sig;
664         }
665         return tmp;
666 }