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
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
|
/* Copyright (c) 2009-2018 Dovecot authors, see the included COPYING file */
#include "lib.h"
#include "array.h"
#include "test-common.h"
#include "mail-index-modseq.h"
#include "mail-storage-private.h"
static uint32_t expunge_uids[] = { 25, 15, 7, 3, 11, 1, 53, 33 };
static guid_128_t mail_guids[N_ELEMENTS(expunge_uids)];
static unsigned int expunge_idx;
static unsigned int nonexternal_idx;
uint32_t mail_index_view_get_messages_count(struct mail_index_view *view ATTR_UNUSED)
{
return 0;
}
void mail_index_lookup_uid(struct mail_index_view *view ATTR_UNUSED,
uint32_t seq, uint32_t *uid_r)
{
*uid_r = seq;
}
bool mail_index_lookup_seq_range(struct mail_index_view *view ATTR_UNUSED,
uint32_t first_uid, uint32_t last_uid,
uint32_t *first_seq_r, uint32_t *last_seq_r)
{
*first_seq_r = first_uid;
*last_seq_r = last_uid;
return TRUE;
}
bool mail_index_modseq_get_next_log_offset(struct mail_index_view *view ATTR_UNUSED,
uint64_t modseq, uint32_t *log_seq_r,
uoff_t *log_offset_r)
{
*log_seq_r = modseq >> 32;
*log_offset_r = modseq & 0xfffffff;
return TRUE;
}
struct mail_transaction_log_view *
mail_transaction_log_view_open(struct mail_transaction_log *log ATTR_UNUSED) { return NULL; }
int mail_transaction_log_view_set(struct mail_transaction_log_view *view ATTR_UNUSED,
uint32_t min_file_seq ATTR_UNUSED, uoff_t min_file_offset ATTR_UNUSED,
uint32_t max_file_seq ATTR_UNUSED, uoff_t max_file_offset ATTR_UNUSED,
bool *reset_r ATTR_UNUSED, const char **reason_r ATTR_UNUSED) {
if (min_file_seq < 99)
return 0;
return 1;
}
void mail_transaction_log_view_close(struct mail_transaction_log_view **view ATTR_UNUSED) { }
void mail_transaction_log_get_tail(struct mail_transaction_log *log ATTR_UNUSED,
uint32_t *file_seq_r)
{
*file_seq_r = 100;
}
int mail_transaction_log_view_next(struct mail_transaction_log_view *view ATTR_UNUSED,
const struct mail_transaction_header **hdr_r,
const void **data_r)
{
static struct mail_transaction_header hdr;
static struct mail_transaction_expunge_guid exp;
static struct mail_transaction_expunge old_exp;
if (expunge_idx == N_ELEMENTS(expunge_uids))
return 0;
if (mail_guids[expunge_idx][0] == 0) {
old_exp.uid1 = old_exp.uid2 = expunge_uids[expunge_idx];
hdr.type = MAIL_TRANSACTION_EXPUNGE;
hdr.size = sizeof(old_exp);
*data_r = &old_exp;
} else {
exp.uid = expunge_uids[expunge_idx];
memcpy(exp.guid_128, mail_guids[expunge_idx], sizeof(exp.guid_128));
hdr.type = MAIL_TRANSACTION_EXPUNGE_GUID;
hdr.size = sizeof(exp);
*data_r = &exp;
}
if (expunge_idx != nonexternal_idx)
hdr.type |= MAIL_TRANSACTION_EXTERNAL;
*hdr_r = &hdr;
expunge_idx++;
return 1;
}
void mail_transaction_log_view_mark(struct mail_transaction_log_view *view ATTR_UNUSED)
{
}
void mail_transaction_log_view_rewind(struct mail_transaction_log_view *view ATTR_UNUSED)
{
expunge_idx = 0;
}
static void test_mailbox_get_expunges(void)
{
struct mailbox *box;
ARRAY_TYPE(seq_range) uids_filter;
ARRAY_TYPE(mailbox_expunge_rec) expunges;
const struct mailbox_expunge_rec *exp;
unsigned int count;
uint64_t modseq;
box = t_new(struct mailbox, 1);
box->index = t_new(struct mail_index, 1);
box->view = t_new(struct mail_index_view, 1);
box->view->log_file_head_seq = 101;
box->view->log_file_head_offset = 1024;
test_begin("mailbox get expunges");
nonexternal_idx = 1;
memset(mail_guids + 2, 0, GUID_128_SIZE);
memset(mail_guids + 4, 0, GUID_128_SIZE);
t_array_init(&uids_filter, 32);
seq_range_array_add_range(&uids_filter, 1, 20);
seq_range_array_add_range(&uids_filter, 53, 53);
t_array_init(&expunges, 32);
modseq = 98ULL << 32;
test_assert(!mailbox_get_expunges(box, modseq, &uids_filter,
&expunges));
exp = array_get(&expunges, &count);
test_assert(count == 5);
test_assert(exp[0].uid == 3);
test_assert(memcmp(exp[0].guid_128, mail_guids[3], GUID_128_SIZE) == 0);
test_assert(exp[1].uid == 1);
test_assert(memcmp(exp[1].guid_128, mail_guids[5], GUID_128_SIZE) == 0);
test_assert(exp[2].uid == 53);
test_assert(memcmp(exp[2].guid_128, mail_guids[6], GUID_128_SIZE) == 0);
test_assert(exp[3].uid == 7);
test_assert(memcmp(exp[3].guid_128, mail_guids[2], GUID_128_SIZE) == 0);
test_assert(exp[4].uid == 11);
test_assert(memcmp(exp[4].guid_128, mail_guids[4], GUID_128_SIZE) == 0);
test_end();
}
int main(void)
{
static void (*const test_functions[])(void) = {
test_mailbox_get_expunges,
NULL
};
unsigned int i, j;
for (i = 0; i < N_ELEMENTS(mail_guids); i++) {
for (j = 0; j < GUID_128_SIZE; j++)
mail_guids[i][j] = j + i + 1;
}
return test_run(test_functions);
}
|
