Cross Reference: /illumos-gate/usr/src/uts/common/os/strsubr.c

Lines Matching refs:q_flag
84 	(((q)->q_flag & QREADR) == ((q)->q_next->q_flag & QREADR)))
633 		ASSERT(!(q->q_flag & QINSERVICE));			\
1189 		rq->q_flag |= _QINSERTING;
1206 	rq->q_flag &= ~_QINSERTING;
1227 	ASSERT(qp->q_flag & QREADR);
1275 			qp->q_flag |= _QREMOVING;
1282 		ASSERT((qp->q_flag & QWCLOSE) && (wqp->q_flag & QWCLOSE));
1304 	ASSERT((qp->q_flag & QPERMOD) ||
1309 	ASSERT(qp->q_fp != NULL || qp->q_flag & QISDRV);
1323 	ASSERT(qp->q_flag & QREADR);
1325 	qp->q_flag |= QWCLOSE;
1328 	wqp->q_flag |= QWCLOSE;
1338 	ASSERT(qp->q_flag & QREADR);
1340 	qp->q_flag &= ~QWCLOSE;
1343 	wqp->q_flag &= ~QWCLOSE;
1361 	if (qp->q_flag & QENAB && qhead != NULL) {
1371 			qp->q_flag &= ~QENAB;
1391 	ASSERT(qp->q_flag & QREADR);
1411 	if (!(qp->q_flag & QPERMOD)) {
1425 	while (qp->q_flag & (QINSERVICE|QENAB))
1429 	while (wqp->q_flag & (QINSERVICE|QENAB))
1871 	ASSERT((rq->q_flag & QMT_TYPEMASK) == QMTSAFE);
2100 	if (wrq->q_flag & QPERMOD) {
2126 		 * which will access the rq->q_flag. Hence, we have to
2168 		ASSERT((rq->q_flag & QPERMOD) ||
2178 	if (rq->q_flag & QPERMOD) {
2212 	ASSERT((rq->q_flag & QMT_TYPEMASK) == QMTSAFE);
2492 	ASSERT(rq->q_flag & QREADR);
2521 		if (!(rq->q_flag & QPERMOD))
2537 	if (!(rq->q_flag & QPERMOD) &&
2548 	if (!(wq->q_flag & QPERMOD) &&
2585 	 * where canputnext, backenable, etc can access the q_flag.
2589 		rq->q_flag = (rq->q_flag & ~QMT_TYPEMASK) | QWANTR | qflag;
2592 		wq->q_flag = (wq->q_flag & ~QMT_TYPEMASK) | QWANTR | qflag;
2595 		rq->q_flag = (rq->q_flag & ~QMT_TYPEMASK) | QWANTR | qflag;
2596 		wq->q_flag = (wq->q_flag & ~QMT_TYPEMASK) | QWANTR | qflag;
2631 	ASSERT((rq->q_flag & QMT_TYPEMASK) == (qflag & QMT_TYPEMASK));
2637 	    (rq->q_flag & QSYNCSTR) ? rinit->qi_struiot : STRUIOT_NONE;
2639 	    (wq->q_flag & QSYNCSTR) ? winit->qi_struiot : STRUIOT_NONE;
3364 	qp->q_flag	= QUSE | QREADR;
3380 	wqp->q_flag	= QUSE;
3418 	ASSERT(qp->q_flag & QREADR);
3444 	ASSERT(!(qp->q_flag & QENAB));
3445 	ASSERT(!(wqp->q_flag & QENAB));
3456 	if (qp->q_syncq != SQ(qp) && !(qp->q_flag & QPERMOD))
3487 	qp->q_flag &= ~QUSE;
3488 	wqp->q_flag &= ~QUSE;
3491 	/* ASSERT((qp->q_flag & QWANTW) == 0 && (wqp->q_flag & QWANTW) == 0); */
3641 	if (!(q->q_flag & QWCLOSE))
3650 	if (q->q_flag & QENAB) {
3651 		q->q_flag &= ~QENAB;
3655 	q->q_flag &= ~QINSERVICE;
3656 	q->q_flag &= ~QBACK;
4120 		q->q_flag |= QBACK;
4719 		if (q->q_next->q_nfsrv->q_flag & QWANTW)
4753 	if (new->q_flag & _QINSERTING) {
4764 	ASSERT(after->q_flag & QREADR);
4765 	ASSERT(new->q_flag & QREADR);
4783 	new->q_flag &= ~_QINSERTING;
4806 	if (!(new->q_flag & QISDRV))
4866 	ASSERT(qp->q_flag&QREADR);
4872 	if (qp->q_flag & QSYNCSTR) {
4892 			qp->q_flag |= QWANTRMQSYNC;
4899 			wqp->q_flag |= QWANTRMQSYNC;
4913 	isdriver = (qp->q_flag & QISDRV);
5190 		else if (!(q->q_flag & QREADR))
5211 	ASSERT(q->q_flag & QREADR);
6138 		if (q->q_flag & QWCLOSE) {
7115 	ASSERT((qp->q_flag & QPERQ) || (sq->sq_count >= 1));
7123 		isdriver = (qp->q_flag & QISDRV);
7517 		q->q_flag |= QEND;
7519 		q->q_flag &= ~QEND;
7524 		q->q_flag |= QEND;
7526 		q->q_flag &= ~QEND;
7550 	if ((sq_max_size != 0) && (!(q->q_nfsrv->q_flag & QFULL)) &&
7553 			fq->q_flag |= QFULL;
7557 			fq->q_flag |= QFULL;
7571 	if ((q->q_flag & (QFULL|QWANTW)) == 0) {
7588 		q->q_flag &= ~QFULL;
7599 		if ((q->q_flag & QWANTW) &&
7602 			q->q_flag &= ~QWANTW;
7638 		ASSERT(!(rnew->q_flag & _QINSERTING));
7690 			if (rnew->q_flag & _QINSERTING) {
7720 	if ((rqp->q_flag & _QREMOVING) && (wqp->q_qinfo->qi_srvp != NULL)) {
8170 	if (q->q_flag & (QWCLOSE|QENAB))
8179 	q->q_flag |= QENAB;
8180 	if (q->q_flag & QINSERVICE)
8271 	ASSERT(!(q->q_flag & QINSERVICE));
8272 	ASSERT((q->q_flag & QENAB));
8274 	q->q_flag &= ~QENAB;
8275 	q->q_flag |= QINSERVICE;