dovecot/core-2.2: src/doveadm/dsync/dsync-ibc-stream.c annotate

annotate src/doveadm/dsync/dsync-ibc-stream.c @ 15986:f6377e089dee

dsync: If I/O gets stalled, log the state in which it happened.

author	Timo Sirainen <tss@iki.fi>
date	Wed, 27 Feb 2013 12:34:00 +0200
parents	607758d425e7
children	c6082de4bf5b

rev	line source
15715 36ef72481934 Oops :) Update copyrights to 2013 without breaking all .c files. Timo Sirainen <tss@iki.fi> parents: 15714 diff changeset	1 /* Copyright (c) 2013 Dovecot authors, see the included COPYING file */
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	2
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	3 #include "lib.h"
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	4 #include "array.h"
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	5 #include "fd-set-nonblock.h"
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	6 #include "safe-mkstemp.h"
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	7 #include "ioloop.h"
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	8 #include "istream.h"
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	9 #include "istream-seekable.h"
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	10 #include "istream-dot.h"
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	11 #include "ostream.h"
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	12 #include "str.h"
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	13 #include "strescape.h"
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	14 #include "master-service.h"
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	15 #include "mail-cache.h"
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	16 #include "mail-storage-private.h"
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	17 #include "dsync-serializer.h"
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	18 #include "dsync-deserializer.h"
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	19 #include "dsync-mail.h"
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	20 #include "dsync-mailbox.h"
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	21 #include "dsync-mailbox-state.h"
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	22 #include "dsync-mailbox-tree.h"
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	23 #include "dsync-ibc-private.h"
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	24
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	25 #include <stdlib.h>
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	26
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	27 #define DSYNC_IBC_STREAM_TIMEOUT_MSECS (60101000)
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	28 #define DSYNC_IBC_STREAM_OUTBUF_THROTTLE_SIZE (1024*128)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	29
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	30 #define DSYNC_PROTOCOL_VERSION_MAJOR 3
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	31 #define DSYNC_HANDSHAKE_VERSION "VERSION\tdsync\t3\t0\n"
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	32
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	33 enum item_type {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	34 ITEM_NONE,
15767 93a8a32adfd8 dsync: Don't log read() failed: EOF when remote intentionally fails early. Timo Sirainen <tss@iki.fi> parents: 15750 diff changeset	35 ITEM_DONE,
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	36
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	37 ITEM_HANDSHAKE,
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	38 ITEM_MAILBOX_STATE,
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	39 ITEM_MAILBOX_TREE_NODE,
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	40 ITEM_MAILBOX_DELETE,
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	41 ITEM_MAILBOX,
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	42
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	43 ITEM_MAIL_CHANGE,
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	44 ITEM_MAIL_REQUEST,
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	45 ITEM_MAIL,
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	46
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	47 ITEM_MAILBOX_CACHE_FIELD,
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	48
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	49 ITEM_END_OF_LIST
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	50 };
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	51
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	52 #define END_OF_LIST_LINE "."
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	53 static const struct {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	54 /* full human readable name of the item */
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	55 const char *name;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	56 /* unique character identifying the item */
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	57 char chr;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	58 const char *required_keys;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	59 const char *optional_keys;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	60 } items[ITEM_END_OF_LIST+1] = {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	61 { NULL, '\0', NULL, NULL },
15767 93a8a32adfd8 dsync: Don't log read() failed: EOF when remote intentionally fails early. Timo Sirainen <tss@iki.fi> parents: 15750 diff changeset	62 { .name = "done",
93a8a32adfd8 dsync: Don't log read() failed: EOF when remote intentionally fails early. Timo Sirainen <tss@iki.fi> parents: 15750 diff changeset	63 .chr = 'X',
93a8a32adfd8 dsync: Don't log read() failed: EOF when remote intentionally fails early. Timo Sirainen <tss@iki.fi> parents: 15750 diff changeset	64 .optional_keys = ""
93a8a32adfd8 dsync: Don't log read() failed: EOF when remote intentionally fails early. Timo Sirainen <tss@iki.fi> parents: 15750 diff changeset	65 },
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	66 { .name = "handshake",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	67 .chr = 'H',
15782 6f024e0289da dsync: -l parameter locking is now done on the server with "lower" hostname. Timo Sirainen <tss@iki.fi> parents: 15767 diff changeset	68 .required_keys = "hostname",
15836 607758d425e7 dsync: Renamed -a parameter to -N. It also now skips invisible namespaces. Timo Sirainen <tss@iki.fi> parents: 15783 diff changeset	69 .optional_keys = "sync_ns_prefix sync_box sync_type debug sync_visible_namespaces "
15782 6f024e0289da dsync: -l parameter locking is now done on the server with "lower" hostname. Timo Sirainen <tss@iki.fi> parents: 15767 diff changeset	70 "send_mail_requests backup_send backup_recv lock_timeout"
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	71 },
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	72 { .name = "mailbox_state",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	73 .chr = 'S',
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	74 .required_keys = "mailbox_guid last_uidvalidity last_common_uid "
15783 502a50925641 dsync: Merge last-common-* values from both local and remote when they differ. Timo Sirainen <tss@iki.fi> parents: 15782 diff changeset	75 "last_common_modseq last_common_pvt_modseq",
502a50925641 dsync: Merge last-common-* values from both local and remote when they differ. Timo Sirainen <tss@iki.fi> parents: 15782 diff changeset	76 .optional_keys = "changes_during_sync"
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	77 },
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	78 { .name = "mailbox_tree_node",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	79 .chr = 'N',
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	80 .required_keys = "name existence",
15231 454d0563927d doveadm: "backup" command is working again. Timo Sirainen <tss@iki.fi> parents: 15068 diff changeset	81 .optional_keys = "mailbox_guid uid_validity uid_next "
15035 0af20585964d dsync: Rewritten syncing for mailbox renames. Timo Sirainen <tss@iki.fi> parents: 14691 diff changeset	82 "last_renamed_or_created subscribed last_subscription_change"
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	83 },
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	84 { .name = "mailbox_delete",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	85 .chr = 'D',
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	86 .required_keys = "hierarchy_sep",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	87 .optional_keys = "mailboxes dirs"
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	88 },
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	89 { .name = "mailbox",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	90 .chr = 'B',
15496 5d90e2aa1ba8 dsync: Use private modseqs to support syncing private flags in shared mailboxes. Timo Sirainen <tss@iki.fi> parents: 15494 diff changeset	91 .required_keys = "mailbox_guid uid_validity uid_next messages_count "
5d90e2aa1ba8 dsync: Use private modseqs to support syncing private flags in shared mailboxes. Timo Sirainen <tss@iki.fi> parents: 15494 diff changeset	92 "first_recent_uid highest_modseq highest_pvt_modseq",
15750 5a1fc3723371 dsync: Automatically figure out which mailboxes can sync with message GUIDs. Timo Sirainen <tss@iki.fi> parents: 15744 diff changeset	93 .optional_keys = "mailbox_lost cache_fields have_guids"
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	94 },
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	95 { .name = "mail_change",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	96 .chr = 'C',
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	97 .required_keys = "type uid",
15496 5d90e2aa1ba8 dsync: Use private modseqs to support syncing private flags in shared mailboxes. Timo Sirainen <tss@iki.fi> parents: 15494 diff changeset	98 .optional_keys = "guid hdr_hash modseq pvt_modseq save_timestamp "
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	99 "add_flags remove_flags final_flags "
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	100 "keywords_reset keyword_changes"
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	101 },
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	102 { .name = "mail_request",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	103 .chr = 'R',
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	104 .optional_keys = "guid uid"
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	105 },
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	106 { .name = "mail",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	107 .chr = 'M',
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	108 .optional_keys = "guid uid pop3_uidl pop3_order received_date stream"
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	109 },
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	110 { .name = "mailbox_cache_field",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	111 .chr = 'c',
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	112 .required_keys = "name decision",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	113 .optional_keys = "last_used"
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	114 },
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	115
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	116 { "end_of_list", '\0', NULL, NULL }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	117 };
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	118
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	119 struct dsync_ibc_stream {
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	120 struct dsync_ibc ibc;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	121
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	122 char name, temp_path_prefix;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	123 int fd_in, fd_out;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	124 struct istream *input;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	125 struct ostream *output;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	126 struct io *io;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	127 struct timeout *to;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	128
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	129 struct dsync_serializer *serializers[ITEM_END_OF_LIST];
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	130 struct dsync_deserializer *deserializers[ITEM_END_OF_LIST];
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	131
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	132 pool_t ret_pool;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	133 struct dsync_deserializer_decoder *cur_decoder;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	134
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	135 struct istream mail_output, mail_input;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	136 struct dsync_mail *cur_mail;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	137 char mail_output_last;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	138
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	139 unsigned int version_received:1;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	140 unsigned int handshake_received:1;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	141 unsigned int has_pending_data:1;
15767 93a8a32adfd8 dsync: Don't log read() failed: EOF when remote intentionally fails early. Timo Sirainen <tss@iki.fi> parents: 15750 diff changeset	142 unsigned int stopped:1;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	143 };
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	144
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	145 static void dsync_ibc_stream_stop(struct dsync_ibc_stream *ibc)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	146 {
15767 93a8a32adfd8 dsync: Don't log read() failed: EOF when remote intentionally fails early. Timo Sirainen <tss@iki.fi> parents: 15750 diff changeset	147 ibc->stopped = TRUE;
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	148 i_stream_close(ibc->input);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	149 o_stream_close(ibc->output);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	150 io_loop_stop(current_ioloop);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	151 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	152
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	153 static int dsync_ibc_stream_read_mail_stream(struct dsync_ibc_stream *ibc)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	154 {
15483 fc6873897e8b dsync: Minor (probably unnecessary) fix for i_stream_read() API usage. Timo Sirainen <tss@iki.fi> parents: 15482 diff changeset	155 do {
15463 f9e8cbb2792d dsync: Fixed hangs with remote dsyncing Timo Sirainen <tss@iki.fi> parents: 15231 diff changeset	156 i_stream_skip(ibc->mail_input,
f9e8cbb2792d dsync: Fixed hangs with remote dsyncing Timo Sirainen <tss@iki.fi> parents: 15231 diff changeset	157 i_stream_get_data_size(ibc->mail_input));
15483 fc6873897e8b dsync: Minor (probably unnecessary) fix for i_stream_read() API usage. Timo Sirainen <tss@iki.fi> parents: 15482 diff changeset	158 } while (i_stream_read(ibc->mail_input) > 0);
15463 f9e8cbb2792d dsync: Fixed hangs with remote dsyncing Timo Sirainen <tss@iki.fi> parents: 15231 diff changeset	159 if (ibc->mail_input->eof) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	160 if (ibc->mail_input->stream_errno != 0) {
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	161 errno = ibc->mail_input->stream_errno;
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	162 i_error("dsync(%s): read() failed: %m", ibc->name);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	163 dsync_ibc_stream_stop(ibc);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	164 return -1;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	165 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	166 /* finished reading the mail stream */
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	167 i_assert(ibc->mail_input->eof);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	168 i_stream_seek(ibc->mail_input, 0);
15463 f9e8cbb2792d dsync: Fixed hangs with remote dsyncing Timo Sirainen <tss@iki.fi> parents: 15231 diff changeset	169 ibc->has_pending_data = TRUE;
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	170 ibc->mail_input = NULL;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	171 return 1;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	172 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	173 return 0;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	174 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	175
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	176 static void dsync_ibc_stream_input(struct dsync_ibc_stream *ibc)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	177 {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	178 if (ibc->mail_input != NULL) {
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	179 if (dsync_ibc_stream_read_mail_stream(ibc) == 0)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	180 return;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	181 }
15594 5bb80a6491eb dsync: Fixes to handling output stream buffering. Timo Sirainen <tss@iki.fi> parents: 15592 diff changeset	182 o_stream_cork(ibc->output);
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	183 ibc->ibc.io_callback(ibc->ibc.io_context);
15594 5bb80a6491eb dsync: Fixes to handling output stream buffering. Timo Sirainen <tss@iki.fi> parents: 15592 diff changeset	184 o_stream_uncork(ibc->output);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	185 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	186
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	187 static int dsync_ibc_stream_send_mail_stream(struct dsync_ibc_stream *ibc)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	188 {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	189 const unsigned char *data;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	190 unsigned char add;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	191 size_t i, size;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	192 int ret;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	193
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	194 while ((ret = i_stream_read_data(ibc->mail_output,
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	195 &data, &size, 0)) > 0) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	196 add = '\0';
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	197 for (i = 0; i < size; i++) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	198 if (data[i] == '\n') {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	199 if ((i == 0 && ibc->mail_output_last != '\r') \|\|
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	200 (i > 0 && data[i-1] != '\r')) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	201 /* missing CR */
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	202 add = '\r';
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	203 break;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	204 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	205 } else if (data[i] == '.' &&
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	206 ((i == 0 && ibc->mail_output_last == '\n') \|\|
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	207 (i > 0 && data[i-1] == '\n'))) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	208 /* escape the dot */
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	209 add = '.';
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	210 break;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	211 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	212 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	213
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	214 if (i > 0) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	215 o_stream_nsend(ibc->output, data, i);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	216 ibc->mail_output_last = data[i-1];
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	217 i_stream_skip(ibc->mail_output, i);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	218 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	219
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	220 if (o_stream_get_buffer_used_size(ibc->output) >= 4096) {
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	221 if ((ret = o_stream_flush(ibc->output)) < 0) {
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	222 dsync_ibc_stream_stop(ibc);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	223 return -1;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	224 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	225 if (ret == 0) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	226 /* continue later */
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	227 o_stream_set_flush_pending(ibc->output, TRUE);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	228 return 0;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	229 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	230 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	231
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	232 if (add != '\0') {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	233 o_stream_nsend(ibc->output, &add, 1);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	234 ibc->mail_output_last = add;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	235 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	236 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	237 i_assert(ret == -1);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	238
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	239 if (ibc->mail_output->stream_errno != 0) {
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	240 i_error("dsync(%s): read(%s) failed: %m",
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	241 ibc->name, i_stream_get_name(ibc->mail_output));
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	242 dsync_ibc_stream_stop(ibc);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	243 return -1;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	244 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	245
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	246 /* finished sending the stream */
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	247 o_stream_nsend_str(ibc->output, "\r\n.\r\n");
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	248 i_stream_unref(&ibc->mail_output);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	249 return 1;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	250 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	251
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	252 static int dsync_ibc_stream_output(struct dsync_ibc_stream *ibc)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	253 {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	254 struct ostream *output = ibc->output;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	255 int ret;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	256
15482 6f940b2bfbe6 dsync: Fixed hang when sending mail stream to remote dsync. Timo Sirainen <tss@iki.fi> parents: 15481 diff changeset	257 o_stream_cork(ibc->output);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	258 if ((ret = o_stream_flush(output)) < 0)
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	259 ret = 1;
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	260 else if (ibc->mail_output != NULL) {
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	261 if (dsync_ibc_stream_send_mail_stream(ibc) < 0)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	262 ret = 1;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	263 }
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	264 timeout_reset(ibc->to);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	265
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	266 if (!dsync_ibc_is_send_queue_full(&ibc->ibc))
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	267 ibc->ibc.io_callback(ibc->ibc.io_context);
15482 6f940b2bfbe6 dsync: Fixed hang when sending mail stream to remote dsync. Timo Sirainen <tss@iki.fi> parents: 15481 diff changeset	268 o_stream_uncork(ibc->output);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	269 return ret;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	270 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	271
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	272 static void dsync_ibc_stream_timeout(struct dsync_ibc_stream *ibc)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	273 {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	274 i_error("dsync(%s): I/O has stalled, no activity for %u seconds",
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	275 ibc->name, DSYNC_IBC_STREAM_TIMEOUT_MSECS/1000);
15986 f6377e089dee dsync: If I/O gets stalled, log the state in which it happened. Timo Sirainen <tss@iki.fi> parents: 15836 diff changeset	276 ibc->ibc.timeout = TRUE;
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	277 dsync_ibc_stream_stop(ibc);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	278 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	279
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	280 static void dsync_ibc_stream_init(struct dsync_ibc_stream *ibc)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	281 {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	282 unsigned int i;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	283
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	284 ibc->io = io_add(ibc->fd_in, IO_READ, dsync_ibc_stream_input, ibc);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	285 o_stream_set_no_error_handling(ibc->output, TRUE);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	286 o_stream_set_flush_callback(ibc->output, dsync_ibc_stream_output, ibc);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	287 ibc->to = timeout_add(DSYNC_IBC_STREAM_TIMEOUT_MSECS,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	288 dsync_ibc_stream_timeout, ibc);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	289 o_stream_cork(ibc->output);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	290 o_stream_nsend_str(ibc->output, DSYNC_HANDSHAKE_VERSION);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	291
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	292 /* initialize serializers and send their headers to remote */
15767 93a8a32adfd8 dsync: Don't log read() failed: EOF when remote intentionally fails early. Timo Sirainen <tss@iki.fi> parents: 15750 diff changeset	293 for (i = ITEM_DONE + 1; i < ITEM_END_OF_LIST; i++) T_BEGIN {
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	294 const char *keys;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	295
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	296 keys = items[i].required_keys == NULL ? items[i].optional_keys :
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	297 t_strconcat(items[i].required_keys, " ",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	298 items[i].optional_keys, NULL);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	299 if (keys != NULL) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	300 i_assert(items[i].chr != '\0');
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	301
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	302 ibc->serializers[i] =
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	303 dsync_serializer_init(t_strsplit_spaces(keys, " "));
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	304 o_stream_nsend(ibc->output, &items[i].chr, 1);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	305 o_stream_nsend_str(ibc->output,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	306 dsync_serializer_encode_header_line(ibc->serializers[i]));
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	307 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	308 } T_END;
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	309 o_stream_nsend_str(ibc->output, ".\n");
15594 5bb80a6491eb dsync: Fixes to handling output stream buffering. Timo Sirainen <tss@iki.fi> parents: 15592 diff changeset	310 o_stream_uncork(ibc->output);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	311 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	312
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	313 static void dsync_ibc_stream_deinit(struct dsync_ibc *_ibc)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	314 {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	315 struct dsync_ibc_stream ibc = (struct dsync_ibc_stream )_ibc;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	316
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	317 if (ibc->cur_decoder != NULL)
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	318 dsync_deserializer_decode_finish(&ibc->cur_decoder);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	319 if (ibc->mail_output != NULL)
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	320 i_stream_unref(&ibc->mail_output);
15767 93a8a32adfd8 dsync: Don't log read() failed: EOF when remote intentionally fails early. Timo Sirainen <tss@iki.fi> parents: 15750 diff changeset	321 else {
93a8a32adfd8 dsync: Don't log read() failed: EOF when remote intentionally fails early. Timo Sirainen <tss@iki.fi> parents: 15750 diff changeset	322 /* notify remote that we're closing. this is mainly to avoid
93a8a32adfd8 dsync: Don't log read() failed: EOF when remote intentionally fails early. Timo Sirainen <tss@iki.fi> parents: 15750 diff changeset	323 "read() failed: EOF" errors on failing dsyncs */
93a8a32adfd8 dsync: Don't log read() failed: EOF when remote intentionally fails early. Timo Sirainen <tss@iki.fi> parents: 15750 diff changeset	324 o_stream_nsend_str(ibc->output,
93a8a32adfd8 dsync: Don't log read() failed: EOF when remote intentionally fails early. Timo Sirainen <tss@iki.fi> parents: 15750 diff changeset	325 t_strdup_printf("%c\n", items[ITEM_DONE].chr));
93a8a32adfd8 dsync: Don't log read() failed: EOF when remote intentionally fails early. Timo Sirainen <tss@iki.fi> parents: 15750 diff changeset	326 o_stream_nfinish(ibc->output);
93a8a32adfd8 dsync: Don't log read() failed: EOF when remote intentionally fails early. Timo Sirainen <tss@iki.fi> parents: 15750 diff changeset	327 }
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	328
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	329 timeout_remove(&ibc->to);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	330 if (ibc->io != NULL)
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	331 io_remove(&ibc->io);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	332 i_stream_destroy(&ibc->input);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	333 o_stream_destroy(&ibc->output);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	334 pool_unref(&ibc->ret_pool);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	335 i_free(ibc->temp_path_prefix);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	336 i_free(ibc->name);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	337 i_free(ibc);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	338 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	339
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	340 static int dsync_ibc_stream_next_line(struct dsync_ibc_stream *ibc,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	341 const char **line_r)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	342 {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	343 const char *line;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	344
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	345 line = i_stream_next_line(ibc->input);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	346 if (line != NULL) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	347 *line_r = line;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	348 return 1;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	349 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	350 /* try reading some */
15592 0949ddc3a892 dsync: Minor fix for talking with remote dsync. Timo Sirainen <tss@iki.fi> parents: 15496 diff changeset	351 if (i_stream_read(ibc->input) == -1) {
15767 93a8a32adfd8 dsync: Don't log read() failed: EOF when remote intentionally fails early. Timo Sirainen <tss@iki.fi> parents: 15750 diff changeset	352 if (ibc->stopped)
93a8a32adfd8 dsync: Don't log read() failed: EOF when remote intentionally fails early. Timo Sirainen <tss@iki.fi> parents: 15750 diff changeset	353 return -1;
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	354 if (ibc->input->stream_errno != 0) {
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	355 errno = ibc->input->stream_errno;
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	356 i_error("read(%s) failed: %m", ibc->name);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	357 } else {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	358 i_assert(ibc->input->eof);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	359 i_error("read(%s) failed: EOF", ibc->name);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	360 }
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	361 dsync_ibc_stream_stop(ibc);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	362 return -1;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	363 }
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	364 *line_r = i_stream_next_line(ibc->input);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	365 if (*line_r == NULL) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	366 ibc->has_pending_data = FALSE;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	367 return 0;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	368 }
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	369 ibc->has_pending_data = TRUE;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	370 return 1;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	371 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	372
14629 c93ca5e46a8a Marked functions parameters that are allowed to be NULL. Some APIs were also changed. Timo Sirainen <tss@iki.fi> parents: 14584 diff changeset	373 static void ATTR_FORMAT(3, 4) ATTR_NULL(2)
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	374 dsync_ibc_input_error(struct dsync_ibc_stream *ibc,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	375 struct dsync_deserializer_decoder *decoder,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	376 const char *fmt, ...)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	377 {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	378 va_list args;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	379 const char *error;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	380
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	381 va_start(args, fmt);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	382 error = t_strdup_vprintf(fmt, args);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	383 if (decoder == NULL)
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	384 i_error("dsync(%s): %s", ibc->name, error);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	385 else {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	386 i_error("dsync(%s): %s: %s", ibc->name,
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	387 dsync_deserializer_decoder_get_name(decoder), error);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	388 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	389 va_end(args);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	390
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	391 dsync_ibc_stream_stop(ibc);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	392 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	393
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	394 static void
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	395 dsync_ibc_stream_send_string(struct dsync_ibc_stream *ibc,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	396 const string_t *str)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	397 {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	398 i_assert(ibc->mail_output == NULL);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	399 o_stream_nsend(ibc->output, str_data(str), str_len(str));
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	400 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	401
15036 5943cace4e05 dsync: Renamed "io" slave to "stream". Timo Sirainen <tss@iki.fi> parents: 15035 diff changeset	402 static int
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	403 dsync_ibc_check_missing_deserializers(struct dsync_ibc_stream *ibc)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	404 {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	405 unsigned int i;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	406 int ret = 0;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	407
15767 93a8a32adfd8 dsync: Don't log read() failed: EOF when remote intentionally fails early. Timo Sirainen <tss@iki.fi> parents: 15750 diff changeset	408 for (i = ITEM_DONE + 1; i < ITEM_END_OF_LIST; i++) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	409 if (ibc->deserializers[i] == NULL &&
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	410 (items[i].required_keys != NULL \|\|
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	411 items[i].optional_keys != NULL)) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	412 dsync_ibc_input_error(ibc, NULL,
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	413 "Remote didn't handshake deserializer for %s",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	414 items[i].name);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	415 ret = -1;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	416 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	417 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	418 return ret;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	419 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	420
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	421 static bool
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	422 dsync_ibc_stream_handshake(struct dsync_ibc_stream ibc, const char line)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	423 {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	424 enum item_type item = ITEM_NONE;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	425 const char const required_keys, *error;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	426 unsigned int i;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	427
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	428 if (ibc->handshake_received)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	429 return TRUE;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	430
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	431 if (!ibc->version_received) {
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	432 if (!version_string_verify(line, "dsync",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	433 DSYNC_PROTOCOL_VERSION_MAJOR)) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	434 dsync_ibc_input_error(ibc, NULL,
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	435 "Remote dsync doesn't use compatible protocol");
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	436 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	437 }
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	438 ibc->version_received = TRUE;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	439 return FALSE;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	440 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	441
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	442 if (strcmp(line, END_OF_LIST_LINE) == 0) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	443 /* finished handshaking */
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	444 if (dsync_ibc_check_missing_deserializers(ibc) < 0)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	445 return FALSE;
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	446 ibc->handshake_received = TRUE;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	447 return FALSE;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	448 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	449
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	450 for (i = 1; i < ITEM_END_OF_LIST; i++) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	451 if (items[i].chr == line[0]) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	452 item = i;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	453 break;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	454 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	455 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	456 if (item == ITEM_NONE) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	457 /* unknown deserializer, ignore */
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	458 return FALSE;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	459 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	460
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	461 required_keys = items[item].required_keys == NULL ? NULL :
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	462 t_strsplit(items[item].required_keys, " ");
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	463 if (dsync_deserializer_init(items[item].name,
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	464 required_keys, line + 1,
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	465 &ibc->deserializers[item], &error) < 0) {
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	466 dsync_ibc_input_error(ibc, NULL,
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	467 "Remote sent invalid handshake for %s: %s",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	468 items[item].name, error);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	469 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	470 return FALSE;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	471 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	472
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	473 static enum dsync_ibc_recv_ret
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	474 dsync_ibc_stream_input_next(struct dsync_ibc_stream *ibc, enum item_type item,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	475 struct dsync_deserializer_decoder **decoder_r)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	476 {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	477 enum item_type line_item = ITEM_NONE;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	478 const char line, error;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	479 unsigned int i;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	480
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	481 i_assert(ibc->mail_input == NULL);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	482
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	483 timeout_reset(ibc->to);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	484
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	485 do {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	486 if (dsync_ibc_stream_next_line(ibc, &line) <= 0)
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	487 return DSYNC_IBC_RECV_RET_TRYAGAIN;
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	488 } while (!dsync_ibc_stream_handshake(ibc, line));
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	489
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	490 if (strcmp(line, END_OF_LIST_LINE) == 0) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	491 /* end of this list */
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	492 return DSYNC_IBC_RECV_RET_FINISHED;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	493 }
15767 93a8a32adfd8 dsync: Don't log read() failed: EOF when remote intentionally fails early. Timo Sirainen <tss@iki.fi> parents: 15750 diff changeset	494 if (line[0] == items[ITEM_DONE].chr) {
93a8a32adfd8 dsync: Don't log read() failed: EOF when remote intentionally fails early. Timo Sirainen <tss@iki.fi> parents: 15750 diff changeset	495 /* remote cleanly closed the connection, possibly because of
93a8a32adfd8 dsync: Don't log read() failed: EOF when remote intentionally fails early. Timo Sirainen <tss@iki.fi> parents: 15750 diff changeset	496 some failure (which it should have logged). we don't want to
93a8a32adfd8 dsync: Don't log read() failed: EOF when remote intentionally fails early. Timo Sirainen <tss@iki.fi> parents: 15750 diff changeset	497 log any stream errors anyway after this. */
93a8a32adfd8 dsync: Don't log read() failed: EOF when remote intentionally fails early. Timo Sirainen <tss@iki.fi> parents: 15750 diff changeset	498 dsync_ibc_stream_stop(ibc);
93a8a32adfd8 dsync: Don't log read() failed: EOF when remote intentionally fails early. Timo Sirainen <tss@iki.fi> parents: 15750 diff changeset	499 return DSYNC_IBC_RECV_RET_TRYAGAIN;
93a8a32adfd8 dsync: Don't log read() failed: EOF when remote intentionally fails early. Timo Sirainen <tss@iki.fi> parents: 15750 diff changeset	500
93a8a32adfd8 dsync: Don't log read() failed: EOF when remote intentionally fails early. Timo Sirainen <tss@iki.fi> parents: 15750 diff changeset	501 }
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	502 for (i = 1; i < ITEM_END_OF_LIST; i++) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	503 if (*line == items[i].chr) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	504 line_item = i;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	505 break;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	506 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	507 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	508 if (line_item != item) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	509 dsync_ibc_input_error(ibc, NULL,
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	510 "Received unexpected input %c != %c",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	511 *line, items[item].chr);
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	512 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	513 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	514
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	515 if (ibc->cur_decoder != NULL)
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	516 dsync_deserializer_decode_finish(&ibc->cur_decoder);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	517 if (dsync_deserializer_decode_begin(ibc->deserializers[item],
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	518 line+1, &ibc->cur_decoder,
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	519 &error) < 0) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	520 dsync_ibc_input_error(ibc, NULL, "Invalid input to %s: %s",
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	521 items[item].name, error);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	522 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	523 }
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	524 *decoder_r = ibc->cur_decoder;
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	525 return DSYNC_IBC_RECV_RET_OK;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	526 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	527
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	528 static void
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	529 dsync_ibc_stream_send_handshake(struct dsync_ibc *_ibc,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	530 const struct dsync_ibc_settings *set)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	531 {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	532 struct dsync_ibc_stream ibc = (struct dsync_ibc_stream )_ibc;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	533 struct dsync_serializer_encoder *encoder;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	534 string_t *str = t_str_new(128);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	535 char sync_type[2];
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	536
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	537 str_append_c(str, items[ITEM_HANDSHAKE].chr);
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	538 encoder = dsync_serializer_encode_begin(ibc->serializers[ITEM_HANDSHAKE]);
15782 6f024e0289da dsync: -l parameter locking is now done on the server with "lower" hostname. Timo Sirainen <tss@iki.fi> parents: 15767 diff changeset	539 dsync_serializer_encode_add(encoder, "hostname", set->hostname);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	540 if (set->sync_ns_prefix != NULL) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	541 dsync_serializer_encode_add(encoder, "sync_ns_prefix",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	542 set->sync_ns_prefix);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	543 }
15471 88ac919f8afe dsync: Added back support for syncing only one mailbox (-m parameter) Timo Sirainen <tss@iki.fi> parents: 15470 diff changeset	544 if (set->sync_box != NULL)
88ac919f8afe dsync: Added back support for syncing only one mailbox (-m parameter) Timo Sirainen <tss@iki.fi> parents: 15470 diff changeset	545 dsync_serializer_encode_add(encoder, "sync_box", set->sync_box);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	546
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	547 sync_type[0] = sync_type[1] = '\0';
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	548 switch (set->sync_type) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	549 case DSYNC_BRAIN_SYNC_TYPE_UNKNOWN:
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	550 break;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	551 case DSYNC_BRAIN_SYNC_TYPE_FULL:
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	552 sync_type[0] = 'f';
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	553 break;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	554 case DSYNC_BRAIN_SYNC_TYPE_CHANGED:
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	555 sync_type[0] = 'c';
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	556 break;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	557 case DSYNC_BRAIN_SYNC_TYPE_STATE:
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	558 sync_type[0] = 's';
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	559 break;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	560 }
15782 6f024e0289da dsync: -l parameter locking is now done on the server with "lower" hostname. Timo Sirainen <tss@iki.fi> parents: 15767 diff changeset	561 if (sync_type[0] != '\0')
6f024e0289da dsync: -l parameter locking is now done on the server with "lower" hostname. Timo Sirainen <tss@iki.fi> parents: 15767 diff changeset	562 dsync_serializer_encode_add(encoder, "sync_type", sync_type);
6f024e0289da dsync: -l parameter locking is now done on the server with "lower" hostname. Timo Sirainen <tss@iki.fi> parents: 15767 diff changeset	563 if (set->lock_timeout > 0) {
6f024e0289da dsync: -l parameter locking is now done on the server with "lower" hostname. Timo Sirainen <tss@iki.fi> parents: 15767 diff changeset	564 dsync_serializer_encode_add(encoder, "lock_timeout",
6f024e0289da dsync: -l parameter locking is now done on the server with "lower" hostname. Timo Sirainen <tss@iki.fi> parents: 15767 diff changeset	565 t_strdup_printf("%u", set->lock_timeout));
6f024e0289da dsync: -l parameter locking is now done on the server with "lower" hostname. Timo Sirainen <tss@iki.fi> parents: 15767 diff changeset	566 }
15744 b4e2b3b54f0a dsync: Renamed "guid_requests" to "mail_requests" Timo Sirainen <tss@iki.fi> parents: 15715 diff changeset	567 if ((set->brain_flags & DSYNC_BRAIN_FLAG_SEND_MAIL_REQUESTS) != 0)
b4e2b3b54f0a dsync: Renamed "guid_requests" to "mail_requests" Timo Sirainen <tss@iki.fi> parents: 15715 diff changeset	568 dsync_serializer_encode_add(encoder, "send_mail_requests", "");
15231 454d0563927d doveadm: "backup" command is working again. Timo Sirainen <tss@iki.fi> parents: 15068 diff changeset	569 if ((set->brain_flags & DSYNC_BRAIN_FLAG_BACKUP_SEND) != 0)
454d0563927d doveadm: "backup" command is working again. Timo Sirainen <tss@iki.fi> parents: 15068 diff changeset	570 dsync_serializer_encode_add(encoder, "backup_send", "");
454d0563927d doveadm: "backup" command is working again. Timo Sirainen <tss@iki.fi> parents: 15068 diff changeset	571 if ((set->brain_flags & DSYNC_BRAIN_FLAG_BACKUP_RECV) != 0)
454d0563927d doveadm: "backup" command is working again. Timo Sirainen <tss@iki.fi> parents: 15068 diff changeset	572 dsync_serializer_encode_add(encoder, "backup_recv", "");
15464 af3b86a16ac3 dsync: Added debugging and rawlogging support. Timo Sirainen <tss@iki.fi> parents: 15463 diff changeset	573 if ((set->brain_flags & DSYNC_BRAIN_FLAG_DEBUG) != 0)
af3b86a16ac3 dsync: Added debugging and rawlogging support. Timo Sirainen <tss@iki.fi> parents: 15463 diff changeset	574 dsync_serializer_encode_add(encoder, "debug", "");
15836 607758d425e7 dsync: Renamed -a parameter to -N. It also now skips invisible namespaces. Timo Sirainen <tss@iki.fi> parents: 15783 diff changeset	575 if ((set->brain_flags & DSYNC_BRAIN_FLAG_SYNC_VISIBLE_NAMESPACES) != 0)
607758d425e7 dsync: Renamed -a parameter to -N. It also now skips invisible namespaces. Timo Sirainen <tss@iki.fi> parents: 15783 diff changeset	576 dsync_serializer_encode_add(encoder, "sync_visible_namespaces", "");
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	577
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	578 dsync_serializer_encode_finish(&encoder, str);
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	579 dsync_ibc_stream_send_string(ibc, str);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	580 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	581
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	582 static enum dsync_ibc_recv_ret
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	583 dsync_ibc_stream_recv_handshake(struct dsync_ibc *_ibc,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	584 const struct dsync_ibc_settings **set_r)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	585 {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	586 struct dsync_ibc_stream ibc = (struct dsync_ibc_stream )_ibc;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	587 struct dsync_deserializer_decoder *decoder;
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	588 struct dsync_ibc_settings *set;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	589 const char *value;
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	590 pool_t pool = ibc->ret_pool;
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	591 enum dsync_ibc_recv_ret ret;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	592
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	593 ret = dsync_ibc_stream_input_next(ibc, ITEM_HANDSHAKE, &decoder);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	594 if (ret != DSYNC_IBC_RECV_RET_OK) {
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	595 if (ret != DSYNC_IBC_RECV_RET_TRYAGAIN) {
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	596 i_error("dsync(%s): Unexpected input in handshake",
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	597 ibc->name);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	598 dsync_ibc_stream_stop(ibc);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	599 }
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	600 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	601 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	602
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	603 p_clear(pool);
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	604 set = p_new(pool, struct dsync_ibc_settings, 1);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	605
15782 6f024e0289da dsync: -l parameter locking is now done on the server with "lower" hostname. Timo Sirainen <tss@iki.fi> parents: 15767 diff changeset	606 value = dsync_deserializer_decode_get(decoder, "hostname");
6f024e0289da dsync: -l parameter locking is now done on the server with "lower" hostname. Timo Sirainen <tss@iki.fi> parents: 15767 diff changeset	607 set->hostname = p_strdup(pool, value);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	608 if (dsync_deserializer_decode_try(decoder, "sync_ns_prefix", &value))
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	609 set->sync_ns_prefix = p_strdup(pool, value);
15471 88ac919f8afe dsync: Added back support for syncing only one mailbox (-m parameter) Timo Sirainen <tss@iki.fi> parents: 15470 diff changeset	610 if (dsync_deserializer_decode_try(decoder, "sync_box", &value))
88ac919f8afe dsync: Added back support for syncing only one mailbox (-m parameter) Timo Sirainen <tss@iki.fi> parents: 15470 diff changeset	611 set->sync_box = p_strdup(pool, value);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	612 if (dsync_deserializer_decode_try(decoder, "sync_type", &value)) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	613 switch (value[0]) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	614 case 'f':
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	615 set->sync_type = DSYNC_BRAIN_SYNC_TYPE_FULL;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	616 break;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	617 case 'c':
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	618 set->sync_type = DSYNC_BRAIN_SYNC_TYPE_CHANGED;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	619 break;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	620 case 's':
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	621 set->sync_type = DSYNC_BRAIN_SYNC_TYPE_STATE;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	622 break;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	623 default:
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	624 dsync_ibc_input_error(ibc, decoder,
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	625 "Unknown sync_type: %s", value);
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	626 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	627 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	628 }
15782 6f024e0289da dsync: -l parameter locking is now done on the server with "lower" hostname. Timo Sirainen <tss@iki.fi> parents: 15767 diff changeset	629 if (dsync_deserializer_decode_try(decoder, "lock_timeout", &value)) {
6f024e0289da dsync: -l parameter locking is now done on the server with "lower" hostname. Timo Sirainen <tss@iki.fi> parents: 15767 diff changeset	630 if (str_to_uint(value, &set->lock_timeout) < 0 \|\|
6f024e0289da dsync: -l parameter locking is now done on the server with "lower" hostname. Timo Sirainen <tss@iki.fi> parents: 15767 diff changeset	631 set->lock_timeout == 0) {
6f024e0289da dsync: -l parameter locking is now done on the server with "lower" hostname. Timo Sirainen <tss@iki.fi> parents: 15767 diff changeset	632 dsync_ibc_input_error(ibc, decoder,
6f024e0289da dsync: -l parameter locking is now done on the server with "lower" hostname. Timo Sirainen <tss@iki.fi> parents: 15767 diff changeset	633 "Invalid lock_timeout: %s", value);
6f024e0289da dsync: -l parameter locking is now done on the server with "lower" hostname. Timo Sirainen <tss@iki.fi> parents: 15767 diff changeset	634 return DSYNC_IBC_RECV_RET_TRYAGAIN;
6f024e0289da dsync: -l parameter locking is now done on the server with "lower" hostname. Timo Sirainen <tss@iki.fi> parents: 15767 diff changeset	635 }
6f024e0289da dsync: -l parameter locking is now done on the server with "lower" hostname. Timo Sirainen <tss@iki.fi> parents: 15767 diff changeset	636 }
15744 b4e2b3b54f0a dsync: Renamed "guid_requests" to "mail_requests" Timo Sirainen <tss@iki.fi> parents: 15715 diff changeset	637 if (dsync_deserializer_decode_try(decoder, "send_mail_requests", &value))
b4e2b3b54f0a dsync: Renamed "guid_requests" to "mail_requests" Timo Sirainen <tss@iki.fi> parents: 15715 diff changeset	638 set->brain_flags \|= DSYNC_BRAIN_FLAG_SEND_MAIL_REQUESTS;
15231 454d0563927d doveadm: "backup" command is working again. Timo Sirainen <tss@iki.fi> parents: 15068 diff changeset	639 if (dsync_deserializer_decode_try(decoder, "backup_send", &value))
454d0563927d doveadm: "backup" command is working again. Timo Sirainen <tss@iki.fi> parents: 15068 diff changeset	640 set->brain_flags \|= DSYNC_BRAIN_FLAG_BACKUP_SEND;
454d0563927d doveadm: "backup" command is working again. Timo Sirainen <tss@iki.fi> parents: 15068 diff changeset	641 if (dsync_deserializer_decode_try(decoder, "backup_recv", &value))
454d0563927d doveadm: "backup" command is working again. Timo Sirainen <tss@iki.fi> parents: 15068 diff changeset	642 set->brain_flags \|= DSYNC_BRAIN_FLAG_BACKUP_RECV;
15464 af3b86a16ac3 dsync: Added debugging and rawlogging support. Timo Sirainen <tss@iki.fi> parents: 15463 diff changeset	643 if (dsync_deserializer_decode_try(decoder, "debug", &value))
af3b86a16ac3 dsync: Added debugging and rawlogging support. Timo Sirainen <tss@iki.fi> parents: 15463 diff changeset	644 set->brain_flags \|= DSYNC_BRAIN_FLAG_DEBUG;
15836 607758d425e7 dsync: Renamed -a parameter to -N. It also now skips invisible namespaces. Timo Sirainen <tss@iki.fi> parents: 15783 diff changeset	645 if (dsync_deserializer_decode_try(decoder, "sync_visible_namespaces", &value))
607758d425e7 dsync: Renamed -a parameter to -N. It also now skips invisible namespaces. Timo Sirainen <tss@iki.fi> parents: 15783 diff changeset	646 set->brain_flags \|= DSYNC_BRAIN_FLAG_SYNC_VISIBLE_NAMESPACES;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	647
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	648 *set_r = set;
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	649 return DSYNC_IBC_RECV_RET_OK;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	650 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	651
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	652 static void
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	653 dsync_ibc_stream_send_end_of_list(struct dsync_ibc *_ibc)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	654 {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	655 struct dsync_ibc_stream ibc = (struct dsync_ibc_stream )_ibc;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	656
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	657 i_assert(ibc->mail_output == NULL);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	658
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	659 o_stream_nsend_str(ibc->output, END_OF_LIST_LINE"\n");
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	660 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	661
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	662 static void
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	663 dsync_ibc_stream_send_mailbox_state(struct dsync_ibc *_ibc,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	664 const struct dsync_mailbox_state *state)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	665 {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	666 struct dsync_ibc_stream ibc = (struct dsync_ibc_stream )_ibc;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	667 struct dsync_serializer_encoder *encoder;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	668 string_t *str = t_str_new(128);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	669
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	670 str_append_c(str, items[ITEM_MAILBOX_STATE].chr);
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	671 encoder = dsync_serializer_encode_begin(ibc->serializers[ITEM_MAILBOX_STATE]);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	672 dsync_serializer_encode_add(encoder, "mailbox_guid",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	673 guid_128_to_string(state->mailbox_guid));
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	674 dsync_serializer_encode_add(encoder, "last_uidvalidity",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	675 dec2str(state->last_uidvalidity));
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	676 dsync_serializer_encode_add(encoder, "last_common_uid",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	677 dec2str(state->last_common_uid));
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	678 dsync_serializer_encode_add(encoder, "last_common_modseq",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	679 dec2str(state->last_common_modseq));
15496 5d90e2aa1ba8 dsync: Use private modseqs to support syncing private flags in shared mailboxes. Timo Sirainen <tss@iki.fi> parents: 15494 diff changeset	680 dsync_serializer_encode_add(encoder, "last_common_pvt_modseq",
5d90e2aa1ba8 dsync: Use private modseqs to support syncing private flags in shared mailboxes. Timo Sirainen <tss@iki.fi> parents: 15494 diff changeset	681 dec2str(state->last_common_pvt_modseq));
15783 502a50925641 dsync: Merge last-common-* values from both local and remote when they differ. Timo Sirainen <tss@iki.fi> parents: 15782 diff changeset	682 if (state->changes_during_sync)
502a50925641 dsync: Merge last-common-* values from both local and remote when they differ. Timo Sirainen <tss@iki.fi> parents: 15782 diff changeset	683 dsync_serializer_encode_add(encoder, "changes_during_sync", "");
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	684
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	685 dsync_serializer_encode_finish(&encoder, str);
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	686 dsync_ibc_stream_send_string(ibc, str);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	687 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	688
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	689 static enum dsync_ibc_recv_ret
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	690 dsync_ibc_stream_recv_mailbox_state(struct dsync_ibc *_ibc,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	691 struct dsync_mailbox_state *state_r)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	692 {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	693 struct dsync_ibc_stream ibc = (struct dsync_ibc_stream )_ibc;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	694 struct dsync_deserializer_decoder *decoder;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	695 const char *value;
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	696 enum dsync_ibc_recv_ret ret;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	697
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	698 memset(state_r, 0, sizeof(*state_r));
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	699
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	700 ret = dsync_ibc_stream_input_next(ibc, ITEM_MAILBOX_STATE, &decoder);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	701 if (ret != DSYNC_IBC_RECV_RET_OK)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	702 return ret;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	703
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	704 value = dsync_deserializer_decode_get(decoder, "mailbox_guid");
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	705 if (guid_128_from_string(value, state_r->mailbox_guid) < 0) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	706 dsync_ibc_input_error(ibc, decoder, "Invalid mailbox_guid");
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	707 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	708 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	709 value = dsync_deserializer_decode_get(decoder, "last_uidvalidity");
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	710 if (str_to_uint32(value, &state_r->last_uidvalidity) < 0) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	711 dsync_ibc_input_error(ibc, decoder, "Invalid last_uidvalidity");
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	712 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	713 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	714 value = dsync_deserializer_decode_get(decoder, "last_common_uid");
15494 b7d8027a8f74 dsync: Fixed parsing mailbox state from remote dsync. Timo Sirainen <tss@iki.fi> parents: 15483 diff changeset	715 if (str_to_uint32(value, &state_r->last_common_uid) < 0) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	716 dsync_ibc_input_error(ibc, decoder, "Invalid last_common_uid");
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	717 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	718 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	719 value = dsync_deserializer_decode_get(decoder, "last_common_modseq");
15494 b7d8027a8f74 dsync: Fixed parsing mailbox state from remote dsync. Timo Sirainen <tss@iki.fi> parents: 15483 diff changeset	720 if (str_to_uint64(value, &state_r->last_common_modseq) < 0) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	721 dsync_ibc_input_error(ibc, decoder, "Invalid last_common_modseq");
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	722 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	723 }
15496 5d90e2aa1ba8 dsync: Use private modseqs to support syncing private flags in shared mailboxes. Timo Sirainen <tss@iki.fi> parents: 15494 diff changeset	724 value = dsync_deserializer_decode_get(decoder, "last_common_pvt_modseq");
5d90e2aa1ba8 dsync: Use private modseqs to support syncing private flags in shared mailboxes. Timo Sirainen <tss@iki.fi> parents: 15494 diff changeset	725 if (str_to_uint64(value, &state_r->last_common_pvt_modseq) < 0) {
5d90e2aa1ba8 dsync: Use private modseqs to support syncing private flags in shared mailboxes. Timo Sirainen <tss@iki.fi> parents: 15494 diff changeset	726 dsync_ibc_input_error(ibc, decoder, "Invalid last_common_pvt_modseq");
5d90e2aa1ba8 dsync: Use private modseqs to support syncing private flags in shared mailboxes. Timo Sirainen <tss@iki.fi> parents: 15494 diff changeset	727 return DSYNC_IBC_RECV_RET_TRYAGAIN;
5d90e2aa1ba8 dsync: Use private modseqs to support syncing private flags in shared mailboxes. Timo Sirainen <tss@iki.fi> parents: 15494 diff changeset	728 }
15783 502a50925641 dsync: Merge last-common-* values from both local and remote when they differ. Timo Sirainen <tss@iki.fi> parents: 15782 diff changeset	729 if (dsync_deserializer_decode_try(decoder, "changes_during_sync", &value))
502a50925641 dsync: Merge last-common-* values from both local and remote when they differ. Timo Sirainen <tss@iki.fi> parents: 15782 diff changeset	730 state_r->changes_during_sync = TRUE;
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	731 return DSYNC_IBC_RECV_RET_OK;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	732 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	733
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	734 static void
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	735 dsync_ibc_stream_send_mailbox_tree_node(struct dsync_ibc *_ibc,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	736 const char const name,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	737 const struct dsync_mailbox_node *node)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	738 {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	739 struct dsync_ibc_stream ibc = (struct dsync_ibc_stream )_ibc;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	740 struct dsync_serializer_encoder *encoder;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	741 string_t str, namestr;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	742
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	743 i_assert(*name != NULL);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	744
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	745 str = t_str_new(128);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	746 str_append_c(str, items[ITEM_MAILBOX_TREE_NODE].chr);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	747
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	748 /* convert all hierarchy separators to tabs. mailbox names really
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	749 aren't supposed to have any tabs, but escape them anyway if there
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	750 are. */
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	751 namestr = t_str_new(128);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	752 for (; *name != NULL; name++) {
15068 002e0a120c2a Renamed str_tabescape_write() to str_append_tabescaped() Timo Sirainen <tss@iki.fi> parents: 15037 diff changeset	753 str_append_tabescaped(namestr, *name);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	754 str_append_c(namestr, '\t');
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	755 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	756 str_truncate(namestr, str_len(namestr)-1);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	757
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	758 encoder = dsync_serializer_encode_begin(ibc->serializers[ITEM_MAILBOX_TREE_NODE]);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	759 dsync_serializer_encode_add(encoder, "name", str_c(namestr));
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	760 switch (node->existence) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	761 case DSYNC_MAILBOX_NODE_NONEXISTENT:
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	762 dsync_serializer_encode_add(encoder, "existence", "n");
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	763 break;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	764 case DSYNC_MAILBOX_NODE_EXISTS:
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	765 dsync_serializer_encode_add(encoder, "existence", "y");
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	766 break;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	767 case DSYNC_MAILBOX_NODE_DELETED:
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	768 dsync_serializer_encode_add(encoder, "existence", "d");
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	769 break;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	770 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	771
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	772 if (!guid_128_is_empty(node->mailbox_guid)) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	773 dsync_serializer_encode_add(encoder, "mailbox_guid",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	774 guid_128_to_string(node->mailbox_guid));
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	775 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	776 if (node->uid_validity != 0) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	777 dsync_serializer_encode_add(encoder, "uid_validity",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	778 dec2str(node->uid_validity));
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	779 }
15231 454d0563927d doveadm: "backup" command is working again. Timo Sirainen <tss@iki.fi> parents: 15068 diff changeset	780 if (node->uid_next != 0) {
454d0563927d doveadm: "backup" command is working again. Timo Sirainen <tss@iki.fi> parents: 15068 diff changeset	781 dsync_serializer_encode_add(encoder, "uid_next",
454d0563927d doveadm: "backup" command is working again. Timo Sirainen <tss@iki.fi> parents: 15068 diff changeset	782 dec2str(node->uid_next));
454d0563927d doveadm: "backup" command is working again. Timo Sirainen <tss@iki.fi> parents: 15068 diff changeset	783 }
15035 0af20585964d dsync: Rewritten syncing for mailbox renames. Timo Sirainen <tss@iki.fi> parents: 14691 diff changeset	784 if (node->last_renamed_or_created != 0) {
0af20585964d dsync: Rewritten syncing for mailbox renames. Timo Sirainen <tss@iki.fi> parents: 14691 diff changeset	785 dsync_serializer_encode_add(encoder, "last_renamed_or_created",
0af20585964d dsync: Rewritten syncing for mailbox renames. Timo Sirainen <tss@iki.fi> parents: 14691 diff changeset	786 dec2str(node->last_renamed_or_created));
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	787 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	788 if (node->last_subscription_change != 0) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	789 dsync_serializer_encode_add(encoder, "last_subscription_change",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	790 dec2str(node->last_subscription_change));
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	791 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	792 if (node->subscribed)
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	793 dsync_serializer_encode_add(encoder, "subscribed", "");
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	794 dsync_serializer_encode_finish(&encoder, str);
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	795 dsync_ibc_stream_send_string(ibc, str);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	796 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	797
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	798 static enum dsync_ibc_recv_ret
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	799 dsync_ibc_stream_recv_mailbox_tree_node(struct dsync_ibc *_ibc,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	800 const char const *name_r,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	801 const struct dsync_mailbox_node **node_r)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	802 {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	803 struct dsync_ibc_stream ibc = (struct dsync_ibc_stream )_ibc;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	804 struct dsync_deserializer_decoder *decoder;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	805 struct dsync_mailbox_node *node;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	806 const char *value;
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	807 enum dsync_ibc_recv_ret ret;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	808
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	809 ret = dsync_ibc_stream_input_next(ibc, ITEM_MAILBOX_TREE_NODE, &decoder);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	810 if (ret != DSYNC_IBC_RECV_RET_OK)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	811 return ret;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	812
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	813 p_clear(ibc->ret_pool);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	814 node = p_new(ibc->ret_pool, struct dsync_mailbox_node, 1);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	815
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	816 value = dsync_deserializer_decode_get(decoder, "name");
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	817 if (*value == '\0') {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	818 dsync_ibc_input_error(ibc, decoder, "Empty name");
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	819 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	820 }
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	821 name_r = (void )p_strsplit_tabescaped(ibc->ret_pool, value);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	822
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	823 value = dsync_deserializer_decode_get(decoder, "existence");
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	824 switch (*value) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	825 case 'n':
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	826 node->existence = DSYNC_MAILBOX_NODE_NONEXISTENT;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	827 break;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	828 case 'y':
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	829 node->existence = DSYNC_MAILBOX_NODE_EXISTS;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	830 break;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	831 case 'd':
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	832 node->existence = DSYNC_MAILBOX_NODE_DELETED;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	833 break;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	834 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	835
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	836 if (dsync_deserializer_decode_try(decoder, "mailbox_guid", &value) &&
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	837 guid_128_from_string(value, node->mailbox_guid) < 0) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	838 dsync_ibc_input_error(ibc, decoder, "Invalid mailbox_guid");
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	839 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	840 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	841 if (dsync_deserializer_decode_try(decoder, "uid_validity", &value) &&
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	842 str_to_uint32(value, &node->uid_validity) < 0) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	843 dsync_ibc_input_error(ibc, decoder, "Invalid uid_validity");
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	844 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	845 }
15231 454d0563927d doveadm: "backup" command is working again. Timo Sirainen <tss@iki.fi> parents: 15068 diff changeset	846 if (dsync_deserializer_decode_try(decoder, "uid_next", &value) &&
454d0563927d doveadm: "backup" command is working again. Timo Sirainen <tss@iki.fi> parents: 15068 diff changeset	847 str_to_uint32(value, &node->uid_next) < 0) {
454d0563927d doveadm: "backup" command is working again. Timo Sirainen <tss@iki.fi> parents: 15068 diff changeset	848 dsync_ibc_input_error(ibc, decoder, "Invalid uid_next");
454d0563927d doveadm: "backup" command is working again. Timo Sirainen <tss@iki.fi> parents: 15068 diff changeset	849 return DSYNC_IBC_RECV_RET_TRYAGAIN;
454d0563927d doveadm: "backup" command is working again. Timo Sirainen <tss@iki.fi> parents: 15068 diff changeset	850 }
15035 0af20585964d dsync: Rewritten syncing for mailbox renames. Timo Sirainen <tss@iki.fi> parents: 14691 diff changeset	851 if (dsync_deserializer_decode_try(decoder, "last_renamed_or_created", &value) &&
0af20585964d dsync: Rewritten syncing for mailbox renames. Timo Sirainen <tss@iki.fi> parents: 14691 diff changeset	852 str_to_time(value, &node->last_renamed_or_created) < 0) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	853 dsync_ibc_input_error(ibc, decoder, "Invalid last_renamed_or_created");
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	854 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	855 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	856 if (dsync_deserializer_decode_try(decoder, "last_subscription_change", &value) &&
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	857 str_to_time(value, &node->last_subscription_change) < 0) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	858 dsync_ibc_input_error(ibc, decoder, "Invalid last_subscription_change");
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	859 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	860 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	861 if (dsync_deserializer_decode_try(decoder, "subscribed", &value))
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	862 node->subscribed = TRUE;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	863
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	864 *node_r = node;
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	865 return DSYNC_IBC_RECV_RET_OK;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	866 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	867
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	868 static void
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	869 dsync_ibc_stream_send_mailbox_deletes(struct dsync_ibc *_ibc,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	870 const struct dsync_mailbox_delete *deletes,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	871 unsigned int count, char hierarchy_sep)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	872 {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	873 struct dsync_ibc_stream ibc = (struct dsync_ibc_stream )_ibc;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	874 struct dsync_serializer_encoder *encoder;
15035 0af20585964d dsync: Rewritten syncing for mailbox renames. Timo Sirainen <tss@iki.fi> parents: 14691 diff changeset	875 string_t str, substr;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	876 char sep[2];
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	877 unsigned int i;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	878
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	879 str = t_str_new(128);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	880 str_append_c(str, items[ITEM_MAILBOX_DELETE].chr);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	881
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	882 encoder = dsync_serializer_encode_begin(ibc->serializers[ITEM_MAILBOX_DELETE]);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	883 sep[0] = hierarchy_sep; sep[1] = '\0';
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	884 dsync_serializer_encode_add(encoder, "hierarchy_sep", sep);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	885
15035 0af20585964d dsync: Rewritten syncing for mailbox renames. Timo Sirainen <tss@iki.fi> parents: 14691 diff changeset	886 substr = t_str_new(128);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	887 for (i = 0; i < count; i++) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	888 if (deletes[i].delete_mailbox) {
15035 0af20585964d dsync: Rewritten syncing for mailbox renames. Timo Sirainen <tss@iki.fi> parents: 14691 diff changeset	889 str_append(substr, guid_128_to_string(deletes[i].guid));
0af20585964d dsync: Rewritten syncing for mailbox renames. Timo Sirainen <tss@iki.fi> parents: 14691 diff changeset	890 str_printfa(substr, " %ld ", (long)deletes[i].timestamp);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	891 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	892 }
15035 0af20585964d dsync: Rewritten syncing for mailbox renames. Timo Sirainen <tss@iki.fi> parents: 14691 diff changeset	893 if (str_len(substr) > 0) {
0af20585964d dsync: Rewritten syncing for mailbox renames. Timo Sirainen <tss@iki.fi> parents: 14691 diff changeset	894 str_truncate(substr, str_len(substr)-1);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	895 dsync_serializer_encode_add(encoder, "mailboxes",
15035 0af20585964d dsync: Rewritten syncing for mailbox renames. Timo Sirainen <tss@iki.fi> parents: 14691 diff changeset	896 str_c(substr));
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	897 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	898
15035 0af20585964d dsync: Rewritten syncing for mailbox renames. Timo Sirainen <tss@iki.fi> parents: 14691 diff changeset	899 str_truncate(substr, 0);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	900 for (i = 0; i < count; i++) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	901 if (!deletes[i].delete_mailbox) {
15035 0af20585964d dsync: Rewritten syncing for mailbox renames. Timo Sirainen <tss@iki.fi> parents: 14691 diff changeset	902 str_append(substr, guid_128_to_string(deletes[i].guid));
0af20585964d dsync: Rewritten syncing for mailbox renames. Timo Sirainen <tss@iki.fi> parents: 14691 diff changeset	903 str_printfa(substr, " %ld ", (long)deletes[i].timestamp);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	904 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	905 }
15035 0af20585964d dsync: Rewritten syncing for mailbox renames. Timo Sirainen <tss@iki.fi> parents: 14691 diff changeset	906 if (str_len(substr) > 0) {
0af20585964d dsync: Rewritten syncing for mailbox renames. Timo Sirainen <tss@iki.fi> parents: 14691 diff changeset	907 str_truncate(substr, str_len(substr)-1);
0af20585964d dsync: Rewritten syncing for mailbox renames. Timo Sirainen <tss@iki.fi> parents: 14691 diff changeset	908 dsync_serializer_encode_add(encoder, "dirs", str_c(substr));
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	909 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	910 dsync_serializer_encode_finish(&encoder, str);
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	911 dsync_ibc_stream_send_string(ibc, str);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	912 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	913
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	914 ARRAY_DEFINE_TYPE(dsync_mailbox_delete, struct dsync_mailbox_delete);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	915 static int
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	916 decode_mailbox_deletes(ARRAY_TYPE(dsync_mailbox_delete) *deletes,
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	917 const char *value, bool delete_mailbox)
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	918 {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	919 struct dsync_mailbox_delete *del;
15035 0af20585964d dsync: Rewritten syncing for mailbox renames. Timo Sirainen <tss@iki.fi> parents: 14691 diff changeset	920 const char const tmp;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	921 unsigned int i;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	922
15035 0af20585964d dsync: Rewritten syncing for mailbox renames. Timo Sirainen <tss@iki.fi> parents: 14691 diff changeset	923 tmp = t_strsplit(value, " ");
0af20585964d dsync: Rewritten syncing for mailbox renames. Timo Sirainen <tss@iki.fi> parents: 14691 diff changeset	924 for (i = 0; tmp[i] != NULL; i += 2) {
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	925 del = array_append_space(deletes);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	926 del->delete_mailbox = delete_mailbox;
15035 0af20585964d dsync: Rewritten syncing for mailbox renames. Timo Sirainen <tss@iki.fi> parents: 14691 diff changeset	927 if (guid_128_from_string(tmp[i], del->guid) < 0)
0af20585964d dsync: Rewritten syncing for mailbox renames. Timo Sirainen <tss@iki.fi> parents: 14691 diff changeset	928 return -1;
0af20585964d dsync: Rewritten syncing for mailbox renames. Timo Sirainen <tss@iki.fi> parents: 14691 diff changeset	929 if (tmp[i+1] == NULL \|\|
0af20585964d dsync: Rewritten syncing for mailbox renames. Timo Sirainen <tss@iki.fi> parents: 14691 diff changeset	930 str_to_time(tmp[i+1], &del->timestamp) < 0)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	931 return -1;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	932 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	933 return 0;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	934 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	935
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	936 static enum dsync_ibc_recv_ret
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	937 dsync_ibc_stream_recv_mailbox_deletes(struct dsync_ibc *_ibc,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	938 const struct dsync_mailbox_delete **deletes_r,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	939 unsigned int count_r, char hierarchy_sep_r)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	940 {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	941 struct dsync_ibc_stream ibc = (struct dsync_ibc_stream )_ibc;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	942 struct dsync_deserializer_decoder *decoder;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	943 ARRAY_TYPE(dsync_mailbox_delete) deletes;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	944 const char *value;
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	945 enum dsync_ibc_recv_ret ret;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	946
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	947 ret = dsync_ibc_stream_input_next(ibc, ITEM_MAILBOX_DELETE, &decoder);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	948 if (ret != DSYNC_IBC_RECV_RET_OK)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	949 return ret;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	950
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	951 p_clear(ibc->ret_pool);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	952 p_array_init(&deletes, ibc->ret_pool, 16);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	953
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	954 value = dsync_deserializer_decode_get(decoder, "hierarchy_sep");
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	955 if (strlen(value) != 1) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	956 dsync_ibc_input_error(ibc, decoder, "Invalid hierarchy_sep");
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	957 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	958 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	959 *hierarchy_sep_r = value[0];
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	960
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	961 if (dsync_deserializer_decode_try(decoder, "mailboxes", &value) &&
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	962 decode_mailbox_deletes(&deletes, value, TRUE) < 0) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	963 dsync_ibc_input_error(ibc, decoder, "Invalid mailboxes");
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	964 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	965 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	966 if (dsync_deserializer_decode_try(decoder, "dirs", &value) &&
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	967 decode_mailbox_deletes(&deletes, value, FALSE) < 0) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	968 dsync_ibc_input_error(ibc, decoder, "Invalid dirs");
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	969 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	970 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	971 *deletes_r = array_get(&deletes, count_r);
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	972 return DSYNC_IBC_RECV_RET_OK;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	973 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	974
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	975 static const char *
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	976 get_cache_fields(struct dsync_ibc_stream *ibc,
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	977 const struct dsync_mailbox *dsync_box)
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	978 {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	979 struct dsync_serializer_encoder *encoder;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	980 string_t *str;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	981 const struct mailbox_cache_field *cache_fields;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	982 unsigned int i, count;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	983 char decision[3];
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	984
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	985 cache_fields = array_get(&dsync_box->cache_fields, &count);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	986 if (count == 0)
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	987 return "";
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	988
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	989 str = t_str_new(128);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	990 for (i = 0; i < count; i++) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	991 const struct mailbox_cache_field *field = &cache_fields[i];
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	992
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	993 encoder = dsync_serializer_encode_begin(ibc->serializers[ITEM_MAILBOX_CACHE_FIELD]);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	994 dsync_serializer_encode_add(encoder, "name", field->name);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	995
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	996 memset(decision, 0, sizeof(decision));
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	997 switch (field->decision & ~MAIL_CACHE_DECISION_FORCED) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	998 case MAIL_CACHE_DECISION_NO:
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	999 decision[0] = 'n';
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1000 break;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1001 case MAIL_CACHE_DECISION_TEMP:
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1002 decision[0] = 't';
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1003 break;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1004 case MAIL_CACHE_DECISION_YES:
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1005 decision[0] = 'y';
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1006 break;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1007 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1008 i_assert(decision[0] != '\0');
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1009 if ((field->decision & MAIL_CACHE_DECISION_FORCED) != 0)
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1010 decision[1] = 'F';
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1011 dsync_serializer_encode_add(encoder, "decision", decision);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1012 if (field->last_used != 0) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1013 dsync_serializer_encode_add(encoder, "last_used",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1014 dec2str(field->last_used));
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1015 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1016 dsync_serializer_encode_finish(&encoder, str);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1017 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1018 if (i > 0) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1019 /* remove the trailing LF */
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1020 str_truncate(str, str_len(str)-1);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1021 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1022 return str_c(str);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1023 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1024
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1025 static void
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1026 dsync_ibc_stream_send_mailbox(struct dsync_ibc *_ibc,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1027 const struct dsync_mailbox *dsync_box)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1028 {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1029 struct dsync_ibc_stream ibc = (struct dsync_ibc_stream )_ibc;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1030 struct dsync_serializer_encoder *encoder;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1031 string_t *str = t_str_new(128);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1032 const char *value;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1033
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1034 str_append_c(str, items[ITEM_MAILBOX].chr);
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1035 encoder = dsync_serializer_encode_begin(ibc->serializers[ITEM_MAILBOX]);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1036 dsync_serializer_encode_add(encoder, "mailbox_guid",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1037 guid_128_to_string(dsync_box->mailbox_guid));
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1038
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1039 if (dsync_box->mailbox_lost)
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1040 dsync_serializer_encode_add(encoder, "mailbox_lost", "");
15750 5a1fc3723371 dsync: Automatically figure out which mailboxes can sync with message GUIDs. Timo Sirainen <tss@iki.fi> parents: 15744 diff changeset	1041 if (dsync_box->have_guids)
5a1fc3723371 dsync: Automatically figure out which mailboxes can sync with message GUIDs. Timo Sirainen <tss@iki.fi> parents: 15744 diff changeset	1042 dsync_serializer_encode_add(encoder, "have_guids", "");
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1043 dsync_serializer_encode_add(encoder, "uid_validity",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1044 dec2str(dsync_box->uid_validity));
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1045 dsync_serializer_encode_add(encoder, "uid_next",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1046 dec2str(dsync_box->uid_next));
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1047 dsync_serializer_encode_add(encoder, "messages_count",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1048 dec2str(dsync_box->messages_count));
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1049 dsync_serializer_encode_add(encoder, "first_recent_uid",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1050 dec2str(dsync_box->first_recent_uid));
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1051 dsync_serializer_encode_add(encoder, "highest_modseq",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1052 dec2str(dsync_box->highest_modseq));
15496 5d90e2aa1ba8 dsync: Use private modseqs to support syncing private flags in shared mailboxes. Timo Sirainen <tss@iki.fi> parents: 15494 diff changeset	1053 dsync_serializer_encode_add(encoder, "highest_pvt_modseq",
5d90e2aa1ba8 dsync: Use private modseqs to support syncing private flags in shared mailboxes. Timo Sirainen <tss@iki.fi> parents: 15494 diff changeset	1054 dec2str(dsync_box->highest_pvt_modseq));
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1055
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1056 value = get_cache_fields(ibc, dsync_box);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1057 if (value != NULL)
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1058 dsync_serializer_encode_add(encoder, "cache_fields", value);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1059
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1060 dsync_serializer_encode_finish(&encoder, str);
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1061 dsync_ibc_stream_send_string(ibc, str);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1062 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1063
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1064 static int
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1065 parse_cache_field(struct dsync_ibc_stream ibc, struct dsync_mailbox box,
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1066 const char *value)
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1067 {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1068 struct dsync_deserializer_decoder *decoder;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1069 struct mailbox_cache_field field;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1070 const char *error;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1071 int ret = 0;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1072
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1073 if (dsync_deserializer_decode_begin(ibc->deserializers[ITEM_MAILBOX_CACHE_FIELD],
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1074 value, &decoder, &error) < 0) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1075 dsync_ibc_input_error(ibc, NULL,
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1076 "cache_field: Invalid input: %s", error);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1077 return -1;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1078 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1079
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1080 memset(&field, 0, sizeof(field));
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1081 value = dsync_deserializer_decode_get(decoder, "name");
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1082 field.name = p_strdup(ibc->ret_pool, value);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1083
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1084 value = dsync_deserializer_decode_get(decoder, "decision");
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1085 switch (*value) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1086 case 'n':
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1087 field.decision = MAIL_CACHE_DECISION_NO;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1088 break;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1089 case 't':
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1090 field.decision = MAIL_CACHE_DECISION_TEMP;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1091 break;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1092 case 'y':
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1093 field.decision = MAIL_CACHE_DECISION_YES;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1094 break;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1095 default:
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1096 dsync_ibc_input_error(ibc, decoder, "Invalid decision: %s",
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1097 value);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1098 ret = -1;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1099 break;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1100 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1101 if (value[1] == 'F')
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1102 field.decision \|= MAIL_CACHE_DECISION_FORCED;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1103
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1104 if (dsync_deserializer_decode_try(decoder, "last_used", &value) &&
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1105 str_to_time(value, &field.last_used) < 0) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1106 dsync_ibc_input_error(ibc, decoder, "Invalid last_used");
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1107 ret = -1;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1108 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1109 array_append(&box->cache_fields, &field, 1);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1110
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1111 dsync_deserializer_decode_finish(&decoder);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1112 return ret;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1113 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1114
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1115 static enum dsync_ibc_recv_ret
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1116 dsync_ibc_stream_recv_mailbox(struct dsync_ibc *_ibc,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1117 const struct dsync_mailbox **dsync_box_r)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1118 {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1119 struct dsync_ibc_stream ibc = (struct dsync_ibc_stream )_ibc;
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1120 pool_t pool = ibc->ret_pool;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1121 struct dsync_deserializer_decoder *decoder;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1122 struct dsync_mailbox *box;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1123 const char *value;
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1124 enum dsync_ibc_recv_ret ret;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1125
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1126 p_clear(pool);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1127 box = p_new(pool, struct dsync_mailbox, 1);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1128
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1129 ret = dsync_ibc_stream_input_next(ibc, ITEM_MAILBOX, &decoder);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1130 if (ret != DSYNC_IBC_RECV_RET_OK)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1131 return ret;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1132
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1133 value = dsync_deserializer_decode_get(decoder, "mailbox_guid");
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1134 if (guid_128_from_string(value, box->mailbox_guid) < 0) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1135 dsync_ibc_input_error(ibc, decoder, "Invalid mailbox_guid");
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1136 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1137 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1138
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1139 if (dsync_deserializer_decode_try(decoder, "mailbox_lost", &value))
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1140 box->mailbox_lost = TRUE;
15750 5a1fc3723371 dsync: Automatically figure out which mailboxes can sync with message GUIDs. Timo Sirainen <tss@iki.fi> parents: 15744 diff changeset	1141 if (dsync_deserializer_decode_try(decoder, "have_guids", &value))
5a1fc3723371 dsync: Automatically figure out which mailboxes can sync with message GUIDs. Timo Sirainen <tss@iki.fi> parents: 15744 diff changeset	1142 box->have_guids = TRUE;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1143 value = dsync_deserializer_decode_get(decoder, "uid_validity");
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1144 if (str_to_uint32(value, &box->uid_validity) < 0) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1145 dsync_ibc_input_error(ibc, decoder, "Invalid uid_validity");
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1146 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1147 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1148 value = dsync_deserializer_decode_get(decoder, "uid_next");
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1149 if (str_to_uint32(value, &box->uid_next) < 0) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1150 dsync_ibc_input_error(ibc, decoder, "Invalid uid_next");
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1151 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1152 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1153 value = dsync_deserializer_decode_get(decoder, "messages_count");
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1154 if (str_to_uint32(value, &box->messages_count) < 0) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1155 dsync_ibc_input_error(ibc, decoder, "Invalid messages_count");
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1156 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1157 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1158 value = dsync_deserializer_decode_get(decoder, "first_recent_uid");
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1159 if (str_to_uint32(value, &box->first_recent_uid) < 0) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1160 dsync_ibc_input_error(ibc, decoder, "Invalid first_recent_uid");
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1161 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1162 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1163 value = dsync_deserializer_decode_get(decoder, "highest_modseq");
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1164 if (str_to_uint64(value, &box->highest_modseq) < 0) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1165 dsync_ibc_input_error(ibc, decoder, "Invalid highest_modseq");
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1166 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1167 }
15496 5d90e2aa1ba8 dsync: Use private modseqs to support syncing private flags in shared mailboxes. Timo Sirainen <tss@iki.fi> parents: 15494 diff changeset	1168 value = dsync_deserializer_decode_get(decoder, "highest_pvt_modseq");
5d90e2aa1ba8 dsync: Use private modseqs to support syncing private flags in shared mailboxes. Timo Sirainen <tss@iki.fi> parents: 15494 diff changeset	1169 if (str_to_uint64(value, &box->highest_pvt_modseq) < 0) {
5d90e2aa1ba8 dsync: Use private modseqs to support syncing private flags in shared mailboxes. Timo Sirainen <tss@iki.fi> parents: 15494 diff changeset	1170 dsync_ibc_input_error(ibc, decoder, "Invalid highest_pvt_modseq");
5d90e2aa1ba8 dsync: Use private modseqs to support syncing private flags in shared mailboxes. Timo Sirainen <tss@iki.fi> parents: 15494 diff changeset	1171 return DSYNC_IBC_RECV_RET_TRYAGAIN;
5d90e2aa1ba8 dsync: Use private modseqs to support syncing private flags in shared mailboxes. Timo Sirainen <tss@iki.fi> parents: 15494 diff changeset	1172 }
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1173
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1174 p_array_init(&box->cache_fields, pool, 32);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1175 if (dsync_deserializer_decode_try(decoder, "cache_fields", &value)) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1176 const char const fields = t_strsplit(value, "\n");
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1177 for (; *fields != NULL; fields++) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1178 if (parse_cache_field(ibc, box, *fields) < 0)
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1179 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1180 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1181 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1182
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1183 *dsync_box_r = box;
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1184 return DSYNC_IBC_RECV_RET_OK;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1185 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1186
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1187 static void
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1188 dsync_ibc_stream_send_change(struct dsync_ibc *_ibc,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1189 const struct dsync_mail_change *change)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1190 {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1191 struct dsync_ibc_stream ibc = (struct dsync_ibc_stream )_ibc;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1192 struct dsync_serializer_encoder *encoder;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1193 string_t *str = t_str_new(128);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1194 char type[2];
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1195
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1196 str_append_c(str, items[ITEM_MAIL_CHANGE].chr);
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1197 encoder = dsync_serializer_encode_begin(ibc->serializers[ITEM_MAIL_CHANGE]);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1198
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1199 type[0] = type[1] = '\0';
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1200 switch (change->type) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1201 case DSYNC_MAIL_CHANGE_TYPE_SAVE:
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1202 type[0] = 's';
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1203 break;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1204 case DSYNC_MAIL_CHANGE_TYPE_EXPUNGE:
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1205 type[0] = 'e';
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1206 break;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1207 case DSYNC_MAIL_CHANGE_TYPE_FLAG_CHANGE:
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1208 type[0] = 'f';
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1209 break;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1210 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1211 i_assert(type[0] != '\0');
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1212 dsync_serializer_encode_add(encoder, "type", type);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1213 dsync_serializer_encode_add(encoder, "uid", dec2str(change->uid));
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1214 if (change->guid != NULL)
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1215 dsync_serializer_encode_add(encoder, "guid", change->guid);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1216 if (change->hdr_hash != NULL) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1217 dsync_serializer_encode_add(encoder, "hdr_hash",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1218 change->hdr_hash);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1219 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1220 if (change->modseq != 0) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1221 dsync_serializer_encode_add(encoder, "modseq",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1222 dec2str(change->modseq));
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1223 }
15496 5d90e2aa1ba8 dsync: Use private modseqs to support syncing private flags in shared mailboxes. Timo Sirainen <tss@iki.fi> parents: 15494 diff changeset	1224 if (change->pvt_modseq != 0) {
5d90e2aa1ba8 dsync: Use private modseqs to support syncing private flags in shared mailboxes. Timo Sirainen <tss@iki.fi> parents: 15494 diff changeset	1225 dsync_serializer_encode_add(encoder, "pvt_modseq",
5d90e2aa1ba8 dsync: Use private modseqs to support syncing private flags in shared mailboxes. Timo Sirainen <tss@iki.fi> parents: 15494 diff changeset	1226 dec2str(change->pvt_modseq));
5d90e2aa1ba8 dsync: Use private modseqs to support syncing private flags in shared mailboxes. Timo Sirainen <tss@iki.fi> parents: 15494 diff changeset	1227 }
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1228 if (change->save_timestamp != 0) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1229 dsync_serializer_encode_add(encoder, "save_timestamp",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1230 dec2str(change->save_timestamp));
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1231 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1232 if (change->add_flags != 0) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1233 dsync_serializer_encode_add(encoder, "add_flags",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1234 t_strdup_printf("%x", change->add_flags));
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1235 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1236 if (change->remove_flags != 0) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1237 dsync_serializer_encode_add(encoder, "remove_flags",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1238 t_strdup_printf("%x", change->remove_flags));
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1239 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1240 if (change->final_flags != 0) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1241 dsync_serializer_encode_add(encoder, "final_flags",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1242 t_strdup_printf("%x", change->final_flags));
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1243 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1244 if (change->keywords_reset)
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1245 dsync_serializer_encode_add(encoder, "keywords_reset", "");
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1246
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1247 if (array_is_created(&change->keyword_changes) &&
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1248 array_count(&change->keyword_changes) > 0) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1249 string_t *kw_str = t_str_new(128);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1250 const char const changes;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1251 unsigned int i, count;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1252
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1253 changes = array_get(&change->keyword_changes, &count);
15068 002e0a120c2a Renamed str_tabescape_write() to str_append_tabescaped() Timo Sirainen <tss@iki.fi> parents: 15037 diff changeset	1254 str_append_tabescaped(kw_str, changes[0]);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1255 for (i = 1; i < count; i++) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1256 str_append_c(kw_str, '\t');
15068 002e0a120c2a Renamed str_tabescape_write() to str_append_tabescaped() Timo Sirainen <tss@iki.fi> parents: 15037 diff changeset	1257 str_append_tabescaped(kw_str, changes[i]);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1258 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1259 dsync_serializer_encode_add(encoder, "keyword_changes",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1260 str_c(kw_str));
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1261 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1262
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1263 dsync_serializer_encode_finish(&encoder, str);
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1264 dsync_ibc_stream_send_string(ibc, str);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1265 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1266
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1267 static enum dsync_ibc_recv_ret
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1268 dsync_ibc_stream_recv_change(struct dsync_ibc *_ibc,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1269 const struct dsync_mail_change **change_r)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1270 {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1271 struct dsync_ibc_stream ibc = (struct dsync_ibc_stream )_ibc;
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1272 pool_t pool = ibc->ret_pool;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1273 struct dsync_deserializer_decoder *decoder;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1274 struct dsync_mail_change *change;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1275 const char *value;
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1276 enum dsync_ibc_recv_ret ret;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1277
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1278 p_clear(pool);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1279 change = p_new(pool, struct dsync_mail_change, 1);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1280
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1281 ret = dsync_ibc_stream_input_next(ibc, ITEM_MAIL_CHANGE, &decoder);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1282 if (ret != DSYNC_IBC_RECV_RET_OK)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1283 return ret;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1284
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1285 value = dsync_deserializer_decode_get(decoder, "type");
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1286 switch (*value) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1287 case 's':
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1288 change->type = DSYNC_MAIL_CHANGE_TYPE_SAVE;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1289 break;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1290 case 'e':
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1291 change->type = DSYNC_MAIL_CHANGE_TYPE_EXPUNGE;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1292 break;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1293 case 'f':
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1294 change->type = DSYNC_MAIL_CHANGE_TYPE_FLAG_CHANGE;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1295 break;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1296 default:
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1297 dsync_ibc_input_error(ibc, decoder, "Invalid type: %s", value);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1298 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1299 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1300
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1301 value = dsync_deserializer_decode_get(decoder, "uid");
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1302 if (str_to_uint32(value, &change->uid) < 0) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1303 dsync_ibc_input_error(ibc, decoder, "Invalid uid");
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1304 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1305 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1306
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1307 if (dsync_deserializer_decode_try(decoder, "guid", &value))
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1308 change->guid = p_strdup(pool, value);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1309 if (dsync_deserializer_decode_try(decoder, "hdr_hash", &value))
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1310 change->hdr_hash = p_strdup(pool, value);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1311 if (dsync_deserializer_decode_try(decoder, "modseq", &value) &&
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1312 str_to_uint64(value, &change->modseq) < 0) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1313 dsync_ibc_input_error(ibc, decoder, "Invalid modseq");
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1314 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1315 }
15496 5d90e2aa1ba8 dsync: Use private modseqs to support syncing private flags in shared mailboxes. Timo Sirainen <tss@iki.fi> parents: 15494 diff changeset	1316 if (dsync_deserializer_decode_try(decoder, "pvt_modseq", &value) &&
5d90e2aa1ba8 dsync: Use private modseqs to support syncing private flags in shared mailboxes. Timo Sirainen <tss@iki.fi> parents: 15494 diff changeset	1317 str_to_uint64(value, &change->pvt_modseq) < 0) {
5d90e2aa1ba8 dsync: Use private modseqs to support syncing private flags in shared mailboxes. Timo Sirainen <tss@iki.fi> parents: 15494 diff changeset	1318 dsync_ibc_input_error(ibc, decoder, "Invalid pvt_modseq");
5d90e2aa1ba8 dsync: Use private modseqs to support syncing private flags in shared mailboxes. Timo Sirainen <tss@iki.fi> parents: 15494 diff changeset	1319 return DSYNC_IBC_RECV_RET_TRYAGAIN;
5d90e2aa1ba8 dsync: Use private modseqs to support syncing private flags in shared mailboxes. Timo Sirainen <tss@iki.fi> parents: 15494 diff changeset	1320 }
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1321 if (dsync_deserializer_decode_try(decoder, "save_timestamp", &value) &&
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1322 str_to_time(value, &change->save_timestamp) < 0) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1323 dsync_ibc_input_error(ibc, decoder, "Invalid save_timestamp");
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1324 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1325 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1326
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1327 if (dsync_deserializer_decode_try(decoder, "add_flags", &value))
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1328 change->add_flags = strtoul(value, NULL, 16);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1329 if (dsync_deserializer_decode_try(decoder, "remove_flags", &value))
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1330 change->remove_flags = strtoul(value, NULL, 16);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1331 if (dsync_deserializer_decode_try(decoder, "final_flags", &value))
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1332 change->final_flags = strtoul(value, NULL, 16);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1333 if (dsync_deserializer_decode_try(decoder, "keywords_reset", &value))
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1334 change->keywords_reset = TRUE;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1335
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1336 if (dsync_deserializer_decode_try(decoder, "keyword_changes", &value) &&
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1337 *value != '\0') {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1338 const char const changes = t_strsplit_tab(value);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1339 unsigned int i, count = str_array_length(changes);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1340
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1341 p_array_init(&change->keyword_changes, pool, count);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1342 for (i = 0; i < count; i++) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1343 value = p_strdup(pool, changes[i]);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1344 array_append(&change->keyword_changes, &value, 1);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1345 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1346 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1347
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1348 *change_r = change;
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1349 return DSYNC_IBC_RECV_RET_OK;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1350 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1351
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1352 static void
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1353 dsync_ibc_stream_send_mail_request(struct dsync_ibc *_ibc,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1354 const struct dsync_mail_request *request)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1355 {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1356 struct dsync_ibc_stream ibc = (struct dsync_ibc_stream )_ibc;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1357 struct dsync_serializer_encoder *encoder;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1358 string_t *str = t_str_new(128);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1359
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1360 str_append_c(str, items[ITEM_MAIL_REQUEST].chr);
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1361 encoder = dsync_serializer_encode_begin(ibc->serializers[ITEM_MAIL_REQUEST]);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1362 if (request->guid != NULL)
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1363 dsync_serializer_encode_add(encoder, "guid", request->guid);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1364 if (request->uid != 0) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1365 dsync_serializer_encode_add(encoder, "uid",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1366 dec2str(request->uid));
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1367 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1368 dsync_serializer_encode_finish(&encoder, str);
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1369 dsync_ibc_stream_send_string(ibc, str);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1370 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1371
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1372 static enum dsync_ibc_recv_ret
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1373 dsync_ibc_stream_recv_mail_request(struct dsync_ibc *_ibc,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1374 const struct dsync_mail_request **request_r)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1375 {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1376 struct dsync_ibc_stream ibc = (struct dsync_ibc_stream )_ibc;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1377 struct dsync_deserializer_decoder *decoder;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1378 struct dsync_mail_request *request;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1379 const char *value;
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1380 enum dsync_ibc_recv_ret ret;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1381
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1382 p_clear(ibc->ret_pool);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1383 request = p_new(ibc->ret_pool, struct dsync_mail_request, 1);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1384
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1385 ret = dsync_ibc_stream_input_next(ibc, ITEM_MAIL_REQUEST, &decoder);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1386 if (ret != DSYNC_IBC_RECV_RET_OK)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1387 return ret;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1388
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1389 if (dsync_deserializer_decode_try(decoder, "guid", &value))
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1390 request->guid = p_strdup(ibc->ret_pool, value);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1391 if (dsync_deserializer_decode_try(decoder, "uid", &value) &&
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1392 str_to_uint32(value, &request->uid) < 0) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1393 dsync_ibc_input_error(ibc, decoder, "Invalid uid");
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1394 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1395 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1396
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1397 *request_r = request;
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1398 return DSYNC_IBC_RECV_RET_OK;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1399 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1400
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1401 static void
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1402 dsync_ibc_stream_send_mail(struct dsync_ibc *_ibc,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1403 const struct dsync_mail *mail)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1404 {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1405 struct dsync_ibc_stream ibc = (struct dsync_ibc_stream )_ibc;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1406 struct dsync_serializer_encoder *encoder;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1407 string_t *str = t_str_new(128);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1408
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1409 i_assert(ibc->mail_output == NULL);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1410
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1411 str_append_c(str, items[ITEM_MAIL].chr);
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1412 encoder = dsync_serializer_encode_begin(ibc->serializers[ITEM_MAIL]);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1413 if (mail->guid != NULL)
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1414 dsync_serializer_encode_add(encoder, "guid", mail->guid);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1415 if (mail->uid != 0)
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1416 dsync_serializer_encode_add(encoder, "uid", dec2str(mail->uid));
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1417 if (mail->pop3_uidl != NULL) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1418 dsync_serializer_encode_add(encoder, "pop3_uidl",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1419 mail->pop3_uidl);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1420 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1421 if (mail->pop3_order > 0) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1422 dsync_serializer_encode_add(encoder, "pop3_order",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1423 dec2str(mail->pop3_order));
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1424 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1425 if (mail->received_date > 0) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1426 dsync_serializer_encode_add(encoder, "received_date",
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1427 dec2str(mail->received_date));
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1428 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1429 if (mail->input != NULL)
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1430 dsync_serializer_encode_add(encoder, "stream", "");
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1431
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1432 dsync_serializer_encode_finish(&encoder, str);
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1433 dsync_ibc_stream_send_string(ibc, str);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1434
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1435 if (mail->input != NULL) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1436 ibc->mail_output_last = '\0';
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1437 ibc->mail_output = mail->input;
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1438 i_stream_ref(ibc->mail_output);
15594 5bb80a6491eb dsync: Fixes to handling output stream buffering. Timo Sirainen <tss@iki.fi> parents: 15592 diff changeset	1439 (void)dsync_ibc_stream_send_mail_stream(ibc);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1440 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1441 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1442
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1443 static int seekable_fd_callback(const char *path_r, void context)
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1444 {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1445 struct dsync_ibc_stream *ibc = context;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1446 string_t *path;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1447 int fd;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1448
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1449 path = t_str_new(128);
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1450 str_append(path, ibc->temp_path_prefix);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1451 fd = safe_mkstemp(path, 0600, (uid_t)-1, (gid_t)-1);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1452 if (fd == -1) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1453 i_error("safe_mkstemp(%s) failed: %m", str_c(path));
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1454 return -1;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1455 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1456
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1457 /* we just want the fd, unlink it */
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1458 if (unlink(str_c(path)) < 0) {
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1459 /* shouldn't happen.. */
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1460 i_error("unlink(%s) failed: %m", str_c(path));
14691 3945a3646c67 Changed i_close_fd() API to set the fd to -1 after closing. Timo Sirainen <tss@iki.fi> parents: 14687 diff changeset	1461 i_close_fd(&fd);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1462 return -1;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1463 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1464
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1465 *path_r = str_c(path);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1466 return fd;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1467 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1468
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1469 static enum dsync_ibc_recv_ret
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1470 dsync_ibc_stream_recv_mail(struct dsync_ibc _ibc, struct dsync_mail *mail_r)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1471 {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1472 struct dsync_ibc_stream ibc = (struct dsync_ibc_stream )_ibc;
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1473 pool_t pool = ibc->ret_pool;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1474 struct dsync_deserializer_decoder *decoder;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1475 struct dsync_mail *mail;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1476 struct istream *inputs[2];
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1477 const char *value;
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1478 enum dsync_ibc_recv_ret ret;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1479
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1480 if (ibc->mail_input != NULL) {
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1481 /* wait until the mail's stream has been read */
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1482 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1483 }
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1484 if (ibc->cur_mail != NULL) {
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1485 /* finished reading the stream, return the mail now */
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1486 *mail_r = ibc->cur_mail;
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1487 ibc->cur_mail = NULL;
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1488 return DSYNC_IBC_RECV_RET_OK;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1489 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1490
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1491 p_clear(pool);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1492 mail = p_new(pool, struct dsync_mail, 1);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1493
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1494 ret = dsync_ibc_stream_input_next(ibc, ITEM_MAIL, &decoder);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1495 if (ret != DSYNC_IBC_RECV_RET_OK)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1496 return ret;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1497
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1498 if (dsync_deserializer_decode_try(decoder, "guid", &value))
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1499 mail->guid = p_strdup(pool, value);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1500 if (dsync_deserializer_decode_try(decoder, "uid", &value) &&
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1501 str_to_uint32(value, &mail->uid) < 0) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1502 dsync_ibc_input_error(ibc, decoder, "Invalid uid");
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1503 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1504 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1505 if (dsync_deserializer_decode_try(decoder, "pop3_uidl", &value))
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1506 mail->pop3_uidl = p_strdup(pool, value);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1507 if (dsync_deserializer_decode_try(decoder, "pop3_order", &value) &&
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1508 str_to_uint(value, &mail->pop3_order) < 0) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1509 dsync_ibc_input_error(ibc, decoder, "Invalid pop3_order");
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1510 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1511 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1512 if (dsync_deserializer_decode_try(decoder, "received_date", &value) &&
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1513 str_to_time(value, &mail->received_date) < 0) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1514 dsync_ibc_input_error(ibc, decoder, "Invalid received_date");
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1515 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1516 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1517 if (dsync_deserializer_decode_try(decoder, "stream", &value)) {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1518 inputs[0] = i_stream_create_dot(ibc->input, FALSE);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1519 inputs[1] = NULL;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1520 mail->input = i_stream_create_seekable(inputs,
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1521 MAIL_READ_FULL_BLOCK_SIZE, seekable_fd_callback, ibc);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1522 i_stream_unref(&inputs[0]);
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1523
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1524 ibc->mail_input = mail->input;
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1525 if (dsync_ibc_stream_read_mail_stream(ibc) <= 0) {
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1526 ibc->cur_mail = mail;
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1527 return DSYNC_IBC_RECV_RET_TRYAGAIN;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1528 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1529 /* already finished reading the stream */
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1530 i_assert(ibc->mail_input == NULL);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1531 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1532
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1533 *mail_r = mail;
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1534 return DSYNC_IBC_RECV_RET_OK;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1535 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1536
15632 40dd9a080b6e dsync: Close mail streams earlier on failures to avoid assert-crashing Timo Sirainen <tss@iki.fi> parents: 15594 diff changeset	1537 static void dsync_ibc_stream_close_mail_streams(struct dsync_ibc *_ibc)
40dd9a080b6e dsync: Close mail streams earlier on failures to avoid assert-crashing Timo Sirainen <tss@iki.fi> parents: 15594 diff changeset	1538 {
40dd9a080b6e dsync: Close mail streams earlier on failures to avoid assert-crashing Timo Sirainen <tss@iki.fi> parents: 15594 diff changeset	1539 struct dsync_ibc_stream ibc = (struct dsync_ibc_stream )_ibc;
40dd9a080b6e dsync: Close mail streams earlier on failures to avoid assert-crashing Timo Sirainen <tss@iki.fi> parents: 15594 diff changeset	1540
40dd9a080b6e dsync: Close mail streams earlier on failures to avoid assert-crashing Timo Sirainen <tss@iki.fi> parents: 15594 diff changeset	1541 if (ibc->mail_output != NULL) {
40dd9a080b6e dsync: Close mail streams earlier on failures to avoid assert-crashing Timo Sirainen <tss@iki.fi> parents: 15594 diff changeset	1542 i_stream_unref(&ibc->mail_output);
40dd9a080b6e dsync: Close mail streams earlier on failures to avoid assert-crashing Timo Sirainen <tss@iki.fi> parents: 15594 diff changeset	1543 dsync_ibc_stream_stop(ibc);
40dd9a080b6e dsync: Close mail streams earlier on failures to avoid assert-crashing Timo Sirainen <tss@iki.fi> parents: 15594 diff changeset	1544 }
40dd9a080b6e dsync: Close mail streams earlier on failures to avoid assert-crashing Timo Sirainen <tss@iki.fi> parents: 15594 diff changeset	1545 }
40dd9a080b6e dsync: Close mail streams earlier on failures to avoid assert-crashing Timo Sirainen <tss@iki.fi> parents: 15594 diff changeset	1546
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1547 static bool dsync_ibc_stream_is_send_queue_full(struct dsync_ibc *_ibc)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1548 {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1549 struct dsync_ibc_stream ibc = (struct dsync_ibc_stream )_ibc;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1550 size_t bytes;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1551
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1552 if (ibc->mail_output != NULL)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1553 return TRUE;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1554
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1555 bytes = o_stream_get_buffer_used_size(ibc->output);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1556 if (bytes < DSYNC_IBC_STREAM_OUTBUF_THROTTLE_SIZE)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1557 return FALSE;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1558
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1559 o_stream_set_flush_pending(ibc->output, TRUE);
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1560 return TRUE;
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1561 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1562
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1563 static bool dsync_ibc_stream_has_pending_data(struct dsync_ibc *_ibc)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1564 {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1565 struct dsync_ibc_stream ibc = (struct dsync_ibc_stream )_ibc;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1566
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1567 return ibc->has_pending_data;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1568 }
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1569
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1570 static const struct dsync_ibc_vfuncs dsync_ibc_stream_vfuncs = {
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1571 dsync_ibc_stream_deinit,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1572 dsync_ibc_stream_send_handshake,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1573 dsync_ibc_stream_recv_handshake,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1574 dsync_ibc_stream_send_end_of_list,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1575 dsync_ibc_stream_send_mailbox_state,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1576 dsync_ibc_stream_recv_mailbox_state,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1577 dsync_ibc_stream_send_mailbox_tree_node,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1578 dsync_ibc_stream_recv_mailbox_tree_node,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1579 dsync_ibc_stream_send_mailbox_deletes,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1580 dsync_ibc_stream_recv_mailbox_deletes,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1581 dsync_ibc_stream_send_mailbox,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1582 dsync_ibc_stream_recv_mailbox,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1583 dsync_ibc_stream_send_change,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1584 dsync_ibc_stream_recv_change,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1585 dsync_ibc_stream_send_mail_request,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1586 dsync_ibc_stream_recv_mail_request,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1587 dsync_ibc_stream_send_mail,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1588 dsync_ibc_stream_recv_mail,
15632 40dd9a080b6e dsync: Close mail streams earlier on failures to avoid assert-crashing Timo Sirainen <tss@iki.fi> parents: 15594 diff changeset	1589 dsync_ibc_stream_close_mail_streams,
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1590 dsync_ibc_stream_is_send_queue_full,
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1591 dsync_ibc_stream_has_pending_data
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1592 };
b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1593
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1594 struct dsync_ibc *
15464 af3b86a16ac3 dsync: Added debugging and rawlogging support. Timo Sirainen <tss@iki.fi> parents: 15463 diff changeset	1595 dsync_ibc_init_stream(struct istream input, struct ostream output,
af3b86a16ac3 dsync: Added debugging and rawlogging support. Timo Sirainen <tss@iki.fi> parents: 15463 diff changeset	1596 const char name, const char temp_path_prefix)
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1597 {
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1598 struct dsync_ibc_stream *ibc;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1599
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1600 ibc = i_new(struct dsync_ibc_stream, 1);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1601 ibc->ibc.v = dsync_ibc_stream_vfuncs;
15464 af3b86a16ac3 dsync: Added debugging and rawlogging support. Timo Sirainen <tss@iki.fi> parents: 15463 diff changeset	1602 ibc->input = input;
af3b86a16ac3 dsync: Added debugging and rawlogging support. Timo Sirainen <tss@iki.fi> parents: 15463 diff changeset	1603 ibc->output = output;
af3b86a16ac3 dsync: Added debugging and rawlogging support. Timo Sirainen <tss@iki.fi> parents: 15463 diff changeset	1604 ibc->fd_in = i_stream_get_fd(input);
15037 920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1605 ibc->name = i_strdup(name);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1606 ibc->temp_path_prefix = i_strdup(temp_path_prefix);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1607 ibc->ret_pool = pool_alloconly_create("ibc stream data", 2048);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1608 dsync_ibc_stream_init(ibc);
920756cd29b8 dsync: Renamed "slave" to "ibc" (= inter-brain communicator) Timo Sirainen <tss@iki.fi> parents: 15036 diff changeset	1609 return &ibc->ibc;
14584 b2076acc3715 Initial version of dsync rewrite. Timo Sirainen <tss@iki.fi> parents: diff changeset	1610 }

Mercurial > dovecot > core-2.2

annotate src/doveadm/dsync/dsync-ibc-stream.c @ 15986:f6377e089dee