19namespace pillar_chain {
20class PillarChainManager;
63 const std::vector<std::pair<bool, WalletConfig>> &
getWallets(
PbftPeriod current_pbft_period)
const;
79 std::shared_ptr<PbftVote>
vote;
82 using time_point = std::chrono::system_clock::time_point;
86 std::shared_ptr<VoteManager> vote_mgr, std::shared_ptr<DagManager> dag_mgr,
87 std::shared_ptr<TransactionManager> trx_mgr, std::shared_ptr<final_chain::FinalChain> final_chain,
88 std::shared_ptr<pillar_chain::PillarChainManager> pillar_chain_mgr);
99 void setNetwork(std::weak_ptr<Network> network);
177 const std::optional<PbftBlockExtraData> &extra_data,
178 const std::vector<WalletConfig> &eligible_wallets);
219 std::vector<std::shared_ptr<PbftVote>> &¤t_block_cert_votes);
317 void gossipVote(
const std::shared_ptr<PbftVote> &vote,
const std::shared_ptr<PbftBlock> &voted_block);
329 std::map<PbftPeriod, std::vector<std::shared_ptr<PbftBlock>>>
getProposedBlocks()
const;
450 const blk_hash_t &block_hash, std::shared_ptr<PbftBlock> pbft_block =
nullptr);
460 std::vector<std::shared_ptr<PbftVote>> &&reward_votes);
468 void gossipNewVote(
const std::shared_ptr<PbftVote> &vote,
const std::shared_ptr<PbftBlock> &voted_block);
490 std::optional<std::pair<std::shared_ptr<PbftBlock>, std::shared_ptr<PbftVote>>>
identifyLeaderBlock(
491 std::vector<std::shared_ptr<PbftVote>> &&propose_votes);
498 h256
getProposal(
const std::shared_ptr<PbftVote> &vote)
const;
535 std::vector<std::shared_ptr<PbftVote>> &¤t_round_cert_votes);
544 bool synchronous_processing =
false);
568 std::optional<std::pair<PeriodData, std::vector<std::shared_ptr<PbftVote>>>>
processPeriodData();
578 const std::vector<std::shared_ptr<PbftVote>> &cert_votes)
const;
607 std::shared_ptr<DbStorage>
db_;
619 std::shared_ptr<util::ThreadPool>
Definition pbft_manager.hpp:59
std::vector< std::pair< bool, WalletConfig > > wallets_
Definition pbft_manager.hpp:73
const std::vector< std::pair< bool, WalletConfig > > & getWallets(PbftPeriod current_pbft_period) const
Definition pbft_manager.cpp:2324
PbftPeriod period_
Definition pbft_manager.hpp:72
void updateWalletsEligibility(PbftPeriod period, const std::shared_ptr< final_chain::FinalChain > &final_chain)
Definition pbft_manager.cpp:2312
PbftPeriod getWalletsEligiblePeriod() const
Definition pbft_manager.cpp:2331
class ProposedBlocks holds proposed pbft blocks together with propose votes hashes per period & round
Definition proposed_blocks.hpp:18
std::optional< ProposedBlockData > generatePbftBlock(PbftPeriod propose_period, const blk_hash_t &prev_blk_hash, const blk_hash_t &anchor_hash, const blk_hash_t &order_hash, const std::optional< PbftBlockExtraData > &extra_data, const std::vector< WalletConfig > &eligible_wallets)
Generate PBFT block, push into unverified queue, and broadcast to peers.
Definition pbft_manager.cpp:1163
std::vector< std::shared_ptr< PbftVote > > reward_votes
Definition pbft_manager.hpp:78
std::chrono::system_clock::time_point time_point
Definition pbft_manager.hpp:82
uint32_t rebroadcast_reward_votes_counter_
Definition pbft_manager.hpp:631
std::shared_ptr< pillar_chain::PillarChainManager > pillar_chain_mgr_
Definition pbft_manager.hpp:614
void secondFinish_()
PBFT finish polling state: Happens at odd number steps from step 5. Place a next vote at finishing va...
Definition pbft_manager.cpp:1096
std::atomic< PbftRound > round_
Definition pbft_manager.hpp:634
void testBroadcastVotesFunctionality()
Test/enforce broadcastVotes() to actually send votes.
Definition pbft_manager.cpp:681
const std::chrono::milliseconds kMinLambda
Definition pbft_manager.hpp:622
void processProposedBlock(const std::shared_ptr< PbftBlock > &proposed_block)
Push proposed block into the proposed_blocks_ in case it is not there yet.
Definition pbft_manager.cpp:1234
std::shared_ptr< PbftChain > pbft_chain_
Definition pbft_manager.hpp:608
void setPbftStep(PbftStep pbft_step)
Set PBFT step.
Definition pbft_manager.cpp:275
const blk_hash_t dag_genesis_block_hash_
Definition pbft_manager.hpp:659
std::shared_ptr< PbftBlock > getValidPbftProposedBlock(PbftPeriod period, const blk_hash_t &block_hash)
Get valid proposed pbft block. It will retrieve block from proposed_blocks and then validate it if no...
Definition pbft_manager.cpp:751
bool executed_pbft_block_
Definition pbft_manager.hpp:648
void start()
Start PBFT daemon.
Definition pbft_manager.cpp:107
void setFilterState_()
Set PBFT filter state.
Definition pbft_manager.cpp:548
std::shared_ptr< PbftVote > vote
Definition pbft_manager.hpp:79
std::chrono::milliseconds getPbftInitialLambda() const
Get PBFT lambda. PBFT lambda is a timer clock.
Definition pbft_manager.hpp:231
uint32_t rebroadcast_votes_counter_
Definition pbft_manager.hpp:629
EligibleWallets eligible_wallets_
Definition pbft_manager.hpp:672
std::shared_ptr< TransactionManager > trx_mgr_
Definition pbft_manager.hpp:612
bool already_next_voted_null_block_hash_
Definition pbft_manager.hpp:650
std::shared_ptr< util::ThreadPool > sync_thread_pool_
Definition pbft_manager.hpp:620
void setFinishState_()
Set PBFT finish state.
Definition pbft_manager.cpp:561
std::pair< bool, PbftPeriod > getDagBlockPeriod(const blk_hash_t &hash)
Get a DAG block period number.
Definition pbft_manager.cpp:188
void sleep_()
Time to sleep for PBFT protocol.
Definition pbft_manager.cpp:446
static blk_hash_t calculateOrderHash(const std::vector< blk_hash_t > &dag_block_hashes)
Calculate DAG blocks ordering hash.
Definition pbft_manager.cpp:1242
~PbftManager()
Definition pbft_manager.cpp:103
const uint32_t kSyncingThreadPoolSize
Definition pbft_manager.hpp:618
size_t periodDataQueueSize() const
Get PBFT blocks syncing queue size.
Definition pbft_manager.cpp:2281
bool go_finish_state_
Definition pbft_manager.hpp:651
void setNetwork(std::weak_ptr< Network > network)
Set network as a weak pointer.
Definition pbft_manager.cpp:105
void setCertifyState_()
Set PBFT certify state.
Definition pbft_manager.cpp:554
PbftPeriod pbftSyncingPeriod() const
Get PBFT blocks synced period.
Definition pbft_manager.cpp:1942
size_t getPbftCommitteeSize() const
Get PBFT committee size.
Definition pbft_manager.hpp:283
bool pushCertVotedPbftBlockIntoChain_(const std::shared_ptr< PbftBlock > &pbft_block, std::vector< std::shared_ptr< PbftVote > > &¤t_round_cert_votes)
If there are enough certify votes, push the vote PBFT block in PBFT chain.
Definition pbft_manager.cpp:1666
bool advanceRound()
If node receives 2t+1 next votes for some block(including kNullBlockHash), advance round to + 1.
Definition pbft_manager.cpp:370
std::chrono::milliseconds lambda_
Definition pbft_manager.hpp:623
PbftStates state_
Definition pbft_manager.hpp:633
PbftStep getPbftStep() const
Get PBFT step number.
Definition pbft_manager.cpp:208
void identifyBlock_()
PBFT filter state. PBFT step 2. Identify a leader block from all received proposed blocks for the cur...
Definition pbft_manager.cpp:954
std::optional< uint64_t > getCurrentNodeVotesCount() const
Get current node DPOS votes count.
Definition pbft_manager.cpp:238
uint32_t broadcast_reward_votes_counter_
Definition pbft_manager.hpp:630
bool stateOperations_()
If there are any synced PBFT blocks from peers, push the synced blocks in PBFT chain....
Definition pbft_manager.cpp:710
time_point second_finish_step_start_datetime_
Definition pbft_manager.hpp:645
std::atomic< bool > stopped_
Definition pbft_manager.hpp:600
std::shared_ptr< DagManager > dag_mgr_
Definition pbft_manager.hpp:610
bool validatePbftBlockExtraData(const std::shared_ptr< PbftBlock > &pbft_block) const
Validates pbft block extra data presence:
Definition pbft_manager.cpp:1517
std::chrono::milliseconds next_step_time_ms_
Definition pbft_manager.hpp:646
h256 getProposal(const std::shared_ptr< PbftVote > &vote) const
Calculate the lowest hash of a vote by vote weight.
Definition pbft_manager.cpp:1441
uint32_t broadcast_votes_counter_
Definition pbft_manager.hpp:628
std::shared_ptr< PbftBlock > pbft_block
Definition pbft_manager.hpp:77
void printVotingSummary() const
Prints all votes generated by node in current round.
Definition pbft_manager.cpp:689
std::shared_ptr< final_chain::FinalChain > final_chain_
Definition pbft_manager.hpp:613
PbftPeriod getPbftPeriod() const
Get current PBFT period number.
Definition pbft_manager.cpp:200
std::shared_ptr< PbftBlock > getPbftProposedBlock(PbftPeriod period, const blk_hash_t &block_hash) const
Get a proposed PBFT block based on specified period and block hash.
Definition pbft_manager.cpp:2296
const FullNodeConfig kConfig
Definition pbft_manager.hpp:617
void firstFinish_()
PBFT finish state. Happens at even number steps from step 4. Place a next vote at finishing value for...
Definition pbft_manager.cpp:1047
bool canParticipateInConsensus(PbftPeriod period, const addr_t &node_addr) const
Definition pbft_manager.cpp:2222
std::mutex stop_mtx_
Definition pbft_manager.hpp:664
bool validatePbftBlock(const std::shared_ptr< PbftBlock > &pbft_block) const
Validates pbft block. It checks if:
Definition pbft_manager.cpp:1572
std::optional< uint64_t > getCurrentDposTotalVotesCount() const
Get current total DPOS votes count.
Definition pbft_manager.cpp:225
void pushSyncedPbftBlocksIntoChain()
Check PBFT blocks syncing queue. If there are synced PBFT blocks in queue, push it to PBFT chain.
Definition pbft_manager.cpp:1702
void resetPbftConsensus(PbftRound round)
Resets pbft consensus: current pbft round is set to round, step is set to the beginning value.
Definition pbft_manager.cpp:388
PbftPeriod last_placed_pillar_vote_period_
Definition pbft_manager.hpp:653
void setPbftRound(PbftRound round)
Set PBFT round number.
Definition pbft_manager.cpp:210
const std::chrono::milliseconds kMaxLambda
Definition pbft_manager.hpp:624
std::unordered_map< blk_hash_t, std::vector< std::shared_ptr< DagBlock > > > anchor_dag_block_order_cache_
Definition pbft_manager.hpp:604
PeriodDataQueue sync_queue_
Definition pbft_manager.hpp:666
bool validatePbftBlockCertVotes(const std::shared_ptr< PbftBlock > pbft_block, const std::vector< std::shared_ptr< PbftVote > > &cert_votes) const
Validates PBFT block cert votes.
Definition pbft_manager.cpp:2075
PbftManager & operator=(const PbftManager &)=delete
blk_hash_t getLastPbftBlockHash()
Definition pbft_manager.cpp:2294
std::chrono::milliseconds elapsedTimeInMs(const time_point &start_time)
Definition pbft_manager.cpp:442
void gossipNewVote(const std::shared_ptr< PbftVote > &vote, const std::shared_ptr< PbftBlock > &voted_block)
Gossips newly generated vote to the other peers.
Definition pbft_manager.cpp:866
PbftStateRootValidation validateFinalChainHash(const std::shared_ptr< PbftBlock > &pbft_block) const
Validates pbft block final chain hash.
Definition pbft_manager.cpp:1499
bool checkBlockWeight(const std::vector< std::shared_ptr< DagBlock > > &dag_blocks, PbftPeriod period) const
Check a block weight of gas estimation.
Definition pbft_manager.cpp:2283
ProposedBlocks proposed_blocks_
Definition pbft_manager.hpp:669
std::optional< ProposedBlockData > proposePbftBlock()
Propose a new PBFT block.
Definition pbft_manager.cpp:1282
std::optional< PbftBlockExtraData > createPbftBlockExtraData(PbftPeriod pbft_period) const
Creates pbft block extra data.
Definition pbft_manager.cpp:1419
bool pushPbftBlock_(PeriodData &&period_data, std::vector< std::shared_ptr< PbftVote > > &&cert_votes)
Push a new PBFT block into the PBFT chain.
Definition pbft_manager.cpp:1802
void certifyBlock_()
PBFT certify state. PBFT step 3. If receive enough soft votes and pass verification,...
Definition pbft_manager.cpp:991
void resetStep()
Reset PBFT step to 1.
Definition pbft_manager.cpp:313
std::condition_variable stop_cv_
Definition pbft_manager.hpp:663
void setFinishPollingState_()
Set PBFT finish polling state.
Definition pbft_manager.cpp:568
const GenesisConfig & kGenesisConfig
Definition pbft_manager.hpp:661
void finalize_(PeriodData &&period_data, std::vector< h256 > &&finalized_dag_blk_hashes, bool synchronous_processing=false)
Final chain executes a finalized PBFT block.
Definition pbft_manager.cpp:1782
bool loop_back_finish_state_
Definition pbft_manager.hpp:652
bool printSecondFinishStepInfo_
Definition pbft_manager.hpp:656
static void reorderTransactions(SharedTransactions &transactions)
Reorder transactions data if DAG reordering caused transactions with same sender to have nonce in inc...
Definition pbft_manager.cpp:1729
void stop()
Stop PBFT daemon.
Definition pbft_manager.cpp:116
std::optional< std::pair< PeriodData, std::vector< std::shared_ptr< PbftVote > > > > processPeriodData()
Process synced PBFT blocks if PBFT syncing queue is not empty.
Definition pbft_manager.cpp:1946
PbftManager(const PbftManager &)=delete
bool periodDataQueueEmpty() const
Returns true if queue is empty.
Definition pbft_manager.cpp:2248
std::weak_ptr< Network > network_
Definition pbft_manager.hpp:611
time_point current_round_start_datetime_
Definition pbft_manager.hpp:643
void broadcastVotes()
Broadcast or rebroadcast 2t+1 soft/reward/previous round next votes + all own votes if needed.
Definition pbft_manager.cpp:594
bool already_next_voted_value_
Definition pbft_manager.hpp:649
bool validatePillarDataInPeriodData(const PeriodData &period_data) const
Validates pbft block extra data presence + pillar votes presence based on pbft block number and ficus...
Definition pbft_manager.cpp:1549
bool validatePbftBlockPillarVotes(const PeriodData &period_data) const
Validates PBFT block pillar votes.
Definition pbft_manager.cpp:2158
blk_hash_t lastPbftBlockHashFromQueueOrChain()
Get last pbft block hash from queue or if queue empty, from chain.
Definition pbft_manager.cpp:2240
bool genAndPlaceProposeVote(const std::shared_ptr< PbftBlock > &proposed_block, std::vector< std::shared_ptr< PbftVote > > &&reward_votes)
Generate propose vote for provided block place (gossip) it.
Definition pbft_manager.cpp:839
bool advancePeriod()
If node receives 2t+1 cert votes for some valid block and pushes it to the chain, advance period to +...
Definition pbft_manager.cpp:345
bool tryPushCertVotesBlock()
Check if there is 2t+1 cert votes for some valid block, if yes - push it into the chain.
Definition pbft_manager.cpp:318
std::map< blk_hash_t, std::vector< PbftStep > > current_round_broadcasted_votes_
Definition pbft_manager.hpp:641
std::map< PbftPeriod, std::vector< std::shared_ptr< PbftBlock > > > getProposedBlocks() const
Definition pbft_manager.cpp:2236
std::unique_ptr< std::thread > daemon_
Definition pbft_manager.hpp:606
void periodDataQueuePush(PeriodData &&period_data, dev::p2p::NodeID const &node_id, std::vector< std::shared_ptr< PbftVote > > &¤t_block_cert_votes)
Push synced period data in syncing queue.
Definition pbft_manager.cpp:2250
bool genAndPlaceVote(PbftVoteTypes vote_type, PbftPeriod period, PbftRound round, PbftStep step, const blk_hash_t &block_hash, std::shared_ptr< PbftBlock > pbft_block=nullptr)
Generate and place(gossip) vote.
Definition pbft_manager.cpp:774
void initialState()
Initial PBFT states when node start PBFT.
Definition pbft_manager.cpp:463
const uint32_t kBroadcastVotesLambdaTime
Definition pbft_manager.hpp:626
void run()
Run PBFT daemon.
Definition pbft_manager.cpp:139
PbftRound getPbftRound() const
Get current PBFT round number.
Definition pbft_manager.cpp:202
PbftManager & operator=(PbftManager &&)=delete
std::pair< PbftRound, PbftPeriod > getPbftRoundAndPeriod() const
Get PBFT round & period number.
Definition pbft_manager.cpp:204
PbftStep step_
Definition pbft_manager.hpp:635
void waitForPeriodFinalization()
wait for DPOS period finalization
Definition pbft_manager.cpp:215
void proposeBlock_()
PBFT proposal state. PBFT step 1. Propose a PBFT block and place a proposal vote on the block hash.
Definition pbft_manager.cpp:890
PbftManager(PbftManager &&)=delete
void gossipVote(const std::shared_ptr< PbftVote > &vote, const std::shared_ptr< PbftBlock > &voted_block)
Gossips vote to the other peers.
Definition pbft_manager.cpp:877
void processPillarBlock(PbftPeriod period)
Creates pillar block (and pillar vote in case node is eligible to vote & is not syncing)
Definition pbft_manager.cpp:1907
std::shared_ptr< VoteManager > vote_mgr_
Definition pbft_manager.hpp:609
const uint32_t kRebroadcastVotesLambdaTime
Definition pbft_manager.hpp:627
std::optional< std::shared_ptr< PbftBlock > > cert_voted_block_for_round_
Definition pbft_manager.hpp:638
bool printCertStepInfo_
Definition pbft_manager.hpp:657
logger::Logger logger_
Definition pbft_manager.hpp:674
void loopBackFinishState_()
Set back to PBFT finish state from PBFT finish polling state.
Definition pbft_manager.cpp:582
std::optional< std::pair< std::shared_ptr< PbftBlock >, std::shared_ptr< PbftVote > > > identifyLeaderBlock(std::vector< std::shared_ptr< PbftVote > > &&propose_votes)
Identify a leader block from all received proposed PBFT blocks for the current round by using minimum...
Definition pbft_manager.cpp:1452
std::shared_ptr< DbStorage > db_
Definition pbft_manager.hpp:607
time_point current_period_start_datetime_
Definition pbft_manager.hpp:644
PbftManager class is a daemon that is used to finalize a bench of directed acyclic graph (DAG) blocks...
Definition pbft_manager.hpp:57
PeriodData class is for block execution, that includes PBFT block, certify votes, DAG blocks,...
Definition period_data.hpp:26
PeriodDataQueue class is a syncing queue, the queue stores blocks synced from peers.
Definition period_data_queue.hpp:20
PbftStateRootValidation
Definition pbft_manager.hpp:26
PbftStates
Definition pbft_manager.hpp:25
@ finish_state
Definition pbft_manager.hpp:25
@ certify_state
Definition pbft_manager.hpp:25
@ value_proposal_state
Definition pbft_manager.hpp:25
@ finish_polling_state
Definition pbft_manager.hpp:25
@ filter_state
Definition pbft_manager.hpp:25
Definition pbft_manager.hpp:76
PbftVoteTypes
Definition vrf_sortition.hpp:21
std::shared_ptr< spdlog::logger > Logger
Definition logging.hpp:12
uint32_t PbftStep
Definition types.hpp:27
uint32_t PbftRound
Definition types.hpp:26
EthBlockNumber PbftPeriod
Definition types.hpp:25
std::vector< SharedTransaction > SharedTransactions
Definition transaction.hpp:86
Definition genesis.hpp:23
PbftConfig pbft
Definition genesis.hpp:28
uint32_t committee_size
Definition pbft_config.hpp:11