DistributedTable/persistence_manager.h at master · vascoorey/DistributedTable · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
#ifndef _PERSISTENCE_MANAGER_H
#define _PERSISTENCE_MANAGER_H

#include "table.h"

#define MODE_ASYNC 0 /* Escritas assincronas no log */
#define MODE_FSYNC 1 /* Escritas sincronas no log com integridade de ficheiros */
#define MODE_DSYNC 2 /* Escritas sincronas no log com integridade de dados */

struct pmanager_t; /* A definir pelo grupo em persistence_manager-private.h */

/*
 * Cria um gestor de persistência que armazena logs em filename+".log" e o
 * estado do sistema em filename+".ckp". O parâmetro logsize define o tamanho
 * máximo em bytes que o ficheiro de log pode ter enquanto mode define o modo
 * de escrita dos logs (MODE_ASYNC, MODE_FSYNC e MODE_DSYNC).
 * Retorna o pmanager criado ou NULL em caso de erro.
 */
struct pmanager_t *pmanager_create(char *filename, int logsize, int mode);

/*
 * Destroi este gestor de persistência. Retorna 0 se tudo estiver OK ou -1
 * em caso de erro.
 * Note que esta função não limpa os ficheiros de log e ckp do sistema.
 */
int pmanager_destroy(struct pmanager_t *pmanager);

/*
 * Apaga os ficheiros de log e ckp geridos por este gestor de persistência
 * e o destroi. Retorna 0 se tudo estiver OK ou -1 em caso de erro.
 */
int pmanager_destroy_clear(struct pmanager_t *pmanager);

/*
 * Retorna 1 caso existam dados nos ficheiros de log e/ou checkpoint e 0
 * caso contrário.
 */
int pmanager_have_data(struct pmanager_t *pmanager);

/*
 * Escreve uma string msg no fim do ficheiro de log associado a pmanager.
 * Retorna o número de bytes escritos no log ou -1 em caso de problemas na
 * escrita (e.g., erro no write()) ou caso o tamanho do ficheiro de log após
 * o armazenamento da mensagem seja maior que logsize (neste caso msg não é
 * escrita no log).
 */
int pmanager_log(struct pmanager_t *pmanager, char *msg);

/*
 * Cria um ficheiro filename+".stt" com o estado de table. Retorna
 * o tamanho do ficheiro criado ou -1 em caso de erro.
 */
int pmanager_store_table(struct pmanager_t *pmanager, struct table_t *table);

/*
 * Limpa o ficheiro ".log" e copia o ficheiro ".stt" para ".ckp". Retorna 0
 * se tudo correr bem ou -1 em caso de erro.
 */
int pmanager_rotate_log(struct pmanager_t *pmanager);

/*
 * Mete o estado contido nos ficheiros .log, .stt ou .ckp na tabela passada
 * como argumento.
 */
int pmanager_fill_state(struct pmanager_t *pmanager, struct table_t *table);

#endif