fix

jito-foundation · May 18, 2024 · 7872d51 · 7872d51
1 parent 6e52c39
commit 7872d51
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/relayer/src/health_manager.rs b/relayer/src/health_manager.rs
@@ -51,7 +51,8 @@ impl HealthManager {
                                 *health_state.write().unwrap() = new_health_state;
                                 datapoint_info!(
                                     "relayer-health-state",
-                                    ("health_state", new_health_state, i64)
+                                    ("health_state", new_health_state, i64),
+                                    ("slot_receiver_len", slot_receiver.len(), i64),
                                 );
                             }
                             recv(slot_receiver) -> _maybe_slot => {

diff --git a/rpc/src/load_balancer.rs b/rpc/src/load_balancer.rs
@@ -55,7 +55,7 @@ impl LoadBalancer {
         }));
 
         let highest_slot = Arc::new(AtomicU64::default());
-        // sender tracked as health_manager-channel_stats.slot_sender_len
+        // size tracked as relayer-health-state.slot_receiver_len
         let (slot_sender, slot_receiver) = crossbeam_channel::bounded(Self::SLOT_QUEUE_CAPACITY);
         let subscription_threads = Self::start_subscription_threads(
             servers,