217 #define	SQUEUE_DBG_SET(sqp, mp, proc, connp, tag) {		\  argument
220 	(sqp)->sq_connp = (connp);				\
230 #define	SQUEUE_DBG_SET(sqp, mp, proc, connp, tag)  argument
333 	conn_t		*connp;  in squeue_enter()  local
372 			connp = (conn_t *)mp->b_prev;  in squeue_enter()
376 			ASSERT(proc != NULL && connp != NULL);  in squeue_enter()
383 			if (connp->conn_sqp == sqp) {  in squeue_enter()
384 				SQUEUE_DBG_SET(sqp, mp, proc, connp,  in squeue_enter()
386 				connp->conn_on_sqp = B_TRUE;  in squeue_enter()
388 				    sqp, mblk_t *, mp, conn_t *, connp);  in squeue_enter()
389 				(*proc)(connp, mp, sqp, ira);  in squeue_enter()
391 				    sqp, conn_t *, connp);  in squeue_enter()
392 				connp->conn_on_sqp = B_FALSE;  in squeue_enter()
394 				CONN_DEC_REF(connp);  in squeue_enter()
396 				SQUEUE_ENTER_ONE(connp->conn_sqp, mp, proc,  in squeue_enter()
397 				    connp, ira, SQ_FILL, SQTAG_SQUEUE_CHANGE);  in squeue_enter()
411 					squeue_try_drain_one(sqp, connp);  in squeue_enter()
495 		connp = (conn_t *)mp->b_prev;  in squeue_enter()
499 		    (connp->conn_on_sqp == B_FALSE)) {  in squeue_enter()
514 			if (connp->conn_sqp == sqp) {  in squeue_enter()
515 				connp->conn_on_sqp = B_TRUE;  in squeue_enter()
517 				    sqp, mblk_t *, mp, conn_t *, connp);  in squeue_enter()
518 				(*proc)(connp, mp, sqp, ira);  in squeue_enter()
520 				    sqp, conn_t *, connp);  in squeue_enter()
521 				connp->conn_on_sqp = B_FALSE;  in squeue_enter()
522 				CONN_DEC_REF(connp);  in squeue_enter()
524 				SQUEUE_ENTER_ONE(connp->conn_sqp, mp, proc,  in squeue_enter()
525 				    connp, ira, SQ_FILL, SQTAG_SQUEUE_CHANGE);  in squeue_enter()
604 	conn_t		*connp;  in squeue_drain()  local
657 		connp = (conn_t *)mp->b_prev;  in squeue_drain()
676 				CONN_DEC_REF(connp);  in squeue_drain()
689 		if (connp->conn_sqp == sqp) {  in squeue_drain()
690 			SQUEUE_DBG_SET(sqp, mp, proc, connp,  in squeue_drain()
692 			connp->conn_on_sqp = B_TRUE;  in squeue_drain()
694 			    sqp, mblk_t *, mp, conn_t *, connp);  in squeue_drain()
695 			(*proc)(connp, mp, sqp, ira);  in squeue_drain()
697 			    sqp, conn_t *, connp);  in squeue_drain()
698 			connp->conn_on_sqp = B_FALSE;  in squeue_drain()
699 			CONN_DEC_REF(connp);  in squeue_drain()
701 			SQUEUE_ENTER_ONE(connp->conn_sqp, mp, proc, connp, ira,  in squeue_drain()
1254 	conn_t *connp = (conn_t *)arg;  in squeue_wakeup_conn()  local
1255 	squeue_t *sqp = connp->conn_sqp;  in squeue_wakeup_conn()
1270 	cv_broadcast(&connp->conn_sq_cv);  in squeue_wakeup_conn()
1283 squeue_synch_enter(conn_t *connp, mblk_t *use_mp)  in squeue_synch_enter()  argument
1288 	sqp = connp->conn_sqp;  in squeue_synch_enter()
1311 		if (sqp != connp->conn_sqp) {  in squeue_synch_enter()
1321 		sqp->sq_connp = connp;  in squeue_synch_enter()
1323 		connp->conn_on_sqp = B_TRUE;  in squeue_synch_enter()
1342 		CONN_INC_REF(connp);  in squeue_synch_enter()
1343 		SET_SQUEUE(mp, squeue_wakeup_conn, connp);  in squeue_synch_enter()
1350 			cv_wait(&connp->conn_sq_cv, &sqp->sq_lock);  in squeue_synch_enter()
1370 	conn_t *connp;  in squeue_try_drain_one()  local
1384 	connp = (conn_t *)mp->b_prev;  in squeue_try_drain_one()
1385 	if (connp != compare_conn) {  in squeue_try_drain_one()
1427 			CONN_DEC_REF(connp);  in squeue_try_drain_one()
1433 	SQUEUE_DBG_SET(sqp, mp, proc, connp, mp->b_tag);  in squeue_try_drain_one()
1434 	connp->conn_on_sqp = B_TRUE;  in squeue_try_drain_one()
1436 	    conn_t *, connp);  in squeue_try_drain_one()
1437 	(*proc)(connp, mp, sqp, ira);  in squeue_try_drain_one()
1438 	DTRACE_PROBE2(squeue__proc__end, squeue_t *, sqp, conn_t *, connp);  in squeue_try_drain_one()
1439 	connp->conn_on_sqp = B_FALSE;  in squeue_try_drain_one()
1440 	CONN_DEC_REF(connp);  in squeue_try_drain_one()
1453 squeue_synch_exit(conn_t *connp, int flag)  in squeue_synch_exit()  argument
1455 	squeue_t *sqp = connp->conn_sqp;  in squeue_synch_exit()
1479 	connp->conn_on_sqp = B_FALSE;  in squeue_synch_exit()
1483 		squeue_try_drain_one(sqp, connp);  in squeue_synch_exit()