Lines Matching refs:wq
114 int dm2s_wput(queue_t *wq, mblk_t *mp);
116 int dm2s_wsrv(queue_t *wq);
121 void dm2s_start(queue_t *wq, dm2s_t *dm2sp);
123 int dm2s_transmit(queue_t *wq, mblk_t *mp, target_id_t target, mkey_t key);
533 dm2s_wsrv(queue_t *wq) in dm2s_wsrv() argument
535 dm2s_t *dm2sp = (dm2s_t *)wq->q_ptr; in dm2s_wsrv()
546 dm2s_start(wq, dm2sp); in dm2s_wsrv()
560 dm2s_wput(queue_t *wq, mblk_t *mp) in dm2s_wput() argument
562 dm2s_t *dm2sp = (dm2s_t *)wq->q_ptr; in dm2s_wput()
587 (void) putq(wq, mp); in dm2s_wput()
588 qenable(wq); in dm2s_wput()
597 qreply(wq, mp); in dm2s_wput()
610 miocnak(wq, mp, 0, EINVAL); in dm2s_wput()
628 flushq(wq, FLUSHDATA); in dm2s_wput()
634 flushq(RD(wq), FLUSHDATA); in dm2s_wput()
635 qreply(wq, mp); in dm2s_wput()
901 dm2s_start(queue_t *wq, dm2s_t *dm2sp) in dm2s_start() argument
910 while ((mp = getq(wq)) != NULL) { in dm2s_start()
914 ret = dm2s_transmit(wq, mp, dm2sp->ms_target, in dm2s_start()
925 dm2sp->ms_wq_timeoutid = qtimeout(wq, in dm2s_start()
937 flushq(wq, FLUSHDATA); in dm2s_start()
938 (void) putnextctl(RD(wq), M_HANGUP); in dm2s_start()
1053 dm2s_transmit(queue_t *wq, mblk_t *mp, target_id_t target, mkey_t key) in dm2s_transmit() argument
1055 dm2s_t *dm2sp = (dm2s_t *)wq->q_ptr; in dm2s_transmit()
1086 (void) putbq(wq, mp); in dm2s_transmit()
1111 (void) putbq(wq, mp); in dm2s_transmit()