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 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;
};
 
}
 
using quiet::ISampleStreamTracer;
 
}
}