maildir-keywords.c revision 79fcd3f95a6266cc62ceaa753e56dd4456ab7c4b
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen/* Copyright (C) 2005 Timo Sirainen */
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen/* note that everything here depends on uidlist file being locked the whole
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen time. that's why we don't have any locking of our own, or that we do things
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen that would be racy otherwise. */
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen const array_t *ARRAY_DEFINE_PTR(keywords, const char *);
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen unsigned int chridx_to_idx[MAILDIR_MAX_KEYWORDS];
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainenstruct maildir_keywords *maildir_keywords_init(struct maildir_mailbox *mbox)
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen mk->pool = pool_alloconly_create("maildir keywords", 256);
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen mk->hash = hash_create(default_pool, mk->pool, 0,
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen strcase_hash, (hash_cmp_callback_t *)strcasecmp);
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainenvoid maildir_keywords_deinit(struct maildir_keywords *mk)
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainenstatic void maildir_keywords_clear(struct maildir_keywords *mk)
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainenstatic int maildir_keywords_sync(struct maildir_keywords *mk)
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen const char **strp;
1e47cfede3a0b62654105daab00e97b5d660bc6bTimo Sirainen /* Remember that we rely on uidlist file locking in here. That's why
1e47cfede3a0b62654105daab00e97b5d660bc6bTimo Sirainen we rely on stat()'s timestamp and don't bother handling ESTALE
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen mail_storage_set_critical(STORAGE(mk->mbox->storage),
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen /* hasn't changed */
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen mail_storage_set_critical(STORAGE(mk->mbox->storage),
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen input = i_stream_create_file(fd, default_pool, 1024, FALSE);
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen while ((line = i_stream_read_next_line(input)) != NULL) {
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen /* note that when converting .customflags file this
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen case happens in the first line. */
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen /* shouldn't happen */
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen /* save it */
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen hash_insert(mk->hash, new_name, POINTER_CAST(idx + 1));
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen mail_storage_set_critical(STORAGE(mk->mbox->storage),
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainenmaildir_keywords_lookup(struct maildir_keywords *mk, const char *name)
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen i_assert(maildir_uidlist_is_locked(mk->mbox->uidlist));
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainenmaildir_keywords_create(struct maildir_keywords *mk, const char *name,
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen unsigned int chridx)
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen const char **strp;
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen hash_insert(mk->hash, new_name, POINTER_CAST(chridx + 1));
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen strp = array_idx_modifyable(&mk->list, chridx);
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainenmaildir_keywords_lookup_or_create(struct maildir_keywords *mk, const char *name)
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen const char *const *keywords;
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen unsigned int i, count;
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen /* see if we are full */
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen for (i = 0; i < count; i++) {
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen if (i == count && count >= MAILDIR_MAX_KEYWORDS)
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainenstatic const char *
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainenmaildir_keywords_idx(struct maildir_keywords *mk, unsigned int idx)
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen const char *const *keywords;
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen unsigned int count;
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen i_assert(maildir_uidlist_is_locked(mk->mbox->uidlist));
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainenstatic int maildir_keywords_commit(struct maildir_keywords *mk)
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen unsigned int i, count;
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen /* we could just create the temp file directly, but doing it this
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen ways avoids potential problems with overwriting contents in
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen malicious symlinks */
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen lock_path = t_strconcat(mk->path, ".lock", NULL);
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen fd = file_dotlock_open(&mk->dotlock_settings, mk->path,
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen mail_storage_set_critical(STORAGE(mk->mbox->storage),
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen "file_dotlock_open(%s) failed: %m", mk->path);
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen for (i = 0; i < count; i++) {
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen if (write_full(fd, str_data(str), str_len(str)) < 0) {
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen mail_storage_set_critical(STORAGE(mk->mbox->storage),
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen /* mtime must grow every time */
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen mk->synced_mtime = ioloop_time <= mk->synced_mtime ?
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen mail_storage_set_critical(STORAGE(mk->mbox->storage),
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen mail_storage_set_critical(STORAGE(mk->mbox->storage),
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen "file_dotlock_replace(%s) failed: %m", mk->path);
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainenmaildir_keywords_sync_init(struct maildir_keywords *mk,
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen ctx = i_new(struct maildir_keywords_sync_ctx, 1);
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen ctx->keywords = mail_index_get_keywords(index);
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainenvoid maildir_keywords_sync_deinit(struct maildir_keywords_sync_ctx *ctx)
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainenunsigned int maildir_keywords_char_idx(struct maildir_keywords_sync_ctx *ctx,
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen /* lookup / create */
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen /* name is lost. just generate one ourself. */
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen while (maildir_keywords_lookup(ctx->mk, name) >= 0) {
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen /* don't create a duplicate name.
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen keep changing the name until it doesn't exist */
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen maildir_keywords_create(ctx->mk, name, chridx);
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen if (!mail_index_keyword_lookup(ctx->index, name, TRUE, &idx))
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainenchar maildir_keywords_idx_char(struct maildir_keywords_sync_ctx *ctx,
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen unsigned int idx)
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen const char *const *name_p;
cce169a321c9c629e4f2db1a69dae3b75bbcb27aTimo Sirainen chr_p = array_idx_modifyable(&ctx->idx_to_chr, idx);