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