Lines Matching refs:thread
23 io_queue_cb_t *qcb = thread_io_queue_get(c->thread, q->type); in _mcp_queue_hack()
192 lua_State *L = fgen->thread->L; in _mcplib_funcgen_cache()
201 mcp_funcgen_cleanup(fgen->thread->L, fgen); in _mcplib_funcgen_cache()
228 mcp_resp_t *r = mcp_prep_bare_resobj(L, fgen->thread); in _mcplib_funcgen_gencall()
326 lua_State *L = fgen->thread->L; in _mcp_funcgen_return_rctx()
338 mcp_request_cleanup(fgen->thread, rctx->request); in _mcp_funcgen_return_rctx()
352 mcp_response_cleanup(fgen->thread, rqu->res_obj); in _mcp_funcgen_return_rctx()
392 WSTAT_DECR(rctx->fgen->thread, proxy_req_active, 1); in mcp_funcgen_return_rctx()
461 WSTAT_INCR(fgen->thread, proxy_req_active, 1); in mcp_funcgen_start()
595 mcp_sharedvm_delta(fgen->thread->proxy_ctx, SHAREDVM_FGEN_IDX, fgen->name, 1); in mcplib_funcgenbare_new()
608 fgen->thread = t; in mcplib_funcgen_new()
717 mcp_sharedvm_delta(fgen->thread->proxy_ctx, SHAREDVM_FGEN_IDX, fgen->name, 1); in mcplib_funcgen_ready()
832 mcp_resp_t *r = mcp_prep_bare_resobj(rctx->Lc, rctx->fgen->thread); in _mcp_resume_rctx_process_error()
846 mcp_resp_t *r = mcp_prep_bare_resobj(rctx->Lc, rctx->fgen->thread); in _mcp_start_rctx_process_error()
973 do_cache_free(p->thread->io_cache, p); in proxy_return_rqu_dummy_cb()
1125 do_cache_free(p->thread->io_cache, p); in proxy_return_rqu_cb()
1141 mcp_set_resobj(rqu->res_obj, rq, be, rctx->fgen->thread); in mcp_run_rcontext_handle()
1929 fgen->thread = t; in mcplib_router_new()