iceoryx_doc
1.0.1
|
The SubscriberPortMultiProducer is the implementation of the SubscriberPortRouDi for a setup where subscribers can have multiple matching publishers. I.e. a n:m pub/sub deployment. The handling of CaPro messages is different for 1:m and n:m deployment. More...
#include <subscriber_port_multi_producer.hpp>
Public Types | |
using | MemberType_t = SubscriberPortData |
![]() | |
using | MemberType_t = SubscriberPortData |
![]() | |
using | MemberType_t = BasePortData |
Public Member Functions | |
SubscriberPortMultiProducer (cxx::not_null< MemberType_t *const > publisherPortDataPtr) noexcept | |
SubscriberPortMultiProducer (const SubscriberPortMultiProducer &other)=delete | |
SubscriberPortMultiProducer & | operator= (const SubscriberPortMultiProducer &)=delete |
SubscriberPortMultiProducer (SubscriberPortMultiProducer &&rhs)=default | |
SubscriberPortMultiProducer & | operator= (SubscriberPortMultiProducer &&rhs)=default |
cxx::optional< capro::CaproMessage > | tryGetCaProMessage () noexcept override |
get an optional CaPro message that changes the subscription state of the subscriber More... | |
cxx::optional< capro::CaproMessage > | dispatchCaProMessageAndGetPossibleResponse (const capro::CaproMessage &caProMessage) noexcept override |
dispatch a CaPro message to the subscriber for processing More... | |
![]() | |
SubscriberPortRouDi (cxx::not_null< MemberType_t *const > subscriberPortDataPtr) noexcept | |
SubscriberPortRouDi (const SubscriberPortRouDi &other)=delete | |
SubscriberPortRouDi & | operator= (const SubscriberPortRouDi &)=delete |
SubscriberPortRouDi (SubscriberPortRouDi &&rhs)=default | |
SubscriberPortRouDi & | operator= (SubscriberPortRouDi &&rhs)=default |
QueueFullPolicy | getQueueFullPolicy () const noexcept |
Returns behaviour in case of a full delivery queue. More... | |
void | releaseAllChunks () noexcept |
cleanup the subscriber and release all the chunks it currently holds Caution: Contract is that user process is no more running when cleanup is called | |
![]() | |
BasePort (MemberType_t *const basePortDataPtr) noexcept | |
BasePort (const BasePort &other)=delete | |
BasePort & | operator= (const BasePort &)=delete |
BasePort (BasePort &&) noexcept | |
BasePort & | operator= (BasePort &&) noexcept |
operator bool () const noexcept | |
a port can be constructed from a nullptr, additionally it also can be moved and in these cases the member methods would work on a nullptr. to circumvent this problem More... | |
capro::ServiceDescription | getCaProServiceDescription () const noexcept |
Reads Type of actual CaPro Port (publisher/subscriber...) More... | |
RuntimeName_t | getRuntimeName () const noexcept |
Gets name of the application's runtime for the active port. More... | |
UniquePortId | getUniqueID () const noexcept |
Gets Id of the active port. More... | |
NodeName_t | getNodeName () const noexcept |
returns node name for the active port More... | |
void | destroy () noexcept |
Indicate that this port can be destroyed. | |
bool | toBeDestroyed () const noexcept |
Checks whether port can be destroyed. More... | |
Additional Inherited Members | |
![]() | |
const MemberType_t * | getMembers () const noexcept |
MemberType_t * | getMembers () noexcept |
![]() | |
const MemberType_t * | getMembers () const noexcept |
MemberType_t * | getMembers () noexcept |
![]() | |
ChunkReceiver< SubscriberPortData::ChunkReceiverData_t > | m_chunkReceiver |
The SubscriberPortMultiProducer is the implementation of the SubscriberPortRouDi for a setup where subscribers can have multiple matching publishers. I.e. a n:m pub/sub deployment. The handling of CaPro messages is different for 1:m and n:m deployment.
|
overridevirtualnoexcept |
dispatch a CaPro message to the subscriber for processing
[in] | caProMessage | to process |
Implements iox::popo::SubscriberPortRouDi.
|
overridevirtualnoexcept |
get an optional CaPro message that changes the subscription state of the subscriber
Implements iox::popo::SubscriberPortRouDi.