Mercurial > dovecot > core-2.2
view src/doveadm/dsync/dsync-mailbox-state.c @ 15496:5d90e2aa1ba8
dsync: Use private modseqs to support syncing private flags in shared mailboxes.
author | Timo Sirainen <tss@iki.fi> |
---|---|
date | Fri, 04 Jan 2013 01:13:05 +0200 |
parents | 6c850258002f |
children | 1d7d160015cb |
line wrap: on
line source
/* Copyright (c) 2012 Dovecot authors, see the included COPYING file */ #include "lib.h" #include "array.h" #include "base64.h" #include "crc32.h" #include "hash.h" #include "dsync-mailbox-state.h" #define MAILBOX_SIZE (GUID_128_SIZE + 4 + 4 + 8) static void put_uint32(buffer_t *output, uint32_t num) { buffer_append_c(output, num & 0xff); buffer_append_c(output, (num >> 8) & 0xff); buffer_append_c(output, (num >> 16) & 0xff); buffer_append_c(output, (num >> 24) & 0xff); } static uint32_t get_uint32(const unsigned char *data) { return data[0] | (data[1] << 8) | (data[2] << 16) | ((unsigned int)data[3] << 24); } void dsync_mailbox_states_export(const HASH_TABLE_TYPE(dsync_mailbox_state) states, string_t *output) { struct hash_iterate_context *iter; struct dsync_mailbox_state *state; uint8_t *guid; buffer_t *buf = buffer_create_dynamic(pool_datastack_create(), 128); uint32_t crc = 0; iter = hash_table_iterate_init(states); while (hash_table_iterate(iter, states, &guid, &state)) { buffer_append(buf, state->mailbox_guid, sizeof(state->mailbox_guid)); put_uint32(buf, state->last_uidvalidity); put_uint32(buf, state->last_common_uid); put_uint32(buf, state->last_common_modseq & 0xffffffffU); put_uint32(buf, state->last_common_modseq >> 32); put_uint32(buf, state->last_common_pvt_modseq & 0xffffffffU); put_uint32(buf, state->last_common_pvt_modseq >> 32); if (buf->used % 3 == 0) { crc = crc32_data_more(crc, buf->data, buf->used); base64_encode(buf->data, buf->used, output); buffer_set_used_size(buf, 0); } } hash_table_iterate_deinit(&iter); crc = crc32_data_more(crc, buf->data, buf->used); put_uint32(buf, crc); base64_encode(buf->data, buf->used, output); } int dsync_mailbox_states_import(HASH_TABLE_TYPE(dsync_mailbox_state) states, pool_t pool, const char *input, const char **error_r) { struct dsync_mailbox_state *state; buffer_t *buf; uint8_t *guid_p; const unsigned char *data; size_t pos; unsigned int i, count; buf = buffer_create_dynamic(pool_datastack_create(), strlen(input)); if (base64_decode(input, strlen(input), &pos, buf) < 0) { *error_r = "Invalid base64 data"; return -1; } if (buf->used < 4) { *error_r = "Input too small"; return -1; } if ((buf->used-4) % MAILBOX_SIZE != 0) { *error_r = "Invalid input size"; return -1; } data = buf->data; count = (buf->used-4) / MAILBOX_SIZE; if (get_uint32(data + buf->used-4) != crc32_data(data, buf->used-4)) { *error_r = "CRC32 mismatch"; return -1; } for (i = 0; i < count; i++, data += MAILBOX_SIZE) { state = p_new(pool, struct dsync_mailbox_state, 1); memcpy(state->mailbox_guid, data, GUID_128_SIZE); state->last_uidvalidity = get_uint32(data + GUID_128_SIZE); state->last_common_uid = get_uint32(data + GUID_128_SIZE + 4); state->last_common_modseq = get_uint32(data + GUID_128_SIZE + 8) | (uint64_t)get_uint32(data + GUID_128_SIZE + 12) << 32; state->last_common_pvt_modseq = get_uint32(data + GUID_128_SIZE + 16) | (uint64_t)get_uint32(data + GUID_128_SIZE + 20) << 32; guid_p = state->mailbox_guid; hash_table_insert(states, guid_p, state); } return 0; }