mail-index-transaction-finish.c revision 1279090ba03f9c176976a69ab7718f0ed77b19af
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen/* Copyright (c) 2003-2009 Dovecot authors, see the included COPYING file */
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen#include "lib.h"
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen#include "array.h"
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen#include "mail-index-private.h"
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen#include "mail-index-modseq.h"
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen#include "mail-index-transaction-private.h"
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainenstatic void
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainenext_reset_update_atomic(struct mail_index_transaction *t,
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen uint32_t ext_id, uint32_t expected_reset_id)
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen{
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen const struct mail_index_ext *map_ext;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen struct mail_transaction_ext_reset *reset;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen uint32_t idx, reset_id;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (!mail_index_map_get_ext_idx(t->view->index->map, ext_id, &idx)) {
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen /* new extension */
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen reset_id = 1;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen } else {
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen map_ext = array_idx(&t->view->index->map->extensions, idx);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen reset_id = map_ext->reset_id + 1;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen }
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (reset_id != expected_reset_id) {
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen /* ignore this extension update */
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen mail_index_ext_set_reset_id(t, ext_id, 0);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen return;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen }
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (reset_id == 0)
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen reset_id++;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen array_idx_set(&t->ext_reset_ids, ext_id, &reset_id);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen /* reseting existing data is optional */
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (array_is_created(&t->ext_resets)) {
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen reset = array_idx_modifiable(&t->ext_resets, ext_id);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (reset->new_reset_id == (uint32_t)-1)
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen reset->new_reset_id = reset_id;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen }
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen}
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainenstatic void
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainentransaction_update_atomic_reset_ids(struct mail_index_transaction *t)
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen{
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen const uint32_t *expected_reset_ids;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen unsigned int ext_id, count;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (!array_is_created(&t->ext_reset_atomic))
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen return;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen expected_reset_ids = array_get(&t->ext_reset_atomic, &count);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen for (ext_id = 0; ext_id < count; ext_id++) {
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (expected_reset_ids[ext_id] != 0) {
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen ext_reset_update_atomic(t, ext_id,
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen expected_reset_ids[ext_id]);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen }
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen }
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen}
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainenstatic bool
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainenmail_index_update_cancel_array(ARRAY_TYPE(seq_range) *array, uint32_t seq)
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen{
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (array_is_created(array)) {
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (seq_range_array_remove(array, seq)) {
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (array_count(array) == 0)
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen array_free(array);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen return TRUE;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen }
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen }
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen return FALSE;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen}
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainenstatic bool
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainenmail_index_update_cancel(struct mail_index_transaction *t, uint32_t seq)
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen{
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen struct mail_index_transaction_keyword_update *kw;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen struct mail_transaction_flag_update *updates, tmp_update;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen unsigned int i, count;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen bool ret, have_kw_changes = FALSE;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen ret = mail_index_update_cancel_array(&t->keyword_resets, seq);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (array_is_created(&t->keyword_updates)) {
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen kw = array_get_modifiable(&t->keyword_updates, &count);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen for (i = 0; i < count; i++) {
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (mail_index_update_cancel_array(&kw[i].add_seq, seq))
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen ret = TRUE;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (mail_index_update_cancel_array(&kw[i].remove_seq,
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen seq))
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen ret = TRUE;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (array_is_created(&kw[i].add_seq) ||
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen array_is_created(&kw[i].remove_seq))
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen have_kw_changes = TRUE;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen }
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (!have_kw_changes)
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen array_free(&t->keyword_updates);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen }
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (!array_is_created(&t->updates))
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen return ret;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen updates = array_get_modifiable(&t->updates, &count);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen i = mail_index_transaction_get_flag_update_pos(t, 0, count, seq);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (i < count && updates[i].uid1 <= seq && updates[i].uid2 >= seq) {
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen /* exists */
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen ret = TRUE;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (updates[i].uid1 == seq && updates[i].uid2 == seq) {
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (count > 1)
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen array_delete(&t->updates, i, 1);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen else
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen array_free(&t->updates);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen } else if (updates[i].uid1 == seq)
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen updates[i].uid1++;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen else if (updates[i].uid2 == seq)
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen updates[i].uid2--;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen else {
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen /* need to split it in two */
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen tmp_update = updates[i];
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen tmp_update.uid1 = seq+1;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen updates[i].uid2 = seq-1;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen array_insert(&t->updates, i + 1, &tmp_update, 1);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen }
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen }
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen return ret;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen}
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainenstatic void
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainenmail_index_transaction_check_conflicts(struct mail_index_transaction *t)
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen{
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen uint32_t seq;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen i_assert(t->max_modseq != 0);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen i_assert(t->conflict_seqs != NULL);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (t->max_modseq == mail_index_modseq_get_highest(t->view)) {
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen /* no conflicts possible */
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen return;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen }
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (t->min_flagupdate_seq == 0) {
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen /* no flag updates */
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen return;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen }
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen for (seq = t->min_flagupdate_seq; seq <= t->max_flagupdate_seq; seq++) {
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (mail_index_modseq_lookup(t->view, seq) > t->max_modseq) {
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (mail_index_update_cancel(t, seq))
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen seq_range_array_add(t->conflict_seqs, 0, seq);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen }
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen }
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen mail_index_transaction_set_log_updates(t);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen}
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainenstatic uint32_t
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainenmail_index_transaction_get_uid(struct mail_index_transaction *t, uint32_t seq)
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen{
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen const struct mail_index_record *rec;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen i_assert(seq > 0);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (seq >= t->first_new_seq)
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen rec = mail_index_transaction_lookup(t, seq);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen else {
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen i_assert(seq <= t->view->map->hdr.messages_count);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen rec = MAIL_INDEX_MAP_IDX(t->view->map, seq - 1);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen }
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen i_assert(rec->uid != 0);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen return rec->uid;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen}
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainenstatic void
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainenmail_index_convert_to_uids(struct mail_index_transaction *t,
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen ARRAY_TYPE(seq_array) *array)
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen{
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen uint32_t *seq;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen unsigned int i, count;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (!array_is_created(array))
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen return;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen count = array_count(array);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen for (i = 0; i < count; i++) {
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen seq = array_idx_modifiable(array, i);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen *seq = mail_index_transaction_get_uid(t, *seq);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen }
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen}
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainenstatic uint32_t
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainenget_nonexpunged_uid2(struct mail_index_transaction *t,
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen uint32_t uid1, uint32_t seq1)
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen{
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen seq1++;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen while (mail_index_transaction_get_uid(t, seq1) == uid1 + 1) {
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen seq1++;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen uid1++;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen }
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen return uid1;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen}
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainenstatic void
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainenmail_index_convert_to_uid_ranges(struct mail_index_transaction *t,
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen ARRAY_TYPE(seq_range) *array)
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen{
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen struct seq_range *range, *new_range;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen unsigned int i, count;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen uint32_t uid1, uid2;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (!array_is_created(array))
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen return;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen count = array_count(array);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen for (i = 0; i < count; i++) {
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen range = array_idx_modifiable(array, i);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen uid1 = mail_index_transaction_get_uid(t, range->seq1);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen uid2 = mail_index_transaction_get_uid(t, range->seq2);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (uid2 - uid1 == range->seq2 - range->seq1) {
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen /* simple conversion */
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen range->seq1 = uid1;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen range->seq2 = uid2;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen } else {
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen /* remove expunged UIDs */
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen new_range = array_insert_space(array, i);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen range = array_idx_modifiable(array, i + 1);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen count++;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen memcpy(new_range, range, array->arr.element_size);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen new_range->seq1 = uid1;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen new_range->seq2 = get_nonexpunged_uid2(t, uid1,
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen range->seq1);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen /* continue the range without the inserted seqs */
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen range->seq1 += new_range->seq2 - new_range->seq1 + 1;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen }
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen }
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen}
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainenstatic void keyword_updates_convert_to_uids(struct mail_index_transaction *t)
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen{
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen struct mail_index_transaction_keyword_update *updates;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen unsigned int i, count;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (!array_is_created(&t->keyword_updates))
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen return;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen updates = array_get_modifiable(&t->keyword_updates, &count);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen for (i = 0; i < count; i++) {
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen mail_index_convert_to_uid_ranges(t, &updates[i].add_seq);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen mail_index_convert_to_uid_ranges(t, &updates[i].remove_seq);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen }
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen}
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainenstatic void
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainenmail_index_transaction_convert_to_uids(struct mail_index_transaction *t)
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen{
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen ARRAY_TYPE(seq_array) *updates;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen unsigned int i, count;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (array_is_created(&t->ext_rec_updates)) {
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen updates = array_get_modifiable(&t->ext_rec_updates, &count);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen for (i = 0; i < count; i++)
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen mail_index_convert_to_uids(t, (void *)&updates[i]);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen }
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (array_is_created(&t->ext_rec_atomics)) {
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen updates = array_get_modifiable(&t->ext_rec_atomics, &count);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen for (i = 0; i < count; i++)
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen mail_index_convert_to_uids(t, (void *)&updates[i]);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen }
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen keyword_updates_convert_to_uids(t);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen mail_index_convert_to_uid_ranges(t, &t->expunges);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen mail_index_convert_to_uid_ranges(t, (void *)&t->updates);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen mail_index_convert_to_uid_ranges(t, &t->keyword_resets);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen}
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainenint mail_index_transaction_finish(struct mail_index_transaction *t)
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen{
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen mail_index_transaction_sort_appends(t);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (array_is_created(&t->ext_reset_atomic) || t->max_modseq != 0) {
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (mail_index_map(t->view->index,
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen MAIL_INDEX_SYNC_HANDLER_HEAD) <= 0)
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen return -1;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen }
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (array_is_created(&t->ext_reset_atomic))
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen transaction_update_atomic_reset_ids(t);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen if (t->max_modseq != 0)
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen mail_index_transaction_check_conflicts(t);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen /* finally convert all sequences to UIDs before we write them,
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen but after we've checked and removed conflicts */
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen mail_index_transaction_convert_to_uids(t);
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen return 0;
1279090ba03f9c176976a69ab7718f0ed77b19afTimo Sirainen}