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
103
104
|
#ifndef MAIL_INDEX_SYNC_PRIVATE_H
#define MAIL_INDEX_SYNC_PRIVATE_H
#include "mail-index-private.h"
#include "mail-transaction-log.h"
struct uid_range {
uint32_t uid1, uid2;
};
ARRAY_DEFINE_TYPE(uid_range, struct uid_range);
struct mail_index_sync_list {
const ARRAY_TYPE(uid_range) *array;
unsigned int idx;
unsigned int keyword_idx:31;
bool keyword_remove:1;
};
struct mail_index_expunge_handler {
mail_index_expunge_handler_t *handler;
void *context;
void **sync_context;
uint32_t record_offset;
};
struct mail_index_sync_map_ctx {
struct mail_index_view *view;
struct mail_index_modseq_sync *modseq_ctx;
uint32_t cur_ext_map_idx;
uint32_t cur_ext_record_size;
uint32_t ext_intro_seq;
uoff_t ext_intro_offset, ext_intro_end_offset;
ARRAY(struct mail_index_expunge_handler) expunge_handlers;
ARRAY(void *) extra_contexts;
buffer_t *unknown_extensions;
enum mail_index_sync_handler_type type;
bool sync_handlers_initialized:1;
bool expunge_handlers_set:1;
bool expunge_handlers_used:1;
bool cur_ext_ignore:1;
bool internal_update:1; /* used by keywords for ext_intro */
bool errors:1;
};
extern struct mail_transaction_map_functions mail_index_map_sync_funcs;
void mail_index_sync_map_init(struct mail_index_sync_map_ctx *sync_map_ctx,
struct mail_index_view *view,
enum mail_index_sync_handler_type type);
void mail_index_sync_map_deinit(struct mail_index_sync_map_ctx *sync_map_ctx);
bool mail_index_sync_map_want_index_reopen(struct mail_index_map *map,
enum mail_index_sync_handler_type type);
int mail_index_sync_map(struct mail_index_map **_map,
enum mail_index_sync_handler_type type,
const char **reason_r);
int mail_index_sync_record(struct mail_index_sync_map_ctx *ctx,
const struct mail_transaction_header *hdr,
const void *data);
struct mail_index_map *
mail_index_sync_get_atomic_map(struct mail_index_sync_map_ctx *ctx);
void mail_index_sync_init_expunge_handlers(struct mail_index_sync_map_ctx *ctx);
void
mail_index_sync_deinit_expunge_handlers(struct mail_index_sync_map_ctx *ctx);
void mail_index_sync_init_handlers(struct mail_index_sync_map_ctx *ctx);
void mail_index_sync_deinit_handlers(struct mail_index_sync_map_ctx *ctx);
int mail_index_sync_ext_intro(struct mail_index_sync_map_ctx *ctx,
const struct mail_transaction_ext_intro *u);
int mail_index_sync_ext_reset(struct mail_index_sync_map_ctx *ctx,
const struct mail_transaction_ext_reset *u);
int mail_index_sync_ext_hdr_update(struct mail_index_sync_map_ctx *ctx,
uint32_t offset, uint32_t size,
const void *data);
int
mail_index_sync_ext_rec_update(struct mail_index_sync_map_ctx *ctx,
const struct mail_transaction_ext_rec_update *u);
int
mail_index_sync_ext_atomic_inc(struct mail_index_sync_map_ctx *ctx,
const struct mail_transaction_ext_atomic_inc *u);
int mail_index_sync_keywords(struct mail_index_sync_map_ctx *ctx,
const struct mail_transaction_header *hdr,
const struct mail_transaction_keyword_update *rec);
int
mail_index_sync_keywords_reset(struct mail_index_sync_map_ctx *ctx,
const struct mail_transaction_header *hdr,
const struct mail_transaction_keyword_reset *r);
void mail_index_sync_set_corrupted(struct mail_index_sync_map_ctx *ctx,
const char *fmt, ...)
ATTR_FORMAT(2, 3) ATTR_COLD;
#ifdef DEBUG
void mail_index_map_check(struct mail_index_map *map);
#endif
#endif
|
