Home
last modified time | relevance | path

Searched refs:resp (Results 1 – 24 of 24) sorted by relevance

/memcached-1.6.32/
Dproxy_internal.c74 resp_add_iov(resp, resp->wbuf, len + 2); in pout_string()
249 resp_add_iov(resp, resp->wbuf, p - resp->wbuf); in process_get_cmd()
935 resp_add_iov(resp, resp->wbuf, p - resp->wbuf); in process_mget_cmd()
1042 resp_add_iov(resp, resp->wbuf, resp->wbytes); in process_mget_cmd()
1174 resp->wbytes = p - resp->wbuf; in process_mset_cmd()
1253 resp->wbytes = p - resp->wbuf; in process_mset_cmd()
1254 resp_add_iov(resp, resp->wbuf, resp->wbytes); in process_mset_cmd()
1395 resp->wbytes = p - resp->wbuf; in process_mdelete_cmd()
1398 resp_add_iov(resp, resp->wbuf, resp->wbytes); in process_mdelete_cmd()
1624 resp->wbytes = p - resp->wbuf; in process_marithmetic_cmd()
[all …]
Dproto_text.c53 mc_resp *resp = c->resp; in _finalize_mset() local
124 resp->wbytes = p - resp->wbuf; in _finalize_mset()
556 mc_resp *resp = c->resp; in process_get_command() local
687 resp = c->resp; in process_get_command()
892 resp_add_iov(resp, resp->wbuf, resp->wbytes); in process_meta_command()
1088 mc_resp *resp = c->resp; in process_mget_command() local
1272 resp_add_iov(resp, resp->wbuf, p - resp->wbuf); in process_mget_command()
1381 resp_add_iov(resp, resp->wbuf, resp->wbytes); in process_mget_command()
1406 mc_resp *resp = c->resp; in process_mset_command() local
1750 resp_add_iov(resp, resp->wbuf, resp->wbytes); in process_mdelete_command()
[all …]
Dproto_proxy.c595 mc_resp *resp = rctx->resp; in proxy_return_rctx_cb() local
762 assert(resp != NULL); in proxy_out_errstring()
764 resp_reset(resp); in proxy_out_errstring()
775 char *w = resp->wbuf; in proxy_out_errstring()
783 resp_add_iov(resp, resp->wbuf, len + prefix_len + 2); in proxy_out_errstring()
832 resp->tosend = 0; in _proxy_run_tresp_to_resp()
842 resp->iov[0].iov_base = resp->wbuf; in _proxy_run_tresp_to_resp()
900 mc_resp *resp = rctx->resp; in proxy_run_rcontext() local
935 resp_add_iov(resp, resp->wbuf, l); in proxy_run_rcontext()
1126 resp_add_iov(c->resp, c->resp->wbuf, ENDLEN); in proxy_process_command()
[all …]
Dmemcached.c841 resp = resp_finish(c, resp); in conn_release_items()
1027 resp->chunked_data_iov = resp->iovcnt; in resp_add_chunked_iov()
1165 c->resp = resp; in resp_start()
1167 c->resp->next = resp; in resp_start()
1168 c->resp = resp; in resp_start()
1233 if (c->resp == resp) { in resp_finish()
1248 mc_resp *resp = c->resp; in out_string() local
1742 mc_resp *resp = c->resp; in write_and_free() local
2594 resp = resp->next;
2645 resp = resp->next;
[all …]
Dproxy_result.c27 if (r->status == MCMC_OK && r->resp.code != MCMC_CODE_END) { in mcplib_response_hit()
44 if (r->resp.vlen >= 2) { in mcplib_response_vlen()
45 lua_pushinteger(L, r->resp.vlen-2); in mcplib_response_vlen()
57 lua_pushinteger(L, r->resp.code); in mcplib_response_code()
66 if (r->resp.rline != NULL) { in mcplib_response_line()
67 lua_pushlstring(L, r->resp.rline, r->resp.rlen); in mcplib_response_line()
Dproxy_network.c507 if (r->resp.code == MCMC_WANT_READ) { in proxy_backend_drive_machine()
516 switch (r->resp.type) { in proxy_backend_drive_machine()
527 assert(r->resp.vlen == 0); in proxy_backend_drive_machine()
571 r->blen = r->resp.reslen + r->resp.vlen; in proxy_backend_drive_machine()
597 if (r->resp.vlen != r->resp.vlen_read) { in proxy_backend_drive_machine()
600 assert(be->rbufused == r->resp.reslen+r->resp.vlen_read); in proxy_backend_drive_machine()
603 memcpy(r->buf, be->rbuf, r->resp.reslen + r->resp.vlen_read); in proxy_backend_drive_machine()
604 r->bread = r->resp.reslen + r->resp.vlen_read; in proxy_backend_drive_machine()
613 memcpy(r->buf, be->rbuf, r->resp.reslen+r->resp.vlen_read); in proxy_backend_drive_machine()
617 be->rbufused -= r->resp.reslen + r->resp.vlen_read; in proxy_backend_drive_machine()
[all …]
Dstorage.c35 mc_resp *resp; member
147 mc_resp *resp = p->resp; in _storage_get_item_cb() local
182 resp->skip = true; in _storage_get_item_cb()
197 resp->tosend -= resp->iov[p->iovec_data].iov_len + hdr_len; in _storage_get_item_cb()
215 resp->iovcnt = 1; in _storage_get_item_cb()
218 resp->tosend = 4; in _storage_get_item_cb()
223 resp->tosend -= resp->iov[i].iov_len; in _storage_get_item_cb()
228 resp->chunked_total = 0; in _storage_get_item_cb()
289 p->resp = resp; in storage_get_item()
336 p->iovec_data = resp->iovcnt; in storage_get_item()
[all …]
Dproto_bin.c134 mc_resp *resp = c->resp; in add_bin_header() local
138 resp_reset(resp); in add_bin_header()
166 resp->wbytes = sizeof(header->response); in add_bin_header()
167 resp_add_iov(resp, resp->wbuf, resp->wbytes); in add_bin_header()
223 resp_add_iov(c->resp, errstr, len); in write_bin_error()
248 mc_resp *resp = c->resp; in write_bin_response() local
250 resp_add_iov(resp, d, dlen); in write_bin_response()
448 resp_add_iov(c->resp, ofs, nkey); in write_bin_miss_response()
559 c->resp->item = NULL; in process_bin_get_or_touch()
561 c->resp->item = it; in process_bin_get_or_touch()
[all …]
Dproxy_inspector.c312 if (res->resp.type == MCMC_RESP_META) { in mcp_inspector_hasflag_r()
316 mcmc_tokenize_res(res_buf(res), res->resp.reslen, &res->tok); in mcp_inspector_hasflag_r()
345 if (res->resp.type == MCMC_RESP_META) { in mcp_inspector_flagtoken_r()
346 mcmc_tokenize_res(res_buf(res), res->resp.reslen, &res->tok); in mcp_inspector_flagtoken_r()
381 if (res->resp.type == MCMC_RESP_META) { in mcp_inspector_flagint_r()
382 mcmc_tokenize_res(res_buf(res), res->resp.reslen, &res->tok); in mcp_inspector_flagint_r()
455 if (res->resp.type == MCMC_RESP_META) { in mcp_inspector_flagis_r()
456 mcmc_tokenize_res(res_buf(res), res->resp.reslen, &res->tok); in mcp_inspector_flagis_r()
Dmemcached.h816 mc_resp *resp; // associated response object member
853 mc_resp *resp; // tail response. member
1052 void resp_reset(mc_resp *resp);
1053 void resp_add_iov(mc_resp *resp, const void *buf, int len);
1054 void resp_add_chunked_iov(mc_resp *resp, const void *buf, int len);
1057 mc_resp* resp_finish(conn *c, mc_resp *resp);
1058 void resp_free(LIBEVENT_THREAD *th, mc_resp *resp);
Dstorage.h18 int storage_get_item(conn *c, item *it, mc_resp *resp);
Dproxy.h492 mcmc_resp_t resp; member
517 mc_resp *resp; member
752 mc_resp *resp; // top level response object to fill. member
859 void proxy_out_errstring(mc_resp *resp, char *type, const char *str);
Dproxy_mutator.c449 if (srs->resp.type == MCMC_RESP_META) { in mut_step_n()
450 mcmc_tokenize_res(srs->buf, srs->resp.reslen, &srs->tok); in mut_step_n()
683 if (srs->resp.type != MCMC_RESP_META) { in mut_step_n()
687 mcmc_tokenize_res(srs->buf, srs->resp.reslen, &srs->tok); in mut_step_n()
1049 if (mcmc_parse_buf(rs->buf, run->d_pos - rs->buf, &rs->resp) != MCMC_OK) { in mcp_mut_run()
Dproxy_request.c631 if (r->resp.value) { in mcplib_request()
632 val = r->resp.value; in mcplib_request()
633 vlen = r->resp.vlen_read; // paranoia, so we can't overread into memory. in mcplib_request()
Dproxy_lua.c1382 rtype = rs->resp.type; in mcplib_log_req()
1383 rcode = rs->resp.code; in mcplib_log_req()
1444 rtype = rs->resp.type; in mcplib_log_reqsample()
1445 rcode = rs->resp.code; in mcplib_log_reqsample()
Dproxy_luafgen.c335 rctx->resp = NULL; in _mcp_funcgen_return_rctx()
834 r->resp.code = MCMC_CODE_SERVER_ERROR; in _mcp_resume_rctx_process_error()
848 r->resp.code = MCMC_CODE_SERVER_ERROR; in _mcp_start_rctx_process_error()
1064 if (res->resp.code != MCMC_CODE_END) { in mcp_process_rqueue_return()
/memcached-1.6.32/vendor/mcmc/
Dexample.c18 mcmc_resp_t resp; in show_response_buffer() local
26 status = mcmc_parse_buf(rbuf, bread, &resp); in show_response_buffer()
27 } while (resp.code == MCMC_WANT_READ); in show_response_buffer()
38 if (resp.vlen != resp.vlen_read) { in show_response_buffer()
41 val = malloc(resp.vlen); in show_response_buffer()
42 memcpy(val, resp.value, resp.vlen_read); in show_response_buffer()
43 size_t toread = resp.vlen - resp.vlen_read; in show_response_buffer()
44 char *buf = val + resp.vlen_read; in show_response_buffer()
51 val = resp.value; in show_response_buffer()
/memcached-1.6.32/t/
Dudp.t69 my $resp = construct_udp_message($res);
70 is($resp, "VALUE bigvalue 0 $bsize\r\n$bvalue\r\nEND\r\n");
101 my $resp = construct_udp_message($datagrams);
104 is($resp,"STORED\r\n","Store key $key using ASCII protocol");
107 $resp_opaque, $resp_ident_hi, $resp_ident_lo) = unpack(::RES_PKT_FMT, $resp);
126 my $resp = construct_udp_message($datagrams);
136 $resp_opaque, $resp_ident_hi, $resp_ident_lo) = unpack(::RES_PKT_FMT, $resp);
159 my $resp = construct_udp_message($datagrams);
162 is($resp,"DELETED\r\n","Delete key $key using ASCII protocol");
165 $resp_opaque, $resp_ident_hi, $resp_ident_lo) = unpack(::RES_PKT_FMT, $resp);
[all …]
Ddash-M.t15 my $resp = "STORED\r\n";
18 while($resp eq "STORED\r\n") {
21 $resp = scalar <$sock>;
Dmetaget.t924 my $resp = shift;
927 if ($resp =~ m/^VA (\d+) ([^\r]+)\r\n(.*)\r\n/gm) {
931 } elsif ($resp =~ m/^HD\s*([^\r]+)\r\n/gm) {
934 } elsif ($resp =~ m/^EN/gm) {
937 die "Unable to parse mget response: $resp";
944 my $resp = shift;
946 if ($resp =~ m/^(\w\w)\s*([^\r]+)\r\n/gm) {
Dbinary-extstore.t425 my $resp = ($resp_hi * 2 ** 32) + $resp_lo;
427 return $resp, $rcas;
Dbinary-sasl.t475 my $resp = ($resp_hi * 2 ** 32) + $resp_lo;
477 return $resp;
Dbinary.t704 my $resp = ($resp_hi * 2 ** 32) + $resp_lo;
706 return $resp, $rcas;
/memcached-1.6.32/doc/
Dprotocol.txt1326 | response_obj_bytes | 64u | Total bytes used for resp. objects. is a |
1328 | read_buf_count | 64u | Total read/resp buffers allocated |
1329 | read_buf_bytes | 64u | Total read/resp buffer bytes allocated |
1330 | read_buf_bytes_free | 64u | Total read/resp buffer bytes cached |
1518 | read_obj_mem_limit| 32u | Megabyte limit for conn. read/resp buffers. |