Struct solana_core::crds_gossip_pull::CrdsGossipPull

pub struct CrdsGossipPull {
    pub pull_request_time: HashMap<Pubkey, u64>,
    pub crds_timeout: u64,
    pub msg_timeout: u64,
    // some fields omitted
}

Fields

pull_request_time: HashMap<Pubkey, u64>

timestamp of last request

crds_timeout: u64

msg_timeout: u64

Methods

impl CrdsGossipPull

pub fn new_pull_request(
    &self,
    crds: &Crds,
    self_id: &Pubkey,
    now: u64,
    stakes: &HashMap<Pubkey, u64>,
    bloom_size: usize
) -> Result<(Pubkey, Vec<CrdsFilter>, CrdsValue), CrdsGossipError>

generate a random request

pub fn mark_pull_request_creation_time(&mut self, from: &Pubkey, now: u64)

time when a request to from was initiated This is used for weighted random selection during new_pull_request It's important to use the local nodes request creation time as the weight instead of the response received time otherwise failed nodes will increase their weight.

pub fn record_old_hash(&mut self, hash: Hash, timestamp: u64)

Store an old hash in the purged values set

pub fn process_pull_requests(
    &mut self,
    crds: &mut Crds,
    requests: Vec<(CrdsValue, CrdsFilter)>,
    now: u64
) -> Vec<Vec<CrdsValue>>

process a pull request and create a response

pub fn process_pull_response(
    &mut self,
    crds: &mut Crds,
    from: &Pubkey,
    timeouts: &HashMap<Pubkey, u64>,
    response: Vec<CrdsValue>,
    now: u64
) -> usize

process a pull response

pub fn build_crds_filters(
    &self,
    crds: &Crds,
    bloom_size: usize
) -> Vec<CrdsFilter>

pub fn make_timeouts_def(
    &self,
    self_id: &Pubkey,
    stakes: &HashMap<Pubkey, u64>,
    epoch_ms: u64,
    min_ts: u64
) -> HashMap<Pubkey, u64>

pub fn make_timeouts(
    &self,
    self_id: &Pubkey,
    stakes: &HashMap<Pubkey, u64>,
    epoch_ms: u64
) -> HashMap<Pubkey, u64>

pub fn purge_active(
    &mut self,
    crds: &mut Crds,
    now: u64,
    timeouts: &HashMap<Pubkey, u64>
) -> usize

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_purged(&mut self, min_ts: u64)

Purge values from the self.purged_values queue that are older then purge_timeout

Trait Implementations

impl Clone for CrdsGossipPull

fn clone(&self) -> CrdsGossipPull

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for CrdsGossipPull

fn default() -> Self

Returns the "default value" for a type.