Skip to content

Commit

Permalink
Backport Jito Patch (#408)
Browse files Browse the repository at this point in the history
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)
  • Loading branch information
buffalu committed May 1, 2024
1 parent 9beddd4 commit 3ecfa52
Showing 1 changed file with 18 additions and 18 deletions.
36 changes: 18 additions & 18 deletions core/src/banking_stage.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down Expand Up @@ -1250,7 +1250,7 @@ mod tests {
20,
start_hash,
))
.unwrap();
.unwrap();
}

// Send a bunch of votes and transfers
Expand Down Expand Up @@ -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);
Expand Down

0 comments on commit 3ecfa52

Please sign in to comment.