TARAXA
Loading...
Searching...
No Matches
taraxa::network::tarcap::ISyncPacketHandler Class Reference

#include <sync_packet_handler.hpp>

Collaboration diagram for taraxa::network::tarcap::ISyncPacketHandler:

Public Member Functions

 ISyncPacketHandler (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 startSyncingPbft ()
 Start syncing pbft if needed.
 
virtual bool syncPeerPbft (PbftPeriod request_period)
 Send sync request to the current syncing peer with specified request_period.
 
void sendStatusToPeers ()
 
virtual bool sendStatus (const dev::p2p::NodeID &node_id, bool initial)
 
- 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
 
ExtSyncingPacketHandleroperator= (const ExtSyncingPacketHandler &)=delete
 
ExtSyncingPacketHandleroperator= (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
 
PacketHandleroperator= (const PacketHandler &)=delete
 
PacketHandleroperator= (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
 
BasePacketHandleroperator= (const BasePacketHandler &)=default
 
BasePacketHandleroperator= (BasePacketHandler &&)=default
 

Private Attributes

const h256 kGenesisHash
 

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)
 
- Protected Attributes inherited from taraxa::network::tarcap::ExtSyncingPacketHandler
std::shared_ptr< PbftSyncingStatepbft_syncing_state_ {nullptr}
 
std::shared_ptr< PbftChainpbft_chain_ {nullptr}
 
std::shared_ptr< PbftManagerpbft_mgr_ {nullptr}
 
std::shared_ptr< DagManagerdag_mgr_ {nullptr}
 
std::shared_ptr< DbStoragedb_ {nullptr}
 
- Protected Attributes inherited from taraxa::network::tarcap::PacketHandler
const FullNodeConfigkConf
 
std::shared_ptr< PeersStatepeers_state_ {nullptr}
 
std::shared_ptr< TimePeriodPacketsStatspackets_stats_
 
logger::Logger logger_
 

Constructor & Destructor Documentation

◆ ISyncPacketHandler()

taraxa::network::tarcap::ISyncPacketHandler::ISyncPacketHandler ( 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 
)

Member Function Documentation

◆ sendStatus()

bool taraxa::network::tarcap::ISyncPacketHandler::sendStatus ( const dev::p2p::NodeID node_id,
bool  initial 
)
virtual

◆ sendStatusToPeers()

void taraxa::network::tarcap::ISyncPacketHandler::sendStatusToPeers ( )

◆ startSyncingPbft()

void taraxa::network::tarcap::ISyncPacketHandler::startSyncingPbft ( )

Start syncing pbft if needed.

◆ syncPeerPbft()

bool taraxa::network::tarcap::ISyncPacketHandler::syncPeerPbft ( PbftPeriod  request_period)
virtual

Send sync request to the current syncing peer with specified request_period.

Parameters
request_period
Returns
true if sync request was sent, otherwise false

Member Data Documentation

◆ kGenesisHash

const h256 taraxa::network::tarcap::ISyncPacketHandler::kGenesisHash
private

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