#include <dag_block_packet_handler.hpp>

Collaboration diagram for taraxa::network::tarcap::DagBlockPacketHandler:

[legend]

Public Member Functions
	DagBlockPacketHandler (const FullNodeConfig &conf, std::shared_ptr< PeersState > peers_state, std::shared_ptr< TimePeriodPacketsStats > packets_stats, std::shared_ptr< PbftSyncingState > pbft_syncing_state, std::shared_ptr< PbftChain > pbft_chain, std::shared_ptr< PbftManager > pbft_mgr, std::shared_ptr< DagManager > dag_mgr, std::shared_ptr< TransactionManager > trx_mgr, std::shared_ptr< DbStorage > db, const std::string &logs_prefix="")

void	sendBlockWithTransactions (const std::shared_ptr< TaraxaPeer > &peer, const std::shared_ptr< DagBlock > &block, SharedTransactions &&trxs) override

void	onNewBlockReceived (std::shared_ptr< DagBlock > &&block, const std::shared_ptr< TaraxaPeer > &peer=nullptr, const std::unordered_map< trx_hash_t, std::shared_ptr< Transaction > > &trxs={})

Public Member Functions inherited from taraxa::network::tarcap::IDagBlockPacketHandler
	IDagBlockPacketHandler (const FullNodeConfig &conf, std::shared_ptr< PeersState > peers_state, std::shared_ptr< TimePeriodPacketsStats > packets_stats, std::shared_ptr< PbftSyncingState > pbft_syncing_state, std::shared_ptr< PbftChain > pbft_chain, std::shared_ptr< PbftManager > pbft_mgr, std::shared_ptr< DagManager > dag_mgr, std::shared_ptr< DbStorage > db, const std::string &log_channel_name)

void	onNewBlockVerified (const std::shared_ptr< DagBlock > &block, bool proposed, const SharedTransactions &trxs)

void	requestDagBlocks (std::shared_ptr< TaraxaPeer > peer)

Public Member Functions inherited from taraxa::network::tarcap::ExtSyncingPacketHandler
	ExtSyncingPacketHandler (const FullNodeConfig &conf, std::shared_ptr< PeersState > peers_state, std::shared_ptr< TimePeriodPacketsStats > packets_stats, std::shared_ptr< PbftSyncingState > pbft_syncing_state, std::shared_ptr< PbftChain > pbft_chain, std::shared_ptr< PbftManager > pbft_mgr, std::shared_ptr< DagManager > dag_mgr, std::shared_ptr< DbStorage > db, const std::string &log_channel_name)

virtual	~ExtSyncingPacketHandler ()=default

ExtSyncingPacketHandler &	operator= (const ExtSyncingPacketHandler &)=delete

ExtSyncingPacketHandler &	operator= (ExtSyncingPacketHandler &&)=delete

void	requestDagBlocks (const dev::p2p::NodeID &_nodeID, std::vector< blk_hash_t > &&blocks, PbftPeriod period)

void	requestPendingDagBlocks (std::shared_ptr< TaraxaPeer > peer=nullptr)

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 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) override
	Packet processing function wrapper that logs packet stats and calls process function.

Public Member Functions inherited from taraxa::network::tarcap::BasePacketHandler
	BasePacketHandler ()=default

virtual	~BasePacketHandler ()=default

	BasePacketHandler (const BasePacketHandler &)=default

	BasePacketHandler (BasePacketHandler &&)=default

BasePacketHandler &	operator= (const BasePacketHandler &)=default

BasePacketHandler &	operator= (BasePacketHandler &&)=default

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

Protected Attributes
std::shared_ptr< TransactionManager >	trx_mgr_ {nullptr}

Protected Attributes inherited from taraxa::network::tarcap::ExtSyncingPacketHandler
std::shared_ptr< PbftSyncingState >	pbft_syncing_state_ {nullptr}

std::shared_ptr< PbftChain >	pbft_chain_ {nullptr}

std::shared_ptr< PbftManager >	pbft_mgr_ {nullptr}

std::shared_ptr< DagManager >	dag_mgr_ {nullptr}

std::shared_ptr< DbStorage >	db_ {nullptr}

Protected Attributes inherited from taraxa::network::tarcap::PacketHandler
const FullNodeConfig &	kConf

std::shared_ptr< PeersState >	peers_state_ {nullptr}

std::shared_ptr< TimePeriodPacketsStats >	packets_stats_

logger::Logger	logger_

Private Member Functions
virtual void	process (const threadpool::PacketData &packet_data, const std::shared_ptr< TaraxaPeer > &peer) override
	Main packet processing function.

Additional Inherited Members
Protected Member Functions inherited from taraxa::network::tarcap::PacketHandler
bool	sealAndSend (const dev::p2p::NodeID &node_id, SubprotocolPacketType packet_type, dev::bytes &&rlp_bytes)

void	disconnect (const dev::p2p::NodeID &node_id, dev::p2p::DisconnectReason reason)

Constructor & Destructor Documentation

◆ DagBlockPacketHandler()

taraxa::network::tarcap::DagBlockPacketHandler::DagBlockPacketHandler	(	const FullNodeConfig &	conf,
		std::shared_ptr< PeersState >	peers_state,
		std::shared_ptr< TimePeriodPacketsStats >	packets_stats,
		std::shared_ptr< PbftSyncingState >	pbft_syncing_state,
		std::shared_ptr< PbftChain >	pbft_chain,
		std::shared_ptr< PbftManager >	pbft_mgr,
		std::shared_ptr< DagManager >	dag_mgr,
		std::shared_ptr< TransactionManager >	trx_mgr,
		std::shared_ptr< DbStorage >	db,
		const std::string &	logs_prefix = `""`
	)

Member Function Documentation

◆ onNewBlockReceived()

void taraxa::network::tarcap::DagBlockPacketHandler::onNewBlockReceived	(	std::shared_ptr< DagBlock > &&	block,
		const std::shared_ptr< TaraxaPeer > &	peer = `nullptr`,
		const std::unordered_map< trx_hash_t, std::shared_ptr< Transaction > > &	trxs = `{}`
	)

◆ process()

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

overrideprivatevirtual

Main packet processing function.

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

◆ sendBlockWithTransactions()

void taraxa::network::tarcap::DagBlockPacketHandler::sendBlockWithTransactions	(	const std::shared_ptr< TaraxaPeer > &	peer,
		const std::shared_ptr< DagBlock > &	block,
		SharedTransactions &&	trxs
	)

overridevirtual

Implements taraxa::network::tarcap::IDagBlockPacketHandler.

Member Data Documentation

◆ kPacketType_

constexpr SubprotocolPacketType taraxa::network::tarcap::DagBlockPacketHandler::kPacketType_ = SubprotocolPacketType::kDagBlockPacket

staticconstexpr

◆ trx_mgr_

std::shared_ptr<TransactionManager> taraxa::network::tarcap::DagBlockPacketHandler::trx_mgr_ {nullptr}

protected

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

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

Public Member Functions

Static Public Attributes

Protected Attributes

Private Member Functions

Additional Inherited Members