return ret;
while (doveadm_mail_iter_next(iter, &mail)) {
- if (doveadm_debug) {
- i_debug("altmove: box=%s uid=%u",
- info->vname, mail->uid);
- }
+ e_debug(mail_event(mail), "altmove");
mail_update_flags(mail, modify_type,
(enum mail_flags)MAIL_INDEX_MAIL_FLAG_BACKEND);
}
struct mail_storage *storage)
{
if (mail_storage_purge(storage) < 0) {
- i_error("Purging namespace '%s' failed: %s", ns->prefix,
+ e_error(ns->user->event,
+ "Purging namespace '%s' failed: %s", ns->prefix,
mail_storage_get_last_internal_error(storage, NULL));
doveadm_mail_failed_storage(ctx, storage);
return -1;
else
ret2 = mailbox_copy(&save_ctx, mail);
if (ret2 < 0) {
- i_error("%s message UID %u from '%s' failed: %s",
+ e_error(ctx->ctx.cctx->event,
+ "%s message UID %u from '%s' failed: %s",
ctx->move ? "Moving" : "Copying",
mail->uid, info->vname,
mailbox_get_last_internal_error(destbox, NULL));
}
if (mailbox_transaction_commit(&desttrans) < 0) {
- i_error("Committing %s mails failed: %s",
+ e_error(ctx->ctx.cctx->event, "Committing %s mails failed: %s",
ctx->move ? "moved" : "copied",
mailbox_get_last_internal_error(destbox, NULL));
doveadm_mail_failed_mailbox(&ctx->ctx, destbox);
ns = mail_namespace_find(user->namespaces, ctx->destname);
destbox = mailbox_alloc(ns->list, ctx->destname, MAILBOX_FLAG_SAVEONLY);
if (mailbox_open(destbox) < 0) {
- i_error("Can't open mailbox '%s': %s", ctx->destname,
+ e_error(ctx->ctx.cctx->event,
+ "Can't open mailbox '%s': %s", ctx->destname,
mailbox_get_last_internal_error(destbox, NULL));
doveadm_mail_failed_mailbox(&ctx->ctx, destbox);
mailbox_free(&destbox);
ret = -1;
if (mailbox_sync(destbox, 0) < 0) {
- i_error("Syncing mailbox '%s' failed: %s", ctx->destname,
+ e_error(ctx->ctx.cctx->event,
+ "Syncing mailbox '%s' failed: %s", ctx->destname,
mailbox_get_last_internal_error(destbox, NULL));
doveadm_mail_failed_mailbox(&ctx->ctx, destbox);
ret = -1;
errstr = mailbox_get_last_internal_error(mail->box, &error);
if (error == MAIL_ERROR_NOTFOUND)
continue;
- i_error("Couldn't lookup Message-ID: for UID=%u: %s",
+ e_error(ctx->ctx.cctx->event,
+ "Couldn't lookup Message-ID: for UID=%u: %s",
mail->uid, errstr);
doveadm_mail_failed_error(_ctx, error);
ret = -1;
errstr = mailbox_get_last_internal_error(mail->box, &error);
if (error == MAIL_ERROR_NOTFOUND)
continue;
- i_error("Couldn't lookup GUID: for UID=%u: %s",
+ e_error(ctx->ctx.cctx->event,
+ "Couldn't lookup GUID: for UID=%u: %s",
mail->uid, errstr);
doveadm_mail_failed_error(_ctx, error);
ret = -1;
ret = 0;
while (doveadm_mail_iter_next(iter, &mail)) {
- if (doveadm_debug) {
- i_debug("expunge: box=%s uid=%u",
- info->vname, mail->uid);
- }
+ e_debug(mail_event(mail), "expunge");
mail_expunge(mail);
}
if (doveadm_mail_iter_deinit_keep_box(&iter, &box) < 0)
ret = -1;
else if (mailbox_sync(box, 0) < 0) {
- i_error("Syncing mailbox '%s' failed: %s",
+ e_debug(ctx->ctx.cctx->event,
+ "Syncing mailbox '%s' failed: %s",
mailbox_get_vname(box),
mailbox_get_last_internal_error(box, NULL));
doveadm_mail_failed_mailbox(_ctx, box);
if (mailbox_delete_empty(box) < 0) {
error = mailbox_get_last_mail_error(box);
if (error != MAIL_ERROR_EXISTS) {
- i_error("Deleting mailbox '%s' failed: %s",
+ e_debug(ctx->ctx.cctx->event,
+ "Deleting mailbox '%s' failed: %s",
mailbox_get_vname(box),
mailbox_get_last_internal_error(box, NULL));
doveadm_mail_failed_mailbox(_ctx, box);
}
} else {
if (mailbox_set_subscribed(box, FALSE) < 0) {
- i_error("Unsubscribing mailbox '%s' failed: %s",
+ e_debug(ctx->ctx.cctx->event,
+ "Unsubscribing mailbox '%s' failed: %s",
mailbox_get_vname(box),
mailbox_get_last_internal_error(box, NULL));
doveadm_mail_failed_mailbox(_ctx, box);
doveadm_print_stream("", 0);
if (input->stream_errno != 0) {
- i_error("read(%s) failed: %s", i_stream_get_name(input),
+ e_error(ctx->ctx.cctx->event,
+ "read(%s) failed: %s", i_stream_get_name(input),
i_stream_get_error(input));
return -1;
}
array_foreach(&ctx->fields, field) {
ctx->cur_field = field;
if (field->print(ctx) < 0) {
- i_error("fetch(%s) failed for box=%s uid=%u: %s",
+ e_error(ctx->ctx.cctx->event,
+ "fetch(%s) failed for box=%s uid=%u: %s",
field->name, mailbox_get_vname(mail->box),
mail->uid,
ctx->print_error != NULL ? ctx->print_error :
if (ctx->keywords != NULL) {
if (mailbox_keywords_create(box, ctx->keywords, &kw) < 0) {
- i_error("Invalid keywords: %s",
+ e_error(ctx->ctx.cctx->event, "Invalid keywords: %s",
mailbox_get_last_internal_error(box, NULL));
(void)doveadm_mail_iter_deinit(&iter);
ctx->ctx.exit_code = DOVEADM_EX_NOTPOSSIBLE;
if (mailbox_create(box, NULL, FALSE) < 0) {
errstr = mailbox_get_last_internal_error(box, &error);
if (error != MAIL_ERROR_EXISTS) {
- i_error("Couldn't create mailbox %s: %s", name, errstr);
+ e_error(user->event,
+ "Couldn't create mailbox %s: %s", name, errstr);
doveadm_mail_failed_mailbox(&ctx->ctx, box);
mailbox_free(&box);
return -1;
}
if (ctx->subscribe) {
if (mailbox_set_subscribed(box, TRUE) < 0) {
- i_error("Couldn't subscribe to mailbox %s: %s",
+ e_error(user->event,
+ "Couldn't subscribe to mailbox %s: %s",
name, mailbox_get_last_internal_error(box, NULL));
}
}
if (mailbox_sync(box, MAILBOX_SYNC_FLAG_FULL_READ) < 0) {
- i_error("Syncing mailbox %s failed: %s", name,
+ e_error(user->event,
+ "Syncing mailbox %s failed: %s", name,
mailbox_get_last_internal_error(box, NULL));
doveadm_mail_failed_mailbox(&ctx->ctx, box);
mailbox_free(&box);
{
struct mail_save_context *save_ctx;
struct mailbox_transaction_context *dest_trans;
- const char *mailbox = mailbox_get_vname(dest_box);
int ret = 0;
dest_trans = mailbox_transaction_begin(dest_box,
MAILBOX_TRANSACTION_FLAG_EXTERNAL |
ctx->transaction_flags, __func__);
do {
- if (doveadm_debug) {
- i_debug("import: box=%s uid=%u",
- mailbox, src_mail->uid);
- }
+ e_debug(mail_event(src_mail), "import");
save_ctx = mailbox_save_alloc(dest_trans);
mailbox_save_copy_flags(save_ctx, src_mail);
if (mailbox_copy(&save_ctx, src_mail) < 0) {
- i_error("Copying box=%s uid=%u failed: %s",
- mailbox, src_mail->uid,
+ e_error(mail_event(src_mail),
+ "Copying failed: %s",
mailbox_get_last_internal_error(dest_box, NULL));
ret = -1;
}
} while (doveadm_mail_iter_next(iter, &src_mail));
if (mailbox_transaction_commit(&dest_trans) < 0) {
- i_error("Committing copied mails to %s failed: %s", mailbox,
+ e_error(ctx->cctx->event,
+ "Committing copied mails failed: %s",
mailbox_get_last_internal_error(dest_box, NULL));
ret = -1;
}
static int cmd_index_box_precache(struct doveadm_mail_cmd_context *dctx,
struct mailbox *box)
{
+ struct event *event = dctx->cctx->event;
struct mailbox_status status;
struct mailbox_transaction_context *trans;
struct mail_search_args *search_args;
if (mailbox_get_metadata(box, MAILBOX_METADATA_PRECACHE_FIELDS,
&metadata) < 0) {
- i_error("Mailbox %s: Precache-fields lookup failed: %s",
+ e_error(event, "Mailbox %s: Precache-fields lookup failed: %s",
mailbox_get_vname(box),
mailbox_get_last_internal_error(box, NULL));
}
if (mailbox_get_status(box, STATUS_MESSAGES | STATUS_LAST_CACHED_SEQ,
&status) < 0) {
- i_error("Mailbox %s: Status lookup failed: %s",
+ e_error(event, "Mailbox %s: Status lookup failed: %s",
mailbox_get_vname(box),
mailbox_get_last_internal_error(box, NULL));
return -1;
seq = status.last_cached_seq + 1;
if (seq > status.messages) {
if (doveadm_verbose) {
- i_info("%s: Cache is already up to date",
+ e_info(event, "%s: Cache is already up to date",
mailbox_get_vname(box));
}
return 0;
}
if (doveadm_verbose) {
- i_info("%s: Caching mails seq=%u..%u",
+ e_info(event, "%s: Caching mails seq=%u..%u",
mailbox_get_vname(box), seq, status.messages);
}
max = status.messages - seq + 1;
while (mailbox_search_next(ctx, &mail)) {
if (mail_precache(mail) < 0) {
- i_error("Mailbox %s: Precache for UID=%u failed: %s",
+ e_error(event,
+ "Mailbox %s: Precache for UID=%u failed: %s",
mailbox_get_vname(box), mail->uid,
mailbox_get_last_internal_error(box, NULL));
ret = -1;
if (doveadm_verbose)
printf("\r%u/%u\n", counter, max);
if (mailbox_search_deinit(&ctx) < 0) {
- i_error("Mailbox %s: Mail search failed: %s",
+ e_error(event, "Mailbox %s: Mail search failed: %s",
mailbox_get_vname(box),
mailbox_get_last_internal_error(box, NULL));
ret = -1;
}
if (mailbox_transaction_commit(&trans) < 0) {
- i_error("Mailbox %s: Transaction commit failed: %s",
+ e_error(event, "Mailbox %s: Transaction commit failed: %s",
mailbox_get_vname(box),
mailbox_get_last_internal_error(box, NULL));
ret = -1;
static int
cmd_index_box(struct index_cmd_context *ctx, const struct mailbox_info *info)
{
+ struct event *event = ctx->ctx.cctx->event;
struct mailbox *box;
struct mailbox_status status;
int ret = 0;
don't bother syncing the mailbox, that alone can take a
while with large maildirs. */
if (mailbox_open(box) < 0) {
- i_error("Opening mailbox %s failed: %s", info->vname,
+ e_error(event,
+ "Opening mailbox %s failed: %s", info->vname,
mailbox_get_last_internal_error(box, NULL));
doveadm_mail_failed_mailbox(&ctx->ctx, box);
mailbox_free(&box);
}
if (mailbox_sync(box, MAILBOX_SYNC_FLAG_FULL_READ) < 0) {
- i_error("Syncing mailbox %s failed: %s", info->vname,
+ e_error(event, "Syncing mailbox %s failed: %s", info->vname,
mailbox_get_last_internal_error(box, NULL));
doveadm_mail_failed_mailbox(&ctx->ctx, box);
ret = -1;
{
struct index_cmd_context *ctx =
container_of(_ctx, struct index_cmd_context, ctx);
+ struct event *event = ctx->ctx.cctx->event;
const enum mailbox_list_iter_flags iter_flags =
MAILBOX_LIST_ITER_NO_AUTO_BOXES |
MAILBOX_LIST_ITER_RETURN_NO_FLAGS |
} T_END;
}
if (mailbox_list_iter_deinit(&iter) < 0) {
- i_error("Listing mailboxes failed: %s",
+ e_error(event, "Listing mailboxes failed: %s",
mailbox_list_get_last_internal_error(user->namespaces->list, NULL));
doveadm_mail_failed_error(_ctx, MAIL_ERROR_TEMP);
ret = -1;
*iter_r = NULL;
errstr = mailbox_get_last_internal_error(iter->box, &error);
if (error != MAIL_ERROR_NOTFOUND) {
- i_error("Syncing mailbox %s failed: %s", info->vname, errstr);
+ e_error(ctx->cctx->event, "Syncing mailbox %s failed: %s",
+ info->vname, errstr);
doveadm_mail_failed_mailbox(ctx, iter->box);
}
mailbox_free(&iter->box);
if (iter->search_ctx != NULL) {
if (mailbox_search_deinit(&iter->search_ctx) < 0) {
- i_error("Searching mailbox %s failed: %s",
+ e_error(iter->ctx->cctx->event,
+ "Searching mailbox %s failed: %s",
mailbox_get_vname(iter->box),
mailbox_get_last_internal_error(iter->box, NULL));
ret = -1;
;
else if (commit) {
if (mailbox_transaction_commit(&iter->t) < 0) {
- i_error("Committing mailbox %s failed: %s",
+ e_error(iter->ctx->cctx->event,
+ "Committing mailbox %s failed: %s",
mailbox_get_vname(iter->box),
mailbox_get_last_internal_error(iter->box, NULL));
ret = -1;
if (ret == 0 && sync) {
ret = mailbox_sync(iter->box, 0);
if (ret < 0) {
- i_error("Mailbox %s: Mailbox sync failed: %s",
+ e_error(iter->ctx->cctx->event,
+ "Mailbox %s: Mailbox sync failed: %s",
mailbox_get_vname(iter->box),
mailbox_get_last_internal_error(iter->box, NULL));
}
struct mailbox *box = doveadm_mailbox_find(user, boxname);
if (mailbox_open(box) < 0 || mailbox_sync(box, 0) < 0) {
- i_error("Cannot open mailbox %s: %s",
+ e_error(ctx->cctx->event, "Cannot open mailbox %s: %s",
mailbox_get_vname(box),
mailbox_get_last_internal_error(box, NULL));
doveadm_mail_failed_mailbox(ctx, box);
if (mail_cache_open_and_verify(cache) < 0 ||
MAIL_CACHE_IS_UNUSABLE(cache)) {
mailbox_transaction_rollback(&t);
- i_error("Cache is unusable");
+ e_error(ctx->ctx.cctx->event, "Cache is unusable");
ctx->ctx.exit_code = EX_TEMPFAIL;
return -1;
}
mail_cache_view_close(&view);
if (mailbox_transaction_commit(&t) < 0) {
- i_error("mailbox_transaction_commit() failed: %s",
+ e_error(ctx->ctx.cctx->event, "mailbox_transaction_commit() failed: %s",
mailbox_get_last_internal_error(box, NULL));
doveadm_mail_failed_mailbox(&ctx->ctx, box);
return -1;
ret = 0;
if (mail_index_transaction_commit(&t) < 0) {
- i_error("mail_index_transaction_commit() failed: %s",
+ e_error(ctx->ctx.cctx->event, "mail_index_transaction_commit() failed: %s",
mailbox_get_last_internal_error(box, NULL));
doveadm_mail_failed_mailbox(&ctx->ctx, box);
ret = -1;
if (mctx->empty_mailbox_name) {
if (!mctx->allow_empty_mailbox_name) {
const char *op_str = doveadm_metadata_op_names[op];
- i_error("Failed to %s: %s", op_str,
+ e_error(mctx->ctx.cctx->event, "Failed to %s: %s", op_str,
"mailbox name cannot be empty");
mctx->ctx.exit_code = EX_USAGE;
return -1;
if (op == DOVEADM_METADATA_OP_SET &&
mailbox_open(*box_r) < 0) {
- i_error("Failed to open mailbox: %s",
+ e_error(mctx->ctx.cctx->event, "Failed to open mailbox: %s",
mailbox_get_last_internal_error(*box_r, NULL));
doveadm_mail_failed_mailbox(&mctx->ctx, *box_r);
mailbox_free(box_r);
mailbox_attribute_unset(trans, ctx->key_type, ctx->key) :
mailbox_attribute_set(trans, ctx->key_type, ctx->key, &ctx->value);
if (ret < 0) {
- i_error("Failed to set attribute: %s",
+ e_error(ctx->ctx.cctx->event, "Failed to set attribute: %s",
mailbox_get_last_internal_error(box, NULL));
doveadm_mail_failed_mailbox(_ctx, box);
mailbox_transaction_rollback(&trans);
} else if (mailbox_transaction_commit(&trans) < 0) {
- i_error("Failed to commit transaction: %s",
+ e_error(ctx->ctx.cctx->event, "Failed to commit transaction: %s",
mailbox_get_last_internal_error(box, NULL));
doveadm_mail_failed_mailbox(_ctx, box);
ret = -1;
ret = mailbox_attribute_get_stream(box, ctx->key_type, ctx->key, &value);
if (ret < 0) {
- i_error("Failed to get attribute: %s",
+ e_error(ctx->ctx.cctx->event, "Failed to get attribute: %s",
mailbox_get_last_internal_error(box, NULL));
doveadm_mail_failed_mailbox(_ctx, box);
} else if (ret == 0) {
doveadm_print("");
} else if (value.value_stream != NULL) {
if (doveadm_print_istream(value.value_stream) < 0) {
- i_error("read(%s) failed: %s",
+ e_error(ctx->ctx.cctx->event, "read(%s) failed: %s",
i_stream_get_name(value.value_stream),
i_stream_get_error(value.value_stream));
ret = -1;
}
}
if (mailbox_attribute_iter_deinit(&iter) < 0) {
- i_error("Mailbox %s: Failed to iterate mailbox attributes: %s",
+ e_error(ctx->ctx.cctx->event, "Mailbox %s: Failed to iterate mailbox attributes: %s",
mailbox_get_vname(box),
mailbox_get_last_internal_error(box, NULL));
return -1;
box = doveadm_mailbox_find(ctx->ctx.cur_mail_user, info->vname);
if (mailbox_get_status(box, ctx->status_items, &status) < 0 ||
mailbox_get_metadata(box, ctx->metadata_items, &metadata) < 0) {
- i_error("Mailbox %s: Failed to lookup mailbox status: %s",
+ e_error(ctx->ctx.cctx->event,
+ "Mailbox %s: Failed to lookup mailbox status: %s",
mailbox_get_vname(box),
mailbox_get_last_internal_error(box, NULL));
doveadm_mail_failed_mailbox(&ctx->ctx, box);
box = mailbox_alloc(ns->list, name, 0);
if (mailbox_create(box, &ctx->update, directory) < 0) {
- i_error("Can't create mailbox %s: %s", name,
+ e_error(ctx->ctx.ctx.cctx->event,
+ "Can't create mailbox %s: %s", name,
mailbox_get_last_internal_error(box, NULL));
doveadm_mail_failed_mailbox(_ctx, box);
ret = -1;
}
if (ctx->ctx.subscriptions) {
if (mailbox_set_subscribed(box, TRUE) < 0) {
- i_error("Can't subscribe to mailbox %s: %s", name,
+ e_error(ctx->ctx.ctx.cctx->event,
+ "Can't subscribe to mailbox %s: %s", name,
mailbox_get_last_internal_error(box, NULL));
doveadm_mail_failed_mailbox(_ctx, box);
ret = -1;
ret2 = ctx->require_empty ? mailbox_delete_empty(box) :
mailbox_delete(box);
if (ret2 < 0) {
- i_error("Can't delete mailbox %s: %s", name,
+ e_error(ctx->ctx.ctx.cctx->event,
+ "Can't delete mailbox %s: %s", name,
mailbox_get_last_internal_error(box, NULL));
doveadm_mail_failed_mailbox(_ctx, box);
ret = -1;
}
if (ctx->ctx.subscriptions) {
if (mailbox_set_subscribed(box, FALSE) < 0) {
- i_error("Can't unsubscribe mailbox %s: %s", name,
+ e_error(ctx->ctx.ctx.cctx->event,
+ "Can't unsubscribe mailbox %s: %s", name,
mail_storage_get_last_internal_error(storage, NULL));
doveadm_mail_failed_mailbox(_ctx, box);
ret = -1;
oldbox = mailbox_alloc(oldns->list, oldname, 0);
newbox = mailbox_alloc(newns->list, newname, 0);
if (mailbox_rename(oldbox, newbox) < 0) {
- i_error("Can't rename mailbox %s to %s: %s", oldname, newname,
+ e_error(ctx->ctx.ctx.cctx->event,
+ "Can't rename mailbox %s to %s: %s", oldname, newname,
mailbox_get_last_internal_error(oldbox, NULL));
doveadm_mail_failed_mailbox(_ctx, oldbox);
ret = -1;
}
if (ctx->ctx.subscriptions) {
if (mailbox_set_subscribed(oldbox, FALSE) < 0) {
- i_error("Can't unsubscribe mailbox %s: %s", ctx->oldname,
+ e_error(ctx->ctx.ctx.cctx->event,
+ "Can't unsubscribe mailbox %s: %s", ctx->oldname,
mailbox_get_last_internal_error(oldbox, NULL));
doveadm_mail_failed_mailbox(_ctx, oldbox);
ret = -1;
}
if (mailbox_set_subscribed(newbox, TRUE) < 0) {
- i_error("Can't subscribe to mailbox %s: %s", ctx->newname,
+ e_error(ctx->ctx.ctx.cctx->event,
+ "Can't subscribe to mailbox %s: %s", ctx->newname,
mailbox_get_last_internal_error(newbox, NULL));
doveadm_mail_failed_mailbox(_ctx, newbox);
ret = -1;
ns = mail_namespace_find(user->namespaces, name);
box = mailbox_alloc(ns->list, name, 0);
if (mailbox_set_subscribed(box, ctx->ctx.subscriptions) < 0) {
- i_error("Can't %s mailbox %s: %s", name,
- ctx->ctx.subscriptions ? "subscribe to" :
- "unsubscribe",
+ e_error(ctx->ctx.ctx.cctx->event,
+ "Can't %s mailbox %s: %s", name,
+ ctx->ctx.subscriptions ?
+ "subscribe to" : "unsubscribe",
mailbox_get_last_internal_error(box, NULL));
doveadm_mail_failed_mailbox(_ctx, box);
ret = -1;
box = mailbox_alloc(ns->list, ctx->mailbox, 0);
if ((ret = mailbox_update(box, &(ctx->update))) != 0) {
- i_error("Cannot update %s: %s",
- ctx->mailbox,
- mailbox_get_last_internal_error(box, &mail_error));
+ const char *error = mailbox_get_last_internal_error(
+ box, &mail_error);
+ e_error(ctx->ctx.ctx.cctx->event,
+ "Cannot update %s: %s", ctx->mailbox, error);
doveadm_mail_failed_error(_ctx, mail_error);
}
storage_name = mailbox_list_get_storage_name(ns->list, ctx->mailbox);
ret = mailbox_list_get_path(ns->list, storage_name, ctx->path_type, &path);
if (ret < 0) {
- i_error("Failed to lookup mailbox %s path: %s",
- ctx->mailbox,
- mailbox_list_get_last_internal_error(ns->list, &mail_error));
+ const char *error = mailbox_list_get_last_internal_error(
+ ns->list, &mail_error);
+ e_error(ctx->ctx.ctx.cctx->event,
+ "Failed to lookup mailbox %s path: %s",
+ ctx->mailbox, error);
doveadm_mail_failed_error(_ctx, mail_error);
} else if (ret > 0) {
doveadm_print(path);
bool save_failed = FALSE;
if (input->stream_errno != 0) {
- i_error("open(%s) failed: %s",
+ e_error(ctx->ctx.cctx->event, "open(%s) failed: %s",
i_stream_get_name(input),
i_stream_get_error(input));
ctx->ctx.exit_code = EX_TEMPFAIL;
}
if (mailbox_open(box) < 0) {
- i_error("Failed to open mailbox %s: %s",
+ e_error(ctx->ctx.cctx->event, "Failed to open mailbox %s: %s",
mailbox_get_vname(box),
mailbox_get_last_internal_error(box, NULL));
doveadm_mail_failed_storage(&ctx->ctx, storage);
ctx->ctx.transaction_flags, __func__);
save_ctx = mailbox_save_alloc(trans);
if (mailbox_save_begin(&save_ctx, input) < 0) {
- i_error("Saving failed: %s",
+ e_error(ctx->ctx.cctx->event, "Saving failed: %s",
mailbox_get_last_internal_error(box, NULL));
doveadm_mail_failed_storage(&ctx->ctx, storage);
mailbox_transaction_rollback(&trans);
i_assert(ret == -1);
if (input->stream_errno != 0) {
- i_error("read(msg input) failed: %s", i_stream_get_error(input));
+ e_error(ctx->ctx.cctx->event,
+ "read(msg input) failed: %s", i_stream_get_error(input));
doveadm_mail_failed_error(&ctx->ctx, MAIL_ERROR_TEMP);
} else if (save_failed) {
- i_error("Saving failed: %s",
+ e_error(ctx->ctx.cctx->event, "Saving failed: %s",
mailbox_get_last_internal_error(box, NULL));
doveadm_mail_failed_storage(&ctx->ctx, storage);
} else if (mailbox_save_finish(&save_ctx) < 0) {
- i_error("Saving failed: %s",
+ e_error(ctx->ctx.cctx->event, "Saving failed: %s",
mailbox_get_last_internal_error(box, NULL));
doveadm_mail_failed_storage(&ctx->ctx, storage);
} else if (mailbox_transaction_commit(&trans) < 0) {
- i_error("Save transaction commit failed: %s",
+ e_error(ctx->ctx.cctx->event,
+ "Save transaction commit failed: %s",
mailbox_get_last_internal_error(box, NULL));
doveadm_mail_failed_storage(&ctx->ctx, storage);
} else {
ret = 0;
if (mailbox_get_metadata(box, MAILBOX_METADATA_GUID, &metadata) < 0) {
- i_error("Couldn't get mailbox '%s' GUID: %s",
+ e_error(ctx->cctx->event, "Couldn't get mailbox '%s' GUID: %s",
mailbox_get_vname(box),
mailbox_get_last_internal_error(box, NULL));
ret = -1;
int ret;
if (!auth_proxy_parse_redirect(destination, &destuser, &host, &port)) {
- i_error("%s: Invalid redirect destination: %s",
+ e_error(cmd_ctx->cctx->event,
+ "%s: Invalid redirect destination: %s",
orig_server->name, destination);
return -1;
}
destuser, &error);
} else {
if (net_addr2ip(host, &ip) < 0) {
- i_error("%s: Redirect destination host is not an IP: %s",
+ e_error(cmd_ctx->cctx->event,
+ "%s: Redirect destination host is not an IP: %s",
orig_server->name, destination);
return -1;
}
&error);
}
if (ret < 0) {
- i_error("%s: %s", orig_server->name, error);
+ e_error(cmd_ctx->cctx->event,
+ "%s: %s", orig_server->name, error);
return -1;
}
return ret;
case 0:
break;
case DOVEADM_CLIENT_EXIT_CODE_DISCONNECTED:
- i_error("%s: Command %s failed for %s: %s",
+ e_error(cmd_ctx->cctx->event,
+ "%s: Command %s failed for %s: %s",
server->name, cmd_ctx->cmd->name, servercmd->username,
reply->error);
internal_failure = TRUE;
doveadm_mail_server_cmd_free(&servercmd);
return;
case EX_NOUSER:
- i_error("%s: No such user: %s", server->name,
+ e_error(cmd_ctx->cctx->event,
+ "%s: No such user: %s", server->name,
servercmd->username);
if (cmd_ctx->exit_code == 0)
cmd_ctx->exit_code = EX_NOUSER;
if (strcmp(key, "proxy-ttl") == 0) {
if (str_to_int(value, &ctx->proxy_ttl) < 0 ||
ctx->proxy_ttl <= 0)
- i_error("Invalid proxy-ttl value: %s", value);
+ e_error(ctx->cctx->event,
+ "Invalid proxy-ttl value: %s", value);
} else if (strcmp(key, "forward") == 0) {
if (!array_is_created(&ctx->proxy_forward_fields)) {
p_array_init(&ctx->proxy_forward_fields,
if (array_count(&doveadm_server_request_queue) == 0)
break;
if (doveadm_mail_server_request_queue_handle_next(&error) < 0) {
- i_error("%s", error);
+ e_error(cmd_ctx->cctx->event, "%s", error);
break;
}
}
doveadm_clients_destroy_all();
if (master_service_is_killed(master_service))
- i_error("Aborted");
+ e_error(cmd_ctx->cctx->event, "Aborted");
if (DOVEADM_MAIL_SERVER_FAILED())
doveadm_mail_failed_error(cmd_ctx, MAIL_ERROR_TEMP);
storage = mail_namespace_get_default_storage(ns);
if (mail_storage_purge(storage) < 0) {
- i_error("Purging namespace '%s' failed: %s", ns->prefix,
+ e_error(ctx->cctx->event,
+ "Purging namespace '%s' failed: %s", ns->prefix,
mail_storage_get_last_internal_error(storage, NULL));
doveadm_mail_failed_storage(ctx, storage);
ret = -1;
return;
if (ctx->cmd_input->stream_errno != 0) {
- i_error("read(%s) failed: %s",
+ e_error(ctx->cctx->event, "read(%s) failed: %s",
i_stream_get_name(ctx->cmd_input),
i_stream_get_error(ctx->cmd_input));
}
box = mailbox_alloc(info->ns->list, info->vname, flags);
if (mailbox_open(box) < 0) {
- i_error("Opening mailbox %s failed: %s", info->vname,
+ e_error(ctx->ctx.cctx->event,
+ "Opening mailbox %s failed: %s", info->vname,
mailbox_get_last_internal_error(box, NULL));
doveadm_mail_failed_mailbox(_ctx, box);
ret = -1;
} else if (mailbox_sync(box, MAILBOX_SYNC_FLAG_FORCE_RESYNC |
MAILBOX_SYNC_FLAG_FIX_INCONSISTENT) < 0) {
- i_error("Forcing a resync on mailbox %s failed: %s",
+ e_error(ctx->ctx.cctx->event,
+ "Forcing a resync on mailbox %s failed: %s",
info->vname, mailbox_get_last_internal_error(box, NULL));
doveadm_mail_failed_mailbox(_ctx, box);
ret = -1;
} T_END;
}
if (mailbox_list_iter_deinit(&iter) < 0) {
- i_error("Listing mailboxes failed: %s",
+ e_error(ctx->ctx.cctx->event,
+ "Listing mailboxes failed: %s",
mailbox_list_get_last_internal_error(user->namespaces->list, NULL));
doveadm_mail_failed_list(_ctx, user->namespaces->list);
ret = -1;
T_BEGIN {
ret = doveadm_mail_next_user(ctx, &error);
if (ret < 0)
- i_error("%s", error);
+ e_error(ctx->cctx->event, "%s", error);
else if (ret == 0)
- i_info("User no longer exists, skipping");
+ e_info(ctx->cctx->event,
+ "User no longer exists, skipping");
} T_END;
if (ret == -1)
break;
else
i_set_failure_prefix("doveadm(%s): ", ip);
if (ret < 0) {
- i_error("Failed to iterate through some users");
+ e_error(ctx->cctx->event, "Failed to iterate through some users");
ctx->exit_code = EX_TEMPFAIL;
}
}
*username_r = i_stream_read_next_line(ctx->users_list_input);
if (ctx->users_list_input->stream_errno != 0) {
- i_error("read(%s) failed: %s",
+ e_error(ctx->cctx->event, "read(%s) failed: %s",
i_stream_get_name(ctx->users_list_input),
i_stream_get_error(ctx->users_list_input));
return -1;
if (ret < 0) {
/* user lookup/init failed somehow */
doveadm_exit_code = EX_TEMPFAIL;
- i_error("%s", error);
+ e_error(ctx->cctx->event, "%s", error);
} else if (ret == 0) {
doveadm_exit_code = EX_NOUSER;
- i_error("User doesn't exist");
+ e_error(ctx->cctx->event, "User doesn't exist");
}
} else {
ctx->service_flags |= MAIL_STORAGE_SERVICE_FLAG_TEMP_PRIV_DROP;