+}
+
+int emufs_tipo1_eliminar_ordenado(EMUFS *emu, CLAVE clave, INDICE_DATO dato)
+{
+ char *bloque, *aux;
+ INDEX_DAT query;
+ int result, iter, cant_reg;
+ EMUFS_REG_SIZE tam_reg;
+ CLAVE clave_ajena, ancla;
+ int err = 0;
+
+ /*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_tipo1_leer_bloque(emu, query.num_bloque, &err);
+ if ( bloque == NULL ){
+ PERR("NO SE CARGO EL BLOQUE");
+ return -1;
+ }
+ /*me fijo si el que tengo que eliminar es el ancla del bloque*/
+ ancla = emufs_indice_generar_clave(emu->indices, bloque+sizeof(EMUFS_TIPO1_REG_HEADER));
+ /*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;
+ while ( iter < emu->tam_bloque /*&& leidos < cant_reg*/){
+ memcpy(&tam_reg, aux+sizeof(EMUFS_REG_ID), sizeof(EMUFS_REG_SIZE));
+ clave_ajena = emufs_indice_generar_clave(emu->indices, aux+sizeof(EMUFS_TIPO1_REG_HEADER));
+ if ( emufs_indice_es_igual(emu->indices, clave, clave_ajena) ){
+ /*tengo que borrar este registro*/
+ /*limpio el espacio que ocupaba*/
+ memset(aux, 0, tam_reg+sizeof(EMUFS_TIPO1_REG_HEADER));
+ /*hay que reacomodar todo*/
+ /*me posiciono en el reg siguiente*/
+ iter += tam_reg+sizeof(EMUFS_TIPO1_REG_HEADER);
+ break;/*ya borre, corto aca*/
+ }
+ iter += tam_reg+sizeof(EMUFS_TIPO1_REG_HEADER);
+ aux += tam_reg+sizeof(EMUFS_TIPO1_REG_HEADER);
+ }
+ /*reacomodo el bloque */
+ memcpy(aux, aux+tam_reg+sizeof(EMUFS_TIPO1_REG_HEADER), 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_tipo1_grabar_bloque_fsc(emu, bloque, query.num_bloque, EMUFS_NOT_FOUND, &err) == EMUFS_NOT_FOUND ){
+ PERR("NO SE PUDO GRABAR EL BLOQUE");
+ free(bloque);
+ return -1;
+ }
+ /*me fijo si el que tengo que eliminar es el ancla del bloque*/
+ if ( emufs_indice_es_igual(emu->indices, clave, ancla) ){
+ if ( cant_reg == 0 )
+ emufs_b_plus_eliminar(emu->indices, clave, 0);
+ else {
+ /*obtengo la nueva ancla del bloque*/
+ query.clave = emufs_indice_generar_clave(emu->indices, bloque+sizeof(EMUFS_TIPO1_REG_HEADER));
+ emufs_b_plus_reemplazar_clave(emu->indices, ancla, query, 0);
+ }
+ }
+ free(bloque);
+ return 0;
+}
+
+void *emufs_tipo1_leer_registro_plus(EMUFS *emu, CLAVE clave, EMUFS_REG_SIZE *size, int *err)
+{
+ CLAVE clave_ajena;
+ char *reg = NULL;
+ char *bloque, *aux;
+ INDEX_DAT query;
+ int result, cant_reg, i;
+ EMUFS_REG_SIZE tam_reg;
+
+ /*cargo el query*/
+ query.clave = clave;
+ query.num_bloque = 0;
+ /*hago la consulta*/
+
+ result = emufs_b_plus_get_bloque(emu->indices, &query, 0);
+
+ if (result == -1){
+ PERR("NO EXISTE EL BLOQUE");
+ return NULL;
+ }
+ if (result == 1){
+ PERR("SE PRODUJO UN ERROR EN EL ARBOL");
+ return NULL;
+ }
+ /*leo el bloque*/
+ bloque = emufs_tipo1_leer_bloque(emu, query.num_bloque, err);
+ /*busco el registro en el bloque*/
+ /*copio la cantidad de registros*/
+ memcpy(&cant_reg, bloque+emu->tam_bloque-sizeof(int), sizeof(int));
+ aux = bloque;
+ for (i=0; i<cant_reg; i++){
+ /*copio el tamanio del registro*/
+ memcpy(&tam_reg, aux+sizeof(EMUFS_REG_ID), sizeof(EMUFS_REG_SIZE));
+ /*leo la clave*/
+ clave_ajena = emufs_indice_generar_clave(emu->indices, aux+sizeof(EMUFS_TIPO1_REG_HEADER));
+ if ( emufs_indice_es_igual(emu->indices, clave, clave_ajena) ){
+ reg = (char*)malloc(tam_reg);
+ if (reg == NULL){
+ PERR("NO SE PUDO CARGAR EL REGISTRO");
+ *err = -1;
+ free(bloque);
+ return NULL;
+ }
+ /*copio el registro*/
+ memcpy(reg, aux+sizeof(EMUFS_TIPO1_REG_HEADER), tam_reg);
+ *size = tam_reg;
+ break; /*ya lo encontre, corto el for*/
+ }
+ aux += tam_reg+sizeof(EMUFS_TIPO1_REG_HEADER); /*paso al proximo*/
+ }
+ if (cant_reg == i ) *err = -1;
+ free(bloque);
+ return reg;
+}
+
+EMUFS_REG_ID emufs_tipo1_modificar_registro_plus(EMUFS *emu, CLAVE k, void *ptr , EMUFS_REG_SIZE size, int* err, INDICE_DATO dato)
+{
+ emufs_tipo1_eliminar_ordenado(emu, k, dato);
+ return emufs_tipo1_insertar_ordenado(emu, ptr, size, err);
+}
+
+B_PLUS_KEYBUCKET *emufs_tipo1_obtener_claves_raw(EMUFS *emu, int num_bloque)
+{
+ B_PLUS_KEYBUCKET *keys;
+ char *bloque, *aux;;
+ int err = 0, cant_reg, i;
+ EMUFS_REG_SIZE tam_reg;
+
+ keys = (B_PLUS_KEYBUCKET*)malloc(sizeof(B_PLUS_KEYBUCKET));
+ if (keys == NULL){
+ PERR("NO SE PUDO CREAR EL BUCKET");
+ return NULL;
+ }
+ /*leo el bloque*/
+ bloque = emufs_tipo1_leer_bloque(emu, num_bloque, &err);
+ if ( bloque == NULL ){
+ PERR("NO SE PUDO LEER EL BLOQUE");
+ return NULL;
+ }
+ aux = bloque;
+ /*leo la cantidad de registros*/
+ memcpy(&cant_reg, bloque+emu->tam_bloque-sizeof(int), sizeof(int));
+ /*ya se cuanto guardarle al vector*/
+ keys->claves = (CLAVE*)malloc(cant_reg*sizeof(CLAVE));
+ if (keys->claves == NULL){
+ PERR("NO SE PUDO CREAR EL ARRAY DE CLAVES");
+ free(bloque);
+ free(keys);
+ return NULL;
+ }
+ keys->cant_keys = cant_reg;
+ keys->current_key = 0;
+ for (i=0; i<cant_reg; i++){
+ memcpy(&tam_reg, bloque+sizeof(EMUFS_REG_ID), sizeof(EMUFS_REG_SIZE));
+ keys->claves[i] = emufs_indice_generar_clave(emu->indices, bloque+sizeof(EMUFS_TIPO1_REG_HEADER));
+ bloque += tam_reg+sizeof(EMUFS_TIPO1_REG_HEADER);
+ }
+ free(aux);
+ return keys;
projects / z.facultad / 75.06 / emufs.git / blobdiff