Lines Matching refs:qp

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