Cross Reference: /dovecot/src/lib-index/mail-transaction-log-view.c
mail-transaction-log-view.c revision 01ac83a86f9f29741b585205eefeec9c0c546f8b
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
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen/* Copyright (C) 2003-2004 Timo Sirainen */
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen#include "lib.h"
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen#include "buffer.h"
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen#include "mail-index-private.h"
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen#include "mail-transaction-log-private.h"
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen#include "mail-transaction-util.h"
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainenstruct mail_transaction_log_view {
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen struct mail_transaction_log *log;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen struct mail_transaction_log_view *next;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen uint32_t min_file_seq, max_file_seq;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen uoff_t min_file_offset, max_file_offset;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen enum mail_transaction_type type_mask;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen struct mail_transaction_header tmp_hdr;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
a24f6b02ed8d0dde933a715be1c86f01977bf610Timo Sirainen struct mail_transaction_log_file *cur, *head, *tail;
a24f6b02ed8d0dde933a715be1c86f01977bf610Timo Sirainen uoff_t cur_offset;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen uint32_t prev_file_seq;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen uoff_t prev_file_offset;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen unsigned int broken:1;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen};
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainenstruct mail_transaction_log_view *
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainenmail_transaction_log_view_open(struct mail_transaction_log *log)
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen{
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen struct mail_transaction_log_view *view;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen view = i_new(struct mail_transaction_log_view, 1);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen view->log = log;
7888a9d2008eab9985096c46e1da9ee985c22a2aTimo Sirainen view->broken = TRUE;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
a24f6b02ed8d0dde933a715be1c86f01977bf610Timo Sirainen view->head = view->tail = view->log->head;
a24f6b02ed8d0dde933a715be1c86f01977bf610Timo Sirainen view->head->refcount++;
a24f6b02ed8d0dde933a715be1c86f01977bf610Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen view->next = log->views;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen log->views = view;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen return view;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen}
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainenvoid mail_transaction_log_view_close(struct mail_transaction_log_view *view)
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen{
93b29720c5141f787bd1861796867e4595c9d084Timo Sirainen struct mail_transaction_log_view **p;
a24f6b02ed8d0dde933a715be1c86f01977bf610Timo Sirainen struct mail_transaction_log_file *file;
93b29720c5141f787bd1861796867e4595c9d084Timo Sirainen
93b29720c5141f787bd1861796867e4595c9d084Timo Sirainen for (p = &view->log->views; *p != NULL; p = &(*p)->next) {
93b29720c5141f787bd1861796867e4595c9d084Timo Sirainen if (*p == view) {
93b29720c5141f787bd1861796867e4595c9d084Timo Sirainen *p = view->next;
93b29720c5141f787bd1861796867e4595c9d084Timo Sirainen break;
93b29720c5141f787bd1861796867e4595c9d084Timo Sirainen }
93b29720c5141f787bd1861796867e4595c9d084Timo Sirainen }
93b29720c5141f787bd1861796867e4595c9d084Timo Sirainen
a24f6b02ed8d0dde933a715be1c86f01977bf610Timo Sirainen for (file = view->tail; file != view->head; file = file->next)
a24f6b02ed8d0dde933a715be1c86f01977bf610Timo Sirainen file->refcount--;
a24f6b02ed8d0dde933a715be1c86f01977bf610Timo Sirainen view->head->refcount--;
a24f6b02ed8d0dde933a715be1c86f01977bf610Timo Sirainen
a24f6b02ed8d0dde933a715be1c86f01977bf610Timo Sirainen mail_transaction_logs_clean(view->log);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen i_free(view);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen}
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
93b29720c5141f787bd1861796867e4595c9d084Timo Sirainenvoid mail_transaction_log_views_close(struct mail_transaction_log *log)
93b29720c5141f787bd1861796867e4595c9d084Timo Sirainen{
93b29720c5141f787bd1861796867e4595c9d084Timo Sirainen struct mail_transaction_log_view *view;
93b29720c5141f787bd1861796867e4595c9d084Timo Sirainen
93b29720c5141f787bd1861796867e4595c9d084Timo Sirainen for (view = log->views; view != NULL; view = view->next)
93b29720c5141f787bd1861796867e4595c9d084Timo Sirainen view->log = NULL;
93b29720c5141f787bd1861796867e4595c9d084Timo Sirainen}
93b29720c5141f787bd1861796867e4595c9d084Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainenint
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainenmail_transaction_log_view_set(struct mail_transaction_log_view *view,
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen uint32_t min_file_seq, uoff_t min_file_offset,
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen uint32_t max_file_seq, uoff_t max_file_offset,
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen enum mail_transaction_type type_mask)
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen{
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen /* FIXME: error handling for "not found" case is bad.. should the
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen caller after all check it and handle as it sees best..? */
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen struct mail_transaction_log_file *file, *first;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen uint32_t seq;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen uoff_t end_offset;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen int ret;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen i_assert(min_file_seq <= max_file_seq);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
93b29720c5141f787bd1861796867e4595c9d084Timo Sirainen if (view->log == NULL)
93b29720c5141f787bd1861796867e4595c9d084Timo Sirainen return -1;
93b29720c5141f787bd1861796867e4595c9d084Timo Sirainen
0d658231054332c3f4c04aab0422af649de89a8cTimo Sirainen if (min_file_seq == 0) {
0d658231054332c3f4c04aab0422af649de89a8cTimo Sirainen /* new index, transaction file not synced yet */
0d658231054332c3f4c04aab0422af649de89a8cTimo Sirainen min_file_seq = 1;
f2786c07cbd4a7a0a6a46c3e06dc4545aaf2f278Timo Sirainen min_file_offset = 0;
0d658231054332c3f4c04aab0422af649de89a8cTimo Sirainen
0d658231054332c3f4c04aab0422af649de89a8cTimo Sirainen if (max_file_seq == 0) {
0d658231054332c3f4c04aab0422af649de89a8cTimo Sirainen max_file_seq = min_file_seq;
0d658231054332c3f4c04aab0422af649de89a8cTimo Sirainen max_file_offset = min_file_offset;
0d658231054332c3f4c04aab0422af649de89a8cTimo Sirainen }
f2786c07cbd4a7a0a6a46c3e06dc4545aaf2f278Timo Sirainen }
0d658231054332c3f4c04aab0422af649de89a8cTimo Sirainen
9df8c9225140d9d1df5ddf4c6c9da61662ae6c44Timo Sirainen if (min_file_seq == view->log->tail->hdr.prev_file_seq &&
9df8c9225140d9d1df5ddf4c6c9da61662ae6c44Timo Sirainen min_file_offset == view->log->tail->hdr.prev_file_offset) {
9df8c9225140d9d1df5ddf4c6c9da61662ae6c44Timo Sirainen /* we can skip this */
9df8c9225140d9d1df5ddf4c6c9da61662ae6c44Timo Sirainen min_file_seq = view->log->tail->hdr.file_seq;
f2786c07cbd4a7a0a6a46c3e06dc4545aaf2f278Timo Sirainen min_file_offset = 0;
9df8c9225140d9d1df5ddf4c6c9da61662ae6c44Timo Sirainen
9df8c9225140d9d1df5ddf4c6c9da61662ae6c44Timo Sirainen if (min_file_seq > max_file_seq) {
9df8c9225140d9d1df5ddf4c6c9da61662ae6c44Timo Sirainen /* empty view */
9df8c9225140d9d1df5ddf4c6c9da61662ae6c44Timo Sirainen max_file_seq = min_file_seq;
9df8c9225140d9d1df5ddf4c6c9da61662ae6c44Timo Sirainen max_file_offset = min_file_offset;
40ef82c46f6652412b068ebcdac7c3e74840a284Timo Sirainen }
9df8c9225140d9d1df5ddf4c6c9da61662ae6c44Timo Sirainen }
40ef82c46f6652412b068ebcdac7c3e74840a284Timo Sirainen
fc7b17677ac1a5fa3f7fe13d5ef7dcfea8d9b4a1Timo Sirainen /* find the oldest log file first. */
9df8c9225140d9d1df5ddf4c6c9da61662ae6c44Timo Sirainen ret = mail_transaction_log_file_find(view->log, min_file_seq, &file);
9df8c9225140d9d1df5ddf4c6c9da61662ae6c44Timo Sirainen if (ret <= 0) {
40ef82c46f6652412b068ebcdac7c3e74840a284Timo Sirainen if (ret == 0) {
40ef82c46f6652412b068ebcdac7c3e74840a284Timo Sirainen mail_index_set_error(view->log->index,
40ef82c46f6652412b068ebcdac7c3e74840a284Timo Sirainen "Lost transaction log file %s seq %u",
40ef82c46f6652412b068ebcdac7c3e74840a284Timo Sirainen view->log->tail->filepath, min_file_seq);
f75188af11dce30be322cc2eefa3e3884871abf7Timo Sirainen mail_index_set_inconsistent(view->log->index);
40ef82c46f6652412b068ebcdac7c3e74840a284Timo Sirainen }
9df8c9225140d9d1df5ddf4c6c9da61662ae6c44Timo Sirainen return -1;
40ef82c46f6652412b068ebcdac7c3e74840a284Timo Sirainen }
ed1f14af0d426b5550521a58fc414d130aa14172Timo Sirainen
f2786c07cbd4a7a0a6a46c3e06dc4545aaf2f278Timo Sirainen if (min_file_offset == 0) {
f2786c07cbd4a7a0a6a46c3e06dc4545aaf2f278Timo Sirainen /* this could happen if internal transactions haven't yet been
f2786c07cbd4a7a0a6a46c3e06dc4545aaf2f278Timo Sirainen committed but external are. just assume we're at the
f2786c07cbd4a7a0a6a46c3e06dc4545aaf2f278Timo Sirainen beginning. */
f2786c07cbd4a7a0a6a46c3e06dc4545aaf2f278Timo Sirainen min_file_offset = file->hdr.hdr_size;
f2786c07cbd4a7a0a6a46c3e06dc4545aaf2f278Timo Sirainen if (max_file_offset == 0 && min_file_seq == max_file_seq)
f2786c07cbd4a7a0a6a46c3e06dc4545aaf2f278Timo Sirainen max_file_offset = min_file_offset;
f2786c07cbd4a7a0a6a46c3e06dc4545aaf2f278Timo Sirainen }
f2786c07cbd4a7a0a6a46c3e06dc4545aaf2f278Timo Sirainen
ed1f14af0d426b5550521a58fc414d130aa14172Timo Sirainen /* check these later than others as index file may have corrupted
ed1f14af0d426b5550521a58fc414d130aa14172Timo Sirainen log_file_offset. we should have recreated the log file and
ed1f14af0d426b5550521a58fc414d130aa14172Timo Sirainen skipped min_file_seq file above.. max_file_offset can be broken
ed1f14af0d426b5550521a58fc414d130aa14172Timo Sirainen only if min_file_seq = max_file_seq. */
f2786c07cbd4a7a0a6a46c3e06dc4545aaf2f278Timo Sirainen i_assert(min_file_offset >= file->hdr.hdr_size);
8eeafcb306872435f3171e6acf5a9937aec3a175Timo Sirainen i_assert(min_file_seq != max_file_seq ||
8eeafcb306872435f3171e6acf5a9937aec3a175Timo Sirainen min_file_offset <= max_file_offset);
8eeafcb306872435f3171e6acf5a9937aec3a175Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen end_offset = min_file_seq == max_file_seq ?
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen max_file_offset : (uoff_t)-1;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen ret = mail_transaction_log_file_map(file, min_file_offset, end_offset);
1b56f5fdd415270c743a38719d41b4d9497bcacdTimo Sirainen if (ret <= 0) {
1b56f5fdd415270c743a38719d41b4d9497bcacdTimo Sirainen if (ret == 0) {
fc7b17677ac1a5fa3f7fe13d5ef7dcfea8d9b4a1Timo Sirainen /* File is corrupted or stale NFS handle */
1b56f5fdd415270c743a38719d41b4d9497bcacdTimo Sirainen mail_index_set_error(view->log->index,
1b56f5fdd415270c743a38719d41b4d9497bcacdTimo Sirainen "Lost transaction log file %s seq %u",
1b56f5fdd415270c743a38719d41b4d9497bcacdTimo Sirainen file->filepath, file->hdr.file_seq);
f75188af11dce30be322cc2eefa3e3884871abf7Timo Sirainen mail_index_set_inconsistent(view->log->index);
1b56f5fdd415270c743a38719d41b4d9497bcacdTimo Sirainen }
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen return -1;
1b56f5fdd415270c743a38719d41b4d9497bcacdTimo Sirainen }
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen first = file;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen for (seq = min_file_seq+1; seq <= max_file_seq; seq++) {
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen file = file->next;
fc7b17677ac1a5fa3f7fe13d5ef7dcfea8d9b4a1Timo Sirainen if (file == NULL || file->hdr.file_seq != seq) {
fc7b17677ac1a5fa3f7fe13d5ef7dcfea8d9b4a1Timo Sirainen /* see if we could find the missing file */
fc7b17677ac1a5fa3f7fe13d5ef7dcfea8d9b4a1Timo Sirainen ret = mail_transaction_log_file_find(view->log,
fc7b17677ac1a5fa3f7fe13d5ef7dcfea8d9b4a1Timo Sirainen seq, &file);
fc7b17677ac1a5fa3f7fe13d5ef7dcfea8d9b4a1Timo Sirainen if (ret <= 0) {
fc7b17677ac1a5fa3f7fe13d5ef7dcfea8d9b4a1Timo Sirainen if (ret < 0)
fc7b17677ac1a5fa3f7fe13d5ef7dcfea8d9b4a1Timo Sirainen return -1;
fc7b17677ac1a5fa3f7fe13d5ef7dcfea8d9b4a1Timo Sirainen
fc7b17677ac1a5fa3f7fe13d5ef7dcfea8d9b4a1Timo Sirainen /* not found / corrupted */
fc7b17677ac1a5fa3f7fe13d5ef7dcfea8d9b4a1Timo Sirainen file = NULL;
fc7b17677ac1a5fa3f7fe13d5ef7dcfea8d9b4a1Timo Sirainen }
fc7b17677ac1a5fa3f7fe13d5ef7dcfea8d9b4a1Timo Sirainen }
fc7b17677ac1a5fa3f7fe13d5ef7dcfea8d9b4a1Timo Sirainen
fc7b17677ac1a5fa3f7fe13d5ef7dcfea8d9b4a1Timo Sirainen if (file == NULL || file->hdr.file_seq != seq) {
e86d0d34fe365da4c7ca4312d575bfcbf3a01c0eTimo Sirainen if (file == NULL && max_file_seq == (uint32_t)-1) {
e86d0d34fe365da4c7ca4312d575bfcbf3a01c0eTimo Sirainen /* we just wanted to sync everything */
e86d0d34fe365da4c7ca4312d575bfcbf3a01c0eTimo Sirainen max_file_seq = seq-1;
e86d0d34fe365da4c7ca4312d575bfcbf3a01c0eTimo Sirainen break;
e86d0d34fe365da4c7ca4312d575bfcbf3a01c0eTimo Sirainen }
e86d0d34fe365da4c7ca4312d575bfcbf3a01c0eTimo Sirainen
fc7b17677ac1a5fa3f7fe13d5ef7dcfea8d9b4a1Timo Sirainen /* missing files in the middle */
1b56f5fdd415270c743a38719d41b4d9497bcacdTimo Sirainen mail_index_set_error(view->log->index,
1b56f5fdd415270c743a38719d41b4d9497bcacdTimo Sirainen "Lost transaction log file %s seq %u",
8830fab191cab8440281eb641dfdd93974b2933bTimo Sirainen view->log->tail->filepath, seq);
f75188af11dce30be322cc2eefa3e3884871abf7Timo Sirainen mail_index_set_inconsistent(view->log->index);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen return -1;
1b56f5fdd415270c743a38719d41b4d9497bcacdTimo Sirainen }
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen end_offset = file->hdr.file_seq == max_file_seq ?
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen max_file_offset : (uoff_t)-1;
f2786c07cbd4a7a0a6a46c3e06dc4545aaf2f278Timo Sirainen ret = mail_transaction_log_file_map(file, file->hdr.hdr_size,
f2786c07cbd4a7a0a6a46c3e06dc4545aaf2f278Timo Sirainen end_offset);
1b56f5fdd415270c743a38719d41b4d9497bcacdTimo Sirainen if (ret == 0) {
fc7b17677ac1a5fa3f7fe13d5ef7dcfea8d9b4a1Timo Sirainen /* File is corrupted or stale NFS handle */
1b56f5fdd415270c743a38719d41b4d9497bcacdTimo Sirainen mail_index_set_error(view->log->index,
1b56f5fdd415270c743a38719d41b4d9497bcacdTimo Sirainen "Lost transaction log file %s seq %u",
1b56f5fdd415270c743a38719d41b4d9497bcacdTimo Sirainen file->filepath, file->hdr.file_seq);
f75188af11dce30be322cc2eefa3e3884871abf7Timo Sirainen mail_index_set_inconsistent(view->log->index);
1b56f5fdd415270c743a38719d41b4d9497bcacdTimo Sirainen }
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen if (ret <= 0)
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen return -1;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen }
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
527ed64bc924b4a13b570a8450f8be3efdf71879Timo Sirainen i_assert(max_file_offset == (uoff_t)-1 ||
527ed64bc924b4a13b570a8450f8be3efdf71879Timo Sirainen max_file_offset <= file->sync_offset);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
a24f6b02ed8d0dde933a715be1c86f01977bf610Timo Sirainen /* we have all of them. update refcounts. */
a24f6b02ed8d0dde933a715be1c86f01977bf610Timo Sirainen if (view->tail->hdr.file_seq < first->hdr.file_seq) {
a24f6b02ed8d0dde933a715be1c86f01977bf610Timo Sirainen /* unref old files */
a24f6b02ed8d0dde933a715be1c86f01977bf610Timo Sirainen for (file = view->tail; file != first; file = file->next)
a24f6b02ed8d0dde933a715be1c86f01977bf610Timo Sirainen file->refcount--;
a24f6b02ed8d0dde933a715be1c86f01977bf610Timo Sirainen view->tail = first;
a24f6b02ed8d0dde933a715be1c86f01977bf610Timo Sirainen } else {
9df8c9225140d9d1df5ddf4c6c9da61662ae6c44Timo Sirainen /* going backwards, reference them */
9df8c9225140d9d1df5ddf4c6c9da61662ae6c44Timo Sirainen for (file = first; file != view->tail; file = file->next)
9df8c9225140d9d1df5ddf4c6c9da61662ae6c44Timo Sirainen file->refcount++;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen }
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
a24f6b02ed8d0dde933a715be1c86f01977bf610Timo Sirainen /* reference all new files */
a24f6b02ed8d0dde933a715be1c86f01977bf610Timo Sirainen for (file = view->head->next; file != NULL; file = file->next)
a24f6b02ed8d0dde933a715be1c86f01977bf610Timo Sirainen file->refcount++;
a24f6b02ed8d0dde933a715be1c86f01977bf610Timo Sirainen view->head = view->log->head;
a24f6b02ed8d0dde933a715be1c86f01977bf610Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen view->prev_file_seq = 0;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen view->prev_file_offset = 0;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
a24f6b02ed8d0dde933a715be1c86f01977bf610Timo Sirainen view->cur = first;
a24f6b02ed8d0dde933a715be1c86f01977bf610Timo Sirainen view->cur_offset = min_file_offset;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen view->min_file_seq = min_file_seq;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen view->min_file_offset = min_file_offset;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen view->max_file_seq = max_file_seq;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen view->max_file_offset = max_file_offset;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen view->type_mask = type_mask;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen view->broken = FALSE;
f2786c07cbd4a7a0a6a46c3e06dc4545aaf2f278Timo Sirainen
fadd878cd6098f5b873c21c121209a922679dae4Timo Sirainen i_assert(view->cur_offset <= view->cur->sync_offset);
f2786c07cbd4a7a0a6a46c3e06dc4545aaf2f278Timo Sirainen i_assert(view->cur->hdr.file_seq == min_file_seq);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen return 0;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen}
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainenvoid
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainenmail_transaction_log_view_get_prev_pos(struct mail_transaction_log_view *view,
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen uint32_t *file_seq_r,
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen uoff_t *file_offset_r)
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen{
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen *file_seq_r = view->prev_file_seq;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen *file_offset_r = view->prev_file_offset;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen}
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainenvoid
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainenmail_transaction_log_view_set_corrupted(struct mail_transaction_log_view *view,
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen const char *fmt, ...)
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen{
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen va_list va;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen view->broken = TRUE;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen va_start(va, fmt);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen t_push();
c1d45cada20777e1973579d40d0ebe43f89bb053Timo Sirainen mail_transaction_log_file_set_corrupted(view->log->head, "%s",
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen t_strdup_vprintf(fmt, va));
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen t_pop();
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen va_end(va);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen}
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainenint
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainenmail_transaction_log_view_is_corrupted(struct mail_transaction_log_view *view)
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen{
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen return view->broken;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen}
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
a8012fea2a7315033bc467acbf46be8e7323318cTimo Sirainenstatic int
a8012fea2a7315033bc467acbf46be8e7323318cTimo Sirainenlog_view_get_next(struct mail_transaction_log_view *view,
a8012fea2a7315033bc467acbf46be8e7323318cTimo Sirainen const struct mail_transaction_header **hdr_r,
834b90e1f426d1e3308670e09c050bcdea546eb8Timo Sirainen const void **data_r)
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen{
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen const struct mail_transaction_header *hdr;
0add8c99ca65e56dbf613595fc37c41aafff3f7fTimo Sirainen struct mail_transaction_log_file *file;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen const struct mail_transaction_type_map *type_rec;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen const void *data;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen unsigned int record_size;
44ff75ca53188056ff5a3e50428e3f2078800b3cTimo Sirainen uint32_t hdr_size;
f1e1d821d93e4a1dc6ed8f23febde868b5d64cd5Timo Sirainen size_t file_size;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
f2786c07cbd4a7a0a6a46c3e06dc4545aaf2f278Timo Sirainen if (view->cur == NULL)
f2786c07cbd4a7a0a6a46c3e06dc4545aaf2f278Timo Sirainen return 0;
f2786c07cbd4a7a0a6a46c3e06dc4545aaf2f278Timo Sirainen
fadd878cd6098f5b873c21c121209a922679dae4Timo Sirainen /* prev_file_offset should point to beginning of previous log record.
fadd878cd6098f5b873c21c121209a922679dae4Timo Sirainen when we reach EOF, it should be left there, not to beginning of the
fadd878cd6098f5b873c21c121209a922679dae4Timo Sirainen next file. */
f2786c07cbd4a7a0a6a46c3e06dc4545aaf2f278Timo Sirainen view->prev_file_seq = view->cur->hdr.file_seq;
f2786c07cbd4a7a0a6a46c3e06dc4545aaf2f278Timo Sirainen view->prev_file_offset = view->cur_offset;
f2786c07cbd4a7a0a6a46c3e06dc4545aaf2f278Timo Sirainen
fadd878cd6098f5b873c21c121209a922679dae4Timo Sirainen if (view->cur->hdr.file_seq == view->max_file_seq) {
fadd878cd6098f5b873c21c121209a922679dae4Timo Sirainen /* last file */
fadd878cd6098f5b873c21c121209a922679dae4Timo Sirainen if (view->cur_offset == view->max_file_offset ||
fadd878cd6098f5b873c21c121209a922679dae4Timo Sirainen view->cur_offset == view->cur->sync_offset) {
fadd878cd6098f5b873c21c121209a922679dae4Timo Sirainen /* we're all finished */
fadd878cd6098f5b873c21c121209a922679dae4Timo Sirainen view->cur = NULL;
fadd878cd6098f5b873c21c121209a922679dae4Timo Sirainen return 0;
fadd878cd6098f5b873c21c121209a922679dae4Timo Sirainen }
fadd878cd6098f5b873c21c121209a922679dae4Timo Sirainen } else if (view->cur_offset == view->cur->sync_offset) {
fadd878cd6098f5b873c21c121209a922679dae4Timo Sirainen /* end of file, go to next one */
fadd878cd6098f5b873c21c121209a922679dae4Timo Sirainen view->cur = view->cur->next;
fadd878cd6098f5b873c21c121209a922679dae4Timo Sirainen if (view->cur == NULL)
d6f50f100ce17fa4b3a89e9567a5ff993b38b872Timo Sirainen return 0;
0add8c99ca65e56dbf613595fc37c41aafff3f7fTimo Sirainen
fadd878cd6098f5b873c21c121209a922679dae4Timo Sirainen view->cur_offset = view->cur->hdr.hdr_size;
fadd878cd6098f5b873c21c121209a922679dae4Timo Sirainen return log_view_get_next(view, hdr_r, data_r);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen }
fadd878cd6098f5b873c21c121209a922679dae4Timo Sirainen file = view->cur;
b7cf555b699d73f2d71de0dabc088af6a7be3627Timo Sirainen
f1e1d821d93e4a1dc6ed8f23febde868b5d64cd5Timo Sirainen data = buffer_get_data(file->buffer, &file_size);
f1e1d821d93e4a1dc6ed8f23febde868b5d64cd5Timo Sirainen file_size += file->buffer_offset;
f1e1d821d93e4a1dc6ed8f23febde868b5d64cd5Timo Sirainen
a24f6b02ed8d0dde933a715be1c86f01977bf610Timo Sirainen if (view->cur_offset + sizeof(*hdr) > file_size) {
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen mail_transaction_log_file_set_corrupted(file,
f1e1d821d93e4a1dc6ed8f23febde868b5d64cd5Timo Sirainen "offset points outside file "
f1e1d821d93e4a1dc6ed8f23febde868b5d64cd5Timo Sirainen "(%"PRIuUOFF_T" + %"PRIuSIZE_T" > %"PRIuSIZE_T")",
a24f6b02ed8d0dde933a715be1c86f01977bf610Timo Sirainen view->cur_offset, sizeof(*hdr), file_size);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen return -1;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen }
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
6eb30032b4a50c383dea4c9c74342d906de6ad36Timo Sirainen i_assert(view->cur_offset >= file->buffer_offset);
a24f6b02ed8d0dde933a715be1c86f01977bf610Timo Sirainen hdr = CONST_PTR_OFFSET(data, view->cur_offset - file->buffer_offset);
1175f27441385a7011629f295f42708f9a3a4ffcTimo Sirainen data = CONST_PTR_OFFSET(hdr, sizeof(*hdr));
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
44ff75ca53188056ff5a3e50428e3f2078800b3cTimo Sirainen hdr_size = mail_index_offset_to_uint32(hdr->size);
44ff75ca53188056ff5a3e50428e3f2078800b3cTimo Sirainen if (hdr_size < sizeof(*hdr)) {
5a07b37a9df398b5189c14872a600384208ab74bTimo Sirainen type_rec = NULL;
5a07b37a9df398b5189c14872a600384208ab74bTimo Sirainen record_size = 0;
5a07b37a9df398b5189c14872a600384208ab74bTimo Sirainen } else {
5a07b37a9df398b5189c14872a600384208ab74bTimo Sirainen type_rec = mail_transaction_type_lookup(hdr->type);
5a07b37a9df398b5189c14872a600384208ab74bTimo Sirainen if (type_rec != NULL)
5a07b37a9df398b5189c14872a600384208ab74bTimo Sirainen record_size = type_rec->record_size;
5a07b37a9df398b5189c14872a600384208ab74bTimo Sirainen else {
5a07b37a9df398b5189c14872a600384208ab74bTimo Sirainen mail_transaction_log_file_set_corrupted(file,
5a07b37a9df398b5189c14872a600384208ab74bTimo Sirainen "unknown record type 0x%x",
5a07b37a9df398b5189c14872a600384208ab74bTimo Sirainen hdr->type & MAIL_TRANSACTION_TYPE_MASK);
5a07b37a9df398b5189c14872a600384208ab74bTimo Sirainen return -1;
5a07b37a9df398b5189c14872a600384208ab74bTimo Sirainen }
5a07b37a9df398b5189c14872a600384208ab74bTimo Sirainen }
5a07b37a9df398b5189c14872a600384208ab74bTimo Sirainen
5a07b37a9df398b5189c14872a600384208ab74bTimo Sirainen if (hdr_size < sizeof(*hdr) + record_size) {
44ff75ca53188056ff5a3e50428e3f2078800b3cTimo Sirainen mail_transaction_log_file_set_corrupted(file,
1225a5a7ce39f1d5545d5ed3b84ecd4f72438d36Timo Sirainen "record size too small (type=0x%x, "
1225a5a7ce39f1d5545d5ed3b84ecd4f72438d36Timo Sirainen "offset=%"PRIuUOFF_T", size=%u)",
1225a5a7ce39f1d5545d5ed3b84ecd4f72438d36Timo Sirainen hdr->type & MAIL_TRANSACTION_TYPE_MASK,
1225a5a7ce39f1d5545d5ed3b84ecd4f72438d36Timo Sirainen view->cur_offset, hdr_size);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen return -1;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen }
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
5a07b37a9df398b5189c14872a600384208ab74bTimo Sirainen if ((hdr_size - sizeof(*hdr)) % record_size != 0) {
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen mail_transaction_log_file_set_corrupted(file,
1225a5a7ce39f1d5545d5ed3b84ecd4f72438d36Timo Sirainen "record size wrong (type 0x%x, "
01ac83a86f9f29741b585205eefeec9c0c546f8bTimo Sirainen "offset=%"PRIuUOFF_T", size=%"PRIuSIZE_T" %% %u != 0)",
5a07b37a9df398b5189c14872a600384208ab74bTimo Sirainen hdr->type & MAIL_TRANSACTION_TYPE_MASK,
1225a5a7ce39f1d5545d5ed3b84ecd4f72438d36Timo Sirainen view->cur_offset, (hdr_size - sizeof(*hdr)),
1225a5a7ce39f1d5545d5ed3b84ecd4f72438d36Timo Sirainen record_size);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen return -1;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen }
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
6eb30032b4a50c383dea4c9c74342d906de6ad36Timo Sirainen if (file_size - view->cur_offset < hdr_size) {
6eb30032b4a50c383dea4c9c74342d906de6ad36Timo Sirainen mail_transaction_log_file_set_corrupted(file,
1225a5a7ce39f1d5545d5ed3b84ecd4f72438d36Timo Sirainen "record size too large (type=0x%x, "
1225a5a7ce39f1d5545d5ed3b84ecd4f72438d36Timo Sirainen "offset=%"PRIuUOFF_T", size=%u, end=%"PRIuSIZE_T")",
6eb30032b4a50c383dea4c9c74342d906de6ad36Timo Sirainen hdr->type & MAIL_TRANSACTION_TYPE_MASK,
6eb30032b4a50c383dea4c9c74342d906de6ad36Timo Sirainen view->cur_offset, hdr_size, file_size);
6eb30032b4a50c383dea4c9c74342d906de6ad36Timo Sirainen return -1;
6eb30032b4a50c383dea4c9c74342d906de6ad36Timo Sirainen }
6eb30032b4a50c383dea4c9c74342d906de6ad36Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen if ((hdr->type & MAIL_TRANSACTION_EXPUNGE) != 0) {
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen if ((hdr->type & MAIL_TRANSACTION_TYPE_MASK) !=
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen (MAIL_TRANSACTION_EXPUNGE|MAIL_TRANSACTION_EXPUNGE_PROT)) {
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen mail_transaction_log_file_set_corrupted(file,
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen "found expunge without protection mask");
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen return -1;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen }
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen } else if ((hdr->type & MAIL_TRANSACTION_TYPE_MASK) != type_rec->type) {
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen mail_transaction_log_file_set_corrupted(file,
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen "extra bits in header type: 0x%x",
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen hdr->type & MAIL_TRANSACTION_TYPE_MASK);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen return -1;
7797aa2479e99aeb71057b7a2584b2cb72e4d3f8Timo Sirainen } else if (hdr->type == MAIL_TRANSACTION_EXT_INTRO) {
bbf796c17f02538058d7559bfe96d677e5b55015Timo Sirainen const struct mail_transaction_ext_intro *intro;
bbf796c17f02538058d7559bfe96d677e5b55015Timo Sirainen uint32_t i;
bbf796c17f02538058d7559bfe96d677e5b55015Timo Sirainen
a9bbb619908c206d9cb319398d4aaad37a22cd67Timo Sirainen for (i = 0; i < hdr_size; ) {
a9bbb619908c206d9cb319398d4aaad37a22cd67Timo Sirainen if (i + sizeof(*intro) > hdr_size) {
bbf796c17f02538058d7559bfe96d677e5b55015Timo Sirainen /* should be just extra padding */
bbf796c17f02538058d7559bfe96d677e5b55015Timo Sirainen break;
bbf796c17f02538058d7559bfe96d677e5b55015Timo Sirainen }
bbf796c17f02538058d7559bfe96d677e5b55015Timo Sirainen
bbf796c17f02538058d7559bfe96d677e5b55015Timo Sirainen intro = CONST_PTR_OFFSET(data, i);
bbf796c17f02538058d7559bfe96d677e5b55015Timo Sirainen if (intro->name_size >
bbf796c17f02538058d7559bfe96d677e5b55015Timo Sirainen hdr_size - sizeof(*hdr) - sizeof(*intro)) {
bbf796c17f02538058d7559bfe96d677e5b55015Timo Sirainen mail_transaction_log_file_set_corrupted(file,
bbf796c17f02538058d7559bfe96d677e5b55015Timo Sirainen "extension intro: name_size too large");
bbf796c17f02538058d7559bfe96d677e5b55015Timo Sirainen return -1;
bbf796c17f02538058d7559bfe96d677e5b55015Timo Sirainen }
bbf796c17f02538058d7559bfe96d677e5b55015Timo Sirainen
bbf796c17f02538058d7559bfe96d677e5b55015Timo Sirainen i += sizeof(*intro) + intro->name_size;
5a07b37a9df398b5189c14872a600384208ab74bTimo Sirainen }
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen }
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen *hdr_r = hdr;
1175f27441385a7011629f295f42708f9a3a4ffcTimo Sirainen *data_r = data;
44ff75ca53188056ff5a3e50428e3f2078800b3cTimo Sirainen view->cur_offset += hdr_size;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen return 1;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen}
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainenint mail_transaction_log_view_next(struct mail_transaction_log_view *view,
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen const struct mail_transaction_header **hdr_r,
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen const void **data_r, int *skipped_r)
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen{
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen const struct mail_transaction_header *hdr;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen const void *data;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen int ret = 0;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen if (skipped_r != NULL)
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen *skipped_r = FALSE;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen if (view->broken)
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen return -1;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
834b90e1f426d1e3308670e09c050bcdea546eb8Timo Sirainen while ((ret = log_view_get_next(view, &hdr, &data)) > 0) {
6e354c4070b611471727692919d29440d73a73f7Timo Sirainen if ((view->type_mask & hdr->type) != 0) {
6e354c4070b611471727692919d29440d73a73f7Timo Sirainen /* looks like this is within our mask, but expunge
6e354c4070b611471727692919d29440d73a73f7Timo Sirainen protection may mess up the check. */
6e354c4070b611471727692919d29440d73a73f7Timo Sirainen if ((hdr->type & MAIL_TRANSACTION_EXPUNGE) == 0 ||
6e354c4070b611471727692919d29440d73a73f7Timo Sirainen (view->type_mask & MAIL_TRANSACTION_EXPUNGE) != 0)
6e354c4070b611471727692919d29440d73a73f7Timo Sirainen break;
6e354c4070b611471727692919d29440d73a73f7Timo Sirainen }
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen /* we don't want this record */
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen if (skipped_r != NULL)
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen *skipped_r = TRUE;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen /* FIXME: hide flag/cache updates for appends if
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen append isn't in mask */
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen }
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
5a07b37a9df398b5189c14872a600384208ab74bTimo Sirainen if (ret < 0) {
5a07b37a9df398b5189c14872a600384208ab74bTimo Sirainen view->cur_offset = view->cur->sync_offset;
5a07b37a9df398b5189c14872a600384208ab74bTimo Sirainen return -1;
5a07b37a9df398b5189c14872a600384208ab74bTimo Sirainen }
5a07b37a9df398b5189c14872a600384208ab74bTimo Sirainen if (ret == 0)
5a07b37a9df398b5189c14872a600384208ab74bTimo Sirainen return 0;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
44ff75ca53188056ff5a3e50428e3f2078800b3cTimo Sirainen view->tmp_hdr = *hdr;
44ff75ca53188056ff5a3e50428e3f2078800b3cTimo Sirainen view->tmp_hdr.size =
44ff75ca53188056ff5a3e50428e3f2078800b3cTimo Sirainen mail_index_offset_to_uint32(view->tmp_hdr.size) - sizeof(*hdr);
44ff75ca53188056ff5a3e50428e3f2078800b3cTimo Sirainen i_assert(view->tmp_hdr.size != 0);
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen if ((hdr->type & MAIL_TRANSACTION_EXPUNGE) != 0) {
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen /* hide expunge protection */
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen view->tmp_hdr.type &= ~MAIL_TRANSACTION_EXPUNGE_PROT;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen }
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen
44ff75ca53188056ff5a3e50428e3f2078800b3cTimo Sirainen *hdr_r = &view->tmp_hdr;
44ff75ca53188056ff5a3e50428e3f2078800b3cTimo Sirainen *data_r = data;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen return 1;
0cb2e8eb55e70f8ebe1e8349bdf49e4cbe5d8834Timo Sirainen}