throughput from delivered message

1 files changed, 9 insertions, 0 deletions

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();