equal
deleted
inserted
replaced
727 #if SQUEUE_PROFILE |
727 #if SQUEUE_PROFILE |
728 hrtime_t start, delta; |
728 hrtime_t start, delta; |
729 #endif |
729 #endif |
730 #if SQUEUE_DEBUG |
730 #if SQUEUE_DEBUG |
731 conn_t *connp = (conn_t *)arg; |
731 conn_t *connp = (conn_t *)arg; |
732 ASSERT(connp->conn_tcp->tcp_connp == connp); |
732 ASSERT(!IPCL_IS_TCP(connp) || connp->conn_tcp->tcp_connp == connp); |
|
733 ASSERT(!IPCL_IS_UDP(connp) || connp->conn_udp->udp_connp == connp); |
733 #endif |
734 #endif |
734 |
735 |
735 ASSERT(proc != NULL); |
736 ASSERT(proc != NULL); |
736 ASSERT(sqp != NULL); |
737 ASSERT(sqp != NULL); |
737 ASSERT(mp != NULL); |
738 ASSERT(mp != NULL); |
952 |
953 |
953 ASSERT(proc != NULL); |
954 ASSERT(proc != NULL); |
954 ASSERT(sqp != NULL); |
955 ASSERT(sqp != NULL); |
955 ASSERT(mp != NULL); |
956 ASSERT(mp != NULL); |
956 ASSERT(mp->b_next == NULL); |
957 ASSERT(mp->b_next == NULL); |
957 ASSERT(connp->conn_tcp->tcp_connp == connp); |
958 ASSERT(!IPCL_IS_TCP(connp) || connp->conn_tcp->tcp_connp == connp); |
958 |
959 ASSERT(!IPCL_IS_UDP(connp) || connp->conn_udp->udp_connp == connp); |
959 ASSERT(MUTEX_NOT_HELD(&sqp->sq_lock)); |
960 ASSERT(MUTEX_NOT_HELD(&sqp->sq_lock)); |
|
961 |
960 mutex_enter(&sqp->sq_lock); |
962 mutex_enter(&sqp->sq_lock); |
961 |
963 |
962 being_processed = (sqp->sq_state & SQS_PROC); |
964 being_processed = (sqp->sq_state & SQS_PROC); |
963 if (!being_processed && (sqp->sq_first == NULL)) { |
965 if (!being_processed && (sqp->sq_first == NULL)) { |
964 /* |
966 /* |
1098 #endif |
1100 #endif |
1099 ASSERT(proc != NULL); |
1101 ASSERT(proc != NULL); |
1100 ASSERT(sqp != NULL); |
1102 ASSERT(sqp != NULL); |
1101 ASSERT(mp != NULL); |
1103 ASSERT(mp != NULL); |
1102 ASSERT(mp->b_next == NULL); |
1104 ASSERT(mp->b_next == NULL); |
1103 ASSERT(connp->conn_tcp->tcp_connp == connp); |
1105 ASSERT(!IPCL_IS_TCP(connp) || connp->conn_tcp->tcp_connp == connp); |
|
1106 ASSERT(!IPCL_IS_UDP(connp) || connp->conn_udp->udp_connp == connp); |
1104 |
1107 |
1105 ASSERT(MUTEX_NOT_HELD(&sqp->sq_lock)); |
1108 ASSERT(MUTEX_NOT_HELD(&sqp->sq_lock)); |
1106 mutex_enter(&sqp->sq_lock); |
1109 mutex_enter(&sqp->sq_lock); |
1107 ENQUEUE_MP(sqp, mp, proc, arg); |
1110 ENQUEUE_MP(sqp, mp, proc, arg); |
1108 #if SQUEUE_DEBUG |
1111 #if SQUEUE_DEBUG |