2014-11-24 20:55:49 +00:00
|
|
|
/*
|
|
|
|
htop - LinuxProcessList.c
|
|
|
|
(C) 2014 Hisham H. Muhammad
|
2020-10-05 07:51:32 +00:00
|
|
|
Released under the GNU GPLv2, see the COPYING file
|
2014-11-24 20:55:49 +00:00
|
|
|
in the source distribution for its full text.
|
|
|
|
*/
|
|
|
|
|
2020-09-19 11:55:23 +00:00
|
|
|
#include "config.h" // IWYU pragma: keep
|
|
|
|
|
2014-11-24 21:22:50 +00:00
|
|
|
#include "LinuxProcessList.h"
|
2020-10-14 18:21:09 +00:00
|
|
|
|
2020-09-19 11:55:23 +00:00
|
|
|
#include <assert.h>
|
2014-11-24 21:22:50 +00:00
|
|
|
#include <dirent.h>
|
2020-09-19 11:55:23 +00:00
|
|
|
#include <errno.h>
|
|
|
|
#include <fcntl.h>
|
2014-11-24 21:22:50 +00:00
|
|
|
#include <math.h>
|
2020-09-19 11:55:23 +00:00
|
|
|
#include <stdbool.h>
|
|
|
|
#include <stdio.h>
|
|
|
|
#include <stdlib.h>
|
2014-11-24 21:22:50 +00:00
|
|
|
#include <string.h>
|
2020-09-19 11:55:23 +00:00
|
|
|
#include <strings.h>
|
|
|
|
#include <unistd.h>
|
|
|
|
#include <sys/stat.h>
|
|
|
|
#include <sys/time.h>
|
2014-11-24 21:22:50 +00:00
|
|
|
#include <sys/types.h>
|
2014-11-24 20:55:49 +00:00
|
|
|
|
2017-12-04 02:15:29 +00:00
|
|
|
#ifdef HAVE_DELAYACCT
|
2020-09-19 11:55:23 +00:00
|
|
|
#include <linux/netlink.h>
|
|
|
|
#include <linux/taskstats.h>
|
2017-12-04 02:15:29 +00:00
|
|
|
#include <netlink/attr.h>
|
2020-09-19 11:55:23 +00:00
|
|
|
#include <netlink/handlers.h>
|
|
|
|
#include <netlink/msg.h>
|
2017-12-04 02:15:29 +00:00
|
|
|
#include <netlink/netlink.h>
|
2020-09-19 11:55:23 +00:00
|
|
|
#include <netlink/socket.h>
|
2017-12-04 02:15:29 +00:00
|
|
|
#include <netlink/genl/genl.h>
|
|
|
|
#include <netlink/genl/ctrl.h>
|
|
|
|
#endif
|
|
|
|
|
2020-09-19 11:55:23 +00:00
|
|
|
#include "CRT.h"
|
|
|
|
#include "LinuxProcess.h"
|
|
|
|
#include "Macros.h"
|
|
|
|
#include "Object.h"
|
|
|
|
#include "Process.h"
|
|
|
|
#include "Settings.h"
|
|
|
|
#include "XUtils.h"
|
|
|
|
|
|
|
|
#ifdef MAJOR_IN_MKDEV
|
|
|
|
#include <sys/mkdev.h>
|
|
|
|
#elif defined(MAJOR_IN_SYSMACROS)
|
|
|
|
#include <sys/sysmacros.h>
|
|
|
|
#endif
|
|
|
|
|
|
|
|
|
2016-10-01 06:09:04 +00:00
|
|
|
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 int sortTtyDrivers(const void* va, const void* vb) {
|
2020-09-23 12:15:51 +00:00
|
|
|
const TtyDriver* a = (const TtyDriver*) va;
|
|
|
|
const TtyDriver* b = (const TtyDriver*) vb;
|
2020-09-09 22:09:01 +00:00
|
|
|
return (a->major == b->major) ? ((int)a->minorFrom - (int)b->minorFrom) : ((int)a->major - (int)b->major);
|
2016-10-01 06:09:04 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
static void LinuxProcessList_initTtyDrivers(LinuxProcessList* this) {
|
|
|
|
TtyDriver* ttyDrivers;
|
|
|
|
int fd = open(PROCTTYDRIVERSFILE, O_RDONLY);
|
|
|
|
if (fd == -1)
|
|
|
|
return;
|
|
|
|
char* buf = NULL;
|
|
|
|
int bufSize = MAX_READ;
|
|
|
|
int bufLen = 0;
|
|
|
|
for(;;) {
|
2020-09-21 12:27:32 +00:00
|
|
|
buf = xRealloc(buf, bufSize);
|
2016-10-01 06:09:04 +00:00
|
|
|
int size = xread(fd, buf + bufLen, MAX_READ);
|
|
|
|
if (size <= 0) {
|
|
|
|
buf[bufLen] = '\0';
|
|
|
|
close(fd);
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
bufLen += size;
|
|
|
|
bufSize += MAX_READ;
|
|
|
|
}
|
|
|
|
if (bufLen == 0) {
|
|
|
|
free(buf);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
int numDrivers = 0;
|
|
|
|
int allocd = 10;
|
2020-09-21 12:27:32 +00:00
|
|
|
ttyDrivers = xMalloc(sizeof(TtyDriver) * allocd);
|
2016-10-01 06:09:04 +00:00
|
|
|
char* at = buf;
|
|
|
|
while (*at != '\0') {
|
|
|
|
at = strchr(at, ' '); // skip first token
|
|
|
|
while (*at == ' ') at++; // skip spaces
|
|
|
|
char* token = at; // mark beginning of path
|
|
|
|
at = strchr(at, ' '); // find end of path
|
|
|
|
*at = '\0'; at++; // clear and skip
|
2020-09-21 12:27:32 +00:00
|
|
|
ttyDrivers[numDrivers].path = xStrdup(token); // save
|
2016-10-01 06:09:04 +00:00
|
|
|
while (*at == ' ') at++; // skip spaces
|
|
|
|
token = at; // mark beginning of major
|
|
|
|
at = strchr(at, ' '); // find end of major
|
|
|
|
*at = '\0'; at++; // clear and skip
|
|
|
|
ttyDrivers[numDrivers].major = atoi(token); // save
|
|
|
|
while (*at == ' ') at++; // skip spaces
|
|
|
|
token = at; // mark beginning of minorFrom
|
|
|
|
while (*at >= '0' && *at <= '9') at++; //find end of minorFrom
|
|
|
|
if (*at == '-') { // if has range
|
|
|
|
*at = '\0'; at++; // clear and skip
|
|
|
|
ttyDrivers[numDrivers].minorFrom = atoi(token); // save
|
|
|
|
token = at; // mark beginning of minorTo
|
|
|
|
at = strchr(at, ' '); // find end of minorTo
|
|
|
|
*at = '\0'; at++; // clear and skip
|
|
|
|
ttyDrivers[numDrivers].minorTo = atoi(token); // save
|
|
|
|
} else { // no range
|
|
|
|
*at = '\0'; at++; // clear and skip
|
|
|
|
ttyDrivers[numDrivers].minorFrom = atoi(token); // save
|
|
|
|
ttyDrivers[numDrivers].minorTo = atoi(token); // save
|
|
|
|
}
|
|
|
|
at = strchr(at, '\n'); // go to end of line
|
|
|
|
at++; // skip
|
|
|
|
numDrivers++;
|
|
|
|
if (numDrivers == allocd) {
|
|
|
|
allocd += 10;
|
2020-09-21 12:27:32 +00:00
|
|
|
ttyDrivers = xRealloc(ttyDrivers, sizeof(TtyDriver) * allocd);
|
2016-10-01 06:09:04 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
free(buf);
|
|
|
|
numDrivers++;
|
2020-09-21 12:27:32 +00:00
|
|
|
ttyDrivers = xRealloc(ttyDrivers, sizeof(TtyDriver) * numDrivers);
|
2016-10-01 06:09:04 +00:00
|
|
|
ttyDrivers[numDrivers - 1].path = NULL;
|
|
|
|
qsort(ttyDrivers, numDrivers - 1, sizeof(TtyDriver), sortTtyDrivers);
|
|
|
|
this->ttyDrivers = ttyDrivers;
|
|
|
|
}
|
|
|
|
|
2017-12-04 02:15:29 +00:00
|
|
|
#ifdef HAVE_DELAYACCT
|
|
|
|
|
|
|
|
static void LinuxProcessList_initNetlinkSocket(LinuxProcessList* this) {
|
|
|
|
this->netlink_socket = nl_socket_alloc();
|
|
|
|
if (this->netlink_socket == NULL) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
if (nl_connect(this->netlink_socket, NETLINK_GENERIC) < 0) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
this->netlink_family = genl_ctrl_resolve(this->netlink_socket, TASKSTATS_GENL_NAME);
|
|
|
|
}
|
|
|
|
|
|
|
|
#endif
|
|
|
|
|
2020-09-22 18:04:41 +00:00
|
|
|
static int LinuxProcessList_computeCPUcount(void) {
|
|
|
|
FILE* file = fopen(PROCSTATFILE, "r");
|
|
|
|
if (file == NULL)
|
|
|
|
CRT_fatalError("Cannot open " PROCSTATFILE);
|
|
|
|
|
|
|
|
int cpus = 0;
|
|
|
|
char buffer[PROC_LINE_LENGTH + 1];
|
|
|
|
while(fgets(buffer, sizeof(buffer), file)) {
|
|
|
|
if (String_startsWith(buffer, "cpu"))
|
|
|
|
cpus++;
|
|
|
|
}
|
|
|
|
|
|
|
|
fclose(file);
|
|
|
|
|
|
|
|
/* subtract raw cpu entry */
|
|
|
|
if (cpus > 0)
|
|
|
|
cpus--;
|
|
|
|
|
|
|
|
return cpus;
|
|
|
|
}
|
|
|
|
|
|
|
|
static void LinuxProcessList_updateCPUcount(LinuxProcessList* this) {
|
|
|
|
ProcessList* pl = &(this->super);
|
|
|
|
int cpus = LinuxProcessList_computeCPUcount();
|
|
|
|
if (cpus == 0 || cpus == pl->cpuCount)
|
|
|
|
return;
|
|
|
|
|
|
|
|
pl->cpuCount = cpus;
|
|
|
|
free(this->cpus);
|
|
|
|
this->cpus = xCalloc(cpus + 1, sizeof(CPUData));
|
|
|
|
|
|
|
|
for (int i = 0; i <= cpus; i++) {
|
|
|
|
this->cpus[i].totalTime = 1;
|
|
|
|
this->cpus[i].totalPeriod = 1;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-09-09 09:38:15 +00:00
|
|
|
ProcessList* ProcessList_new(UsersTable* usersTable, Hashtable* pidMatchList, uid_t userId) {
|
2016-02-02 14:53:02 +00:00
|
|
|
LinuxProcessList* this = xCalloc(1, sizeof(LinuxProcessList));
|
2015-01-22 01:27:31 +00:00
|
|
|
ProcessList* pl = &(this->super);
|
2018-08-19 04:29:03 +00:00
|
|
|
|
2020-09-09 09:38:15 +00:00
|
|
|
ProcessList_init(pl, Class(LinuxProcess), usersTable, pidMatchList, userId);
|
2016-10-01 06:09:04 +00:00
|
|
|
LinuxProcessList_initTtyDrivers(this);
|
2014-11-24 20:55:49 +00:00
|
|
|
|
2017-12-04 02:15:29 +00:00
|
|
|
#ifdef HAVE_DELAYACCT
|
|
|
|
LinuxProcessList_initNetlinkSocket(this);
|
|
|
|
#endif
|
|
|
|
|
2018-10-16 18:08:23 +00:00
|
|
|
// Check for /proc/*/smaps_rollup availability (improves smaps parsing speed, Linux 4.14+)
|
|
|
|
FILE* file = fopen(PROCDIR "/self/smaps_rollup", "r");
|
|
|
|
if(file != NULL) {
|
|
|
|
this->haveSmapsRollup = true;
|
|
|
|
fclose(file);
|
|
|
|
} else {
|
|
|
|
this->haveSmapsRollup = false;
|
|
|
|
}
|
|
|
|
|
2020-09-22 18:04:41 +00:00
|
|
|
// Read btime
|
|
|
|
{
|
|
|
|
FILE* statfile = fopen(PROCSTATFILE, "r");
|
|
|
|
if (statfile == NULL)
|
|
|
|
CRT_fatalError("Cannot open " PROCSTATFILE);
|
|
|
|
|
|
|
|
while(true) {
|
|
|
|
char buffer[PROC_LINE_LENGTH + 1];
|
|
|
|
if (fgets(buffer, sizeof(buffer), statfile) == NULL) {
|
|
|
|
CRT_fatalError("No btime in " PROCSTATFILE);
|
|
|
|
} else if (String_startsWith(buffer, "btime ")) {
|
|
|
|
if (sscanf(buffer, "btime %lld\n", &btime) != 1)
|
|
|
|
CRT_fatalError("Failed to parse btime from " PROCSTATFILE);
|
|
|
|
break;
|
|
|
|
}
|
2018-08-19 04:29:03 +00:00
|
|
|
}
|
|
|
|
|
2020-09-22 18:04:41 +00:00
|
|
|
fclose(statfile);
|
|
|
|
}
|
2014-11-24 20:55:49 +00:00
|
|
|
|
2020-09-22 18:04:41 +00:00
|
|
|
// Initialze CPU count
|
|
|
|
{
|
|
|
|
int cpus = LinuxProcessList_computeCPUcount();
|
|
|
|
pl->cpuCount = MAXIMUM(cpus, 1);
|
|
|
|
this->cpus = xCalloc(cpus + 1, sizeof(CPUData));
|
2014-11-24 20:55:49 +00:00
|
|
|
|
2020-09-22 18:04:41 +00:00
|
|
|
for (int i = 0; i <= cpus; i++) {
|
|
|
|
this->cpus[i].totalTime = 1;
|
|
|
|
this->cpus[i].totalPeriod = 1;
|
|
|
|
}
|
2014-11-24 20:55:49 +00:00
|
|
|
}
|
2020-09-22 18:04:41 +00:00
|
|
|
|
2015-01-22 01:27:31 +00:00
|
|
|
return pl;
|
2014-11-24 20:55:49 +00:00
|
|
|
}
|
|
|
|
|
2015-01-22 01:27:31 +00:00
|
|
|
void ProcessList_delete(ProcessList* pl) {
|
|
|
|
LinuxProcessList* this = (LinuxProcessList*) pl;
|
|
|
|
ProcessList_done(pl);
|
|
|
|
free(this->cpus);
|
2016-10-01 06:09:04 +00:00
|
|
|
if (this->ttyDrivers) {
|
|
|
|
for(int i = 0; this->ttyDrivers[i].path; i++) {
|
|
|
|
free(this->ttyDrivers[i].path);
|
|
|
|
}
|
|
|
|
free(this->ttyDrivers);
|
|
|
|
}
|
2017-12-04 02:15:29 +00:00
|
|
|
#ifdef HAVE_DELAYACCT
|
|
|
|
if (this->netlink_socket) {
|
|
|
|
nl_close(this->netlink_socket);
|
|
|
|
nl_socket_free(this->netlink_socket);
|
|
|
|
}
|
|
|
|
#endif
|
2014-11-27 19:48:38 +00:00
|
|
|
free(this);
|
|
|
|
}
|
|
|
|
|
2015-03-17 02:01:48 +00:00
|
|
|
static inline unsigned long long LinuxProcess_adjustTime(unsigned long long t) {
|
2020-10-12 10:51:18 +00:00
|
|
|
static double jiffy = NAN;
|
2020-09-07 09:56:12 +00:00
|
|
|
if(isnan(jiffy)) {
|
|
|
|
errno = 0;
|
|
|
|
long sc_jiffy = sysconf(_SC_CLK_TCK);
|
|
|
|
if(errno || -1 == sc_jiffy) {
|
|
|
|
jiffy = NAN;
|
|
|
|
return t; // Assume 100Hz clock
|
|
|
|
}
|
|
|
|
jiffy = sc_jiffy;
|
|
|
|
}
|
2015-03-17 02:01:48 +00:00
|
|
|
double jiffytime = 1.0 / jiffy;
|
2020-09-28 10:17:52 +00:00
|
|
|
return t * jiffytime * 100;
|
2015-03-17 02:01:48 +00:00
|
|
|
}
|
|
|
|
|
2016-02-02 14:56:52 +00:00
|
|
|
static bool LinuxProcessList_readStatFile(Process *process, const char* dirname, const char* name, char* command, int* commLen) {
|
2015-03-16 04:43:04 +00:00
|
|
|
LinuxProcess* lp = (LinuxProcess*) process;
|
2020-09-15 17:55:21 +00:00
|
|
|
const int commLenIn = *commLen;
|
|
|
|
*commLen = 0;
|
2014-11-24 20:55:49 +00:00
|
|
|
char filename[MAX_NAME+1];
|
2017-07-27 19:07:50 +00:00
|
|
|
xSnprintf(filename, MAX_NAME, "%s/%s/stat", dirname, name);
|
2014-11-24 20:55:49 +00:00
|
|
|
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;
|
2019-10-31 16:39:12 +00:00
|
|
|
|
2020-09-15 17:55:21 +00:00
|
|
|
int commsize = MINIMUM(end - location, commLenIn - 1);
|
2020-09-24 17:52:08 +00:00
|
|
|
// deepcode ignore BufferOverflow: commsize is bounded by the allocated length passed in by commLen, saved into commLenIn
|
2014-11-24 20:55:49 +00:00
|
|
|
memcpy(command, location, commsize);
|
|
|
|
command[commsize] = '\0';
|
2016-02-02 14:56:52 +00:00
|
|
|
*commLen = commsize;
|
2014-11-24 20:55:49 +00:00
|
|
|
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;
|
2015-03-16 04:43:04 +00:00
|
|
|
lp->cminflt = strtoull(location, &location, 10);
|
2014-11-24 20:55:49 +00:00
|
|
|
location += 1;
|
|
|
|
process->majflt = strtoull(location, &location, 10);
|
|
|
|
location += 1;
|
2015-03-16 04:43:04 +00:00
|
|
|
lp->cmajflt = strtoull(location, &location, 10);
|
2014-11-24 20:55:49 +00:00
|
|
|
location += 1;
|
2015-03-17 02:01:48 +00:00
|
|
|
lp->utime = LinuxProcess_adjustTime(strtoull(location, &location, 10));
|
2014-11-24 20:55:49 +00:00
|
|
|
location += 1;
|
2015-03-17 02:01:48 +00:00
|
|
|
lp->stime = LinuxProcess_adjustTime(strtoull(location, &location, 10));
|
2014-11-24 20:55:49 +00:00
|
|
|
location += 1;
|
2015-03-17 02:01:48 +00:00
|
|
|
lp->cutime = LinuxProcess_adjustTime(strtoull(location, &location, 10));
|
2014-11-24 20:55:49 +00:00
|
|
|
location += 1;
|
2015-03-17 02:01:48 +00:00
|
|
|
lp->cstime = LinuxProcess_adjustTime(strtoull(location, &location, 10));
|
2014-11-24 20:55:49 +00:00
|
|
|
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;
|
2018-08-19 04:29:03 +00:00
|
|
|
location = strchr(location, ' ')+1;
|
2020-10-12 10:51:18 +00:00
|
|
|
if (process->starttime_ctime == 0) {
|
|
|
|
process->starttime_ctime = btime + LinuxProcess_adjustTime(strtoll(location, &location, 10)) / 100;
|
|
|
|
} else {
|
|
|
|
location = strchr(location, ' ')+1;
|
|
|
|
}
|
2018-08-19 04:29:03 +00:00
|
|
|
location += 1;
|
|
|
|
for (int i=0; i<15; i++) location = strchr(location, ' ')+1;
|
2014-11-24 20:55:49 +00:00
|
|
|
process->exit_signal = strtol(location, &location, 10);
|
|
|
|
location += 1;
|
|
|
|
assert(location != NULL);
|
2015-03-17 02:03:40 +00:00
|
|
|
process->processor = strtol(location, &location, 10);
|
2019-10-31 16:39:12 +00:00
|
|
|
|
2015-03-16 04:43:04 +00:00
|
|
|
process->time = lp->utime + lp->stime;
|
2019-10-31 16:39:12 +00:00
|
|
|
|
2014-11-24 20:55:49 +00:00
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
|
|
|
|
2018-08-24 21:05:58 +00:00
|
|
|
static bool LinuxProcessList_statProcessDir(Process* process, const char* dirname, char* name) {
|
2014-11-24 20:55:49 +00:00
|
|
|
char filename[MAX_NAME+1];
|
|
|
|
filename[MAX_NAME] = '\0';
|
|
|
|
|
2017-07-27 19:07:50 +00:00
|
|
|
xSnprintf(filename, MAX_NAME, "%s/%s", dirname, name);
|
2014-11-24 20:55:49 +00:00
|
|
|
struct stat sstat;
|
|
|
|
int statok = stat(filename, &sstat);
|
|
|
|
if (statok == -1)
|
|
|
|
return false;
|
|
|
|
process->st_uid = sstat.st_uid;
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
|
|
|
#ifdef HAVE_TASKSTATS
|
|
|
|
|
2015-03-16 04:43:04 +00:00
|
|
|
static void LinuxProcessList_readIoFile(LinuxProcess* process, const char* dirname, char* name, unsigned long long now) {
|
2014-11-24 20:55:49 +00:00
|
|
|
char filename[MAX_NAME+1];
|
|
|
|
filename[MAX_NAME] = '\0';
|
|
|
|
|
2017-07-27 19:07:50 +00:00
|
|
|
xSnprintf(filename, MAX_NAME, "%s/%s/io", dirname, name);
|
2014-11-24 20:55:49 +00:00
|
|
|
int fd = open(filename, O_RDONLY);
|
2015-01-22 01:27:31 +00:00
|
|
|
if (fd == -1) {
|
2020-09-07 09:53:58 +00:00
|
|
|
process->io_rate_read_bps = NAN;
|
|
|
|
process->io_rate_write_bps = NAN;
|
2017-07-10 23:57:34 +00:00
|
|
|
process->io_rchar = -1LL;
|
|
|
|
process->io_wchar = -1LL;
|
|
|
|
process->io_syscr = -1LL;
|
|
|
|
process->io_syscw = -1LL;
|
|
|
|
process->io_read_bytes = -1LL;
|
|
|
|
process->io_write_bytes = -1LL;
|
|
|
|
process->io_cancelled_write_bytes = -1LL;
|
|
|
|
process->io_rate_read_time = -1LL;
|
|
|
|
process->io_rate_write_time = -1LL;
|
2014-11-24 20:55:49 +00:00
|
|
|
return;
|
2015-01-22 01:27:31 +00:00
|
|
|
}
|
2019-10-31 16:39:12 +00:00
|
|
|
|
2014-11-24 20:55:49 +00:00
|
|
|
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':
|
2020-10-03 19:20:43 +00:00
|
|
|
if (line[1] == 'c' && String_startsWith(line+2, "har: "))
|
2014-11-24 20:55:49 +00:00
|
|
|
process->io_rchar = strtoull(line+7, NULL, 10);
|
2020-10-03 19:20:43 +00:00
|
|
|
else if (String_startsWith(line+1, "ead_bytes: ")) {
|
2014-11-24 20:55:49 +00:00
|
|
|
process->io_read_bytes = strtoull(line+12, NULL, 10);
|
2019-10-31 16:39:12 +00:00
|
|
|
process->io_rate_read_bps =
|
2014-11-24 20:55:49 +00:00
|
|
|
((double)(process->io_read_bytes - last_read))/(((double)(now - process->io_rate_read_time))/1000);
|
|
|
|
process->io_rate_read_time = now;
|
|
|
|
}
|
|
|
|
break;
|
|
|
|
case 'w':
|
2020-10-03 19:20:43 +00:00
|
|
|
if (line[1] == 'c' && String_startsWith(line+2, "har: "))
|
2014-11-24 20:55:49 +00:00
|
|
|
process->io_wchar = strtoull(line+7, NULL, 10);
|
2020-10-03 19:20:43 +00:00
|
|
|
else if (String_startsWith(line+1, "rite_bytes: ")) {
|
2014-11-24 20:55:49 +00:00
|
|
|
process->io_write_bytes = strtoull(line+13, NULL, 10);
|
2019-10-31 16:39:12 +00:00
|
|
|
process->io_rate_write_bps =
|
2014-11-24 20:55:49 +00:00
|
|
|
((double)(process->io_write_bytes - last_write))/(((double)(now - process->io_rate_write_time))/1000);
|
|
|
|
process->io_rate_write_time = now;
|
|
|
|
}
|
|
|
|
break;
|
|
|
|
case 's':
|
2020-10-03 19:20:43 +00:00
|
|
|
if (line[4] == 'r' && String_startsWith(line+1, "yscr: ")) {
|
2014-11-24 20:55:49 +00:00
|
|
|
process->io_syscr = strtoull(line+7, NULL, 10);
|
2020-10-03 19:20:43 +00:00
|
|
|
} else if (String_startsWith(line+1, "yscw: ")) {
|
2014-11-24 20:55:49 +00:00
|
|
|
process->io_syscw = strtoull(line+7, NULL, 10);
|
2016-02-16 16:34:25 +00:00
|
|
|
}
|
2014-11-24 20:55:49 +00:00
|
|
|
break;
|
|
|
|
case 'c':
|
2020-10-03 19:20:43 +00:00
|
|
|
if (String_startsWith(line+1, "ancelled_write_bytes: ")) {
|
2014-11-24 20:55:49 +00:00
|
|
|
process->io_cancelled_write_bytes = strtoull(line+23, NULL, 10);
|
2016-02-16 16:34:25 +00:00
|
|
|
}
|
2014-11-24 20:55:49 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
#endif
|
|
|
|
|
|
|
|
|
|
|
|
|
2015-03-16 04:43:04 +00:00
|
|
|
static bool LinuxProcessList_readStatmFile(LinuxProcess* process, const char* dirname, const char* name) {
|
2014-11-24 20:55:49 +00:00
|
|
|
char filename[MAX_NAME+1];
|
2020-09-28 10:01:56 +00:00
|
|
|
xSnprintf(filename, sizeof(filename), "%s/%s/statm", dirname, name);
|
|
|
|
FILE* statmfile = fopen(filename, "r");
|
|
|
|
if (!statmfile)
|
2014-11-24 20:55:49 +00:00
|
|
|
return false;
|
2020-09-28 10:01:56 +00:00
|
|
|
int r = fscanf(statmfile, "%ld %ld %ld %ld %ld %ld %ld",
|
|
|
|
&process->super.m_size,
|
|
|
|
&process->super.m_resident,
|
|
|
|
&process->m_share,
|
|
|
|
&process->m_trs,
|
|
|
|
&process->m_lrs,
|
|
|
|
&process->m_drs,
|
|
|
|
&process->m_dt);
|
|
|
|
fclose(statmfile);
|
|
|
|
return r == 7;
|
2014-11-24 20:55:49 +00:00
|
|
|
}
|
|
|
|
|
2018-10-16 18:08:23 +00:00
|
|
|
static bool LinuxProcessList_readSmapsFile(LinuxProcess* process, const char* dirname, const char* name, bool haveSmapsRollup) {
|
2018-10-09 19:49:29 +00:00
|
|
|
//http://elixir.free-electrons.com/linux/v4.10/source/fs/proc/task_mmu.c#L719
|
|
|
|
//kernel will return data in chunks of size PAGE_SIZE or less.
|
|
|
|
|
|
|
|
char buffer[PAGE_SIZE];// 4k
|
|
|
|
char *start,*end;
|
|
|
|
ssize_t nread=0;
|
|
|
|
int tmp=0;
|
2018-10-16 18:08:23 +00:00
|
|
|
if(haveSmapsRollup) {// only available in Linux 4.14+
|
2020-08-19 07:50:43 +00:00
|
|
|
snprintf(buffer, PAGE_SIZE-1, "%s/%s/smaps_rollup", dirname, name);
|
2018-10-16 18:08:23 +00:00
|
|
|
} else {
|
2020-08-19 07:50:43 +00:00
|
|
|
snprintf(buffer, PAGE_SIZE-1, "%s/%s/smaps", dirname, name);
|
2018-10-16 18:08:23 +00:00
|
|
|
}
|
2018-10-09 19:49:29 +00:00
|
|
|
int fd = open(buffer, O_RDONLY);
|
|
|
|
if (fd == -1)
|
|
|
|
return false;
|
|
|
|
|
|
|
|
process->m_pss = 0;
|
|
|
|
process->m_swap = 0;
|
|
|
|
process->m_psswp = 0;
|
|
|
|
|
|
|
|
while ( ( nread = read(fd,buffer, sizeof(buffer)) ) > 0 ){
|
|
|
|
start = (char *)&buffer;
|
|
|
|
end = start + nread;
|
|
|
|
do{//parse 4k block
|
|
|
|
|
|
|
|
if( (tmp = (end - start)) > 0 &&
|
|
|
|
(start = memmem(start,tmp,"\nPss:",5)) != NULL )
|
|
|
|
{
|
|
|
|
process->m_pss += strtol(start+5, &start, 10);
|
|
|
|
start += 3;//now we must be at the end of line "Pss: 0 kB"
|
|
|
|
}else
|
|
|
|
break; //read next 4k block
|
|
|
|
|
|
|
|
if( (tmp = (end - start)) > 0 &&
|
|
|
|
(start = memmem(start,tmp,"\nSwap:",6)) != NULL )
|
|
|
|
{
|
|
|
|
process->m_swap += strtol(start+6, &start, 10);
|
|
|
|
start += 3;
|
|
|
|
}else
|
|
|
|
break;
|
|
|
|
|
|
|
|
if( (tmp = (end - start)) > 0 &&
|
|
|
|
(start = memmem(start,tmp,"\nSwapPss:",9)) != NULL )
|
|
|
|
{
|
|
|
|
process->m_psswp += strtol(start+9, &start, 10);
|
|
|
|
start += 3;
|
|
|
|
}else
|
|
|
|
break;
|
|
|
|
|
|
|
|
}while(1);
|
|
|
|
}//while read
|
|
|
|
close(fd);
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
2014-11-24 20:55:49 +00:00
|
|
|
#ifdef HAVE_OPENVZ
|
|
|
|
|
2015-05-13 18:00:58 +00:00
|
|
|
static void LinuxProcessList_readOpenVZData(LinuxProcess* process, const char* dirname, const char* name) {
|
2020-09-15 10:29:46 +00:00
|
|
|
if ( (access(PROCDIR "/vz", R_OK) != 0)) {
|
2020-09-30 21:46:52 +00:00
|
|
|
free(process->ctid);
|
|
|
|
process->ctid = NULL;
|
2015-05-13 18:00:58 +00:00
|
|
|
process->vpid = process->super.pid;
|
2014-11-24 20:55:49 +00:00
|
|
|
return;
|
|
|
|
}
|
2020-09-30 21:46:52 +00:00
|
|
|
|
2014-11-24 20:55:49 +00:00
|
|
|
char filename[MAX_NAME+1];
|
2020-09-30 21:46:52 +00:00
|
|
|
xSnprintf(filename, sizeof(filename), "%s/%s/status", dirname, name);
|
2014-11-24 20:55:49 +00:00
|
|
|
FILE* file = fopen(filename, "r");
|
2020-09-30 21:46:52 +00:00
|
|
|
if (!file) {
|
|
|
|
free(process->ctid);
|
|
|
|
process->ctid = NULL;
|
|
|
|
process->vpid = process->super.pid;
|
2014-11-24 20:55:49 +00:00
|
|
|
return;
|
2020-09-30 21:46:52 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
bool foundEnvID = false;
|
|
|
|
bool foundVPid = false;
|
|
|
|
char linebuf[256];
|
|
|
|
while(fgets(linebuf, sizeof(linebuf), file) != NULL) {
|
|
|
|
if(strchr(linebuf, '\n') == NULL) {
|
|
|
|
// Partial line, skip to end of this line
|
|
|
|
while(fgets(linebuf, sizeof(linebuf), file) != NULL) {
|
|
|
|
if(strchr(linebuf, '\n') != NULL) {
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
|
|
|
char* name_value_sep = strchr(linebuf, ':');
|
|
|
|
if(name_value_sep == NULL) {
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
|
|
|
int field;
|
|
|
|
if(0 == strncasecmp(linebuf, "envID", name_value_sep - linebuf)) {
|
|
|
|
field = 1;
|
|
|
|
} else if(0 == strncasecmp(linebuf, "VPid", name_value_sep - linebuf)) {
|
|
|
|
field = 2;
|
|
|
|
} else {
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
|
|
|
do {
|
|
|
|
name_value_sep++;
|
|
|
|
} while(*name_value_sep != '\0' && *name_value_sep <= 32);
|
|
|
|
|
|
|
|
char* value_end = name_value_sep;
|
|
|
|
|
|
|
|
while(*value_end != '\0' && *value_end > 32) {
|
|
|
|
value_end++;
|
|
|
|
}
|
|
|
|
|
|
|
|
if(name_value_sep == value_end) {
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
|
|
|
*value_end = '\0';
|
|
|
|
|
|
|
|
switch(field) {
|
|
|
|
case 1:
|
|
|
|
foundEnvID = true;
|
2020-10-03 19:20:43 +00:00
|
|
|
if(!String_eq(name_value_sep, process->ctid ? process->ctid : "")) {
|
2020-09-30 21:46:52 +00:00
|
|
|
free(process->ctid);
|
|
|
|
process->ctid = xStrdup(name_value_sep);
|
|
|
|
}
|
|
|
|
break;
|
|
|
|
case 2:
|
|
|
|
foundVPid = true;
|
|
|
|
process->vpid = strtoul(name_value_sep, NULL, 0);
|
|
|
|
break;
|
|
|
|
default:
|
|
|
|
//Sanity Check: Should never reach here, or the implementation is missing something!
|
|
|
|
assert(false && "OpenVZ handling: Unimplemented case for field handling reached.");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2014-11-24 20:55:49 +00:00
|
|
|
fclose(file);
|
2020-09-30 21:46:52 +00:00
|
|
|
|
|
|
|
if(!foundEnvID) {
|
|
|
|
free(process->ctid);
|
|
|
|
process->ctid = NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
if(!foundVPid) {
|
|
|
|
process->vpid = process->super.pid;
|
|
|
|
}
|
2014-11-24 20:55:49 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
#endif
|
|
|
|
|
|
|
|
#ifdef HAVE_CGROUP
|
|
|
|
|
2015-03-16 04:43:04 +00:00
|
|
|
static void LinuxProcessList_readCGroupFile(LinuxProcess* process, const char* dirname, const char* name) {
|
2014-11-24 20:55:49 +00:00
|
|
|
char filename[MAX_NAME+1];
|
2017-07-27 19:07:50 +00:00
|
|
|
xSnprintf(filename, MAX_NAME, "%s/%s/cgroup", dirname, name);
|
2014-11-24 20:55:49 +00:00
|
|
|
FILE* file = fopen(filename, "r");
|
|
|
|
if (!file) {
|
2020-09-21 11:47:39 +00:00
|
|
|
if (process->cgroup) {
|
|
|
|
free(process->cgroup);
|
|
|
|
process->cgroup = NULL;
|
|
|
|
}
|
2014-11-24 20:55:49 +00:00
|
|
|
return;
|
|
|
|
}
|
2015-12-14 15:27:11 +00:00
|
|
|
char output[PROC_LINE_LENGTH + 1];
|
2015-03-08 22:47:49 +00:00
|
|
|
output[0] = '\0';
|
|
|
|
char* at = output;
|
2015-12-14 15:27:11 +00:00
|
|
|
int left = PROC_LINE_LENGTH;
|
2015-03-08 22:47:49 +00:00
|
|
|
while (!feof(file) && left > 0) {
|
2015-12-14 15:27:11 +00:00
|
|
|
char buffer[PROC_LINE_LENGTH + 1];
|
|
|
|
char *ok = fgets(buffer, PROC_LINE_LENGTH, file);
|
2015-03-08 22:47:49 +00:00
|
|
|
if (!ok) break;
|
|
|
|
char* group = strchr(buffer, ':');
|
|
|
|
if (!group) break;
|
|
|
|
if (at != output) {
|
|
|
|
*at = ';';
|
|
|
|
at++;
|
|
|
|
left--;
|
2014-11-24 20:55:49 +00:00
|
|
|
}
|
2017-08-01 22:48:43 +00:00
|
|
|
int wrote = snprintf(at, left, "%s", group);
|
2015-03-08 22:47:49 +00:00
|
|
|
left -= wrote;
|
2014-11-24 20:55:49 +00:00
|
|
|
}
|
|
|
|
fclose(file);
|
2015-03-08 22:47:49 +00:00
|
|
|
free(process->cgroup);
|
2016-02-02 14:53:02 +00:00
|
|
|
process->cgroup = xStrdup(output);
|
2014-11-24 20:55:49 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
#endif
|
|
|
|
|
|
|
|
#ifdef HAVE_VSERVER
|
|
|
|
|
2015-03-16 04:43:04 +00:00
|
|
|
static void LinuxProcessList_readVServerData(LinuxProcess* process, const char* dirname, const char* name) {
|
2014-11-24 20:55:49 +00:00
|
|
|
char filename[MAX_NAME+1];
|
2017-07-27 19:07:50 +00:00
|
|
|
xSnprintf(filename, MAX_NAME, "%s/%s/status", dirname, name);
|
2014-11-24 20:55:49 +00:00
|
|
|
FILE* file = fopen(filename, "r");
|
|
|
|
if (!file)
|
|
|
|
return;
|
2015-12-14 15:27:11 +00:00
|
|
|
char buffer[PROC_LINE_LENGTH + 1];
|
2014-11-24 20:55:49 +00:00
|
|
|
process->vxid = 0;
|
2015-12-14 15:27:11 +00:00
|
|
|
while (fgets(buffer, PROC_LINE_LENGTH, file)) {
|
2014-11-24 20:55:49 +00:00
|
|
|
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
|
|
|
|
|
2015-03-16 04:43:04 +00:00
|
|
|
static void LinuxProcessList_readOomData(LinuxProcess* process, const char* dirname, const char* name) {
|
2014-11-24 20:55:49 +00:00
|
|
|
char filename[MAX_NAME+1];
|
2017-07-27 19:07:50 +00:00
|
|
|
xSnprintf(filename, MAX_NAME, "%s/%s/oom_score", dirname, name);
|
2014-11-24 20:55:49 +00:00
|
|
|
FILE* file = fopen(filename, "r");
|
2017-07-10 23:57:34 +00:00
|
|
|
if (!file) {
|
2014-11-24 20:55:49 +00:00
|
|
|
return;
|
2017-07-10 23:57:34 +00:00
|
|
|
}
|
2015-12-14 15:27:11 +00:00
|
|
|
char buffer[PROC_LINE_LENGTH + 1];
|
|
|
|
if (fgets(buffer, PROC_LINE_LENGTH, file)) {
|
2014-11-24 20:55:49 +00:00
|
|
|
unsigned int oom;
|
2020-08-28 12:24:40 +00:00
|
|
|
int ok = sscanf(buffer, "%u", &oom);
|
2014-11-24 20:55:49 +00:00
|
|
|
if (ok >= 1) {
|
|
|
|
process->oom = oom;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
fclose(file);
|
|
|
|
}
|
|
|
|
|
2020-09-11 13:02:00 +00:00
|
|
|
static void LinuxProcessList_readCtxtData(LinuxProcess* process, const char* dirname, const char* name) {
|
|
|
|
char filename[MAX_NAME+1];
|
|
|
|
xSnprintf(filename, MAX_NAME, "%s/%s/status", dirname, name);
|
|
|
|
FILE* file = fopen(filename, "r");
|
|
|
|
if (!file)
|
|
|
|
return;
|
|
|
|
char buffer[PROC_LINE_LENGTH + 1];
|
|
|
|
unsigned long ctxt = 0;
|
|
|
|
while (fgets(buffer, PROC_LINE_LENGTH, file)) {
|
|
|
|
if (String_startsWith(buffer, "voluntary_ctxt_switches:")) {
|
|
|
|
unsigned long vctxt;
|
|
|
|
int ok = sscanf(buffer, "voluntary_ctxt_switches:\t%lu", &vctxt);
|
|
|
|
if (ok >= 1)
|
|
|
|
ctxt += vctxt;
|
|
|
|
} else if (String_startsWith(buffer, "nonvoluntary_ctxt_switches:")) {
|
|
|
|
unsigned long nvctxt;
|
|
|
|
int ok = sscanf(buffer, "nonvoluntary_ctxt_switches:\t%lu", &nvctxt);
|
|
|
|
if (ok >= 1)
|
|
|
|
ctxt += nvctxt;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
fclose(file);
|
|
|
|
process->ctxt_diff = (ctxt > process->ctxt_total) ? (ctxt - process->ctxt_total) : 0;
|
|
|
|
process->ctxt_total = ctxt;
|
|
|
|
}
|
|
|
|
|
2020-09-28 10:06:13 +00:00
|
|
|
static void LinuxProcessList_readSecattrData(LinuxProcess* process, const char* dirname, const char* name) {
|
|
|
|
char filename[MAX_NAME+1];
|
|
|
|
xSnprintf(filename, sizeof(filename), "%s/%s/attr/current", dirname, name);
|
|
|
|
FILE* file = fopen(filename, "r");
|
|
|
|
if (!file) {
|
|
|
|
free(process->secattr);
|
|
|
|
process->secattr = NULL;
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
char buffer[PROC_LINE_LENGTH + 1];
|
|
|
|
char *res = fgets(buffer, sizeof(buffer), file);
|
|
|
|
fclose(file);
|
|
|
|
if (!res) {
|
|
|
|
free(process->secattr);
|
|
|
|
process->secattr = NULL;
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
char *newline = strchr(buffer, '\n');
|
|
|
|
if (newline)
|
|
|
|
*newline = '\0';
|
2020-10-03 19:20:43 +00:00
|
|
|
if (process->secattr && String_eq(process->secattr, buffer))
|
2020-09-28 10:06:13 +00:00
|
|
|
return;
|
|
|
|
free(process->secattr);
|
|
|
|
process->secattr = xStrdup(buffer);
|
|
|
|
}
|
|
|
|
|
2017-12-04 02:15:29 +00:00
|
|
|
#ifdef HAVE_DELAYACCT
|
|
|
|
|
|
|
|
static int handleNetlinkMsg(struct nl_msg *nlmsg, void *linuxProcess) {
|
|
|
|
struct nlmsghdr *nlhdr;
|
2018-02-17 22:52:07 +00:00
|
|
|
struct nlattr *nlattrs[TASKSTATS_TYPE_MAX + 1];
|
|
|
|
struct nlattr *nlattr;
|
2020-10-17 21:28:26 +00:00
|
|
|
struct taskstats stats;
|
2018-02-17 22:52:07 +00:00
|
|
|
int rem;
|
|
|
|
unsigned long long int timeDelta;
|
|
|
|
LinuxProcess* lp = (LinuxProcess*) linuxProcess;
|
2017-12-04 02:15:29 +00:00
|
|
|
|
2018-02-17 22:52:07 +00:00
|
|
|
nlhdr = nlmsg_hdr(nlmsg);
|
2017-12-04 02:15:29 +00:00
|
|
|
|
|
|
|
if (genlmsg_parse(nlhdr, 0, nlattrs, TASKSTATS_TYPE_MAX, NULL) < 0) {
|
|
|
|
return NL_SKIP;
|
2018-02-17 22:52:07 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
if ((nlattr = nlattrs[TASKSTATS_TYPE_AGGR_PID]) || (nlattr = nlattrs[TASKSTATS_TYPE_NULL])) {
|
2020-10-17 21:28:26 +00:00
|
|
|
memcpy(&stats, nla_data(nla_next(nla_data(nlattr), &rem)), sizeof(stats));
|
|
|
|
assert(lp->super.pid == (pid_t)stats.ac_pid);
|
|
|
|
|
|
|
|
timeDelta = (stats.ac_etime*1000 - lp->delay_read_time);
|
2018-02-17 22:52:07 +00:00
|
|
|
#define BOUNDS(x) isnan(x) ? 0.0 : (x > 100) ? 100.0 : x;
|
|
|
|
#define DELTAPERC(x,y) BOUNDS((float) (x - y) / timeDelta * 100);
|
2020-10-17 21:28:26 +00:00
|
|
|
lp->cpu_delay_percent = DELTAPERC(stats.cpu_delay_total, lp->cpu_delay_total);
|
|
|
|
lp->blkio_delay_percent = DELTAPERC(stats.blkio_delay_total, lp->blkio_delay_total);
|
|
|
|
lp->swapin_delay_percent = DELTAPERC(stats.swapin_delay_total, lp->swapin_delay_total);
|
2018-02-17 22:52:07 +00:00
|
|
|
#undef DELTAPERC
|
|
|
|
#undef BOUNDS
|
2020-10-17 21:28:26 +00:00
|
|
|
lp->swapin_delay_total = stats.swapin_delay_total;
|
|
|
|
lp->blkio_delay_total = stats.blkio_delay_total;
|
|
|
|
lp->cpu_delay_total = stats.cpu_delay_total;
|
|
|
|
lp->delay_read_time = stats.ac_etime*1000;
|
2018-02-17 22:52:07 +00:00
|
|
|
}
|
|
|
|
return NL_OK;
|
2017-12-04 02:15:29 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
static void LinuxProcessList_readDelayAcctData(LinuxProcessList* this, LinuxProcess* process) {
|
|
|
|
struct nl_msg *msg;
|
|
|
|
|
|
|
|
if (nl_socket_modify_cb(this->netlink_socket, NL_CB_VALID, NL_CB_CUSTOM, handleNetlinkMsg, process) < 0) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (! (msg = nlmsg_alloc())) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (! genlmsg_put(msg, NL_AUTO_PID, NL_AUTO_SEQ, this->netlink_family, 0, NLM_F_REQUEST, TASKSTATS_CMD_GET, TASKSTATS_VERSION)) {
|
|
|
|
nlmsg_free(msg);
|
|
|
|
}
|
|
|
|
|
|
|
|
if (nla_put_u32(msg, TASKSTATS_CMD_ATTR_PID, process->super.pid) < 0) {
|
|
|
|
nlmsg_free(msg);
|
|
|
|
}
|
|
|
|
|
|
|
|
if (nl_send_sync(this->netlink_socket, msg) < 0) {
|
2020-09-18 15:04:01 +00:00
|
|
|
process->swapin_delay_percent = NAN;
|
|
|
|
process->blkio_delay_percent = NAN;
|
|
|
|
process->cpu_delay_percent = NAN;
|
2017-12-04 02:15:29 +00:00
|
|
|
return;
|
|
|
|
}
|
2019-10-31 16:39:12 +00:00
|
|
|
|
2017-12-04 02:15:29 +00:00
|
|
|
if (nl_recvmsgs_default(this->netlink_socket) < 0) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
#endif
|
|
|
|
|
2016-02-02 14:56:52 +00:00
|
|
|
static void setCommand(Process* process, const char* command, int len) {
|
2016-02-13 04:18:28 +00:00
|
|
|
if (process->comm && process->commLen >= len) {
|
2016-02-02 14:56:52 +00:00
|
|
|
strncpy(process->comm, command, len + 1);
|
|
|
|
} else {
|
|
|
|
free(process->comm);
|
|
|
|
process->comm = xStrdup(command);
|
|
|
|
}
|
|
|
|
process->commLen = len;
|
|
|
|
}
|
|
|
|
|
2014-11-24 20:55:49 +00:00
|
|
|
static bool LinuxProcessList_readCmdlineFile(Process* process, const char* dirname, const char* name) {
|
|
|
|
char filename[MAX_NAME+1];
|
2017-07-27 19:07:50 +00:00
|
|
|
xSnprintf(filename, MAX_NAME, "%s/%s/cmdline", dirname, name);
|
2014-11-24 20:55:49 +00:00
|
|
|
int fd = open(filename, O_RDONLY);
|
|
|
|
if (fd == -1)
|
|
|
|
return false;
|
2019-10-31 16:39:12 +00:00
|
|
|
|
2014-11-24 20:55:49 +00:00
|
|
|
char command[4096+1]; // max cmdline length on Linux
|
|
|
|
int amtRead = xread(fd, command, sizeof(command) - 1);
|
|
|
|
close(fd);
|
2019-10-31 16:39:12 +00:00
|
|
|
int tokenEnd = 0;
|
2016-06-15 15:41:50 +00:00
|
|
|
int lastChar = 0;
|
2018-03-25 18:26:05 +00:00
|
|
|
if (amtRead == 0) {
|
2019-12-13 12:05:28 +00:00
|
|
|
if (process->state == 'Z') {
|
|
|
|
process->basenameOffset = 0;
|
|
|
|
} else {
|
|
|
|
((LinuxProcess*)process)->isKernelThread = true;
|
|
|
|
}
|
2018-03-25 18:26:05 +00:00
|
|
|
return true;
|
|
|
|
} else if (amtRead < 0) {
|
2016-08-24 21:11:10 +00:00
|
|
|
return false;
|
|
|
|
}
|
|
|
|
for (int i = 0; i < amtRead; i++) {
|
|
|
|
if (command[i] == '\0' || command[i] == '\n') {
|
|
|
|
if (tokenEnd == 0) {
|
|
|
|
tokenEnd = i;
|
2014-11-24 20:55:49 +00:00
|
|
|
}
|
2016-08-24 21:11:10 +00:00
|
|
|
command[i] = ' ';
|
|
|
|
} else {
|
|
|
|
lastChar = i;
|
|
|
|
}
|
2014-11-24 20:55:49 +00:00
|
|
|
}
|
|
|
|
if (tokenEnd == 0) {
|
|
|
|
tokenEnd = amtRead;
|
|
|
|
}
|
2016-06-15 15:41:50 +00:00
|
|
|
command[lastChar + 1] = '\0';
|
2014-11-24 20:55:49 +00:00
|
|
|
process->basenameOffset = tokenEnd;
|
2018-07-28 03:08:40 +00:00
|
|
|
setCommand(process, command, lastChar + 1);
|
2014-11-24 20:55:49 +00:00
|
|
|
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
2016-10-01 06:09:04 +00:00
|
|
|
static char* LinuxProcessList_updateTtyDevice(TtyDriver* ttyDrivers, unsigned int tty_nr) {
|
|
|
|
unsigned int maj = major(tty_nr);
|
|
|
|
unsigned int min = minor(tty_nr);
|
|
|
|
|
|
|
|
int i = -1;
|
|
|
|
for (;;) {
|
|
|
|
i++;
|
|
|
|
if ((!ttyDrivers[i].path) || maj < ttyDrivers[i].major) {
|
|
|
|
break;
|
2019-10-31 16:39:12 +00:00
|
|
|
}
|
2016-10-01 06:09:04 +00:00
|
|
|
if (maj > ttyDrivers[i].major) {
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
if (min < ttyDrivers[i].minorFrom) {
|
|
|
|
break;
|
2019-10-31 16:39:12 +00:00
|
|
|
}
|
2016-10-01 06:09:04 +00:00
|
|
|
if (min > ttyDrivers[i].minorTo) {
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
unsigned int idx = min - ttyDrivers[i].minorFrom;
|
|
|
|
struct stat sstat;
|
|
|
|
char* fullPath;
|
|
|
|
for(;;) {
|
2020-08-21 08:37:29 +00:00
|
|
|
xAsprintf(&fullPath, "%s/%d", ttyDrivers[i].path, idx);
|
2016-10-01 06:09:04 +00:00
|
|
|
int err = stat(fullPath, &sstat);
|
|
|
|
if (err == 0 && major(sstat.st_rdev) == maj && minor(sstat.st_rdev) == min) return fullPath;
|
|
|
|
free(fullPath);
|
2020-08-21 08:37:29 +00:00
|
|
|
xAsprintf(&fullPath, "%s%d", ttyDrivers[i].path, idx);
|
2016-10-01 06:09:04 +00:00
|
|
|
err = stat(fullPath, &sstat);
|
|
|
|
if (err == 0 && major(sstat.st_rdev) == maj && minor(sstat.st_rdev) == min) return fullPath;
|
|
|
|
free(fullPath);
|
|
|
|
if (idx == min) break;
|
|
|
|
idx = min;
|
|
|
|
}
|
|
|
|
int err = stat(ttyDrivers[i].path, &sstat);
|
2020-09-21 12:27:32 +00:00
|
|
|
if (err == 0 && tty_nr == sstat.st_rdev) return xStrdup(ttyDrivers[i].path);
|
2016-10-01 06:09:04 +00:00
|
|
|
}
|
|
|
|
char* out;
|
2020-08-21 08:37:29 +00:00
|
|
|
xAsprintf(&out, "/dev/%u:%u", maj, min);
|
2016-10-01 06:09:04 +00:00
|
|
|
return out;
|
|
|
|
}
|
|
|
|
|
2015-03-17 02:01:48 +00:00
|
|
|
static bool LinuxProcessList_recurseProcTree(LinuxProcessList* this, const char* dirname, Process* parent, double period, struct timeval tv) {
|
2015-03-16 06:25:43 +00:00
|
|
|
ProcessList* pl = (ProcessList*) this;
|
2014-11-24 20:55:49 +00:00
|
|
|
DIR* dir;
|
|
|
|
struct dirent* entry;
|
2015-03-17 02:01:48 +00:00
|
|
|
Settings* settings = pl->settings;
|
2014-11-24 20:55:49 +00:00
|
|
|
|
|
|
|
#ifdef HAVE_TASKSTATS
|
|
|
|
unsigned long long now = tv.tv_sec*1000LL+tv.tv_usec/1000LL;
|
|
|
|
#endif
|
|
|
|
|
|
|
|
dir = opendir(dirname);
|
|
|
|
if (!dir) return false;
|
2015-03-17 02:01:48 +00:00
|
|
|
int cpus = pl->cpuCount;
|
2015-01-22 01:27:31 +00:00
|
|
|
bool hideKernelThreads = settings->hideKernelThreads;
|
|
|
|
bool hideUserlandThreads = settings->hideUserlandThreads;
|
2014-11-24 20:55:49 +00:00
|
|
|
while ((entry = readdir(dir)) != NULL) {
|
|
|
|
char* name = entry->d_name;
|
|
|
|
|
|
|
|
// The RedHat kernel hides threads with a dot.
|
|
|
|
// I believe this is non-standard.
|
2015-01-22 01:27:31 +00:00
|
|
|
if ((!settings->hideThreads) && name[0] == '.') {
|
2014-11-24 20:55:49 +00:00
|
|
|
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);
|
2019-10-31 16:39:12 +00:00
|
|
|
|
2014-11-24 20:55:49 +00:00
|
|
|
if (parent && pid == parent->pid)
|
|
|
|
continue;
|
|
|
|
|
2019-10-31 16:39:12 +00:00
|
|
|
if (pid <= 0)
|
2014-11-24 20:55:49 +00:00
|
|
|
continue;
|
|
|
|
|
2015-03-17 02:01:48 +00:00
|
|
|
bool preExisting = false;
|
2015-04-02 04:57:37 +00:00
|
|
|
Process* proc = ProcessList_getProcess(pl, pid, &preExisting, (Process_New) LinuxProcess_new);
|
2015-03-17 02:01:48 +00:00
|
|
|
proc->tgid = parent ? parent->pid : pid;
|
2019-10-31 16:39:12 +00:00
|
|
|
|
2015-03-16 04:43:04 +00:00
|
|
|
LinuxProcess* lp = (LinuxProcess*) proc;
|
2014-11-24 20:55:49 +00:00
|
|
|
|
|
|
|
char subdirname[MAX_NAME+1];
|
2017-07-27 19:07:50 +00:00
|
|
|
xSnprintf(subdirname, MAX_NAME, "%s/%s/task", dirname, name);
|
2015-03-17 02:01:48 +00:00
|
|
|
LinuxProcessList_recurseProcTree(this, subdirname, proc, period, tv);
|
2014-11-24 20:55:49 +00:00
|
|
|
|
|
|
|
#ifdef HAVE_TASKSTATS
|
2015-01-22 01:27:31 +00:00
|
|
|
if (settings->flags & PROCESS_FLAG_IO)
|
2015-03-16 04:43:04 +00:00
|
|
|
LinuxProcessList_readIoFile(lp, dirname, name, now);
|
2014-11-24 20:55:49 +00:00
|
|
|
#endif
|
|
|
|
|
2015-03-16 04:43:04 +00:00
|
|
|
if (! LinuxProcessList_readStatmFile(lp, dirname, name))
|
2014-11-24 20:55:49 +00:00
|
|
|
goto errorReadingProcess;
|
|
|
|
|
2018-10-09 19:49:29 +00:00
|
|
|
if ((settings->flags & PROCESS_FLAG_LINUX_SMAPS) && !Process_isKernelThread(proc)){
|
|
|
|
if (!parent){
|
|
|
|
// Read smaps file of each process only every second pass to improve performance
|
|
|
|
static int smaps_flag = 0;
|
|
|
|
if ((pid & 1) == smaps_flag){
|
2018-10-16 18:08:23 +00:00
|
|
|
LinuxProcessList_readSmapsFile(lp, dirname, name, this->haveSmapsRollup);
|
2018-10-09 19:49:29 +00:00
|
|
|
}
|
|
|
|
if (pid == 1) {
|
|
|
|
smaps_flag = !smaps_flag;
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
lp->m_pss = ((LinuxProcess*)parent)->m_pss;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2015-03-16 04:43:04 +00:00
|
|
|
proc->show = ! ((hideKernelThreads && Process_isKernelThread(proc)) || (hideUserlandThreads && Process_isUserlandThread(proc)));
|
2014-11-24 20:55:49 +00:00
|
|
|
|
|
|
|
char command[MAX_NAME+1];
|
2015-03-16 04:43:04 +00:00
|
|
|
unsigned long long int lasttimes = (lp->utime + lp->stime);
|
2020-09-15 17:55:21 +00:00
|
|
|
int commLen = sizeof(command);
|
2016-10-01 06:09:04 +00:00
|
|
|
unsigned int tty_nr = proc->tty_nr;
|
2016-02-02 14:56:52 +00:00
|
|
|
if (! LinuxProcessList_readStatFile(proc, dirname, name, command, &commLen))
|
2014-11-24 20:55:49 +00:00
|
|
|
goto errorReadingProcess;
|
2016-10-01 06:09:04 +00:00
|
|
|
if (tty_nr != proc->tty_nr && this->ttyDrivers) {
|
|
|
|
free(lp->ttyDevice);
|
|
|
|
lp->ttyDevice = LinuxProcessList_updateTtyDevice(this->ttyDrivers, proc->tty_nr);
|
|
|
|
}
|
2015-03-15 23:29:13 +00:00
|
|
|
if (settings->flags & PROCESS_FLAG_LINUX_IOPRIO)
|
2015-03-16 04:43:04 +00:00
|
|
|
LinuxProcess_updateIOPriority(lp);
|
|
|
|
float percent_cpu = (lp->utime + lp->stime - lasttimes) / period * 100.0;
|
Introduce CLAMP macro. Unify all MIN(MAX(a,b),c) uses.
With the CLAMP macro replacing the combination of MIN and MAX, we will
have at least two advantages:
1. It's more obvious semantically.
2. There are no more mixes of confusing uses like MIN(MAX(a,b),c) and
MAX(MIN(a,b),c) and MIN(a,MAX(b,c)) appearing everywhere. We unify
the 'clamping' with a single macro.
Note that the behavior of this CLAMP macro is different from
the combination `MAX(low,MIN(x,high))`.
* This CLAMP macro expands to two comparisons instead of three from
MAX and MIN combination. In theory, this makes the code slightly
smaller, in case that (low) or (high) or both are computed at
runtime, so that compilers cannot optimize them. (The third
comparison will matter if (low)>(high); see below.)
* CLAMP has a side effect, that if (low)>(high) it will produce weird
results. Unlike MIN & MAX which will force either (low) or (high) to
win. No assertion of ((low)<=(high)) is done in this macro, for now.
This CLAMP macro is implemented like described in glib
<http://developer.gnome.org/glib/stable/glib-Standard-Macros.html>
and does not handle weird uses like CLAMP(a++, low++, high--) .
2016-01-15 12:26:01 +00:00
|
|
|
proc->percent_cpu = CLAMP(percent_cpu, 0.0, cpus * 100.0);
|
2015-03-16 04:43:04 +00:00
|
|
|
if (isnan(proc->percent_cpu)) proc->percent_cpu = 0.0;
|
2015-03-16 06:25:43 +00:00
|
|
|
proc->percent_mem = (proc->m_resident * PAGE_SIZE_KB) / (double)(pl->totalMem) * 100.0;
|
2014-11-24 20:55:49 +00:00
|
|
|
|
2015-03-17 02:01:48 +00:00
|
|
|
if(!preExisting) {
|
2014-11-24 20:55:49 +00:00
|
|
|
|
2018-08-24 21:05:58 +00:00
|
|
|
if (! LinuxProcessList_statProcessDir(proc, dirname, name))
|
2014-11-24 20:55:49 +00:00
|
|
|
goto errorReadingProcess;
|
|
|
|
|
2015-03-17 02:01:48 +00:00
|
|
|
proc->user = UsersTable_getRef(pl->usersTable, proc->st_uid);
|
2014-11-24 20:55:49 +00:00
|
|
|
|
|
|
|
#ifdef HAVE_OPENVZ
|
2015-05-13 18:00:58 +00:00
|
|
|
if (settings->flags & PROCESS_FLAG_LINUX_OPENVZ) {
|
|
|
|
LinuxProcessList_readOpenVZData(lp, dirname, name);
|
|
|
|
}
|
2014-11-24 20:55:49 +00:00
|
|
|
#endif
|
2019-10-31 16:39:12 +00:00
|
|
|
|
2014-11-24 20:55:49 +00:00
|
|
|
#ifdef HAVE_VSERVER
|
2015-05-13 18:00:58 +00:00
|
|
|
if (settings->flags & PROCESS_FLAG_LINUX_VSERVER) {
|
2015-03-16 04:43:04 +00:00
|
|
|
LinuxProcessList_readVServerData(lp, dirname, name);
|
2015-05-13 18:00:58 +00:00
|
|
|
}
|
2014-11-24 20:55:49 +00:00
|
|
|
#endif
|
|
|
|
|
2015-05-13 18:00:58 +00:00
|
|
|
if (! LinuxProcessList_readCmdlineFile(proc, dirname, name)) {
|
2014-11-24 20:55:49 +00:00
|
|
|
goto errorReadingProcess;
|
2015-05-13 18:00:58 +00:00
|
|
|
}
|
2014-11-24 20:55:49 +00:00
|
|
|
|
2020-10-13 12:26:40 +00:00
|
|
|
Process_fillStarttimeBuffer(proc);
|
2020-10-12 10:51:18 +00:00
|
|
|
|
2015-03-17 02:01:48 +00:00
|
|
|
ProcessList_add(pl, proc);
|
2014-11-24 20:55:49 +00:00
|
|
|
} else {
|
2016-02-19 22:51:57 +00:00
|
|
|
if (settings->updateProcessNames && proc->state != 'Z') {
|
2015-05-13 18:00:58 +00:00
|
|
|
if (! LinuxProcessList_readCmdlineFile(proc, dirname, name)) {
|
2014-11-24 20:55:49 +00:00
|
|
|
goto errorReadingProcess;
|
2015-05-13 18:00:58 +00:00
|
|
|
}
|
2014-11-24 20:55:49 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2017-12-04 02:15:29 +00:00
|
|
|
#ifdef HAVE_DELAYACCT
|
|
|
|
LinuxProcessList_readDelayAcctData(this, lp);
|
|
|
|
#endif
|
|
|
|
|
2014-11-24 20:55:49 +00:00
|
|
|
#ifdef HAVE_CGROUP
|
2015-03-15 23:29:13 +00:00
|
|
|
if (settings->flags & PROCESS_FLAG_LINUX_CGROUP)
|
2015-03-16 04:43:04 +00:00
|
|
|
LinuxProcessList_readCGroupFile(lp, dirname, name);
|
2014-11-24 20:55:49 +00:00
|
|
|
#endif
|
2019-10-31 16:39:12 +00:00
|
|
|
|
2015-04-09 18:41:21 +00:00
|
|
|
if (settings->flags & PROCESS_FLAG_LINUX_OOM)
|
|
|
|
LinuxProcessList_readOomData(lp, dirname, name);
|
2014-11-24 20:55:49 +00:00
|
|
|
|
2020-09-11 13:02:00 +00:00
|
|
|
if (settings->flags & PROCESS_FLAG_LINUX_CTXT)
|
|
|
|
LinuxProcessList_readCtxtData(lp, dirname, name);
|
|
|
|
|
2020-09-28 10:06:13 +00:00
|
|
|
if (settings->flags & PROCESS_FLAG_LINUX_SECATTR)
|
|
|
|
LinuxProcessList_readSecattrData(lp, dirname, name);
|
|
|
|
|
2016-02-19 22:51:57 +00:00
|
|
|
if (proc->state == 'Z' && (proc->basenameOffset == 0)) {
|
2015-03-16 04:43:04 +00:00
|
|
|
proc->basenameOffset = -1;
|
2016-02-02 14:56:52 +00:00
|
|
|
setCommand(proc, command, commLen);
|
2015-03-16 04:43:04 +00:00
|
|
|
} else if (Process_isThread(proc)) {
|
2016-02-19 22:51:57 +00:00
|
|
|
if (settings->showThreadNames || Process_isKernelThread(proc) || (proc->state == 'Z' && proc->basenameOffset == 0)) {
|
2015-03-16 04:43:04 +00:00
|
|
|
proc->basenameOffset = -1;
|
2016-02-02 14:56:52 +00:00
|
|
|
setCommand(proc, command, commLen);
|
2015-01-22 01:27:31 +00:00
|
|
|
} else if (settings->showThreadNames) {
|
2015-03-16 04:43:04 +00:00
|
|
|
if (! LinuxProcessList_readCmdlineFile(proc, dirname, name))
|
2014-11-24 20:55:49 +00:00
|
|
|
goto errorReadingProcess;
|
|
|
|
}
|
2015-03-16 04:43:04 +00:00
|
|
|
if (Process_isKernelThread(proc)) {
|
2015-03-17 02:03:40 +00:00
|
|
|
pl->kernelThreads++;
|
2014-11-24 20:55:49 +00:00
|
|
|
} else {
|
2015-03-17 02:03:40 +00:00
|
|
|
pl->userlandThreads++;
|
2014-11-24 20:55:49 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2015-03-17 02:03:40 +00:00
|
|
|
pl->totalTasks++;
|
2015-03-16 04:43:04 +00:00
|
|
|
if (proc->state == 'R')
|
2015-03-17 02:03:40 +00:00
|
|
|
pl->runningTasks++;
|
2015-03-16 04:43:04 +00:00
|
|
|
proc->updated = true;
|
2014-11-24 20:55:49 +00:00
|
|
|
continue;
|
|
|
|
|
|
|
|
// Exception handler.
|
|
|
|
errorReadingProcess: {
|
2015-03-17 02:01:48 +00:00
|
|
|
if (preExisting) {
|
2015-03-17 02:03:40 +00:00
|
|
|
ProcessList_remove(pl, proc);
|
2015-03-17 02:01:48 +00:00
|
|
|
} else {
|
2015-03-16 04:43:04 +00:00
|
|
|
Process_delete((Object*)proc);
|
2015-03-17 02:01:48 +00:00
|
|
|
}
|
2014-11-24 20:55:49 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
closedir(dir);
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
2015-03-16 06:25:43 +00:00
|
|
|
static inline void LinuxProcessList_scanMemoryInfo(ProcessList* this) {
|
2014-11-27 18:31:42 +00:00
|
|
|
unsigned long long int swapFree = 0;
|
2015-11-29 00:22:00 +00:00
|
|
|
unsigned long long int shmem = 0;
|
|
|
|
unsigned long long int sreclaimable = 0;
|
2014-11-27 18:31:42 +00:00
|
|
|
|
2014-11-24 20:55:49 +00:00
|
|
|
FILE* file = fopen(PROCMEMINFOFILE, "r");
|
|
|
|
if (file == NULL) {
|
|
|
|
CRT_fatalError("Cannot open " PROCMEMINFOFILE);
|
|
|
|
}
|
2014-11-27 18:31:42 +00:00
|
|
|
char buffer[128];
|
|
|
|
while (fgets(buffer, 128, file)) {
|
|
|
|
|
2019-02-10 11:32:47 +00:00
|
|
|
#define tryRead(label, variable) do { if (String_startsWith(buffer, label) && sscanf(buffer + strlen(label), " %32llu kB", variable)) { break; } } while(0)
|
2014-11-27 18:31:42 +00:00
|
|
|
switch (buffer[0]) {
|
|
|
|
case 'M':
|
2019-02-10 11:32:47 +00:00
|
|
|
tryRead("MemTotal:", &this->totalMem);
|
|
|
|
tryRead("MemFree:", &this->freeMem);
|
|
|
|
tryRead("MemShared:", &this->sharedMem);
|
2014-11-27 18:31:42 +00:00
|
|
|
break;
|
|
|
|
case 'B':
|
2019-02-10 11:32:47 +00:00
|
|
|
tryRead("Buffers:", &this->buffersMem);
|
2014-11-27 18:31:42 +00:00
|
|
|
break;
|
|
|
|
case 'C':
|
2019-02-10 11:32:47 +00:00
|
|
|
tryRead("Cached:", &this->cachedMem);
|
2014-11-27 18:31:42 +00:00
|
|
|
break;
|
|
|
|
case 'S':
|
2015-11-29 00:22:00 +00:00
|
|
|
switch (buffer[1]) {
|
|
|
|
case 'w':
|
2019-02-10 11:32:47 +00:00
|
|
|
tryRead("SwapTotal:", &this->totalSwap);
|
|
|
|
tryRead("SwapFree:", &swapFree);
|
2015-11-29 00:22:00 +00:00
|
|
|
break;
|
|
|
|
case 'h':
|
2019-02-10 11:32:47 +00:00
|
|
|
tryRead("Shmem:", &shmem);
|
2015-11-29 00:22:00 +00:00
|
|
|
break;
|
|
|
|
case 'R':
|
2019-02-10 11:32:47 +00:00
|
|
|
tryRead("SReclaimable:", &sreclaimable);
|
2015-11-29 00:22:00 +00:00
|
|
|
break;
|
|
|
|
}
|
2014-11-27 18:31:42 +00:00
|
|
|
break;
|
2014-11-24 20:55:49 +00:00
|
|
|
}
|
2015-11-29 00:22:00 +00:00
|
|
|
#undef tryRead
|
2014-11-24 20:55:49 +00:00
|
|
|
}
|
|
|
|
|
2015-11-30 01:55:31 +00:00
|
|
|
this->usedMem = this->totalMem - this->freeMem;
|
|
|
|
this->cachedMem = this->cachedMem + sreclaimable - shmem;
|
2014-11-24 20:55:49 +00:00
|
|
|
this->usedSwap = this->totalSwap - swapFree;
|
|
|
|
fclose(file);
|
2014-11-27 18:28:32 +00:00
|
|
|
}
|
2014-11-24 20:55:49 +00:00
|
|
|
|
2019-07-07 02:37:02 +00:00
|
|
|
static inline void LinuxProcessList_scanZfsArcstats(LinuxProcessList* lpl) {
|
2020-08-28 13:31:16 +00:00
|
|
|
unsigned long long int dbufSize = 0;
|
|
|
|
unsigned long long int dnodeSize = 0;
|
|
|
|
unsigned long long int bonusSize = 0;
|
2019-07-07 02:37:02 +00:00
|
|
|
|
|
|
|
FILE* file = fopen(PROCARCSTATSFILE, "r");
|
|
|
|
if (file == NULL) {
|
2019-07-07 23:27:00 +00:00
|
|
|
lpl->zfs.enabled = 0;
|
2019-07-07 02:37:02 +00:00
|
|
|
return;
|
|
|
|
}
|
|
|
|
char buffer[128];
|
|
|
|
while (fgets(buffer, 128, file)) {
|
|
|
|
#define tryRead(label, variable) do { if (String_startsWith(buffer, label) && sscanf(buffer + strlen(label), " %*2u %32llu", variable)) { break; } } while(0)
|
2019-09-03 18:26:02 +00:00
|
|
|
#define tryReadFlag(label, variable, flag) do { if (String_startsWith(buffer, label) && sscanf(buffer + strlen(label), " %*2u %32llu", variable)) { flag = 1; break; } else { flag = 0; } } while(0)
|
2019-07-07 02:37:02 +00:00
|
|
|
switch (buffer[0]) {
|
|
|
|
case 'c':
|
2019-07-07 23:27:00 +00:00
|
|
|
tryRead("c_max", &lpl->zfs.max);
|
2019-09-03 19:56:38 +00:00
|
|
|
tryReadFlag("compressed_size", &lpl->zfs.compressed, lpl->zfs.isCompressed);
|
2019-09-03 18:26:02 +00:00
|
|
|
break;
|
|
|
|
case 'u':
|
2019-09-03 19:56:38 +00:00
|
|
|
tryRead("uncompressed_size", &lpl->zfs.uncompressed);
|
2019-07-07 02:37:02 +00:00
|
|
|
break;
|
|
|
|
case 's':
|
2019-07-07 23:27:00 +00:00
|
|
|
tryRead("size", &lpl->zfs.size);
|
2019-07-07 02:37:02 +00:00
|
|
|
break;
|
|
|
|
case 'h':
|
2019-07-07 23:27:00 +00:00
|
|
|
tryRead("hdr_size", &lpl->zfs.header);
|
2019-07-07 02:37:02 +00:00
|
|
|
break;
|
|
|
|
case 'd':
|
|
|
|
tryRead("dbuf_size", &dbufSize);
|
|
|
|
tryRead("dnode_size", &dnodeSize);
|
|
|
|
break;
|
|
|
|
case 'b':
|
|
|
|
tryRead("bonus_size", &bonusSize);
|
|
|
|
break;
|
|
|
|
case 'a':
|
2019-07-07 23:27:00 +00:00
|
|
|
tryRead("anon_size", &lpl->zfs.anon);
|
2019-07-07 02:37:02 +00:00
|
|
|
break;
|
|
|
|
case 'm':
|
2019-07-07 23:27:00 +00:00
|
|
|
tryRead("mfu_size", &lpl->zfs.MFU);
|
|
|
|
tryRead("mru_size", &lpl->zfs.MRU);
|
2019-07-07 02:37:02 +00:00
|
|
|
break;
|
|
|
|
}
|
|
|
|
#undef tryRead
|
2019-09-03 18:26:02 +00:00
|
|
|
#undef tryReadFlag
|
2019-07-07 02:37:02 +00:00
|
|
|
}
|
|
|
|
fclose(file);
|
|
|
|
|
2019-07-07 23:27:00 +00:00
|
|
|
lpl->zfs.enabled = (lpl->zfs.size > 0 ? 1 : 0);
|
|
|
|
lpl->zfs.size /= 1024;
|
|
|
|
lpl->zfs.max /= 1024;
|
|
|
|
lpl->zfs.MFU /= 1024;
|
|
|
|
lpl->zfs.MRU /= 1024;
|
|
|
|
lpl->zfs.anon /= 1024;
|
|
|
|
lpl->zfs.header /= 1024;
|
|
|
|
lpl->zfs.other = (dbufSize + dnodeSize + bonusSize) / 1024;
|
2019-09-03 18:26:02 +00:00
|
|
|
if ( lpl->zfs.isCompressed ) {
|
|
|
|
lpl->zfs.compressed /= 1024;
|
|
|
|
lpl->zfs.uncompressed /= 1024;
|
|
|
|
}
|
2019-07-07 02:37:02 +00:00
|
|
|
}
|
|
|
|
|
2015-01-22 01:27:31 +00:00
|
|
|
static inline double LinuxProcessList_scanCPUTime(LinuxProcessList* this) {
|
2014-11-27 18:31:42 +00:00
|
|
|
|
2014-11-27 18:28:32 +00:00
|
|
|
FILE* file = fopen(PROCSTATFILE, "r");
|
2014-11-24 20:55:49 +00:00
|
|
|
if (file == NULL) {
|
|
|
|
CRT_fatalError("Cannot open " PROCSTATFILE);
|
|
|
|
}
|
2015-01-22 01:27:31 +00:00
|
|
|
int cpus = this->super.cpuCount;
|
2014-11-27 18:31:42 +00:00
|
|
|
assert(cpus > 0);
|
2014-11-24 20:55:49 +00:00
|
|
|
for (int i = 0; i <= cpus; i++) {
|
2015-12-14 15:27:11 +00:00
|
|
|
char buffer[PROC_LINE_LENGTH + 1];
|
2015-08-20 04:12:34 +00:00
|
|
|
unsigned long long int usertime, nicetime, systemtime, idletime;
|
2014-11-24 20:55:49 +00:00
|
|
|
unsigned long long int ioWait, irq, softIrq, steal, guest, guestnice;
|
|
|
|
ioWait = irq = softIrq = steal = guest = guestnice = 0;
|
2015-08-04 13:48:34 +00:00
|
|
|
// Depending on your kernel version,
|
2014-11-24 20:55:49 +00:00
|
|
|
// 5, 7, 8 or 9 of these fields will be set.
|
|
|
|
// The rest will remain at zero.
|
2015-12-14 15:27:11 +00:00
|
|
|
char* ok = fgets(buffer, PROC_LINE_LENGTH, file);
|
2015-02-23 06:34:06 +00:00
|
|
|
if (!ok) buffer[0] = '\0';
|
2014-11-24 20:55:49 +00:00
|
|
|
if (i == 0)
|
2020-08-28 13:28:50 +00:00
|
|
|
(void) sscanf(buffer, "cpu %16llu %16llu %16llu %16llu %16llu %16llu %16llu %16llu %16llu %16llu", &usertime, &nicetime, &systemtime, &idletime, &ioWait, &irq, &softIrq, &steal, &guest, &guestnice);
|
2014-11-24 20:55:49 +00:00
|
|
|
else {
|
2015-08-20 04:12:34 +00:00
|
|
|
int cpuid;
|
2020-08-28 13:28:50 +00:00
|
|
|
(void) 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);
|
2014-11-24 20:55:49 +00:00
|
|
|
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...)
|
2015-08-20 04:12:34 +00:00
|
|
|
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;
|
2014-11-24 20:55:49 +00:00
|
|
|
CPUData* cpuData = &(this->cpus[i]);
|
2015-08-30 19:26:47 +00:00
|
|
|
// 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.
|
2016-03-01 00:57:03 +00:00
|
|
|
#define WRAP_SUBTRACT(a,b) (a > b) ? a - b : 0
|
|
|
|
cpuData->userPeriod = WRAP_SUBTRACT(usertime, cpuData->userTime);
|
|
|
|
cpuData->nicePeriod = WRAP_SUBTRACT(nicetime, cpuData->niceTime);
|
|
|
|
cpuData->systemPeriod = WRAP_SUBTRACT(systemtime, cpuData->systemTime);
|
|
|
|
cpuData->systemAllPeriod = WRAP_SUBTRACT(systemalltime, cpuData->systemAllTime);
|
|
|
|
cpuData->idleAllPeriod = WRAP_SUBTRACT(idlealltime, cpuData->idleAllTime);
|
|
|
|
cpuData->idlePeriod = WRAP_SUBTRACT(idletime, cpuData->idleTime);
|
|
|
|
cpuData->ioWaitPeriod = WRAP_SUBTRACT(ioWait, cpuData->ioWaitTime);
|
|
|
|
cpuData->irqPeriod = WRAP_SUBTRACT(irq, cpuData->irqTime);
|
|
|
|
cpuData->softIrqPeriod = WRAP_SUBTRACT(softIrq, cpuData->softIrqTime);
|
|
|
|
cpuData->stealPeriod = WRAP_SUBTRACT(steal, cpuData->stealTime);
|
|
|
|
cpuData->guestPeriod = WRAP_SUBTRACT(virtalltime, cpuData->guestTime);
|
|
|
|
cpuData->totalPeriod = WRAP_SUBTRACT(totaltime, cpuData->totalTime);
|
|
|
|
#undef WRAP_SUBTRACT
|
2014-11-24 20:55:49 +00:00
|
|
|
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;
|
2019-08-11 05:19:32 +00:00
|
|
|
|
2014-11-24 20:55:49 +00:00
|
|
|
}
|
2015-08-30 19:26:47 +00:00
|
|
|
double period = (double)this->cpus[0].totalPeriod / cpus;
|
|
|
|
fclose(file);
|
2014-11-27 18:28:32 +00:00
|
|
|
return period;
|
|
|
|
}
|
|
|
|
|
2020-09-22 12:50:50 +00:00
|
|
|
static int scanCPUFreqencyFromSysCPUFreq(LinuxProcessList* this) {
|
2019-08-11 05:19:32 +00:00
|
|
|
int cpus = this->super.cpuCount;
|
2020-09-22 12:50:50 +00:00
|
|
|
int numCPUsWithFrequency = 0;
|
|
|
|
unsigned long totalFrequency = 0;
|
|
|
|
|
|
|
|
for (int i = 0; i < cpus; ++i) {
|
|
|
|
char pathBuffer[64];
|
|
|
|
xSnprintf(pathBuffer, sizeof(pathBuffer), "/sys/devices/system/cpu/cpu%d/cpufreq/scaling_cur_freq", i);
|
|
|
|
|
|
|
|
FILE* file = fopen(pathBuffer, "r");
|
|
|
|
if (!file)
|
|
|
|
return -errno;
|
|
|
|
|
|
|
|
unsigned long frequency;
|
|
|
|
if (fscanf(file, "%lu", &frequency) == 1) {
|
|
|
|
/* convert kHz to MHz */
|
|
|
|
frequency = frequency / 1000;
|
|
|
|
this->cpus[i + 1].frequency = frequency;
|
|
|
|
numCPUsWithFrequency++;
|
|
|
|
totalFrequency += frequency;
|
|
|
|
}
|
2019-08-11 05:19:32 +00:00
|
|
|
|
2020-09-22 12:50:50 +00:00
|
|
|
fclose(file);
|
2019-08-11 05:19:32 +00:00
|
|
|
}
|
|
|
|
|
2020-09-22 12:50:50 +00:00
|
|
|
if (numCPUsWithFrequency > 0)
|
|
|
|
this->cpus[0].frequency = (double)totalFrequency / numCPUsWithFrequency;
|
|
|
|
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
static void scanCPUFreqencyFromCPUinfo(LinuxProcessList* this) {
|
|
|
|
FILE* file = fopen(PROCCPUINFOFILE, "r");
|
|
|
|
if (file == NULL)
|
|
|
|
return;
|
|
|
|
|
|
|
|
int cpus = this->super.cpuCount;
|
2019-08-11 05:19:32 +00:00
|
|
|
int numCPUsWithFrequency = 0;
|
|
|
|
double totalFrequency = 0;
|
2020-09-22 12:50:50 +00:00
|
|
|
int cpuid = -1;
|
2019-08-11 05:19:32 +00:00
|
|
|
|
2020-09-22 12:50:50 +00:00
|
|
|
while (!feof(file)) {
|
2019-08-11 05:19:32 +00:00
|
|
|
double frequency;
|
2020-09-22 12:50:50 +00:00
|
|
|
char buffer[PROC_LINE_LENGTH];
|
2019-08-11 05:19:32 +00:00
|
|
|
|
2020-09-22 12:50:50 +00:00
|
|
|
if (fgets(buffer, PROC_LINE_LENGTH, file) == NULL)
|
|
|
|
break;
|
2019-08-11 05:19:32 +00:00
|
|
|
|
2020-09-22 12:50:50 +00:00
|
|
|
if (
|
|
|
|
(sscanf(buffer, "processor : %d", &cpuid) == 1) ||
|
|
|
|
(sscanf(buffer, "processor: %d", &cpuid) == 1)
|
|
|
|
) {
|
|
|
|
continue;
|
|
|
|
} else if (
|
|
|
|
(sscanf(buffer, "cpu MHz : %lf", &frequency) == 1) ||
|
|
|
|
(sscanf(buffer, "cpu MHz: %lf", &frequency) == 1)
|
|
|
|
) {
|
|
|
|
if (cpuid < 0 || cpuid > (cpus - 1))
|
|
|
|
continue;
|
|
|
|
|
|
|
|
CPUData* cpuData = &(this->cpus[cpuid + 1]);
|
|
|
|
/* do not override sysfs data */
|
|
|
|
if (isnan(cpuData->frequency))
|
|
|
|
cpuData->frequency = frequency;
|
|
|
|
numCPUsWithFrequency++;
|
|
|
|
totalFrequency += frequency;
|
|
|
|
} else if (buffer[0] == '\n') {
|
|
|
|
cpuid = -1;
|
2019-08-11 05:19:32 +00:00
|
|
|
}
|
|
|
|
}
|
2020-09-22 12:50:50 +00:00
|
|
|
fclose(file);
|
2019-08-11 05:19:32 +00:00
|
|
|
|
2020-09-22 12:50:50 +00:00
|
|
|
if (numCPUsWithFrequency > 0)
|
|
|
|
this->cpus[0].frequency = totalFrequency / numCPUsWithFrequency;
|
|
|
|
}
|
|
|
|
|
|
|
|
static void LinuxProcessList_scanCPUFrequency(LinuxProcessList* this) {
|
|
|
|
int cpus = this->super.cpuCount;
|
|
|
|
assert(cpus > 0);
|
|
|
|
|
|
|
|
for (int i = 0; i <= cpus; i++)
|
|
|
|
this->cpus[i].frequency = NAN;
|
|
|
|
|
|
|
|
if (scanCPUFreqencyFromSysCPUFreq(this) == 0)
|
|
|
|
return;
|
|
|
|
|
|
|
|
scanCPUFreqencyFromCPUinfo(this);
|
2019-08-11 05:19:32 +00:00
|
|
|
}
|
|
|
|
|
2015-03-17 02:01:48 +00:00
|
|
|
void ProcessList_goThroughEntries(ProcessList* super) {
|
2015-01-22 01:27:31 +00:00
|
|
|
LinuxProcessList* this = (LinuxProcessList*) super;
|
2020-09-22 12:50:50 +00:00
|
|
|
const Settings* settings = super->settings;
|
2014-11-27 18:28:32 +00:00
|
|
|
|
2015-03-16 06:25:43 +00:00
|
|
|
LinuxProcessList_scanMemoryInfo(super);
|
2019-07-07 02:37:02 +00:00
|
|
|
LinuxProcessList_scanZfsArcstats(this);
|
2020-09-22 18:04:41 +00:00
|
|
|
|
|
|
|
LinuxProcessList_updateCPUcount(this);
|
|
|
|
|
2014-11-27 18:31:42 +00:00
|
|
|
double period = LinuxProcessList_scanCPUTime(this);
|
2014-11-24 20:55:49 +00:00
|
|
|
|
2020-09-22 12:50:50 +00:00
|
|
|
if (settings->showCPUFrequency)
|
|
|
|
LinuxProcessList_scanCPUFrequency(this);
|
2019-08-11 05:19:32 +00:00
|
|
|
|
2014-11-24 20:55:49 +00:00
|
|
|
struct timeval tv;
|
|
|
|
gettimeofday(&tv, NULL);
|
2015-03-17 02:01:48 +00:00
|
|
|
LinuxProcessList_recurseProcTree(this, PROCDIR, NULL, period, tv);
|
2014-11-24 20:55:49 +00:00
|
|
|
}
|