Mercurial > dovecot > core-2.2

changeset 19633:7c03eb7b0f67

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
pop3c: Avoid unnecessarily email deletions from local index when mails have been deleted from remote POP3.
author Timo Sirainen <timo.sirainen@dovecot.fi>
date Mon, 25 Jan 2016 21:57:35 +0200
parents 727307a98574
children 98b116c28a95
files src/lib-storage/index/pop3c/pop3c-sync.c
diffstat 1 files changed, 16 insertions(+), 18 deletions(-) [+]
line wrap: on
line diff
--- a/src/lib-storage/index/pop3c/pop3c-sync.c	Mon Jan 25 17:37:02 2016 +0200
+++ b/src/lib-storage/index/pop3c/pop3c-sync.c	Mon Jan 25 21:57:35 2016 +0200
@@ -139,7 +139,7 @@
 	const struct mail_index_header *hdr;
 	struct mail_cache_transaction_ctx *cache_trans;
 	string_t *str;
-	uint32_t seq, seq1, seq2, iseq, uid;
+	uint32_t lseq, rseq, seq1, seq2, uid;
 	unsigned int cache_idx = ibox->cache_fields[MAIL_CACHE_POP3_UIDL].idx;
 
 	i_assert(mbox->msg_uids == NULL);
@@ -153,34 +153,32 @@
 			&uid_validity, sizeof(uid_validity), TRUE);
 	}
 
-	/* skip over existing messages with matching UIDLs */
+	/* skip over existing messages with matching UIDLs and expunge the ones
+	   that no longer exist in remote. */
 	mbox->msg_uids = i_new(uint32_t, mbox->msg_count + 1);
 	str = t_str_new(128);
-	for (seq = 1; seq <= hdr->messages_count && seq <= mbox->msg_count; seq++) {
+	for (lseq = rseq = 1; lseq <= hdr->messages_count && rseq <= mbox->msg_count; lseq++) {
 		str_truncate(str, 0);
-		if (mail_cache_lookup_field(cache_view, str, seq,
+		if (mail_cache_lookup_field(cache_view, str, lseq,
 					    cache_idx) > 0 &&
-		    strcmp(str_c(str), mbox->msg_uidls[seq-1]) == 0) {
+		    strcmp(str_c(str), mbox->msg_uidls[rseq-1]) == 0) {
 			/* UIDL matched */
-			mail_index_lookup_uid(sync_view, seq,
-					      &mbox->msg_uids[seq-1]);
+			mail_index_lookup_uid(sync_view, lseq,
+					      &mbox->msg_uids[rseq-1]);
+			rseq++;
 		} else {
-			break;
+			mail_index_expunge(sync_trans, lseq);
 		}
 	}
-	seq2 = seq;
-	/* remove the rest of the messages from index */
-	for (; seq <= hdr->messages_count; seq++)
-		mail_index_expunge(sync_trans, seq);
 	/* add the rest of the messages in POP3 mailbox to index */
 	cache_trans = mail_cache_get_transaction(cache_view, sync_trans);
 	uid = hdr->next_uid;
-	for (seq = seq2; seq <= mbox->msg_count; seq++) {
-		mbox->msg_uids[seq-1] = uid;
-		mail_index_append(sync_trans, uid++, &iseq);
-		mail_cache_add(cache_trans, iseq, cache_idx,
-			       mbox->msg_uidls[seq-1],
-			       strlen(mbox->msg_uidls[seq-1])+1);
+	for (; rseq <= mbox->msg_count; rseq++) {
+		mbox->msg_uids[rseq-1] = uid;
+		mail_index_append(sync_trans, uid++, &lseq);
+		mail_cache_add(cache_trans, lseq, cache_idx,
+			       mbox->msg_uidls[rseq-1],
+			       strlen(mbox->msg_uidls[rseq-1])+1);
 	}
 
 	/* mark the newly seen messages as recent */