Algunos detalles de coding style y pruebas de stats.

[z.facultad/75.06/emufs.git] / emufs / tipo3.c

diff --git a/emufs/tipo3.c b/emufs/tipo3.c
index 97752e75ad4b8340a0208a48f5561babeb1d6215..eb7bbf14725747d730dca9cb7f2d1bfec8f2b0ad 100644 (file)
--- a/emufs/tipo3.c
+++ b/emufs/tipo3.c
@@ -36,8 +36,9 @@
  */
 
 #include "tipo3.h"
  */
 
 #include "tipo3.h"

+#include "error.h"
+#include "common.h"

 #include <unistd.h>
 #include <unistd.h>

-#include <sys/types.h>

 #include <stdio.h>
 #include <string.h>
 
 #include <stdio.h>
 #include <string.h>
 


@@ -64,9 +65,8 @@ void* emufs_tipo3_leer_registro(EMUFS *emu, EMUFS_REG_ID ID,
        
        registro = (char*) malloc(emu->tam_reg);
        if (registro == NULL) {
        
        registro = (char*) malloc(emu->tam_reg);
        if (registro == NULL) {

-               /* TODO Manejo de errores */

                PERR("No hay memoria");
                PERR("No hay memoria");

-               *err = 2; /* EMUFS_ERROR_OUT_OF_MEMORY */
+               *err = EMUFS_ERROR_OUT_OF_MEMORY;

                return NULL;
        }
 
                return NULL;
        }
 


@@ -116,8 +116,8 @@ void* emufs_tipo3_leer_bloque(EMUFS *emu, EMUFS_BLOCK_ID ID, int* err)
        
        if ((file = fopen(name_f, "r")) == NULL) {
                PERR("No se pudo abrir el archivo de datos");
        
        if ((file = fopen(name_f, "r")) == NULL) {
                PERR("No se pudo abrir el archivo de datos");

-               *err = 4; /* EMUFS_ERROR_CANT_OPEN_FILE */
-               return NULL; /* FIXME ERROR */
+               *err = EMUFS_ERROR_CANT_OPEN_FILE;
+               return NULL;

        }
        fseek(file,sizeof(EMUFS_Tipo)+sizeof(EMUFS_BLOCK_SIZE)+sizeof(EMUFS_REG_SIZE),SEEK_SET);
        /*FIXME: verificar que no se pase de fin de archivo*/
        }
        fseek(file,sizeof(EMUFS_Tipo)+sizeof(EMUFS_BLOCK_SIZE)+sizeof(EMUFS_REG_SIZE),SEEK_SET);
        /*FIXME: verificar que no se pase de fin de archivo*/


@@ -129,16 +129,15 @@ void* emufs_tipo3_leer_bloque(EMUFS *emu, EMUFS_BLOCK_ID ID, int* err)
        
        block = (char*) malloc(emu->tam_bloque);
        if (block == NULL) {
        
        block = (char*) malloc(emu->tam_bloque);
        if (block == NULL) {

-               /* TODO Manejo de errores */

                PERR("No hay memoria");
                PERR("No hay memoria");

-               *err = 2; /* EMUFS_ERROR_OUT_OF_MEMORY */
+               *err = EMUFS_ERROR_OUT_OF_MEMORY;

                return NULL;
        }
        if (fread(block, emu->tam_bloque, 1, file) != 1) {
                /* TODO Manejo de errores */
                free(block);
                PERR("Error al leer bloque");
                return NULL;
        }
        if (fread(block, emu->tam_bloque, 1, file) != 1) {
                /* TODO Manejo de errores */
                free(block);
                PERR("Error al leer bloque");

-               *err = 3; /* EMUFS_ERROR_FILE_READ */
+               *err = EMUFS_ERROR_FILE_READ;

                return NULL;
        }
 
                return NULL;
        }
 


@@ -192,7 +191,6 @@ EMUFS_REG_ID emufs_tipo3_grabar_registro(EMUFS *emu, void *ptr, EMUFS_REG_SIZE t
                        fseek(file, 0, SEEK_END);
                        /* grabo el bloque en el final del archivo */
                        fwrite(bloque,emu->tam_bloque,1,file);
                        fseek(file, 0, SEEK_END);
                        /* grabo el bloque en el final del archivo */
                        fwrite(bloque,emu->tam_bloque,1,file);

-                       /*actualizo el archivo de espacios libres*/

                        /*tengo que buscar la cantidad de bloques que existen*/
                        fseek(file, 0, SEEK_END); /* Me paro al final */
                        cant = (ftell(file)-(sizeof(EMUFS_Tipo)+sizeof(EMUFS_REG_SIZE)+sizeof(EMUFS_BLOCK_SIZE))) / emu->tam_bloque;
                        /*tengo que buscar la cantidad de bloques que existen*/
                        fseek(file, 0, SEEK_END); /* Me paro al final */
                        cant = (ftell(file)-(sizeof(EMUFS_Tipo)+sizeof(EMUFS_REG_SIZE)+sizeof(EMUFS_BLOCK_SIZE))) / emu->tam_bloque;


@@ -214,7 +212,6 @@ EMUFS_REG_ID emufs_tipo3_grabar_registro(EMUFS *emu, void *ptr, EMUFS_REG_SIZE t
                                free(bloque);
                                return -1;
                        }
                                free(bloque);
                                return -1;
                        }

-                               

                }
                fclose(file);
        } else {
                }
                fclose(file);
        } else {


@@ -350,16 +347,32 @@ int emufs_tipo3_borrar_registro(EMUFS *emu, EMUFS_REG_ID ID)
        /*actualizo archivo .fsc*/
        if ( emu->tam_bloque < emu->tam_reg ) {
                for (i=0; i<emu->tam_reg/(emu->tam_bloque-sizeof(EMUFS_REG_ID))+1; i++)
        /*actualizo archivo .fsc*/
        if ( emu->tam_bloque < emu->tam_reg ) {
                for (i=0; i<emu->tam_reg/(emu->tam_bloque-sizeof(EMUFS_REG_ID))+1; i++)

-                       if ( emufs_fsc_agregar(emu, num_bloque+i, emu->tam_bloque) != 0 ) return -1;
+                       if (emufs_fsc_agregar(emu, num_bloque+i, emu->tam_bloque)) {
+                               PERR("no se pudo agregar fsc"); 
+                               free(bloque);
+                               return -1;
+                       }

        } else { 
                fs = emufs_fsc_get_fs(emu, num_bloque);
        } else { 
                fs = emufs_fsc_get_fs(emu, num_bloque);

-               if ( emufs_fsc_agregar(emu, num_bloque, fs + emu->tam_reg + sizeof(EMUFS_REG_ID)) != 0 ) return -1;
+               if (emufs_fsc_agregar(emu, num_bloque, fs + emu->tam_reg + sizeof(EMUFS_REG_ID))) {
+                       PERR("no se pudo agregar fsc"); 
+                       free(bloque);
+                       return -1;
+               }

        }
        /*actualizo archivo .did*/
        }
        /*actualizo archivo .did*/

-       if ( emufs_did_agregar(emu, ID) != 0 ) return -1;
+       if (emufs_did_agregar(emu, ID)) {
+               PERR("no se pudo agregar did"); 
+               free(bloque);
+               return -1;
+       }

                
        /*actualizo archivo .idx*/
                
        /*actualizo archivo .idx*/

-       if ( emufs_idx_borrar(emu, ID) != 0 ) return -1; 
+       if (emufs_idx_borrar(emu, ID)) {
+               PERR("no se pudo agregar idx"); 
+               free(bloque);
+               return -1;
+       }

 
        free(bloque);
        return 0;
 
        free(bloque);
        return 0;


@@ -367,33 +380,48 @@ int emufs_tipo3_borrar_registro(EMUFS *emu, EMUFS_REG_ID ID)
 
 EMUFS_Estadisticas emufs_tipo3_leer_estadisticas(EMUFS *emu)
 {
 
 EMUFS_Estadisticas emufs_tipo3_leer_estadisticas(EMUFS *emu)
 {

-       FILE *f;
+       int err = 0,err1 = 0, err2 = 0, err3 = 0;

        EMUFS_Estadisticas stats;
        EMUFS_Estadisticas stats;

-       EMUFS_REG_ID *tmp;
-       char name_f[255];
-

        memset(&stats,0,sizeof(EMUFS_Estadisticas));
        memset(&stats,0,sizeof(EMUFS_Estadisticas));

-       strcpy(name_f,emu->nombre);
-       strcat(name_f,".dat");
-       if ( (f = fopen(name_f,"r")) == NULL){
-                       PERR("No se pudo abrir el archivo");
-                       return stats;   
+       
+       { /* obtengo tamaño del archivo en bytes */
+               char name_f[255];
+               strcpy(name_f, emu->nombre);
+               strcat(name_f, ".dat");
+               stats.tam_archivo = emufs_common_get_file_size(name_f, &err);
+               if (err) {
+                       PERR("no se pudo obtener el tamaño del archivo");
+                       return stats;
+               }

        }
        
        }
        

-       fseek(f,0,SEEK_END);
-       stats.tam_archivo_bytes = ftell(f);
-       stats.cant_bloques =(stats.tam_archivo_bytes-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE)-sizeof(EMUFS_REG_SIZE))/
-                                                emu->tam_bloque;
-       tmp = emufs_idx_get(emu, &stats.tam_archivo);
-       if (tmp) free(tmp);
-               stats.info_control=stats.tam_archivo*sizeof(EMUFS_REG_ID)+sizeof(EMUFS_Tipo)+
-                                               sizeof(EMUFS_BLOCK_SIZE)+sizeof(EMUFS_REG_SIZE);
+       /* obtengo la cantidad de bloques en el archivo */
+       stats.cant_bloques = (stats.tam_archivo-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE)-sizeof(EMUFS_REG_SIZE))/
+                                                 emu->tam_bloque;
+
+       /* obtengo la cantidad de registros en el archivo */
+       {
+               EMUFS_REG_ID *tmp = emufs_idx_get(emu, &stats.cant_registros);
+               if (tmp) free(tmp); /* libera memoria innecesaria */
+       }
+
+       /* obtengo información de control que guarda el archivo .dat */
+       stats.tam_info_control_dat = stats.cant_registros*sizeof(EMUFS_REG_ID)+sizeof(EMUFS_Tipo)+
+                                                sizeof(EMUFS_BLOCK_SIZE)+sizeof(EMUFS_REG_SIZE);
+

        /* Obtengo las stats de FSC */
        stats.total_fs = emufs_fsc_get_total_fs(emu);
        stats.media_fs = emufs_fsc_get_media_fs(emu);
        emufs_fsc_get_max_min_fs(emu,&stats.min_fs,&stats.max_fs);
        /* Obtengo las stats de FSC */
        stats.total_fs = emufs_fsc_get_total_fs(emu);
        stats.media_fs = emufs_fsc_get_media_fs(emu);
        emufs_fsc_get_max_min_fs(emu,&stats.min_fs,&stats.max_fs);

+       
+       /* obtengo informacion de control guardada por los archivos auxiliares */
+       stats.tam_archivos_aux = emufs_idx_get_file_size(emu,&err1) + emufs_fsc_get_file_size(emu,&err2)
+                                                       + emufs_did_get_file_size(emu,&err3);
+       if (err1 || err2 || err3) {
+               PERR("Hubo problemas en lectura de filesize archivos auxiliares");
+               return stats;
+       }               

 
 

-       fclose(f);

        return stats;   
 }
 
        return stats;   
 }
 


