Modularizo Lectura / Escritura de Nodos a disco

diff --git a/emufs/b_plus.c b/emufs/b_plus.c
index bb4e564e93feaa715bae715ec10227157bf37371..0e84bcd6df9a618c027bc8057ab2ddac68762192 100644 (file)
--- a/emufs/b_plus.c
+++ b/emufs/b_plus.c
@@ -2,11 +2,13 @@
 #include "b_plus.h"
 
 /* Private prototypes */
 #include "b_plus.h"
 
 /* Private prototypes */

+int b_plus_grabar_nodo(INDEXSPECS *idx, NODO_B_PLUS *nodo, int num_node);

 NODO_B_PLUS *b_plus_leer_nodo(INDEXSPECS *idx, int num_node);
 NODO_B_PLUS *b_plus_leer_nodo(INDEXSPECS *idx, int num_node);

-NODO_B_PLUS *emufs_b_plus_crearnodo(INDEXSPECS *idx);
+NODO_B_PLUS *b_plus_crearnodo(INDEXSPECS *idx);
+

 
 /** Crea un nuevo nodo y lo inicializa */
 
 /** Crea un nuevo nodo y lo inicializa */

-NODO_B_PLUS *emufs_b_plus_crearnodo(INDEXSPECS *idx) {
+NODO_B_PLUS *b_plus_crearnodo(INDEXSPECS *idx) {

        
        NODO_B_PLUS *nodo = (NODO_B_PLUS*)malloc(sizeof(NODO_B_PLUS));
        nodo->nivel = 0;
        
        NODO_B_PLUS *nodo = (NODO_B_PLUS*)malloc(sizeof(NODO_B_PLUS));
        nodo->nivel = 0;


@@ -26,29 +28,27 @@ int emufs_b_plus_crear(INDEXSPECS *idx) {
        
        FILE *fp;
        NODO_B_PLUS *raiz;
        
        FILE *fp;
        NODO_B_PLUS *raiz;

+       int error = 0;

                
        /* Creamos el archivo que contendra el indice */
        fp = fopen(idx->filename, "w");
                
        /* Creamos el archivo que contendra el indice */
        fp = fopen(idx->filename, "w");

-       PERR("Creando indice");
-       fprintf(stderr, "Archivo = (%s)\n", idx->filename);
+       PERR("Creando indice con nodo raiz");

        if (fp == NULL) {
                PERR("Error al crear el archivo");
                return -1;
        }
        if (fp == NULL) {
                PERR("Error al crear el archivo");
                return -1;
        }

+       fclose(fp);

        
        /* Creamos el nodo raiz y lo guardamos el en indice */
        
        /* Creamos el nodo raiz y lo guardamos el en indice */

-       raiz = emufs_b_plus_crearnodo(idx);
-       fwrite(raiz,SIZE_B_PLUS_HEADER,1,fp);
-       fwrite(raiz->claves,idx->size_claves,1,fp);
-       fwrite(raiz->hijos,idx->size_hijos,1,fp);
-       fclose(fp);
+       raiz = b_plus_crearnodo(idx);
+       error = b_plus_grabar_nodo(idx,raiz,0);

        
        /* Liberamos areas de memoria reservadas */
        free(raiz->claves);
        free(raiz->hijos);
        free(raiz);
        
        
        /* Liberamos areas de memoria reservadas */
        free(raiz->claves);
        free(raiz->hijos);
        free(raiz);
        

-       return 0;
+       return error;

 }
 
 /** Busca el nro de bloque donde se debe guardar un reg con clave X */
 }
 
 /** Busca el nro de bloque donde se debe guardar un reg con clave X */


@@ -57,7 +57,7 @@ int emufs_b_plus_get_bloque(INDEXSPECS *idx, INDEX_DAT *query) {
     NODO_B_PLUS *curnode;
        
        /* Comienzo leyendo la raiz, entry point de toda funcion */
     NODO_B_PLUS *curnode;
        
        /* Comienzo leyendo la raiz, entry point de toda funcion */

-       printf ("Buscando donde insertar clave: %i\n",query->clave.i_clave);
+       printf ("Buscando donde insertar clave: %i\n\n",query->clave.i_clave);

        curnode = b_plus_leer_nodo(idx,0);      
        if (curnode == NULL) return -1;
        
        curnode = b_plus_leer_nodo(idx,0);      
        if (curnode == NULL) return -1;
        


@@ -67,6 +67,8 @@ int emufs_b_plus_get_bloque(INDEXSPECS *idx, INDEX_DAT *query) {
                
        }
        
                
        }
        

+       free(curnode);
+       

        return 0;
 }
 
        return 0;
 }
 


