Dash Core Source Documentation (0.16.0.1)

Find detailed information regarding the Dash Core source code.

CTxMemPool stores valid-according-to-the-current-best-chain transactions that may be included in the next block. More...

#include <txmempool.h>

+ Collaboration diagram for CTxMemPool:

Classes

struct  CompareIteratorByHash
 
struct  TxLinks
 

Public Types

typedef boost::multi_index_container< CTxMemPoolEntry, boost::multi_index::indexed_by< boost::multi_index::hashed_unique< mempoolentry_txid, SaltedTxidHasher >, boost::multi_index::ordered_non_unique< boost::multi_index::tag< descendant_score >, boost::multi_index::identity< CTxMemPoolEntry >, CompareTxMemPoolEntryByDescendantScore >, boost::multi_index::ordered_non_unique< boost::multi_index::tag< entry_time >, boost::multi_index::identity< CTxMemPoolEntry >, CompareTxMemPoolEntryByEntryTime >, boost::multi_index::ordered_non_unique< boost::multi_index::tag< ancestor_score >, boost::multi_index::identity< CTxMemPoolEntry >, CompareTxMemPoolEntryByAncestorFee > > > indexed_transaction_set
 
typedef indexed_transaction_set::nth_index< 0 >::type::iterator txiter
 
typedef std::set< txiter, CompareIteratorByHashsetEntries
 

Public Member Functions

const setEntriesGetMemPoolParents (txiter entry) const
 
const setEntriesGetMemPoolChildren (txiter entry) const
 
 CTxMemPool (CBlockPolicyEstimator *estimator=nullptr)
 Create a new CTxMemPool. More...
 
void check (const CCoinsViewCache *pcoins) const
 If sanity-checking is turned on, check makes sure the pool is consistent (does not contain two transactions that spend the same inputs, all inputs are in the mapNextTx array). More...
 
void setSanityCheck (double dFrequency=1.0)
 
bool addUnchecked (const uint256 &hash, const CTxMemPoolEntry &entry, bool validFeeEstimate=true)
 
bool addUnchecked (const uint256 &hash, const CTxMemPoolEntry &entry, setEntries &setAncestors, bool validFeeEstimate=true)
 
void addAddressIndex (const CTxMemPoolEntry &entry, const CCoinsViewCache &view)
 
bool getAddressIndex (std::vector< std::pair< uint160, int > > &addresses, std::vector< std::pair< CMempoolAddressDeltaKey, CMempoolAddressDelta > > &results)
 
bool removeAddressIndex (const uint256 txhash)
 
void addSpentIndex (const CTxMemPoolEntry &entry, const CCoinsViewCache &view)
 
bool getSpentIndex (CSpentIndexKey &key, CSpentIndexValue &value)
 
bool removeSpentIndex (const uint256 txhash)
 
void removeRecursive (const CTransaction &tx, MemPoolRemovalReason reason=MemPoolRemovalReason::UNKNOWN)
 
void removeForReorg (const CCoinsViewCache *pcoins, unsigned int nMemPoolHeight, int flags)
 
void removeConflicts (const CTransaction &tx)
 
void removeProTxPubKeyConflicts (const CTransaction &tx, const CKeyID &keyId)
 
void removeProTxPubKeyConflicts (const CTransaction &tx, const CBLSPublicKey &pubKey)
 
void removeProTxCollateralConflicts (const CTransaction &tx, const COutPoint &collateralOutpoint)
 
void removeProTxSpentCollateralConflicts (const CTransaction &tx)
 
void removeProTxKeyChangedConflicts (const CTransaction &tx, const uint256 &proTxHash, const uint256 &newKeyHash)
 
void removeProTxConflicts (const CTransaction &tx)
 
void removeForBlock (const std::vector< CTransactionRef > &vtx, unsigned int nBlockHeight)
 Called when a block is connected. More...
 
void clear ()
 
void _clear ()
 
bool CompareDepthAndScore (const uint256 &hasha, const uint256 &hashb)
 
void queryHashes (std::vector< uint256 > &vtxid)
 
bool isSpent (const COutPoint &outpoint)
 
unsigned int GetTransactionsUpdated () const
 
void AddTransactionsUpdated (unsigned int n)
 
bool HasNoInputsOf (const CTransaction &tx) const
 Check that none of this transactions inputs are in the mempool, and thus the tx is not dependent on other mempool transactions to be included in a block. More...
 
void PrioritiseTransaction (const uint256 &hash, const CAmount &nFeeDelta)
 Affect CreateNewBlock prioritisation of transactions. More...
 
void ApplyDelta (const uint256 hash, CAmount &nFeeDelta) const
 
void ClearPrioritisation (const uint256 hash)
 
void RemoveStaged (setEntries &stage, bool updateDescendants, MemPoolRemovalReason reason=MemPoolRemovalReason::UNKNOWN)
 Remove a set of transactions from the mempool. More...
 
void UpdateTransactionsFromBlock (const std::vector< uint256 > &vHashesToUpdate)
 When adding transactions from a disconnected block back to the mempool, new mempool entries may have children in the mempool (which is generally not the case when otherwise adding transactions). More...
 
