inet/tcp/tcp_fusion.c

84 	conn_t		*peer_connp, *connp = tcp->tcp_connp;
112 		peer_connp = ipcl_conn_tcp_lookup_reversed_ipv4(connp,
115 		peer_connp = ipcl_conn_tcp_lookup_reversed_ipv6(connp,
128 	ASSERT(peer_connp == NULL || peer_connp != connp);
129 	if (peer_connp == NULL || peer_connp->conn_sqp != connp->conn_sqp ||
130 	    !IPCL_IS_TCP(peer_connp) ||
131 	    IPCL_IS_NONSTR(connp) != IPCL_IS_NONSTR(peer_connp)) {
132 		if (peer_connp != NULL) {
134 			CONN_DEC_REF(peer_connp);
138 	peer_tcp = peer_connp->conn_tcp;	/* active connect tcp */
142 	ASSERT(peer_connp->conn_sqp == connp->conn_sqp);
150 		CONN_DEC_REF(peer_connp);
163 		queue_t *peer_rq = peer_connp->conn_rq;
243 			ASSERT(IPCL_IS_TCP(peer_connp));
248 			(*peer_connp->conn_upcalls->su_set_proto_props)
249 			    (peer_connp->conn_upper_handle, &sopp);
254 	CONN_DEC_REF(peer_connp);
266 	CONN_DEC_REF(peer_connp);
442 	conn_t		*peer_connp = peer_tcp->tcp_connp;
458 	ASSERT(connp->conn_sqp == peer_connp->conn_sqp);
497 		    CONN_INBOUND_POLICY_PRESENT(peer_connp, ipss);
504 		    CONN_INBOUND_POLICY_PRESENT_V6(peer_connp, ipss);
523 		    hooks_in, do_ipsec ? peer_connp : NULL);
563 	if (IPCL_IS_NONSTR(peer_connp) &&
571 			(*peer_connp->conn_upcalls->su_signal_oob)
572 			    (peer_connp->conn_upper_handle, 0);
575 		if ((*peer_connp->conn_upcalls->su_recv)(
576 		    peer_connp->conn_upper_handle, mp, recv_size,
582 		if (IPCL_IS_NONSTR(peer_connp) &&
616 	    (peer_tcp->tcp_rcv_cnt >= peer_connp->conn_rcvbuf)) ||
618 	    !IPCL_IS_NONSTR(peer_connp) && !canputnext(peer_connp->conn_rq))) {
661 	    peer_connp->conn_ixa, __dtrace_tcp_void_ip_t *, NULL,
675 			 * correct peer_connp->conn_rq is globally visible
682 			(void) tcp_fuse_rcv_drain(peer_connp->conn_rq, peer_tcp,