Skip to content

Commit

Permalink
[review] address review comments
Browse files Browse the repository at this point in the history
  • Loading branch information
akichidis committed Dec 20, 2023
1 parent ff1d779 commit 4763e6f
Showing 1 changed file with 2 additions and 8 deletions.
10 changes: 2 additions & 8 deletions mysticeti-core/src/syncer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,6 @@ use crate::metrics::UtilizationTimerVecExt;
use crate::runtime::timestamp_utc;
use crate::types::{AuthoritySet, RoundNumber, StatementBlock};
use crate::{block_handler::BlockHandler, metrics::Metrics};
use itertools::Itertools;
use std::sync::Arc;

pub struct Syncer<H: BlockHandler, S: SyncerSignals, C: CommitObserver> {
Expand Down Expand Up @@ -51,13 +50,8 @@ impl<H: BlockHandler, S: SyncerSignals, C: CommitObserver> Syncer<H, S, C> {
.metrics
.utilization_timer
.utilization_timer("Syncer::add_blocks");
for block in blocks
.into_iter()
.sorted_by(|b1, b2| b1.round().cmp(&b2.round()))
{
self.core.add_blocks(vec![block]);
self.try_new_block(connected_authorities.clone());
}
self.core.add_blocks(blocks);
self.try_new_block(connected_authorities.clone());
}

pub fn force_new_block(
Expand Down

0 comments on commit 4763e6f

Please sign in to comment.