Lines Matching refs:wq
1008 static void mir_svc_release(queue_t *wq, mblk_t *mp, bool_t);
1009 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()
2027 mir_svc_release(queue_t *wq, mblk_t *mp, bool_t enable) in mir_svc_release() argument
2029 mir_t *mir = (mir_t *)wq->q_ptr; in mir_svc_release()
2032 ASSERT((wq->q_flag & QREADR) == 0); in mir_svc_release()
2037 qenable(RD(wq)); in mir_svc_release()
2052 (void *)RD(wq)); in mir_svc_release()
2056 putnext(RD(wq), cmp); in mir_svc_release()
2067 "because ref cnt is zero\n", (void *) wq); in mir_svc_release()
2069 mir_svc_idle_start(wq, mir); in mir_svc_release()
2090 mir_svc_start(queue_t *wq) in mir_svc_start() argument
2092 mir_t *mir = (mir_t *)wq->q_ptr; in mir_svc_start()
2101 qenable(RD(wq)); in mir_svc_start()
2108 mir_clnt_idle_stop(queue_t *wq, mir_t *mir) in mir_clnt_idle_stop() argument
2111 ASSERT((wq->q_flag & QREADR) == 0); in mir_clnt_idle_stop()
2121 mir_clnt_idle_start(queue_t *wq, mir_t *mir) in mir_clnt_idle_start() argument
2124 ASSERT((wq->q_flag & QREADR) == 0); in mir_clnt_idle_start()
2127 mir_timer_start(wq, mir, mir->mir_idle_timeout); in mir_clnt_idle_start()
2135 mir_clnt_idle_do_stop(queue_t *wq) in mir_clnt_idle_do_stop() argument
2137 mir_t *mir = (mir_t *)wq->q_ptr; in mir_clnt_idle_do_stop()
2139 RPCLOG(1, "mir_clnt_idle_do_stop: wq 0x%p\n", (void *)wq); in mir_clnt_idle_do_stop()
2142 mir_clnt_idle_stop(wq, mir); in mir_clnt_idle_do_stop()
2152 queue_t *wq = (queue_t *)arg; in mir_timer() local
2153 mir_t *mir = (mir_t *)wq->q_ptr; in mir_timer()
2210 mir_timer_start(wq, mir, tout); in mir_timer()
2224 mir_clnt_idle_start(wq, mir); in mir_timer()
2235 clnt_dispatch_notifyall(wq, T_ORDREL_REQ, 0); in mir_timer()
2268 "to close stream (0x%p)\n", (void *) RD(wq)); in mir_timer()
2269 (void) mir_svc_policy_notify(RD(wq), 1); in mir_timer()