Simulate two entities - peer directly connected to the server (via squelch in PeerSim) and PeerImp (via Overlay) More...

Inheritance diagram for ripple::test::PeerPartial:

[legend]

Collaboration diagram for ripple::test::PeerPartial:

[legend]

Public Types
using	ptr = std::shared_ptr< Peer >

using	id_t = std::uint32_t
	Uniquely identifies a peer. More...

Public Member Functions
virtual	~PeerPartial ()

virtual void	onMessage (MessageSPtr const &m, SquelchCB f)=0

virtual void	onMessage (protocol::TMSquelch const &squelch)=0

void	send (protocol::TMSquelch const &squelch)

void	send (std::shared_ptr< Message > const &m) override

beast::IP::Endpoint	getRemoteAddress () const override

void	charge (Resource::Charge const &fee) override
	Adjust this peer's load balance based on the type of load imposed. More...

bool	cluster () const override
	Returns `true` if this connection is a member of the cluster. More...

bool	isHighLatency () const override

int	getScore (bool) const override

PublicKey const &	getNodePublic () const override

Json::Value	json () override

bool	supportsFeature (ProtocolFeature f) const override

std::optional< std::size_t >	publisherListSequence (PublicKey const &) const override

void	setPublisherListSequence (PublicKey const &, std::size_t const) override

uint256 const &	getClosedLedgerHash () const override

bool	hasLedger (uint256 const &hash, std::uint32_t seq) const override

void	ledgerRange (std::uint32_t &minSeq, std::uint32_t &maxSeq) const override

bool	hasTxSet (uint256 const &hash) const override

void	cycleStatus () override

bool	hasRange (std::uint32_t uMin, std::uint32_t uMax) override

bool	compressionEnabled () const override

bool	txReduceRelayEnabled () const override

void	sendTxQueue () override
	Send aggregated transactions' hashes. More...

void	addTxQueue (const uint256 &) override
	Aggregate transaction's hash. More...

void	removeTxQueue (const uint256 &) override
	Remove hash from the transactions' hashes queue. More...

virtual id_t	id () const =0

Detailed Description

Simulate two entities - peer directly connected to the server (via squelch in PeerSim) and PeerImp (via Overlay)

Definition at line 58 of file reduce_relay_test.cpp.

Member Typedef Documentation

◆ ptr

using ripple::Peer::ptr = std::shared_ptr<Peer>

inherited

Definition at line 48 of file ripple/overlay/Peer.h.

◆ id_t

using ripple::Peer::id_t = std::uint32_t

inherited

Uniquely identifies a peer.

This can be stored in tables to find the peer later. Callers can discover if the peer is no longer connected and make adjustments as needed.

Definition at line 55 of file ripple/overlay/Peer.h.

Constructor & Destructor Documentation

◆ ~PeerPartial()

virtual ripple::test::PeerPartial::~PeerPartial ( )

virtual

Definition at line 61 of file reduce_relay_test.cpp.

Member Function Documentation

◆ onMessage() [1/2]

virtual void ripple::test::PeerPartial::onMessage	(	MessageSPtr const &	m,
		SquelchCB	f
	)

pure virtual

Implemented in ripple::test::PeerSim.

◆ onMessage() [2/2]

virtual void ripple::test::PeerPartial::onMessage ( protocol::TMSquelch const & squelch )

pure virtual

Implemented in ripple::test::PeerSim.

◆ send() [1/2]

void ripple::test::PeerPartial::send ( protocol::TMSquelch const & squelch )

Definition at line 69 of file reduce_relay_test.cpp.

◆ send() [2/2]

void ripple::test::PeerPartial::send ( std::shared_ptr< Message > const & m )

overridevirtual

Implements ripple::Peer.

Definition at line 76 of file reduce_relay_test.cpp.

◆ getRemoteAddress()

beast::IP::Endpoint ripple::test::PeerPartial::getRemoteAddress ( ) const

overridevirtual

Implements ripple::Peer.

Definition at line 80 of file reduce_relay_test.cpp.

◆ charge()

void ripple::test::PeerPartial::charge ( Resource::Charge const & fee )

overridevirtual

Adjust this peer's load balance based on the type of load imposed.

Implements ripple::Peer.

Definition at line 85 of file reduce_relay_test.cpp.

◆ cluster()

bool ripple::test::PeerPartial::cluster ( ) const

overridevirtual

Returns true if this connection is a member of the cluster.

Implements ripple::Peer.

Definition at line 89 of file reduce_relay_test.cpp.

◆ isHighLatency()

bool ripple::test::PeerPartial::isHighLatency ( ) const

overridevirtual

Implements ripple::Peer.

Definition at line 94 of file reduce_relay_test.cpp.

◆ getScore()

int ripple::test::PeerPartial::getScore ( bool ) const

overridevirtual

Implements ripple::Peer.

Definition at line 99 of file reduce_relay_test.cpp.

