Method poll_ready

nodedb-crdt/src/deferred.rs:118–132

Poll for entries ready for retry. Returns all entries whose `next_retry_ms <= now_ms`.

(&mut self, now_ms: u64)

    ///
    /// Returns all entries whose `next_retry_ms <= now_ms`.
    pub fn poll_ready(&mut self, now_ms: u64) -> Vec<DeferredEntry> {
        let mut ready = Vec::new();

        while let Some(front) = self.entries.front() {
            if front.next_retry_ms <= now_ms
                && let Some(entry) = self.entries.pop_front()
            {
                ready.push(entry);
            } else {
                break;
            }
        }

        ready
    }

    /// Expire entries past their TTL deadline.
    ///