blob: c18a201f2c7835c2e4547f598a77ccea2a8f3fb4 (
plain)
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
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
|
#ifndef RSPAMD_BINLOG_H
#define RSPAMD_BINLOG_H
#include "config.h"
#include "main.h"
#include "statfile.h"
/* How much records are in a single index */
#define BINLOG_IDX_LEN 200
#define METAINDEX_LEN 1024
/* Assume 8 bytes words */
struct rspamd_binlog_header {
gchar magic[3];
gchar version[2];
gchar padding[3];
guint64 create_time;
};
struct rspamd_binlog_index {
guint64 time;
guint64 seek;
guint32 len;
};
struct rspamd_index_block {
struct rspamd_binlog_index indexes[BINLOG_IDX_LEN];
guint32 last_index;
};
struct rspamd_binlog_metaindex {
guint64 indexes[METAINDEX_LEN];
guint64 last_index;
};
struct rspamd_binlog_element {
guint32 h1;
guint32 h2;
float value;
} __attribute__((__packed__));
struct rspamd_binlog {
gchar *filename;
time_t rotate_time;
gint rotate_jitter;
guint64 cur_seq;
guint64 cur_time;
gint fd;
rspamd_mempool_t *pool;
struct rspamd_binlog_header header;
struct rspamd_binlog_metaindex *metaindex;
struct rspamd_index_block *cur_idx;
};
struct rspamd_classifier_config;
/*
* Open binlog at specified path with specified rotate params
*/
struct rspamd_binlog * binlog_open (rspamd_mempool_t *pool,
const gchar *path,
time_t rotate_time,
gint rotate_jitter);
/*
* Get and open binlog for specified statfile
*/
struct rspamd_binlog * get_binlog_by_statfile (struct rspamd_statfile_config *st);
/*
* Close binlog
*/
void binlog_close (struct rspamd_binlog *log);
/*
* Insert new nodes inside binlog
*/
gboolean binlog_insert (struct rspamd_binlog *log, GTree *nodes);
/*
* Sync binlog from specified revision
* @param log binlog structure
* @param from_rev from revision
* @param from_time from time
* @param rep a portion of changes for revision is stored here
* @return TRUE if there are more revisions to get and FALSE if synchronization is complete
*/
gboolean binlog_sync (struct rspamd_binlog *log,
guint64 from_rev,
guint64 *from_time,
GByteArray **rep);
/*
* Conditional write to a binlog for specified statfile
*/
gboolean maybe_write_binlog (struct rspamd_classifier_config *ccf,
struct rspamd_statfile_config *st,
stat_file_t *file,
GTree *nodes);
#endif
|
