pillar_votes.hpp

Go to the documentation of this file.

#pragma once
 
#include <memory>
#include <shared_mutex>
 
#include "vote/pillar_vote.hpp"
 
namespace taraxa::pillar_chain {
 
class PillarVotes {
 public:
  struct WeightVotes {
    std::unordered_map<vote_hash_t, std::pair<std::shared_ptr<PillarVote>, uint64_t /* vote weight */>> votes;
    uint64_t weight{0};  // votes accumulated weight
  };
 
  struct PeriodVotes {
    std::unordered_map<blk_hash_t, WeightVotes> pillar_block_votes;
    std::unordered_map<addr_t, vote_hash_t> unique_voters;
 
    // threshold for pillar chain consensus - total votes count / 2 + 1
    uint64_t threshold{0};
  };
 
 public:
  bool voteExists(const std::shared_ptr<PillarVote> vote) const;
 
  bool isUniqueVote(const std::shared_ptr<PillarVote> vote) const;
 
  bool periodDataInitialized(PbftPeriod period) const;
 
  void initializePeriodData(PbftPeriod period, uint64_t threshold);
 
  bool addVerifiedVote(const std::shared_ptr<PillarVote>& vote, uint64_t validator_vote_count);
 
  std::vector<std::shared_ptr<PillarVote>> getVerifiedVotes(PbftPeriod period, const blk_hash_t& pillar_block_hash,
                                                            bool above_threshold = false) const;
 
  void eraseVotes(PbftPeriod min_period);
 
 private:
  // Votes for latest_pillar_block_.period - 1, latest_pillar_block_.period and potential +1 future pillar
  // block period
  std::map<PbftPeriod, PeriodVotes> votes_;
  mutable std::shared_mutex mutex_;
};
 
}  // namespace taraxa::pillar_chain