src/usr.bin/rsync/sender.c - diff - 1.23

Return to sender.c CVS log

Up to [local] / src / usr.bin / rsync

Diff for /src/usr.bin/rsync/sender.c between version 1.22 and 1.23

version 1.22, 2019/05/08 20:00:25

version 1.23, 2019/05/08 21:30:11

Line 260

Line 260

return 0;

return 0;

}

}

assert(sizeof(buf) == 20);

assert(sizeof(buf) == 20);

blk_recv_ack(sess, buf, up->cur->blks, up->cur->idx);

blk_recv_ack(buf, up->cur->blks, up->cur->idx);

io_lowbuffer_buf(sess, *wb, &pos, *wbsz, buf, 20);

io_lowbuffer_buf(sess, *wb, &pos, *wbsz, buf, 20);

LOG3("%s: primed for %jd B total",

LOG3("%s: primed for %jd B total",

Line 480

Line 480

ERRX1("io_read_flush");

ERRX1("io_read_flush");

goto out;

goto out;

} else if (sess->mplex_read_remain == 0) {

} else if (sess->mplex_read_remain == 0) {

c = io_read_check(sess, fdin);

c = io_read_check(fdin);

if (c < 0) {

if (c < 0) {

ERRX1("io_read_check");

ERRX1("io_read_check");

goto out;

goto out;

Line 507

Line 507

ERRX1("send_dl_enqueue");

ERRX1("send_dl_enqueue");

goto out;

goto out;

}

}

c = io_read_check(sess, fdin);

c = io_read_check(fdin);

if (c < 0) {

if (c < 0) {

ERRX1("io_read_check");

ERRX1("io_read_check");

goto out;

goto out;