Lines Matching refs:pending_reqs
84 assert(rctx->pending_reqs == 0); in mcp_rcontext_cleanup()
316 assert(rctx->pending_reqs == 0); in _mcp_funcgen_return_rctx()
378 if (rctx->pending_reqs != 0) { in mcp_funcgen_return_rctx()
385 rctx->parent->pending_reqs--; in mcp_funcgen_return_rctx()
386 assert(rctx->parent->pending_reqs > -1); in mcp_funcgen_return_rctx()
387 if (rctx->parent->pending_reqs == 0) { in mcp_funcgen_return_rctx()
771 subrctx->pending_reqs++; in _mcplib_rcontext_queue()
966 rctx->pending_reqs--; in proxy_return_rqu_dummy_cb()
967 assert(rctx->pending_reqs > -1); in proxy_return_rqu_dummy_cb()
1031 assert(rctx->pending_reqs != 0); in mcp_process_rctx_wait()
1032 …if ((status & RQUEUE_R_RESUME) || rctx->wait_done == rctx->wait_count || rctx->pending_reqs == 1) { in mcp_process_rctx_wait()
1116 rctx->pending_reqs--; in proxy_return_rqu_cb()
1117 assert(rctx->pending_reqs > -1); in proxy_return_rqu_cb()
1145 rctx->pending_reqs++; in mcp_run_rcontext_handle()
1150 rctx->pending_reqs++; in mcp_run_rcontext_handle()
1239 rctx->pending_reqs++; in mcplib_rcontext_wait_cond()