Lines Matching refs:p
853 io_pending_proxy_t *p = mcp_queue_rctx_io(rctx->parent, NULL, NULL, r); in _mcp_start_rctx_process_error() local
854 p->return_cb = proxy_return_rqu_cb; in _mcp_start_rctx_process_error()
855 p->queue_handle = rctx->parent_handle; in _mcp_start_rctx_process_error()
856 p->background = true; in _mcp_start_rctx_process_error()
870 io_pending_proxy_t *p = mcp_queue_rctx_io(rctx->parent, NULL, NULL, r); in mcp_start_subrctx() local
871 p->return_cb = proxy_return_rqu_cb; in mcp_start_subrctx()
872 p->queue_handle = rctx->parent_handle; in mcp_start_subrctx()
875 p->background = true; in mcp_start_subrctx()
884 io_pending_proxy_t *p = mcp_queue_rctx_io(rctx->parent, NULL, NULL, NULL); in mcp_start_subrctx() local
885 p->return_cb = proxy_return_rqu_cb; in mcp_start_subrctx()
886 p->queue_handle = rctx->parent_handle; in mcp_start_subrctx()
887 p->background = true; in mcp_start_subrctx()
963 io_pending_proxy_t *p = (io_pending_proxy_t *)pending; in proxy_return_rqu_dummy_cb() local
964 mcp_rcontext_t *rctx = p->rctx; in proxy_return_rqu_dummy_cb()
973 do_cache_free(p->thread->io_cache, p); in proxy_return_rqu_dummy_cb()
1110 io_pending_proxy_t *p = (io_pending_proxy_t *)pending; in proxy_return_rqu_cb() local
1111 mcp_rcontext_t *rctx = p->rctx; in proxy_return_rqu_cb()
1113 if (p->client_resp) { in proxy_return_rqu_cb()
1114 mcp_process_rqueue_return(rctx, p->queue_handle, p->client_resp); in proxy_return_rqu_cb()
1120 mcp_process_rctx_wait(rctx, p->queue_handle); in proxy_return_rqu_cb()
1125 do_cache_free(p->thread->io_cache, p); in proxy_return_rqu_cb()
1142 io_pending_proxy_t *p = mcp_queue_rctx_io(rctx, rq, be, rqu->res_obj); in mcp_run_rcontext_handle() local
1143 p->return_cb = proxy_return_rqu_cb; in mcp_run_rcontext_handle()
1144 p->queue_handle = handle; in mcp_run_rcontext_handle()
1236 io_pending_proxy_t *p = mcp_queue_rctx_io(rctx, NULL, NULL, NULL); in mcplib_rcontext_wait_cond() local
1237 p->return_cb = proxy_return_rqu_dummy_cb; in mcplib_rcontext_wait_cond()
1238 p->background = true; in mcplib_rcontext_wait_cond()