#include <InboundLedger.h>

Inheritance diagram for xrpl::InboundLedger:

[legend]

Collaboration diagram for xrpl::InboundLedger:

[legend]

Public Types
enum class	Reason { HISTORY , GENERIC , CONSENSUS }

using	clock_type = beast::abstract_clock< std::chrono::steady_clock >

using	neededHash_t = std::pair< protocol::TMGetObjectByHash::ObjectType, uint256 >

Public Member Functions
	InboundLedger (Application &app, uint256 const &hash, std::uint32_t seq, Reason reason, clock_type &, std::unique_ptr< PeerSet > peerSet)

	~InboundLedger ()

void	update (std::uint32_t seq)

bool	isComplete () const
	Returns true if we got all the data.

bool	isFailed () const
	Returns false if we failed to get the data.

std::shared_ptr< Ledger const >	getLedger () const

std::uint32_t	getSeq () const

bool	checkLocal ()

void	init (ScopedLockType &collectionLock)

bool	gotData (std::weak_ptr< Peer >, std::shared_ptr< protocol::TMLedgerData > const &)
	Stash a TMLedgerData received from a peer for later processing Returns 'true' if we need to dispatch.

Json::Value	getJson (int)
	Return a Json::objectValue.

void	runData ()
	Process pending TMLedgerData Query the a random sample of the 'best' peers.

void	touch ()

clock_type::time_point	getLastAction () const

virtual void	cancel ()
	Cancel the task by marking it as failed if the task is not done.

T	shared_from_this (T... args)

T	weak_from_this (T... args)

Protected Types
using	ScopedLockType = std::unique_lock< std::recursive_mutex >

Protected Member Functions
void	setTimer (ScopedLockType &)
	Schedule a call to queueJob() after mTimerInterval.

void	queueJob (ScopedLockType &)
	Queue a job to call invokeOnTimer().

bool	isDone () const

Protected Attributes
Application &	app_

beast::Journal	journal_

std::recursive_mutex	mtx_

uint256 const	hash_
	The hash of the object (in practice, always a ledger) we are trying to fetch.

int	timeouts_

bool	complete_

bool	failed_

bool	progress_
	Whether forward progress has been made.

std::chrono::milliseconds	timerInterval_
	The minimum time to wait between calls to execute().

QueueJobParameter	queueJobParameter_

Private Types
enum class	TriggerReason { added , reply , timeout }

Private Member Functions
void	filterNodes (std::vector< std::pair< SHAMapNodeID, uint256 > > &nodes, TriggerReason reason)

void	trigger (std::shared_ptr< Peer > const &, TriggerReason)
	Request more nodes, perhaps from a specific peer.

std::vector< neededHash_t >	getNeededHashes ()

void	addPeers ()
	Add more peers to the set, if possible.

void	tryDB (NodeStore::Database &srcDB)

void	done ()

void	onTimer (bool progress, ScopedLockType &peerSetLock) override
	Called with a lock by the PeerSet when the timer expires.

std::size_t	getPeerCount () const

std::weak_ptr< TimeoutCounter >	pmDowncast () override
	Return a weak pointer to this.

int	processData (std::shared_ptr< Peer > peer, protocol::TMLedgerData &data)
	Process one TMLedgerData Returns the number of useful nodes.

bool	takeHeader (std::string const &data)
	Take ledger header data Call with a lock.

void	receiveNode (protocol::TMLedgerData &packet, SHAMapAddNode &)
	Process node data received from a peer Call with a lock.

bool	takeTxRootNode (Slice const &data, SHAMapAddNode &)
	Process AS root node received from a peer Call with a lock.

bool	takeAsRootNode (Slice const &data, SHAMapAddNode &)
	Process AS root node received from a peer Call with a lock.

std::vector< uint256 >	neededTxHashes (int max, SHAMapSyncFilter *filter) const

std::vector< uint256 >	neededStateHashes (int max, SHAMapSyncFilter *filter) const

