diff --git a/src/runtime2/component/component_internet.rs b/src/runtime2/component/component_internet.rs index 7e3ba9ca5512298f3a6bdbf2c7277889fb4cabec..cd80e3b817f8818688e722288db1721673a55d6c 100644 --- a/src/runtime2/component/component_internet.rs +++ b/src/runtime2/component/component_internet.rs @@ -104,7 +104,7 @@ impl Component for ComponentTcpClient { }, 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( @@ -238,7 +238,7 @@ impl Component for ComponentTcpClient { // finish the sync round let decision = self.consensus.notify_sync_end_success(sched_ctx, comp_ctx); self.exec_state.mode = CompMode::SyncEnd; - 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::Immediate; }, SyncState::Getting => { @@ -275,7 +275,7 @@ impl Component for ComponentTcpClient { SyncState::FinishSync | SyncState::FinishSyncThenQuit => { let decision = self.consensus.notify_sync_end_success(sched_ctx, comp_ctx); self.exec_state.mode = CompMode::SyncEnd; - 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; }, }