diff --git a/packages/ciphernode/net/src/bin/p2p_test.rs b/packages/ciphernode/net/src/bin/p2p_test.rs index be597c45..27aea85b 100644 --- a/packages/ciphernode/net/src/bin/p2p_test.rs +++ b/packages/ciphernode/net/src/bin/p2p_test.rs @@ -93,14 +93,14 @@ async fn main() -> Result<()> { .into_iter() .filter(|n| *n != name) .collect(); + println!("{} waiting for messages from: {:?}", name, expected); // Then wait to receive from others with a timeout let mut received = HashSet::new(); let receive_result = timeout(Duration::from_secs(10), async { - let history = net_bus.send(GetHistory::::new()).await?; - println!("{} history: {:?}", name, history); while received != expected { + let history = net_bus.send(GetHistory::::new()).await?; for event in history.clone() { match event { NetworkPeerEvent::GossipData(msg) => { @@ -114,6 +114,7 @@ async fn main() -> Result<()> { _ => (), } } + tokio::time::sleep(Duration::from_secs(1)).await; } Ok::<(), anyhow::Error>(()) }) diff --git a/packages/ciphernode/net/src/network_peer.rs b/packages/ciphernode/net/src/network_peer.rs index 314cda24..e7f3ce40 100644 --- a/packages/ciphernode/net/src/network_peer.rs +++ b/packages/ciphernode/net/src/network_peer.rs @@ -92,7 +92,6 @@ impl NetworkPeer { } } NetworkPeerCommand::Dial(multi) => { - info!("DIAL: {:?}", multi); let connection_id = multi.connection_id(); match self.swarm.dial(multi) { Ok(v) => {