ripple::reduce_relay::Slots< clock_type > Class Template Reference

Slots is a container for validator's Slot and handles Slot update when a message is received from a validator. More...

#include <Slot.h>

Collaboration diagram for ripple::reduce_relay::Slots< clock_type >:

Public Member Functions
	Slots (Logs &logs, SquelchHandler const &handler)
	~Slots ()=default
void	updateSlotAndSquelch (uint256 const &key, PublicKey const &validator, id_t id, protocol::MessageType type)
	Calls Slot::update of Slot associated with the validator. More...
void	deleteIdlePeers ()
	Check if peers stopped relaying messages and if slots stopped receiving messages from the validator. More...
std::optional< std::uint16_t >	inState (PublicKey const &validator, PeerState state) const
	Return number of peers in state. More...
std::optional< std::uint16_t >	notInState (PublicKey const &validator, PeerState state) const
	Return number of peers not in state. More...
bool	inState (PublicKey const &validator, SlotState state) const
	Return true if Slot is in state. More...
std::set< id_t >	getSelected (PublicKey const &validator)
	Get selected peers. More...
std::unordered_map< typename Peer::id_t, std::tuple< PeerState, uint16_t, uint32_t, std::uint32_t > >	getPeers (PublicKey const &validator)
	Get peers info. More...
std::optional< SlotState >	getState (PublicKey const &validator)
	Get Slot's state. More...
void	deletePeer (id_t id, bool erase)
	Called when a peer is deleted. More...

Private Types
using	time_point = typename clock_type::time_point
using	id_t = typename Peer::id_t
using	messages = beast::aged_unordered_map< uint256, std::unordered_set< Peer::id_t >, clock_type, hardened_hash< strong_hash > >

Private Member Functions
bool	addPeerMessage (uint256 const &key, id_t id)
	Add message/peer if have not seen this message from the peer. More...

Private Attributes
hash_map< PublicKey, Slot< clock_type > >	slots_
SquelchHandler const &	handler_
Logs &	logs_
beast::Journal const	journal_

Static Private Attributes
static messages	peersWithMessage_

Detailed Description

template<typename clock_type>
class ripple::reduce_relay::Slots< clock_type >

Slots is a container for validator's Slot and handles Slot update when a message is received from a validator.

It also handles Slot aging and checks for peers which are disconnected or stopped relaying the messages.

Definition at line 535 of file overlay/Slot.h.

Member Typedef Documentation

time_point

template<typename clock_type >

using ripple::reduce_relay::Slots< clock_type >::time_point = typename clock_type::time_point

private

Definition at line 537 of file overlay/Slot.h.

id_t

template<typename clock_type >

using ripple::reduce_relay::Slots< clock_type >::id_t = typename Peer::id_t

private

Definition at line 538 of file overlay/Slot.h.

messages

template<typename clock_type >

using ripple::reduce_relay::Slots< clock_type >::messages = beast::aged_unordered_map< uint256, std::unordered_set<Peer::id_t>, clock_type, hardened_hash<strong_hash> >

private

Definition at line 539 of file overlay/Slot.h.

Constructor & Destructor Documentation

Slots()

template<typename clock_type >

ripple::reduce_relay::Slots< clock_type >::Slots	(	Logs &	logs,
		SquelchHandler const &	handler
	)

Parameters

app	Applicaton reference
handler	Squelch/unsquelch implementation

Definition at line 550 of file overlay/Slot.h.

~Slots()

template<typename clock_type >

ripple::reduce_relay::Slots< clock_type >::~Slots ( )

default

Member Function Documentation

updateSlotAndSquelch()

template<typename clock_type >

void ripple::reduce_relay::Slots< clock_type >::updateSlotAndSquelch	(	uint256 const &	key,
		PublicKey const &	validator,
		id_t	id,
		protocol::MessageType	type
	)

Calls Slot::update of Slot associated with the validator.

