gaspersic/solana
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

fix bank-benching test

Browse Source
This commit is contained in:
Tao Zhu
2021-12-24 16:38:09 -06:00
committed by Tao Zhu
parent 3d6ab96587
commit f8c97a3d1f
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
banking-bench/src/main.rs
View File

@@ -226,6 +226,7 @@ fn main() {
SocketAddrSpace::Unspecified, SocketAddrSpace::Unspecified,
); );
let cluster_info = Arc::new(cluster_info); let cluster_info = Arc::new(cluster_info);
let packet_deduper = PacketDeduper::default();
let banking_stage = BankingStage::new( let banking_stage = BankingStage::new(
&cluster_info, &cluster_info,
&poh_recorder, &poh_recorder,
@@ -235,7 +236,7 @@ fn main() {
None, None,
replay_vote_sender, replay_vote_sender,
Arc::new(RwLock::new(CostModel::default())), Arc::new(RwLock::new(CostModel::default())),
PacketDeduper::default(), packet_deduper.clone(),
); );
poh_recorder.lock().unwrap().set_bank(&bank); poh_recorder.lock().unwrap().set_bank(&bank);
@@ -350,6 +351,7 @@ fn main() {
// in this chunk, but since we rotate between CHUNKS then // in this chunk, but since we rotate between CHUNKS then
// we should clear them by the time we come around again to re-use that chunk. // we should clear them by the time we come around again to re-use that chunk.
bank.clear_signatures(); bank.clear_signatures();
packet_deduper.reset();
total_us += duration_as_us(&now.elapsed()); total_us += duration_as_us(&now.elapsed());
debug!( debug!(
"time: {} us checked: {} sent: {}", "time: {} us checked: {} sent: {}",