gistfile1.txt

./src/chained_bft/event_processor_test.rs
nodes.push(Self::new(
                playground,
                executor.clone(),
                signer.clone(),
                proposer_author,
                storage,
                initial_data,
                Arc::clone(&epoch_mgr),
            ));
./src/chained_bft/event_processor_test.rs
new(
        playground: &mut NetworkPlayground,
        executor: TaskExecutor,
        signer: ValidatorSigner,
        proposer_author: Author,
        storage: Arc<MockStorage<TestPayload>>,
        initial_data: RecoveryData<TestPayload>,
        epoch_mgr: Arc<EpochManager>,
    )
./src/chained_bft/event_processor_test.rs
EventProcessor::new(
            author,
            Arc::clone(&block_store),
            pacemaker,
            proposer_election,
            proposal_generator,
            safety_rules,
            Arc::new(MockStateComputer::new(commit_cb_sender)),
            Arc::new(MockTransactionManager::new()),
            network,
            storage.clone(),
            time_service,
            true,
            Arc::clone(&epoch_mgr),
        );
./src/chained_bft/event_processor_test.rs
Self::new(
            playground,
            executor,
            self.signer,
            self.proposer_author,
            self.storage,
            recover_data,
            self.epoch_mgr,
        )
./src/chained_bft/event_processor_test.rs
placeholder_certificate_for_block(
        vec![&static_proposer.signer, &non_proposer.signer],
        block_0_id,
        1,
        block_0.quorum_cert().certified_block_id(),
        block_0.quorum_cert().certified_block_round(),
        block_0.quorum_cert().parent_block_id(),
        block_0.quorum_cert().parent_block_round(),
    );
./src/chained_bft/event_processor_test.rs
SyncInfo::new(
                    block_0_quorum_cert,
                    QuorumCert::certificate_for_genesis(),
                    None,
                ),
                PacemakerTimeout::new(2, &non_proposer.signer, None),
                &non_proposer.signer,
            )),
    );
./src/chained_bft/test_utils/mod.rs
placeholder_certificate_for_block(
            vec![self.block_store.signer()],
            parent.id(),
            parent.round(),
            parent.quorum_cert().certified_block_id(),
            parent.quorum_cert().certified_block_round(),
            parent.quorum_cert().parent_block_id(),
            parent.quorum_cert().parent_block_round(),
        );
./src/chained_bft/test_utils/mod.rs
placeholder_certificate_for_block(
                qc_signers,
                block.parent_id(),
                new_round,
                block.quorum_cert().parent_block_id(),
                block.quorum_cert().parent_block_round(),
                block.quorum_cert().grandparent_block_id(),
                block.quorum_cert().grandparent_block_round(),
            )
./src/chained_bft/test_utils/mod.rs
Block::new_internal(
            block.get_payload().clone(),
            block.parent_id(),
            block.round(),
            block.height(),
            block.timestamp_usecs(),
            parent_qc,
            block_signer,
        );
./src/chained_bft/test_utils/mod.rs
LedgerInfo::new(
        0,
        HashValue::zero(),
        HashValue::zero(),
        HashValue::zero(),
        0,
        0,
        None,
    )
./src/chained_bft/test_utils/mod.rs
placeholder_certificate_for_block(
    signers: Vec<&ValidatorSigner>,
    certified_block_id: HashValue,
    certified_block_round: u64,
    certified_parent_block_id: HashValue,
    certified_parent_block_round: u64,
    certified_grandparent_block_id: HashValue,
    certified_grandparent_block_round: u64,
)
./src/chained_bft/test_utils/mod.rs
VoteData::vote_digest(
        certified_block_id,
        certified_block_state.state_id,
        certified_block_round,
        certified_parent_block_id,
        certified_parent_block_round,
        certified_grandparent_block_id,
        certified_grandparent_block_round,
    );
./src/chained_bft/test_utils/mod.rs
VoteData::new(
            certified_block_id,
            certified_block_state.state_id,
            certified_block_round,
            certified_parent_block_id,
            certified_parent_block_round,
            certified_grandparent_block_id,
            certified_grandparent_block_round,
        ),
        LedgerInfoWithSignatures::new(ledger_info_placeholder, signatures),
    )
./src/chained_bft/chained_bft_consensus_provider.rs
ChainedBftSMR::new(
            initial_setup.author,
            initial_setup.signer,
            proposer,
            network,
            runtime,
            config,
            storage,
            initial_data,
            epoch_mgr,
        );
./src/chained_bft/proto_test.rs
VoteData::new(
            HashValue::random(),
            ExecutedState::state_for_genesis().state_id,
            1,
            HashValue::random(),
            0,
            HashValue::random(),
            0,
        ),
        signer.author(),
        placeholder_ledger_info(),
        &signer,
    );
