Lines Matching refs:rlbytes
552 c->rlbytes = 0; in conn_new()
1735 c->rlbytes = c->keylen + extra; in bin_read_key()
1739 if (c->rlbytes > c->rsize - offset) { in bin_read_key()
1741 size_t size = c->rlbytes + sizeof(protocol_binary_request_header); in bin_read_key()
1880 c->rlbytes = vlen; in process_bin_sasl_auth()
2265 c->rlbytes = vlen; in process_bin_update()
2320 c->rlbytes = vlen; in process_bin_append_prepend()
3423 c->rlbytes = it->nbytes; in process_update_command()
4416 while (c->rlbytes > 0) { in read_into_chunked_item()
4422 int tocopy = c->rbytes > c->rlbytes ? c->rlbytes : c->rbytes; in read_into_chunked_item()
4428 c->rlbytes -= tocopy; in read_into_chunked_item()
4432 if (c->rlbytes == 0) { in read_into_chunked_item()
4438 (unused > c->rlbytes ? c->rlbytes : unused)); in read_into_chunked_item()
4445 c->rlbytes -= res; in read_into_chunked_item()
4459 assert(c->rlbytes == 0); in read_into_chunked_item()
4610 if (c->rlbytes == 0) { in drive_machine()
4616 if (c->rlbytes < 0) { in drive_machine()
4618 fprintf(stderr, "Invalid rlbytes to read: len %d\n", c->rlbytes); in drive_machine()
4627 int tocopy = c->rbytes > c->rlbytes ? c->rlbytes : c->rbytes; in drive_machine()
4632 c->rlbytes -= tocopy; in drive_machine()
4635 if (c->rlbytes == 0) { in drive_machine()
4641 res = read(c->sfd, c->ritem, c->rlbytes); in drive_machine()
4650 c->rlbytes -= res; in drive_machine()
4681 (int)c->rlbytes, (int)c->rsize); in drive_machine()