Skip to content

iox::popo::ChunkQueueData🔗

More...

Inherits from LockingPolicy

Inherited by iox::popo::ChunkReceiverData< MAX_REQUESTS_PROCESSED_SIMULTANEOUSLY, ServerChunkQueueData_t >, iox::popo::ChunkReceiverData< MAX_RESPONSES_PROCESSED_SIMULTANEOUSLY, ClientChunkQueueData_t >

Public Types🔗

Name
using ChunkQueueData< ChunkQueueDataProperties, LockingPolicy > ThisType_t
using std::lock_guard< const ThisType_t > LockGuard_t
using ChunkQueueDataProperties ChunkQueueDataProperties_t

Public Functions🔗

Name
ChunkQueueData(const QueueFullPolicy policy, const cxx::VariantQueueTypes queueType)

Public Attributes🔗

Name
constexpr uint64_t MAX_CAPACITY
cxx::VariantQueue< mepoo::ShmSafeUnmanagedChunk, MAX_CAPACITY > m_queue
std::atomic_bool m_queueHasLostChunks
rp::RelativePointer< ConditionVariableData > m_conditionVariableDataPtr
cxx::optional< uint64_t > m_conditionVariableNotificationIndex
const QueueFullPolicy m_queueFullPolicy

Detailed Description🔗

template <typename ChunkQueueDataProperties ,
typename LockingPolicy >
struct iox::popo::ChunkQueueData;

Public Types Documentation🔗

using ThisType_t🔗

using iox::popo::ChunkQueueData< ChunkQueueDataProperties, LockingPolicy >::ThisType_t =  ChunkQueueData<ChunkQueueDataProperties, LockingPolicy>;

using LockGuard_t🔗

using iox::popo::ChunkQueueData< ChunkQueueDataProperties, LockingPolicy >::LockGuard_t =  std::lock_guard<const ThisType_t>;

using ChunkQueueDataProperties_t🔗

using iox::popo::ChunkQueueData< ChunkQueueDataProperties, LockingPolicy >::ChunkQueueDataProperties_t =  ChunkQueueDataProperties;

Public Functions Documentation🔗

function ChunkQueueData🔗

inline ChunkQueueData(
    const QueueFullPolicy policy,
    const cxx::VariantQueueTypes queueType
)

Public Attributes Documentation🔗

variable MAX_CAPACITY🔗

static constexpr uint64_t MAX_CAPACITY = ChunkQueueDataProperties_t::MAX_QUEUE_CAPACITY;

variable m_queue🔗

cxx::VariantQueue< mepoo::ShmSafeUnmanagedChunk, MAX_CAPACITY > m_queue;

variable m_queueHasLostChunks🔗

std::atomic_bool m_queueHasLostChunks {false};

variable m_conditionVariableDataPtr🔗

rp::RelativePointer< ConditionVariableData > m_conditionVariableDataPtr;

variable m_conditionVariableNotificationIndex🔗

cxx::optional< uint64_t > m_conditionVariableNotificationIndex;

variable m_queueFullPolicy🔗

const QueueFullPolicy m_queueFullPolicy;

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