sikkienl/dash
1
0
Fork 0
mirror of https://github.com/dashpay/dash.git synced 2024-12-28 13:32:47 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

Call TransactionRemovedFromMempool in the CScheduler thread

Browse Source 
This is both good practice (we want to move all such callbacks
into a background thread eventually) and prevents a lock inversion
when we go to use this in wallet (mempool.cs->cs_wallet and
cs_wallet->mempool.cs would otherwise both be used).
This commit is contained in:
Matt Corallo 2017-06-08 11:05:18 -04:00
parent a7d3936de8
commit 0343676ce3
2 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/validationinterface.cpp
View File

@ -106,7 +106,9 @@ void UnregisterAllValidationInterfaces() {
void CMainSignals::MempoolEntryRemoved(CTransactionRef ptx, MemPoolRemovalReason reason) { void CMainSignals::MempoolEntryRemoved(CTransactionRef ptx, MemPoolRemovalReason reason) {
if (reason != MemPoolRemovalReason::BLOCK && reason != MemPoolRemovalReason::CONFLICT) { if (reason != MemPoolRemovalReason::BLOCK && reason != MemPoolRemovalReason::CONFLICT) {
m_internals->TransactionRemovedFromMempool(ptx); m_internals->m_schedulerClient.AddToProcessQueue([ptx, this] {
m_internals->TransactionRemovedFromMempool(ptx);
});
} }
} }

2
src/validationinterface.h
View File

@ -45,6 +45,8 @@ protected:
* size limiting, reorg (changes in lock times/coinbase maturity), or * size limiting, reorg (changes in lock times/coinbase maturity), or
* replacement. This does not include any transactions which are included * replacement. This does not include any transactions which are included
* in BlockConnectedDisconnected either in block->vtx or in txnConflicted. * in BlockConnectedDisconnected either in block->vtx or in txnConflicted.
*
* Called on a background thread.
*/ */
virtual void TransactionRemovedFromMempool(const CTransactionRef &ptx) {} virtual void TransactionRemovedFromMempool(const CTransactionRef &ptx) {}
/** /**