Cross Reference: /dovecot/src/doveadm/dsync/dsync-ibc.c

Lines Matching defs:ibc
5 #include "dsync-ibc-private.h"
9 	struct dsync_ibc *ibc = *_ibc;
12 	ibc->v.deinit(ibc);
15 void dsync_ibc_set_io_callback(struct dsync_ibc *ibc,
18 	ibc->io_callback = callback;
19 	ibc->io_context = context;
22 void dsync_ibc_send_handshake(struct dsync_ibc *ibc,
25 	ibc->v.send_handshake(ibc, set);
29 dsync_ibc_recv_handshake(struct dsync_ibc *ibc,
32 	return ibc->v.recv_handshake(ibc, set_r);
36 dsync_ibc_send_ret(struct dsync_ibc *ibc)
38 	return ibc->v.is_send_queue_full(ibc) ?
44 dsync_ibc_send_end_of_list(struct dsync_ibc *ibc, enum dsync_ibc_eol_type type)
46 	ibc->v.send_end_of_list(ibc, type);
47 	return dsync_ibc_send_ret(ibc);
51 dsync_ibc_send_mailbox_state(struct dsync_ibc *ibc,
55 		ibc->v.send_mailbox_state(ibc, state);
57 	return dsync_ibc_send_ret(ibc);
61 dsync_ibc_recv_mailbox_state(struct dsync_ibc *ibc,
64 	return ibc->v.recv_mailbox_state(ibc, state_r);
68 dsync_ibc_send_mailbox_tree_node(struct dsync_ibc *ibc,
75 		ibc->v.send_mailbox_tree_node(ibc, name, node);
77 	return dsync_ibc_send_ret(ibc);
81 dsync_ibc_recv_mailbox_tree_node(struct dsync_ibc *ibc,
85 	return ibc->v.recv_mailbox_tree_node(ibc, name_r, node_r);
89 dsync_ibc_send_mailbox_deletes(struct dsync_ibc *ibc,
94 		ibc->v.send_mailbox_deletes(ibc, deletes, count,
97 	return dsync_ibc_send_ret(ibc);
101 dsync_ibc_recv_mailbox_deletes(struct dsync_ibc *ibc,
105 	return ibc->v.recv_mailbox_deletes(ibc, deletes_r, count_r,
110 dsync_ibc_send_mailbox(struct dsync_ibc *ibc,
114 		ibc->v.send_mailbox(ibc, dsync_box);
116 	return dsync_ibc_send_ret(ibc);
120 dsync_ibc_recv_mailbox(struct dsync_ibc *ibc,
123 	return ibc->v.recv_mailbox(ibc, dsync_box_r);
127 dsync_ibc_send_mailbox_attribute(struct dsync_ibc *ibc,
131 		ibc->v.send_mailbox_attribute(ibc, attr);
133 	return dsync_ibc_send_ret(ibc);
137 dsync_ibc_recv_mailbox_attribute(struct dsync_ibc *ibc,
140 	return ibc->v.recv_mailbox_attribute(ibc, attr_r);
144 dsync_ibc_send_change(struct dsync_ibc *ibc,
150 		ibc->v.send_change(ibc, change);
152 	return dsync_ibc_send_ret(ibc);
156 dsync_ibc_recv_change(struct dsync_ibc *ibc,
159 	return ibc->v.recv_change(ibc, change_r);
163 dsync_ibc_send_mail_request(struct dsync_ibc *ibc,
169 		ibc->v.send_mail_request(ibc, request);
171 	return dsync_ibc_send_ret(ibc);
175 dsync_ibc_recv_mail_request(struct dsync_ibc *ibc,
178 	return ibc->v.recv_mail_request(ibc, request_r);
182 dsync_ibc_send_mail(struct dsync_ibc *ibc, const struct dsync_mail *mail)
187 		ibc->v.send_mail(ibc, mail);
189 	return dsync_ibc_send_ret(ibc);
193 dsync_ibc_recv_mail(struct dsync_ibc *ibc, struct dsync_mail **mail_r)
195 	return ibc->v.recv_mail(ibc, mail_r);
198 void dsync_ibc_send_finish(struct dsync_ibc *ibc, const char *error,
202 	ibc->v.send_finish(ibc, error, mail_error, require_full_resync);
206 dsync_ibc_recv_finish(struct dsync_ibc *ibc, const char **error_r,
210 	return ibc->v.recv_finish(ibc, error_r, mail_error_r,
214 void dsync_ibc_close_mail_streams(struct dsync_ibc *ibc)
216 	ibc->v.close_mail_streams(ibc);
219 bool dsync_ibc_has_failed(struct dsync_ibc *ibc)
221 	return ibc->failed;
224 bool dsync_ibc_has_timed_out(struct dsync_ibc *ibc)
226 	return ibc->timeout;
229 bool dsync_ibc_is_send_queue_full(struct dsync_ibc *ibc)
231 	return ibc->v.is_send_queue_full(ibc);
234 bool dsync_ibc_has_pending_data(struct dsync_ibc *ibc)
236 	return ibc->v.has_pending_data(ibc);