15 struct FicusHardforkConfig;
41 std::shared_ptr<final_chain::FinalChain> final_chain, std::shared_ptr<KeyManager> key_manager,
55 const std::shared_ptr<const final_chain::BlockHeader>& block_header,
56 const h256& bridge_root,
const h256& bridge_epoch);
69 const secret_t& node_sk,
bool broadcast_vote);
75 void setNetwork(std::weak_ptr<Network> network);
135 bool above_threshold =
false)
const;
158 const std::vector<state_api::ValidatorVoteCount>& current_vote_counts,
159 const std::vector<state_api::ValidatorVoteCount>& previous_pillar_block_vote_counts);
168 std::vector<state_api::ValidatorVoteCount>&& new_vote_counts);
174 std::shared_ptr<DbStorage>
db_;
Definition: FixedHash.h:35
Definition: pillar_votes.hpp:10
void saveNewPillarBlock(std::shared_ptr< PillarBlock > pillar_block, std::vector< state_api::ValidatorVoteCount > &&new_vote_counts)
Save new pillar block into db & class data members.
Definition: pillar_chain_manager.cpp:109
bool isRelevantPillarVote(const std::shared_ptr< PillarVote > vote) const
Checks if vote is related to saved latest_pillar_block_ and it is not already saved.
Definition: pillar_chain_manager.cpp:216
std::shared_ptr< PillarVote > genAndPlacePillarVote(PbftPeriod period, const blk_hash_t &pillar_block_hash, const secret_t &node_sk, bool broadcast_vote)
Generate and place pillar vote for provided pillar_block_hash in case the whole pillar block is prese...
Definition: pillar_chain_manager.cpp:119
std::vector< std::shared_ptr< PillarVote > > finalizePillarBlock(const blk_hash_t &pillar_block_hash)
Finalize pillar block.
Definition: pillar_chain_manager.cpp:145
std::vector< state_api::ValidatorVoteCount > current_pillar_block_vote_counts_
Definition: pillar_chain_manager.hpp:186
const addr_t node_addr_
Definition: pillar_chain_manager.hpp:179
std::shared_ptr< PillarBlock > current_pillar_block_
Definition: pillar_chain_manager.hpp:184
std::weak_ptr< Network > network_
Definition: pillar_chain_manager.hpp:175
bool validatePillarVote(const std::shared_ptr< PillarVote > vote) const
Validates pillar vote.
Definition: pillar_chain_manager.cpp:249
std::shared_ptr< final_chain::FinalChain > final_chain_
Definition: pillar_chain_manager.hpp:176
std::shared_ptr< DbStorage > db_
Definition: pillar_chain_manager.hpp:174
bool isValidPillarBlock(const std::shared_ptr< PillarBlock > &pillar_block) const
Definition: pillar_chain_manager.cpp:329
std::shared_ptr< PillarBlock > last_finalized_pillar_block_
Definition: pillar_chain_manager.hpp:182
const util::EventEmitter< const PillarBlockData & > pillar_block_finalized_emitter_
Definition: pillar_chain_manager.hpp:33
std::shared_ptr< PillarBlock > createPillarBlock(PbftPeriod period, const std::shared_ptr< const final_chain::BlockHeader > &block_header, const h256 &bridge_root, const h256 &bridge_epoch)
Definition: pillar_chain_manager.cpp:52
std::vector< std::shared_ptr< PillarVote > > getVerifiedPillarVotes(PbftPeriod period, const blk_hash_t pillar_block_hash, bool above_threshold=false) const
Get all pillar votes for specified pillar block.
Definition: pillar_chain_manager.cpp:316
std::vector< PillarBlock::ValidatorVoteCountChange > getOrderedValidatorsVoteCountsChanges(const std::vector< state_api::ValidatorVoteCount > ¤t_vote_counts, const std::vector< state_api::ValidatorVoteCount > &previous_pillar_block_vote_counts)
Return a vector of validators vote counts changes between the current and previous pillar block Chang...
Definition: pillar_chain_manager.cpp:365
const FicusHardforkConfig & kFicusHfConfig
Definition: pillar_chain_manager.hpp:172
std::optional< uint64_t > getPillarConsensusThreshold(PbftPeriod period) const
Definition: pillar_chain_manager.cpp:351
decltype(pillar_block_finalized_emitter_) const ::Subscriber & pillar_block_finalized_
Definition: pillar_chain_manager.hpp:36
std::shared_mutex mutex_
Definition: pillar_chain_manager.hpp:193
void setNetwork(std::weak_ptr< Network > network)
Set network as a weak pointer.
Definition: pillar_chain_manager.cpp:430
std::shared_ptr< PillarBlock > getCurrentPillarBlock() const
Definition: pillar_chain_manager.cpp:211
PillarVotes pillar_votes_
Definition: pillar_chain_manager.hpp:190
bool isPillarBlockLatestFinalized(const blk_hash_t &block_hash) const
Definition: pillar_chain_manager.cpp:195
PillarChainManager(const FicusHardforkConfig &ficus_hf_config, std::shared_ptr< DbStorage > db, std::shared_ptr< final_chain::FinalChain > final_chain, std::shared_ptr< KeyManager > key_manager, addr_t node_addr)
Definition: pillar_chain_manager.cpp:14
std::shared_ptr< PillarBlock > getLastFinalizedPillarBlock() const
Definition: pillar_chain_manager.cpp:206
uint64_t addVerifiedPillarVote(const std::shared_ptr< PillarVote > &vote)
Add a vote to the pillar votes map.
Definition: pillar_chain_manager.cpp:279
std::shared_ptr< KeyManager > key_manager_
Definition: pillar_chain_manager.hpp:177
PillarChainMgr class contains functionality related to pillar chain.
Definition: pillar_chain_manager.hpp:31
#define LOG_OBJECTS_DEFINE
Definition: logger.hpp:60
Definition: dag_block_proposer.hpp:21
Definition: pillar_block.hpp:16
EthBlockNumber PbftPeriod
Definition: types.hpp:24
Definition: hardfork.hpp:43