diff --git a/src/runtime2/component/component_ip.rs b/src/runtime2/component/component_ip.rs index 7848835ed25cb158db34797fed309145e0ec0141..459110cf79312dbd28e6873288e07476d2bd83fc 100644 --- a/src/runtime2/component/component_ip.rs +++ b/src/runtime2/component/component_ip.rs @@ -45,7 +45,8 @@ impl Component for ComponentRandomU32 { &mut self.exec_state, &mut self.control, &mut self.consensus, message, sched_ctx, comp_ctx ); - } + }, + Message::Poll => unreachable!(), } } @@ -101,7 +102,7 @@ impl Component for ComponentRandomU32 { let message = self.consensus.annotate_data_message(comp_ctx, port_info, value_group); let peer_handle = comp_ctx.get_peer_handle(port_info.peer_comp_id); let peer_info = comp_ctx.get_peer(peer_handle); - peer_info.handle.send_message(sched_ctx, Message::Data(message), true); + peer_info.handle.send_message(&sched_ctx.runtime, Message::Data(message), true); // Remain in sync mode, but after `did_perform_send` was // set to true.