Lines Matching refs:rq
1123 queue_t *rq; in qattach() local
1131 rq = allocq(); in qattach()
1132 wrq = _WR(rq); in qattach()
1133 STREAM(rq) = STREAM(wrq) = STREAM(qp); in qattach()
1147 rq->q_fp = fp; in qattach()
1173 setq(rq, str->st_rdinit, str->st_wrinit, dmp, qflag, sqtype, B_FALSE); in qattach()
1189 rq->q_flag |= _QINSERTING; in qattach()
1190 rq->q_next = qp; in qattach()
1197 entersq(rq->q_syncq, SQ_OPENCLOSE); in qattach()
1198 error = (*rq->q_qinfo->qi_qopen)(rq, devp, oflag, sflag, crp); in qattach()
1201 leavesq(rq->q_syncq, SQ_OPENCLOSE); in qattach()
1202 ASSERT(qprocsareon(rq)); in qattach()
1206 rq->q_flag &= ~_QINSERTING; in qattach()
1208 qprocsoff(rq); in qattach()
1209 leavesq(rq->q_syncq, SQ_OPENCLOSE); in qattach()
1210 rq->q_next = wrq->q_next = NULL; in qattach()
1211 qdetach(rq, 0, 0, crp, B_FALSE); in qattach()
1736 queue_t *rq; in mlink_file() local
1802 rq = getendq(stp->sd_wrq); in mlink_file()
1804 rq = NULL; in mlink_file()
1806 linkp = alloclink(rq, stpdown->sd_wrq, fpdown); in mlink_file()
1858 rq = _RD(stpdown->sd_wrq); in mlink_file()
1866 wait_sq_svc(rq->q_syncq); in mlink_file()
1871 ASSERT((rq->q_flag & QMT_TYPEMASK) == QMTSAFE); in mlink_file()
1872 ASSERT(rq->q_syncq == SQ(rq) && _WR(rq)->q_syncq == SQ(rq)); in mlink_file()
1873 rq->q_ptr = _WR(rq)->q_ptr = NULL; in mlink_file()
1891 setq(rq, str->st_muxrinit, str->st_muxwinit, dmp, qflag, sqtype, in mlink_file()
1910 rq->q_ptr = _WR(rq)->q_ptr = stpdown; in mlink_file()
1911 setq(rq, &strdata, &stwdata, NULL, QMTSAFE, SQ_CI|SQ_CO, in mlink_file()
1967 cv_broadcast(&rq->q_wait); in mlink_file()
1968 cv_broadcast(&_WR(rq)->q_wait); in mlink_file()
2014 queue_t *rq, *wrq; in munlink() local
2084 rq = _RD(wrq); in munlink()
2091 disable_svc(rq); in munlink()
2092 wait_svc(rq); in munlink()
2139 sq = rq->q_syncq; in munlink()
2168 ASSERT((rq->q_flag & QPERMOD) || in munlink()
2169 ((rq->q_syncq->sq_head == NULL) && in munlink()
2170 (_WR(rq)->q_syncq->sq_head == NULL))); in munlink()
2178 if (rq->q_flag & QPERMOD) { in munlink()
2179 syncq_t *sq = rq->q_syncq; in munlink()
2182 while (rq->q_sqflags & Q_SQQUEUED) { in munlink()
2193 ASSERT(flush_syncq(rq->q_syncq, rq) == 0); in munlink()
2202 flushq(rq, FLUSHALL); in munlink()
2203 flushq(_WR(rq), FLUSHALL); in munlink()
2209 rq->q_ptr = wrq->q_ptr = stpdown; in munlink()
2210 setq(rq, &strdata, &stwdata, NULL, QMTSAFE, SQ_CI|SQ_CO, B_TRUE); in munlink()
2212 ASSERT((rq->q_flag & QMT_TYPEMASK) == QMTSAFE); in munlink()
2213 ASSERT(rq->q_syncq == SQ(rq) && _WR(rq)->q_syncq == SQ(rq)); in munlink()
2215 enable_svc(rq); in munlink()
2486 setq(queue_t *rq, struct qinit *rinit, struct qinit *winit, in setq() argument
2492 ASSERT(rq->q_flag & QREADR); in setq()
2496 wq = _WR(rq); in setq()
2497 rq->q_qinfo = rinit; in setq()
2498 rq->q_hiwat = rinit->qi_minfo->mi_hiwat; in setq()
2499 rq->q_lowat = rinit->qi_minfo->mi_lowat; in setq()
2500 rq->q_minpsz = rinit->qi_minfo->mi_minpsz; in setq()
2501 rq->q_maxpsz = rinit->qi_minfo->mi_maxpsz; in setq()
2509 sq = rq->q_syncq; in setq()
2513 outer_remove(outer, rq->q_syncq); in setq()
2514 if (wq->q_syncq != rq->q_syncq) in setq()
2520 if (sq != SQ(rq)) { in setq()
2521 if (!(rq->q_flag & QPERMOD)) in setq()
2523 if (wq->q_syncq == rq->q_syncq) in setq()
2525 rq->q_syncq = NULL; in setq()
2528 wq->q_syncq != SQ(rq)) { in setq()
2532 ASSERT(rq->q_syncq == NULL || (rq->q_syncq->sq_head == NULL && in setq()
2533 rq->q_syncq->sq_tail == NULL)); in setq()
2537 if (!(rq->q_flag & QPERMOD) && in setq()
2538 rq->q_syncq != NULL && rq->q_syncq->sq_ciputctrl != NULL) { in setq()
2539 ASSERT(rq->q_syncq->sq_nciputctrl == n_ciputctrl - 1); in setq()
2540 SUMCHECK_CIPUTCTRL_COUNTS(rq->q_syncq->sq_ciputctrl, in setq()
2541 rq->q_syncq->sq_nciputctrl, 0); in setq()
2543 kmem_cache_free(ciputctrl_cache, rq->q_syncq->sq_ciputctrl); in setq()
2544 rq->q_syncq->sq_ciputctrl = NULL; in setq()
2545 rq->q_syncq->sq_nciputctrl = 0; in setq()
2559 sq = SQ(rq); in setq()
2570 rq->q_syncq = wq->q_syncq = sq; in setq()
2588 mutex_enter(QLOCK(rq)); in setq()
2589 rq->q_flag = (rq->q_flag & ~QMT_TYPEMASK) | QWANTR | qflag; in setq()
2590 mutex_exit(QLOCK(rq)); in setq()
2595 rq->q_flag = (rq->q_flag & ~QMT_TYPEMASK) | QWANTR | qflag; in setq()
2602 sq->sq_type = rq->q_syncq->sq_type; in setq()
2603 sq->sq_flags = rq->q_syncq->sq_flags; in setq()
2617 rq->q_syncq = wq->q_syncq = sq; in setq()
2623 outer_insert(outer, rq->q_syncq); in setq()
2624 if (wq->q_syncq != rq->q_syncq) in setq()
2627 ASSERT((rq->q_syncq->sq_flags & SQ_TYPES_IN_FLAGS) == in setq()
2628 (rq->q_syncq->sq_type & SQ_TYPES_IN_FLAGS)); in setq()
2631 ASSERT((rq->q_flag & QMT_TYPEMASK) == (qflag & QMT_TYPEMASK)); in setq()
2636 rq->q_struiot = in setq()
2637 (rq->q_flag & QSYNCSTR) ? rinit->qi_struiot : STRUIOT_NONE; in setq()
5319 qprocsareon(queue_t *rq) in qprocsareon() argument
5321 if (rq->q_next == NULL) in qprocsareon()
5323 return (_WR(rq->q_next)->q_next == _WR(rq)); in qprocsareon()
7949 queue_t *rq = _RD(stp->sd_wrq); in strwaitmark() local
7953 while (rq->q_first == NULL && in strwaitmark()
7958 if (str_cv_wait(&rq->q_wait, &stp->sd_lock, 100, 1) == -1) { in strwaitmark()
7965 else if (rq->q_first != NULL && (rq->q_first->b_flag & MSGMARK)) in strwaitmark()