diff --git a/src/runtime2/scheduler.rs b/src/runtime2/scheduler.rs index 5623f2f59e5c52e89029c2adcd4533c4400b492a..70274990203972a1013b5025d7720cdd57369f05 100644 --- a/src/runtime2/scheduler.rs +++ b/src/runtime2/scheduler.rs @@ -73,7 +73,6 @@ impl Scheduler { pub fn run(&mut self) { // Setup global storage and workspaces that are reused for every // connector that we run - let scheduler_id = self.scheduler_id; let mut delta_state = RunDeltaState::new(); 'thread_loop: loop { @@ -100,12 +99,14 @@ impl Scheduler { // Check all the message that are in the shared inbox while let Some(message) = scheduled.public.inbox.take_message() { // Check for rerouting - self.debug_conn(connector_id, &format!("Handling message from {}:{}\n --- {:?}", message.sending_connector.0, message.receiving_port.index, message)); + self.debug_conn(connector_id, &format!("Handling message from conn({}) at port({})\n --- {:?}", message.sending_connector.0, message.receiving_port.index, message)); if let Some(other_connector_id) = scheduled.router.should_reroute(message.sending_connector, message.receiving_port) { + self.debug_conn(connector_id, &format!(" ... Rerouting to connector {}", other_connector_id.0)); self.runtime.send_message(other_connector_id, message); continue; } + self.debug_conn(connector_id, " ... Handling message myself"); // Check for messages that requires special action from the // scheduler. if let MessageContents::Control(content) = message.contents {