2016-05-31 03:58:58 +00:00
|
|
|
#pragma once
|
2016-05-19 14:41:06 +00:00
|
|
|
|
2016-06-15 03:32:35 +00:00
|
|
|
#include <istream>
|
2016-05-19 14:41:06 +00:00
|
|
|
|
2016-06-15 03:32:35 +00:00
|
|
|
#include "config.hpp"
|
2016-05-19 14:41:06 +00:00
|
|
|
#include "drawtypes/label.hpp"
|
2016-06-15 03:32:35 +00:00
|
|
|
#include "drawtypes/progressbar.hpp"
|
2016-05-19 14:41:06 +00:00
|
|
|
#include "drawtypes/ramp.hpp"
|
2016-06-15 03:32:35 +00:00
|
|
|
#include "modules/meta.hpp"
|
2016-05-19 14:41:06 +00:00
|
|
|
|
2016-06-15 03:32:35 +00:00
|
|
|
LEMONBUDDY_NS
|
|
|
|
|
|
|
|
namespace modules {
|
|
|
|
struct cpu_time {
|
2016-05-19 14:41:06 +00:00
|
|
|
unsigned long long user;
|
|
|
|
unsigned long long nice;
|
|
|
|
unsigned long long system;
|
|
|
|
unsigned long long idle;
|
|
|
|
unsigned long long total;
|
|
|
|
};
|
|
|
|
|
2016-06-15 03:32:35 +00:00
|
|
|
using cpu_time_t = unique_ptr<cpu_time>;
|
|
|
|
|
|
|
|
class cpu_module : public timer_module<cpu_module> {
|
|
|
|
public:
|
|
|
|
using timer_module::timer_module;
|
|
|
|
|
|
|
|
void setup() {
|
|
|
|
m_interval = chrono::duration<double>(m_conf.get<float>(name(), "interval", 1));
|
|
|
|
|
|
|
|
m_formatter->add(DEFAULT_FORMAT, TAG_LABEL,
|
|
|
|
{TAG_LABEL, TAG_BAR_LOAD, TAG_RAMP_LOAD, TAG_RAMP_LOAD_PER_CORE});
|
|
|
|
|
|
|
|
if (m_formatter->has(TAG_BAR_LOAD))
|
2016-10-25 05:10:03 +00:00
|
|
|
m_barload = load_progressbar(m_bar, m_conf, name(), TAG_BAR_LOAD);
|
2016-06-15 03:32:35 +00:00
|
|
|
if (m_formatter->has(TAG_RAMP_LOAD))
|
2016-10-25 05:10:03 +00:00
|
|
|
m_rampload = load_ramp(m_conf, name(), TAG_RAMP_LOAD);
|
2016-06-15 03:32:35 +00:00
|
|
|
if (m_formatter->has(TAG_RAMP_LOAD_PER_CORE))
|
2016-10-25 05:10:03 +00:00
|
|
|
m_rampload_core = load_ramp(m_conf, name(), TAG_RAMP_LOAD_PER_CORE);
|
2016-10-18 23:26:17 +00:00
|
|
|
if (m_formatter->has(TAG_LABEL))
|
2016-10-25 05:10:03 +00:00
|
|
|
m_label = load_optional_label(m_conf, name(), TAG_LABEL, "%percentage%");
|
2016-06-15 03:32:35 +00:00
|
|
|
|
|
|
|
// warmup
|
|
|
|
read_values();
|
|
|
|
read_values();
|
|
|
|
}
|
|
|
|
|
|
|
|
bool update() {
|
|
|
|
if (!read_values())
|
|
|
|
return false;
|
|
|
|
|
|
|
|
m_total = 0.0f;
|
|
|
|
m_load.clear();
|
|
|
|
|
|
|
|
auto cores_n = m_cputimes.size();
|
|
|
|
|
|
|
|
if (!cores_n)
|
|
|
|
return false;
|
|
|
|
|
|
|
|
for (size_t i = 0; i < cores_n; i++) {
|
|
|
|
auto load = get_load(i);
|
|
|
|
m_total += load;
|
|
|
|
m_load.emplace_back(load);
|
|
|
|
}
|
|
|
|
|
|
|
|
m_total = m_total / static_cast<float>(cores_n);
|
|
|
|
|
2016-10-18 23:26:17 +00:00
|
|
|
if (m_label) {
|
|
|
|
m_label->reset_tokens();
|
|
|
|
m_label->replace_token("%percentage%", to_string(static_cast<int>(m_total + 0.5f)) + "%");
|
2016-06-15 03:32:35 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
2016-10-18 23:26:17 +00:00
|
|
|
bool build(builder* builder, string tag) const {
|
2016-06-15 03:32:35 +00:00
|
|
|
if (tag == TAG_LABEL)
|
2016-10-18 23:26:17 +00:00
|
|
|
builder->node(m_label);
|
2016-06-15 03:32:35 +00:00
|
|
|
else if (tag == TAG_BAR_LOAD)
|
|
|
|
builder->node(m_barload->output(m_total));
|
|
|
|
else if (tag == TAG_RAMP_LOAD)
|
|
|
|
builder->node(m_rampload->get_by_percentage(m_total));
|
|
|
|
else if (tag == TAG_RAMP_LOAD_PER_CORE) {
|
|
|
|
auto i = 0;
|
|
|
|
for (auto&& load : m_load) {
|
|
|
|
if (i++ > 0)
|
|
|
|
builder->space(1);
|
|
|
|
builder->node(m_rampload_core->get_by_percentage(load));
|
|
|
|
}
|
|
|
|
builder->node(builder->flush());
|
|
|
|
} else
|
|
|
|
return false;
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
|
|
|
protected:
|
|
|
|
bool read_values() {
|
|
|
|
m_cputimes_prev.swap(m_cputimes);
|
|
|
|
m_cputimes.clear();
|
|
|
|
|
|
|
|
try {
|
|
|
|
std::ifstream in(PATH_CPU_INFO);
|
|
|
|
string str;
|
|
|
|
|
|
|
|
while (std::getline(in, str) && str.compare(0, 3, "cpu") == 0) {
|
|
|
|
// skip line with accumulated value
|
|
|
|
if (str.compare(0, 4, "cpu ") == 0)
|
|
|
|
continue;
|
|
|
|
|
|
|
|
auto values = string_util::split(str, ' ');
|
|
|
|
|
|
|
|
m_cputimes.emplace_back(new cpu_time);
|
|
|
|
m_cputimes.back()->user = std::stoull(values[1].c_str(), 0, 10);
|
|
|
|
m_cputimes.back()->nice = std::stoull(values[2].c_str(), 0, 10);
|
|
|
|
m_cputimes.back()->system = std::stoull(values[3].c_str(), 0, 10);
|
|
|
|
m_cputimes.back()->idle = std::stoull(values[4].c_str(), 0, 10);
|
|
|
|
m_cputimes.back()->total = m_cputimes.back()->user + m_cputimes.back()->nice +
|
|
|
|
m_cputimes.back()->system + m_cputimes.back()->idle;
|
|
|
|
}
|
|
|
|
} catch (const std::ios_base::failure& e) {
|
|
|
|
m_log.err("Failed to read CPU values (what: %s)", e.what());
|
|
|
|
}
|
|
|
|
|
|
|
|
return !m_cputimes.empty();
|
|
|
|
}
|
|
|
|
|
2016-10-18 23:26:17 +00:00
|
|
|
float get_load(size_t core) const {
|
2016-10-15 21:37:39 +00:00
|
|
|
if (m_cputimes.empty() || m_cputimes_prev.empty())
|
2016-06-15 03:32:35 +00:00
|
|
|
return 0;
|
2016-10-15 21:37:39 +00:00
|
|
|
else if (core >= m_cputimes.size() || core >= m_cputimes_prev.size())
|
2016-06-15 03:32:35 +00:00
|
|
|
return 0;
|
|
|
|
|
|
|
|
auto& last = m_cputimes[core];
|
|
|
|
auto& prev = m_cputimes_prev[core];
|
|
|
|
|
|
|
|
auto last_idle = last->idle;
|
|
|
|
auto prev_idle = prev->idle;
|
|
|
|
|
|
|
|
auto diff = last->total - prev->total;
|
|
|
|
|
|
|
|
if (diff == 0)
|
|
|
|
return 0;
|
|
|
|
|
|
|
|
float percentage = 100.0f * (diff - (last_idle - prev_idle)) / diff;
|
|
|
|
|
|
|
|
return math_util::cap<float>(percentage, 0, 100);
|
|
|
|
}
|
|
|
|
|
|
|
|
private:
|
2016-05-31 03:58:58 +00:00
|
|
|
static constexpr auto TAG_LABEL = "<label>";
|
2016-05-26 00:14:56 +00:00
|
|
|
static constexpr auto TAG_BAR_LOAD = "<bar-load>";
|
|
|
|
static constexpr auto TAG_RAMP_LOAD = "<ramp-load>";
|
2016-10-12 03:19:29 +00:00
|
|
|
static constexpr auto TAG_RAMP_LOAD_PER_CORE = "<ramp-coreload>";
|
2016-05-19 14:41:06 +00:00
|
|
|
|
2016-06-15 03:32:35 +00:00
|
|
|
progressbar_t m_barload;
|
|
|
|
ramp_t m_rampload;
|
|
|
|
ramp_t m_rampload_core;
|
|
|
|
label_t m_label;
|
2016-05-19 14:41:06 +00:00
|
|
|
|
2016-06-15 03:32:35 +00:00
|
|
|
vector<cpu_time_t> m_cputimes;
|
|
|
|
vector<cpu_time_t> m_cputimes_prev;
|
2016-05-19 14:41:06 +00:00
|
|
|
|
2016-06-15 03:32:35 +00:00
|
|
|
float m_total = 0;
|
|
|
|
vector<float> m_load;
|
2016-05-19 14:41:06 +00:00
|
|
|
};
|
|
|
|
}
|
2016-06-15 03:32:35 +00:00
|
|
|
|
|
|
|
LEMONBUDDY_NS_END
|