#include <peermanager.h>

Collaboration diagram for avalanche::PeerManager:

Public Types
enum class	RegistrationMode { DEFAULT , FORCE_ACCEPT }
	Registration mode. More...

enum class	RejectionMode { DEFAULT , INVALIDATE }
	Rejection mode. More...

Public Member Functions
	PeerManager (const Amount &stakeUtxoDustThresholdIn, ChainstateManager &chainmanIn, bool stakingPreConsensus=false, const ProofRef &localProofIn=ProofRef())

bool	addNode (NodeId nodeid, const ProofId &proofid)
	Node API. More...

bool	removeNode (NodeId nodeid)

size_t	getNodeCount () const

size_t	getPendingNodeCount () const

bool	updateNextRequestTime (NodeId nodeid, SteadyMilliseconds timeout)

bool	latchAvaproofsSent (NodeId nodeid)
	Flag that a node did send its compact proofs. More...

NodeId	selectNode ()

bool	shouldRequestMoreNodes ()
	Returns true if we encountered a lack of node since the last call. More...

template<typename Callable >
bool	forNode (NodeId nodeid, Callable &&func) const

template<typename Callable >
void	forEachNode (const Peer &peer, Callable &&func) const

bool	updateNextPossibleConflictTime (PeerId peerid, const std::chrono::seconds &nextTime)
	Proof and Peer related API. More...

bool	setFinalized (PeerId peerid)
	Latch on that this peer has a finalized proof. More...

bool	registerProof (const ProofRef &proof, ProofRegistrationState &registrationState, RegistrationMode mode=RegistrationMode::DEFAULT)

bool	registerProof (const ProofRef &proof, RegistrationMode mode=RegistrationMode::DEFAULT)

bool	rejectProof (const ProofId &proofid, RejectionMode mode=RejectionMode::DEFAULT)

bool	exists (const ProofId &proofid) const
	Return true if the (valid) proof exists, but only for non-dangling proofs. More...

void	cleanupDanglingProofs (std::unordered_set< ProofRef, SaltedProofHasher > &registeredProofs)

template<typename Callable >
bool	forPeer (const ProofId &proofid, Callable &&func) const

template<typename Callable >
void	forEachPeer (Callable &&func) const

std::unordered_set< ProofRef, SaltedProofHasher >	updatedBlockTip ()
	Update the peer set when a new block is connected. More...

void	addUnbroadcastProof (const ProofId &proofid)
	Proof broadcast API. More...

void	removeUnbroadcastProof (const ProofId &proofid)

auto	getUnbroadcastProofs () const

uint32_t	getTotalPeersScore () const

uint32_t	getConnectedPeersScore () const

bool	saveRemoteProof (const ProofId &proofid, const NodeId nodeid, const bool present)

std::vector< RemoteProof >	getRemoteProofs (const NodeId nodeid) const

bool	isRemoteProof (const ProofId &proofid) const

bool	setFlaky (const ProofId &proofid)

bool	unsetFlaky (const ProofId &proofid)

template<typename Callable >
void	forEachFlakyProof (Callable &&func) const

void	cleanupStakeContenders (const int requestedMinHeight)
	Make some of the contender cache API available. More...

void	addStakeContender (const ProofRef &proof)

int	getStakeContenderStatus (const StakeContenderId &contenderId, BlockHash &prevblockhashout) const

void	acceptStakeContender (const StakeContenderId &contenderId)

void	finalizeStakeContender (const StakeContenderId &contenderId, BlockHash &prevblockhash, std::vector< std::pair< ProofId, CScript > > &newWinners)

void	rejectStakeContender (const StakeContenderId &contenderId)

void	promoteStakeContendersToBlock (const CBlockIndex *pindex)

bool	setContenderStatusForLocalWinners (const CBlockIndex *prevblock, const std::vector< std::pair< ProofId, CScript > > winners, size_t maxPollable, std::vector< StakeContenderId > &pollableContenders)

bool	setStakeContenderWinners (const CBlockIndex *pindex, const std::vector< CScript > &payoutScripts)

bool	removePeer (const PeerId peerid)
	Remove an existing peer. More...

PeerId	selectPeer () const
	Randomly select a peer to poll. More...

uint64_t	compact ()
	Trigger maintenance of internal data structures. More...

bool	verify () const
	Perform consistency check on internal data structures. More...

uint64_t	getSlotCount () const

uint64_t	getFragmentation () const

const ProofPool &	getValidProofPool () const

