diff --git a/src/runtime2/component/component_pdl.rs b/src/runtime2/component/component_pdl.rs index 123fb16ec9f429712a6b766f9f0c5364fb7a09a4..c125b9dbe01c19ce69428411d420711a9c634d0d 100644 --- a/src/runtime2/component/component_pdl.rs +++ b/src/runtime2/component/component_pdl.rs @@ -244,7 +244,7 @@ impl Component for CompPDL { // sched_ctx.log(&format!("handling message: {:?}", message)); if let Some(new_target) = self.control.should_reroute(&mut message) { let mut target = sched_ctx.runtime.get_component_public(new_target); // TODO: @NoDirectHandle - target.send_message(&sched_ctx.runtime, message, false); // not waking up: we schedule once we've received all PortPeerChanged Acks + target.send_message_logged(sched_ctx, message, false); // not waking up: we schedule once we've received all PortPeerChanged Acks let _should_remove = target.decrement_users(); debug_assert!(_should_remove.is_none()); return; @@ -274,7 +274,7 @@ impl Component for CompPDL { fn run(&mut self, sched_ctx: &mut SchedulerCtx, comp_ctx: &mut CompCtx) -> CompScheduling { use EvalContinuation as EC; - sched_ctx.log(&format!("Running component (mode: {:?})", self.exec_state.mode)); + sched_ctx.info(&format!("Running component (mode: {:?})", self.exec_state.mode)); // Depending on the mode don't do anything at all, take some special // actions, or fall through and run the PDL code. @@ -335,7 +335,7 @@ impl Component for CompPDL { }, EC::Put(expr_id, port_id, value) => { debug_assert_eq!(self.exec_state.mode, CompMode::Sync); - sched_ctx.log(&format!("Putting value {:?}", value)); + sched_ctx.info(&format!("Putting value {:?}", value)); // Send the message let target_port_id = port_id_from_eval(port_id); @@ -764,7 +764,7 @@ impl CompPDL { ); let peer_handle = created_ctx.get_peer_handle(port_info.peer_comp_id); let peer_info = created_ctx.get_peer(peer_handle); - peer_info.handle.send_message(&sched_ctx.runtime, message, true); + peer_info.handle.send_message_logged(sched_ctx, message, true); } } } else {