diff --git a/src/runtime2/component/component.rs b/src/runtime2/component/component.rs index 2a49e852f3e325391f077e5ea1978c0524b1fd9c..245ad152d4210f97b46e8fe5aa0d762d77df67a7 100644 --- a/src/runtime2/component/component.rs +++ b/src/runtime2/component/component.rs @@ -268,7 +268,7 @@ pub(crate) fn default_handle_busy_exit( #[inline] pub(crate) fn default_handle_exit(_exec_state: &CompExecState) -> CompScheduling { - debug_assert_eq!(exec_state.mode, CompMode::Exit); + debug_assert_eq!(_exec_state.mode, CompMode::Exit); return CompScheduling::Exit; } @@ -342,6 +342,7 @@ fn default_handle_unblock_put( if exec_state.is_blocked_on_put(port_id) { // Annotate the message that we're going to send + let port_info = comp_ctx.get_port(port_handle); // for immutable access debug_assert_eq!(port_info.kind, PortKind::Putter); let to_send = exec_state.mode_value.take(); let to_send = consensus.annotate_data_message(comp_ctx, port_info, to_send);