100 send_up_fsm(struct sess *sess, size_t *phase,  in send_up_fsm()  argument
121 		if (!io_lowbuffer_alloc(sess, wb, wbsz, wbmax, isz)) {  in send_up_fsm()
125 		io_lowbuffer_int(sess, *wb, &pos, *wbsz, sz);  in send_up_fsm()
126 		if (!io_lowbuffer_alloc(sess, wb, wbsz, wbmax, sz)) {  in send_up_fsm()
130 		io_lowbuffer_buf(sess, *wb, &pos, *wbsz,  in send_up_fsm()
146 		if (!io_lowbuffer_alloc(sess, wb, wbsz, wbmax, isz)) {  in send_up_fsm()
150 		io_lowbuffer_int(sess, *wb,  in send_up_fsm()
163 		if (!io_lowbuffer_alloc(sess, wb, wbsz, wbmax, dsz)) {  in send_up_fsm()
167 		io_lowbuffer_buf(sess, *wb, &pos, *wbsz, fmd, dsz);  in send_up_fsm()
177 		if (!sess->opts->dry_run)  in send_up_fsm()
204 		blk_match(sess, up->cur->blks,  in send_up_fsm()
221 		if (!io_lowbuffer_alloc(sess, wb, wbsz, wbmax, isz)) {  in send_up_fsm()
225 		io_lowbuffer_int(sess, *wb, &pos, *wbsz, -1);  in send_up_fsm()
227 		if (sess->opts->server && sess->rver > 27) {  in send_up_fsm()
228 			if (!io_lowbuffer_alloc(sess,  in send_up_fsm()
233 			io_lowbuffer_int(sess, *wb, &pos, *wbsz, -1);  in send_up_fsm()
236 	} else if (sess->opts->dry_run) {  in send_up_fsm()
237 		if (!sess->opts->server)  in send_up_fsm()
240 		if (!io_lowbuffer_alloc(sess, wb, wbsz, wbmax, isz)) {  in send_up_fsm()
244 		io_lowbuffer_int(sess, *wb, &pos, *wbsz, up->cur->idx);  in send_up_fsm()
255 		if (!sess->opts->server)  in send_up_fsm()
258 		if (!io_lowbuffer_alloc(sess, wb, wbsz, wbmax, 20)) {  in send_up_fsm()
264 		io_lowbuffer_buf(sess, *wb, &pos, *wbsz, buf, 20);  in send_up_fsm()
283 send_dl_enqueue(struct sess *sess, struct send_dlq *q,  in send_dl_enqueue()  argument
335 	if (!sess->opts->dry_run) {  in send_dl_enqueue()
336 		s->blks = blk_recv(sess, fd, fl[idx].path);  in send_dl_enqueue()
356 rsync_sender(struct sess *sess, int fdin,  in rsync_sender()  argument
390 	if (!flist_gen(sess, argc, argv, &fl, &flsz)) {  in rsync_sender()
396 	if (!sess->opts->server && sess->opts->del)  in rsync_sender()
397 		send_rules(sess, fdout);  in rsync_sender()
404 	if (!flist_send(sess, fdin, fdout, fl, flsz)) {  in rsync_sender()
407 	} else if (!io_write_int(sess, fdout, 0)) {  in rsync_sender()
414 	if (flsz == 0 && sess->opts->server) {  in rsync_sender()
418 	} else if (!sess->opts->server)  in rsync_sender()
426 	if (sess->opts->server)  in rsync_sender()
427 		recv_rules(sess, fdin);  in rsync_sender()
472 		if (sess->mplex_reads && (pfd[0].revents & POLLIN)) {  in rsync_sender()
473 			if (!io_read_flush(sess, fdin)) {  in rsync_sender()
476 			} else if (sess->mplex_read_remain == 0) {  in rsync_sender()
495 			if (!io_read_int(sess, fdin, &idx)) {  in rsync_sender()
499 			if (!send_dl_enqueue(sess,  in rsync_sender()
576 			sess->total_write += ssz;  in rsync_sender()
587 			if (!send_up_fsm(sess, &phase,  in rsync_sender()
623 			hash_file_start(&up.stat.ctx, sess);  in rsync_sender()
658 	if (!sess_stats_send(sess, fdout)) {  in rsync_sender()
665 	if (!io_read_int(sess, fdin, &idx)) {  in rsync_sender()