light.hpp

Go to the documentation of this file.

#include "common/thread_pool.hpp"
#include "logger/logger.hpp"
#include "plugin/plugin.hpp"
 
namespace taraxa::net {}  // namespace taraxa::net
 
namespace taraxa::plugin {
 
class Light : public Plugin {
 public:
  explicit Light(std::shared_ptr<AppBase> app);
 
  std::string name() const override { return "light"; }
  std::string description() const override { return "Light node plugin"; }
 
  void init(const boost::program_options::variables_map& options) override;
  void addOptions(boost::program_options::options_description& command_line_options) override;
 
  void start() override;
  void shutdown() override;
 
  void clearLightNodeHistory(bool live_cleanup = false);
 
 private:
  void clearHistory(PbftPeriod end_period, uint64_t dag_level_to_keep, bool live_cleanup);
  void clearNonBlockData(PbftPeriod start, PbftPeriod end, bool live_cleanup);
  void recreateNonBlockData(PbftPeriod last_block_number);
  void pruneStateDb();
 
  uint64_t getCleanupPeriod(uint64_t dag_period, std::optional<uint64_t> proposal_period) const;
 
  static constexpr uint64_t kPeriodsToKeepNonBlockData = 1000;
  std::shared_ptr<util::ThreadPool> cleanup_pool_ = std::make_shared<util::ThreadPool>(1);
  uint64_t& history_;
  bool state_db_pruning_;
  bool live_cleanup_;
  std::atomic<bool> live_cleanup_in_progress_ = false;
 
  LOG_OBJECTS_DEFINE
};
 
}  // namespace taraxa::plugin