const ProofPool &	getConflictingProofPool () const

const ProofPool &	getImmatureProofPool () const

ProofRef	getProof (const ProofId &proofid) const

bool	isBoundToPeer (const ProofId &proofid) const

bool	isImmature (const ProofId &proofid) const

bool	isInConflictingPool (const ProofId &proofid) const

bool	isDangling (const ProofId &proofid) const

void	setInvalid (const ProofId &proofid)

bool	isInvalid (const ProofId &proofid) const

void	clearAllInvalid ()

const ProofRadixTree &	getShareableProofsSnapshot () const

const Amount &	getStakeUtxoDustThreshold () const

bool	selectStakingRewardWinner (const CBlockIndex *pprev, std::vector< std::pair< ProofId, CScript > > &winners)
	Deterministically select a list of payout scripts based on the proof set and the previous block hash. More...

bool	dumpPeersToFile (const fs::path &dumpPath) const

bool	loadPeersFromFile (const fs::path &dumpPath, std::unordered_set< ProofRef, SaltedProofHasher > &registeredProofs)

Static Public Attributes
static constexpr size_t	MAX_REMOTE_PROOFS {100}

Private Types
using	PeerSet = boost::multi_index_container< Peer, bmi::indexed_by< bmi::hashed_unique< bmi::member< Peer, PeerId, &Peer::peerid > >, bmi::hashed_unique< bmi::tag< by_proofid >, proof_index, SaltedProofIdHasher >, bmi::ordered_non_unique< bmi::tag< by_score >, score_index, std::greater< uint32_t > > > >
	Several nodes can make an avalanche peer. More...

using	ProofRadixTree = RadixTree< const Proof, ProofRadixTreeAdapter >

using	NodeSet = boost::multi_index_container< Node, bmi::indexed_by< bmi::hashed_unique< bmi::member< Node, NodeId, &Node::nodeid > >, bmi::ordered_non_unique< bmi::tag< next_request_time >, bmi::composite_key< Node, bmi::member< Node, PeerId, &Node::peerid >, bmi::member< Node, SteadyMilliseconds, &Node::nextRequestTime > > > > >

using	PendingNodeSet = boost::multi_index_container< PendingNode, bmi::indexed_by< bmi::hashed_non_unique< bmi::tag< by_proofid >, bmi::member< PendingNode, ProofId, &PendingNode::proofid >, SaltedProofIdHasher >, bmi::hashed_unique< bmi::tag< by_nodeid >, bmi::member< PendingNode, NodeId, &PendingNode::nodeid > > > >

using	RemoteProofSet = boost::multi_index_container< RemoteProof, bmi::indexed_by< bmi::hashed_unique< bmi::composite_key< RemoteProof, bmi::member< RemoteProof, ProofId, &RemoteProof::proofid >, bmi::member< RemoteProof, NodeId, &RemoteProof::nodeid > >, bmi::composite_key_hash< SaltedProofIdHasher, boost::hash< NodeId > > >, bmi::hashed_non_unique< bmi::tag< by_proofid >, bmi::member< RemoteProof, ProofId, &RemoteProof::proofid >, SaltedProofIdHasher >, bmi::hashed_non_unique< bmi::tag< by_nodeid >, bmi::member< RemoteProof, NodeId, &RemoteProof::nodeid > >, bmi::ordered_non_unique< bmi::tag< by_lastUpdate >, bmi::composite_key< RemoteProof, bmi::member< RemoteProof, NodeId, &RemoteProof::nodeid >, bmi::member< RemoteProof, std::chrono::seconds, &RemoteProof::lastUpdate > > > > >

Private Member Functions
template<typename ProofContainer >
void	moveToConflictingPool (const ProofContainer &proofs)

bool	addOrUpdateNode (const PeerSet::iterator &it, NodeId nodeid)

bool	addNodeToPeer (const PeerSet::iterator &it)

bool	removeNodeFromPeer (const PeerSet::iterator &it, uint32_t count=1)

std::optional< bool >	getRemotePresenceStatus (const ProofId &proofid) const
	Get the presence remote status of a proof. More...

bool	isFlaky (const ProofId &proofid) const

Private Attributes
std::vector< Slot >	slots

uint64_t	slotCount = 0

uint64_t	fragmentation = 0

PeerId	nextPeerId = 0

PeerSet	peers

ProofPool	validProofPool

ProofPool	conflictingProofPool

ProofPool	immatureProofPool

ProofPool	danglingProofPool

ProofRadixTree	shareableProofs

