sdbox-storage.c revision b18b7c9b35a2f66a63c364c11ce4045bec6b8de9
5f5870385cff47efd2f58e7892f251cf13761528Timo Sirainen/* Copyright (c) 2007-2011 Dovecot authors, see the included COPYING file */
4ae81f8f7aad06aad2f570535cad6e40aaec2b28Timo Sirainenextern struct mail_storage dbox_storage, sdbox_storage;
74ab5ea66c0c4b388f1c774ae6a47ab94f1b4f18Timo Sirainenextern struct dbox_storage_vfuncs sdbox_dbox_storage_vfuncs;
74ab5ea66c0c4b388f1c774ae6a47ab94f1b4f18Timo Sirainenstatic struct mail_storage *sdbox_storage_alloc(void)
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen pool = pool_alloconly_create("sdbox storage", 512+256);
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen storage = p_new(pool, struct sdbox_storage, 1);
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen storage->storage.v = sdbox_dbox_storage_vfuncs;
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainenstatic const char *
12055678401e913f4be130fa41b22fbeb626cc7eTimo Sirainensdbox_storage_find_root_dir(const struct mail_namespace *ns)
74ab5ea66c0c4b388f1c774ae6a47ab94f1b4f18Timo Sirainen if (mail_user_get_home(ns->owner, &home) > 0) {
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen i_debug("sdbox: access(%s, rwx): failed: %m", path);
4ae81f8f7aad06aad2f570535cad6e40aaec2b28Timo Sirainenstatic bool sdbox_storage_autodetect(const struct mail_namespace *ns,
4ae81f8f7aad06aad2f570535cad6e40aaec2b28Timo Sirainen /* NOTE: this check works for mdbox as well. we'll rely on the
9261dbf0675204898c6557591c7aa376e23a52b2Timo Sirainen autodetect ordering to catch mdbox before we get here. */
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen path = t_strconcat(root_dir, "/"DBOX_MAILBOX_DIR_NAME, NULL);
4ae81f8f7aad06aad2f570535cad6e40aaec2b28Timo Sirainen i_debug("sdbox autodetect: stat(%s) failed: %m", path);
4ae81f8f7aad06aad2f570535cad6e40aaec2b28Timo Sirainen i_debug("sdbox autodetect: %s not a directory", path);
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainenstatic struct mailbox *
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainensdbox_mailbox_alloc(struct mail_storage *storage, struct mailbox_list *list,
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen /* dbox can't work without index files */
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen pool = pool_alloconly_create("sdbox mailbox", 1024*3);
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen index_storage_mailbox_alloc(&mbox->box, vname,
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen ibox->index_flags |= MAIL_INDEX_OPEN_FLAG_KEEP_BACKUPS |
37cd04fc1d01c4a7140ffcb514e15cee1e97986aTimo Sirainen mbox->storage = (struct sdbox_storage *)storage;
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainenint sdbox_read_header(struct sdbox_mailbox *mbox,
2615df45a8027948a474abe5e817b34b0499c171Timo Sirainen struct sdbox_index_header *hdr, bool log_error)
a64adf62fa33f2463a86f990217b0c9078531a40Timo Sirainen mail_index_get_header_ext(view, mbox->hdr_ext_id,
ebfbf5d78dcf95e8b176429f4b5b0694eb4e17d5Timo Sirainen if (data_size < SDBOX_INDEX_HEADER_MIN_SIZE &&
ca98892a6b8a30ffc1fe26fcf02c7d59e3204e7eTimo Sirainen "sdbox %s: Invalid dbox header size",
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen memcpy(hdr, data, I_MIN(data_size, sizeof(*hdr)));
74ab5ea66c0c4b388f1c774ae6a47ab94f1b4f18Timo Sirainenvoid sdbox_update_header(struct sdbox_mailbox *mbox,
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen if (update != NULL && !guid_128_is_empty(update->mailbox_guid)) {
1b0cfbf3cc77a670b92fff5c30f7b1eb17a63ab1Timo Sirainen memcpy(new_hdr.mailbox_guid, update->mailbox_guid,
e62f6437a4ff01d692a5a61369fe4168d69191edTimo Sirainen } else if (guid_128_is_empty(new_hdr.mailbox_guid)) {
74ab5ea66c0c4b388f1c774ae6a47ab94f1b4f18Timo Sirainen if (memcmp(&hdr, &new_hdr, sizeof(hdr)) != 0) {
1caf757864e7734345660e7d190f84e42668a6f8Timo Sirainen mail_index_update_header_ext(trans, mbox->hdr_ext_id, 0,
1caf757864e7734345660e7d190f84e42668a6f8Timo Sirainen memcpy(mbox->mailbox_guid, new_hdr.mailbox_guid,
1caf757864e7734345660e7d190f84e42668a6f8Timo Sirainenstatic int sdbox_mailbox_create_indexes(struct mailbox *box,
c4b376dd6e0c423006d7ac83a39253bcaf8e7c47Timo Sirainen struct sdbox_mailbox *mbox = (struct sdbox_mailbox *)box;
eef4ba0cc3e78f8c26804c1c9251a76580a41f0cTimo Sirainen struct mail_index_transaction *new_trans = NULL;
fcde781c3ceb470c8dff34a68df19c69f93bcec9Timo Sirainen new_trans = mail_index_transaction_begin(box->view, 0);
1caf757864e7734345660e7d190f84e42668a6f8Timo Sirainen if (update != NULL && update->uid_validity != 0)
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen /* set uidvalidity */
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen uid_validity = dbox_get_uidvalidity_next(box->list);
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen /* UIDVALIDITY change requires index to be reset */
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen offsetof(struct mail_index_header, uid_validity),
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen if (update != NULL && hdr->next_uid < update->min_next_uid) {
1caf757864e7734345660e7d190f84e42668a6f8Timo Sirainen if (update != NULL && update->min_first_recent_uid != 0 &&
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen hdr->first_recent_uid < update->min_first_recent_uid) {
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen uint32_t first_recent_uid = update->min_first_recent_uid;
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen offsetof(struct mail_index_header, first_recent_uid),
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen &first_recent_uid, sizeof(first_recent_uid), FALSE);
74ab5ea66c0c4b388f1c774ae6a47ab94f1b4f18Timo Sirainen if (update != NULL && update->min_highest_modseq != 0 &&
1caf757864e7734345660e7d190f84e42668a6f8Timo Sirainen if (mail_index_transaction_commit(&new_trans) < 0) {
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainenstatic const char *
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainensdbox_get_attachment_path_suffix(struct dbox_file *_file)
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen struct sdbox_file *file = (struct sdbox_file *)_file;
74ab5ea66c0c4b388f1c774ae6a47ab94f1b4f18Timo Sirainenvoid sdbox_set_mailbox_corrupted(struct mailbox *box)
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen struct sdbox_mailbox *mbox = (struct sdbox_mailbox *)box;
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen if (sdbox_read_header(mbox, &hdr, TRUE) < 0 || hdr.rebuild_count == 0)
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen mbox->corrupted_rebuild_count = hdr.rebuild_count;
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainenstatic void sdbox_set_file_corrupted(struct dbox_file *_file)
37cd04fc1d01c4a7140ffcb514e15cee1e97986aTimo Sirainen struct sdbox_file *file = (struct sdbox_file *)_file;
37cd04fc1d01c4a7140ffcb514e15cee1e97986aTimo Sirainen sdbox_set_mailbox_corrupted(&file->mbox->box);
74ab5ea66c0c4b388f1c774ae6a47ab94f1b4f18Timo Sirainenstatic int sdbox_mailbox_open(struct mailbox *box)
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen struct sdbox_mailbox *mbox = (struct sdbox_mailbox *)box;
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen mail_index_ext_register(box->index, "dbox-hdr",
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen sizeof(struct sdbox_index_header), 0, 0);
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen /* wait for mailbox creation to initialize the index */
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen /* wait for mailbox creation to initialize the index */
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen /* get/generate mailbox guid */
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen if (sdbox_read_header(mbox, &hdr, FALSE) < 0) {
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen /* it's possible that this mailbox is just now being created
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen by another process. lock it first and see if the header is
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen available then. */
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen if (mail_index_sync_begin(box->index, &sync_ctx,
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen if (sdbox_read_header(mbox, &hdr, TRUE) < 0) {
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen /* looks like the mailbox is corrupted */
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen (void)sdbox_sync(mbox, SDBOX_SYNC_FLAG_FORCE);
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen /* regenerate it */
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen if (sdbox_mailbox_create_indexes(box, NULL, NULL) < 0 ||
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainenstatic void sdbox_mailbox_close(struct mailbox *box)
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen struct sdbox_mailbox *mbox = (struct sdbox_mailbox *)box;
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainensdbox_mailbox_get_metadata(struct mailbox *box,
e62f6437a4ff01d692a5a61369fe4168d69191edTimo Sirainen struct sdbox_mailbox *mbox = (struct sdbox_mailbox *)box;
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen if (index_mailbox_get_metadata(box, items, metadata_r) < 0)
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainendbox_mailbox_update(struct mailbox *box, const struct mailbox_update *update)
5601c23c0d59376dfda22c7eb807c9e1a0870426Timo Sirainen index_storage_mailbox_update_cache(box, update);
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen return sdbox_mailbox_create_indexes(box, update, NULL);
8d587838c414c48a331f0b54cd7ffd97e5024abdTimo Sirainen .class_flags = MAIL_STORAGE_CLASS_FLAG_FILE_PER_MSG,