#include <cryptonote_protocol_handler.h>

Inheritance diagram for cryptonote::t_cryptonote_protocol_handler< t_core >:

Collaboration diagram for cryptonote::t_cryptonote_protocol_handler< t_core >:

Public Types
typedef cryptonote_connection_context	connection_context

typedef core_stat_info	stat_info

typedef t_cryptonote_protocol_handler< t_core >	cryptonote_protocol_handler

typedef CORE_SYNC_DATA	payload_type

Public Member Functions
	t_cryptonote_protocol_handler (t_core &rcore, nodetool::i_p2p_endpoint< connection_context > *p_net_layout, bool offline=false)

bool	on_idle ()

bool	init (const boost::program_options::variables_map &vm)

bool	deinit ()

void	set_p2p_endpoint (nodetool::i_p2p_endpoint< connection_context > *p2p)

bool	process_payload_sync_data (const CORE_SYNC_DATA &hshd, cryptonote_connection_context &context, bool is_inital)

bool	get_payload_sync_data (blobdata &data)

bool	get_payload_sync_data (CORE_SYNC_DATA &hshd)

bool	get_stat_info (core_stat_info &stat_inf)

bool	on_callback (cryptonote_connection_context &context)

t_core &	get_core ()

bool	is_synchronized ()

void	log_connections ()

std::list< connection_info >	get_connections ()

const block_queue &	get_block_queue () const

void	stop ()

void	on_connection_close (cryptonote_connection_context &context)

Private Member Functions
int	handle_notify_new_block (int command, NOTIFY_NEW_BLOCK::request &arg, cryptonote_connection_context &context)

int	handle_notify_new_transactions (int command, NOTIFY_NEW_TRANSACTIONS::request &arg, cryptonote_connection_context &context)

int	handle_request_get_objects (int command, NOTIFY_REQUEST_GET_OBJECTS::request &arg, cryptonote_connection_context &context)

int	handle_response_get_objects (int command, NOTIFY_RESPONSE_GET_OBJECTS::request &arg, cryptonote_connection_context &context)

int	handle_request_chain (int command, NOTIFY_REQUEST_CHAIN::request &arg, cryptonote_connection_context &context)

int	handle_response_chain_entry (int command, NOTIFY_RESPONSE_CHAIN_ENTRY::request &arg, cryptonote_connection_context &context)

int	handle_notify_new_fluffy_block (int command, NOTIFY_NEW_FLUFFY_BLOCK::request &arg, cryptonote_connection_context &context)

int	handle_request_fluffy_missing_tx (int command, NOTIFY_REQUEST_FLUFFY_MISSING_TX::request &arg, cryptonote_connection_context &context)

virtual bool	relay_block (NOTIFY_NEW_BLOCK::request &arg, cryptonote_connection_context &exclude_context)

virtual bool	relay_transactions (NOTIFY_NEW_TRANSACTIONS::request &arg, cryptonote_connection_context &exclude_context)

bool	request_missing_objects (cryptonote_connection_context &context, bool check_having_blocks, bool force_next_span=false)

size_t	get_synchronizing_connections_count ()

bool	on_connection_synchronized ()

bool	should_download_next_span (cryptonote_connection_context &context) const

void	drop_connection (cryptonote_connection_context &context, bool add_fail, bool flush_all_spans)

bool	kick_idle_peers ()

int	try_add_next_blocks (cryptonote_connection_context &context)

double	get_avg_block_size ()

template<class t_parameter >
bool	post_notify (typename t_parameter::request &arg, cryptonote_connection_context &context)

template<class t_parameter >
bool	relay_post_notify (typename t_parameter::request &arg, cryptonote_connection_context &exclude_context)

Private Member Functions inherited from cryptonote::cryptonote_protocol_handler_base
	cryptonote_protocol_handler_base ()

virtual	~cryptonote_protocol_handler_base ()

void	handler_request_blocks_history (std::list< crypto::hash > &ids)