NodeSet	nodes

std::atomic< bool >	needMoreNodes {false}
	Flag indicating that we failed to select a node and need to expand our node set. More...

PendingNodeSet	pendingNodes

ProofIdSet	m_unbroadcast_proofids
	Track proof ids to broadcast. More...

uint32_t	totalPeersScore = 0
	Quorum management. More...

uint32_t	connectedPeersScore = 0

Amount	stakeUtxoDustThreshold

ChainstateManager &	chainman

const bool	m_stakingPreConsensus {false}

ProofRef	localProof

RemoteProofSet	remoteProofs
	Remember which node sent which proof so we have an image of the proof set of our peers. More...

CRollingBloomFilter	invalidProofs {100000, 0.000001}
	Filter for proofs that are consensus-invalid or were recently invalidated by avalanche (finalized rejection). More...

std::unordered_set< ProofId, SaltedProofIdHasher >	manualFlakyProofids

StakeContenderCache	stakeContenderCache

Static Private Attributes
static constexpr int	SELECT_PEER_MAX_RETRY = 3

static constexpr int	SELECT_NODE_MAX_RETRY = 3

Friends
struct	::avalanche::TestPeerManager

Detailed Description

Definition at line 162 of file peermanager.h.

Member Typedef Documentation

◆ NodeSet

using avalanche::PeerManager::NodeSet = boost::multi_index_container< Node, bmi::indexed_by< bmi::hashed_unique<bmi::member<Node, NodeId, &Node::nodeid> >, bmi::ordered_non_unique< bmi::tag<next_request_time>, bmi::composite_key< Node, bmi::member<Node, PeerId, &Node::peerid>, bmi::member<Node, SteadyMilliseconds, &Node::nextRequestTime> >> >>

private

Definition at line 193 of file peermanager.h.

◆ PeerSet

using avalanche::PeerManager::PeerSet = boost::multi_index_container< Peer, bmi::indexed_by< bmi::hashed_unique<bmi::member<Peer, PeerId, &Peer::peerid> >, bmi::hashed_unique<bmi::tag<by_proofid>, proof_index, SaltedProofIdHasher>, bmi::ordered_non_unique<bmi::tag<by_score>, score_index, std::greater<uint32_t> >> >

private

Several nodes can make an avalanche peer.

In this case, all nodes are considered interchangeable parts of the same peer.

Definition at line 171 of file peermanager.h.

◆ PendingNodeSet

using avalanche::PeerManager::PendingNodeSet = boost::multi_index_container< PendingNode, bmi::indexed_by< bmi::hashed_non_unique< bmi::tag<by_proofid>, bmi::member<PendingNode, ProofId, &PendingNode::proofid>, SaltedProofIdHasher>, bmi::hashed_unique< bmi::tag<by_nodeid>, bmi::member<PendingNode, NodeId, &PendingNode::nodeid> >> >

private

Definition at line 213 of file peermanager.h.

◆ ProofRadixTree

using avalanche::PeerManager::ProofRadixTree = RadixTree<const Proof, ProofRadixTreeAdapter>

private

Definition at line 190 of file peermanager.h.

◆ RemoteProofSet

using avalanche::PeerManager::RemoteProofSet = boost::multi_index_container< RemoteProof, bmi::indexed_by< bmi::hashed_unique< bmi::composite_key< RemoteProof, bmi::member<RemoteProof, ProofId, &RemoteProof::proofid>, bmi::member<RemoteProof, NodeId, &RemoteProof::nodeid> >, bmi::composite_key_hash<SaltedProofIdHasher, boost::hash<NodeId> >>, bmi::hashed_non_unique< bmi::tag<by_proofid>, bmi::member<RemoteProof, ProofId, &RemoteProof::proofid>, SaltedProofIdHasher>, bmi::hashed_non_unique< bmi::tag<by_nodeid>, bmi::member<RemoteProof, NodeId, &RemoteProof::nodeid> >, bmi::ordered_non_unique< bmi::tag<by_lastUpdate>, bmi::composite_key< RemoteProof, bmi::member<RemoteProof, NodeId, &RemoteProof::nodeid>, bmi::member<RemoteProof, std::chrono::seconds, &RemoteProof::lastUpdate> >> >>

private

Definition at line 251 of file peermanager.h.

Member Enumeration Documentation

◆ RegistrationMode

enum class avalanche::PeerManager::RegistrationMode

strong

Registration mode.

