Inheritance diagram for ripple::InboundLedgersImp:

Collaboration diagram for ripple::InboundLedgersImp:

[legend]

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

Public Member Functions
	InboundLedgersImp (Application &app, clock_type &clock, beast::insight::Collector::ptr const &collector, std::unique_ptr< PeerSetBuilder > peerSetBuilder)

std::shared_ptr< Ledger const >	acquire (uint256 const &hash, std::uint32_t seq, InboundLedger::Reason reason) override

void	acquireAsync (uint256 const &hash, std::uint32_t seq, InboundLedger::Reason reason) override

std::shared_ptr< InboundLedger >	find (uint256 const &hash) override

bool	gotLedgerData (LedgerHash const &hash, std::shared_ptr< Peer > peer, std::shared_ptr< protocol::TMLedgerData > packet) override
	We received a TMLedgerData from a peer.

void	logFailure (uint256 const &h, std::uint32_t seq) override

bool	isFailure (uint256 const &h) override

void	gotStaleData (std::shared_ptr< protocol::TMLedgerData > packet_ptr) override
	We got some data for a ledger we are no longer acquiring Since we paid the price to receive it, we might as well stash it in case we need it.

void	clearFailures () override

std::size_t	fetchRate () override
	Returns the rate of historical ledger fetches per minute.

void	onLedgerFetched () override
	Called when a complete ledger is obtained.

Json::Value	getInfo () override

void	gotFetchPack () override

void	sweep () override

void	stop () override

std::size_t	cacheSize () override

virtual std::shared_ptr< InboundLedger >	find (LedgerHash const &hash)=0

Static Public Attributes
static constexpr std::chrono::minutes const	kReacquireInterval {5}

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

using	MapType = hash_map< uint256, std::shared_ptr< InboundLedger > >

Private Attributes
Application &	app_

std::mutex	fetchRateMutex_

DecayWindow< 30, clock_type >	fetchRate_

beast::Journal const	j_

clock_type &	m_clock

std::recursive_mutex	mLock

bool	stopping_ = false

MapType	mLedgers

beast::aged_map< uint256, std::uint32_t >	mRecentFailures

beast::insight::Counter	mCounter

std::unique_ptr< PeerSetBuilder >	mPeerSetBuilder

std::set< uint256 >	pendingAcquires_

std::mutex	acquiresMutex_

Detailed Description

Definition at line 21 of file InboundLedgers.cpp.

Member Typedef Documentation

◆ ScopedLockType

using ripple::InboundLedgersImp::ScopedLockType = std::unique_lock<std::recursive_mutex>

private

Definition at line 432 of file InboundLedgers.cpp.

◆ MapType

using ripple::InboundLedgersImp::MapType = hash_map<uint256, std::shared_ptr<InboundLedger> >

private

Definition at line 436 of file InboundLedgers.cpp.

◆ clock_type

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

inherited

Definition at line 17 of file InboundLedgers.h.

Constructor & Destructor Documentation

◆ InboundLedgersImp()

ripple::InboundLedgersImp::InboundLedgersImp	(	Application &	app,
		clock_type &	clock,
		beast::insight::Collector::ptr const &	collector,
		std::unique_ptr< PeerSetBuilder >	peerSetBuilder
	)

Definition at line 34 of file InboundLedgers.cpp.

Member Function Documentation

◆ acquire()

std::shared_ptr< Ledger const > ripple::InboundLedgersImp::acquire	(	uint256 const &	hash,
		std::uint32_t	seq,
		InboundLedger::Reason	reason
	)

overridevirtual

Implements ripple::InboundLedgers.

Definition at line 51 of file InboundLedgers.cpp.

Here is the call graph for this function:

◆ acquireAsync()

void ripple::InboundLedgersImp::acquireAsync	(	uint256 const &	hash,
		std::uint32_t	seq,
		InboundLedger::Reason	reason
	)

overridevirtual

Implements ripple::InboundLedgers.

Definition at line 116 of file InboundLedgers.cpp.

◆ find() [1/2]

std::shared_ptr< InboundLedger > ripple::InboundLedgersImp::find ( uint256 const & hash )

override

Definition at line 146 of file InboundLedgers.cpp.

◆ gotLedgerData()

bool ripple::InboundLedgersImp::gotLedgerData	(	LedgerHash const &	hash,
		std::shared_ptr< Peer >	peer,
		std::shared_ptr< protocol::TMLedgerData >	packet
	)

overridevirtual

We received a TMLedgerData from a peer.

Implements ripple::InboundLedgers.

Definition at line 182 of file InboundLedgers.cpp.

◆ logFailure()

void ripple::InboundLedgersImp::logFailure	(	uint256 const &	h,
		std::uint32_t	seq
	)

overridevirtual

Implements ripple::InboundLedgers.

Definition at line 220 of file InboundLedgers.cpp.

◆ isFailure()

bool ripple::InboundLedgersImp::isFailure ( uint256 const & h )

overridevirtual

Implements ripple::InboundLedgers.

Definition at line 228 of file InboundLedgers.cpp.

◆ gotStaleData()

void ripple::InboundLedgersImp::gotStaleData ( std::shared_ptr< protocol::TMLedgerData > packet_ptr )

overridevirtual

We got some data for a ledger we are no longer acquiring Since we paid the price to receive it, we might as well stash it in case we need it.

Nodes are received in wire format and must be stashed/hashed in prefix format