void	handler_response_blocks_now (size_t packet_size)

virtual double	estimate_one_block_size () noexcept

Private Attributes
t_core &	m_core

nodetool::p2p_endpoint_stub< connection_context >	m_p2p_stub

nodetool::i_p2p_endpoint< connection_context > *	m_p2p

std::atomic< uint32_t >	m_syncronized_connections_count

std::atomic< bool >	m_synchronized

std::atomic< bool >	m_stopping

boost::mutex	m_sync_lock

block_queue	m_block_queue

epee::math_helper::once_a_time_seconds< 30 >	m_idle_peer_kicker

boost::mutex	m_buffer_mutex

boost::circular_buffer< size_t >	m_avg_buffer = boost::circular_buffer<size_t>(10)

Member Typedef Documentation

◆ connection_context

template<class t_core>

typedef cryptonote_connection_context cryptonote::t_cryptonote_protocol_handler< t_core >::connection_context

◆ cryptonote_protocol_handler

template<class t_core>

typedef t_cryptonote_protocol_handler<t_core> cryptonote::t_cryptonote_protocol_handler< t_core >::cryptonote_protocol_handler

◆ payload_type

template<class t_core>

typedef CORE_SYNC_DATA cryptonote::t_cryptonote_protocol_handler< t_core >::payload_type

◆ stat_info

template<class t_core>

typedef core_stat_info cryptonote::t_cryptonote_protocol_handler< t_core >::stat_info

Constructor & Destructor Documentation

◆ t_cryptonote_protocol_handler()

template<class t_core>

cryptonote::t_cryptonote_protocol_handler< t_core >::t_cryptonote_protocol_handler	(	t_core &	rcore,
		nodetool::i_p2p_endpoint< connection_context > *	p_net_layout,
		bool	offline = `false`
	)

Member Function Documentation

◆ deinit()

template<class t_core >

bool cryptonote::t_cryptonote_protocol_handler< t_core >::deinit ( )

◆ drop_connection()

template<class t_core >

void cryptonote::t_cryptonote_protocol_handler< t_core >::drop_connection	(	cryptonote_connection_context &	context,
		bool	add_fail,
		bool	flush_all_spans
	)

private

◆ get_avg_block_size()

template<class t_core >

double cryptonote::t_cryptonote_protocol_handler< t_core >::get_avg_block_size ( )

privatevirtual

Implements cryptonote::cryptonote_protocol_handler_base.

◆ get_block_queue()

template<class t_core>

const block_queue& cryptonote::t_cryptonote_protocol_handler< t_core >::get_block_queue ( ) const

inline

◆ get_connections()

template<class t_core >

std::list< connection_info > cryptonote::t_cryptonote_protocol_handler< t_core >::get_connections ( )

◆ get_core()

template<class t_core>

t_core& cryptonote::t_cryptonote_protocol_handler< t_core >::get_core ( )

inline

◆ get_payload_sync_data() [1/2]

template<class t_core >

bool cryptonote::t_cryptonote_protocol_handler< t_core >::get_payload_sync_data ( blobdata & data )

◆ get_payload_sync_data() [2/2]

template<class t_core >

bool cryptonote::t_cryptonote_protocol_handler< t_core >::get_payload_sync_data ( CORE_SYNC_DATA & hshd )

◆ get_stat_info()

template<class t_core >

bool cryptonote::t_cryptonote_protocol_handler< t_core >::get_stat_info ( core_stat_info & stat_inf )

◆ get_synchronizing_connections_count()

template<class t_core >

size_t cryptonote::t_cryptonote_protocol_handler< t_core >::get_synchronizing_connections_count ( )

private

◆ handle_notify_new_block()

template<class t_core >

int cryptonote::t_cryptonote_protocol_handler< t_core >::handle_notify_new_block	(	int	command,
		NOTIFY_NEW_BLOCK::request &	arg,
		cryptonote_connection_context &	context
	)

private

◆ handle_notify_new_fluffy_block()

