| /linux-6.6.21/net/ipv4/ |
| D | tcp_bic.c | 83 static inline void bictcp_update(struct bictcp *ca, u32 cwnd) in bictcp_update() argument
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()
111 ca->cnt = (cwnd * smooth_part) / BICTCP_B; in bictcp_update()
114 ca->cnt = cwnd / dist; in bictcp_update()
[all …]
|
| D | tcp_cubic.c | 214 static inline void bictcp_update(struct bictcp *ca, u32 cwnd, u32 acked) in bictcp_update() argument
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()
289 ca->cnt = 100 * cwnd; /* very small increment*/ in bictcp_update()
[all …]
|
| 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()
|
| D | tcp_bbr.c | 394 static u32 bbr_quantization_budget(struct sock *sk, u32 cwnd) in bbr_quantization_budget() argument
399 cwnd += 3 * bbr_tso_segs_goal(sk); in bbr_quantization_budget()
402 cwnd = (cwnd + 1) & ~1U; in bbr_quantization_budget()
406 cwnd += 2; in bbr_quantization_budget()
408 return cwnd; in bbr_quantization_budget()
485 u32 cwnd = tcp_snd_cwnd(tp); in bbr_set_cwnd_to_recover_or_restore() local
492 cwnd = max_t(s32, cwnd - rs->losses, 1); in bbr_set_cwnd_to_recover_or_restore()
499 cwnd = tcp_packets_in_flight(tp) + acked; in bbr_set_cwnd_to_recover_or_restore()
502 cwnd = max(cwnd, bbr->prior_cwnd); in bbr_set_cwnd_to_recover_or_restore()
508 *new_cwnd = max(cwnd, tcp_packets_in_flight(tp) + acked); in bbr_set_cwnd_to_recover_or_restore()
[all …]
|
| D | tcp_cong.c | 460 u32 cwnd = min(tcp_snd_cwnd(tp) + acked, tp->snd_ssthresh); in tcp_slow_start() local
462 acked -= cwnd - tcp_snd_cwnd(tp); in tcp_slow_start()
463 tcp_snd_cwnd_set(tp, min(cwnd, tp->snd_cwnd_clamp)); in tcp_slow_start()
|
| D | tcp_output.c | 146 u32 cwnd = tcp_snd_cwnd(tp); in tcp_cwnd_restart() local
151 restart_cwnd = min(restart_cwnd, cwnd); in tcp_cwnd_restart()
153 while ((delta -= inet_csk(sk)->icsk_rto) > 0 && cwnd > restart_cwnd) in tcp_cwnd_restart()
154 cwnd >>= 1; in tcp_cwnd_restart()
155 tcp_snd_cwnd_set(tp, max(cwnd, restart_cwnd)); in tcp_cwnd_restart()
2047 u32 in_flight, cwnd, halfcwnd; in tcp_cwnd_test() local
2055 cwnd = tcp_snd_cwnd(tp); in tcp_cwnd_test()
2056 if (in_flight >= cwnd) in tcp_cwnd_test()
2062 halfcwnd = max(cwnd >> 1, 1U); in tcp_cwnd_test()
2063 return min(halfcwnd, cwnd - in_flight); in tcp_cwnd_test()
|
| /linux-6.6.21/net/sctp/ |
| D | transport.c | 559 __u32 cwnd, ssthresh, flight_size, pba, pmtu; in sctp_transport_raise_cwnd() local
561 cwnd = transport->cwnd; in sctp_transport_raise_cwnd()
573 if (cwnd <= ssthresh) { in sctp_transport_raise_cwnd()
596 if (flight_size < cwnd) in sctp_transport_raise_cwnd()
600 cwnd += pmtu; in sctp_transport_raise_cwnd()
602 cwnd += bytes_acked; in sctp_transport_raise_cwnd()
606 __func__, transport, bytes_acked, cwnd, ssthresh, in sctp_transport_raise_cwnd()
632 if (pba > cwnd && flight_size < cwnd) in sctp_transport_raise_cwnd()
633 pba = cwnd; in sctp_transport_raise_cwnd()
634 if (pba >= cwnd && flight_size >= cwnd) { in sctp_transport_raise_cwnd()
[all …]
|
| 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()
|
| /linux-6.6.21/tools/testing/selftests/bpf/progs/ |
| D | bpf_cubic.c | 266 static __always_inline void bictcp_update(struct bictcp *ca, __u32 cwnd, in bictcp_update() argument
274 if (ca->last_cwnd == cwnd && in bictcp_update()
285 ca->last_cwnd = cwnd; in bictcp_update()
291 ca->tcp_cwnd = cwnd; /* syn with cubic */ in bictcp_update()
293 if (ca->last_max_cwnd <= cwnd) { in bictcp_update()
295 ca->bic_origin_point = cwnd; in bictcp_update()
301 * (ca->last_max_cwnd - cwnd)); in bictcp_update()
339 if (bic_target > cwnd) { in bictcp_update()
340 ca->cnt = cwnd / (bic_target - cwnd); in bictcp_update()
342 ca->cnt = 100 * cwnd; /* very small increment*/ in bictcp_update()
[all …]
|
| /linux-6.6.21/samples/bpf/ |
| D | hbm_kern.h | 74 int cwnd; member
94 pkti->cwnd = tp->snd_cwnd; in get_tcp_info()
102 pkti->cwnd = 0; in get_tcp_info()
114 pkti->cwnd = 0; in hbm_get_pkt_info()
187 if (pkti->cwnd) { in hbm_update_stats()
189 pkti->cwnd); in hbm_update_stats()
|
| /linux-6.6.21/net/batman-adv/ |
| 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()
157 ((mss * mss) << 6) / (tp_vars->cwnd << 3)); 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()
514 tp_vars->other_end, tp_vars->cwnd, tp_vars->ss_threshold, 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
699 tp_vars->ss_threshold = tp_vars->cwnd >> 1; in batadv_tp_recv_ack()
[all …]
|
| /linux-6.6.21/include/trace/events/ |
| D | sctp.h | 23 __field(__u32, cwnd)
35 __entry->cwnd = sp->cwnd;
45 __entry->ipaddr, __entry->state, __entry->cwnd,
|
| D | rxrpc.h | 1560 __entry->sum.cwnd,
1581 __field(unsigned short, cwnd)
1592 __entry->cwnd = call->cong_cwnd;
1604 __entry->cwnd,
|
| /linux-6.6.21/net/rxrpc/ |
| D | input.c | 28 unsigned int cwnd = call->cong_cwnd; in rxrpc_congestion_management() local
38 cwnd = 1; in rxrpc_congestion_management()
39 if (cwnd >= call->cong_ssthresh && in rxrpc_congestion_management()
51 summary->cwnd = call->cong_cwnd; in rxrpc_congestion_management()
61 cwnd += 1; in rxrpc_congestion_management()
62 if (cwnd >= call->cong_ssthresh) { in rxrpc_congestion_management()
83 if (cumulative_acks >= cwnd) in rxrpc_congestion_management()
84 cwnd++; in rxrpc_congestion_management()
107 cwnd = call->cong_ssthresh + 3; in rxrpc_congestion_management()
116 cwnd += 1; in rxrpc_congestion_management()
[all …]
|
| /linux-6.6.21/include/linux/qed/ |
| D | tcp_common.h | 92 __le32 cwnd; member
158 __le32 cwnd; member
238 __le32 cwnd; member
|
| D | qed_nvmetcp_if.h | 51 u32 cwnd; member
|
| D | qed_iscsi_if.h | 75 u32 cwnd; member
|
| /linux-6.6.21/net/dccp/ccids/ |
| D | ccid2.c | 220 u32 cwnd = hc->tx_cwnd, restart_cwnd, in ccid2_cwnd_restart() local
224 hc->tx_ssthresh = max(hc->tx_ssthresh, (cwnd >> 1) + (cwnd >> 2)); in ccid2_cwnd_restart()
227 restart_cwnd = min(cwnd, iwnd); in ccid2_cwnd_restart()
229 while ((delta -= hc->tx_rto) >= 0 && cwnd > restart_cwnd) in ccid2_cwnd_restart()
230 cwnd >>= 1; in ccid2_cwnd_restart()
231 hc->tx_cwnd = max(cwnd, restart_cwnd); in ccid2_cwnd_restart()
|
| /linux-6.6.21/net/sunrpc/ |
| 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 …]
|
| /linux-6.6.21/net/sunrpc/xprtrdma/ |
| D | svc_rdma_backchannel.c | 50 xprt->cwnd = credits << RPC_CWNDSHIFT; in svc_rdma_handle_bc_reply()
203 xprt->cwnd = RPC_CWNDSHIFT; in xprt_rdma_bc_close()
|
| /linux-6.6.21/drivers/net/ethernet/qlogic/qed/ |
| D | qed_nvmetcp.h | 73 u32 cwnd; member
|
| D | qed_iscsi.c | 80 u32 cwnd; member
364 p_tcp->cwnd = cpu_to_le32(p_conn->cwnd); in qed_sp_iscsi_conn_offload()
439 p_tcp2->cwnd = cpu_to_le32(p_conn->cwnd); in qed_sp_iscsi_conn_offload()
1245 con->cwnd = conn_info->cwnd; in qed_iscsi_offload_conn()
|
| D | qed_nvmetcp.c | 347 p_tcp->cwnd = cpu_to_le32(p_conn->cwnd); in qed_sp_nvmetcp_conn_offload()
715 con->cwnd = conn_info->cwnd; in qed_nvmetcp_offload_conn()
|
| /linux-6.6.21/include/linux/sunrpc/ |
| D | xprt.h | 31 #define RPCXPRT_CONGESTED(xprt) ((xprt)->cong >= (xprt)->cwnd)
218 unsigned long cwnd; /* congestion window */ member
|
| /linux-6.6.21/Documentation/netlink/specs/ |
| D | rt_route.yaml | 206 name: rtax-cwnd
|