Struct solana_gossip::crds_gossip::CrdsGossip

pub struct CrdsGossip {
    pub crds: RwLock<Crds>,
    pub push: CrdsGossipPush,
    pub pull: CrdsGossipPull,
}

Fields

crds: RwLock<Crds>

push: CrdsGossipPush

pull: CrdsGossipPull

Implementations

impl CrdsGossip

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

Process a push message to the network.

Returns unique origins’ pubkeys of upserted values.

pub fn prune_received_cache<I>(
    &self,
    self_pubkey: &Pubkey,
    origins: I,
    stakes: &HashMap<Pubkey, u64>
) -> HashMap<Pubkey, Vec<Pubkey>>where
    I: IntoIterator<Item = Pubkey>,

Remove redundant paths in the network.

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

pub fn process_prune_msg(
    &self,
    self_pubkey: &Pubkey,
    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(
    &self,
    self_keypair: &Keypair,
    self_shred_version: u16,
    stakes: &HashMap<Pubkey, u64>,
    gossip_validators: Option<&HashSet<Pubkey>>,
    ping_cache: &Mutex<PingCache>,
    pings: &mut Vec<(SocketAddr, Ping<[u8; 32]>)>,
    socket_addr_space: &SocketAddrSpace
)

Refresh the push active set.

pub fn new_pull_request(
    &self,
    thread_pool: &ThreadPool,
    self_keypair: &Keypair,
    self_shred_version: u16,
    now: u64,
    gossip_validators: Option<&HashSet<Pubkey>>,
    stakes: &HashMap<Pubkey, u64>,
    bloom_size: usize,
    ping_cache: &Mutex<PingCache>,
    pings: &mut Vec<(SocketAddr, Ping<[u8; 32]>)>,
    socket_addr_space: &SocketAddrSpace
) -> Result<HashMap<ContactInfo, Vec<CrdsFilter>>, CrdsGossipError>

Generate a random request.

pub fn mark_pull_request_creation_time(&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_requests<I>(&self, callers: I, now: u64)where
    I: IntoIterator<Item = CrdsValue>,

Process a pull request and create a response.

pub fn generate_pull_responses(
    &self,
    thread_pool: &ThreadPool,
    filters: &[(CrdsValue, CrdsFilter)],
    output_size_limit: usize,
    now: u64,
    stats: &GossipStats
) -> Vec<Vec<CrdsValue>>

pub fn filter_pull_responses(
    &self,
    timeouts: &HashMap<Pubkey, u64>,
    response: Vec<CrdsValue>,
    now: u64,
    process_pull_stats: &mut ProcessPullStats
) -> (Vec<CrdsValue>, Vec<CrdsValue>, Vec<Hash>)

pub fn process_pull_responses(
    &self,
    from: &Pubkey,
    responses: Vec<CrdsValue>,
    responses_expired_timeout: Vec<CrdsValue>,
    failed_inserts: Vec<Hash>,
    now: u64,
    process_pull_stats: &mut ProcessPullStats
)

Process a pull response.

pub fn make_timeouts(
    &self,
    self_pubkey: Pubkey,
    stakes: &HashMap<Pubkey, u64>,
    epoch_duration: Duration
) -> HashMap<Pubkey, u64>

pub fn purge(
    &self,
    self_pubkey: &Pubkey,
    thread_pool: &ThreadPool,
    now: u64,
    timeouts: &HashMap<Pubkey, u64>
) -> usize

Trait Implementations

impl Default for CrdsGossip

fn default() -> CrdsGossip

Returns the “default value” for a type.