DEFAULT: Default policy, register only if the proof is unknown and has no conflict.
FORCE_ACCEPT: Turn a valid proof into a peer even if it has conflicts and is not the best candidate.

Enumerator
DEFAULT
FORCE_ACCEPT

Definition at line 376 of file peermanager.h.

◆ RejectionMode

enum class avalanche::PeerManager::RejectionMode

strong

Rejection mode.

DEFAULT: Default policy, reject a proof and attempt to keep it in the conflicting pool if possible.
INVALIDATE: Reject a proof by removing it from any of the pool.

In any case if a peer is rejected, it attempts to pull the conflicting proofs back.

Enumerator
DEFAULT
INVALIDATE

Definition at line 399 of file peermanager.h.

Constructor & Destructor Documentation

◆ PeerManager()

avalanche::PeerManager::PeerManager	(	const Amount &	stakeUtxoDustThresholdIn,
		ChainstateManager &	chainmanIn,
		bool	stakingPreConsensus = `false`,
		const ProofRef &	localProofIn = `ProofRef()`
	)

inline

Definition at line 306 of file peermanager.h.

Member Function Documentation

◆ acceptStakeContender()

void PeerManager::acceptStakeContender ( const StakeContenderId & contenderId )

Definition at line 1434 of file peermanager.cpp.

Here is the call graph for this function:

◆ addNode()

bool PeerManager::addNode	(	NodeId	nodeid,
		const ProofId &	proofid
	)

Node API.

Definition at line 33 of file peermanager.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ addNodeToPeer()

bool PeerManager::addNodeToPeer ( const PeerSet::iterator & it )

private

Definition at line 89 of file peermanager.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ addOrUpdateNode()

bool PeerManager::addOrUpdateNode	(	const PeerSet::iterator &	it,
		NodeId	nodeid
	)

private

Definition at line 48 of file peermanager.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ addStakeContender()

void PeerManager::addStakeContender ( const ProofRef & proof )

Definition at line 1415 of file peermanager.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ addUnbroadcastProof()

void PeerManager::addUnbroadcastProof ( const ProofId & proofid )

Proof broadcast API.

Definition at line 1003 of file peermanager.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ cleanupDanglingProofs()

void PeerManager::cleanupDanglingProofs ( std::unordered_set< ProofRef, SaltedProofHasher > & registeredProofs )

Definition at line 480 of file peermanager.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ cleanupStakeContenders()

void PeerManager::cleanupStakeContenders ( const int requestedMinHeight )

Make some of the contender cache API available.

Definition at line 1411 of file peermanager.cpp.

Here is the call graph for this function:

◆ clearAllInvalid()

void PeerManager::clearAllInvalid ( )

Definition at line 659 of file peermanager.cpp.

Here is the call graph for this function:

◆ compact()

uint64_t PeerManager::compact ( )

Trigger maintenance of internal data structures.

Returns how much slot space was saved after compaction.

Definition at line 780 of file peermanager.cpp.

Here is the caller graph for this function:

◆ dumpPeersToFile()

bool PeerManager::dumpPeersToFile ( const fs::path & dumpPath ) const

Definition at line 1299 of file peermanager.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ exists()

bool avalanche::PeerManager::exists ( const ProofId & proofid ) const

inline

Return true if the (valid) proof exists, but only for non-dangling proofs.

Definition at line 411 of file peermanager.h.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ finalizeStakeContender()

void PeerManager::finalizeStakeContender	(	const StakeContenderId &	contenderId,
		BlockHash &	prevblockhash,
		std::vector< std::pair< ProofId, CScript > > &	newWinners
	)

Definition at line 1438 of file peermanager.cpp.

Here is the call graph for this function:

◆ forEachFlakyProof()

template<typename Callable >

void avalanche::PeerManager::forEachFlakyProof ( Callable && func ) const

inline

Definition at line 456 of file peermanager.h.

Here is the caller graph for this function:

◆ forEachNode()

template<typename Callable >

void avalanche::PeerManager::forEachNode	(	const Peer &	peer,
		Callable &&	func
	)		const

inline

Definition at line 345 of file peermanager.h.

Here is the caller graph for this function:

◆ forEachPeer()

template<typename Callable >

void avalanche::PeerManager::forEachPeer ( Callable && func ) const

inline

Definition at line 425 of file peermanager.h.

Here is the caller graph for this function:

◆ forNode()

template<typename Callable >

bool avalanche::PeerManager::forNode	(	NodeId	nodeid,
		Callable &&	func
	)		const

inline

