Cross Reference: /illumos-gate/usr/src/uts/common/io/zcons.c

Lines Matching defs:qp
416 zc_switch(queue_t *qp)
418 	zc_state_t *zcs = qp->q_ptr;
421 	if (qp == zcs->zc_master_rdq)
423 	else if (OTHERQ(qp) == zcs->zc_master_rdq && zcs->zc_slave_rdq != NULL)
425 	else if (qp == zcs->zc_slave_rdq)
427 	else if (OTHERQ(qp) == zcs->zc_slave_rdq && zcs->zc_master_rdq != NULL)
438 zc_side(queue_t *qp)
440 	zc_state_t *zcs = qp->q_ptr;
443 	if (qp == zcs->zc_master_rdq ||
444 	    OTHERQ(qp) == zcs->zc_master_rdq) {
447 	ASSERT(qp == zcs->zc_slave_rdq || OTHERQ(qp) == zcs->zc_slave_rdq);
693 handle_mflush(queue_t *qp, mblk_t *mp)
696 	DBG1("M_FLUSH on %s side", zc_side(qp));
699 		DBG1("M_FLUSH, FLUSHW, %s side", zc_side(qp));
700 		flushq(qp, FLUSHDATA);
708 			if (zc_switch(RD(qp)) != NULL) {
709 				putnext(zc_switch(RD(qp)), mp);
712 		} else if ((zc_switch(RD(qp)) != NULL) &&
719 			putnext(zc_switch(RD(qp)), nmp);
724 		DBG("qreply(qp) turning FLUSHR around\n");
725 		qreply(qp, mp);
744 zc_wput(queue_t *qp, mblk_t *mp)
753 	ASSERT(qp->q_ptr);
755 	DBG1("entering zc_wput, %s side", zc_side(qp));
758 	 * Process zcons ioctl messages if qp is the master console's write
761 	zcs = (zc_state_t *)qp->q_ptr;
762 	if (zcs->zc_master_rdq != NULL && qp == WR(zcs->zc_master_rdq) &&
773 				miocack(qp, mp, 0, EINVAL);
777 				miocack(qp, mp, 0, 0);
786 				miocack(qp, mp, 0, EINVAL);
799 				miocack(qp, mp, 0, EINVAL);
805 				miocack(qp, mp, 0, EINVAL);
822 			miocack(qp, mp, 0, 0);
831 				miocack(qp, mp, 0, EINVAL);
835 				miocack(qp, mp, 0, 0);
844 				miocack(qp, mp, 0, EINVAL);
858 				miocack(qp, mp, 0, EINVAL);
864 				miocack(qp, mp, 0, EINVAL);
881 			miocack(qp, mp, 0, 0);
888 	if (zc_switch(RD(qp)) == NULL) {
889 		DBG1("wput to %s side (no one listening)", zc_side(qp));
892 			handle_mflush(qp, mp);
895 			miocnak(qp, mp, 0, 0);
905 		DBG1("(hipri) wput, %s side", zc_side(qp));
912 			handle_mflush(qp, mp);
918 			ASSERT(zc_switch(RD(qp)) != NULL);
919 			putnext(zc_switch(RD(qp)), mp);
922 		DBG1("done (hipri) wput, %s side", zc_side(qp));
930 	if (qp->q_first == NULL && bcanputnext(RD(zc_switch(qp)), mp->b_band)) {
932 		putnext(RD(zc_switch(qp)), mp);
935 		(void) putq(qp, mp);
937 	DBG1("done wput, %s side", zc_side(qp));
948 zc_rsrv(queue_t *qp)
951 	zcs = (zc_state_t *)qp->q_ptr;
957 	ASSERT(qp == zcs->zc_master_rdq || qp == zcs->zc_slave_rdq);
958 	if (zc_switch(qp) == NULL) {
962 	qenable(WR(zc_switch(qp)));
974 zc_wsrv(queue_t *qp)
978 	DBG1("zc_wsrv master (%s) side", zc_side(qp));
983 	if (zc_switch(RD(qp)) == NULL) {
985 		while ((mp = getq(qp)) != NULL) {
987 				miocnak(qp, mp, 0, 0);
991 		flushq(qp, FLUSHALL);
998 	while ((mp = getq(qp)) != NULL) {
1005 		if (bcanputnext(RD(zc_switch(qp)), mp->b_band)) {
1007 			putnext(RD(zc_switch(qp)), mp);
1010 			(void) putbq(qp, mp);