summaryrefslogtreecommitdiffstats
path: root/pcp/Platform.c
diff options
context:
space:
mode:
authorNathan Scott <nathans@redhat.com>2021-02-17 14:43:56 +1100
committerNathan Scott <nathans@redhat.com>2021-06-09 17:09:29 +1000
commitc14a45ba359148fa0abe7ab72ed8ea0c1aa1ce28 (patch)
treee1814f53637daab6e8a781e317a3a5a1915a0144 /pcp/Platform.c
parentd075d49a0ccd3f311bc0f3d2b4c9f542aff1d613 (diff)
Add a platform for Performance Co-Pilot (PCP) metrics
This introduces an initial platform for extracting metrics using the PCP performance metrics API - PMAPI(3). It can be used via the --enable-pcp=yes configure option. So far I've added support for live localhost metrics only, and only using pre-defined metrics already found in htop. If available, all sampling is performed by pmcd(1) - else, we fallback to htop doing the metric sampling itself (all below the PMAPI). When pmcd is used, it may be configured to run children with elevated privileges, so htop does not need to be setuid (authentication with pmcd is available). Additionally, the PMAPI allows us to support archives (for historical analysis and for automated regression tests in htop). We'll need platform-specific command line argument additions, which isn't yet feasible in htop (not difficult to add though). The goal of this first version is minimal impact in terms of modifying the htop codebase, to introduce key ideas in PCP (metric namespace, metadata, APIs and so on) and give us something to discuss, experiment with and build on.
Diffstat (limited to 'pcp/Platform.c')
-rw-r--r--pcp/Platform.c687
1 files changed, 687 insertions, 0 deletions
diff --git a/pcp/Platform.c b/pcp/Platform.c
new file mode 100644
index 00000000..4ac7c701
--- /dev/null
+++ b/pcp/Platform.c
@@ -0,0 +1,687 @@
+/*
+htop - linux/Platform.c
+(C) 2014 Hisham H. Muhammad
+(C) 2020 htop dev team
+(C) 2020-2021 Red Hat, Inc. All Rights Reserved.
+Released under the GNU GPLv2, see the COPYING file
+in the source distribution for its full text.
+*/
+
+#include "config.h"
+
+#include "Platform.h"
+
+#include <math.h>
+
+#include "BatteryMeter.h"
+#include "ClockMeter.h"
+#include "Compat.h"
+#include "CPUMeter.h"
+#include "DateMeter.h"
+#include "DateTimeMeter.h"
+#include "DiskIOMeter.h"
+#include "HostnameMeter.h"
+#include "LoadAverageMeter.h"
+#include "Macros.h"
+#include "MainPanel.h"
+#include "MemoryMeter.h"
+#include "Meter.h"
+#include "NetworkIOMeter.h"
+#include "Object.h"
+#include "Panel.h"
+#include "PCPProcess.h"
+#include "PCPProcessList.h"
+#include "ProcessList.h"
+#include "ProvideCurses.h"
+#include "Settings.h"
+#include "SwapMeter.h"
+#include "TasksMeter.h"
+#include "UptimeMeter.h"
+#include "XUtils.h"
+
+#include "linux/PressureStallMeter.h"
+#include "linux/ZramMeter.h"
+#include "linux/ZramStats.h"
+
+typedef struct Platform_ {
+ int context; /* PMAPI(3) context identifier */
+ unsigned int total; /* total number of all metrics */
+ const char** names; /* name array indexed by Metric */
+ pmID* pmids; /* all known metric identifiers */
+ pmID* fetch; /* enabled identifiers for sampling */
+ pmDesc* descs; /* metric desc array indexed by Metric */
+ pmResult* result; /* sample values result indexed by Metric */
+
+ long long btime; /* boottime in seconds since the epoch */
+ int pidmax; /* maximum platform process identifier */
+ int ncpu; /* maximum processor count configured */
+} Platform;
+
+Platform* pcp;
+
+ProcessField Platform_defaultFields[] = { PID, USER, PRIORITY, NICE, M_VIRT, M_RESIDENT, (int)M_SHARE, STATE, PERCENT_CPU, PERCENT_MEM, TIME, COMM, 0 };
+
+int Platform_numberOfFields = LAST_PROCESSFIELD;
+
+const SignalItem Platform_signals[] = {
+ { .name = " 0 Cancel", .number = 0 },
+};
+
+const unsigned int Platform_numberOfSignals = ARRAYSIZE(Platform_signals);
+
+const MeterClass* const Platform_meterTypes[] = {
+ &CPUMeter_class,
+ &ClockMeter_class,
+ &DateMeter_class,
+ &DateTimeMeter_class,
+ &LoadAverageMeter_class,
+ &LoadMeter_class,
+ &MemoryMeter_class,
+ &SwapMeter_class,
+ &TasksMeter_class,
+ &UptimeMeter_class,
+ &BatteryMeter_class,
+ &HostnameMeter_class,
+ &AllCPUsMeter_class,
+ &AllCPUs2Meter_class,
+ &AllCPUs4Meter_class,
+ &AllCPUs8Meter_class,
+ &LeftCPUsMeter_class,
+ &RightCPUsMeter_class,
+ &LeftCPUs2Meter_class,
+ &RightCPUs2Meter_class,
+ &LeftCPUs4Meter_class,
+ &RightCPUs4Meter_class,
+ &LeftCPUs8Meter_class,
+ &RightCPUs8Meter_class,
+ &BlankMeter_class,
+ &PressureStallCPUSomeMeter_class,
+ &PressureStallIOSomeMeter_class,
+ &PressureStallIOFullMeter_class,
+ &PressureStallMemorySomeMeter_class,
+ &PressureStallMemoryFullMeter_class,
+ &ZramMeter_class,
+ &DiskIOMeter_class,
+ &NetworkIOMeter_class,
+ NULL
+};
+
+static const char *Platform_metricNames[] = {
+ [PCP_CONTROL_THREADS] = "proc.control.perclient.threads",
+
+ [PCP_HINV_NCPU] = "hinv.ncpu",
+ [PCP_HINV_CPUCLOCK] = "hinv.cpu.clock",
+ [PCP_UNAME_SYSNAME] = "kernel.uname.sysname",
+ [PCP_UNAME_RELEASE] = "kernel.uname.release",
+ [PCP_UNAME_MACHINE] = "kernel.uname.machine",
+ [PCP_LOAD_AVERAGE] = "kernel.all.load",
+ [PCP_PID_MAX] = "kernel.all.pid_max",
+ [PCP_UPTIME] = "kernel.all.uptime",
+ [PCP_BOOTTIME] = "kernel.all.boottime",
+ [PCP_CPU_USER] = "kernel.all.cpu.user",
+ [PCP_CPU_NICE] = "kernel.all.cpu.nice",
+ [PCP_CPU_SYSTEM] = "kernel.all.cpu.sys",
+ [PCP_CPU_IDLE] = "kernel.all.cpu.idle",
+ [PCP_CPU_IOWAIT] = "kernel.all.cpu.wait.total",
+ [PCP_CPU_IRQ] = "kernel.all.cpu.intr",
+ [PCP_CPU_SOFTIRQ] = "kernel.all.cpu.irq.soft",
+ [PCP_CPU_STEAL] = "kernel.all.cpu.steal",
+ [PCP_CPU_GUEST] = "kernel.all.cpu.guest",
+ [PCP_CPU_GUESTNICE] = "kernel.all.cpu.guest_nice",
+ [PCP_PERCPU_USER] = "kernel.percpu.cpu.user",
+ [PCP_PERCPU_NICE] = "kernel.percpu.cpu.nice",
+ [PCP_PERCPU_SYSTEM] = "kernel.percpu.cpu.sys",
+ [PCP_PERCPU_IDLE] = "kernel.percpu.cpu.idle",
+ [PCP_PERCPU_IOWAIT] = "kernel.percpu.cpu.wait.total",
+ [PCP_PERCPU_IRQ] = "kernel.percpu.cpu.intr",
+ [PCP_PERCPU_SOFTIRQ] = "kernel.percpu.cpu.irq.soft",
+ [PCP_PERCPU_STEAL] = "kernel.percpu.cpu.steal",
+ [PCP_PERCPU_GUEST] = "kernel.percpu.cpu.guest",
+ [PCP_PERCPU_GUESTNICE] = "kernel.percpu.cpu.guest_nice",
+ [PCP_MEM_TOTAL] = "mem.physmem",
+ [PCP_MEM_FREE] = "mem.util.free",
+ [PCP_MEM_AVAILABLE] = "mem.util.available",
+ [PCP_MEM_BUFFERS] = "mem.util.bufmem",
+ [PCP_MEM_CACHED] = "mem.util.cached",
+ [PCP_MEM_SRECLAIM] = "mem.util.slabReclaimable",
+ [PCP_MEM_SWAPCACHED] = "mem.util.swapCached",
+ [PCP_MEM_SWAPTOTAL] = "mem.util.swapTotal",
+ [PCP_MEM_SWAPFREE] = "mem.util.swapFree",
+ [PCP_DISK_READB] = "disk.all.read_bytes",
+ [PCP_DISK_WRITEB] = "disk.all.write_bytes",
+ [PCP_DISK_ACTIVE] = "disk.all.avactive",
+ [PCP_NET_RECVB] = "network.all.in.bytes",
+ [PCP_NET_SENDB] = "network.all.out.bytes",
+ [PCP_NET_RECVP] = "network.all.in.packets",
+ [PCP_NET_SENDP] = "network.all.out.packets",
+
+ [PCP_PSI_CPUSOME] = "kernel.all.pressure.cpu.some.avg",
+ [PCP_PSI_IOSOME] = "kernel.all.pressure.io.some.avg",
+ [PCP_PSI_IOFULL] = "kernel.all.pressure.io.full.avg",
+ [PCP_PSI_MEMSOME] = "kernel.all.pressure.memory.some.avg",
+ [PCP_PSI_MEMFULL] = "kernel.all.pressure.memory.full.avg",
+
+ [PCP_ZRAM_CAPACITY] = "zram.capacity",
+ [PCP_ZRAM_ORIGINAL] = "zram.mm_stat.data_size.original",
+ [PCP_ZRAM_COMPRESSED] = "zram.mm_stat.data_size.compressed",
+
+ [PCP_PROC_PID] = "proc.psinfo.pid",
+ [PCP_PROC_PPID] = "proc.psinfo.ppid",
+ [PCP_PROC_TGID] = "proc.psinfo.tgid",
+ [PCP_PROC_PGRP] = "proc.psinfo.pgrp",
+ [PCP_PROC_SESSION] = "proc.psinfo.session",
+ [PCP_PROC_STATE] = "proc.psinfo.sname",
+ [PCP_PROC_TTY] = "proc.psinfo.tty",
+ [PCP_PROC_TTYPGRP] = "proc.psinfo.tty_pgrp",
+ [PCP_PROC_MINFLT] = "proc.psinfo.minflt",
+ [PCP_PROC_MAJFLT] = "proc.psinfo.maj_flt",
+ [PCP_PROC_CMINFLT] = "proc.psinfo.cmin_flt",
+ [PCP_PROC_CMAJFLT] = "proc.psinfo.cmaj_flt",
+ [PCP_PROC_UTIME] = "proc.psinfo.utime",
+ [PCP_PROC_STIME] = "proc.psinfo.stime",
+ [PCP_PROC_CUTIME] = "proc.psinfo.cutime",
+ [PCP_PROC_CSTIME] = "proc.psinfo.cstime",
+ [PCP_PROC_PRIORITY] = "proc.psinfo.priority",
+ [PCP_PROC_NICE] = "proc.psinfo.nice",
+ [PCP_PROC_THREADS] = "proc.psinfo.threads",
+ [PCP_PROC_STARTTIME] = "proc.psinfo.start_time",
+ [PCP_PROC_PROCESSOR] = "proc.psinfo.processor",
+ [PCP_PROC_CMD] = "proc.psinfo.cmd",
+ [PCP_PROC_PSARGS] = "proc.psinfo.psargs",
+ [PCP_PROC_CGROUPS] = "proc.psinfo.cgroups",
+ [PCP_PROC_OOMSCORE] = "proc.psinfo.oom_score",
+ [PCP_PROC_VCTXSW] = "proc.psinfo.vctxsw",
+ [PCP_PROC_NVCTXSW] = "proc.psinfo.nvctxsw",
+ [PCP_PROC_LABELS] = "proc.psinfo.labels",
+ [PCP_PROC_ENVIRON] = "proc.psinfo.environ",
+ [PCP_PROC_TTYNAME] = "proc.psinfo.ttyname",
+ [PCP_PROC_ID_UID] = "proc.id.uid",
+ [PCP_PROC_ID_USER] = "proc.id.uid_nm",
+ [PCP_PROC_IO_RCHAR] = "proc.io.rchar",
+ [PCP_PROC_IO_WCHAR] = "proc.io.wchar",
+ [PCP_PROC_IO_SYSCR] = "proc.io.syscr",
+ [PCP_PROC_IO_SYSCW] = "proc.io.syscw",
+ [PCP_PROC_IO_READB] = "proc.io.read_bytes",
+ [PCP_PROC_IO_WRITEB] = "proc.io.write_bytes",
+ [PCP_PROC_IO_CANCELLED] = "proc.io.cancelled_write_bytes",
+ [PCP_PROC_MEM_SIZE] = "proc.memory.size",
+ [PCP_PROC_MEM_RSS] = "proc.memory.rss",
+ [PCP_PROC_MEM_SHARE] = "proc.memory.share",
+ [PCP_PROC_MEM_TEXTRS] = "proc.memory.textrss",
+ [PCP_PROC_MEM_LIBRS] = "proc.memory.librss",
+ [PCP_PROC_MEM_DATRS] = "proc.memory.datrss",
+ [PCP_PROC_MEM_DIRTY] = "proc.memory.dirty",
+ [PCP_PROC_SMAPS_PSS] = "proc.smaps.pss",
+ [PCP_PROC_SMAPS_SWAP] = "proc.smaps.swap",
+ [PCP_PROC_SMAPS_SWAPPSS] = "proc.smaps.swappss",
+
+ [PCP_METRIC_COUNT] = NULL
+};
+
+pmAtomValue* Metric_values(Metric metric, pmAtomValue *atom, int count, int type) {
+
+ pmValueSet* vset = pcp->result->vset[metric];
+ if (!vset || vset->numval <= 0)
+ return NULL;
+
+ /* allocate space for atom if needed */
+ if (!atom || !count) {
+ if (!count)
+ count = vset->numval;
+ atom = xCalloc(count, sizeof(pmAtomValue));
+ }
+
+ /* extract requested number of values as requested type */
+ const pmDesc* desc = &pcp->descs[metric];
+ for (int i = 0; i < vset->numval; i++) {
+ if (i == count)
+ break;
+ const pmValue *value = &vset->vlist[i];
+ int sts = pmExtractValue(vset->valfmt, value, desc->type, &atom[i], type);
+ if (sts < 0) {
+ if (pmDebugOptions.appl0)
+ fprintf(stderr, "Error: cannot extract metric value: %s\n",
+ pmErrStr(sts));
+ memset(&atom[i], 0, sizeof(pmAtomValue));
+ }
+ }
+ return atom;
+}
+
+int Metric_instanceCount(Metric metric) {
+ pmValueSet* vset = pcp->result->vset[metric];
+ if (vset)
+ return vset->numval;
+ return 0;
+}
+
+int Metric_instanceOffset(Metric metric, int inst) {
+ pmValueSet* vset = pcp->result->vset[metric];
+ if (!vset || vset->numval <= 0)
+ return 0;
+
+ /* search for optimal offset for subsequent inst lookups to begin */
+ for (int i = 0; i < vset->numval; i++) {
+ if (inst == vset->vlist[i].inst)
+ return i;
+ }
+ return 0;
+}
+
+static pmAtomValue *Metric_extract(Metric metric, int inst, int offset, pmValueSet *vset, pmAtomValue *atom, int type) {
+
+ /* extract value (using requested type) of given metric instance */
+ const pmDesc* desc = &pcp->descs[metric];
+ const pmValue *value = &vset->vlist[offset];
+ int sts = pmExtractValue(vset->valfmt, value, desc->type, atom, type);
+ if (sts < 0) {
+ if (pmDebugOptions.appl0)
+ fprintf(stderr, "Error: cannot extract %s instance %d value: %s\n",
+ pcp->names[metric], inst, pmErrStr(sts));
+ memset(atom, 0, sizeof(pmAtomValue));
+ }
+ return atom;
+}
+
+pmAtomValue *Metric_instance(Metric metric, int inst, int offset, pmAtomValue *atom, int type) {
+
+ pmValueSet* vset = pcp->result->vset[metric];
+ if (!vset || vset->numval <= 0)
+ return NULL;
+
+ /* fast-path using heuristic offset based on expected location */
+ if (offset >= 0 && offset < vset->numval && inst == vset->vlist[offset].inst)
+ return Metric_extract(metric, inst, offset, vset, atom, type);
+
+ /* slow-path using a linear search for the requested instance */
+ for (int i = 0; i < vset->numval; i++) {
+ if (inst == vset->vlist[i].inst)
+ return Metric_extract(metric, inst, i, vset, atom, type);
+ }
+ return NULL;
+}
+
+/*
+ * Iterate over a set of instances (incl PM_IN_NULL)
+ * returning the next instance identifier and offset.
+ *
+ * Start it off by passing offset -1 into the routine.
+ */
+bool Metric_iterate(Metric metric, int* instp, int* offsetp) {
+ pmValueSet* vset = pcp->result->vset[metric];
+ if (!vset || vset->numval <= 0)
+ return false;
+
+ int offset = *offsetp;
+ offset = (offset < 0) ? 0 : offset + 1;
+ if (offset > vset->numval - 1)
+ return false;
+
+ *offsetp = offset;
+ *instp = vset->vlist[offset].inst;
+ return true;
+}
+
+/* Switch on/off a metric for value fetching (sampling) */
+void Metric_enable(Metric metric, bool enable) {
+ pcp->fetch[metric] = enable ? pcp->pmids[metric] : PM_ID_NULL;
+}
+
+bool Metric_enabled(Metric metric) {
+ return pcp->fetch[metric] != PM_ID_NULL;
+}
+
+void Metric_enableThreads(void) {
+ pmValueSet* vset = xCalloc(1, sizeof(pmValueSet));
+ vset->vlist[0].inst = PM_IN_NULL;
+ vset->vlist[0].value.lval = 1;
+ vset->valfmt = PM_VAL_INSITU;
+ vset->numval = 1;
+ vset->pmid = pcp->pmids[PCP_CONTROL_THREADS];
+
+ pmResult* result = xCalloc(1, sizeof(pmResult));
+ result->vset[0] = vset;
+ result->numpmid = 1;
+
+ int sts = pmStore(result);
+ if (sts < 0 && pmDebugOptions.appl0)
+ fprintf(stderr, "Error: cannot enable threads: %s\n", pmErrStr(sts));
+
+ pmFreeResult(result);
+}
+
+bool Metric_fetch(struct timeval *timestamp) {
+ int sts = pmFetch(pcp->total, pcp->fetch, &pcp->result);
+ if (sts < 0) {
+ if (pmDebugOptions.appl0)
+ fprintf(stderr, "Error: cannot fetch metric values): %s\n",
+ pmErrStr(sts));
+ return false;
+ }
+ if (timestamp)
+ *timestamp = pcp->result->timestamp;
+ return true;
+}
+
+static int Platform_addMetric(Metric id, const char *name) {
+ unsigned int i = (unsigned int)id;
+
+ if (i >= PCP_METRIC_COUNT && i >= pcp->total) {
+ /* added via configuration files */
+ unsigned int j = pcp->total + 1;
+ pcp->fetch = xRealloc(pcp->fetch, j * sizeof(pmID));
+ pcp->pmids = xRealloc(pcp->pmids, j * sizeof(pmID));
+ pcp->names = xRealloc(pcp->names, j * sizeof(char*));
+ pcp->descs = xRealloc(pcp->descs, j * sizeof(pmDesc));
+ memset(&pcp->descs[i], 0, sizeof(pmDesc));
+ }
+
+ pcp->pmids[i] = pcp->fetch[i] = PM_ID_NULL;
+ pcp->names[i] = name;
+ return ++pcp->total;
+}
+
+void Platform_init(void) {
+ int sts = pmNewContext(PM_CONTEXT_HOST, "local:");
+ if (sts < 0)
+ sts = pmNewContext(PM_CONTEXT_LOCAL, NULL);
+ if (sts < 0) {
+ fprintf(stderr, "Cannot setup PCP metric source: %s\n", pmErrStr(sts));
+ exit(1);
+ }
+ pcp = xCalloc(1, sizeof(Platform));
+ pcp->context = sts;
+ pcp->fetch = xCalloc(PCP_METRIC_COUNT, sizeof(pmID));
+ pcp->pmids = xCalloc(PCP_METRIC_COUNT, sizeof(pmID));
+ pcp->names = xCalloc(PCP_METRIC_COUNT, sizeof(char*));
+ pcp->descs = xCalloc(PCP_METRIC_COUNT, sizeof(pmDesc));
+
+ for (unsigned int i = 0; i < PCP_METRIC_COUNT; i++)
+ Platform_addMetric(i, Platform_metricNames[i]);
+
+ sts = pmLookupName(pcp->total, pcp->names, pcp->pmids);
+ if (sts < 0) {
+ fprintf(stderr, "Error: cannot lookup metric names: %s\n", pmErrStr(sts));
+ exit(1);
+ }
+
+ for (unsigned int i = 0; i < pcp->total; i++) {
+ pcp->fetch[i] = PM_ID_NULL; /* default is to not sample */
+
+ /* expect some metrics to be missing - e.g. PMDA not available */
+ if (pcp->pmids[i] == PM_ID_NULL)
+ continue;
+
+ sts = pmLookupDesc(pcp->pmids[i], &pcp->descs[i]);
+ if (sts < 0) {
+ if (pmDebugOptions.appl0)
+ fprintf(stderr, "Error: cannot lookup metric %s(%s): %s\n",
+ pcp->names[i], pmIDStr(pcp->pmids[i]), pmErrStr(sts));
+ pcp->pmids[i] = PM_ID_NULL;
+ continue;
+ }
+ }
+
+ /* set proc.control.perclient.threads to 1 for live contexts */
+ Metric_enableThreads();
+
+ /* extract values needed for setup - e.g. cpu count, pid_max */
+ Metric_enable(PCP_PID_MAX, true);
+ Metric_enable(PCP_BOOTTIME, true);
+ Metric_enable(PCP_HINV_NCPU, true);
+ Metric_enable(PCP_PERCPU_SYSTEM, true);
+ Metric_enable(PCP_UNAME_SYSNAME, true);
+ Metric_enable(PCP_UNAME_RELEASE, true);
+ Metric_enable(PCP_UNAME_MACHINE, true);
+
+ Metric_fetch(NULL);
+
+ for (Metric metric = 0; metric < PCP_PROC_PID; metric++)
+ Metric_enable(metric, true);
+ Metric_enable(PCP_PID_MAX, false); /* needed one time only */
+ Metric_enable(PCP_BOOTTIME, false);
+ Metric_enable(PCP_UNAME_SYSNAME, false);
+ Metric_enable(PCP_UNAME_RELEASE, false);
+ Metric_enable(PCP_UNAME_MACHINE, false);
+
+ /* first sample (fetch) performed above, save constants */
+ Platform_getBootTime();
+ Platform_getMaxCPU();
+ Platform_getMaxPid();
+}
+
+void Platform_done(void) {
+ pmDestroyContext(pcp->context);
+ free(pcp->fetch);
+ free(pcp->pmids);
+ free(pcp->names);
+ free(pcp->descs);
+ free(pcp);
+}
+
+void Platform_setBindings(Htop_Action* keys) {
+ /* no platform-specific key bindings */
+ (void)keys;
+}
+
+int Platform_getUptime(void) {
+ pmAtomValue value;
+ if (Metric_values(PCP_UPTIME, &value, 1, PM_TYPE_32) == NULL)
+ return 0;
+ return value.l;
+}
+
+void Platform_getLoadAverage(double* one, double* five, double* fifteen) {
+ *one = *five = *fifteen = 0.0;
+
+ pmAtomValue values[3] = {0};
+ if (Metric_values(PCP_LOAD_AVERAGE, values, 3, PM_TYPE_DOUBLE) != NULL) {
+ *one = values[0].d;
+ *five = values[1].d;
+ *fifteen = values[2].d;
+ }
+}
+
+int Platform_getMaxCPU(void) {
+ if (pcp->ncpu)
+ return pcp->ncpu;
+
+ pmAtomValue value;
+ if (Metric_values(PCP_HINV_NCPU, &value, 1, PM_TYPE_32) != NULL)
+ pcp->ncpu = value.l;
+ else
+ pcp->ncpu = -1;
+ return pcp->ncpu;
+}
+
+int Platform_getMaxPid(void) {
+ if (pcp->pidmax)
+ return pcp->pidmax;
+
+ pmAtomValue value;
+ if (Metric_values(PCP_PID_MAX, &value, 1, PM_TYPE_32) == NULL)
+ return -1;
+ pcp->pidmax = value.l;
+ return pcp->pidmax;
+}
+
+long long Platform_getBootTime(void) {
+ if (pcp->btime)
+ return pcp->btime;
+
+ pmAtomValue value;
+ if (Metric_values(PCP_BOOTTIME, &value, 1, PM_TYPE_64) != NULL)
+ pcp->btime = value.ll;
+ return pcp->btime;
+}
+
+static double Platform_setOneCPUValues(Meter* this, pmAtomValue* values) {
+
+ unsigned long long value = values[CPU_TOTAL_PERIOD].ull;
+ double total = (double) (value == 0 ? 1 : value);
+ double percent;
+
+ double* v = this->values;
+ v[CPU_METER_NICE] = values[CPU_NICE_PERIOD].ull / total * 100.0;
+ v[CPU_METER_NORMAL] = values[CPU_USER_PERIOD].ull / total * 100.0;
+ if (this->pl->settings->detailedCPUTime) {
+ v[CPU_METER_KERNEL] = values[CPU_SYSTEM_PERIOD].ull / total * 100.0;
+ v[CPU_METER_IRQ] = values[CPU_IRQ_PERIOD].ull / total * 100.0;
+ v[CPU_METER_SOFTIRQ] = values[CPU_SOFTIRQ_PERIOD].ull / total * 100.0;
+ v[CPU_METER_STEAL] = values[CPU_STEAL_PERIOD].ull / total * 100.0;
+ v[CPU_METER_GUEST] = values[CPU_GUEST_PERIOD].ull / total * 100.0;
+ v[CPU_METER_IOWAIT] = values[CPU_IOWAIT_PERIOD].ull / total * 100.0;
+ this->curItems = 8;
+ if (this->pl->settings->accountGuestInCPUMeter)
+ percent = v[0] + v[1] + v[2] + v[3] + v[4] + v[5] + v[6];
+ else
+ percent = v[0] + v[1] + v[2] + v[3] + v[4];
+ } else {
+ v[2] = values[CPU_SYSTEM_ALL_PERIOD].ull / total * 100.0;
+ value = values[CPU_STEAL_PERIOD].ull + values[CPU_GUEST_PERIOD].ull;
+ v[3] = value / total * 100.0;
+ this->curItems = 4;
+ percent = v[0] + v[1] + v[2] + v[3];
+ }
+ percent = CLAMP(percent, 0.0, 100.0);
+ if (isnan(percent))
+ percent = 0.0;
+
+ v[CPU_METER_FREQUENCY] = values[CPU_FREQUENCY].d;
+ v[CPU_METER_TEMPERATURE] = NAN;
+
+ return percent;
+}
+
+double Platform_setCPUValues(Meter* this, int cpu) {
+ const PCPProcessList* pl = (const PCPProcessList*) this->pl;
+ if (cpu <= 0) /* use aggregate values */
+ return Platform_setOneCPUValues(this, pl->cpu);
+ return Platform_setOneCPUValues(this, pl->percpu[cpu - 1]);
+}
+
+void Platform_setMemoryValues(Meter* this) {
+ const ProcessList* pl = this->pl;
+ long int usedMem = pl->usedMem;
+ long int buffersMem = pl->buffersMem;
+ long int cachedMem = pl->cachedMem;
+ usedMem -= buffersMem + cachedMem;
+ this->total = pl->totalMem;
+ this->values[0] = usedMem;
+ this->values[1] = buffersMem;
+ this->values[2] = cachedMem;
+}
+
+void Platform_setSwapValues(Meter* this) {
+ const ProcessList* pl = this->pl;
+ this->total = pl->totalSwap;
+ this->values[0] = pl->usedSwap;
+ this->values[1] = pl->cachedSwap;
+}
+
+void Platform_setZramValues(Meter* this) {
+ (void)this;
+
+ int i, count = Metric_instanceCount(PCP_ZRAM_CAPACITY);
+ pmAtomValue *values = xCalloc(count, sizeof(pmAtomValue));
+ ZramStats stats = {0};
+
+ if (Metric_values(PCP_ZRAM_CAPACITY, values, count, PM_TYPE_U64)) {
+ for (i = 0; i < count; i++)
+ stats.totalZram += values[i].ull;
+ }
+ if (Metric_values(PCP_ZRAM_ORIGINAL, values, count, PM_TYPE_U64)) {
+ for (i = 0; i < count; i++)
+ stats.usedZramOrig += values[i].ull;
+ }
+ if (Metric_values(PCP_ZRAM_COMPRESSED, values, count, PM_TYPE_U64)) {
+ for (i = 0; i < count; i++)
+ stats.usedZramComp += values[i].ull;
+ }
+
+ free(values);
+
+ this->total = stats.totalZram;
+ this->values[0] = stats.usedZramComp;
+ this->values[1] = stats.usedZramOrig;
+}
+
+char* Platform_getProcessEnv(pid_t pid) {
+ pmAtomValue value;
+ if (!Metric_instance(PCP_PROC_ENVIRON, pid, 0, &value, PM_TYPE_STRING))
+ return NULL;
+ return value.cp;
+}
+
+char* Platform_getInodeFilename(pid_t pid, ino_t inode) {
+ (void)pid;
+ (void)inode;
+ return NULL;
+}
+
+FileLocks_ProcessData* Platform_getProcessLocks(pid_t pid) {
+ (void)pid;
+ return NULL;
+}
+
+void Platform_getPressureStall(const char* file, bool some, double* ten, double* sixty, double* threehundred) {
+ *ten = *sixty = *threehundred = 0;
+
+ Metric metric;
+ if (String_eq(file, "cpu"))
+ metric = PCP_PSI_CPUSOME;
+ else if (String_eq(file, "io"))
+ metric = some ? PCP_PSI_IOSOME : PCP_PSI_IOFULL;
+ else if (String_eq(file, "mem"))
+ metric = some ? PCP_PSI_MEMSOME : PCP_PSI_MEMFULL;
+ else
+ return;
+
+ pmAtomValue values[3] = {0};
+ if (Metric_values(metric, values, 3, PM_TYPE_DOUBLE) != NULL) {
+ *ten = values[0].d;
+ *sixty = values[1].d;
+ *threehundred = values[2].d;
+ }
+}
+
+bool Platform_getDiskIO(DiskIOData* data) {
+ data->totalBytesRead = 0;
+ data->totalBytesWritten = 0;
+ data->totalMsTimeSpend = 0;
+
+ pmAtomValue value;
+ if (Metric_values(PCP_DISK_READB, &value, 1, PM_TYPE_U64) != NULL)
+ data->totalBytesRead = value.ull;
+ if (Metric_values(PCP_DISK_WRITEB, &value, 1, PM_TYPE_U64) != NULL)
+ data->totalBytesWritten = value.ull;
+ if (Metric_values(PCP_DISK_ACTIVE, &value, 1, PM_TYPE_U64) != NULL)
+ data->totalMsTimeSpend = value.ull;
+ return true;
+}
+
+bool Platform_getNetworkIO(unsigned long int* bytesReceived,
+ unsigned long int* packetsReceived,
+ unsigned long int* bytesTransmitted,
+ unsigned long int* packetsTransmitted) {
+ *bytesReceived = 0;
+ *packetsReceived = 0;
+ *bytesTransmitted = 0;
+ *packetsTransmitted = 0;
+
+ pmAtomValue value;
+ if (Metric_values(PCP_NET_RECVB, &value, 1, PM_TYPE_U64) != NULL)
+ *bytesReceived = value.ull;
+ if (Metric_values(PCP_NET_SENDB, &value, 1, PM_TYPE_U64) != NULL)
+ *bytesTransmitted = value.ull;
+ if (Metric_values(PCP_NET_RECVP, &value, 1, PM_TYPE_U64) != NULL)
+ *packetsReceived = value.ull;
+ if (Metric_values(PCP_NET_SENDP, &value, 1, PM_TYPE_U64) != NULL)
+ *packetsTransmitted = value.ull;
+ return true;
+}
+
+void Platform_getBattery(double* level, ACPresence* isOnAC) {
+ *level = NAN;
+ *isOnAC = AC_ERROR;
+}

© 2014-2024 Faster IT GmbH | imprint | privacy policy