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

More stats in dynamic multinode test

Browse Source
This commit is contained in:
Stephen Akridge
2018-07-27 18:38:49 +00:00
committed by sakridge
parent 50e1e0ae47
commit 7f4844f426
1 changed files with 21 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
tests/multinode.rs
View File

@ -15,6 +15,7 @@ use solana::service::Service;
use solana::signature::{KeyPair, KeyPairUtil, PublicKey}; use solana::signature::{KeyPair, KeyPairUtil, PublicKey};
use solana::streamer::default_window; use solana::streamer::default_window;
use solana::thin_client::ThinClient; use solana::thin_client::ThinClient;
use solana::timing::duration_as_s;
use std::env; use std::env;
use std::fs::File; use std::fs::File;
use std::net::UdpSocket; use std::net::UdpSocket;
@ -22,7 +23,7 @@ use std::sync::atomic::AtomicBool;
use std::sync::{Arc, RwLock}; use std::sync::{Arc, RwLock};
use std::thread::sleep; use std::thread::sleep;
use std::thread::Builder; use std::thread::Builder;
use std::time::Duration; use std::time::{Duration, Instant};
fn converge(leader: &NodeInfo, num_nodes: usize) -> Vec<NodeInfo> { fn converge(leader: &NodeInfo, num_nodes: usize) -> Vec<NodeInfo> {
//lets spy on the network //lets spy on the network
@ -466,7 +467,9 @@ fn test_multi_node_dynamic_network() {
let validators: Vec<_> = t2.into_iter().map(|t| t.join().unwrap()).collect(); let validators: Vec<_> = t2.into_iter().map(|t| t.join().unwrap()).collect();
let now = Instant::now();
let mut consecutive_success = 0; let mut consecutive_success = 0;
let mut failures = 0;
for i in 0..num_nodes { for i in 0..num_nodes {
//verify leader can do transfer //verify leader can do transfer
let expected = ((i + 3) * 500) as i64; let expected = ((i + 3) * 500) as i64;
@ -485,7 +488,8 @@ fn test_multi_node_dynamic_network() {
//verify all validators have the same balance //verify all validators have the same balance
{ {
let mut success = 0usize; let mut success = 0usize;
let mut distance = 0i64; let mut max_distance = 0i64;
let mut total_distance = 0i64;
for server in validators.iter() { for server in validators.iter() {
let mut client = mk_client(&server.0); let mut client = mk_client(&server.0);
trace!("{:x} {} get_balance start", server.0.debug_id(), i); trace!("{:x} {} get_balance start", server.0.debug_id(), i);
@ -498,7 +502,11 @@ fn test_multi_node_dynamic_network() {
leader_balance leader_balance
); );
let bal = getbal.unwrap_or(0); let bal = getbal.unwrap_or(0);
distance += (leader_balance - bal) / 500; let distance = (leader_balance - bal) / 500;
if distance > max_distance {
max_distance = distance;
}
total_distance += distance;
if let Some(bal) = getbal { if let Some(bal) = getbal {
if bal == leader_balance { if bal == leader_balance {
success += 1; success += 1;
@ -506,16 +514,18 @@ fn test_multi_node_dynamic_network() {
} }
} }
info!( info!(
"SUCCESS[{}] {} out of {} distance: {}", "SUCCESS[{}] {} out of {} distance: {} max_distance: {}",
i, i,
success, success,
validators.len(), validators.len(),
distance total_distance,
max_distance
); );
if success == validators.len() && distance == 0 { if success == validators.len() && total_distance == 0 {
consecutive_success += 1; consecutive_success += 1;
} else { } else {
consecutive_success = 0; consecutive_success = 0;
failures += 1;
} }
if consecutive_success == 10 { if consecutive_success == 10 {
break; break;
@ -523,6 +533,11 @@ fn test_multi_node_dynamic_network() {
} }
} }
assert_eq!(consecutive_success, 10); assert_eq!(consecutive_success, 10);
info!(
"Took {} s to converge total failures: {}",
duration_as_s(&now.elapsed()),
failures
);
for (_, node) in &validators { for (_, node) in &validators {
node.exit(); node.exit();
} }