Print this page
*** NO COMMENTS ***

@@ -775,10 +775,12 @@
         UPDATE_MIB(&tcps->tcps_mib, tcpInDataInorderBytes, send_size);
 
         BUMP_LOCAL(tcp->tcp_obsegs);
         BUMP_LOCAL(peer_tcp->tcp_ibsegs);
 
+        DTRACE_TCPF5(send, void, NULL, conn_t *, NULL,
+            __dtrace_tcpf_ipinfo_t *, tcp, tcp_t *, tcp, uint_t, send_size);
         DTRACE_PROBE2(tcp__fuse__output, tcp_t *, tcp, uint_t, send_size);
 
         if (!TCP_IS_DETACHED(peer_tcp)) {
                 /*
                  * Drain the peer's receive queue it has urgent data or if

@@ -915,10 +917,14 @@
         }
 
         if (tcp->tcp_direct_sockfs && !sd_rd_eof)
                 (void) strrput_sig(q, B_TRUE);
 
+        DTRACE_TCPF5(receive, void, NULL, conn_t *, NULL,
+            __dtrace_tcpf_ipinfo_t *, tcp, tcp_t *, tcp, uint_t,
+            tcp->tcp_rcv_cnt);
+
         ASSERT(cnt == tcp->tcp_rcv_cnt);
         tcp->tcp_rcv_last_head = NULL;
         tcp->tcp_rcv_last_tail = NULL;
         tcp->tcp_rcv_cnt = 0;
         tcp->tcp_fuse_rcv_unread_cnt = 0;

@@ -1024,10 +1030,13 @@
                 mutex_enter(&peer_tcp->tcp_non_sq_lock);
         }
 
         if ((mp = tcp->tcp_rcv_list) != NULL) {
 
+                DTRACE_TCPF5(receive, void, NULL, conn_t *, NULL,
+                    __dtrace_tcpf_ipinfo_t *, tcp, tcp_t *, tcp, uint_t,
+                    tcp->tcp_rcv_cnt);
                 DTRACE_PROBE3(tcp__fuse__rrw, tcp_t *, tcp,
                     uint32_t, tcp->tcp_rcv_cnt, ssize_t, dp->d_uio.uio_resid);
 
                 tcp->tcp_rcv_list = NULL;
                 TCP_STAT(tcps, tcp_fusion_rrw_msgcnt);