Changeset View
Changeset View
Standalone View
Standalone View
src/avalanche/processor.cpp
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 |