From f331f1d1e993b894a3e9a4db0abdad7ffd33ce98 Mon Sep 17 00:00:00 2001 From: Pankaj Garg Date: Wed, 2 Oct 2019 14:07:34 -0700 Subject: [PATCH] Don't forward transaction to self (#6218) --- core/src/banking_stage.rs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/core/src/banking_stage.rs b/core/src/banking_stage.rs index aa03ff3462..0c62b2e7c0 100644 --- a/core/src/banking_stage.rs +++ b/core/src/banking_stage.rs @@ -278,10 +278,10 @@ impl BankingStage { enable_forwarding: bool, batch_limit: usize, ) -> Result<()> { - let (poh_next_slot_leader, poh_has_bank, would_be_leader) = { + let (leader_at_slot_offset, poh_has_bank, would_be_leader) = { let poh = poh_recorder.lock().unwrap(); ( - poh.next_slot_leader(), + poh.leader_after_slots(FORWARD_TRANSACTIONS_TO_LEADER_AT_SLOT_OFFSET), poh.has_bank(), poh.would_be_leader( (FORWARD_TRANSACTIONS_TO_LEADER_AT_SLOT_OFFSET - 1) * DEFAULT_TICKS_PER_SLOT, @@ -291,7 +291,7 @@ impl BankingStage { let decision = Self::consume_or_forward_packets( my_pubkey, - poh_next_slot_leader, + leader_at_slot_offset, poh_has_bank, would_be_leader, );