Lines Matching refs:rbytes
554 c->rbytes = c->wbytes = 0; in conn_new()
708 if (c->rsize > READ_BUFFER_HIGHWAT && c->rbytes < DATA_BUFFER_SIZE) { in conn_shrink()
712 memmove(c->rbuf, c->rcurr, (size_t)c->rbytes); in conn_shrink()
1771 memmove(c->rbuf, c->rcurr, c->rbytes); in bin_read_key()
1998 MEMCACHED_PROCESS_COMMAND_START(c->sfd, c->rcurr, c->rbytes); in dispatch_bin_command()
2457 if (c->rbytes > 0) { in reset_cmd_handler()
3791 MEMCACHED_PROCESS_COMMAND_START(c->sfd, c->rcurr, c->rbytes); in process_command()
4042 assert(c->rbytes > 0); in try_read_command()
4059 if (c->rbytes < sizeof(c->binary_header)) { in try_read_command()
4066 memmove(c->rbuf, c->rcurr, c->rbytes); in try_read_command()
4120 c->rbytes -= sizeof(c->binary_header); in try_read_command()
4126 if (c->rbytes == 0) in try_read_command()
4129 el = memchr(c->rcurr, '\n', c->rbytes); in try_read_command()
4131 if (c->rbytes > 1024) { in try_read_command()
4157 assert(cont <= (c->rcurr + c->rbytes)); in try_read_command()
4162 c->rbytes -= (cont - c->rcurr); in try_read_command()
4202 c->rbytes = res; in try_read_udp()
4228 if (c->rbytes != 0) /* otherwise there's nothing to copy */ in try_read_network()
4229 memmove(c->rbuf, c->rcurr, c->rbytes); in try_read_network()
4234 if (c->rbytes >= c->rsize) { in try_read_network()
4247 c->rbytes = 0; /* ignore what we read */ in try_read_network()
4256 int avail = c->rsize - c->rbytes; in try_read_network()
4257 res = read(c->sfd, c->rbuf + c->rbytes, avail); in try_read_network()
4263 c->rbytes += res; in try_read_network()
4420 if (c->rbytes > 0) { in read_into_chunked_item()
4422 int tocopy = c->rbytes > c->rlbytes ? c->rlbytes : c->rbytes; in read_into_chunked_item()
4430 c->rbytes -= tocopy; in read_into_chunked_item()
4591 if (c->rbytes > 0) { in drive_machine()
4626 if (c->rbytes > 0) { in drive_machine()
4627 int tocopy = c->rbytes > c->rlbytes ? c->rlbytes : c->rbytes; in drive_machine()
4634 c->rbytes -= tocopy; in drive_machine()
4694 if (c->rbytes > 0) { in drive_machine()
4695 int tocopy = c->rbytes > c->sbytes ? c->sbytes : c->rbytes; in drive_machine()
4698 c->rbytes -= tocopy; in drive_machine()