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/telegrafAdapter.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,
                              TelegrafAdapter* telegraf_adapter = nullptr);
    ~ComponentMetrics() noexcept override;
 
    void StartMonitoring() override;
    void StopMonitoring() noexcept override;
    bool IsMonitoring() noexcept override;
    void UpdateParams() override;
    Parameters GetParams();
 
    [[nodiscard]] perfc::ScopedRegistration
    AddCounter(CounterVariant counter, CounterMetricInfo info) override;
    bool RemoveCounter(CounterVariant counter) override;
 
private:
    struct MonitoringThread {
        MonitoringThread(std::thread t) : thread(std::move(t)) {
        }
        bool stop_flag = false;
        pid_t id = 0;
        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;
    TelegrafAdapter* m_telegraf_adapter;
};
 
}  // namespace rtctk::componentFramework
 
#endif  // RTCTK_COMPONENTFRAMEWORK_COMPONENTMETRICS_HPP