raw-storage.c revision 7a7d2aa11e46195e2d92d6c337d7e78052a5ce67
e59faf65ce864fe95dc00f5d52b8323cdbd0608aTimo Sirainen/* Copyright (c) 2007-2010 Dovecot authors, see the included COPYING file */
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen#include "lib.h"
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen#include "ioloop.h"
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen#include "istream.h"
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen#include "index-mail.h"
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen#include "mail-copy.h"
7a7d2aa11e46195e2d92d6c337d7e78052a5ce67Timo Sirainen#include "mailbox-list-private.h"
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen#include "raw-sync.h"
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen#include "raw-storage.h"
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainenextern struct mail_storage raw_storage;
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainenextern struct mailbox raw_mailbox;
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainenstatic struct mail_storage *raw_storage_alloc(void)
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen{
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen struct raw_storage *storage;
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen pool_t pool;
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen pool = pool_alloconly_create("raw storage", 512+256);
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen storage = p_new(pool, struct raw_storage, 1);
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen storage->storage = raw_storage;
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen storage->storage.pool = pool;
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen return &storage->storage;
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen}
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainenstatic void
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainenraw_storage_get_list_settings(const struct mail_namespace *ns ATTR_UNUSED,
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainen struct mailbox_list_settings *set)
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainen{
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainen if (set->layout == NULL)
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainen set->layout = MAILBOX_LIST_NAME_FS;
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainen if (set->subscription_fname == NULL)
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainen set->subscription_fname = RAW_SUBSCRIPTION_FILE_NAME;
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainen}
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainen
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainenstatic struct mailbox *
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainenraw_mailbox_alloc(struct mail_storage *storage, struct mailbox_list *list,
e5fd6dfd0a492e4708d4dbb7971d7fc5d7b8fd85Timo Sirainen const char *name, enum mailbox_flags flags)
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen{
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen struct raw_mailbox *mbox;
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen pool_t pool;
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen flags |= MAILBOX_FLAG_READONLY | MAILBOX_FLAG_NO_INDEX_FILES;
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen
3b32bc12710240f86465a00fbb2bd1ef030e6c40Timo Sirainen pool = pool_alloconly_create("raw mailbox", 1024*3);
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen mbox = p_new(pool, struct raw_mailbox, 1);
d22301419109ed4a38351715e6760011421dadecTimo Sirainen mbox->box = raw_mailbox;
d22301419109ed4a38351715e6760011421dadecTimo Sirainen mbox->box.pool = pool;
d22301419109ed4a38351715e6760011421dadecTimo Sirainen mbox->box.storage = storage;
d22301419109ed4a38351715e6760011421dadecTimo Sirainen mbox->box.list = list;
d22301419109ed4a38351715e6760011421dadecTimo Sirainen mbox->box.mail_vfuncs = &raw_mail_vfuncs;
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen
e5fd6dfd0a492e4708d4dbb7971d7fc5d7b8fd85Timo Sirainen index_storage_mailbox_alloc(&mbox->box, name, flags, NULL);
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen
e5fd6dfd0a492e4708d4dbb7971d7fc5d7b8fd85Timo Sirainen mbox->mtime = mbox->ctime = (time_t)-1;
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainen mbox->storage = (struct raw_storage *)storage;
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen mbox->size = (uoff_t)-1;
d22301419109ed4a38351715e6760011421dadecTimo Sirainen return &mbox->box;
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen}
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainenstatic int raw_mailbox_open(struct mailbox *box)
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen{
e5fd6dfd0a492e4708d4dbb7971d7fc5d7b8fd85Timo Sirainen struct raw_mailbox *mbox = (struct raw_mailbox *)box;
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen int fd;
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen
e5fd6dfd0a492e4708d4dbb7971d7fc5d7b8fd85Timo Sirainen if (box->input != NULL) {
e5fd6dfd0a492e4708d4dbb7971d7fc5d7b8fd85Timo Sirainen mbox->mtime = mbox->ctime = ioloop_time;
d22301419109ed4a38351715e6760011421dadecTimo Sirainen return index_storage_mailbox_open(box, FALSE);
e5fd6dfd0a492e4708d4dbb7971d7fc5d7b8fd85Timo Sirainen }
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen
a09aefe16dc9b4edaaaaabbe37c72c2b7907e613Timo Sirainen box->path = box->name;
e5fd6dfd0a492e4708d4dbb7971d7fc5d7b8fd85Timo Sirainen mbox->have_filename = TRUE;
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen fd = open(box->path, O_RDONLY);
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen if (fd == -1) {
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen if (ENOTFOUND(errno)) {
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen mail_storage_set_error(box->storage,
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen MAIL_ERROR_NOTFOUND,
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen T_MAIL_ERR_MAILBOX_NOT_FOUND(box->name));
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen } else if (!mail_storage_set_error_from_errno(box->storage)) {
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen mail_storage_set_critical(box->storage,
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen "open(%s) failed: %m", box->path);
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen }
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen return -1;
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen }
573f0491a5733fe21fa062a455acb4790b4e0499Timo Sirainen box->input = i_stream_create_fd(fd, MAIL_READ_FULL_BLOCK_SIZE, TRUE);
f0a2d04321ba456e5c5ba821c0d1ed9e8e0e2e08Timo Sirainen i_stream_set_name(box->input, box->path);
573f0491a5733fe21fa062a455acb4790b4e0499Timo Sirainen i_stream_set_init_buffer_size(box->input, MAIL_READ_FULL_BLOCK_SIZE);
d22301419109ed4a38351715e6760011421dadecTimo Sirainen return index_storage_mailbox_open(box, FALSE);
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen}
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainenstatic int
17ad2164c747cedbf81dae1893063e71a3df0356Timo Sirainenraw_mailbox_create(struct mailbox *box,
17ad2164c747cedbf81dae1893063e71a3df0356Timo Sirainen const struct mailbox_update *update ATTR_UNUSED,
17ad2164c747cedbf81dae1893063e71a3df0356Timo Sirainen bool directory ATTR_UNUSED)
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen{
17ad2164c747cedbf81dae1893063e71a3df0356Timo Sirainen mail_storage_set_error(box->storage, MAIL_ERROR_NOTPOSSIBLE,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen "Raw mailbox creation isn't supported");
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen return -1;
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen}
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen
17ad2164c747cedbf81dae1893063e71a3df0356Timo Sirainenstatic int
17ad2164c747cedbf81dae1893063e71a3df0356Timo Sirainenraw_mailbox_update(struct mailbox *box,
17ad2164c747cedbf81dae1893063e71a3df0356Timo Sirainen const struct mailbox_update *update ATTR_UNUSED)
17ad2164c747cedbf81dae1893063e71a3df0356Timo Sirainen{
17ad2164c747cedbf81dae1893063e71a3df0356Timo Sirainen mail_storage_set_error(box->storage, MAIL_ERROR_NOTPOSSIBLE,
17ad2164c747cedbf81dae1893063e71a3df0356Timo Sirainen "Raw mailbox update isn't supported");
17ad2164c747cedbf81dae1893063e71a3df0356Timo Sirainen return -1;
17ad2164c747cedbf81dae1893063e71a3df0356Timo Sirainen}
17ad2164c747cedbf81dae1893063e71a3df0356Timo Sirainen
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainenstatic void raw_notify_changes(struct mailbox *box ATTR_UNUSED)
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen{
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen}
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainenstruct mail_storage raw_storage = {
7bafda1813454621e03615e83d55bccfa7cc56bdTimo Sirainen .name = RAW_STORAGE_NAME,
e5fd6dfd0a492e4708d4dbb7971d7fc5d7b8fd85Timo Sirainen .class_flags = MAIL_STORAGE_CLASS_FLAG_MAILBOX_IS_FILE |
e5fd6dfd0a492e4708d4dbb7971d7fc5d7b8fd85Timo Sirainen MAIL_STORAGE_CLASS_FLAG_OPEN_STREAMS,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen
7bafda1813454621e03615e83d55bccfa7cc56bdTimo Sirainen .v = {
a64adf62fa33f2463a86f990217b0c9078531a40Timo Sirainen NULL,
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainen raw_storage_alloc,
563273bdac80393af63b9520cbf4d24cc0efd028Timo Sirainen NULL,
ac26a4607cb12b156f6a42f1ead2881bedd43d94Timo Sirainen NULL,
dca6d617a23e3f93af3b8df59acb46478179fe55Timo Sirainen NULL,
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainen raw_storage_get_list_settings,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen NULL,
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen raw_mailbox_alloc,
3e564425db51f3921ce4de11859777135fdedd15Timo Sirainen NULL
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen }
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen};
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainenstruct mailbox raw_mailbox = {
7bafda1813454621e03615e83d55bccfa7cc56bdTimo Sirainen .v = {
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen index_storage_is_readonly,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen index_storage_allow_new_keywords,
a2f250a332dfc1e6cd4ffd196c621eb9dbf7b8a1Timo Sirainen index_storage_mailbox_enable,
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen raw_mailbox_open,
1d2b188f0eedc3cab6e27ceac5425a037f38042eTimo Sirainen index_storage_mailbox_close,
438f12d7a776da695019114884b48188d94613efTimo Sirainen index_storage_mailbox_free,
17ad2164c747cedbf81dae1893063e71a3df0356Timo Sirainen raw_mailbox_create,
17ad2164c747cedbf81dae1893063e71a3df0356Timo Sirainen raw_mailbox_update,
61b0637759146621cbb7edcbd0b03a71cfd66dfeTimo Sirainen index_storage_mailbox_delete,
2649b237dd4690575e75a30b2bf3b39ebd37b835Timo Sirainen index_storage_mailbox_rename,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen index_storage_get_status,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen NULL,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen NULL,
fbd918f47f591f8084fd52b207ef29515ddd11b9Timo Sirainen NULL,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen raw_storage_sync_init,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen index_mailbox_sync_next,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen index_mailbox_sync_deinit,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen NULL,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen raw_notify_changes,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen index_transaction_begin,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen index_transaction_commit,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen index_transaction_rollback,
48270badadd82279bfe50ae3d187aea8b0b2b30eTimo Sirainen index_transaction_set_max_modseq,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen index_keywords_create,
14ab4610b6038da6c5d0814fecabc6b74bc81a6bTimo Sirainen index_keywords_create_from_indexes,
84ed9f8f3d0e5ed47607ef417618e49e4f865557Timo Sirainen index_keywords_ref,
84ed9f8f3d0e5ed47607ef417618e49e4f865557Timo Sirainen index_keywords_unref,
e3796bfd2bc0fd5ba664893d346df9334a5b3af0Timo Sirainen index_keyword_is_valid,
5afa8e2edf4f313cd56e5909f92f39c3b5b7b4d3Timo Sirainen index_storage_get_seq_range,
408e5be344c9131fdebe771718a5bf49f88cc51cTimo Sirainen index_storage_get_uid_range,
370b60cfccff7c50586fc30f4f591499a55301a8Timo Sirainen index_storage_get_expunges,
ecdce39e5ef4b62eefa9f5818f17d153fd5d710aTimo Sirainen NULL,
3852872e6954b7132e637294132005e86b8ebd4aTimo Sirainen NULL,
3852872e6954b7132e637294132005e86b8ebd4aTimo Sirainen NULL,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen index_mail_alloc,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen index_header_lookup_init,
de58be41126e5d68008d2ea706d62ccdc1f29337Timo Sirainen index_header_lookup_deinit,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen index_storage_search_init,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen index_storage_search_deinit,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen index_storage_search_next_nonblock,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen index_storage_search_next_update_seq,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen NULL,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen NULL,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen NULL,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen NULL,
e3aeeb634245e80d4f643f8d2eea11d6b72336d8Timo Sirainen NULL,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen mail_storage_copy,
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen index_storage_is_inconsistent
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen }
4146f38412c650f4d0e100cf22d7b32e7d24b2b6Timo Sirainen};