25class TransactionManager;
29namespace pillar_chain {
30class PillarChainManager;
33namespace final_chain {
41class ISyncPacketHandler;
42class IVotePacketHandler;
43class IPillarVotePacketHandler;
44class IGetPillarVotesBundlePacketHandler;
45class ITransactionPacketHandler;
46class IDagBlockPacketHandler;
48class PbftSyncingState;
57 const std::string &logs_prefix,
const FullNodeConfig &config,
const h256 &genesis_hash,
58 const std::shared_ptr<PeersState> &peers_state,
const std::shared_ptr<PbftSyncingState> &pbft_syncing_state,
60 const std::shared_ptr<tarcap::TimePeriodPacketsStats> &packets_stats,
const std::shared_ptr<DbStorage> &db,
61 const std::shared_ptr<PbftManager> &pbft_mgr,
const std::shared_ptr<PbftChain> &pbft_chain,
62 const std::shared_ptr<VoteManager> &vote_mgr,
const std::shared_ptr<DagManager> &dag_mgr,
63 const std::shared_ptr<TransactionManager> &trx_mgr,
const std::shared_ptr<SlashingManager> &slashing_manager,
64 const std::shared_ptr<pillar_chain::PillarChainManager> &pillar_chain_mgr,
75 std::weak_ptr<dev::p2p::Host> host,
76 std::shared_ptr<network::threadpool::PacketsThreadPool> threadpool,
77 std::shared_ptr<TimePeriodPacketsStats> packets_stats,
78 std::shared_ptr<PbftSyncingState> syncing_state, std::shared_ptr<DbStorage> db,
79 std::shared_ptr<PbftManager> pbft_mgr, std::shared_ptr<PbftChain> pbft_chain,
80 std::shared_ptr<VoteManager> vote_mgr, std::shared_ptr<DagManager> dag_mgr,
81 std::shared_ptr<TransactionManager> trx_mgr, std::shared_ptr<SlashingManager> slashing_manager,
82 std::shared_ptr<pillar_chain::PillarChainManager> pillar_chain_mgr,
83 std::shared_ptr<final_chain::FinalChain> final_chain,
93 std::string
name()
const override;
96 void onConnect(std::weak_ptr<dev::p2p::Session> session, u256
const &)
override;
110 template <
typename PacketHandlerType>
148template <
typename PacketHandlerType>
153 switch (packet_type) {
156 if (!std::is_same<ISyncPacketHandler, PacketHandlerType>::value) {
162 if (!std::is_same<ITransactionPacketHandler, PacketHandlerType>::value) {
169 if (!std::is_same<IVotePacketHandler, PacketHandlerType>::value) {
175 if (!std::is_same<IPillarVotePacketHandler, PacketHandlerType>::value) {
181 if (!std::is_same<IGetPillarVotesBundlePacketHandler, PacketHandlerType>::value) {
187 if (!std::is_same<IDagBlockPacketHandler, PacketHandlerType>::value) {
198 return std::dynamic_pointer_cast<PacketHandlerType>(handler);
The Capability interface. This interface has to be implemented to support any devp2p subprotocol.
Definition Capability.h:16
Definition taraxa_capability.hpp:51
std::function< std::shared_ptr< PacketsHandler >(const std::string &logs_prefix, const FullNodeConfig &config, const h256 &genesis_hash, const std::shared_ptr< PeersState > &peers_state, const std::shared_ptr< PbftSyncingState > &pbft_syncing_state, const std::shared_ptr< tarcap::TimePeriodPacketsStats > &packets_stats, const std::shared_ptr< DbStorage > &db, const std::shared_ptr< PbftManager > &pbft_mgr, const std::shared_ptr< PbftChain > &pbft_chain, const std::shared_ptr< VoteManager > &vote_mgr, const std::shared_ptr< DagManager > &dag_mgr, const std::shared_ptr< TransactionManager > &trx_mgr, const std::shared_ptr< SlashingManager > &slashing_manager, const std::shared_ptr< pillar_chain::PillarChainManager > &pillar_chain_mgr, const std::shared_ptr< final_chain::FinalChain > &final_chain, TarcapVersion version)> InitPacketsHandlers
Function signature for creating taraxa capability packets handlers.
Definition taraxa_capability.hpp:65
std::string packetTypeToString(unsigned _packetType) const override
Convert supplied packet type to string - used for logging purposes.
Definition taraxa_capability.cpp:124
virtual ~TaraxaCapability()=default
TarcapVersion version_
Definition taraxa_capability.hpp:119
std::string name() const override
Subprotocol name, used in negotiating common capabilities with the peers.
Definition taraxa_capability.cpp:61
void onDisconnect(dev::p2p::NodeID const &_nodeID) override
Definition taraxa_capability.cpp:105
void handlePacketQueueOverLimit(std::shared_ptr< dev::p2p::Host > host, dev::p2p::NodeID node_id, size_t tp_queue_size)
Definition taraxa_capability.cpp:206
const FullNodeConfig & kConf
Definition taraxa_capability.hpp:125
TaraxaCapability & operator=(const TaraxaCapability &ro)=delete
uint32_t last_disconnect_number_of_peers_
Definition taraxa_capability.hpp:143
std::shared_ptr< PbftSyncingState > pbft_syncing_state_
Definition taraxa_capability.hpp:131
std::shared_ptr< PacketHandlerType > getSpecificHandler(SubprotocolPacketType packet_type) const
templated getSpecificHandler method for getting specific packet handler based on packet_type
Definition taraxa_capability.hpp:149
static const InitPacketsHandlers kInitLatestVersionHandlers
Default InitPacketsHandlers function definition with the latest version of packets handlers.
Definition taraxa_capability.hpp:70
std::chrono::system_clock::time_point queue_over_limit_start_time_
Definition taraxa_capability.hpp:141
static const InitPacketsHandlers kInitV5VersionHandlers
Definition taraxa_capability.hpp:71
TaraxaCapability(TaraxaCapability &&ro)=delete
TarcapVersion version() const override
Definition taraxa_capability.cpp:63
void onConnect(std::weak_ptr< dev::p2p::Session > session, u256 const &) override
Definition taraxa_capability.cpp:67
std::shared_ptr< PacketsHandler > packets_handlers_
Definition taraxa_capability.hpp:134
void interpretCapabilityPacket(std::weak_ptr< dev::p2p::Session > session, unsigned _id, dev::RLP const &_r) override
Definition taraxa_capability.cpp:128
std::shared_ptr< TimePeriodPacketsStats > all_packets_stats_
Definition taraxa_capability.hpp:122
const std::shared_ptr< PeersState > & getPeersState()
Definition taraxa_capability.cpp:257
TaraxaCapability(const TaraxaCapability &ro)=delete
logger::Logger logger_
Definition taraxa_capability.hpp:145
std::shared_ptr< threadpool::PacketsThreadPool > thread_pool_
Definition taraxa_capability.hpp:137
TaraxaCapability & operator=(TaraxaCapability &&ro)=delete
bool queue_over_limit_
Definition taraxa_capability.hpp:142
std::shared_ptr< PeersState > peers_state_
Definition taraxa_capability.hpp:128
unsigned messageCount() const override
Number of messages supported by the subprotocol version.
Definition taraxa_capability.cpp:65
bool filterSyncIrrelevantPackets(SubprotocolPacketType packet_type) const
Definition taraxa_capability.cpp:246
std::chrono::system_clock::time_point last_ddos_disconnect_time_
Definition taraxa_capability.hpp:140
TransactionStatus
TransactionStatus enum class defines current transaction status.
Definition transaction_manager.hpp:23
std::shared_ptr< spdlog::logger > Logger
Definition logging.hpp:12
Definition vote_manager.hpp:24
unsigned TarcapVersion
Definition tarcap_version.hpp:4
SubprotocolPacketType
SubprotocolPacketType is used in networking layer to differentiate packet types.
Definition packet_types.hpp:12
@ kGetPillarVotesBundlePacket
Definition packet_types.hpp:33
@ kStatusPacket
Definition packet_types.hpp:28
@ kDagBlockPacket
Definition packet_types.hpp:21
@ kVotePacket
Definition packet_types.hpp:15
@ kPbftSyncPacket
Definition packet_types.hpp:30
@ kVotesBundlePacket
Definition packet_types.hpp:17
@ kTransactionPacket
Definition packet_types.hpp:24
@ kPillarVotePacket
Definition packet_types.hpp:32