The Logic for maintaining the list of Slot addresses. More...

#include <Logic.h>

Collaboration diagram for xrpl::PeerFinder::Logic< Checker >:

[legend]

Public Types
using	Slots = std::map<beast::IP::Endpoint, std::shared_ptr<SlotImp>>

Public Member Functions
	Logic (clock_type &clock, Store &store, Checker &checker, beast::Journal journal)
void	load ()
void	stop ()
	Stop the logic.
void	config (Config const &c)
Config	config ()
void	addFixedPeer (std::string_view name, beast::IP::Endpoint const &ep)
void	addFixedPeer (std::string_view name, std::vector< beast::IP::Endpoint > const &addresses)
void	checkComplete (beast::IP::Endpoint const &remoteAddress, beast::IP::Endpoint const &checkedAddress, boost::system::error_code ec)
std::pair< SlotImp::ptr, Result >	newInboundSlot (beast::IP::Endpoint const &localEndpoint, beast::IP::Endpoint const &remoteEndpoint)
std::pair< SlotImp::ptr, Result >	newOutboundSlot (beast::IP::Endpoint const &remoteEndpoint)
bool	onConnected (SlotImp::ptr const &slot, beast::IP::Endpoint const &localEndpoint)
Result	activate (SlotImp::ptr const &slot, PublicKey const &key, bool reserved)
std::vector< Endpoint >	redirect (SlotImp::ptr const &slot)
	Return a list of addresses suitable for redirection.
std::vector< beast::IP::Endpoint >	autoconnect ()
	Create new outbound connection attempts as needed.
std::vector< std::pair< std::shared_ptr< Slot >, std::vector< Endpoint > > >	buildEndpointsForPeers ()
void	oncePerSecond ()
void	preprocess (SlotImp::ptr const &slot, Endpoints &list)
void	onEndpoints (SlotImp::ptr const &slot, Endpoints list)
void	remove (SlotImp::ptr const &slot)
void	onClosed (SlotImp::ptr const &slot)
void	onFailure (SlotImp::ptr const &slot)
template<class FwdIter>
void	onRedirects (FwdIter first, FwdIter last, boost::asio::ip::tcp::endpoint const &remoteAddress)
bool	fixed (beast::IP::Endpoint const &endpoint) const
bool	fixed (beast::IP::Address const &address) const
template<class Container>
void	getFixed (std::size_t needed, Container &c, ConnectHandouts::Squelches &squelches)
	Adds eligible Fixed addresses for outbound attempts.
void	addStaticSource (std::shared_ptr< Source > const &source)
void	addSource (std::shared_ptr< Source > const &source)
int	addBootcacheAddresses (IPAddresses const &list)
void	fetch (std::shared_ptr< Source > const &source)
bool	isValidAddress (beast::IP::Endpoint const &address)
void	writeSlots (beast::PropertyStream::Set &set, Slots const &slots)
void	onWrite (beast::PropertyStream::Map &map)
Counts const &	counts () const

Static Public Member Functions
static std::string	stateString (Slot::State state)

Public Attributes
beast::Journal	journal
clock_type &	clock
Store &	store
Checker &	checker
std::recursive_mutex	lock
bool	stopping = false
std::shared_ptr< Source >	fetchSource
Livecache	livecache
Bootcache	bootcache
Slots	slots
std::multiset< beast::IP::Address >	connectedAddresses
std::set< PublicKey >	keys
std::vector< std::shared_ptr< Source > >	sources
clock_type::time_point	whenBroadcast
ConnectHandouts::Squelches	squelches

Private Attributes
Config	config_
Counts	counts_
std::map< beast::IP::Endpoint, Fixed >	fixed_

Detailed Description

template<class Checker>
class xrpl::PeerFinder::Logic< Checker >

The Logic for maintaining the list of Slot addresses.

We keep this in a separate class so it can be instantiated for unit tests.

Definition at line 33 of file src/xrpld/peerfinder/detail/Logic.h.

Member Typedef Documentation

◆ Slots

template<class Checker>

using xrpl::PeerFinder::Logic< Checker >::Slots = std::map<beast::IP::Endpoint, std::shared_ptr<SlotImp>>

Definition at line 39 of file src/xrpld/peerfinder/detail/Logic.h.

Constructor & Destructor Documentation

◆ Logic()

template<class Checker>

xrpl::PeerFinder::Logic< Checker >::Logic	(	clock_type &	clock,
		Store &	store,
		Checker &	checker,
		beast::Journal	journal )

Definition at line 92 of file src/xrpld/peerfinder/detail/Logic.h.

Member Function Documentation

◆ load()

template<class Checker>

void xrpl::PeerFinder::Logic< Checker >::load ( )

Definition at line 108 of file src/xrpld/peerfinder/detail/Logic.h.

◆ stop()

template<class Checker>

void xrpl::PeerFinder::Logic< Checker >::stop ( )

Stop the logic.

This will cancel the current fetch and set the stopping flag to true to prevent further fetches. Thread safety: Safe to call from any thread.

Definition at line 121 of file src/xrpld/peerfinder/detail/Logic.h.

◆ config() [1/2]

template<class Checker>

void xrpl::PeerFinder::Logic< Checker >::config ( Config const & c )

Definition at line 136 of file src/xrpld/peerfinder/detail/Logic.h.

◆ config() [2/2]

template<class Checker>

Config xrpl::PeerFinder::Logic< Checker >::config ( )

Definition at line 144 of file src/xrpld/peerfinder/detail/Logic.h.

◆ addFixedPeer() [1/2]

template<class Checker>

void xrpl::PeerFinder::Logic< Checker >::addFixedPeer	(	std::string_view	name,
		beast::IP::Endpoint const &	ep )

Definition at line 151 of file src/xrpld/peerfinder/detail/Logic.h.

◆ addFixedPeer() [2/2]

template<class Checker>

void xrpl::PeerFinder::Logic< Checker >::addFixedPeer	(	std::string_view	name,
		std::vector< beast::IP::Endpoint > const &	addresses )

Definition at line 157 of file src/xrpld/peerfinder/detail/Logic.h.

◆ checkComplete()

template<class Checker>

void xrpl::PeerFinder::Logic< Checker >::checkComplete	(	beast::IP::Endpoint const &	remoteAddress,
		beast::IP::Endpoint const &	checkedAddress,
		boost::system::error_code	ec )

Definition at line 193 of file src/xrpld/peerfinder/detail/Logic.h.

◆ newInboundSlot()

template<class Checker>

std::pair< SlotImp::ptr, Result > xrpl::PeerFinder::Logic< Checker >::newInboundSlot	(	beast::IP::Endpoint const &	localEndpoint,
		beast::IP::Endpoint const &	remoteEndpoint )