Lines Matching refs:rq
201 sbopen(queue_t *rq, dev_t *dev, int oflag, int sflag, cred_t *crp) in sbopen() argument
204 ASSERT(rq); in sbopen()
209 if (rq->q_ptr) in sbopen()
216 sbp->sb_rq = rq; in sbopen()
228 rq->q_ptr = WR(rq)->q_ptr = sbp; in sbopen()
230 qprocson(rq); in sbopen()
238 sbclose(queue_t *rq, int flag, cred_t *credp) in sbclose() argument
240 struct sb *sbp = (struct sb *)rq->q_ptr; in sbclose()
244 qprocsoff(rq); in sbclose()
249 (void) quntimeout(rq, sbp->sb_timeoutid); in sbclose()
265 rq->q_ptr = WR(rq)->q_ptr = NULL; in sbclose()
459 sbrput(queue_t *rq, mblk_t *mp) in sbrput() argument
461 struct sb *sbp = (struct sb *)rq->q_ptr; in sbrput()
469 sbsendit(rq, mp); in sbrput()
483 sbsendit(rq, mp); in sbrput()
486 sbaddmsg(rq, mp); in sbrput()
511 flushq(rq, FLUSHALL); in sbrput()
513 putnext(rq, mp); in sbrput()
525 sbsendit(rq, mp); in sbrput()
532 sbsendit(rq, mp); in sbrput()
535 putnext(rq, mp); in sbrput()
546 sbrsrv(queue_t *rq) in sbrsrv() argument
554 while ((mp = getq(rq)) != NULL) { in sbrsrv()
555 if (!canputnext(rq) && (mp->b_datap->db_type <= QPCTL)) { in sbrsrv()
557 (void) putbq(rq, mp); in sbrsrv()
560 putnext(rq, mp); in sbrsrv()
954 sbaddmsg(queue_t *rq, mblk_t *mp) in sbaddmsg() argument
965 sbp = (struct sb *)rq->q_ptr; in sbaddmsg()
991 sbsendit(rq, mp); in sbaddmsg()
1141 queue_t *rq; in sbtick() local
1145 rq = sbp->sb_rq; in sbtick()
1148 if (putctl(rq, M_CTL) == 0) /* failure */ in sbtick()
1149 sbp->sb_timeoutid = qtimeout(rq, sbtick, sbp, sbp->sb_ticks); in sbtick()
1163 queue_t *rq; in sbclosechunk() local
1173 rq = sbp->sb_rq; in sbclosechunk()
1180 sbsendit(rq, mp); in sbclosechunk()
1195 sbsendit(queue_t *rq, mblk_t *mp) in sbsendit() argument
1197 struct sb *sbp = (struct sb *)rq->q_ptr; in sbsendit()
1199 if (!canputnext(rq)) { in sbsendit()
1201 (void) putq(rq, mp); in sbsendit()
1212 if (qsize(rq) > 0) { in sbsendit()
1214 (void) putq(rq, mp); in sbsendit()
1217 putnext(rq, mp); in sbsendit()