Lines Matching refs:rq
59 int clnopen(queue_t *rq, dev_t *devp, int flag, int sflag, cred_t *crp);
163 clnopen(queue_t *rq, dev_t *devp, int flag, int sflag, cred_t *crp) in clnopen() argument
237 rinit = rq->q_qinfo; in clnopen()
238 winit = WR(rq)->q_qinfo; in clnopen()
239 ASSERT(rq->q_syncq->sq_type == (SQ_CI|SQ_CO)); in clnopen()
240 ASSERT((rq->q_flag & QMT_TYPEMASK) == QMTSAFE); in clnopen()
260 leavesq(rq->q_syncq, SQ_OPENCLOSE); in clnopen()
266 setq(rq, str->st_rdinit, str->st_wrinit, dmp, qflag, sqtype, B_FALSE); in clnopen()
275 entersq(rq->q_syncq, SQ_OPENCLOSE); in clnopen()
281 error = (*rq->q_qinfo->qi_qopen)(rq, &newdev, flag, CLONEOPEN, crp); in clnopen()
295 (void) (*rq->q_qinfo->qi_qclose)(rq, flag, crp); in clnopen()
308 if (backq(WR(rq)) && backq(WR(rq))->q_next == WR(rq)) in clnopen()
309 qprocsoff(rq); in clnopen()
310 leavesq(rq->q_syncq, SQ_OPENCLOSE); in clnopen()
311 rq->q_next = WR(rq)->q_next = NULL; in clnopen()
312 ASSERT(flush_syncq(rq->q_syncq, rq) == 0); in clnopen()
313 ASSERT(flush_syncq(WR(rq)->q_syncq, WR(rq)) == 0); in clnopen()
314 rq->q_ptr = WR(rq)->q_ptr = NULL; in clnopen()
316 setq(rq, rinit, winit, NULL, QMTSAFE, SQ_CI|SQ_CO, in clnopen()
320 entersq(rq->q_syncq, SQ_OPENCLOSE); in clnopen()