Implements ripple::InboundLedgers.

Definition at line 243 of file InboundLedgers.cpp.

◆ clearFailures()

void ripple::InboundLedgersImp::clearFailures ( )

overridevirtual

Implements ripple::InboundLedgers.

Definition at line 275 of file InboundLedgers.cpp.

◆ fetchRate()

std::size_t ripple::InboundLedgersImp::fetchRate ( )

overridevirtual

Returns the rate of historical ledger fetches per minute.

Implements ripple::InboundLedgers.

Definition at line 284 of file InboundLedgers.cpp.

◆ onLedgerFetched()

void ripple::InboundLedgersImp::onLedgerFetched ( )

overridevirtual

Called when a complete ledger is obtained.

Implements ripple::InboundLedgers.

Definition at line 293 of file InboundLedgers.cpp.

◆ getInfo()

Json::Value ripple::InboundLedgersImp::getInfo ( )

overridevirtual

Implements ripple::InboundLedgers.

Definition at line 300 of file InboundLedgers.cpp.

◆ gotFetchPack()

void ripple::InboundLedgersImp::gotFetchPack ( )

overridevirtual

Implements ripple::InboundLedgers.

Definition at line 340 of file InboundLedgers.cpp.

◆ sweep()

void ripple::InboundLedgersImp::sweep ( )

overridevirtual

Implements ripple::InboundLedgers.

Definition at line 364 of file InboundLedgers.cpp.

◆ stop()

void ripple::InboundLedgersImp::stop ( )

overridevirtual

Implements ripple::InboundLedgers.

Definition at line 414 of file InboundLedgers.cpp.

◆ cacheSize()

std::size_t ripple::InboundLedgersImp::cacheSize ( )

overridevirtual

Implements ripple::InboundLedgers.

Definition at line 423 of file InboundLedgers.cpp.

◆ find() [2/2]

virtual std::shared_ptr< InboundLedger > ripple::InboundLedgers::find ( LedgerHash const & hash )

pure virtualinherited

Implemented in ripple::test::MagicInboundLedgers.

Member Data Documentation

◆ app_

Application& ripple::InboundLedgersImp::app_

private

Definition at line 24 of file InboundLedgers.cpp.

◆ fetchRateMutex_

std::mutex ripple::InboundLedgersImp::fetchRateMutex_

private

Definition at line 25 of file InboundLedgers.cpp.

◆ fetchRate_

DecayWindow<30, clock_type> ripple::InboundLedgersImp::fetchRate_

private

Definition at line 27 of file InboundLedgers.cpp.

◆ j_

beast::Journal const ripple::InboundLedgersImp::j_

private

Definition at line 28 of file InboundLedgers.cpp.

◆ kReacquireInterval

constexpr std::chrono::minutes const ripple::InboundLedgersImp::kReacquireInterval {5}

staticconstexpr

Definition at line 32 of file InboundLedgers.cpp.

◆ m_clock

clock_type& ripple::InboundLedgersImp::m_clock

private

Definition at line 430 of file InboundLedgers.cpp.

◆ mLock

std::recursive_mutex ripple::InboundLedgersImp::mLock

private

Definition at line 433 of file InboundLedgers.cpp.

◆ stopping_

bool ripple::InboundLedgersImp::stopping_ = false

private

Definition at line 435 of file InboundLedgers.cpp.

◆ mLedgers

MapType ripple::InboundLedgersImp::mLedgers

private

Definition at line 437 of file InboundLedgers.cpp.

◆ mRecentFailures

beast::aged_map<uint256, std::uint32_t> ripple::InboundLedgersImp::mRecentFailures

private

Definition at line 439 of file InboundLedgers.cpp.

◆ mCounter

beast::insight::Counter ripple::InboundLedgersImp::mCounter

private

Definition at line 441 of file InboundLedgers.cpp.

◆ mPeerSetBuilder

std::unique_ptr<PeerSetBuilder> ripple::InboundLedgersImp::mPeerSetBuilder

private

Definition at line 443 of file InboundLedgers.cpp.

◆ pendingAcquires_

std::set<uint256> ripple::InboundLedgersImp::pendingAcquires_

private

Definition at line 445 of file InboundLedgers.cpp.

◆ acquiresMutex_

std::mutex ripple::InboundLedgersImp::acquiresMutex_

private

Definition at line 446 of file InboundLedgers.cpp.

Public Types

Public Member Functions

Static Public Attributes

Private Types

Private Attributes

Detailed Description

Member Typedef Documentation

◆ ScopedLockType

◆ MapType

◆ clock_type

Constructor & Destructor Documentation

◆ InboundLedgersImp()

Member Function Documentation

◆ acquire()

◆ acquireAsync()

◆ find() [1/2]

◆ gotLedgerData()

◆ logFailure()

◆ isFailure()

◆ gotStaleData()

◆ clearFailures()

◆ fetchRate()

◆ onLedgerFetched()

◆ getInfo()

◆ gotFetchPack()

◆ sweep()

◆ stop()

◆ cacheSize()

◆ find() [2/2]

Member Data Documentation

◆ app_

◆ fetchRateMutex_

◆ fetchRate_

◆ j_

◆ kReacquireInterval

◆ m_clock

◆ mLock

◆ stopping_

◆ mLedgers

◆ mRecentFailures

◆ mCounter

◆ mPeerSetBuilder

◆ pendingAcquires_

◆ acquiresMutex_