mbox-sync-private.h revision 32d9a75612a5df455e4169b56538bb31dfe359e4
c25356d5978632df6203437e1953bcb29e0c736fTimo Sirainen#ifndef MBOX_SYNC_PRIVATE_H
c25356d5978632df6203437e1953bcb29e0c736fTimo Sirainen#define MBOX_SYNC_PRIVATE_H
4a6f9ed8e5412508dcba1eabb58a3680ad5e9b68Timo Sirainen
839c67ba93b58e394daa435f7b99587eec97cefbTimo Sirainen#include "md5.h"
4a6f9ed8e5412508dcba1eabb58a3680ad5e9b68Timo Sirainen#include "mail-index.h"
839c67ba93b58e394daa435f7b99587eec97cefbTimo Sirainen
4a6f9ed8e5412508dcba1eabb58a3680ad5e9b68Timo Sirainen#include <sys/stat.h>
4a6f9ed8e5412508dcba1eabb58a3680ad5e9b68Timo Sirainen
4a6f9ed8e5412508dcba1eabb58a3680ad5e9b68Timo Sirainenenum mbox_sync_flags {
c0435c854a0e7246373b9752d163095cc4fbe985Timo Sirainen MBOX_SYNC_LAST_COMMIT = 0x01,
4a6f9ed8e5412508dcba1eabb58a3680ad5e9b68Timo Sirainen MBOX_SYNC_HEADER = 0x02,
4a6f9ed8e5412508dcba1eabb58a3680ad5e9b68Timo Sirainen MBOX_SYNC_LOCK_READING = 0x04,
4d3e576109a91270c04821f8d727cd1afec8c801Timo Sirainen MBOX_SYNC_UNDIRTY = 0x08,
4a6f9ed8e5412508dcba1eabb58a3680ad5e9b68Timo Sirainen MBOX_SYNC_REWRITE = 0x10,
047ebb958b682bc058097eddc34df574c3f3d6d4Timo Sirainen MBOX_SYNC_FORCE_SYNC = 0x20
146e7e3fabdd843d50680cdb6e4f7829890f5fcfTimo Sirainen};
146e7e3fabdd843d50680cdb6e4f7829890f5fcfTimo Sirainen
146e7e3fabdd843d50680cdb6e4f7829890f5fcfTimo Sirainenstruct mbox_flag_type {
047ebb958b682bc058097eddc34df574c3f3d6d4Timo Sirainen char chr;
03b33ccb012636e453189ceef3865dee7812392eTimo Sirainen enum mail_flags flag;
146e7e3fabdd843d50680cdb6e4f7829890f5fcfTimo Sirainen};
4a6f9ed8e5412508dcba1eabb58a3680ad5e9b68Timo Sirainen
enum header_position {
MBOX_HDR_STATUS,
MBOX_HDR_X_IMAPBASE,
MBOX_HDR_X_KEYWORDS,
MBOX_HDR_X_STATUS,
MBOX_HDR_X_UID,
MBOX_HDR_COUNT
};
/* kludgy. swap MAIL_RECENT with MBOX_NONRECENT_KLUDGE when writing Status
header, because 'O' flag means non-recent but internally we want to use
recent flag. */
#define MBOX_NONRECENT_KLUDGE MAIL_RECENT
#define STATUS_FLAGS_MASK (MAIL_SEEN|MBOX_NONRECENT_KLUDGE)
#define XSTATUS_FLAGS_MASK (MAIL_ANSWERED|MAIL_FLAGGED|MAIL_DRAFT|MAIL_DELETED)
extern struct mbox_flag_type mbox_status_flags[];
extern struct mbox_flag_type mbox_xstatus_flags[];
struct mbox_sync_mail {
/* uid=0 can mean that this mail describes an expunged area or that
this is a pseudo message */
uint32_t uid;
uint32_t idx_seq;
ARRAY_TYPE(keyword_indexes) keywords;
uint8_t flags;
unsigned int uid_broken:1;
unsigned int expunged:1;
unsigned int pseudo:1;
uoff_t from_offset;
uoff_t body_size;
/* following variables have a bit overloaded functionality:
a) space <= 0 : offset points to beginning of headers. space is the
amount of space missing that is required to be able to rewrite
the headers
b) space > 0 : offset points to beginning of whitespace that can
be removed. space is the amount of data that can be removed from
there. note that the message may contain more whitespace
elsewhere. */
uoff_t offset;
off_t space;
};
struct mbox_sync_mail_context {
struct mbox_sync_context *sync_ctx;
struct mbox_sync_mail mail;
uint32_t seq;
uoff_t hdr_offset, body_offset;
size_t header_first_change, header_last_change;
string_t *header;
unsigned char hdr_md5_sum[16];
uoff_t content_length;
size_t hdr_pos[MBOX_HDR_COUNT];
uint32_t parsed_uid, last_uid_updated_value;
unsigned int last_uid_value_start_pos;
unsigned int have_eoh:1;
unsigned int need_rewrite:1;
unsigned int seen_imapbase:1;
unsigned int updated:1;
unsigned int recent:1;
unsigned int dirty:1;
unsigned int imapbase_rewrite:1;
unsigned int imapbase_updated:1;
};
struct mbox_sync_context {
struct mbox_mailbox *mbox;
enum mbox_sync_flags flags;
struct istream *input, *file_input;
int write_fd;
time_t orig_mtime, orig_atime;
uoff_t orig_size;
struct stat last_stat;
struct mail_index_sync_ctx *index_sync_ctx;
struct mail_index_view *sync_view;
struct mail_index_transaction *t;
struct mail_index_header reset_hdr;
const struct mail_index_header *hdr;
string_t *header, *from_line;
/* header state: */
uint32_t base_uid_validity, base_uid_last;
uoff_t base_uid_last_offset;
/* mail state: */
ARRAY_DEFINE(mails, struct mbox_sync_mail);
struct index_sync_changes_context *sync_changes;
/* per-mail pool */
pool_t mail_keyword_pool;
/* used for mails[].keywords */
pool_t saved_keywords_pool;
uint32_t prev_msg_uid, next_uid, idx_next_uid;
uint32_t seq, idx_seq, need_space_seq;
uint32_t last_nonrecent_uid;
off_t expunged_space, space_diff;
unsigned int dest_first_mail:1;
unsigned int first_mail_crlf_expunged:1;
/* global flags: */
unsigned int delay_writes:1;
unsigned int renumber_uids:1;
unsigned int moved_offsets:1;
unsigned int ext_modified:1;
unsigned int index_reset:1;
};
int mbox_sync(struct mbox_mailbox *mbox, enum mbox_sync_flags flags);
int mbox_sync_has_changed(struct mbox_mailbox *mbox, bool leave_dirty);
int mbox_sync_has_changed_full(struct mbox_mailbox *mbox, bool leave_dirty,
bool *empty_r);
void mbox_sync_set_critical(struct mbox_sync_context *sync_ctx,
const char *fmt, ...) ATTR_FORMAT(2, 3);
void mbox_sync_parse_next_mail(struct istream *input,
struct mbox_sync_mail_context *ctx);
bool mbox_sync_parse_match_mail(struct mbox_mailbox *mbox,
struct mail_index_view *view, uint32_t seq);
void mbox_sync_update_header(struct mbox_sync_mail_context *ctx);
void mbox_sync_update_header_from(struct mbox_sync_mail_context *ctx,
const struct mbox_sync_mail *mail);
int mbox_sync_try_rewrite(struct mbox_sync_mail_context *ctx, off_t move_diff);
int mbox_sync_rewrite(struct mbox_sync_context *sync_ctx,
struct mbox_sync_mail_context *mail_ctx,
uoff_t end_offset, off_t move_diff, uoff_t extra_space,
uint32_t first_seq, uint32_t last_seq);
int mbox_sync_seek(struct mbox_sync_context *sync_ctx, uoff_t from_offset);
void mbox_sync_file_update_ext_modified(struct mbox_sync_context *sync_ctx);
void mbox_sync_file_updated(struct mbox_sync_context *sync_ctx, bool dirty);
int mbox_move(struct mbox_sync_context *sync_ctx,
uoff_t dest, uoff_t source, uoff_t size);
void mbox_sync_move_buffer(struct mbox_sync_mail_context *ctx,
size_t pos, size_t need, size_t have);
void mbox_sync_headers_add_space(struct mbox_sync_mail_context *ctx,
size_t size);
#endif