diff --git a/src/runtime2/component/consensus.rs b/src/runtime2/component/consensus.rs index b782ef0bf1d7ee20baaa589eb2b6aceaa3e1b2c6..72e7c475fc94b9f82e2f4de4da0d1cc4cc6cafb8 100644 --- a/src/runtime2/component/consensus.rs +++ b/src/runtime2/component/consensus.rs @@ -504,7 +504,7 @@ impl Consensus { sync_header: self.create_sync_header(comp_ctx), content: SyncMessageContent::NotificationOfLeader, }; - peer.handle.send_message(sched_ctx, Message::Sync(message), true); + peer.handle.send_message(&sched_ctx.runtime, Message::Sync(message), true); } self.forward_partial_solution(sched_ctx, comp_ctx); @@ -516,7 +516,7 @@ impl Consensus { }; let peer_handle = comp_ctx.get_peer_handle(header.sending_id); let peer_info = comp_ctx.get_peer(peer_handle); - peer_info.handle.send_message(sched_ctx, Message::Sync(message), true); + peer_info.handle.send_message(&sched_ctx.runtime, Message::Sync(message), true); } // else: exactly equal } @@ -622,7 +622,7 @@ impl Consensus { sync_header: self.create_sync_header(comp_ctx), content: if is_success { SyncMessageContent::GlobalSolution } else { SyncMessageContent::GlobalFailure }, }); - handle.send_message(sched_ctx, message, true); + handle.send_message(&sched_ctx.runtime, message, true); let _should_remove = handle.decrement_users(); debug_assert!(_should_remove.is_none()); } @@ -631,7 +631,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 let mut leader_info = sched_ctx.runtime.get_component_public(self.highest_id); - leader_info.send_message(sched_ctx, message, true); + leader_info.send_message(&sched_ctx.runtime, message, true); let should_remove = leader_info.decrement_users(); if let Some(key) = should_remove { sched_ctx.runtime.destroy_component(key);