aboutsummaryrefslogtreecommitdiffstats
path: root/linux/LinuxProcessList.c
diff options
context:
space:
mode:
authorDaniel Lange <DLange@git.local>2016-04-11 13:01:07 +0200
committerDaniel Lange <DLange@git.local>2016-04-11 13:01:07 +0200
commitff9409b1737627857eb47f64f536a3f66b6a09a4 (patch)
tree61b631ba551e68a4f656b8b76ff7bd0d9955fc64 /linux/LinuxProcessList.c
parentf75ab6d2c11e8a8e18191b087564aedebbeb96c5 (diff)
downloaddebian_htop-ff9409b1737627857eb47f64f536a3f66b6a09a4.tar.gz
debian_htop-ff9409b1737627857eb47f64f536a3f66b6a09a4.tar.bz2
debian_htop-ff9409b1737627857eb47f64f536a3f66b6a09a4.zip
Imported Upstream version 2.0.0upstream/2.0.0
Diffstat (limited to 'linux/LinuxProcessList.c')
-rw-r--r--linux/LinuxProcessList.c775
1 files changed, 775 insertions, 0 deletions
diff --git a/linux/LinuxProcessList.c b/linux/LinuxProcessList.c
new file mode 100644
index 0000000..591210e
--- /dev/null
+++ b/linux/LinuxProcessList.c
@@ -0,0 +1,775 @@
+/*
+htop - LinuxProcessList.c
+(C) 2014 Hisham H. Muhammad
+Released under the GNU GPL, see the COPYING file
+in the source distribution for its full text.
+*/
+
+#include "LinuxProcessList.h"
+#include "LinuxProcess.h"
+#include "CRT.h"
+#include "StringUtils.h"
+#include <errno.h>
+#include <sys/time.h>
+#include <sys/utsname.h>
+#include <sys/stat.h>
+#include <unistd.h>
+#include <dirent.h>
+#include <stdlib.h>
+#include <stdio.h>
+#include <signal.h>
+#include <stdbool.h>
+#include <stdarg.h>
+#include <math.h>
+#include <string.h>
+#include <time.h>
+#include <assert.h>
+#include <sys/types.h>
+#include <fcntl.h>
+
+/*{
+
+#include "ProcessList.h"
+
+typedef struct CPUData_ {
+ unsigned long long int totalTime;
+ unsigned long long int userTime;
+ unsigned long long int systemTime;
+ unsigned long long int systemAllTime;
+ unsigned long long int idleAllTime;
+ unsigned long long int idleTime;
+ unsigned long long int niceTime;
+ unsigned long long int ioWaitTime;
+ unsigned long long int irqTime;
+ unsigned long long int softIrqTime;
+ unsigned long long int stealTime;
+ unsigned long long int guestTime;
+
+ unsigned long long int totalPeriod;
+ unsigned long long int userPeriod;
+ unsigned long long int systemPeriod;
+ unsigned long long int systemAllPeriod;
+ unsigned long long int idleAllPeriod;
+ unsigned long long int idlePeriod;
+ unsigned long long int nicePeriod;
+ unsigned long long int ioWaitPeriod;
+ unsigned long long int irqPeriod;
+ unsigned long long int softIrqPeriod;
+ unsigned long long int stealPeriod;
+ unsigned long long int guestPeriod;
+} CPUData;
+
+typedef struct LinuxProcessList_ {
+ ProcessList super;
+
+ CPUData* cpus;
+
+} LinuxProcessList;
+
+#ifndef PROCDIR
+#define PROCDIR "/proc"
+#endif
+
+#ifndef PROCSTATFILE
+#define PROCSTATFILE PROCDIR "/stat"
+#endif
+
+#ifndef PROCMEMINFOFILE
+#define PROCMEMINFOFILE PROCDIR "/meminfo"
+#endif
+
+#ifndef PROC_LINE_LENGTH
+#define PROC_LINE_LENGTH 512
+#endif
+
+}*/
+
+#ifndef CLAMP
+#define CLAMP(x,low,high) (((x)>(high))?(high):(((x)<(low))?(low):(x)))
+#endif
+
+ProcessList* ProcessList_new(UsersTable* usersTable, Hashtable* pidWhiteList, uid_t userId) {
+ LinuxProcessList* this = xCalloc(1, sizeof(LinuxProcessList));
+ ProcessList* pl = &(this->super);
+ ProcessList_init(pl, Class(LinuxProcess), usersTable, pidWhiteList, userId);
+
+ // Update CPU count:
+ FILE* file = fopen(PROCSTATFILE, "r");
+ if (file == NULL) {
+ CRT_fatalError("Cannot open " PROCSTATFILE);
+ }
+ char buffer[PROC_LINE_LENGTH + 1];
+ int cpus = -1;
+ do {
+ cpus++;
+ char * s = fgets(buffer, PROC_LINE_LENGTH, file);
+ (void) s;
+ } while (String_startsWith(buffer, "cpu"));
+ fclose(file);
+
+ pl->cpuCount = MAX(cpus - 1, 1);
+ this->cpus = xCalloc(cpus, sizeof(CPUData));
+
+ for (int i = 0; i < cpus; i++) {
+ this->cpus[i].totalTime = 1;
+ this->cpus[i].totalPeriod = 1;
+ }
+
+ return pl;
+}
+
+void ProcessList_delete(ProcessList* pl) {
+ LinuxProcessList* this = (LinuxProcessList*) pl;
+ ProcessList_done(pl);
+ free(this->cpus);
+ free(this);
+}
+
+static ssize_t xread(int fd, void *buf, size_t count) {
+ // Read some bytes. Retry on EINTR and when we don't get as many bytes as we requested.
+ size_t alreadyRead = 0;
+ for(;;) {
+ ssize_t res = read(fd, buf, count);
+ if (res == -1 && errno == EINTR) continue;
+ if (res > 0) {
+ buf = ((char*)buf)+res;
+ count -= res;
+ alreadyRead += res;
+ }
+ if (res == -1) return -1;
+ if (count == 0 || res == 0) return alreadyRead;
+ }
+}
+
+static double jiffy = 0.0;
+
+static inline unsigned long long LinuxProcess_adjustTime(unsigned long long t) {
+ if(jiffy == 0.0) jiffy = sysconf(_SC_CLK_TCK);
+ double jiffytime = 1.0 / jiffy;
+ return (unsigned long long) t * jiffytime * 100;
+}
+
+static bool LinuxProcessList_readStatFile(Process *process, const char* dirname, const char* name, char* command, int* commLen) {
+ LinuxProcess* lp = (LinuxProcess*) process;
+ char filename[MAX_NAME+1];
+ snprintf(filename, MAX_NAME, "%s/%s/stat", dirname, name);
+ int fd = open(filename, O_RDONLY);
+ if (fd == -1)
+ return false;
+
+ static char buf[MAX_READ+1];
+
+ int size = xread(fd, buf, MAX_READ);
+ close(fd);
+ if (size <= 0) return false;
+ buf[size] = '\0';
+
+ assert(process->pid == atoi(buf));
+ char *location = strchr(buf, ' ');
+ if (!location) return false;
+
+ location += 2;
+ char *end = strrchr(location, ')');
+ if (!end) return false;
+
+ int commsize = end - location;
+ memcpy(command, location, commsize);
+ command[commsize] = '\0';
+ *commLen = commsize;
+ location = end + 2;
+
+ process->state = location[0];
+ location += 2;
+ process->ppid = strtol(location, &location, 10);
+ location += 1;
+ process->pgrp = strtoul(location, &location, 10);
+ location += 1;
+ process->session = strtoul(location, &location, 10);
+ location += 1;
+ process->tty_nr = strtoul(location, &location, 10);
+ location += 1;
+ process->tpgid = strtol(location, &location, 10);
+ location += 1;
+ process->flags = strtoul(location, &location, 10);
+ location += 1;
+ process->minflt = strtoull(location, &location, 10);
+ location += 1;
+ lp->cminflt = strtoull(location, &location, 10);
+ location += 1;
+ process->majflt = strtoull(location, &location, 10);
+ location += 1;
+ lp->cmajflt = strtoull(location, &location, 10);
+ location += 1;
+ lp->utime = LinuxProcess_adjustTime(strtoull(location, &location, 10));
+ location += 1;
+ lp->stime = LinuxProcess_adjustTime(strtoull(location, &location, 10));
+ location += 1;
+ lp->cutime = LinuxProcess_adjustTime(strtoull(location, &location, 10));
+ location += 1;
+ lp->cstime = LinuxProcess_adjustTime(strtoull(location, &location, 10));
+ location += 1;
+ process->priority = strtol(location, &location, 10);
+ location += 1;
+ process->nice = strtol(location, &location, 10);
+ location += 1;
+ process->nlwp = strtol(location, &location, 10);
+ location += 1;
+ for (int i=0; i<17; i++) location = strchr(location, ' ')+1;
+ process->exit_signal = strtol(location, &location, 10);
+ location += 1;
+ assert(location != NULL);
+ process->processor = strtol(location, &location, 10);
+
+ process->time = lp->utime + lp->stime;
+
+ return true;
+}
+
+
+static bool LinuxProcessList_statProcessDir(Process* process, const char* dirname, char* name, time_t curTime) {
+ char filename[MAX_NAME+1];
+ filename[MAX_NAME] = '\0';
+
+ snprintf(filename, MAX_NAME, "%s/%s", dirname, name);
+ struct stat sstat;
+ int statok = stat(filename, &sstat);
+ if (statok == -1)
+ return false;
+ process->st_uid = sstat.st_uid;
+
+ struct tm date;
+ time_t ctime = sstat.st_ctime;
+ process->starttime_ctime = ctime;
+ (void) localtime_r((time_t*) &ctime, &date);
+ strftime(process->starttime_show, 7, ((ctime > curTime - 86400) ? "%R " : "%b%d "), &date);
+
+ return true;
+}
+
+#ifdef HAVE_TASKSTATS
+
+static void LinuxProcessList_readIoFile(LinuxProcess* process, const char* dirname, char* name, unsigned long long now) {
+ char filename[MAX_NAME+1];
+ filename[MAX_NAME] = '\0';
+
+ snprintf(filename, MAX_NAME, "%s/%s/io", dirname, name);
+ int fd = open(filename, O_RDONLY);
+ if (fd == -1) {
+ process->io_rate_read_bps = -1;
+ process->io_rate_write_bps = -1;
+ return;
+ }
+
+ char buffer[1024];
+ ssize_t buflen = xread(fd, buffer, 1023);
+ close(fd);
+ if (buflen < 1) return;
+ buffer[buflen] = '\0';
+ unsigned long long last_read = process->io_read_bytes;
+ unsigned long long last_write = process->io_write_bytes;
+ char *buf = buffer;
+ char *line = NULL;
+ while ((line = strsep(&buf, "\n")) != NULL) {
+ switch (line[0]) {
+ case 'r':
+ if (line[1] == 'c' && strncmp(line+2, "har: ", 5) == 0)
+ process->io_rchar = strtoull(line+7, NULL, 10);
+ else if (strncmp(line+1, "ead_bytes: ", 11) == 0) {
+ process->io_read_bytes = strtoull(line+12, NULL, 10);
+ process->io_rate_read_bps =
+ ((double)(process->io_read_bytes - last_read))/(((double)(now - process->io_rate_read_time))/1000);
+ process->io_rate_read_time = now;
+ }
+ break;
+ case 'w':
+ if (line[1] == 'c' && strncmp(line+2, "har: ", 5) == 0)
+ process->io_wchar = strtoull(line+7, NULL, 10);
+ else if (strncmp(line+1, "rite_bytes: ", 12) == 0) {
+ process->io_write_bytes = strtoull(line+13, NULL, 10);
+ process->io_rate_write_bps =
+ ((double)(process->io_write_bytes - last_write))/(((double)(now - process->io_rate_write_time))/1000);
+ process->io_rate_write_time = now;
+ }
+ break;
+ case 's':
+ if (line[5] == 'r' && strncmp(line+1, "yscr: ", 6) == 0)
+ process->io_syscr = strtoull(line+7, NULL, 10);
+ else if (strncmp(line+1, "yscw: ", 6) == 0)
+ sscanf(line, "syscw: %32llu", &process->io_syscw);
+ process->io_syscw = strtoull(line+7, NULL, 10);
+ break;
+ case 'c':
+ if (strncmp(line+1, "ancelled_write_bytes: ", 22) == 0)
+ process->io_cancelled_write_bytes = strtoull(line+23, NULL, 10);
+ }
+ }
+}
+
+#endif
+
+
+
+static bool LinuxProcessList_readStatmFile(LinuxProcess* process, const char* dirname, const char* name) {
+ char filename[MAX_NAME+1];
+ snprintf(filename, MAX_NAME, "%s/%s/statm", dirname, name);
+ int fd = open(filename, O_RDONLY);
+ if (fd == -1)
+ return false;
+ char buf[PROC_LINE_LENGTH + 1];
+ ssize_t rres = xread(fd, buf, PROC_LINE_LENGTH);
+ close(fd);
+ if (rres < 1) return false;
+
+ char *p = buf;
+ errno = 0;
+ process->super.m_size = strtol(p, &p, 10); if (*p == ' ') p++;
+ process->super.m_resident = strtol(p, &p, 10); if (*p == ' ') p++;
+ process->m_share = strtol(p, &p, 10); if (*p == ' ') p++;
+ process->m_trs = strtol(p, &p, 10); if (*p == ' ') p++;
+ process->m_lrs = strtol(p, &p, 10); if (*p == ' ') p++;
+ process->m_drs = strtol(p, &p, 10); if (*p == ' ') p++;
+ process->m_dt = strtol(p, &p, 10);
+ return (errno == 0);
+}
+
+#ifdef HAVE_OPENVZ
+
+static void LinuxProcessList_readOpenVZData(LinuxProcess* process, const char* dirname, const char* name) {
+ if ( (access("/proc/vz", R_OK) != 0)) {
+ process->vpid = process->super.pid;
+ process->ctid = 0;
+ return;
+ }
+ char filename[MAX_NAME+1];
+ snprintf(filename, MAX_NAME, "%s/%s/stat", dirname, name);
+ FILE* file = fopen(filename, "r");
+ if (!file)
+ return;
+ (void) fscanf(file,
+ "%*32u %*32s %*1c %*32u %*32u %*32u %*32u %*32u %*32u %*32u "
+ "%*32u %*32u %*32u %*32u %*32u %*32u %*32u %*32u "
+ "%*32u %*32u %*32u %*32u %*32u %*32u %*32u %*32u "
+ "%*32u %*32u %*32u %*32u %*32u %*32u %*32u %*32u "
+ "%*32u %*32u %*32u %*32u %*32u %*32u %*32u %*32u "
+ "%*32u %*32u %*32u %*32u %*32u %*32u %*32u "
+ "%*32u %*32u %32u %32u",
+ &process->vpid, &process->ctid);
+ fclose(file);
+ return;
+}
+
+#endif
+
+#ifdef HAVE_CGROUP
+
+static void LinuxProcessList_readCGroupFile(LinuxProcess* process, const char* dirname, const char* name) {
+ char filename[MAX_NAME+1];
+ snprintf(filename, MAX_NAME, "%s/%s/cgroup", dirname, name);
+ FILE* file = fopen(filename, "r");
+ if (!file) {
+ process->cgroup = xStrdup("");
+ return;
+ }
+ char output[PROC_LINE_LENGTH + 1];
+ output[0] = '\0';
+ char* at = output;
+ int left = PROC_LINE_LENGTH;
+ while (!feof(file) && left > 0) {
+ char buffer[PROC_LINE_LENGTH + 1];
+ char *ok = fgets(buffer, PROC_LINE_LENGTH, file);
+ if (!ok) break;
+ char* group = strchr(buffer, ':');
+ if (!group) break;
+ if (at != output) {
+ *at = ';';
+ at++;
+ left--;
+ }
+ int wrote = snprintf(at, left, "%s", group);
+ left -= wrote;
+ }
+ fclose(file);
+ free(process->cgroup);
+ process->cgroup = xStrdup(output);
+}
+
+#endif
+
+#ifdef HAVE_VSERVER
+
+static void LinuxProcessList_readVServerData(LinuxProcess* process, const char* dirname, const char* name) {
+ char filename[MAX_NAME+1];
+ snprintf(filename, MAX_NAME, "%s/%s/status", dirname, name);
+ FILE* file = fopen(filename, "r");
+ if (!file)
+ return;
+ char buffer[PROC_LINE_LENGTH + 1];
+ process->vxid = 0;
+ while (fgets(buffer, PROC_LINE_LENGTH, file)) {
+ if (String_startsWith(buffer, "VxID:")) {
+ int vxid;
+ int ok = sscanf(buffer, "VxID:\t%32d", &vxid);
+ if (ok >= 1) {
+ process->vxid = vxid;
+ }
+ }
+ #if defined HAVE_ANCIENT_VSERVER
+ else if (String_startsWith(buffer, "s_context:")) {
+ int vxid;
+ int ok = sscanf(buffer, "s_context:\t%32d", &vxid);
+ if (ok >= 1) {
+ process->vxid = vxid;
+ }
+ }
+ #endif
+ }
+ fclose(file);
+}
+
+#endif
+
+static void LinuxProcessList_readOomData(LinuxProcess* process, const char* dirname, const char* name) {
+ char filename[MAX_NAME+1];
+ snprintf(filename, MAX_NAME, "%s/%s/oom_score", dirname, name);
+ FILE* file = fopen(filename, "r");
+ if (!file)
+ return;
+ char buffer[PROC_LINE_LENGTH + 1];
+ if (fgets(buffer, PROC_LINE_LENGTH, file)) {
+ unsigned int oom;
+ int ok = sscanf(buffer, "%32u", &oom);
+ if (ok >= 1) {
+ process->oom = oom;
+ }
+ }
+ fclose(file);
+}
+
+static void setCommand(Process* process, const char* command, int len) {
+ if (process->comm && process->commLen <= len) {
+ strncpy(process->comm, command, len + 1);
+ } else {
+ free(process->comm);
+ process->comm = xStrdup(command);
+ }
+ process->commLen = len;
+}
+
+static bool LinuxProcessList_readCmdlineFile(Process* process, const char* dirname, const char* name) {
+ if (Process_isKernelThread(process))
+ return true;
+
+ char filename[MAX_NAME+1];
+ snprintf(filename, MAX_NAME, "%s/%s/cmdline", dirname, name);
+ int fd = open(filename, O_RDONLY);
+ if (fd == -1)
+ return false;
+
+ char command[4096+1]; // max cmdline length on Linux
+ int amtRead = xread(fd, command, sizeof(command) - 1);
+ close(fd);
+ int tokenEnd = 0;
+ if (amtRead > 0) {
+ for (int i = 0; i < amtRead; i++)
+ if (command[i] == '\0' || command[i] == '\n') {
+ if (tokenEnd == 0) {
+ tokenEnd = i;
+ }
+ command[i] = ' ';
+ }
+ }
+ if (tokenEnd == 0) {
+ tokenEnd = amtRead;
+ }
+ command[amtRead] = '\0';
+ process->basenameOffset = tokenEnd;
+ setCommand(process, command, amtRead);
+
+ return true;
+}
+
+static bool LinuxProcessList_recurseProcTree(LinuxProcessList* this, const char* dirname, Process* parent, double period, struct timeval tv) {
+ ProcessList* pl = (ProcessList*) this;
+ DIR* dir;
+ struct dirent* entry;
+ Settings* settings = pl->settings;
+
+ time_t curTime = tv.tv_sec;
+ #ifdef HAVE_TASKSTATS
+ unsigned long long now = tv.tv_sec*1000LL+tv.tv_usec/1000LL;
+ #endif
+
+ dir = opendir(dirname);
+ if (!dir) return false;
+ int cpus = pl->cpuCount;
+ bool hideKernelThreads = settings->hideKernelThreads;
+ bool hideUserlandThreads = settings->hideUserlandThreads;
+ while ((entry = readdir(dir)) != NULL) {
+ char* name = entry->d_name;
+
+ // The RedHat kernel hides threads with a dot.
+ // I believe this is non-standard.
+ if ((!settings->hideThreads) && name[0] == '.') {
+ name++;
+ }
+
+ // Just skip all non-number directories.
+ if (name[0] < '0' || name[0] > '9') {
+ continue;
+ }
+
+ // filename is a number: process directory
+ int pid = atoi(name);
+
+ if (parent && pid == parent->pid)
+ continue;
+
+ if (pid <= 0)
+ continue;
+
+ bool preExisting = false;
+ Process* proc = ProcessList_getProcess(pl, pid, &preExisting, (Process_New) LinuxProcess_new);
+ proc->tgid = parent ? parent->pid : pid;
+
+ LinuxProcess* lp = (LinuxProcess*) proc;
+
+ char subdirname[MAX_NAME+1];
+ snprintf(subdirname, MAX_NAME, "%s/%s/task", dirname, name);
+ LinuxProcessList_recurseProcTree(this, subdirname, proc, period, tv);
+
+ #ifdef HAVE_TASKSTATS
+ if (settings->flags & PROCESS_FLAG_IO)
+ LinuxProcessList_readIoFile(lp, dirname, name, now);
+ #endif
+
+ if (! LinuxProcessList_readStatmFile(lp, dirname, name))
+ goto errorReadingProcess;
+
+ proc->show = ! ((hideKernelThreads && Process_isKernelThread(proc)) || (hideUserlandThreads && Process_isUserlandThread(proc)));
+
+ char command[MAX_NAME+1];
+ unsigned long long int lasttimes = (lp->utime + lp->stime);
+ int commLen = 0;
+ if (! LinuxProcessList_readStatFile(proc, dirname, name, command, &commLen))
+ goto errorReadingProcess;
+ if (settings->flags & PROCESS_FLAG_LINUX_IOPRIO)
+ LinuxProcess_updateIOPriority(lp);
+ float percent_cpu = (lp->utime + lp->stime - lasttimes) / period * 100.0;
+ proc->percent_cpu = CLAMP(percent_cpu, 0.0, cpus * 100.0);
+ if (isnan(proc->percent_cpu)) proc->percent_cpu = 0.0;
+ proc->percent_mem = (proc->m_resident * PAGE_SIZE_KB) / (double)(pl->totalMem) * 100.0;
+
+ if(!preExisting) {
+
+ if (! LinuxProcessList_statProcessDir(proc, dirname, name, curTime))
+ goto errorReadingProcess;
+
+ proc->user = UsersTable_getRef(pl->usersTable, proc->st_uid);
+
+ #ifdef HAVE_OPENVZ
+ if (settings->flags & PROCESS_FLAG_LINUX_OPENVZ) {
+ LinuxProcessList_readOpenVZData(lp, dirname, name);
+ }
+ #endif
+
+ #ifdef HAVE_VSERVER
+ if (settings->flags & PROCESS_FLAG_LINUX_VSERVER) {
+ LinuxProcessList_readVServerData(lp, dirname, name);
+ }
+ #endif
+
+ if (! LinuxProcessList_readCmdlineFile(proc, dirname, name)) {
+ goto errorReadingProcess;
+ }
+
+ ProcessList_add(pl, proc);
+ } else {
+ if (settings->updateProcessNames) {
+ if (! LinuxProcessList_readCmdlineFile(proc, dirname, name)) {
+ goto errorReadingProcess;
+ }
+ }
+ }
+
+ #ifdef HAVE_CGROUP
+ if (settings->flags & PROCESS_FLAG_LINUX_CGROUP)
+ LinuxProcessList_readCGroupFile(lp, dirname, name);
+ #endif
+
+ if (settings->flags & PROCESS_FLAG_LINUX_OOM)
+ LinuxProcessList_readOomData(lp, dirname, name);
+
+ if (proc->state == 'Z') {
+ proc->basenameOffset = -1;
+ setCommand(proc, command, commLen);
+ } else if (Process_isThread(proc)) {
+ if (settings->showThreadNames || Process_isKernelThread(proc) || proc->state == 'Z') {
+ proc->basenameOffset = -1;
+ setCommand(proc, command, commLen);
+ } else if (settings->showThreadNames) {
+ if (! LinuxProcessList_readCmdlineFile(proc, dirname, name))
+ goto errorReadingProcess;
+ }
+ if (Process_isKernelThread(proc)) {
+ pl->kernelThreads++;
+ } else {
+ pl->userlandThreads++;
+ }
+ }
+
+ pl->totalTasks++;
+ if (proc->state == 'R')
+ pl->runningTasks++;
+ proc->updated = true;
+ continue;
+
+ // Exception handler.
+ errorReadingProcess: {
+ if (preExisting) {
+ ProcessList_remove(pl, proc);
+ } else {
+ Process_delete((Object*)proc);
+ }
+ }
+ }
+ closedir(dir);
+ return true;
+}
+
+static inline void LinuxProcessList_scanMemoryInfo(ProcessList* this) {
+ unsigned long long int swapFree = 0;
+ unsigned long long int shmem = 0;
+ unsigned long long int sreclaimable = 0;
+
+ FILE* file = fopen(PROCMEMINFOFILE, "r");
+ if (file == NULL) {
+ CRT_fatalError("Cannot open " PROCMEMINFOFILE);
+ }
+ char buffer[128];
+ while (fgets(buffer, 128, file)) {
+
+ #define tryRead(label, variable) (String_startsWith(buffer, label) && sscanf(buffer + strlen(label), " %32llu kB", variable))
+ switch (buffer[0]) {
+ case 'M':
+ if (tryRead("MemTotal:", &this->totalMem)) {}
+ else if (tryRead("MemFree:", &this->freeMem)) {}
+ else if (tryRead("MemShared:", &this->sharedMem)) {}
+ break;
+ case 'B':
+ if (tryRead("Buffers:", &this->buffersMem)) {}
+ break;
+ case 'C':
+ if (tryRead("Cached:", &this->cachedMem)) {}
+ break;
+ case 'S':
+ switch (buffer[1]) {
+ case 'w':
+ if (tryRead("SwapTotal:", &this->totalSwap)) {}
+ else if (tryRead("SwapFree:", &swapFree)) {}
+ break;
+ case 'h':
+ if (tryRead("Shmem:", &shmem)) {}
+ break;
+ case 'R':
+ if (tryRead("SReclaimable:", &sreclaimable)) {}
+ break;
+ }
+ break;
+ }
+ #undef tryRead
+ }
+
+ this->usedMem = this->totalMem - this->freeMem;
+ this->cachedMem = this->cachedMem + sreclaimable - shmem;
+ this->usedSwap = this->totalSwap - swapFree;
+ fclose(file);
+}
+
+static inline double LinuxProcessList_scanCPUTime(LinuxProcessList* this) {
+
+ FILE* file = fopen(PROCSTATFILE, "r");
+ if (file == NULL) {
+ CRT_fatalError("Cannot open " PROCSTATFILE);
+ }
+ int cpus = this->super.cpuCount;
+ assert(cpus > 0);
+ for (int i = 0; i <= cpus; i++) {
+ char buffer[PROC_LINE_LENGTH + 1];
+ unsigned long long int usertime, nicetime, systemtime, idletime;
+ unsigned long long int ioWait, irq, softIrq, steal, guest, guestnice;
+ ioWait = irq = softIrq = steal = guest = guestnice = 0;
+ // Depending on your kernel version,
+ // 5, 7, 8 or 9 of these fields will be set.
+ // The rest will remain at zero.
+ char* ok = fgets(buffer, PROC_LINE_LENGTH, file);
+ if (!ok) buffer[0] = '\0';
+ if (i == 0)
+ sscanf(buffer, "cpu %16llu %16llu %16llu %16llu %16llu %16llu %16llu %16llu %16llu %16llu", &usertime, &nicetime, &systemtime, &idletime, &ioWait, &irq, &softIrq, &steal, &guest, &guestnice);
+ else {
+ int cpuid;
+ sscanf(buffer, "cpu%4d %16llu %16llu %16llu %16llu %16llu %16llu %16llu %16llu %16llu %16llu", &cpuid, &usertime, &nicetime, &systemtime, &idletime, &ioWait, &irq, &softIrq, &steal, &guest, &guestnice);
+ assert(cpuid == i - 1);
+ }
+ // Guest time is already accounted in usertime
+ usertime = usertime - guest;
+ nicetime = nicetime - guestnice;
+ // Fields existing on kernels >= 2.6
+ // (and RHEL's patched kernel 2.4...)
+ unsigned long long int idlealltime = idletime + ioWait;
+ unsigned long long int systemalltime = systemtime + irq + softIrq;
+ unsigned long long int virtalltime = guest + guestnice;
+ unsigned long long int totaltime = usertime + nicetime + systemalltime + idlealltime + steal + virtalltime;
+ CPUData* cpuData = &(this->cpus[i]);
+ assert (systemtime >= cpuData->systemTime);
+ assert (idletime >= cpuData->idleTime);
+ assert (totaltime >= cpuData->totalTime);
+ assert (systemalltime >= cpuData->systemAllTime);
+ assert (idlealltime >= cpuData->idleAllTime);
+ assert (ioWait >= cpuData->ioWaitTime);
+ assert (irq >= cpuData->irqTime);
+ assert (softIrq >= cpuData->softIrqTime);
+ assert (steal >= cpuData->stealTime);
+ assert (virtalltime >= cpuData->guestTime);
+ // Since we do a subtraction (usertime - guest) and cputime64_to_clock_t()
+ // used in /proc/stat rounds down numbers, it can lead to a case where the
+ // integer overflow.
+ cpuData->userPeriod = (usertime > cpuData->userTime) ? usertime - cpuData->userTime : 0;
+ cpuData->nicePeriod = (nicetime > cpuData->niceTime) ? nicetime - cpuData->niceTime : 0;
+ cpuData->systemPeriod = systemtime - cpuData->systemTime;
+ cpuData->systemAllPeriod = systemalltime - cpuData->systemAllTime;
+ cpuData->idleAllPeriod = idlealltime - cpuData->idleAllTime;
+ cpuData->idlePeriod = idletime - cpuData->idleTime;
+ cpuData->ioWaitPeriod = ioWait - cpuData->ioWaitTime;
+ cpuData->irqPeriod = irq - cpuData->irqTime;
+ cpuData->softIrqPeriod = softIrq - cpuData->softIrqTime;
+ cpuData->stealPeriod = steal - cpuData->stealTime;
+ cpuData->guestPeriod = virtalltime - cpuData->guestTime;
+ cpuData->totalPeriod = totaltime - cpuData->totalTime;
+ cpuData->userTime = usertime;
+ cpuData->niceTime = nicetime;
+ cpuData->systemTime = systemtime;
+ cpuData->systemAllTime = systemalltime;
+ cpuData->idleAllTime = idlealltime;
+ cpuData->idleTime = idletime;
+ cpuData->ioWaitTime = ioWait;
+ cpuData->irqTime = irq;
+ cpuData->softIrqTime = softIrq;
+ cpuData->stealTime = steal;
+ cpuData->guestTime = virtalltime;
+ cpuData->totalTime = totaltime;
+ }
+ double period = (double)this->cpus[0].totalPeriod / cpus;
+ fclose(file);
+ return period;
+}
+
+void ProcessList_goThroughEntries(ProcessList* super) {
+ LinuxProcessList* this = (LinuxProcessList*) super;
+
+ LinuxProcessList_scanMemoryInfo(super);
+ double period = LinuxProcessList_scanCPUTime(this);
+
+ struct timeval tv;
+ gettimeofday(&tv, NULL);
+ LinuxProcessList_recurseProcTree(this, PROCDIR, NULL, period, tv);
+}

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