./src/chained_bft/block_storage/block_store_test.rs
LedgerInfo::new(
        1,
        HashValue::zero(),
        HashValue::zero(),
        HashValue::zero(),
        0,
        0,
        None,
    );
./src/chained_bft/block_storage/block_store_test.rs
LedgerInfo::new(
        1,
        HashValue::zero(),
        HashValue::zero(),
        HashValue::zero(),
        0,
        0,
        None,
    );
./src/chained_bft/block_storage/block_store_test.rs
placeholder_certificate_for_block(
        vec![block_tree.signer()],
        HashValue::zero(),
        a3.round() + 1,
        HashValue::zero(),
        a3.round(),
        HashValue::zero(),
        a3.round() - 1,
    );
./src/chained_bft/block_storage/block_store_test.rs
placeholder_certificate_for_block(
        vec![block_tree.signer()],
        a3.id(),
        a3.round(),
        a2.id(),
        a2.round(),
        a1.id(),
        a1.round(),
    );
./src/chained_bft/block_storage/block_store_test.rs
placeholder_certificate_for_block(
        vec![block_tree.signer()],
        HashValue::zero(),
        a3.round() + 3,
        HashValue::zero(),
        a3.round() + 2,
        HashValue::zero(),
        a3.round() + 1,
    );
./src/chained_bft/block_storage/block_store_test.rs
placeholder_certificate_for_block(
        vec![block_tree.signer()],
        HashValue::zero(),
        a3.round() + 2,
        HashValue::zero(),
        a3.round() + 1,
        HashValue::zero(),
        a3.round(),
    );
./src/chained_bft/block_storage/block_store.rs
LedgerInfo::new(
            0,
            HashValue::zero(),
            HashValue::zero(),
            HashValue::zero(),
            0,
            0,
            None,
        )
./src/chained_bft/block_storage/block_tree.rs
VoteData::new(
                    block_id,
                    vote_msg.executed_state_id(),
                    vote_msg.block_round(),
                    vote_msg.parent_block_id(),
                    vote_msg.parent_block_round(),
                    vote_msg.grandparent_block_id(),
                    vote_msg.grandparent_block_round(),
                ),
                li_with_sig.clone(),
            );
./src/chained_bft/chained_bft_smr_test.rs
start(
        playground: &mut NetworkPlayground,
        signer: ValidatorSigner,
        epoch_mgr: Arc<EpochManager>,
        proposer: Vec<Author>,
        smr_id: usize,
        storage: Arc<MockStorage<TestPayload>>,
        initial_data: RecoveryData<TestPayload>,
        proposer_type: ConsensusProposerType,
    )
./src/chained_bft/chained_bft_smr_test.rs
ChainedBftSMR::new(
            author,
            signer.clone(),
            proposer.clone(),
            network,
            runtime,
            config,
            storage.clone(),
            initial_data,
            Arc::clone(&epoch_mgr),
        );
./src/chained_bft/chained_bft_smr_test.rs
Self::start(
            playground,
            self.signer,
            self.epoch_mgr,
            self.proposer,
            self.smr_id + 10,
            self.storage,
            recover_data,
            self.proposer_type,
        )
./src/chained_bft/chained_bft_smr_test.rs
nodes.push(Self::start(
                playground,
                signers.remove(0),
                Arc::clone(&epoch_mgr),
                proposer.clone(),
                smr_id,
                storage,
                initial_data,
                proposer_type,
            ));
./src/chained_bft/event_processor.rs
new(
        author: Author,
        block_store: Arc<BlockStore<T>>,
        pacemaker: Pacemaker,
        proposer_election: Box<dyn ProposerElection<T> + Send + Sync>,
        proposal_generator: ProposalGenerator<T>,
        safety_rules: SafetyRules,
        state_computer: Arc<dyn StateComputer<Payload = T>>,
        txn_manager: Arc<dyn TxnManager<Payload = T>>,
        network: ConsensusNetworkImpl,
        storage: Arc<dyn PersistentStorage<T>>,
        time_service: Arc<dyn TimeService>,
        enforce_increasing_timestamps: bool,
        epoch_mgr: Arc<EpochManager>,
    )
./src/chained_bft/event_processor.rs
VoteData::new(
                proposal_id,
                executed_state_id,
                block.round(),
                vote_info.parent_block_id(),
                vote_info.parent_block_round(),
                vote_info.grandparent_block_id(),
                vote_info.grandparent_block_round(),
            ),
            self.author,
            ledger_info_placeholder,
            self.block_store.signer(),
        ))
./src/chained_bft/network_tests.rs
VoteData::new(
            HashValue::random(),
            ExecutedState::state_for_genesis().state_id,
            1,
            HashValue::random(),
            0,
            HashValue::random(),
            0,
        ),
        peers[0],
        placeholder_ledger_info(),
        &signers[0],
    );
