Differential D9487 Diff 28392 src/avalanche/peermanager.h

Changeset View

Standalone View

src/avalanche/peermanager.h

Show First 20 Lines • Show All 73 Lines • ▼ Show 20 Lines

struct proof_index {		struct proof_index {
using result_type = ProofId;		using result_type = ProofId;
result_type operator()(const Peer &p) const { return p.proof.getId(); }		result_type operator()(const Peer &p) const { return p.proof.getId(); }
};		};

struct next_request_time {};		struct next_request_time {};

		struct AvaHelloSigData {
		uint256 sigHash;
		SchnorrSig signature;

		AvaHelloSigData(uint256 hash, SchnorrSig sig)
		: sigHash(hash), signature(sig) {}

		bool verify(const CPubKey pubkey) const {
		return pubkey.VerifySchnorr(sigHash, signature);
		}
		};

class PeerManager {		class PeerManager {
std::vector<Slot> slots;		std::vector<Slot> slots;
uint64_t slotCount = 0;		uint64_t slotCount = 0;
uint64_t fragmentation = 0;		uint64_t fragmentation = 0;

/**		/**
* Several nodes can make an avalanche peer. In this case, all nodes are		* Several nodes can make an avalanche peer. In this case, all nodes are
* considered interchangeable parts of the same peer.		* considered interchangeable parts of the same peer.
Show All 33 Lines	class PeerManager {
static constexpr int SELECT_PEER_MAX_RETRY = 3;		static constexpr int SELECT_PEER_MAX_RETRY = 3;
static constexpr int SELECT_NODE_MAX_RETRY = 3;		static constexpr int SELECT_NODE_MAX_RETRY = 3;

public:		public:
/**		/**
* Node API.		* Node API.
*/		*/
bool addNode(NodeId nodeid, const Proof &proof,		bool addNode(NodeId nodeid, const Proof &proof,
const Delegation &delegation);		const Delegation &delegation,
		std::optional<AvaHelloSigData> sigData = std::nullopt);
bool removeNode(NodeId nodeid);		bool removeNode(NodeId nodeid);

bool forNode(NodeId nodeid, std::function<bool(const Node &n)> func) const;		bool forNode(NodeId nodeid, std::function<bool(const Node &n)> func) const;
bool updateNextRequestTime(NodeId nodeid, TimePoint timeout);		bool updateNextRequestTime(NodeId nodeid, TimePoint timeout);

/**		/**
* Randomly select a node to poll.		* Randomly select a node to poll.
*/		*/
▲ Show 20 Lines • Show All 59 Lines • Show Last 20 Lines