diff --git a/src/proxy/middle_relay.rs b/src/proxy/middle_relay.rs
index 85c1844..5c91918 100644
--- a/src/proxy/middle_relay.rs
+++ b/src/proxy/middle_relay.rs
@@ -1199,9 +1199,13 @@ where
                 user = %user,
                 "Middle-relay pressure eviction for idle-candidate session"
             );
-            let _ =
-                enqueue_c2me_command(&c2me_tx, C2MeCommand::Close, c2me_send_timeout, stats.as_ref())
-                    .await;
+            let _ = enqueue_c2me_command(
+                &c2me_tx,
+                C2MeCommand::Close,
+                c2me_send_timeout,
+                stats.as_ref(),
+            )
+            .await;
             main_result = Err(ProxyError::Proxy(
                 "middle-relay session evicted under pressure (idle-candidate)".to_string(),
             ));
@@ -1220,9 +1224,13 @@ where
                 "Cutover affected middle session, closing client connection"
             );
             tokio::time::sleep(delay).await;
-            let _ =
-                enqueue_c2me_command(&c2me_tx, C2MeCommand::Close, c2me_send_timeout, stats.as_ref())
-                    .await;
+            let _ = enqueue_c2me_command(
+                &c2me_tx,
+                C2MeCommand::Close,
+                c2me_send_timeout,
+                stats.as_ref(),
+            )
+            .await;
             main_result = Err(ProxyError::Proxy(ROUTE_SWITCH_ERROR_MSG.to_string()));
             break;
         }
diff --git a/src/stats/mod.rs b/src/stats/mod.rs
index a87ec7e..6f3d3f8 100644
--- a/src/stats/mod.rs
+++ b/src/stats/mod.rs
@@ -1436,8 +1436,7 @@ impl Stats {
 
     pub fn increment_me_c2me_send_full_total(&self) {
         if self.telemetry_me_allows_normal() {
-            self.me_c2me_send_full_total
-                .fetch_add(1, Ordering::Relaxed);
+            self.me_c2me_send_full_total.fetch_add(1, Ordering::Relaxed);
         }
     }
 
@@ -1838,13 +1837,11 @@ impl Stats {
     }
 
     pub fn get_me_c2me_send_high_water_total(&self) -> u64 {
-        self.me_c2me_send_high_water_total
-            .load(Ordering::Relaxed)
+        self.me_c2me_send_high_water_total.load(Ordering::Relaxed)
     }
 
     pub fn get_me_c2me_send_timeout_total(&self) -> u64 {
-        self.me_c2me_send_timeout_total
-            .load(Ordering::Relaxed)
+        self.me_c2me_send_timeout_total.load(Ordering::Relaxed)
     }
     pub fn get_me_d2c_batch_timeout_armed_total(&self) -> u64 {
         self.me_d2c_batch_timeout_armed_total