peer worker sleeps until deadline, not fixed time

1 files changed, 11 insertions, 0 deletions

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