bool CalculateMemPoolAncestors (const CTxMemPoolEntry &entry, setEntries &setAncestors, uint64_t limitAncestorCount, uint64_t limitAncestorSize, uint64_t limitDescendantCount, uint64_t limitDescendantSize, std::string &errString, bool fSearchForParents=true) const
 Try to calculate all in-mempool ancestors of entry. More...
 
void CalculateDescendants (txiter it, setEntries &setDescendants)
 Populate setDescendants with all in-mempool descendants of hash. More...
 
CFeeRate GetMinFee (size_t sizelimit) const
 The minimum fee to get into the mempool, which may itself not be enough for larger-sized transactions. More...
 
void TrimToSize (size_t sizelimit, std::vector< COutPoint > *pvNoSpendsRemaining=nullptr)
 Remove transactions from the mempool until its dynamic size is <= sizelimit. More...
 
int Expire (int64_t time)
 Expire all transaction (and their dependencies) in the mempool older than time. More...
 
bool TransactionWithinChainLimit (const uint256 &txid, size_t chainLimit) const
 Returns false if the transaction is in the mempool and not within the chain limit specified. More...
 
unsigned long size ()
 
uint64_t GetTotalTxSize () const
 
bool exists (uint256 hash) const
 
CTransactionRef get (const uint256 &hash) const
 
TxMempoolInfo info (const uint256 &hash) const
 
std::vector< TxMempoolInfoinfoAll () const
 
bool existsProviderTxConflict (const CTransaction &tx) const
 
size_t DynamicMemoryUsage () const
 

Public Attributes

CCriticalSection cs
 
indexed_transaction_set mapTx
 
std::vector< std::pair< uint256, txiter > > vTxHashes
 All tx hashes/entries in mapTx, in random order. More...
 
indirectmap< COutPoint, const CTransaction * > mapNextTx
 
std::map< uint256, CAmountmapDeltas
 
boost::signals2::signal< void(CTransactionRef)> NotifyEntryAdded
 
boost::signals2::signal< void(CTransactionRef, MemPoolRemovalReason)> NotifyEntryRemoved
 

Static Public Attributes

static const int ROLLING_FEE_HALFLIFE = 60 * 60 * 12
 

Private Types

typedef std::map< txiter, setEntries, CompareIteratorByHashcacheMap
 
typedef std::map< txiter, TxLinks, CompareIteratorByHashtxlinksMap
 
typedef std::map< CMempoolAddressDeltaKey, CMempoolAddressDelta, CMempoolAddressDeltaKeyCompareaddressDeltaMap
 
typedef std::map< uint256, std::vector< CMempoolAddressDeltaKey > > addressDeltaMapInserted
 
typedef std::map< CSpentIndexKey, CSpentIndexValue, CSpentIndexKeyComparemapSpentIndex
 
typedef std::map< uint256, std::vector< CSpentIndexKey > > mapSpentIndexInserted
 

Private Member Functions

void trackPackageRemoved (const CFeeRate &rate)
 
void UpdateParent (txiter entry, txiter parent, bool add)
 
void UpdateChild (txiter entry, txiter child, bool add)
 
std::vector< indexed_transaction_set::const_iterator > GetSortedDepthAndScore () const
 
void UpdateForDescendants (txiter updateIt, cacheMap &cachedDescendants, const std::set< uint256 > &setExclude)
 UpdateForDescendants is used by UpdateTransactionsFromBlock to update the descendants for a single transaction that has been added to the mempool but may have child transactions in the mempool, eg during a chain reorg. More...
 
void UpdateAncestorsOf (bool add, txiter hash, setEntries &setAncestors)
 Update ancestors of hash to add/remove it as a descendant transaction. More...
 
void UpdateEntryForAncestors (txiter it, const setEntries &setAncestors)
 Set ancestor state for an entry. More...
 
void UpdateForRemoveFromMempool (const setEntries &entriesToRemove, bool updateDescendants)
 For each transaction being removed, update ancestors and any direct children. More...
 
void UpdateChildrenForRemoval (txiter entry)
 Sever link between specified transaction and direct children. More...
 
void removeUnchecked (txiter entry, MemPoolRemovalReason reason=MemPoolRemovalReason::UNKNOWN)
 Before calling removeUnchecked for a given transaction, UpdateForRemoveFromMempool must be called on the entire (dependent) set of transactions being removed at the same time. More...
 

Private Attributes

uint32_t nCheckFrequency
 Value n means that n times in 2^32 we check. More...
 
unsigned int nTransactionsUpdated
 Used by getblocktemplate to trigger CreateNewBlock() invocation. More...
 
CBlockPolicyEstimatorminerPolicyEstimator
 
uint64_t totalTxSize
 sum of all mempool tx' byte sizes More...
 
uint64_t cachedInnerUsage
 sum of dynamic memory usage of all the map elements (NOT the maps themselves) More...
 
int64_t lastRollingFeeUpdate
 
bool blockSinceLastRollingFeeBump
 
double rollingMinimumFeeRate
 minimum fee to get into the pool, decreases exponentially More...
 
