diff --git a/src/runtime2/native.rs b/src/runtime2/native.rs index b0de3c54ae700703f8812d335c2397c0075f3269..04285976db5961cf363f5ff5ca65a4907151da43 100644 --- a/src/runtime2/native.rs +++ b/src/runtime2/native.rs @@ -80,7 +80,7 @@ pub struct ApplicationInterface { job_queue: JobQueue, runtime: Arc, connector_id: ConnectorId, - owned_ports: Vec, + owned_ports: Vec, } impl ApplicationInterface { @@ -99,15 +99,21 @@ impl ApplicationInterface { let putter_id = PortIdLocal::new(getter_id + 1); let getter_id = PortIdLocal::new(getter_id); - self.ports.push(Port{ + self.owned_ports.push(Port{ self_id: getter_id, peer_id: putter_id, kind: PortKind::Getter, - owning_connector: self.connector_id, peer_connector: self.connector_id, }); - return channel; + self.owned_ports.push(Port{ + self_id: putter_id, + peer_id: getter_id, + kind: PortKind::Putter, + peer_connector: self.connector_id, + }); + + return Channel{ putter_id, getter_id }; } /// Creates a new connector. Note that it is not scheduled immediately, but