mirror of
https://github.com/LizardByte/Sunshine.git
synced 2025-08-10 00:52:16 +00:00
18e7dfb190
* Refactor periodic loggers * Limit network batch size also by packet count Previously it was limited only by size, and exceeding 64 packets in a single batch is asking for problems.
57 lines
1.5 KiB
C++
57 lines
1.5 KiB
C++
/**
|
|
* @file src/stat_trackers.h
|
|
* @brief Declarations for streaming statistic tracking.
|
|
*/
|
|
#pragma once
|
|
|
|
#include <chrono>
|
|
#include <functional>
|
|
#include <limits>
|
|
|
|
#include <boost/format.hpp>
|
|
|
|
namespace stat_trackers {
|
|
|
|
boost::format
|
|
one_digit_after_decimal();
|
|
|
|
boost::format
|
|
two_digits_after_decimal();
|
|
|
|
template <typename T>
|
|
class min_max_avg_tracker {
|
|
public:
|
|
using callback_function = std::function<void(T stat_min, T stat_max, double stat_avg)>;
|
|
|
|
void
|
|
collect_and_callback_on_interval(T stat, const callback_function &callback, std::chrono::seconds interval_in_seconds) {
|
|
if (data.calls == 0) {
|
|
data.last_callback_time = std::chrono::steady_clock::now();
|
|
}
|
|
else if (std::chrono::steady_clock::now() > data.last_callback_time + interval_in_seconds) {
|
|
callback(data.stat_min, data.stat_max, data.stat_total / data.calls);
|
|
data = {};
|
|
}
|
|
data.stat_min = std::min(data.stat_min, stat);
|
|
data.stat_max = std::max(data.stat_max, stat);
|
|
data.stat_total += stat;
|
|
data.calls += 1;
|
|
}
|
|
|
|
void
|
|
reset() {
|
|
data = {};
|
|
}
|
|
|
|
private:
|
|
struct {
|
|
std::chrono::steady_clock::time_point last_callback_time = std::chrono::steady_clock::now();
|
|
T stat_min = std::numeric_limits<T>::max();
|
|
T stat_max = std::numeric_limits<T>::min();
|
|
double stat_total = 0;
|
|
uint32_t calls = 0;
|
|
} data;
|
|
};
|
|
|
|
} // namespace stat_trackers
|