suspend detected

1 files changed, 12 insertions, 0 deletions

diff --git a/src/state/peer.rs b/src/state/peer.rs
index e0cea7e..857c29d 100644
--- a/src/state/peer.rs
+++ b/src/state/peer.rs
@@ -370,6 +370,18 @@ impl PeerState {
             .map(|(bytes, _)| bytes)
     }
 
+    /// The machine slept for `gap` (`swarm::suspend`): heard from, added, and awaiting
+    /// an answer that much earlier, as the monotonic clock stood still meanwhile.
+    pub(crate) fn aged(&mut self, gap: Duration) {
+        let earlier = |at: Instant| at.checked_sub(gap).unwrap_or(at);
+        self.last_seen = self.last_seen.map(earlier);
+        self.added_at = earlier(self.added_at);
+        if let Some(awaiting) = &mut self.awaiting_answer {
+            awaiting.ask_again_at = awaiting.ask_again_at.map(earlier);
+            awaiting.unreached_at = earlier(awaiting.unreached_at);
+        }
+    }
+
     fn quiet_for(&self, now: Instant) -> Duration {
         now.saturating_duration_since(self.last_seen.unwrap_or(self.added_at))
     }