iox::popo::SubscriberPortData🔗

Public Types🔗

	Name
using ChunkQueueData< DefaultChunkQueueConfig, ThreadSafePolicy >	ChunkQueueData_t
using ChunkReceiverData< MAX_CHUNKS_HELD_PER_SUBSCRIBER_SIMULTANEOUSLY, ChunkQueueData_t >	ChunkReceiverData_t

Public Functions🔗

	Name
	SubscriberPortData(const capro::ServiceDescription & serviceDescription, const RuntimeName_t & runtimeName, cxx::VariantQueueTypes queueType, const SubscriberOptions & subscriberOptions, const mepoo::MemoryInfo & memoryInfo =mepoo::MemoryInfo())

Public Attributes🔗

	Name
ChunkReceiverData_t	m_chunkReceiverData
const uint64_t	m_historyRequest
std::atomic_bool	m_subscribeRequested
std::atomic< SubscribeState >	m_subscriptionState

Additional inherited members🔗

Public Functions inherited from iox::popo::BasePortData

	Name
	BasePortData() =default Constructor for base port data members.
	BasePortData(const capro::ServiceDescription & serviceDescription, const RuntimeName_t & runtimeName, const NodeName_t & nodeName) Constructor.
	BasePortData(const BasePortData & )
BasePortData &	operator=(const BasePortData & )
	BasePortData(BasePortData && )
BasePortData &	operator=(BasePortData && )
	~BasePortData() =default

Public Attributes inherited from iox::popo::BasePortData

	Name
capro::ServiceDescription	m_serviceDescription
RuntimeName_t	m_runtimeName
NodeName_t	m_nodeName
UniquePortId	m_uniqueId
std::atomic_bool	m_toBeDestroyed

Public Types Documentation🔗

using ChunkQueueData_t🔗

using iox::popo::SubscriberPortData::ChunkQueueData_t =  ChunkQueueData<DefaultChunkQueueConfig, ThreadSafePolicy>;

using ChunkReceiverData_t🔗

using iox::popo::SubscriberPortData::ChunkReceiverData_t =  ChunkReceiverData<MAX_CHUNKS_HELD_PER_SUBSCRIBER_SIMULTANEOUSLY, ChunkQueueData_t>;

Public Functions Documentation🔗

function SubscriberPortData🔗

SubscriberPortData(
    const capro::ServiceDescription & serviceDescription,
    const RuntimeName_t & runtimeName,
    cxx::VariantQueueTypes queueType,
    const SubscriberOptions & subscriberOptions,
    const mepoo::MemoryInfo & memoryInfo =mepoo::MemoryInfo()
)

Public Attributes Documentation🔗

variable m_chunkReceiverData🔗

ChunkReceiverData_t m_chunkReceiverData;

variable m_historyRequest🔗

const uint64_t m_historyRequest;

variable m_subscribeRequested🔗

std::atomic_bool m_subscribeRequested {false};

variable m_subscriptionState🔗

std::atomic< SubscribeState > m_subscriptionState {SubscribeState::NOT_SUBSCRIBED};

Updated on 31 May 2022 at 15:29:16 CEST