iceoryx_posh 2.0.3
|
The UntypedSubscriber class for the publish-subscribe messaging pattern in iceoryx. More...
#include <iceoryx_posh/popo/untyped_subscriber.hpp>
Additional Inherited Members | |
![]() | |
using | BaseSubscriber = BaseSubscriberType |
using | SelfType = UntypedSubscriberImpl< BaseSubscriberType > |
![]() | |
UntypedSubscriberImpl (const capro::ServiceDescription &service, const SubscriberOptions &subscriberOptions=SubscriberOptions()) | |
UntypedSubscriberImpl (const UntypedSubscriberImpl &other)=delete | |
UntypedSubscriberImpl & | operator= (const UntypedSubscriberImpl &)=delete |
UntypedSubscriberImpl (UntypedSubscriberImpl &&rhs)=delete | |
UntypedSubscriberImpl & | operator= (UntypedSubscriberImpl &&rhs)=delete |
cxx::expected< const void *, ChunkReceiveResult > | take () noexcept |
Take the chunk from the top of the receive queue. More... | |
void | release (const void *const userPayload) noexcept |
Releases the ownership of the chunk provided by the user-payload pointer. More... | |
![]() | |
uid_t | getUid () const noexcept |
uid Get the unique ID of the subscriber. More... | |
capro::ServiceDescription | getServiceDescription () const noexcept |
getServiceDescription Get the service description of the subscriber. More... | |
void | subscribe () noexcept |
subscribe Initiate subscription. More... | |
SubscribeState | getSubscriptionState () const noexcept |
getSubscriptionState Get current subscription state. More... | |
void | unsubscribe () noexcept |
unsubscribe Unsubscribes if currently subscribed, otherwise do nothing. | |
bool | hasData () const noexcept |
Check if data is available. More... | |
bool | hasMissedData () noexcept |
Check if data has been missed since the last call of this method. More... | |
void | releaseQueuedData () noexcept |
Releases any unread queued data. | |
![]() | |
using | SelfType = BaseSubscriber< port_t > |
Only usable by the WaitSet, not for public use. Invalidates the internal triggerHandle. More... | |
using | PortType = port_t |
![]() | |
BaseSubscriber (const capro::ServiceDescription &service, const SubscriberOptions &subscriberOptions) noexcept | |
BaseSubscriber (const BaseSubscriber &other)=delete | |
BaseSubscriber & | operator= (const BaseSubscriber &)=delete |
BaseSubscriber (BaseSubscriber &&rhs)=delete | |
BaseSubscriber & | operator= (BaseSubscriber &&rhs)=delete |
cxx::expected< const mepoo::ChunkHeader *, ChunkReceiveResult > | takeChunk () noexcept |
small helper method to unwrap the expected<optional<ChunkHeader*>> from the tryGetChunk method of the port | |
void | invalidateTrigger (const uint64_t trigger) noexcept |
void | enableState (iox::popo::TriggerHandle &&triggerHandle, const SubscriberState subscriberState) noexcept |
Only usable by the WaitSet, not for public use. Attaches the triggerHandle to the internal trigger. More... | |
WaitSetIsConditionSatisfiedCallback | getCallbackForIsStateConditionSatisfied (const SubscriberState subscriberState) const noexcept |
Only usable by the WaitSet, not for public use. Returns method pointer to the event corresponding hasTriggered method callback. More... | |
void | disableState (const SubscriberState subscriberState) noexcept |
Only usable by the WaitSet, not for public use. Resets the internal triggerHandle. More... | |
void | enableEvent (iox::popo::TriggerHandle &&triggerHandle, const SubscriberEvent subscriberState) noexcept |
Only usable by the WaitSet, not for public use. Attaches the triggerHandle to the internal trigger. More... | |
void | disableEvent (const SubscriberEvent subscriberEvent) noexcept |
Only usable by the WaitSet, not for public use. Resets the internal triggerHandle. More... | |
const port_t & | port () const noexcept |
const accessor of the underlying port | |
port_t & | port () noexcept |
accessor of the underlying port | |
![]() | |
port_t | m_port {nullptr} |
TriggerHandle | m_trigger |
The UntypedSubscriber class for the publish-subscribe messaging pattern in iceoryx.