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)) {
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)) {
283 /* Asigna punteros a funciones. */
284 if ((err = emufs_tipo1_inicializar(efs))) {
285 PERR("No se pudo inicializar el EMUFS de tipo1");
291 /* Asigna punteros a funciones. */
292 emufs_tipo2_inicializar(efs);
295 if ((!fread(&(efs->tam_bloque), sizeof(EMUFS_BLOCK_SIZE), 1, fp)) ||
296 (!fread(&(efs->tam_reg), sizeof(EMUFS_REG_SIZE), 1, fp)))
303 /* Asigna punteros a funciones. */
304 emufs_tipo3_inicializar(efs);
308 /* Lee cabeceras propias. */
309 if (!fread(&(efs->tam_bloque), sizeof(EMUFS_BLOCK_SIZE), 1, fp)) {
315 emufs_tipo4_inicializar(efs);
319 if ((!fread(&(efs->tam_bloque), sizeof(EMUFS_BLOCK_SIZE), 1, fp)) ||
320 (!fread(&(efs->tam_reg), sizeof(EMUFS_REG_SIZE), 1, fp)))
327 /* Asigna punteros a funciones. */
328 emufs_tipo5_inicializar(efs);
331 /* finalmente cargo la data de los indices */
337 int emufs_destruir(EMUFS *e)
341 if (e == NULL) return 1;
347 fprintf(stderr, "INDICE A ELIMINAR = %s\n", del->nombre);
349 emufs_indice_destruir(e, del);
357 int ver_archivo_FS(EMUFS *emu)
361 char name_f_block_free[255];
363 strcpy(name_f_block_free,emu->nombre);
364 strcat(name_f_block_free,".fsc");
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);
370 fprintf(stderr,"BOQUES Y ESPACIO LIBRE\n");
371 fread(®,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(®,sizeof(reg),1,f_block_free);
377 fclose(f_block_free);
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");
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);
391 fclose(f_block_free);
396 int debug_ver_estadisticas(EMUFS* efs)
398 EMUFS_Estadisticas s = efs->leer_estadisticas(efs);
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",
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);
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)
429 /* Verifico que no existe un indice con el mismo nombre */
430 /* y que no exista un indice primario */
431 PERR("Agregando indice");
434 if (strcmp(tmp->nombre, nombre)==0) {
438 if ((funcion == IND_PRIMARIO) && (tmp->funcion == funcion)) {
448 PERR("Ya existe un indice con el mismo nombre!");
451 PERR("EMUFS ya tiene indice primario!!");
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);
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);
464 PERR("NO SE PUDO CREAR INDICE!!!");
469 if (emu->indices==NULL)
472 tmp->sig = emu->indices;
478 INDICE_DATO *emufs_buscar_registros(EMUFS *emu, char *indice, char *data, int *cant)
485 if (strcmp(tmp->nombre, indice) == 0) break;
490 PERR("NO EXISTE EL INDICE");
495 PERR("GENERANDO CLAVE")
497 k = emufs_indice_generar_clave_desde_valor(tmp, data);
499 return tmp->buscar_entradas(tmp, k, cant);
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)
506 int cant; /* cantidad de indices hasta el momento */
509 sprintf(filename, "%s.info", emu->nombre);
510 fp = fopen(filename, "r+");
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;
530 fseek(fp, SEEK_SET, 0);
532 fwrite(&cant, 1, sizeof(int), fp);
533 fwrite(indices, cant, sizeof(t_Indice), fp);
539 int cargar_indices(EMUFS *emu)
543 int cant, i; /* cantidad de indices hasta el momento */
546 sprintf(filename, "%s.info", emu->nombre);
547 fp = fopen(filename, "r");
556 fread(&cant, 1, sizeof(int), fp);
558 PERR("NO HAY INDICES EN ESTE ARCHIVO");
561 indices = malloc(cant*sizeof(t_Indice));
562 fread(indices, cant, sizeof(t_Indice), fp);
566 for(i=0; i<cant; i++) {
568 tmp = emufs_indice_abrir(emu,
572 indices[i].tipo_dato,
574 indices[i].tam_bloque,
575 indices[i].str_offset
577 PERR(indices[i].nombre);
578 if (emu->indices==NULL)
581 tmp->sig = emu->indices;
590 /*crea un bloque y devuelve en numero del mismo*/
591 EMUFS_BLOCK_ID emufs_create_new_block(EMUFS *emu)
598 /* obtengo nombre del archivo */
599 strcpy(name, emu->nombre);
602 if ( (fp=fopen(name,"a+")) == NULL ){
603 PERR("NO SE PUDO ABRIR EL ARCHIVO");
607 dummy = (char*)malloc(emu->tam_bloque);
608 memset(dummy, 0, emu->tam_bloque);
609 fwrite(dummy, emu->tam_bloque, 1, fp);
611 case T4: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE))/emu->tam_bloque;
613 case T5: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE)-sizeof(EMUFS_REG_SIZE))/emu->tam_bloque;
622 /*devuelve un numero de bloque siguiente al ultimo*/
623 EMUFS_BLOCK_ID emufs_get_new_block_number(EMUFS *emu)
627 EMUFS_BLOCK_ID num=0;
629 /* obtengo nombre del archivo */
630 strcpy(name, emu->nombre);
632 if ( (fp=fopen(name,"r")) == NULL ){
633 PERR("NO SE PUDO ABRIR EL ARCHIVO");
636 if ( fseek(fp, 0, SEEK_END)!=0 ){
637 PERR("NO PUDE HACER EL SEEK");
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;
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;
653 INDICE *emufs_buscar_indice_por_nombre(EMUFS *emu, const char *nombre)
659 if (strcmp(tmp->nombre, nombre) == 0) break;