Actual implementation for TxRequestTracker's data structure. More...

Collaboration diagram for TxRequestTracker::Impl:

Public Member Functions
void	SanityCheck () const

void	PostGetRequestableSanityCheck (std::chrono::microseconds now) const

	Impl (bool deterministic)

	Impl (const Impl &)=delete

Impl &	operator= (const Impl &)=delete

void	DisconnectedPeer (NodeId peer)

void	ForgetTxHash (const uint256 &txhash)

void	GetCandidatePeers (const uint256 &txhash, std::vector< NodeId > &result_peers) const

void	ReceivedInv (NodeId peer, const GenTxid &gtxid, bool preferred, std::chrono::microseconds reqtime)

std::vector< GenTxid >	GetRequestable (NodeId peer, std::chrono::microseconds now, std::vector< std::pair< NodeId, GenTxid > > *expired)
	Find the GenTxids to request now from peer.

void	RequestedTx (NodeId peer, const uint256 &txhash, std::chrono::microseconds expiry)

void	ReceivedResponse (NodeId peer, const uint256 &txhash)

size_t	CountInFlight (NodeId peer) const

size_t	CountCandidates (NodeId peer) const

size_t	Count (NodeId peer) const

size_t	Size () const
	Count how many announcements are being tracked in total across all peers and transactions.

uint64_t	ComputePriority (const uint256 &txhash, NodeId peer, bool preferred) const

Private Member Functions
template<typename Tag >
Iter< Tag >	Erase (Iter< Tag > it)
	Wrapper around Index::...::erase that keeps m_peerinfo up to date.

template<typename Tag , typename Modifier >
void	Modify (Iter< Tag > it, Modifier modifier)
	Wrapper around Index::...modify that keeps m_peerinfo up to date.

void	PromoteCandidateReady (Iter< ByTxHash > it)
	Convert a CANDIDATE_DELAYED announcement into a CANDIDATE_READY.

void	ChangeAndReselect (Iter< ByTxHash > it, State new_state)
	Change the state of an announcement to something non-IsSelected().

bool	IsOnlyNonCompleted (Iter< ByTxHash > it)
	Check if 'it' is the only announcement for a given txhash that isn't COMPLETED.

bool	MakeCompleted (Iter< ByTxHash > it)
	Convert any announcement to a COMPLETED one.

void	SetTimePoint (std::chrono::microseconds now, std::vector< std::pair< NodeId, GenTxid > > *expired)
	Make the data structure consistent with a given point in time:

Private Attributes
SequenceNumber	m_current_sequence {0}
	The current sequence number.

const PriorityComputer	m_computer
	This tracker's priority computer.

Index	m_index
	This tracker's main data structure. See SanityCheck() for the invariants that apply to it.

std::unordered_map< NodeId, PeerInfo >	m_peerinfo
	Map with this tracker's per-peer statistics.

Detailed Description

Actual implementation for TxRequestTracker's data structure.

Definition at line 299 of file txrequest.cpp.

Constructor & Destructor Documentation

◆ Impl() [1/2]

TxRequestTracker::Impl::Impl ( bool deterministic )

inlineexplicit

Definition at line 514 of file txrequest.cpp.

◆ Impl() [2/2]

TxRequestTracker::Impl::Impl ( const Impl & )

delete

Member Function Documentation

◆ ChangeAndReselect()

void TxRequestTracker::Impl::ChangeAndReselect	(	Iter< ByTxHash >	it,
		State	new_state
	)

inlineprivate

Change the state of an announcement to something non-IsSelected().

If it was IsSelected(), the next best announcement will be marked CANDIDATE_BEST.

Definition at line 419 of file txrequest.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ ComputePriority()

uint64_t TxRequestTracker::Impl::ComputePriority	(	const uint256 &	txhash,
		NodeId	peer,
		bool	preferred
	)		const

inline

Definition at line 703 of file txrequest.cpp.

Here is the call graph for this function:

◆ Count()

size_t TxRequestTracker::Impl::Count ( NodeId peer ) const

inline

Definition at line 693 of file txrequest.cpp.

◆ CountCandidates()

size_t TxRequestTracker::Impl::CountCandidates ( NodeId peer ) const

inline

Definition at line 686 of file txrequest.cpp.

◆ CountInFlight()

size_t TxRequestTracker::Impl::CountInFlight ( NodeId peer ) const

inline

Definition at line 679 of file txrequest.cpp.

◆ DisconnectedPeer()

void TxRequestTracker::Impl::DisconnectedPeer ( NodeId peer )

inline

Definition at line 527 of file txrequest.cpp.

Here is the call graph for this function:

◆ Erase()

template<typename Tag >

Iter< Tag > TxRequestTracker::Impl::Erase ( Iter< Tag > it )

inlineprivate

Wrapper around Index::...::erase that keeps m_peerinfo up to date.

Definition at line 366 of file txrequest.cpp.

Here is the call graph for this function:

◆ ForgetTxHash()

void TxRequestTracker::Impl::ForgetTxHash ( const uint256 & txhash )

inline

Definition at line 558 of file txrequest.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetCandidatePeers()

void TxRequestTracker::Impl::GetCandidatePeers	(	const uint256 &	txhash,
		std::vector< NodeId > &	result_peers
	)		const

inline

Definition at line 566 of file txrequest.cpp.

Here is the call graph for this function:

◆ GetRequestable()

std::vector< GenTxid > TxRequestTracker::Impl::GetRequestable	(	NodeId	peer,
		std::chrono::microseconds	now,
		std::vector< std::pair< NodeId, GenTxid > > *	expired
	)

