xrpl::peer_finder::Bootcache Class Reference

Stores IP addresses useful for gaining initial connections. More...

#include <Bootcache.h>

Collaboration diagram for xrpl::peer_finder::Bootcache:

Classes
class	Entry
struct	Transform

Public Types
using	iterator = boost::transform_iterator<Transform, map_type::right_map::const_iterator>
using	const_iterator = iterator

Public Member Functions
	Bootcache (Store &store, clock_type &clock, beast::Journal journal)
	~Bootcache ()
bool	empty () const
	Returns true if the cache is empty.
map_type::size_type	size () const
	Returns the number of entries in the cache.
void	load ()
	Load the persisted data from the Store into the container.
bool	insert (beast::ip::Endpoint const &endpoint)
	Add a newly-learned address to the cache.
bool	insertStatic (beast::ip::Endpoint const &endpoint)
	Add a staticallyconfigured address to the cache.
void	onSuccess (beast::ip::Endpoint const &endpoint)
	Called when an outbound connection handshake completes.
void	onFailure (beast::ip::Endpoint const &endpoint)
	Called when an outbound connection attempt fails to handshake.
void	periodicActivity ()
	Stores the cache in the persistent database on a timer.
void	onWrite (beast::PropertyStream::Map &map)
	Write the cache state to the property stream.
const_iterator	begin () const
	ip::Endpoint iterators that traverse in decreasing valence.
const_iterator	cbegin () const
const_iterator	end () const
const_iterator	cend () const
void	clear ()

Static Public Attributes
static constexpr int	kStaticValence = 32

Private Types
using	left_t
using	right_t = boost::bimaps::multiset_of<Entry, std::less<>>
using	map_type = boost::bimap<left_t, right_t>
using	value_type = map_type::value_type

Private Member Functions
void	prune ()
void	update ()
void	checkUpdate ()
void	flagForUpdate ()

Private Attributes
map_type	map_
Store &	store_
clock_type &	clock_
beast::Journal	journal_
clock_type::time_point	whenUpdate_
bool	needsUpdate_ {false}

Detailed Description

Stores IP addresses useful for gaining initial connections.

This is one of the caches that is consulted when additional outgoing connections are needed. Along with the address, each entry has this additional metadata:

Valence A signed integer which represents the number of successful consecutive connection attempts when positive, and the number of failed consecutive connection attempts when negative.

When choosing addresses from the boot cache for the purpose of establishing outgoing connections, addresses are ranked in decreasing order of high uptime, with valence as the tie breaker.

Definition at line 35 of file Bootcache.h.

Member Typedef Documentation

left_t

using xrpl::peer_finder::Bootcache::left_t

private

Initial value:

boost::bimaps::
       unordered_set_of<beast::ip::Endpoint, boost::hash<beast::ip::Endpoint>, std::equal_to<>>

Definition at line 67 of file Bootcache.h.

right_t

using xrpl::peer_finder::Bootcache::right_t = boost::bimaps::multiset_of<Entry, std::less<>>

private

Definition at line 69 of file Bootcache.h.

map_type

using xrpl::peer_finder::Bootcache::map_type = boost::bimap<left_t, right_t>

private

Definition at line 70 of file Bootcache.h.

value_type

using xrpl::peer_finder::Bootcache::value_type = map_type::value_type

private

Definition at line 71 of file Bootcache.h.

iterator

using xrpl::peer_finder::Bootcache::iterator = boost::transform_iterator<Transform, map_type::right_map::const_iterator>

Definition at line 103 of file Bootcache.h.

const_iterator

using xrpl::peer_finder::Bootcache::const_iterator = iterator

Definition at line 105 of file Bootcache.h.

Constructor & Destructor Documentation

Bootcache()

xrpl::peer_finder::Bootcache::Bootcache	(	Store &	store,
		clock_type &	clock,
		beast::Journal	journal )

Definition at line 21 of file Bootcache.cpp.

~Bootcache()

xrpl::peer_finder::Bootcache::~Bootcache

(

)

Definition at line 27 of file Bootcache.cpp.

Member Function Documentation

empty()

bool xrpl::peer_finder::Bootcache::empty ( ) const

nodiscard

