Changeset View

Standalone View

Show First 20 Lines • Show All 754 Lines • ▼ Show 20 Lines	do {
peerManager->removeNode(nodeid);		peerManager->removeNode(nodeid);
}		}

// Get next suitable node to try again		// Get next suitable node to try again
nodeid = getSuitableNodeToQuery();		nodeid = getSuitableNodeToQuery();
} while (nodeid != NO_NODE);		} while (nodeid != NO_NODE);
}		}

std::vector<avalanche::Peer> Processor::getPeers() const {
LOCK(cs_peerManager);
return peerManager->getPeers();
}

std::vector<NodeId> Processor::getNodeIdsForPeer(PeerId peerId) const {
LOCK(cs_peerManager);
return peerManager->getNodeIdsForPeer(peerId);
}

void Processor::addUnbroadcastProof(const ProofId &proofid) {		void Processor::addUnbroadcastProof(const ProofId &proofid) {
LOCK(cs_peerManager);		LOCK(cs_peerManager);
peerManager->addUnbroadcastProof(proofid);		peerManager->addUnbroadcastProof(proofid);
}		}

void Processor::removeUnbroadcastProof(const ProofId &proofid) {		void Processor::removeUnbroadcastProof(const ProofId &proofid) {
LOCK(cs_peerManager);		LOCK(cs_peerManager);
peerManager->removeUnbroadcastProof(proofid);		peerManager->removeUnbroadcastProof(proofid);
}		}

void Processor::broadcastProofs() {		void Processor::broadcastProofs() {
LOCK(cs_peerManager);		LOCK(cs_peerManager);
peerManager->broadcastProofs(*connman);		peerManager->broadcastProofs(*connman);
}		}

} // namespace avalanche		} // namespace avalanche