diff --git a/src/runtime2/component/component_pdl.rs b/src/runtime2/component/component_pdl.rs index cc1b91b1a9023cc110ec827b2ad7e1022b3027c1..092b5d9e444392d7cb5a700e5143f1979e258a6b 100644 --- a/src/runtime2/component/component_pdl.rs +++ b/src/runtime2/component/component_pdl.rs @@ -347,7 +347,7 @@ impl Component for CompPDL { self.handle_component_error(sched_ctx, CompError::Executor(EvalError::new_error_at_expr( &self.prompt, &protocol.modules, &protocol.heap, expr_id, String::from("Cannot get from this port, as this causes a deadlock. This happens if you `get` in a different order as another component `put`s") - )); + ))); return CompScheduling::Sleep; } } else if port_is_closed { @@ -601,7 +601,7 @@ impl CompPDL { fn handle_incoming_sync_message(&mut self, sched_ctx: &SchedulerCtx, comp_ctx: &mut CompCtx, message: SyncMessage) { 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); } /// Handles an error coming from the generic `component::handle_xxx`