Returns true if the cache is empty.

Definition at line 33 of file Bootcache.cpp.

size()

Bootcache::map_type::size_type xrpl::peer_finder::Bootcache::size ( ) const

nodiscard

Returns the number of entries in the cache.

Definition at line 39 of file Bootcache.cpp.

begin()

Bootcache::const_iterator xrpl::peer_finder::Bootcache::begin ( ) const

nodiscard

ip::Endpoint iterators that traverse in decreasing valence.

Definition at line 45 of file Bootcache.cpp.

cbegin()

Bootcache::const_iterator xrpl::peer_finder::Bootcache::cbegin ( ) const

nodiscard

Definition at line 51 of file Bootcache.cpp.

end()

Bootcache::const_iterator xrpl::peer_finder::Bootcache::end ( ) const

nodiscard

Definition at line 57 of file Bootcache.cpp.

cend()

Bootcache::const_iterator xrpl::peer_finder::Bootcache::cend ( ) const

nodiscard

Definition at line 63 of file Bootcache.cpp.

clear()

void xrpl::peer_finder::Bootcache::clear

(

)

Definition at line 69 of file Bootcache.cpp.

load()

void xrpl::peer_finder::Bootcache::load

(

)

Load the persisted data from the Store into the container.

Definition at line 78 of file Bootcache.cpp.

insert()

bool xrpl::peer_finder::Bootcache::insert

(

beast::ip::Endpoint const &

endpoint

)

Add a newly-learned address to the cache.

Definition at line 99 of file Bootcache.cpp.

insertStatic()

bool xrpl::peer_finder::Bootcache::insertStatic

(

beast::ip::Endpoint const &

endpoint

)

Add a staticallyconfigured address to the cache.

Definition at line 112 of file Bootcache.cpp.

onSuccess()

void xrpl::peer_finder::Bootcache::onSuccess

(

beast::ip::Endpoint const &

endpoint

)

Called when an outbound connection handshake completes.

Definition at line 133 of file Bootcache.cpp.

onFailure()

void xrpl::peer_finder::Bootcache::onFailure

(

beast::ip::Endpoint const &

endpoint

)

Called when an outbound connection attempt fails to handshake.

Definition at line 157 of file Bootcache.cpp.

periodicActivity()

void xrpl::peer_finder::Bootcache::periodicActivity

(

)

Stores the cache in the persistent database on a timer.

Definition at line 181 of file Bootcache.cpp.

onWrite()

void xrpl::peer_finder::Bootcache::onWrite

(

beast::PropertyStream::Map &

map

)

Write the cache state to the property stream.

Definition at line 189 of file Bootcache.cpp.

prune()

void xrpl::peer_finder::Bootcache::prune ( )

private

Definition at line 202 of file Bootcache.cpp.

update()

void xrpl::peer_finder::Bootcache::update ( )

private

Definition at line 231 of file Bootcache.cpp.

checkUpdate()

void xrpl::peer_finder::Bootcache::checkUpdate ( )

private

Definition at line 252 of file Bootcache.cpp.

flagForUpdate()

void xrpl::peer_finder::Bootcache::flagForUpdate ( )

private

Definition at line 260 of file Bootcache.cpp.

Member Data Documentation

map_

map_type xrpl::peer_finder::Bootcache::map_

private

Definition at line 88 of file Bootcache.h.

store_

Store& xrpl::peer_finder::Bootcache::store_

private

Definition at line 90 of file Bootcache.h.

clock_

clock_type& xrpl::peer_finder::Bootcache::clock_

private

Definition at line 91 of file Bootcache.h.

journal_

beast::Journal xrpl::peer_finder::Bootcache::journal_

private

Definition at line 92 of file Bootcache.h.

whenUpdate_

clock_type::time_point xrpl::peer_finder::Bootcache::whenUpdate_

private

Definition at line 95 of file Bootcache.h.

needsUpdate_

bool xrpl::peer_finder::Bootcache::needsUpdate_ {false}

private

Definition at line 98 of file Bootcache.h.

kStaticValence

int xrpl::peer_finder::Bootcache::kStaticValence = 32

staticconstexpr

Definition at line 101 of file Bootcache.h.