samplestreamoutport.h

Go to the documentation of this file.

#pragma once
 
#include "samplestream.h"
#include "streaming_graph_intf.h"
#include "samplestreamport_intf.h"
 
namespace adtf
{
namespace streaming
{
namespace ant
{
class cSampleStreamOutPort :
    public ucom::catwo::object<IStreamingPort, IStreamingOutPort, sample_stream<ISampleStreamOutPort>>
{
public:
    ADTF_CLASS_ID_NAME(cSampleStreamOutPort,
                       "default_sample_stream_out_port.streaming.adtf.cid",
                       "Sample Stream Outport");
 
protected:
    cSampleStreamOutPort(const cSampleStreamOutPort&) = delete;
    cSampleStreamOutPort(cSampleStreamOutPort&&) = delete;
    cSampleStreamOutPort& operator=(const cSampleStreamOutPort&) = delete;
    cSampleStreamOutPort& operator=(cSampleStreamOutPort&&) = delete;

    cSampleStreamOutPort() = default;
 
public:
    cSampleStreamOutPort(const char* strName, const char* strPortID)
    {
        SetName(strName);
        m_strPortID = strPortID;
    }

    virtual ~cSampleStreamOutPort() = default;
 
public:
    tResult GetPortID(adtf::base::ant::IString&& strID) override
    {
        return strID.Set(m_strPortID);
    }
 
private:
    adtf_util::cString m_strPortID;
};
 
} // namespace ant
 
namespace flash
{
 
class cSampleStreamOutPort :
    public trigger_pipe_item<ant::INamedGraphObject,
                             ant::ISampleStream,
                             ant::IStreamingPort,
                             ant::IStreamingOutPort,
                             ant::ISampleStreamOutPort>
{
public:
    cSampleStreamOutPort();
    cSampleStreamOutPort(const char* strName, const char* strPortId);
    ~cSampleStreamOutPort() 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::cSampleStreamOutPort;
 
}

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