diff --git a/src/runtime2/connector.rs b/src/runtime2/connector.rs index 64edbdde1602c20a4130b8dd1fc6d55ca69ca186..0cd20a6adf9fa855d54512e54e2b32c76eb19717 100644 --- a/src/runtime2/connector.rs +++ b/src/runtime2/connector.rs @@ -225,6 +225,7 @@ impl ConnectorPorts { return &mut self.port_mapping(mapped_idx); } + #[inline] fn num_ports(&self) -> usize { return self.owned_ports.len(); } @@ -341,6 +342,10 @@ impl ConnectorPDL { return self.in_sync; } + pub fn insert_data_message(&mut self, message: DataMessage) { + self.inbox.insert_message(message); + } + /// Accepts a synchronous message and combines it with the locally stored /// solution(s). pub fn insert_sync_message(&mut self, message: SyncMessage, global: &GlobalStore, results: &mut RunDeltaState) {