Home
last modified time | relevance | path

Searched refs:mcp_request_t (Results 1 – 8 of 8) sorted by relevance

/memcached-1.6.32/
Dproxy_request.c457 …mcp_request_t *rq = lua_newuserdatauv(L, sizeof(mcp_request_t) + MCP_REQUEST_MAXLEN + KEY_MAX_LENG… in mcp_new_request()
460 memset(rq, 0, sizeof(mcp_request_t)); in mcp_new_request()
477 memset(rq, 0, sizeof(mcp_request_t)); in mcp_set_request()
650 mcp_request_t *rq = mcp_new_request(L, &pr, cmd, len); in mcplib_request()
722 mcp_request_t *rq = luaL_checkudata(L, 1, "mcp.request"); in mcplib_request_token()
763 mcp_request_t *rq = luaL_checkudata(L, 1, "mcp.request"); in mcplib_request_token_int()
800 mcp_request_t *rq = luaL_checkudata(L, 1, "mcp.request"); in mcplib_request_ntokens()
812 mcp_request_t *rq = luaL_checkudata(L, 1, "mcp.request"); in mcplib_request_has_flag()
836 mcp_request_t *rq = luaL_checkudata(L, 1, "mcp.request"); in mcplib_request_flag_token()
892 mcp_request_t *rq = luaL_checkudata(L, 1, "mcp.request"); in mcplib_request_flag_token_int()
[all …]
Dproxy.h315 typedef struct mcp_request_s mcp_request_t; typedef
624 void mcp_set_request(mcp_parser_t *pr, mcp_request_t *r, const char *command, size_t cmdlen);
726 mcp_request_t *rq; // request set to this slot
749 mcp_request_t *request; // ptr to the above reference.
811 void mcp_request_cleanup(LIBEVENT_THREAD *t, mcp_request_t *rq);
835 void mcp_set_resobj(mcp_resp_t *r, mcp_request_t *rq, mcp_backend_t *be, LIBEVENT_THREAD *t);
844 void mcp_request_attach(mcp_request_t *rq, io_pending_proxy_t *p);
845 int mcp_request_render(mcp_request_t *rq, int idx, char flag, const char *tok, size_t len);
846 int mcp_request_append(mcp_request_t *rq, const char flag, const char *tok, size_t len);
847 int mcp_request_find_flag_index(mcp_request_t *rq, const char flag);
[all …]
Dproxy_inspector.c203 mcp_request_t *rq = arg; in mcp_inspector_sepkey_r()
267 mcp_request_t *rq = arg; in mcp_inspector_keybegin_r()
284 mcp_request_t *rq = arg; in mcp_inspector_keyis_r()
303 mcp_request_t *rq = arg; in mcp_inspector_hasflag_r()
333 mcp_request_t *rq = arg; in mcp_inspector_flagtoken_r()
367 mcp_request_t *rq = arg; in mcp_inspector_flagint_r()
439 mcp_request_t *rq = arg; in mcp_inspector_flagis_r()
Dproxy_mutator.c278 mcp_request_t *srq = lua_touserdata(run->L, idx); in mut_step_n()
320 mcp_request_t *srq = lua_touserdata(run->L, idx); in mut_step_n()
665 mcp_request_t *srq = lua_touserdata(run->L, idx); in mut_step_n()
771 mcp_request_t *srq; in mut_step_n()
1002 mcp_request_t *rq = run->arg; in mcp_mut_run()
Dproxy_luafgen.c450 …mcp_request_t *rq = lua_newuserdatauv(L, sizeof(mcp_request_t) + MCP_REQUEST_MAXLEN + KEY_MAX_LENG… in mcp_funcgen_start()
451 memset(rq, 0, sizeof(mcp_request_t)); in mcp_funcgen_start()
751 static void _mcplib_rcontext_queue(lua_State *L, mcp_rcontext_t *rctx, mcp_request_t *rq, int handl… in _mcplib_rcontext_queue()
786 mcp_request_t *rq = luaL_checkudata(L, 2, "mcp.request"); in mcplib_rcontext_enqueue()
1135 mcp_request_t *rq = rqu->rq; in mcp_run_rcontext_handle()
1252 mcp_request_t *rq = luaL_checkudata(L, 2, "mcp.request"); in mcplib_rcontext_enqueue_and_wait()
Dproto_proxy.c718 mcp_request_t *rq = rctx->request; in complete_nread_proxy()
1248 void mcp_set_resobj(mcp_resp_t *r, mcp_request_t *rq, mcp_backend_t *be, LIBEVENT_THREAD *t) { in mcp_set_resobj()
1284 mcp_resp_t *mcp_prep_resobj(lua_State *L, mcp_request_t *rq, mcp_backend_t *be, LIBEVENT_THREAD *t)… in mcp_prep_resobj()
1306 io_pending_proxy_t *mcp_queue_rctx_io(mcp_rcontext_t *rctx, mcp_request_t *rq, mcp_backend_t *be, m… in mcp_queue_rctx_io()
Dproxy_lua.c1378 mcp_request_t *rq = luaL_checkudata(L, 1, "mcp.request"); in mcplib_log_req()
1440 mcp_request_t *rq = luaL_checkudata(L, 4, "mcp.request"); in mcplib_log_reqsample()
Dproxy_internal.c1655 mcp_request_t *rq = luaL_checkudata(L, 1, "mcp.request"); in mcplib_internal_run()