Skip to content

Commit

Permalink
cargo fmt
Browse files Browse the repository at this point in the history
  • Loading branch information
pompon0 committed Dec 23, 2023
1 parent 0f72363 commit dbd860c
Show file tree
Hide file tree
Showing 19 changed files with 551 additions and 346 deletions.
2 changes: 1 addition & 1 deletion node/actors/bft/src/config.rs
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
//! The inner data of the consensus state machine. This is shared between the different roles.
use crate::{misc, PayloadManager};
use std::sync::Arc;
use zksync_consensus_storage as storage;
use tracing::instrument;
use zksync_consensus_roles::validator;
use zksync_consensus_storage as storage;

/// Configuration of the bft actor.
#[derive(Debug)]
Expand Down
7 changes: 4 additions & 3 deletions node/actors/bft/src/leader/state_machine.rs
Original file line number Diff line number Diff line change
Expand Up @@ -104,7 +104,7 @@ impl StateMachine {
ctx: &ctx::Ctx,
config: &Config,
mut prepare_qc: sync::watch::Receiver<Option<validator::PrepareQC>>,
pipe: &OutputPipe,
pipe: &OutputPipe,
) -> ctx::Result<()> {
let mut next_view = validator::ViewNumber(0);
loop {
Expand Down Expand Up @@ -158,7 +158,8 @@ impl StateMachine {
Some(proposal) if proposal != highest_qc.message.proposal => (proposal, None),
// The previous block was finalized, so we can propose a new block.
_ => {
let payload = cfg.payload_manager
let payload = cfg
.payload_manager
.propose(ctx, highest_qc.message.proposal.number.next())
.await?;
metrics::METRICS
Expand All @@ -173,7 +174,7 @@ impl StateMachine {
// ----------- Prepare our message and send it --------------

// Broadcast the leader prepare message to all replicas (ourselves included).
let msg = cfg
let msg = cfg
.secret_key
.sign_msg(validator::ConsensusMsg::LeaderPrepare(
validator::LeaderPrepare {
Expand Down
Loading

0 comments on commit dbd860c

Please sign in to comment.