Definition at line 339 of file peermanager.h.

Here is the caller graph for this function:

◆ forPeer()

template<typename Callable >

bool avalanche::PeerManager::forPeer	(	const ProofId &	proofid,
		Callable &&	func
	)		const

inline

Definition at line 419 of file peermanager.h.

Here is the caller graph for this function:

◆ getConflictingProofPool()

const ProofPool & avalanche::PeerManager::getConflictingProofPool ( ) const

inline

Definition at line 510 of file peermanager.h.

Here is the caller graph for this function:

◆ getConnectedPeersScore()

uint32_t avalanche::PeerManager::getConnectedPeersScore ( ) const

inline

Definition at line 447 of file peermanager.h.

Here is the caller graph for this function:

◆ getFragmentation()

uint64_t avalanche::PeerManager::getFragmentation ( ) const

inline

Definition at line 507 of file peermanager.h.

Here is the caller graph for this function:

◆ getImmatureProofPool()

const ProofPool & avalanche::PeerManager::getImmatureProofPool ( ) const

inline

Definition at line 513 of file peermanager.h.

Here is the caller graph for this function:

◆ getNodeCount()

size_t avalanche::PeerManager::getNodeCount ( ) const

inline

Definition at line 318 of file peermanager.h.

Here is the caller graph for this function:

◆ getPendingNodeCount()

size_t avalanche::PeerManager::getPendingNodeCount ( ) const

inline

Definition at line 319 of file peermanager.h.

Here is the caller graph for this function:

◆ getProof()

ProofRef PeerManager::getProof ( const ProofId & proofid ) const

Definition at line 615 of file peermanager.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ getRemotePresenceStatus()

std::optional< bool > PeerManager::getRemotePresenceStatus ( const ProofId & proofid ) const

private

Get the presence remote status of a proof.

Parameters

proofid The target proof id

Returns: true if it's likely present, false if likely missing, nullopt if uncertain.

Definition at line 1213 of file peermanager.cpp.

Here is the caller graph for this function:

◆ getRemoteProofs()

std::vector< RemoteProof > PeerManager::getRemoteProofs ( const NodeId nodeid ) const

Definition at line 705 of file peermanager.cpp.

Here is the caller graph for this function:

◆ getShareableProofsSnapshot()

const ProofRadixTree & avalanche::PeerManager::getShareableProofsSnapshot ( ) const

inline

Definition at line 525 of file peermanager.h.

Here is the caller graph for this function:

◆ getSlotCount()

uint64_t avalanche::PeerManager::getSlotCount ( ) const

inline

Definition at line 506 of file peermanager.h.

Here is the caller graph for this function:

◆ getStakeContenderStatus()

int PeerManager::getStakeContenderStatus	(	const StakeContenderId &	contenderId,
		BlockHash &	prevblockhashout
	)		const

Definition at line 1429 of file peermanager.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ getStakeUtxoDustThreshold()

const Amount & avalanche::PeerManager::getStakeUtxoDustThreshold ( ) const

inline

Definition at line 529 of file peermanager.h.

Here is the caller graph for this function:

◆ getTotalPeersScore()

uint32_t avalanche::PeerManager::getTotalPeersScore ( ) const

inline

Definition at line 446 of file peermanager.h.

Here is the caller graph for this function:

◆ getUnbroadcastProofs()

auto avalanche::PeerManager::getUnbroadcastProofs ( ) const

inline

Definition at line 441 of file peermanager.h.

◆ getValidProofPool()

const ProofPool & avalanche::PeerManager::getValidProofPool ( ) const

inline

Definition at line 509 of file peermanager.h.

Here is the caller graph for this function:

◆ isBoundToPeer()

bool PeerManager::isBoundToPeer ( const ProofId & proofid ) const

Definition at line 634 of file peermanager.cpp.

Here is the caller graph for this function:

◆ isDangling()

bool PeerManager::isDangling ( const ProofId & proofid ) const

Definition at line 647 of file peermanager.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ isFlaky()

bool PeerManager::isFlaky ( const ProofId & proofid ) const

private

Definition at line 1149 of file peermanager.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ isImmature()

bool PeerManager::isImmature ( const ProofId & proofid ) const

Definition at line 639 of file peermanager.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ isInConflictingPool()

bool PeerManager::isInConflictingPool ( const ProofId & proofid ) const

Definition at line 643 of file peermanager.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ isInvalid()

bool PeerManager::isInvalid ( const ProofId & proofid ) const

