diff options
Diffstat (limited to 'src/swarm/sync.rs')
| -rw-r--r-- | src/swarm/sync.rs | 9 |
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(); |