Agrego un TODO para convertir (o compartir) B a B*.

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

diff --git a/emufs/b_plus.c b/emufs/b_plus.c
index 92ab3850a52f24c075153b3344815bc7fb1ce56e..0e84bcd6df9a618c027bc8057ab2ddac68762192 100644 (file)
--- a/emufs/b_plus.c
+++ b/emufs/b_plus.c
@@ -2,13 +2,15 @@
 #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 *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, int es_hoja) {
+NODO_B_PLUS *b_plus_crearnodo(INDEXSPECS *idx) {

        
        NODO_B_PLUS *nodo = (NODO_B_PLUS*)malloc(sizeof(NODO_B_PLUS));
        
        NODO_B_PLUS *nodo = (NODO_B_PLUS*)malloc(sizeof(NODO_B_PLUS));

-       nodo->es_hoja = es_hoja;

        nodo->nivel = 0;
        nodo->cant_claves = 0;
 
        nodo->nivel = 0;
        nodo->cant_claves = 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,1);
-       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,16 +57,18 @@ 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;
        
        /* Mientras no encontre la hoja con la clave, busco.. */
        curnode = b_plus_leer_nodo(idx,0);      
        if (curnode == NULL) return -1;
        
        /* Mientras no encontre la hoja con la clave, busco.. */

-       while ((curnode->es_hoja == 0) && curnode)
+       while ((curnode->nivel > 0) && curnode)

        {
                
        }
        
        {
                
        }
        

+       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,11 +102,11 @@ 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("Nivel: %i  Cant Claves: %i  Es Hoja: %i\n",memnode->nivel,memnode->cant_claves,memnode->es_hoja);
+       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("\nHijos:");
        printf("Claves:");
        for (i = 0; i < idx->size_claves/sizeof(int); ++i) printf(" %i",memnode->claves[i]);
        printf("\nHijos:");


@@ -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;
+}