StatsCollector.hpp

Go to the documentation of this file.

/*
 * Copyright (c) 2015 - 2024 Intel Corporation
 * SPDX-License-Identifier: BSD-3-Clause
 */
 
#ifndef STATSCOLLECTOR_HPP_INCLUDE
#define STATSCOLLECTOR_HPP_INCLUDE
 
#include <vector>
#include <array>
#include <string>
#include <memory>
 
#include "geopm/PlatformIO.hpp"
#include "geopm_stats_collector.h"
 
namespace geopm
{
    class RuntimeStats;
 
    class StatsCollector
    {
        public:
            struct report_s {
                std::string host;
                std::string sample_time_first;
                std::array<double, GEOPM_NUM_SAMPLE_STATS> sample_stats;
                std::vector<std::string> metric_names;
                std::vector<std::array<double, GEOPM_NUM_METRIC_STATS> > metric_stats;
            };
 
            static std::unique_ptr<StatsCollector> make_unique(const std::vector<geopm_request_s> &requests);
            StatsCollector() = default;
            virtual ~StatsCollector() = default;
            virtual void update(void) = 0;
            virtual std::string report_yaml(void) const = 0;
            virtual void reset(void) = 0;
            virtual report_s report_struct(void) const = 0;
            virtual size_t update_count(void) const = 0;
    };
 
 
    class StatsCollectorImp : public StatsCollector
    {
        public:
            StatsCollectorImp();
            StatsCollectorImp(const std::vector<geopm_request_s> &requests);
            StatsCollectorImp(const std::vector<geopm_request_s> &requests, PlatformIO &pio);
            ~StatsCollectorImp() = default;
            void update(void) override;
            std::string report_yaml(void) const override;
            void reset(void) override;
            report_s report_struct(void) const override;
            size_t update_count(void) const override;
        private:
            std::vector<std::string> register_requests(const std::vector<geopm_request_s> &requests);
            std::string report_yaml_curr(void) const;
            PlatformIO &m_pio;
            std::vector<std::string> m_metric_names;
            std::vector<int> m_pio_idx;
            std::shared_ptr<RuntimeStats> m_stats;
            int m_time_pio_idx;
            size_t m_update_count; // Number of times update() has been called
            double m_time_sample;
            double m_time_delta_m_1;
            double m_time_delta_m_2;
            std::string m_time_begin_str;
            double m_time_begin;
            mutable bool m_is_cached;
            mutable std::string m_report_cache;
    };
 
}
 
#endif