diff options
Diffstat (limited to 'src/smooth_refresh.cpp')
| -rw-r--r-- | src/smooth_refresh.cpp | 173 |
1 files changed, 173 insertions, 0 deletions
diff --git a/src/smooth_refresh.cpp b/src/smooth_refresh.cpp new file mode 100644 index 0000000..f21c023 --- /dev/null +++ b/src/smooth_refresh.cpp @@ -0,0 +1,173 @@ +#include <config.h> + +#include <sys/types.h> +#include <unistd.h> + +#include <glib.h> +#include <mateconf/mateconf-client.h> +#include <glibtop.h> +#include <glibtop/proctime.h> +#include <glibtop/cpu.h> + +#include <algorithm> + +#include "smooth_refresh.h" +#include "procman.h" +#include "util.h" + + +const string SmoothRefresh::KEY("/apps/procman/smooth_refresh"); +const bool SmoothRefresh::KEY_DEFAULT_VALUE(true); + + + +unsigned SmoothRefresh::get_own_cpu_usage() +{ + glibtop_cpu cpu; + glibtop_proc_time proctime; + guint64 elapsed; + unsigned usage = PCPU_LO; + + glibtop_get_cpu (&cpu); + elapsed = cpu.total - this->last_total_time; + + if (elapsed) { // avoid division by 0 + glibtop_get_proc_time(&proctime, getpid()); + usage = (proctime.rtime - this->last_cpu_time) * 100 / elapsed; + } + + usage = CLAMP(usage, 0, 100); + + this->last_total_time = cpu.total; + this->last_cpu_time = proctime.rtime; + + return usage; +} + + + +void SmoothRefresh::status_changed(MateConfClient *client, + guint cnxn_id, + MateConfEntry *entry, + gpointer user_data) +{ + static_cast<SmoothRefresh*>(user_data)->load_mateconf_value(mateconf_entry_get_value(entry)); +} + +void SmoothRefresh::load_mateconf_value(MateConfValue* value) +{ + bool own_value = false; + + if (not value) { + value = mateconf_client_get(mateconf_client_get_default(), KEY.c_str(), NULL); + } + + this->active = value ? mateconf_value_get_bool(value) : KEY_DEFAULT_VALUE; + + if (this->active) + procman_debug("smooth_refresh is enabled"); + + if (own_value and value) + mateconf_value_free(value); +} + + +SmoothRefresh::SmoothRefresh() +{ + this->connection = mateconf_client_notify_add(mateconf_client_get_default(), + KEY.c_str(), + status_changed, + this, + NULL, + NULL); + + this->reset(); + this->load_mateconf_value(); +} + + + +void SmoothRefresh::reset() +{ + glibtop_cpu cpu; + glibtop_proc_time proctime; + + glibtop_get_cpu(&cpu); + glibtop_get_proc_time(&proctime, getpid()); + + this->interval = ProcData::get_instance()->config.update_interval; + this->last_pcpu = PCPU_LO; + this->last_total_time = cpu.total; + this->last_cpu_time = proctime.rtime; +} + + + +SmoothRefresh::~SmoothRefresh() +{ + if (this->connection) + mateconf_client_notify_remove(mateconf_client_get_default(), + this->connection); +} + + + +bool +SmoothRefresh::get(guint &new_interval) +{ + const unsigned config_interval = ProcData::get_instance()->config.update_interval; + + g_assert(this->interval >= config_interval); + + if (not this->active) + return false; + + + const unsigned pcpu = this->get_own_cpu_usage(); + /* + invariant: MAX_UPDATE_INTERVAL >= interval >= config_interval >= MIN_UPDATE_INTERVAL + + i see 3 cases: + + a) interval is too big (CPU usage < 10%) + -> increase interval + + b) interval is too small (CPU usage > 10%) AND interval != config_interval + > + -> decrease interval + + c) interval is config_interval (start or interval is perfect) + + */ + + if (pcpu > PCPU_HI && this->last_pcpu > PCPU_HI) + new_interval = this->interval * 11 / 10; + else if (this->interval != config_interval && pcpu < PCPU_LO && this->last_pcpu < PCPU_LO) + new_interval = this->interval * 9 / 10; + else + new_interval = this->interval; + + new_interval = CLAMP(new_interval, config_interval, config_interval * 2); + new_interval = CLAMP(new_interval, MIN_UPDATE_INTERVAL, MAX_UPDATE_INTERVAL); + + bool changed = this->interval != new_interval; + + if (changed) + this->interval = new_interval; + + this->last_pcpu = pcpu; + + + if (changed) { + procman_debug("CPU usage is %3u%%, changed refresh_interval to %u (config %u)", + this->last_pcpu, + this->interval, + config_interval); + } + + g_assert(this->interval == new_interval); + g_assert(this->interval >= config_interval); + + return changed; +} + |