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)
535 dm2s_t *dm2sp = (dm2s_t *)wq->q_ptr;
546 dm2s_start(wq, dm2sp);
560 dm2s_wput(queue_t *wq, mblk_t *mp)
562 dm2s_t *dm2sp = (dm2s_t *)wq->q_ptr;
587 (void) putq(wq, mp);
588 qenable(wq);
597 qreply(wq, mp);
610 miocnak(wq, mp, 0, EINVAL);
628 flushq(wq, FLUSHDATA);
634 flushq(RD(wq), FLUSHDATA);
635 qreply(wq, mp);
901 dm2s_start(queue_t *wq, dm2s_t *dm2sp)
910 while ((mp = getq(wq)) != NULL) {
914 ret = dm2s_transmit(wq, mp, dm2sp->ms_target,
925 dm2sp->ms_wq_timeoutid = qtimeout(wq,
937 flushq(wq, FLUSHDATA);
938 (void) putnextctl(RD(wq), M_HANGUP);
1037 * Note: flushing the wq initiates a faster close.
1053 dm2s_transmit(queue_t *wq, mblk_t *mp, target_id_t target, mkey_t key)
1055 dm2s_t *dm2sp = (dm2s_t *)wq->q_ptr;
1086 (void) putbq(wq, mp);
1111 (void) putbq(wq, mp);