64 PortPool(PortPoolData& portPoolData)
noexcept;
72 cxx::vector<SubscriberPortType::MemberType_t*, MAX_SUBSCRIBERS> getSubscriberPortDataList() noexcept;
73 cxx::vector<popo::ClientPortData*, MAX_CLIENTS> getClientPortDataList() noexcept;
74 cxx::vector<popo::ServerPortData*, MAX_SERVERS> getServerPortDataList() noexcept;
75 cxx::vector<popo::InterfacePortData*, MAX_INTERFACE_NUMBER> getInterfacePortDataList() noexcept;
76 cxx::vector<runtime::NodeData*, MAX_NODE_NUMBER> getNodeDataList() noexcept;
77 cxx::vector<popo::ConditionVariableData*, MAX_NUMBER_OF_CONDITION_VARIABLES>
78 getConditionVariableDataList() noexcept;
81 addPublisherPort(const capro::ServiceDescription& serviceDescription,
82 mepoo::MemoryManager* const memoryManager,
83 const RuntimeName_t& runtimeName,
84 const popo::PublisherOptions& publisherOptions,
85 const mepoo::MemoryInfo& memoryInfo = mepoo::MemoryInfo()) noexcept;
87 cxx::expected<SubscriberPortType::MemberType_t*, PortPoolError>
88 addSubscriberPort(const capro::ServiceDescription& serviceDescription,
89 const RuntimeName_t& runtimeName,
90 const popo::SubscriberOptions& subscriberOptions,
91 const mepoo::MemoryInfo& memoryInfo = mepoo::MemoryInfo()) noexcept;
93 template <typename T, std::enable_if_t<std::is_same<T, iox::build::ManyToManyPolicy>::value>* =
nullptr>
94 iox::popo::
SubscriberPortData* constructSubscriber(const capro::ServiceDescription& serviceDescription,
95 const RuntimeName_t& runtimeName,
96 const popo::SubscriberOptions& subscriberOptions,
97 const mepoo::MemoryInfo& memoryInfo) noexcept;
99 template <typename T, std::enable_if_t<std::is_same<T, iox::build::OneToManyPolicy>::value>* =
nullptr>
100 iox::popo::
SubscriberPortData* constructSubscriber(const capro::ServiceDescription& serviceDescription,
101 const RuntimeName_t& runtimeName,
102 const popo::SubscriberOptions& subscriberOptions,
103 const mepoo::MemoryInfo& memoryInfo) noexcept;
112 cxx::expected<popo::ClientPortData*, PortPoolError>
114 mepoo::MemoryManager* const memoryManager,
115 const RuntimeName_t& runtimeName,
116 const popo::ClientOptions& clientOptions,
117 const mepoo::MemoryInfo& memoryInfo = mepoo::MemoryInfo()) noexcept;
126 cxx::expected<popo::ServerPortData*, PortPoolError>
128 mepoo::MemoryManager* const memoryManager,
129 const RuntimeName_t& runtimeName,
130 const popo::ServerOptions& serverOptions,
131 const mepoo::MemoryInfo& memoryInfo = mepoo::MemoryInfo()) noexcept;
133 cxx::expected<popo::InterfacePortData*, PortPoolError> addInterfacePort(const RuntimeName_t& runtimeName,
134 const capro::Interfaces interface) noexcept;
136 cxx::expected<runtime::NodeData*, PortPoolError> addNodeData(const RuntimeName_t& runtimeName,
137 const NodeName_t& nodeName,
138 const uint64_t nodeDeviceIdentifier) noexcept;
140 cxx::expected<popo::ConditionVariableData*, PortPoolError>
141 addConditionVariableData(const RuntimeName_t& runtimeName) noexcept;
179 PortPoolData* m_portPoolData;