Changeset View

Standalone View

Show First 20 Lines • Show All 163 Lines • ▼ Show 20 Lines	if (reason != MemPoolRemovalReason::BLOCK &&
m_internals->m_schedulerClient.AddToProcessQueue(		m_internals->m_schedulerClient.AddToProcessQueue(
[ptx, this] { m_internals->TransactionRemovedFromMempool(ptx); });		[ptx, this] { m_internals->TransactionRemovedFromMempool(ptx); });
}		}
}		}

void CMainSignals::UpdatedBlockTip(const CBlockIndex *pindexNew,		void CMainSignals::UpdatedBlockTip(const CBlockIndex *pindexNew,
const CBlockIndex *pindexFork,		const CBlockIndex *pindexFork,
bool fInitialDownload) {		bool fInitialDownload) {
		// Dependencies exist that require UpdatedBlockTip events to be delivered in
		// the order in which the chain actually updates. One way to ensure this is
		// for the caller to invoke this signal in the same critical section where
		// the chain is updated

m_internals->m_schedulerClient.AddToProcessQueue([pindexNew, pindexFork,		m_internals->m_schedulerClient.AddToProcessQueue([pindexNew, pindexFork,
fInitialDownload, this] {		fInitialDownload, this] {
m_internals->UpdatedBlockTip(pindexNew, pindexFork, fInitialDownload);		m_internals->UpdatedBlockTip(pindexNew, pindexFork, fInitialDownload);
});		});
}		}

void CMainSignals::TransactionAddedToMempool(const CTransactionRef &ptx) {		void CMainSignals::TransactionAddedToMempool(const CTransactionRef &ptx) {
m_internals->m_schedulerClient.AddToProcessQueue(		m_internals->m_schedulerClient.AddToProcessQueue(
Show All 36 Lines