ripple::LedgerReplayer Class Reference

Manages the lifetime of ledger replay tasks. More...

#include <LedgerReplayer.h>

Collaboration diagram for ripple::LedgerReplayer:

Public Member Functions
	LedgerReplayer (Application &app, InboundLedgers &inboundLedgers, std::unique_ptr< PeerSetBuilder > peerSetBuilder)
	~LedgerReplayer ()
void	replay (InboundLedger::Reason r, uint256 const &finishLedgerHash, std::uint32_t totalNumLedgers)
	Replay a range of ledgers.
void	createDeltas (std::shared_ptr< LedgerReplayTask > task)
	Create LedgerDeltaAcquire subtasks for the LedgerReplayTask task.
void	gotSkipList (LedgerInfo const &info, boost::intrusive_ptr< SHAMapItem const > const &data)
	Process a skip list (extracted from a TMProofPathResponse message)
void	gotReplayDelta (LedgerInfo const &info, std::map< std::uint32_t, std::shared_ptr< STTx const > > &&txns)
	Process a ledger delta (extracted from a TMReplayDeltaResponse message)
void	sweep ()
	Remove completed tasks.
void	stop ()
std::size_t	tasksSize () const
std::size_t	deltasSize () const
std::size_t	skipListsSize () const

Private Attributes
std::mutex	mtx_
std::vector< std::shared_ptr< LedgerReplayTask > >	tasks_
hash_map< uint256, std::weak_ptr< LedgerDeltaAcquire > >	deltas_
hash_map< uint256, std::weak_ptr< SkipListAcquire > >	skipLists_
Application &	app_
InboundLedgers &	inboundLedgers_
std::unique_ptr< PeerSetBuilder >	peerSetBuilder_
beast::Journal	j_

Friends
class	test::LedgerReplayClient

Detailed Description

Manages the lifetime of ledger replay tasks.

Definition at line 53 of file LedgerReplayer.h.

Constructor & Destructor Documentation

LedgerReplayer()

ripple::LedgerReplayer::LedgerReplayer	(	Application &	app,
		InboundLedgers &	inboundLedgers,
		std::unique_ptr< PeerSetBuilder >	peerSetBuilder
	)

Definition at line 7 of file LedgerReplayer.cpp.

~LedgerReplayer()

ripple::LedgerReplayer::~LedgerReplayer

(

)

Definition at line 18 of file LedgerReplayer.cpp.

Member Function Documentation

replay()

void ripple::LedgerReplayer::replay	(	InboundLedger::Reason	r,
		uint256 const &	finishLedgerHash,
		std::uint32_t	totalNumLedgers
	)

Replay a range of ledgers.

Parameters

r	reason for the replay request
finishLedgerHash	hash of the last ledger
totalNumLedgers	total number of ledgers in the range, inclusive

Note

totalNumLedgers must > 0 && totalNumLedgers must <= 256

Definition at line 25 of file LedgerReplayer.cpp.

createDeltas()

void ripple::LedgerReplayer::createDeltas

(

std::shared_ptr< LedgerReplayTask >

task

)

Create LedgerDeltaAcquire subtasks for the LedgerReplayTask task.

Definition at line 93 of file LedgerReplayer.cpp.

gotSkipList()

void ripple::LedgerReplayer::gotSkipList	(	LedgerInfo const &	info,
		boost::intrusive_ptr< SHAMapItem const > const &	data
	)

Process a skip list (extracted from a TMProofPathResponse message)

Parameters

info	ledger info
data	skip list holder

Note

info and data must have been verified against the ledger hash

Definition at line 154 of file LedgerReplayer.cpp.

gotReplayDelta()

void ripple::LedgerReplayer::gotReplayDelta	(	LedgerInfo const &	info,
		std::map< std::uint32_t, std::shared_ptr< STTx const > > &&	txns
	)

Process a ledger delta (extracted from a TMReplayDeltaResponse message)

Parameters

info	ledger info
txns	set of Txns of the ledger

Note

info and txns must have been verified against the ledger hash

Definition at line 177 of file LedgerReplayer.cpp.

sweep()

void ripple::LedgerReplayer::sweep

(

)

Remove completed tasks.

Definition at line 200 of file LedgerReplayer.cpp.

stop()

void ripple::LedgerReplayer::stop

(

)

Definition at line 246 of file LedgerReplayer.cpp.

tasksSize()

std::size_t ripple::LedgerReplayer::tasksSize

(

)

const

Definition at line 110 of file LedgerReplayer.h.

deltasSize()

std::size_t ripple::LedgerReplayer::deltasSize

(

)

const

Definition at line 117 of file LedgerReplayer.h.

skipListsSize()

std::size_t ripple::LedgerReplayer::skipListsSize

(

)

const

Definition at line 124 of file LedgerReplayer.h.

Friends And Related Symbol Documentation

test::LedgerReplayClient

friend class test::LedgerReplayClient

friend

Definition at line 141 of file LedgerReplayer.h.

Member Data Documentation

mtx_

std::mutex ripple::LedgerReplayer::mtx_

mutableprivate

Definition at line 131 of file LedgerReplayer.h.

tasks_

std::vector<std::shared_ptr<LedgerReplayTask> > ripple::LedgerReplayer::tasks_

private

Definition at line 132 of file LedgerReplayer.h.

deltas_

hash_map<uint256, std::weak_ptr<LedgerDeltaAcquire> > ripple::LedgerReplayer::deltas_

private

Definition at line 133 of file LedgerReplayer.h.

skipLists_

hash_map<uint256, std::weak_ptr<SkipListAcquire> > ripple::LedgerReplayer::skipLists_

private

Definition at line 134 of file LedgerReplayer.h.

app_

Application& ripple::LedgerReplayer::app_

private

Definition at line 136 of file LedgerReplayer.h.

inboundLedgers_

InboundLedgers& ripple::LedgerReplayer::inboundLedgers_

private

Definition at line 137 of file LedgerReplayer.h.

peerSetBuilder_

std::unique_ptr<PeerSetBuilder> ripple::LedgerReplayer::peerSetBuilder_

private

Definition at line 138 of file LedgerReplayer.h.

j_

beast::Journal ripple::LedgerReplayer::j_

private

Definition at line 139 of file LedgerReplayer.h.