diff --git a/src/runtime2/component/consensus.rs b/src/runtime2/component/consensus.rs index 05856ffc3820837f251057c98e963c98eb51ddf4..db9a1e3c366b8118a8d58e038ea8d823741002d7 100644 --- a/src/runtime2/component/consensus.rs +++ b/src/runtime2/component/consensus.rs @@ -270,6 +270,11 @@ impl Consensus { } } + #[inline] + pub(crate) fn round_number(&self) -> u32 { + return self.round_index; + } + // ------------------------------------------------------------------------- // Managing sync state // ------------------------------------------------------------------------- @@ -331,7 +336,7 @@ impl Consensus { /// we've failed and wait until all the participants have been notified of /// the error. pub(crate) fn notify_sync_end_failure(&mut self, sched_ctx: &SchedulerCtx, comp_ctx: &CompCtx) -> SyncRoundDecision { - debug_assert_eq!(self.mode, Mode::SyncBusy); + // debug_assert_eq!(self.mode, Mode::SyncBusy); self.mode = Mode::SyncAwaitingSolution; let local_solution = self.generate_local_solution(comp_ctx, true);