Definition at line 655 of file peermanager.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ isRemoteProof()

bool PeerManager::isRemoteProof ( const ProofId & proofid ) const

Definition at line 718 of file peermanager.cpp.

Here is the caller graph for this function:

◆ latchAvaproofsSent()

bool PeerManager::latchAvaproofsSent ( NodeId nodeid )

Flag that a node did send its compact proofs.

Returns: True if the flag changed state, i;e. if this is the first time the message is accounted for this node.

Definition at line 194 of file peermanager.cpp.

Here is the caller graph for this function:

◆ loadPeersFromFile()

bool PeerManager::loadPeersFromFile	(	const fs::path &	dumpPath,
		std::unordered_set< ProofRef, SaltedProofHasher > &	registeredProofs
	)

Definition at line 1340 of file peermanager.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ moveToConflictingPool()

template<typename ProofContainer >

void PeerManager::moveToConflictingPool ( const ProofContainer & proofs )

private

Definition at line 238 of file peermanager.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ promoteStakeContendersToBlock()

void PeerManager::promoteStakeContendersToBlock ( const CBlockIndex * pindex )

Definition at line 1455 of file peermanager.cpp.

Here is the call graph for this function:

◆ registerProof() [1/2]

bool PeerManager::registerProof	(	const ProofRef &	proof,
		ProofRegistrationState &	registrationState,
		RegistrationMode	mode = `RegistrationMode::DEFAULT`
	)

Definition at line 250 of file peermanager.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ registerProof() [2/2]

bool avalanche::PeerManager::registerProof	(	const ProofRef &	proof,
		RegistrationMode	mode = `RegistrationMode::DEFAULT`
	)

inline

Definition at line 384 of file peermanager.h.

Here is the call graph for this function:

◆ rejectProof()

bool PeerManager::rejectProof	(	const ProofId &	proofid,
		RejectionMode	mode = `RejectionMode::DEFAULT`
	)

Definition at line 425 of file peermanager.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ rejectStakeContender()

void PeerManager::rejectStakeContender ( const StakeContenderId & contenderId )

Definition at line 1451 of file peermanager.cpp.

Here is the call graph for this function:

◆ removeNode()

bool PeerManager::removeNode ( NodeId nodeid )

Definition at line 109 of file peermanager.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ removeNodeFromPeer()

bool PeerManager::removeNodeFromPeer	(	const PeerSet::iterator &	it,
		uint32_t	count = `1`
	)

private

Definition at line 135 of file peermanager.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ removePeer()

bool PeerManager::removePeer ( const PeerId peerid )

Remove an existing peer.

Definition at line 723 of file peermanager.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ removeUnbroadcastProof()

void PeerManager::removeUnbroadcastProof ( const ProofId & proofid )

Definition at line 1010 of file peermanager.cpp.

◆ saveRemoteProof()

bool PeerManager::saveRemoteProof	(	const ProofId &	proofid,
		const NodeId	nodeid,
		const bool	present
	)

Definition at line 663 of file peermanager.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ selectNode()

NodeId PeerManager::selectNode ( )

Definition at line 534 of file peermanager.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ selectPeer()

PeerId PeerManager::selectPeer ( ) const

Randomly select a peer to poll.

Definition at line 764 of file peermanager.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ selectStakingRewardWinner()

bool PeerManager::selectStakingRewardWinner	(	const CBlockIndex *	pprev,
		std::vector< std::pair< ProofId, CScript > > &	winners
	)

Deterministically select a list of payout scripts based on the proof set and the previous block hash.

Definition at line 1014 of file peermanager.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ setContenderStatusForLocalWinners()

bool PeerManager::setContenderStatusForLocalWinners	(	const CBlockIndex *	prevblock,
		const std::vector< std::pair< ProofId, CScript > >	winners,
		size_t	maxPollable,
		std::vector< StakeContenderId > &	pollableContenders
	)

Definition at line 1462 of file peermanager.cpp.

Here is the call graph for this function:

◆ setFinalized()

bool PeerManager::setFinalized ( PeerId peerid )

Latch on that this peer has a finalized proof.

Definition at line 225 of file peermanager.cpp.

Here is the caller graph for this function:

◆ setFlaky()

bool PeerManager::setFlaky ( const ProofId & proofid )

Definition at line 1141 of file peermanager.cpp.

◆ setInvalid()

void PeerManager::setInvalid ( const ProofId & proofid )

Definition at line 651 of file peermanager.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ setStakeContenderWinners()

