]> git.llucax.com Git - z.facultad/75.06/emufs.git/blob - emufs/tipo1.c
Se termina borrar_registro() (ya desplaza a izquierda).
[z.facultad/75.06/emufs.git] / emufs / tipo1.c
1 /* vim: set noexpandtab tabstop=4 shiftwidth=4 wrap:
2  *----------------------------------------------------------------------------
3  *                                  emufs
4  *----------------------------------------------------------------------------
5  * This file is part of emufs.
6  *
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
10  * version.
11  *
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
15  * details.
16  *
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:  vie abr  9 16:47:32 ART 2004
22  * Autores: Leandro Lucarella <llucare@fi.uba.ar>
23  *----------------------------------------------------------------------------
24  *
25  * $Id$
26  *
27  */
28
29 /** \file
30  *
31  * Archivo con bloque de longitud parametrizada, registro de longitud variable.
32  * 
33  * Implementación del archivo con bloques de longitud parametrizada y registros
34  * de longitud variable.
35  *
36  */
37
38 #include "tipo1.h"
39 #include "idx.h"
40 #include "fsc.h"
41 #include "did.h"
42 #include <stdio.h>
43 #include <stdlib.h>
44 #include <string.h>
45 #include <unistd.h>
46
47 #ifndef MIN
48 #       define MIN(x, y) (((x) > (y)) ? (y) : (x))
49 #endif
50
51 /*------------------ Declaraciones privadas ----------------------*/
52
53 /** Cabecera de un registro de un archivo tipo1. */
54 typedef struct {
55         EMUFS_REG_ID   id;   /**< Identificador del registro. */
56         EMUFS_REG_SIZE size; /**< Tamaño del registro. */
57 } EMUFS_TIPO1_REG_HEADER;
58
59 static size_t emufs_tipo1_header_size(void);
60
61 static int emufs_tipo1_header_jump(FILE*);
62
63 static int emufs_tipo1_block_jump(EMUFS*, FILE*, EMUFS_BLOCK_ID);
64
65 static void emufs_tipo1_escribir_reg_en_memoria(char*, EMUFS_TIPO1_REG_HEADER,
66                 char*);
67
68 static void emufs_tipo1_escribir_reg_chunk_en_memoria(char* dst,
69                 EMUFS_TIPO1_REG_HEADER header, char* reg, EMUFS_REG_SIZE reg_size);
70
71 /*------------------ Funciones públicas ----------------------*/
72
73 int emufs_tipo1_inicializar(EMUFS* efs)
74 {
75         /* Asigna punteros a funciones. */
76         efs->leer_bloque       = emufs_tipo1_leer_bloque;
77         efs->grabar_registro   = emufs_tipo1_grabar_registro;
78         efs->borrar_registro   = emufs_tipo1_borrar_registro;
79         efs->leer_registro     = emufs_tipo1_leer_registro;
80         efs->leer_registro_raw = emufs_tipo1_leer_registro_raw;
81         return 0;
82 }
83
84 void* emufs_tipo1_leer_registro(EMUFS* efs, EMUFS_REG_ID reg_id,
85                 EMUFS_REG_SIZE* reg_size, int *err)
86 {
87         char* block; /* bloque leido (en donde está el registro a leer) */
88         char* registro; /* registro a leer */
89         EMUFS_BLOCK_ID block_id; /* id del bloque en donde esta el registro a leer */
90         EMUFS_BLOCK_SIZE offset; /* offset del bloque leído */
91         EMUFS_TIPO1_REG_HEADER curr_reg_header; /* cabecera del registro a leer */
92
93         block_id = emufs_idx_buscar_registro(efs, reg_id);
94         if (block_id == EMUFS_NOT_FOUND) {
95                 /* TODO Manejo de errores */
96                 PERR("Registro no encontrado");
97                 *err = EMUFS_NOT_FOUND;
98                 return NULL;
99         }
100         if (!(block = (char*) emufs_tipo1_leer_bloque(efs, block_id, err))) {
101                 /* TODO Manejo de errores */
102                 PERR("no se pudo reservar memoria");
103                 *err = 2; /* EMUFS_ERROR_OUT_OF_MEMORY */
104                 return NULL;
105         }
106
107         /* Busco secuencialmente en el bloque el registro a leer */
108         offset = 0;
109         do {
110                 /* Copio la cabecera del registro actual. */
111                 memcpy(&curr_reg_header, block + offset, sizeof(EMUFS_TIPO1_REG_HEADER));
112                 offset += sizeof(EMUFS_TIPO1_REG_HEADER);
113                 if (curr_reg_header.id == reg_id) {
114                         /* tamaño máximo ultilizable para datos en un bloque */
115                         EMUFS_BLOCK_SIZE block_space
116                                         = efs->tam_bloque - sizeof(EMUFS_TIPO1_REG_HEADER);
117                         /* tamaño de la porción de registro que se guarda */
118                         EMUFS_REG_SIZE chunk_size = 0; 
119                         /* puntero a la porción actual del registro */
120                         char* chunk_ptr;
121
122                         *reg_size = curr_reg_header.size;
123                         registro = chunk_ptr = (char*) malloc(*reg_size);
124                         if (registro == NULL) {
125                                 /* TODO Manejo de errores */
126                                 free(block);
127                                 PERR("No hay memoria");
128                                 *err = 2; /* EMUFS_ERROR_OUT_OF_MEMORY */
129                                 return NULL;
130                         }
131                         while (1) {
132                                 chunk_ptr += chunk_size; /* Avanzo para guardar prox chunk */
133                                 curr_reg_header.size -= chunk_size; /* Resto lo que ya guardé */
134                                 chunk_size = MIN(curr_reg_header.size, block_space);
135                                 /* copio porción de registro en el buffer */
136                                 memcpy(chunk_ptr, block + offset, chunk_size);
137                                  /* falta leer un bloque */
138                                 if (curr_reg_header.size > block_space) {
139                                         free(block);
140                                         if (!(block = (char*) emufs_tipo1_leer_bloque(efs,
141                                                                         ++block_id, err))) {
142                                                 /* TODO Manejo de errores */
143                                                 free(registro);
144                                                 PERR("no se pudo reservar memoria");
145                                                 *err = 2; /* EMUFS_ERROR_OUT_OF_MEMORY */
146                                                 return NULL;
147                                         }
148                                 } else { /* se terminó de leer */
149                                         break;
150                                 }
151                         }
152                         break;
153                 }
154                 /* Desplazo el offset */
155                 offset += curr_reg_header.size;
156
157         /* esto no debería ser nunca false porque sé positivamente que el */
158         } while (offset < efs->tam_bloque); /* registro está en el bloque */
159
160         free(block);
161         return registro;
162 }
163
164 /* @todo TODO hacer que soporte registros de más de un bloque */
165 void* emufs_tipo1_leer_registro_raw(EMUFS *efs, EMUFS_REG_ID id,
166                 EMUFS_REG_SIZE *size, int *pos)
167 {
168         char* block; /* bloque leido (en donde está el registro a leer) */
169         EMUFS_BLOCK_ID block_id; /* id del bloque en donde esta el registro a leer */
170         EMUFS_BLOCK_SIZE offset; /* offset del bloque leído */
171         EMUFS_TIPO1_REG_HEADER curr_reg_header; /* cabecera del registro a leer */
172         int err;
173
174         block_id = emufs_idx_buscar_registro(efs, id);
175         if (block_id == EMUFS_NOT_FOUND) {
176                 return NULL;
177         }
178         err = 0;
179         if (!(block = (char*) emufs_tipo1_leer_bloque(efs, block_id, &err))) {
180                 return NULL;
181         }
182
183         /* Busco secuencialmente en el bloque el registro a leer */
184         offset = 0;
185         do {
186                 /* Copio la cabecera del registro. */
187                 memcpy(&curr_reg_header, block + offset, sizeof(EMUFS_TIPO1_REG_HEADER));
188                 offset += sizeof(EMUFS_TIPO1_REG_HEADER);
189                 if (curr_reg_header.id == id) {
190                         *pos = offset - sizeof(EMUFS_TIPO1_REG_HEADER);
191                         break;
192                 }
193                 /* Desplazo el offset */
194                 offset += curr_reg_header.size;
195         } while (offset < efs->tam_bloque);
196
197         (*size) = efs->tam_bloque;
198         return block;
199 }
200
201 void* emufs_tipo1_leer_bloque(EMUFS* efs, EMUFS_BLOCK_ID block_id, int *err)
202 {
203         FILE* file;
204         char* block; /* bloque leido (en donde está el registro a leer) */
205         char  name_f[255];
206
207         strcpy(name_f,efs->nombre);
208         strcat(name_f,".dat");
209
210         if ((file = fopen(name_f, "r")) == NULL) {
211                 PERR("No se puede abrir archivo");
212                 *err = 4; /* EMUFS_ERROR_CANT_OPEN_FILE */
213                 return NULL; /* FIXME ERROR */
214         }
215         emufs_tipo1_header_jump(file); /* salta cabeceras */
216         emufs_tipo1_block_jump(efs, file, block_id); /* salta bloques */
217         /* FIXME: verificar que no se pase de fin de archivo*/
218         block = (char*) malloc(efs->tam_bloque);
219         if (block == NULL) {
220                 /* TODO Manejo de errores */
221                 PERR("No hay memoria");
222                 *err = 2; /* EMUFS_ERROR_OUT_OF_MEMORY */
223                 return NULL;
224         }
225         if (fread(block, efs->tam_bloque, 1, file) != 1) {
226                 /* TODO Manejo de errores */
227                 free(block);
228                 PERR("Error al leer bloque");
229                 *err = 3; /* EMUFS_ERROR_FILE_READ */
230                 return NULL;
231         }
232         fclose(file);
233         return block;
234 }
235
236 EMUFS_REG_ID emufs_tipo1_grabar_registro(EMUFS* efs, void* reg, EMUFS_REG_SIZE reg_size, int* err)
237 {
238         EMUFS_TIPO1_REG_HEADER reg_header; /* cabecera del registro a guardar */
239         EMUFS_FREE             fs; /* espacio libre en el bloque */
240         EMUFS_BLOCK_ID         block_id; /* identificador del 1er bloque */
241         char*                  block; /* buffer del bloque a guardar en disco */
242         char                   name_f[255];
243
244         strcpy(name_f, efs->nombre);
245         strcat(name_f, ".dat");
246
247         /* pongo tamaño del registro en la cabecera. */
248         reg_header.size = reg_size;
249         /* busco lugar para el registro en un bloque existente */
250         block_id = emufs_fsc_buscar_lugar(efs, sizeof(EMUFS_TIPO1_REG_HEADER)
251                         + reg_size, &fs);
252         /* si no hay bloques con suficiente espacio creo un bloque nuevo */
253         if (block_id == EMUFS_NOT_FOUND) {
254                 /* tamaño máximo ultilizable para datos en un bloque */
255                 EMUFS_BLOCK_SIZE block_space = efs->tam_bloque - sizeof(EMUFS_TIPO1_REG_HEADER);
256                 /* identificador del bloque que se guarda */
257                 EMUFS_BLOCK_ID curr_block_id = EMUFS_NOT_FOUND;
258                 /* tamaño de la porción de registro que se guarda */
259                 EMUFS_REG_SIZE chunk_size = 0; 
260                 /* puntero a la poción del registro */
261                 char* chunk_ptr = reg; 
262
263                 /* crear un nuevo bloque en memoria */
264                 block = (char*) malloc(efs->tam_bloque);
265                 if (block == NULL) {
266                         /* TODO Manejo de errores */
267                         PERR("No hay memoria");
268                         *err = 2; /* EMUFS_ERROR_OUT_OF_MEMORY */
269                         return EMUFS_NOT_FOUND;
270                 }
271                 reg_header.id = emufs_idx_get_new_id(efs, err);
272                 do {
273                         memset(block, 0, efs->tam_bloque); /* inicializa bloque */
274                         chunk_ptr += chunk_size; /* Avanzo para guardar prox chunk */
275                         reg_header.size -= chunk_size; /* Resto lo que ya guardé */
276                         chunk_size = MIN(reg_header.size, block_space);
277                         /* graba porción del registro en bloque */
278                         emufs_tipo1_escribir_reg_chunk_en_memoria(block, reg_header, chunk_ptr, chunk_size);
279                         /* graba el bloque en el archivo */
280                         curr_block_id = emufs_tipo1_grabar_bloque(efs, block, EMUFS_NOT_FOUND, err);
281                         if (*err) {
282                                 PERR("error al grabar bloque");
283                                 free(block);
284                                 return EMUFS_NOT_FOUND;
285                         }
286                         /* grabo el nuevo registro en el archivo de espacios libres */
287                         *err = emufs_fsc_agregar(efs, curr_block_id, block_space - chunk_size);
288                         if (*err) {
289                                 PERR("No se pudo agregar fsc");
290                                 free(block);
291                                 return EMUFS_NOT_FOUND;
292                         }
293                         /* si es el primer id de bloque obtenido, lo guardo para
294                          * agregarlo después al archivo de índices. */
295                         if (block_id == EMUFS_NOT_FOUND) {
296                                 block_id = curr_block_id;
297                         }
298                 } while (reg_header.size > block_space);
299                 free(block);
300
301         /* Encontró espacio en un bloque existente, graba registro ahí */
302         } else {
303                 /* cargo el bloque en block_id */
304                 if (!(block = (char*) emufs_tipo1_leer_bloque(efs, block_id, err))) {
305                         /* TODO Manejo de errores */
306                         PERR("no se pudo leer el bloque");
307                         return EMUFS_NOT_FOUND;
308                 }
309                 /* inserta el registro en el bloque */
310                 /* tengo que buscar un ID válido para el nuevo registro */
311                 reg_header.id = emufs_idx_get_new_id(efs, err);
312                 /* graba registro en bloque */
313                 emufs_tipo1_escribir_reg_en_memoria(block + efs->tam_bloque - fs,
314                                 reg_header, reg);
315                 /* graba el bloque en el archivo */
316                 block_id = emufs_tipo1_grabar_bloque(efs, block, block_id, err);
317                 if (*err) {
318                         PERR("error al grabar bloque");
319                         free(block);
320                         return EMUFS_NOT_FOUND;
321                 }
322                 free(block);
323                 /* actualizo el archivo de espacios libres */
324                 *err = emufs_fsc_actualizar(efs, block_id, fs - reg_size
325                                 - sizeof(EMUFS_TIPO1_REG_HEADER));
326                 if (*err) {
327                         PERR("No se pudo actualizar fsc");
328                         return EMUFS_NOT_FOUND;
329                 }
330         }
331                 
332         /* actualizo el indice de bloques y registros */
333         *err = emufs_idx_agregar(efs, reg_header.id, block_id);
334         if (*err){
335                 PERR("No se pudo agregar idx");
336                 return EMUFS_NOT_FOUND;
337         }
338         
339         return reg_header.id;
340 }
341
342 int emufs_tipo1_borrar_registro(EMUFS* efs, EMUFS_REG_ID reg_id)
343 {
344         char* block; /* bloque leido (en donde está el registro a leer) */
345         EMUFS_BLOCK_ID block_id; /* id del bloque en donde esta el registro a leer */
346         EMUFS_BLOCK_SIZE offset; /* offset del bloque leído */
347         EMUFS_TIPO1_REG_HEADER curr_reg_header; /* cabecera del registro a leer */
348         int err = 0; /* para almacenar código de error */
349
350         block_id = emufs_idx_buscar_registro(efs, reg_id);
351         if (block_id == EMUFS_NOT_FOUND) {
352                 /* TODO Manejo de errores */
353                 PERR("Registro no encontrado");
354                 return EMUFS_NOT_FOUND;
355         }
356         if (!(block = (char*) emufs_tipo1_leer_bloque(efs, block_id, &err))) {
357                 /* TODO Manejo de errores */
358                 PERR("no se pudo reservar memoria");
359                 return err;
360         }
361
362         /* Busco secuencialmente en el bloque el registro a leer */
363         offset = 0;
364         do {
365                 /* Copio la cabecera del registro actual. */
366                 memcpy(&curr_reg_header, block + offset, sizeof(EMUFS_TIPO1_REG_HEADER));
367                 if (curr_reg_header.id == reg_id) {
368                         /* identificador del bloque actual */
369                         EMUFS_BLOCK_ID curr_block_id = block_id;
370                         /* tamaño máximo ultilizable para datos en un bloque */
371                         EMUFS_BLOCK_SIZE block_space
372                                         = efs->tam_bloque - sizeof(EMUFS_TIPO1_REG_HEADER);
373                         EMUFS_FREE fs; /* cantidad de espacio libre en el bloque */
374
375                         while (1) {
376                                 /* actualizo archivo de espacio libre por bloque */
377                                 fs = emufs_fsc_get_fs(efs, curr_block_id)
378                                         + MIN(curr_reg_header.size, block_space)
379                                         + sizeof(EMUFS_TIPO1_REG_HEADER);
380                                 if ((err = emufs_fsc_actualizar(efs, curr_block_id, fs))) {
381                                         /* TODO Manejo de errores */
382                                         PERR("no se pudo actualizar .fsc");
383                                         free(block);
384                                         return err;
385                                 }
386                                 /* falta liberar un bloque (o porción) */
387                                 if (curr_reg_header.size > block_space) {
388                                         free(block);
389                                         if (!(block = (char*) emufs_tipo1_leer_bloque(efs,
390                                                                         ++curr_block_id, &err))) {
391                                                 /* TODO Manejo de errores */
392                                                 PERR("no se pudo leer el bloque");
393                                                 return err;
394                                         }
395                                         /* copio la cabecera del primer registro (si ocupa más de un
396                                          * registro está en bloques contiguos) */
397                                         memcpy(&curr_reg_header, block,
398                                                         sizeof(EMUFS_TIPO1_REG_HEADER));
399                                 } else { /* se terminó de leer */
400                                         break;
401                                 }
402                         }
403
404                         /* actualizo archivo de identificadores de registros borrados */
405                         if ((err = emufs_did_agregar(efs, reg_id))) {
406                                 /* TODO Manejo de errores */
407                                 PERR("no se pudo actualizar .did");
408                                 free(block);
409                                 return err;
410                         }
411                         /*actualizo archivo .idx*/
412                         if ((err = emufs_idx_borrar(efs, reg_id))) {
413                                 /* TODO Manejo de errores */
414                                 PERR("no se pudo actualizar .did");
415                                 free(block);
416                                 return err;
417                         }
418
419                         /* desplazo registros a izquierda */
420                         {   /* offset del fin del registro a borrar */
421                                 EMUFS_BLOCK_SIZE offset_reg_end = offset
422                                         + sizeof(EMUFS_TIPO1_REG_HEADER) + curr_reg_header.size;
423                                 /* si es necesario desplazar */
424                                 if (offset < offset_reg_end) {
425                                         /* muevo la porción de bloque a izquierda */
426                                         memcpy(block + offset, block + offset_reg_end,
427                                                 efs->tam_bloque - offset_reg_end);
428                                 }
429                         }
430                         /* guardo el bloque en disco */
431                         emufs_tipo1_grabar_bloque(efs, block, curr_block_id, &err);
432                         if (err) {
433                                 /* TODO Manejo de errores */
434                                 PERR("no se pudo grabar bloque en disco");
435                                 free(block);
436                                 return err;
437                         }
438
439                         break; /* salgo del loop, ya hice todo lo que tenía que hacer */
440                 }
441                 /* desplazo el offset */
442                 offset += sizeof(EMUFS_TIPO1_REG_HEADER) + curr_reg_header.size;
443
444         /* esto no debería ser nunca false porque sé positivamente que el */
445         } while (offset < efs->tam_bloque); /* registro está en el bloque */
446
447         free(block);
448         return 0; /* EMUFS_OK */
449 }
450
451 /** Graba un bloque en el archivo. */
452 EMUFS_BLOCK_ID emufs_tipo1_grabar_bloque(EMUFS *efs, void *block,
453                 EMUFS_BLOCK_ID block_id, int* err)
454 {
455         FILE* file;
456         char name_f[255];
457
458         strcpy(name_f,efs->nombre);
459         strcat(name_f,".dat");
460
461         if ((file = fopen(name_f, "r+b")) == NULL) {
462                 /* TODO Manejo de errores */
463                 PERR("Error al abrir archivo");
464                 *err = 4; /* EMUFS_ERROR_CANT_OPEN_FILE */
465                 return EMUFS_NOT_FOUND;
466         }
467         /* Si es NOT_FOUND tengo que agregar un bloque al final del archivo */
468         if (block_id == EMUFS_NOT_FOUND) {
469                 /* me paro al final del archivo */
470                 if (fseek(file, 0l, SEEK_END)) {
471                         /* TODO Manejo de errores */
472                         PERR("No se pudo hacer fseek()");
473                         fclose(file);
474                         *err = 8; /* EMUFS_ERROR_SEEK_FILE */
475                         return EMUFS_NOT_FOUND;
476                 }
477                 /* Obtengo ID del bloque nuevo */
478                 block_id = (ftell(file) - emufs_tipo1_header_size()) / efs->tam_bloque;
479         /* Si es un ID válido, salto hasta ese bloque. */
480         } else {
481                 /* Salta el header del archivo */
482                 if ((*err = emufs_tipo1_header_jump(file))) {
483                         PERR("no se pudo saltar la cabecera del archivo");
484                         fclose(file);
485                         return EMUFS_NOT_FOUND;
486                 }
487                 /* Salta bloques */
488                 if ((*err = emufs_tipo1_block_jump(efs, file, block_id))) {
489                         PERR("no se pudo saltar la cabecera del bloque");
490                         fclose(file);
491                         return EMUFS_NOT_FOUND;
492                 }
493         }
494         /* Grabo el bloque */
495         if (fwrite(block, efs->tam_bloque, 1, file) != 1) {
496                 PERR("No se pudo escribir el archivo");
497                 fclose(file);
498                 *err = 6; /* EMUFS_ERROR_WRITE_FILE */
499                 return EMUFS_NOT_FOUND;
500         }
501
502         fclose(file);
503         return block_id;
504 }
505
506 EMUFS_REG_ID emufs_tipo1_modificar_registro(EMUFS *emu, EMUFS_REG_ID id,
507                 void *data, EMUFS_REG_SIZE size, int *error)
508 {
509         emufs_tipo1_borrar_registro(emu, id);
510         return emufs_tipo1_grabar_registro(emu, data, size, error);
511 }
512
513 size_t emufs_tipo1_header_size(void)
514 {
515         return sizeof(EMUFS_Tipo) + sizeof(EMUFS_BLOCK_SIZE);
516 }
517
518 int emufs_tipo1_header_jump(FILE* fp)
519 {
520         if (fseek(fp, emufs_tipo1_header_size(), SEEK_CUR)) {
521                 PERR("No se pudo hacer fseek()");
522                 return 8; /* EMUFS_ERROR_SEEK_FILE */
523         }
524         return 0; /* EMUFS_OK */
525 }
526
527 int emufs_tipo1_block_jump(EMUFS* efs, FILE* fp, EMUFS_BLOCK_ID block_count)
528 {
529         if (fseek(fp, block_count * efs->tam_bloque, SEEK_CUR)) {
530                 PERR("No se pudo hacer fseek()");
531                 return 8; /* EMUFS_ERROR_SEEK_FILE */
532         }
533         return 0; /* EMUFS_OK */
534 }
535
536 void emufs_tipo1_escribir_reg_en_memoria(char* dst, EMUFS_TIPO1_REG_HEADER header,
537                 char* reg)
538 {
539         emufs_tipo1_escribir_reg_chunk_en_memoria(dst, header, reg, header.size);
540 }
541
542 void emufs_tipo1_escribir_reg_chunk_en_memoria(char* dst,
543                 EMUFS_TIPO1_REG_HEADER header, char* reg, EMUFS_REG_SIZE reg_size)
544 {
545         /* grabo cabecera del registro en el bloque */
546         memcpy(dst, &header, sizeof(EMUFS_TIPO1_REG_HEADER));
547         /* incremento puntero de escritura */
548         dst += sizeof(EMUFS_TIPO1_REG_HEADER);
549         /* grabo el registro en el bloque */
550         memcpy(dst, reg, reg_size);
551 }
552