diff --git a/src/runtime2/component/component_context.rs b/src/runtime2/component/component_context.rs index b2c3435d5606f217b687597005aec6e3b4e3a262..3a72bdffe37e35420b89c72d12824a8a517d5ea1 100644 --- a/src/runtime2/component/component_context.rs +++ b/src/runtime2/component/component_context.rs @@ -29,6 +29,7 @@ pub enum PortStateFlag { Closed = 0x01, // If not closed, then the port is open BlockedDueToPeerChange = 0x02, // busy changing peers, hence use of port is temporarily blocked BlockedDueToFullBuffers = 0x04, + Transmitted, // Transmitted, so cannot be used anymore } #[derive(Copy, Clone)] @@ -307,11 +308,6 @@ impl CompCtx { // Local utilities // ------------------------------------------------------------------------- - #[inline] - fn requires_peer_reference(port: &Port, self_id: CompId, required_if_closed: bool) -> bool { - return (!port.state.is_closed() || required_if_closed) && port.peer_comp_id != self_id; - } - fn must_get_port_index(&self, handle: LocalPortHandle) -> usize { for (index, port) in self.ports.iter().enumerate() { if port.self_id == handle.0 {