template<class t_core >

int cryptonote::t_cryptonote_protocol_handler< t_core >::handle_notify_new_fluffy_block	(	int	command,
		NOTIFY_NEW_FLUFFY_BLOCK::request &	arg,
		cryptonote_connection_context &	context
	)

private

◆ handle_notify_new_transactions()

template<class t_core >

int cryptonote::t_cryptonote_protocol_handler< t_core >::handle_notify_new_transactions	(	int	command,
		NOTIFY_NEW_TRANSACTIONS::request &	arg,
		cryptonote_connection_context &	context
	)

private

◆ handle_request_chain()

template<class t_core >

int cryptonote::t_cryptonote_protocol_handler< t_core >::handle_request_chain	(	int	command,
		NOTIFY_REQUEST_CHAIN::request &	arg,
		cryptonote_connection_context &	context
	)

private

◆ handle_request_fluffy_missing_tx()

template<class t_core >

int cryptonote::t_cryptonote_protocol_handler< t_core >::handle_request_fluffy_missing_tx	(	int	command,
		NOTIFY_REQUEST_FLUFFY_MISSING_TX::request &	arg,
		cryptonote_connection_context &	context
	)

private

◆ handle_request_get_objects()

template<class t_core >

int cryptonote::t_cryptonote_protocol_handler< t_core >::handle_request_get_objects	(	int	command,
		NOTIFY_REQUEST_GET_OBJECTS::request &	arg,
		cryptonote_connection_context &	context
	)

private

◆ handle_response_chain_entry()

template<class t_core >

int cryptonote::t_cryptonote_protocol_handler< t_core >::handle_response_chain_entry	(	int	command,
		NOTIFY_RESPONSE_CHAIN_ENTRY::request &	arg,
		cryptonote_connection_context &	context
	)

private

◆ handle_response_get_objects()

template<class t_core >

int cryptonote::t_cryptonote_protocol_handler< t_core >::handle_response_get_objects	(	int	command,
		NOTIFY_RESPONSE_GET_OBJECTS::request &	arg,
		cryptonote_connection_context &	context
	)

private

◆ init()

template<class t_core >

bool cryptonote::t_cryptonote_protocol_handler< t_core >::init ( const boost::program_options::variables_map & vm )

◆ is_synchronized()

template<class t_core>

bool cryptonote::t_cryptonote_protocol_handler< t_core >::is_synchronized ( )

inline

◆ kick_idle_peers()

template<class t_core >

bool cryptonote::t_cryptonote_protocol_handler< t_core >::kick_idle_peers ( )

private

◆ log_connections()

template<class t_core >

void cryptonote::t_cryptonote_protocol_handler< t_core >::log_connections ( )

◆ on_callback()

template<class t_core >

bool cryptonote::t_cryptonote_protocol_handler< t_core >::on_callback ( cryptonote_connection_context & context )

◆ on_connection_close()

template<class t_core >

void cryptonote::t_cryptonote_protocol_handler< t_core >::on_connection_close ( cryptonote_connection_context & context )

◆ on_connection_synchronized()

template<class t_core >

bool cryptonote::t_cryptonote_protocol_handler< t_core >::on_connection_synchronized ( )

private

◆ on_idle()

template<class t_core >

bool cryptonote::t_cryptonote_protocol_handler< t_core >::on_idle ( )

◆ post_notify()

template<class t_core>

template<class t_parameter >

bool cryptonote::t_cryptonote_protocol_handler< t_core >::post_notify	(	typename t_parameter::request &	arg,
		cryptonote_connection_context &	context
	)

inlineprivate

◆ process_payload_sync_data()

template<class t_core >

bool cryptonote::t_cryptonote_protocol_handler< t_core >::process_payload_sync_data	(	const CORE_SYNC_DATA &	hshd,
		cryptonote_connection_context &	context,
		bool	is_inital
	)

◆ relay_block()

template<class t_core >

