TARAXA
|
#include <pbft_blocks_bundle_packet_handler.hpp>
Public Member Functions | |
PbftBlocksBundlePacketHandler (const FullNodeConfig &conf, std::shared_ptr< PeersState > peers_state, std::shared_ptr< TimePeriodPacketsStats > packets_stats, std::shared_ptr< PbftManager > pbft_mgr, std::shared_ptr< PbftSyncingState > syncing_state, const std::string &logs_prefix="") | |
![]() | |
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. | |
![]() | |
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::kPbftBlocksBundlePacket |
static constexpr size_t | kMaxBlocksInPacket = 10 |
Private Member Functions | |
virtual void | process (const threadpool::PacketData &packet_data, const std::shared_ptr< TaraxaPeer > &peer) override |
Main packet processing function. | |
Private Attributes | |
std::shared_ptr< PbftManager > | pbft_mgr_ |
std::shared_ptr< PbftSyncingState > | pbft_syncing_state_ |
Additional Inherited Members | |
![]() | |
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) |
![]() | |
const FullNodeConfig & | kConf |
std::shared_ptr< PeersState > | peers_state_ {nullptr} |
std::shared_ptr< TimePeriodPacketsStats > | packets_stats_ |
logger::Logger | logger_ |
taraxa::network::tarcap::PbftBlocksBundlePacketHandler::PbftBlocksBundlePacketHandler | ( | const FullNodeConfig & | conf, |
std::shared_ptr< PeersState > | peers_state, | ||
std::shared_ptr< TimePeriodPacketsStats > | packets_stats, | ||
std::shared_ptr< PbftManager > | pbft_mgr, | ||
std::shared_ptr< PbftSyncingState > | syncing_state, | ||
const std::string & | logs_prefix = "" |
||
) |
|
overrideprivatevirtual |
Main packet processing function.
Implements taraxa::network::tarcap::PacketHandler.
|
staticconstexpr |
|
staticconstexpr |
|
private |
|
private |