diff --git a/protocols/ping/src/lib.rs b/protocols/ping/src/lib.rs index 75aee971..81133b86 100644 --- a/protocols/ping/src/lib.rs +++ b/protocols/ping/src/lib.rs @@ -120,6 +120,14 @@ impl NetworkBehaviour for Behaviour { _: &mut impl PollParameters, ) -> Poll> { if let Some(e) = self.events.pop_back() { + let Event { result, peer } = &e; + + match result { + Ok(Success::Ping { .. }) => log::debug!("Ping sent to {:?}", peer), + Ok(Success::Pong) => log::debug!("Ping received from {:?}", peer), + _ => {} + } + Poll::Ready(NetworkBehaviourAction::GenerateEvent(e)) } else { Poll::Pending diff --git a/protocols/ping/src/protocol.rs b/protocols/ping/src/protocol.rs index 703a9275..ae60f67a 100644 --- a/protocols/ping/src/protocol.rs +++ b/protocols/ping/src/protocol.rs @@ -85,12 +85,10 @@ where S: AsyncRead + AsyncWrite + Unpin, { let payload: [u8; PING_SIZE] = thread_rng().sample(distributions::Standard); - log::debug!("Preparing ping payload {:?}", payload); stream.write_all(&payload).await?; stream.flush().await?; let started = Instant::now(); let mut recv_payload = [0u8; PING_SIZE]; - log::debug!("Awaiting pong for {:?}", payload); stream.read_exact(&mut recv_payload).await?; if recv_payload == payload { Ok((stream, started.elapsed())) @@ -108,9 +106,7 @@ where S: AsyncRead + AsyncWrite + Unpin, { let mut payload = [0u8; PING_SIZE]; - log::debug!("Waiting for ping ..."); stream.read_exact(&mut payload).await?; - log::debug!("Sending pong for {:?}", payload); stream.write_all(&payload).await?; stream.flush().await?; Ok(stream)