sample_streaming_sink.h

Go to the documentation of this file.

#pragma once
#include <adtfstreaming3/streaming_sink_intf.h>
#include <adtfstreaming3/streaming_source.h>
#include "graph_object.h"
 
#include <memory>
 
namespace adtf
{
namespace filter
{

class cSampleStreamingSink:
        public ucom::catwo::object<streaming::ant::INamedGraphObject,
                                   streaming::ant::IDataBinding,
                                   streaming::ant::IInterfaceBinding,
                                   streaming::ant::IRuntimeBehaviour,
                                   streaming::ant::IDynamicDataBinding,
                                   streaming::ant::IDynamicInterfaceBinding,
                                   streaming::ant::IStreamingService,
                                   streaming::ant::IStreamingSink,
                                   streaming::ant::ISampleStreamingSink,
                                   base::ant::IConfiguration>,
        public cGraphObject,
        protected streaming::ant::streaming_level_machine
{
    public:
        // this needs to be here because unfortunately multiple base classes have this as well (altough it is not needed at all)
        template <typename T>
        using iobject_ptr = adtf::ucom::ant::iobject_ptr<T>;
 
        cSampleStreamingSink();
        ~cSampleStreamingSink() override;

        tResult Init() override;

        tResult StartStreaming() override;

        tResult StopStreaming() override;
 
        tResult SetName(const char* strName) override;
        tResult GetName(base::ant::IString&& strName) const override;
        tResult SetParent(const ucom::ant::IObject* poParentObject) override;
        tResult GetParent(const ucom::ant::IObject*& poParentObject) const override;
 
        tResult GetPins(ucom::ant::iobject_list<streaming::ant::IPin>& oPins) const override;
        tResult FindPin(const char* strName, ucom::ant::iobject_ptr<ucom::ant::IObject>& pPin) const override;
 
        tResult GetBindingObjects(ucom::ant::iobject_list<streaming::ant::IBindingObject>& lstBindingObject) override;
        tResult GetBindingObjects(ucom::ant::iobject_list<const streaming::ant::IBindingObject>& lstBindingObject) const override;
        tResult FindBindingObject(const char* strName,
            ucom::ant::iobject_ptr<const ucom::ant::IObject>& pIBindingObject) const override;
        tResult FindBindingObject(const char* strName,
            ucom::ant::iobject_ptr<ucom::ant::IObject>& pIBindingObject) override;
 
        tResult GetRunners(ucom::ant::iobject_list<streaming::ant::IRunner>& lstRunners) const override;
        tResult FindRunner(const char* strName, ucom::ant::iobject_ptr<ucom::ant::IObject>& pRunner) const override;
        tResult GetInnerPipes(ucom::ant::iobject_list<streaming::ant::ITriggerPipe>& lstInnerTriggerPipes) const override;
 
        tResult RequestPin(const char* strName,
                           const ucom::ant::iobject_ptr<const streaming::ant::IStreamType>& pType,
                           ucom::ant::iobject_ptr<streaming::ant::IInPin>& pInPin) override;
        tResult RequestPin(const char* strName,
                           const ucom::ant::iobject_ptr<const streaming::ant::IStreamType>& pType,
                           ucom::ant::iobject_ptr<streaming::ant::IOutPin>& pOutPin) override;
 
        tResult RequestBindingObject(const char* strName,
                                     const ucom::ant::iobject_ptr<const streaming::ant::IBindingType>& pType,
                                     ucom::ant::iobject_ptr<streaming::ant::IBindingClient>& pBindingClient) override;
        tResult RequestBindingObject(const char* strName,
                                     const ucom::ant::iobject_ptr<const streaming::ant::IBindingType>& pType,
                                     ucom::ant::iobject_ptr<streaming::ant::IBindingServer>& pBindingServer) override;
 
        tResult SetState(tStreamingState eFilterState) override;
        tStreamingState GetState() override;
 
        tResult GetProperties(ucom::ant::iobject_ptr<const base::ant::IProperties>& pProperties) const override;
        tResult GetProperties(ucom::ant::iobject_ptr<base::ant::IProperties>& pProperties) override;
        tResult AttachConfiguration(const char* strName, base::ant::IConfiguration& oAttachedConfiguration) override;
        tResult DetachConfiguration(const char* strName) override;
 
    private:
        class cImplementation;
        std::unique_ptr<cImplementation> m_pImplementation;
};
 
}
}