5 /* Cantidad de claves por nodo */
6 #define CANT_HIJOS(x) ((x->tam_bloque-sizeof(B_NodoHeader))/sizeof(B_NodoEntry))
7 #define CANT_NODOS(x) (CANT_HIJOS(x)+1)
8 #define MIN_HIJOS(x) (CANT_HIJOS(x)/2)
11 /** Graba el nodo en el archivo */
12 static void b_grabar_nodo(INDICE *idx, int id, char *data);
13 /** Da el ID del proximo nodo a poder ser utilizado */
14 static int b_ultimo_id(INDICE *idx);
15 /** Lee un nodo desde el archivo */
16 static char *b_leer_nodo(INDICE *idx, int id);
17 /** Crea un nodo en el archivo y lo retorna. En i se pone el ID asignado */
18 static char *b_crear_nodo(INDICE *idx, int *i);
19 /** Lee el header de un nodo y lo guarda en header */
20 static void b_leer_header(char *src, B_NodoHeader *header);
21 /** Actualiza el header de un nodo desde header */
22 static void b_actualizar_header(char *src, B_NodoHeader *header);
23 /** Retorna el array de claves del nodo (esta data modifica directamente el bloque
24 * por eso no es necesario usar un actualizar_claves
26 static B_NodoEntry *b_leer_claves(char *src, B_NodoHeader *header);
27 /** Inserta una clave en el nodo de manera iterativa.
28 * \param idx Índice en donde insertar la clave.
29 * \param clave Clave a insertar.
30 * \param dato Dato a insertar
31 * \param nodo_id Id del nodo en el cual insertar la nueva clave.
32 * \param nodo FIXME Nodo en donde insertar??? No entiendo por que char*.
33 * \param hijo1 Id del nodo hijo de la izquierda del insertado.
34 * \param hijo2 Id del nodo hijo de la derecha del insertado.
36 static void b_insertar_en_nodo(INDICE *idx, CLAVE clave, INDICE_DATO dato, int nodo_id, char *nodo, int hijo1, int hijo2);
37 /** Inserta en un nodo en el que se sabe positivamente que hay lugar. */
38 static void b_insertar_en_nodo_con_lugar(INDICE *idx, CLAVE clave, INDICE_DATO dato, int nodo_id, char *nodo, int hijo1, int hijo2);
39 /** Esto es para asegurar el orden de los hijos luego de partir, en el caso de que
40 * lo que se parta sea la raiz
42 static int b_elegir_izquierdo(INDICE *idx, int a, int b);
43 /** Borra una clave del arbol */
44 static void b_borrar_clave(INDICE *idx, char *nodo, int nodo_id, CLAVE k);
45 /** Le pide al hermano derecho del nodo una clave cuando se eliminan claves */
46 static void b_pedir_clave_derecha(char *, int, char *, int, char *, int, int);
47 /** Le pide al hermano izquierdo una clave cuando se eliminan claves */
48 static void b_pedir_clave_izquierda(char *, int, char *, int, char *, int, int);
49 /** Le pasa al hermano derecho del nodo una clave cuando se insertan claves */
50 static void b_pasar_clave_a_derecha(INDICE*, char*, int, char*, int, int, B_NodoEntry);
51 /** Le pasa al hermano izquierdo una clave cuando se insertan claves */
52 static void b_pasar_clave_a_izquierda(INDICE*, char*, int, char*, int, int, B_NodoEntry);
53 /** Junta 2 nodos y hace uno solo */
54 static void b_fundir_nodo(char *, int, char *, int, char *, int, int);
56 void emufs_indice_b_crear(INDICE *idx)
65 header.hijo_izquierdo = -1;
67 fp = fopen(idx->filename, "w");
68 PERR("Creando indice");
69 fprintf(stderr, "Archivo = (%s)\n", idx->filename);
71 PERR("Error al crear el archivo");
75 /* Creo el archivo con el Nodo raiz */
76 bloque = (char *)malloc(idx->tam_bloque);
77 memset(bloque, -1, idx->tam_bloque);
79 memcpy(bloque, &header, sizeof(B_NodoHeader));
81 fwrite(bloque, idx->tam_bloque, 1, fp);
85 int emufs_indice_b_insertar(INDICE *idx, CLAVE clave, INDICE_DATO dato)
87 int i, nodo_id, padre_id;
93 nodo = b_leer_nodo(idx, 0);
94 padre_id = nodo_id = 0;
97 if (padre) free(padre);
100 b_leer_header(nodo, &header);
101 claves = b_leer_claves(nodo, &header);
103 while ((i<header.cant) && (emufs_indice_es_menor(idx, claves[i].clave, clave))) i++;
104 if ((i<header.cant) && (emufs_indice_es_igual(idx, claves[i].clave, clave))) {
105 /* CLAVE DUPLICADA! */
109 nodo = b_leer_nodo(idx, header.hijo_izquierdo);
110 nodo_id = header.hijo_izquierdo;
112 nodo = b_leer_nodo(idx, claves[i-1].hijo_derecho);
113 nodo_id = claves[i-1].hijo_derecho;
118 if (nodo) free(nodo);
121 b_insertar_en_nodo(idx, clave, dato, nodo_id, nodo, -1, -1);
122 return 1; /* Agregar OK! */
125 INDICE_DATO emufs_indice_b_buscar(INDICE *idx, CLAVE clave)
134 nodo = b_leer_nodo(idx, 0);
136 b_leer_header(nodo, &header);
137 claves = b_leer_claves(nodo, &header);
139 while ((i<header.cant) && (emufs_indice_es_menor(idx, claves[i].clave, clave))) i++;
140 if (emufs_indice_es_igual(idx, claves[i].clave, clave)) {
141 ret = claves[i].dato;
147 nodo = b_leer_nodo(idx, header.hijo_izquierdo);
149 nodo = b_leer_nodo(idx, claves[i-1].hijo_derecho);
155 /* Nodo no encontrado */
156 ret.id = ret.bloque = -1;
160 int emufs_indice_b_borrar(INDICE *idx, CLAVE k)
162 /* Busco el nodo que contiene la clave,si es que esta existe */
169 nodo_id = 0; /* Tomo la raiz */
170 nodo = b_leer_nodo(idx, nodo_id);
171 PERR("Buscando clave a borrar");
172 while (nodo && !encontrado) {
173 /* Obtengo los datos del nodo */
174 b_leer_header(nodo, &header);
175 claves = b_leer_claves(nodo, &header);
178 while ((i<header.cant) && (emufs_indice_es_menor(idx, claves[i].clave, k))) i++;
180 if ((emufs_indice_es_igual(idx, claves[i].clave, k)) && (i<header.cant))
185 nodo_id = header.hijo_izquierdo;
186 nodo = b_leer_nodo(idx, nodo_id);
188 nodo_id = claves[i-1].hijo_derecho;
190 nodo = b_leer_nodo(idx, nodo_id);
196 PERR("Clave encontrada, borrando ...");
197 b_borrar_clave(idx, nodo, nodo_id, k);
199 PERR("Clave no encontrada");
204 static int b_ultimo_id(INDICE *idx)
208 fp = fopen(idx->filename, "r");
209 fseek(fp, 0, SEEK_END);
210 i = ftell(fp)/idx->tam_bloque;
216 static char *b_crear_nodo(INDICE *idx, int *id)
221 (*id) = b_ultimo_id(idx);
225 header.hijo_izquierdo = -1;
228 bloque = (char *)malloc(idx->tam_bloque);
229 memset(bloque, -1, idx->tam_bloque);
230 memcpy(bloque, &header, sizeof(B_NodoHeader));
232 b_grabar_nodo(idx, *id, bloque);
237 static char *b_leer_nodo(INDICE *idx, int id)
242 if (id < 0) return NULL;
244 fp = fopen(idx->filename, "r");
245 if (fp == NULL) return NULL;
247 fseek(fp, id*idx->tam_bloque, SEEK_SET);
249 out = (char *)malloc(idx->tam_bloque);
255 if (fread(out, 1, idx->tam_bloque, fp) != idx->tam_bloque) {
257 /* No se puso leer el nodo */
266 static void b_grabar_nodo(INDICE *idx, int id, char *data)
270 /* if (id > b_ultimo_id()) {
271 printf("AGREGANDO AL FINAL\n");
272 fp = fopen(FILENAME, "a");
274 _("No se pudo abrir archivo\n");
278 fp = fopen(FILENAME, "w");
280 _("No se pudo abrir archivo\n");
283 fseek(fp, id*BLOCK_SIZE, SEEK_SET);
284 printf("SOLO GUARDO DATA\n");
287 fp = fopen(idx->filename, "r+");
288 fseek(fp, id*idx->tam_bloque, SEEK_SET);
289 fwrite(data, 1, idx->tam_bloque, fp);
293 static void b_leer_header(char *src, B_NodoHeader *header)
297 memcpy(header, src, sizeof(B_NodoHeader));
300 static void b_actualizar_header(char *src, B_NodoHeader *header)
303 memcpy(src, header, sizeof(B_NodoHeader));
306 static B_NodoEntry *b_leer_claves(char *src, B_NodoHeader *header)
308 return (B_NodoEntry *)(src+sizeof(B_NodoHeader));
311 static void b_insertar_en_nodo(INDICE *idx, CLAVE clave, INDICE_DATO dato, int nodo_id, char *nodo, int hijo1, int hijo2)
318 B_NodoHeader nodo_header, nuevo_header;
319 B_NodoEntry *claves, *tmp_claves, *claves_nuevo;
324 nodo = b_crear_nodo(idx, &nodo_id);
326 b_leer_header(nodo, &nodo_header);
327 claves = b_leer_claves(nodo, &nodo_header);
329 padre = b_leer_nodo(idx, nodo_header.padre);
331 if (nodo_header.cant == CANT_HIJOS(idx)) {
333 /* TODO: Si es B*, hay que chequear si alguno de los 2
334 * nodos hermanos pueden prestarme espacio (y
335 * desplazar si es así). Si no pueden, hay que
336 * hacer un split de 2 nodos en 3.
337 * Si no es B*, hay que hacer lo que sigue:
339 nuevo = b_crear_nodo(idx, &nuevo_id);
341 /* Creo una lista ordenada de los nodos a partir */
342 tmp_claves = (B_NodoEntry *)malloc(sizeof(B_NodoEntry)*(nodo_header.cant+1));
343 total = nodo_header.cant;
344 while ((i<nodo_header.cant) && (emufs_indice_es_menor(idx, claves[i].clave, clave))) {
345 tmp_claves[i] = claves[i];
348 tmp_claves[i].clave = clave;
349 tmp_claves[i].dato = dato;
350 tmp_claves[i].hijo_derecho = hijo1;
351 tmp_claves[i+1].hijo_derecho = hijo2;
352 while (i < nodo_header.cant) {
353 tmp_claves[i+1] = claves[i];
357 /* Asigno a cada nodo lo que corresponde */
358 b_leer_header(nuevo, &nuevo_header);
360 nuevo_header.nivel = nodo_header.nivel;
361 nodo_header.cant = total/2;
362 nuevo_header.cant = total - nodo_header.cant;
364 memset(claves, '*', idx->tam_bloque-sizeof(B_NodoHeader));
365 for(j=0; j<nodo_header.cant; j++)
366 claves[j] = tmp_claves[j];
368 claves_nuevo = b_leer_claves(nuevo, &nuevo_header);
369 memset(claves_nuevo, '*', idx->tam_bloque-sizeof(B_NodoHeader));
370 for(j=0; j<nuevo_header.cant; j++)
371 claves_nuevo[j] = tmp_claves[j+total/2+1];
373 b_actualizar_header(nodo, &nodo_header);
374 b_actualizar_header(nuevo, &nuevo_header);
377 clave = tmp_claves[total/2].clave;
378 /* XXX dato.bloque = nuevo_id; */
380 b_grabar_nodo(idx, nodo_id, nodo);
381 b_grabar_nodo(idx, nuevo_id, nuevo);
390 nodo_id = nodo_header.padre;
392 /* Oops, parti el raiz, y este debe quedar en 0, lo paso a otro bloque
393 * y dejo el padre vacio
395 char *tmp_nuevo = b_crear_nodo(idx, &nodo_id);
396 memcpy(tmp_nuevo, nodo, idx->tam_bloque);
400 clave = tmp_claves[total/2].clave;
401 /* XXX dato.bloque = nuevo_id; */
403 b_grabar_nodo(idx, nuevo_id+1, nodo);
404 b_grabar_nodo(idx, nuevo_id, nuevo);
413 /* Limpio al padre */
414 nuevo = b_leer_nodo(idx, 0);
416 b_leer_header(nuevo, &nuevo_header);
417 nuevo_header.cant = 0;
418 nuevo_header.padre = -1;
419 nuevo_header.nivel = nodo_header.nivel+1;
420 memset(nuevo, -1, idx->tam_bloque);
421 b_actualizar_header(nuevo, &nuevo_header);
422 b_grabar_nodo(idx, 0, nuevo);
429 /* La clave entra en este nodo!! */
430 b_insertar_en_nodo_con_lugar(idx, clave, dato, nodo_id, nodo, hijo1, hijo2);
436 void b_insertar_en_nodo_con_lugar(INDICE *idx, CLAVE clave, INDICE_DATO dato, int nodo_id, char *nodo, int hijo1, int hijo2)
439 B_NodoHeader nodo_header;
441 b_leer_header(nodo, &nodo_header);
442 claves = b_leer_claves(nodo, &nodo_header);
443 if (nodo_header.cant > 0) {
445 while ((emufs_indice_es_menor(idx, claves[i].clave, clave)) && (i < nodo_header.cant)) i++;
446 for(j=nodo_header.cant; j > i; j--)
447 claves[j] = claves[j-1];
450 claves[i].clave = clave;
451 claves[i].dato = dato;
452 claves[i].hijo_derecho = hijo2;
453 nodo_header.hijo_izquierdo = b_elegir_izquierdo(idx, nodo_header.hijo_izquierdo, hijo1);
455 b_actualizar_header(nodo, &nodo_header);
456 b_grabar_nodo(idx, nodo_id, nodo);
458 /* Debo actualizar los punteros al padre de los hijos */
460 char* nuevo = b_leer_nodo(idx, hijo1);
462 B_NodoHeader nuevo_header;
463 b_leer_header(nuevo, &nuevo_header);
464 nuevo_header.padre = nodo_id;
465 b_actualizar_header(nuevo, &nuevo_header);
466 b_grabar_nodo(idx, hijo1, nuevo);
468 } else printf("FUCK! hijo1=%d no existe!\n", hijo1);
471 char* nuevo = b_leer_nodo(idx, hijo2);
473 B_NodoHeader nuevo_header;
474 b_leer_header(nuevo, &nuevo_header);
475 nuevo_header.padre = nodo_id;
476 b_actualizar_header(nuevo, &nuevo_header);
477 b_grabar_nodo(idx, hijo2, nuevo);
479 } else printf("FUCK! hijo2=%d no existe!\n", hijo2);
483 static int b_elegir_izquierdo(INDICE *idx, int a, int b)
487 B_NodoHeader header1, header2;
488 B_NodoEntry *claves1, *claves2;
493 nodo1 = b_leer_nodo(idx, a);
494 nodo2 = b_leer_nodo(idx, b);
496 b_leer_header(nodo1, &header1);
497 b_leer_header(nodo2, &header2);
499 claves1 = b_leer_claves(nodo1, &header1);
500 claves2 = b_leer_claves(nodo2, &header2);
502 if (emufs_indice_es_menor(idx, claves1[0].clave, claves2[0].clave))
512 INDICE_DATO *emufs_indice_b_buscar_muchos(INDICE *idx, CLAVE clave, int *cant)
514 /* Si el indice es primario no tiene sentido hacer nada */
515 if (idx->funcion == IND_PRIMARIO) {
520 /* TODO Implementar indices con repeticion */
524 static void b_borrar_clave(INDICE *idx, char *nodo, int nodo_id, CLAVE k)
526 int pos, actual_id, padre_id, i, pos_padre, izquierda_id, derecha_id;
527 B_NodoHeader header, header_actual, header_padre, header_izq, header_der;
528 B_NodoEntry *claves, *claves_actual, *claves_padre;/*, *claves_izq, *claves_der;*/
529 char *actual, *padre, *izq, *der;
531 b_leer_header(nodo, &header);
532 claves = b_leer_claves(nodo, &header);
535 /* Busco la posicion dentro de la lista de claves */
536 while (emufs_indice_es_menor(idx, claves[pos].clave, k)) pos++;
538 /* Es el nodo una hoja? */
539 if (header.hijo_izquierdo != -1) {
540 /* No!, es un nodo intermedio!! */
542 actual = b_leer_nodo(idx, header.hijo_izquierdo);
544 actual = b_leer_nodo(idx, claves[pos+1].hijo_derecho);
546 b_leer_header(actual, &header_actual);
547 while (header_actual.hijo_izquierdo != -1) {
548 actual_id = header_actual.hijo_izquierdo;
550 actual = b_leer_nodo(idx, actual_id);
551 b_leer_header(actual, &header_actual);
553 claves_actual = b_leer_claves(actual, &header);
555 claves[pos] = claves_actual[0];
557 b_grabar_nodo(idx, nodo_id, nodo);
563 for(i=pos; i < header_actual.cant; i++) {
564 claves_actual[i] = claves_actual[i+1];
566 header_actual.cant--;
567 /* Guardo los cambios */
568 b_actualizar_header(actual, &header_actual);
569 b_grabar_nodo(idx, actual_id, actual);
571 /* Se cumple la condicion de hijos? */
572 if (header_actual.cant >= MIN_HIJOS(idx)) {
573 PERR("Borrar completo sin fundir");
577 /* Tengo que pasar datos o fundir nodos :-( */
579 padre_id = header.padre;
580 padre = b_leer_nodo(idx, padre_id);
581 b_leer_header(padre, &header_padre);
582 claves_padre = b_leer_claves(padre, &header_padre);
583 /* TODO Tengo el hijo_izquierdo para revisar!! XXX */
584 if (header_padre.hijo_izquierdo == actual_id) {
585 izquierda_id = -1; /* No tengo hermano izquierdo */
586 /* Mi hermano derecho es el primer nodo del padre */
587 derecha_id = claves_padre[0].hijo_derecho;
588 der = b_leer_nodo(idx, derecha_id);
589 b_leer_header(der, &header_der);
591 for(pos_padre=0; claves_padre[pos_padre].hijo_derecho != actual_id; pos_padre++) { }
593 /* Busco mis hermanos a derecha e izquierda, si es que existen */
594 if (pos_padre >= 0) {
596 izquierda_id = header_padre.hijo_izquierdo;
598 izquierda_id = claves_padre[pos_padre-1].hijo_derecho;
599 izq = b_leer_nodo(idx, izquierda_id);
600 b_leer_header(izq, &header_izq);
604 if (pos_padre < header_padre.cant) {
605 derecha_id = claves_padre[pos_padre+1].hijo_derecho;
606 der = b_leer_nodo(idx, derecha_id);
607 b_leer_header(der, &header_der);
612 /* Intendo pasar una clave desde un hermano hacia mi */
613 if ((derecha_id != -1) && (header_der.cant > MIN_HIJOS(idx))) {
614 b_pedir_clave_derecha(der, derecha_id, padre, padre_id, actual, actual_id, pos_padre);
615 } else if ((izquierda_id != -1) && (header_izq.cant > MIN_HIJOS(idx))) {
616 b_pedir_clave_izquierda(izq, izquierda_id, padre, padre_id, actual, actual_id, pos_padre-1);
618 /* No pude pasar clave, tengo que fundir :-( */
619 if (derecha_id != -1) {
620 b_fundir_nodo(actual, actual_id, padre, padre_id, der, derecha_id, pos_padre);
622 b_fundir_nodo(izq, izquierda_id, padre, padre_id, actual, actual_id, pos_padre-1);
626 /* TODO que guardo ?, todo ? */
627 b_grabar_nodo(idx, actual_id, actual);
628 b_grabar_nodo(idx, izquierda_id, izq);
629 b_grabar_nodo(idx, derecha_id, der);
630 b_grabar_nodo(idx, padre_id, padre);
631 if (actual_id != -1) free(actual);
632 /*if (padre_id != -1) free(padre);*/
633 if (derecha_id != -1) free(der);
634 if (izquierda_id != -1) free(izq);
636 actual_id = padre_id;
637 } while ((actual_id != -1) && (header_actual.cant < MIN_HIJOS(idx)));
640 static void b_pedir_clave_derecha(char *der, int der_id, char *padre, int padre_id, char *nodo, int nodo_id, int pos_clave)
643 B_NodoHeader h_der, h_padre, h_nodo;
644 B_NodoEntry *c_der, *c_padre, *c_nodo;
646 b_leer_header(nodo, &h_nodo);
647 c_nodo = b_leer_claves(nodo, &h_nodo);
648 b_leer_header(der, &h_der);
649 c_der = b_leer_claves(der, &h_der);
650 b_leer_header(padre, &h_padre);
651 c_padre = b_leer_claves(padre, &h_padre);
653 c_nodo[h_nodo.cant] = c_padre[pos_clave];
654 c_nodo[h_nodo.cant].hijo_derecho = -1; /* XXX */
656 c_padre[pos_clave] = c_der[0];
657 c_padre[pos_clave].hijo_derecho = der_id;
659 /* Muevo las claves de derecho */
660 for(i=0; i<h_der.cant; i++) {
661 c_der[i] = c_der[i+1];
666 b_actualizar_header(der, &h_der);
667 b_actualizar_header(nodo, &h_nodo);
670 void b_pasar_clave_a_derecha(INDICE *idx, char *der, int der_id, char *padre, int padre_id, int padre_pos, B_NodoEntry entry)
672 B_NodoHeader der_h, padre_h;
673 B_NodoEntry *der_entries, *padre_entries;
674 /* Leo claves y cabecera del nodo de la derecha y del padre */
675 b_leer_header(der, &der_h);
676 der_entries = b_leer_claves(der, &der_h);
677 b_leer_header(padre, &padre_h);
678 padre_entries = b_leer_claves(padre, &padre_h);
679 /* Inserto en el hijo derecho la clave del padre */
680 b_insertar_en_nodo_con_lugar(idx, padre_entries[padre_pos].clave, padre_entries[padre_pos].dato,
681 der_id, der, entry.hijo_derecho, der_h.hijo_izquierdo);
682 /* Reemplazo clave del padre por clave nueva */
683 entry.hijo_derecho = der_id;
684 padre_entries[padre_pos] = entry;
687 void b_pedir_clave_izquierda(char *izq, int izq_id, char *padre, int padre_id, char *nodo, int nodo_id, int pos_clave)
690 B_NodoHeader h_izq, h_padre, h_nodo;
691 B_NodoEntry *c_izq, *c_padre, *c_nodo;
693 b_leer_header(nodo, &h_nodo);
694 c_nodo = b_leer_claves(nodo, &h_nodo);
695 b_leer_header(izq, &h_izq);
696 c_izq = b_leer_claves(izq, &h_izq);
697 b_leer_header(padre, &h_padre);
698 c_padre = b_leer_claves(padre, &h_padre);
700 for(i=h_nodo.cant; i>0;i++)
701 c_nodo[i] = c_nodo[i-1];
704 c_nodo[0] = c_padre[pos_clave];
705 c_nodo[0].hijo_derecho = -1; /* XXX */
706 c_padre[pos_clave] = c_izq[h_izq.cant-1];
707 c_padre[pos_clave].hijo_derecho = izq_id;
710 b_actualizar_header(izq, &h_izq);
711 b_actualizar_header(padre, &h_padre);
712 b_actualizar_header(nodo, &h_nodo);
715 void b_pasar_clave_a_izquierda(INDICE* idx, char *izq, int izq_id, char *padre, int padre_id, int padre_pos, B_NodoEntry entry)
718 B_NodoHeader h_izq, h_padre, h_nodo;
719 B_NodoEntry *c_izq, *c_padre, *c_nodo;
721 b_leer_header(nodo, &h_nodo);
722 c_nodo = b_leer_claves(nodo, &h_nodo);
723 b_leer_header(izq, &h_izq);
724 c_izq = b_leer_claves(izq, &h_izq);
725 b_leer_header(padre, &h_padre);
726 c_padre = b_leer_claves(padre, &h_padre);
728 for(i=h_nodo.cant; i>0;i++)
729 c_nodo[i] = c_nodo[i-1];
732 c_nodo[0] = c_padre[pos_clave];
733 c_nodo[0].hijo_derecho = -1; / * XXX * /
734 c_padre[pos_clave] = c_izq[h_izq.cant-1];
735 c_padre[pos_clave].hijo_derecho = izq_id;
738 b_actualizar_header(izq, &h_izq);
739 b_actualizar_header(padre, &h_padre);
740 b_actualizar_header(nodo, &h_nodo);
744 static void b_fundir_nodo(char *izq, int izq_id, char *padre, int padre_id, char *der, int der_id, int pos_clave)