+ 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);
+
+ return error;
+}
+
+/* Inserta una nueva clave y reestructura el arbol para que quede como debe */
+int b_plus_insertar_clave(INDEXSPECS *idx, INDEX_DAT *query)
+{
+ NODO_B_PLUS *curnode, *padre;
+ int i,j, prox_nodo = 0;
+
+ /* Comienzo leyendo la raiz, entry point de toda funcion */
+ curnode = b_plus_leer_nodo(idx,0);
+ if (curnode == NULL) return -1;
+ padre = curnode;
+ while ( curnode->nivel > 0 && curnode ) {
+ for(i=0; i<curnode->cant_claves; i++){
+ /* me fijo que si es mayor */
+ if ( (query->clave.i_clave > curnode->claves[i])) {
+ if ( curnode->cant_claves != i ) /* si no es la ultima clave del nodo */
+ continue; /*paso a la siguiente*/
+ else { /* si era la ultima, la clave deberia ir ahi */
+ /*cargo el proximo nodo*/
+ prox_nodo = curnode->hijos[i+1];
+ break; /*salgo del for*/
+ }
+ } else { /*si no es mayor o igual es menor*/
+ prox_nodo = curnode->hijos[i];
+ break;
+ }
+ }
+ padre = curnode;
+ curnode = b_plus_leer_nodo(idx, prox_nodo);
+ }
+ /* aca tengo el nodo donde deberia ir la clave, y su padre */
+
+ if ( curnode->cant_claves < idx->size_claves/sizeof(int) ){
+ int *claves_aux = (int*)malloc(idx->size_claves);
+ int *hijos_aux = (int*)malloc(idx->size_hijos);
+ memset(claves_aux,-1,idx->size_claves);
+ memset(hijos_aux,-1,idx->size_hijos);
+ i = 0;
+ while ( (curnode->claves[i] < query->clave.i_clave) && (i < curnode->cant_claves)){
+ claves_aux[i] = curnode->claves[i];
+ hijos_aux[i] = curnode->hijos[i];
+ i++;
+ }
+ curnode->cant_claves++;
+ claves_aux[i] = query->clave.i_clave;
+ hijos_aux[i] = query->num_bloque;
+ for (j=i+1; j<curnode->cant_claves; j++){
+ claves_aux[j] = curnode->claves[j-1];
+ hijos_aux[j] = curnode->hijos[j-1];
+ }
+ free(curnode->claves);
+ free(curnode->hijos);
+ curnode->claves = claves_aux;
+ curnode->hijos = hijos_aux;
+ printf ("Prox Nodo es: %i\n",prox_nodo);
+ b_plus_grabar_nodo(idx, curnode, prox_nodo);
+ b_plus_destruir_nodo(curnode);
+ }
+
+ /* si el nodo esta lleno tengo que splitear */
+ if ( curnode->cant_claves == idx->size_claves )
+ {
+ /**FIXME**/
+ }
+ return 0;
+}
+
+/** Busca el nro de bloque donde se debe guardar un reg con clave X.
+ * Posibilidades: return 0 - Encontro un bloque potencial
+ * return -1 - No hay clave, inserto clave de nuevo bloques
+ * return 1 - Hubo falla de lectura de un nodo, Abortar
+ */
+int emufs_b_plus_get_bloque(INDEXSPECS *idx, INDEX_DAT *query, int num_node) {
+
+ NODO_B_PLUS *nodo;
+ nodo = b_plus_leer_nodo(idx,num_node);
+ if (nodo == NULL) return 1;
+ int i = nodo->cant_claves - 1;
+ int exitcode = 0;
+
+ /* Si es un hoja, busco dentro de la hoja, otherwise, busco la hoja */
+ if (nodo->nivel == 0) {
+ /* Vemos en que bloque deberia ir */
+ while ( i >= 0 && query->clave.i_clave < nodo->claves[i] ) i--;
+ if (i < 0) {
+ /* La clave es menor que todas, debo insertarla */
+ b_plus_destruir_nodo(nodo);
+ emufs_b_plus_insertar(idx,query);
+ return -1;
+ }
+ else {
+ /* Encontre un bloque potencial */
+ query->num_bloque = nodo->hijos[i];
+ b_plus_destruir_nodo(nodo);
+ return 0;
+ }
+ }
+ else {
+ /* Buscamos por donde descender al siguiente nivel */
+ while ( i >= 0 && query->clave.i_clave < nodo->claves[i] ) i--;
+ i++;
+ num_node = nodo->hijos[i];
+ b_plus_destruir_nodo(nodo);
+ exitcode = emufs_b_plus_get_bloque(idx,query,num_node);
+ return exitcode;
+ }
+}
+
+NODO_B_PLUS *b_plus_leer_nodo(INDEXSPECS *idx, int num_node) {
+
+ /*int i = 0;*/
+ FILE *fp;
+ NODO_B_PLUS *memnode = b_plus_crearnodo(idx);
+ char *disknode = (char*)malloc(idx->tam_bloque);
+
+ if (num_node < 0) {
+ PERR("Se intento leer nodo negativo!!\n");
+ exit(1);
+ }
+ if (disknode == NULL) return NULL;
+ if (memnode == NULL) return NULL;
+
+ /* Open up file */
+ fp = fopen(idx->filename, "r+");
+ if (fp == NULL) {
+ free(disknode);
+ b_plus_destruir_nodo(memnode);
+ return NULL;
+ }
+
+ /* Intentamos leer un nodo, sino podemos error! */
+ fseek(fp, num_node*idx->tam_bloque, SEEK_SET);
+ if (fread(disknode, idx->tam_bloque, 1, fp) != 1) {
+ free(disknode);
+ fclose(fp);
+ return NULL;
+ }
+ fclose(fp);
+
+ /* 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_claves,idx->size_hijos);
+ free(disknode);
+
+ /*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:");
+ for (i = 0; i < idx->size_hijos/sizeof(int); ++i) printf(" %i",memnode->hijos[i]);
+ printf("\nEnd Dump\n"); */
+
+ 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*(SIZE_B_PLUS_HEADER+idx->size_claves+idx->size_hijos),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);
projects / z.facultad / 75.06 / emufs.git / blobdiff