pub fn purge_active(&mut self, crds: &mut Crds, self_id: &Pubkey, min_ts: u64) {
        let old = crds.find_old_labels(min_ts);
        let mut purged: VecDeque<_> = old
            .iter()
            .filter(|label| label.pubkey() != *self_id)
            .filter_map(|label| {
                let rv = crds
                    .lookup_versioned(label)
                    .map(|val| (val.value_hash, val.local_timestamp));
                crds.remove(label);
                rv
            })
            .collect();
        self.purged_values.append(&mut purged);
    }
/// Purge values from the crds that are older then `active_timeout`
/// The value_hash of an active item is put into self.purged_values queue
Purge values from the crds that are older then `active_timeout`
The value_hash of an active item is put into self.purged_values queue
Purge values from the crds that are older then ` active_timeout ` The value_hash of an active item is put into self . purged_values queue
pub fn purge_active(&mut self, crds: &mut Crds, self_id: &Pubkey, min_ts: u64) {
        let old = crds.find_old_labels(min_ts);
        let mut purged: VecDeque<_> = old
            .iter()
            .filter(|label| label.pubkey() != *self_id)
            .filter_map(|label| {
                let rv = crds
                    .lookup_versioned(label)
                    .map(|val| (val.value_hash, val.local_timestamp));
                crds.remove(label);
                rv
            })
            .collect();
        self.purged_values.append(&mut purged);
    }
pub fn purge_active ( & mut self , crds : & mut Crds , self_id : & Pubkey , min_ts : u64 ) { let old = crds . find_old_labels ( min_ts ) ; let mut purged : VecDeque < _ > = old . iter ( ) . filter ( | label | label . pubkey ( ) != * self_id ) . filter_map ( | label | { let rv = crds . lookup_versioned ( label ) . map ( | val | ( val . value_hash , val . local_timestamp ) ) ; crds . remove ( label ) ; rv } ) . collect ( ) ; self . purged_values . append ( & mut purged ) ; }
Purge values from the crds that are older then `active_timeout`
The value_hash of an active item is put into self.purged_values queue
Purge values from the crds that are older then ` active_timeout ` The value_hash of an active item is put into self . purged_values queue
&mut self
crds
&mut Crds
self_id
&Pubkey
min_ts
u64
&mut self
crds
&mut Crds
self_id
&Pubkey
min_ts
u64