Mercurial > dovecot > core-2.2
view src/plugins/quota/quota-count.c @ 18906:421f595a0e93
quota: Use MAILBOX_METADATA_PHYSICAL_SIZE for recalculating mailbox's size.
author | Timo Sirainen <tss@iki.fi> |
---|---|
date | Sat, 11 Jul 2015 12:14:48 +0300 |
parents | 02088971322e |
children | 7f26cfb08fcd |
line wrap: on
line source
/* Copyright (c) 2006-2015 Dovecot authors, see the included COPYING file */ #include "lib.h" #include "mailbox-list-iter.h" #include "quota-private.h" extern struct quota_backend quota_backend_count; static int quota_count_mailbox(struct quota_root *root, struct mail_namespace *ns, const char *vname, uint64_t *bytes_r, uint64_t *count_r) { struct quota_rule *rule; struct mailbox *box; struct mailbox_metadata metadata; struct mailbox_status status; enum mail_error error; const char *errstr; int ret; rule = quota_root_rule_find(root->set, vname); if (rule != NULL && rule->ignore) { /* mailbox not included in quota */ return 0; } box = mailbox_alloc(ns->list, vname, MAILBOX_FLAG_READONLY); if (mailbox_get_metadata(box, MAILBOX_METADATA_PHYSICAL_SIZE, &metadata) < 0 || mailbox_get_status(box, STATUS_MESSAGES, &status) < 0) { errstr = mailbox_get_last_error(box, &error); if (error == MAIL_ERROR_TEMP) { i_error("quota: Couldn't get physical size of mailbox %s: %s", vname, errstr); ret = -1; } else { /* non-temporary error, e.g. ACLs denied access. */ ret = 0; } } else { ret = 1; *bytes_r = metadata.physical_size; *count_r = status.messages; } mailbox_free(&box); return ret; } static int quota_count_namespace(struct quota_root *root, struct mail_namespace *ns, uint64_t *bytes, uint64_t *count) { struct mailbox_list_iterate_context *ctx; const struct mailbox_info *info; int ret = 0; ctx = mailbox_list_iter_init(ns->list, "*", MAILBOX_LIST_ITER_SKIP_ALIASES | MAILBOX_LIST_ITER_RETURN_NO_FLAGS); while ((info = mailbox_list_iter_next(ctx)) != NULL) { if ((info->flags & (MAILBOX_NONEXISTENT | MAILBOX_NOSELECT)) == 0) { ret = quota_count_mailbox(root, ns, info->vname, bytes, count); if (ret < 0) break; } } if (mailbox_list_iter_deinit(&ctx) < 0) { i_error("quota: Listing namespace '%s' failed: %s", ns->prefix, mailbox_list_get_last_error(ns->list, NULL)); ret = -1; } if (ns->prefix_len > 0 && ret == 0 && (ns->prefix_len != 6 || strncasecmp(ns->prefix, "INBOX", 5) != 0)) { /* if the namespace prefix itself exists, count it also */ const char *name = t_strndup(ns->prefix, ns->prefix_len-1); ret = quota_count_mailbox(root, ns, name, bytes, count); } return ret; } int quota_count(struct quota_root *root, uint64_t *bytes_r, uint64_t *count_r) { struct mail_namespace *const *namespaces; unsigned int i, count; int ret = 0; *bytes_r = *count_r = 0; if (root->recounting) return 0; root->recounting = TRUE; namespaces = array_get(&root->quota->namespaces, &count); for (i = 0; i < count; i++) { if (!quota_root_is_namespace_visible(root, namespaces[i])) continue; ret = quota_count_namespace(root, namespaces[i], bytes_r, count_r); if (ret < 0) break; } root->recounting = FALSE; return ret; }