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

        )
        .await;

        // create the buffer
        let (buffer, buffer_mailbox) = buffered::Engine::new(
            context.child("buffer"),
            buffered::Config {
                public_key: node_public_key.clone(),
                mailbox_size: cfg.mailbox_size,
                deque_size: cfg.deque_size,
                priority: true,
                codec_config: (),
                peer_provider: cfg.oracle.clone(),
            },
        );

        let syncer_config = summit_syncer::Config {
            scheme_provider: scheme_provider.clone(),
            epocher: epocher.clone(),
            partition_prefix: cfg.partition_prefix.clone(),
            mailbox_size: cfg.mailbox_size,
            view_retention_timeout: ViewDelta::new(cfg.activity_timeout),
            namespace: consensus_domain.clone(),
            prunable_items_per_section: PRUNABLE_ITEMS_PER_SECTION,
            page_cache: page_cache.clone(),
            replay_buffer: REPLAY_BUFFER,
            key_write_buffer: WRITE_BUFFER,
            value_write_buffer: WRITE_BUFFER,
            block_codec_config: (),
            max_repair: MAX_REPAIR,
            max_pending_acks: MAX_REPAIR,
            strategy: Sequential,
        };

        let (syncer, syncer_mailbox) = summit_syncer::Actor::init(
            context.child("syncer"),
            finalizations_by_height,
            finalized_blocks,