rippled
Loading...
Searching...
No Matches
Public Types | Public Member Functions | Static Public Member Functions | Public Attributes | Private Attributes | Static Private Attributes | List of all members
xrpl::test::PeerSim Class Reference
Inheritance diagram for xrpl::test::PeerSim:
Inheritance graph
[legend]
Collaboration diagram for xrpl::test::PeerSim:
Collaboration graph
[legend]

Public Types

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

Public Member Functions

 PeerSim (Overlay &overlay, beast::Journal journal)
 
 ~PeerSim ()=default
 
id_t id () const override
 
std::string const & fingerprint () const override
 
void onMessage (MessageSPtr const &m, SquelchCB f) override
 Local Peer (PeerImp)
 
virtual void onMessage (protocol::TMSquelch const &squelch) override
 Remote Peer (Directly connected Peer)
 
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, std::string const &context={}) override
 Adjust this peer's load balance based on the type of load imposed.
 
bool cluster () const override
 Returns true if this connection is a member of the cluster.
 
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.
 
void addTxQueue (uint256 const &) override
 Aggregate transaction's hash.
 
void removeTxQueue (uint256 const &) override
 Remove hash from the transactions' hashes queue.
 
T shared_from_this (T... args)
 
T weak_from_this (T... args)
 

Static Public Member Functions

static void resetId ()
 

Public Attributes

PublicKey nodePublicKey_
 

Private Attributes

std::string fingerprint_
 
id_t id_
 
Overlay & overlay_
 
reduce_relay::Squelch< ManualClock > squelch_
 

Static Private Attributes

static id_t sid_ = 0
 

Detailed Description

Definition at line 431 of file reduce_relay_test.cpp.

Member Typedef Documentation

◆ id_t

using xrpl::test::PeerSim::id_t = Peer::id_t

Definition at line 434 of file reduce_relay_test.cpp.

◆ ptr

using xrpl::Peer::ptr = std::shared_ptr<Peer>
inherited

Definition at line 26 of file xrpld/overlay/Peer.h.

Constructor & Destructor Documentation

◆ PeerSim()

xrpl::test::PeerSim::PeerSim ( Overlay &  overlay,
beast::Journal  journal 
)

Definition at line 435 of file reduce_relay_test.cpp.

◆ ~PeerSim()

xrpl::test::PeerSim::~PeerSim ( )
default

Member Function Documentation

◆ id()

id_t xrpl::test::PeerSim::id ( ) const
overridevirtual

Implements xrpl::Peer.

Definition at line 443 of file reduce_relay_test.cpp.

◆ fingerprint()

std::string const & xrpl::test::PeerSim::fingerprint ( ) const
overridevirtual

Implements xrpl::Peer.

Definition at line 449 of file reduce_relay_test.cpp.

◆ resetId()

static void xrpl::test::PeerSim::resetId ( )
static

Definition at line 455 of file reduce_relay_test.cpp.

◆ onMessage() [1/2]

void xrpl::test::PeerSim::onMessage ( MessageSPtr const &  m,
SquelchCB  f 
)
overridevirtual

Local Peer (PeerImp)

Implements xrpl::test::PeerPartial.

Definition at line 462 of file reduce_relay_test.cpp.

◆ onMessage() [2/2]

virtual void xrpl::test::PeerSim::onMessage ( protocol::TMSquelch const &  squelch)
overridevirtual

Remote Peer (Directly connected Peer)

Implements xrpl::test::PeerPartial.

Definition at line 474 of file reduce_relay_test.cpp.

◆ send() [1/2]

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

Definition at line 61 of file reduce_relay_test.cpp.

◆ send() [2/2]

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

Implements xrpl::Peer.

Definition at line 68 of file reduce_relay_test.cpp.

◆ getRemoteAddress()

beast::IP::Endpoint xrpl::test::PeerPartial::getRemoteAddress ( ) const
overridevirtualinherited

Implements xrpl::Peer.

Definition at line 72 of file reduce_relay_test.cpp.

◆ charge()

void xrpl::test::PeerPartial::charge ( Resource::Charge const &  fee,
std::string const &  context = {} 
)
overridevirtualinherited

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

Implements xrpl::Peer.

Definition at line 77 of file reduce_relay_test.cpp.

◆ cluster()

bool xrpl::test::PeerPartial::cluster ( ) const
overridevirtualinherited

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

Implements xrpl::Peer.

Definition at line 81 of file reduce_relay_test.cpp.

◆ isHighLatency()

bool xrpl::test::PeerPartial::isHighLatency ( ) const
overridevirtualinherited

