mediapipelinestats.h

Go to the documentation of this file.

 
#pragma once
 
 
#include <promeki/config.h>
#if PROMEKI_ENABLE_PROAV
#include <promeki/namespace.h>
#include <promeki/datastream.h>
#include <promeki/error.h>
#include <promeki/json.h>
#include <promeki/list.h>
#include <promeki/map.h>
#include <promeki/mediaiocommand.h>
#include <promeki/mediaiostats.h>
#include <promeki/sharedptr.h>
#include <promeki/string.h>
#include <promeki/stringlist.h>
#include <promeki/windowedstatsbundle.h>
 
PROMEKI_NAMESPACE_BEGIN
 
class MediaPipelineStageStats {
        public:
                using WindowedMap = ::promeki::Map<MediaIOCommand::Kind, WindowedStatsBundle>;
 
                using List = ::promeki::List<MediaPipelineStageStats>;
 
                MediaPipelineStageStats() = default;
 
                String name;
 
                MediaIOStats cumulative;
 
                WindowedMap windowed;
 
                WindowedStatsBundle &windowedBundle(MediaIOCommand::Kind kind);
 
                bool isEmpty() const { return cumulative.size() == 0 && windowed.isEmpty(); }
 
                void clear();
 
                bool operator==(const MediaPipelineStageStats &other) const;
                bool operator!=(const MediaPipelineStageStats &other) const { return !(*this == other); }
 
                JsonObject toJson() const;
 
                static MediaPipelineStageStats fromJson(const JsonObject &obj, Error *err = nullptr);
};
 
DataStream &operator<<(DataStream &stream, const MediaPipelineStageStats &s);
 
DataStream &operator>>(DataStream &stream, MediaPipelineStageStats &s);
 
class MediaPipelineStats {
                PROMEKI_SHARED_FINAL(MediaPipelineStats)
        public:
                using Ptr = SharedPtr<MediaPipelineStats>;
 
                using List = ::promeki::List<MediaPipelineStats>;
 
                using PtrList = ::promeki::List<Ptr>;
 
                using StageList = MediaPipelineStageStats::List;
 
                MediaPipelineStats() = default;
 
                // ------------------------------------------------------------
                // Stage accessors
                // ------------------------------------------------------------
 
                const StageList &stages() const { return _stages; }
 
                StageList &stages() { return _stages; }
 
                void addStage(const MediaPipelineStageStats &s) { _stages.pushToBack(s); }
 
                void addStage(MediaPipelineStageStats &&s) { _stages.pushToBack(std::move(s)); }
 
                MediaPipelineStageStats stage(const String &name) const;
 
                const MediaPipelineStageStats *findStage(const String &name) const;
 
                MediaPipelineStageStats *findStage(const String &name);
 
                bool containsStage(const String &name) const { return findStage(name) != nullptr; }
 
                StringList stageNames() const;
 
                bool isEmpty() const { return _stages.isEmpty(); }
 
                void clear() { _stages.clear(); }
 
                // ------------------------------------------------------------
                // Rendering / serialization
                // ------------------------------------------------------------
 
                StringList describe() const;
 
                JsonObject toJson() const;
 
                static MediaPipelineStats fromJson(const JsonObject &obj, Error *err = nullptr);
 
                bool operator==(const MediaPipelineStats &other) const;
                bool operator!=(const MediaPipelineStats &other) const { return !(*this == other); }
 
        private:
                StageList _stages;
};
 
DataStream &operator<<(DataStream &stream, const MediaPipelineStats &s);
 
DataStream &operator>>(DataStream &stream, MediaPipelineStats &s);
 
PROMEKI_NAMESPACE_END
 
#endif // PROMEKI_ENABLE_PROAV