Home
last modified time | relevance | path

Searched refs:cwnd (Results 1 – 18 of 18) sorted by relevance

/third_party/node/deps/ngtcp2/ngtcp2/lib/
Dngtcp2_cc.c117 if (cc->target_cwnd && cc->target_cwnd < cstat->cwnd) { in ngtcp2_cc_reno_cc_on_pkt_acked()
121 if (cstat->cwnd < cstat->ssthresh) { in ngtcp2_cc_reno_cc_on_pkt_acked()
122 cstat->cwnd += pkt->pktlen; in ngtcp2_cc_reno_cc_on_pkt_acked()
125 pkt->pkt_num, cstat->cwnd); in ngtcp2_cc_reno_cc_on_pkt_acked()
130 cc->pending_add = m % cstat->cwnd; in ngtcp2_cc_reno_cc_on_pkt_acked()
132 cstat->cwnd += m / cstat->cwnd; in ngtcp2_cc_reno_cc_on_pkt_acked()
146 cstat->cwnd >>= NGTCP2_LOSS_REDUCTION_FACTOR_BITS; in ngtcp2_cc_reno_cc_congestion_event()
148 cstat->cwnd = ngtcp2_max(cstat->cwnd, min_cwnd); in ngtcp2_cc_reno_cc_congestion_event()
149 cstat->ssthresh = cstat->cwnd; in ngtcp2_cc_reno_cc_congestion_event()
155 cstat->cwnd); in ngtcp2_cc_reno_cc_congestion_event()
[all …]
Dngtcp2_bbr.c108 cc->initial_cwnd = cstat->cwnd; in ngtcp2_bbr_cc_init()
204 cstat->cwnd = 2 * cstat->max_udp_payload_size; in ngtcp2_cc_bbr_cc_on_persistent_congestion()
310 cstat->cwnd = cstat->bytes_in_flight + in bbr_handle_recovery()
414 if (cstat->cwnd > ack->bytes_lost) { in bbr_modulate_cwnd_for_recovery()
415 cstat->cwnd -= ack->bytes_lost; in bbr_modulate_cwnd_for_recovery()
416 cstat->cwnd = ngtcp2_max(cstat->cwnd, 2 * cstat->max_udp_payload_size); in bbr_modulate_cwnd_for_recovery()
418 cstat->cwnd = cstat->max_udp_payload_size; in bbr_modulate_cwnd_for_recovery()
423 cstat->cwnd = in bbr_modulate_cwnd_for_recovery()
424 ngtcp2_max(cstat->cwnd, cstat->bytes_in_flight + ack->bytes_delivered); in bbr_modulate_cwnd_for_recovery()
430 cc->prior_cwnd = cstat->cwnd; in bbr_save_cwnd()
[all …]
Dngtcp2_bbr2.c551 bbr->inflight_lo = cstat->cwnd; in bbr_init_lower_bounds()
632 extra = ngtcp2_min(extra, cstat->cwnd); in bbr_update_ack_aggregation()
819 bbr->probe_up_cnt = ngtcp2_max(cstat->cwnd / growth_this_round, 1) * in bbr_raise_inflight_hi_slope()
828 if (!bbr->rst->is_cwnd_limited || cstat->cwnd < bbr->inflight_hi) { in bbr_probe_inflight_hi_upward()
917 return ngtcp2_min(bdp, cstat->cwnd); in bbr_target_inflight()
1196 if (cstat->cwnd > ack->bytes_lost) { in bbr_modulate_cwnd_for_recovery()
1197 cstat->cwnd -= ack->bytes_lost; in bbr_modulate_cwnd_for_recovery()
1198 cstat->cwnd = ngtcp2_max(cstat->cwnd, 2 * cstat->max_udp_payload_size); in bbr_modulate_cwnd_for_recovery()
1200 cstat->cwnd = cstat->max_udp_payload_size; in bbr_modulate_cwnd_for_recovery()
1205 cstat->cwnd = in bbr_modulate_cwnd_for_recovery()
[all …]
Dngtcp2_cc.h364 uint64_t cwnd; member
Dngtcp2_conn.c812 cstat->cwnd = in conn_reset_conn_stat_cc()
1892 : conn->cstat.cwnd; in conn_get_cwnd()
1901 uint64_t cwnd = conn_get_cwnd(conn); in conn_cwnd_is_zero() local
1903 if (bytes_in_flight >= cwnd) { in conn_cwnd_is_zero()
1906 bytes_in_flight, cwnd); in conn_cwnd_is_zero()
1909 return bytes_in_flight >= cwnd; in conn_cwnd_is_zero()
11496 if (cstat->bytes_in_flight >= cstat->cwnd) { in conn_write_vmsg_wrapper()
11500 if (vmsg == NULL && cstat->bytes_in_flight < cstat->cwnd && in conn_write_vmsg_wrapper()
13187 uint64_t cwnd = conn_get_cwnd(conn); in ngtcp2_conn_get_cwnd_left() local
13189 if (cwnd > bytes_in_flight) { in ngtcp2_conn_get_cwnd_left()
[all …]
Dngtcp2_qlog.c1057 p = write_pair_number(p, "congestion_window", cstat->cwnd); in ngtcp2_qlog_metrics_updated()
/third_party/lwip/test/unit/tcp/
Dtest_tcp.c471 pcb->cwnd = pcb->snd_wnd; in START_TEST()
654 pcb->cwnd = 2*TCP_MSS; in START_TEST()
656 pcb->ssthresh = pcb->cwnd; in START_TEST()
744 pcb->cwnd = 2*TCP_MSS; in START_TEST()
774 pcb->cwnd = pcb->snd_wnd; in START_TEST()
826 pcb->cwnd = pcb->snd_wnd; in test_tcp_tx_full_window_lost()
973 pcb->cwnd = pcb->snd_wnd; in START_TEST()
1092 pcb->cwnd = 5*TCP_MSS; in START_TEST()
1125 EXPECT(pcb->cwnd == pcb->mss); in START_TEST()
1149 EXPECT(pcb->cwnd == (tcpwnd_size_t)(2 * pcb->mss)); in START_TEST()
[all …]
/third_party/lwip/src/core/
Dtcp_in.c907 pcb->cwnd = LWIP_TCP_CALC_INITIAL_CWND(pcb->mss);
910 pcb->cwnd, pcb->ssthresh));
995 pcb->cwnd = LWIP_TCP_CALC_INITIAL_CWND(pcb->mss);
998 pcb->cwnd, pcb->ssthresh));
1248 TCP_WND_INC(pcb->cwnd, pcb->mss);
1272 pcb->cwnd = pcb->ssthresh;
1292 if (pcb->cwnd < pcb->ssthresh) {
1298 TCP_WND_INC(pcb->cwnd, increase);
1299 … LWIP_DEBUGF(TCP_CWND_DEBUG, ("tcp_receive: slow start cwnd %"TCPWNDSIZE_F"\n", pcb->cwnd));
1303 if (pcb->bytes_acked >= pcb->cwnd) {
[all …]
Dtcp_out.c1275 wnd = LWIP_MIN(pcb->snd_wnd, pcb->cwnd); in tcp_output()
1285 pcb->snd_wnd, pcb->cwnd, wnd, pcb->lastack)); in tcp_output()
1298 pcb->snd_wnd, pcb->cwnd, wnd, in tcp_output()
1362 pcb->snd_wnd, pcb->cwnd, wnd, in tcp_output()
1810 pcb->ssthresh = LWIP_MIN(pcb->cwnd, pcb->snd_wnd) / 2; in tcp_rexmit_fast()
1821 pcb->cwnd = pcb->ssthresh + 3 * pcb->mss; in tcp_rexmit_fast()
Dtcp.c1339 pcb->cwnd = 1;
1474 eff_wnd = LWIP_MIN(pcb->cwnd, pcb->snd_wnd);
1479 pcb->cwnd = pcb->mss;
1482 pcb->cwnd, pcb->ssthresh));
2081 pcb->cwnd = 1;
/third_party/lwip/
D0046-add-dataack-when-recv-too-many-acks-with-data.patch62 /* Update the congestion control variables (cwnd and
D0056-fix-tso-small-packet-drop-in-kernel-server.patch308 …LWIP_DEBUGF(TCP_CWND_DEBUG, ("tcp_output: snd_wnd %"TCPWNDSIZE_F", cwnd %"TCPWNDSIZE_F", wnd %"U32…
309 pcb->snd_wnd, pcb->cwnd, wnd,
D0041-optimite-pcb-list-limit-send-size-and-ack-now.patch209 …LWIP_DEBUGF(TCP_CWND_DEBUG, ("tcp_output: snd_wnd %"TCPWNDSIZE_F", cwnd %"TCPWNDSIZE_F", wnd %"U32…
210 pcb->snd_wnd, pcb->cwnd, wnd,
Dlwip.spec349 - do not update cwnd when send dataack
DCHANGELOG2244 * tcp_in.c: fix BUG#27445: grow cwnd with every duplicate ACK
2500 * tcp_out.c: bug #24212: Deadlocked tcp_retransmit due to exceeded pcb->cwnd
/third_party/lwip/src/include/lwip/
Dtcp.h312 tcpwnd_size_t cwnd; member
/third_party/node/deps/ngtcp2/ngtcp2/lib/includes/ngtcp2/
Dngtcp2.h1618 uint64_t cwnd; member
/third_party/libbpf/.github/actions/build-selftests/
Dvmlinux.h12246 long unsigned int cwnd; member
53527 __u32 cwnd; member