logos-co/nomos-node
1
0
Fork 0
mirror of synced 2025-01-09 23:35:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix gather_new_views

Browse Source
This commit is contained in:
Giacomo Pasini 2023-05-03 17:43:51 +02:00
parent fc48f55a25
commit 430dbf510e
No known key found for this signature in database
GPG Key ID: FC08489D2D895D4B
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
nomos-services/consensus/src/lib.rs
View File

@ -284,7 +284,7 @@ where
}
}
async fn gather_new_view(
async fn gather_new_views(
&self,
committee: &Committee,
view: consensus_engine::View,
@ -339,7 +339,7 @@ where
Some((qc, _, _)) = happy_path.next() => {
qc
}
_votes = self.gather_new_view(&leader_committee, previous_view) => {
_votes = self.gather_new_views(&leader_committee, previous_view) => {
Qc::Aggregated(AggregateQc {
high_qc: self.carnot.high_qc(),
view: self.carnot.current_view(),
@ -361,7 +361,7 @@ where
let local_timeout = tokio::time::sleep(self.timeout);
let root_timeout = self.gather_timeout().fuse();
let get_previous_block_qc = self.get_previous_block_qc().fuse();
let gather_new_view_votes = self.gather_new_view(&self.committee, self.view()).fuse();
let gather_new_view_votes = self.gather_new_views(&self.committee, self.view()).fuse();
tokio::pin!(proposal_stream);
tokio::pin!(local_timeout);