|
| TransactionPacketHandler (const FullNodeConfig &conf, std::shared_ptr< PeersState > peers_state, std::shared_ptr< TimePeriodPacketsStats > packets_stats, std::shared_ptr< TransactionManager > trx_mgr, const std::string &logs_prefix="") |
|
void | sendTransactions (std::shared_ptr< TaraxaPeer > peer, std::pair< SharedTransactions, std::vector< trx_hash_t > > &&transactions) override |
| Send transactions.
|
|
Public Member Functions inherited from taraxa::network::tarcap::ITransactionPacketHandler |
| ITransactionPacketHandler (const FullNodeConfig &conf, std::shared_ptr< PeersState > peers_state, std::shared_ptr< TimePeriodPacketsStats > packets_stats, const std::string &log_channel_name) |
|
void | periodicSendTransactions (std::vector< SharedTransactions > &&transactions) |
| Sends batch of transactions to all connected peers.
|
|
std::vector< std::pair< std::shared_ptr< TaraxaPeer >, std::pair< SharedTransactions, std::vector< trx_hash_t > > > > | transactionsToSendToPeers (std::vector< SharedTransactions > &&transactions) |
| select which transactions and hashes to send to which connected peer
|
|
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 |
|