diff --git a/src/runtime2/component/component_pdl.rs b/src/runtime2/component/component_pdl.rs index b9ea01cc12e8b5278cdd85698c98e7ff25dae917..72e1a7dd27cf4167fa96d46a68a74763d6e6d111 100644 --- a/src/runtime2/component/component_pdl.rs +++ b/src/runtime2/component/component_pdl.rs @@ -241,15 +241,17 @@ impl Component for CompPDL { } fn handle_message(&mut self, sched_ctx: &mut SchedulerCtx, comp_ctx: &mut CompCtx, mut message: Message) { - // sched_ctx.log(&format!("handling message: {:?}", message)); + sched_ctx.debug(&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 + sched_ctx.debug(&format!("rerouting to: {:?}", new_target)); 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; } + sched_ctx.debug("handling message myself"); match message { Message::Data(message) => { self.handle_incoming_data_message(sched_ctx, comp_ctx, message);