Differential D11630 Diff 34037 src/avalanche/processor.h

Changeset View

Standalone View

src/avalanche/processor.h

Show First 20 Lines • Show All 187 Lines • ▼ Show 20 Lines	static std::unique_ptr<Processor> MakeProcessor(const ArgsManager &argsman,
CConnman *connman,		CConnman *connman,
bilingual_str &error);		bilingual_str &error);

void setQueryTimeoutDuration(std::chrono::milliseconds d) {		void setQueryTimeoutDuration(std::chrono::milliseconds d) {
queryTimeoutDuration = d;		queryTimeoutDuration = d;
}		}

bool addBlockToReconcile(const CBlockIndex *pindex);		bool addBlockToReconcile(const CBlockIndex *pindex);
void addProofToReconcile(const ProofRef &proof);		bool addProofToReconcile(const ProofRef &proof);
bool isAccepted(const CBlockIndex *pindex) const;		bool isAccepted(const CBlockIndex *pindex) const;
bool isAccepted(const ProofRef &proof) const;		bool isAccepted(const ProofRef &proof) const;
int getConfidence(const CBlockIndex *pindex) const;		int getConfidence(const CBlockIndex *pindex) const;
int getConfidence(const ProofRef &proof) const;		int getConfidence(const ProofRef &proof) const;

// TODO: Refactor the API to remove the dependency on avalanche/protocol.h		// TODO: Refactor the API to remove the dependency on avalanche/protocol.h
void sendResponse(CNode *pfrom, Response response) const;		void sendResponse(CNode *pfrom, Response response) const;
bool registerVotes(NodeId nodeid, const Response &response,		bool registerVotes(NodeId nodeid, const Response &response,
Show All 37 Lines	void FinalizeNode(const Config &config, const CNode &node,
bool &update_connection_time) override;		bool &update_connection_time) override;

private:		private:
void runEventLoop();		void runEventLoop();
void clearTimedoutRequests();		void clearTimedoutRequests();
std::vector<CInv> getInvsForNextPoll(bool forPoll = true);		std::vector<CInv> getInvsForNextPoll(bool forPoll = true);
NodeId getSuitableNodeToQuery();		NodeId getSuitableNodeToQuery();

		bool IsWorthPolling(const ProofRef &proof) const
		EXCLUSIVE_LOCKS_REQUIRED(cs_peerManager);
		bool IsWorthPolling(const CBlockIndex *pindex) const
		EXCLUSIVE_LOCKS_REQUIRED(cs_main);

/**		/**
* Build and return the challenge whose signature is included in the		* Build and return the challenge whose signature is included in the
* AVAHELLO message that we send to a peer.		* AVAHELLO message that we send to a peer.
*/		*/
uint256 buildLocalSighash(CNode *pfrom) const;		uint256 buildLocalSighash(CNode *pfrom) const;

friend struct ::avalanche::AvalancheTest;		friend struct ::avalanche::AvalancheTest;
};		};

} // namespace avalanche		} // namespace avalanche

#endif // BITCOIN_AVALANCHE_PROCESSOR_H		#endif // BITCOIN_AVALANCHE_PROCESSOR_H