componentMetrics.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_COMPONENTFRAMEWORK_COMPONENTMETRICS_HPP
#define RTCTK_COMPONENTFRAMEWORK_COMPONENTMETRICS_HPP
 
#include <condition_variable>
#include <optional>
#include <thread>
 
#include <log4cplus/logger.h>
 
#include <rtctk/componentFramework/componentMetricsIf.hpp>
#include <rtctk/componentFramework/dataPointPath.hpp>
 
namespace rtctk::componentFramework {
 
class RepositoryIf;
class OldbIf;
class RuntimeRepoIf;
 
class ComponentMetrics : public ComponentMetricsIf {
public:
    using ComponentMetricsIf::CounterTypes;
    using ComponentMetricsIf::CounterVariant;
 
    struct Parameters {
        std::chrono::milliseconds counter_poll_interval = std::chrono::milliseconds(5000);
        int thread_nice = 5;
    };
 
    explicit ComponentMetrics(OldbIf& oldb,
                              DataPointPath oldb_root,
                              RuntimeRepoIf& rtr,
                              DataPointPath rtr_root,
                              log4cplus::Logger logger);
    ~ComponentMetrics() noexcept;
 
    void StartMonitoring() override;
    void StopMonitoring() noexcept override;
    bool IsMonitoring() noexcept override;
    void UpdateParams() override;
    Parameters GetParams();
 
    [[nodiscard]] virtual perfc::ScopedRegistration
    AddCounter(CounterVariant counter, CounterMetricInfo info) override;
    bool RemoveCounter(CounterVariant counter) override;
 
private:
    struct MonitoringThread {
        MonitoringThread(std::thread t) : stop_flag(false), id(0), thread(std::move(t)) {
        }
        bool stop_flag;
        pid_t id;
        std::thread thread;
    };
 
    void MonitoringLoop();
 
    OldbIf& m_oldb;
    DataPointPath m_oldb_root;
 
    RuntimeRepoIf& m_rtr;
    DataPointPath m_rtr_root;
 
    std::recursive_mutex m_api_mtx;
 
    std::mutex m_mon_mtx;
 
    std::condition_variable m_cond;
 
    Parameters m_params;
 
    perfc::Register<CounterTypes, CounterMetricInfo> m_counters;
    std::optional<MonitoringThread> m_monitoring_thread;
    log4cplus::Logger m_logger;
};
 
}  // namespace rtctk::componentFramework
 
#endif  // RTCTK_COMPONENTFRAMEWORK_COMPONENTMETRICS_HPP