| /dovecot/src/doveadm/dsync/ |
| H A D | dsync-ibc.c | 5 #include "dsync-ibc-private.h"
9 struct dsync_ibc *ibc = *_ibc; local
12 ibc->v.deinit(ibc);
15 void dsync_ibc_set_io_callback(struct dsync_ibc *ibc, argument
18 ibc->io_callback = callback;
19 ibc->io_context = context;
22 void dsync_ibc_send_handshake(struct dsync_ibc *ibc, argument
25 ibc->v.send_handshake(ibc, se
29 dsync_ibc_recv_handshake(struct dsync_ibc *ibc, const struct dsync_ibc_settings **set_r) argument
36 dsync_ibc_send_ret(struct dsync_ibc *ibc) argument
44 dsync_ibc_send_end_of_list(struct dsync_ibc *ibc, enum dsync_ibc_eol_type type) argument
51 dsync_ibc_send_mailbox_state(struct dsync_ibc *ibc, const struct dsync_mailbox_state *state) argument
61 dsync_ibc_recv_mailbox_state(struct dsync_ibc *ibc, struct dsync_mailbox_state *state_r) argument
68 dsync_ibc_send_mailbox_tree_node(struct dsync_ibc *ibc, const char *const *name, const struct dsync_mailbox_node *node) argument
81 dsync_ibc_recv_mailbox_tree_node(struct dsync_ibc *ibc, const char *const **name_r, const struct dsync_mailbox_node **node_r) argument
89 dsync_ibc_send_mailbox_deletes(struct dsync_ibc *ibc, const struct dsync_mailbox_delete *deletes, unsigned int count, char hierarchy_sep) argument
101 dsync_ibc_recv_mailbox_deletes(struct dsync_ibc *ibc, const struct dsync_mailbox_delete **deletes_r, unsigned int *count_r, char *hierarchy_sep_r) argument
110 dsync_ibc_send_mailbox(struct dsync_ibc *ibc, const struct dsync_mailbox *dsync_box) argument
120 dsync_ibc_recv_mailbox(struct dsync_ibc *ibc, const struct dsync_mailbox **dsync_box_r) argument
127 dsync_ibc_send_mailbox_attribute(struct dsync_ibc *ibc, const struct dsync_mailbox_attribute *attr) argument
137 dsync_ibc_recv_mailbox_attribute(struct dsync_ibc *ibc, const struct dsync_mailbox_attribute **attr_r) argument
144 dsync_ibc_send_change(struct dsync_ibc *ibc, const struct dsync_mail_change *change) argument
156 dsync_ibc_recv_change(struct dsync_ibc *ibc, const struct dsync_mail_change **change_r) argument
163 dsync_ibc_send_mail_request(struct dsync_ibc *ibc, const struct dsync_mail_request *request) argument
175 dsync_ibc_recv_mail_request(struct dsync_ibc *ibc, const struct dsync_mail_request **request_r) argument
182 dsync_ibc_send_mail(struct dsync_ibc *ibc, const struct dsync_mail *mail) argument
193 dsync_ibc_recv_mail(struct dsync_ibc *ibc, struct dsync_mail **mail_r) argument
198 dsync_ibc_send_finish(struct dsync_ibc *ibc, const char *error, enum mail_error mail_error, bool require_full_resync) argument
206 dsync_ibc_recv_finish(struct dsync_ibc *ibc, const char **error_r, enum mail_error *mail_error_r, bool *require_full_resync_r) argument
214 dsync_ibc_close_mail_streams(struct dsync_ibc *ibc) argument
219 dsync_ibc_has_failed(struct dsync_ibc *ibc) argument
224 dsync_ibc_has_timed_out(struct dsync_ibc *ibc) argument
229 dsync_ibc_is_send_queue_full(struct dsync_ibc *ibc) argument
234 dsync_ibc_has_pending_data(struct dsync_ibc *ibc) argument
[all...] |
| H A D | dsync-brain.c | 15 #include "dsync-ibc.h"
102 if (dsync_ibc_has_failed(brain->ibc)) {
117 if (dsync_ibc_has_pending_data(brain->ibc))
125 dsync_brain_common_init(struct mail_user *user, struct dsync_ibc *ibc) argument
138 brain->ibc = ibc;
181 dsync_brain_master_init(struct mail_user *user, struct dsync_ibc *ibc, argument
197 brain = dsync_brain_common_init(user, ibc);
280 dsync_ibc_send_handshake(ibc, &ibc_set);
282 dsync_ibc_set_io_callback(ibc, dsync_brain_run_i
291 dsync_brain_slave_init(struct mail_user *user, struct dsync_ibc *ibc, bool local, const char *process_title_prefix) argument
[all...] |
| H A D | dsync-brain-private.h | 54 struct dsync_ibc *ibc; member in struct:dsync_brain
|
| H A D | dsync-ibc-pipe.c | 10 #include "dsync-ibc-private.h"
54 struct dsync_ibc ibc; member in struct:dsync_ibc_pipe
140 static void dsync_ibc_pipe_deinit(struct dsync_ibc *ibc) argument
142 struct dsync_ibc_pipe *pipe = (struct dsync_ibc_pipe *)ibc;
163 dsync_ibc_pipe_send_handshake(struct dsync_ibc *ibc, argument
166 struct dsync_ibc_pipe *pipe = (struct dsync_ibc_pipe *)ibc;
186 dsync_ibc_pipe_recv_handshake(struct dsync_ibc *ibc, argument
189 struct dsync_ibc_pipe *pipe = (struct dsync_ibc_pipe *)ibc;
200 static bool dsync_ibc_pipe_is_send_queue_full(struct dsync_ibc *ibc) argument
202 struct dsync_ibc_pipe *pipe = (struct dsync_ibc_pipe *)ibc;
207 dsync_ibc_pipe_has_pending_data(struct dsync_ibc *ibc) argument
215 dsync_ibc_pipe_send_end_of_list(struct dsync_ibc *ibc, enum dsync_ibc_eol_type type ATTR_UNUSED) argument
224 dsync_ibc_pipe_send_mailbox_state(struct dsync_ibc *ibc, const struct dsync_mailbox_state *state) argument
235 dsync_ibc_pipe_recv_mailbox_state(struct dsync_ibc *ibc, struct dsync_mailbox_state *state_r) argument
253 dsync_ibc_pipe_send_mailbox_tree_node(struct dsync_ibc *ibc, const char *const *name, const struct dsync_mailbox_node *node) argument
268 dsync_ibc_pipe_recv_mailbox_tree_node(struct dsync_ibc *ibc, const char *const **name_r, const struct dsync_mailbox_node **node_r) argument
290 dsync_ibc_pipe_send_mailbox_deletes(struct dsync_ibc *ibc, const struct dsync_mailbox_delete *deletes, unsigned int count, char hierarchy_sep) argument
307 dsync_ibc_pipe_recv_mailbox_deletes(struct dsync_ibc *ibc, const struct dsync_mailbox_delete **deletes_r, unsigned int *count_r, char *hierarchy_sep_r) argument
329 dsync_ibc_pipe_send_mailbox(struct dsync_ibc *ibc, const struct dsync_mailbox *dsync_box) argument
350 dsync_ibc_pipe_recv_mailbox(struct dsync_ibc *ibc, const struct dsync_mailbox **dsync_box_r) argument
368 dsync_ibc_pipe_send_mailbox_attribute(struct dsync_ibc *ibc, const struct dsync_mailbox_attribute *attr) argument
379 dsync_ibc_pipe_recv_mailbox_attribute(struct dsync_ibc *ibc, const struct dsync_mailbox_attribute **attr_r) argument
397 dsync_ibc_pipe_send_change(struct dsync_ibc *ibc, const struct dsync_mail_change *change) argument
408 dsync_ibc_pipe_recv_change(struct dsync_ibc *ibc, const struct dsync_mail_change **change_r) argument
426 dsync_ibc_pipe_send_mail_request(struct dsync_ibc *ibc, const struct dsync_mail_request *request) argument
438 dsync_ibc_pipe_recv_mail_request(struct dsync_ibc *ibc, const struct dsync_mail_request **request_r) argument
456 dsync_ibc_pipe_send_mail(struct dsync_ibc *ibc, const struct dsync_mail *mail) argument
476 dsync_ibc_pipe_recv_mail(struct dsync_ibc *ibc, struct dsync_mail **mail_r) argument
493 dsync_ibc_pipe_send_finish(struct dsync_ibc *ibc, const char *error, enum mail_error mail_error, bool require_full_resync) argument
507 dsync_ibc_pipe_recv_finish(struct dsync_ibc *ibc, const char **error_r, enum mail_error *mail_error_r, bool *require_full_resync_r) argument
536 dsync_ibc_pipe_close_mail_streams(struct dsync_ibc *ibc) argument
[all...] |
| H A D | dsync-ibc-stream.c | 22 #include "dsync-ibc-private.h"
144 struct dsync_ibc ibc; member in struct:dsync_ibc_stream
177 static const char *dsync_ibc_stream_get_state(struct dsync_ibc_stream *ibc) argument
179 if (!ibc->version_received)
181 else if (!ibc->handshake_received)
185 items[ibc->last_sent_item].name,
186 ibc->last_sent_item_eol ? " (EOL)" : "",
187 items[ibc->last_recv_item].name,
188 ibc->last_recv_item_eol ? " (EOL)" : "");
191 static void dsync_ibc_stream_stop(struct dsync_ibc_stream *ibc) argument
199 dsync_ibc_stream_read_mail_stream(struct dsync_ibc_stream *ibc) argument
224 dsync_ibc_stream_input(struct dsync_ibc_stream *ibc) argument
236 dsync_ibc_stream_send_value_stream(struct dsync_ibc_stream *ibc) argument
296 dsync_ibc_stream_output(struct dsync_ibc_stream *ibc) argument
314 dsync_ibc_stream_timeout(struct dsync_ibc_stream *ibc) argument
322 dsync_ibc_stream_init(struct dsync_ibc_stream *ibc) argument
357 struct dsync_ibc_stream *ibc = (struct dsync_ibc_stream *)_ibc; local
400 dsync_ibc_stream_next_line(struct dsync_ibc_stream *ibc, const char **line_r) argument
440 dsync_ibc_input_error(struct dsync_ibc_stream *ibc, struct dsync_deserializer_decoder *decoder, const char *fmt, ...) argument
461 dsync_ibc_stream_send_string(struct dsync_ibc_stream *ibc, const string_t *str) argument
470 struct dsync_ibc_stream *ibc = context; local
494 dsync_ibc_stream_input_stream(struct dsync_ibc_stream *ibc) argument
508 dsync_ibc_check_missing_deserializers(struct dsync_ibc_stream *ibc) argument
528 dsync_ibc_stream_handshake(struct dsync_ibc_stream *ibc, const char *line) argument
582 dsync_ibc_stream_input_next(struct dsync_ibc_stream *ibc, enum item_type item, struct dsync_deserializer_decoder **decoder_r) argument
642 dsync_ibc_send_encode_begin(struct dsync_ibc_stream *ibc, enum item_type item) argument
653 struct dsync_ibc_stream *ibc = (struct dsync_ibc_stream *)_ibc; local
767 struct dsync_ibc_stream *ibc = (struct dsync_ibc_stream *)_ibc; local
905 struct dsync_ibc_stream *ibc = (struct dsync_ibc_stream *)_ibc; local
926 struct dsync_ibc_stream *ibc = (struct dsync_ibc_stream *)_ibc; local
955 struct dsync_ibc_stream *ibc = (struct dsync_ibc_stream *)_ibc; local
1006 struct dsync_ibc_stream *ibc = (struct dsync_ibc_stream *)_ibc; local
1070 struct dsync_ibc_stream *ibc = (struct dsync_ibc_stream *)_ibc; local
1162 struct dsync_ibc_stream *ibc = (struct dsync_ibc_stream *)_ibc; local
1215 struct dsync_ibc_stream *ibc = (struct dsync_ibc_stream *)_ibc; local
1258 get_cache_fields(struct dsync_ibc_stream *ibc, const struct dsync_mailbox *dsync_box) argument
1311 struct dsync_ibc_stream *ibc = (struct dsync_ibc_stream *)_ibc; local
1353 parse_cache_field(struct dsync_ibc_stream *ibc, struct dsync_mailbox *box, const char *value) argument
1407 struct dsync_ibc_stream *ibc = (struct dsync_ibc_stream *)_ibc; local
1486 struct dsync_ibc_stream *ibc = (struct dsync_ibc_stream *)_ibc; local
1540 struct dsync_ibc_stream *ibc = (struct dsync_ibc_stream *)_ibc; local
1620 struct dsync_ibc_stream *ibc = (struct dsync_ibc_stream *)_ibc; local
1704 struct dsync_ibc_stream *ibc = (struct dsync_ibc_stream *)_ibc; local
1821 struct dsync_ibc_stream *ibc = (struct dsync_ibc_stream *)_ibc; local
1841 struct dsync_ibc_stream *ibc = (struct dsync_ibc_stream *)_ibc; local
1870 struct dsync_ibc_stream *ibc = (struct dsync_ibc_stream *)_ibc; local
1916 struct dsync_ibc_stream *ibc = (struct dsync_ibc_stream *)_ibc; local
1984 struct dsync_ibc_stream *ibc = (struct dsync_ibc_stream *)_ibc; local
2007 struct dsync_ibc_stream *ibc = (struct dsync_ibc_stream *)_ibc; local
2043 struct dsync_ibc_stream *ibc = (struct dsync_ibc_stream *)_ibc; local
2053 struct dsync_ibc_stream *ibc = (struct dsync_ibc_stream *)_ibc; local
2069 struct dsync_ibc_stream *ibc = (struct dsync_ibc_stream *)_ibc; local
2107 struct dsync_ibc_stream *ibc; local
[all...] |
| /dovecot/src/doveadm/ |
| H A D | doveadm-dsync.c | 34 #include "dsync/dsync-ibc.h"
575 struct dsync_ibc *ibc, *ibc2 = NULL; local
635 dsync_ibc_init_pipe(&ibc, &ibc2);
639 ibc = cmd_dsync_ibc_stream_init(ctx, ctx->remote_name,
672 brain = dsync_brain_master_init(user, ibc, ctx->sync_type,
719 dsync_ibc_deinit(&ibc);
1163 struct dsync_ibc *ibc; local
1203 ibc = cmd_dsync_ibc_stream_init(ctx, name, str_c(temp_prefix));
1204 brain = dsync_brain_slave_init(user, ibc, FALSE, process_title_prefix);
1216 dsync_ibc_deinit(&ibc);
[all...] |