-}
-
-static void msg2sndr_flush(void)
-{
- if (defer_forwarding_messages)
- return;
-
- while (msg2sndr.head && io_multiplexing_out) {
- struct msg_list_item *m = msg2sndr.head;
- if (!(msg2sndr.head = m->next))
- msg2sndr.tail = NULL;
- stats.total_written += m->len;
- defer_forwarding_messages = 1;
- writefd_unbuffered(sock_f_out, m->buf, m->len);
- defer_forwarding_messages = 0;
- free(m);
- }
-}
-
-/**
- * Write an message to a multiplexed stream. If this fails then rsync
- * exits.
- **/
-static void mplex_write(enum msgcode code, const char *buf, size_t len)
-{
- char buffer[1024];
- size_t n = len;
-
- SIVAL(buffer, 0, ((MPLEX_BASE + (int)code)<<24) + len);
-
- if (n > sizeof buffer - 4)
- n = 0;
- else
- memcpy(buffer + 4, buf, n);
-
- writefd_unbuffered(sock_f_out, buffer, n+4);
-
- len -= n;
- buf += n;
-
- if (len) {
- defer_forwarding_messages = 1;
- writefd_unbuffered(sock_f_out, buf, len);
- defer_forwarding_messages = 0;