Home
last modified time | relevance | path

Searched refs:mcp_parser_t (Results 1 – 5 of 5) sorted by relevance

/memcached-1.6.32/
Dproxy_request.c10 static int _process_tokenize(mcp_parser_t *pr, const size_t max) { in _process_tokenize()
77 static int _process_request_key(mcp_parser_t *pr) { in _process_request_key()
94 size_t _process_request_next_key(mcp_parser_t *pr) { in _process_request_next_key()
169 static int _process_request_meta(mcp_parser_t *pr) { in _process_request_meta()
183 static int _process_request_mset(mcp_parser_t *pr) { in _process_request_mset()
213 static int _process_request_gat(mcp_parser_t *pr) { in _process_request_gat()
229 static int _process_request_noreply(mcp_parser_t *pr) { in _process_request_noreply()
494 mcp_parser_t *pr = &rq->pr; in mcp_request_render()
554 mcp_parser_t *pr = &rq->pr; in mcp_request_append()
594 mcp_parser_t *pr = &rq->pr; in mcp_request_attach()
[all …]
Dproxy.h316 typedef struct mcp_parser_s mcp_parser_t; typedef
352 mcp_parser_t pr; // non-lua-specific parser handling.
621 size_t _process_request_next_key(mcp_parser_t *pr);
622 int process_request(mcp_parser_t *pr, const char *command, size_t cmdlen);
623 mcp_request_t *mcp_new_request(lua_State *L, mcp_parser_t *pr, const char *command, size_t cmdlen);
624 void mcp_set_request(mcp_parser_t *pr, mcp_request_t *r, const char *command, size_t cmdlen);
782 mcp_rcontext_t *mcp_funcgen_start(lua_State *L, mcp_funcgen_t *fgen, mcp_parser_t *pr);
Dproxy_internal.c309 static void process_update_cmd(LIBEVENT_THREAD *t, mcp_parser_t *pr, mc_resp *resp, int comm, bool … in process_update_cmd()
420 static void process_arithmetic_cmd(LIBEVENT_THREAD *t, mcp_parser_t *pr, mc_resp *resp, const bool … in process_arithmetic_cmd()
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()
547 static int _process_token_len(mcp_parser_t *pr, size_t token) { in _process_token_len()
604 static int _meta_flag_preparse(mcp_parser_t *pr, const size_t start, in _meta_flag_preparse()
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 …]
Dproxy_luafgen.c8 static mcp_funcgen_t *mcp_funcgen_route(lua_State *L, mcp_funcgen_t *fgen, mcp_parser_t *pr);
430 mcp_rcontext_t *mcp_funcgen_start(lua_State *L, mcp_funcgen_t *fgen, mcp_parser_t *pr) { in mcp_funcgen_start()
1454 mcp_parser_t pr = {0}; in mcplib_rcontext_request_new()
1566 static mcp_funcgen_t *mcp_funcgen_route(lua_State *L, mcp_funcgen_t *fgen, mcp_parser_t *pr) { in mcp_funcgen_route()
Dproto_proxy.c1012 mcp_parser_t pr = {0}; in proxy_process_command()