Struct solana::crds_gossip::CrdsGossip

pub struct CrdsGossip {
    pub crds: Crds,
    pub id: Pubkey,
    pub push: CrdsGossipPush,
    pub pull: CrdsGossipPull,
}

Fields

crds: Crds

id: Pubkey

push: CrdsGossipPush

pull: CrdsGossipPull

Methods

impl CrdsGossip

pub fn set_self(&mut self, id: &Pubkey)

pub fn process_push_message(
    &mut self,
    values: Vec<CrdsValue>,
    now: u64
) -> Vec<Pubkey>

process a push message to the network

pub fn new_push_messages(
    &mut self,
    now: u64
) -> (Pubkey, HashMap<Pubkey, Vec<CrdsValue>>)

pub fn process_prune_msg(
    &mut self,
    peer: &Pubkey,
    destination: &Pubkey,
    origin: &[Pubkey],
    wallclock: u64,
    now: u64
) -> Result<(), CrdsGossipError>

add the from to the peer's filter of nodes

pub fn refresh_push_active_set(&mut self, stakes: &HashMap<Pubkey, u64>)

refresh the push active set

• ratio - number of actives to rotate

pub fn new_pull_request(
    &self,
    now: u64,
    stakes: &HashMap<Pubkey, u64>
) -> Result<(Pubkey, Bloom<Hash>, 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 process_pull_request(
    &mut self,
    caller: CrdsValue,
    filter: Bloom<Hash>,
    now: u64
) -> Vec<CrdsValue>

process a pull request and create a response

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

process a pull response

pub fn purge(&mut self, now: u64)

Trait Implementations

impl Default for CrdsGossip

fn default() -> Self

Returns the "default value" for a type.

impl Clone for CrdsGossip

fn clone(&self) -> CrdsGossip

Returns a copy of the value.

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

Performs copy-assignment from source.