Home
last modified time | relevance | path

Searched refs:rctx (Results 1 – 20 of 20) sorted by relevance

/memcached-1.6.32/
Dproxy_luafgen.c53 rctx->lua_narg = 2; in mcp_funcgen_wait_handler()
62 lua_pushinteger(rctx->Lc, rctx->wait_done); in mcp_funcgen_wait_handler()
427 return rctx; in mcp_funcgen_get_rctx()
462 return rctx; in mcp_funcgen_start()
837 mcp_process_rqueue_return(rctx->parent, rctx->parent_handle, r); in _mcp_resume_rctx_process_error()
839 mcp_process_rctx_wait(rctx->parent, rctx->parent_handle); in _mcp_resume_rctx_process_error()
964 mcp_rcontext_t *rctx = p->rctx; in proxy_return_rqu_dummy_cb() local
1032 …if ((status & RQUEUE_R_RESUME) || rctx->wait_done == rctx->wait_count || rctx->pending_reqs == 1) { in mcp_process_rctx_wait()
1039 mcp_rcontext_push_rqu_res(rctx->Lc, rctx, handle); in mcp_process_rctx_wait()
1041 lua_pushinteger(rctx->Lc, rctx->wait_done); in mcp_process_rctx_wait()
[all …]
Dproto_proxy.c591 mcp_rcontext_t *rctx = p->rctx; in proxy_return_rctx_cb() local
696 rctx->pending_reqs = 0; in proxy_cleanup_conn()
1171 if (rctx == NULL) { in proxy_process_command()
1182 rctx->c = c; in proxy_process_command()
1187 rctx->resp = c->resp; in proxy_process_command()
1192 lua_rawgeti(rctx->Lc, LUA_REGISTRYINDEX, rctx->function_ref); in proxy_process_command()
1193 lua_rawgeti(rctx->Lc, LUA_REGISTRYINDEX, rctx->request_ref); in proxy_process_command()
1307 conn *c = rctx->c; in mcp_queue_rctx_io()
1331 p->rctx = rctx; in mcp_queue_rctx_io()
1343 while (rctx->parent) { in mcp_queue_rctx_io()
[all …]
Dproxy.h523 mcp_rcontext_t *rctx; // pointer to request context. member
611 io_pending_proxy_t *mcp_queue_rctx_io(mcp_rcontext_t *rctx, mcp_request_t *rq, mcp_backend_t *be, m…
615 int mcplib_internal_run(mcp_rcontext_t *rctx);
760 void mcp_run_rcontext_handle(mcp_rcontext_t *rctx, int handle);
761 void mcp_process_rctx_wait(mcp_rcontext_t *rctx, int handle);
762 int mcp_process_rqueue_return(mcp_rcontext_t *rctx, int handle, mcp_resp_t *res);
784 void mcp_funcgen_return_rctx(mcp_rcontext_t *rctx);
788 void mcp_rcontext_push_rqu_res(lua_State *L, mcp_rcontext_t *rctx, int handle);
842 int proxy_run_rcontext(mcp_rcontext_t *rctx);
Dproxy_internal.c1653 int mcplib_internal_run(mcp_rcontext_t *rctx) { in mcplib_internal_run() argument
1654 lua_State *L = rctx->Lc; in mcplib_internal_run()
1657 mc_resp *resp = resp_start_unlinked(rctx->c); in mcplib_internal_run()
1658 LIBEVENT_THREAD *t = rctx->c->thread; in mcplib_internal_run()
1762 rctx->resp->io_pending = resp->io_pending; in mcplib_internal_run()
1766 io_queue_t *q = conn_io_queue_get(rctx->c, IO_QUEUE_EXTSTORE); in mcplib_internal_run()
1767 io_pending_proxy_t *io = (io_pending_proxy_t *)rctx->resp->io_pending; in mcplib_internal_run()
1774 io->rctx = rctx; in mcplib_internal_run()
1775 io->c = rctx->c; in mcplib_internal_run()
/memcached-1.6.32/t/
Dproxyfuncgen.lua215 rctx:enqueue(r, t)
250 rctx:enqueue(r, t)
284 rctx:enqueue(r, t)
343 rctx:enqueue(r, t)
381 rctx:enqueue(r, t)
409 rctx:enqueue(r, t)
426 rctx:enqueue(r, t)
430 rctx:enqueue(r, t)
565 rctx:enqueue(r, b)
597 function badreturn_gen(rctx)
[all …]
Dproxyrctxtimeout.lua23 rctx:enqueue(r, near)
27 rctx:enqueue(r, far)
30 local res = rctx:res_any(all[x])
37 return rctx:res_any(near)
56 rctx:enqueue(r, far)
82 rctx:enqueue(r, near)
86 rctx:enqueue(r, far)
109 rctx:enqueue(r, near)
130 rctx:enqueue(r, near)
151 fgen:ready({ n = "sleep", f = function(rctx)
[all …]
Dproxyunits.lua53 map.b = new_basic(zones, function(rctx, a)
55 return rctx:enqueue_and_wait(r, a.t.z1)
59 map.errcheck = new_basic(zones, function(rctx, a)
78 map.getkey = new_basic(zones, function(rctx, a)
87 return rctx:enqueue_and_wait(r, a.t.z1)
94 return rctx:enqueue_and_wait(r, a.t.z1)
98 map.nolabel = new_basic(zones, function(rctx, a)
425 rctx:enqueue(r, z)
426 rctx:wait_cond(3)
427 return rctx:result(a.t.z3)
[all …]
Dproxyrequest.lua10 setfg:ready({ f = function(rctx)
21 return rctx:enqueue_and_wait(r, sh)
28 mgfg:ready({ f = function(rctx)
34 return rctx:enqueue_and_wait(r, h)
37 return rctx:enqueue_and_wait(r, h)
40 return rctx:enqueue_and_wait(r, h)
51 return rctx:enqueue_and_wait(r, h)
54 return rctx:enqueue_and_wait(r, h)
57 return rctx:enqueue_and_wait(r, h)
77 return rctx:enqueue_and_wait(r, h)
[all …]
Dproxyintext.lua8 fg:ready({ f = function(rctx)
10 rctx:enqueue(r, h_a)
11 rctx:enqueue(r, h_b)
12 rctx:wait_cond(2, mcp.WAIT_ANY)
13 return rctx:res_any(h_a)
26 mfg:ready({ f = function(rctx)
Dproxymut.lua54 n = "mgtest", f = function(rctx)
60 local nreq = rctx:request_new()
61 local nres = rctx:response_new()
69 return rctx:enqueue_and_wait(nreq, mgfgh)
72 return rctx:enqueue_and_wait(nreq, mgfgh)
80 local res = rctx:enqueue_and_wait(r, mgfgh)
89 n = "mstest", f = function(rctx)
Dproxyrouter.lua16 function factory(rctx, h)
18 return rctx:enqueue_and_wait(r, h)
22 function d_factory(rctx)
30 fg:ready({ f = function(rctx)
Dproxyins.lua40 n = "sepkey", f = function(rctx)
93 n = "reshasflag", f = function(rctx)
96 local res = rctx:enqueue_and_wait(r, mgreshasfh)
126 n = "reqkey", f = function(rctx)
138 n = "intres", f = function(rctx)
Dproxyconfigmulti2.lua6 f = function(rctx)
8 return rctx:enqueue_and_wait(r, h)
Dproxydepthlim.lua15 n = "depth", f = function(rctx)
17 return rctx:enqueue_and_wait(r, h)
Dproxytags.lua19 f = function(rctx)
21 return rctx:enqueue_and_wait(r, h)
Dproxymatch.lua13 n = "match", f = function(rctx)
15 local res = rctx:enqueue_and_wait(r, h)
Dproxyantiflap.lua28 f = function(rctx)
30 return rctx:enqueue_and_wait(r, handle)
Dproxyslotcache.lua15 fgen:ready({ n = "foo", f = function(rctx)
25 return rctx:enqueue_and_wait(r, h)
Dproxylimits.lua79 f = function(rctx)
81 return rctx:enqueue_and_wait(r, h)
Dproxyconfig.lua85 f = function(rctx)
87 return rctx:enqueue_and_wait(r, h)