Skip to content
This repository was archived by the owner on Jan 22, 2025. It is now read-only.

Commit 74dd570

Browse files
committed
pr comments and hotswap logic
1 parent d51b326 commit 74dd570

6 files changed

+148
-70
lines changed

core/benches/banking_stage.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -9,12 +9,11 @@ use {
99
rand::{thread_rng, Rng},
1010
rayon::prelude::*,
1111
solana_core::{
12-
banking_stage::{
13-
BankingStage, BankingStageStats, ThreadType, UnprocessedTransactionStorage,
14-
},
12+
banking_stage::{BankingStage, BankingStageStats},
1513
leader_slot_banking_stage_metrics::LeaderSlotMetricsTracker,
1614
qos_service::QosService,
1715
unprocessed_packet_batches::*,
16+
unprocessed_transaction_storage::{ThreadType, UnprocessedTransactionStorage},
1817
},
1918
solana_entry::entry::{next_hash, Entry},
2019
solana_gossip::cluster_info::{ClusterInfo, Node},
@@ -82,9 +81,10 @@ fn bench_consume_buffered(bencher: &mut Bencher) {
8281
let transactions = vec![tx; 4194304];
8382
let batches = transactions_to_deserialized_packets(&transactions).unwrap();
8483
let batches_len = batches.len();
85-
let mut transaction_buffer = UnprocessedTransactionStorage::TransactionStorage(
84+
let mut transaction_buffer = UnprocessedTransactionStorage::new_transaction_storage(
8685
UnprocessedPacketBatches::from_iter(batches.into_iter(), 2 * batches_len),
8786
ThreadType::Transactions,
87+
None,
8888
);
8989
let (s, _r) = unbounded();
9090
// This tests the performance of buffering packets.

0 commit comments

Comments
 (0)