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