diff --git a/src/runtime2/component/component.rs b/src/runtime2/component/component.rs index 94a11291b2605b9209da0974ff3a32044e0a32b0..e3bbc5105e1884f3a66e3cd2002165d27c8b10bc 100644 --- a/src/runtime2/component/component.rs +++ b/src/runtime2/component/component.rs @@ -867,6 +867,7 @@ fn prepare_send_message_with_ports( // Block the peer of the port let message = control.create_port_transfer_message(unblock_put_control_id, comp_ctx.id, peer_port_id); + println!("DEBUG: Port transfer message\nControl ID: {:?}\nMessage: {:?}", unblock_put_control_id, message); let peer_handle = comp_ctx.get_peer_handle(peer_comp_id); let peer_info = comp_ctx.get_peer(peer_handle); @@ -938,6 +939,7 @@ fn default_handle_ack( ) { // Since an `Ack` may cause another one, handle them in a loop let mut to_ack = control_id; + loop { let (action, new_to_ack) = control.handle_ack(to_ack, sched_ctx, comp_ctx); match action { @@ -962,6 +964,7 @@ fn default_handle_ack( }, AckAction::UnblockPutWithPorts => { // Send the message (containing ports) to the recipient + println!("DEBUG: Unblocking put with ports"); perform_send_message_with_ports(exec_state, sched_ctx, comp_ctx, consensus, inbox_main, inbox_backup); exec_state.mode = CompMode::Sync; exec_state.mode_port = PortId::new_invalid();