logos-co
/
nomos-node
mirror of
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

gather enough new views then construct ProposalBlock event

This commit is contained in:
al8n 2023-05-17 21:21:52 +08:00
parent 9ca5060ce7
commit 87da2bdd0c
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
simulations/src/node/carnot/event_builder.rs
View File

@ -1,5 +1,5 @@
use crate::node::carnot::messages::CarnotMessage; use crate::node::carnot::messages::CarnotMessage;
use consensus_engine::View; use consensus_engine::{View, Qc, AggregateQc};
use nomos_consensus::network::messages::{NewViewMsg, TimeoutMsg, VoteMsg}; use nomos_consensus::network::messages::{NewViewMsg, TimeoutMsg, VoteMsg};
use nomos_consensus::Event::TimeoutQc; use nomos_consensus::Event::TimeoutQc;
use nomos_consensus::{Event, NodeId}; use nomos_consensus::{Event, NodeId};
@ -75,10 +75,10 @@ impl EventBuilder {
let msg_view = msg.vote.view; let msg_view = msg.vote.view;
let timeout_qc = msg.vote.timeout_qc.clone(); let timeout_qc = msg.vote.timeout_qc.clone();
if let Some(new_views) = self.new_view_message.tally(msg_view, msg) { if let Some(new_views) = self.new_view_message.tally(msg_view, msg) {
events.push(Event::NewView { events.push(Event::ProposeBlock { qc: Qc::Aggregated(AggregateQc {
new_views, high_qc: timeout_qc.high_qc,
timeout_qc, view: timeout_qc.view + 2,
}) }) })
} }
} }
} }