Home
last modified time | relevance | path

Searched refs:mc_resp (Results 1 – 11 of 11) sorted by relevance

/memcached-1.6.32/
Dmemcached.h798 } mc_resp; typedef
807 mc_resp r[];
816 mc_resp *resp; // associated response object
853 mc_resp *resp; // tail response.
854 mc_resp *resp_head; // first response in current stack.
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);
1056 mc_resp *resp_start_unlinked(conn *c);
1057 mc_resp* resp_finish(conn *c, mc_resp *resp);
[all …]
Dsizes.c25 display("Response object", sizeof(mc_resp)); in main()
Dproxy_internal.c47 static void pout_string(mc_resp *resp, const char *str) { in pout_string()
80 static void pout_errstring(mc_resp *resp, const char *str) { in pout_errstring()
89 mc_resp *resp = io->tresp; in _storage_get_item_cb()
140 static int proxy_storage_get(LIBEVENT_THREAD *t, item *it, mc_resp *resp, in proxy_storage_get()
464 static void process_delete_cmd(LIBEVENT_THREAD *t, mcp_parser_t *pr, mc_resp *resp) { in process_delete_cmd()
505 static void process_touch_cmd(LIBEVENT_THREAD *t, mcp_parser_t *pr, mc_resp *resp) { in process_touch_cmd()
747 static void process_mget_cmd(LIBEVENT_THREAD *t, mcp_parser_t *pr, mc_resp *resp) { in process_mget_cmd()
1055 static void process_mset_cmd(LIBEVENT_THREAD *t, mcp_parser_t *pr, mc_resp *resp) { in process_mset_cmd()
1265 static void process_mdelete_cmd(LIBEVENT_THREAD *t, mcp_parser_t *pr, mc_resp *resp) { in process_mdelete_cmd()
1410 static void process_marithmetic_cmd(LIBEVENT_THREAD *t, mcp_parser_t *pr, mc_resp *resp) { in process_marithmetic_cmd()
[all …]
Dstorage.h18 int storage_get_item(conn *c, item *it, mc_resp *resp);
Dproxy.h495 mc_resp *cresp; // client mc_resp object during extstore fetches.
517 mc_resp *resp;
532 mc_resp *tresp; // temporary mc_resp for storage to fill.
752 mc_resp *resp; // top level response object to fill.
859 void proxy_out_errstring(mc_resp *resp, char *type, const char *str);
Dproxy_result.c137 mc_resp *cresp = r->cresp; in mcp_response_cleanup()
Dproto_proxy.c595 mc_resp *resp = rctx->resp; in proxy_return_rctx_cb()
758 void proxy_out_errstring(mc_resp *resp, char *type, const char *str) { in proxy_out_errstring()
791 static void _set_noreply_mode(mc_resp *resp, mcp_resp_t *r) { in _set_noreply_mode()
823 static void _proxy_run_tresp_to_resp(mc_resp *tresp, mc_resp *resp) { in _proxy_run_tresp_to_resp()
900 mc_resp *resp = rctx->resp; in proxy_run_rcontext()
913 mc_resp *tresp = r->cresp; in proxy_run_rcontext()
Dmemcached.c826 mc_resp *resp = c->resp_head; in conn_release_items()
989 void resp_reset(mc_resp *resp) { in resp_reset()
1039 mc_resp *resp = NULL; in resp_allocate()
1148 mc_resp *resp = resp_allocate(c); in resp_start()
1204 mc_resp* resp_finish(conn *c, mc_resp *resp) { in resp_finish()
1205 mc_resp *next = resp->next; in resp_finish()
1248 mc_resp *resp = c->resp; in out_string()
1742 mc_resp *resp = c->resp; in write_and_free()
2589 mc_resp *resp = c->resp_head;
2660 mc_resp *resp = c->resp_head;
[all …]
Dproto_text.c53 mc_resp *resp = c->resp; in _finalize_mset()
556 mc_resp *resp = c->resp; in process_get_command()
863 mc_resp *resp = c->resp; in process_meta_command()
1088 mc_resp *resp = c->resp; in process_mget_command()
1406 mc_resp *resp = c->resp; in process_mset_command()
1619 mc_resp *resp = c->resp; in process_mdelete_command()
1769 mc_resp *resp = c->resp; in process_marithmetic_command()
Dstorage.c35 mc_resp *resp;
147 mc_resp *resp = p->resp; in _storage_get_item_cb()
249 int storage_get_item(conn *c, item *it, mc_resp *resp) { in storage_get_item()
Dproto_bin.c134 mc_resp *resp = c->resp; in add_bin_header()
248 mc_resp *resp = c->resp; in write_bin_response()