@@ -74,14 +76,14 @@ NODO_B_PLUS *b_plus_leer_nodo(INDEXSPECS *idx, int num_node) {
 
        int i = 0;
        FILE *fp;
 
        int i = 0;
        FILE *fp;

-       NODO_B_PLUS *memnode = (NODO_B_PLUS*)malloc(sizeof(NODO_B_PLUS));
-       char *disknode = (char*)malloc(sizeof(idx->tam_bloque));
+       NODO_B_PLUS *memnode = b_plus_crearnodo(idx);   
+       char *disknode = (char*)malloc(idx->tam_bloque);

        
        if (disknode == NULL) return NULL;
        if (memnode == NULL) return NULL;
        
     /* Open up file */
        
        if (disknode == NULL) return NULL;
        if (memnode == NULL) return NULL;
        
     /* Open up file */

-       fp = fopen(idx->filename, "r");
+       fp = fopen(idx->filename, "r+");

        if (fp == NULL) {
                free(disknode);
                free(memnode);
        if (fp == NULL) {
                free(disknode);
                free(memnode);


@@ -100,10 +102,10 @@ NODO_B_PLUS *b_plus_leer_nodo(INDEXSPECS *idx, int num_node) {
        /* Pudimos leer un nodo de disco, ahora lo transformamos a nodo mem */
        memcpy(memnode,disknode,SIZE_B_PLUS_HEADER);
        memcpy(memnode->claves,disknode+SIZE_B_PLUS_HEADER,idx->size_claves);
        /* Pudimos leer un nodo de disco, ahora lo transformamos a nodo mem */
        memcpy(memnode,disknode,SIZE_B_PLUS_HEADER);
        memcpy(memnode->claves,disknode+SIZE_B_PLUS_HEADER,idx->size_claves);

-       memcpy(memnode->hijos,disknode+SIZE_B_PLUS_HEADER,idx->size_hijos);
+       memcpy(memnode->hijos,disknode+SIZE_B_PLUS_HEADER+idx->size_claves,idx->size_hijos);

        free(disknode);
        
        free(disknode);
        

-       printf("Dumping nodo leido...\n");
+       printf("Dumping Node_%i\n",num_node);

        printf("Nivel: %i  Cant Claves: %i\n",memnode->nivel,memnode->cant_claves);
        printf("Claves:");
        for (i = 0; i < idx->size_claves/sizeof(int); ++i) printf(" %i",memnode->claves[i]);
        printf("Nivel: %i  Cant Claves: %i\n",memnode->nivel,memnode->cant_claves);
        printf("Claves:");
        for (i = 0; i < idx->size_claves/sizeof(int); ++i) printf(" %i",memnode->claves[i]);


@@ -114,3 +116,19 @@ NODO_B_PLUS *b_plus_leer_nodo(INDEXSPECS *idx, int num_node) {
        return memnode;
        
 }
        return memnode;
        
 }

+
+int b_plus_grabar_nodo(INDEXSPECS *idx, NODO_B_PLUS *nodo, int num_node)
+{
+       FILE *fp;
+       
+       fp = fopen(idx->filename, "r+");
+       if (fp == NULL) return -1;
+               
+       fseek(fp,num_node*sizeof(NODO_B_PLUS),SEEK_SET);        
+       fwrite(nodo,SIZE_B_PLUS_HEADER,1,fp);
+       fwrite(nodo->claves,idx->size_claves,1,fp);
+       fwrite(nodo->hijos,idx->size_hijos,1,fp);
+       fclose(fp);
+       
+       return 0;
+}

diff --git a/emufs/b_plus_test.c b/emufs/b_plus_test.c
index 8680d73461c75ab32d70b16cf1c1c7b26dacc3f8..996603b0be9e46a33a5072c409b3ba125495ea79 100644 (file)
--- a/emufs/b_plus_test.c
+++ b/emufs/b_plus_test.c
@@ -12,6 +12,7 @@ indice.tam_bloque = SIZE_B_PLUS_HEADER + sizeof(int)*4 + sizeof(int)*5;
 indice.size_claves = (indice.tam_bloque - SIZE_B_PLUS_HEADER - sizeof(int))/2;
 indice.size_hijos = indice.size_claves + sizeof(int);
 indice.filename = "idxbplus_primary.idx";
 indice.size_claves = (indice.tam_bloque - SIZE_B_PLUS_HEADER - sizeof(int))/2;
 indice.size_hijos = indice.size_claves + sizeof(int);
 indice.filename = "idxbplus_primary.idx";

+printf("\nTam Nodo: %i  Size Claves: %i  Size_Hijos: %i\n",indice.tam_bloque,indice.size_claves,indice.size_hijos);

 emufs_b_plus_crear(&indice);
        
 /* Pedimos al arbol el nro de bloque donde guardar la clave 5. Should */
 emufs_b_plus_crear(&indice);
        
 /* Pedimos al arbol el nro de bloque donde guardar la clave 5. Should */