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

#include <txmempool.h>

Inheritance diagram for CTxMemPool:

[legend]

Collaboration diagram for CTxMemPool:

[legend]

Classes
class	ChangeSet

struct	CTxMemPoolEntry_Indices

struct	delta_info

Public Types
typedef boost::multi_index_container< CTxMemPoolEntry, CTxMemPoolEntry_Indices >	indexed_transaction_set

using	txiter = indexed_transaction_set::nth_index< 0 >::type::const_iterator

typedef std::set< txiter, CompareIteratorByHash >	setEntries

using	Limits = kernel::MemPoolLimits

using	Options = kernel::MemPoolOptions

Public Member Functions
std::unique_ptr< TxGraph > m_txgraph	GUARDED_BY (cs)

std::unique_ptr< TxGraph::BlockBuilder > m_builder	GUARDED_BY (cs)

indexed_transaction_set mapTx	GUARDED_BY (cs)

std::vector< std::pair< Wtxid, txiter > > txns_randomized	GUARDED_BY (cs)
	All transactions in mapTx with their wtxids, in arbitrary order. More...

std::tuple< size_t, size_t, CAmount >	CalculateAncestorData (const CTxMemPoolEntry &entry) const EXCLUSIVE_LOCKS_REQUIRED(cs)

std::tuple< size_t, size_t, CAmount >	CalculateDescendantData (const CTxMemPoolEntry &entry) const EXCLUSIVE_LOCKS_REQUIRED(cs)

int64_t	GetDescendantCount (txiter it) const

int64_t	GetDescendantCount (const CTxMemPoolEntry &e) const

int64_t	GetAncestorCount (const CTxMemPoolEntry &e) const

std::vector< CTxMemPoolEntry::CTxMemPoolEntryRef >	GetChildren (const CTxMemPoolEntry &entry) const

std::vector< CTxMemPoolEntry::CTxMemPoolEntryRef >	GetParents (const CTxMemPoolEntry &entry) const

indirectmap< COutPoint, txiter > mapNextTx	GUARDED_BY (cs)

std::map< Txid, CAmount > mapDeltas	GUARDED_BY (cs)

	CTxMemPool (Options opts, bilingual_str &error)
	Create a new CTxMemPool. More...

void	removeForReorg (CChain &chain, std::function< bool(txiter)> filter_final_and_mature) EXCLUSIVE_LOCKS_REQUIRED(cs
	After reorg, filter the entries that would no longer be valid in the next block, and update the entries' cached LockPoints if needed. More...

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

bool	CompareMiningScoreWithTopology (const Wtxid &hasha, const Wtxid &hashb) const

bool	isSpent (const COutPoint &outpoint) const

unsigned int	GetTransactionsUpdated () const

void	AddTransactionsUpdated (unsigned int n)

bool	HasNoInputsOf (const CTransaction &tx) const EXCLUSIVE_LOCKS_REQUIRED(cs)
	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 Txid &hash, const CAmount &nFeeDelta)
	Affect CreateNewBlock prioritisation of transactions. More...

void	ApplyDelta (const Txid &hash, CAmount &nFeeDelta) const EXCLUSIVE_LOCKS_REQUIRED(cs)

void	ClearPrioritisation (const Txid &hash) EXCLUSIVE_LOCKS_REQUIRED(cs)

std::vector< delta_info >	GetPrioritisedTransactions () const EXCLUSIVE_LOCKS_REQUIRED(!cs)
	Return a vector of all entries in mapDeltas with their corresponding delta_info. More...

const CTransaction *	GetConflictTx (const COutPoint &prevout) const EXCLUSIVE_LOCKS_REQUIRED(cs)
	Get the transaction in the pool that spends the same prevout. More...

std::optional< txiter >	GetIter (const Txid &txid) const EXCLUSIVE_LOCKS_REQUIRED(cs)
	Returns an iterator to the given hash, if found. More...

std::optional< txiter >	GetIter (const Wtxid &wtxid) const EXCLUSIVE_LOCKS_REQUIRED(cs)

setEntries	GetIterSet (const std::set< Txid > &hashes) const EXCLUSIVE_LOCKS_REQUIRED(cs)
	Translate a set of hashes into a set of pool iterators to avoid repeated lookups. More...

std::vector< txiter >	GetIterVec (const std::vector< Txid > &txids) const EXCLUSIVE_LOCKS_REQUIRED(cs)
	Translate a list of hashes into a list of mempool iterators to avoid repeated lookups. More...