void	invokeOnTimer ()
	Calls onTimer() if in the right state.

Static Private Member Functions
static auto &	getCounter () noexcept

Private Attributes
clock_type &	m_clock

clock_type::time_point	mLastAction

std::shared_ptr< Ledger >	mLedger

bool	mHaveHeader

bool	mHaveState

bool	mHaveTransactions

bool	mSignaled

bool	mByHash

std::uint32_t	mSeq

Reason const	mReason

std::set< uint256 >	mRecentNodes

SHAMapAddNode	mStats

std::mutex	mReceivedDataLock

std::vector< std::pair< std::weak_ptr< Peer >, std::shared_ptr< protocol::TMLedgerData > > >	mReceivedData

bool	mReceiveDispatched

std::unique_ptr< PeerSet >	mPeerSet

boost::asio::basic_waitable_timer< std::chrono::steady_clock >	timer_

Detailed Description

Definition at line 17 of file InboundLedger.h.

Member Typedef Documentation

◆ clock_type

using xrpl::InboundLedger::clock_type = beast::abstract_clock<std::chrono::steady_clock>

Definition at line 22 of file InboundLedger.h.

◆ neededHash_t

using xrpl::InboundLedger::neededHash_t = std::pair<protocol::TMGetObjectByHash::ObjectType, uint256>

Definition at line 79 of file InboundLedger.h.

◆ ScopedLockType

using xrpl::TimeoutCounter::ScopedLockType = std::unique_lock<std::recursive_mutex>

protectedinherited

Definition at line 63 of file TimeoutCounter.h.

Member Enumeration Documentation

◆ Reason

enum class xrpl::InboundLedger::Reason

strong

Enumerator
HISTORY
GENERIC
CONSENSUS

Definition at line 25 of file InboundLedger.h.

◆ TriggerReason

enum class xrpl::InboundLedger::TriggerReason

strongprivate

Enumerator
added
reply
timeout

Definition at line 101 of file InboundLedger.h.

Constructor & Destructor Documentation

◆ InboundLedger()

xrpl::InboundLedger::InboundLedger	(	Application &	app,
		uint256 const &	hash,
		std::uint32_t	seq,
		Reason	reason,
		clock_type &	clock,
		std::unique_ptr< PeerSet >	peerSet
	)

Definition at line 57 of file InboundLedger.cpp.

◆ ~InboundLedger()

xrpl::InboundLedger::~InboundLedger ( )

Definition at line 154 of file InboundLedger.cpp.

Member Function Documentation

◆ update()

void xrpl::InboundLedger::update ( std::uint32_t seq )

Definition at line 123 of file InboundLedger.cpp.

◆ isComplete()

bool xrpl::InboundLedger::isComplete ( ) const

Returns true if we got all the data.

Definition at line 47 of file InboundLedger.h.

◆ isFailed()

bool xrpl::InboundLedger::isFailed ( ) const

Returns false if we failed to get the data.

Definition at line 54 of file InboundLedger.h.

◆ getLedger()

std::shared_ptr< Ledger const > xrpl::InboundLedger::getLedger ( ) const

Definition at line 60 of file InboundLedger.h.

◆ getSeq()

std::uint32_t xrpl::InboundLedger::getSeq ( ) const

Definition at line 66 of file InboundLedger.h.

◆ checkLocal()

bool xrpl::InboundLedger::checkLocal ( )

Definition at line 136 of file InboundLedger.cpp.

◆ init()

void xrpl::InboundLedger::init ( ScopedLockType & collectionLock )

Definition at line 81 of file InboundLedger.cpp.

◆ gotData()

bool xrpl::InboundLedger::gotData	(	std::weak_ptr< Peer >	peer,
		std::shared_ptr< protocol::TMLedgerData > const &	data
	)

Stash a TMLedgerData received from a peer for later processing Returns 'true' if we need to dispatch.

Definition at line 953 of file InboundLedger.cpp.

◆ getJson()

