samplestreamer_intf.h

Go to the documentation of this file.

#pragma once
#include "streamtype_intf.h"
#include "samplestream_intf.h"
#include "streamitem_intf.h"
#include "sample_intf.h"
 
#include <adtfucom3/adtf_ucom3.h>
#include <adtfbase/string_intf.h>
 
namespace adtf
{
namespace streaming
{
namespace ant
{
    class ISampleStreamer
    {
 
    protected:
        ~ISampleStreamer() = default;
 
    public:
        virtual tResult EndStreaming() = 0;
        virtual tResult GetType(ucom::ant::iobject_ptr<const IStreamType>& pStreamType) const = 0;
 
    };

    class ISampleReader : public ISampleStreamer
    {
 
    protected:
        ~ISampleReader() = default;
 
    public:
        virtual tResult BeginStreaming(ISampleStream& pStream) = 0;
 
    };

    class ISampleWriter : public ISampleStreamer
    {
 
    protected:
        ~ISampleWriter() = default;
 
    public:
        virtual tResult BeginStreaming(ISampleStream& pStream) = 0;
 
    };

    class ISampleReaderQueue
    {
    public:
        virtual tResult Push(const IStreamItem& oStreamItem, tTimeStamp tmTime) = 0;

        virtual void Clear() = 0;

        virtual tResult Pop(IStreamItem& oStreamItem) = 0;
 
    };
 
} //namespace ant
 
namespace flash
{
 
class IStreamerPin;

class ISampleStreamer
{
 
    protected:
        virtual ~ISampleStreamer() = default;
 
    public:
        virtual void SetName(const char* strName) = 0;

        virtual tResult GetName(base::ant::IString&& strName) = 0;

        virtual tResult SetType(const ucom::ant::iobject_ptr<const ant::IStreamType>& pStreamType) = 0;

        virtual tResult GetType(ucom::ant::iobject_ptr<const ant::IStreamType>& pStreamType) const = 0;

        virtual tResult BeginStreaming(ant::ISampleStream& pStream) = 0;

        virtual tResult EndStreaming() = 0;

        virtual tResult SetStreamerPin(const ucom::ant::iobject_ptr<flash::IStreamerPin>& pStreamerPin) = 0;
};

class ISampleReader: public ISampleStreamer
{
    public:
        virtual tResult GetNextSample(ucom::ant::iobject_ptr<const ant::ISample>& pSample) = 0;

        virtual tResult GetLastSample(ucom::ant::iobject_ptr<const ant::ISample>& pSample) = 0;

        virtual tResult GetLastType(ucom::ant::iobject_ptr<const IStreamType>& pType) = 0;

        virtual tResult SetStreamError(tResult oError) = 0;

        virtual tResult ReadAllAvailableItems() = 0;
};

class ISampleWriter: public ISampleStreamer
{
    public:
        virtual tResult Write(const ucom::ant::iobject_ptr<const ant::ISample>& pSample) = 0;

        virtual tResult ChangeType(const ucom::ant::iobject_ptr<const ant::IStreamType>& pType)= 0;

        virtual tResult Flush() = 0;

        virtual tResult SetStreamError(tResult oError) = 0;

        virtual tResult ManualTrigger(base::flash::tNanoSeconds tmActivationTime = base::flash::tNanoSeconds{-1}) = 0;
};
 
}

using flash::ISampleStreamer;
using flash::ISampleReader;
using flash::ISampleWriter;
using ant::ISampleReaderQueue;
 
} //namespace streaming
} //namespace adtf