samplestream_intf.h

Go to the documentation of this file.

#pragma once
#include "triggerpipe_intf.h"
#include "named_graph_object_intf.h"
#include "streamtype_intf.h"
#include "samplestreamaccess_intf.h"
#include "sampleinstream_intf.h"
#include "sampleoutstream_intf.h"
 
namespace adtf
{
namespace streaming
{
namespace ant
{
    
    class ISampleStream : public ITriggerPipeItem,
                          public INamedGraphObject
    {
        protected:
            ~ISampleStream() = default;
 
        public:
            ADTF_IID(ISampleStream, "samplestream.ant.streaming.adtf.iid");
            UCOM_RESOLVE(adtf::ucom::ant::IObject, INamedGraphObject)
 
            class IPushReadEventSink: public adtf::base::ant::IRunnable
            {
                protected:
                    IPushReadEventSink() = default;
                public:
                    virtual void Reset() = 0;
            };
 
        public:
            virtual tResult    GetType(adtf::ucom::ant::iobject_ptr<const IStreamType>& pStreamType) const = 0;

            virtual tTimeStamp GetTime() const = 0;

            virtual tResult    SetStreamError(const tResult& oError) = 0;

            virtual tResult    AttachRouting(const adtf::ucom::ant::iobject_ptr<ISampleStream>& pSampleStreamTo) = 0;

            virtual tResult    DetachRouting(const adtf::ucom::ant::iobject_ptr<ISampleStream>& pSampleStreamTo) = 0;
   
            virtual tResult    Open(const char* strName,
                                    adtf::ucom::ant::iobject_ptr<ISampleInStream>& pInStream,
                                    const adtf::ucom::ant::iobject_ptr<const IStreamType>& pInitialAcceptedStreamType,
                                    IPushReadEventSink*& pPushEventSink,
                                    ISampleStreamAccess::tMode ui32Mode,
                                    size_t szQueueSize) = 0;
            virtual tResult    Open(const char* strName,
                                    adtf::ucom::ant::iobject_ptr<ISampleOutStream>& pOutStream,
                                    ISampleStreamAccess::tMode ui32Mode,
                                    size_t szQueueSize) = 0;
    };
 
    
} //namespace ant
 
namespace vision
{
    class IBlockableSampleStream : public ucom::ant::IObject
    {
    protected:
        virtual ~IBlockableSampleStream() = default;
 
    public:
        ADTF_IID(IBlockableSampleStream, "blockable_samplestream.vision.streaming.adtf.iid");

        virtual void BlockSampleStreaming(bool bBlock) = 0;
        virtual bool IsSampleStreamingBlocked() const = 0;
    };
}
using ant::ISampleStream;
using vision::IBlockableSampleStream;
 
} // namespace streaming
} // namespace adtf