mirror of
https://github.com/esphome/esphome.git
synced 2025-09-10 23:32:23 +01:00
127 lines
3.6 KiB
C++
127 lines
3.6 KiB
C++
#pragma once
|
|
|
|
#include "esphome/core/defines.h"
|
|
|
|
#ifdef USE_RUNTIME_STATS
|
|
|
|
#include <map>
|
|
#include <string>
|
|
#include <vector>
|
|
#include <cstdint>
|
|
#include "esphome/core/helpers.h"
|
|
#include "esphome/core/log.h"
|
|
|
|
namespace esphome {
|
|
|
|
class Component; // Forward declaration
|
|
|
|
namespace runtime_stats {
|
|
|
|
static const char *const TAG = "runtime_stats";
|
|
|
|
class ComponentRuntimeStats {
|
|
public:
|
|
ComponentRuntimeStats()
|
|
: period_count_(0),
|
|
total_count_(0),
|
|
period_time_ms_(0),
|
|
total_time_ms_(0),
|
|
period_max_time_ms_(0),
|
|
total_max_time_ms_(0) {}
|
|
|
|
void record_time(uint32_t duration_ms) {
|
|
// Update period counters
|
|
this->period_count_++;
|
|
this->period_time_ms_ += duration_ms;
|
|
if (duration_ms > this->period_max_time_ms_)
|
|
this->period_max_time_ms_ = duration_ms;
|
|
|
|
// Update total counters
|
|
this->total_count_++;
|
|
this->total_time_ms_ += duration_ms;
|
|
if (duration_ms > this->total_max_time_ms_)
|
|
this->total_max_time_ms_ = duration_ms;
|
|
}
|
|
|
|
void reset_period_stats() {
|
|
this->period_count_ = 0;
|
|
this->period_time_ms_ = 0;
|
|
this->period_max_time_ms_ = 0;
|
|
}
|
|
|
|
// Period stats (reset each logging interval)
|
|
uint32_t get_period_count() const { return this->period_count_; }
|
|
uint32_t get_period_time_ms() const { return this->period_time_ms_; }
|
|
uint32_t get_period_max_time_ms() const { return this->period_max_time_ms_; }
|
|
float get_period_avg_time_ms() const {
|
|
return this->period_count_ > 0 ? this->period_time_ms_ / static_cast<float>(this->period_count_) : 0.0f;
|
|
}
|
|
|
|
// Total stats (persistent until reboot)
|
|
uint32_t get_total_count() const { return this->total_count_; }
|
|
uint32_t get_total_time_ms() const { return this->total_time_ms_; }
|
|
uint32_t get_total_max_time_ms() const { return this->total_max_time_ms_; }
|
|
float get_total_avg_time_ms() const {
|
|
return this->total_count_ > 0 ? this->total_time_ms_ / static_cast<float>(this->total_count_) : 0.0f;
|
|
}
|
|
|
|
protected:
|
|
// Period stats (reset each logging interval)
|
|
uint32_t period_count_;
|
|
uint32_t period_time_ms_;
|
|
uint32_t period_max_time_ms_;
|
|
|
|
// Total stats (persistent until reboot)
|
|
uint32_t total_count_;
|
|
uint32_t total_time_ms_;
|
|
uint32_t total_max_time_ms_;
|
|
};
|
|
|
|
// For sorting components by run time
|
|
struct ComponentStatPair {
|
|
std::string name;
|
|
const ComponentRuntimeStats *stats;
|
|
|
|
bool operator>(const ComponentStatPair &other) const {
|
|
// Sort by period time as that's what we're displaying in the logs
|
|
return stats->get_period_time_ms() > other.stats->get_period_time_ms();
|
|
}
|
|
};
|
|
|
|
class RuntimeStatsCollector {
|
|
public:
|
|
RuntimeStatsCollector();
|
|
|
|
void set_log_interval(uint32_t log_interval) { this->log_interval_ = log_interval; }
|
|
uint32_t get_log_interval() const { return this->log_interval_; }
|
|
|
|
void record_component_time(Component *component, uint32_t duration_ms, uint32_t current_time);
|
|
|
|
// Process any pending stats printing (should be called after component loop)
|
|
void process_pending_stats(uint32_t current_time);
|
|
|
|
protected:
|
|
void log_stats_();
|
|
|
|
void reset_stats_() {
|
|
for (auto &it : this->component_stats_) {
|
|
it.second.reset_period_stats();
|
|
}
|
|
}
|
|
|
|
// Back to string keys, but we'll cache the source name per component
|
|
std::map<std::string, ComponentRuntimeStats> component_stats_;
|
|
std::map<Component *, std::string> component_names_cache_;
|
|
uint32_t log_interval_;
|
|
uint32_t next_log_time_;
|
|
};
|
|
|
|
} // namespace runtime_stats
|
|
|
|
extern runtime_stats::RuntimeStatsCollector
|
|
*global_runtime_stats; // NOLINT(cppcoreguidelines-avoid-non-const-global-variables)
|
|
|
|
} // namespace esphome
|
|
|
|
#endif // USE_RUNTIME_STATS
|