218 #define	SQUEUE_DBG_SET(sqp, mp, proc, connp, tag) {		\  argument
221 	(sqp)->sq_connp = (connp);				\
231 #define	SQUEUE_DBG_SET(sqp, mp, proc, connp, tag)  argument
428 	conn_t		*connp;  in squeue_enter()  local
467 			connp = (conn_t *)mp->b_prev;  in squeue_enter()
471 			ASSERT(proc != NULL && connp != NULL);  in squeue_enter()
478 			if (connp->conn_sqp == sqp) {  in squeue_enter()
479 				SQUEUE_DBG_SET(sqp, mp, proc, connp,  in squeue_enter()
481 				connp->conn_on_sqp = B_TRUE;  in squeue_enter()
483 				    sqp, mblk_t *, mp, conn_t *, connp);  in squeue_enter()
484 				(*proc)(connp, mp, sqp, ira);  in squeue_enter()
486 				    sqp, conn_t *, connp);  in squeue_enter()
487 				connp->conn_on_sqp = B_FALSE;  in squeue_enter()
489 				CONN_DEC_REF(connp);  in squeue_enter()
491 				SQUEUE_ENTER_ONE(connp->conn_sqp, mp, proc,  in squeue_enter()
492 				    connp, ira, SQ_FILL, SQTAG_SQUEUE_CHANGE);  in squeue_enter()
586 		connp = (conn_t *)mp->b_prev;  in squeue_enter()
590 		    (connp->conn_on_sqp == B_FALSE)) {  in squeue_enter()
605 			if (connp->conn_sqp == sqp) {  in squeue_enter()
606 				connp->conn_on_sqp = B_TRUE;  in squeue_enter()
608 				    sqp, mblk_t *, mp, conn_t *, connp);  in squeue_enter()
609 				(*proc)(connp, mp, sqp, ira);  in squeue_enter()
611 				    sqp, conn_t *, connp);  in squeue_enter()
612 				connp->conn_on_sqp = B_FALSE;  in squeue_enter()
613 				CONN_DEC_REF(connp);  in squeue_enter()
615 				SQUEUE_ENTER_ONE(connp->conn_sqp, mp, proc,  in squeue_enter()
616 				    connp, ira, SQ_FILL, SQTAG_SQUEUE_CHANGE);  in squeue_enter()
716 	conn_t		*connp;  in squeue_drain()  local
778 		connp = (conn_t *)mp->b_prev;  in squeue_drain()
797 				CONN_DEC_REF(connp);  in squeue_drain()
810 		if (connp->conn_sqp == sqp) {  in squeue_drain()
811 			SQUEUE_DBG_SET(sqp, mp, proc, connp,  in squeue_drain()
813 			connp->conn_on_sqp = B_TRUE;  in squeue_drain()
815 			    sqp, mblk_t *, mp, conn_t *, connp);  in squeue_drain()
816 			(*proc)(connp, mp, sqp, ira);  in squeue_drain()
818 			    sqp, conn_t *, connp);  in squeue_drain()
819 			connp->conn_on_sqp = B_FALSE;  in squeue_drain()
820 			CONN_DEC_REF(connp);  in squeue_drain()
822 			SQUEUE_ENTER_ONE(connp->conn_sqp, mp, proc, connp, ira,  in squeue_drain()
1380 	conn_t *connp = (conn_t *)arg;  in squeue_wakeup_conn()  local
1381 	squeue_t *sqp = connp->conn_sqp;  in squeue_wakeup_conn()
1396 	cv_broadcast(&connp->conn_sq_cv);  in squeue_wakeup_conn()
1409 squeue_synch_enter(conn_t *connp, mblk_t *use_mp)  in squeue_synch_enter()  argument
1414 	sqp = connp->conn_sqp;  in squeue_synch_enter()
1437 		if (sqp != connp->conn_sqp) {  in squeue_synch_enter()
1447 		sqp->sq_connp = connp;  in squeue_synch_enter()
1449 		connp->conn_on_sqp = B_TRUE;  in squeue_synch_enter()
1468 		CONN_INC_REF(connp);  in squeue_synch_enter()
1469 		SET_SQUEUE(mp, squeue_wakeup_conn, connp);  in squeue_synch_enter()
1476 			cv_wait(&connp->conn_sq_cv, &sqp->sq_lock);  in squeue_synch_enter()
1487 squeue_synch_exit(conn_t *connp)  in squeue_synch_exit()  argument
1489 	squeue_t *sqp = connp->conn_sqp;  in squeue_synch_exit()
1497 		connp->conn_on_sqp = B_FALSE;  in squeue_synch_exit()