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.