monitor_adapter.h

Go to the documentation of this file.

// BSD 3-Clause License
// Copyright (c) 2021-2025, 🍀☀🌕🌥 🌊
// See the LICENSE file in the project root for full license information.
 
#pragma once
 
#include <kcenon/monitoring/core/performance_monitor.h>
#include <memory>
#include <chrono>
 
// For thread_system v3.0+ integration, use common_adapters.h which provides
// adapters for kcenon::common::interfaces::IMonitor and IMonitorable
 
namespace kcenon::monitoring::adapters {
 
class performance_monitor_adapter {
public:
    explicit performance_monitor_adapter(std::shared_ptr<kcenon::monitoring::performance_monitor> monitor)
        : monitor_(std::move(monitor)) {
    }
 
    performance_monitor_adapter() {
        // Create default monitor configuration
        kcenon::monitoring::performance_monitor::config config;
        config.enable_cpu_monitoring = true;
        config.enable_memory_monitoring = true;
        config.sampling_interval_ms = 1000;
        monitor_ = std::make_shared<kcenon::monitoring::performance_monitor>(config);
    }
 
    bool initialize() {
        if (monitor_) {
            monitor_->start();
            is_running_ = true;
            return true;
        }
        return false;
    }
 
    void shutdown() {
        if (monitor_) {
            monitor_->stop();
        }
        is_running_ = false;
    }
 
    bool is_running() const {
        return is_running_ && monitor_ != nullptr;
    }
 
    std::string name() const {
        return "MonitorAdapter";
    }
 
    std::shared_ptr<kcenon::monitoring::performance_monitor> get_monitor() const {
        return monitor_;
    }
 
    void set_config(const kcenon::monitoring::performance_monitor::config& config) {
        if (monitor_) {
            // Stop, reconfigure, and restart if running
            bool was_running = is_running_;
            if (was_running) {
                monitor_->stop();
            }
 
            monitor_ = std::make_shared<kcenon::monitoring::performance_monitor>(config);
 
            if (was_running) {
                monitor_->start();
            }
        }
    }
 
    void set_metrics_enabled(bool enabled) {
        metrics_enabled_ = enabled;
        if (monitor_) {
            if (enabled) {
                monitor_->start();
            } else {
                monitor_->stop();
            }
        }
    }
 
private:
    std::shared_ptr<kcenon::monitoring::performance_monitor> monitor_;
    bool metrics_enabled_{true};
    bool is_running_{false};
};
 
// Legacy alias for backward compatibility
using monitor_adapter = performance_monitor_adapter;
 
} // namespace kcenon::monitoring::adapters