@@ -496,9 +524,6 @@ void emufs_tipo3_compactar(EMUFS *emu)
        
        strcpy(name, emu->nombre);
        strcat(name, ".dat");
        
        strcpy(name, emu->nombre);
        strcat(name, ".dat");

-       
-       /* si el bloque es mas chico que el registro no hace falta compactar */
-       /*if( emu->tam_reg-sizeof(EMUFS_REG_ID) > emu->tam_bloque ) return;     */

 
        tmp = emufs_idx_get(emu, &max_id);
        if (tmp) free(tmp);
 
        tmp = emufs_idx_get(emu, &max_id);
        if (tmp) free(tmp);


@@ -513,7 +538,6 @@ void emufs_tipo3_compactar(EMUFS *emu)
                emufs_tipo3_borrar_registro(emu, i);
                ID_aux = emufs_tipo3_grabar_registro(emu, reg, emu->tam_reg, &err);
                free(reg);
                emufs_tipo3_borrar_registro(emu, i);
                ID_aux = emufs_tipo3_grabar_registro(emu, reg, emu->tam_reg, &err);
                free(reg);

-               i++;

        }
        /*tengo que truncar el archivo*/
        /*bloques_vacios = emufs_fsc_get_cant_bloques_vacios(emu)-1;
        }
        /*tengo que truncar el archivo*/
        /*bloques_vacios = emufs_fsc_get_cant_bloques_vacios(emu)-1;


@@ -527,3 +551,21 @@ void emufs_tipo3_compactar(EMUFS *emu)
        if (emufs_fsc_truncate(emu, block_id)!= 0)
                PERR("NO TURNQUE EL FSC");
 }
        if (emufs_fsc_truncate(emu, block_id)!= 0)
                PERR("NO TURNQUE EL FSC");
 }

+
+void emufs_tipo3_leer_bloque_raw(EMUFS *efs, EMUFS_BLOCK_ID id, char **actual, char **anterior, char **siguiente,
+                                                                EMUFS_BLOCK_SIZE *size1, EMUFS_BLOCK_SIZE *size2, EMUFS_BLOCK_SIZE *size3)
+{
+       int err;
+       (*actual) = emufs_tipo3_leer_bloque(efs, id, &err);
+       (*anterior) = emufs_tipo3_leer_bloque(efs, id-1, &err);
+       (*siguiente) = emufs_tipo3_leer_bloque(efs, id+1, &err);
+       if (!(*anterior)) {
+               (*anterior) = (char *)malloc(efs->tam_bloque);
+               memset(*anterior, 0, efs->tam_bloque);          
+       }       
+       if (!(*siguiente)) {
+               (*siguiente) = (char *)malloc(efs->tam_bloque);
+               memset(*siguiente, 0, efs->tam_bloque);         
+       }
+       (*size1) = (*size2) = (*size3) = efs->tam_bloque;
+}