async fn start_recovery_manager(
        &mut self,
        ledger_recovery_data: LedgerRecoveryData,
        epoch_state: EpochState,
    ) {
        let epoch = epoch_state.epoch;
        let network_sender = NetworkSender::new(
            self.author,
            self.network_sender.clone(),
            self.self_sender.clone(),
            epoch_state.verifier.clone(),
        );
        self.processor = Some(RoundProcessor::Recovery(RecoveryManager::new(
            epoch_state,
            network_sender,
            self.storage.clone(),
            self.state_computer.clone(),
            ledger_recovery_data.commit_round(),
        )));
        info!(epoch = epoch, "SyncProcessor started");
    }
// Depending on what data we can extract from consensusdb, we may or may not have an
// event processor at startup. If we need to sync up with peers for blocks to construct
// a valid block store, which is required to construct an event processor, we will take
// care of the sync up here.
Depending on what data we can extract from consensusdb, we may or may not have an
event processor at startup. If we need to sync up with peers for blocks to construct
a valid block store, which is required to construct an event processor, we will take
care of the sync up here.
Depending on what data we can extract from consensusdb we may or may not have an event processor at startup . If we need to sync up with peers for blocks to construct a valid block store which is required to construct an event processor we will take care of the sync up here .
async fn start_recovery_manager(
        &mut self,
        ledger_recovery_data: LedgerRecoveryData,
        epoch_state: EpochState,
    ) {
        let epoch = epoch_state.epoch;
        let network_sender = NetworkSender::new(
            self.author,
            self.network_sender.clone(),
            self.self_sender.clone(),
            epoch_state.verifier.clone(),
        );
        self.processor = Some(RoundProcessor::Recovery(RecoveryManager::new(
            epoch_state,
            network_sender,
            self.storage.clone(),
            self.state_computer.clone(),
            ledger_recovery_data.commit_round(),
        )));
        info!(epoch = epoch, "SyncProcessor started");
    }
async fn start_recovery_manager ( & mut self , ledger_recovery_data : LedgerRecoveryData , epoch_state : EpochState , ) { let epoch = epoch_state . epoch ; let network_sender = NetworkSender :: new ( self . author , self . network_sender . clone ( ) , self . self_sender . clone ( ) , epoch_state . verifier . clone ( ) , ) ; self . processor = Some ( RoundProcessor :: Recovery ( RecoveryManager :: new ( epoch_state , network_sender , self . storage . clone ( ) , self . state_computer . clone ( ) , ledger_recovery_data . commit_round ( ) , ) ) ) ; info ! ( epoch epoch " " ) ; }
Depending on what data we can extract from consensusdb, we may or may not have an
event processor at startup.
Depending on what data we can extract from consensusdb we may or may not have an event processor at startup .
&mut self
ledger_recovery_data
LedgerRecoveryData
epoch_state
EpochState
&mut self
ledger_recovery_data
LedgerRecoveryData
epoch_state
EpochState