check for prior discard in shred_fetch_stage (#31293)

2023-04-21 11:43:10 -07:00 · 2023-04-21 11:43:10 -07:00 · 3cdd59e55f
parent 39b548153a
commit 3cdd59e55f
1 changed files with 1 additions and 1 deletions
--- 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,