mediaiostatscollector.h

Go to the documentation of this file.

 
#pragma once
 
 
#include <promeki/config.h>
#if PROMEKI_ENABLE_PROAV
#include <cstddef>
#include <functional>
#include <promeki/mediaiocommand.h>
#include <promeki/mediaiostats.h>
#include <promeki/namespace.h>
 
PROMEKI_NAMESPACE_BEGIN
 
struct MediaIOStatsCollectorKey {
                MediaIOCommand::Kind kind = MediaIOCommand::Open;
 
                MediaIOStats::ID id;
 
                bool operator==(const MediaIOStatsCollectorKey &o) const noexcept {
                        return kind == o.kind && id == o.id;
                }
 
                bool operator!=(const MediaIOStatsCollectorKey &o) const noexcept { return !(*this == o); }
};
 
PROMEKI_NAMESPACE_END
 
template <> struct std::hash<promeki::MediaIOStatsCollectorKey> {
                std::size_t operator()(const promeki::MediaIOStatsCollectorKey &k) const noexcept {
                        std::size_t h = std::hash<promeki::MediaIOStats::ID>{}(k.id);
                        h ^= static_cast<std::size_t>(k.kind) + 0x9e3779b97f4a7c15ULL + (h << 6) + (h >> 2);
                        return h;
                }
};
 
#include <promeki/hashmap.h>
#include <promeki/objectbase.h>
#include <promeki/windowedstat.h>
 
PROMEKI_NAMESPACE_BEGIN
 
class MediaIO;
 
class MediaIOStatsCollector : public ObjectBase {
                PROMEKI_OBJECT(MediaIOStatsCollector, ObjectBase)
        public:
                using Key = MediaIOStatsCollectorKey;
 
                using WindowMap = HashMap<Key, WindowedStat>;
 
                static constexpr int DefaultWindowSize = 256;
 
                explicit MediaIOStatsCollector(ObjectBase *parent = nullptr);
 
                explicit MediaIOStatsCollector(MediaIO *target, ObjectBase *parent = nullptr);
 
                ~MediaIOStatsCollector() override;
 
                MediaIO *target() const { return const_cast<ObjectBasePtr<MediaIO> &>(_target).data(); }
 
                void setTarget(MediaIO *io);
 
                int windowSize() const { return _windowSize; }
 
                void setWindowSize(int n);
 
                const WindowMap &windows() const { return _windows; }
 
                WindowedStat window(const Key &key) const;
 
                void clear();
 
        private:
                void onCommandCompleted(MediaIOCommand::Ptr cmd);
 
                ObjectBasePtr<MediaIO> _target;
                int                    _windowSize = DefaultWindowSize;
                WindowMap              _windows;
};
 
PROMEKI_NAMESPACE_END
 
#endif // PROMEKI_ENABLE_PROAV