Lines Matching refs:rq
200 sbopen(queue_t *rq, dev_t *dev, int oflag, int sflag, cred_t *crp) in sbopen() argument
203 ASSERT(rq); in sbopen()
208 if (rq->q_ptr) in sbopen()
215 sbp->sb_rq = rq; in sbopen()
227 rq->q_ptr = WR(rq)->q_ptr = sbp; in sbopen()
229 qprocson(rq); in sbopen()
237 sbclose(queue_t *rq, int flag, cred_t *credp) in sbclose() argument
239 struct sb *sbp = (struct sb *)rq->q_ptr; in sbclose()
243 qprocsoff(rq); in sbclose()
248 (void) quntimeout(rq, sbp->sb_timeoutid); in sbclose()
264 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()
547 sbrsrv(queue_t *rq) in sbrsrv() argument
555 while ((mp = getq(rq)) != NULL) { in sbrsrv()
556 if (!canputnext(rq) && (mp->b_datap->db_type <= QPCTL)) { in sbrsrv()
558 (void) putbq(rq, mp); in sbrsrv()
561 putnext(rq, mp); in sbrsrv()
956 sbaddmsg(queue_t *rq, mblk_t *mp) in sbaddmsg() argument
967 sbp = (struct sb *)rq->q_ptr; in sbaddmsg()
993 sbsendit(rq, mp); in sbaddmsg()
1147 queue_t *rq; in sbtick() local
1151 rq = sbp->sb_rq; in sbtick()
1154 if (putctl(rq, M_CTL) == 0) /* failure */ in sbtick()
1155 sbp->sb_timeoutid = qtimeout(rq, sbtick, sbp, sbp->sb_ticks); in sbtick()
1169 queue_t *rq; in sbclosechunk() local
1179 rq = sbp->sb_rq; in sbclosechunk()
1186 sbsendit(rq, mp); in sbclosechunk()
1201 sbsendit(queue_t *rq, mblk_t *mp) in sbsendit() argument
1203 struct sb *sbp = (struct sb *)rq->q_ptr; in sbsendit()
1205 if (!canputnext(rq)) { in sbsendit()
1207 (void) putq(rq, mp); in sbsendit()
1218 if (qsize(rq) > 0) { in sbsendit()
1220 (void) putq(rq, mp); in sbsendit()
1223 putnext(rq, mp); in sbsendit()