sortition_params_manager.hpp

Go to the documentation of this file.

#pragma once
 
#include "pbft/period_data.hpp"
#include "storage/storage.hpp"
#include "vdf/config.hpp"
 
namespace taraxa {
 
using EfficienciesMap = std::map<uint16_t, int32_t>;
 
struct SortitionParamsChange {
  PbftPeriod period = 0;
  VrfParams vrf_params;
  uint16_t interval_efficiency = 0;
 
  SortitionParamsChange() = default;
  SortitionParamsChange(PbftPeriod period, uint16_t efficiency, const VrfParams& vrf);
  static SortitionParamsChange from_rlp(const dev::RLP& rlp);
  bytes rlp() const;
};
 
class SortitionParamsManager {
 public:
  SortitionParamsManager(const addr_t& node_addr, SortitionConfig sort_conf, std::shared_ptr<DbStorage> db);
  SortitionParams getSortitionParams(std::optional<PbftPeriod> for_period = {}) const;
 
  uint16_t calculateDagEfficiency(const PeriodData& block) const;
 
  void pbftBlockPushed(const PeriodData& block, Batch& batch, PbftPeriod non_empty_pbft_chain_size);
 
  uint16_t averageDagEfficiency();
 
  const std::deque<SortitionParamsChange>& getParamsChanges() const { return params_changes_; }
 
 protected:
  SortitionConfig config_;
  std::shared_ptr<DbStorage> db_;
  std::deque<uint16_t> dag_efficiencies_;
  uint32_t ignored_efficiency_counter_ = 0;
  std::deque<SortitionParamsChange> params_changes_;
  SortitionParamsChange calculateChange(PbftPeriod period);
  EfficienciesMap getEfficienciesToUpperRange(uint16_t efficiency, int32_t threshold) const;
  int32_t getNewUpperRange(uint16_t efficiency) const;
  void cleanup();
 
  LOG_OBJECTS_DEFINE
};
}  // namespace taraxa