processed slots should be always increasing

blockworks-foundation · May 30, 2024 · 5dd6515 · 5dd6515
1 parent d10910e
commit 5dd6515
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/cluster-endpoints/src/grpc_multiplex.rs b/cluster-endpoints/src/grpc_multiplex.rs
@@ -498,12 +498,18 @@ pub fn create_grpc_multiplex_processed_slots_subscription(
                 })
                 .collect_vec();
 
+            let mut last_slot = 0;
             'recv_loop: loop {
                 let next = tokio::time::timeout(Duration::from_secs(30), slots_rx.recv()).await;
                 match next {
                     Ok(Some(Message::GeyserSubscribeUpdate(slot_update))) => {
                         let mapfilter = map_slot_from_yellowstone_update(*slot_update);
                         if let Some(slot) = mapfilter {
+                            if last_slot > slot {
+                                continue;
+                            }
+                            last_slot = slot;
+
                             let _span = debug_span!("grpc_multiplex_processed_slots_stream", ?slot)
                                 .entered();
                             let send_started_at = Instant::now();

diff --git a/services/src/tpu_utils/tpu_service.rs b/services/src/tpu_utils/tpu_service.rs
@@ -28,9 +28,6 @@ lazy_static::lazy_static! {
     static ref NB_OF_LEADERS_IN_SCHEDULE: GenericGauge<prometheus::core::AtomicI64> =
     register_int_gauge!(opts!("literpc_cached_leader", "Number of leaders in schedule cache")).unwrap();
 
-    static ref CURRENT_SLOT: GenericGauge<prometheus::core::AtomicI64> =
-    register_int_gauge!(opts!("literpc_current_slot", "Current slot seen by last rpc")).unwrap();
-
     static ref ESTIMATED_SLOT: GenericGauge<prometheus::core::AtomicI64> =
     register_int_gauge!(opts!("literpc_estimated_slot", "Estimated slot seen by last rpc")).unwrap();
 }