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

fmt

Browse Source
This commit is contained in:
Anatoly Yakovenko
2018-08-26 22:25:15 -07:00
committed by Grimes
parent 61492fd27e
commit e5408368f7
1 changed files with 11 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
src/bin/bench-tps.rs
View File

@ -284,7 +284,9 @@ fn airdrop_tokens(client: &mut ThinClient, leader: &NodeInfo, id: &Keypair, tx_c
let airdrop_amount = tx_count - starting_balance;
println!(
"Airdropping {:?} tokens from {} for {}",
airdrop_amount, drone_addr, id.pubkey(),
airdrop_amount,
drone_addr,
id.pubkey(),
);
request_airdrop(&drone_addr, &id.pubkey(), airdrop_amount as u64).unwrap();
@ -304,7 +306,12 @@ fn airdrop_tokens(client: &mut ThinClient, leader: &NodeInfo, id: &Keypair, tx_c
}
metrics_submit_token_balance(current_balance);
if current_balance - starting_balance != airdrop_amount {
println!("Airdrop failed! {} {} {}", id.pubkey(), current_balance, starting_balance);
println!(
"Airdrop failed! {} {} {}",
id.pubkey(),
current_balance,
starting_balance
);
exit(1);
}
}
@ -681,9 +688,7 @@ fn converge(
let mut v: Vec<NodeInfo> = vec![];
//wait for the network to converge, 30 seconds should be plenty
for _ in 0..30 {
if spy_ref
.read()
.unwrap().leader_data().is_none() {
if spy_ref.read().unwrap().leader_data().is_none() {
continue;
}
@ -710,7 +715,7 @@ fn converge(
}
threads.extend(ncp.thread_hdls().into_iter());
let leader = spy_ref.read().unwrap().leader_data().cloned();
(v,leader)
(v, leader)
}
fn read_leader(path: &str) -> Config {