void	UpdateTransactionsFromBlock (const std::vector< Txid > &vHashesToUpdate) EXCLUSIVE_LOCKS_REQUIRED(cs
	UpdateTransactionsFromBlock is called 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...

void cs_main	LOCKS_EXCLUDED (m_epoch)

std::vector< FeePerWeight >	GetFeerateDiagram () const EXCLUSIVE_LOCKS_REQUIRED(cs)

FeePerWeight	GetMainChunkFeerate (const CTxMemPoolEntry &tx) const EXCLUSIVE_LOCKS_REQUIRED(cs)

std::vector< const CTxMemPoolEntry * >	GetCluster (Txid txid) const EXCLUSIVE_LOCKS_REQUIRED(cs)

size_t	GetUniqueClusterCount (const setEntries &iters_conflicting) const EXCLUSIVE_LOCKS_REQUIRED(cs)

setEntries	CalculateMemPoolAncestors (const CTxMemPoolEntry &entry) const EXCLUSIVE_LOCKS_REQUIRED(cs)
	Calculate all in-mempool ancestors of entry (not including the tx itself) More...

bool	HasDescendants (const Txid &txid) const

std::vector< txiter >	GatherClusters (const std::vector< Txid > &txids) const EXCLUSIVE_LOCKS_REQUIRED(cs)
	Collect the entire cluster of connected transactions for each transaction in txids. More...

void	CalculateDescendants (txiter it, setEntries &setDescendants) const EXCLUSIVE_LOCKS_REQUIRED(cs)
	Populate setDescendants with all in-mempool descendants of given transaction. More...

CTxMemPool::txiter	CalculateDescendants (const CTxMemPoolEntry &entry, setEntries &setDescendants) const EXCLUSIVE_LOCKS_REQUIRED(cs)

CFeeRate	GetMinFee () 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) EXCLUSIVE_LOCKS_REQUIRED(cs)
	Remove transactions from the mempool until its dynamic size is <= sizelimit. More...

int	Expire (std::chrono::seconds time) EXCLUSIVE_LOCKS_REQUIRED(cs)
	Expire all transaction (and their dependencies) in the mempool older than time. More...

void	GetTransactionAncestry (const Txid &txid, size_t &ancestors, size_t &cluster_count, size_t ancestorsize=nullptr, CAmount ancestorfees=nullptr) const
	Calculate the ancestor and cluster count for the given transaction. More...

bool	GetLoadTried () const

void	SetLoadTried (bool load_tried)
	Set whether or not an initial attempt to load the persisted mempool was made (regardless of whether the attempt was successful or not) More...

unsigned long	size () const

uint64_t	GetTotalTxSize () const EXCLUSIVE_LOCKS_REQUIRED(cs)

CAmount	GetTotalFee () const EXCLUSIVE_LOCKS_REQUIRED(cs)

bool	exists (const Txid &txid) const

bool	exists (const Wtxid &wtxid) const

const CTxMemPoolEntry *	GetEntry (const Txid &txid) const LIFETIMEBOUND EXCLUSIVE_LOCKS_REQUIRED(cs)

CTransactionRef	get (const Txid &hash) const

template<TxidOrWtxid T>
TxMempoolInfo	info (const T &id) const

template<TxidOrWtxid T>
TxMempoolInfo	info_for_relay (const T &id, uint64_t last_sequence) const
	Returns info for a transaction if its entry_sequence < last_sequence. More...

std::vector< CTxMemPoolEntryRef >	entryAll () const EXCLUSIVE_LOCKS_REQUIRED(cs)

std::vector< TxMempoolInfo >	infoAll () const

size_t	DynamicMemoryUsage () const

void	AddUnbroadcastTx (const Txid &txid)
	Adds a transaction to the unbroadcast set. More...

bool	CheckPolicyLimits (const CTransactionRef &tx)

void	RemoveUnbroadcastTx (const Txid &txid, const bool unchecked=false)
	Removes a transaction from the unbroadcast set. More...

std::set< Txid >	GetUnbroadcastTxs () const
	Returns transactions in unbroadcast set. More...

bool	IsUnbroadcastTx (const Txid &txid) const EXCLUSIVE_LOCKS_REQUIRED(cs)
	Returns whether a txid is in the unbroadcast set. More...

uint64_t	GetAndIncrementSequence () const EXCLUSIVE_LOCKS_REQUIRED(cs)
	Guards this internal counter for external reporting. More...

uint64_t	GetSequence () const EXCLUSIVE_LOCKS_REQUIRED(cs)

