aboutsummaryrefslogtreecommitdiffstats
path: root/contrib/libs/ngtcp2/lib/ngtcp2_rst.c
diff options
context:
space:
mode:
authorrobot-contrib <robot-contrib@yandex-team.com>2025-03-10 19:42:22 +0300
committerrobot-contrib <robot-contrib@yandex-team.com>2025-03-10 19:56:23 +0300
commitfc6cd7d48282fba73b60215b3fd31fc0a8825982 (patch)
treebcb36b06098e700fd726b6b19c89e6fae7d429e2 /contrib/libs/ngtcp2/lib/ngtcp2_rst.c
parent21c1cc59ef7d0910313ef39ca737c78380ef3ec3 (diff)
downloadydb-fc6cd7d48282fba73b60215b3fd31fc0a8825982.tar.gz
Update contrib/libs/ngtcp2 to 1.11.0
commit_hash:3beea54841aa142a4af33f802d5bdb7d6010b68d
Diffstat (limited to 'contrib/libs/ngtcp2/lib/ngtcp2_rst.c')
-rw-r--r--contrib/libs/ngtcp2/lib/ngtcp2_rst.c11
1 files changed, 10 insertions, 1 deletions
diff --git a/contrib/libs/ngtcp2/lib/ngtcp2_rst.c b/contrib/libs/ngtcp2/lib/ngtcp2_rst.c
index 89c89acdc2..181691f3e6 100644
--- a/contrib/libs/ngtcp2/lib/ngtcp2_rst.c
+++ b/contrib/libs/ngtcp2/lib/ngtcp2_rst.c
@@ -46,6 +46,11 @@ void ngtcp2_rs_init(ngtcp2_rs *rs) {
}
void ngtcp2_rst_init(ngtcp2_rst *rst) {
+ rst->last_seq = -1;
+ ngtcp2_rst_reset(rst);
+}
+
+void ngtcp2_rst_reset(ngtcp2_rst *rst) {
ngtcp2_rs_init(&rst->rs);
rst->delivered = 0;
rst->delivered_ts = 0;
@@ -53,7 +58,7 @@ void ngtcp2_rst_init(ngtcp2_rst *rst) {
rst->app_limited = 0;
rst->is_cwnd_limited = 0;
rst->lost = 0;
- rst->last_seq = -1;
+ rst->valid_after_seq = rst->last_seq;
}
void ngtcp2_rst_on_pkt_sent(ngtcp2_rst *rst, ngtcp2_rtb_entry *ent,
@@ -108,6 +113,10 @@ void ngtcp2_rst_update_rate_sample(ngtcp2_rst *rst, const ngtcp2_rtb_entry *ent,
ngtcp2_tstamp ts) {
ngtcp2_rs *rs = &rst->rs;
+ if (ent->rst.end_seq <= rst->valid_after_seq) {
+ return;
+ }
+
rst->delivered += ent->pktlen;
rst->delivered_ts = ts;