Differential D11677 Diff 34191 src/avalanche/processor.cpp

Changeset View

Standalone View

src/avalanche/processor.cpp

	Show First 20 Lines • Show All 103 Lines • ▼ Show 20 Lines
	class Processor::NotificationsHandler			class Processor::NotificationsHandler
	: public interfaces::Chain::Notifications {			: public interfaces::Chain::Notifications {
	Processor *m_processor;			Processor *m_processor;

	public:			public:
	NotificationsHandler(Processor *p) : m_processor(p) {}			NotificationsHandler(Processor *p) : m_processor(p) {}

	void updatedBlockTip() override {			void updatedBlockTip() override {
				auto registerProofs = [&]() {
	LOCK(m_processor->cs_peerManager);			LOCK(m_processor->cs_peerManager);

	if (m_processor->peerData && m_processor->peerData->proof) {			if (m_processor->peerData && m_processor->peerData->proof) {
	m_processor->peerManager->registerProof(			m_processor->peerManager->registerProof(
	m_processor->peerData->proof);			m_processor->peerData->proof);
	}			}

	m_processor->peerManager->updatedBlockTip();			return m_processor->peerManager->updatedBlockTip();
				};

				auto registeredProofs = registerProofs();
				for (const auto &proof : registeredProofs) {
				m_processor->addProofToReconcile(proof);
				}
	}			}
	};			};

	Processor::Processor(const ArgsManager &argsman, interfaces::Chain &chain,			Processor::Processor(const ArgsManager &argsman, interfaces::Chain &chain,
	CConnman *connmanIn, CScheduler &scheduler,			CConnman *connmanIn, CScheduler &scheduler,
	std::unique_ptr<PeerData> peerDataIn, CKey sessionKeyIn,			std::unique_ptr<PeerData> peerDataIn, CKey sessionKeyIn,
	uint32_t minQuorumTotalScoreIn,			uint32_t minQuorumTotalScoreIn,
	double minQuorumConnectedScoreRatioIn,			double minQuorumConnectedScoreRatioIn,
	▲ Show 20 Lines • Show All 826 Lines • Show Last 20 Lines