+ if (new_bloque) free(new_bloque);
+ if (bloque) free(bloque);
+ return 0;
+}
+
+/*inserta un registro ordenado en un bloque y devuelve la menor de las claves*/
+CLAVE grabar_ordenado_en_bloque(EMUFS *emu, void *ptr, EMUFS_REG_SIZE size, void *bloque, int num_bloque, EMUFS_FREE fs, int *err)
+{
+ char *aux, *new_bloque;
+ int cant_reg, tam_reg, i, j;
+ EMUFS_REG_ID header;
+ CLAVE clave, clave_ajena;
+
+ tam_reg = size;
+ /*saco la cant de registros del bloque*/
+ memcpy(&cant_reg, bloque+emu->tam_bloque-sizeof(int), sizeof(int));
+ /*obtengo la clave del nuevo registro*/
+ clave = emufs_indice_generar_clave(emu->indices, ptr);
+ /*cargo el header*/
+ header = emufs_idx_get_new_id(emu, err);
+ new_bloque = (char*)malloc(emu->tam_bloque);
+ memset(new_bloque, 0, emu->tam_bloque);
+ aux = new_bloque;
+ for (i=0; i<cant_reg+1; i++){
+ bloque += sizeof(EMUFS_REG_ID); /*salteo el encabezado del registro*/
+ if ( emu->tam_bloque-fs < sizeof(EMUFS_REG_ID)+emu->indices->offset ){
+ PERR("ESTOY LEYENDO FUERA DEL BLOQUE!!!");
+ free(new_bloque);
+ *err = -1;
+ return clave;
+ }
+ clave_ajena = emufs_indice_generar_clave(emu->indices, bloque); /*leo la clave*/
+ bloque -= sizeof(EMUFS_REG_ID); /*vuelvo al principio*/
+ if ( i<cant_reg && emufs_indice_es_menor(emu->indices, clave_ajena, clave) ){
+ /*copio el reg al bloque nuevo*/
+ memcpy(new_bloque, bloque, sizeof(EMUFS_REG_ID)+tam_reg);
+ bloque += sizeof(EMUFS_REG_ID)+ tam_reg; /*paso al proximo*/
+ new_bloque += sizeof(EMUFS_REG_ID)+ tam_reg; /*dejo preparado*/
+ continue;
+ } else {
+ /*meto el registro que me mandan*/
+ memcpy(new_bloque, &header, sizeof(EMUFS_REG_ID));
+ memcpy(new_bloque+sizeof(EMUFS_REG_ID), ptr, size);
+ new_bloque += sizeof(EMUFS_REG_ID)+size;
+ /*tengo que copiar los que faltan*/
+ j = i;
+ while ( j < cant_reg ){
+ memcpy(new_bloque, bloque, sizeof(EMUFS_REG_ID)+tam_reg);
+ bloque += sizeof(EMUFS_REG_ID)+tam_reg;
+ new_bloque += sizeof(EMUFS_REG_ID)+tam_reg;
+ j++;
+ }
+ break; /*corto el for porque ya inserte todos*/
+ }
+ }
+ /*grabo el bloque en el archivo*/
+ new_bloque = aux; /*apunto al principio del bloque*/
+ cant_reg++; /*voy a poner un reg mas*/
+ memcpy(new_bloque+emu->tam_bloque-sizeof(int), &cant_reg, sizeof(int));
+ emufs_tipo3_grabar_bloque(emu, new_bloque, num_bloque);
+ clave = emufs_indice_generar_clave(emu->indices, new_bloque+sizeof(EMUFS_REG_ID));
+ free(new_bloque);
+ return clave;
+}
+
+int emufs_tipo3_eliminar_ordenado(EMUFS *emu, CLAVE clave, int *err)
+{
+ char *bloque, *aux;
+ INDEX_DAT query;
+ int result, iter, cant_reg;
+ EMUFS_REG_SIZE tam_reg = emu->tam_reg;
+ CLAVE clave_ajena;
+
+ /*cargo el query para buscar*/
+ query.num_bloque = 0;
+ query.clave = clave;
+ /*mando a buscar el bloque donde esta la clave que quiero eliminar*/
+ result = emufs_b_plus_get_bloque(emu->indices, &query, 0);
+ if ( result == 1 ){
+ PERR("SE PRODUJO UN ERROR EN EL ARBOL");
+ return -1;
+ }
+ if ( result == -1 ){
+ PERR("NO EXISTE EL BLOQUE ¿?¿?¿?");
+ return -1;
+ }
+ /*cargo el bloque que corresponde*/
+ bloque = emufs_tipo3_leer_bloque(emu, query.num_bloque, err);
+ if ( bloque == NULL ){
+ PERR("NO SE CARGO EL BLOQUE");
+ return -1;
+ }
+ /*leo la cantidad de registros en el bloque*/
+ memcpy(&cant_reg, bloque+emu->tam_bloque-sizeof(int), sizeof(int));
+ /*busco y elimino*/
+ iter = 0;
+ aux = bloque;
+ /*me fijo si el que tengo que eliminar es el ancla del bloque*/
+ clave_ajena = emufs_indice_generar_clave(emu->indices, bloque+sizeof(EMUFS_REG_ID));
+ if ( emufs_indice_es_igual(emu->indices, clave, clave_ajena) ){
+ /* TENGOQ QUE BORRAR LA CLAVE DEL ARBOL !!!!*/
+ /* Y HAY QUE BORRAR EL BLOQUE DEL ARCHIVO*/
+ }
+ while ( iter < emu->tam_bloque ){
+ clave_ajena = emufs_indice_generar_clave(emu->indices, aux+sizeof(EMUFS_REG_ID));
+ if ( emufs_indice_es_igual(emu->indices, clave, clave_ajena) ){
+ /*tenngo que borrar este registro*/
+ /*limpio el espacio que ocupaba*/
+ memset(aux, 0, tam_reg+sizeof(EMUFS_REG_ID));
+ /*hay que reacomodar todo*/
+ /*me posiciono en el reg siguiente*/
+ iter += tam_reg+sizeof(EMUFS_REG_ID);
+ break;/*ya borre, corto aca*/
+ }
+ iter += tam_reg+sizeof(EMUFS_REG_ID);
+ aux += tam_reg+sizeof(EMUFS_REG_ID);
+ }
+ /*reacomodo el bloque */
+ memcpy(aux, aux+tam_reg+sizeof(EMUFS_REG_ID), emu->tam_bloque-iter-sizeof(int));
+ /*le vuelvo a copiar la cantidad de registros*/
+ cant_reg--;
+ memcpy(bloque+emu->tam_bloque-sizeof(int), &cant_reg, sizeof(int));
+ /*grabo el bloque en el archivo*/
+ if ( emufs_tipo3_grabar_bloque(emu, bloque, query.num_bloque) == -1){
+ PERR("NO SE PUDO GRABAR EL BLOQUE");
+ free(bloque);
+ return -1;
+ }
+ free(bloque);
+ return 0;
projects / z.facultad / 75.06 / emufs.git / blobdiff