Parameters

key	Message's hash
validator	Validator's public key
id	Peer's id which received the message
type	Received protocol message type

Definition at line 701 of file overlay/Slot.h.

deleteIdlePeers()

template<typename clock_type >

void ripple::reduce_relay::Slots< clock_type >::deleteIdlePeers

Check if peers stopped relaying messages and if slots stopped receiving messages from the validator.

Definition at line 736 of file overlay/Slot.h.

inState() [1/2]

template<typename clock_type >

std::optional< std::uint16_t > ripple::reduce_relay::Slots< clock_type >::inState	(	PublicKey const &	validator,
		PeerState	state
	)		const

Return number of peers in state.

Definition at line 576 of file overlay/Slot.h.

notInState()

template<typename clock_type >

std::optional< std::uint16_t > ripple::reduce_relay::Slots< clock_type >::notInState	(	PublicKey const &	validator,
		PeerState	state
	)		const

Return number of peers not in state.

Definition at line 586 of file overlay/Slot.h.

inState() [2/2]

template<typename clock_type >

bool ripple::reduce_relay::Slots< clock_type >::inState	(	PublicKey const &	validator,
		SlotState	state
	)		const

Return true if Slot is in state.

Definition at line 596 of file overlay/Slot.h.

getSelected()

template<typename clock_type >

std::set< id_t > ripple::reduce_relay::Slots< clock_type >::getSelected

(

PublicKey const &

validator

)

Get selected peers.

Definition at line 606 of file overlay/Slot.h.

getPeers()

template<typename clock_type >

std::unordered_map< typename Peer::id_t, std::tuple< PeerState, uint16_t, uint32_t, std::uint32_t > > ripple::reduce_relay::Slots< clock_type >::getPeers

(

PublicKey const &

validator

)

Get peers info.

Return map of peer's state, count, and squelch expiration milliseconds.

Definition at line 620 of file overlay/Slot.h.

getState()

template<typename clock_type >

std::optional< SlotState > ripple::reduce_relay::Slots< clock_type >::getState

(

PublicKey const &

validator

)

Get Slot's state.

Definition at line 630 of file overlay/Slot.h.

deletePeer()

template<typename clock_type >

void ripple::reduce_relay::Slots< clock_type >::deletePeer	(	id_t	id,
		bool	erase
	)

Called when a peer is deleted.

If the peer was selected to be the source of messages from the validator then squelched peers have to be unsquelched.

Parameters

id	Peer's id
erase	If true then erase the peer

Definition at line 728 of file overlay/Slot.h.

addPeerMessage()

template<typename clock_type >

bool ripple::reduce_relay::Slots< clock_type >::addPeerMessage ( uint256 const &  key, id_t  id  )

private

Add message/peer if have not seen this message from the peer.

A message is aged after IDLED seconds. Return true if added

Definition at line 668 of file overlay/Slot.h.

Member Data Documentation

slots_

template<typename clock_type >

hash_map<PublicKey, Slot<clock_type> > ripple::reduce_relay::Slots< clock_type >::slots_

private

Definition at line 654 of file overlay/Slot.h.

handler_

template<typename clock_type >

SquelchHandler const& ripple::reduce_relay::Slots< clock_type >::handler_

private

Definition at line 655 of file overlay/Slot.h.

logs_

template<typename clock_type >

Logs& ripple::reduce_relay::Slots< clock_type >::logs_

private

Definition at line 656 of file overlay/Slot.h.

journal_

template<typename clock_type >

beast::Journal const ripple::reduce_relay::Slots< clock_type >::journal_

private

Definition at line 657 of file overlay/Slot.h.

peersWithMessage_

template<typename clock_type >

messages ripple::reduce_relay::Slots< clock_type >::peersWithMessage_

staticprivate

Initial value:

{
        beast::get_abstract_clock<clock_type>()}

Definition at line 662 of file overlay/Slot.h.