pub fn process_pull_request(
        &mut self,
        crds: &mut Crds,
        caller: CrdsValue,
        mut filter: Bloom<Hash>,
        now: u64,
    ) -> Vec<CrdsValue> {
        let rv = self.filter_crds_values(crds, &mut filter);
        let key = caller.label().pubkey();
        let old = crds.insert(caller, now);
        if let Some(val) = old.ok().and_then(|opt| opt) {
            self.purged_values
                .push_back((val.value_hash, val.local_timestamp))
        }
        crds.update_record_timestamp(&key, now);
        rv
    }
/// process a pull request and create a response
process a pull request and create a response
process a pull request and create a response
pub fn process_pull_request(
        &mut self,
        crds: &mut Crds,
        caller: CrdsValue,
        mut filter: Bloom<Hash>,
        now: u64,
    ) -> Vec<CrdsValue> {
        let rv = self.filter_crds_values(crds, &mut filter);
        let key = caller.label().pubkey();
        let old = crds.insert(caller, now);
        if let Some(val) = old.ok().and_then(|opt| opt) {
            self.purged_values
                .push_back((val.value_hash, val.local_timestamp))
        }
        crds.update_record_timestamp(&key, now);
        rv
    }
pub fn process_pull_request ( & mut self , crds : & mut Crds , caller : CrdsValue , mut filter : Bloom < Hash > , now : u64 , ) -> Vec < CrdsValue > { let rv = self . filter_crds_values ( crds , & mut filter ) ; let key = caller . label ( ) . pubkey ( ) ; let old = crds . insert ( caller , now ) ; if let Some ( val ) = old . ok ( ) . and_then ( | opt | opt ) { self . purged_values . push_back ( ( val . value_hash , val . local_timestamp ) ) } crds . update_record_timestamp ( & key , now ) ; rv }
process a pull request and create a response
process a pull request and create a response
&mut self
crds
&mut Crds
caller
CrdsValue
filter
Bloom<Hash>
now
u64
&mut self
crds
&mut Crds
caller
CrdsValue
filter
Bloom<Hash>
now
u64