bool cryptonote::t_cryptonote_protocol_handler< t_core >::relay_block	(	NOTIFY_NEW_BLOCK::request &	arg,
		cryptonote_connection_context &	exclude_context
	)

privatevirtual

Implements cryptonote::i_cryptonote_protocol.

◆ relay_post_notify()

template<class t_core>

template<class t_parameter >

bool cryptonote::t_cryptonote_protocol_handler< t_core >::relay_post_notify	(	typename t_parameter::request &	arg,
		cryptonote_connection_context &	exclude_context
	)

inlineprivate

◆ relay_transactions()

template<class t_core >

bool cryptonote::t_cryptonote_protocol_handler< t_core >::relay_transactions	(	NOTIFY_NEW_TRANSACTIONS::request &	arg,
		cryptonote_connection_context &	exclude_context
	)

privatevirtual

Implements cryptonote::i_cryptonote_protocol.

◆ request_missing_objects()

template<class t_core >

bool cryptonote::t_cryptonote_protocol_handler< t_core >::request_missing_objects	(	cryptonote_connection_context &	context,
		bool	check_having_blocks,
		bool	force_next_span = `false`
	)

private

◆ set_p2p_endpoint()

template<class t_core >

void cryptonote::t_cryptonote_protocol_handler< t_core >::set_p2p_endpoint ( nodetool::i_p2p_endpoint< connection_context > * p2p )

◆ should_download_next_span()

template<class t_core >

bool cryptonote::t_cryptonote_protocol_handler< t_core >::should_download_next_span ( cryptonote_connection_context & context ) const

private

◆ stop()

template<class t_core >

void cryptonote::t_cryptonote_protocol_handler< t_core >::stop ( )

◆ try_add_next_blocks()

template<class t_core >

template<class t_core>

std::atomic<bool> cryptonote::t_cryptonote_protocol_handler< t_core >::m_synchronized

private

◆ m_syncronized_connections_count

template<class t_core>

std::atomic<uint32_t> cryptonote::t_cryptonote_protocol_handler< t_core >::m_syncronized_connections_count

private

The documentation for this class was generated from the following files:

src/cryptonote_protocol/cryptonote_protocol_handler.h
src/cryptonote_protocol/cryptonote_protocol_handler.inl

Public Types

Public Member Functions

Private Member Functions

Private Attributes

Member Typedef Documentation

◆ connection_context

◆ cryptonote_protocol_handler

◆ payload_type

◆ stat_info

Constructor & Destructor Documentation

◆ t_cryptonote_protocol_handler()

Member Function Documentation

◆ deinit()

◆ drop_connection()

◆ get_avg_block_size()

◆ get_block_queue()

◆ get_connections()

◆ get_core()

◆ get_payload_sync_data() [1/2]

◆ get_payload_sync_data() [2/2]

◆ get_stat_info()

◆ get_synchronizing_connections_count()

◆ handle_notify_new_block()

◆ handle_notify_new_fluffy_block()

◆ handle_notify_new_transactions()

◆ handle_request_chain()

◆ handle_request_fluffy_missing_tx()

◆ handle_request_get_objects()

◆ handle_response_chain_entry()

◆ handle_response_get_objects()

◆ init()

◆ is_synchronized()

◆ kick_idle_peers()

◆ log_connections()

◆ on_callback()

◆ on_connection_close()

◆ on_connection_synchronized()

◆ on_idle()

◆ post_notify()

◆ process_payload_sync_data()

◆ relay_block()

◆ relay_post_notify()

◆ relay_transactions()

◆ request_missing_objects()

◆ set_p2p_endpoint()

◆ should_download_next_span()

◆ stop()

◆ try_add_next_blocks()

Member Data Documentation

◆ m_avg_buffer

◆ m_block_queue

◆ m_buffer_mutex

◆ m_core

◆ m_idle_peer_kicker

◆ m_p2p

◆ m_p2p_stub

◆ m_stopping

◆ m_sync_lock

◆ m_synchronized

◆ m_syncronized_connections_count