./src/chained_bft/chained_bft_smr.rs
new(
        author: Author,
        signer: ValidatorSigner,
        proposers: Vec<Author>,
        network: ConsensusNetworkImpl,
        runtime: Runtime,
        config: ChainedBftSMRConfig,
        storage: Arc<dyn PersistentStorage<T>>,
        initial_data: RecoveryData<T>,
        epoch_mgr: Arc<EpochManager>,
    )
./src/chained_bft/chained_bft_smr.rs
EventProcessor::new(
            self.author,
            Arc::clone(&block_store),
            pacemaker,
            proposer_election,
            proposal_generator,
            safety_rules,
            state_computer,
            txn_manager,
            self.network.clone(),
            Arc::clone(&self.storage),
            time_service.clone(),
            true,
            Arc::clone(&self.epoch_mgr),
        );
./src/chained_bft/event_processor_fuzzing.rs
EventProcessor::new(
        signer.author(),
        Arc::clone(&block_store),
        pacemaker,
        proposer_election,
        proposal_generator,
        safety_rules,
        empty_state_computer,
        Arc::new(MockTransactionManager::new()),
        network,
        storage.clone(),
        time_service,
        enforce_increasing_timestamps,
        Arc::clone(&epoch_mgr),
    )
./src/chained_bft/consensus_types/block.rs
LedgerInfo::new(
                    0,
                    state_id,
                    HashValue::zero(),
                    HashValue::zero(),
                    0,
                    0,
                    None,
                ),
                HashMap::new(),
            ),
        );
./src/chained_bft/consensus_types/block.rs
new_internal(
        payload: T,
        parent_id: HashValue,
        round: Round,
        height: Height,
        timestamp_usecs: u64,
        quorum_cert: QuorumCert,
        validator_signer: &ValidatorSigner,
    )
./src/chained_bft/consensus_types/block_test.rs
Block::new_internal(
            vec![payload],
            parent_id,
            round,
            height,
            get_current_timestamp().as_micros() as u64,
            parent_qc,
            &signer,
        )
./src/chained_bft/consensus_types/block_test.rs
placeholder_certificate_for_block(
        vec![&signer],
        nil_block.id(),
        nil_block.round(),
        nil_block.quorum_cert().certified_block_id(),
        nil_block.quorum_cert().certified_block_round(),
        nil_block.quorum_cert().parent_block_id(),
        nil_block.quorum_cert().parent_block_round(),
    );
./src/chained_bft/consensus_types/block_test.rs
placeholder_certificate_for_block(
        vec![&signer],
        a1.id(),
        a1.round(),
        a1.quorum_cert().certified_block_id(),
        a1.quorum_cert().certified_block_round(),
        a1.quorum_cert().parent_block_id(),
        a1.quorum_cert().parent_block_round(),
    );
./src/chained_bft/consensus_types/vote_data.rs
new(
        block_id: HashValue,
        executed_state_id: HashValue,
        round: Round,
        parent_block_id: HashValue,
        parent_block_round: Round,
        grandparent_block_id: HashValue,
        grandparent_block_round: Round,
    )
./src/chained_bft/consensus_types/vote_data.rs
Self::vote_digest(
            self.block_id,
            self.executed_state_id,
            self.round,
            self.parent_block_id,
            self.parent_block_round,
            self.grandparent_block_id,
            self.grandparent_block_round,
        )
./src/chained_bft/consensus_types/vote_data.rs
vote_digest(
        block_id: HashValue,
        executed_state_id: HashValue,
        round: Round,
        parent_block_id: HashValue,
        parent_block_round: Round,
        grandparent_block_id: HashValue,
        grandparent_block_round: Round,
    )
./src/chained_bft/consensus_types/quorum_cert.rs
VoteData::vote_digest(
            *GENESIS_BLOCK_ID,
            *ACCUMULATOR_PLACEHOLDER_HASH,
            0,
            *GENESIS_BLOCK_ID,
            0,
            *GENESIS_BLOCK_ID,
            0,
        );
./src/chained_bft/consensus_types/quorum_cert.rs
LedgerInfo::new(
            0,
            *ACCUMULATOR_PLACEHOLDER_HASH,
            genesis_digest,
            *GENESIS_BLOCK_ID,
            0,
            0,
            None,
        );
./src/chained_bft/consensus_types/quorum_cert.rs
VoteData::new(
                *GENESIS_BLOCK_ID,
                *ACCUMULATOR_PLACEHOLDER_HASH,
                0,
                *GENESIS_BLOCK_ID,
                0,
                *GENESIS_BLOCK_ID,
                0,
            ),
            LedgerInfoWithSignatures::new(li, signatures),
        )