| /net/sctp/ |
| D | transport.c | 416 __u32 cwnd, ssthresh, flight_size, pba, pmtu; in sctp_transport_raise_cwnd() local
418 cwnd = transport->cwnd; in sctp_transport_raise_cwnd()
430 if (cwnd <= ssthresh) { in sctp_transport_raise_cwnd()
453 if (flight_size < cwnd) in sctp_transport_raise_cwnd()
457 cwnd += pmtu; in sctp_transport_raise_cwnd()
459 cwnd += bytes_acked; in sctp_transport_raise_cwnd()
463 __func__, transport, bytes_acked, cwnd, ssthresh, in sctp_transport_raise_cwnd()
489 if (pba > cwnd && flight_size < cwnd) in sctp_transport_raise_cwnd()
490 pba = cwnd; in sctp_transport_raise_cwnd()
491 if (pba >= cwnd && flight_size >= cwnd) { in sctp_transport_raise_cwnd()
[all …]
|
| D | probe.c | 150 (full || sp->cwnd != lcwnd)) { in jsctp_sf_eat_sack()
151 lcwnd = sp->cwnd; in jsctp_sf_eat_sack()
169 &sp->ipaddr, sp->state, sp->cwnd, sp->ssthresh, in jsctp_sf_eat_sack()
|
| D | output.c | 702 flight_size >= transport->cwnd) in sctp_packet_can_append_data()
822 psize + chunk_len > (packet->transport->cwnd >> 1)) in sctp_packet_will_fit()
|
| D | outqueue.c | 530 transport->cwnd, transport->ssthresh, transport->flight_size, in sctp_retransmit_mark()
1733 transport->cwnd, transport->ssthresh, in sctp_mark_missing()
|
| D | associola.c | 704 peer->cwnd = min(4*asoc->pathmtu, max_t(__u32, 2*asoc->pathmtu, 4380)); in sctp_assoc_add_peer()
830 transport->cwnd = asoc->pathmtu; in sctp_assoc_control_transport()
|
| D | socket.c | 628 trans->cwnd = min(4*asoc->pathmtu, max_t(__u32, in sctp_send_asconf_add_ip()
4600 info->sctpi_p_cwnd = prim->cwnd; in sctp_get_sctp_info()
4813 status.sstat_primary.spinfo_cwnd = transport->cwnd; in sctp_getsockopt_sctp_status()
4873 pinfo.spinfo_cwnd = transport->cwnd; in sctp_getsockopt_peer_addr_info()
|
| /net/ipv4/ |
| D | tcp_bic.c | 82 static inline void bictcp_update(struct bictcp *ca, u32 cwnd) in bictcp_update() argument
84 if (ca->last_cwnd == cwnd && in bictcp_update()
88 ca->last_cwnd = cwnd; in bictcp_update()
95 if (cwnd <= low_window) { in bictcp_update()
96 ca->cnt = cwnd; in bictcp_update()
101 if (cwnd < ca->last_max_cwnd) { in bictcp_update()
102 __u32 dist = (ca->last_max_cwnd - cwnd) in bictcp_update()
107 ca->cnt = cwnd / max_increment; in bictcp_update()
110 ca->cnt = (cwnd * smooth_part) / BICTCP_B; in bictcp_update()
113 ca->cnt = cwnd / dist; in bictcp_update()
[all …]
|
| D | tcp_bbr.c | 333 u32 cwnd; in bbr_target_cwnd() local
348 cwnd = (((w * gain) >> BBR_SCALE) + BW_UNIT - 1) / BW_UNIT; in bbr_target_cwnd()
351 cwnd += 3 * bbr->tso_segs_goal; in bbr_target_cwnd()
354 cwnd = (cwnd + 1) & ~1U; in bbr_target_cwnd()
358 cwnd += 2; in bbr_target_cwnd()
360 return cwnd; in bbr_target_cwnd()
377 u32 cwnd = tp->snd_cwnd; in bbr_set_cwnd_to_recover_or_restore() local
384 cwnd = max_t(s32, cwnd - rs->losses, 1); in bbr_set_cwnd_to_recover_or_restore()
391 cwnd = tcp_packets_in_flight(tp) + acked; in bbr_set_cwnd_to_recover_or_restore()
401 cwnd = max(cwnd, bbr->prior_cwnd); in bbr_set_cwnd_to_recover_or_restore()
[all …]
|
| D | tcp_cubic.c | 224 static inline void bictcp_update(struct bictcp *ca, u32 cwnd, u32 acked) in bictcp_update() argument
231 if (ca->last_cwnd == cwnd && in bictcp_update()
242 ca->last_cwnd = cwnd; in bictcp_update()
248 ca->tcp_cwnd = cwnd; /* syn with cubic */ in bictcp_update()
250 if (ca->last_max_cwnd <= cwnd) { in bictcp_update()
252 ca->bic_origin_point = cwnd; in bictcp_update()
258 * (ca->last_max_cwnd - cwnd)); in bictcp_update()
296 if (bic_target > cwnd) { in bictcp_update()
297 ca->cnt = cwnd / (bic_target - cwnd); in bictcp_update()
299 ca->cnt = 100 * cwnd; /* very small increment*/ in bictcp_update()
[all …]
|
| D | tcp_highspeed.c | 16 unsigned int cwnd; member
129 if (tp->snd_cwnd > hstcp_aimd_vals[ca->ai].cwnd) { in hstcp_cong_avoid()
130 while (tp->snd_cwnd > hstcp_aimd_vals[ca->ai].cwnd && in hstcp_cong_avoid()
133 } else if (ca->ai && tp->snd_cwnd <= hstcp_aimd_vals[ca->ai-1].cwnd) { in hstcp_cong_avoid()
134 while (ca->ai && tp->snd_cwnd <= hstcp_aimd_vals[ca->ai-1].cwnd) in hstcp_cong_avoid()
|
| D | tcp_cong.c | 399 u32 cwnd = min(tp->snd_cwnd + acked, tp->snd_ssthresh); in tcp_slow_start() local
401 acked -= cwnd - tp->snd_cwnd; in tcp_slow_start()
402 tp->snd_cwnd = min(cwnd, tp->snd_cwnd_clamp); in tcp_slow_start()
|
| D | tcp_output.c | 144 u32 cwnd = tp->snd_cwnd; in tcp_cwnd_restart() local
149 restart_cwnd = min(restart_cwnd, cwnd); in tcp_cwnd_restart()
151 while ((delta -= inet_csk(sk)->icsk_rto) > 0 && cwnd > restart_cwnd) in tcp_cwnd_restart()
152 cwnd >>= 1; in tcp_cwnd_restart()
153 tp->snd_cwnd = max(cwnd, restart_cwnd); in tcp_cwnd_restart()
1766 u32 in_flight, cwnd, halfcwnd; in tcp_cwnd_test() local
1774 cwnd = tp->snd_cwnd; in tcp_cwnd_test()
1775 if (in_flight >= cwnd) in tcp_cwnd_test()
1781 halfcwnd = max(cwnd >> 1, 1U); in tcp_cwnd_test()
1782 return min(halfcwnd, cwnd - in_flight); in tcp_cwnd_test()
|
| D | Kconfig | 562 coalescence. In addition, it will decrease its cwnd multiplicatively
565 Note that in general congestion avoidance (cwnd decreased when # packets
566 queued grows) cannot coexist with congestion control (cwnd decreased only
|
| D | tcp_input.c | 870 __u32 cwnd = (dst ? dst_metric(dst, RTAX_INITCWND) : 0); in tcp_init_cwnd() local
872 if (!cwnd) in tcp_init_cwnd()
873 cwnd = TCP_INIT_CWND; in tcp_init_cwnd()
874 return min_t(__u32, cwnd, tp->snd_cwnd_clamp); in tcp_init_cwnd()
|
| /net/batman-adv/ |
| D | tp_meter.c | 157 if (tp_vars->cwnd <= tp_vars->ss_threshold) { in batadv_tp_update_cwnd()
159 tp_vars->cwnd = batadv_tp_cwnd(tp_vars->cwnd, mss, mss); in batadv_tp_update_cwnd()
166 ((mss * mss) << 6) / (tp_vars->cwnd << 3)); in batadv_tp_update_cwnd()
172 tp_vars->cwnd = batadv_tp_cwnd(tp_vars->cwnd, mss, mss); in batadv_tp_update_cwnd()
422 tp_vars->cwnd, tp_vars->ss_threshold); in batadv_tp_sender_end()
513 tp_vars->ss_threshold = tp_vars->cwnd >> 1; in batadv_tp_sender_timeout()
519 tp_vars->other_end, tp_vars->cwnd, tp_vars->ss_threshold, in batadv_tp_sender_timeout()
522 tp_vars->cwnd = BATADV_TP_PLEN * 3; in batadv_tp_sender_timeout()
640 u32 rtt, recv_ack, cwnd; in batadv_tp_recv_ack() local
704 tp_vars->ss_threshold = tp_vars->cwnd >> 1; in batadv_tp_recv_ack()
[all …]
|
| D | types.h | 943 u32 cwnd; member
|
| /net/sunrpc/xprtrdma/ |
| D | svc_rdma_backchannel.c | 32 unsigned long cwnd; in svc_rdma_handle_bc_reply() local
74 cwnd = xprt->cwnd; in svc_rdma_handle_bc_reply()
75 xprt->cwnd = credits << RPC_CWNDSHIFT; in svc_rdma_handle_bc_reply()
76 if (xprt->cwnd > cwnd) in svc_rdma_handle_bc_reply()
|
| D | rpc_rdma.c | 1231 unsigned long cwnd; in rpcrdma_reply_handler() local
1304 cwnd = xprt->cwnd; in rpcrdma_reply_handler()
1305 xprt->cwnd = atomic_read(&r_xprt->rx_buf.rb_credits) << RPC_CWNDSHIFT; in rpcrdma_reply_handler()
1306 if (xprt->cwnd > cwnd) in rpcrdma_reply_handler()
|
| /net/sunrpc/ |
| D | xprt.c | 398 task->tk_pid, xprt->cong, xprt->cwnd); in __xprt_get_cong()
453 unsigned long cwnd = xprt->cwnd; in xprt_adjust_cwnd() local
455 if (result >= 0 && cwnd <= xprt->cong) { in xprt_adjust_cwnd()
458 cwnd += (RPC_CWNDSCALE * RPC_CWNDSCALE + (cwnd >> 1)) / cwnd; in xprt_adjust_cwnd()
459 if (cwnd > RPC_MAXCWND(xprt)) in xprt_adjust_cwnd()
460 cwnd = RPC_MAXCWND(xprt); in xprt_adjust_cwnd()
463 cwnd >>= 1; in xprt_adjust_cwnd()
464 if (cwnd < RPC_CWNDSCALE) in xprt_adjust_cwnd()
465 cwnd = RPC_CWNDSCALE; in xprt_adjust_cwnd()
468 xprt->cong, xprt->cwnd, cwnd); in xprt_adjust_cwnd()
[all …]
|
| /net/rxrpc/ |
| D | input.c | 49 unsigned int cwnd = call->cong_cwnd; in rxrpc_congestion_management() local
59 cwnd = 1; in rxrpc_congestion_management()
60 if (cwnd >= call->cong_ssthresh && in rxrpc_congestion_management()
74 summary->cwnd = call->cong_cwnd; in rxrpc_congestion_management()
84 cwnd += 1; in rxrpc_congestion_management()
85 if (cwnd >= call->cong_ssthresh) { in rxrpc_congestion_management()
106 if (cumulative_acks >= cwnd) in rxrpc_congestion_management()
107 cwnd++; in rxrpc_congestion_management()
130 cwnd = call->cong_ssthresh + 3; in rxrpc_congestion_management()
139 cwnd += 1; in rxrpc_congestion_management()
[all …]
|
| D | ar-internal.h | 631 u8 cwnd; member
|
| /net/dccp/ccids/ |
| D | ccid2.c | 229 u32 cwnd = hc->tx_cwnd, restart_cwnd, in ccid2_cwnd_restart() local
233 hc->tx_ssthresh = max(hc->tx_ssthresh, (cwnd >> 1) + (cwnd >> 2)); in ccid2_cwnd_restart()
236 restart_cwnd = min(cwnd, iwnd); in ccid2_cwnd_restart()
238 while ((delta -= hc->tx_rto) >= 0 && cwnd > restart_cwnd) in ccid2_cwnd_restart()
239 cwnd >>= 1; in ccid2_cwnd_restart()
240 hc->tx_cwnd = max(cwnd, restart_cwnd); in ccid2_cwnd_restart()
|