Lines Matching refs:handle
730 int handle = lua_tointeger(L, 2); in mcplib_rcontext_handle_set_cb() local
731 if (handle < 0 || handle >= rctx->fgen->max_queues) { in mcplib_rcontext_handle_set_cb()
736 struct mcp_rqueue_s *rqu = &rctx->qslots[handle]; in mcplib_rcontext_handle_set_cb()
751 …ic void _mcplib_rcontext_queue(lua_State *L, mcp_rcontext_t *rctx, mcp_request_t *rq, int handle) { in _mcplib_rcontext_queue() argument
752 if (handle < 0 || handle >= rctx->fgen->max_queues) { in _mcplib_rcontext_queue()
756 struct mcp_rqueue_s *rqu = &rctx->qslots[handle]; in _mcplib_rcontext_queue()
800 int handle = lua_tointeger(L, 3); in mcplib_rcontext_enqueue() local
803 _mcplib_rcontext_queue(L, rctx, rq, handle); in mcplib_rcontext_enqueue()
813 int handle = lua_tointeger(L, 4); in mcplib_rcontext_enqueue() local
817 _mcplib_rcontext_queue(L, rctx, rq, handle); in mcplib_rcontext_enqueue()
976 void mcp_process_rctx_wait(mcp_rcontext_t *rctx, int handle) { in mcp_process_rctx_wait() argument
977 struct mcp_rqueue_s *rqu = &rctx->qslots[handle]; in mcp_process_rctx_wait()
1021 if (handle == rctx->wait_handle) { in mcp_process_rctx_wait()
1039 mcp_rcontext_push_rqu_res(rctx->Lc, rctx, handle); in mcp_process_rctx_wait()
1057 int mcp_process_rqueue_return(mcp_rcontext_t *rctx, int handle, mcp_resp_t *res) { in mcp_process_rqueue_return() argument
1058 struct mcp_rqueue_s *rqu = &rctx->qslots[handle]; in mcp_process_rqueue_return()
1128 void mcp_run_rcontext_handle(mcp_rcontext_t *rctx, int handle) { in mcp_run_rcontext_handle() argument
1130 rqu = &rctx->qslots[handle]; in mcp_run_rcontext_handle()
1144 p->queue_handle = handle; in mcp_run_rcontext_handle()
1158 mcp_process_rctx_wait(rctx, handle); in mcp_run_rcontext_handle()
1254 int handle = lua_tointegerx(L, 3, &isnum); in mcplib_rcontext_enqueue_and_wait() local
1273 _mcplib_rcontext_queue(L, rctx, rq, handle); in mcplib_rcontext_enqueue_and_wait()
1282 rctx->wait_handle = handle; in mcplib_rcontext_enqueue_and_wait()
1291 int handle = lua_tointegerx(L, 2, &isnum); in mcplib_rcontext_wait_handle() local
1298 if (!isnum || handle < 0 || handle >= rctx->fgen->max_queues) { in mcplib_rcontext_wait_handle()
1303 struct mcp_rqueue_s *rqu = &rctx->qslots[handle]; in mcplib_rcontext_wait_handle()
1316 rctx->wait_handle = handle; in mcplib_rcontext_wait_handle()
1365 int handle = lua_tointegerx(L, 2, &isnum); in _mcplib_rcontext_checkhandle() local
1366 if (!isnum || handle < 0 || handle >= rctx->fgen->max_queues) { in _mcplib_rcontext_checkhandle()
1371 struct mcp_rqueue_s *rqu = &rctx->qslots[handle]; in _mcplib_rcontext_checkhandle()
1470 void mcp_rcontext_push_rqu_res(lua_State *L, mcp_rcontext_t *rctx, int handle) { in mcp_rcontext_push_rqu_res() argument
1471 struct mcp_rqueue_s *rqu = &rctx->qslots[handle]; in mcp_rcontext_push_rqu_res()