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;
348 emufs_indice_destruir(e, cur);
356 int ver_archivo_FS(EMUFS *emu)
360 char name_f_block_free[255];
362 strcpy(name_f_block_free,emu->nombre);
363 strcat(name_f_block_free,".fsc");
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);
369 fprintf(stderr,"BOQUES Y ESPACIO LIBRE\n");
370 fread(®,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(®,sizeof(reg),1,f_block_free);
376 fclose(f_block_free);
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");
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);
390 fclose(f_block_free);
395 int debug_ver_estadisticas(EMUFS* efs)
397 EMUFS_Estadisticas s = efs->leer_estadisticas(efs);
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",
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);
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)
428 /* Verifico que no existe un indice con el mismo nombre */
429 /* y que no exista un indice primario */
430 PERR("Agregando indice");
433 if (strcmp(tmp->nombre, nombre)==0) {
437 if ((funcion == IND_PRIMARIO) && (tmp->funcion == funcion)) {
447 PERR("Ya existe un indice con el mismo nombre!");
450 PERR("EMUFS ya tiene indice primario!!");
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);
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);
463 PERR("NO SE PUDO CREAR INDICE!!!");
467 if (emu->indices==NULL)
470 tmp->sig = emu->indices;
476 INDICE_DATO *emufs_buscar_registros(EMUFS *emu, char *indice, char *data, int *cant)
483 if (strcmp(tmp->nombre, indice) == 0) break;
488 PERR("NO EXISTE EL INDICE");
493 PERR("GENERANDO CLAVE")
495 k = emufs_indice_generar_clave_desde_valor(tmp, data);
497 return tmp->buscar_entradas(tmp, k, cant);
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)
504 int cant; /* cantidad de indices hasta el momento */
507 sprintf(filename, "%s.info", emu->nombre);
508 fp = fopen(filename, "r+");
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;
528 fseek(fp, SEEK_SET, 0);
530 fwrite(&cant, 1, sizeof(int), fp);
531 fwrite(indices, cant, sizeof(t_Indice), fp);
537 int cargar_indices(EMUFS *emu)
541 int cant, i; /* cantidad de indices hasta el momento */
544 sprintf(filename, "%s.info", emu->nombre);
545 fp = fopen(filename, "r");
553 fread(&cant, 1, sizeof(int), fp);
554 indices = malloc(cant*sizeof(t_Indice));
555 fread(indices, cant, sizeof(t_Indice), fp);
560 for(i=cant-1; i>=0; i++) {
562 tmp = emufs_indice_abrir(emu,
566 indices[i].tipo_dato,
568 indices[i].tam_bloque,
569 indices[i].str_offset
571 tmp->sig = emu->indices;
579 /*crea un bloque y devuelve en numero del mismo*/
580 EMUFS_BLOCK_ID emufs_create_new_block(EMUFS *emu)
587 /* obtengo nombre del archivo */
588 strcpy(name, emu->nombre);
591 if ( (fp=fopen(name,"a+")) == NULL ){
592 PERR("NO SE PUDO ABRIR EL ARCHIVO");
596 dummy = (char*)malloc(emu->tam_bloque);
597 memset(dummy, 0, emu->tam_bloque);
598 fwrite(dummy, emu->tam_bloque, 1, fp);
600 case T4: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE))/emu->tam_bloque;
602 case T5: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE)-sizeof(EMUFS_REG_SIZE))/emu->tam_bloque;
611 /*devuelve un numero de bloque siguiente al ultimo*/
612 EMUFS_BLOCK_ID emufs_get_new_block_number(EMUFS *emu)
616 EMUFS_BLOCK_ID num=0;
618 /* obtengo nombre del archivo */
619 strcpy(name, emu->nombre);
621 if ( (fp=fopen(name,"r")) == NULL ){
622 PERR("NO SE PUDO ABRIR EL ARCHIVO");
625 if ( fseek(fp, 0, SEEK_END)!=0 ){
626 PERR("NO PUDE HACER EL SEEK");
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;
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;
642 INDICE *emufs_buscar_indice_por_nombre(EMUFS *emu, const char *nombre)
648 if (strcmp(tmp->nombre, nombre) == 0) break;