Json::Value xrpl::InboundLedger::getJson ( int )

Return a Json::objectValue.

Definition at line 1191 of file InboundLedger.cpp.

◆ runData()

void xrpl::InboundLedger::runData ( )

Process pending TMLedgerData Query the a random sample of the 'best' peers.

Definition at line 1146 of file InboundLedger.cpp.

◆ touch()

void xrpl::InboundLedger::touch ( )

Definition at line 89 of file InboundLedger.h.

◆ getLastAction()

clock_type::time_point xrpl::InboundLedger::getLastAction ( ) const

Definition at line 95 of file InboundLedger.h.

◆ filterNodes()

void xrpl::InboundLedger::filterNodes	(	std::vector< std::pair< SHAMapNodeID, uint256 > > &	nodes,
		TriggerReason	reason
	)

private

Definition at line 700 of file InboundLedger.cpp.

◆ trigger()

void xrpl::InboundLedger::trigger	(	std::shared_ptr< Peer > const &	peer,
		TriggerReason	reason
	)

private

Request more nodes, perhaps from a specific peer.

Definition at line 435 of file InboundLedger.cpp.

◆ getNeededHashes()

std::vector< InboundLedger::neededHash_t > xrpl::InboundLedger::getNeededHashes ( )

private

Definition at line 918 of file InboundLedger.cpp.

◆ addPeers()

void xrpl::InboundLedger::addPeers ( )

private

Add more peers to the set, if possible.

Definition at line 368 of file InboundLedger.cpp.

◆ tryDB()

void xrpl::InboundLedger::tryDB ( NodeStore::Database & srcDB )

private

Definition at line 208 of file InboundLedger.cpp.

◆ done()

void xrpl::InboundLedger::done ( )

private

Definition at line 388 of file InboundLedger.cpp.

◆ onTimer()

void xrpl::InboundLedger::onTimer	(	bool	progress,
		ScopedLockType &	peerSetLock
	)

overrideprivatevirtual

Called with a lock by the PeerSet when the timer expires.

Implements xrpl::TimeoutCounter.

Definition at line 320 of file InboundLedger.cpp.

◆ getPeerCount()

std::size_t xrpl::InboundLedger::getPeerCount ( ) const

private

Definition at line 115 of file InboundLedger.cpp.

◆ pmDowncast()

std::weak_ptr< TimeoutCounter > xrpl::InboundLedger::pmDowncast ( )

overrideprivatevirtual

Return a weak pointer to this.

Implements xrpl::TimeoutCounter.

Definition at line 382 of file InboundLedger.cpp.

◆ processData()

int xrpl::InboundLedger::processData	(	std::shared_ptr< Peer >	peer,
		protocol::TMLedgerData &	data
	)

private

Process one TMLedgerData Returns the number of useful nodes.

Definition at line 978 of file InboundLedger.cpp.

◆ takeHeader()

bool xrpl::InboundLedger::takeHeader ( std::string const & data )

private

Take ledger header data Call with a lock.

Definition at line 741 of file InboundLedger.cpp.

◆ receiveNode()

void xrpl::InboundLedger::receiveNode	(	protocol::TMLedgerData &	packet,
		SHAMapAddNode &	san
	)

private

Process node data received from a peer Call with a lock.

Definition at line 784 of file InboundLedger.cpp.

◆ takeTxRootNode()

bool xrpl::InboundLedger::takeTxRootNode	(	Slice const &	data,
		SHAMapAddNode &	san
	)

private

Process AS root node received from a peer Call with a lock.

Definition at line 896 of file InboundLedger.cpp.

◆ takeAsRootNode()

bool xrpl::InboundLedger::takeAsRootNode	(	Slice const &	data,
		SHAMapAddNode &	san
	)

private

Process AS root node received from a peer Call with a lock.

Definition at line 871 of file InboundLedger.cpp.

◆ neededTxHashes()

std::vector< uint256 > xrpl::InboundLedger::neededTxHashes	(	int	max,
		SHAMapSyncFilter *	filter
	)		const

