record RTT from keepalive messages

1 files changed, 3 insertions, 8 deletions

diff --git a/src/swarm/relay.rs b/src/swarm/relay.rs
index a0fa6e1..454a46a 100644
--- a/src/swarm/relay.rs
+++ b/src/swarm/relay.rs
@@ -18,10 +18,10 @@ use tokio::time::Instant;
 use tracing::debug;
 
 use crate::state::{AppState, Standing};
-use crate::swarm::peer::local_keepalive;
+use crate::swarm::peer::send_ping;
 use crate::swarm::sync::SyncEvent;
 use crate::swarm::topology;
-use crate::transport::{self, HeadsSummary, ParsedMessage};
+use crate::transport::{self, HeadsSummary};
 
 /// A pull that brought nothing for this long no longer blocks pulling from another peer.
 const PULL_TIMEOUT: Duration = Duration::from_secs(15);
@@ -41,12 +41,7 @@ pub(crate) async fn announce(state: &AppState, from: &str) {
         .cloned()
         .collect();
     for peer in neighbours {
-        let keepalive = local_keepalive(state, &peer).await;
-        if let Err(error) = state
-            .transport
-            .send_message(&peer, &ParsedMessage::Ping(keepalive))
-            .await
-        {
+        if let Err(error) = send_ping(state, &peer).await {
             debug!(peer = %peer, error = %format!("{error:#}"), "Announcing our heads failed");
         }
     }