taraxa::network::tarcap::GetDagSyncPacketHandler Class Reference

#include <get_dag_sync_packet_handler.hpp>

Collaboration diagram for taraxa::network::tarcap::GetDagSyncPacketHandler:

Public Member Functions
	GetDagSyncPacketHandler (const FullNodeConfig &conf, std::shared_ptr< PeersState > peers_state, std::shared_ptr< TimePeriodPacketsStats > packets_stats, std::shared_ptr< TransactionManager > trx_mgr, std::shared_ptr< DagManager > dag_mgr, std::shared_ptr< DbStorage > db, const addr_t &node_addr, const std::string &logs_prefix="GET_DAG_SYNC_PH")
void	sendBlocks (const dev::p2p::NodeID &peer_id, std::vector< std::shared_ptr< DagBlock >> &&blocks, SharedTransactions &&transactions, PbftPeriod request_period, PbftPeriod period)
Public Member Functions inherited from taraxa::network::tarcap::PacketHandler
	PacketHandler (const FullNodeConfig &conf, std::shared_ptr< PeersState > peers_state, std::shared_ptr< TimePeriodPacketsStats > packets_stats, const addr_t &node_addr, const std::string &log_channel_name)
virtual	~PacketHandler ()=default
	PacketHandler (const PacketHandler &)=default
	PacketHandler (PacketHandler &&)=default
PacketHandler &	operator= (const PacketHandler &)=delete
PacketHandler &	operator= (PacketHandler &&)=delete
void	processPacket (const threadpool::PacketData &packet_data)
	Packet processing function wrapper that logs packet stats and calls process function. More...
void	requestPbftNextVotesAtPeriodRound (const dev::p2p::NodeID &peerID, PbftPeriod pbft_period, PbftRound pbft_round)

Static Public Attributes
static constexpr SubprotocolPacketType	kPacketType_ = SubprotocolPacketType::GetDagSyncPacket

Protected Attributes
std::shared_ptr< TransactionManager >	trx_mgr_
std::shared_ptr< DagManager >	dag_mgr_
std::shared_ptr< DbStorage >	db_
Protected Attributes inherited from taraxa::network::tarcap::PacketHandler
const FullNodeConfig &	kConf
std::shared_ptr< PeersState >	peers_state_ {nullptr}
std::shared_ptr< TimePeriodPacketsStats >	packets_stats_

Private Member Functions
virtual void	validatePacketRlpFormat (const threadpool::PacketData &packet_data) const override
	Validates packet rlp format - items count. More...
virtual void	process (const threadpool::PacketData &packet_data, const std::shared_ptr< TaraxaPeer > &peer) override
	Main packet processing function. More...

Additional Inherited Members
Protected Member Functions inherited from taraxa::network::tarcap::PacketHandler
void	checkPacketRlpIsList (const threadpool::PacketData &packet_data) const
	Checks if packet rlp is a list, if not it throws InvalidRlpItemsCountException. More...
bool	sealAndSend (const dev::p2p::NodeID &nodeID, SubprotocolPacketType packet_type, dev::RLPStream &&rlp)
void	disconnect (const dev::p2p::NodeID &node_id, dev::p2p::DisconnectReason reason)

Constructor & Destructor Documentation

GetDagSyncPacketHandler()

taraxa::network::tarcap::GetDagSyncPacketHandler::GetDagSyncPacketHandler	(	const FullNodeConfig &	conf,
		std::shared_ptr< PeersState >	peers_state,
		std::shared_ptr< TimePeriodPacketsStats >	packets_stats,
		std::shared_ptr< TransactionManager >	trx_mgr,
		std::shared_ptr< DagManager >	dag_mgr,
		std::shared_ptr< DbStorage >	db,
		const addr_t &	node_addr,
		const std::string &	logs_prefix = "GET_DAG_SYNC_PH"
	)

Member Function Documentation

process()

void taraxa::network::tarcap::GetDagSyncPacketHandler::process ( const threadpool::PacketData &  packet_data, const std::shared_ptr< TaraxaPeer > &  peer  )

overrideprivatevirtual

Main packet processing function.

Implements taraxa::network::tarcap::PacketHandler.

sendBlocks()

void taraxa::network::tarcap::GetDagSyncPacketHandler::sendBlocks	(	const dev::p2p::NodeID &	peer_id,
		std::vector< std::shared_ptr< DagBlock >> &&	blocks,
		SharedTransactions &&	transactions,
		PbftPeriod	request_period,
		PbftPeriod	period
	)

validatePacketRlpFormat()

void taraxa::network::tarcap::GetDagSyncPacketHandler::validatePacketRlpFormat ( const threadpool::PacketData &  packet_data ) const

overrideprivatevirtual

Validates packet rlp format - items count.

Exceptions

InvalidRlpItemsCountException

exception

Implements taraxa::network::tarcap::PacketHandler.

Member Data Documentation

dag_mgr_

std::shared_ptr<DagManager> taraxa::network::tarcap::GetDagSyncPacketHandler::dag_mgr_

protected

db_

std::shared_ptr<DbStorage> taraxa::network::tarcap::GetDagSyncPacketHandler::db_

protected

kPacketType_

constexpr SubprotocolPacketType taraxa::network::tarcap::GetDagSyncPacketHandler::kPacketType_ = SubprotocolPacketType::GetDagSyncPacket

staticconstexpr

trx_mgr_

std::shared_ptr<TransactionManager> taraxa::network::tarcap::GetDagSyncPacketHandler::trx_mgr_

protected

---

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

• libraries/core_libs/network/include/network/tarcap/packets_handlers/latest/get_dag_sync_packet_handler.hpp
• libraries/core_libs/network/src/tarcap/packets_handlers/latest/get_dag_sync_packet_handler.cpp