Searched refs:rbuf (Results 1 – 10 of 10) sorted by relevance
| /memcached-1.6.32/vendor/mcmc/ |
| D | example.c | 16 static void show_response_buffer(void *c, char *rbuf, size_t bufsize) { in show_response_buffer() argument
22 int bread = recv(mcmc_fd(c), rbuf, bufsize, 0); in show_response_buffer()
26 status = mcmc_parse_buf(rbuf, bread, &resp); in show_response_buffer()
55 printf("read a response: %s\n", rbuf); in show_response_buffer()
148 char *rbuf = malloc(bufsize); in buffer_mode() local
167 show_response_buffer(c, rbuf, bufsize); in buffer_mode()
|
| /memcached-1.6.32/ |
| D | proxy_network.c | 205 free(bec->rbuf); in _cleanup_backend()
504 r->status = mcmc_parse_buf(be->rbuf, be->rbufused, &r->resp); in proxy_backend_drive_machine()
532 memmove(be->rbuf, be->rbuf+r->resp.reslen, be->rbufused); in proxy_backend_drive_machine()
619 memmove(be->rbuf, be->rbuf+r->resp.reslen+r->resp.vlen_read, be->rbufused); in proxy_backend_drive_machine()
629 if (memcmp(be->rbuf, ENDSTR, ENDLEN) != 0) { in proxy_backend_drive_machine()
648 memmove(be->rbuf, be->rbuf+ENDLEN, be->rbufused); in proxy_backend_drive_machine()
669 memcpy(r->buf+r->bread, be->rbuf, tocopy); in proxy_backend_drive_machine()
683 memmove(be->rbuf, be->rbuf+tocopy, be->rbufused); in proxy_backend_drive_machine()
1089 int status = mcmc_parse_buf(be->rbuf, be->rbufused, &r); in proxy_bevalidate_tls_handler()
1259 int status = mcmc_parse_buf(be->rbuf, be->rbufused, &r); in proxy_beconn_handler()
[all …]
|
| D | memcached.c | 395 free(c->rbuf); in rbuf_release()
401 c->rbuf = NULL; in rbuf_release()
407 if (c->rbuf == NULL) { in rbuf_alloc()
409 if (!c->rbuf) { in rbuf_alloc()
416 c->rcurr = c->rbuf; in rbuf_alloc()
434 c->rcurr = c->rbuf = tmp; in rbuf_switch_to_malloc()
649 c->rbuf = NULL; in conn_new()
730 c->rcurr = c->rbuf; in conn_new()
877 if (c->rbuf) in conn_free()
878 free(c->rbuf); in conn_free()
[all …]
|
| D | proxy_tls.c | 176 int n = SSL_read(be->ssl, be->rbuf + be->rbufused, READ_BUFFER_SIZE - be->rbufused); in mcp_tls_read()
|
| D | logger.c | 455 char rbuf[MAX_RBUF_READ * 3]; // x 3 for worst case URI encoding. in _logger_parse_prx_errbe() local
468 uriencode(be_rbuf, rbuf, le->be_rbuflen, MAX_RBUF_READ * 3); in _logger_parse_prx_errbe()
480 (int)le->be_portlen, be_port, (int)le->be_labellen, be_label, le->be_depth, rbuf); in _logger_parse_prx_errbe()
|
| D | proxy.h | 411 char *rbuf; // statically allocated read buffer. member
|
| D | proxy_lua.c | 552 bec->rbuf = malloc(READ_BUFFER_SIZE); in _mcplib_make_backendconn()
553 if (bec->rbuf == NULL) { in _mcplib_make_backendconn()
|
| D | memcached.h | 848 char *rbuf; /** buffer to read commands into */ member
|
| D | proto_proxy.c | 684 assert(c->rcurr <= (c->rbuf + c->rsize)); in try_read_command_proxy()
|
| D | proto_text.c | 497 assert(c->rcurr <= (c->rbuf + c->rsize)); in try_read_command_ascii()
|