| /net/ipv4/ |
| D | tcp_cdg.c | 77 struct minmax rtt; member
143 ca->delay_min = min_not_zero(ca->delay_min, ca->rtt.min); in tcp_cdg_hystart_update()
176 if (ca->rtt.min > thresh) { in tcp_cdg_hystart_update()
190 s32 gmin = ca->rtt.min - ca->rtt_prev.min; in tcp_cdg_grad()
191 s32 gmax = ca->rtt.max - ca->rtt_prev.max; in tcp_cdg_grad()
270 if (after(ack, ca->rtt_seq) && ca->rtt.v64) { in tcp_cdg_cong_avoid()
276 ca->rtt_prev = ca->rtt; in tcp_cdg_cong_avoid()
277 ca->rtt.v64 = 0; in tcp_cdg_cong_avoid()
314 ca->rtt.min = min(ca->rtt.min, rtt_us); in tcp_cdg_acked()
322 ca->rtt.min = min_not_zero(ca->rtt.min, rtt_us); in tcp_cdg_acked()
[all …]
|
| D | tcp_westwood.c | 39 u32 rtt; member
70 w->rtt_min = w->rtt = TCP_WESTWOOD_INIT_RTT; in tcp_westwood_init()
102 static void tcp_westwood_pkts_acked(struct sock *sk, u32 cnt, s32 rtt) in tcp_westwood_pkts_acked() argument
106 if (rtt > 0) in tcp_westwood_pkts_acked()
107 w->rtt = usecs_to_jiffies(rtt); in tcp_westwood_pkts_acked()
138 if (w->rtt && delta > max_t(u32, w->rtt, TCP_WESTWOOD_RTT_MIN)) { in westwood_update_window()
149 w->rtt_min = w->rtt; in update_rtt_min()
152 w->rtt_min = min(w->rtt, w->rtt_min); in update_rtt_min()
267 info->vegas.tcpv_rtt = jiffies_to_usecs(ca->rtt), in tcp_westwood_info()
|
| D | tcp_illinois.c | 85 static void tcp_illinois_acked(struct sock *sk, u32 pkts_acked, s32 rtt) in tcp_illinois_acked() argument
92 if (rtt < 0) in tcp_illinois_acked()
96 if (rtt > RTT_MAX) in tcp_illinois_acked()
97 rtt = RTT_MAX; in tcp_illinois_acked()
100 if (ca->base_rtt > rtt) in tcp_illinois_acked()
101 ca->base_rtt = rtt; in tcp_illinois_acked()
104 if (ca->max_rtt < rtt) in tcp_illinois_acked()
105 ca->max_rtt = rtt; in tcp_illinois_acked()
108 ca->sum_rtt += rtt; in tcp_illinois_acked()
|
| D | tcp_yeah.c | 131 u32 rtt, queue; in tcp_yeah_cong_avoid() local
145 rtt = yeah->vegas.minRTT; in tcp_yeah_cong_avoid()
151 bw *= rtt - yeah->vegas.baseRTT; in tcp_yeah_cong_avoid()
152 do_div(bw, rtt); in tcp_yeah_cong_avoid()
156 rtt - yeah->vegas.baseRTT > (yeah->vegas.baseRTT / TCP_YEAH_PHY)) { in tcp_yeah_cong_avoid()
|
| D | tcp_vegas.c | 197 u32 rtt, diff; in tcp_vegas_cong_avoid() local
211 rtt = vegas->minRTT; in tcp_vegas_cong_avoid()
220 do_div(target_cwnd, rtt); in tcp_vegas_cong_avoid()
226 diff = tp->snd_cwnd * (rtt-vegas->baseRTT) / vegas->baseRTT; in tcp_vegas_cong_avoid()
|
| D | tcp_veno.c | 139 u32 rtt; in tcp_veno_cong_avoid() local
145 rtt = veno->minrtt; in tcp_veno_cong_avoid()
149 do_div(target_cwnd, rtt); in tcp_veno_cong_avoid()
|
| D | tcp_htcp.c | 102 u32 pkts_acked, s32 rtt) in measure_achieved_throughput() argument
112 if (rtt > 0) in measure_achieved_throughput()
113 measure_rtt(sk, usecs_to_jiffies(rtt)); in measure_achieved_throughput()
|
| D | tcp_metrics.c | 373 unsigned long rtt; in tcp_update_metrics() local
399 rtt = tcp_metric_get(tm, TCP_METRIC_RTT); in tcp_update_metrics()
400 m = rtt - tp->srtt_us; in tcp_update_metrics()
408 rtt = tp->srtt_us; in tcp_update_metrics()
410 rtt -= (m >> 3); in tcp_update_metrics()
411 tcp_metric_set(tm, TCP_METRIC_RTT, rtt); in tcp_update_metrics()
|
| D | tcp_bic.c | 200 static void bictcp_acked(struct sock *sk, u32 cnt, s32 rtt) in bictcp_acked() argument
|
| D | tcp_lp.c | 220 static void tcp_lp_rtt_sample(struct sock *sk, u32 rtt) in tcp_lp_rtt_sample() argument
|
| D | tcp_output.c | 2198 u32 rtt = usecs_to_jiffies(tp->srtt_us >> 3); in tcp_schedule_loss_probe() local
2232 timeout = rtt << 1 ? : TCP_TIMEOUT_INIT; in tcp_schedule_loss_probe()
2235 (rtt + (rtt >> 1) + TCP_DELACK_MAX)); in tcp_schedule_loss_probe()
3367 int rtt = max_t(int, usecs_to_jiffies(tp->srtt_us >> 3), in tcp_send_delayed_ack() local
3370 if (rtt < max_ato) in tcp_send_delayed_ack()
3371 max_ato = rtt; in tcp_send_delayed_ack()
|
| D | tcp_input.c | 502 u32 new_sample = tp->rcv_rtt_est.rtt; in tcp_rcv_rtt_update()
532 if (tp->rcv_rtt_est.rtt != new_sample) in tcp_rcv_rtt_update()
533 tp->rcv_rtt_est.rtt = new_sample; in tcp_rcv_rtt_update()
570 if (time < (tp->rcv_rtt_est.rtt >> 3) || tp->rcv_rtt_est.rtt == 0) in tcp_rcv_space_adjust()
2931 .rtt = likely(rtt_us) ? rtt_us : jiffies_to_usecs(1), in tcp_update_rtt_min()
2937 if (unlikely(rttm.rtt <= m[0].rtt)) in tcp_update_rtt_min()
2939 else if (rttm.rtt <= m[1].rtt) in tcp_update_rtt_min()
2941 else if (rttm.rtt <= m[2].rtt) in tcp_update_rtt_min()
|
| D | tcp_minisocks.c | 474 newtp->rtt_min[0].rtt = ~0U; in tcp_create_openreq_child()
|
| D | tcp.c | 392 tp->rtt_min[0].rtt = ~0U; in tcp_init_sock()
2732 info->tcpi_rcv_rtt = jiffies_to_usecs(tp->rcv_rtt_est.rtt)>>3; in tcp_get_info()
|
| /net/ax25/ |
| D | ax25_subr.c | 242 ax25->t1 = t * ax25->rtt; in ax25_calculate_t1()
254 ax25->rtt = (9 * ax25->rtt + ax25->t1 - ax25_display_timer(&ax25->t1timer)) / 10; in ax25_calculate_rtt()
256 if (ax25->rtt < AX25_T1CLAMPLO) in ax25_calculate_rtt()
257 ax25->rtt = AX25_T1CLAMPLO; in ax25_calculate_rtt()
259 if (ax25->rtt > AX25_T1CLAMPHI) in ax25_calculate_rtt()
260 ax25->rtt = AX25_T1CLAMPHI; in ax25_calculate_rtt()
|
| D | af_ax25.c | 402 ax25->rtt = (ax25_ctl.arg * HZ) / 2; in ax25_ctl_ioctl()
453 ax25->rtt = msecs_to_jiffies(ax25_dev->values[AX25_VALUES_T1]) / 2; in ax25_fillin_cb_from_dev()
487 ax25->rtt = msecs_to_jiffies(AX25_DEF_T1) / 2; in ax25_fillin_cb()
579 ax25->rtt = (opt * HZ) >> 1; in ax25_setsockopt()
935 ax25->rtt = oax25->rtt; in ax25_make_new()
1925 ax25->rtt / HZ, in ax25_info_show()
|
| /net/sctp/ |
| D | transport.c | 314 void sctp_transport_update_rto(struct sctp_transport *tp, __u32 rtt) in sctp_transport_update_rto() argument
334 + (((__u32)abs((__s64)tp->srtt - (__s64)rtt)) >> net->sctp.rto_beta); in sctp_transport_update_rto()
336 + (rtt >> net->sctp.rto_alpha); in sctp_transport_update_rto()
341 tp->srtt = rtt; in sctp_transport_update_rto()
342 tp->rttvar = rtt >> 1; in sctp_transport_update_rto()
367 tp->rtt = rtt; in sctp_transport_update_rto()
375 __func__, tp, rtt, tp->srtt, tp->rttvar, tp->rto); in sctp_transport_update_rto()
530 transport->rtt)) { in sctp_transport_lower_cwnd()
624 t->rtt = 0; in sctp_transport_reset()
|
| D | outqueue.c | 1311 __u32 rtt; in sctp_check_transmitted() local
1365 rtt = jiffies - tchunk->sent_at; in sctp_check_transmitted()
1367 rtt); in sctp_check_transmitted()
|
| D | socket.c | 643 trans->rtt = trans->srtt = trans->rttvar = 0; in sctp_send_asconf_add_ip()
|
| /net/decnet/ |
| D | dn_nsp_out.c | 165 static void dn_nsp_rtt(struct sock *sk, long rtt) in dn_nsp_rtt() argument
177 if (rtt < 0) in dn_nsp_rtt()
178 rtt = -rtt; in dn_nsp_rtt()
182 delta = ((rtt << 3) - srtt); in dn_nsp_rtt()
|
| /net/sunrpc/ |
| D | xprt.c | 547 struct rpc_rtt *rtt = clnt->cl_rtt; in xprt_set_retrans_timeout_rtt() local
551 task->tk_timeout = rpc_calc_rto(rtt, timer); in xprt_set_retrans_timeout_rtt()
552 task->tk_timeout <<= rpc_ntimeo(rtt, timer) + req->rq_retries; in xprt_set_retrans_timeout_rtt()
835 struct rpc_rtt *rtt = task->tk_client->cl_rtt; in xprt_update_rtt() local
841 rpc_update_rtt(rtt, timer, m); in xprt_update_rtt()
842 rpc_set_timeo(rtt, timer, req->rq_ntrans - 1); in xprt_update_rtt()
|
| /net/rxrpc/ |
| D | ar-internal.h | 191 suseconds_t rtt; /* current RTT estimate (in uS) */ member
|