remove external usage of mempool conflict tracking
This commit is contained in:
parent
7d5d44969b
commit
bf663f8e93
4 changed files with 7 additions and 13 deletions
|
@ -412,7 +412,7 @@ BOOST_AUTO_TEST_CASE(MempoolAncestorIndexingTest)
|
||||||
/* after tx6 is mined, tx7 should move up in the sort */
|
/* after tx6 is mined, tx7 should move up in the sort */
|
||||||
std::vector<CTransactionRef> vtx;
|
std::vector<CTransactionRef> vtx;
|
||||||
vtx.push_back(MakeTransactionRef(tx6));
|
vtx.push_back(MakeTransactionRef(tx6));
|
||||||
pool.removeForBlock(vtx, 1, NULL, false);
|
pool.removeForBlock(vtx, 1);
|
||||||
|
|
||||||
sortedOrder.erase(sortedOrder.begin()+1);
|
sortedOrder.erase(sortedOrder.begin()+1);
|
||||||
sortedOrder.pop_back();
|
sortedOrder.pop_back();
|
||||||
|
|
|
@ -597,7 +597,7 @@ void CTxMemPool::removeConflicts(const CTransaction &tx, std::vector<CTransactio
|
||||||
* Called when a block is connected. Removes from mempool and updates the miner fee estimator.
|
* Called when a block is connected. Removes from mempool and updates the miner fee estimator.
|
||||||
*/
|
*/
|
||||||
void CTxMemPool::removeForBlock(const std::vector<CTransactionRef>& vtx, unsigned int nBlockHeight,
|
void CTxMemPool::removeForBlock(const std::vector<CTransactionRef>& vtx, unsigned int nBlockHeight,
|
||||||
std::vector<CTransactionRef>* conflicts, bool fCurrentEstimate)
|
bool fCurrentEstimate)
|
||||||
{
|
{
|
||||||
LOCK(cs);
|
LOCK(cs);
|
||||||
std::vector<CTxMemPoolEntry> entries;
|
std::vector<CTxMemPoolEntry> entries;
|
||||||
|
@ -617,7 +617,7 @@ void CTxMemPool::removeForBlock(const std::vector<CTransactionRef>& vtx, unsigne
|
||||||
stage.insert(it);
|
stage.insert(it);
|
||||||
RemoveStaged(stage, true);
|
RemoveStaged(stage, true);
|
||||||
}
|
}
|
||||||
removeConflicts(*tx, conflicts);
|
removeConflicts(*tx);
|
||||||
ClearPrioritisation(tx->GetHash());
|
ClearPrioritisation(tx->GetHash());
|
||||||
}
|
}
|
||||||
// After the txs in the new block have been removed from the mempool, update policy estimates
|
// After the txs in the new block have been removed from the mempool, update policy estimates
|
||||||
|
|
|
@ -531,7 +531,7 @@ public:
|
||||||
void removeForReorg(const CCoinsViewCache *pcoins, unsigned int nMemPoolHeight, int flags);
|
void removeForReorg(const CCoinsViewCache *pcoins, unsigned int nMemPoolHeight, int flags);
|
||||||
void removeConflicts(const CTransaction &tx, std::vector<CTransactionRef>* removed = NULL);
|
void removeConflicts(const CTransaction &tx, std::vector<CTransactionRef>* removed = NULL);
|
||||||
void removeForBlock(const std::vector<CTransactionRef>& vtx, unsigned int nBlockHeight,
|
void removeForBlock(const std::vector<CTransactionRef>& vtx, unsigned int nBlockHeight,
|
||||||
std::vector<CTransactionRef>* conflicts = NULL, bool fCurrentEstimate = true);
|
bool fCurrentEstimate = true);
|
||||||
void clear();
|
void clear();
|
||||||
void _clear(); //lock free
|
void _clear(); //lock free
|
||||||
bool CompareDepthAndScore(const uint256& hasha, const uint256& hashb);
|
bool CompareDepthAndScore(const uint256& hasha, const uint256& hashb);
|
||||||
|
|
|
@ -2153,11 +2153,10 @@ static int64_t nTimeChainState = 0;
|
||||||
static int64_t nTimePostConnect = 0;
|
static int64_t nTimePostConnect = 0;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Used to track conflicted transactions removed from mempool and transactions
|
* Used to track blocks whose transactions were applied to the UTXO state as a
|
||||||
* applied to the UTXO state as a part of a single ActivateBestChainStep call.
|
* part of a single ActivateBestChainStep call.
|
||||||
*/
|
*/
|
||||||
struct ConnectTrace {
|
struct ConnectTrace {
|
||||||
std::vector<CTransactionRef> txConflicted;
|
|
||||||
std::vector<std::pair<CBlockIndex*, std::shared_ptr<const CBlock> > > blocksConnected;
|
std::vector<std::pair<CBlockIndex*, std::shared_ptr<const CBlock> > > blocksConnected;
|
||||||
};
|
};
|
||||||
|
|
||||||
|
@ -2208,7 +2207,7 @@ bool static ConnectTip(CValidationState& state, const CChainParams& chainparams,
|
||||||
int64_t nTime5 = GetTimeMicros(); nTimeChainState += nTime5 - nTime4;
|
int64_t nTime5 = GetTimeMicros(); nTimeChainState += nTime5 - nTime4;
|
||||||
LogPrint("bench", " - Writing chainstate: %.2fms [%.2fs]\n", (nTime5 - nTime4) * 0.001, nTimeChainState * 0.000001);
|
LogPrint("bench", " - Writing chainstate: %.2fms [%.2fs]\n", (nTime5 - nTime4) * 0.001, nTimeChainState * 0.000001);
|
||||||
// Remove conflicting transactions from the mempool.;
|
// Remove conflicting transactions from the mempool.;
|
||||||
mempool.removeForBlock(blockConnecting.vtx, pindexNew->nHeight, &connectTrace.txConflicted, !IsInitialBlockDownload());
|
mempool.removeForBlock(blockConnecting.vtx, pindexNew->nHeight, !IsInitialBlockDownload());
|
||||||
// Update chainActive & related variables.
|
// Update chainActive & related variables.
|
||||||
UpdateTip(pindexNew, chainparams);
|
UpdateTip(pindexNew, chainparams);
|
||||||
|
|
||||||
|
@ -2433,11 +2432,6 @@ bool ActivateBestChain(CValidationState &state, const CChainParams& chainparams,
|
||||||
|
|
||||||
// throw all transactions though the signal-interface
|
// throw all transactions though the signal-interface
|
||||||
// while _not_ holding the cs_main lock
|
// while _not_ holding the cs_main lock
|
||||||
for (const auto& tx : connectTrace.txConflicted)
|
|
||||||
{
|
|
||||||
GetMainSignals().SyncTransaction(*tx, pindexNewTip, CMainSignals::SYNC_TRANSACTION_NOT_IN_BLOCK);
|
|
||||||
}
|
|
||||||
// ... and about transactions that got confirmed:
|
|
||||||
for (const auto& pair : connectTrace.blocksConnected) {
|
for (const auto& pair : connectTrace.blocksConnected) {
|
||||||
assert(pair.second);
|
assert(pair.second);
|
||||||
const CBlock& block = *(pair.second);
|
const CBlock& block = *(pair.second);
|
||||||
|
|
Loading…
Reference in a new issue