TARAXA
taraxa::network::tarcap::GetPbftSyncPacketHandler Class Reference

#include <get_pbft_sync_packet_handler.hpp>

Collaboration diagram for taraxa::network::tarcap::GetPbftSyncPacketHandler:

Public Member Functions

 GetPbftSyncPacketHandler (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< VoteManager > vote_mgr, std::shared_ptr< DbStorage > db, const addr_t &node_addr, const std::string &logs_prefix="GET_PBFT_SYNC_PH")
 
- 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
 
PacketHandleroperator= (const PacketHandler &)=delete
 
PacketHandleroperator= (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::GetPbftSyncPacket
 

Protected Attributes

std::shared_ptr< PbftSyncingStatepbft_syncing_state_
 
std::shared_ptr< PbftChainpbft_chain_
 
std::shared_ptr< VoteManagervote_mgr_
 
std::shared_ptr< DbStoragedb_
 
- Protected Attributes inherited from taraxa::network::tarcap::PacketHandler
const FullNodeConfigkConf
 
std::shared_ptr< PeersStatepeers_state_ {nullptr}
 
std::shared_ptr< TimePeriodPacketsStatspackets_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...
 
virtual void sendPbftBlocks (const std::shared_ptr< TaraxaPeer > &peer, PbftPeriod from_period, size_t blocks_to_transfer, bool pbft_chain_synced)
 

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

◆ GetPbftSyncPacketHandler()

taraxa::network::tarcap::GetPbftSyncPacketHandler::GetPbftSyncPacketHandler ( 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< VoteManager vote_mgr,
std::shared_ptr< DbStorage db,
const addr_t node_addr,
const std::string &  logs_prefix = "GET_PBFT_SYNC_PH" 
)

Member Function Documentation

◆ process()

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

Main packet processing function.

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

◆ sendPbftBlocks()

void taraxa::network::tarcap::GetPbftSyncPacketHandler::sendPbftBlocks ( const std::shared_ptr< TaraxaPeer > &  peer,
PbftPeriod  from_period,
size_t  blocks_to_transfer,
bool  pbft_chain_synced 
)
privatevirtual

◆ validatePacketRlpFormat()

void taraxa::network::tarcap::GetPbftSyncPacketHandler::validatePacketRlpFormat ( const threadpool::PacketData packet_data) const
overrideprivatevirtual

Validates packet rlp format - items count.

Exceptions
InvalidRlpItemsCountExceptionexception

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

Member Data Documentation

◆ db_

std::shared_ptr<DbStorage> taraxa::network::tarcap::GetPbftSyncPacketHandler::db_
protected

◆ kPacketType_

constexpr SubprotocolPacketType taraxa::network::tarcap::GetPbftSyncPacketHandler::kPacketType_ = SubprotocolPacketType::GetPbftSyncPacket
staticconstexpr

◆ pbft_chain_

std::shared_ptr<PbftChain> taraxa::network::tarcap::GetPbftSyncPacketHandler::pbft_chain_
protected

◆ pbft_syncing_state_

std::shared_ptr<PbftSyncingState> taraxa::network::tarcap::GetPbftSyncPacketHandler::pbft_syncing_state_
protected

◆ vote_mgr_

std::shared_ptr<VoteManager> taraxa::network::tarcap::GetPbftSyncPacketHandler::vote_mgr_
protected

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