From 77a7f89075c108ed056b2a981eebec667ccaf33e Mon Sep 17 00:00:00 2001 From: Alexey <247128645+axkurcom@users.noreply.github.com> Date: Fri, 22 May 2026 19:56:38 +0300 Subject: [PATCH] Reuse ME reader scratch buffer across read loop iterations --- src/transport/middle_proxy/reader.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/transport/middle_proxy/reader.rs b/src/transport/middle_proxy/reader.rs index adad859..15f6c71 100644 --- a/src/transport/middle_proxy/reader.rs +++ b/src/transport/middle_proxy/reader.rs @@ -242,6 +242,7 @@ pub(crate) async fn reader_loop( let mut raw = enc_leftover; let mut expected_seq: i32 = 0; let mut data_route_queue_full_streak = HashMap::::new(); + let mut tmp = [0u8; 65_536]; let mut fairness = WorkerFairnessState::new( WorkerFairnessConfig { worker_id: (writer_id as u16).saturating_add(1), @@ -263,7 +264,6 @@ pub(crate) async fn reader_loop( let fairshare_enabled = route_fairshare_enabled.load(Ordering::Relaxed); fairness.set_backpressure_enabled(backpressure_enabled); let fairness_has_backlog = should_schedule_fairness_retry(&fairness_snapshot); - let mut tmp = [0u8; 65_536]; let backlog_retry_enabled = fairness_has_backlog; let backlog_retry_delay = fairness_retry_delay(reader_route_data_wait_ms.load(Ordering::Relaxed));