bool PeerManager::setStakeContenderWinners	(	const CBlockIndex *	pindex,
		const std::vector< CScript > &	payoutScripts
	)

Definition at line 1498 of file peermanager.cpp.

Here is the call graph for this function:

◆ shouldRequestMoreNodes()

bool avalanche::PeerManager::shouldRequestMoreNodes ( )

inline

Returns true if we encountered a lack of node since the last call.

Definition at line 336 of file peermanager.h.

Here is the caller graph for this function:

◆ unsetFlaky()

bool PeerManager::unsetFlaky ( const ProofId & proofid )

Definition at line 1145 of file peermanager.cpp.

Here is the caller graph for this function:

◆ updatedBlockTip()

std::unordered_set< ProofRef, SaltedProofHasher > PeerManager::updatedBlockTip ( )

Update the peer set when a new block is connected.

Definition at line 560 of file peermanager.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ updateNextPossibleConflictTime()

bool PeerManager::updateNextPossibleConflictTime	(	PeerId	peerid,
		const std::chrono::seconds &	nextTime
	)

Proof and Peer related API.

Update the time before which a proof is not allowed to have conflicting UTXO with this peer's proof.

Definition at line 208 of file peermanager.cpp.

Here is the caller graph for this function:

◆ updateNextRequestTime()

bool PeerManager::updateNextRequestTime	(	NodeId	nodeid,
		SteadyMilliseconds	timeout
	)

Definition at line 184 of file peermanager.cpp.

Here is the caller graph for this function:

◆ verify()

bool PeerManager::verify ( ) const

Perform consistency check on internal data structures.

Definition at line 812 of file peermanager.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

Friends And Related Function Documentation

◆ ::avalanche::TestPeerManager

friend struct ::avalanche::TestPeerManager

friend

Definition at line 565 of file peermanager.h.

Member Data Documentation

◆ chainman

ChainstateManager& avalanche::PeerManager::chainman

private

Definition at line 243 of file peermanager.h.

◆ conflictingProofPool

ProofPool avalanche::PeerManager::conflictingProofPool

private

Definition at line 186 of file peermanager.h.

◆ connectedPeersScore

uint32_t avalanche::PeerManager::connectedPeersScore = 0

private

Definition at line 239 of file peermanager.h.

◆ danglingProofPool

ProofPool avalanche::PeerManager::danglingProofPool

private

Definition at line 188 of file peermanager.h.

◆ fragmentation

uint64_t avalanche::PeerManager::fragmentation = 0

private

Definition at line 165 of file peermanager.h.

◆ immatureProofPool

ProofPool avalanche::PeerManager::immatureProofPool

private

Definition at line 187 of file peermanager.h.

◆ invalidProofs

CRollingBloomFilter avalanche::PeerManager::invalidProofs {100000, 0.000001}

private

Filter for proofs that are consensus-invalid or were recently invalidated by avalanche (finalized rejection).

These are not rerequested until they are rolled out of the filter.

Without this filter we'd be re-requesting proofs from each of our peers, increasing bandwidth consumption considerably.

Decreasing the false positive rate is fairly cheap, so we pick one in a million to make it highly unlikely for users to have issues with this filter.

Definition at line 297 of file peermanager.h.

◆ localProof

ProofRef avalanche::PeerManager::localProof

private

Definition at line 247 of file peermanager.h.

◆ m_stakingPreConsensus

const bool avalanche::PeerManager::m_stakingPreConsensus {false}

private

Definition at line 245 of file peermanager.h.

◆ m_unbroadcast_proofids

ProofIdSet avalanche::PeerManager::m_unbroadcast_proofids

private

Track proof ids to broadcast.

Definition at line 233 of file peermanager.h.

◆ manualFlakyProofids

std::unordered_set<ProofId, SaltedProofIdHasher> avalanche::PeerManager::manualFlakyProofids

private

Definition at line 299 of file peermanager.h.

◆ MAX_REMOTE_PROOFS

constexpr size_t avalanche::PeerManager::MAX_REMOTE_PROOFS {100}

staticconstexpr

Definition at line 304 of file peermanager.h.

◆ needMoreNodes

std::atomic<bool> avalanche::PeerManager::needMoreNodes {false}

private

Flag indicating that we failed to select a node and need to expand our node set.

Definition at line 211 of file peermanager.h.

◆ nextPeerId

PeerId avalanche::PeerManager::nextPeerId = 0

private

Definition at line 182 of file peermanager.h.

◆ nodes

