Method start

node/src/engine.rs:371–403

Start the `simplex` consensus engine. This will also rebuild the state of the engine from provided `Journal`.

(
        self,
        pending_network: (
            impl Sender<PublicKey = S::PublicKey>,
            impl Receiver<PublicKey = S::PublicKey>,
        ),
        recovered_network: (
            i

            view: initial_state.get_view(),
        };
        let num_validators = initial_state.num_validators();

        info!(
            sync_height = sync_start.height,
            sync_epoch = sync_start.epoch,
            sync_view = sync_start.view,
            num_validators,
            blocks_per_epoch,
            "engine initialized"
        );

        let checkpoint = cfg.checkpoint_last_block.map(|last_block| SyncCheckpoint {
            last_block,
            finalized_header: cfg.checkpoint_finalized_header,
        });

        Self {
            context,
            application,
            buffer,
            buffer_mailbox,
            syncer,
            syncer_mailbox,
            finalizer,
            finalizer_mailbox,
            finalizer_state_query,
            orchestrator,
            orchestrator_mailbox,
            oracle: cfg.oracle,
            node_public_key,
            mailbox_size: cfg.mailbox_size,
            fetch_timeout: cfg.fetch_timeout,
            sync_start,
            checkpoint,
            cancellation_token,
            #[cfg(feature = "permissioned")]