Differential D9417 Diff 28188 src/avalanche/peermanager.cpp

Changeset View

Standalone View

src/avalanche/peermanager.cpp

	Show First 20 Lines • Show All 181 Lines • ▼ Show 20 Lines

	PeerId PeerManager::getPeerId(const Proof &proof) {			PeerId PeerManager::getPeerId(const Proof &proof) {
	auto it = fetchOrCreatePeer(proof);			auto it = fetchOrCreatePeer(proof);
	return it == peers.end() ? NO_PEER : it->peerid;			return it == peers.end() ? NO_PEER : it->peerid;
	}			}

	PeerManager::PeerSet::iterator			PeerManager::PeerSet::iterator
	PeerManager::fetchOrCreatePeer(const Proof &proof) {			PeerManager::fetchOrCreatePeer(const Proof &proof) {
				ProofValidationState state;
				return fetchOrCreatePeer(proof, state);
				}

				PeerManager::PeerSet::iterator
				PeerManager::fetchOrCreatePeer(const Proof &proof,
				ProofValidationState &state) {
	{			{
	// Check if we already know of that peer.			// Check if we already know of that peer.
	auto &pview = peers.get<proof_index>();			auto &pview = peers.get<proof_index>();
	auto it = pview.find(proof.getId());			auto it = pview.find(proof.getId());
	if (it != pview.end()) {			if (it != pview.end()) {
	return peers.project<0>(it);			return peers.project<0>(it);
	}			}
	}			}

	{			{
	// Reject invalid proof.			// Reject invalid proof.
	LOCK(cs_main);			LOCK(cs_main);
	const CCoinsViewCache &coins = ::ChainstateActive().CoinsTip();			const CCoinsViewCache &coins = ::ChainstateActive().CoinsTip();

	ProofValidationState state;
	if (!proof.verify(state, coins)) {			if (!proof.verify(state, coins)) {
	return peers.end();			return peers.end();
	}			}
	}			}

	// New peer means new peerid!			// New peer means new peerid!
	const PeerId peerid = nextPeerId++;			const PeerId peerid = nextPeerId++;

	▲ Show 20 Lines • Show All 247 Lines • Show Last 20 Lines