1 /* vim: set noexpandtab tabstop=4 shiftwidth=4:
2 *----------------------------------------------------------------------------
4 *----------------------------------------------------------------------------
5 * This file is part of emufs.
7 * emufs is free software; you can redistribute it and/or modify it under the
8 * terms of the GNU General Public License as published by the Free Software
9 * Foundation; either version 2 of the License, or (at your option) any later
12 * emufs is distributed in the hope that it will be useful, but WITHOUT ANY
13 * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
14 * FOR A PARTICULAR PURPOSE. See the GNU General Public License for more
17 * You should have received a copy of the GNU General Public License along
18 * with emufs; if not, write to the Free Software Foundation, Inc., 59 Temple
19 * Place, Suite 330, Boston, MA 02111-1307 USA
20 *----------------------------------------------------------------------------
21 * Creado: mié mar 31 17:26:46 ART 2004
22 * Autores: Nicolás Dimov <sagardua@uolsinectis.com.ar>
23 *----------------------------------------------------------------------------
31 * Archivo con bloques y registros de longitud parametrizada.
33 * Implementación del archivo con bloques y registros de longitud
45 static CLAVE grabar_ordenado_en_bloque(EMUFS *emu, void *ptr, EMUFS_REG_SIZE size,
46 void *bloque, int num_bloque, EMUFS_FREE fs, int *err);
49 int emufs_tipo3_inicializar(EMUFS* efs)
51 /* como mínimo el tamaño de bloque debe ser 2 veces el tamaño de la cabecera
52 * (una relación 1/2 entre datos e info de control ya es lo suficientemente
54 if (efs->tam_bloque < (sizeof(EMUFS_REG_ID) * 2)) {
55 PERR("bloque demasiado chico");
56 return EMUFS_ERROR_BLOCK_TOO_SMALL;
58 /* Asigna punteros a funciones. */
59 efs->leer_bloque = emufs_tipo3_leer_bloque;
60 efs->leer_bloque_raw = emufs_tipo3_leer_bloque_raw;
61 efs->grabar_registro = emufs_tipo3_grabar_registro;
62 efs->borrar_registro = emufs_tipo3_borrar_registro;
63 efs->leer_registro = emufs_tipo3_leer_registro;
64 efs->leer_registro_raw = emufs_tipo3_leer_registro_raw;
65 efs->leer_estadisticas = emufs_tipo3_leer_estadisticas;
66 efs->compactar = emufs_tipo3_compactar;
67 efs->modificar_registro = emufs_tipo3_modificar_registro;
68 efs->obtener_claves_raw = emufs_tipo3_obtener_claves_raw;
73 int emufs_tipo5_inicializar(EMUFS* efs)
75 /* como mínimo el tamaño de bloque debe ser 2 veces el tamaño de la cabecera
76 * (una relación 1/2 entre datos e info de control ya es lo suficientemente
78 if (efs->tam_bloque < (sizeof(EMUFS_REG_ID) * 2)) {
79 PERR("bloque demasiado chico");
80 return EMUFS_ERROR_BLOCK_TOO_SMALL;
82 /* Asigna punteros a funciones. */
83 efs->leer_bloque = emufs_tipo3_leer_bloque;
84 efs->leer_bloque_raw = emufs_tipo3_leer_bloque_raw;
85 efs->grabar_registro = emufs_tipo3_insertar_ordenado;
86 efs->borrar_registro = emufs_tipo3_eliminar_ordenado;
87 efs->leer_registro = emufs_tipo3_leer_registro_plus;
88 efs->leer_registro_raw = emufs_tipo3_leer_registro_raw;
89 efs->leer_estadisticas = emufs_tipo3_leer_estadisticas;
90 efs->compactar = emufs_tipo3_compactar;
91 efs->modificar_registro= emufs_tipo3_modificar_registro_plus;
95 /** Leo un registro del archivo, devuelve NULL si no lo encuentra.**/
96 void* emufs_tipo3_leer_registro(EMUFS *emu, CLAVE clave,
97 EMUFS_REG_SIZE* reg_size, int* err)
101 char* registro; /* registro a leer */
102 EMUFS_BLOCK_ID block;
103 EMUFS_REG_ID ID_aux, ID;
104 EMUFS_BLOCK_SIZE iterador = 0;
105 int cant_bloques = 0, resto, i, copiado=0;
107 cant_bloques = (emu->tam_reg / (emu->tam_bloque-sizeof(EMUFS_REG_ID))) + 1;
108 if ( emu->tam_reg+sizeof(EMUFS_REG_ID) == emu->tam_bloque )
111 /*si existe, lo busco en el archivo de bloques*/
112 if ((emu->indices != NULL) && (*err != 1)) {
113 /* TODO : Verificar donde esta el indice primario */
114 dato = emu->indices->existe_entrada(emu->indices, clave);
118 fprintf(stderr, "Datos leidos : id=%ld, bloque=%ld\n", ID, block);
120 /* Si no tengo claves, uso el campo entero para pasar un ID
125 block = emufs_idx_buscar_registro(emu,ID); /*me devuelve el nro de bloque al que pertenece el registro*/
126 if (*err == 1) *err = 0;
128 if ( block == EMUFS_NOT_FOUND ){
129 PERR("No se encontro el bloque");
134 registro = (char*) malloc(emu->tam_reg);
135 if (registro == NULL) {
136 PERR("No hay memoria");
137 *err = EMUFS_ERROR_OUT_OF_MEMORY;
141 resto = emu->tam_bloque - sizeof(EMUFS_REG_ID);
142 for (i=0; i<cant_bloques; i++){
143 if ((bloque = emufs_tipo3_leer_bloque(emu, block+i, err)) == NULL) {
144 /* TODO Manejo de errores, queda en el codigo de error lo que devolvio
145 * emufs_tipo3_leer_bloque() */
146 PERR("no se pudo leer el bloque");
148 return NULL; /*No se pudo leer el bloque*/
152 while ( iterador < emu->tam_bloque ) {
153 memcpy(&ID_aux, bloque+iterador, sizeof(EMUFS_REG_ID));
154 iterador += sizeof(EMUFS_REG_ID);
156 if ( cant_bloques == 0 )
157 memcpy(registro,bloque+iterador,emu->tam_reg);
159 if ( cant_bloques-1 == i )
160 resto = emu->tam_reg - copiado;
161 memcpy(registro+(emu->tam_bloque-sizeof(EMUFS_REG_ID))*i,bloque+iterador,resto);
165 *reg_size = emu->tam_reg;
167 iterador += emu->tam_reg;
175 /*leo el bloque "ID" del archivo que viene en "emu->nombre", y lo almaceno en "ptr"*/
176 void* emufs_tipo3_leer_bloque(EMUFS *emu, EMUFS_BLOCK_ID ID, int* err)
179 char* block; /* bloque leido (en donde está el registro a leer) */
182 strcpy(name_f,emu->nombre);
183 strcat(name_f,".dat");
185 if ((file = fopen(name_f, "r")) == NULL) {
186 PERR("No se pudo abrir el archivo de datos");
187 *err = EMUFS_ERROR_CANT_OPEN_FILE;
190 fseek(file,sizeof(EMUFS_Tipo)+sizeof(EMUFS_BLOCK_SIZE)+sizeof(EMUFS_REG_SIZE),SEEK_SET);
191 /*FIXME: verificar que no se pase de fin de archivo*/
192 if (fseek(file,ID*emu->tam_bloque,SEEK_CUR) != 0){
193 PERR("Fallo la busqueda del bloque");
198 block = (char*) malloc(emu->tam_bloque);
200 PERR("No hay memoria");
201 *err = EMUFS_ERROR_OUT_OF_MEMORY;
204 if (fread(block, emu->tam_bloque, 1, file) != 1) {
205 /* TODO Manejo de errores */
207 PERR("Error al leer bloque");
208 *err = EMUFS_ERROR_FILE_READ;
216 EMUFS_REG_ID emufs_tipo3_grabar_registro(EMUFS *emu, void *ptr, EMUFS_REG_SIZE tam, int* err)
218 INDICE_DATO idx_data;
220 EMUFS_FREE fs, new_fs;
221 EMUFS_BLOCK_ID num_bloque;
222 EMUFS_BLOCK_SIZE cant;
226 int cant_bloques, resto, i=0;
228 strcpy(name_f,emu->nombre);
229 strcat(name_f,".dat");
231 cant_bloques = (emu->tam_reg / (emu->tam_bloque-sizeof(EMUFS_REG_ID))) + 1;
232 if ( emu->tam_reg+sizeof(EMUFS_REG_ID) == emu->tam_bloque )
235 resto = emu->tam_bloque - sizeof(EMUFS_REG_ID);
239 if ( cant_bloques == 1 )
240 /* me devuelve el ID del bloque donde quepa un registro y el espacio libre en "fs"*/
241 num_bloque = emufs_fsc_buscar_lugar(emu, emu->tam_reg+sizeof(EMUFS_REG_ID), &fs);
243 /* me devuelve el ID del bloque donde quepan n registros y el espacio libre en "fs"*/
244 num_bloque = emufs_fsc_buscar_n_lugares(emu, cant_bloques, emu->tam_bloque, &fs, err);
246 /*si no hay bloques con suficiente espacio creo un bloque nuevo */
247 if (num_bloque == EMUFS_NOT_FOUND) {
248 if ( (file = fopen(name_f,"a+"))==NULL ) return -1; /*ERROR*/
249 /*tengo que buscar un ID valido para el nuevo registro*/
250 ID_aux = emufs_idx_get_new_id(emu, err);
251 /* El free esta al final de la funcion! */
252 bloque = (char*)malloc(emu->tam_bloque);
253 for (i=0; i<cant_bloques; i++) {
254 /*crear un nuevo bloque en memoria */
255 memset(bloque, 0, emu->tam_bloque);
256 /* grabar el registro al principio del bloque */
257 /*grabo el id en el bloque*/
258 memcpy(bloque,&ID_aux,sizeof(EMUFS_REG_ID));
259 /*grabo el registro en el bloque*/
260 if ( cant_bloques == 1 ){
261 memcpy(bloque+sizeof(EMUFS_REG_ID),ptr,emu->tam_reg);
263 if ( cant_bloques-1 == i )
264 resto = emu->tam_reg - i*(emu->tam_bloque - sizeof(EMUFS_REG_ID));
265 memcpy(bloque+sizeof(EMUFS_REG_ID),((char*)ptr)+i*(emu->tam_bloque-sizeof(EMUFS_REG_ID)),resto);
267 /* me paro al final del archivo */
268 fseek(file, 0, SEEK_END);
269 /* grabo el bloque en el final del archivo */
270 fwrite(bloque,emu->tam_bloque,1,file);
271 /*tengo que buscar la cantidad de bloques que existen*/
272 fseek(file, 0, SEEK_END); /* Me paro al final */
273 cant = (ftell(file)-(sizeof(EMUFS_Tipo)+sizeof(EMUFS_REG_SIZE)+sizeof(EMUFS_BLOCK_SIZE))) / emu->tam_bloque;
274 cant--; /* Resto uno porque el numero de bloque debe empezar en 0 */
278 /* Tengo que agregar el primer bloque en IDX */
279 if ( emufs_idx_agregar(emu, ID_aux, num_bloque) != 0 ){
283 idx_data.id = ID_aux;
284 idx_data.bloque = num_bloque;
285 emufs_indice_agregar(emu->indices, ptr, idx_data);
288 /* grabo el nuevo registro en el archivo de espacios libres */
289 if ( emu->tam_bloque-sizeof(EMUFS_REG_ID) < emu->tam_reg )
290 new_fs = emu->tam_bloque - sizeof(EMUFS_REG_ID) - resto ;
291 else new_fs = emu->tam_bloque - sizeof(EMUFS_REG_ID) - emu->tam_reg ;
292 if ( emufs_fsc_agregar(emu, num_bloque+i, new_fs) ) {
300 /*tengo que buscar un ID valido para el nuevo registro*/
301 ID_aux = emufs_idx_get_new_id(emu, err);
302 for (i=0; i<cant_bloques; i++){
303 resto = emu->tam_bloque-sizeof(EMUFS_REG_ID);
304 /*cargo el bloque en "bloque"*/
305 if (!(bloque = emufs_tipo3_leer_bloque(emu, num_bloque+i, err))) {
306 /* TODO Manejo de errores */
307 PERR("no se pudo leer el bloque");
310 /*El error puede haberse producido porque la funcion leer_bloque devolvio -1, el cual es un bloque invalido*/
311 /*insertar el registro en el bloque*/
312 /*grabo el id en el bloque*/
313 /*veo el espacio libre que queda*/
314 fs = emufs_fsc_get_fs(emu, num_bloque+i);
315 if (emu->tam_bloque-sizeof(EMUFS_REG_ID) < emu->tam_reg)
316 memcpy(bloque,&ID_aux,sizeof(EMUFS_REG_ID));
318 memcpy(bloque+emu->tam_bloque-fs,&ID_aux,sizeof(EMUFS_REG_ID));
319 /*grabo el registro en el bloque*/
320 if ( cant_bloques == 1 ){
321 memcpy(bloque+emu->tam_bloque-fs+sizeof(EMUFS_REG_ID),ptr,emu->tam_reg);
323 if ( cant_bloques-1 == i )
324 resto = emu->tam_reg - i*(emu->tam_bloque - sizeof(EMUFS_REG_ID));
325 memcpy(bloque+sizeof(EMUFS_REG_ID),((char*)ptr)+i*(emu->tam_bloque-sizeof(EMUFS_REG_ID)),resto);
328 /*grabo el bloque en el archivo*/
329 if ( emufs_tipo3_grabar_bloque(emu, bloque, num_bloque+i) != 0) {
330 PERR("error al grabar bloque");
331 if (bloque) free(bloque);
332 return -1; /* se produjo un error */
335 /*actualizo el archivo de espacios libres*/
336 if ( emu->tam_bloque-sizeof(EMUFS_REG_ID) < emu->tam_reg ){
337 /*Si el registro ocupa mas de un bloque (original) resto = emu->tam_bloque-sizeof(EMUFS_REG_ID)*/
338 resto += sizeof(EMUFS_REG_ID);
339 if ( cant_bloques-1 == i )
340 resto = emu->tam_reg - i*(emu->tam_bloque - sizeof(EMUFS_REG_ID))+sizeof(EMUFS_REG_ID);
341 if ( emufs_fsc_agregar(emu, num_bloque+i, fs-resto) !=0 ){
343 if (bloque) free(bloque);
347 /* si ocupa menos de un bloque*/
348 resto = emu->tam_reg;
349 if ( emufs_fsc_agregar(emu, num_bloque, fs - resto - sizeof(EMUFS_REG_ID) ) != 0 ) {
351 if (bloque) free(bloque);
356 if ( emufs_idx_agregar(emu, ID_aux, num_bloque) != 0 ){
357 if (bloque) free(bloque);
360 idx_data.id = ID_aux;
361 idx_data.bloque = num_bloque;
362 emufs_indice_agregar(emu->indices, ptr, idx_data);
366 if (bloque) free(bloque);
370 /*Graba un bloque en el archivo*/
371 int emufs_tipo3_grabar_bloque(EMUFS *emu, void *ptr, EMUFS_BLOCK_ID num)
376 strcpy(name_f,emu->nombre);
377 strcat(name_f,".dat");
379 if ( (file = fopen(name_f,"r+"))==NULL ) return -1; /*ERROR*/
380 /* Salto el header del archivo */
381 fseek(file, sizeof(EMUFS_Tipo)+sizeof(EMUFS_REG_SIZE)+sizeof(EMUFS_BLOCK_SIZE), SEEK_SET);
382 fseek(file, num*emu->tam_bloque, SEEK_CUR);
383 fwrite(ptr, emu->tam_bloque, 1, file);
389 /*borra un registro de un bloque y acomoda los registros que quedan*/
390 int emufs_tipo3_borrar_registro(EMUFS *emu, CLAVE k, INDICE_DATO dato1)
392 EMUFS_BLOCK_SIZE num_bloque;
393 EMUFS_BLOCK_SIZE ptr_elim;
394 EMUFS_BLOCK_SIZE ptr_mov;
395 EMUFS_REG_ID ID_aux, ID;
399 int err = 0, i, cant_bloques;
401 /*cantidad de bloques que ocupa un registro*/
402 cant_bloques = emu->tam_reg/(emu->tam_bloque-sizeof(EMUFS_REG_ID))+1;
403 if ( emu->tam_reg+sizeof(EMUFS_REG_ID) == emu->tam_bloque )
406 PERR("Buscando datos del registro en el indice");
407 if (emu->indices != NULL) {
408 dato = emu->indices->existe_entrada(emu->indices, k);
409 num_bloque = dato.bloque;
413 num_bloque = emufs_idx_buscar_registro(emu, ID);
416 if (!(bloque = emufs_tipo3_leer_bloque(emu, num_bloque, &err))) {
417 /* TODO Manejo de errores */
418 PERR("no se pudo leer el bloque");
422 /*apunto al registro que voy a eliminar*/
424 while ( ptr_elim < emu->tam_bloque ){
425 memcpy(&ID_aux, bloque+ptr_elim, sizeof(EMUFS_REG_ID));
428 ptr_elim += emu->tam_reg + sizeof(EMUFS_REG_ID);
431 /*apunto al registro que voy a mover*/
432 ptr_mov = ptr_elim + emu->tam_reg + sizeof(EMUFS_REG_ID);
434 while ( (ptr_mov+sizeof(EMUFS_REG_ID)+emu->tam_reg) < emu->tam_bloque ){
435 memcpy(bloque+ptr_elim, bloque+ptr_mov, sizeof(EMUFS_REG_ID)+emu->tam_reg);
436 /* Blanqueo el area que movi */
437 memset(bloque+ptr_mov, 0, sizeof(EMUFS_REG_ID)+emu->tam_reg);
439 ptr_mov += sizeof(EMUFS_REG_ID) + emu->tam_reg;
442 /*grabo el bloque en el archivo*/
443 if ( emu->tam_bloque-sizeof(EMUFS_REG_ID) < emu->tam_reg )
444 memset(bloque, 0, emu->tam_bloque);
445 if ( emufs_tipo3_grabar_bloque(emu, bloque, num_bloque) == -1 ){
447 PERR("No se pudo grabar el bloque");
451 /*actualizo archivo .fsc*/
452 if ( emu->tam_bloque-sizeof(EMUFS_REG_ID) < emu->tam_reg ) {
453 for (i=0; i<cant_bloques; i++)
454 if (emufs_fsc_agregar(emu, num_bloque+i, emu->tam_bloque)) {
455 PERR("no se pudo agregar fsc");
460 fs = emufs_fsc_get_fs(emu, num_bloque);
461 if (emufs_fsc_agregar(emu, num_bloque, fs + emu->tam_reg + sizeof(EMUFS_REG_ID))) {
462 PERR("no se pudo agregar fsc");
467 /*actualizo archivo .did*/
468 if (emufs_did_agregar(emu, ID)) {
469 PERR("no se pudo agregar did");
474 /*actualizo archivo .idx*/
475 if (emufs_idx_borrar(emu, ID)) {
476 PERR("no se pudo agregar idx");
482 PERR("Borrando claves");
483 emufs_indice_borrar(emu->indices, k, dato1);
484 PERR("Clave borrada de todos los indices");
488 EMUFS_Estadisticas emufs_tipo3_leer_estadisticas(EMUFS *emu)
490 int err = 0,err1 = 0, err2 = 0, err3 = 0;
491 EMUFS_Estadisticas stats;
492 memset(&stats,0,sizeof(EMUFS_Estadisticas));
494 { /* obtengo tamaño del archivo en bytes */
496 strcpy(name_f, emu->nombre);
497 strcat(name_f, ".dat");
498 stats.tam_archivo = emufs_common_get_file_size(name_f, &err);
500 PERR("no se pudo obtener el tamaño del archivo");
505 /* obtengo la cantidad de bloques en el archivo */
506 stats.cant_bloques = (stats.tam_archivo-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE)-sizeof(EMUFS_REG_SIZE))/
509 /* obtengo la cantidad de registros en el archivo */
511 EMUFS_REG_ID *tmp = emufs_idx_get(emu, &stats.cant_registros);
512 if (tmp) free(tmp); /* libera memoria innecesaria */
515 /* obtengo información de control que guarda el archivo .dat */
516 stats.tam_info_control_dat = stats.cant_registros*sizeof(EMUFS_REG_ID)+sizeof(EMUFS_Tipo)+
517 sizeof(EMUFS_BLOCK_SIZE)+sizeof(EMUFS_REG_SIZE);
519 /* Obtengo las stats de FSC */
520 stats.total_fs = emufs_fsc_get_total_fs(emu);
521 stats.media_fs = emufs_fsc_get_media_fs(emu);
522 emufs_fsc_get_max_min_fs(emu,&stats.min_fs,&stats.max_fs);
524 /* obtengo informacion de control guardada por los archivos auxiliares */
525 stats.tam_archivos_aux = emufs_idx_get_file_size(emu,&err1) + emufs_fsc_get_file_size(emu,&err2)
526 + emufs_did_get_file_size(emu,&err3);
527 if (err1 || err2 || err3) {
528 PERR("Hubo problemas en lectura de filesize archivos auxiliares");
535 EMUFS_REG_ID emufs_tipo3_modificar_registro(EMUFS *emu, CLAVE k, void *data, EMUFS_REG_SIZE size, int *error, INDICE_DATO dato)
537 emufs_tipo3_borrar_registro(emu, k, dato);
538 return emufs_tipo3_grabar_registro(emu, data, size, error);
541 void* emufs_tipo3_leer_registro_raw(EMUFS *emu, EMUFS_REG_ID ID, EMUFS_REG_SIZE *size, int *pos)
544 EMUFS_BLOCK_ID block;
546 EMUFS_BLOCK_SIZE iterador = 0;
551 /* Aca estoy en el caso de que 1 registro entra en 1 solo bloque */
552 block = emufs_idx_buscar_registro(emu,ID);
553 if ( block == EMUFS_NOT_FOUND ) {
556 if ((bloque = emufs_tipo3_leer_bloque(emu, block, &err)) == NULL) {
563 /* Busco el offset desde el comienzo desde donde arranca el registro
564 * buscado, para luego resaltarlo en al GUI
566 while ( iterador < emu->tam_bloque ) {
567 memcpy(&ID_aux, bloque+iterador, sizeof(EMUFS_REG_ID));
570 *size = emu->tam_bloque;
573 iterador += sizeof(EMUFS_REG_ID);
574 iterador += emu->tam_reg;
579 void emufs_tipo3_compactar(EMUFS *emu)
582 #ifdef PEPITO_EL_GALAN
583 EMUFS_REG_ID *tmp, max_id;
584 EMUFS_BLOCK_ID block_id;
589 int err=0, ID_aux, i;
591 strcpy(name, emu->nombre);
592 strcat(name, ".dat");
594 tmp = emufs_idx_get(emu, &max_id);
596 for( i=0; i<max_id; i++){
597 /* si el id no existe paso al siguiente*/
598 if ( emufs_idx_existe_id(emu, i) != 0 ) continue;
599 reg = emufs_tipo3_leer_registro(emu, i, &size, &err);
601 PERR("No se pudo leer el registro para reacomodar");
604 emufs_tipo3_borrar_registro(emu, i);
605 ID_aux = emufs_tipo3_grabar_registro(emu, reg, emu->tam_reg, &err);
608 /*trunco el archivo sacando los bloques vacios*/
609 block_id = emufs_fsc_buscar_lugar(emu, emu->tam_bloque, &fs);
610 size = sizeof(EMUFS_Tipo)+sizeof(EMUFS_REG_SIZE)+sizeof(EMUFS_BLOCK_SIZE)+block_id*emu->tam_bloque;
611 if (truncate(name, size)!=0)
612 PERR("NO TRUNQUE NADA");
613 /*hay que truncar el fsc!!!*/
614 if(emu->tam_bloque-sizeof(EMUFS_REG_ID) < emu->tam_reg) block_id = block_id/2;
615 if (emufs_fsc_truncate(emu, block_id)!= 0)
616 PERR("NO TURNQUE EL FSC");
620 void emufs_tipo3_leer_bloque_raw(EMUFS *efs, EMUFS_BLOCK_ID id, char **actual, char **anterior, char **siguiente,
621 EMUFS_BLOCK_SIZE *size1, EMUFS_BLOCK_SIZE *size2, EMUFS_BLOCK_SIZE *size3)
624 (*actual) = emufs_tipo3_leer_bloque(efs, id, &err);
625 (*anterior) = emufs_tipo3_leer_bloque(efs, id-1, &err);
626 (*siguiente) = emufs_tipo3_leer_bloque(efs, id+1, &err);
628 (*anterior) = (char *)malloc(efs->tam_bloque);
629 memset(*anterior, 0, efs->tam_bloque);
632 (*siguiente) = (char *)malloc(efs->tam_bloque);
633 memset(*siguiente, 0, efs->tam_bloque);
635 (*size1) = (*size2) = (*size3) = efs->tam_bloque;
638 EMUFS_REG_ID emufs_tipo3_insertar_ordenado(EMUFS *emu, void *ptr, EMUFS_REG_SIZE size, int *err)
640 CLAVE clave, menor_clave_bloque_nuevo;
641 EMUFS_BLOCK_ID num_bloque;
643 EMUFS_REG_SIZE tam_reg, move_size;
646 char *bloque = 0, *aux, *new_bloque = 0;
647 int cant_reg, i, result, dif;
650 /*le asigno un posible numero de bloque para el caso en que no encuentre donde meterlo*/
651 num_bloque = emufs_get_new_block_number(emu);
652 query.num_bloque = num_bloque;
653 /*saco la clave del stream*/
654 query.clave = emufs_indice_generar_clave(emu->indices, ptr);
655 /*mando a buscar en el arbol el bloque correspondiente a esa clave*/
656 /*en query->num_bloque tengo el bloque donde debo meter el registro*/
657 /*debo insertar el reg en el bloque en forma ordenada*/
658 /*si es el menor de todos tengo que cambiar el ancla en el arbol*/
659 /*si no entra, tengo que insertar una nueva clave en el arbol y separar los registros en 2 bloques*/
660 /* emufs_b_plus_get_bloque retorna asi
661 -1 = Nuevo bloque, retorno idem num_bloque que ingreso
662 0 = Sin problemas, retorno bloque donde insertar
663 1 = Error de lectura en algun nodo, abortar operacion en funcion invocante.
665 result = emufs_b_plus_get_bloque(emu->indices, &query, 0);
667 PERR("SE PRODUJO UN ERROR EN EL ARBOL.. ABORTANDO");
671 /*creo un bloque nuevo*/
672 bloque = (char*) malloc(emu->tam_bloque);
674 PERR("NO SE PUDO CREAR EL BLOQUE");
677 memset(bloque, 0, emu->tam_bloque);
678 header = emufs_idx_get_new_id(emu, err);
680 PERR("NO SE PUDO OBTENER UN ID");
685 /*pongo la cabecera en el registro*/
686 memcpy(bloque, &header, sizeof(EMUFS_REG_ID));
687 /*inserto el footer en el bloque*/
688 memcpy(bloque+emu->tam_bloque-sizeof(int), &cant_reg, sizeof(int));
689 /*inserto el registro en el bloqude*/
690 if ( size <= emu->tam_bloque-sizeof(EMUFS_REG_ID)-sizeof(int) )
691 memcpy(bloque+sizeof(EMUFS_REG_ID), ptr, size);
693 PERR("NO ENTRA EL REGISTRO EN EL BLOQUE!!!!!");
697 /*hago lugar en el archivo para grabar*/
698 if ( num_bloque != emufs_create_new_block(emu) ) PERR("NUMEROS DE NUEVO BLOQUE DISTINTOS");
699 /*grabo el bloque en el archivo*/ /* OJO CON LO DE FS = 0 */
700 emufs_tipo3_grabar_bloque(emu, bloque, query.num_bloque);
701 /*agrego la clave al arbol*/
702 emufs_b_plus_insertar(emu->indices, &query);
705 } else { /*tengo que meter el registro en el bloque que me dijo el arbol*/
706 /*leo el bloque correspondiente*/
707 bloque = emufs_tipo3_leer_bloque(emu, query.num_bloque, err);
708 /*me fijo cuantos registros hay en el */
709 memcpy(&cant_reg, bloque+emu->tam_bloque-sizeof(int), sizeof(int));
710 /*me fijo si entra en nuevo reg en el bloque */
711 fs = emu->tam_bloque;
713 for (i=0; i<cant_reg; i++){
714 aux += sizeof(EMUFS_REG_ID)+tam_reg;
715 fs -= (tam_reg+sizeof(EMUFS_REG_ID));
716 } /*aca deberia estar apuntando al final de los registros. espacio libre*/
717 fs -= sizeof(int); /*footer*/
718 if ( fs >= size+sizeof(EMUFS_REG_ID) ){ /* puedo meter el registro en este bloque*/
719 PERR("GRABO ORDENADO");
720 grabar_ordenado_en_bloque(emu, ptr, size, bloque, query.num_bloque, fs, err);
721 /*en teoria el nuevo registro no debe cambiar el ancla, por lo cual no actualizo el arbol*/
724 } else { /* el registro no entra en el bloque, hay que crear uno nuevo y desparramar */
725 PERR(" COMO NO ENTRA DEBO DIVIDIR LOS REGISTROS EN 2 BLOQUES");
726 new_bloque = (char*)malloc(emu->tam_bloque);
727 memset(new_bloque,0,emu->tam_bloque);
730 for(i=0; i<cant_reg/2; i++){ /*copio mitad-1 aca y mitad en el nuevo*/
732 aux += sizeof(EMUFS_REG_ID)+tam_reg;
733 move_size += sizeof(EMUFS_REG_ID)+tam_reg;
734 }/*apunto al reg mitad_mas_uno para copiar todo a otro bloque*/
735 /*copio el resto del bloque al nuevo bloque*/ /*footer ¿?*/
736 memcpy(new_bloque, aux, emu->tam_bloque-move_size-sizeof(int));
737 /*borro lo que sobra en el bloque original, guardando el footer*/
738 memset(aux, 0, emu->tam_bloque - move_size - sizeof(int));
739 menor_clave_bloque_nuevo = emufs_indice_generar_clave(emu->indices, new_bloque+sizeof(EMUFS_REG_ID));
740 /* TENGO QUE VER EN CUAL DE LOS DOS BLOQUES METO EL REGISTRO NUEVO */
741 if ( emufs_indice_es_menor(emu->indices, menor_clave_bloque_nuevo, clave) ){
742 /* GRABO EN EL BLOQUE NUEVO */
743 /*actualizo la cant de registros del bloque original (footer)*/
744 memcpy(bloque+emu->tam_bloque-sizeof(int), &i, sizeof(int));
745 /*actualizo el footer del nuevo bloque*/
746 dif = cant_reg - i; /*por las dudas*/
747 memcpy(new_bloque+emu->tam_bloque-sizeof(int), &dif, sizeof(int));
748 /*genero un nuevo espacio para un bloque en el archivo y lo cargo en queryla clave ya estaba en query desde antes*/
749 num_bloque = query.num_bloque;
750 query.num_bloque = emufs_create_new_block(emu);
751 /*inserto el nuevo registro en el nuevo bloque y obtengo la clave del menor*/
752 clave = grabar_ordenado_en_bloque(emu,ptr,size,new_bloque,query.num_bloque, emu->tam_bloque-move_size,err);
753 /*actualizo el arbol con la nueva clave*/
755 emufs_b_plus_insertar(emu->indices, &query);
756 /*grabo el bloque original*/
757 emufs_tipo3_grabar_bloque(emu, bloque, num_bloque);
759 PERR("GRABO EN BLOQUE VIEJO");
760 /* GRABO EN EL BLOQUE VIEJO */
761 /*actualizo la cant de registros del bloque original (footer)*/
762 memcpy(bloque+emu->tam_bloque-sizeof(int), &i, sizeof(int));
763 /*actualizo el footer del nuevo bloque*/
764 dif = cant_reg - i; /*por las dudas*/
765 /*meto el footer en el reg */
766 memcpy(new_bloque+emu->tam_bloque-sizeof(int), &dif, sizeof(int));
767 /*guardo el num de bloque original */
768 num_bloque = query.num_bloque;
769 /* pido un bloque nuevo para guardar */
770 query.num_bloque = emufs_create_new_block(emu);
771 /*grabo el bloque nuevo*/
772 emufs_tipo3_grabar_bloque(emu, new_bloque, query.num_bloque);
773 /*grabo el registro en el bloque original*/
774 grabar_ordenado_en_bloque(emu,ptr,size,bloque,num_bloque,fs+move_size,err);
775 /*actualizo el arbol con la menor clave del bloque nuevo*/
776 query.clave = emufs_indice_generar_clave(emu->indices, new_bloque+sizeof(EMUFS_REG_ID));
777 emufs_b_plus_insertar(emu->indices, &query);
780 PERR("NO SE PUDO GRABAR ORDENADO");
790 if (new_bloque) free(new_bloque);
791 if (bloque) free(bloque);
795 /*inserta un registro ordenado en un bloque y devuelve la menor de las claves*/
796 CLAVE grabar_ordenado_en_bloque(EMUFS *emu, void *ptr, EMUFS_REG_SIZE size, void *bloque, int num_bloque, EMUFS_FREE fs, int *err)
798 char *aux, *new_bloque;
799 int cant_reg, tam_reg, i, j;
801 CLAVE clave, clave_ajena;
804 /*saco la cant de registros del bloque*/
805 memcpy(&cant_reg, bloque+emu->tam_bloque-sizeof(int), sizeof(int));
806 /*obtengo la clave del nuevo registro*/
807 clave = emufs_indice_generar_clave(emu->indices, ptr);
809 header = emufs_idx_get_new_id(emu, err);
810 new_bloque = (char*)malloc(emu->tam_bloque);
811 memset(new_bloque, 0, emu->tam_bloque);
813 for (i=0; i<cant_reg+1; i++){
814 bloque += sizeof(EMUFS_REG_ID); /*salteo el encabezado del registro*/
815 if ( emu->tam_bloque-fs < sizeof(EMUFS_REG_ID)+emu->indices->offset ){
816 PERR("ESTOY LEYENDO FUERA DEL BLOQUE!!!");
821 clave_ajena = emufs_indice_generar_clave(emu->indices, bloque); /*leo la clave*/
822 bloque -= sizeof(EMUFS_REG_ID); /*vuelvo al principio*/
823 if ( i<cant_reg && emufs_indice_es_menor(emu->indices, clave_ajena, clave) ){
824 /*copio el reg al bloque nuevo*/
825 memcpy(new_bloque, bloque, sizeof(EMUFS_REG_ID)+tam_reg);
826 bloque += sizeof(EMUFS_REG_ID)+ tam_reg; /*paso al proximo*/
827 new_bloque += sizeof(EMUFS_REG_ID)+ tam_reg; /*dejo preparado*/
830 /*meto el registro que me mandan*/
831 memcpy(new_bloque, &header, sizeof(EMUFS_REG_ID));
832 memcpy(new_bloque+sizeof(EMUFS_REG_ID), ptr, size);
833 new_bloque += sizeof(EMUFS_REG_ID)+size;
834 /*tengo que copiar los que faltan*/
836 while ( j < cant_reg ){
837 memcpy(new_bloque, bloque, sizeof(EMUFS_REG_ID)+tam_reg);
838 bloque += sizeof(EMUFS_REG_ID)+tam_reg;
839 new_bloque += sizeof(EMUFS_REG_ID)+tam_reg;
842 break; /*corto el for porque ya inserte todos*/
845 /*grabo el bloque en el archivo*/
846 new_bloque = aux; /*apunto al principio del bloque*/
847 cant_reg++; /*voy a poner un reg mas*/
848 memcpy(new_bloque+emu->tam_bloque-sizeof(int), &cant_reg, sizeof(int));
849 emufs_tipo3_grabar_bloque(emu, new_bloque, num_bloque);
850 clave = emufs_indice_generar_clave(emu->indices, new_bloque+sizeof(EMUFS_REG_ID));
855 int emufs_tipo3_eliminar_ordenado(EMUFS *emu, CLAVE clave, INDICE_DATO dato)
859 int result, iter, cant_reg;
860 EMUFS_REG_SIZE tam_reg = emu->tam_reg;
861 CLAVE clave_ajena, ancla;
864 /*cargo el query para buscar*/
865 query.num_bloque = 0;
867 /*mando a buscar el bloque donde esta la clave que quiero eliminar*/
868 result = emufs_b_plus_get_bloque(emu->indices, &query, 0);
870 PERR("SE PRODUJO UN ERROR EN EL ARBOL");
874 PERR("NO EXISTE EL BLOQUE ¿?¿?¿?");
877 /*cargo el bloque que corresponde*/
878 bloque = emufs_tipo3_leer_bloque(emu, query.num_bloque, &err);
879 if ( bloque == NULL ){
880 PERR("NO SE CARGO EL BLOQUE");
883 /*me fijo si el que tengo que eliminar es el ancla del bloque*/
884 ancla = emufs_indice_generar_clave(emu->indices, bloque+sizeof(EMUFS_REG_ID));
885 /*leo la cantidad de registros en el bloque*/
886 memcpy(&cant_reg, bloque+emu->tam_bloque-sizeof(int), sizeof(int));
890 while ( iter < emu->tam_bloque ){
891 clave_ajena = emufs_indice_generar_clave(emu->indices, aux+sizeof(EMUFS_REG_ID));
892 if ( emufs_indice_es_igual(emu->indices, clave, clave_ajena) ){
893 /*tenngo que borrar este registro*/
894 /*limpio el espacio que ocupaba*/
895 memset(aux, 0, tam_reg+sizeof(EMUFS_REG_ID));
896 /*hay que reacomodar todo*/
897 /*me posiciono en el reg siguiente*/
898 iter += tam_reg+sizeof(EMUFS_REG_ID);
899 break;/*ya borre, corto aca*/
901 iter += tam_reg+sizeof(EMUFS_REG_ID);
902 aux += tam_reg+sizeof(EMUFS_REG_ID);
904 /*reacomodo el bloque */
905 memcpy(aux, aux+tam_reg+sizeof(EMUFS_REG_ID), emu->tam_bloque-iter-sizeof(int));
906 /*le vuelvo a copiar la cantidad de registros*/
908 memcpy(bloque+emu->tam_bloque-sizeof(int), &cant_reg, sizeof(int));
909 /*grabo el bloque en el archivo*/
910 if ( emufs_tipo3_grabar_bloque(emu, bloque, query.num_bloque) == -1){
911 PERR("NO SE PUDO GRABAR EL BLOQUE");
915 /*me fijo si el que tengo que eliminar es el ancla del bloque*/
916 if ( emufs_indice_es_igual(emu->indices, clave, ancla) ){
918 emufs_b_plus_eliminar(emu->indices, clave, 0);
920 /*obtengo la nueva ancla del bloque*/
921 query.clave = emufs_indice_generar_clave(emu->indices, bloque+sizeof(EMUFS_REG_ID));
922 emufs_b_plus_reemplazar_clave(emu->indices, ancla, query, 0);
929 void *emufs_tipo3_leer_registro_plus(EMUFS *emu, CLAVE clave, EMUFS_REG_SIZE *size, int *err)
935 int result, cant_reg, i;
936 EMUFS_REG_SIZE tam_reg;
938 tam_reg = emu->tam_reg;
941 query.num_bloque = 0;
944 result = emufs_b_plus_get_bloque(emu->indices, &query, 0);
946 PERR("NO EXISTE EL BLOQUE");
950 PERR("SE PRODUJO UN ERROR EN EL ARBOL");
954 bloque = emufs_tipo3_leer_bloque(emu, query.num_bloque, err);
955 /*busco el registro en el bloque*/
956 /*copio la cantidad de registros*/
957 memcpy(&cant_reg, bloque+emu->tam_bloque-sizeof(int), sizeof(int));
959 for (i=0; i<cant_reg; i++){
961 clave_ajena = emufs_indice_generar_clave(emu->indices, aux+sizeof(EMUFS_REG_ID));
962 if ( emufs_indice_es_igual(emu->indices, clave, clave_ajena) ){
963 reg = (char*)malloc(tam_reg);
965 PERR("NO SE PUDO CARGAR EL REGISTRO");
970 /*copio el registro*/
971 memcpy(reg, aux+sizeof(EMUFS_REG_ID), tam_reg);
973 break; /*ya lo encontre, corto el for*/
975 aux += tam_reg+sizeof(EMUFS_REG_ID); /*paso al proximo*/
977 if ( i == cant_reg ) *err=-1;
983 EMUFS_REG_ID emufs_tipo3_modificar_registro_plus(EMUFS *emu, CLAVE k, void *ptr , EMUFS_REG_SIZE size, int* err, INDICE_DATO dato)
985 emufs_tipo3_eliminar_ordenado(emu, k, dato);
986 return emufs_tipo3_insertar_ordenado(emu, ptr, size, err);
989 B_PLUS_KEYBUCKET *emufs_tipo3_obtener_claves_raw(EMUFS *emu, int num_bloque)
991 B_PLUS_KEYBUCKET *keys;
993 int err = 0, cant_reg, i;
994 EMUFS_REG_SIZE tam_reg = emu->tam_reg;
996 keys = (B_PLUS_KEYBUCKET*)malloc(sizeof(B_PLUS_KEYBUCKET));
998 PERR("NO SE PUDO CREAR EL BUCKET");
1002 bloque = emufs_tipo3_leer_bloque(emu, num_bloque, &err);
1003 if ( bloque == NULL ){
1004 PERR("NO SE PUDO LEER EL BLOQUE");
1008 /*leo la cantidad de registros*/
1009 memcpy(&cant_reg, bloque+emu->tam_bloque-sizeof(int), sizeof(int));
1010 /*ya se cuanto guardarle al vector*/
1011 keys->claves = (CLAVE*)malloc(cant_reg*sizeof(CLAVE));
1012 if (keys->claves == NULL){
1013 PERR("NO SE PUDO CREAR EL ARRAY DE CLAVES");
1017 keys->cant_keys = cant_reg;
1018 keys->current_key = 0;
1020 for (i=0; i<cant_reg; i++){
1021 keys->claves[i] = emufs_indice_generar_clave(emu->indices, bloque+sizeof(EMUFS_REG_ID));
1022 bloque += tam_reg+sizeof(EMUFS_REG_ID);