From 6b046a5c18d670c3097b8563c191a2dc06ce1179 Mon Sep 17 00:00:00 2001
From: tv <tv@krebsco.de>
Date: Sat, 24 Oct 2026 04:50:16 +0200
Subject: record RTT from keepalive messages

---
 src/swarm/relay.rs | 11 +++--------
 1 file changed, 3 insertions(+), 8 deletions(-)

(limited to 'src/swarm/relay.rs')

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");
         }
     }
-- 
cgit v1.3.1