ext_syncing_packet_handler.hpp

Go to the documentation of this file.

#pragma once
 
#include "dag/dag_manager.hpp"
#include "packet_handler.hpp"
 
namespace taraxa {
class PbftChain;
class PbftManager;
class DagManager;
class DbStorage;
}  // namespace taraxa
 
namespace taraxa::network::tarcap {
 
class PbftSyncingState;
 
class ExtSyncingPacketHandler : public PacketHandler {
 public:
  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 addr_t &node_addr, const std::string &log_channel_name);
 
  virtual ~ExtSyncingPacketHandler() = default;
  ExtSyncingPacketHandler &operator=(const ExtSyncingPacketHandler &) = delete;
  ExtSyncingPacketHandler &operator=(ExtSyncingPacketHandler &&) = delete;
 
  void startSyncingPbft();
 
  bool syncPeerPbft(PbftPeriod request_period);
 
  void requestDagBlocks(const dev::p2p::NodeID &_nodeID, const std::unordered_set<blk_hash_t> &blocks,
                        PbftPeriod period);
  void requestPendingDagBlocks(std::shared_ptr<TaraxaPeer> peer = nullptr);
 
  std::shared_ptr<TaraxaPeer> getMaxChainPeer(std::function<bool(const std::shared_ptr<TaraxaPeer> &)> filter_func =
                                                  [](const std::shared_ptr<TaraxaPeer> &) { return true; });
 
 protected:
  std::shared_ptr<PbftSyncingState> pbft_syncing_state_{nullptr};
 
  std::shared_ptr<PbftChain> pbft_chain_{nullptr};
  std::shared_ptr<PbftManager> pbft_mgr_{nullptr};
  std::shared_ptr<DagManager> dag_mgr_{nullptr};
  std::shared_ptr<DbStorage> db_{nullptr};
};
 
}  // namespace taraxa::network::tarcap