diff --git a/src/runtime2/component/consensus.rs b/src/runtime2/component/consensus.rs index f9f3ab3f1df69fe514ced318d8eb388adec96ea9..881a7f6fc3400aded9a2d379dc1f08f2f2212613 100644 --- a/src/runtime2/component/consensus.rs +++ b/src/runtime2/component/consensus.rs @@ -632,7 +632,7 @@ impl Consensus { } fn send_to_leader(&mut self, sched_ctx: &SchedulerCtx, comp_ctx: &CompCtx, message: Message) { - debug_assert_ne!(self.highest_id, comp_ctx.id); // we're not the leader + debug_assert_ne!(self.highest_id, comp_ctx.id); // we're not the leader, // TODO: @NoDirectHandle let mut leader_info = sched_ctx.runtime.get_component_public(self.highest_id); leader_info.send_message(&sched_ctx.runtime, message, true); let should_remove = leader_info.decrement_users();