private

Definition at line 194 of file InboundLedger.cpp.

◆ neededStateHashes()

std::vector< uint256 > xrpl::InboundLedger::neededStateHashes	(	int	max,
		SHAMapSyncFilter *	filter
	)		const

private

Definition at line 200 of file InboundLedger.cpp.

◆ cancel()

void xrpl::TimeoutCounter::cancel ( )

virtualinherited

Cancel the task by marking it as failed if the task is not done.

Note: this function does not attempt to cancel the scheduled timer or to remove the queued job if any. When the timer expires or the queued job starts, however, the code will see that the task is done and returns immediately, if it can lock the weak pointer of the task.

Definition at line 94 of file TimeoutCounter.cpp.

◆ setTimer()

void xrpl::TimeoutCounter::setTimer ( ScopedLockType & sl )

protectedinherited

Schedule a call to queueJob() after mTimerInterval.

Definition at line 32 of file TimeoutCounter.cpp.

◆ queueJob()

void xrpl::TimeoutCounter::queueJob ( ScopedLockType & sl )

protectedinherited

Queue a job to call invokeOnTimer().

Definition at line 50 of file TimeoutCounter.cpp.

◆ isDone()

bool xrpl::TimeoutCounter::isDone ( ) const

protectedinherited

Definition at line 98 of file TimeoutCounter.h.

◆ invokeOnTimer()

void xrpl::TimeoutCounter::invokeOnTimer ( )

privateinherited

Calls onTimer() if in the right state.

Only called by queueJob().

Definition at line 69 of file TimeoutCounter.cpp.

◆ getCounter()

static auto & xrpl::CountedObject< InboundLedger >::getCounter ( )

staticprivatenoexceptinherited

Definition at line 109 of file CountedObject.h.

Member Data Documentation

◆ m_clock

clock_type& xrpl::InboundLedger::m_clock

private

Definition at line 151 of file InboundLedger.h.

◆ mLastAction

clock_type::time_point xrpl::InboundLedger::mLastAction

private

Definition at line 152 of file InboundLedger.h.

◆ mLedger

std::shared_ptr<Ledger> xrpl::InboundLedger::mLedger

private

Definition at line 154 of file InboundLedger.h.

◆ mHaveHeader

bool xrpl::InboundLedger::mHaveHeader

private

Definition at line 155 of file InboundLedger.h.

◆ mHaveState

bool xrpl::InboundLedger::mHaveState

private

Definition at line 156 of file InboundLedger.h.

◆ mHaveTransactions

bool xrpl::InboundLedger::mHaveTransactions

private

Definition at line 157 of file InboundLedger.h.

◆ mSignaled

bool xrpl::InboundLedger::mSignaled

private

Definition at line 158 of file InboundLedger.h.

◆ mByHash

bool xrpl::InboundLedger::mByHash

private

Definition at line 159 of file InboundLedger.h.

◆ mSeq

std::uint32_t xrpl::InboundLedger::mSeq

private

Definition at line 160 of file InboundLedger.h.

◆ mReason

Reason const xrpl::InboundLedger::mReason

private

Definition at line 161 of file InboundLedger.h.

◆ mRecentNodes

std::set<uint256> xrpl::InboundLedger::mRecentNodes

private

Definition at line 163 of file InboundLedger.h.

◆ mStats

SHAMapAddNode xrpl::InboundLedger::mStats

private

Definition at line 165 of file InboundLedger.h.

◆ mReceivedDataLock

std::mutex xrpl::InboundLedger::mReceivedDataLock

private

Definition at line 168 of file InboundLedger.h.

◆ mReceivedData

std::vector<std::pair<std::weak_ptr<Peer>, std::shared_ptr<protocol::TMLedgerData> > > xrpl::InboundLedger::mReceivedData

private

Definition at line 169 of file InboundLedger.h.

◆ mReceiveDispatched

bool xrpl::InboundLedger::mReceiveDispatched

