Home
last modified time | relevance | path

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

/memcached-1.6.32/t/
Dproxyrctxtimeout.lua14 local fgen = mcp.funcgen_new()
17 fgen:new_handle(p.z3) }
41 return fgen
45 local fgen = mcp.funcgen_new()
48 fgen:new_handle(p.z3) }
70 return fgen
77 fgen:new_handle(p.z3) }
100 return fgen
121 return fgen
144 return fgen
[all …]
Dproxyfuncgen.lua61 local fgen = mcp.funcgen_new()
74 return fgen
78 local fgen = mcp.funcgen_new()
91 return fgen
113 local fgen = mcp.funcgen_new()
116 return fgen
129 local fgen = mcp.funcgen_new()
132 return fgen
313 return fgen
504 return fgen
[all …]
Dproxyslotcache.lua13 local fgen = mcp.funcgen_new()
14 local h = fgen:new_handle(p)
15 fgen:ready({ n = "foo", f = function(rctx)
31 return fgen
Dproxyunits.lua36 local fgen = mcp.funcgen_new()
39 o.t.z1 = fgen:new_handle(zones.z1)
40 o.t.z2 = fgen:new_handle(zones.z2)
41 o.t.z3 = fgen:new_handle(zones.z3)
42 o.t.dead = fgen:new_handle(zones.dead)
43 o.t.no_label = fgen:new_handle(zones.no_label)
45 fgen:ready({ f = func, a = o})
46 return fgen
/memcached-1.6.32/
Dproxy_luafgen.c158 if (fgen->free > fgen->total/2 - 1) { in _mcplib_funcgen_cache()
179 if (fgen->free + 1 >= fgen->free_max) { in _mcplib_funcgen_cache()
187 fgen->list[fgen->free] = rctx; in _mcplib_funcgen_cache()
200 if (fgen->closed && fgen->free == fgen->total) { in _mcplib_funcgen_cache()
217 rc->fgen = fgen; in _mcplib_funcgen_gencall()
315 mcp_funcgen_t *fgen = rctx->fgen; in _mcp_funcgen_return_rctx() local
377 mcp_funcgen_t *fgen = rctx->fgen; in mcp_funcgen_return_rctx() local
422 rctx = fgen->list[fgen->free-1]; in mcp_funcgen_get_rctx()
423 fgen->list[fgen->free-1] = NULL; in mcp_funcgen_get_rctx()
432 fgen = mcp_funcgen_route(L, fgen, pr); in mcp_funcgen_start()
[all …]
Dproxy.h753 mcp_funcgen_t *fgen; // parent function generator context. member
782 mcp_rcontext_t *mcp_funcgen_start(lua_State *L, mcp_funcgen_t *fgen, mcp_parser_t *pr);
783 mcp_rcontext_t *mcp_funcgen_get_rctx(lua_State *L, int fgen_ref, mcp_funcgen_t *fgen);
787 void mcp_funcgen_dereference(lua_State *L, mcp_funcgen_t *fgen);
Dproxy_lua.c1241 mcp_funcgen_t *fgen = NULL; in mcplib_attach() local
1246 fgen = luaL_checkudata(L, -1, "mcp.funcgen"); // set our pointer ref. in mcplib_attach()
1251 } else if ((fgen = luaL_testudata(L, 2, "mcp.funcgen")) != NULL) { in mcplib_attach()
1258 if (fgen->closed) { in mcplib_attach()
1337 href->ctx = fgen; in mcplib_attach()
Dproto_proxy.c818 for (int x = 0; x < rctx->fgen->max_queues; x++) { in _proxy_run_rcontext_queues()