cDynamicSampleReaderQueue

Implementation of a adtf::streaming::ant::ISampleReaderQueue with dynamic growing sample queue. More...

Inheritance diagram for cDynamicSampleReaderQueue:

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 &oStreamItem) override
	Returns the next sample from the queue. More...

Private Types
typedef adtf_util::lock_free_queue< cStreamItem >	base_type
	base type of cDynamicSampleReaderQueue

Detailed Description

Implementation of a adtf::streaming::ant::ISampleReaderQueue with dynamic growing sample queue.

Definition at line 604 of file samplereader.h.

Member Function Documentation

Pop()

tResult Pop ( IStreamItem &  oStreamItem )

inlineoverridevirtual

Returns the next sample from the queue.

Parameters

[out]

oStreamItem

stream item reference to copy the references to

Implements ISampleReaderQueue.

Definition at line 623 of file samplereader.h.

References cStreamItem::CopyTo(), and RETURN_IF_FAILED.

Push()

tResult Push ( const IStreamItem &  oStreamItem, tTimeStamp  tmTime  )

inlineoverridevirtual

Push a new value to the internal sample queue.

Parameters

[in]	oStreamItem	The sample to store
[in]	tmTime	Time of storage

Implements ISampleReaderQueue.

Definition at line 612 of file samplereader.h.