| /net/ipv4/ |
| A D | tcp_bic.c | 85 if (ca->last_cwnd == cwnd && in bictcp_update()
89 ca->last_cwnd = cwnd; in bictcp_update()
96 if (cwnd <= low_window) { in bictcp_update()
97 ca->cnt = cwnd; in bictcp_update()
102 if (cwnd < ca->last_max_cwnd) { in bictcp_update()
103 __u32 dist = (ca->last_max_cwnd - cwnd) in bictcp_update()
108 ca->cnt = cwnd / max_increment; in bictcp_update()
114 ca->cnt = cwnd / dist; in bictcp_update()
122 ca->cnt = (cwnd * (BICTCP_B-1)) in bictcp_update()
123 / (cwnd - ca->last_max_cwnd); in bictcp_update()
[all …]
|
| A D | tcp_cubic.c | 221 if (ca->last_cwnd == cwnd && in bictcp_update()
232 ca->last_cwnd = cwnd; in bictcp_update()
238 ca->tcp_cwnd = cwnd; /* syn with cubic */ in bictcp_update()
240 if (ca->last_max_cwnd <= cwnd) { in bictcp_update()
242 ca->bic_origin_point = cwnd; in bictcp_update()
248 * (ca->last_max_cwnd - cwnd)); in bictcp_update()
286 if (bic_target > cwnd) { in bictcp_update()
287 ca->cnt = cwnd / (bic_target - cwnd); in bictcp_update()
304 delta = (cwnd * scale) >> 3; in bictcp_update()
311 delta = ca->tcp_cwnd - cwnd; in bictcp_update()
[all …]
|
| A D | tcp_bbr.c | 400 cwnd += 3 * bbr_tso_segs_goal(sk); in bbr_quantization_budget()
403 cwnd = (cwnd + 1) & ~1U; in bbr_quantization_budget()
407 cwnd += 2; in bbr_quantization_budget()
409 return cwnd; in bbr_quantization_budget()
486 u32 cwnd = tcp_snd_cwnd(tp); in bbr_set_cwnd_to_recover_or_restore() local
493 cwnd = max_t(s32, cwnd - rs->losses, 1); in bbr_set_cwnd_to_recover_or_restore()
503 cwnd = max(cwnd, bbr->prior_cwnd); in bbr_set_cwnd_to_recover_or_restore()
512 *new_cwnd = cwnd; in bbr_set_cwnd_to_recover_or_restore()
542 cwnd = min(cwnd + acked, target_cwnd); in bbr_set_cwnd()
544 cwnd = cwnd + acked; in bbr_set_cwnd()
[all …]
|
| A D | tcp_highspeed.c | 17 unsigned int cwnd; member
130 if (tcp_snd_cwnd(tp) > hstcp_aimd_vals[ca->ai].cwnd) { in hstcp_cong_avoid()
131 while (tcp_snd_cwnd(tp) > hstcp_aimd_vals[ca->ai].cwnd && in hstcp_cong_avoid()
134 } else if (ca->ai && tcp_snd_cwnd(tp) <= hstcp_aimd_vals[ca->ai-1].cwnd) { in hstcp_cong_avoid()
135 while (ca->ai && tcp_snd_cwnd(tp) <= hstcp_aimd_vals[ca->ai-1].cwnd) in hstcp_cong_avoid()
|
| A D | tcp_cong.c | 457 u32 cwnd = min(tcp_snd_cwnd(tp) + acked, tp->snd_ssthresh); in tcp_slow_start() local
459 acked -= cwnd - tcp_snd_cwnd(tp); in tcp_slow_start()
460 tcp_snd_cwnd_set(tp, min(cwnd, tp->snd_cwnd_clamp)); in tcp_slow_start()
|
| A D | tcp_output.c | 148 u32 cwnd = tcp_snd_cwnd(tp); in tcp_cwnd_restart() local
153 restart_cwnd = min(restart_cwnd, cwnd); in tcp_cwnd_restart()
155 while ((delta -= inet_csk(sk)->icsk_rto) > 0 && cwnd > restart_cwnd) in tcp_cwnd_restart()
156 cwnd >>= 1; in tcp_cwnd_restart()
157 tcp_snd_cwnd_set(tp, max(cwnd, restart_cwnd)); in tcp_cwnd_restart()
2090 u32 in_flight, cwnd, halfcwnd; in tcp_cwnd_test() local
2093 cwnd = tcp_snd_cwnd(tp); in tcp_cwnd_test()
2094 if (in_flight >= cwnd) in tcp_cwnd_test()
2100 halfcwnd = max(cwnd >> 1, 1U); in tcp_cwnd_test()
2101 return min(halfcwnd, cwnd - in_flight); in tcp_cwnd_test()
|
| A D | Kconfig | 564 coalescence. In addition, it will decrease its cwnd multiplicatively
567 Note that in general congestion avoidance (cwnd decreased when # packets
568 queued grows) cannot coexist with congestion control (cwnd decreased only
|
| A D | tcp_input.c | 1017 __u32 cwnd = (dst ? dst_metric(dst, RTAX_INITCWND) : 0); in tcp_init_cwnd() local
1019 if (!cwnd) in tcp_init_cwnd()
1020 cwnd = TCP_INIT_CWND; in tcp_init_cwnd()
1021 return min_t(__u32, cwnd, tp->snd_cwnd_clamp); in tcp_init_cwnd()
|
| /net/sctp/ |
| A D | transport.c | 563 cwnd = transport->cwnd; in sctp_transport_raise_cwnd()
575 if (cwnd <= ssthresh) { in sctp_transport_raise_cwnd()
602 cwnd += pmtu; in sctp_transport_raise_cwnd()
604 cwnd += bytes_acked; in sctp_transport_raise_cwnd()
634 if (pba > cwnd && flight_size < cwnd) in sctp_transport_raise_cwnd()
635 pba = cwnd; in sctp_transport_raise_cwnd()
636 if (pba >= cwnd && flight_size >= cwnd) { in sctp_transport_raise_cwnd()
637 pba = pba - cwnd; in sctp_transport_raise_cwnd()
638 cwnd += pmtu; in sctp_transport_raise_cwnd()
648 transport->cwnd = cwnd; in sctp_transport_raise_cwnd()
[all …]
|
| A D | output.c | 718 flight_size >= transport->cwnd) in sctp_packet_can_append_data()
848 psize + chunk_len > (packet->transport->cwnd >> 1)) in sctp_packet_will_fit()
|
| A D | outqueue.c | 530 transport->cwnd, transport->ssthresh, transport->flight_size, in sctp_retransmit_mark()
1766 transport->cwnd, transport->ssthresh, in sctp_mark_missing()
|
| A D | associola.c | 692 peer->cwnd = min(4*asoc->pathmtu, max_t(__u32, 2*asoc->pathmtu, 4380)); in sctp_assoc_add_peer()
|
| A D | socket.c | 646 trans->cwnd = min(4*asoc->pathmtu, max_t(__u32, in sctp_send_asconf_add_ip()
5242 info->sctpi_p_cwnd = prim->cwnd; in sctp_get_sctp_info()
5460 status.sstat_primary.spinfo_cwnd = transport->cwnd; in sctp_getsockopt_sctp_status()
5528 pinfo.spinfo_cwnd = transport->cwnd; in sctp_getsockopt_peer_addr_info()
|
| /net/batman-adv/ |
| A D | tp_meter.c | 148 if (tp_vars->cwnd <= tp_vars->ss_threshold) { in batadv_tp_update_cwnd()
150 tp_vars->cwnd = batadv_tp_cwnd(tp_vars->cwnd, mss, mss); in batadv_tp_update_cwnd()
163 tp_vars->cwnd = batadv_tp_cwnd(tp_vars->cwnd, mss, mss); in batadv_tp_update_cwnd()
417 tp_vars->cwnd, tp_vars->ss_threshold); in batadv_tp_sender_end()
508 tp_vars->ss_threshold = tp_vars->cwnd >> 1; in batadv_tp_sender_timeout()
517 tp_vars->cwnd = BATADV_TP_PLEN * 3; in batadv_tp_sender_timeout()
636 u32 rtt, recv_ack, cwnd; in batadv_tp_recv_ack() local
702 tp_vars->cwnd, tp_vars->ss_threshold, in batadv_tp_recv_ack()
730 tp_vars->cwnd = batadv_tp_cwnd(tp_vars->cwnd, in batadv_tp_recv_ack()
740 tp_vars->cwnd = cwnd; in batadv_tp_recv_ack()
[all …]
|
| A D | types.h | 1467 u32 cwnd; member
|
| /net/sunrpc/ |
| A D | xprt.c | 565 unsigned long cwnd = xprt->cwnd; in xprt_adjust_cwnd() local
567 if (result >= 0 && cwnd <= xprt->cong) { in xprt_adjust_cwnd()
570 cwnd += (RPC_CWNDSCALE * RPC_CWNDSCALE + (cwnd >> 1)) / cwnd; in xprt_adjust_cwnd()
571 if (cwnd > RPC_MAXCWND(xprt)) in xprt_adjust_cwnd()
572 cwnd = RPC_MAXCWND(xprt); in xprt_adjust_cwnd()
575 cwnd >>= 1; in xprt_adjust_cwnd()
576 if (cwnd < RPC_CWNDSCALE) in xprt_adjust_cwnd()
577 cwnd = RPC_CWNDSCALE; in xprt_adjust_cwnd()
580 xprt->cong, xprt->cwnd, cwnd); in xprt_adjust_cwnd()
581 xprt->cwnd = cwnd; in xprt_adjust_cwnd()
[all …]
|
| A D | sysfs.c | 234 xprt->last_used, xprt->cong, xprt->cwnd, xprt->max_reqs, in rpc_sysfs_xprt_info_show()
|
| /net/sunrpc/xprtrdma/ |
| A D | svc_rdma_backchannel.c | 50 xprt->cwnd = credits << RPC_CWNDSHIFT; in svc_rdma_handle_bc_reply()
200 xprt->cwnd = RPC_CWNDSHIFT; in xprt_rdma_bc_close()
|
| A D | rpc_rdma.c | 992 xprt->cwnd = grant << RPC_CWNDSHIFT; in __rpcrdma_update_cwnd_locked()
|