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 static void b_grabar_nodo(INDICE *idx, int id, char *data);
12 static int b_ultimo_id(INDICE *idx);
13 static char *b_leer_nodo(INDICE *idx, int id);
14 static char *b_crear_nodo(INDICE *idx, int *i);
15 static void b_leer_header(char *src, B_NodoHeader *header);
16 static void b_actualizar_header(char *src, B_NodoHeader *header);
17 static B_NodoEntry *b_leer_claves(char *src, B_NodoHeader *header);
18 static void b_insertar_en_nodo(INDICE *idx, CLAVE clave, INDICE_DATO dato, int nodo_id, char *nodo, int hijo1, int hijo2);
19 static int b_elegir_izquierdo(INDICE *idx, int a, int b);
20 static void b_borrar_clave(INDICE *idx, char *nodo, int nodo_id, CLAVE k);
21 static void b_pasar_clave_derecha(char *, int, char *, int, char *, int, int);
22 static void b_pasar_clave_izquierda(char *, int, char *, int, char *, int, int);
23 static void b_fundir_nodo(char *, int, char *, int, char *, int, int);
25 void emufs_indice_b_crear(INDICE *idx)
34 header.hijo_izquierdo = -1;
36 fp = fopen(idx->filename, "w");
37 PERR("Creando indice");
38 fprintf(stderr, "Archivo = (%s)\n", idx->filename);
40 PERR("Error al crear el archivo");
44 /* Creo el archivo con el Nodo raiz */
45 bloque = (char *)malloc(idx->tam_bloque);
46 memset(bloque, -1, idx->tam_bloque);
48 memcpy(bloque, &header, sizeof(B_NodoHeader));
50 fwrite(bloque, idx->tam_bloque, 1, fp);
54 int emufs_indice_b_insertar(INDICE *idx, CLAVE clave, INDICE_DATO dato)
56 int i, nodo_id, padre_id;
62 nodo = b_leer_nodo(idx, 0);
63 padre_id = nodo_id = 0;
66 if (padre) free(padre);
69 b_leer_header(nodo, &header);
70 claves = b_leer_claves(nodo, &header);
72 while ((i<header.cant) && (emufs_indice_es_menor(idx, claves[i].clave, clave))) i++;
73 if ((i<header.cant) && (emufs_indice_es_igual(idx, claves[i].clave, clave))) {
74 /* CLAVE DUPLICADA! */
78 nodo = b_leer_nodo(idx, header.hijo_izquierdo);
79 nodo_id = header.hijo_izquierdo;
81 nodo = b_leer_nodo(idx, claves[i-1].hijo_derecho);
82 nodo_id = claves[i-1].hijo_derecho;
90 b_insertar_en_nodo(idx, clave, dato, nodo_id, nodo, -1, -1);
91 return 1; /* Agregar OK! */
94 INDICE_DATO emufs_indice_b_buscar(INDICE *idx, CLAVE clave)
103 nodo = b_leer_nodo(idx, 0);
105 b_leer_header(nodo, &header);
106 claves = b_leer_claves(nodo, &header);
108 while ((i<header.cant) && (emufs_indice_es_menor(idx, claves[i].clave, clave))) i++;
109 if (emufs_indice_es_igual(idx, claves[i].clave, clave)) {
110 ret = claves[i].dato;
116 nodo = b_leer_nodo(idx, header.hijo_izquierdo);
118 nodo = b_leer_nodo(idx, claves[i-1].hijo_derecho);
124 /* Nodo no encontrado */
125 ret.id = ret.bloque = -1;
129 int emufs_indice_b_borrar(INDICE *idx, CLAVE k)
131 /* Busco el nodo que contiene la clave,si es que esta existe */
138 nodo_id = 0; /* Tomo la raiz */
139 nodo = b_leer_nodo(idx, nodo_id);
140 PERR("Buscando clave a borrar");
141 while (nodo && !encontrado) {
142 /* Obtengo los datos del nodo */
143 b_leer_header(nodo, &header);
144 claves = b_leer_claves(nodo, &header);
147 while ((i<header.cant) && (emufs_indice_es_menor(idx, claves[i].clave, k))) i++;
149 if ((emufs_indice_es_igual(idx, claves[i].clave, k)) && (i<header.cant))
154 nodo_id = header.hijo_izquierdo;
155 nodo = b_leer_nodo(idx, nodo_id);
157 nodo_id = claves[i-1].hijo_derecho;
159 nodo = b_leer_nodo(idx, nodo_id);
165 PERR("Clave encontrada, borrando ...");
166 b_borrar_clave(idx, nodo, nodo_id, k);
168 PERR("Clave no encontrada");
173 static int b_ultimo_id(INDICE *idx)
177 fp = fopen(idx->filename, "r");
178 fseek(fp, 0, SEEK_END);
179 i = ftell(fp)/idx->tam_bloque;
185 static char *b_crear_nodo(INDICE *idx, int *id)
190 (*id) = b_ultimo_id(idx);
194 header.hijo_izquierdo = -1;
197 bloque = (char *)malloc(idx->tam_bloque);
198 memset(bloque, -1, idx->tam_bloque);
199 memcpy(bloque, &header, sizeof(B_NodoHeader));
201 b_grabar_nodo(idx, *id, bloque);
206 static char *b_leer_nodo(INDICE *idx, int id)
211 if (id < 0) return NULL;
213 fp = fopen(idx->filename, "r");
214 if (fp == NULL) return NULL;
216 fseek(fp, id*idx->tam_bloque, SEEK_SET);
218 out = (char *)malloc(idx->tam_bloque);
224 if (fread(out, 1, idx->tam_bloque, fp) != idx->tam_bloque) {
226 /* No se puso leer el nodo */
235 static void b_grabar_nodo(INDICE *idx, int id, char *data)
239 /* if (id > b_ultimo_id()) {
240 printf("AGREGANDO AL FINAL\n");
241 fp = fopen(FILENAME, "a");
243 _("No se pudo abrir archivo\n");
247 fp = fopen(FILENAME, "w");
249 _("No se pudo abrir archivo\n");
252 fseek(fp, id*BLOCK_SIZE, SEEK_SET);
253 printf("SOLO GUARDO DATA\n");
256 fp = fopen(idx->filename, "r+");
257 fseek(fp, id*idx->tam_bloque, SEEK_SET);
258 fwrite(data, 1, idx->tam_bloque, fp);
262 static void b_leer_header(char *src, B_NodoHeader *header)
266 memcpy(header, src, sizeof(B_NodoHeader));
269 static void b_actualizar_header(char *src, B_NodoHeader *header)
272 memcpy(src, header, sizeof(B_NodoHeader));
275 static B_NodoEntry *b_leer_claves(char *src, B_NodoHeader *header)
277 return (B_NodoEntry *)(src+sizeof(B_NodoHeader));
280 static void b_insertar_en_nodo(INDICE *idx, CLAVE clave, INDICE_DATO dato, int nodo_id, char *nodo, int hijo1, int hijo2)
287 B_NodoHeader nodo_header, nuevo_header;
288 B_NodoEntry *claves, *tmp_claves, *claves_nuevo;
293 nodo = b_crear_nodo(idx, &nodo_id);
295 b_leer_header(nodo, &nodo_header);
296 claves = b_leer_claves(nodo, &nodo_header);
298 padre = b_leer_nodo(idx, nodo_header.padre);
300 if (nodo_header.cant == CANT_HIJOS(idx)) {
302 nuevo = b_crear_nodo(idx, &nuevo_id);
304 /* Creo una lista ordenada de los nodos a partir */
305 tmp_claves = (B_NodoEntry *)malloc(sizeof(B_NodoEntry)*(nodo_header.cant+1));
306 total = nodo_header.cant;
307 while ((i<nodo_header.cant) && (emufs_indice_es_menor(idx, claves[i].clave, clave))) {
308 tmp_claves[i] = claves[i];
311 tmp_claves[i].clave = clave;
312 tmp_claves[i].dato = dato;
313 tmp_claves[i].hijo_derecho = hijo1;
314 tmp_claves[i+1].hijo_derecho = hijo2;
315 while (i < nodo_header.cant) {
316 tmp_claves[i+1] = claves[i];
320 /* Asigno a cada nodo lo que corresponde */
321 b_leer_header(nuevo, &nuevo_header);
323 nuevo_header.nivel = nodo_header.nivel;
324 nodo_header.cant = total/2;
325 nuevo_header.cant = total - nodo_header.cant;
327 memset(claves, '*', idx->tam_bloque-sizeof(B_NodoHeader));
328 for(j=0; j<nodo_header.cant; j++)
329 claves[j] = tmp_claves[j];
331 claves_nuevo = b_leer_claves(nuevo, &nuevo_header);
332 memset(claves_nuevo, '*', idx->tam_bloque-sizeof(B_NodoHeader));
333 for(j=0; j<nuevo_header.cant; j++)
334 claves_nuevo[j] = tmp_claves[j+total/2+1];
336 b_actualizar_header(nodo, &nodo_header);
337 b_actualizar_header(nuevo, &nuevo_header);
340 clave = tmp_claves[total/2].clave;
341 /* XXX dato.bloque = nuevo_id; */
343 b_grabar_nodo(idx, nodo_id, nodo);
344 b_grabar_nodo(idx, nuevo_id, nuevo);
353 nodo_id = nodo_header.padre;
355 /* Oops, parti el raiz, y este debe quedar en 0, lo paso a otro bloque
356 * y dejo el padre vacio
358 char *tmp_nuevo = b_crear_nodo(idx, &nodo_id);
359 memcpy(tmp_nuevo, nodo, idx->tam_bloque);
363 clave = tmp_claves[total/2].clave;
364 /* XXX dato.bloque = nuevo_id; */
366 b_grabar_nodo(idx, nuevo_id+1, nodo);
367 b_grabar_nodo(idx, nuevo_id, nuevo);
376 /* Limpio al padre */
377 nuevo = b_leer_nodo(idx, 0);
379 b_leer_header(nuevo, &nuevo_header);
380 nuevo_header.cant = 0;
381 nuevo_header.padre = -1;
382 nuevo_header.nivel = nodo_header.nivel+1;
383 memset(nuevo, -1, idx->tam_bloque);
384 b_actualizar_header(nuevo, &nuevo_header);
385 b_grabar_nodo(idx, 0, nuevo);
392 /* La clave entra en este nodo!! */
394 if (nodo_header.cant > 0) {
395 while ((emufs_indice_es_menor(idx, claves[i].clave, clave)) && (i < nodo_header.cant)) i++;
396 for(j=nodo_header.cant; j > i; j--)
397 claves[j] = claves[j-1];
400 claves[i].clave = clave;
401 claves[i].dato = dato;
402 claves[i].hijo_derecho = hijo2;
403 nodo_header.hijo_izquierdo = b_elegir_izquierdo(idx, nodo_header.hijo_izquierdo, hijo1);
405 b_actualizar_header(nodo, &nodo_header);
406 b_grabar_nodo(idx, nodo_id, nodo);
408 /* Debo actualizar los punteros al padre de los hijos */
410 nuevo = b_leer_nodo(idx, hijo1);
412 b_leer_header(nuevo, &nuevo_header);
413 nuevo_header.padre = nodo_id;
414 b_actualizar_header(nuevo, &nuevo_header);
415 b_grabar_nodo(idx, hijo1, nuevo);
417 } else printf("FUCK! hijo1=%d no existe!\n", hijo1);
420 nuevo = b_leer_nodo(idx, hijo2);
422 b_leer_header(nuevo, &nuevo_header);
423 nuevo_header.padre = nodo_id;
424 b_actualizar_header(nuevo, &nuevo_header);
425 b_grabar_nodo(idx, hijo2, nuevo);
427 } else printf("FUCK! hijo2=%d no existe!\n", hijo2);
434 static int b_elegir_izquierdo(INDICE *idx, int a, int b)
438 B_NodoHeader header1, header2;
439 B_NodoEntry *claves1, *claves2;
444 nodo1 = b_leer_nodo(idx, a);
445 nodo2 = b_leer_nodo(idx, b);
447 b_leer_header(nodo1, &header1);
448 b_leer_header(nodo2, &header2);
450 claves1 = b_leer_claves(nodo1, &header1);
451 claves2 = b_leer_claves(nodo2, &header2);
453 if (emufs_indice_es_menor(idx, claves1[0].clave, claves2[0].clave))
463 INDICE_DATO *emufs_indice_b_buscar_muchos(INDICE *idx, CLAVE clave, int *cant)
465 /* Si el indice es primario no tiene sentido hacer nada */
466 if (idx->funcion == IND_PRIMARIO) {
471 /* TODO Implementar indices con repeticion */
475 static void b_borrar_clave(INDICE *idx, char *nodo, int nodo_id, CLAVE k)
477 int pos, actual_id, padre_id, i, pos_padre, izquierda_id, derecha_id;
478 B_NodoHeader header, header_actual, header_padre, header_izq, header_der;
479 B_NodoEntry *claves, *claves_actual, *claves_padre;/*, *claves_izq, *claves_der;*/
480 char *actual, *padre, *izq, *der;
482 b_leer_header(nodo, &header);
483 claves = b_leer_claves(nodo, &header);
486 /* Busco la posicion dentro de la lista de claves */
487 while (emufs_indice_es_menor(idx, claves[pos].clave, k)) pos++;
489 /* Es el nodo una hoja? */
490 if (header.hijo_izquierdo != -1) {
491 /* No!, es un nodo intermedio!! */
493 actual = b_leer_nodo(idx, header.hijo_izquierdo);
495 actual = b_leer_nodo(idx, claves[pos+1].hijo_derecho);
497 b_leer_header(actual, &header_actual);
498 while (header_actual.hijo_izquierdo != -1) {
499 actual_id = header_actual.hijo_izquierdo;
501 actual = b_leer_nodo(idx, actual_id);
502 b_leer_header(actual, &header_actual);
504 claves_actual = b_leer_claves(actual, &header);
506 claves[pos] = claves_actual[0];
508 b_grabar_nodo(idx, nodo_id, nodo);
514 for(i=pos; i < header_actual.cant; i++) {
515 claves_actual[i] = claves_actual[i+1];
517 header_actual.cant--;
518 /* Guardo los cambios */
519 b_actualizar_header(actual, &header_actual);
520 b_grabar_nodo(idx, actual_id, actual);
522 /* Se cumple la condicion de hijos? */
523 if (header_actual.cant >= MIN_HIJOS(idx)) {
524 PERR("Borrar completo sin fundir");
528 /* Tengo que pasar datos o fundir nodos :-( */
530 padre_id = header.padre;
531 padre = b_leer_nodo(idx, padre_id);
532 b_leer_header(padre, &header_padre);
533 claves_padre = b_leer_claves(padre, &header_padre);
534 /* TODO Tengo el hijo_izquierdo para revisar!! XXX */
535 if (header_padre.hijo_izquierdo == actual_id) {
536 izquierda_id = -1; /* No tengo hermano izquierdo */
537 /* Mi hermano derecho es el primer nodo del padre */
538 derecha_id = claves_padre[0].hijo_derecho;
539 der = b_leer_nodo(idx, derecha_id);
540 b_leer_header(der, &header_der);
542 for(pos_padre=0; claves_padre[pos_padre].hijo_derecho != actual_id; pos_padre++) { }
544 /* Busco mis hermanos a derecha e izquierda, si es que existen */
545 if (pos_padre >= 0) {
547 izquierda_id = header_padre.hijo_izquierdo;
549 izquierda_id = claves_padre[pos_padre-1].hijo_derecho;
550 izq = b_leer_nodo(idx, izquierda_id);
551 b_leer_header(izq, &header_izq);
555 if (pos_padre < header_padre.cant) {
556 derecha_id = claves_padre[pos_padre+1].hijo_derecho;
557 der = b_leer_nodo(idx, derecha_id);
558 b_leer_header(der, &header_der);
563 /* Intendo pasar una clave desde un hermano hacia mi */
564 if ((derecha_id != -1) && (header_der.cant > MIN_HIJOS(idx))) {
565 b_pasar_clave_derecha(der, derecha_id, padre, padre_id, actual, actual_id, pos_padre);
566 } else if ((izquierda_id != -1) && (header_izq.cant > MIN_HIJOS(idx))) {
567 b_pasar_clave_izquierda(izq, izquierda_id, padre, padre_id, actual, actual_id, pos_padre-1);
569 /* No pude pasar clave, tengo que fundir :-( */
570 if (derecha_id != -1) {
571 b_fundir_nodo(actual, actual_id, padre, padre_id, der, derecha_id, pos_padre);
573 b_fundir_nodo(izq, izquierda_id, padre, padre_id, actual, actual_id, pos_padre-1);
577 /* TODO que guardo ?, todo ? */
578 b_grabar_nodo(idx, actual_id, actual);
579 b_grabar_nodo(idx, izquierda_id, izq);
580 b_grabar_nodo(idx, derecha_id, der);
581 b_grabar_nodo(idx, padre_id, padre);
582 if (actual_id != -1) free(actual);
583 /*if (padre_id != -1) free(padre);*/
584 if (derecha_id != -1) free(der);
585 if (izquierda_id != -1) free(izq);
587 actual_id = padre_id;
588 } while ((actual_id != -1) && (header_actual.cant < MIN_HIJOS(idx)));
591 static void b_pasar_clave_derecha(char *der, int der_id, char *padre, int padre_id, char *nodo, int nodo_id, int pos_clave)
594 B_NodoHeader h_der, h_padre, h_nodo;
595 B_NodoEntry *c_der, *c_padre, *c_nodo;
597 b_leer_header(nodo, &h_nodo);
598 c_nodo = b_leer_claves(nodo, &h_nodo);
599 b_leer_header(der, &h_der);
600 c_der = b_leer_claves(der, &h_der);
601 b_leer_header(padre, &h_padre);
602 c_padre = b_leer_claves(padre, &h_padre);
604 c_nodo[h_nodo.cant] = c_padre[pos_clave];
605 c_nodo[h_nodo.cant].hijo_derecho = -1; /* XXX */
607 c_padre[pos_clave] = c_der[0];
608 c_padre[pos_clave].hijo_derecho = der_id;
610 /* Muevo las claves de derecho */
611 for(i=0; i<h_der.cant; i++) {
612 c_der[i] = c_der[i+1];
617 b_actualizar_header(der, &h_der);
618 b_actualizar_header(nodo, &h_nodo);
621 static void b_pasar_clave_izquierda(char *izq, int izq_id, char *padre, int padre_id, char *nodo, int nodo_id, int pos_clave)
624 B_NodoHeader h_izq, h_padre, h_nodo;
625 B_NodoEntry *c_izq, *c_padre, *c_nodo;
627 b_leer_header(nodo, &h_nodo);
628 c_nodo = b_leer_claves(nodo, &h_nodo);
629 b_leer_header(izq, &h_izq);
630 c_izq = b_leer_claves(izq, &h_izq);
631 b_leer_header(padre, &h_padre);
632 c_padre = b_leer_claves(padre, &h_padre);
634 for(i=h_nodo.cant; i>0;i++)
635 c_nodo[i] = c_nodo[i-1];
638 c_nodo[0] = c_padre[pos_clave];
639 c_nodo[0].hijo_derecho = -1; /* XXX */
640 c_padre[pos_clave] = c_izq[h_izq.cant-1];
641 c_padre[pos_clave].hijo_derecho = izq_id;
644 b_actualizar_header(izq, &h_izq);
645 b_actualizar_header(padre, &h_padre);
646 b_actualizar_header(nodo, &h_nodo);
649 static void b_fundir_nodo(char *izq, int izq_id, char *padre, int padre_id, char *der, int der_id, int pos_clave)