Lines Matching refs:rctx

94 function prefix_factory_gen(rctx, arg)
106             return rctx:enqueue_and_wait(r, d)
108         return rctx:enqueue_and_wait(r, handle)
119 function direct_factory_gen(rctx, h)
124         return rctx:enqueue_and_wait(r, h)
138 function locality_factory_gen(rctx, h)
145         local res = rctx:enqueue_and_wait(r, h)
154 function first_factory_gen(rctx, arg)
162             rctx:enqueue(r, t[x])
165         return rctx:wait_handle(t[1])
170 function partial_factory_gen(rctx, arg)
179             rctx:enqueue(r, t[x])
182         local done = rctx:wait_cond(wait)
186             local res = rctx:res_good(t[x])
196             local res = rctx:res_any(t[x])
205 function all_factory_gen(rctx, arg)
215         rctx:enqueue(r, t)
216         local done = rctx:wait_cond(count, mode)
219         local res = rctx:res_any(t[1])
227 function fastgood_factory_gen(rctx, arg)
244         rctx:handle_set_cb(v, cb)
250         rctx:enqueue(r, t)
251         local done = rctx:wait_cond(wait, mcp.WAIT_GOOD)
258                 local res = rctx:res_good(t[x])
268                 local res = rctx:res_any(t[x])
278 function fastgoodint_factory_gen(rctx, arg)
284         rctx:enqueue(r, t)
285         local done = rctx:wait_cond(wait, mcp.WAIT_FASTGOOD)
290             local res, mode = rctx:result(t[x])
317 function blocker_factory_gen(rctx, arg)
337     rctx:handle_set_cb(blocker, cb)
343         rctx:enqueue(r, t)
347         local bres = rctx:enqueue_and_wait(r, blocker)
356             local done = rctx:wait_cond(count, mcp.WAIT_ANY)
357             return rctx:res_any(t[1])
365 function logall_factory_gen(rctx, arg)
372         mcp.log_req(req, res, "even more logs", rctx:cfd())
377         rctx:handle_set_cb(v, cb)
381         rctx:enqueue(r, t)
382         return rctx:wait_handle(t[1])
387 function summary_factory_gen(rctx, arg)
402         rctx:handle_set_cb(v, cb)
409         rctx:enqueue(r, t)
413         return rctx:wait_handle(t[1])
418 function waitfor_factory_gen(rctx, arg)
426             rctx:enqueue(r, t)
427             rctx:wait_cond(0) -- issue the requests in the background
430             rctx:enqueue(r, t)
431             rctx:wait_cond(0) -- issue requests and resume
433             local done = rctx:wait_cond(2)
440                 local res = rctx:res_good(x)
447             rctx:enqueue(r, t[1])
448             rctx:wait_cond(0) -- issue the first queued request
450             rctx:enqueue(r, t[2])
451             rctx:enqueue(r, t[3])
453             return rctx:wait_handle(t[1])
456             rctx:enqueue(r, t[1])
457             rctx:enqueue(r, t[2])
458             rctx:wait_handle(t[1])
459             return rctx:wait_handle(t[2])
466 function failover_factory_gen(rctx, arg)
478         local fres = rctx:enqueue_and_wait(r, first)
482             rctx:enqueue(r, t)
484             local done = rctx:wait_cond(1, mcp.WAIT_GOOD)
487                 local res = rctx:res_good(t[x])
494             return rctx:res_any(first)
507 function errors_factory_gen(rctx)
525 function suberrors_factory_gen(rctx)
557 function split_factory_gen(rctx, arg)
565         rctx:enqueue(r, b)
568         return rctx:enqueue_and_wait(r, a)
573 function failgen_factory_gen(rctx)
586 function failgenret_factory_gen(rctx)
597 function badreturn_gen(rctx)
601         return rctx
611 function postreturn_factory(rctx, arg)