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

Lines Matching defs:qp
194 push_mod(queue_t *qp, dev_t *devp, struct stdata *stp, const char *name,
216 	if ((error = qattach(qp, devp, 0, crp, fp, B_FALSE)) != 0)
240 	queue_t *qp;
347 		qp = stp->sd_wrq;
348 		while (_SAMESTR(qp)) {
349 			qp = qp->q_next;
350 			if ((error = qreopen(_RD(qp), devp, flag, crp)) != 0)
369 	qp = allocq();
370 	stp = shalloc(qp);
396 	qp->q_ptr = _WR(qp)->q_ptr = stp;
397 	STREAM(qp) = STREAM(_WR(qp)) = stp;
412 		setq(qp, &fifo_strdata, &fifo_stwdata, NULL, QMTSAFE,
415 		set_qend(qp);
417 		_WR(qp)->q_nfsrv = _WR(qp);
418 		qp->q_nfsrv = qp;
428 		stp->sd_qn_minpsz = qp->q_minpsz;
429 		stp->sd_qn_maxpsz = qp->q_maxpsz;
434 	setq(qp, &strdata, &stwdata, NULL, QMTSAFE, SQ_CI|SQ_CO, B_FALSE);
436 	set_qend(qp);
443 	if ((error = qattach(qp, devp, flag, crp, NULL, B_FALSE)) != 0) {
450 		freeq(_RD(qp));
470 	brq = _RD(_WR(qp)->q_next);
474 		if (push_mod(qp, &dummydev, stp, DRMODNAME, 0, crp, 0) != 0)
503 				error = push_mod(qp, &dummydev, stp,
540 		error = push_mod(qp, &dummydev, stp, ap->ap_list[s],
615 	queue_t *qp;
626 	qp = stp->sd_wrq;
680 	ASSERT(qp->q_first == NULL);	/* No more delayed write */
696 	while (_SAMESTR(qp)) {
708 				mutex_enter(QLOCK(qp->q_next));
709 				if (!(qp->q_next->q_mblkcnt)) {
710 					mutex_exit(QLOCK(qp->q_next));
716 				qp->q_next->q_flag |= QWANTW;
717 				mutex_exit(QLOCK(qp->q_next));
719 				if (str_cv_wait(&qp->q_wait, &stp->sd_lock,
728 		rmq = qp->q_next;
731 			wait_sq_svc(_RD(qp)->q_syncq);
754 	disable_svc(_RD(qp));
760 	wait_svc(_RD(qp));
765 	flushq(_RD(qp), FLUSHALL);
766 	flushq(qp, FLUSHALL);
774 	if (qp->q_next && !_SAMESTR(qp)) {
775 		if (qp->q_next->q_qinfo == &deadrend) {	/* half-closed pipe */
776 			flushq(qp->q_next, FLUSHALL); /* ensure no message */
777 			shfree(qp->q_next->q_stream);
778 			freeq(qp->q_next);
779 			freeq(_RD(qp));
780 		} else if (qp->q_next == _RD(qp)) {	/* fifo */
781 			freeq(_RD(qp));
788 			ASSERT(qp->q_syncq == _RD(qp)->q_syncq);
789 			mutex_enter(SQLOCK(qp->q_syncq));
790 			qp->q_qinfo = &deadwend;
791 			_RD(qp)->q_qinfo = &deadrend;
792 			mutex_exit(SQLOCK(qp->q_syncq));
795 		freeq(_RD(qp)); /* free stream head queue pair */
1883 	queue_t *wq, *qp;
1901 	qp = wq->q_next;
1903 		dname = Q2NAME(qp);
1904 		islast = !SAMESTR(qp) || qp->q_next == NULL;
1920 		qp = qp->q_next;
5703 	queue_t *qp, *nextqp;
5719 		qp = _RD(stp->sd_mate->sd_wrq);
5720 		claimstr(qp);
5721 		mate = qp;
5730 		qp = stp->sd_wrq;
5734 		 * On completion, qp points to the write queue
5738 		while (((qp = qp->q_next) != NULL) && _SAMESTR(qp))
5747 		ASSERT(qp);
5748 		if (qp == NULL) {
5761 		if ((sq = qp->q_syncq) != NULL)
5764 		/* Now get the q_next value from this qp. */
5765 		nextqp = qp->q_next;
5776 			ASSERT(qp->q_qinfo->qi_srvp);
5777 			ASSERT(_OTHERQ(qp)->q_qinfo->qi_srvp);
5778 			ASSERT(_OTHERQ(qp->q_next)->q_qinfo->qi_srvp);
5782 			if (nextqp != qp->q_next) {
5788 			qp = _RD(STREAM(nextqp)->sd_wrq);
5789 			mate = qp;
5797 	if (qp->q_qinfo != &strdata && qp->q_qinfo != &fifo_strdata) {
5802 	if (qp->q_flag & QFULL) {
5840 	put(qp, mp);
8214 		queue_t	*qp = stp->sd_wrq;
8216 		claimstr(qp);
8218 		tq = qp->q_next->q_nfsrv;
8222 			releasestr(qp);
8237 					releasestr(qp);
8249 					releasestr(qp);
8255 					releasestr(qp);
8277 		releasestr(qp);
8283 		queue_t	*qp = _RD(stp->sd_wrq);
8295 		mp = qp->q_first;
8505 strq2vp(queue_t *qp)
8508 	vp = STREAM(qp)->sd_vnode;