From f137a43b44684959a5e1de1f1e54566d8995926f Mon Sep 17 00:00:00 2001
From: tv <tv@krebsco.de>
Date: Wed, 4 Nov 2026 22:15:34 +0100
Subject: throughput from delivered message

---
 src/swarm/sync.rs | 9 +++++++++
 1 file changed, 9 insertions(+)

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

diff --git a/src/swarm/sync.rs b/src/swarm/sync.rs
index a9d98b0..de2d86d 100644
--- a/src/swarm/sync.rs
+++ b/src/swarm/sync.rs
@@ -440,6 +440,15 @@ pub(crate) async fn handle_sync(
                 throughput
                     .lock_or_recover()
                     .exchange(&peer, wait.started, arrived, rtt);
+            } else if let Some(delay_ms) = hop_delay.filter(|ms| *ms > 0) {
+                // Nothing awaited: as long as it took to come.
+                throughput.lock_or_recover().message(
+                    &peer,
+                    payload_len as u64,
+                    std::time::Duration::from_millis(delay_ms as u64),
+                    arrived.0,
+                    rtt,
+                );
             }
             peer_state.sync.reply_settled();
 
-- 
cgit v1.3.1