filter old retransmit shreds (#5068)

anza-xyz · Feb 26, 2025 · ad43a7d · ad43a7d
1 parent 521aba4
commit ad43a7d
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/turbine/src/retransmit_stage.rs b/turbine/src/retransmit_stage.rs
@@ -319,7 +319,9 @@ fn retransmit_shred(
 )> {
     let key = shred::layout::get_shred_id(shred.as_ref())?;
     let (slot_leader, cluster_nodes) = cache.get(&key.slot())?;
-    if shred_deduper.dedup(key, shred.as_ref(), MAX_DUPLICATE_COUNT) {
+    if key.slot() < root_bank.slot()
+        || shred_deduper.dedup(key, shred.as_ref(), MAX_DUPLICATE_COUNT)
+    {
         stats.num_shreds_skipped.fetch_add(1, Ordering::Relaxed);
         return None;
     }