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;
351 fprintf(stderr, "INDICE A ELIMINAR = %s\n", del->nombre);
353 emufs_indice_destruir(e, del);
361 int ver_archivo_FS(EMUFS *emu)
365 char name_f_block_free[255];
367 strcpy(name_f_block_free,emu->nombre);
368 strcat(name_f_block_free,".fsc");
370 if ( (f_block_free = fopen(name_f_block_free,"r"))==NULL ){
371 fprintf(stderr, "no pude abrir el archivo %s\n",name_f_block_free);
374 fprintf(stderr,"BOQUES Y ESPACIO LIBRE\n");
375 fread(®,sizeof(reg),1,f_block_free);
376 while ( !feof(f_block_free) ){
377 fprintf(stderr, "Bloque = %li Espacio libre = %li\n",reg.marker, reg.freespace);
378 fread(®,sizeof(reg),1,f_block_free);
381 fclose(f_block_free);
383 /* Imprimo la lista de bloques/registros */
384 fprintf(stderr, "BLOQUES Y REGISTROS\n");
385 strcpy(name_f_block_free,emu->nombre);
386 strcat(name_f_block_free,".idx");
387 f_block_free = fopen(name_f_block_free, "r");
390 while (!feof(f_block_free)) {
391 if (fread(&r, sizeof(EMUFS_IDX), 1, f_block_free) != 1) continue;
392 fprintf(stderr, "ID %li en bloque %li\n", r.id_reg, r.location);
395 fclose(f_block_free);
400 int debug_ver_estadisticas(EMUFS* efs)
402 EMUFS_Estadisticas s = efs->leer_estadisticas(efs);
404 printf("ESTADISTICAS:\n");
405 printf("=============\n");
406 printf("Tamaño del archivo: %lu bytes\n", s.tam_archivo);
407 printf("Tamaño de datos (incluye espacio libre): %lu bytes (%.2f %%)\n",
408 s.tam_archivo - s.tam_info_control_dat,
409 (s.tam_archivo - s.tam_info_control_dat) * 100.0
410 / (float) s.tam_archivo);
411 printf("Tamaño de info de control total: %lu bytes (%.2f %%)\n",
412 s.tam_info_control_dat + s.tam_archivos_aux,
413 (s.tam_info_control_dat + s.tam_archivos_aux) * 100.0
414 / (float) s.tam_archivo);
415 printf("Tamaño de los archivos auxiliares: %lu bytes\n",
417 printf("Tamaño de la información de control en el .dat: %lu bytes\n",
418 s.tam_info_control_dat);
419 printf("Total de espacio libre: %lu bytes\n", s.total_fs);
420 printf("Máximo espacio libre en bloque: %lu bytes\n", s.max_fs);
421 printf("Mínimo espacio libre en bloque: %lu bytes\n", s.min_fs);
422 printf("Media del espacio libre por bloque: %lu bytes\n", s.media_fs);
423 printf("Cantidad de registros: %lu\n", s.cant_registros);
424 printf("Cantidad de bloques: %lu\n", s.cant_bloques);
428 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)
433 /* Verifico que no existe un indice con el mismo nombre */
434 /* y que no exista un indice primario */
435 PERR("Agregando indice");
438 if (strcmp(tmp->nombre, nombre)==0) {
442 if ((funcion == IND_PRIMARIO) && (tmp->funcion == funcion)) {
452 PERR("Ya existe un indice con el mismo nombre!");
455 PERR("EMUFS ya tiene indice primario!!");
460 /* Creo el nuevo indice */
461 PERR("Creando indice\n");
462 tmp = emufs_indice_crear(emu, nombre, funcion, tipo, tipo_dato, offset, tam_bloque, str_offset);
464 /* Guardo la info del indice para poder abrir despues el archivo */
465 guardar_indice(emu, nombre, funcion, tipo, tipo_dato, offset, tam_bloque, str_offset);
468 PERR("NO SE PUDO CREAR INDICE!!!");
473 if (emu->indices==NULL)
476 tmp->sig = emu->indices;
482 INDICE_DATO *emufs_buscar_registros(EMUFS *emu, char *indice, char *data, int *cant)
489 if (strcmp(tmp->nombre, indice) == 0) break;
494 PERR("NO EXISTE EL INDICE");
499 PERR("GENERANDO CLAVE")
501 k = emufs_indice_generar_clave_desde_valor(tmp, data);
503 return tmp->buscar_entradas(tmp, k, cant);
506 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)
510 int cant; /* cantidad de indices hasta el momento */
513 sprintf(filename, "%s.info", emu->nombre);
514 fp = fopen(filename, "r+");
522 fread(&cant, 1, sizeof(int), fp);
523 indices = malloc((cant+1)*sizeof(t_Indice));
524 fread(indices, cant, sizeof(t_Indice), fp);
525 memset(indices[cant].nombre, 0, 50);
526 strcpy(indices[cant].nombre, nombre);
527 indices[cant].funcion = funcion;
528 indices[cant].tipo = tipo;
529 indices[cant].tipo_dato = tipo_dato;
530 indices[cant].offset = offset;
531 indices[cant].tam_bloque = tam_bloque;
532 indices[cant].str_offset = str_offset;
534 fseek(fp, SEEK_SET, 0);
536 fwrite(&cant, 1, sizeof(int), fp);
537 fwrite(indices, cant, sizeof(t_Indice), fp);
543 int cargar_indices(EMUFS *emu)
547 int cant, i; /* cantidad de indices hasta el momento */
550 sprintf(filename, "%s.info", emu->nombre);
551 fp = fopen(filename, "r");
560 fread(&cant, 1, sizeof(int), fp);
562 PERR("NO HAY INDICES EN ESTE ARCHIVO");
565 indices = malloc(cant*sizeof(t_Indice));
566 fread(indices, cant, sizeof(t_Indice), fp);
570 for(i=0; i<cant; i++) {
572 tmp = emufs_indice_abrir(emu,
576 indices[i].tipo_dato,
578 indices[i].tam_bloque,
579 indices[i].str_offset
581 PERR(indices[i].nombre);
582 if (emu->indices==NULL)
585 tmp->sig = emu->indices;
594 /*crea un bloque y devuelve en numero del mismo*/
595 EMUFS_BLOCK_ID emufs_create_new_block(EMUFS *emu)
602 /* obtengo nombre del archivo */
603 strcpy(name, emu->nombre);
606 if ( (fp=fopen(name,"a+")) == NULL ){
607 PERR("NO SE PUDO ABRIR EL ARCHIVO");
611 dummy = (char*)malloc(emu->tam_bloque);
612 memset(dummy, 0, emu->tam_bloque);
613 fwrite(dummy, emu->tam_bloque, 1, fp);
615 case T4: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE))/emu->tam_bloque;
617 case T5: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE)-sizeof(EMUFS_REG_SIZE))/emu->tam_bloque;
626 /*devuelve un numero de bloque siguiente al ultimo*/
627 EMUFS_BLOCK_ID emufs_get_new_block_number(EMUFS *emu)
631 EMUFS_BLOCK_ID num=0;
633 /* obtengo nombre del archivo */
634 strcpy(name, emu->nombre);
636 if ( (fp=fopen(name,"r")) == NULL ){
637 PERR("NO SE PUDO ABRIR EL ARCHIVO");
640 if ( fseek(fp, 0, SEEK_END)!=0 ){
641 PERR("NO PUDE HACER EL SEEK");
645 case T4: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE))/emu->tam_bloque;
646 if (ftell(fp) == sizeof(EMUFS_Tipo)+sizeof(EMUFS_BLOCK_SIZE)) num = 0;
648 case T5: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE)-sizeof(EMUFS_REG_SIZE))/emu->tam_bloque;
649 if (ftell(fp) == sizeof(EMUFS_Tipo)+sizeof(EMUFS_BLOCK_SIZE)+sizeof(EMUFS_REG_SIZE)) num = 0;
657 INDICE *emufs_buscar_indice_por_nombre(EMUFS *emu, const char *nombre)
663 if (strcmp(tmp->nombre, nombre) == 0) break;