xrpl::test::OverlaySim Class Reference

Inheritance diagram for xrpl::test::OverlaySim:

Collaboration diagram for xrpl::test::OverlaySim:

Public Types
using	ID = Peer::ID
using	ClockType = ManualClock

Public Member Functions
	OverlaySim (Application &app)
	~OverlaySim () override=default
void	clear ()
std::uint16_t	inState (PublicKey const &validator, reduce_relay::PeerState state)
void	updateSlotAndSquelch (UInt256 const &key, PublicKey const &validator, Peer::ID id, SquelchCB f, protocol::MessageType type=protocol::mtVALIDATION) override
void	deletePeer (ID id, UnsquelchCB f) override
void	deleteIdlePeers (UnsquelchCB f) override
PeerSPtr	addPeer (bool useCache=true)
void	deletePeer (Peer::ID id, bool useCache=true)
void	resetPeers ()
std::optional< Peer::ID >	deleteLastPeer ()
bool	isCountingState (PublicKey const &validator)
std::set< ID >	getSelected (PublicKey const &validator)
bool	isSelected (PublicKey const &validator, Peer::ID peer)
ID	getSelectedPeer (PublicKey const &validator)
std::unordered_map< ID, std::tuple< reduce_relay::PeerState, std::uint16_t, std::uint32_t, std::uint32_t > >	getPeers (PublicKey const &validator)
std::uint16_t	getNumPeers () const

Private Types
using	Peers = std::unordered_map<Peer::ID, PeerSPtr>

Private Member Functions
void	squelch (PublicKey const &validator, Peer::ID id, std::uint32_t squelchDuration) const override
	Squelch handler.
void	unsquelch (PublicKey const &validator, Peer::ID id) const override
	Unsquelch handler.

Private Attributes
SquelchCB	squelch_
UnsquelchCB	unsquelch_
Peers	peers_
Peers	peersCache_
reduce_relay::Slots< ManualClock >	slots_
ServiceRegistry &	registry_

Detailed Description

Definition at line 414 of file reduce_relay_test.cpp.

Member Typedef Documentation

Peers

using xrpl::test::OverlaySim::Peers = std::unordered_map<Peer::ID, PeerSPtr>

private

Definition at line 416 of file reduce_relay_test.cpp.

ID

using xrpl::test::OverlaySim::ID = Peer::ID

Definition at line 419 of file reduce_relay_test.cpp.

ClockType

using xrpl::test::OverlaySim::ClockType = ManualClock

Definition at line 420 of file reduce_relay_test.cpp.

Constructor & Destructor Documentation

OverlaySim()

xrpl::test::OverlaySim::OverlaySim

(

Application &

app

)

Definition at line 421 of file reduce_relay_test.cpp.

~OverlaySim()

xrpl::test::OverlaySim::~OverlaySim ( )

overridedefault

Member Function Documentation

clear()

void xrpl::test::OverlaySim::clear

(

)

Definition at line 428 of file reduce_relay_test.cpp.

inState()

std::uint16_t xrpl::test::OverlaySim::inState	(	PublicKey const &	validator,
		reduce_relay::PeerState	state )

Definition at line 436 of file reduce_relay_test.cpp.

updateSlotAndSquelch()

void xrpl::test::OverlaySim::updateSlotAndSquelch ( UInt256 const & key, PublicKey const & validator, Peer::ID id, SquelchCB f, protocol::MessageType type = protocol::mtVALIDATION )

overridevirtual

Implements xrpl::test::Overlay.

Definition at line 443 of file reduce_relay_test.cpp.

deletePeer() [1/2]

void xrpl::test::OverlaySim::deletePeer ( ID id, UnsquelchCB f )

overridevirtual

Implements xrpl::test::Overlay.

Definition at line 455 of file reduce_relay_test.cpp.

deleteIdlePeers()

void xrpl::test::OverlaySim::deleteIdlePeers ( UnsquelchCB f )

overridevirtual

Implements xrpl::test::Overlay.

Definition at line 462 of file reduce_relay_test.cpp.

addPeer()

PeerSPtr xrpl::test::OverlaySim::addPeer

(

bool

useCache = true

)

Definition at line 469 of file reduce_relay_test.cpp.

deletePeer() [2/2]

void xrpl::test::OverlaySim::deletePeer	(	Peer::ID	id,
		bool	useCache = true )

Definition at line 490 of file reduce_relay_test.cpp.

resetPeers()

void xrpl::test::OverlaySim::resetPeers

(

)

Definition at line 501 of file reduce_relay_test.cpp.

deleteLastPeer()

std::optional< Peer::ID > xrpl::test::OverlaySim::deleteLastPeer

(

)

Definition at line 510 of file reduce_relay_test.cpp.

isCountingState()

bool xrpl::test::OverlaySim::isCountingState

(

PublicKey const &

validator

)

Definition at line 529 of file reduce_relay_test.cpp.

getSelected()

std::set< ID > xrpl::test::OverlaySim::getSelected

(

PublicKey const &

validator

)

Definition at line 535 of file reduce_relay_test.cpp.

isSelected()

bool xrpl::test::OverlaySim::isSelected	(	PublicKey const &	validator,
		Peer::ID	peer )

Definition at line 541 of file reduce_relay_test.cpp.

getSelectedPeer()

ID xrpl::test::OverlaySim::getSelectedPeer

(

PublicKey const &

validator

)

Definition at line 548 of file reduce_relay_test.cpp.

getPeers()

std::unordered_map< ID, std::tuple< reduce_relay::PeerState, std::uint16_t, std::uint32_t, std::uint32_t > > xrpl::test::OverlaySim::getPeers

(

PublicKey const &

validator

)

Definition at line 558 of file reduce_relay_test.cpp.

getNumPeers()

std::uint16_t xrpl::test::OverlaySim::getNumPeers

(

)

const

Definition at line 564 of file reduce_relay_test.cpp.

squelch()

void xrpl::test::OverlaySim::squelch ( PublicKey const & validator, Peer::ID id, std::uint32_t duration ) const

overrideprivatevirtual

Squelch handler.

Parameters

validator	Public key of the source validator
id	Peer's id to squelch
duration	Squelch duration in seconds

Implements xrpl::reduce_relay::SquelchHandler.

Definition at line 571 of file reduce_relay_test.cpp.

unsquelch()

void xrpl::test::OverlaySim::unsquelch ( PublicKey const & validator, Peer::ID id ) const

overrideprivatevirtual

Unsquelch handler.

Parameters

validator	Public key of the source validator
id	Peer's id to unsquelch

Implements xrpl::reduce_relay::SquelchHandler.

Definition at line 577 of file reduce_relay_test.cpp.

Member Data Documentation

squelch_

SquelchCB xrpl::test::OverlaySim::squelch_

private

Definition at line 582 of file reduce_relay_test.cpp.

unsquelch_

UnsquelchCB xrpl::test::OverlaySim::unsquelch_

private

Definition at line 583 of file reduce_relay_test.cpp.

peers_

Peers xrpl::test::OverlaySim::peers_

private

Definition at line 584 of file reduce_relay_test.cpp.

peersCache_

Peers xrpl::test::OverlaySim::peersCache_

private

Definition at line 585 of file reduce_relay_test.cpp.

slots_

reduce_relay::Slots<ManualClock> xrpl::test::OverlaySim::slots_

private

Definition at line 586 of file reduce_relay_test.cpp.

registry_

ServiceRegistry& xrpl::test::OverlaySim::registry_

private

Definition at line 587 of file reduce_relay_test.cpp.