| /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_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 | 831 u32 new_sample, old_sample = tp->rcv_rtt_est.rtt_us; in tcp_rcv_rtt_update()
855 tp->rcv_rtt_est.rtt_us = new_sample; in tcp_rcv_rtt_update()
916 u32 rtt_threshold, rtt_us; in tcp_rcvbuf_grow() local
929 rtt_us = tp->rcv_rtt_est.rtt_us >> 3; in tcp_rcvbuf_grow()
931 if (rtt_us < rtt_threshold) { in tcp_rcvbuf_grow()
936 grow = div_u64((u64)rcvwin * rtt_us, rtt_threshold); in tcp_rcvbuf_grow()
967 if (unlikely(!tp->rcv_rtt_est.rtt_us)) in tcp_rcv_space_adjust()
975 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 …]
|
| /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 | mptcp.h | 195 __field(__u32, rtt_us)
220 __entry->rtt_us = mptcp_rtt_us_est(msk) >> 3;
252 __entry->time, __entry->rtt_us, __entry->copied,
|
| 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,
|
| /linux/tools/testing/selftests/bpf/progs/ |
| H A D | bpf_cubic.c | 515 if (sample->rtt_us < 0) in BPF_PROG()
522 delay = sample->rtt_us; in BPF_PROG()
|
| /linux/include/linux/ |
| H A D | tcp.h | 357 u32 rtt_us; member
384 u32 rtt_us; /* Associated RTT */ member
|
| /linux/net/mptcp/ |
| H A D | protocol.h | 453 u32 rtt_us = READ_ONCE(msk->rcv_rtt_est.samples[0]); in mptcp_rtt_us_est() local
458 rtt_us = min(rtt_us, READ_ONCE(msk->rcv_rtt_est.samples[i])); in mptcp_rtt_us_est()
459 return rtt_us; in mptcp_rtt_us_est()
|
| H A D | protocol.c | 989 u32 rtt_us = tp->rcv_rtt_est.rtt_us; in mptcp_rcv_rtt_update() local
995 if (!rtt_us || tp->rcv_rtt_est.seq == subflow->prev_rtt_seq) in mptcp_rcv_rtt_update()
1002 WRITE_ONCE(msk->rcv_rtt_est.samples[id], rtt_us); in mptcp_rcv_rtt_update()
2238 u32 time, rtt_us; in mptcp_rcv_space_adjust() local
2254 rtt_us = mptcp_rtt_us_est(msk); in mptcp_rcv_space_adjust()
2255 if (rtt_us == U32_MAX || time < (rtt_us >> 3)) in mptcp_rcv_space_adjust()
|