◆ getNodePublic()

PublicKey const& ripple::test::PeerPartial::getNodePublic ( ) const

overridevirtual

Implements ripple::Peer.

Definition at line 104 of file reduce_relay_test.cpp.

◆ json()

Json::Value ripple::test::PeerPartial::json ( )

overridevirtual

Implements ripple::Peer.

Definition at line 110 of file reduce_relay_test.cpp.

◆ supportsFeature()

bool ripple::test::PeerPartial::supportsFeature ( ProtocolFeature f ) const

overridevirtual

Implements ripple::Peer.

Definition at line 115 of file reduce_relay_test.cpp.

◆ publisherListSequence()

std::optional<std::size_t> ripple::test::PeerPartial::publisherListSequence ( PublicKey const & ) const

overridevirtual

Implements ripple::Peer.

Definition at line 120 of file reduce_relay_test.cpp.

◆ setPublisherListSequence()

void ripple::test::PeerPartial::setPublisherListSequence	(	PublicKey const &	,
		std::size_t const
	)

overridevirtual

Implements ripple::Peer.

Definition at line 125 of file reduce_relay_test.cpp.

◆ getClosedLedgerHash()

uint256 const& ripple::test::PeerPartial::getClosedLedgerHash ( ) const

overridevirtual

Implements ripple::Peer.

Definition at line 129 of file reduce_relay_test.cpp.

◆ hasLedger()

bool ripple::test::PeerPartial::hasLedger	(	uint256 const &	hash,
		std::uint32_t	seq
	)		const

overridevirtual

Implements ripple::Peer.

Definition at line 135 of file reduce_relay_test.cpp.

◆ ledgerRange()

void ripple::test::PeerPartial::ledgerRange	(	std::uint32_t &	minSeq,
		std::uint32_t &	maxSeq
	)		const

overridevirtual

Implements ripple::Peer.

Definition at line 140 of file reduce_relay_test.cpp.

◆ hasTxSet()

bool ripple::test::PeerPartial::hasTxSet ( uint256 const & hash ) const

overridevirtual

Implements ripple::Peer.

Definition at line 144 of file reduce_relay_test.cpp.

◆ cycleStatus()

void ripple::test::PeerPartial::cycleStatus ( )

overridevirtual

Implements ripple::Peer.

Definition at line 149 of file reduce_relay_test.cpp.

◆ hasRange()

bool ripple::test::PeerPartial::hasRange	(	std::uint32_t	uMin,
		std::uint32_t	uMax
	)

overridevirtual

Implements ripple::Peer.

Definition at line 153 of file reduce_relay_test.cpp.

◆ compressionEnabled()

bool ripple::test::PeerPartial::compressionEnabled ( ) const

overridevirtual

Implements ripple::Peer.

Definition at line 158 of file reduce_relay_test.cpp.

◆ txReduceRelayEnabled()

bool ripple::test::PeerPartial::txReduceRelayEnabled ( ) const

overridevirtual

Implements ripple::Peer.

Definition at line 163 of file reduce_relay_test.cpp.

◆ sendTxQueue()

void ripple::test::PeerPartial::sendTxQueue ( )

overridevirtual

Send aggregated transactions' hashes.

Implements ripple::Peer.

Definition at line 168 of file reduce_relay_test.cpp.

◆ addTxQueue()

void ripple::test::PeerPartial::addTxQueue ( const uint256 & )

overridevirtual

Aggregate transaction's hash.

Implements ripple::Peer.

Definition at line 172 of file reduce_relay_test.cpp.

◆ removeTxQueue()

void ripple::test::PeerPartial::removeTxQueue ( const uint256 & )

overridevirtual

Remove hash from the transactions' hashes queue.

Implements ripple::Peer.

Definition at line 176 of file reduce_relay_test.cpp.

◆ id()

virtual id_t ripple::Peer::id ( ) const

pure virtualinherited

Implemented in ripple::test::PeerSim, ripple::PeerImp, and ripple::test::TestPeer.

Public Types

Public Member Functions

Detailed Description

Member Typedef Documentation

◆ ptr

◆ id_t

Constructor & Destructor Documentation

◆ ~PeerPartial()

Member Function Documentation

◆ onMessage() [1/2]

◆ onMessage() [2/2]

◆ send() [1/2]

◆ send() [2/2]

◆ getRemoteAddress()

◆ charge()

◆ cluster()

◆ isHighLatency()

◆ getScore()

◆ getNodePublic()

◆ json()

◆ supportsFeature()

◆ publisherListSequence()

◆ setPublisherListSequence()

◆ getClosedLedgerHash()

◆ hasLedger()

◆ ledgerRange()

◆ hasTxSet()

◆ cycleStatus()

◆ hasRange()

◆ compressionEnabled()

◆ txReduceRelayEnabled()

◆ sendTxQueue()

◆ addTxQueue()

◆ removeTxQueue()

◆ id()