system_monitor_detail.hpp

Go to the documentation of this file.

 
#pragma once
 
#include <chrono>
#include <cstddef>
#include <memory>
#include <optional>
#include <string>
#include <vector>
 
#include "pulsatrix/system_monitor.hpp"
 
namespace pulsatrix::detail {
 
struct CpuTimes {
    double busy = 0.0;
    double total = 0.0;
};
 
struct RawReading {
    std::optional<CpuTimes> system_cpu;
    std::optional<double> process_cpu_seconds;  
    std::optional<double> memory_used_bytes;
    std::optional<double> memory_total_bytes;
    std::optional<double> process_rss_bytes;
    std::optional<double> cpu_temperature_c;
    std::vector<GpuSample> gpus;
};
 
class PlatformSources {
public:
    virtual ~PlatformSources() = default;
    virtual RawReading read() = 0;
    virtual std::vector<MetricCapability> capabilities() = 0;
};
 
std::unique_ptr<PlatformSources> make_host_sources();
 
std::optional<double> cpu_percent_from_deltas(const CpuTimes& previous, const CpuTimes& current);
 
struct AmdGpuDevice {
    std::string card;        
    std::string device_dir;  
    std::string pci_device;  
};
 
class LinuxSources : public PlatformSources {
public:
    explicit LinuxSources(std::string proc_root = "/proc", std::string sys_root = "/sys",
                          long clock_ticks_per_second = 0);
 
    RawReading read() override;
    std::vector<MetricCapability> capabilities() override;
 
    [[nodiscard]] std::optional<CpuTimes> read_system_cpu_times() const;
    [[nodiscard]] std::optional<double> read_process_cpu_seconds() const;
    [[nodiscard]] std::optional<double> read_memory_total_bytes() const;
    [[nodiscard]] std::optional<double> read_memory_used_bytes() const;
    [[nodiscard]] std::optional<double> read_process_rss_bytes() const;
    [[nodiscard]] std::optional<std::string> find_cpu_temperature_input() const;
    [[nodiscard]] std::optional<double> read_cpu_temperature_c() const;
    [[nodiscard]] std::vector<AmdGpuDevice> find_amd_gpus() const;
    [[nodiscard]] GpuSample read_amd_gpu(const AmdGpuDevice& device, int index) const;
 
private:
    std::string proc_root_;
    std::string sys_root_;
    double clock_ticks_per_second_;
};
 
std::string json_escape(const std::string& text);
 
std::string format_number(double value);
 
std::string mark_to_json(std::chrono::system_clock::time_point timestamp, double elapsed_seconds,
                         const std::string& label);
 
std::string csv_header(std::size_t gpu_count);
 
std::string sample_to_csv(const SystemSample& sample, std::size_t gpu_count);
 
std::string mark_to_csv(std::chrono::system_clock::time_point timestamp, double elapsed_seconds,
                        const std::string& label, std::size_t gpu_count);
 
}  // namespace pulsatrix::detail