Searched refs:rbytes (Results 1 – 5 of 5) sorted by relevance
| /memcached-1.6.32/ |
| D | memcached.c | 729 c->rbytes = 0; in conn_new()
907 c->rbytes = 0; in conn_close()
1436 if (c->rbytes > 0) { in reset_cmd_handler()
2382 assert(c->rbytes > 0);
2404 assert(c->rbytes > 0);
2445 c->rbytes = res;
2507 c->rbytes += res;
2943 if (c->rbytes > 0) {
2945 int tocopy = c->rbytes > c->rlbytes ? c->rlbytes : c->rbytes;
3191 int tocopy = c->rbytes > c->rlbytes ? c->rlbytes : c->rbytes;
[all …]
|
| D | proto_text.c | 344 if (c->rbytes < 2) in try_read_command_asciiauth()
347 el = memchr(c->rcurr, '\n', c->rbytes); in try_read_command_asciiauth()
351 if (c->rbytes > 2048) { in try_read_command_asciiauth()
367 c->rbytes -= (el - c->rcurr) + 1; in try_read_command_asciiauth()
391 if (c->rbytes < c->rlbytes) { in try_read_command_asciiauth()
406 c->rbytes -= c->rlbytes; in try_read_command_asciiauth()
448 if (c->rbytes == 0) in try_read_command_ascii()
451 el = memchr(c->rcurr, '\n', c->rbytes); in try_read_command_ascii()
453 if (c->rbytes > 2048) { in try_read_command_ascii()
489 assert(cont <= (c->rcurr + c->rbytes)); in try_read_command_ascii()
[all …]
|
| D | proto_proxy.c | 639 if (c->rbytes == 0) in try_read_command_proxy()
642 el = memchr(c->rcurr, '\n', c->rbytes); in try_read_command_proxy()
644 if (c->rbytes > 1024) { in try_read_command_proxy()
676 assert(cont <= (c->rcurr + c->rbytes)); in try_read_command_proxy()
681 c->rbytes -= (cont - c->rcurr); in try_read_command_proxy()
|
| D | proto_bin.c | 51 if (c->rbytes < sizeof(c->binary_header)) { in try_read_command_binary()
88 if (c->rbytes < keylen + extlen + sizeof(c->binary_header)) { in try_read_command_binary()
116 c->rbytes -= sizeof(c->binary_header) + extlen + keylen; in try_read_command_binary()
906 MEMCACHED_PROCESS_COMMAND_START(c->sfd, c->rcurr, c->rbytes); in dispatch_bin_command()
|
| D | memcached.h | 851 int rbytes; /** how much data, starting from rcur, do we have unparsed */ member
|