private

Definition at line 170 of file InboundLedger.h.

◆ mPeerSet

std::unique_ptr<PeerSet> xrpl::InboundLedger::mPeerSet

private

Definition at line 171 of file InboundLedger.h.

◆ app_

Application& xrpl::TimeoutCounter::app_

protectedinherited

Definition at line 105 of file TimeoutCounter.h.

◆ journal_

beast::Journal xrpl::TimeoutCounter::journal_

protectedinherited

Definition at line 106 of file TimeoutCounter.h.

◆ mtx_

std::recursive_mutex xrpl::TimeoutCounter::mtx_

mutableprotectedinherited

Definition at line 107 of file TimeoutCounter.h.

◆ hash_

uint256 const xrpl::TimeoutCounter::hash_

protectedinherited

The hash of the object (in practice, always a ledger) we are trying to fetch.

Definition at line 111 of file TimeoutCounter.h.

◆ timeouts_

int xrpl::TimeoutCounter::timeouts_

protectedinherited

Definition at line 112 of file TimeoutCounter.h.

◆ complete_

bool xrpl::TimeoutCounter::complete_

protectedinherited

Definition at line 113 of file TimeoutCounter.h.

◆ failed_

bool xrpl::TimeoutCounter::failed_

protectedinherited

Definition at line 114 of file TimeoutCounter.h.

◆ progress_

bool xrpl::TimeoutCounter::progress_

protectedinherited

Whether forward progress has been made.

Definition at line 116 of file TimeoutCounter.h.

◆ timerInterval_

std::chrono::milliseconds xrpl::TimeoutCounter::timerInterval_

protectedinherited

The minimum time to wait between calls to execute().

Definition at line 118 of file TimeoutCounter.h.

◆ queueJobParameter_

QueueJobParameter xrpl::TimeoutCounter::queueJobParameter_

protectedinherited

Definition at line 120 of file TimeoutCounter.h.

◆ timer_

boost::asio::basic_waitable_timer<std::chrono::steady_clock> xrpl::TimeoutCounter::timer_

privateinherited

Definition at line 129 of file TimeoutCounter.h.

Public Types

Public Member Functions

Protected Types

Protected Member Functions

Protected Attributes

Private Types

Private Member Functions

Static Private Member Functions

Private Attributes

Detailed Description

Member Typedef Documentation

◆ clock_type

◆ neededHash_t

◆ ScopedLockType

Member Enumeration Documentation

◆ Reason

◆ TriggerReason

Constructor & Destructor Documentation

◆ InboundLedger()

◆ ~InboundLedger()

Member Function Documentation

◆ update()

◆ isComplete()

◆ isFailed()

◆ getLedger()

◆ getSeq()

◆ checkLocal()

◆ init()

◆ gotData()

◆ getJson()

◆ runData()

◆ touch()

◆ getLastAction()

◆ filterNodes()

◆ trigger()

◆ getNeededHashes()

◆ addPeers()

◆ tryDB()

◆ done()

◆ onTimer()

◆ getPeerCount()

◆ pmDowncast()

◆ processData()

◆ takeHeader()

◆ receiveNode()

◆ takeTxRootNode()

◆ takeAsRootNode()

◆ neededTxHashes()

◆ neededStateHashes()

◆ cancel()

◆ setTimer()

◆ queueJob()

◆ isDone()

◆ invokeOnTimer()

◆ getCounter()

Member Data Documentation

◆ m_clock

◆ mLastAction

◆ mLedger

◆ mHaveHeader

◆ mHaveState

◆ mHaveTransactions

◆ mSignaled

◆ mByHash

◆ mSeq

◆ mReason

◆ mRecentNodes

◆ mStats

◆ mReceivedDataLock

◆ mReceivedData

◆ mReceiveDispatched

◆ mPeerSet

◆ app_

◆ journal_

◆ mtx_

◆ hash_

◆ timeouts_

◆ complete_

◆ failed_

◆ progress_