Lines Matching refs:wq
1012 static void mir_svc_start(queue_t *wq);
1995 mir_svc_start_close(queue_t *wq, mir_t *mir) in mir_svc_start_close() argument
1998 ASSERT((wq->q_flag & QREADR) == 0); in mir_svc_start_close()
2013 qenable(RD(wq)); in mir_svc_start_close()
2019 qenable(wq); in mir_svc_start_close()
2023 mir_svc_hold(queue_t *wq) in mir_svc_hold() argument
2025 mir_t *mir = (mir_t *)wq->q_ptr; in mir_svc_hold()
2037 mir_svc_release(queue_t *wq, mblk_t *mp, bool_t enable) in mir_svc_release() argument
2039 mir_t *mir = (mir_t *)wq->q_ptr; in mir_svc_release()
2042 ASSERT((wq->q_flag & QREADR) == 0); in mir_svc_release()
2047 qenable(RD(wq)); in mir_svc_release()
2062 (void *)RD(wq)); in mir_svc_release()
2066 putnext(RD(wq), cmp); in mir_svc_release()
2077 "because ref cnt is zero\n", (void *) wq); in mir_svc_release()
2079 mir_svc_idle_start(wq, mir); in mir_svc_release()
2100 mir_svc_start(queue_t *wq) in mir_svc_start() argument
2102 mir_t *mir = (mir_t *)wq->q_ptr; in mir_svc_start()
2111 qenable(RD(wq)); in mir_svc_start()
2118 mir_clnt_idle_stop(queue_t *wq, mir_t *mir) in mir_clnt_idle_stop() argument
2121 ASSERT((wq->q_flag & QREADR) == 0); in mir_clnt_idle_stop()
2131 mir_clnt_idle_start(queue_t *wq, mir_t *mir) in mir_clnt_idle_start() argument
2134 ASSERT((wq->q_flag & QREADR) == 0); in mir_clnt_idle_start()
2137 mir_timer_start(wq, mir, mir->mir_idle_timeout); in mir_clnt_idle_start()
2145 mir_clnt_idle_do_stop(queue_t *wq) in mir_clnt_idle_do_stop() argument
2147 mir_t *mir = (mir_t *)wq->q_ptr; in mir_clnt_idle_do_stop()
2149 RPCLOG(1, "mir_clnt_idle_do_stop: wq 0x%p\n", (void *)wq); in mir_clnt_idle_do_stop()
2152 mir_clnt_idle_stop(wq, mir); in mir_clnt_idle_do_stop()
2162 queue_t *wq = (queue_t *)arg; in mir_timer() local
2163 mir_t *mir = (mir_t *)wq->q_ptr; in mir_timer()
2220 mir_timer_start(wq, mir, tout); in mir_timer()
2234 mir_clnt_idle_start(wq, mir); in mir_timer()
2245 clnt_dispatch_notifyall(wq, T_ORDREL_REQ, 0); in mir_timer()
2278 "to close stream (0x%p)\n", (void *) RD(wq)); in mir_timer()
2279 (void) mir_svc_policy_notify(RD(wq), 1); in mir_timer()