From b2c83cfe1385612a702f15038af6ee127e17be24 Mon Sep 17 00:00:00 2001 From: buffalu <85544055+buffalu@users.noreply.github.com> Date: Wed, 11 Oct 2023 09:40:45 -0500 Subject: [PATCH] Backport Jito Patch (#408) Backport clone derivation (416) (#418) backports #430: update jito-programs (#432) Backport #446 to v1.17 (#448) [JIT-1661] Faster Autosnapshot (#445) v1.17: Backport #449 (#451) backports #419: add upsert to accountoverrides (#421) backport 428 runtime-plugin (#458) [JIT-1713] Fix bundle's blockspace preallocation (Backport to 1.17) (#499) Backport #500 to v1.17 (#507) Backport #520: add priority fees to mev claim (#525) Faster MEV tip claiming (v1.17) (#568) Backport Release Fixes (#586) --- core/src/banking_stage.rs | 36 ++++++++++++++++++------------------ 1 file changed, 18 insertions(+), 18 deletions(-) diff --git a/core/src/banking_stage.rs b/core/src/banking_stage.rs index 622c5cfdee..48c6bcd043 100644 --- a/core/src/banking_stage.rs +++ b/core/src/banking_stage.rs @@ -122,19 +122,19 @@ impl BankingStageStats { .load(Ordering::Relaxed) as u64 + self.dropped_packets_count.load(Ordering::Relaxed) as u64 + self - .dropped_duplicated_packets_count - .load(Ordering::Relaxed) as u64 + .dropped_duplicated_packets_count + .load(Ordering::Relaxed) as u64 + self.dropped_forward_packets_count.load(Ordering::Relaxed) as u64 + self.newly_buffered_packets_count.load(Ordering::Relaxed) as u64 + self.current_buffered_packets_count.load(Ordering::Relaxed) as u64 + self.rebuffered_packets_count.load(Ordering::Relaxed) as u64 + self.consumed_buffered_packets_count.load(Ordering::Relaxed) as u64 + self - .consume_buffered_packets_elapsed - .load(Ordering::Relaxed) + .consume_buffered_packets_elapsed + .load(Ordering::Relaxed) + self - .receive_and_buffer_packets_elapsed - .load(Ordering::Relaxed) + .receive_and_buffer_packets_elapsed + .load(Ordering::Relaxed) + self.filter_pending_packets_elapsed.load(Ordering::Relaxed) + self.packet_conversion_elapsed.load(Ordering::Relaxed) + self.transaction_processing_elapsed.load(Ordering::Relaxed) @@ -1250,7 +1250,7 @@ mod tests { 20, start_hash, )) - .unwrap(); + .unwrap(); } // Send a bunch of votes and transfers @@ -1309,17 +1309,17 @@ mod tests { (tpu_packet_batches, tpu_vote_sender), (gossip_packet_batches, gossip_vote_sender), ] - .into_iter() - .map(|(packet_batches, sender)| { - Builder::new() - .spawn(move || { - sender - .send(BankingPacketBatch::new((packet_batches, None))) - .unwrap() - }) - .unwrap() - }) - .for_each(|handle| handle.join().unwrap()); + .into_iter() + .map(|(packet_batches, sender)| { + Builder::new() + .spawn(move || { + sender + .send(BankingPacketBatch::new((packet_batches, None))) + .unwrap() + }) + .unwrap() + }) + .for_each(|handle| handle.join().unwrap()); banking_stage.join().unwrap(); exit.store(true, Ordering::Relaxed);