cSubStreamTypes

Helper class to create a stream type with multiple Substreams. More...

Inheritance diagram for cSubStreamTypes:

Public Member Functions
void	SetSubStream (const char *strName, uint32_t nSubStreamId, const flash::cStreamTypeHelper &oType)
	Adds or updates a Substream. More...
Public Member Functions inherited from cSubStreamTypes
template<typename MetaType = stream_meta_type_substreams, typename = std::enable_if_t<is_stream_meta_type<MetaType>::value, MetaType>>
	cSubStreamTypes (const MetaType &=MetaType())
	Constructor. More...
	cSubStreamTypes (const ucom::ant::iobject_ptr< const ant::IStreamMetaType > &pMetaType)
	Constructor. More...
virtual	~cSubStreamTypes ()
	Destructor.
void	SetSubStream (const char *strName, uint32_t nSubStreamId, const ucom::ant::iobject_ptr< const ant::IStreamType > &pType)
	Adds or updates a Substream. More...
void	SetRequestProperties (const base::ant::IProperties &oProperties, const char *strSubStreamName="")
	Sets the common or Substream specific request properties. More...
ucom::ant::object_ptr< const streaming::ant::IStreamType >	GetSubStreamType (const char *strName) const
	Retrieve the Stream Type of a given Substream. More...
ucom::ant::object_ptr< ant::IStreamType >	GetStreamType () const
	Get a Stream Type that contains all currently set Substreams. More...

Additional Inherited Members
Protected Attributes inherited from cSubStreamTypes
std::unique_ptr< cImplementation >	m_pImplementation

Detailed Description

Helper class to create a stream type with multiple Substreams.

Example Usage

#include <adtffiltersdk/adtf_filtersdk.h>
#include <set>
 
class cMyFilter: public adtf::filter::cFilter
{
    public:
        ADTF_CLASS_ID_NAME(cMyFilter, "my_filter.filter.example.cid", "My Filter");
 
        cMyFilter()
        {
            CreateRunner("generate_samples");
 
            adtf::filter::cSubStreamTypes oSubStreams;
            oSubStreams.SetSubStream("stream1", 0, adtf::streaming::stream_type_plain<uint32_t>());
            oSubStreams.SetSubStream("stream2", 1, adtf::streaming::stream_type_plain<uint32_t>());
            oSubStreams.SetSubStream("stream3", 2, adtf::streaming::stream_type_plain<uint32_t>());
 
            m_pWriter = CreateRequestableOutputPin("output", oSubStreams);
        }       
 
        tResult EnableSubStream(adtf::streaming::ISampleWriter* /*pWriter*/,
                                uint32_t nSubStreamId,
                                const adtf::base::IProperties* /*pRequestProperties*/) override
        {
            if (nSubStreamId > 2)
            {
                RETURN_ERROR_DESC(ERR_INVALID_ARG, "No Substream with id %d available", nSubStreamId);
            }
 
            m_oEnabledSubStreams.insert(nSubStreamId);
            RETURN_NOERROR;
        }
 
        void DisableSubStream(adtf::streaming::ISampleWriter* /*pWriter*/, uint32_t nSubStreamId) override
        {
            m_oEnabledSubStreams.erase(nSubStreamId);
        }
 
        tResult Process(adtf::base::tNanoSeconds tmTrigger, adtf::streaming::IRunner* /*pRunner*/) override
        {
            ++m_nTriggerCounter;
 
            for (const auto& nSubStreamId: m_oEnabledSubStreams)
            {
                adtf::streaming::output_sample_data<uint32_t> oNewData(tmTrigger, m_nTriggerCounter, nSubStreamId);
                m_pWriter->Write(oNewData.Release());
            }
 
            RETURN_NOERROR;
        }
 
    private:
        adtf::streaming::ISampleWriter* m_pWriter = nullptr;
        std::set<uint32_t> m_oEnabledSubStreams;
        uint32_t m_nTriggerCounter = 0;
};

Definition at line 150 of file stream_type_helper.h.

Member Function Documentation

SetSubStream()

void SetSubStream	(	const char *	strName,
		uint32_t	nSubStreamId,
		const flash::cStreamTypeHelper &	oType
	)

Adds or updates a Substream.

Parameters

[in]	strName	The name of the Substream, required to be unique, this is the key to the map of substreams.
[in]	nSubStreamId	The id of the Substream, should be unique, but can be reused for aliases etc.
[in]	oType	The type of the substream.