bool	visited (const txiter it) const EXCLUSIVE_LOCKS_REQUIRED(cs
	visited marks a CTxMemPoolEntry as having been traversed during the lifetime of the most recently created Epoch::Guard and returns false if we are the first visitor, true otherwise. More...

bool	visited (std::optional< txiter > it) const EXCLUSIVE_LOCKS_REQUIRED(cs

std::unique_ptr< ChangeSet >	GetChangeSet () EXCLUSIVE_LOCKS_REQUIRED(cs)

bool m_have_changeset	GUARDED_BY (cs)

void	StartBlockBuilding () const EXCLUSIVE_LOCKS_REQUIRED(cs)

FeePerWeight	GetBlockBuilderChunk (std::vector< CTxMemPoolEntry::CTxMemPoolEntryRef > &entries) const EXCLUSIVE_LOCKS_REQUIRED(cs)

void	IncludeBuilderChunk () const EXCLUSIVE_LOCKS_REQUIRED(cs)

void	SkipBuilderChunk () const EXCLUSIVE_LOCKS_REQUIRED(cs)

void	StopBlockBuilding () const EXCLUSIVE_LOCKS_REQUIRED(cs)

Public Attributes
RecursiveMutex	cs
	This mutex needs to be locked when accessing `mapTx` or other members that are guarded by it. More...

const Options	m_opts

void check(const CCoinsViewCache &active_coins_tip, int64_t spendheight) const EXCLUSIVE_LOCKS_REQUIRED(void	removeRecursive (const CTransaction &tx, MemPoolRemovalReason reason) EXCLUSIVE_LOCKS_REQUIRED(cs)
	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	cs_main

bool	m_epoch

return !it visited *	it

Static Public Attributes
static const int	ROLLING_FEE_HALFLIFE = 60 * 60 * 12

Protected Member Functions
uint64_t totalTxSize	GUARDED_BY (cs)

CAmount m_total_fee	GUARDED_BY (cs)
	sum of all mempool tx's virtual sizes. Differs from serialized tx size since witness data is discounted. Defined in BIP 141. More...

uint64_t cachedInnerUsage	GUARDED_BY (cs)
	sum of all mempool tx's fees (NOT modified fee) More...

int64_t lastRollingFeeUpdate	GUARDED_BY (cs)
	sum of dynamic memory usage of all the map elements (NOT the maps themselves) More...

bool blockSinceLastRollingFeeBump	GUARDED_BY (cs)

double rollingMinimumFeeRate	GUARDED_BY (cs)

Epoch m_epoch	GUARDED_BY (cs)
	minimum fee to get into the pool, decreases exponentially More...

uint64_t m_sequence_number	GUARDED_BY (cs)

void	trackPackageRemoved (const CFeeRate &rate) EXCLUSIVE_LOCKS_REQUIRED(cs)

bool m_load_tried	GUARDED_BY (cs)

CFeeRate	GetMinFee (size_t sizelimit) const

Protected Attributes
std::atomic< unsigned int >	nTransactionsUpdated {0}
	Used by getblocktemplate to trigger CreateNewBlock() invocation. More...

Private Member Functions
std::vector< indexed_transaction_set::const_iterator >	GetSortedScoreWithTopology () const EXCLUSIVE_LOCKS_REQUIRED(cs)

std::set< Txid > m_unbroadcast_txids	GUARDED_BY (cs)
	Track locally submitted transactions to periodically retry initial broadcast. More...

void	removeConflicts (const CTransaction &tx) EXCLUSIVE_LOCKS_REQUIRED(cs)

void	RemoveStaged (setEntries &stage, MemPoolRemovalReason reason) EXCLUSIVE_LOCKS_REQUIRED(cs)
	Remove a set of transactions from the mempool. More...

void	removeRecursive (txiter to_remove, MemPoolRemovalReason reason) EXCLUSIVE_LOCKS_REQUIRED(cs)

void	removeUnchecked (txiter entry, MemPoolRemovalReason reason) EXCLUSIVE_LOCKS_REQUIRED(cs)
	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...

void	Apply (CTxMemPool::ChangeSet *changeset) EXCLUSIVE_LOCKS_REQUIRED(cs)

void	addNewTransaction (CTxMemPool::txiter it) EXCLUSIVE_LOCKS_REQUIRED(cs)

Static Private Member Functions
static TxMempoolInfo	GetInfo (CTxMemPool::indexed_transaction_set::const_iterator it)

Friends
class	CTxMemPool::ChangeSet

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 where the new transaction does not meet the Replace-By-Fee requirements as defined in doc/policy/mempool-replacements.md.
a non-standard transaction.

TxGraph (CTxMemPool::m_txgraph) provides an abstraction layer for separating the transaction graph parts of the mempool from the rest of the Bitcoin-specific logic. Specifically, TxGraph handles (for each transaction) managing the in-mempool parents and children, and has knowledge of the fee and size of every transaction. It uses this to partition the mempool into connected clusters, and it implements (among other things):

limits on the size of a cluster (in both number of transactions and total weight)
sorting the mempool optimally for block inclusion, taking into account dependencies
selecting transactions for removal due to cluster size limit violations after a reorg. See txgraph.h and txgraph.cpp for more details.

CTxMemPool itself handles the Bitcoin-specific parts of mempool transactions; it stores the full transaction inside CTxMemPoolEntry, along with other consensus-specific fields (such as whether a transaction spends a coinbase, or the LockPoints for transaction finality). And it provides interfaces to the rest of the codebase, such as:

to validation for replace-by-fee calculations and cluster size limits when evaluating unconfirmed transactions
to validation for evicting transactions due to expiry or the mempool size limit being hit
to validation for updating the mempool to be consistent with the best chain after a new block is connected or after a reorg.
to net_processing for ordering transactions that are to-be-announced to other peers
to RPC code for inspecting the mempool

(Many of these interfaces are just wrappers around corresponding TxGraph functions.)

Within CTxMemPool, the mempool entries are stored in a boost::multi_index mapTx, which sorts the mempool on 3 criteria:

transaction hash (txid)
witness-transaction hash (wtxid)
time in mempool

We also maintain a map from COutPoint to the (in-mempool) transaction that spends it (mapNextTx). This allows us to recover from a reorg and find transactions in the mempool that conflict with transactions that are confirmed in a block.

Definition at line 188 of file txmempool.h.

Member Typedef Documentation

◆ indexed_transaction_set

typedef boost::multi_index_container< CTxMemPoolEntry, CTxMemPoolEntry_Indices > CTxMemPool::indexed_transaction_set

Definition at line 237 of file txmempool.h.

◆ Limits

using CTxMemPool::Limits = kernel::MemPoolLimits

Definition at line 273 of file txmempool.h.

◆ Options

using CTxMemPool::Options = kernel::MemPoolOptions

Definition at line 304 of file txmempool.h.

◆ setEntries

typedef std::set<txiter, CompareIteratorByHash> CTxMemPool::setEntries

Definition at line 271 of file txmempool.h.

◆ txiter

using CTxMemPool::txiter = indexed_transaction_set::nth_index<0>::type::const_iterator

Definition at line 268 of file txmempool.h.

Constructor & Destructor Documentation

◆ CTxMemPool()

CTxMemPool::CTxMemPool	(	Options	opts,
		bilingual_str &	error
	)

explicit

Create a new CTxMemPool.

Sanity checks will be off by default for performance, because otherwise accepting transactions becomes O(N^2) where N is the number of transactions in the pool.

Definition at line 173 of file txmempool.cpp.

Here is the call graph for this function:

Member Function Documentation

◆ addNewTransaction()

void CTxMemPool::addNewTransaction ( CTxMemPool::txiter it )

private

Definition at line 216 of file txmempool.cpp.

Here is the call graph for this function:

◆ AddTransactionsUpdated()

void CTxMemPool::AddTransactionsUpdated ( unsigned int n )

Definition at line 190 of file txmempool.cpp.

◆ AddUnbroadcastTx()

void CTxMemPool::AddUnbroadcastTx ( const Txid & txid )

inline

Adds a transaction to the unbroadcast set.

Definition at line 545 of file txmempool.h.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Apply()

void CTxMemPool::Apply ( CTxMemPool::ChangeSet * changeset )

private

Definition at line 195 of file txmempool.cpp.

Here is the call graph for this function:

◆ ApplyDelta()

void CTxMemPool::ApplyDelta	(	const Txid &	hash,
		CAmount &	nFeeDelta
	)		const

Definition at line 640 of file txmempool.cpp.

Here is the call graph for this function:

◆ CalculateAncestorData()

std::tuple< size_t, size_t, CAmount > CTxMemPool::CalculateAncestorData ( const CTxMemPoolEntry & entry ) const

Definition at line 896 of file txmempool.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ CalculateDescendantData()

std::tuple< size_t, size_t, CAmount > CTxMemPool::CalculateDescendantData ( const CTxMemPoolEntry & entry ) const

Definition at line 911 of file txmempool.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ CalculateDescendants() [1/2]

CTxMemPool::txiter CTxMemPool::CalculateDescendants	(	const CTxMemPoolEntry &	entry,
		setEntries &	setDescendants
	)		const

Definition at line 302 of file txmempool.cpp.

◆ CalculateDescendants() [2/2]

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

Populate setDescendants with all in-mempool descendants of given transaction.

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

Definition at line 296 of file txmempool.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ CalculateMemPoolAncestors()

CTxMemPool::setEntries CTxMemPool::CalculateMemPoolAncestors ( const CTxMemPoolEntry & entry ) const

Calculate all in-mempool ancestors of entry (not including the tx itself)

Parameters

[in] entry CTxMemPoolEntry of which all in-mempool ancestors are calculated

Returns: all in-mempool ancestors

Definition at line 127 of file txmempool.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ CheckPolicyLimits()

bool CTxMemPool::CheckPolicyLimits ( const CTransactionRef & tx )

Definition at line 783 of file txmempool.cpp.

Here is the call graph for this function:

◆ ClearPrioritisation()

void CTxMemPool::ClearPrioritisation ( const Txid & hash )

Definition at line 650 of file txmempool.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ CompareMiningScoreWithTopology()

bool CTxMemPool::CompareMiningScoreWithTopology	(	const Wtxid &	hasha,
		const Wtxid &	hashb
	)		const

Definition at line 539 of file txmempool.cpp.

Here is the call graph for this function:

◆ DynamicMemoryUsage()

size_t CTxMemPool::DynamicMemoryUsage ( ) const

Definition at line 761 of file txmempool.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ entryAll()

std::vector< CTxMemPoolEntryRef > CTxMemPool::entryAll ( ) const

Definition at line 571 of file txmempool.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ exists() [1/2]

bool CTxMemPool::exists ( const Txid & txid ) const

inline

Definition at line 506 of file txmempool.h.

Here is the caller graph for this function:

◆ exists() [2/2]

bool CTxMemPool::exists ( const Wtxid & wtxid ) const

inline

Definition at line 512 of file txmempool.h.

◆ Expire()

int CTxMemPool::Expire ( std::chrono::seconds time )

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

Return the number of removed transactions.

Definition at line 794 of file txmempool.cpp.

Here is the call graph for this function:

◆ GatherClusters()

std::vector< CTxMemPool::txiter > CTxMemPool::GatherClusters ( const std::vector< Txid > & txids ) const

Collect the entire cluster of connected transactions for each transaction in txids.

All txids must correspond to transaction entries in the mempool, otherwise this returns an empty vector. This call will also exit early and return an empty vector if it collects 500 or more transactions as a DoS protection.

Definition at line 951 of file txmempool.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ get()

CTransactionRef CTxMemPool::get ( const Txid & hash ) const

Definition at line 604 of file txmempool.cpp.

Here is the caller graph for this function:

◆ GetAncestorCount()

int64_t CTxMemPool::GetAncestorCount ( const CTxMemPoolEntry & e ) const

inline

Definition at line 279 of file txmempool.h.

Here is the caller graph for this function:

◆ GetAndIncrementSequence()

uint64_t CTxMemPool::GetAndIncrementSequence ( ) const

inline

Guards this internal counter for external reporting.

Definition at line 573 of file txmempool.h.

Here is the caller graph for this function:

◆ GetBlockBuilderChunk()

FeePerWeight CTxMemPool::GetBlockBuilderChunk ( std::vector< CTxMemPoolEntry::CTxMemPoolEntryRef > & entries ) const

inline

Definition at line 750 of file txmempool.h.

Here is the caller graph for this function:

◆ GetChangeSet()

std::unique_ptr< ChangeSet > CTxMemPool::GetChangeSet ( )

inline

Definition at line 724 of file txmempool.h.

Here is the caller graph for this function:

◆ GetChildren()

std::vector< CTxMemPoolEntry::CTxMemPoolEntryRef > CTxMemPool::GetChildren ( const CTxMemPoolEntry & entry ) const

Definition at line 57 of file txmempool.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetCluster()

std::vector< const CTxMemPoolEntry * > CTxMemPool::GetCluster ( Txid txid ) const

inline

Definition at line 403 of file txmempool.h.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetConflictTx()

const CTransaction * CTxMemPool::GetConflictTx ( const COutPoint & prevout ) const

Get the transaction in the pool that spends the same prevout.

Definition at line 672 of file txmempool.cpp.

Here is the caller graph for this function:

◆ GetDescendantCount() [1/2]

int64_t CTxMemPool::GetDescendantCount ( const CTxMemPoolEntry & e ) const

inline

Definition at line 278 of file txmempool.h.

◆ GetDescendantCount() [2/2]

int64_t CTxMemPool::GetDescendantCount ( txiter it ) const

inline

Definition at line 277 of file txmempool.h.

Here is the caller graph for this function:

◆ GetEntry()

const CTxMemPoolEntry * CTxMemPool::GetEntry ( const Txid & txid ) const

Definition at line 597 of file txmempool.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetFeerateDiagram()

std::vector< FeePerWeight > CTxMemPool::GetFeerateDiagram ( ) const

Definition at line 1064 of file txmempool.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetInfo()

static TxMempoolInfo CTxMemPool::GetInfo ( CTxMemPool::indexed_transaction_set::const_iterator it )

inlinestaticprivate

Definition at line 291 of file txmempool.h.

Here is the caller graph for this function:

◆ GetIter() [1/2]

std::optional< CTxMemPool::txiter > CTxMemPool::GetIter ( const Txid & txid ) const

Returns an iterator to the given hash, if found.

Definition at line 678 of file txmempool.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetIter() [2/2]

std::optional< CTxMemPool::txiter > CTxMemPool::GetIter ( const Wtxid & wtxid ) const

Definition at line 685 of file txmempool.cpp.

Here is the call graph for this function:

◆ GetIterSet()

CTxMemPool::setEntries CTxMemPool::GetIterSet ( const std::set< Txid > & hashes ) const

Translate a set of hashes into a set of pool iterators to avoid repeated lookups.

Does not require that all of the hashes correspond to actual transactions in the mempool, only returns the ones that exist.

Definition at line 692 of file txmempool.cpp.

Here is the call graph for this function:

◆ GetIterVec()

std::vector< CTxMemPool::txiter > CTxMemPool::GetIterVec ( const std::vector< Txid > & txids ) const

Translate a list of hashes into a list of mempool iterators to avoid repeated lookups.

The nth element in txids becomes the nth element in the returned vector. If any of the txids don't actually exist in the mempool, returns an empty vector.

Definition at line 702 of file txmempool.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetLoadTried()

bool CTxMemPool::GetLoadTried ( ) const

Returns: true if an initial attempt to load the persisted mempool was made, regardless of whether the attempt was successful or not

Definition at line 939 of file txmempool.cpp.

Here is the caller graph for this function:

◆ GetMainChunkFeerate()

FeePerWeight CTxMemPool::GetMainChunkFeerate ( const CTxMemPoolEntry & tx ) const

inline

Definition at line 400 of file txmempool.h.

◆ GetMinFee() [1/2]

CFeeRate CTxMemPool::GetMinFee ( ) const

inline

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

The m_incremental_relay_feerate 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 455 of file txmempool.h.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetMinFee() [2/2]

CFeeRate CTxMemPool::GetMinFee ( size_t sizelimit ) const

protected

Definition at line 812 of file txmempool.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetParents()

std::vector< CTxMemPoolEntry::CTxMemPoolEntryRef > CTxMemPool::GetParents ( const CTxMemPoolEntry & entry ) const

Definition at line 71 of file txmempool.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetPrioritisedTransactions()

std::vector< CTxMemPool::delta_info > CTxMemPool::GetPrioritisedTransactions ( ) const

Return a vector of all entries in mapDeltas with their corresponding delta_info.

Definition at line 656 of file txmempool.cpp.

Here is the caller graph for this function:

◆ GetSequence()

uint64_t CTxMemPool::GetSequence ( ) const

inline

Definition at line 577 of file txmempool.h.

Here is the caller graph for this function:

◆ GetSortedScoreWithTopology()

std::vector< CTxMemPool::indexed_transaction_set::const_iterator > CTxMemPool::GetSortedScoreWithTopology ( ) const

private

Definition at line 555 of file txmempool.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetTotalFee()

CAmount CTxMemPool::GetTotalFee ( ) const

inline

Definition at line 500 of file txmempool.h.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetTotalTxSize()

uint64_t CTxMemPool::GetTotalTxSize ( ) const

inline

Definition at line 494 of file txmempool.h.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetTransactionAncestry()

void CTxMemPool::GetTransactionAncestry	(	const Txid &	txid,
		size_t &	ancestors,
		size_t &	cluster_count,
		size_t *	ancestorsize = `nullptr`,
		CAmount *	ancestorfees = `nullptr`
	)		const

Calculate the ancestor and cluster count for the given transaction.

The counts include the transaction itself. When ancestors is non-zero (ie, the transaction itself is in the mempool), ancestorsize and ancestorfees will also be set to the appropriate values.

Definition at line 926 of file txmempool.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetTransactionsUpdated()

unsigned int CTxMemPool::GetTransactionsUpdated ( ) const

Definition at line 185 of file txmempool.cpp.

Here is the caller graph for this function:

◆ GetUnbroadcastTxs()

std::set< Txid > CTxMemPool::GetUnbroadcastTxs ( ) const

inline

Returns transactions in unbroadcast set.

Definition at line 559 of file txmempool.h.

Here is the caller graph for this function:

◆ GetUniqueClusterCount()

size_t CTxMemPool::GetUniqueClusterCount ( const setEntries & iters_conflicting ) const

inline

Definition at line 416 of file txmempool.h.

Here is the caller graph for this function:

◆ GUARDED_BY() [1/17]

uint64_t totalTxSize CTxMemPool::GUARDED_BY ( cs )

inlineprotected

Definition at line 193 of file txmempool.h.

◆ GUARDED_BY() [2/17]

CAmount m_total_fee CTxMemPool::GUARDED_BY ( cs )

inlineprotected

sum of all mempool tx's virtual sizes. Differs from serialized tx size since witness data is discounted. Defined in BIP 141.

Definition at line 194 of file txmempool.h.

◆ GUARDED_BY() [3/17]

uint64_t cachedInnerUsage CTxMemPool::GUARDED_BY ( cs )

inlineprotected

sum of all mempool tx's fees (NOT modified fee)

Definition at line 195 of file txmempool.h.

◆ GUARDED_BY() [4/17]

int64_t lastRollingFeeUpdate CTxMemPool::GUARDED_BY ( cs )

inlinemutableprotected

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

Definition at line 197 of file txmempool.h.

Here is the call graph for this function:

◆ GUARDED_BY() [5/17]

bool blockSinceLastRollingFeeBump CTxMemPool::GUARDED_BY ( cs )

inlinemutableprotected

Definition at line 198 of file txmempool.h.

◆ GUARDED_BY() [6/17]

double rollingMinimumFeeRate CTxMemPool::GUARDED_BY ( cs )

inlinemutableprotected

Definition at line 199 of file txmempool.h.

◆ GUARDED_BY() [7/17]

Epoch m_epoch CTxMemPool::GUARDED_BY ( cs )

inlinemutableprotected

minimum fee to get into the pool, decreases exponentially

Definition at line 200 of file txmempool.h.

◆ GUARDED_BY() [8/17]

uint64_t m_sequence_number CTxMemPool::GUARDED_BY ( cs )

inlinemutableprotected

Definition at line 205 of file txmempool.h.

◆ GUARDED_BY() [9/17]

bool m_load_tried CTxMemPool::GUARDED_BY ( cs )

inlineprotected

Definition at line 209 of file txmempool.h.

◆ GUARDED_BY() [10/17]

std::unique_ptr< TxGraph > m_txgraph CTxMemPool::GUARDED_BY ( cs )

◆ GUARDED_BY() [11/17]

std::unique_ptr< TxGraph::BlockBuilder > m_builder CTxMemPool::GUARDED_BY ( cs )

mutable

◆ GUARDED_BY() [12/17]

indexed_transaction_set mapTx CTxMemPool::GUARDED_BY ( cs )

◆ GUARDED_BY() [13/17]

std::vector< std::pair< Wtxid, txiter > > txns_randomized CTxMemPool::GUARDED_BY ( cs )

All transactions in mapTx with their wtxids, in arbitrary order.

◆ GUARDED_BY() [14/17]

std::set< Txid > m_unbroadcast_txids CTxMemPool::GUARDED_BY ( cs )

private

Track locally submitted transactions to periodically retry initial broadcast.

◆ GUARDED_BY() [15/17]

indirectmap< COutPoint, txiter > mapNextTx CTxMemPool::GUARDED_BY ( cs )

◆ GUARDED_BY() [16/17]

std::map< Txid, CAmount > mapDeltas CTxMemPool::GUARDED_BY ( cs )

◆ GUARDED_BY() [17/17]

bool m_have_changeset CTxMemPool::GUARDED_BY ( cs )

inline

Definition at line 730 of file txmempool.h.

◆ HasDescendants()

bool CTxMemPool::HasDescendants ( const Txid & txid ) const

Definition at line 119 of file txmempool.cpp.

Here is the call graph for this function:

◆ 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 715 of file txmempool.cpp.

Here is the call graph for this function:

◆ IncludeBuilderChunk()

void CTxMemPool::IncludeBuilderChunk ( ) const

inline

Definition at line 763 of file txmempool.h.

Here is the caller graph for this function:

◆ info()

template<TxidOrWtxid T>

TxMempoolInfo CTxMemPool::info ( const T & id ) const

inline

Definition at line 523 of file txmempool.h.

Here is the call graph for this function:

◆ info_for_relay()

template<TxidOrWtxid T>

TxMempoolInfo CTxMemPool::info_for_relay	(	const T &	id,
		uint64_t	last_sequence
	)		const

inline

Returns info for a transaction if its entry_sequence < last_sequence.

Definition at line 532 of file txmempool.h.

Here is the call graph for this function:

◆ infoAll()

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

Definition at line 583 of file txmempool.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ isSpent()

bool CTxMemPool::isSpent ( const COutPoint & outpoint ) const

Definition at line 179 of file txmempool.cpp.

Here is the caller graph for this function:

◆ IsUnbroadcastTx()

bool CTxMemPool::IsUnbroadcastTx ( const Txid & txid ) const

inline

Returns whether a txid is in the unbroadcast set.

Definition at line 566 of file txmempool.h.

Here is the call graph for this function:

◆ LOCKS_EXCLUDED()

void cs_main CTxMemPool::LOCKS_EXCLUDED ( m_epoch )

◆ PrioritiseTransaction()

void CTxMemPool::PrioritiseTransaction	(	const Txid &	hash,
		const CAmount &	nFeeDelta
	)

Affect CreateNewBlock prioritisation of transactions.

Definition at line 613 of file txmempool.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ removeConflicts()

void CTxMemPool::removeConflicts ( const CTransaction & tx )

private

Definition at line 373 of file txmempool.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ removeForBlock()

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

Definition at line 390 of file txmempool.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ removeForReorg()

void CTxMemPool::removeForReorg	(	CChain &	chain,
		std::function< bool(txiter)>	filter_final_and_mature
	)

After reorg, filter the entries that would no longer be valid in the next block, and update the entries' cached LockPoints if needed.

The mempool does not have any knowledge of consensus rules. It just applies the callable function and removes the ones for which it returns true.

Parameters

[in] filter_final_and_mature Predicate that checks the relevant validation rules and updates an entry's LockPoints.

Definition at line 347 of file txmempool.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ removeRecursive()

void CTxMemPool::removeRecursive	(	txiter	to_remove,
		MemPoolRemovalReason	reason
	)

private

◆ RemoveStaged()

void CTxMemPool::RemoveStaged	(	setEntries &	stage,
		MemPoolRemovalReason	reason
	)

private

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.

Definition at line 776 of file txmempool.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ RemoveUnbroadcastTx()

void CTxMemPool::RemoveUnbroadcastTx	(	const Txid &	txid,
		const bool	unchecked = `false`
	)

Removes a transaction from the unbroadcast set.

Definition at line 767 of file txmempool.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ removeUnchecked()

void CTxMemPool::removeUnchecked	(	txiter	entry,
		MemPoolRemovalReason	reason
	)

private

Before calling removeUnchecked for a given transaction, UpdateForRemoveFromMempool must be called on the entire (dependent) set of transactions being removed at the same time.

We use each CTxMemPoolEntry's m_parents in order to walk ancestors of a given transaction that is removed, so we can't remove intermediate transactions in a chain before we've updated all the state for the removal.

Definition at line 250 of file txmempool.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ SetLoadTried()

void CTxMemPool::SetLoadTried ( bool load_tried )

Set whether or not an initial attempt to load the persisted mempool was made (regardless of whether the attempt was successful or not)

Definition at line 945 of file txmempool.cpp.

◆ size()

unsigned long CTxMemPool::size ( ) const

inline

Definition at line 488 of file txmempool.h.

Here is the caller graph for this function:

◆ SkipBuilderChunk()

void CTxMemPool::SkipBuilderChunk ( ) const

inline

Definition at line 764 of file txmempool.h.

◆ StartBlockBuilding()

void CTxMemPool::StartBlockBuilding ( ) const

inline

Definition at line 749 of file txmempool.h.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ StopBlockBuilding()

void CTxMemPool::StopBlockBuilding ( ) const

inline

Definition at line 765 of file txmempool.h.

Here is the caller graph for this function:

◆ trackPackageRemoved()

void CTxMemPool::trackPackageRemoved ( const CFeeRate & rate )

protected

Definition at line 836 of file txmempool.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ 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 844 of file txmempool.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ UpdateTransactionsFromBlock()

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

UpdateTransactionsFromBlock is called 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).

Postcondition: updated descendant state for descendants of each transaction in vHashesToUpdate (excluding any child transactions present in vHashesToUpdate, which are already accounted for). Updated state includes add fee/size information for such descendants to the parent and updated ancestor state to include the parent.

Parameters

[in] vHashesToUpdate The set of txids from the disconnected block that have been accepted back into the mempool.

Definition at line 88 of file txmempool.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ visited() [1/2]

bool CTxMemPool::visited ( const txiter it ) const

visited marks a CTxMemPoolEntry as having been traversed during the lifetime of the most recently created Epoch::Guard and returns false if we are the first visitor, true otherwise.

An Epoch::Guard must be held when visited is called or an assert will be triggered.

Here is the caller graph for this function:

◆ visited() [2/2]

bool CTxMemPool::visited ( std::optional< txiter > it ) const

Here is the call graph for this function:

Friends And Related Function Documentation

◆ CTxMemPool::ChangeSet

friend class CTxMemPool::ChangeSet

friend

Definition at line 732 of file txmempool.h.

Member Data Documentation

◆ cs

RecursiveMutex CTxMemPool::cs

mutable

This mutex needs to be locked when accessing mapTx or other members that are guarded by it.

Consistency guarantees

By design, it is guaranteed that:

Locking both cs_main and mempool.cs will give a view of mempool that is consistent with current chain tip (ActiveChain() and CoinsTip()) and is fully populated. Fully populated means that if the current active chain is missing transactions that were present in a previously active chain, all the missing transactions will have been re-added to the mempool and should be present if they meet size and consistency constraints.
Locking mempool.cs without cs_main will give a view of a mempool consistent with some chain that was active since cs_main was last locked, and that is fully populated as described above. It is ok for code that only needs to query or remove transactions from the mempool to lock just mempool.cs without cs_main.

To provide these guarantees, it is necessary to lock both cs_main and mempool.cs whenever adding transactions to the mempool and whenever changing the chain tip. It's necessary to keep both mutexes locked until the mempool is consistent with the new chain tip and fully populated.

Definition at line 263 of file txmempool.h.

◆ cs_main

void CTxMemPool::cs_main

Definition at line 336 of file txmempool.h.

◆ it

return !it visited* CTxMemPool::it

Definition at line 618 of file txmempool.h.

◆ m_epoch

bool CTxMemPool::m_epoch

Initial value:

{

return m_epoch.visited(it->m_epoch_marker)

CTxMemPool::it

return !it visited * it

Definition: txmempool.h:618

CTxMemPool::m_epoch

bool m_epoch

Definition: txmempool.h:611

Definition at line 610 of file txmempool.h.

◆ m_opts

const Options CTxMemPool::m_opts

Definition at line 306 of file txmempool.h.

◆ nTransactionsUpdated

std::atomic<unsigned int> CTxMemPool::nTransactionsUpdated {0}

protected

Used by getblocktemplate to trigger CreateNewBlock() invocation.

Definition at line 191 of file txmempool.h.

◆ removeRecursive

void CTxMemPool::removeRecursive

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).

If sanity-checking is turned off, check does nothing. Remove a transaction from the mempool along with any descendants. If the transaction is not already in the mempool, find any descendants and remove them.

Definition at line 328 of file txmempool.h.

◆ ROLLING_FEE_HALFLIFE

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

static

Definition at line 215 of file txmempool.h.

The documentation for this class was generated from the following files:

src/txmempool.h
src/txmempool.cpp

Classes

Public Types

Public Member Functions

Public Attributes

Static Public Attributes

Protected Member Functions

Protected Attributes

Private Member Functions

Static Private Member Functions

Friends

Detailed Description

Member Typedef Documentation

◆ indexed_transaction_set

◆ Limits

◆ Options

◆ setEntries

◆ txiter

Constructor & Destructor Documentation

◆ CTxMemPool()

Member Function Documentation

◆ addNewTransaction()

◆ AddTransactionsUpdated()

◆ AddUnbroadcastTx()

◆ Apply()

◆ ApplyDelta()

◆ CalculateAncestorData()

◆ CalculateDescendantData()

◆ CalculateDescendants() [1/2]

◆ CalculateDescendants() [2/2]

◆ CalculateMemPoolAncestors()

◆ CheckPolicyLimits()

◆ ClearPrioritisation()

◆ CompareMiningScoreWithTopology()

◆ DynamicMemoryUsage()

◆ entryAll()

◆ exists() [1/2]

◆ exists() [2/2]

◆ Expire()

◆ GatherClusters()

◆ get()

◆ GetAncestorCount()

◆ GetAndIncrementSequence()

◆ GetBlockBuilderChunk()

◆ GetChangeSet()

◆ GetChildren()

◆ GetCluster()

◆ GetConflictTx()

◆ GetDescendantCount() [1/2]

◆ GetDescendantCount() [2/2]

◆ GetEntry()

◆ GetFeerateDiagram()

◆ GetInfo()

◆ GetIter() [1/2]

◆ GetIter() [2/2]

◆ GetIterSet()

◆ GetIterVec()

◆ GetLoadTried()

◆ GetMainChunkFeerate()

◆ GetMinFee() [1/2]

◆ GetMinFee() [2/2]

◆ GetParents()

◆ GetPrioritisedTransactions()

◆ GetSequence()

◆ GetSortedScoreWithTopology()

◆ GetTotalFee()

◆ GetTotalTxSize()

◆ GetTransactionAncestry()

◆ GetTransactionsUpdated()

◆ GetUnbroadcastTxs()

◆ GetUniqueClusterCount()

◆ GUARDED_BY() [1/17]

◆ GUARDED_BY() [2/17]

◆ GUARDED_BY() [3/17]

◆ GUARDED_BY() [4/17]

◆ GUARDED_BY() [5/17]

◆ GUARDED_BY() [6/17]

◆ GUARDED_BY() [7/17]

◆ GUARDED_BY() [8/17]

◆ GUARDED_BY() [9/17]

◆ GUARDED_BY() [10/17]