pub(crate) fn purge_vertices(&mut self, oldest: Timestamp) {
        info!("purging synchronizer queues");
        let no_deps_expired = self.vertices_no_deps.remove_expired(oldest);
        trace!(?no_deps_expired, "expired no dependencies");
        self.requests_sent.clear();
        let to_be_added_later_expired =
            Self::remove_expired(&mut self.vertices_to_be_added_later, oldest);
        trace!(
            ?to_be_added_later_expired,
            "expired to be added later dependencies"
        );
        let awaiting_deps_expired = Self::remove_expired(&mut self.vertices_awaiting_deps, oldest);
        trace!(?awaiting_deps_expired, "expired awaiting dependencies");
    }
/// Removes expired pending vertices from the queues, and schedules the next purge.
Removes expired pending vertices from the queues, and schedules the next purge.
Removes expired pending vertices from the queues and schedules the next purge .
pub(crate) fn purge_vertices(&mut self, oldest: Timestamp) {
        info!("purging synchronizer queues");
        let no_deps_expired = self.vertices_no_deps.remove_expired(oldest);
        trace!(?no_deps_expired, "expired no dependencies");
        self.requests_sent.clear();
        let to_be_added_later_expired =
            Self::remove_expired(&mut self.vertices_to_be_added_later, oldest);
        trace!(
            ?to_be_added_later_expired,
            "expired to be added later dependencies"
        );
        let awaiting_deps_expired = Self::remove_expired(&mut self.vertices_awaiting_deps, oldest);
        trace!(?awaiting_deps_expired, "expired awaiting dependencies");
    }
pub ( crate ) fn purge_vertices ( & mut self , oldest : Timestamp ) { info ! ( " " ) ; let no_deps_expired = self . vertices_no_deps . remove_expired ( oldest ) ; trace ! ( no_deps_expired " " ) ; self . requests_sent . clear ( ) ; let to_be_added_later_expired = Self :: remove_expired ( & mut self . vertices_to_be_added_later , oldest ) ; trace ! ( to_be_added_later_expired " " ) ; let awaiting_deps_expired = Self :: remove_expired ( & mut self . vertices_awaiting_deps , oldest ) ; trace ! ( awaiting_deps_expired " " ) ; }
Removes expired pending vertices from the queues, and schedules the next purge.
Removes expired pending vertices from the queues and schedules the next purge .
&mut self
oldest
Timestamp
&mut self
oldest
Timestamp