ADTF
|
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< cStreamItem > | m_oItems |
cStreamItem | m_oLastType |
size_t | m_nSampleCount = 0 |
Definition at line 640 of file samplereader.h.
|
inlinevirtual |
Returns the next sample from the queue.
[out] | oStreamItem | stream 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.
|
inlineoverridevirtual |
Push a new value to the internal sample queue.
[in] | oStreamItem | The sample to store |
[in] | tmTime | Time of storage |
Implements ISampleReaderQueue.
Definition at line 650 of file samplereader.h.
References IStreamItem::GetType(), RETURN_NOERROR, and IStreamItem::Sample.