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 72 of file LedgerReplayer.h.

Constructor & Destructor Documentation

LedgerReplayer()

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

Definition at line 26 of file LedgerReplayer.cpp.

~LedgerReplayer()

ripple::LedgerReplayer::~LedgerReplayer

(

)

Definition at line 37 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 44 of file LedgerReplayer.cpp.

createDeltas()

void ripple::LedgerReplayer::createDeltas

(

std::shared_ptr< LedgerReplayTask >

task

)

Create LedgerDeltaAcquire subtasks for the LedgerReplayTask task.

Definition at line 112 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 173 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 196 of file LedgerReplayer.cpp.

sweep()

void ripple::LedgerReplayer::sweep

(

)

Remove completed tasks.

Definition at line 219 of file LedgerReplayer.cpp.

stop()

void ripple::LedgerReplayer::stop

(

)

Definition at line 265 of file LedgerReplayer.cpp.

tasksSize()

std::size_t ripple::LedgerReplayer::tasksSize

(

)

const

Definition at line 129 of file LedgerReplayer.h.

deltasSize()

std::size_t ripple::LedgerReplayer::deltasSize

(

)

const

Definition at line 136 of file LedgerReplayer.h.

skipListsSize()

std::size_t ripple::LedgerReplayer::skipListsSize

(

)

const

Definition at line 143 of file LedgerReplayer.h.

Friends And Related Symbol Documentation

test::LedgerReplayClient

friend class test::LedgerReplayClient

friend

Definition at line 160 of file LedgerReplayer.h.

Member Data Documentation

mtx_

std::mutex ripple::LedgerReplayer::mtx_

mutableprivate

Definition at line 150 of file LedgerReplayer.h.

tasks_

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

private

Definition at line 151 of file LedgerReplayer.h.

deltas_

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

private

Definition at line 152 of file LedgerReplayer.h.

skipLists_

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

private

Definition at line 153 of file LedgerReplayer.h.

app_

Application& ripple::LedgerReplayer::app_

private

Definition at line 155 of file LedgerReplayer.h.

inboundLedgers_

InboundLedgers& ripple::LedgerReplayer::inboundLedgers_

private

Definition at line 156 of file LedgerReplayer.h.

peerSetBuilder_

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

private

Definition at line 157 of file LedgerReplayer.h.

j_

beast::Journal ripple::LedgerReplayer::j_

private

Definition at line 158 of file LedgerReplayer.h.