diff --git a/src/runtime2/component/component_random.rs b/src/runtime2/component/component_random.rs index dc8a63334b8e19a37604d51f35b79cd67734cf8d..07bb9bbee0bdedaaa31cd3339b942d37b71ac007 100644 --- a/src/runtime2/component/component_random.rs +++ b/src/runtime2/component/component_random.rs @@ -46,7 +46,7 @@ impl Component for ComponentRandomU32 { Message::Data(_message) => unreachable!(), Message::Sync(message) => { let decision = self.consensus.receive_sync_message(sched_ctx, comp_ctx, message); - component::default_handle_sync_decision(sched_ctx, &mut self.exec_state, decision, &mut self.consensus); + component::default_handle_sync_decision(sched_ctx, &mut self.exec_state, comp_ctx, decision, &mut self.consensus); }, Message::Control(message) => { if let Err(location_and_message) = component::default_handle_control_message( @@ -123,7 +123,7 @@ impl Component for ComponentRandomU32 { sched_ctx.log("Waiting for consensus"); self.exec_state.mode = CompMode::SyncEnd; let decision = self.consensus.notify_sync_end_success(sched_ctx, comp_ctx); - component::default_handle_sync_decision(sched_ctx, &mut self.exec_state, decision, &mut self.consensus); + component::default_handle_sync_decision(sched_ctx, &mut self.exec_state, comp_ctx, decision, &mut self.consensus); return CompScheduling::Requeue; } },