diff --git a/src/runtime2/connector.rs b/src/runtime2/connector.rs index f4b4e6bce2b76eda2f3da9ed9c8c1b3ef09b2666..0407db8aa68a774673bd42935987886773a78196 100644 --- a/src/runtime2/connector.rs +++ b/src/runtime2/connector.rs @@ -193,7 +193,9 @@ impl ConnectorPDL { match message { Message::Data(message) => self.handle_new_data_message(message, ctx), Message::SyncComp(message) => { - return self.handle_new_sync_comp_message(message, ctx) + if let Some(result) = self.handle_new_sync_comp_message(message, ctx) { + return Some(result); + } }, Message::SyncPort(message) => self.handle_new_sync_port_message(message, ctx), Message::Control(_) => unreachable!("control message in component"), @@ -221,7 +223,6 @@ impl ConnectorPDL { // This branch can receive, so fork and given it the message let receiving_branch_id = self.tree.fork_branch(branch_id); - println!("DEBUG: ### Branching due to new data message"); self.consensus.notify_of_new_branch(branch_id, receiving_branch_id); let receiving_branch = &mut self.tree[receiving_branch_id]; @@ -327,7 +328,6 @@ impl ConnectorPDL { branch.awaiting_port = PortIdLocal::new_invalid(); branch.prepared = PreparedStatement::PerformedGet(message.content.as_message().unwrap().clone()); - println!("DEBUG: ### Branching due to BlockGet with existing message"); self.consensus.notify_of_new_branch(branch_id, receiving_branch_id); self.consensus.notify_of_received_message(receiving_branch_id, &message, comp_ctx); self.tree.push_into_queue(QueueKind::Runnable, receiving_branch_id); @@ -418,7 +418,6 @@ impl ConnectorPDL { match run_result { EvalContinuation::ComponentTerminated => { branch.sync_state = SpeculativeState::Finished; - println!("DEBUG: ************ DOING THEM EXITS"); return ConnectorScheduling::Exit; }, EvalContinuation::SyncBlockStart => {