| /linux/net/ipv4/ |
| H A D | tcp_illinois.c | 89 s32 rtt_us = sample->rtt_us; in tcp_illinois_acked() local 94 if (rtt_us < 0) in tcp_illinois_acked() 98 if (rtt_us > RTT_MAX) in tcp_illinois_acked() 99 rtt_us = RTT_MAX; in tcp_illinois_acked() 102 if (ca->base_rtt > rtt_us) in tcp_illinois_acked() 103 ca->base_rtt = rtt_us; in tcp_illinois_acked() 106 if (ca->max_rtt < rtt_us) in tcp_illinois_acked() 107 ca->max_rtt = rtt_us; in tcp_illinois_acked() 110 ca->sum_rtt += rtt_us; in tcp_illinois_acked()
|
| H A D | tcp_recovery.c | 34 return tp->rack.rtt_us + reo_wnd - in tcp_rack_skb_timeout() 121 u32 rtt_us; tcp_rack_advance() local
|
| H A D | tcp_nv.c | 251 if (sample->rtt_us < 0) in tcpnv_acked() 274 avg_rtt = (((u64)sample->rtt_us) * nv_rtt_factor + in tcpnv_acked() 278 avg_rtt = sample->rtt_us; in tcpnv_acked() 283 avg_rtt = sample->rtt_us; in tcpnv_acked()
|
| H A D | tcp_cdg.c | 304 if (sample->rtt_us <= 0) in tcp_cdg_acked() 316 ca->rtt.min = min(ca->rtt.min, sample->rtt_us); in tcp_cdg_acked() 324 ca->rtt.min = min_not_zero(ca->rtt.min, sample->rtt_us); in tcp_cdg_acked() 325 ca->rtt.max = max(ca->rtt.max, sample->rtt_us); in tcp_cdg_acked()
|
| H A D | tcp_veno.c | 79 if (sample->rtt_us < 0) in tcp_veno_pkts_acked() 83 vrtt = sample->rtt_us + 1; in tcp_veno_pkts_acked()
|
| H A D | tcp_bbr.c | 271 u32 rtt_us; in bbr_init_pacing_rate_from_rtt() local 274 rtt_us = max(tp->srtt_us >> 3, 1U); in bbr_init_pacing_rate_from_rtt() 277 rtt_us = USEC_PER_MSEC; /* use nominal default RTT */ in bbr_init_pacing_rate_from_rtt() 280 do_div(bw, rtt_us); in bbr_init_pacing_rate_from_rtt() 950 if (rs->rtt_us >= 0 && in bbr_update_min_rtt() 951 (rs->rtt_us < bbr->min_rtt_us || in bbr_update_min_rtt() 953 bbr->min_rtt_us = rs->rtt_us; in bbr_update_min_rtt()
|
| H A D | tcp_vegas.c | 116 if (sample->rtt_us < 0) in tcp_vegas_pkts_acked() 120 vrtt = sample->rtt_us + 1; in tcp_vegas_pkts_acked()
|
| H A D | tcp_lp.c | 281 if (sample->rtt_us > 0) in tcp_lp_pkts_acked() 282 tcp_lp_rtt_sample(sk, sample->rtt_us); in tcp_lp_pkts_acked()
|
| H A D | tcp_westwood.c | 108 if (sample->rtt_us > 0) in tcp_westwood_pkts_acked() 109 w->rtt = usecs_to_jiffies(sample->rtt_us); in tcp_westwood_pkts_acked()
|
| H A D | tcp_htcp.c | 112 if (sample->rtt_us > 0) in measure_achieved_throughput() 113 measure_rtt(sk, usecs_to_jiffies(sample->rtt_us)); in measure_achieved_throughput()
|
| H A D | tcp_input.c | 832 u32 new_sample, old_sample = tp->rcv_rtt_est.rtt_us; in tcp_rcv_rtt_update() 856 tp->rcv_rtt_est.rtt_us = new_sample; in tcp_rcv_rtt_update() 917 u32 rtt_threshold, rtt_us; in tcp_rcvbuf_grow() local 930 rtt_us = tp->rcv_rtt_est.rtt_us >> 3; in tcp_rcvbuf_grow() 932 if (rtt_us < rtt_threshold) { in tcp_rcvbuf_grow() 937 grow = div_u64((u64)rcvwin * rtt_us, rtt_threshold); in tcp_rcvbuf_grow() 968 if (unlikely(!tp->rcv_rtt_est.rtt_us)) in tcp_rcv_space_adjust() 976 if (time < (tp->rcv_rtt_est.rtt_us >> 3)) in tcp_rcv_space_adjust() 1586 u32 rtt_us; in tcp_rack_advance() local 1588 rtt_us = tcp_stamp_us_delta(tp->tcp_mstamp, xmit_time); in tcp_rack_advance() [all …]
|
| H A D | tcp.c | 4336 info->tcpi_rcv_rtt = tp->rcv_rtt_est.rtt_us >> 3; in tcp_get_info()
|
| /linux/fs/afs/ |
| H A D | vl_probe.c | 53 unsigned int rtt_us = 0; in afs_vlserver_probe_result() local 119 rtt_us = rxrpc_kernel_get_srtt(addr->peer); in afs_vlserver_probe_result() 120 if (rtt_us < server->probe.rtt) { in afs_vlserver_probe_result() 121 server->probe.rtt = rtt_us; in afs_vlserver_probe_result() 122 server->rtt = rtt_us; in afs_vlserver_probe_result() 134 trace_afs_vl_probe(server, false, alist, index, call->error, call->abort_code, rtt_us); in afs_vlserver_probe_result() 137 rtt_us, ret); in afs_vlserver_probe_result()
|
| H A D | fs_probe.c | 145 unsigned int rtt_us = -1, cap0; in afs_fileserver_probe_result() local 211 rtt_us = rxrpc_kernel_get_srtt(addr->peer); in afs_fileserver_probe_result() 212 if (rtt_us < estate->rtt) { in afs_fileserver_probe_result() 213 estate->rtt = rtt_us; in afs_fileserver_probe_result() 214 server->rtt = rtt_us; in afs_fileserver_probe_result() 225 trace_afs_fs_probe(server, false, estate, index, call->error, call->abort_code, rtt_us); in afs_fileserver_probe_result() 229 rtt_us, ret); in afs_fileserver_probe_result()
|
| /linux/include/trace/events/ |
| H A D | afs.h | 1669 unsigned int addr_index, int error, s32 abort_code, unsigned int rtt_us), 1671 TP_ARGS(server, tx, estate, addr_index, error, abort_code, rtt_us), 1680 __field(unsigned int, rtt_us) 1692 __entry->rtt_us = rtt_us; 1699 __entry->addr_index, __entry->error, __entry->abort_code, __entry->rtt_us, 1705 unsigned int addr_index, int error, s32 abort_code, unsigned int rtt_us), 1707 TP_ARGS(server, tx, alist, addr_index, error, abort_code, rtt_us), 1716 __field(unsigned int, rtt_us) 1726 __entry->rtt_us = rtt_us; 1733 __entry->error, __entry->abort_code, __entry->rtt_us,
|
| H A D | tcp.h | 215 __field(__u32, rtt_us) 242 __entry->rtt_us = tp->rcv_rtt_est.rtt_us >> 3; 272 TP_printk("time=%u rtt_us=%u copied=%u inq=%u space=%u ooo=%u scaling_ratio=%u rcvbuf=%u " 276 __entry->time, __entry->rtt_us, __entry->copied,
|
| /linux/tools/testing/selftests/bpf/progs/ |
| H A D | bpf_cubic.c | 504 if (sample->rtt_us < 0) in BPF_PROG() 511 delay = sample->rtt_us; in BPF_PROG()
|
| /linux/net/mptcp/ |
| H A D | protocol.c | 2077 msk->rcvq_space.rtt_us = 0; in mptcp_rcv_space_init() 2096 u64 rtt_us, mstamp; in mptcp_rcv_space_adjust() local 2111 rtt_us = msk->rcvq_space.rtt_us; in mptcp_rcv_space_adjust() 2112 if (rtt_us && time < (rtt_us >> 3)) in mptcp_rcv_space_adjust() 2115 rtt_us = 0; in mptcp_rcv_space_adjust() 2123 sf_rtt_us = READ_ONCE(tp->rcv_rtt_est.rtt_us); in mptcp_rcv_space_adjust() 2126 rtt_us = max(sf_rtt_us, rtt_us); in mptcp_rcv_space_adjust() 2131 msk->rcvq_space.rtt_us = rtt_us; in mptcp_rcv_space_adjust() 2133 if (time < (rtt_us >> 3) || rtt_us == 0) in mptcp_rcv_space_adjust()
|
| H A D | protocol.h | 347 u64 rtt_us; /* last maximum rtt of subflows */ member
|
| /linux/include/net/ |
| H A D | tcp.h | 1244 s32 rtt_us; member 1265 long rtt_us; /* RTT of last (S)ACKed packet (or -1) */ member
|