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);