From b6a30c1b51da55568e999ac49e8983d5f6839583 Mon Sep 17 00:00:00 2001 From: miniusercoder Date: Tue, 7 Apr 2026 13:52:35 +0300 Subject: [PATCH] refactor: cargo fmt fixes --- src/transport/middle_proxy/health.rs | 6 +++--- src/transport/middle_proxy/pool.rs | 3 ++- 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/src/transport/middle_proxy/health.rs b/src/transport/middle_proxy/health.rs index e56d001..000bca0 100644 --- a/src/transport/middle_proxy/health.rs +++ b/src/transport/middle_proxy/health.rs @@ -383,8 +383,7 @@ async fn check_family( let reconnect_budget = health_reconnect_budget(pool, dc_endpoints.len()); let reconnect_sem = Arc::new(Semaphore::new(reconnect_budget)); - if pool.floor_mode() == MeFloorMode::Static { - } + if pool.floor_mode() == MeFloorMode::Static {} let mut live_addr_counts = HashMap::<(i32, SocketAddr), usize>::new(); let mut live_writer_ids_by_addr = HashMap::<(i32, SocketAddr), Vec>::new(); @@ -617,7 +616,8 @@ async fn check_family( continue; } - let base_req = pool_for_reconnect.required_writers_for_dc_with_floor_mode(endpoints_for_dc.len(), false); + let base_req = pool_for_reconnect + .required_writers_for_dc_with_floor_mode(endpoints_for_dc.len(), false); if alive + restored >= base_req { pool_for_reconnect .stats diff --git a/src/transport/middle_proxy/pool.rs b/src/transport/middle_proxy/pool.rs index 315b6fc..b89a844 100644 --- a/src/transport/middle_proxy/pool.rs +++ b/src/transport/middle_proxy/pool.rs @@ -1670,7 +1670,8 @@ impl MePool { } if endpoints_len > 0 { - let base_req = self.required_writers_for_dc_with_floor_mode(endpoints_len, false); + let base_req = + self.required_writers_for_dc_with_floor_mode(endpoints_len, false); let active_for_dc = { let ws = self.writers.read().await; ws.iter()