mail-transaction-log.h revision 94aa90d2d17a7aebcda5a4193a62e80ddbb169b7
3bce8af465e45b9b06f106f6c7f28b2a4b6cca43Timo Sirainen#ifndef MAIL_TRANSACTION_LOG_H
3bce8af465e45b9b06f106f6c7f28b2a4b6cca43Timo Sirainen#define MAIL_TRANSACTION_LOG_H
3bce8af465e45b9b06f106f6c7f28b2a4b6cca43Timo Sirainen
79789a60ce068d7abcb9a91b846334047441295dTimo Sirainen#define MAIL_TRANSACTION_LOG_MAJOR_VERSION 1
95ba9d0ffaa6963b3e3838a353e7bdec45526851Timo Sirainen#define MAIL_TRANSACTION_LOG_MINOR_VERSION 0
935a507ad94d7725eb3f1dae4d1eac23d900e6a9Timo Sirainen#define MAIL_TRANSACTION_LOG_HEADER_MIN_SIZE 24
935a507ad94d7725eb3f1dae4d1eac23d900e6a9Timo Sirainen
9f86dab529923d0b73f8f42be23a01651c5212c3Timo Sirainenstruct mail_transaction_log_header {
935a507ad94d7725eb3f1dae4d1eac23d900e6a9Timo Sirainen uint8_t major_version;
935a507ad94d7725eb3f1dae4d1eac23d900e6a9Timo Sirainen uint8_t minor_version;
95ba9d0ffaa6963b3e3838a353e7bdec45526851Timo Sirainen uint16_t hdr_size;
95ba9d0ffaa6963b3e3838a353e7bdec45526851Timo Sirainen
95ba9d0ffaa6963b3e3838a353e7bdec45526851Timo Sirainen uint32_t indexid;
9f86dab529923d0b73f8f42be23a01651c5212c3Timo Sirainen uint32_t file_seq;
95ba9d0ffaa6963b3e3838a353e7bdec45526851Timo Sirainen uint32_t prev_file_seq;
95ba9d0ffaa6963b3e3838a353e7bdec45526851Timo Sirainen uint32_t prev_file_offset;
35efafe673ad2917b234bc8747707093cb2f0746Timo Sirainen uint32_t create_stamp;
935a507ad94d7725eb3f1dae4d1eac23d900e6a9Timo Sirainen};
935a507ad94d7725eb3f1dae4d1eac23d900e6a9Timo Sirainen
a8bfc59dc5f87930d419ef5479368cc84e42fceeTimo Sirainenenum mail_transaction_type {
935a507ad94d7725eb3f1dae4d1eac23d900e6a9Timo Sirainen MAIL_TRANSACTION_EXPUNGE = 0x00000001,
3210ef33348492656c4eec6c3ee72dea4c7302c1Timo Sirainen MAIL_TRANSACTION_APPEND = 0x00000002,
935a507ad94d7725eb3f1dae4d1eac23d900e6a9Timo Sirainen MAIL_TRANSACTION_FLAG_UPDATE = 0x00000004,
650f4afac9bd8cfa889cbb62e39b7490f5a628fbTimo Sirainen MAIL_TRANSACTION_HEADER_UPDATE = 0x00000020,
650f4afac9bd8cfa889cbb62e39b7490f5a628fbTimo Sirainen MAIL_TRANSACTION_EXT_INTRO = 0x00000040,
650f4afac9bd8cfa889cbb62e39b7490f5a628fbTimo Sirainen MAIL_TRANSACTION_EXT_RESET = 0x00000080,
650f4afac9bd8cfa889cbb62e39b7490f5a628fbTimo Sirainen MAIL_TRANSACTION_EXT_HDR_UPDATE = 0x00000100,
650f4afac9bd8cfa889cbb62e39b7490f5a628fbTimo Sirainen MAIL_TRANSACTION_EXT_REC_UPDATE = 0x00000200,
MAIL_TRANSACTION_KEYWORD_UPDATE = 0x00000400,
MAIL_TRANSACTION_KEYWORD_RESET = 0x00000800,
MAIL_TRANSACTION_TYPE_MASK = 0x0000ffff,
#define MAIL_TRANSACTION_EXT_MASK \
(MAIL_TRANSACTION_EXT_INTRO | MAIL_TRANSACTION_EXT_RESET | \
MAIL_TRANSACTION_EXT_HDR_UPDATE | MAIL_TRANSACTION_EXT_REC_UPDATE)
/* since we'll expunge mails based on data read from transaction log,
try to avoid the possibility of corrupted transaction log expunging
messages. this value is ORed to the actual MAIL_TRANSACTION_EXPUNGE
flag. if it's not present, assume corrupted log. */
MAIL_TRANSACTION_EXPUNGE_PROT = 0x0000cd90,
/* Mailbox synchronization noticed this change. */
MAIL_TRANSACTION_EXTERNAL = 0x10000000
};
struct mail_transaction_header {
uint32_t size;
uint32_t type; /* enum mail_transaction_type */
};
struct mail_transaction_expunge {
uint32_t uid1, uid2;
};
struct mail_transaction_flag_update {
uint32_t uid1, uid2;
uint8_t add_flags;
uint8_t remove_flags;
uint16_t padding;
};
struct mail_transaction_keyword_update {
uint8_t modify_type; /* enum modify_type : MODIFY_ADD / MODIFY_REMOVE */
uint8_t padding;
uint16_t name_size;
/* unsigned char name[];
array of { uint32_t uid1, uid2; }
*/
};
struct mail_transaction_keyword_reset {
uint32_t uid1, uid2;
};
struct mail_transaction_header_update {
uint16_t offset;
uint16_t size;
/* unsigned char data[]; */
};
struct mail_transaction_ext_intro {
/* old extension: set ext_id. don't set name.
new extension: ext_id = (uint32_t)-1. give name. */
uint32_t ext_id;
uint32_t reset_id;
uint32_t hdr_size;
uint16_t record_size;
uint16_t record_align;
uint16_t unused_padding;
uint16_t name_size;
/* unsigned char name[]; */
};
struct mail_transaction_ext_reset {
uint32_t new_reset_id;
uint8_t preserve_data;
uint8_t unused_padding[3];
};
/* these are set for the last ext_intro */
struct mail_transaction_ext_hdr_update {
uint16_t offset;
uint16_t size;
/* unsigned char data[]; */
};
struct mail_transaction_ext_rec_update {
uint32_t uid;
/* unsigned char data[]; */
};
#define LOG_IS_BEFORE(seq1, offset1, seq2, offset2) \
(((offset1) < (offset2) && (seq1) == (seq2)) || (seq1) < (seq2))
struct mail_transaction_log *
mail_transaction_log_alloc(struct mail_index *index);
void mail_transaction_log_free(struct mail_transaction_log **log);
/* Open the transaction log. Returns 1 if ok, 0 if file doesn't exist or it's
is corrupted, -1 if there was some I/O error. */
int mail_transaction_log_open(struct mail_transaction_log *log);
/* Create, or recreate, the transaction log. Returns 0 if ok, -1 if error. */
int mail_transaction_log_create(struct mail_transaction_log *log, bool reset);
/* Close all the open transactions log files. */
void mail_transaction_log_close(struct mail_transaction_log *log);
/* Notify of indexid change */
void mail_transaction_log_indexid_changed(struct mail_transaction_log *log);
/* Returns the file seq/offset where the mailbox is currently synced at.
Since the log is rotated only when mailbox is fully synced, the sequence
points always to the latest file. This function doesn't actually find the
latest sync position, so you'll need to use eg. log_view_set() before
calling this. */
void mail_transaction_log_get_mailbox_sync_pos(struct mail_transaction_log *log,
uint32_t *file_seq_r,
uoff_t *file_offset_r);
/* Set the current mailbox sync position. file_seq must always be the latest
log file's sequence. The offset written automatically to the log when
other transactions are being written. */
void mail_transaction_log_set_mailbox_sync_pos(struct mail_transaction_log *log,
uint32_t file_seq,
uoff_t file_offset);
struct mail_transaction_log_view *
mail_transaction_log_view_open(struct mail_transaction_log *log);
void mail_transaction_log_view_close(struct mail_transaction_log_view **view);
/* Set view boundaries. Returns -1 if error, 0 if files are lost, 1 if ok.
reset_r=TRUE if the whole index should be reset before applying any
changes. */
int mail_transaction_log_view_set(struct mail_transaction_log_view *view,
uint32_t min_file_seq, uoff_t min_file_offset,
uint32_t max_file_seq, uoff_t max_file_offset,
bool *reset_r);
/* Clear the view. Keep oldest_file_seq log referenced so we don't get
desynced. */
void mail_transaction_log_view_clear(struct mail_transaction_log_view *view,
uint32_t oldest_file_seq);
/* Read next transaction record from current position. The position is updated.
Returns -1 if error, 0 if we're at end of the view, 1 if ok. */
int mail_transaction_log_view_next(struct mail_transaction_log_view *view,
const struct mail_transaction_header **hdr_r,
const void **data_r);
/* Seek to given position within view. Must be inside the view's range. */
void mail_transaction_log_view_seek(struct mail_transaction_log_view *view,
uint32_t seq, uoff_t offset);
/* Returns the position of the record returned previously with
mail_transaction_log_view_next() */
void
mail_transaction_log_view_get_prev_pos(struct mail_transaction_log_view *view,
uint32_t *file_seq_r,
uoff_t *file_offset_r);
/* Returns TRUE if we're at the end of the view window. */
bool mail_transaction_log_view_is_last(struct mail_transaction_log_view *view);
/* Marks the log file in current position to be corrupted. */
void
mail_transaction_log_view_set_corrupted(struct mail_transaction_log_view *view,
const char *fmt, ...)
ATTR_FORMAT(2, 3);
bool
mail_transaction_log_view_is_corrupted(struct mail_transaction_log_view *view);
void mail_transaction_log_views_close(struct mail_transaction_log *log);
/* Write data to transaction log. This is atomic operation. Sequences in
updates[] and expunges[] are relative to given view, they're modified
to real ones. If nothing is written, log_file_seq_r and log_file_offset_r
will be set to 0. */
int mail_transaction_log_append(struct mail_index_transaction *t,
uint32_t *log_file_seq_r,
uoff_t *log_file_offset_r);
/* Lock transaction log for index synchronization. Log cannot be read or
written to while it's locked. Returns end offset. */
int mail_transaction_log_sync_lock(struct mail_transaction_log *log,
uint32_t *file_seq_r, uoff_t *file_offset_r);
void mail_transaction_log_sync_unlock(struct mail_transaction_log *log);
/* Returns the current head. Works only when log is locked. */
void mail_transaction_log_get_head(struct mail_transaction_log *log,
uint32_t *file_seq_r, uoff_t *file_offset_r);
/* Returns TRUE if given seq/offset is current head log's rotate point. */
bool mail_transaction_log_is_head_prev(struct mail_transaction_log *log,
uint32_t file_seq, uoff_t file_offset);
/* Move currently opened log head file to memory (called by
mail_index_move_to_memory()) */
void mail_transaction_log_move_to_memory(struct mail_transaction_log *log);
#endif