diff --git a/core/src/shred_fetch_stage.rs b/core/src/shred_fetch_stage.rs index 7fba33d15..95383f61e 100644 --- a/core/src/shred_fetch_stage.rs +++ b/core/src/shred_fetch_stage.rs @@ -88,7 +88,7 @@ impl ShredFetchStage { let should_drop_merkle_shreds = |shred_slot| should_drop_merkle_shreds(shred_slot, &root_bank); let turbine_disabled = turbine_disabled.load(Ordering::Relaxed); - for packet in packet_batch.iter_mut() { + for packet in packet_batch.iter_mut().filter(|p| !p.meta().discard()) { if turbine_disabled || should_discard_shred( packet,