From e293047c25d7167f25af0a611b33545f12225b05 Mon Sep 17 00:00:00 2001
From: tv <tv@krebsco.de>
Date: Sun, 1 Nov 2026 20:36:17 +0100
Subject: peer worker sleeps until deadline, not fixed time

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

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

diff --git a/src/swarm/sync.rs b/src/swarm/sync.rs
index c643004..c8564c2 100644
--- a/src/swarm/sync.rs
+++ b/src/swarm/sync.rs
@@ -198,6 +198,17 @@ async fn deliver_sync_to_peer(state: &AppState, peer: &str) -> Result<()> {
         let Some(encoded) = generated else {
             return Ok(());
         };
+        // Its answer is due.
+        let reply_due = peer_state_mutex
+            .lock()
+            .await
+            .sync
+            .reply
+            .as_ref()
+            .map(|wait| wait.deadline);
+        if let Some(at) = reply_due {
+            state.peers_due.by(at);
+        }
 
         (session, encoded)
     };
-- 
cgit v1.3.1