Implements xrpl::Peer.

Definition at line 86 of file reduce_relay_test.cpp.

◆ getScore()

int xrpl::test::PeerPartial::getScore ( bool  ) const
overridevirtualinherited

Implements xrpl::Peer.

Definition at line 91 of file reduce_relay_test.cpp.

◆ getNodePublic()

PublicKey const & xrpl::test::PeerPartial::getNodePublic ( ) const
overridevirtualinherited

Implements xrpl::Peer.

Definition at line 96 of file reduce_relay_test.cpp.

◆ json()

Json::Value xrpl::test::PeerPartial::json ( )
overridevirtualinherited

Implements xrpl::Peer.

Definition at line 101 of file reduce_relay_test.cpp.

◆ supportsFeature()

bool xrpl::test::PeerPartial::supportsFeature ( ProtocolFeature  f) const
overridevirtualinherited

Implements xrpl::Peer.

Definition at line 106 of file reduce_relay_test.cpp.

◆ publisherListSequence()

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

Implements xrpl::Peer.

Definition at line 111 of file reduce_relay_test.cpp.

◆ setPublisherListSequence()

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

Implements xrpl::Peer.

Definition at line 116 of file reduce_relay_test.cpp.

◆ getClosedLedgerHash()

uint256 const & xrpl::test::PeerPartial::getClosedLedgerHash ( ) const
overridevirtualinherited

Implements xrpl::Peer.

Definition at line 120 of file reduce_relay_test.cpp.

◆ hasLedger()

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

Implements xrpl::Peer.

Definition at line 126 of file reduce_relay_test.cpp.

◆ ledgerRange()

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

Implements xrpl::Peer.

Definition at line 131 of file reduce_relay_test.cpp.

◆ hasTxSet()

bool xrpl::test::PeerPartial::hasTxSet ( uint256 const &  hash) const
overridevirtualinherited

Implements xrpl::Peer.

Definition at line 135 of file reduce_relay_test.cpp.

◆ cycleStatus()

void xrpl::test::PeerPartial::cycleStatus ( )
overridevirtualinherited

Implements xrpl::Peer.

Definition at line 140 of file reduce_relay_test.cpp.

◆ hasRange()

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

Implements xrpl::Peer.

Definition at line 144 of file reduce_relay_test.cpp.

◆ compressionEnabled()

bool xrpl::test::PeerPartial::compressionEnabled ( ) const
overridevirtualinherited

Implements xrpl::Peer.

Definition at line 149 of file reduce_relay_test.cpp.

◆ txReduceRelayEnabled()

bool xrpl::test::PeerPartial::txReduceRelayEnabled ( ) const
overridevirtualinherited

Implements xrpl::Peer.

Definition at line 154 of file reduce_relay_test.cpp.

◆ sendTxQueue()

void xrpl::test::PeerPartial::sendTxQueue ( )
overridevirtualinherited

Send aggregated transactions' hashes.

Implements xrpl::Peer.

Definition at line 159 of file reduce_relay_test.cpp.

◆ addTxQueue()

void xrpl::test::PeerPartial::addTxQueue ( uint256 const &  )
overridevirtualinherited

Aggregate transaction's hash.

Implements xrpl::Peer.

Definition at line 163 of file reduce_relay_test.cpp.

◆ removeTxQueue()

void xrpl::test::PeerPartial::removeTxQueue ( uint256 const &  )
overridevirtualinherited

Remove hash from the transactions' hashes queue.

Implements xrpl::Peer.

Definition at line 167 of file reduce_relay_test.cpp.

Member Data Documentation

◆ sid_

id_t xrpl::test::PeerSim::sid_ = 0
staticprivate

Definition at line 485 of file reduce_relay_test.cpp.

◆ fingerprint_

std::string xrpl::test::PeerSim::fingerprint_
private

Definition at line 486 of file reduce_relay_test.cpp.

◆ id_

id_t xrpl::test::PeerSim::id_
private

Definition at line 487 of file reduce_relay_test.cpp.

◆ overlay_

Overlay& xrpl::test::PeerSim::overlay_
private

Definition at line 488 of file reduce_relay_test.cpp.

◆ squelch_

reduce_relay::Squelch<ManualClock> xrpl::test::PeerSim::squelch_
private

Definition at line 489 of file reduce_relay_test.cpp.

◆ nodePublicKey_

PublicKey xrpl::test::PeerPartial::nodePublicKey_
inherited

Definition at line 52 of file reduce_relay_test.cpp.

Generated by doxygen 1.9.8