mbox-transaction.c revision 4dec2a9f173755b475550f4af858bfe073e76518
b5ab29780f74cf88212a547ebbe3b6bc0cb867c5Stephan Bosch/* Copyright (C) 2004 Timo Sirainen */
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi
796beea86bcdc92e4ba2f4865414a951b1717e5cTimo Sirainen#include "lib.h"
796beea86bcdc92e4ba2f4865414a951b1717e5cTimo Sirainen#include "array.h"
796beea86bcdc92e4ba2f4865414a951b1717e5cTimo Sirainen#include "mbox-storage.h"
dfe2b5d36666dfc941821dadf59267d28ff58ff5Aki Tuomi#include "mbox-lock.h"
796beea86bcdc92e4ba2f4865414a951b1717e5cTimo Sirainen#include "mbox-sync-private.h"
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi
d7a2f56cd0e550a92cb160b346f33a84b0daa75eTimo Sirainenstatic void (*next_hook_mail_index_transaction_created)
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi (struct mail_index_transaction *t) = NULL;
796beea86bcdc92e4ba2f4865414a951b1717e5cTimo Sirainen
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvistatic int mbox_transaction_commit(struct mail_index_transaction *t,
796beea86bcdc92e4ba2f4865414a951b1717e5cTimo Sirainen uint32_t *log_file_seq_r,
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi uoff_t *log_file_offset_r)
796beea86bcdc92e4ba2f4865414a951b1717e5cTimo Sirainen{
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi struct mbox_transaction_context *mt = MAIL_STORAGE_CONTEXT(t);
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi struct mbox_mailbox *mbox = (struct mbox_mailbox *)mt->ictx.ibox;
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi unsigned int lock_id = mt->mbox_lock_id;
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi enum mailbox_sync_flags flags = mt->ictx.commit_flags;
d7a2f56cd0e550a92cb160b346f33a84b0daa75eTimo Sirainen bool mbox_modified;
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi bool syncing = t->sync_transaction;
7ebda61d3fd228451530ca8faa33380105230ebeAki Tuomi int ret = 0;
7ebda61d3fd228451530ca8faa33380105230ebeAki Tuomi
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi if (mt->save_ctx != NULL)
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi ret = mbox_transaction_save_commit(mt->save_ctx);
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi mbox_modified = mt->mbox_modified;
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi if (ret < 0)
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi index_transaction_finish_rollback(&mt->ictx);
7ebda61d3fd228451530ca8faa33380105230ebeAki Tuomi else {
7ebda61d3fd228451530ca8faa33380105230ebeAki Tuomi if (index_transaction_finish_commit(&mt->ictx, log_file_seq_r,
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi log_file_offset_r) < 0)
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi ret = -1;
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi }
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi /* transaction is destroyed now. */
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi mt = NULL;
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi if (lock_id != 0 && mbox->mbox_lock_type != F_WRLCK) {
7ebda61d3fd228451530ca8faa33380105230ebeAki Tuomi /* unlock before writing any changes */
7ebda61d3fd228451530ca8faa33380105230ebeAki Tuomi (void)mbox_unlock(mbox, lock_id);
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi lock_id = 0;
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi }
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi if (ret == 0 && !syncing) {
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi enum mbox_sync_flags mbox_sync_flags = MBOX_SYNC_LAST_COMMIT;
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi if ((flags & MAILBOX_SYNC_FLAG_FULL_READ) != 0 &&
7ebda61d3fd228451530ca8faa33380105230ebeAki Tuomi !mbox->mbox_very_dirty_syncs)
7ebda61d3fd228451530ca8faa33380105230ebeAki Tuomi mbox_sync_flags |= MBOX_SYNC_UNDIRTY;
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi if ((flags & MAILBOX_SYNC_FLAG_FULL_WRITE) != 0)
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi mbox_sync_flags |= MBOX_SYNC_REWRITE;
9b5576a265cbadb1f0b3c3d5e40e928e1fed1ec9Timo Sirainen if (mbox_modified) {
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi /* after saving mails we want to update the last-uid */
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi mbox_sync_flags |= MBOX_SYNC_HEADER | MBOX_SYNC_REWRITE;
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi }
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi if (mbox_sync(mbox, mbox_sync_flags) < 0)
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi ret = -1;
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi }
7ebda61d3fd228451530ca8faa33380105230ebeAki Tuomi
7ebda61d3fd228451530ca8faa33380105230ebeAki Tuomi if (lock_id != 0) {
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi if (mbox_unlock(mbox, lock_id) < 0)
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi ret = -1;
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi }
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi return ret;
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi}
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvistatic void mbox_transaction_rollback(struct mail_index_transaction *t)
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi{
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi struct mbox_transaction_context *mt = MAIL_STORAGE_CONTEXT(t);
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi struct mbox_mailbox *mbox = (struct mbox_mailbox *)mt->ictx.ibox;
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi
7ebda61d3fd228451530ca8faa33380105230ebeAki Tuomi if (mt->save_ctx != NULL)
7ebda61d3fd228451530ca8faa33380105230ebeAki Tuomi mbox_transaction_save_rollback(mt->save_ctx);
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi if (mt->mbox_lock_id != 0)
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi (void)mbox_unlock(mbox, mt->mbox_lock_id);
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi index_transaction_finish_rollback(&mt->ictx);
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi}
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvistatic void mbox_transaction_created(struct mail_index_transaction *t)
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi{
7ebda61d3fd228451530ca8faa33380105230ebeAki Tuomi struct mailbox *box = MAIL_STORAGE_CONTEXT(t->view->index);
7ebda61d3fd228451530ca8faa33380105230ebeAki Tuomi
796beea86bcdc92e4ba2f4865414a951b1717e5cTimo Sirainen /* index can be for mailbox list index, in which case box=NULL */
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi if (box != NULL && strcmp(box->storage->name, MBOX_STORAGE_NAME) == 0) {
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi struct mbox_mailbox *mbox = (struct mbox_mailbox *)box;
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi struct mbox_transaction_context *mt;
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi mt = i_new(struct mbox_transaction_context, 1);
796beea86bcdc92e4ba2f4865414a951b1717e5cTimo Sirainen mt->ictx.trans = t;
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi mt->ictx.super = t->v;
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi
796beea86bcdc92e4ba2f4865414a951b1717e5cTimo Sirainen t->v.commit = mbox_transaction_commit;
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi t->v.rollback = mbox_transaction_rollback;
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi MODULE_CONTEXT_SET(t, mail_storage_mail_index_module, mt);
796beea86bcdc92e4ba2f4865414a951b1717e5cTimo Sirainen
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi index_transaction_init(&mt->ictx, &mbox->ibox);
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi }
7ebda61d3fd228451530ca8faa33380105230ebeAki Tuomi
7ebda61d3fd228451530ca8faa33380105230ebeAki Tuomi if (next_hook_mail_index_transaction_created != NULL)
d7a2f56cd0e550a92cb160b346f33a84b0daa75eTimo Sirainen next_hook_mail_index_transaction_created(t);
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi}
b28403dc4da6ee942ff18315596b43d4c4e9b7bdMartti Rannanjärvi
d7a2f56cd0e550a92cb160b346f33a84b0daa75eTimo Sirainenvoid mbox_transaction_class_init(void)
d7a2f56cd0e550a92cb160b346f33a84b0daa75eTimo Sirainen{
d7a2f56cd0e550a92cb160b346f33a84b0daa75eTimo Sirainen next_hook_mail_index_transaction_created =
d7a2f56cd0e550a92cb160b346f33a84b0daa75eTimo Sirainen hook_mail_index_transaction_created;
d7a2f56cd0e550a92cb160b346f33a84b0daa75eTimo Sirainen hook_mail_index_transaction_created = mbox_transaction_created;
d7a2f56cd0e550a92cb160b346f33a84b0daa75eTimo Sirainen}
d7a2f56cd0e550a92cb160b346f33a84b0daa75eTimo Sirainen
d7a2f56cd0e550a92cb160b346f33a84b0daa75eTimo Sirainenvoid mbox_transaction_class_deinit(void)
d7a2f56cd0e550a92cb160b346f33a84b0daa75eTimo Sirainen{
d7a2f56cd0e550a92cb160b346f33a84b0daa75eTimo Sirainen i_assert(hook_mail_index_transaction_created ==
d7a2f56cd0e550a92cb160b346f33a84b0daa75eTimo Sirainen mbox_transaction_created);
d7a2f56cd0e550a92cb160b346f33a84b0daa75eTimo Sirainen hook_mail_index_transaction_created =
d7a2f56cd0e550a92cb160b346f33a84b0daa75eTimo Sirainen next_hook_mail_index_transaction_created;
d7a2f56cd0e550a92cb160b346f33a84b0daa75eTimo Sirainen}
d7a2f56cd0e550a92cb160b346f33a84b0daa75eTimo Sirainen