imapc-mailbox.c revision 34bc7b583d5f34ac786ff16ff0f7d6c169ebe857
/* Copyright (c) 2011 Dovecot authors, see the included COPYING file */
#include "lib.h"
#include "ioloop.h"
#include "imap-arg.h"
#include "imap-util.h"
#include "imapc-client.h"
#include "imapc-mail.h"
#include "imapc-msgmap.h"
#include "imapc-sync.h"
#include "imapc-storage.h"
#define NOTIFY_DELAY_MSECS 500
const char *reason, ...)
{
i_error("imapc: Mailbox '%s' state corrupted: %s",
if (!mbox->initial_sync_done) {
/* we failed during initial sync. need to rebuild indexes if
we want to get this fixed */
} else {
/* maybe the remote server is buggy and has become confused.
try reconnecting. */
}
}
static struct mail_index_view *
{
}
{
return;
}
{
struct mail_index_transaction *trans;
int ret;
}
if (ret < 0)
return ret;
}
bool *changes_r)
{
int ret = 0;
ret = -1;
}
}
/* delayed expunges - commit them now in a separate
transaction */
if (imapc_mailbox_commit_delayed_expunges(mbox) < 0)
ret = -1;
}
return ret;
}
{
}
{
}
}
static void
struct imapc_mailbox *mbox)
{
const struct mail_index_header *hdr;
return;
/* We don't know the latest flags, refresh them. */
}
}
{
const unsigned int *kw_idx;
unsigned int i, j, count;
return FALSE;
/* there are normally only a few keywords, so O(n^2) is fine */
for (i = 0; i < count; i++) {
for (j = 0; j < count; j++) {
break;
}
if (j == count)
return FALSE;
}
return TRUE;
}
static int
{
struct imapc_msgmap *msgmap;
*lseq_r = 0;
/* Receiving a FETCH for a message that EXISTS hasn't
announced yet. MS Exchange has a bug where our UID FETCH
request sometimes sends replies where sequences are above
EXISTS value, but their UIDs are for existing messages.
We'll just ignore these replies. */
return 0;
}
/* This was the initial attempt at catching the above
MS Exchange bug, but the above one appears to catch all
these cases. But keep it here just in case. */
"(seq=%u,%u vs uid=%u,%u)",
return -1;
}
"FETCH UID mismatch (%u != %u)",
return -1;
}
/* probably a flag update for a message we haven't yet
received our initial UID FETCH for. we should get
another one. */
if (fetch_uid == 0)
return 0;
"FETCH returned wrong sequence for UID %u "
return -1;
}
"Expunged message reappeared in session "
"(uid=%u < next_uid=%u)",
return -1;
} else {
/* newly seen message */
/* message is already added to index */
if (!mbox->initial_sync_done &&
"Expunged message reappeared "
"(uid=%u < next_uid=%u)",
return -1;
}
}
}
return 0;
}
struct imapc_mailbox *mbox)
{
struct imapc_mail *const *mailp;
const char *atom;
enum mail_flags flags;
unsigned int i, j;
bool seen_flags = FALSE;
return;
return;
return;
return;
seen_flags = TRUE;
return;
if (atom[0] == '\\')
else {
/* keyword */
}
}
}
}
/* FIXME: need to do something about recent flags */
flags &= ~MAIL_RECENT;
return;
/* if this is a reply to some FETCH request, update the mail's fields */
}
if (lseq == 0) {
/* already expunged by another session */
return;
}
}
/* we're doing the initial full sync of mails. expunge any
mails that no longer exist. */
mbox->sync_next_lseq++;
}
mbox->sync_next_rseq++;
mbox->sync_next_lseq++;
}
}
if (seen_flags) T_BEGIN {
struct mail_keywords *kw;
&old_kws);
(void)array_append_space(&keywords);
}
} T_END;
}
struct imapc_mailbox *mbox)
{
struct imapc_msgmap *msgmap;
return;
mbox->prev_skipped_rseq = 0;
mbox->prev_skipped_uid = 0;
if (mbox->exists_count == 0) {
"EXPUNGE received for empty mailbox");
return;
}
mbox->exists_count--;
/* we haven't even seen this message yet */
return;
}
/* this message exists only in this transaction. lib-index
can't currently handle expunging anything except the last
appended message in a transaction, and fixing it would be
quite a lot of trouble. so instead we'll just delay doing
this expunge until after the current transaction has been
committed. */
} else {
/* already expunged by another session */
}
}
static void
struct imapc_mailbox *mbox)
{
return;
}
}
static void
struct imapc_mailbox *mbox)
{
return;
}
static void
struct imapc_mailbox *mbox)
{
const char *flag;
unsigned int idx;
return;
mbox->permanent_flags = 0;
continue;
else if (*flag == '\\')
else {
/* we'll simply make sure that it exists in the index */
}
}
}
const char *key,
{
struct imapc_mailbox_event_callback *cb;
}
const char *key,
{
struct imapc_mailbox_event_callback *cb;
}
{
}