Print this page
*** NO COMMENTS ***
*** 775,784 ****
--- 775,786 ----
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,924 ****
--- 917,930 ----
}
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,1033 ****
--- 1030,1042 ----
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);