sample_stream_tracer_intf.h

Go to the documentation of this file.

#pragma once
 
#include <adtf_utils.h>
#include <adtfucom3/adtf_ucom3.h>
#include <adtfstreaming3/samplestream_intf.h>
 
#define CID_SAMPLE_STREAM_TRACE_PROVIDER_SERVICE "core_sample_stream_tracer.service.adtf.cid"
 
namespace adtf
{
namespace services
{
namespace bat
{

class ISampleStreamTracer : public adtf::ucom::IObject
{
    public:
        ADTF_IID(ISampleStreamTracer, "sample_stream_tracer.bat.services.adtf.iid");
 
    protected:
        ~ISampleStreamTracer() = default;
 
    public:
        struct tTraceData
        {
            uint64_t ui64SampleCount = 0;
            tTimeStamp tmLastSample = 0;
            double fSamplesPerSecond = 0.0;
            double fBytesPerSecond = 0.0;

            uint64_t ui64TriggerCount = 0;
            tTimeStamp tmLastTrigger = 0;
            double fTriggerPerSecond = 0.0;
        };
        class IListener    // call back function -> gui service
        {
            public:
                virtual void Updated(const streaming::ant::ISampleStream* pSampleStream,
                                      const tTraceData& sData) = 0;
                virtual void Init(const streaming::ant::ISampleStream* pSampleStream,
                                  const streaming::ant::INamedGraphObject* pSource = nullptr) = 0;
        };
 
    public:

        virtual tResult RegisterListener(IListener& oListener) = 0;
        virtual tResult UnregisterListener(IListener& oListener) = 0;
};
 
} // namespace bat
 
namespace quiet {

class ISampleStreamTracer : public bat::ISampleStreamTracer
{
    public:
        ADTF_IID(ISampleStreamTracer, "sample_stream_tracer.quiet.services.adtf.iid");
 
    protected:
        ~ISampleStreamTracer() = default;
 
    public:
        struct tTraceData : public bat::ISampleStreamTracer::tTraceData
        {
            uint64_t ui64StreamTypeCount = 0;
            tTimeStamp tmLastStreamType = 0;
            double fStreamTypePerSecond = 0.0;
        };
        class IListener // call back function -> gui service
        {
            public:
                virtual void Updated(const streaming::ant::ISampleStream* pSampleStream, const tTraceData& sData) = 0;
                virtual void Init(const streaming::ant::ISampleStream* pSampleStream,
                                  const streaming::ant::INamedGraphObject* pSource = nullptr,
                                  const char* strSourceFullName = nullptr) = 0;
        };
 
    public:
        using bat::ISampleStreamTracer::RegisterListener;
        virtual tResult RegisterListener(IListener& oListener) = 0;
 
        using bat::ISampleStreamTracer::UnregisterListener;
        virtual tResult UnregisterListener(IListener& oListener) = 0;
};
 
} // namespace quiet
 
namespace vision
{

class ISampleStreamTracer : public quiet::ISampleStreamTracer
{
public:
    ADTF_IID(ISampleStreamTracer, "sample_stream_tracer.vision.services.adtf.iid");
 
protected:
    ~ISampleStreamTracer() = default;
 
public:
    struct tTraceData : public quiet::ISampleStreamTracer::tTraceData
    {
        double fSamplesPerSecondWallTime = 0.0;
        double fTriggerPerSecondWallTime = 0.0;
        double fStreamTypePerSecondWallTime = 0.0;
        double fBytesPerSecondWallTime = 0.0;
        int64_t tmLastSampleWallTime = 0;
        int64_t tmLastTriggerWallTime = 0;
        int64_t tmLastStreamTypeWallTime = 0;
    };
    class IListener // call back function -> gui service
    {
    public:
        virtual void Updated(const streaming::ant::ISampleStream* pSampleStream, const tTraceData& sData) = 0;
        virtual void Init(const streaming::ant::ISampleStream* pSampleStream,
                          const streaming::ant::INamedGraphObject* pSource = nullptr,
                          const char* strSourceFullName = nullptr) = 0;
    };
 
public:
    using quiet::ISampleStreamTracer::RegisterListener;
    virtual tResult RegisterListener(IListener& oListener) = 0;
 
    using quiet::ISampleStreamTracer::UnregisterListener;
    virtual tResult UnregisterListener(IListener& oListener) = 0;
};
 
} // namespace vision
 
namespace wolverine
{
class ISampleStreamTracer : public vision::ISampleStreamTracer
{
public:
    ADTF_IID(ISampleStreamTracer, "sample_stream_tracer.wolverine.services.adtf.iid");
 
protected:
    ~ISampleStreamTracer() = default;
 
public:
    struct tTraceData
    {
        vision::ISampleStreamTracer::tTraceData sSampleStreamInput;
        vision::ISampleStreamTracer::tTraceData sSampleStreamOutput;
    };
    class IListener // call back function -> gui service
    {
    public:
        virtual void Updated(const streaming::ant::ISampleStream* pSampleStream, const tTraceData& sData) = 0;
        virtual void Init(const streaming::ant::ISampleStream* pSampleStream,
                          const streaming::ant::INamedGraphObject* pSource = nullptr,
                          const char* strSourceFullName = nullptr) = 0;
    };
 
public:
    using vision::ISampleStreamTracer::RegisterListener;
    virtual tResult RegisterListener(IListener& oListener) = 0;
 
    using vision::ISampleStreamTracer::UnregisterListener;
    virtual tResult UnregisterListener(IListener& oListener) = 0;
};
 
} // namespace wolverine
 
using wolverine::ISampleStreamTracer;
 
} // namespace services
} // namespace adtf