txlinksMap mapLinks
 
addressDeltaMap mapAddress
 
addressDeltaMapInserted mapAddressInserted
 
mapSpentIndex mapSpent
 
mapSpentIndexInserted mapSpentInserted
 
std::multimap< uint256, uint256mapProTxRefs
 
std::map< CService, uint256mapProTxAddresses
 
std::map< CKeyID, uint256mapProTxPubKeyIDs
 
std::map< uint256, uint256mapProTxBlsPubKeyHashes
 
std::map< COutPoint, uint256mapProTxCollaterals
 

Detailed Description

CTxMemPool stores valid-according-to-the-current-best-chain transactions that may be included in the next block.

Transactions are added when they are seen on the network (or created by the local node), but not all transactions seen are added to the pool. For example, the following new transactions will not be added to the mempool:

  • a transaction which doesn't meet the minimum fee requirements.
  • a new transaction that double-spends an input of a transaction already in the pool.
  • a non-standard transaction.

CTxMemPool::mapTx, and CTxMemPoolEntry bookkeeping:

mapTx is a boost::multi_index that sorts the mempool on 4 criteria:

  • transaction hash
  • feerate [we use max(feerate of tx, feerate of tx with all descendants)]
  • time in mempool

Note: the term "descendant" refers to in-mempool transactions that depend on this one, while "ancestor" refers to in-mempool transactions that a given transaction depends on.

In order for the feerate sort to remain correct, we must update transactions in the mempool when new descendants arrive. To facilitate this, we track the set of in-mempool direct parents and direct children in mapLinks. Within each CTxMemPoolEntry, we track the size and fees of all descendants.

Usually when a new transaction is added to the mempool, it has no in-mempool children (because any such children would be an orphan). So in addUnchecked(), we:

  • update a new entry's setMemPoolParents to include all in-mempool parents
  • update the new entry's direct parents to include the new tx as a child
  • update all ancestors of the transaction to include the new tx's size/fee

When a transaction is removed from the mempool, we must:

  • update all in-mempool parents to not track the tx in setMemPoolChildren
  • update all ancestors to not include the tx's size/fees in descendant state
  • update all in-mempool children to not include it as a parent

