blockworks-foundation
/
solana-with-rpc-optimizations
mirror of https://github.com/blockworks-foundation/solana-with-rpc-optimizations.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add expect to get better errors on crash (#4327)

This commit is contained in:
sakridge 2019-05-17 12:49:41 -07:00 committed by GitHub
parent b114bc3674
commit 035a364122
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
bench-tps/src/bench.rs
View File

@ -282,7 +282,7 @@ fn do_tx_transfers<T: Client>(
} }
let txs; let txs;
{ {
let mut shared_txs_wl = shared_txs.write().unwrap(); let mut shared_txs_wl = shared_txs.write().expect("write lock in do_tx_transfers");
txs = shared_txs_wl.pop_front(); txs = shared_txs_wl.pop_front();
} }
if let Some(txs0) = txs { if let Some(txs0) = txs {
@ -299,7 +299,9 @@ fn do_tx_transfers<T: Client>(
if now > tx.1 && now - tx.1 > 1000 * 30 { if now > tx.1 && now - tx.1 > 1000 * 30 {
continue; continue;
} }
client.async_send_transaction(tx.0).unwrap(); client
.async_send_transaction(tx.0)
.expect("async_send_transaction in do_tx_transfers");
} }
shared_tx_thread_count.fetch_add(-1, Ordering::Relaxed); shared_tx_thread_count.fetch_add(-1, Ordering::Relaxed);
total_tx_sent_count.fetch_add(tx_len, Ordering::Relaxed); total_tx_sent_count.fetch_add(tx_len, Ordering::Relaxed);