1 /* vim: set noexpandtab tabstop=4 shiftwidth=4:
2 *----------------------------------------------------------------------------
4 *----------------------------------------------------------------------------
5 * This file is part of emufs.
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
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
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 *----------------------------------------------------------------------------
33 * Estructura general de un archivo <em>abstracto</em> de emufs.
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.
50 typedef struct _data_indices_ {
52 INDICE_FUNCION funcion;
54 INDICE_TIPO_DATO tipo_dato;
56 unsigned int tam_bloque;
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);
63 char *str_dup(const char *s);
65 char *str_dup(const char *s)
68 if (s == NULL) return NULL;
69 tmp = (char *)malloc(sizeof(char)*(strlen(s)+1));
74 int emufs_crear_archivo_auxiliar(const char* name, const char* ext)
79 filename = (char*) malloc(sizeof(char) * (strlen(name) + strlen(ext) + 1));
80 if (filename == NULL) {
81 /* TODO Manejo de errores */
84 strcpy(filename, name);
85 strcat(filename, ext);
86 f = fopen(filename, "w");
89 /* TODO Manejo de errores */
96 EMUFS *emufs_crear(const char *filename, EMUFS_Tipo tipo, EMUFS_BLOCK_SIZE tam_bloque, EMUFS_REG_SIZE tam_reg)
98 char name[255], otroname[255];
103 /* Si no es un tipo conocido, sale. */
104 if ((tipo != T1) && (tipo != T2) && (tipo != T3) && (tipo != T4) && (tipo != T5)) {
108 /* Inicializa parámetros comunes. */
109 efs = (EMUFS*) malloc(sizeof(EMUFS));
114 efs->tam_bloque = tam_bloque;
115 efs->tam_reg = tam_reg;
116 efs->nombre = str_dup(filename);
119 sprintf(otroname, "%s.info", efs->nombre);
120 fp = fopen(otroname, "w");
122 PERR("CARAJO!, NO PUEDO CREAR INFO");
125 fwrite(&err, 1, sizeof(int), fp);
129 /* Abre archivo de datos. */
130 strcpy(name, filename);
131 strcat(name, ".dat");
132 fp = fopen(name, "w");
140 /* Guarda cabecera común. */
141 fwrite(&tipo, sizeof(EMUFS_Tipo), 1, fp);
143 /* Crea archivo de índice. */
144 if (emufs_idx_crear(efs)) {
152 /* Crea archivo de control de espacio libre. */
153 if (emufs_fsc_crear(efs)) {
161 /* Crea archivo de identificadores borrados (recuperables). */
162 if (emufs_did_crear(efs)) {
170 /* Termina de realizar el trabajo según el tipo de archivo. */
174 /* Asigna punteros a funciones. */
175 if ((err = emufs_tipo1_inicializar(efs))) {
177 PERR("No se pudo inicializar el EMUFS de tipo1");
184 /* Guarda cabeceras propias. */
185 fwrite(&tam_bloque, sizeof(EMUFS_BLOCK_SIZE), 1, fp);
190 /* Asigna punteros a funciones. */
191 emufs_tipo2_inicializar(efs);
195 /* Asigna punteros a funciones. */
196 if ((err = emufs_tipo3_inicializar(efs))) {
198 PERR("No se pudo inicializar el EMUFS de tipo3");
204 /* Guarda cabeceras propias. */
205 fwrite(&tam_bloque, sizeof(EMUFS_BLOCK_SIZE), 1, fp);
206 fwrite(&tam_reg, sizeof(EMUFS_REG_SIZE), 1, fp);
210 /* Asigna punteros a funciones. */
211 if ((err = emufs_tipo4_inicializar(efs))) {
213 PERR("No se pudo inicializar el EMUFS de tipo4");
219 /* Guarda cabeceras propias. */
220 fwrite(&tam_bloque, sizeof(EMUFS_BLOCK_SIZE), 1, fp);
224 /* Asigna punteros a funciones. */
225 if ((err = emufs_tipo5_inicializar(efs))) {
227 PERR("No se pudo inicializar el EMUFS de tipo5");
233 /* Guarda cabeceras propias. */
234 fwrite(&tam_bloque, sizeof(EMUFS_BLOCK_SIZE), 1, fp);
235 fwrite(&tam_reg, sizeof(EMUFS_REG_SIZE), 1, fp);
243 EMUFS *emufs_abrir(const char *filename)
251 strcpy(name, filename);
252 strcat(name, ".dat");
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);
259 /* Si no es un tipo conocido, sale. */
260 if ((tipo != T1) && (tipo != T2) && (tipo != T3) && (tipo != T4) && (tipo != T5)) {
265 /* Inicializa parámetros comunes. */
266 efs = (EMUFS*) malloc(sizeof(EMUFS));
272 efs->nombre = str_dup(filename);
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");
284 /* Asigna punteros a funciones. */
285 if ((err = emufs_tipo1_inicializar(efs))) {
286 PERR("No se pudo inicializar el EMUFS de tipo1");
292 /* Asigna punteros a funciones. */
293 emufs_tipo2_inicializar(efs);
296 if ((!fread(&(efs->tam_bloque), sizeof(EMUFS_BLOCK_SIZE), 1, fp)) ||
297 (!fread(&(efs->tam_reg), sizeof(EMUFS_REG_SIZE), 1, fp)))
299 PERR("ERROR Tipo3 no se pudo leer header");
305 /* Asigna punteros a funciones. */
306 emufs_tipo3_inicializar(efs);
310 /* Lee cabeceras propias. */
311 if (!fread(&(efs->tam_bloque), sizeof(EMUFS_BLOCK_SIZE), 1, fp)) {
317 emufs_tipo4_inicializar(efs);
321 if ((!fread(&(efs->tam_bloque), sizeof(EMUFS_BLOCK_SIZE), 1, fp)) ||
322 (!fread(&(efs->tam_reg), sizeof(EMUFS_REG_SIZE), 1, fp)))
329 /* Asigna punteros a funciones. */
330 emufs_tipo5_inicializar(efs);
332 PERR("EMUFS TIPO NO SOPORTADO");
335 /* finalmente cargo la data de los indices */
341 int emufs_destruir(EMUFS *e)
345 if (e == NULL) return 1;
352 emufs_indice_destruir(e, del);
360 int ver_archivo_FS(EMUFS *emu)
364 char name_f_block_free[255];
366 strcpy(name_f_block_free,emu->nombre);
367 strcat(name_f_block_free,".fsc");
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);
373 fprintf(stderr,"BOQUES Y ESPACIO LIBRE\n");
374 fread(®,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(®,sizeof(reg),1,f_block_free);
380 fclose(f_block_free);
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");
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);
394 fclose(f_block_free);
399 int debug_ver_estadisticas(EMUFS* efs)
401 EMUFS_Estadisticas s = efs->leer_estadisticas(efs);
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",
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);
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)
432 /* Verifico que no existe un indice con el mismo nombre */
433 /* y que no exista un indice primario */
434 PERR("Agregando indice");
437 if (strcmp(tmp->nombre, nombre)==0) {
441 if ((funcion == IND_PRIMARIO) && (tmp->funcion == funcion)) {
451 PERR("Ya existe un indice con el mismo nombre!");
454 PERR("EMUFS ya tiene indice primario!!");
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);
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);
467 PERR("NO SE PUDO CREAR INDICE!!!");
472 if (emu->indices==NULL)
475 tmp->sig = emu->indices;
481 INDICE_DATO *emufs_buscar_registros(EMUFS *emu, char *indice, char *data, int *cant)
488 if (strcmp(tmp->nombre, indice) == 0) break;
493 PERR("NO EXISTE EL INDICE");
498 PERR("GENERANDO CLAVE")
500 k = emufs_indice_generar_clave_desde_valor(tmp, data);
502 return tmp->buscar_entradas(tmp, k, cant);
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)
509 int cant; /* cantidad de indices hasta el momento */
512 sprintf(filename, "%s.info", emu->nombre);
513 fp = fopen(filename, "r+");
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;
533 fseek(fp, SEEK_SET, 0);
535 fwrite(&cant, 1, sizeof(int), fp);
536 fwrite(indices, cant, sizeof(t_Indice), fp);
542 int cargar_indices(EMUFS *emu)
546 int cant, i; /* cantidad de indices hasta el momento */
549 sprintf(filename, "%s.info", emu->nombre);
550 fp = fopen(filename, "r");
559 fread(&cant, 1, sizeof(int), fp);
561 PERR("NO HAY INDICES EN ESTE ARCHIVO");
564 indices = malloc(cant*sizeof(t_Indice));
565 fread(indices, cant, sizeof(t_Indice), fp);
569 for(i=0; i<cant; i++) {
571 tmp = emufs_indice_abrir(emu,
575 indices[i].tipo_dato,
577 indices[i].tam_bloque,
578 indices[i].str_offset
580 PERR(indices[i].nombre);
581 if (emu->indices==NULL)
584 tmp->sig = emu->indices;
593 /*crea un bloque y devuelve en numero del mismo*/
594 EMUFS_BLOCK_ID emufs_create_new_block(EMUFS *emu)
601 /* obtengo nombre del archivo */
602 strcpy(name, emu->nombre);
605 if ( (fp=fopen(name,"a+")) == NULL ){
606 PERR("NO SE PUDO ABRIR EL ARCHIVO");
610 dummy = (char*)malloc(emu->tam_bloque);
611 memset(dummy, 0, emu->tam_bloque);
612 fwrite(dummy, emu->tam_bloque, 1, fp);
614 case T4: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE))/emu->tam_bloque;
616 case T5: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE)-sizeof(EMUFS_REG_SIZE))/emu->tam_bloque;
625 /*devuelve un numero de bloque siguiente al ultimo*/
626 EMUFS_BLOCK_ID emufs_get_new_block_number(EMUFS *emu)
630 EMUFS_BLOCK_ID num=0;
632 /* obtengo nombre del archivo */
633 strcpy(name, emu->nombre);
635 if ( (fp=fopen(name,"r")) == NULL ){
636 PERR("NO SE PUDO ABRIR EL ARCHIVO");
639 if ( fseek(fp, 0, SEEK_END)!=0 ){
640 PERR("NO PUDE HACER EL SEEK");
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;
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;
656 INDICE *emufs_buscar_indice_por_nombre(EMUFS *emu, const char *nombre)
662 if (strcmp(tmp->nombre, nombre) == 0) break;