EMUFS_FSC gap_aux,gap_before,gap_after,gap_new;
char name_f_fsc[255];
EMUFS_REG_ID pos_gap_before = 0, pos_gap_after = 0;
- unsigned long source,destination,file_size,reg_count = 0,cant_moved = 0;
+ unsigned long source,destination,limit,file_size,reg_count = 0,cant_moved = 0;
+ char found = 0;
strcpy(name_f_fsc,emu->nombre);
strcat(name_f_fsc, EMUFS_FSC_EXT);
/* Si no encontre gaps ni por delante ni por detras */
if ((gap_before.marker == -1) && (gap_after.marker == -1)) {
- /* Lo guardo en el archivo al final */
+ /* Lo guardo ordenado donde deba ir */
gap_new.marker = marker;
gap_new.freespace = freespace;
- fseek(f_fsc,0,SEEK_END);
- fwrite(&gap_new,sizeof(EMUFS_FSC),1,f_fsc);
+ /* Busco el gap que sucede a este */
+ fseek(f_fsc,0,SEEK_SET);
+ while (!feof(f_fsc)) {
+ fread(&gap_aux,sizeof(EMUFS_FSC),1,f_fsc);
+ if (gap_aux.marker > gap_new.marker) {
+ found = 1;
+ break;
+ }
+ }
+ if (found == 1) {
+ /* Movemos todos los gaps desde el sucesor hasta el final, una pos adelante */
+ limit = ftell(f_fsc) - sizeof(EMUFS_FSC);
+ fseek(f_fsc,0,SEEK_END);
+ reg_count = (ftell(f_fsc) - limit) / sizeof(EMUFS_FSC);
+ source = ftell(f_fsc) - sizeof(EMUFS_FSC);
+
+ while (cant_moved < reg_count)
+ {
+ fseek(f_fsc,source,SEEK_SET);
+ fread(&gap_aux,sizeof(EMUFS_FSC),1,f_fsc);
+ fwrite(&gap_aux,sizeof(EMUFS_FSC),1,f_fsc);
+ source -= sizeof(EMUFS_FSC);
+ ++cant_moved;
+ }
+ /* Agrego el nuevo registro */
+ fseek(f_fsc,limit,SEEK_SET);
+ fwrite(&gap_new,sizeof(EMUFS_FSC),1,f_fsc);
+ }
+ else {
+ fseek(f_fsc,0,SEEK_END);
+ fwrite(&gap_new,sizeof(EMUFS_FSC),1,f_fsc);
+ }
+
fclose(f_fsc);
}
strcpy(name_f_fsc,emu->nombre);
strcat(name_f_fsc, EMUFS_FSC_EXT);
- *min = ULONG_MAX;
- *max = 0;
if ( (f_fsc = fopen(name_f_fsc,"r"))==NULL ) return -1;
-
- while ( !feof(f_fsc) ){
- fread(®, sizeof(EMUFS_FSC), 1, f_fsc);
- if ( reg.freespace < *min )
- *min = reg.freespace;
- if ( reg.freespace > *max )
- *max = reg.freespace;
+
+ /* Si el file esta vacio, devuelvo valores nulos */
+ fseek(f_fsc,0,SEEK_END);
+ if (ftell(f_fsc) == 0) {
+ *min = 0;
+ *max = 0;
+ return 0;
+ }
+ else
+ {
+ /* Busco Min y Max */
+ *min = ULONG_MAX;
+ *max = 0;
+ fseek(f_fsc,0,SEEK_SET);
+ while ( !feof(f_fsc) ){
+ if ( fread(®, sizeof(EMUFS_FSC), 1, f_fsc) != 1) continue;
+ if ( reg.freespace < *min )
+ *min = reg.freespace;
+ if ( reg.freespace > *max )
+ *max = reg.freespace;
+ }
+ fclose(f_fsc);
+ return 0;
}
-
- fclose(f_fsc);
- return 0;
}
EMUFS_FREE emufs_fsc_get_media_fs(EMUFS *emu)
if ( (f_fsc = fopen(name_f_fsc,"r"))==NULL ) return -1;
while ( !feof(f_fsc) ){
- fread(®, sizeof(EMUFS_FSC), 1, f_fsc);
+ if ( fread(®, sizeof(EMUFS_FSC), 1, f_fsc) != 1) continue;
total_fs += reg.freespace;
++gap_count;
}
fclose(f_fsc);
- return total_fs/gap_count;
+
+ if (gap_count > 0) return total_fs/gap_count;
+ else return 0;
}
strcpy(name_f,efs->nombre);
strcat(name_f,".dat");
- if ((f_data = fopen(name_f,"r+")) == NULL) return -1; /* ERROR */
+ if ((f_data = fopen(name_f,"rb+")) == NULL) return -1; /* ERROR */
/* Preparo el garbage y se lo tiro encima */
fill_size = amount+sizeof(EMUFS_REG_ID)+sizeof(EMUFS_REG_SIZE);
return(stats);
}
+
+/* Recompila y devuelve ciertas estadisticas del archivo indicado */
+int emufs_tipo2_recompactar(EMUFS *efs)
+{
+ char name_fdat[255],name_ffsc[255];
+ FILE *datfile;
+ FILE *fscfile;
+ EMUFS_FSC reg1,reg2;
+ unsigned long cant_gaps = 0,mustmove_bytes = 0,source = 0,
+ destination = 0,datsize = 0,totalfsc = 0;
+
+ strcpy(name_fdat,efs->nombre);
+ strcpy(name_ffsc,efs->nombre);
+ strcat(name_fdat,".dat");
+ strcat(name_ffsc,EMUFS_FSC_EXT);
+
+ /* Obtengo el tamanio del .dat */
+ if ( (datfile = fopen(name_fdat,"rb+")) == NULL){
+ PERR("No se pudo abrir el archivo");
+ return -1;
+ }
+ fseek(datfile,0,SEEK_END);
+ datsize = ftell(datfile);
+
+ /* Obtengo la cantidad de gaps */
+ if ( (fscfile = fopen(name_ffsc,"rb")) == NULL){
+ PERR("No se pudo abrir el archivo");
+ return -1;
+ }
+ fseek(fscfile,0,SEEK_END);
+ cant_gaps = ftell(fscfile)/sizeof(EMUFS_FSC);
+
+ if (cant_gaps == 0) return 0;
+ if (cant_gaps == 1) {
+ /* Un solo gap, muevo toda la data luego del gap y trunco */
+ fseek(fscfile,0,SEEK_SET);
+ fread(®1,sizeof(EMUFS_FSC),1,fscfile);
+ source = reg1.marker + reg1.freespace;
+ destination = reg1.marker;
+ mustmove_bytes = datsize - source;
+ /*printf("Para recompactar, must move: %lu bytes\n",mustmove_bytes);
+ printf("Will move from: %lu to %lu\n",source,destination);*/
+ emufs_tipo2_movedata(datfile,&source,&destination,mustmove_bytes);
+ }
+ if (cant_gaps > 1)
+ {
+ /* Comienzo leyendo un gap */
+ fseek(fscfile,0,SEEK_SET);
+ fread(®1,sizeof(EMUFS_FSC),1,fscfile);
+ destination = reg1.marker;
+ --cant_gaps;
+
+ while (cant_gaps > 0)
+ {
+ /* El source siempre sera el fin del anteultimo gap leido */
+ source = reg1.marker + reg1.freespace;
+ /* Leemos otro gap para calcular cuanto debemos mover */
+ fread(®2,sizeof(EMUFS_FSC),1,fscfile);
+ mustmove_bytes = reg2.marker - source;
+ /*printf("Para recompactar, must move: %lu bytes\n",mustmove_bytes);
+ printf("Will move from: %lu to %lu\n",source,destination);*/
+ emufs_tipo2_movedata(datfile,&source,&destination,mustmove_bytes);
+ /* Guardo el nuevo destino que es donde termino de mover */
+ destination = ftell(datfile);
+ /* El ultimo gap leido, pasa a ser el de referencia ahora */
+ reg1.marker = reg2.marker;
+ reg1.freespace = reg2.freespace;
+ --cant_gaps;
+ }
+
+ /* Realizo el movimiento del ultimo chunk de datos */
+ source = reg1.marker + reg1.freespace;
+ mustmove_bytes = datsize - source;
+ emufs_tipo2_movedata(datfile,&source,&destination,mustmove_bytes);
+ }
+
+ fclose(datfile);
+ fclose(fscfile);
+
+ /* Trunco el dat para que no quede el espacio vacio al final */
+ totalfsc = emufs_fsc_get_total_fs(efs);
+ truncate(name_fdat,datsize - totalfsc);
+ truncate(name_ffsc,0);
+ return 0;
+}
+
+void emufs_tipo2_movedata(FILE *datfile,EMUFS_OFFSET *source, EMUFS_OFFSET *destination, EMUFS_BLOCK_SIZE mustmove_bytes)
+{
+ int chunksize = 9;
+ char *chunk = malloc(chunksize*sizeof(char));
+ unsigned long cant_chunks = 0,left_chunk = 0;
+
+ /* Obtengo cuantos bloques de a CHUNKSIZE bytes debo mover. Si la cantidad es no entera */
+ cant_chunks = floor(mustmove_bytes/chunksize);
+ left_chunk = fmod(mustmove_bytes,chunksize);
+
+ /*printf ("Cantidad de chunk de %i bytes movidos: %lu\n",chunksize,cant_chunks);
+ printf ("Left chunk movido fue de: %lu bytes\n",left_chunk);*/
+
+ while(cant_chunks > 0)
+ {
+ fseek(datfile,*source,SEEK_SET);
+ fread(chunk,chunksize,1,datfile);
+ fseek(datfile,*destination,SEEK_SET);
+ fwrite(chunk,chunksize,1,datfile);
+ *source += chunksize;
+ *destination += chunksize;
+ --cant_chunks;
+ }
+
+ if (left_chunk > 0)
+ {
+ fseek(datfile,*source,SEEK_SET);
+ fread(chunk,left_chunk,1,datfile);
+ fseek(datfile,*destination,SEEK_SET);
+ fwrite(chunk,left_chunk,1,datfile);
+ }
+
+ free(chunk);
+}
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
+#include <math.h>
#include "emufs.h"
/** Inicializa la estructura <em>EMUFS* efs</em> que recibe, asignando las funciones que permiten
*/
EMUFS_Estadisticas emufs_tipo2_leer_estadisticas(EMUFS *efs);
+/** Método para recompactar un archivo tipo 2
+ *
+ * \param efs Estructura que realiza el handling de archivos de cualquier tipo.
+ * \return \b int Indicador de exito de la opracion.
+ */
+int emufs_tipo2_recompactar(EMUFS *efs);
+void emufs_tipo2_movedata(FILE * datfile,EMUFS_OFFSET *source, EMUFS_OFFSET *destination, EMUFS_BLOCK_SIZE mustmove_bytes);
+
#endif /* _EMUFS_TIPO2_H_ */
#include <stdio.h>
#include <string.h>
+#include <math.h>
#include "emufs.h"
#include "fsc.h"
+#include "tipo2.h"
int main(int argc, char *argv[])
{
n5 = efs->grabar_registro(efs, f, 9, &err);
n6 = efs->grabar_registro(efs, g, 41, &err);
n7 = efs->grabar_registro(efs, h, 63, &err);
+ n8 = efs->grabar_registro(efs, d, 8, &err);
/* Borramos un registro del medio */
- printf("tipo2_main.c >> Borrando registro: %lu\n",n5);
+ /*printf("tipo2_main.c >> Borrando registro: %lu\n",n5);
efs->borrar_registro(efs, n5);
printf("tipo2_main.c >> Borrando registro: %lu\n",n1);
efs->borrar_registro(efs, n1);
printf("tipo2_main.c >> Borrando registro: %lu\n",n7);
efs->borrar_registro(efs, n7);
printf("tipo2_main.c >> Borrando registro: %lu\n",n4);
+ efs->borrar_registro(efs, n4);*/
+
+ /* Prueba de recompactacion */
+ efs->borrar_registro(efs, n2);
+ efs->borrar_registro(efs, n7);
efs->borrar_registro(efs, n4);
-
- n8 = efs->grabar_registro(efs, d, 8, &err);
- printf("tipo2_main.c >> Id recuperado: %lu\n",n8);
-
+
/* Levanto un registro */
- registro = efs->leer_registro(efs,n2,®_size,&err);
+ registro = efs->leer_registro(efs,n1,®_size,&err);
if (err == 0) {
printf("tipo2_main.c >>Registro: %lu Size: %lu Content: %s\n\n",n2,reg_size,registro);
}
printf("Media de espacio libre en bloque o gap: %lu\n",stats.media_fs);
printf("Cantidad en bytes de informacion de control: %lu\n",stats.info_control);
+ /* Recompacto */
+ printf("Recompactando...\n");
+ emufs_tipo2_recompactar(efs);
+
+ /* Obtengo stats nevas */
+ stats = efs->leer_estadisticas(efs);
+ printf("Size del Archivo de datos: %lu\n",stats.tam_archivo_bytes);
+ printf("Cantidad de Registros en el Archivo de datos: %lu\n",stats.tam_archivo);
+ printf("Total de espacio libre en el .dat: %lu\n",stats.total_fs);
+ printf("Minimo espacio libre en bloque o gap: %lu\n",stats.min_fs);
+ printf("Maximo espacio libre en bloque o gap: %lu\n",stats.max_fs);
+ printf("Media de espacio libre en bloque o gap: %lu\n",stats.media_fs);
+ printf("Cantidad en bytes de informacion de control: %lu\n",stats.info_control);
+
emufs_destruir(efs);
return 0;
projects / z.facultad / 75.06 / emufs.git / commitdiff