v2.1: Update metrics & ema before breaking the connection loop (backp…

…ort of #4414) (#4450) Update metrics & ema before breaking the connection loop (#4414) * Update metrics and ema before breaking connection loop (cherry picked from commit 83919b8) Co-authored-by: Lijun Wang <[email protected]>
anza-xyz · Jan 15, 2025 · 0f3bdc8 · 0f3bdc8
1 parent fdb6acc
commit 0f3bdc8
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/streamer/src/nonblocking/quic.rs b/streamer/src/nonblocking/quic.rs
@@ -1178,6 +1178,8 @@ async fn handle_connection(
                         CONNECTION_CLOSE_CODE_INVALID_STREAM.into(),
                         CONNECTION_CLOSE_REASON_INVALID_STREAM,
                     );
+                    stats.total_streams.fetch_sub(1, Ordering::Relaxed);
+                    stream_load_ema.update_ema_if_needed();
                     break 'conn;
                 }
             }