Skip to content

iox::popo::PublisherPortData🔗

Inherits from iox::popo::BasePortData

Public Types🔗

Name
using SubscriberPortData::ChunkQueueData_t ChunkQueueData_t
using ChunkDistributorData< DefaultChunkDistributorConfig, ThreadSafePolicy, ChunkQueuePusher< ChunkQueueData_t > > ChunkDistributorData_t
using ChunkSenderData< MAX_CHUNKS_ALLOCATED_PER_PUBLISHER_SIMULTANEOUSLY, ChunkDistributorData_t > ChunkSenderData_t

Public Functions🔗

Name
PublisherPortData(const capro::ServiceDescription & serviceDescription, const RuntimeName_t & runtimeName, mepoo::MemoryManager *const memoryManager, const PublisherOptions & publisherOptions, const mepoo::MemoryInfo & memoryInfo =mepoo::MemoryInfo())

Public Attributes🔗

Name
ChunkSenderData_t m_chunkSenderData
std::atomic_bool m_offeringRequested
std::atomic_bool m_offered

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::PublisherPortData::ChunkQueueData_t =  SubscriberPortData::ChunkQueueData_t;

using ChunkDistributorData_t🔗

using iox::popo::PublisherPortData::ChunkDistributorData_t =  ChunkDistributorData<DefaultChunkDistributorConfig, ThreadSafePolicy, ChunkQueuePusher<ChunkQueueData_t> >;

using ChunkSenderData_t🔗

using iox::popo::PublisherPortData::ChunkSenderData_t =  ChunkSenderData<MAX_CHUNKS_ALLOCATED_PER_PUBLISHER_SIMULTANEOUSLY, ChunkDistributorData_t>;

Public Functions Documentation🔗

function PublisherPortData🔗

PublisherPortData(
    const capro::ServiceDescription & serviceDescription,
    const RuntimeName_t & runtimeName,
    mepoo::MemoryManager *const memoryManager,
    const PublisherOptions & publisherOptions,
    const mepoo::MemoryInfo & memoryInfo =mepoo::MemoryInfo()
)

Public Attributes Documentation🔗

variable m_chunkSenderData🔗

ChunkSenderData_t m_chunkSenderData;

variable m_offeringRequested🔗

std::atomic_bool m_offeringRequested {false};

variable m_offered🔗

std::atomic_bool m_offered {false};

Updated on 17 June 2021 at 11:15:27 CEST