These happen in UpdateForRemoveFromMempool(). (Note that when removing a transaction along with its descendants, we must calculate that set of transactions to be removed before doing the removal, or else the mempool can be in an inconsistent state where it's impossible to walk the ancestors of a transaction.)

In the event of a reorg, the assumption that a newly added tx has no in-mempool children is false. In particular, the mempool is in an inconsistent state while new transactions are being added, because there may be descendant transactions of a tx coming from a disconnected block that are unreachable from just looking at transactions in the mempool (the linking transactions may also be in the disconnected block, waiting to be added). Because of this, there's not much benefit in trying to search for in-mempool children in addUnchecked(). Instead, in the special case of transactions being added from a disconnected block, we require the caller to clean up the state, to account for in-mempool, out-of-block descendants for all the in-block transactions by calling UpdateTransactionsFromBlock(). Note that until this is called, the mempool state is not consistent, and in particular mapLinks may not be correct (and therefore functions like CalculateMemPoolAncestors() and CalculateDescendants() that rely on them to walk the mempool are not generally safe to use).

Computational limits:

Updating all in-mempool ancestors of a newly added transaction can be slow, if no bound exists on how many in-mempool ancestors there may be. CalculateMemPoolAncestors() takes configurable limits that are designed to prevent these calculations from being too CPU intensive.

Definition at line 442 of file txmempool.h.

Member Typedef Documentation

◆ addressDeltaMap

◆ addressDeltaMapInserted

typedef std::map<uint256, std::vector<CMempoolAddressDeltaKey> > CTxMemPool::addressDeltaMapInserted
private

Definition at line 517 of file txmempool.h.

◆ cacheMap

Definition at line 504 of file txmempool.h.

◆ indexed_transaction_set

typedef boost::multi_index_container< CTxMemPoolEntry, boost::multi_index::indexed_by< boost::multi_index::hashed_unique<mempoolentry_txid, SaltedTxidHasher>, boost::multi_index::ordered_non_unique< boost::multi_index::tag<descendant_score>, boost::multi_index::identity<CTxMemPoolEntry>, CompareTxMemPoolEntryByDescendantScore >, boost::multi_index::ordered_non_unique< boost::multi_index::tag<entry_time>, boost::multi_index::identity<CTxMemPoolEntry>, CompareTxMemPoolEntryByEntryTime >, boost::multi_index::ordered_non_unique< boost::multi_index::tag<ancestor_score>, boost::multi_index::identity<CTxMemPoolEntry>, CompareTxMemPoolEntryByAncestorFee > > > CTxMemPool::indexed_transaction_set

Definition at line 486 of file txmempool.h.

◆ mapSpentIndex

Definition at line 520 of file txmempool.h.

◆ mapSpentIndexInserted

typedef std::map<uint256, std::vector<CSpentIndexKey> > CTxMemPool::mapSpentIndexInserted
private

Definition at line 523 of file txmempool.h.

◆ setEntries

Definition at line 499 of file txmempool.h.

◆ txiter

typedef indexed_transaction_set::nth_index<0>::type::iterator CTxMemPool::txiter

Definition at line 491 of file txmempool.h.

◆ txlinksMap

Definition at line 511 of file txmempool.h.

Constructor & Destructor Documentation

◆ CTxMemPool()

CTxMemPool::CTxMemPool ( CBlockPolicyEstimator estimator = nullptr)
explicit

Create a new CTxMemPool.

Definition at line 333 of file txmempool.cpp.

References _clear(), and nCheckFrequency.

Member Function Documentation

◆ _clear()

◆ addAddressIndex()

◆ addSpentIndex()

◆ AddTransactionsUpdated()

void CTxMemPool::AddTransactionsUpdated ( unsigned int  n)

◆ addUnchecked() [1/2]

bool CTxMemPool::addUnchecked ( const uint256 hash,
const CTxMemPoolEntry entry,
bool  validFeeEstimate = true 
)

Definition at line 1424 of file txmempool.cpp.

References CalculateMemPoolAncestors(), cs, and LOCK.

Referenced by AcceptToMemoryPoolWorker(), and AddTx().

◆ addUnchecked() [2/2]

◆ ApplyDelta()

void CTxMemPool::ApplyDelta ( const uint256  hash,
CAmount nFeeDelta 
) const

Definition at line 1347 of file txmempool.cpp.

References cs, LOCK, and mapDeltas.

Referenced by AcceptToMemoryPoolWorker().

◆ CalculateDescendants()

void CTxMemPool::CalculateDescendants ( txiter  it,
setEntries setDescendants 
)

Populate setDescendants with all in-mempool descendants of hash.

Assumes that setDescendants includes all in-mempool descendants of anything already in it.

Definition at line 702 of file txmempool.cpp.

References GetMemPoolChildren().

Referenced by Expire(), getmempooldescendants(), PrioritiseTransaction(), removeForReorg(), removeRecursive(), TrimToSize(), UpdateForRemoveFromMempool(), and BlockAssembler::UpdatePackagesForAdded().

◆ CalculateMemPoolAncestors()

bool CTxMemPool::CalculateMemPoolAncestors ( const CTxMemPoolEntry entry,
setEntries setAncestors,
uint64_t  limitAncestorCount,
uint64_t  limitAncestorSize,
uint64_t  limitDescendantCount,
uint64_t  limitDescendantSize,
std::string &  errString,
bool  fSearchForParents = true 
) const

Try to calculate all in-mempool ancestors of entry.

(these are all calculated including the tx itself) limitAncestorCount = max number of ancestors limitAncestorSize = max size of ancestors limitDescendantCount = max number of descendants any ancestor can have limitDescendantSize = max size of descendants any ancestor can have errString = populated with error reason if any limits are hit fSearchForParents = whether to search a tx's vin for in-mempool parents, or look up parents from mapLinks. Must be true for entries not in the mempool

Definition at line 154 of file txmempool.cpp.

References cs, GetMemPoolParents(), CTxMemPoolEntry::GetTx(), CTxMemPoolEntry::GetTxSize(), LOCK, mapTx, strprintf, and CTransaction::vin.

Referenced by AcceptToMemoryPoolWorker(), BlockAssembler::addPackageTxs(), addUnchecked(), check(), CWallet::CreateTransaction(), getmempoolancestors(), PrioritiseTransaction(), and UpdateForRemoveFromMempool().

◆ check()

◆ clear()

void CTxMemPool::clear ( )

Definition at line 998 of file txmempool.cpp.

References _clear(), cs, and LOCK.

Referenced by UnloadBlockIndex().

◆ ClearPrioritisation()

void CTxMemPool::ClearPrioritisation ( const uint256  hash)

Definition at line 1357 of file txmempool.cpp.

References cs, LOCK, and mapDeltas.

Referenced by removeConflicts(), and removeForBlock().

◆ CompareDepthAndScore()

bool CTxMemPool::CompareDepthAndScore ( const uint256 hasha,
const uint256 hashb 
)

Definition at line 1135 of file txmempool.cpp.

References cs, LOCK, and mapTx.

Referenced by CompareInvMempoolOrder::operator()().

◆ DynamicMemoryUsage()

◆ exists()

◆ existsProviderTxConflict()

◆ Expire()

int CTxMemPool::Expire ( int64_t  time)

Expire all transaction (and their dependencies) in the mempool older than time.

Return the number of removed transactions.

Definition at line 1403 of file txmempool.cpp.

References CalculateDescendants(), cs, EXPIRY, LOCK, mapTx, llmq::quorumInstantSendManager, and RemoveStaged().

Referenced by LimitMempoolSize().

◆ get()

◆ getAddressIndex()

bool CTxMemPool::getAddressIndex ( std::vector< std::pair< uint160, int > > &  addresses,
std::vector< std::pair< CMempoolAddressDeltaKey, CMempoolAddressDelta > > &  results 
)

Definition at line 525 of file txmempool.cpp.

References cs, LOCK, and mapAddress.

Referenced by getaddressmempool().

◆ GetMemPoolChildren()

const CTxMemPool::setEntries & CTxMemPool::GetMemPoolChildren ( txiter  entry) const

Definition at line 1462 of file txmempool.cpp.

References mapLinks, and mapTx.

Referenced by CalculateDescendants(), check(), UpdateChildrenForRemoval(), and UpdateForDescendants().

◆ GetMemPoolParents()

const CTxMemPool::setEntries & CTxMemPool::GetMemPoolParents ( txiter  entry) const

Definition at line 1454 of file txmempool.cpp.

References mapLinks, and mapTx.

Referenced by CalculateMemPoolAncestors(), check(), and UpdateAncestorsOf().

◆ GetMinFee()

CFeeRate CTxMemPool::GetMinFee ( size_t  sizelimit) const

The minimum fee to get into the mempool, which may itself not be enough for larger-sized transactions.

The incrementalRelayFee policy variable is used to bound the time it takes the fee rate to go back down all the way to 0. When the feerate would otherwise be half of this, it is set to 0 instead.

Definition at line 1470 of file txmempool.cpp.

References blockSinceLastRollingFeeBump, cs, DynamicMemoryUsage(), CFeeRate::GetFeePerK(), GetTime(), incrementalRelayFee, lastRollingFeeUpdate, LOCK, ROLLING_FEE_HALFLIFE, and rollingMinimumFeeRate.

Referenced by AcceptToMemoryPoolWorker(), GetMinimumFee(), and mempoolInfoToJSON().

◆ GetSortedDepthAndScore()

std::vector< CTxMemPool::indexed_transaction_set::const_iterator > CTxMemPool::GetSortedDepthAndScore ( ) const
private

Definition at line 1166 of file txmempool.cpp.

References AssertLockHeld(), cs, and mapTx.

Referenced by infoAll(), and queryHashes().

◆ getSpentIndex()

bool CTxMemPool::getSpentIndex ( CSpentIndexKey key,
CSpentIndexValue value 
)

Definition at line 595 of file txmempool.cpp.

References cs, LOCK, and mapSpent.

Referenced by GetSpentIndex().

◆ GetTotalTxSize()

uint64_t CTxMemPool::GetTotalTxSize ( ) const
inline

Definition at line 666 of file txmempool.h.

References cs, LOCK, and totalTxSize.

Referenced by mempoolInfoToJSON().

◆ GetTransactionsUpdated()

unsigned int CTxMemPool::GetTransactionsUpdated ( ) const

Definition at line 350 of file txmempool.cpp.

References cs, LOCK, and nTransactionsUpdated.

Referenced by getblocktemplate().

◆ HasNoInputsOf()

bool CTxMemPool::HasNoInputsOf ( const CTransaction tx) const

Check that none of this transactions inputs are in the mempool, and thus the tx is not dependent on other mempool transactions to be included in a block.

Definition at line 1363 of file txmempool.cpp.

References exists(), and CTransaction::vin.

Referenced by AcceptToMemoryPoolWorker().

◆ info()

TxMempoolInfo CTxMemPool::info ( const uint256 hash) const

Definition at line 1220 of file txmempool.cpp.

References cs, GetInfo(), LOCK, and mapTx.

Referenced by ProcessGetData(), and PeerLogicValidation::SendMessages().

◆ infoAll()

std::vector< TxMempoolInfo > CTxMemPool::infoAll ( ) const

Definition at line 1197 of file txmempool.cpp.

References cs, GetInfo(), GetSortedDepthAndScore(), LOCK, and mapTx.

Referenced by DumpMempool(), and PeerLogicValidation::SendMessages().

◆ isSpent()

bool CTxMemPool::isSpent ( const COutPoint outpoint)

Definition at line 344 of file txmempool.cpp.

References indirectmap< K, T >::count(), cs, LOCK, and mapNextTx.

Referenced by gettxout(), CPrivateSend::IsCollateralValid(), and rest_getutxos().

◆ PrioritiseTransaction()

void CTxMemPool::PrioritiseTransaction ( const uint256 hash,
const CAmount nFeeDelta 
)

◆ queryHashes()

void CTxMemPool::queryHashes ( std::vector< uint256 > &  vtxid)

Definition at line 1180 of file txmempool.cpp.

References cs, GetSortedDepthAndScore(), LOCK, and mapTx.

Referenced by CBlockPolicyEstimator::FlushUnconfirmed(), and mempoolToJSON().

◆ removeAddressIndex()

bool CTxMemPool::removeAddressIndex ( const uint256  txhash)

Definition at line 539 of file txmempool.cpp.

References cs, LOCK, mapAddress, and mapAddressInserted.

Referenced by removeUnchecked().

◆ removeConflicts()

◆ removeForBlock()

void CTxMemPool::removeForBlock ( const std::vector< CTransactionRef > &  vtx,
unsigned int  nBlockHeight 
)

Called when a block is connected.

Removes from mempool and updates the miner fee estimator.

Definition at line 953 of file txmempool.cpp.

References BLOCK, blockSinceLastRollingFeeBump, ClearPrioritisation(), cs, GetTime(), lastRollingFeeUpdate, LOCK, mapTx, minerPolicyEstimator, CBlockPolicyEstimator::processBlock(), removeConflicts(), removeProTxConflicts(), and RemoveStaged().

Referenced by CChainState::ConnectTip().

◆ removeForReorg()

◆ removeProTxCollateralConflicts()

void CTxMemPool::removeProTxCollateralConflicts ( const CTransaction tx,
const COutPoint collateralOutpoint 
)

◆ removeProTxConflicts()

◆ removeProTxKeyChangedConflicts()

void CTxMemPool::removeProTxKeyChangedConflicts ( const CTransaction tx,
const uint256 proTxHash,
const uint256 newKeyHash 
)

Definition at line 877 of file txmempool.cpp.

References CONFLICT, mapProTxRefs, mapTx, and removeRecursive().

Referenced by removeProTxConflicts().

◆ removeProTxPubKeyConflicts() [1/2]

void CTxMemPool::removeProTxPubKeyConflicts ( const CTransaction tx,
const CKeyID keyId 
)

Definition at line 811 of file txmempool.cpp.

References CONFLICT, CTransaction::GetHash(), mapProTxPubKeyIDs, mapTx, and removeRecursive().

Referenced by removeProTxConflicts().

◆ removeProTxPubKeyConflicts() [2/2]

void CTxMemPool::removeProTxPubKeyConflicts ( const CTransaction tx,
const CBLSPublicKey pubKey 
)

◆ removeProTxSpentCollateralConflicts()

void CTxMemPool::removeProTxSpentCollateralConflicts ( const CTransaction tx)

◆ removeRecursive()

◆ removeSpentIndex()

bool CTxMemPool::removeSpentIndex ( const uint256  txhash)

Definition at line 608 of file txmempool.cpp.

References cs, LOCK, mapSpent, and mapSpentInserted.

Referenced by removeUnchecked().

◆ RemoveStaged()

void CTxMemPool::RemoveStaged ( setEntries stage,
bool  updateDescendants,
MemPoolRemovalReason  reason = MemPoolRemovalReason::UNKNOWN 
)

Remove a set of transactions from the mempool.

If a transaction is in this set, then all in-mempool descendants must also be in the set, unless this transaction is being removed for being in a block. Set updateDescendants to true when removing a tx that was in a block, so that any in-mempool descendants have their ancestor state updated.

Definition at line 1395 of file txmempool.cpp.

References AssertLockHeld(), cs, removeUnchecked(), and UpdateForRemoveFromMempool().

Referenced by Expire(), removeForBlock(), removeForReorg(), removeRecursive(), and TrimToSize().

◆ removeUnchecked()

void CTxMemPool::removeUnchecked ( txiter  entry,
MemPoolRemovalReason  reason = MemPoolRemovalReason::UNKNOWN 
)
private

◆ setSanityCheck()

void CTxMemPool::setSanityCheck ( double  dFrequency = 1.0)
inline

Definition at line 552 of file txmempool.h.

References nCheckFrequency.

Referenced by AppInitParameterInteraction().

◆ size()

unsigned long CTxMemPool::size ( )
inline

Definition at line 660 of file txmempool.h.

References cs, LOCK, and mapTx.

Referenced by ClientModel::getMempoolSize(), getmininginfo(), mempoolInfoToJSON(), and ProcessMessage().

◆ trackPackageRemoved()

void CTxMemPool::trackPackageRemoved ( const CFeeRate rate)
private

◆ TransactionWithinChainLimit()

bool CTxMemPool::TransactionWithinChainLimit ( const uint256 txid,
size_t  chainLimit 
) const

Returns false if the transaction is in the mempool and not within the chain limit specified.

Definition at line 1545 of file txmempool.cpp.

References cs, LOCK, and mapTx.

Referenced by CWallet::SelectCoinsMinConf().

◆ TrimToSize()

void CTxMemPool::TrimToSize ( size_t  sizelimit,
std::vector< COutPoint > *  pvNoSpendsRemaining = nullptr 
)

Remove transactions from the mempool until its dynamic size is <= sizelimit.

pvNoSpendsRemaining, if set, will be populated with the list of outpoints which are not in mempool which no longer have any spends in this mempool.

Definition at line 1502 of file txmempool.cpp.

References CalculateDescendants(), cs, DynamicMemoryUsage(), exists(), COutPoint::hash, incrementalRelayFee, LOCK, LogPrint, mapTx, BCLog::MEMPOOL, CTxIn::prevout, RemoveStaged(), SIZELIMIT, CFeeRate::ToString(), and trackPackageRemoved().

Referenced by LimitMempoolSize(), and MempoolEviction().

◆ UpdateAncestorsOf()

void CTxMemPool::UpdateAncestorsOf ( bool  add,
txiter  hash,
setEntries setAncestors 
)
private

Update ancestors of hash to add/remove it as a descendant transaction.

Definition at line 218 of file txmempool.cpp.

References GetMemPoolParents(), mapTx, and UpdateChild().

Referenced by addUnchecked(), and UpdateForRemoveFromMempool().

◆ UpdateChild()

void CTxMemPool::UpdateChild ( txiter  entry,
txiter  child,
bool  add 
)
private

◆ UpdateChildrenForRemoval()

void CTxMemPool::UpdateChildrenForRemoval ( txiter  entry)
private

Sever link between specified transaction and direct children.

Definition at line 247 of file txmempool.cpp.

References GetMemPoolChildren(), and UpdateParent().

Referenced by UpdateForRemoveFromMempool().

◆ UpdateEntryForAncestors()

void CTxMemPool::UpdateEntryForAncestors ( txiter  it,
const setEntries setAncestors 
)
private

Set ancestor state for an entry.

Definition at line 233 of file txmempool.cpp.

References mapTx.

Referenced by addUnchecked().

◆ UpdateForDescendants()

void CTxMemPool::UpdateForDescendants ( txiter  updateIt,
cacheMap cachedDescendants,
const std::set< uint256 > &  setExclude 
)
private

UpdateForDescendants is used by UpdateTransactionsFromBlock to update the descendants for a single transaction that has been added to the mempool but may have child transactions in the mempool, eg during a chain reorg.

setExclude is the set of descendant transactions in the mempool that must not be accounted for (because any descendants in setExclude were added to the mempool after the transaction being updated and hence their state is already reflected in the parent state).

cachedDescendants will be updated with the descendants of the transaction being updated, so that future invocations don't need to walk the same transaction again, if encountered in another transaction chain.

Definition at line 64 of file txmempool.cpp.

References GetMemPoolChildren(), and mapTx.

Referenced by UpdateTransactionsFromBlock().

◆ UpdateForRemoveFromMempool()

void CTxMemPool::UpdateForRemoveFromMempool ( const setEntries entriesToRemove,
bool  updateDescendants 
)
private

For each transaction being removed, update ancestors and any direct children.

If updateDescendants is true, then also update in-mempool descendants' ancestor state.

Definition at line 255 of file txmempool.cpp.

References CalculateDescendants(), CalculateMemPoolAncestors(), mapTx, UpdateAncestorsOf(), and UpdateChildrenForRemoval().

Referenced by RemoveStaged().

◆ UpdateParent()

void CTxMemPool::UpdateParent ( txiter  entry,
txiter  parent,
bool  add 
)
private

◆ UpdateTransactionsFromBlock()

void CTxMemPool::UpdateTransactionsFromBlock ( const std::vector< uint256 > &  vHashesToUpdate)

When adding transactions from a disconnected block back to the mempool, new mempool entries may have children in the mempool (which is generally not the case when otherwise adding transactions).

UpdateTransactionsFromBlock() will find child transactions and update the descendant state for each transaction in vHashesToUpdate (excluding any child transactions present in vHashesToUpdate, which are already accounted for). Note: vHashesToUpdate should be the set of transactions from the disconnected block that have been accepted back into the mempool.

Definition at line 111 of file txmempool.cpp.

References cs, indirectmap< K, T >::end(), LOCK, indirectmap< K, T >::lower_bound(), mapNextTx, mapTx, reverse_iterate(), UpdateChild(), UpdateForDescendants(), and UpdateParent().

Referenced by UpdateMempoolForReorg().

Member Data Documentation

◆ blockSinceLastRollingFeeBump

bool CTxMemPool::blockSinceLastRollingFeeBump
mutableprivate

Definition at line 453 of file txmempool.h.

Referenced by _clear(), GetMinFee(), removeForBlock(), and trackPackageRemoved().

◆ cachedInnerUsage

uint64_t CTxMemPool::cachedInnerUsage
private

sum of dynamic memory usage of all the map elements (NOT the maps themselves)

Definition at line 450 of file txmempool.h.

Referenced by _clear(), addUnchecked(), check(), DynamicMemoryUsage(), removeUnchecked(), UpdateChild(), and UpdateParent().

◆ cs

CCriticalSection CTxMemPool::cs
mutable

Definition at line 488 of file txmempool.h.

Referenced by AcceptToMemoryPoolWorker(), addAddressIndex(), addSpentIndex(), AddTransactionsUpdated(), addUnchecked(), ApplyDelta(), CalculateMemPoolAncestors(), check(), CheckInputsFromMempoolAndCache(), CheckSequenceLocks(), llmq::CChainLocksHandler::Cleanup(), clear(), ClearPrioritisation(), combinerawtransaction(), CWallet::CommitTransaction(), CompareDepthAndScore(), CPrivateSendClientSession::CreateDenominated(), BlockAssembler::CreateNewBlock(), CWallet::CreateTransaction(), CPrivateSendClientSession::DoAutomaticDenominating(), DumpMempool(), DynamicMemoryUsage(), entryToJSON(), exists(), existsProviderTxConflict(), Expire(), CWallet::FundTransaction(), get(), getAddressIndex(), getmempoolancestors(), getmempooldescendants(), getmempoolentry(), GetMinFee(), GetSortedDepthAndScore(), getSpentIndex(), GetTotalTxSize(), GetTransactionsUpdated(), gettxout(), info(), infoAll(), PartiallyDownloadedBlock::InitData(), isSpent(), CPrivateSendClientSession::MakeCollateralAmounts(), mempoolToJSON(), WalletModel::prepareTransaction(), PrioritiseTransaction(), queryHashes(), CWallet::ReacceptWalletTransactions(), removeAddressIndex(), removeConflicts(), removeForBlock(), removeForReorg(), llmq::CInstantSendManager::RemoveMempoolConflictsForLock(), removeRecursive(), removeSpentIndex(), RemoveStaged(), resendwallettransactions(), CWallet::ResendWalletTransactionsBefore(), rest_getutxos(), WalletModel::sendCoins(), sendfrom(), sendmany(), PeerLogicValidation::SendMessages(), sendtoaddress(), signrawtransaction(), size(), CPrivateSendClientSession::SubmitDenominate(), trackPackageRemoved(), TransactionWithinChainLimit(), TrimToSize(), and UpdateTransactionsFromBlock().

◆ lastRollingFeeUpdate

int64_t CTxMemPool::lastRollingFeeUpdate
mutableprivate

Definition at line 452 of file txmempool.h.

Referenced by _clear(), GetMinFee(), and removeForBlock().

◆ mapAddress

addressDeltaMap CTxMemPool::mapAddress
private

Definition at line 515 of file txmempool.h.

Referenced by addAddressIndex(), getAddressIndex(), and removeAddressIndex().

◆ mapAddressInserted

addressDeltaMapInserted CTxMemPool::mapAddressInserted
private

Definition at line 518 of file txmempool.h.

Referenced by addAddressIndex(), and removeAddressIndex().

◆ mapDeltas

std::map<uint256, CAmount> CTxMemPool::mapDeltas

◆ mapLinks

◆ mapNextTx

◆ mapProTxAddresses

std::map<CService, uint256> CTxMemPool::mapProTxAddresses
private

◆ mapProTxBlsPubKeyHashes

std::map<uint256, uint256> CTxMemPool::mapProTxBlsPubKeyHashes
private

◆ mapProTxCollaterals

std::map<COutPoint, uint256> CTxMemPool::mapProTxCollaterals
private

◆ mapProTxPubKeyIDs

std::map<CKeyID, uint256> CTxMemPool::mapProTxPubKeyIDs
private

◆ mapProTxRefs

std::multimap<uint256, uint256> CTxMemPool::mapProTxRefs
private

◆ mapSpent

mapSpentIndex CTxMemPool::mapSpent
private

Definition at line 521 of file txmempool.h.

Referenced by addSpentIndex(), getSpentIndex(), and removeSpentIndex().

◆ mapSpentInserted

mapSpentIndexInserted CTxMemPool::mapSpentInserted
private

Definition at line 524 of file txmempool.h.

Referenced by addSpentIndex(), and removeSpentIndex().

◆ mapTx

◆ minerPolicyEstimator

CBlockPolicyEstimator* CTxMemPool::minerPolicyEstimator
private

Definition at line 447 of file txmempool.h.

Referenced by addUnchecked(), removeForBlock(), and removeUnchecked().

◆ nCheckFrequency

uint32_t CTxMemPool::nCheckFrequency
private

Value n means that n times in 2^32 we check.

Definition at line 445 of file txmempool.h.

Referenced by check(), CTxMemPool(), removeForReorg(), and setSanityCheck().

◆ NotifyEntryAdded

boost::signals2::signal<void (CTransactionRef)> CTxMemPool::NotifyEntryAdded

Definition at line 686 of file txmempool.h.

Referenced by addUnchecked().

◆ NotifyEntryRemoved

◆ nTransactionsUpdated

unsigned int CTxMemPool::nTransactionsUpdated
private

Used by getblocktemplate to trigger CreateNewBlock() invocation.

Definition at line 446 of file txmempool.h.

Referenced by _clear(), AddTransactionsUpdated(), addUnchecked(), GetTransactionsUpdated(), PrioritiseTransaction(), and removeUnchecked().

◆ ROLLING_FEE_HALFLIFE

const int CTxMemPool::ROLLING_FEE_HALFLIFE = 60 * 60 * 12
static

Definition at line 460 of file txmempool.h.

Referenced by GetMinFee().

◆ rollingMinimumFeeRate

double CTxMemPool::rollingMinimumFeeRate
mutableprivate

minimum fee to get into the pool, decreases exponentially

Definition at line 454 of file txmempool.h.

Referenced by _clear(), GetMinFee(), and trackPackageRemoved().

◆ totalTxSize

uint64_t CTxMemPool::totalTxSize
private

sum of all mempool tx' byte sizes

Definition at line 449 of file txmempool.h.

Referenced by _clear(), addUnchecked(), check(), GetTotalTxSize(), and removeUnchecked().

◆ vTxHashes

std::vector<std::pair<uint256, txiter> > CTxMemPool::vTxHashes

All tx hashes/entries in mapTx, in random order.

Definition at line 492 of file txmempool.h.

Referenced by addUnchecked(), DynamicMemoryUsage(), PartiallyDownloadedBlock::InitData(), and removeUnchecked().


The documentation for this class was generated from the following files:
Released under the MIT license