ADTF  3.18.2
cLimitedSampleReaderQueueabstract
Inheritance diagram for cLimitedSampleReaderQueue:
[legend]

Public Member Functions

tResult Push (const IStreamItem &oStreamItem, tTimeStamp) override
 Push a new value to the internal sample queue. More...
 
void Clear () override
 clears the local queue of the reader either only EndStreaming or incoming event ISampleInStream::IQueueItem::RE_Flush
 
tResult Pop (IStreamItem &oItem)
 Returns the next sample from the queue. More...
 

Protected Member Functions

virtual void CheckQueue (const std::deque< cStreamItem > &oItems)=0
 
void PopFront ()
 
size_t GetSampleCount ()
 

Private Attributes

std::mutex m_oQueueMutex
 
std::deque< cStreamItemm_oItems
 
cStreamItem m_oLastType
 
size_t m_nSampleCount = 0
 

Detailed Description

Definition at line 640 of file samplereader.h.

Member Function Documentation

◆ Pop()

tResult Pop ( IStreamItem oStreamItem)
inlinevirtual

Returns the next sample from the queue.

Parameters
[out]oStreamItemstream item reference to copy the references to

Implements ISampleReaderQueue.

Definition at line 670 of file samplereader.h.

References cStreamItem::CopyTo(), cStreamItem::GetType(), RETURN_ERROR, RETURN_IF_FAILED, RETURN_NOERROR, IStreamItem::Sample, and IStreamItem::StreamType.

◆ Push()

tResult Push ( const IStreamItem oStreamItem,
tTimeStamp  tmTime 
)
inlineoverridevirtual

Push a new value to the internal sample queue.

Parameters
[in]oStreamItemThe sample to store
[in]tmTimeTime of storage

Implements ISampleReaderQueue.

Definition at line 650 of file samplereader.h.

References IStreamItem::GetType(), RETURN_NOERROR, and IStreamItem::Sample.