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 trigger_pipe_item<ant::INamedGraphObject,
                             ant::ISampleStream,
                             ant::IStreamingPort,
                             ant::IStreamingInPort,
                             ant::ISampleStreamInPort>
{
public:
    cSampleStreamInPort();
    cSampleStreamInPort(const char* strName, const char* strPortId);
    ~cSampleStreamInPort() override;
 
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 SetName(const char* strName) override;
    tResult SetParent(const ucom::ant::IObject* oParentObject) override;
 
public:
    tResult GetPortID(adtf::base::ant::IString&& strID) override;
 
protected:
    class cImplementation;
    std::unique_ptr<cImplementation> m_pImplementation;
};
 
} // namespace flash
 
namespace quiet
{
 
using flash::cSampleStreamInPort;
 
}

using quiet::cSampleStreamInPort;
 
} // namespace streaming
} // namespace adtf