NodeSet avalanche::PeerManager::nodes

private

Definition at line 205 of file peermanager.h.

◆ peers

PeerSet avalanche::PeerManager::peers

private

Definition at line 183 of file peermanager.h.

◆ pendingNodes

PendingNodeSet avalanche::PeerManager::pendingNodes

private

Definition at line 225 of file peermanager.h.

◆ remoteProofs

RemoteProofSet avalanche::PeerManager::remoteProofs

private

Remember which node sent which proof so we have an image of the proof set of our peers.

Definition at line 283 of file peermanager.h.

◆ SELECT_NODE_MAX_RETRY

constexpr int avalanche::PeerManager::SELECT_NODE_MAX_RETRY = 3

staticconstexprprivate

Definition at line 228 of file peermanager.h.

◆ SELECT_PEER_MAX_RETRY

constexpr int avalanche::PeerManager::SELECT_PEER_MAX_RETRY = 3

staticconstexprprivate

Definition at line 227 of file peermanager.h.

◆ shareableProofs

ProofRadixTree avalanche::PeerManager::shareableProofs

private

Definition at line 191 of file peermanager.h.

◆ slotCount

uint64_t avalanche::PeerManager::slotCount = 0

private

Definition at line 164 of file peermanager.h.

◆ slots

std::vector<Slot> avalanche::PeerManager::slots

private

Definition at line 163 of file peermanager.h.

◆ stakeContenderCache

StakeContenderCache avalanche::PeerManager::stakeContenderCache

private

Definition at line 301 of file peermanager.h.

◆ stakeUtxoDustThreshold

Amount avalanche::PeerManager::stakeUtxoDustThreshold

private

Definition at line 241 of file peermanager.h.

◆ totalPeersScore

uint32_t avalanche::PeerManager::totalPeersScore = 0

private

Quorum management.

Definition at line 238 of file peermanager.h.

◆ validProofPool

ProofPool avalanche::PeerManager::validProofPool

private

Definition at line 185 of file peermanager.h.

The documentation for this class was generated from the following files:

/work/src/avalanche/peermanager.h
/work/src/avalanche/peermanager.cpp

Public Types

Public Member Functions

Static Public Attributes

Private Types

Private Member Functions

Private Attributes

Static Private Attributes

Friends

Detailed Description

Member Typedef Documentation

◆ NodeSet

◆ PeerSet

◆ PendingNodeSet

◆ ProofRadixTree

◆ RemoteProofSet

Member Enumeration Documentation

◆ RegistrationMode

◆ RejectionMode

Constructor & Destructor Documentation

◆ PeerManager()

Member Function Documentation

◆ acceptStakeContender()

◆ addNode()

◆ addNodeToPeer()

◆ addOrUpdateNode()

◆ addStakeContender()

◆ addUnbroadcastProof()

◆ cleanupDanglingProofs()

◆ cleanupStakeContenders()

◆ clearAllInvalid()

◆ compact()

◆ dumpPeersToFile()

◆ exists()

◆ finalizeStakeContender()

◆ forEachFlakyProof()

◆ forEachNode()

◆ forEachPeer()

◆ forNode()

◆ forPeer()

◆ getConflictingProofPool()

◆ getConnectedPeersScore()

◆ getFragmentation()

◆ getImmatureProofPool()

◆ getNodeCount()

◆ getPendingNodeCount()

◆ getProof()

◆ getRemotePresenceStatus()

◆ getRemoteProofs()

◆ getShareableProofsSnapshot()

◆ getSlotCount()

◆ getStakeContenderStatus()

◆ getStakeUtxoDustThreshold()

◆ getTotalPeersScore()

◆ getUnbroadcastProofs()

◆ getValidProofPool()

◆ isBoundToPeer()

◆ isDangling()

◆ isFlaky()

◆ isImmature()

◆ isInConflictingPool()

◆ isInvalid()

◆ isRemoteProof()

◆ latchAvaproofsSent()

◆ loadPeersFromFile()

◆ moveToConflictingPool()

◆ promoteStakeContendersToBlock()

◆ registerProof() [1/2]

◆ registerProof() [2/2]

◆ rejectProof()

◆ rejectStakeContender()

◆ removeNode()

◆ removeNodeFromPeer()

◆ removePeer()

◆ removeUnbroadcastProof()

◆ saveRemoteProof()

◆ selectNode()

◆ selectPeer()

◆ selectStakingRewardWinner()

◆ setContenderStatusForLocalWinners()

◆ setFinalized()