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

#include <Logic.h>

Collaboration diagram for ripple::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 const &name, beast::IP::Endpoint const &ep)

void	addFixedPeer (std::string const &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 >	new_inbound_slot (beast::IP::Endpoint const &local_endpoint, beast::IP::Endpoint const &remote_endpoint)

std::pair< SlotImp::ptr, Result >	new_outbound_slot (beast::IP::Endpoint const &remote_endpoint)

bool	onConnected (SlotImp::ptr const &slot, beast::IP::Endpoint const &local_endpoint)

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	once_per_second ()

void	preprocess (SlotImp::ptr const &slot, Endpoints &list)

void	on_endpoints (SlotImp::ptr const &slot, Endpoints list)

void	remove (SlotImp::ptr const &slot)

void	on_closed (SlotImp::ptr const &slot)

void	on_failure (SlotImp::ptr const &slot)

template<class FwdIter >
void	onRedirects (FwdIter first, FwdIter last, boost::asio::ip::tcp::endpoint const &remote_address)

bool	fixed (beast::IP::Endpoint const &endpoint) const

bool	fixed (beast::IP::Address const &address) const

template<class Container >
void	get_fixed (std::size_t needed, Container &c, typename 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	is_valid_address (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	m_journal

clock_type &	m_clock

Store &	m_store

Checker &	m_checker

std::recursive_mutex	lock_

bool	stopping_ = false

std::shared_ptr< Source >	fetchSource_

Config	config_

Counts	counts_

std::map< beast::IP::Endpoint, Fixed >	fixed_

Livecache	livecache_

Bootcache	bootcache_

Slots	slots_

std::multiset< beast::IP::Address >	connectedAddresses_

std::set< PublicKey >	keys_

std::vector< std::shared_ptr< Source > >	m_sources

clock_type::time_point	m_whenBroadcast

ConnectHandouts::Squelches	m_squelches

Detailed Description

template<class Checker>
class ripple::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 35 of file src/xrpld/peerfinder/detail/Logic.h.

Member Typedef Documentation

◆ Slots

template<class Checker >

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

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

Constructor & Destructor Documentation

◆ Logic()

template<class Checker >

ripple::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 ripple::PeerFinder::Logic< Checker >::load ( )

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

◆ stop()

template<class Checker >

void ripple::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 125 of file src/xrpld/peerfinder/detail/Logic.h.

◆ config() [1/2]

template<class Checker >

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

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

◆ config() [2/2]

template<class Checker >

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

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

◆ addFixedPeer() [1/2]

template<class Checker >

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

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

◆ addFixedPeer() [2/2]

template<class Checker >

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

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

◆ checkComplete()

template<class Checker >

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

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

◆ new_inbound_slot()

template<class Checker >

std::pair< SlotImp::ptr, Result > ripple::PeerFinder::Logic< Checker >::new_inbound_slot	(	beast::IP::Endpoint const &	local_endpoint,
		beast::IP::Endpoint const &	remote_endpoint
	)