legacy_streaming_source.h

Go to the documentation of this file.

 
#ifndef _ADTF_ADTF2_LEGACY_STREAMING_SOURCE_HEADER_
#define _ADTF_ADTF2_LEGACY_STREAMING_SOURCE_HEADER_
 
namespace adtf
{
namespace adtf2
{
namespace ant
{
 
class cLegacyStreamingSource:
    public adtf::streaming::cSampleStreamingSource,
    public cKernelAndClockHelper,
    public cConfigurationHelper<cLegacyStreamingSource>,
    public cLegacyStateHandler
{
    protected:
        virtual tResult Construct()
        {
            RETURN_IF_FAILED(Init(cLegacyStateHandler::StageFirst));
            return Init(cLegacyStateHandler::StageNormal);
        }
 
        virtual tResult Destruct()
        {
            RETURN_IF_FAILED(Shutdown(cLegacyStateHandler::StageNormal));
            return Shutdown(cLegacyStateHandler::StageFirst);
        }
 
        virtual tResult Init()
        {
            return Init(cLegacyStateHandler::StageGraphReady);
        }
 
        virtual tResult Shutdown()
        {
            return Shutdown(cLegacyStateHandler::StageGraphReady);
        }
 
        virtual tResult StartStreaming()
        {
            return Start();
        }
 
        virtual tResult StopStreaming()
        {
            return Stop();
        }
 
    protected:
        // these methods are defined here as well in order to allow easy access via
        // cLegacyStreamingSource:: prefix.
 
        tResult Init(tInitStage /* eStage */) override
        {
            RETURN_NOERROR;
        }
 
        tResult Start() override
        {
            RETURN_NOERROR;
        }
 
        tResult Stop() override
        {
            RETURN_NOERROR;
        }
 
        tResult Shutdown(tInitStage /* eStage */) override
        {
            RETURN_NOERROR;
        }
 
    protected:
        tResult RegisterPin(cLegacyOutputPin& oOutput)
        {
            adtf_util::cString strNameOfWriterAndPin;
            RETURN_IF_FAILED(oOutput.GetName(adtf_string_intf(strNameOfWriterAndPin)));
            auto pOutPin = adtf::ucom::make_object_ptr<adtf::streaming::ant::cOutPin>(strNameOfWriterAndPin);
            oOutput.ResetPin(pOutPin);
            adtf::ucom::object_ptr<adtf::streaming::IPin> pPin = pOutPin;
            oOutput.SetManualTriggerRequired(true);
            return cSampleStreamingSource::RegisterPin(pPin);
        }
 
        adtf_util::cString OIGetInstanceName()
        {
            adtf_util::cString strName;
            GetName(adtf_string_intf(strName));
            return strName;
        }
};
 
}
 
using ant::cLegacyStreamingSource;
 
}
}
 
 
#endif