From 7de822dd153aa5f197601e25e60c6ae562bea603 Mon Sep 17 00:00:00 2001 From: Alexey <247128645+axkurcom@users.noreply.github.com> Date: Wed, 25 Mar 2026 22:51:00 +0300 Subject: [PATCH] RPC Proxy-req fixes Co-Authored-By: brekotis <93345790+brekotis@users.noreply.github.com> --- src/transport/middle_proxy/pool_writer.rs | 3 +++ src/transport/middle_proxy/tests/pool_writer_security_tests.rs | 2 +- 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/src/transport/middle_proxy/pool_writer.rs b/src/transport/middle_proxy/pool_writer.rs index 0c31ecb..fae68b9 100644 --- a/src/transport/middle_proxy/pool_writer.rs +++ b/src/transport/middle_proxy/pool_writer.rs @@ -171,6 +171,9 @@ async fn rpc_proxy_req_signal_loop( rpc_proxy_req_every_secs: u64, ) { if rpc_proxy_req_every_secs == 0 { + // Disabled service signal loop must stay parked until writer cancellation. + // Returning immediately here would complete `select!` and tear down writer lifecycle. + cancel_signal.cancelled().await; return; } diff --git a/src/transport/middle_proxy/tests/pool_writer_security_tests.rs b/src/transport/middle_proxy/tests/pool_writer_security_tests.rs index d6ab8d6..e287624 100644 --- a/src/transport/middle_proxy/tests/pool_writer_security_tests.rs +++ b/src/transport/middle_proxy/tests/pool_writer_security_tests.rs @@ -35,7 +35,7 @@ async fn make_pool() -> Arc { NetworkDecision::default(), None, Arc::new(SecureRandom::new()), - Arc::new(Stats::default()), + Arc::new(Stats::new()), general.me_keepalive_enabled, general.me_keepalive_interval_secs, general.me_keepalive_jitter_secs,