int err = 0;
/* Si no es un tipo conocido, sale. */
- if ((tipo != T1) && (tipo != T2) && (tipo != T3)) {
+ if ((tipo != T1) && (tipo != T2) && (tipo != T3) && (tipo != T4) && (tipo != T5)) {
return NULL;
}
case T3:
/* Asigna punteros a funciones. */
- efs->leer_bloque = emufs_tipo3_leer_bloque;
- efs->leer_registro = emufs_tipo3_leer_registro;
- efs->leer_registro_raw = emufs_tipo3_leer_registro_raw;
- efs->grabar_registro = emufs_tipo3_grabar_registro;
- efs->borrar_registro = emufs_tipo3_borrar_registro;
- efs->leer_estadisticas = emufs_tipo3_leer_estadisticas;
- efs->modificar_registro = emufs_tipo3_modificar_registro;
- efs->compactar = emufs_tipo3_compactar;
- efs->leer_bloque_raw = emufs_tipo3_leer_bloque_raw;
+ if ((err = emufs_tipo3_inicializar(efs))) {
+ /* TODO ERROR */
+ PERR("No se pudo inicializar el EMUFS de tipo3");
+ fclose(fp);
+ free(efs->nombre);
+ free(efs);
+ return NULL;
+ }
/* Guarda cabeceras propias. */
fwrite(&tam_bloque, sizeof(EMUFS_BLOCK_SIZE), 1, fp);
fwrite(&tam_reg, sizeof(EMUFS_REG_SIZE), 1, fp);
break;
-
+
+ case T4:
+ /* Asigna punteros a funciones. */
+ if ((err = emufs_tipo4_inicializar(efs))) {
+ /* TODO ERROR */
+ PERR("No se pudo inicializar el EMUFS de tipo4");
+ fclose(fp);
+ free(efs->nombre);
+ free(efs);
+ return NULL;
+ }
+ /* Guarda cabeceras propias. */
+ fwrite(&tam_bloque, sizeof(EMUFS_BLOCK_SIZE), 1, fp);
+ break;
+
+ case T5:
+ /* Asigna punteros a funciones. */
+ if ((err = emufs_tipo5_inicializar(efs))) {
+ /* TODO ERROR */
+ PERR("No se pudo inicializar el EMUFS de tipo5");
+ fclose(fp);
+ free(efs->nombre);
+ free(efs);
+ return NULL;
+ }
+ /* Guarda cabeceras propias. */
+ fwrite(&tam_bloque, sizeof(EMUFS_BLOCK_SIZE), 1, fp);
+ fwrite(&tam_reg, sizeof(EMUFS_REG_SIZE), 1, fp);
+ break;
}
fclose(fp);
return NULL;
}
/* Asigna punteros a funciones. */
- efs->leer_bloque = emufs_tipo3_leer_bloque;
- efs->leer_registro_raw = emufs_tipo3_leer_registro_raw;
- efs->leer_registro = emufs_tipo3_leer_registro;
- efs->grabar_registro = emufs_tipo3_grabar_registro;
- efs->borrar_registro = emufs_tipo3_borrar_registro;
- efs->leer_estadisticas = emufs_tipo3_leer_estadisticas;
- efs->modificar_registro = emufs_tipo3_modificar_registro;
- efs->compactar = emufs_tipo3_compactar;
- efs->leer_bloque_raw = emufs_tipo3_leer_bloque_raw;
+ emufs_tipo3_inicializar(efs);
+ break;
+
+ case T4:
+ /* Lee cabeceras propias. */
+ if (!fread(&(efs->tam_bloque), sizeof(EMUFS_BLOCK_SIZE), 1, fp)) {
+ free(efs->nombre);
+ free(efs);
+ fclose(fp);
+ return NULL;
+ }
+ emufs_tipo4_inicializar(efs);
break;
- }
+
+ case T5:
+ if ((!fread(&(efs->tam_bloque), sizeof(EMUFS_BLOCK_SIZE), 1, fp)) ||
+ (!fread(&(efs->tam_reg), sizeof(EMUFS_REG_SIZE), 1, fp)))
+ {
+ free(efs->nombre);
+ free(efs);
+ fclose(fp);
+ return NULL;
+ }
+ /* Asigna punteros a funciones. */
+ emufs_tipo5_inicializar(efs);
+ }
fclose(fp);
return efs;
int emufs_destruir(EMUFS *e)
{
+ INDICE *del, *cur;
+
if (e == NULL) return 1;
+
+ /* libero indices */
+ cur = e->indices;
+ while (cur) {
+ del = cur;
+ cur = cur->sig;
+ emufs_indice_destruir(e, cur);
+ }
+
free(e->nombre);
free(e);
return 0;
return 0;
}
-int emufs_agregar_indice(EMUFS *emu, char *nombre, INDICE_FUNCION funcion, INDICE_TIPO tipo, INDICE_TIPO_DATO tipo_dato, unsigned int offset, unsigned int tam_bloque)
+int emufs_agregar_indice(EMUFS *emu, char *nombre, INDICE_FUNCION funcion, INDICE_TIPO tipo, INDICE_TIPO_DATO tipo_dato, unsigned int offset, unsigned int tam_bloque, int str_offset)
{
INDICE *tmp;
int error=0;
/* y que no exista un indice primario */
PERR("Agregando indice");
tmp = emu->indices;
+ PERR("IGUALE");
while (tmp) {
if (strcmp(tmp->nombre, nombre)==0) {
error = 1;
/* Creo el nuevo indice */
PERR("Creando indice\n");
- tmp = emufs_indice_crear(emu, nombre, funcion, tipo, tipo_dato, offset, tam_bloque);
+ tmp = emufs_indice_crear(emu, nombre, funcion, tipo, tipo_dato, offset, tam_bloque, str_offset);
/* Guardo la info del indice para poder abrir despues el archivo */
guardar_indice(emu, nombre, funcion, tipo, tipo_dato, offset, tam_bloque);
fwrite(&cant, 1, sizeof(int), fp);
fwrite(indices, cant, sizeof(t_Indice), fp);
fclose(fp);
+ free(indices);
return 1;
}
+/*crea un bloque y devuelve en numero del mismo*/
+EMUFS_BLOCK_ID emufs_create_new_block(EMUFS *emu)
+{
+ FILE *fp;
+ char name[255];
+ char *dummy;
+ EMUFS_BLOCK_ID num;
+
+ /* obtengo nombre del archivo */
+ strcpy(name, emu->nombre);
+ strcat(name,".dat");
+
+ if ( (fp=fopen(name,"a+")) == NULL ){
+ PERR("NO SE PUDO ABRIR EL ARCHIVO");
+ return -1;
+ }
+
+ dummy = (char*)malloc(emu->tam_bloque);
+ memset(dummy, 0, emu->tam_bloque);
+ fwrite(dummy, emu->tam_bloque, 1, fp);
+ switch(emu->tipo){
+ case T1: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE))/emu->tam_bloque;
+ break;
+ case T3: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE)-sizeof(EMUFS_REG_SIZE))/emu->tam_bloque;
+ }
+ fclose(fp);
+ free(dummy);
+ return num-1;
+}
+
+/*devuelve un numero de bloque siguiente al ultimo*/
+EMUFS_BLOCK_ID emufs_get_new_block_number(EMUFS *emu)
+{
+ FILE *fp;
+ char name[255];
+ EMUFS_BLOCK_ID num=0;
+
+ /* obtengo nombre del archivo */
+ strcpy(name, emu->nombre);
+ strcat(name,".dat");
+ if ( (fp=fopen(name,"r")) == NULL ){
+ PERR("NO SE PUDO ABRIR EL ARCHIVO");
+ return -1;
+ }
+ if ( fseek(fp, 0, SEEK_END)!=0 ){
+ PERR("NO PUDE HACER EL SEEK");
+ return -1;
+ }
+ switch(emu->tipo){
+ case T1: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE))/emu->tam_bloque;
+ if (ftell(fp) == sizeof(EMUFS_Tipo)+sizeof(EMUFS_BLOCK_SIZE)) num = 0;
+ break;
+ case T3: num = (ftell(fp)-sizeof(EMUFS_Tipo)-sizeof(EMUFS_BLOCK_SIZE)-sizeof(EMUFS_REG_SIZE))/emu->tam_bloque;
+ if (ftell(fp) == sizeof(EMUFS_Tipo)+sizeof(EMUFS_BLOCK_SIZE)+sizeof(EMUFS_REG_SIZE)) num = 0;
+ }
+ fclose(fp);
+ return num;
+}
+
+INDICE *emufs_buscar_indice_por_nombre(EMUFS *emu, const char *nombre)
+{
+ INDICE *tmp;
+
+ tmp = emu->indices;
+ while (tmp) {
+ if (strcmp(tmp->nombre, nombre) == 0) break;
+ tmp = tmp->sig;
+ }
+ return tmp;
+}
projects / z.facultad / 75.06 / emufs.git / blobdiff