summaryrefslogtreecommitdiffstats
path: root/linux/LinuxProcessList.c
diff options
context:
space:
mode:
authorNathan Scott <nathans@redhat.com>2023-08-31 11:56:43 +1000
committerNathan Scott <nathans@redhat.com>2023-08-31 14:13:16 +1000
commitb74673fe37fd379fc350789e696470556776d815 (patch)
treecbe4f036962c439f9c07a9c96302f5908f6410b0 /linux/LinuxProcessList.c
parent214166a049c2a6ac454dbb37b85b04c039a6a17a (diff)
Rename ProcessList to ProcessTable throughout
Following up with some discusson from a few months back, where it was proposed that ProcessTable is a better name. This data structure is definitely not a list ... if it was one-dimensional it'd be a set, but in practice it has much more in common with a two-dimensional table. The Process table is a familiar operating system concept for many people too so it resonates a little in that way as well.
Diffstat (limited to 'linux/LinuxProcessList.c')
-rw-r--r--linux/LinuxProcessList.c1642
1 files changed, 0 insertions, 1642 deletions
diff --git a/linux/LinuxProcessList.c b/linux/LinuxProcessList.c
deleted file mode 100644
index 9be2433e..00000000
--- a/linux/LinuxProcessList.c
+++ /dev/null
@@ -1,1642 +0,0 @@
-/*
-htop - LinuxProcessList.c
-(C) 2014 Hisham H. Muhammad
-Released under the GNU GPLv2+, see the COPYING file
-in the source distribution for its full text.
-*/
-
-#include "config.h" // IWYU pragma: keep
-
-#include "linux/LinuxProcessList.h"
-
-#include <assert.h>
-#include <ctype.h>
-#include <dirent.h>
-#include <errno.h>
-#include <fcntl.h>
-#include <inttypes.h>
-#include <limits.h>
-#include <math.h>
-#include <stdbool.h>
-#include <stdint.h>
-#include <stdio.h>
-#include <stdlib.h>
-#include <string.h>
-#include <strings.h>
-#include <time.h>
-#include <unistd.h>
-#include <sys/stat.h>
-#include <sys/types.h>
-
-#ifdef HAVE_DELAYACCT
-#include <linux/netlink.h>
-#include <linux/taskstats.h>
-#include <netlink/attr.h>
-#include <netlink/handlers.h>
-#include <netlink/msg.h>
-#include <netlink/netlink.h>
-#include <netlink/socket.h>
-#include <netlink/genl/genl.h>
-#include <netlink/genl/ctrl.h>
-#endif
-
-#include "Compat.h"
-#include "CRT.h"
-#include "Macros.h"
-#include "Object.h"
-#include "Process.h"
-#include "Scheduling.h"
-#include "Settings.h"
-#include "XUtils.h"
-#include "linux/CGroupUtils.h"
-#include "linux/LinuxMachine.h"
-#include "linux/LinuxProcess.h"
-#include "linux/Platform.h" // needed for GNU/hurd to get PATH_MAX // IWYU pragma: keep
-
-#if defined(MAJOR_IN_MKDEV)
-#include <sys/mkdev.h>
-#elif defined(MAJOR_IN_SYSMACROS)
-#include <sys/sysmacros.h>
-#endif
-
-/* Not exposed yet. Defined at include/linux/sched.h */
-#ifndef PF_KTHREAD
-#define PF_KTHREAD 0x00200000
-#endif
-
-static FILE* fopenat(openat_arg_t openatArg, const char* pathname, const char* mode) {
- assert(String_eq(mode, "r")); /* only currently supported mode */
-
- int fd = Compat_openat(openatArg, pathname, O_RDONLY);
- if (fd < 0)
- return NULL;
-
- FILE* stream = fdopen(fd, mode);
- if (!stream)
- close(fd);
-
- return stream;
-}
-
-static inline uint64_t fast_strtoull_dec(char** str, int maxlen) {
- register uint64_t result = 0;
-
- if (!maxlen)
- --maxlen;
-
- while (maxlen-- && **str >= '0' && **str <= '9') {
- result *= 10;
- result += **str - '0';
- (*str)++;
- }
-
- return result;
-}
-
-static inline uint64_t fast_strtoull_hex(char** str, int maxlen) {
- register uint64_t result = 0;
- register int nibble, letter;
- const long valid_mask = 0x03FF007E;
-
- if (!maxlen)
- --maxlen;
-
- while (maxlen--) {
- nibble = (unsigned char)**str;
- if (!(valid_mask & (1 << (nibble & 0x1F))))
- break;
- if ((nibble < '0') || (nibble & ~0x20) > 'F')
- break;
- letter = (nibble & 0x40) ? 'A' - '9' - 1 : 0;
- nibble &=~0x20; // to upper
- nibble ^= 0x10; // switch letters and digits
- nibble -= letter;
- nibble &= 0x0f;
- result <<= 4;
- result += (uint64_t)nibble;
- (*str)++;
- }
-
- return result;
-}
-
-static int sortTtyDrivers(const void* va, const void* vb) {
- const TtyDriver* a = (const TtyDriver*) va;
- const TtyDriver* b = (const TtyDriver*) vb;
-
- int r = SPACESHIP_NUMBER(a->major, b->major);
- if (r)
- return r;
-
- return SPACESHIP_NUMBER(a->minorFrom, b->minorFrom);
-}
-
-static void LinuxProcessList_initTtyDrivers(LinuxProcessList* this) {
- TtyDriver* ttyDrivers;
-
- char buf[16384];
- ssize_t r = xReadfile(PROCTTYDRIVERSFILE, buf, sizeof(buf));
- if (r < 0)
- return;
-
- int numDrivers = 0;
- int allocd = 10;
- ttyDrivers = xMallocArray(allocd, sizeof(TtyDriver));
- char* at = buf;
- while (*at != '\0') {
- at = strchr(at, ' '); // skip first token
- while (*at == ' ') at++; // skip spaces
- const char* token = at; // mark beginning of path
- at = strchr(at, ' '); // find end of path
- *at = '\0'; at++; // clear and skip
- ttyDrivers[numDrivers].path = xStrdup(token); // save
- 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;
- ttyDrivers = xReallocArray(ttyDrivers, allocd, sizeof(TtyDriver));
- }
- }
- numDrivers++;
- ttyDrivers = xRealloc(ttyDrivers, sizeof(TtyDriver) * numDrivers);
- ttyDrivers[numDrivers - 1].path = NULL;
- qsort(ttyDrivers, numDrivers - 1, sizeof(TtyDriver), sortTtyDrivers);
- this->ttyDrivers = ttyDrivers;
-}
-
-#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
-
-ProcessList* ProcessList_new(Machine* host, Hashtable* pidMatchList) {
- LinuxProcessList* this = xCalloc(1, sizeof(LinuxProcessList));
- Object_setClass(this, Class(ProcessList));
-
- ProcessList* super = &this->super;
- ProcessList_init(super, Class(LinuxProcess), host, pidMatchList);
-
- LinuxProcessList_initTtyDrivers(this);
-
- // Test /proc/PID/smaps_rollup availability (faster to parse, Linux 4.14+)
- this->haveSmapsRollup = (access(PROCDIR "/self/smaps_rollup", R_OK) == 0);
-
- return super;
-}
-
-void ProcessList_delete(Object* cast) {
- LinuxProcessList* this = (LinuxProcessList*) cast;
- ProcessList_done(&this->super);
- if (this->ttyDrivers) {
- for (int i = 0; this->ttyDrivers[i].path; i++) {
- free(this->ttyDrivers[i].path);
- }
- free(this->ttyDrivers);
- }
- #ifdef HAVE_DELAYACCT
- if (this->netlink_socket) {
- nl_close(this->netlink_socket);
- nl_socket_free(this->netlink_socket);
- }
- #endif
- free(this);
-}
-
-static inline unsigned long long LinuxProcessList_adjustTime(const LinuxMachine* lhost, unsigned long long t) {
- return t * 100 / lhost->jiffies;
-}
-
-/* Taken from: https://github.com/torvalds/linux/blob/64570fbc14f8d7cb3fe3995f20e26bc25ce4b2cc/fs/proc/array.c#L120 */
-static inline ProcessState LinuxProcessList_getProcessState(char state) {
- switch (state) {
- case 'S': return SLEEPING;
- case 'X': return DEFUNCT;
- case 'Z': return ZOMBIE;
- case 't': return TRACED;
- case 'T': return STOPPED;
- case 'D': return UNINTERRUPTIBLE_WAIT;
- case 'R': return RUNNING;
- case 'P': return BLOCKED;
- case 'I': return IDLE;
- default: return UNKNOWN;
- }
-}
-
-static bool LinuxProcessList_readStatFile(LinuxProcess* lp, openat_arg_t procFd, const LinuxMachine* lhost, bool scanMainThread, char* command, size_t commLen) {
- Process* process = &lp->super;
-
- char buf[MAX_READ + 1];
- char path[22] = "stat";
- if (scanMainThread) {
- xSnprintf(path, sizeof(path), "task/%"PRIi32"/stat", (int32_t)Process_getPid(process));
- }
- ssize_t r = xReadfileat(procFd, path, buf, sizeof(buf));
- if (r < 0)
- return false;
-
- /* (1) pid - %d */
- assert(Process_getPid(process) == atoi(buf));
- char* location = strchr(buf, ' ');
- if (!location)
- return false;
-
- /* (2) comm - (%s) */
- location += 2;
- char* end = strrchr(location, ')');
- if (!end)
- return false;
-
- String_safeStrncpy(command, location, MINIMUM((size_t)(end - location + 1), commLen));
-
- location = end + 2;
-
- /* (3) state - %c */
- process->state = LinuxProcessList_getProcessState(location[0]);
- location += 2;
-
- /* (4) ppid - %d */
- Process_setParent(process, strtol(location, &location, 10));
- location += 1;
-
- /* (5) pgrp - %d */
- process->pgrp = strtol(location, &location, 10);
- location += 1;
-
- /* (6) session - %d */
- process->session = strtol(location, &location, 10);
- location += 1;
-
- /* (7) tty_nr - %d */
- process->tty_nr = strtoul(location, &location, 10);
- location += 1;
-
- /* (8) tpgid - %d */
- process->tpgid = strtol(location, &location, 10);
- location += 1;
-
- /* (9) flags - %u */
- lp->flags = strtoul(location, &location, 10);
- location += 1;
-
- /* (10) minflt - %lu */
- process->minflt = strtoull(location, &location, 10);
- location += 1;
-
- /* (11) cminflt - %lu */
- lp->cminflt = strtoull(location, &location, 10);
- location += 1;
-
- /* (12) majflt - %lu */
- process->majflt = strtoull(location, &location, 10);
- location += 1;
-
- /* (13) cmajflt - %lu */
- lp->cmajflt = strtoull(location, &location, 10);
- location += 1;
-
- /* (14) utime - %lu */
- lp->utime = LinuxProcessList_adjustTime(lhost, strtoull(location, &location, 10));
- location += 1;
-
- /* (15) stime - %lu */
- lp->stime = LinuxProcessList_adjustTime(lhost, strtoull(location, &location, 10));
- location += 1;
-
- /* (16) cutime - %ld */
- lp->cutime = LinuxProcessList_adjustTime(lhost, strtoull(location, &location, 10));
- location += 1;
-
- /* (17) cstime - %ld */
- lp->cstime = LinuxProcessList_adjustTime(lhost, strtoull(location, &location, 10));
- location += 1;
-
- /* (18) priority - %ld */
- process->priority = strtol(location, &location, 10);
- location += 1;
-
- /* (19) nice - %ld */
- process->nice = strtol(location, &location, 10);
- location += 1;
-
- /* (20) num_threads - %ld */
- process->nlwp = strtol(location, &location, 10);
- location += 1;
-
- /* Skip (21) itrealvalue - %ld */
- location = strchr(location, ' ') + 1;
-
- /* (22) starttime - %llu */
- if (process->starttime_ctime == 0) {
- process->starttime_ctime = lhost->boottime + LinuxProcessList_adjustTime(lhost, strtoll(location, &location, 10)) / 100;
- } else {
- location = strchr(location, ' ');
- }
- location += 1;
-
- /* Skip (23) - (38) */
- for (int i = 0; i < 16; i++) {
- location = strchr(location, ' ') + 1;
- }
-
- assert(location != NULL);
-
- /* (39) processor - %d */
- process->processor = strtol(location, &location, 10);
-
- /* Ignore further fields */
-
- process->time = lp->utime + lp->stime;
-
- return true;
-}
-
-static bool LinuxProcessList_readStatusFile(Process* process, openat_arg_t procFd) {
- LinuxProcess* lp = (LinuxProcess*) process;
-
- unsigned long ctxt = 0;
-#ifdef HAVE_VSERVER
- lp->vxid = 0;
-#endif
-
- FILE* statusfile = fopenat(procFd, "status", "r");
- if (!statusfile)
- return false;
-
- char buffer[PROC_LINE_LENGTH + 1];
-
- while (fgets(buffer, sizeof(buffer), statusfile)) {
-
- if (String_startsWith(buffer, "NSpid:")) {
- const char* ptr = buffer;
- int pid_ns_count = 0;
- while (*ptr && *ptr != '\n' && !isdigit((unsigned char)*ptr))
- ++ptr;
-
- while (*ptr && *ptr != '\n') {
- if (isdigit(*ptr))
- pid_ns_count++;
- while (isdigit((unsigned char)*ptr))
- ++ptr;
- while (*ptr && *ptr != '\n' && !isdigit((unsigned char)*ptr))
- ++ptr;
- }
-
- if (pid_ns_count > 1)
- process->isRunningInContainer = true;
-
- } else if (String_startsWith(buffer, "CapPrm:")) {
- char* ptr = buffer + strlen("CapPrm:");
- while (*ptr == ' ' || *ptr == '\t')
- ptr++;
-
- uint64_t cap_permitted = fast_strtoull_hex(&ptr, 16);
- process->elevated_priv = cap_permitted != 0 && process->st_uid != 0;
-
- } else 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;
- }
-
-#ifdef HAVE_VSERVER
- } else if (String_startsWith(buffer, "VxID:")) {
- int vxid;
- int ok = sscanf(buffer, "VxID:\t%32d", &vxid);
- if (ok >= 1) {
- lp->vxid = vxid;
- }
-#ifdef HAVE_ANCIENT_VSERVER
- } else if (String_startsWith(buffer, "s_context:")) {
- int vxid;
- int ok = sscanf(buffer, "s_context:\t%32d", &vxid);
- if (ok >= 1) {
- lp->vxid = vxid;
- }
-#endif /* HAVE_ANCIENT_VSERVER */
-#endif /* HAVE_VSERVER */
- }
- }
-
- fclose(statusfile);
-
- lp->ctxt_diff = (ctxt > lp->ctxt_total) ? (ctxt - lp->ctxt_total) : 0;
- lp->ctxt_total = ctxt;
-
- return true;
-}
-
-static bool LinuxProcessList_updateUser(const Machine* host, Process* process, openat_arg_t procFd) {
- struct stat sstat;
-#ifdef HAVE_OPENAT
- int statok = fstat(procFd, &sstat);
-#else
- int statok = stat(procFd, &sstat);
-#endif
- if (statok == -1)
- return false;
-
- if (process->st_uid != sstat.st_uid) {
- process->st_uid = sstat.st_uid;
- process->user = UsersTable_getRef(host->usersTable, sstat.st_uid);
- }
-
- return true;
-}
-
-static void LinuxProcessList_readIoFile(LinuxProcess* lp, openat_arg_t procFd, bool scanMainThread) {
- Process* process = &lp->super;
- const Machine* host = process->super.host;
- char path[20] = "io";
- char buffer[1024];
- if (scanMainThread) {
- xSnprintf(path, sizeof(path), "task/%"PRIi32"/io", (int32_t)Process_getPid(process));
- }
- ssize_t r = xReadfileat(procFd, path, buffer, sizeof(buffer));
- if (r < 0) {
- lp->io_rate_read_bps = NAN;
- lp->io_rate_write_bps = NAN;
- lp->io_rchar = ULLONG_MAX;
- lp->io_wchar = ULLONG_MAX;
- lp->io_syscr = ULLONG_MAX;
- lp->io_syscw = ULLONG_MAX;
- lp->io_read_bytes = ULLONG_MAX;
- lp->io_write_bytes = ULLONG_MAX;
- lp->io_cancelled_write_bytes = ULLONG_MAX;
- lp->io_last_scan_time_ms = host->realtimeMs;
- return;
- }
-
- unsigned long long last_read = lp->io_read_bytes;
- unsigned long long last_write = lp->io_write_bytes;
- unsigned long long time_delta = saturatingSub(host->realtimeMs, lp->io_last_scan_time_ms);
-
- // Note: Linux Kernel documentation states that /proc/<pid>/io may be racy
- // on 32-bit machines. (Documentation/filesystems/proc.rst)
-
- char* buf = buffer;
- const char* line;
- while ((line = strsep(&buf, "\n")) != NULL) {
- switch (line[0]) {
- case 'r':
- if (line[1] == 'c' && String_startsWith(line + 2, "har: ")) {
- lp->io_rchar = strtoull(line + 7, NULL, 10);
- } else if (String_startsWith(line + 1, "ead_bytes: ")) {
- lp->io_read_bytes = strtoull(line + 12, NULL, 10);
- lp->io_rate_read_bps = time_delta ? saturatingSub(lp->io_read_bytes, last_read) * /*ms to s*/1000. / time_delta : NAN;
- }
- break;
- case 'w':
- if (line[1] == 'c' && String_startsWith(line + 2, "har: ")) {
- lp->io_wchar = strtoull(line + 7, NULL, 10);
- } else if (String_startsWith(line + 1, "rite_bytes: ")) {
- lp->io_write_bytes = strtoull(line + 13, NULL, 10);
- lp->io_rate_write_bps = time_delta ? saturatingSub(lp->io_write_bytes, last_write) * /*ms to s*/1000. / time_delta : NAN;
- }
- break;
- case 's':
- if (line[4] == 'r' && String_startsWith(line + 1, "yscr: ")) {
- lp->io_syscr = strtoull(line + 7, NULL, 10);
- } else if (String_startsWith(line + 1, "yscw: ")) {
- lp->io_syscw = strtoull(line + 7, NULL, 10);
- }
- break;
- case 'c':
- if (String_startsWith(line + 1, "ancelled_write_bytes: ")) {
- lp->io_cancelled_write_bytes = strtoull(line + 23, NULL, 10);
- }
- }
- }
-
- lp->io_last_scan_time_ms = host->realtimeMs;
-}
-
-typedef struct LibraryData_ {
- uint64_t size;
- bool exec;
-} LibraryData;
-
-static void LinuxProcessList_calcLibSize_helper(ATTR_UNUSED ht_key_t key, void* value, void* data) {
- if (!data)
- return;
-
- if (!value)
- return;
-
- const LibraryData* v = (const LibraryData*)value;
- uint64_t* d = (uint64_t*)data;
- if (!v->exec)
- return;
-
- *d += v->size;
-}
-
-static void LinuxProcessList_readMaps(LinuxProcess* process, openat_arg_t procFd, const LinuxMachine* host, bool calcSize, bool checkDeletedLib) {
- Process* proc = (Process*)process;
-
- proc->usesDeletedLib = false;
-
- FILE* mapsfile = fopenat(procFd, "maps", "r");
- if (!mapsfile)
- return;
-
- Hashtable* ht = NULL;
- if (calcSize)
- ht = Hashtable_new(64, true);
-
- char buffer[1024];
- while (fgets(buffer, sizeof(buffer), mapsfile)) {
- uint64_t map_start;
- uint64_t map_end;
- bool map_execute;
- unsigned int map_devmaj;
- unsigned int map_devmin;
- uint64_t map_inode;
-
- // Short circuit test: Look for a slash
- if (!strchr(buffer, '/'))
- continue;
-
- // Parse format: "%Lx-%Lx %4s %x %2x:%2x %Ld"
- char* readptr = buffer;
-
- map_start = fast_strtoull_hex(&readptr, 16);
- if ('-' != *readptr++)
- continue;
-
- map_end = fast_strtoull_hex(&readptr, 16);
- if (' ' != *readptr++)
- continue;
-
- map_execute = (readptr[2] == 'x');
- readptr += 4;
- if (' ' != *readptr++)
- continue;
-
- while (*readptr > ' ')
- readptr++; // Skip parsing this hex value
- if (' ' != *readptr++)
- continue;
-
- map_devmaj = fast_strtoull_hex(&readptr, 4);
- if (':' != *readptr++)
- continue;
-
- map_devmin = fast_strtoull_hex(&readptr, 4);
- if (' ' != *readptr++)
- continue;
-
- //Minor shortcut: Once we know there's no file for this region, we skip
- if (!map_devmaj && !map_devmin)
- continue;
-
- map_inode = fast_strtoull_dec(&readptr, 20);
- if (!map_inode)
- continue;
-
- if (calcSize) {
- LibraryData* libdata = Hashtable_get(ht, map_inode);
- if (!libdata) {
- libdata = xCalloc(1, sizeof(LibraryData));
- Hashtable_put(ht, map_inode, libdata);
- }
-
- libdata->size += map_end - map_start;
- libdata->exec |= map_execute;
- }
-
- if (checkDeletedLib && map_execute && !proc->usesDeletedLib) {
- while (*readptr == ' ')
- readptr++;
-
- if (*readptr != '/')
- continue;
-
- if (String_startsWith(readptr, "/memfd:"))
- continue;
-
- /* Virtualbox maps /dev/zero for memory allocation. That results in
- * false positive, so ignore. */
- if (String_eq(readptr, "/dev/zero (deleted)\n"))
- continue;
-
- if (strstr(readptr, " (deleted)\n")) {
- proc->usesDeletedLib = true;
- if (!calcSize)
- break;
- }
- }
- }
-
- fclose(mapsfile);
-
- if (calcSize) {
- uint64_t total_size = 0;
- Hashtable_foreach(ht, LinuxProcessList_calcLibSize_helper, &total_size);
-
- Hashtable_delete(ht);
-
- process->m_lrs = total_size / host->pageSize;
- }
-}
-
-static bool LinuxProcessList_readStatmFile(LinuxProcess* process, openat_arg_t procFd, const LinuxMachine* host) {
- FILE* statmfile = fopenat(procFd, "statm", "r");
- if (!statmfile)
- return false;
-
- long int dummy, dummy2;
-
- int r = fscanf(statmfile, "%ld %ld %ld %ld %ld %ld %ld",
- &process->super.m_virt,
- &process->super.m_resident,
- &process->m_share,
- &process->m_trs,
- &dummy, /* unused since Linux 2.6; always 0 */
- &process->m_drs,
- &dummy2); /* unused since Linux 2.6; always 0 */
- fclose(statmfile);
-
- if (r == 7) {
- process->super.m_virt *= host->pageSizeKB;
- process->super.m_resident *= host->pageSizeKB;
- }
-
- return r == 7;
-}
-
-static bool LinuxProcessList_readSmapsFile(LinuxProcess* process, openat_arg_t procFd, bool haveSmapsRollup) {
- //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.
- FILE* f = fopenat(procFd, haveSmapsRollup ? "smaps_rollup" : "smaps", "r");
- if (!f)
- return false;
-
- process->m_pss = 0;
- process->m_swap = 0;
- process->m_psswp = 0;
-
- char buffer[256];
- while (fgets(buffer, sizeof(buffer), f)) {
- if (!strchr(buffer, '\n')) {
- // Partial line, skip to end of this line
- while (fgets(buffer, sizeof(buffer), f)) {
- if (strchr(buffer, '\n')) {
- break;
- }
- }
- continue;
- }
-
- if (String_startsWith(buffer, "Pss:")) {
- process->m_pss += strtol(buffer + 4, NULL, 10);
- } else if (String_startsWith(buffer, "Swap:")) {
- process->m_swap += strtol(buffer + 5, NULL, 10);
- } else if (String_startsWith(buffer, "SwapPss:")) {
- process->m_psswp += strtol(buffer + 8, NULL, 10);
- }
- }
-
- fclose(f);
- return true;
-}
-
-#ifdef HAVE_OPENVZ
-
-static void LinuxProcessList_readOpenVZData(LinuxProcess* process, openat_arg_t procFd) {
- if (access(PROCDIR "/vz", R_OK) != 0) {
- free(process->ctid);
- process->ctid = NULL;
- process->vpid = Process_getPid(&process->super);
- return;
- }
-
- FILE* file = fopenat(procFd, "status", "r");
- if (!file) {
- free(process->ctid);
- process->ctid = NULL;
- process->vpid = Process_getPid(&process->super);
- return;
- }
-
- 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 > 32) {
- value_end++;
- }
-
- if (name_value_sep == value_end) {
- continue;
- }
-
- *value_end = '\0';
-
- switch (field) {
- case 1:
- foundEnvID = true;
- if (!String_eq(name_value_sep, process->ctid ? process->ctid : ""))
- free_and_xStrdup(&process->ctid, 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.");
- }
- }
-
- fclose(file);
-
- if (!foundEnvID) {
- free(process->ctid);
- process->ctid = NULL;
- }
-
- if (!foundVPid) {
- process->vpid = Process_getPid(&process->super);
- }
-}
-
-#endif
-
-static void LinuxProcessList_readCGroupFile(LinuxProcess* process, openat_arg_t procFd) {
- FILE* file = fopenat(procFd, "cgroup", "r");
- if (!file) {
- if (process->cgroup) {
- free(process->cgroup);
- process->cgroup = NULL;
- }
- if (process->cgroup_short) {
- free(process->cgroup_short);
- process->cgroup_short = NULL;
- }
- 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];
- const char* ok = fgets(buffer, PROC_LINE_LENGTH, file);
- if (!ok)
- break;
-
- char* group = buffer;
- for (size_t i = 0; i < 2; i++) {
- group = strchrnul(group, ':');
- if (!*group)
- break;
- group++;
- }
-
- char* eol = strchrnul(group, '\n');
- *eol = '\0';
-
- if (at != output) {
- *at = ';';
- at++;
- left--;
- }
- int wrote = snprintf(at, left, "%s", group);
- left -= wrote;
- }
- fclose(file);
-
- bool changed = !process->cgroup || !String_eq(process->cgroup, output);
-
- Row_updateFieldWidth(CGROUP, strlen(output));
- free_and_xStrdup(&process->cgroup, output);
-
- if (!changed) {
- if (process->cgroup_short) {
- Row_updateFieldWidth(CCGROUP, strlen(process->cgroup_short));
- } else {
- //CCGROUP is alias to normal CGROUP if shortening fails
- Row_updateFieldWidth(CCGROUP, strlen(process->cgroup));
- }
- return;
- }
-
- char* cgroup_short = CGroup_filterName(process->cgroup);
- if (cgroup_short) {
- Row_updateFieldWidth(CCGROUP, strlen(cgroup_short));
- free_and_xStrdup(&process->cgroup_short, cgroup_short);
- free(cgroup_short);
- } else {
- //CCGROUP is alias to normal CGROUP if shortening fails
- Row_updateFieldWidth(CCGROUP, strlen(process->cgroup));
- free(process->cgroup_short);
- process->cgroup_short = NULL;
- }
-}
-
-static void LinuxProcessList_readOomData(LinuxProcess* process, openat_arg_t procFd) {
- FILE* file = fopenat(procFd, "oom_score", "r");
- if (!file)
- return;
-
- char buffer[PROC_LINE_LENGTH + 1];
- if (fgets(buffer, PROC_LINE_LENGTH, file)) {
- unsigned int oom;
- int ok = sscanf(buffer, "%u", &oom);
- if (ok >= 1) {
- process->oom = oom;
- }
- }
- fclose(file);
-}
-
-static void LinuxProcessList_readAutogroup(LinuxProcess* process, openat_arg_t procFd) {
- process->autogroup_id = -1;
-
- char autogroup[64]; // space for two numeric values and fixed length strings
- ssize_t amtRead = xReadfileat(procFd, "autogroup", autogroup, sizeof(autogroup));
- if (amtRead < 0)
- return;
-
- long int identity;
- int nice;
- int ok = sscanf(autogroup, "/autogroup-%ld nice %d", &identity, &nice);
- if (ok == 2) {
- process->autogroup_id = identity;
- process->autogroup_nice = nice;
- }
-}
-
-static void LinuxProcessList_readSecattrData(LinuxProcess* process, openat_arg_t procFd) {
- FILE* file = fopenat(procFd, "attr/current", "r");
- if (!file) {
- free(process->secattr);
- process->secattr = NULL;
- return;
- }
-
- char buffer[PROC_LINE_LENGTH + 1];
- const 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';
- }
-
- Row_updateFieldWidth(SECATTR, strlen(buffer));
-
- if (process->secattr && String_eq(process->secattr, buffer)) {
- return;
- }
- free_and_xStrdup(&process->secattr, buffer);
-}
-
-static void LinuxProcessList_readCwd(LinuxProcess* process, openat_arg_t procFd) {
- char pathBuffer[PATH_MAX + 1] = {0};
-
-#if defined(HAVE_READLINKAT) && defined(HAVE_OPENAT)
- ssize_t r = readlinkat(procFd, "cwd", pathBuffer, sizeof(pathBuffer) - 1);
-#else
- ssize_t r = Compat_readlink(procFd, "cwd", pathBuffer, sizeof(pathBuffer) - 1);
-#endif
-
- if (r < 0) {
- free(process->super.procCwd);
- process->super.procCwd = NULL;
- return;
- }
-
- pathBuffer[r] = '\0';
-
- if (process->super.procCwd && String_eq(process->super.procCwd, pathBuffer))
- return;
-
- free_and_xStrdup(&process->super.procCwd, pathBuffer);
-}
-
-#ifdef HAVE_DELAYACCT
-
-static int handleNetlinkMsg(struct nl_msg* nlmsg, void* linuxProcess) {
- struct nlmsghdr* nlhdr;
- struct nlattr* nlattrs[TASKSTATS_TYPE_MAX + 1];
- const struct nlattr* nlattr;
- struct taskstats stats;
- int rem;
- LinuxProcess* lp = (LinuxProcess*) linuxProcess;
-
- nlhdr = nlmsg_hdr(nlmsg);
-
- if (genlmsg_parse(nlhdr, 0, nlattrs, TASKSTATS_TYPE_MAX, NULL) < 0) {
- return NL_SKIP;
- }
-
- if ((nlattr = nlattrs[TASKSTATS_TYPE_AGGR_PID]) || (nlattr = nlattrs[TASKSTATS_TYPE_NULL])) {
- memcpy(&stats, nla_data(nla_next(nla_data(nlattr), &rem)), sizeof(stats));
- assert(Process_getPid(&lp->super) == (pid_t)stats.ac_pid);
-
- // The xxx_delay_total values wrap around on overflow.
- // (Linux Kernel "Documentation/accounting/taskstats-struct.rst")
- unsigned long long int timeDelta = stats.ac_etime * 1000 - lp->delay_read_time;
- #define DELTAPERC(x, y) (timeDelta ? MINIMUM((float)((x) - (y)) / timeDelta * 100.0f, 100.0f) : NAN)
- 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);
- #undef DELTAPERC
-
- 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;
- }
- return NL_OK;
-}
-
-static void LinuxProcessList_readDelayAcctData(LinuxProcessList* this, LinuxProcess* process) {
- struct nl_msg* msg;
-
- if (!this->netlink_socket) {
- LinuxProcessList_initNetlinkSocket(this);
- if (!this->netlink_socket) {
- goto delayacct_failure;
- }
- }
-
- if (nl_socket_modify_cb(this->netlink_socket, NL_CB_VALID, NL_CB_CUSTOM, handleNetlinkMsg, process) < 0) {
- goto delayacct_failure;
- }
-
- if (! (msg = nlmsg_alloc())) {
- goto delayacct_failure;
- }
-
- 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_getPid(&process->super)) < 0) {
- nlmsg_free(msg);
- }
-
- if (nl_send_sync(this->netlink_socket, msg) < 0) {
- goto delayacct_failure;
- }
-
- if (nl_recvmsgs_default(this->netlink_socket) < 0) {
- goto delayacct_failure;
- }
-
- return;
-
-delayacct_failure:
- process->swapin_delay_percent = NAN;
- process->blkio_delay_percent = NAN;
- process->cpu_delay_percent = NAN;
-}
-
-#endif
-
-static bool LinuxProcessList_readCmdlineFile(Process* process, openat_arg_t procFd) {
- char command[4096 + 1]; // max cmdline length on Linux
- ssize_t amtRead = xReadfileat(procFd, "cmdline", command, sizeof(command));
- if (amtRead <= 0)
- return false;
-
- int tokenEnd = 0;
- int tokenStart = 0;
- int lastChar = 0;
- bool argSepNUL = false;
- bool argSepSpace = false;
-
- for (int i = 0; i < amtRead; i++) {
- /* newline used as delimiter - when forming the mergedCommand, newline is
- * converted to space by Process_makeCommandStr */
- if (command[i] == '\0') {
- command[i] = '\n';
- } else {
- /* Record some information for the argument parsing heuristic below. */
- if (tokenEnd)
- argSepNUL = true;
- if (command[i] <= ' ')
- argSepSpace = true;
- }
-
- if (command[i] == '\n') {
- if (tokenEnd == 0) {
- tokenEnd = i;
- }
- } else {
- /* htop considers the next character after the last / that is before
- * basenameOffset, as the start of the basename in cmdline - see
- * Process_writeCommand */
- if (!tokenEnd && command[i] == '/') {
- tokenStart = i + 1;
- }
- lastChar = i;
- }
- }
-
- command[lastChar + 1] = '\0';
-
- if (!argSepNUL && argSepSpace) {
- /* Argument parsing heuristic.
- *
- * This heuristic is used for processes that rewrite their command line.
- * Normally the command line is split by using NUL bytes between each argument.
- * But some programs like chrome flatten this using spaces.
- *
- * This heuristic tries its best to undo this loss of information.
- * To achieve this, we treat every character <= 32 as argument separators
- * (i.e. all of ASCII control sequences and space).
- * We then search for the basename of the cmdline in the first argument we found that way.
- * As path names may contain we try to cross-validate if the path we got that way exists.
- */
-
- tokenStart = tokenEnd = 0;
-
- // From initial scan we know there's at least one space.
- // Check if that's part of a filename for an existing file.
- if (Compat_faccessat(AT_FDCWD, command, F_OK, AT_SYMLINK_NOFOLLOW) != 0) {
- // If we reach here the path does not exist.
- // Thus begin searching for the part of it that actually is.
-
- int tokenArg0Start = 0;
-
- for (int i = 0; i <= lastChar; i++) {
- /* Any ASCII control or space used as delimiter */
- char tmpCommandChar = command[i];
-
- if (command[i] <= ' ') {
- if (!tokenEnd) {
- command[i] = '\0';
-
- bool found = Compat_faccessat(AT_FDCWD, command, F_OK, AT_SYMLINK_NOFOLLOW) == 0;
-
- // Restore if this wasn't it
- command[i] = found ? '\n' : tmpCommandChar;
-
- if (found)
- tokenEnd = i;
- if (!tokenArg0Start)
- tokenArg0Start = tokenStart;
- } else {
- // Split on every further separator, regardless of path correctness
- command[i] = '\n';
- }
- } else if (!tokenEnd) {
- if (command[i] == '/' || (command[i] == '\\' && (!tokenStart || command[tokenStart - 1] == '\\'))) {
- tokenStart = i + 1;
- } else if (command[i] == ':' && (command[i + 1] != '/' && command[i + 1] != '\\')) {
- tokenEnd = i;
- }
- }
- }
-
- if (!tokenEnd) {
- tokenStart = tokenArg0Start;
-
- // No token delimiter found, forcibly split
- for (int i = 0; i <= lastChar; i++) {
- if (command[i] <= ' ') {
- command[i] = '\n';
- if (!tokenEnd) {
- tokenEnd = i;
- }
- }
- }
- }
- }
-
- /* Some command lines are hard to parse, like
- * file.so [kdeinit5] file local:/run/user/1000/klauncherdqbouY.1.slave-socket local:/run/user/1000/kded5TwsDAx.1.slave-socket
- * Reset if start is behind end.
- */
- if (tokenStart >= tokenEnd)
- tokenStart = tokenEnd = 0;
- }
-
- if (tokenEnd == 0) {
- tokenEnd = lastChar + 1;
- }
-
- Process_updateCmdline(process, command, tokenStart, tokenEnd);
-
- /* /proc/[pid]/comm could change, so should be updated */
- if ((amtRead = xReadfileat(procFd, "comm", command, sizeof(command))) > 0) {
- command[amtRead - 1] = '\0';
- Process_updateComm(process, command);
- } else {
- Process_updateComm(process, NULL);
- }
-
- char filename[MAX_NAME + 1];
-
- /* execve could change /proc/[pid]/exe, so procExe should be updated */
-#if defined(HAVE_READLINKAT) && defined(HAVE_OPENAT)
- amtRead = readlinkat(procFd, "exe", filename, sizeof(filename) - 1);
-#else
- amtRead = Compat_readlink(procFd, "exe", filename, sizeof(filename) - 1);
-#endif
- if (amtRead > 0) {
- filename[amtRead] = 0;
- if (!process->procExe ||
- (!process->procExeDeleted && !String_eq(filename, process->procExe)) ||
- process->procExeDeleted) {
-
- const char* deletedMarker = " (deleted)";
- const size_t markerLen = strlen(deletedMarker);
- const size_t filenameLen = strlen(filename);
-
- if (filenameLen > markerLen) {
- bool oldExeDeleted = process->procExeDeleted;
-
- process->procExeDeleted = String_eq(filename + filenameLen - markerLen, deletedMarker);
-
- if (process->procExeDeleted)
- filename[filenameLen - markerLen] = '\0';
-
- if (oldExeDeleted != process->procExeDeleted)
- process->mergedCommand.lastUpdate = 0;
- }
-
- Process_updateExe(process, filename);
- }
- } else if (process->procExe) {
- Process_updateExe(process, NULL);
- process->procExeDeleted = false;
- }
-
- return true;
-}
-
-static char* LinuxProcessList_updateTtyDevice(TtyDriver* ttyDrivers, unsigned long 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;
- }
- if (maj > ttyDrivers[i].major) {
- continue;
- }
- if (min < ttyDrivers[i].minorFrom) {
- break;
- }
- if (min > ttyDrivers[i].minorTo) {
- continue;
- }
- unsigned int idx = min - ttyDrivers[i].minorFrom;
- struct stat sstat;
- char* fullPath;
- for (;;) {
- xAsprintf(&fullPath, "%s/%d", ttyDrivers[i].path, idx);
- int err = stat(fullPath, &sstat);
- if (err == 0 && major(sstat.st_rdev) == maj && minor(sstat.st_rdev) == min) {
- return fullPath;
- }
- free(fullPath);
-
- xAsprintf(&fullPath, "%s%d", ttyDrivers[i].path, idx);
- 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);
- if (err == 0 && tty_nr == sstat.st_rdev) {
- return xStrdup(ttyDrivers[i].path);
- }
- }
- char* out;
- xAsprintf(&out, "/dev/%u:%u", maj, min);
- return out;
-}
-
-static bool isOlderThan(const Process* proc, unsigned int seconds) {
- const Machine* host = proc->super.host;
-
- assert(host->realtimeMs > 0);
-
- /* Starttime might not yet be parsed */
- if (proc->starttime_ctime <= 0)
- return false;
-
- uint64_t realtime = host->realtimeMs / 1000;
-
- if (realtime < (uint64_t)proc->starttime_ctime)
- return false;
-
- return realtime - proc->starttime_ctime > seconds;
-}
-
-static bool LinuxProcessList_recurseProcTree(LinuxProcessList* this, openat_arg_t parentFd, const LinuxMachine* lhost, const char* dirname, const Process* parent) {
- ProcessList* pl = (ProcessList*) this;
- const Machine* host = &lhost->super;
- const Settings* settings = host->settings;
- const ScreenSettings* ss = settings->ss;
- const struct dirent* entry;
-
- /* set runningTasks from /proc/stat (from Machine_scanCPUTime) */
- pl->runningTasks = lhost->runningTasks;
-
-#ifdef HAVE_OPENAT
- int dirFd = openat(parentFd, dirname, O_RDONLY | O_DIRECTORY | O_NOFOLLOW);
- if (dirFd < 0)
- return false;
- DIR* dir = fdopendir(dirFd);
-#else
- char dirFd[4096];
- xSnprintf(dirFd, sizeof(dirFd), "%s/%s", parentFd, dirname);
- DIR* dir = opendir(dirFd);
-#endif
- if (!dir) {
- Compat_openatArgClose(dirFd);
- return false;
- }
-
- const bool hideKernelThreads = settings->hideKernelThreads;
- const bool hideUserlandThreads = settings->hideUserlandThreads;
- const bool hideRunningInContainer = settings->hideRunningInContainer;
- while ((entry = readdir(dir)) != NULL) {
- const char* name = entry->d_name;
-
- // Ignore all non-directories
- if (entry->d_type != DT_DIR && entry->d_type != DT_UNKNOWN) {
- continue;
- }
-
- // The RedHat kernel hides threads with a dot.
- // I believe this is non-standard.
- if (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;
- {
- char* endptr;
- unsigned long parsedPid = strtoul(name, &endptr, 10);
- if (parsedPid == 0 || parsedPid == ULONG_MAX || *endptr != '\0')
- continue;
- pid = parsedPid;
- }
-
- // Skip task directory of main thread
- if (parent && pid == Process_getPid(parent))
- continue;
-
-#ifdef HAVE_OPENAT
- int procFd = openat(dirFd, entry->d_name, O_RDONLY | O_DIRECTORY | O_NOFOLLOW);
- if (procFd < 0)
- continue;
-#else
- char procFd[4096];
- xSnprintf(procFd, sizeof(procFd), "%s/%s", dirFd, entry->d_name);
-#endif
-
- bool preExisting;
- Process* proc = ProcessList_getProcess(pl, pid, &preExisting, LinuxProcess_new);
- LinuxProcess* lp = (LinuxProcess*) proc;
-
- Process_setThreadGroup(proc, parent ? Process_getPid(parent) : pid);
- proc->isUserlandThread = Process_getPid(proc) != Process_getThreadGroup(proc);
-
- LinuxProcessList_recurseProcTree(this, procFd, lhost, "task", proc);
-
- /*
- * These conditions will not trigger on first occurrence, cause we need to
- * add the process to the ProcessList and do all one time scans
- * (e.g. parsing the cmdline to detect a kernel thread)
- * But it will short-circuit subsequent scans.
- */
- if (preExisting && hideKernelThreads && Process_isKernelThread(proc)) {
- proc->super.updated = true;
- proc->super.show = false;
- pl->kernelThreads++;
- pl->totalTasks++;
- Compat_openatArgClose(procFd);
- continue;
- }
- if (preExisting && hideUserlandThreads && Process_isUserlandThread(proc)) {
- proc->super.updated = true;
- proc->super.show = false;
- pl->userlandThreads++;
- pl->totalTasks++;
- Compat_openatArgClose(procFd);
- continue;
- }
- if (preExisting && hideRunningInContainer && proc->isRunningInContainer) {
- proc->super.updated = true;
- proc->super.show = false;
- Compat_openatArgClose(procFd);
- continue;
- }
-
- bool scanMainThread = !hideUserlandThreads && !Process_isKernelThread(proc) && !parent;
- if (ss->flags & PROCESS_FLAG_IO)
- LinuxProcessList_readIoFile(lp, procFd, scanMainThread);
-
- if (!LinuxProcessList_readStatmFile(lp, procFd, lhost))
- goto errorReadingProcess;
-
- {
- bool prev = proc->usesDeletedLib;
-
- if (!proc->isKernelThread && !proc->isUserlandThread &&
- ((ss->flags & PROCESS_FLAG_LINUX_LRS_FIX) || (settings->highlightDeletedExe && !proc->procExeDeleted && isOlderThan(proc, 10)))) {
-
- // Check if we really should recalculate the M_LRS value for this process
- uint64_t passedTimeInMs = host->realtimeMs - lp->last_mlrs_calctime;
-
- uint64_t recheck = ((uint64_t)rand()) % 2048;
-
- if (passedTimeInMs > recheck) {
- lp->last_mlrs_calctime = host->realtimeMs;
- LinuxProcessList_readMaps(lp, procFd, lhost, ss->flags & PROCESS_FLAG_LINUX_LRS_FIX, settings->highlightDeletedExe);
- }
- } else {
- /* Copy from process structure in threads and reset if setting got disabled */
- proc->usesDeletedLib = (proc->isUserlandThread && parent) ? parent->usesDeletedLib : false;
- lp->m_lrs = (proc->isUserlandThread && parent) ? ((const LinuxProcess*)parent)->m_lrs : 0;
- }
-
- if (prev != proc->usesDeletedLib)
- proc->mergedCommand.lastUpdate = 0;
- }
-
- if ((ss->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) {
- LinuxProcessList_readSmapsFile(lp, procFd, this->haveSmapsRollup);
- }
- if (pid == 1) {
- smaps_flag = !smaps_flag;
- }
- } else {
- lp->m_pss = ((const LinuxProcess*)parent)->m_pss;
- }
- }
-
- char statCommand[MAX_NAME + 1];
- unsigned long long int lasttimes = (lp->utime + lp->stime);
- unsigned long int tty_nr = proc->tty_nr;
- if (!LinuxProcessList_readStatFile(lp, procFd, lhost, scanMainThread, statCommand, sizeof(statCommand)))
- goto errorReadingProcess;
-
- if (lp->flags & PF_KTHREAD) {
- proc->isKernelThread = true;
- }
-
- if (tty_nr != proc->tty_nr && this->ttyDrivers) {
- free(proc->tty_name);
- proc->tty_name = LinuxProcessList_updateTtyDevice(this->ttyDrivers, proc->tty_nr);
- }
-
- if (ss->flags & PROCESS_FLAG_LINUX_IOPRIO) {
- LinuxProcess_updateIOPriority(proc);
- }
-
- proc->percent_cpu = NAN;
- /* lhost->period might be 0 after system sleep */
- if (lhost->period > 0.0) {
- float percent_cpu = saturatingSub(lp->utime + lp->stime, lasttimes) / lhost->period * 100.0;
- proc->percent_cpu = MINIMUM(percent_cpu, host->activeCPUs * 100.0F);
- }
- proc->percent_mem = proc->m_resident / (double)(host->totalMem) * 100.0;
- Process_updateCPUFieldWidths(proc->percent_cpu);
-
- if (! LinuxProcessList_updateUser(host, proc, procFd))
- goto errorReadingProcess;
-
- if (!LinuxProcessList_readStatusFile(proc, procFd))
- goto errorReadingProcess;
-
- if (!preExisting) {
-
- #ifdef HAVE_OPENVZ
- if (ss->flags & PROCESS_FLAG_LINUX_OPENVZ) {
- LinuxProcessList_readOpenVZData(lp, procFd);
- }
- #endif
-
- if (proc->isKernelThread) {
- Process_updateCmdline(proc, NULL, 0, 0);
- } else if (!LinuxProcessList_readCmdlineFile(proc, procFd)) {
- Process_updateCmdline(proc, statCommand, 0, strlen(statCommand));
- }
-
- Process_fillStarttimeBuffer(proc);
-
- ProcessList_add(pl, proc);
- } else {
- if (settings->updateProcessNames && proc->state != ZOMBIE) {
- if (proc->isKernelThread) {
- Process_updateCmdline(proc, NULL, 0, 0);
- } else if (!LinuxProcessList_readCmdlineFile(proc, procFd)) {
- Process_updateCmdline(proc, statCommand, 0, strlen(statCommand));
- }
- }
- }
-
- if (ss->flags & PROCESS_FLAG_LINUX_CGROUP)
- LinuxProcessList_readCGroupFile(lp, procFd);
-
- #ifdef HAVE_DELAYACCT
- if (ss->flags & PROCESS_FLAG_LINUX_DELAYACCT) {
- LinuxProcessList_readDelayAcctData(this, lp);
- }
- #endif
-
- if (ss->flags & PROCESS_FLAG_LINUX_OOM) {
- LinuxProcessList_readOomData(lp, procFd);
- }
-
- if (ss->flags & PROCESS_FLAG_LINUX_SECATTR) {
- LinuxProcessList_readSecattrData(lp, procFd);
- }
-
- if (ss->flags & PROCESS_FLAG_CWD) {
- LinuxProcessList_readCwd(lp, procFd);
- }
-
- if ((ss->flags & PROCESS_FLAG_LINUX_AUTOGROUP) && this->haveAutogroup) {
- LinuxProcessList_readAutogroup(lp, procFd);
- }
-
- #ifdef SCHEDULER_SUPPORT
- if (ss->flags & PROCESS_FLAG_SCHEDPOL) {
- Scheduling_readProcessPolicy(proc);
- }
- #endif
-
- if (!proc->cmdline && statCommand[0] &&
- (proc->state == ZOMBIE || Process_isKernelThread(proc) || settings->showThreadNames)) {
- Process_updateCmdline(proc, statCommand, 0, strlen(statCommand));
- }
-
- /*
- * Final section after all data has been gathered
- */
-
- proc->super.updated = true;
- Compat_openatArgClose(procFd);
-
- if (hideRunningInContainer && proc->isRunningInContainer) {
- proc->super.show = false;
- continue;
- }
-
- if (Process_isKernelThread(proc)) {
- pl->kernelThreads++;
- } else if (Process_isUserlandThread(proc)) {
- pl->userlandThreads++;
- }
-
- /* Set at the end when we know if a new entry is a thread */
- proc->super.show = ! ((hideKernelThreads && Process_isKernelThread(proc)) || (hideUserlandThreads && Process_isUserlandThread(proc)));
-
- pl->totalTasks++;
- /* runningTasks is set in Machine_scanCPUTime() from /proc/stat */
- continue;
-
- // Exception handler.
-
-errorReadingProcess:
- {
-#ifdef HAVE_OPENAT
- if (procFd >= 0)
- close(procFd);
-#endif
-
- if (preExisting) {
- /*
- * The only real reason for coming here (apart from Linux violating the /proc API)
- * would be the process going away with its /proc files disappearing (!HAVE_OPENAT).
- * However, we want to keep in the process list for now for the "highlight dying" mode.
- */
- } else {
- /* A really short-lived process that we don't have full info about */
- Process_delete((Object*)proc);
- }
- }
- }
- closedir(dir);
- return true;
-}
-
-void ProcessList_goThroughEntries(ProcessList* super) {
- LinuxProcessList* this = (LinuxProcessList*) super;
- const Machine* host = super->super.host;
- const Settings* settings = host->settings;
- const LinuxMachine* lhost = (const LinuxMachine*) host;
-
- if (settings->ss->flags & PROCESS_FLAG_LINUX_AUTOGROUP) {
- // Refer to sched(7) 'autogroup feature' section
- // The kernel feature can be enabled/disabled through procfs at
- // any time, so check for it at the start of each sample - only
- // read from per-process procfs files if it's globally enabled.
- this->haveAutogroup = LinuxProcess_isAutogroupEnabled();
- } else {
- this->haveAutogroup = false;
- }
-
- /* PROCDIR is an absolute path */
- assert(PROCDIR[0] == '/');
-#ifdef HAVE_OPENAT
- openat_arg_t rootFd = AT_FDCWD;
-#else
- openat_arg_t rootFd = "";
-#endif
-
- LinuxProcessList_recurseProcTree(this, rootFd, lhost, PROCDIR, NULL);
-}

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