samplestreaminport.h

Go to the documentation of this file.

 
#pragma once
 
#include "samplestream.h"
#include "streaming_graph_intf.h"
#include "samplestreamport_intf.h"
 
#include <memory>
 
namespace adtf
{
namespace streaming
{
namespace ant
{
    class cSampleStreamInPort :
        public ucom::catwo::object<IStreamingPort,
                                   IStreamingInPort,
                                   sample_stream<ISampleStreamInPort>>
    {
        public: 
            ADTF_CLASS_ID_NAME(cSampleStreamInPort,
                               "default_sample_stream_in_port.streaming.adtf.cid",
                               "Sample Stream Inport");
 
        protected: 
            cSampleStreamInPort(const cSampleStreamInPort&) = delete;
            cSampleStreamInPort(cSampleStreamInPort&&) = delete;
            cSampleStreamInPort& operator=(const cSampleStreamInPort&) = delete;
            cSampleStreamInPort& operator=(cSampleStreamInPort&&) = delete;
 
            cSampleStreamInPort() = default;
 
        public: 
            
            cSampleStreamInPort(const char* strName, const char* strPortID)
            {
                SetName(strName);
                m_strPortID = strPortID;
            }
            virtual ~cSampleStreamInPort() = default;
 
    public:
        tResult GetPortID(adtf::base::ant::IString&& strID)
        {
            return strID.Set(m_strPortID);
        }
    private:
        adtf_util::cString m_strPortID;
    };
 
 
} //namespace ant
 
namespace flash
{
 
class cSampleStreamInPort: public ucom::catwo::object<base::ant::IRunnable,
                                                      ant::ITriggerPipeSource,
                                                      ant::ITriggerPipeItem,
                                                      ant::INamedGraphObject,
                                                      ant::ISampleStream,
                                                      ant::IStreamingPort,
                                                      ant::IStreamingInPort,
                                                      ant::ISampleStreamInPort,
                                                      base::flash::IRunnable>
{
    public:
        cSampleStreamInPort();
        cSampleStreamInPort(const char* strName, const char* strPortId);        
 
    public:
        ADTF_FLASH_TRIGGER_PIPE_ITEM_METHOD_DECLARATIONS
 
    public:
        tResult GetStreamError();
        tResult GetType(ucom::ant::iobject_ptr<const ant::IStreamType>& pStreamType) const override;
        tTimeStamp GetTime() const override;
        tResult SetStreamError(const tResult& oError) override;
        tResult AttachRouting(const ucom::ant::iobject_ptr<ant::ISampleStream>& pSampleStreamTo) override;
        tResult DetachRouting(const ucom::ant::iobject_ptr<ant::ISampleStream>& pSampleStreamTo) override;
        tResult Open(const char* strName,
                     ucom::ant::iobject_ptr<ant::ISampleInStream>& pInStream,
                     const ucom::ant::iobject_ptr<const ant::IStreamType>& pInitialAcceptedStreamType,
                     ant::ISampleStream::IPushReadEventSink*& pPushEventSink,
                     ant::ISampleStreamAccess::tMode ui32Mode,
                     size_t szQueueSize) override;
        tResult Open(const char* strName,
                     ucom::ant::iobject_ptr<ant::ISampleOutStream>& pOutStream,
                     ant::ISampleStreamAccess::tMode ui32Mode,
                     size_t szQueueSize) override;
    public:
        tResult GetPortID(adtf::base::ant::IString&& strID) override;
 
    protected:
        ~cSampleStreamInPort() override;
 
    protected:
        class cImplementation;
        std::unique_ptr<cImplementation> m_pImplementation;
};
 
}
 
namespace quiet
{
 
class cSampleStreamInPort: public ucom::catwo::object<flash::cSampleStreamInPort,
                                                      ITriggerPipeHierachy>
{
    public:
        cSampleStreamInPort();
        cSampleStreamInPort(const char* strName, const char* strPortId);
        ~cSampleStreamInPort() override;
 
        ADTF_QUIET_TRIGGER_PIPE_ITEM_METHOD_DECLARATIONS
};
 
}
 
using quiet::cSampleStreamInPort;
 
} //namespace streaming
} //namespace adtf