692 	queue_t *wqp = &qip->qu_wqueue;  in queue_constructor()  local
710 	wqp->q_first = NULL;  in queue_constructor()
711 	wqp->q_link = NULL;  in queue_constructor()
712 	wqp->q_count = 0;  in queue_constructor()
713 	wqp->q_mblkcnt = 0;  in queue_constructor()
714 	wqp->q_sqhead = NULL;  in queue_constructor()
715 	wqp->q_sqtail = NULL;  in queue_constructor()
716 	wqp->q_sqnext = NULL;  in queue_constructor()
717 	wqp->q_sqprev = NULL;  in queue_constructor()
718 	wqp->q_sqflags = 0;  in queue_constructor()
719 	wqp->q_rwcnt = 0;  in queue_constructor()
720 	wqp->q_spri = 0;  in queue_constructor()
722 	mutex_init(QLOCK(wqp), NULL, MUTEX_DEFAULT, NULL);  in queue_constructor()
723 	cv_init(&wqp->q_wait, NULL, CV_DEFAULT, NULL);  in queue_constructor()
753 	queue_t *wqp = &qip->qu_wqueue;  in queue_destructor()  local
757 	ASSERT(wqp->q_sqhead == NULL);  in queue_destructor()
759 	ASSERT(wqp->q_sqnext == NULL);  in queue_destructor()
761 	ASSERT(wqp->q_rwcnt == 0);  in queue_destructor()
766 	mutex_destroy(&wqp->q_lock);  in queue_destructor()
767 	cv_destroy(&wqp->q_wait);  in queue_destructor()
1228 	queue_t *wqp = _WR(qp);  in qreopen()  local
1235 	    (wqp->q_next ? 0 : flag), (wqp->q_next ? MODOPEN : 0), crp))) {  in qreopen()
1261 	queue_t *wqp = _WR(qp);  in qdetach()  local
1273 		wait_q_syncq(wqp);  in qdetach()
1285 		ASSERT((qp->q_flag & QWCLOSE) && (wqp->q_flag & QWCLOSE));  in qdetach()
1306 	ASSERT(flush_syncq(wqp->q_syncq, wqp) == 0);  in qdetach()
1309 	    (wqp->q_syncq->sq_head == NULL)));  in qdetach()
1324 	queue_t *wqp = _WR(qp);  in disable_svc()  local
1330 	mutex_enter(QLOCK(wqp));  in disable_svc()
1331 	wqp->q_flag |= QWCLOSE;  in disable_svc()
1332 	mutex_exit(QLOCK(wqp));  in disable_svc()
1339 	queue_t *wqp = _WR(qp);  in enable_svc()  local
1345 	mutex_enter(QLOCK(wqp));  in enable_svc()
1346 	wqp->q_flag &= ~QWCLOSE;  in enable_svc()
1347 	mutex_exit(QLOCK(wqp));  in enable_svc()
1392 	queue_t *wqp = _WR(qp);  in wait_svc()  local
1401 		remove_runlist(wqp);  in wait_svc()
1416 		syncq_t *wsq = wqp->q_syncq;  in wait_svc()
1431 	mutex_enter(QLOCK(wqp));  in wait_svc()
1432 	while (wqp->q_flag & (QINSERVICE|QENAB))  in wait_svc()
1433 		cv_wait(&wqp->q_wait, QLOCK(wqp));  in wait_svc()
1434 	mutex_exit(QLOCK(wqp));  in wait_svc()
3376 	queue_t *qp, *wqp;  in allocq()  local
3382 	wqp = &qip->qu_wqueue;  in allocq()
3401 	wqp->q_last	= NULL;  in allocq()
3402 	wqp->q_next	= NULL;  in allocq()
3403 	wqp->q_ptr	= NULL;  in allocq()
3404 	wqp->q_flag	= QUSE;  in allocq()
3405 	wqp->q_bandp	= NULL;  in allocq()
3406 	wqp->q_stream	= NULL;  in allocq()
3407 	wqp->q_syncq	= sq;  in allocq()
3408 	wqp->q_nband	= 0;  in allocq()
3409 	wqp->q_nfsrv	= NULL;  in allocq()
3410 	wqp->q_draining	= 0;  in allocq()
3411 	wqp->q_syncqmsgs = 0;  in allocq()
3412 	wqp->q_qtstamp	= 0;  in allocq()
3413 	wqp->q_sqtstamp	= 0;  in allocq()
3414 	wqp->q_spri	= 0;  in allocq()
3440 	queue_t *wqp = _WR(qp);  in freeq()  local
3453 	(void) flush_syncq(wqp->q_syncq, wqp);  in freeq()
3454 	ASSERT(qp->q_syncqmsgs == 0 && wqp->q_syncqmsgs == 0);  in freeq()
3464 	flushq(wqp, FLUSHALL);  in freeq()
3467 	qp->q_next = wqp->q_next = NULL;  in freeq()
3469 	ASSERT(!(wqp->q_flag & QENAB));  in freeq()
3474 		if (wqp->q_syncq != qp->q_syncq)  in freeq()
3475 			outer_remove(outer, wqp->q_syncq);  in freeq()
3482 	if (qp->q_syncq != wqp->q_syncq && wqp->q_syncq != SQ(qp))  in freeq()
3483 		free_syncq(wqp->q_syncq);  in freeq()
3486 	ASSERT((wqp->q_sqflags & (Q_SQQUEUED | Q_SQDRAINING)) == 0);  in freeq()
3488 	ASSERT(MUTEX_NOT_HELD(QLOCK(wqp)));  in freeq()
3507 	ASSERT(qp->q_first == NULL && wqp->q_first == NULL);  in freeq()
3508 	ASSERT(qp->q_count == 0 && wqp->q_count == 0);  in freeq()
3509 	ASSERT(qp->q_mblkcnt == 0 && wqp->q_mblkcnt == 0);  in freeq()
3512 	wqp->q_flag &= ~QUSE;  in freeq()
3523 	qbp = wqp->q_bandp;  in freeq()
4878 	queue_t *wqp = _WR(qp);  in removeq()  local
4884 	syncq_t *wsq = wqp->q_syncq;  in removeq()
4889 	    "removeq:%p %p", qp, wqp);  in removeq()
4921 		mutex_enter(QLOCK(wqp));  in removeq()
4922 		while (wqp->q_rwcnt > 0) {  in removeq()
4923 			wqp->q_flag |= QWANTRMQSYNC;  in removeq()
4924 			cv_wait(&wqp->q_wait, QLOCK(wqp));  in removeq()
4926 		mutex_exit(QLOCK(wqp));  in removeq()
4942 	reset_nfsrv_ptr(qp, wqp);  in removeq()
4944 	ASSERT(wqp->q_next == NULL || backq(qp)->q_next == qp);  in removeq()
4945 	ASSERT(qp->q_next == NULL || backq(wqp)->q_next == wqp);  in removeq()
4947 	if (wqp->q_next == qp) {  in removeq()
4950 		if (wqp->q_next)  in removeq()
4953 			backq(wqp)->q_next = wqp->q_next;  in removeq()
4973 	if (wqp->q_syncqmsgs != 0 ||  in removeq()
4974 	    (wqp->q_syncq->sq_flags & SQ_EVENTS))  in removeq()
4975 		moved += propagate_syncq(wqp);  in removeq()
5003 	if (wqp->q_next != NULL) {  in removeq()
5004 		clr_qfull(wqp);  in removeq()
5012 			emptysq(wqp->q_next->q_syncq);  in removeq()
7739 reset_nfsrv_ptr(queue_t *rqp, queue_t *wqp)  in reset_nfsrv_ptr()  argument
7744 	if ((rqp->q_flag & _QREMOVING) && (wqp->q_qinfo->qi_srvp != NULL)) {  in reset_nfsrv_ptr()
7745 		for (tmp_qp = backq(wqp);  in reset_nfsrv_ptr()
7746 		    tmp_qp != NULL && tmp_qp->q_nfsrv == wqp;  in reset_nfsrv_ptr()
7748 			tmp_qp->q_nfsrv = wqp->q_nfsrv;  in reset_nfsrv_ptr()
7754 		if (wqp->q_next) {	/* non-driver case */  in reset_nfsrv_ptr()
7755 			tmp_qp = _OTHERQ(wqp->q_next);  in reset_nfsrv_ptr()