diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/test.rs | 38 |
1 files changed, 23 insertions, 15 deletions
diff --git a/src/test.rs b/src/test.rs index e4ec495..402e891 100644 --- a/src/test.rs +++ b/src/test.rs @@ -1,6 +1,6 @@ use std::net::SocketAddr; -use std::sync::{Arc}; -use std::time::{Duration}; +use std::sync::Arc; +use std::time::Duration; use tokio::select; use tokio::sync::watch; @@ -8,17 +8,16 @@ use tokio::sync::watch; use sodiumoxide::crypto::auth; use sodiumoxide::crypto::sign::ed25519; -use crate::peering::fullmesh::*; use crate::netapp::*; +use crate::peering::fullmesh::*; use crate::NodeID; - -#[tokio::test(flavor="current_thread")] +#[tokio::test(flavor = "current_thread")] async fn test_with_basic_scheduler() { run_test().await } -#[tokio::test(flavor="multi_thread", worker_threads=4)] +#[tokio::test(flavor = "multi_thread", worker_threads = 4)] async fn test_with_threaded_scheduler() { run_test().await } @@ -43,11 +42,19 @@ async fn run_test_inner() { let (stop_tx, stop_rx) = watch::channel(false); - let (thread1, _netapp1, peering1) = run_netapp(netid.clone(), pk1, sk1, addr1, vec![], stop_rx.clone()); + let (thread1, _netapp1, peering1) = + run_netapp(netid.clone(), pk1, sk1, addr1, vec![], stop_rx.clone()); tokio::time::sleep(Duration::from_secs(2)).await; // Connect second node and check it peers with everyone - let (thread2, _netapp2, peering2) = run_netapp(netid.clone(), pk2, sk2, addr2, vec![(pk1, addr1)], stop_rx.clone()); + let (thread2, _netapp2, peering2) = run_netapp( + netid.clone(), + pk2, + sk2, + addr2, + vec![(pk1, addr1)], + stop_rx.clone(), + ); tokio::time::sleep(Duration::from_secs(5)).await; let pl1 = peering1.get_peer_list(); @@ -59,7 +66,8 @@ async fn run_test_inner() { assert_eq!(pl2.len(), 2); // Connect third ndoe and check it peers with everyone - let (thread3, _netapp3, peering3) = run_netapp(netid, pk3, sk3, addr3, vec![(pk2, addr2)], stop_rx.clone()); + let (thread3, _netapp3, peering3) = + run_netapp(netid, pk3, sk3, addr3, vec![(pk2, addr2)], stop_rx.clone()); tokio::time::sleep(Duration::from_secs(5)).await; let pl1 = peering1.get_peer_list(); @@ -87,11 +95,12 @@ fn run_netapp( sk: ed25519::SecretKey, listen_addr: SocketAddr, bootstrap_peers: Vec<(NodeID, SocketAddr)>, - must_exit: watch::Receiver<bool>) - -> - (tokio::task::JoinHandle<()>, Arc<NetApp>, Arc<FullMeshPeeringStrategy>) -{ - + must_exit: watch::Receiver<bool>, +) -> ( + tokio::task::JoinHandle<()>, + Arc<NetApp>, + Arc<FullMeshPeeringStrategy>, +) { let netapp = NetApp::new(netid, sk); let peering = FullMeshPeeringStrategy::new(netapp.clone(), bootstrap_peers); @@ -106,4 +115,3 @@ fn run_netapp( (fut, netapp, peering) } - |