inline

Find the GenTxids to request now from peer.

Definition at line 595 of file txrequest.cpp.

Here is the call graph for this function:

◆ IsOnlyNonCompleted()

bool TxRequestTracker::Impl::IsOnlyNonCompleted ( Iter< ByTxHash > it )

inlineprivate

Check if 'it' is the only announcement for a given txhash that isn't COMPLETED.

Definition at line 436 of file txrequest.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ MakeCompleted()

bool TxRequestTracker::Impl::MakeCompleted ( Iter< ByTxHash > it )

inlineprivate

Convert any announcement to a COMPLETED one.

If there are no non-COMPLETED announcements left for this txhash, they are deleted. If this was a REQUESTED announcement, and there are other CANDIDATEs left, the best one is made CANDIDATE_BEST. Returns whether the announcement still exists.

Definition at line 455 of file txrequest.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Modify()

template<typename Tag , typename Modifier >

void TxRequestTracker::Impl::Modify	(	Iter< Tag >	it,
		Modifier	modifier
	)

inlineprivate

Wrapper around Index::...modify that keeps m_peerinfo up to date.

Definition at line 377 of file txrequest.cpp.

Here is the call graph for this function:

◆ operator=()

Impl & TxRequestTracker::Impl::operator= ( const Impl & )

delete

◆ PostGetRequestableSanityCheck()

void TxRequestTracker::Impl::PostGetRequestableSanityCheck ( std::chrono::microseconds now ) const

inline

Definition at line 348 of file txrequest.cpp.

Here is the call graph for this function:

◆ PromoteCandidateReady()

void TxRequestTracker::Impl::PromoteCandidateReady ( Iter< ByTxHash > it )

inlineprivate

Convert a CANDIDATE_DELAYED announcement into a CANDIDATE_READY.

If this makes it the new best CANDIDATE_READY (and no REQUESTED exists) and better than the CANDIDATE_BEST (if any), it becomes the new CANDIDATE_BEST.

Definition at line 390 of file txrequest.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ ReceivedInv()

void TxRequestTracker::Impl::ReceivedInv	(	NodeId	peer,
		const GenTxid &	gtxid,
		bool	preferred,
		std::chrono::microseconds	reqtime
	)

inline

Definition at line 575 of file txrequest.cpp.

Here is the call graph for this function:

◆ ReceivedResponse()

void TxRequestTracker::Impl::ReceivedResponse	(	NodeId	peer,
		const uint256 &	txhash
	)

inline

Definition at line 669 of file txrequest.cpp.

Here is the call graph for this function:

◆ RequestedTx()

void TxRequestTracker::Impl::RequestedTx	(	NodeId	peer,
		const uint256 &	txhash,
		std::chrono::microseconds	expiry
	)

inline

Definition at line 624 of file txrequest.cpp.

Here is the call graph for this function:

◆ SanityCheck()

void TxRequestTracker::Impl::SanityCheck ( ) const

inline

Definition at line 314 of file txrequest.cpp.

Here is the call graph for this function:

◆ SetTimePoint()

void TxRequestTracker::Impl::SetTimePoint	(	std::chrono::microseconds	now,
		std::vector< std::pair< NodeId, GenTxid > > *	expired
	)

inlineprivate

Make the data structure consistent with a given point in time:

REQUESTED announcements with expiry <= now are turned into COMPLETED.
CANDIDATE_DELAYED announcements with reqtime <= now are turned into CANDIDATE_{READY,BEST}.
CANDIDATE_{READY,BEST} announcements with reqtime > now are turned into CANDIDATE_DELAYED.

Definition at line 482 of file txrequest.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Size()

size_t TxRequestTracker::Impl::Size ( ) const

inline

Count how many announcements are being tracked in total across all peers and transactions.

Definition at line 701 of file txrequest.cpp.

Member Data Documentation

◆ m_computer

const PriorityComputer TxRequestTracker::Impl::m_computer

private

This tracker's priority computer.

Definition at line 305 of file txrequest.cpp.

◆ m_current_sequence

SequenceNumber TxRequestTracker::Impl::m_current_sequence {0}

private

The current sequence number.

Increases for every announcement. This is used to sort txhashes returned by GetRequestable in announcement order.

Definition at line 302 of file txrequest.cpp.

◆ m_index

Index TxRequestTracker::Impl::m_index

private

This tracker's main data structure. See SanityCheck() for the invariants that apply to it.

Definition at line 308 of file txrequest.cpp.

◆ m_peerinfo

std::unordered_map<NodeId, PeerInfo> TxRequestTracker::Impl::m_peerinfo

private

Map with this tracker's per-peer statistics.

Definition at line 311 of file txrequest.cpp.

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

src/txrequest.cpp

Public Member Functions

Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ Impl() [1/2]

◆ Impl() [2/2]

Member Function Documentation

◆ ChangeAndReselect()

◆ ComputePriority()

◆ Count()

◆ CountCandidates()

◆ CountInFlight()

◆ DisconnectedPeer()

◆ Erase()

◆ ForgetTxHash()

◆ GetCandidatePeers()

◆ GetRequestable()

◆ IsOnlyNonCompleted()

◆ MakeCompleted()

◆ Modify()

◆ operator=()

◆ PostGetRequestableSanityCheck()

◆ PromoteCandidateReady()

◆ ReceivedInv()

◆ ReceivedResponse()

◆ RequestedTx()

◆ SanityCheck()

◆ SetTimePoint()

◆ Size()

Member Data Documentation

◆ m_computer

◆ m_current_sequence

◆ m_index

◆ m_peerinfo