common/os/strsubr.c

689 	queue_t *wqp = &qip->qu_wqueue;
707 	wqp->q_first = NULL;
708 	wqp->q_link = NULL;
709 	wqp->q_count = 0;
710 	wqp->q_mblkcnt = 0;
711 	wqp->q_sqhead = NULL;
712 	wqp->q_sqtail = NULL;
713 	wqp->q_sqnext = NULL;
714 	wqp->q_sqprev = NULL;
715 	wqp->q_sqflags = 0;
716 	wqp->q_rwcnt = 0;
717 	wqp->q_spri = 0;
719 	mutex_init(QLOCK(wqp), NULL, MUTEX_DEFAULT, NULL);
720 	cv_init(&wqp->q_wait, NULL, CV_DEFAULT, NULL);
750 	queue_t *wqp = &qip->qu_wqueue;
754 	ASSERT(wqp->q_sqhead == NULL);
756 	ASSERT(wqp->q_sqnext == NULL);
758 	ASSERT(wqp->q_rwcnt == 0);
763 	mutex_destroy(&wqp->q_lock);
764 	cv_destroy(&wqp->q_wait);
1225 	queue_t *wqp = _WR(qp);
1232 	    (wqp->q_next ? 0 : flag), (wqp->q_next ? MODOPEN : 0), crp))) {
1258 	queue_t *wqp = _WR(qp);
1270 		wait_q_syncq(wqp);
1282 		ASSERT((qp->q_flag & QWCLOSE) && (wqp->q_flag & QWCLOSE));
1303 	ASSERT(flush_syncq(wqp->q_syncq, wqp) == 0);
1306 	    (wqp->q_syncq->sq_head == NULL)));
1321 	queue_t *wqp = _WR(qp);
1327 	mutex_enter(QLOCK(wqp));
1328 	wqp->q_flag |= QWCLOSE;
1329 	mutex_exit(QLOCK(wqp));
1336 	queue_t *wqp = _WR(qp);
1342 	mutex_enter(QLOCK(wqp));
1343 	wqp->q_flag &= ~QWCLOSE;
1344 	mutex_exit(QLOCK(wqp));
1389 	queue_t *wqp = _WR(qp);
1398 		remove_runlist(wqp);
1413 		syncq_t *wsq = wqp->q_syncq;
1428 	mutex_enter(QLOCK(wqp));
1429 	while (wqp->q_flag & (QINSERVICE|QENAB))
1430 		cv_wait(&wqp->q_wait, QLOCK(wqp));
1431 	mutex_exit(QLOCK(wqp));
3352 	queue_t *qp, *wqp;
3358 	wqp = &qip->qu_wqueue;
3377 	wqp->q_last	= NULL;
3378 	wqp->q_next	= NULL;
3379 	wqp->q_ptr	= NULL;
3380 	wqp->q_flag	= QUSE;
3381 	wqp->q_bandp	= NULL;
3382 	wqp->q_stream	= NULL;
3383 	wqp->q_syncq	= sq;
3384 	wqp->q_nband	= 0;
3385 	wqp->q_nfsrv	= NULL;
3386 	wqp->q_draining	= 0;
3387 	wqp->q_syncqmsgs = 0;
3388 	wqp->q_qtstamp	= 0;
3389 	wqp->q_sqtstamp	= 0;
3390 	wqp->q_spri	= 0;
3416 	queue_t *wqp = _WR(qp);
3429 	(void) flush_syncq(wqp->q_syncq, wqp);
3430 	ASSERT(qp->q_syncqmsgs == 0 && wqp->q_syncqmsgs == 0);
3440 	flushq(wqp, FLUSHALL);
3443 	qp->q_next = wqp->q_next = NULL;
3445 	ASSERT(!(wqp->q_flag & QENAB));
3450 		if (wqp->q_syncq != qp->q_syncq)
3451 			outer_remove(outer, wqp->q_syncq);
3458 	if (qp->q_syncq != wqp->q_syncq && wqp->q_syncq != SQ(qp))
3459 		free_syncq(wqp->q_syncq);
3462 	ASSERT((wqp->q_sqflags & (Q_SQQUEUED | Q_SQDRAINING)) == 0);
3464 	ASSERT(MUTEX_NOT_HELD(QLOCK(wqp)));
3483 	ASSERT(qp->q_first == NULL && wqp->q_first == NULL);
3484 	ASSERT(qp->q_count == 0 && wqp->q_count == 0);
3485 	ASSERT(qp->q_mblkcnt == 0 && wqp->q_mblkcnt == 0);
3488 	wqp->q_flag &= ~QUSE;
3491 	/* ASSERT((qp->q_flag & QWANTW) == 0 && (wqp->q_flag & QWANTW) == 0); */
3499 	qbp = wqp->q_bandp;
4854 	queue_t *wqp = _WR(qp);
4860 	syncq_t *wsq = wqp->q_syncq;
4865 	    "removeq:%p %p", qp, wqp);
4897 		mutex_enter(QLOCK(wqp));
4898 		while (wqp->q_rwcnt > 0) {
4899 			wqp->q_flag |= QWANTRMQSYNC;
4900 			cv_wait(&wqp->q_wait, QLOCK(wqp));
4902 		mutex_exit(QLOCK(wqp));
4918 	reset_nfsrv_ptr(qp, wqp);
4920 	ASSERT(wqp->q_next == NULL || backq(qp)->q_next == qp);
4921 	ASSERT(qp->q_next == NULL || backq(wqp)->q_next == wqp);
4923 	if (wqp->q_next == qp) {
4926 		if (wqp->q_next)
4929 			backq(wqp)->q_next = wqp->q_next;
4949 	if (wqp->q_syncqmsgs != 0 ||
4950 	    (wqp->q_syncq->sq_flags & SQ_EVENTS))
4951 		moved += propagate_syncq(wqp);
4979 	if (wqp->q_next != NULL) {
4980 		clr_qfull(wqp);
4988 			emptysq(wqp->q_next->q_syncq);
7715 reset_nfsrv_ptr(queue_t *rqp, queue_t *wqp)
7720 	if ((rqp->q_flag & _QREMOVING) && (wqp->q_qinfo->qi_srvp != NULL)) {
7721 		for (tmp_qp = backq(wqp);
7722 		    tmp_qp != NULL && tmp_qp->q_nfsrv == wqp;
7724 			tmp_qp->q_nfsrv = wqp->q_nfsrv;
7730 		if (wqp->q_next) {	/* non-driver case */
7731 			tmp_qp = _OTHERQ(wqp->q_next);