Changeset View
Changeset View
Standalone View
Standalone View
src/validationinterface.cpp
| Show First 20 Lines • Show All 176 Lines • ▼ Show 20 Lines | void CMainSignals::UpdatedBlockTip(const CBlockIndex *pindexNew, | ||||
| bool fInitialDownload) { | bool fInitialDownload) { | ||||
| 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->TransactionAddedToMempool(ptx); | m_internals->m_schedulerClient.AddToProcessQueue( | ||||
| [ptx, this] { m_internals->TransactionAddedToMempool(ptx); }); | |||||
| } | } | ||||
| void CMainSignals::BlockConnected( | void CMainSignals::BlockConnected( | ||||
| const std::shared_ptr<const CBlock> &pblock, const CBlockIndex *pindex, | const std::shared_ptr<const CBlock> &pblock, const CBlockIndex *pindex, | ||||
| const std::vector<CTransactionRef> &vtxConflicted) { | const std::shared_ptr<const std::vector<CTransactionRef>> &pvtxConflicted) { | ||||
| m_internals->BlockConnected(pblock, pindex, vtxConflicted); | m_internals->m_schedulerClient.AddToProcessQueue( | ||||
| [pblock, pindex, pvtxConflicted, this] { | |||||
| m_internals->BlockConnected(pblock, pindex, *pvtxConflicted); | |||||
| }); | |||||
| } | } | ||||
| void CMainSignals::BlockDisconnected( | void CMainSignals::BlockDisconnected( | ||||
| const std::shared_ptr<const CBlock> &pblock) { | const std::shared_ptr<const CBlock> &pblock) { | ||||
| m_internals->BlockDisconnected(pblock); | m_internals->m_schedulerClient.AddToProcessQueue( | ||||
| [pblock, this] { m_internals->BlockDisconnected(pblock); }); | |||||
| } | } | ||||
| void CMainSignals::ChainStateFlushed(const CBlockLocator &locator) { | void CMainSignals::ChainStateFlushed(const CBlockLocator &locator) { | ||||
| m_internals->ChainStateFlushed(locator); | m_internals->m_schedulerClient.AddToProcessQueue( | ||||
| [locator, this] { m_internals->ChainStateFlushed(locator); }); | |||||
| } | } | ||||
| void CMainSignals::Inventory(const uint256 &hash) { | void CMainSignals::Inventory(const uint256 &hash) { | ||||
| m_internals->Inventory(hash); | m_internals->m_schedulerClient.AddToProcessQueue( | ||||
| [hash, this] { m_internals->Inventory(hash); }); | |||||
| } | } | ||||
| void CMainSignals::Broadcast(int64_t nBestBlockTime, CConnman *connman) { | void CMainSignals::Broadcast(int64_t nBestBlockTime, CConnman *connman) { | ||||
| m_internals->Broadcast(nBestBlockTime, connman); | m_internals->Broadcast(nBestBlockTime, connman); | ||||
| } | } | ||||
| void CMainSignals::BlockChecked(const CBlock &block, | void CMainSignals::BlockChecked(const CBlock &block, | ||||
| const CValidationState &state) { | const CValidationState &state) { | ||||
| m_internals->BlockChecked(block, state); | m_internals->BlockChecked(block, state); | ||||
| } | } | ||||
| void CMainSignals::NewPoWValidBlock( | void CMainSignals::NewPoWValidBlock( | ||||
| const CBlockIndex *pindex, const std::shared_ptr<const CBlock> &block) { | const CBlockIndex *pindex, const std::shared_ptr<const CBlock> &block) { | ||||
| m_internals->NewPoWValidBlock(pindex, block); | m_internals->NewPoWValidBlock(pindex, block); | ||||
| } | } | ||||