]> git.llucax.com Git - z.facultad/75.06/emufs.git/blob - emufs/tipo1.c
Una bobada, pongo un FIXME para acordarnos de limpiar algo que mejor no tocar ahora...
[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                 offset += sizeof(EMUFS_TIPO1_REG_HEADER);
368                 if (curr_reg_header.id == reg_id) {
369                         /* identificador del bloque actual */
370                         EMUFS_BLOCK_ID curr_block_id = block_id;
371                         /* tamaño máximo ultilizable para datos en un bloque */
372                         EMUFS_BLOCK_SIZE block_space
373                                         = efs->tam_bloque - sizeof(EMUFS_TIPO1_REG_HEADER);
374                         EMUFS_FREE fs; /* cantidad de espacio libre en el bloque */
375
376                         while (1) {
377                                 /* actualizo archivo de espacio libre por bloque */
378                                 fs = emufs_fsc_get_fs(efs, curr_block_id)
379                                         + MIN(curr_reg_header.size, block_space)
380                                         + sizeof(EMUFS_TIPO1_REG_HEADER);
381                                 if ((err = emufs_fsc_actualizar(efs, curr_block_id, fs))) {
382                                         /* TODO Manejo de errores */
383                                         PERR("no se pudo actualizar .fsc");
384                                         free(block);
385                                         return err;
386                                 }
387                                 /* falta liberar un bloque (o porción) */
388                                 if (curr_reg_header.size > block_space) {
389                                         free(block);
390                                         if (!(block = (char*) emufs_tipo1_leer_bloque(efs,
391                                                                         ++curr_block_id, &err))) {
392                                                 /* TODO Manejo de errores */
393                                                 PERR("no se pudo leer el bloque");
394                                                 return err;
395                                         }
396                                         /* copio la cabecera del primer registro (si ocupa más de un
397                                          * registro está en bloques contiguos) */
398                                         memcpy(&curr_reg_header, block,
399                                                         sizeof(EMUFS_TIPO1_REG_HEADER));
400                                 } else { /* se terminó de leer */
401                                         break;
402                                 }
403                         }
404
405                         /* actualizo archivo de identificadores de registros borrados */
406                         if ((err = emufs_did_agregar(efs, reg_id))) {
407                                 /* TODO Manejo de errores */
408                                 PERR("no se pudo actualizar .did");
409                                 free(block);
410                                 return err;
411                         }
412                         /*actualizo archivo .idx*/
413                         if ((err = emufs_idx_borrar(efs, reg_id))) {
414                                 /* TODO Manejo de errores */
415                                 PERR("no se pudo actualizar .did");
416                                 free(block);
417                                 return err;
418                         }
419
420                         /* TODO desplazar a izquierda registros */
421                 }
422                 /* desplazo el offset */
423                 offset += curr_reg_header.size;
424
425         /* esto no debería ser nunca false porque sé positivamente que el */
426         } while (offset < efs->tam_bloque); /* registro está en el bloque */
427
428         free(block);
429         return 0; /* EMUFS_OK */
430 }
431
432 /** Graba un bloque en el archivo. */
433 EMUFS_BLOCK_ID emufs_tipo1_grabar_bloque(EMUFS *efs, void *block,
434                 EMUFS_BLOCK_ID block_id, int* err)
435 {
436         FILE* file;
437         char name_f[255];
438
439         strcpy(name_f,efs->nombre);
440         strcat(name_f,".dat");
441
442         if ((file = fopen(name_f, "r+b")) == NULL) {
443                 /* TODO Manejo de errores */
444                 PERR("Error al abrir archivo");
445                 *err = 4; /* EMUFS_ERROR_CANT_OPEN_FILE */
446                 return EMUFS_NOT_FOUND;
447         }
448         /* Si es NOT_FOUND tengo que agregar un bloque al final del archivo */
449         if (block_id == EMUFS_NOT_FOUND) {
450                 /* me paro al final del archivo */
451                 if (fseek(file, 0l, SEEK_END)) {
452                         /* TODO Manejo de errores */
453                         PERR("No se pudo hacer fseek()");
454                         fclose(file);
455                         *err = 8; /* EMUFS_ERROR_SEEK_FILE */
456                         return EMUFS_NOT_FOUND;
457                 }
458                 /* Obtengo ID del bloque nuevo */
459                 block_id = (ftell(file) - emufs_tipo1_header_size()) / efs->tam_bloque;
460         /* Si es un ID válido, salto hasta ese bloque. */
461         } else {
462                 /* Salta el header del archivo */
463                 if ((*err = emufs_tipo1_header_jump(file))) {
464                         PERR("no se pudo saltar la cabecera del archivo");
465                         fclose(file);
466                         return EMUFS_NOT_FOUND;
467                 }
468                 /* Salta bloques */
469                 if ((*err = emufs_tipo1_block_jump(efs, file, block_id))) {
470                         PERR("no se pudo saltar la cabecera del bloque");
471                         fclose(file);
472                         return EMUFS_NOT_FOUND;
473                 }
474         }
475         /* Grabo el bloque */
476         if (fwrite(block, efs->tam_bloque, 1, file) != 1) {
477                 PERR("No se pudo escribir el archivo");
478                 fclose(file);
479                 *err = 6; /* EMUFS_ERROR_WRITE_FILE */
480                 return EMUFS_NOT_FOUND;
481         }
482
483         fclose(file);
484         return block_id;
485 }
486
487 EMUFS_REG_ID emufs_tipo1_modificar_registro(EMUFS *emu, EMUFS_REG_ID id,
488                 void *data, EMUFS_REG_SIZE size, int *error)
489 {
490         emufs_tipo1_borrar_registro(emu, id);
491         return emufs_tipo1_grabar_registro(emu, data, size, error);
492 }
493
494 size_t emufs_tipo1_header_size(void)
495 {
496         return sizeof(EMUFS_Tipo) + sizeof(EMUFS_BLOCK_SIZE);
497 }
498
499 int emufs_tipo1_header_jump(FILE* fp)
500 {
501         if (fseek(fp, emufs_tipo1_header_size(), SEEK_CUR)) {
502                 PERR("No se pudo hacer fseek()");
503                 return 8; /* EMUFS_ERROR_SEEK_FILE */
504         }
505         return 0; /* EMUFS_OK */
506 }
507
508 int emufs_tipo1_block_jump(EMUFS* efs, FILE* fp, EMUFS_BLOCK_ID block_count)
509 {
510         if (fseek(fp, block_count * efs->tam_bloque, SEEK_CUR)) {
511                 PERR("No se pudo hacer fseek()");
512                 return 8; /* EMUFS_ERROR_SEEK_FILE */
513         }
514         return 0; /* EMUFS_OK */
515 }
516
517 void emufs_tipo1_escribir_reg_en_memoria(char* dst, EMUFS_TIPO1_REG_HEADER header,
518                 char* reg)
519 {
520         emufs_tipo1_escribir_reg_chunk_en_memoria(dst, header, reg, header.size);
521 }
522
523 void emufs_tipo1_escribir_reg_chunk_en_memoria(char* dst,
524                 EMUFS_TIPO1_REG_HEADER header, char* reg, EMUFS_REG_SIZE reg_size)
525 {
526         /* grabo cabecera del registro en el bloque */
527         memcpy(dst, &header, sizeof(EMUFS_TIPO1_REG_HEADER));
528         /* incremento puntero de escritura */
529         dst += sizeof(EMUFS_TIPO1_REG_HEADER);
530         /* grabo el registro en el bloque */
531         memcpy(dst, reg, reg_size);
532 }
533