aboutsummaryrefslogtreecommitdiffstats
path: root/linux/LinuxProcess.c
diff options
context:
space:
mode:
authorDaniel Lange <DLange@git.local>2020-12-07 10:26:01 +0100
committerDaniel Lange <DLange@git.local>2020-12-07 10:26:01 +0100
commit65357c8c46154de4e4eca14075bfe5523bb5fc14 (patch)
tree8f430ee5a0d5de377c4e7c94e47842a27c70d7e8 /linux/LinuxProcess.c
parentf80394a20254938142011855f2954b3f63fe5909 (diff)
downloaddebian_htop-65357c8c46154de4e4eca14075bfe5523bb5fc14.tar.gz
debian_htop-65357c8c46154de4e4eca14075bfe5523bb5fc14.tar.bz2
debian_htop-65357c8c46154de4e4eca14075bfe5523bb5fc14.zip
New upstream version 3.0.3upstream/3.0.3
Diffstat (limited to 'linux/LinuxProcess.c')
-rw-r--r--linux/LinuxProcess.c739
1 files changed, 623 insertions, 116 deletions
diff --git a/linux/LinuxProcess.c b/linux/LinuxProcess.c
index 377aa5b..8298000 100644
--- a/linux/LinuxProcess.c
+++ b/linux/LinuxProcess.c
@@ -2,25 +2,33 @@
htop - LinuxProcess.c
(C) 2014 Hisham H. Muhammad
(C) 2020 Red Hat, Inc. All Rights Reserved.
-Released under the GNU GPL, see the COPYING file
+Released under the GNU GPLv2, see the COPYING file
in the source distribution for its full text.
*/
-#include "Process.h"
-#include "ProcessList.h"
#include "LinuxProcess.h"
-#include "Platform.h"
-#include "CRT.h"
+#include <math.h>
+#include <stdio.h>
#include <stdlib.h>
-#include <unistd.h>
#include <string.h>
-#include <sys/syscall.h>
-#include <time.h>
+#include <syscall.h>
+#include <unistd.h>
+
+#include "CRT.h"
+#include "Macros.h"
+#include "Process.h"
+#include "ProvideCurses.h"
+#include "RichString.h"
+#include "XUtils.h"
+
/* semi-global */
long long btime;
+/* Used to identify kernel threads in Comm and Exe columns */
+static const char *const kthreadID = "KTHREAD";
+
ProcessFieldData Process_fields[] = {
[0] = { .name = "", .title = NULL, .description = NULL, .flags = 0, },
[PID] = { .name = "PID", .title = " PID ", .description = "Process/thread ID", .flags = 0, },
@@ -61,28 +69,28 @@ ProcessFieldData Process_fields[] = {
[CNSWAP] = { .name = "CNSWAP", .title = NULL, .description = NULL, .flags = 0, },
[EXIT_SIGNAL] = { .name = "EXIT_SIGNAL", .title = NULL, .description = NULL, .flags = 0, },
[PROCESSOR] = { .name = "PROCESSOR", .title = "CPU ", .description = "Id of the CPU the process last executed on", .flags = 0, },
- [M_SIZE] = { .name = "M_SIZE", .title = " VIRT ", .description = "Total program size in virtual memory", .flags = 0, },
+ [M_VIRT] = { .name = "M_VIRT", .title = " VIRT ", .description = "Total program size in virtual memory", .flags = 0, },
[M_RESIDENT] = { .name = "M_RESIDENT", .title = " RES ", .description = "Resident set size, size of the text and data sections, plus stack usage", .flags = 0, },
[M_SHARE] = { .name = "M_SHARE", .title = " SHR ", .description = "Size of the process's shared pages", .flags = 0, },
[M_TRS] = { .name = "M_TRS", .title = " CODE ", .description = "Size of the text segment of the process", .flags = 0, },
[M_DRS] = { .name = "M_DRS", .title = " DATA ", .description = "Size of the data segment plus stack usage of the process", .flags = 0, },
- [M_LRS] = { .name = "M_LRS", .title = " LIB ", .description = "The library size of the process", .flags = 0, },
- [M_DT] = { .name = "M_DT", .title = " DIRTY ", .description = "Size of the dirty pages of the process", .flags = 0, },
+ [M_LRS] = { .name = "M_LRS", .title = " LIB ", .description = "The library size of the process (calculated from memory maps)", .flags = PROCESS_FLAG_LINUX_LRS_FIX, },
+ [M_DT] = { .name = "M_DT", .title = " DIRTY ", .description = "Size of the dirty pages of the process (unused since Linux 2.6; always 0)", .flags = 0, },
[ST_UID] = { .name = "ST_UID", .title = " UID ", .description = "User ID of the process owner", .flags = 0, },
[PERCENT_CPU] = { .name = "PERCENT_CPU", .title = "CPU% ", .description = "Percentage of the CPU time the process used in the last sampling", .flags = 0, },
+ [PERCENT_NORM_CPU] = { .name = "PERCENT_NORM_CPU", .title = "NCPU%", .description = "Normalized percentage of the CPU time the process used in the last sampling (normalized by cpu count)", .flags = 0, },
[PERCENT_MEM] = { .name = "PERCENT_MEM", .title = "MEM% ", .description = "Percentage of the memory the process is using, based on resident memory size", .flags = 0, },
[USER] = { .name = "USER", .title = "USER ", .description = "Username of the process owner (or user ID if name cannot be determined)", .flags = 0, },
[TIME] = { .name = "TIME", .title = " TIME+ ", .description = "Total time the process has spent in user and system time", .flags = 0, },
[NLWP] = { .name = "NLWP", .title = "NLWP ", .description = "Number of threads in the process", .flags = 0, },
[TGID] = { .name = "TGID", .title = " TGID ", .description = "Thread group ID (i.e. process ID)", .flags = 0, },
#ifdef HAVE_OPENVZ
- [CTID] = { .name = "CTID", .title = " CTID ", .description = "OpenVZ container ID (a.k.a. virtual environment ID)", .flags = PROCESS_FLAG_LINUX_OPENVZ, },
- [VPID] = { .name = "VPID", .title = " VPID ", .description = "OpenVZ process ID", .flags = PROCESS_FLAG_LINUX_OPENVZ, },
+ [CTID] = { .name = "CTID", .title = " CTID ", .description = "OpenVZ container ID (a.k.a. virtual environment ID)", .flags = PROCESS_FLAG_LINUX_OPENVZ, },
+ [VPID] = { .name = "VPID", .title = " VPID ", .description = "OpenVZ process ID", .flags = PROCESS_FLAG_LINUX_OPENVZ, },
#endif
#ifdef HAVE_VSERVER
[VXID] = { .name = "VXID", .title = " VXID ", .description = "VServer process ID", .flags = PROCESS_FLAG_LINUX_VSERVER, },
#endif
-#ifdef HAVE_TASKSTATS
[RCHAR] = { .name = "RCHAR", .title = " RD_CHAR ", .description = "Number of bytes the process has read", .flags = PROCESS_FLAG_IO, },
[WCHAR] = { .name = "WCHAR", .title = " WR_CHAR ", .description = "Number of bytes the process has written", .flags = PROCESS_FLAG_IO, },
[SYSCR] = { .name = "SYSCR", .title = " RD_SYSC ", .description = "Number of read(2) syscalls for the process", .flags = PROCESS_FLAG_IO, },
@@ -93,10 +101,7 @@ ProcessFieldData Process_fields[] = {
[IO_READ_RATE] = { .name = "IO_READ_RATE", .title = " DISK READ ", .description = "The I/O rate of read(2) in bytes per second for the process", .flags = PROCESS_FLAG_IO, },
[IO_WRITE_RATE] = { .name = "IO_WRITE_RATE", .title = " DISK WRITE ", .description = "The I/O rate of write(2) in bytes per second for the process", .flags = PROCESS_FLAG_IO, },
[IO_RATE] = { .name = "IO_RATE", .title = " DISK R/W ", .description = "Total I/O rate in bytes per second", .flags = PROCESS_FLAG_IO, },
-#endif
-#ifdef HAVE_CGROUP
[CGROUP] = { .name = "CGROUP", .title = " CGROUP ", .description = "Which cgroup the process is in", .flags = PROCESS_FLAG_LINUX_CGROUP, },
-#endif
[OOM] = { .name = "OOM", .title = " OOM ", .description = "OOM (Out-of-Memory) killer score", .flags = PROCESS_FLAG_LINUX_OOM, },
[IO_PRIORITY] = { .name = "IO_PRIORITY", .title = "IO ", .description = "I/O priority", .flags = PROCESS_FLAG_LINUX_IOPRIO, },
#ifdef HAVE_DELAYACCT
@@ -107,6 +112,11 @@ ProcessFieldData Process_fields[] = {
[M_PSS] = { .name = "M_PSS", .title = " PSS ", .description = "proportional set size, same as M_RESIDENT but each page is divided by the number of processes sharing it.", .flags = PROCESS_FLAG_LINUX_SMAPS, },
[M_SWAP] = { .name = "M_SWAP", .title = " SWAP ", .description = "Size of the process's swapped pages", .flags = PROCESS_FLAG_LINUX_SMAPS, },
[M_PSSWP] = { .name = "M_PSSWP", .title = " PSSWP ", .description = "shows proportional swap share of this mapping, Unlike \"Swap\", this does not take into account swapped out page of underlying shmem objects.", .flags = PROCESS_FLAG_LINUX_SMAPS, },
+ [CTXT] = { .name = "CTXT", .title = " CTXT ", .description = "Context switches (incremental sum of voluntary_ctxt_switches and nonvoluntary_ctxt_switches)", .flags = PROCESS_FLAG_LINUX_CTXT, },
+ [SECATTR] = { .name = "SECATTR", .title = " Security Attribute ", .description = "Security attribute of the process (e.g. SELinux or AppArmor)", .flags = PROCESS_FLAG_LINUX_SECATTR, },
+ [PROC_COMM] = { .name = "COMM", .title = "COMM ", .description = "comm string of the process from /proc/[pid]/comm", .flags = 0, },
+ [PROC_EXE] = { .name = "EXE", .title = "EXE ", .description = "Basename of exe of the process from /proc/[pid]/exe", .flags = 0, },
+ [CWD] = { .name ="CWD", .title = "CWD ", .description = "The current working directory of the process", .flags = PROCESS_FLAG_LINUX_CWD, },
[LAST_PROCESSFIELD] = { .name = "*** report bug! ***", .title = NULL, .description = NULL, .flags = 0, },
};
@@ -123,30 +133,37 @@ ProcessPidColumn Process_pidColumns[] = {
{ .id = 0, .label = NULL },
};
-ProcessClass LinuxProcess_class = {
- .super = {
- .extends = Class(Process),
- .display = Process_display,
- .delete = Process_delete,
- .compare = LinuxProcess_compare
- },
- .writeField = (Process_WriteField) LinuxProcess_writeField,
-};
+/* This function returns the string displayed in Command column, so that sorting
+ * happens on what is displayed - whether comm, full path, basename, etc.. So
+ * this follows LinuxProcess_writeField(COMM) and LinuxProcess_writeCommand */
+static const char* LinuxProcess_getCommandStr(const Process *this) {
+ const LinuxProcess *lp = (const LinuxProcess *)this;
+ if ((Process_isUserlandThread(this) && this->settings->showThreadNames) || !lp->mergedCommand.str) {
+ return this->comm;
+ }
+ return lp->mergedCommand.str;
+}
-LinuxProcess* LinuxProcess_new(Settings* settings) {
+Process* LinuxProcess_new(const Settings* settings) {
LinuxProcess* this = xCalloc(1, sizeof(LinuxProcess));
Object_setClass(this, Class(LinuxProcess));
Process_init(&this->super, settings);
- return this;
+ return &this->super;
}
void Process_delete(Object* cast) {
LinuxProcess* this = (LinuxProcess*) cast;
Process_done((Process*)cast);
-#ifdef HAVE_CGROUP
free(this->cgroup);
+#ifdef HAVE_OPENVZ
+ free(this->ctid);
#endif
+ free(this->cwd);
+ free(this->secattr);
free(this->ttyDevice);
+ free(this->procExe);
+ free(this->procComm);
+ free(this->mergedCommand.str);
free(this);
}
@@ -158,7 +175,13 @@ effort class. The priority within the best effort class will be
dynamically derived from the cpu nice level of the process:
io_priority = (cpu_nice + 20) / 5. -- From ionice(1) man page
*/
-#define LinuxProcess_effectiveIOPriority(p_) (IOPriority_class(p_->ioPriority) == IOPRIO_CLASS_NONE ? IOPriority_tuple(IOPRIO_CLASS_BE, (p_->super.nice + 20) / 5) : p_->ioPriority)
+static int LinuxProcess_effectiveIOPriority(const LinuxProcess* this) {
+ if (IOPriority_class(this->ioPriority) == IOPRIO_CLASS_NONE) {
+ return IOPriority_tuple(IOPRIO_CLASS_BE, (this->super.nice + 20) / 5);
+ }
+
+ return this->ioPriority;
+}
IOPriority LinuxProcess_updateIOPriority(LinuxProcess* this) {
IOPriority ioprio = 0;
@@ -170,30 +193,432 @@ IOPriority LinuxProcess_updateIOPriority(LinuxProcess* this) {
return ioprio;
}
-bool LinuxProcess_setIOPriority(LinuxProcess* this, Arg ioprio) {
+bool LinuxProcess_setIOPriority(Process* this, Arg ioprio) {
// Other OSes masquerading as Linux (NetBSD?) don't have this syscall
#ifdef SYS_ioprio_set
- syscall(SYS_ioprio_set, IOPRIO_WHO_PROCESS, this->super.pid, ioprio.i);
+ syscall(SYS_ioprio_set, IOPRIO_WHO_PROCESS, this->pid, ioprio.i);
#endif
- return (LinuxProcess_updateIOPriority(this) == ioprio.i);
+ return (LinuxProcess_updateIOPriority((LinuxProcess*)this) == ioprio.i);
}
#ifdef HAVE_DELAYACCT
-void LinuxProcess_printDelay(float delay_percent, char* buffer, int n) {
- if (delay_percent == -1LL) {
- xSnprintf(buffer, n, " N/A ");
- } else {
- xSnprintf(buffer, n, "%4.1f ", delay_percent);
- }
+static void LinuxProcess_printDelay(float delay_percent, char* buffer, int n) {
+ if (isnan(delay_percent)) {
+ xSnprintf(buffer, n, " N/A ");
+ } else {
+ xSnprintf(buffer, n, "%4.1f ", delay_percent);
+ }
}
#endif
-void LinuxProcess_writeField(Process* this, RichString* str, ProcessField field) {
- LinuxProcess* lp = (LinuxProcess*) this;
+/*
+TASK_COMM_LEN is defined to be 16 for /proc/[pid]/comm in man proc(5), but it is
+not available in an userspace header - so define it. Note: when colorizing a
+basename with the comm prefix, the entire basename (not just the comm prefix) is
+colorized for better readability, and it is implicit that only upto
+(TASK_COMM_LEN - 1) could be comm
+*/
+#define TASK_COMM_LEN 16
+
+static bool findCommInCmdline(const char *comm, const char *cmdline, int cmdlineBasenameOffset, int *pCommStart, int *pCommEnd) {
+ /* Try to find procComm in tokenized cmdline - this might in rare cases
+ * mis-identify a string or fail, if comm or cmdline had been unsuitably
+ * modified by the process */
+ const char *token;
+ const char *tokenBase;
+ size_t tokenLen;
+ const size_t commLen = strlen(comm);
+
+ for (token = cmdline + cmdlineBasenameOffset; *token; ) {
+ for (tokenBase = token; *token && *token != '\n'; ++token) {
+ if (*token == '/') {
+ tokenBase = token + 1;
+ }
+ }
+ tokenLen = token - tokenBase;
+
+ if ((tokenLen == commLen || (tokenLen > commLen && commLen == (TASK_COMM_LEN - 1))) &&
+ strncmp(tokenBase, comm, commLen) == 0) {
+ *pCommStart = tokenBase - cmdline;
+ *pCommEnd = token - cmdline;
+ return true;
+ }
+ if (*token) {
+ do {
+ ++token;
+ } while ('\n' == *token);
+ }
+ }
+ return false;
+}
+
+static int matchCmdlinePrefixWithExeSuffix(const char *cmdline, int cmdlineBaseOffset, const char *exe, int exeBaseOffset, int exeBaseLen) {
+ int matchLen; /* matching length to be returned */
+ char delim; /* delimiter following basename */
+
+ /* cmdline prefix is an absolute path: it must match whole exe. */
+ if (cmdline[0] == '/') {
+ matchLen = exeBaseLen + exeBaseOffset;
+ if (strncmp(cmdline, exe, matchLen) == 0) {
+ delim = cmdline[matchLen];
+ if (delim == 0 || delim == '\n' || delim == ' ') {
+ return matchLen;
+ }
+ }
+ return 0;
+ }
+
+ /* cmdline prefix is a relative path: We need to first match the basename at
+ * cmdlineBaseOffset and then reverse match the cmdline prefix with the exe
+ * suffix. But there is a catch: Some processes modify their cmdline in ways
+ * that make htop's identification of the basename in cmdline unreliable.
+ * For e.g. /usr/libexec/gdm-session-worker modifies its cmdline to
+ * "gdm-session-worker [pam/gdm-autologin]" and htop ends up with
+ * procCmdlineBasenameOffset at "gdm-autologin]". This issue could arise with
+ * chrome as well as it stores in cmdline its concatenated argument vector,
+ * without NUL delimiter between the arguments (which may contain a '/')
+ *
+ * So if needed, we adjust cmdlineBaseOffset to the previous (if any)
+ * component of the cmdline relative path, and retry the procedure. */
+ bool delimFound; /* if valid basename delimiter found */
+ do {
+ /* match basename */
+ matchLen = exeBaseLen + cmdlineBaseOffset;
+ if (cmdlineBaseOffset < exeBaseOffset &&
+ strncmp(cmdline + cmdlineBaseOffset, exe + exeBaseOffset, exeBaseLen) == 0) {
+ delim = cmdline[matchLen];
+ if (delim == 0 || delim == '\n' || delim == ' ') {
+ int i, j;
+ /* reverse match the cmdline prefix and exe suffix */
+ for (i = cmdlineBaseOffset - 1, j = exeBaseOffset - 1;
+ i >= 0 && cmdline[i] == exe[j]; --i, --j)
+ ;
+ /* full match, with exe suffix being a valid relative path */
+ if (i < 0 && exe[j] == '/') {
+ return matchLen;
+ }
+ }
+ }
+ /* Try to find the previous potential cmdlineBaseOffset - it would be
+ * preceded by '/' or nothing, and delimited by ' ' or '\n' */
+ for (delimFound = false, cmdlineBaseOffset -= 2; cmdlineBaseOffset > 0; --cmdlineBaseOffset) {
+ if (delimFound) {
+ if (cmdline[cmdlineBaseOffset - 1] == '/') {
+ break;
+ }
+ } else if (cmdline[cmdlineBaseOffset] == ' ' || cmdline[cmdlineBaseOffset] == '\n') {
+ delimFound = true;
+ }
+ }
+ } while (delimFound);
+
+ return 0;
+}
+
+/* stpcpy, but also converts newlines to spaces */
+static inline char *stpcpyWithNewlineConversion(char *dstStr, const char *srcStr) {
+ for (; *srcStr; ++srcStr) {
+ *dstStr++ = (*srcStr == '\n') ? ' ' : *srcStr;
+ }
+ *dstStr = 0;
+ return dstStr;
+}
+
+/*
+This function makes the merged Command string. It also stores the offsets of the
+basename, comm w.r.t the merged Command string - these offsets will be used by
+LinuxProcess_writeCommand() for coloring. The merged Command string is also
+returned by LinuxProcess_getCommandStr() for searching, sorting and filtering.
+*/
+void LinuxProcess_makeCommandStr(Process* this) {
+ LinuxProcess *lp = (LinuxProcess *)this;
+ LinuxProcessMergedCommand *mc = &lp->mergedCommand;
+
+ bool showMergedCommand = this->settings->showMergedCommand;
+ bool showProgramPath = this->settings->showProgramPath;
+ bool searchCommInCmdline = this->settings->findCommInCmdline;
+ bool stripExeFromCmdline = this->settings->stripExeFromCmdline;
+
+ /* lp->mergedCommand.str needs updating only if its state or contents changed.
+ * Its content is based on the fields cmdline, comm, and exe. */
+ if (
+ mc->prevMergeSet == showMergedCommand &&
+ mc->prevPathSet == showProgramPath &&
+ mc->prevCommSet == searchCommInCmdline &&
+ mc->prevCmdlineSet == stripExeFromCmdline &&
+ !mc->cmdlineChanged &&
+ !mc->commChanged &&
+ !mc->exeChanged
+ ) {
+ return;
+ }
+
+ /* The field separtor "│" has been chosen such that it will not match any
+ * valid string used for searching or filtering */
+ const char *SEPARATOR = CRT_treeStr[TREE_STR_VERT];
+ const int SEPARATOR_LEN = strlen(SEPARATOR);
+
+ /* Check for any changed fields since we last built this string */
+ if (mc->cmdlineChanged || mc->commChanged || mc->exeChanged) {
+ free(mc->str);
+ /* Accommodate the column text, two field separators and terminating NUL */
+ mc->str = xCalloc(1, mc->maxLen + 2*SEPARATOR_LEN + 1);
+ }
+
+ /* Preserve the settings used in this run */
+ mc->prevMergeSet = showMergedCommand;
+ mc->prevPathSet = showProgramPath;
+ mc->prevCommSet = searchCommInCmdline;
+ mc->prevCmdlineSet = stripExeFromCmdline;
+
+ /* Mark everything as unchanged */
+ mc->cmdlineChanged = false;
+ mc->commChanged = false;
+ mc->exeChanged = false;
+
+ /* Clear any separators */
+ mc->sep1 = 0;
+ mc->sep2 = 0;
+
+ /* Clear any highlighting locations */
+ mc->baseStart = 0;
+ mc->baseEnd = 0;
+ mc->commStart = 0;
+ mc->commEnd = 0;
+
+ const char *cmdline = this->comm;
+ const char *procExe = lp->procExe;
+ const char *procComm = lp->procComm;
+
+ char *strStart = mc->str;
+ char *str = strStart;
+
+ int cmdlineBasenameOffset = lp->procCmdlineBasenameOffset;
+
+ if (!showMergedCommand || !procExe || !procComm) { /* fall back to cmdline */
+ if (showMergedCommand && !procExe && procComm && strlen(procComm)) { /* Prefix column with comm */
+ if (strncmp(cmdline + cmdlineBasenameOffset, procComm, MINIMUM(TASK_COMM_LEN - 1, strlen(procComm))) != 0) {
+ mc->commStart = 0;
+ mc->commEnd = strlen(procComm);
+
+ str = stpcpy(str, procComm);
+
+ mc->sep1 = str - strStart;
+ str = stpcpy(str, SEPARATOR);
+ }
+ }
+
+ if (showProgramPath) {
+ (void) stpcpyWithNewlineConversion(str, cmdline);
+ mc->baseStart = cmdlineBasenameOffset;
+ mc->baseEnd = lp->procCmdlineBasenameEnd;
+ } else {
+ (void) stpcpyWithNewlineConversion(str, cmdline + cmdlineBasenameOffset);
+ mc->baseStart = 0;
+ mc->baseEnd = lp->procCmdlineBasenameEnd - cmdlineBasenameOffset;
+ }
+
+ if (mc->sep1) {
+ mc->baseStart += str - strStart - SEPARATOR_LEN + 1;
+ mc->baseEnd += str - strStart - SEPARATOR_LEN + 1;
+ }
+
+ return;
+ }
+
+ int exeLen = lp->procExeLen;
+ int exeBasenameOffset = lp->procExeBasenameOffset;
+ int exeBasenameLen = exeLen - exeBasenameOffset;
+
+ /* Start with copying exe */
+ if (showProgramPath) {
+ str = stpcpy(str, procExe);
+ mc->baseStart = exeBasenameOffset;
+ mc->baseEnd = exeLen;
+ } else {
+ str = stpcpy(str, procExe + exeBasenameOffset);
+ mc->baseStart = 0;
+ mc->baseEnd = exeBasenameLen;
+ }
+
+ mc->sep1 = 0;
+ mc->sep2 = 0;
+
+ int commStart = 0;
+ int commEnd = 0;
+ bool commInCmdline = false;
+
+ /* Try to match procComm with procExe's basename: This is reliable (predictable) */
+ if (strncmp(procExe + exeBasenameOffset, procComm, TASK_COMM_LEN - 1) == 0) {
+ commStart = mc->baseStart;
+ commEnd = mc->baseEnd;
+ } else if (searchCommInCmdline) {
+ /* commStart/commEnd will be adjusted later along with cmdline */
+ commInCmdline = findCommInCmdline(procComm, cmdline, cmdlineBasenameOffset, &commStart, &commEnd);
+ }
+
+ int matchLen = matchCmdlinePrefixWithExeSuffix(cmdline, cmdlineBasenameOffset, procExe, exeBasenameOffset, exeBasenameLen);
+
+ /* Note: commStart, commEnd are offsets into RichString. But the multibyte
+ * separator (with size SEPARATOR_LEN) has size 1 in RichString. The offset
+ * adjustments below reflect this. */
+ if (commEnd) {
+ mc->unmatchedExe = !matchLen;
+
+ if (matchLen) {
+ /* strip the matched exe prefix */
+ cmdline += matchLen;
+
+ if (commInCmdline) {
+ commStart += str - strStart - matchLen;
+ commEnd += str - strStart - matchLen;
+ }
+ } else {
+ /* cmdline will be a separate field */
+ mc->sep1 = str - strStart;
+ str = stpcpy(str, SEPARATOR);
+
+ if (commInCmdline) {
+ commStart += str - strStart - SEPARATOR_LEN + 1;
+ commEnd += str - strStart - SEPARATOR_LEN + 1;
+ }
+ }
+
+ mc->separateComm = false; /* procComm merged */
+ } else {
+ mc->sep1 = str - strStart;
+ str = stpcpy(str, SEPARATOR);
+
+ commStart = str - strStart - SEPARATOR_LEN + 1;
+ str = stpcpy(str, procComm);
+ commEnd = str - strStart - SEPARATOR_LEN + 1; /* or commStart + strlen(procComm) */
+
+ mc->unmatchedExe = !matchLen;
+
+ if (matchLen) {
+ if (stripExeFromCmdline) {
+ cmdline += matchLen;
+ }
+ }
+
+ if (*cmdline) {
+ mc->sep2 = str - strStart - SEPARATOR_LEN + 1;
+ str = stpcpy(str, SEPARATOR);
+ }
+
+ mc->separateComm = true; /* procComm a separate field */
+ }
+
+ /* Display cmdline if it hasn't been consumed by procExe */
+ if (*cmdline) {
+ (void) stpcpyWithNewlineConversion(str, cmdline);
+ }
+
+ mc->commStart = commStart;
+ mc->commEnd = commEnd;
+}
+
+static void LinuxProcess_writeCommand(const Process* this, int attr, int baseAttr, RichString* str) {
+ const LinuxProcess *lp = (const LinuxProcess *)this;
+ const LinuxProcessMergedCommand *mc = &lp->mergedCommand;
+
+ int strStart = RichString_size(str);
+
+ int baseStart = strStart + lp->mergedCommand.baseStart;
+ int baseEnd = strStart + lp->mergedCommand.baseEnd;
+ int commStart = strStart + lp->mergedCommand.commStart;
+ int commEnd = strStart + lp->mergedCommand.commEnd;
+
+ int commAttr = CRT_colors[Process_isUserlandThread(this) ? PROCESS_THREAD_COMM : PROCESS_COMM];
+
+ bool highlightBaseName = this->settings->highlightBaseName;
+
+ if(lp->procExeDeleted)
+ baseAttr = CRT_colors[FAILED_READ];
+
+ RichString_append(str, attr, lp->mergedCommand.str);
+
+ if (lp->mergedCommand.commEnd) {
+ if (!lp->mergedCommand.separateComm && commStart == baseStart && highlightBaseName) {
+ /* If it was matched with procExe's basename, make it bold if needed */
+ if (commEnd > baseEnd) {
+ RichString_setAttrn(str, A_BOLD | baseAttr, baseStart, baseEnd - 1);
+ RichString_setAttrn(str, A_BOLD | commAttr, baseEnd, commEnd - 1);
+ } else if (commEnd < baseEnd) {
+ RichString_setAttrn(str, A_BOLD | commAttr, commStart, commEnd - 1);
+ RichString_setAttrn(str, A_BOLD | baseAttr, commEnd, baseEnd - 1);
+ } else {
+ // Actually should be highlighted commAttr, but marked baseAttr to reduce visual noise
+ RichString_setAttrn(str, A_BOLD | baseAttr, commStart, commEnd - 1);
+ }
+
+ baseStart = baseEnd;
+ } else {
+ RichString_setAttrn(str, commAttr, commStart, commEnd - 1);
+ }
+ }
+
+ if (baseStart < baseEnd && highlightBaseName) {
+ RichString_setAttrn(str, baseAttr, baseStart, baseEnd - 1);
+ }
+
+ if (mc->sep1)
+ RichString_setAttrn(str, CRT_colors[FAILED_READ], strStart + mc->sep1, strStart + mc->sep1);
+ if (mc->sep2)
+ RichString_setAttrn(str, CRT_colors[FAILED_READ], strStart + mc->sep2, strStart + mc->sep2);
+}
+
+static void LinuxProcess_writeCommandField(const Process *this, RichString *str, char *buffer, int n, int attr) {
+ /* This code is from Process_writeField for COMM, but we invoke
+ * LinuxProcess_writeCommand to display
+ * /proc/pid/exe (or its basename)│/proc/pid/comm│/proc/pid/cmdline */
+ int baseattr = CRT_colors[PROCESS_BASENAME];
+ if (this->settings->highlightThreads && Process_isThread(this)) {
+ attr = CRT_colors[PROCESS_THREAD];
+ baseattr = CRT_colors[PROCESS_THREAD_BASENAME];
+ }
+ if (!this->settings->treeView || this->indent == 0) {
+ LinuxProcess_writeCommand(this, attr, baseattr, str);
+ } else {
+ char* buf = buffer;
+ int maxIndent = 0;
+ bool lastItem = (this->indent < 0);
+ int indent = (this->indent < 0 ? -this->indent : this->indent);
+ int vertLen = strlen(CRT_treeStr[TREE_STR_VERT]);
+
+ for (int i = 0; i < 32; i++) {
+ if (indent & (1U << i)) {
+ maxIndent = i+1;
+ }
+ }
+ for (int i = 0; i < maxIndent - 1; i++) {
+ if (indent & (1 << i)) {
+ if (buf - buffer + (vertLen + 3) > n) {
+ break;
+ }
+ buf = stpcpy(buf, CRT_treeStr[TREE_STR_VERT]);
+ buf = stpcpy(buf, " ");
+ } else {
+ if (buf - buffer + 4 > n) {
+ break;
+ }
+ buf = stpcpy(buf, " ");
+ }
+ }
+ n -= (buf - buffer);
+ const char* draw = CRT_treeStr[lastItem ? (this->settings->direction == 1 ? TREE_STR_BEND : TREE_STR_TEND) : TREE_STR_RTEE];
+ xSnprintf(buf, n, "%s%s ", draw, this->showChildren ? CRT_treeStr[TREE_STR_SHUT] : CRT_treeStr[TREE_STR_OPEN] );
+ RichString_append(str, CRT_colors[PROCESS_TREE], buffer);
+ LinuxProcess_writeCommand(this, attr, baseattr, str);
+ }
+}
+
+static void LinuxProcess_writeField(const Process* this, RichString* str, ProcessField field) {
+ const LinuxProcess* lp = (const LinuxProcess*) this;
bool coloring = this->settings->highlightMegabytes;
char buffer[256]; buffer[255] = '\0';
int attr = CRT_colors[DEFAULT_COLOR];
- int n = sizeof(buffer) - 1;
+ size_t n = sizeof(buffer) - 1;
switch ((int)field) {
case TTY_NR: {
if (lp->ttyDevice) {
@@ -206,11 +631,19 @@ void LinuxProcess_writeField(Process* this, RichString* str, ProcessField field)
}
case CMINFLT: Process_colorNumber(str, lp->cminflt, coloring); return;
case CMAJFLT: Process_colorNumber(str, lp->cmajflt, coloring); return;
- case M_DRS: Process_humanNumber(str, lp->m_drs * PAGE_SIZE_KB, coloring); return;
- case M_DT: Process_humanNumber(str, lp->m_dt * PAGE_SIZE_KB, coloring); return;
- case M_LRS: Process_humanNumber(str, lp->m_lrs * PAGE_SIZE_KB, coloring); return;
- case M_TRS: Process_humanNumber(str, lp->m_trs * PAGE_SIZE_KB, coloring); return;
- case M_SHARE: Process_humanNumber(str, lp->m_share * PAGE_SIZE_KB, coloring); return;
+ case M_DRS: Process_humanNumber(str, lp->m_drs * CRT_pageSizeKB, coloring); return;
+ case M_DT: Process_humanNumber(str, lp->m_dt * CRT_pageSizeKB, coloring); return;
+ case M_LRS:
+ if (lp->m_lrs) {
+ Process_humanNumber(str, lp->m_lrs * CRT_pageSizeKB, coloring);
+ return;
+ }
+
+ attr = CRT_colors[PROCESS_SHADOW];
+ xSnprintf(buffer, n, " N/A ");
+ break;
+ case M_TRS: Process_humanNumber(str, lp->m_trs * CRT_pageSizeKB, coloring); return;
+ case M_SHARE: Process_humanNumber(str, lp->m_share * CRT_pageSizeKB, coloring); return;
case M_PSS: Process_humanNumber(str, lp->m_pss, coloring); return;
case M_SWAP: Process_humanNumber(str, lp->m_swap, coloring); return;
case M_PSSWP: Process_humanNumber(str, lp->m_psswp, coloring); return;
@@ -218,14 +651,6 @@ void LinuxProcess_writeField(Process* this, RichString* str, ProcessField field)
case STIME: Process_printTime(str, lp->stime); return;
case CUTIME: Process_printTime(str, lp->cutime); return;
case CSTIME: Process_printTime(str, lp->cstime); return;
- case STARTTIME: {
- struct tm date;
- time_t starttimewall = btime + (lp->starttime / sysconf(_SC_CLK_TCK));
- (void) localtime_r(&starttimewall, &date);
- strftime(buffer, n, ((starttimewall > time(NULL) - 86400) ? "%R " : "%b%d "), &date);
- break;
- }
- #ifdef HAVE_TASKSTATS
case RCHAR: Process_colorNumber(str, lp->io_rchar, coloring); return;
case WCHAR: Process_colorNumber(str, lp->io_wchar, coloring); return;
case SYSCR: Process_colorNumber(str, lp->io_syscr, coloring); return;
@@ -236,22 +661,25 @@ void LinuxProcess_writeField(Process* this, RichString* str, ProcessField field)
case IO_READ_RATE: Process_outputRate(str, buffer, n, lp->io_rate_read_bps, coloring); return;
case IO_WRITE_RATE: Process_outputRate(str, buffer, n, lp->io_rate_write_bps, coloring); return;
case IO_RATE: {
- double totalRate = (lp->io_rate_read_bps != -1)
- ? (lp->io_rate_read_bps + lp->io_rate_write_bps)
- : -1;
+ double totalRate = NAN;
+ if (!isnan(lp->io_rate_read_bps) && !isnan(lp->io_rate_write_bps))
+ totalRate = lp->io_rate_read_bps + lp->io_rate_write_bps;
+ else if (!isnan(lp->io_rate_read_bps))
+ totalRate = lp->io_rate_read_bps;
+ else if (!isnan(lp->io_rate_write_bps))
+ totalRate = lp->io_rate_write_bps;
+ else
+ totalRate = NAN;
Process_outputRate(str, buffer, n, totalRate, coloring); return;
}
- #endif
#ifdef HAVE_OPENVZ
- case CTID: xSnprintf(buffer, n, "%7u ", lp->ctid); break;
+ case CTID: xSnprintf(buffer, n, "%-8s ", lp->ctid ? lp->ctid : ""); break;
case VPID: xSnprintf(buffer, n, Process_pidFormat, lp->vpid); break;
#endif
#ifdef HAVE_VSERVER
case VXID: xSnprintf(buffer, n, "%5u ", lp->vxid); break;
#endif
- #ifdef HAVE_CGROUP
- case CGROUP: xSnprintf(buffer, n, "%-10s ", lp->cgroup); break;
- #endif
+ case CGROUP: xSnprintf(buffer, n, "%-10s ", lp->cgroup ? lp->cgroup : ""); break;
case OOM: xSnprintf(buffer, n, "%4u ", lp->oom); break;
case IO_PRIORITY: {
int klass = IOPriority_class(lp->ioPriority);
@@ -276,96 +704,175 @@ void LinuxProcess_writeField(Process* this, RichString* str, ProcessField field)
case PERCENT_IO_DELAY: LinuxProcess_printDelay(lp->blkio_delay_percent, buffer, n); break;
case PERCENT_SWAP_DELAY: LinuxProcess_printDelay(lp->swapin_delay_percent, buffer, n); break;
#endif
+ case CTXT:
+ if (lp->ctxt_diff > 1000) {
+ attr |= A_BOLD;
+ }
+ xSnprintf(buffer, n, "%5lu ", lp->ctxt_diff);
+ break;
+ case SECATTR: snprintf(buffer, n, "%-30s ", lp->secattr ? lp->secattr : "?"); break;
+ case COMM: {
+ if ((Process_isUserlandThread(this) && this->settings->showThreadNames) || !lp->mergedCommand.str) {
+ Process_writeField(this, str, field);
+ } else {
+ LinuxProcess_writeCommandField(this, str, buffer, n, attr);
+ }
+ return;
+ }
+ case PROC_COMM: {
+ if (lp->procComm) {
+ attr = CRT_colors[Process_isUserlandThread(this) ? PROCESS_THREAD_COMM : PROCESS_COMM];
+ /* 15 being (TASK_COMM_LEN - 1) */
+ xSnprintf(buffer, n, "%-15.15s ", lp->procComm);
+ } else {
+ attr = CRT_colors[PROCESS_SHADOW];
+ xSnprintf(buffer, n, "%-15.15s ", Process_isKernelThread(lp) ? kthreadID : "N/A");
+ }
+ break;
+ }
+ case PROC_EXE: {
+ if (lp->procExe) {
+ attr = CRT_colors[Process_isUserlandThread(this) ? PROCESS_THREAD_BASENAME : PROCESS_BASENAME];
+ if (lp->procExeDeleted)
+ attr = CRT_colors[FAILED_READ];
+ xSnprintf(buffer, n, "%-15.15s ", lp->procExe + lp->procExeBasenameOffset);
+ } else {
+ attr = CRT_colors[PROCESS_SHADOW];
+ xSnprintf(buffer, n, "%-15.15s ", Process_isKernelThread(lp) ? kthreadID : "N/A");
+ }
+ break;
+ }
+ case CWD:
+ if (!lp->cwd) {
+ xSnprintf(buffer, n, "%-25s ", "N/A");
+ attr = CRT_colors[PROCESS_SHADOW];
+ } else if (String_startsWith(lp->cwd, "/proc/") && strstr(lp->cwd, " (deleted)") != NULL) {
+ xSnprintf(buffer, n, "%-25s ", "main thread terminated");
+ attr = CRT_colors[PROCESS_SHADOW];
+ } else {
+ xSnprintf(buffer, n, "%-25.25s ", lp->cwd);
+ }
+ break;
default:
- Process_writeField((Process*)this, str, field);
+ Process_writeField(this, str, field);
return;
}
RichString_append(str, attr, buffer);
}
-long LinuxProcess_compare(const void* v1, const void* v2) {
- LinuxProcess *p1, *p2;
- Settings *settings = ((Process*)v1)->settings;
+static long LinuxProcess_compare(const void* v1, const void* v2) {
+ const LinuxProcess *p1, *p2;
+ const Settings *settings = ((const Process*)v1)->settings;
+
if (settings->direction == 1) {
- p1 = (LinuxProcess*)v1;
- p2 = (LinuxProcess*)v2;
+ p1 = (const LinuxProcess*)v1;
+ p2 = (const LinuxProcess*)v2;
} else {
- p2 = (LinuxProcess*)v1;
- p1 = (LinuxProcess*)v2;
+ p2 = (const LinuxProcess*)v1;
+ p1 = (const LinuxProcess*)v2;
}
- long long diff;
+
switch ((int)settings->sortKey) {
case M_DRS:
- return (p2->m_drs - p1->m_drs);
+ return SPACESHIP_NUMBER(p2->m_drs, p1->m_drs);
case M_DT:
- return (p2->m_dt - p1->m_dt);
+ return SPACESHIP_NUMBER(p2->m_dt, p1->m_dt);
case M_LRS:
- return (p2->m_lrs - p1->m_lrs);
+ return SPACESHIP_NUMBER(p2->m_lrs, p1->m_lrs);
case M_TRS:
- return (p2->m_trs - p1->m_trs);
+ return SPACESHIP_NUMBER(p2->m_trs, p1->m_trs);
case M_SHARE:
- return (p2->m_share - p1->m_share);
+ return SPACESHIP_NUMBER(p2->m_share, p1->m_share);
case M_PSS:
- return (p2->m_pss - p1->m_pss);
+ return SPACESHIP_NUMBER(p2->m_pss, p1->m_pss);
case M_SWAP:
- return (p2->m_swap - p1->m_swap);
+ return SPACESHIP_NUMBER(p2->m_swap, p1->m_swap);
case M_PSSWP:
- return (p2->m_psswp - p1->m_psswp);
- case UTIME: diff = p2->utime - p1->utime; goto test_diff;
- case CUTIME: diff = p2->cutime - p1->cutime; goto test_diff;
- case STIME: diff = p2->stime - p1->stime; goto test_diff;
- case CSTIME: diff = p2->cstime - p1->cstime; goto test_diff;
- case STARTTIME: {
- if (p1->starttime == p2->starttime)
- return (p1->super.pid - p2->super.pid);
- else
- return (p1->starttime - p2->starttime);
- }
- #ifdef HAVE_TASKSTATS
- case RCHAR: diff = p2->io_rchar - p1->io_rchar; goto test_diff;
- case WCHAR: diff = p2->io_wchar - p1->io_wchar; goto test_diff;
- case SYSCR: diff = p2->io_syscr - p1->io_syscr; goto test_diff;
- case SYSCW: diff = p2->io_syscw - p1->io_syscw; goto test_diff;
- case RBYTES: diff = p2->io_read_bytes - p1->io_read_bytes; goto test_diff;
- case WBYTES: diff = p2->io_write_bytes - p1->io_write_bytes; goto test_diff;
- case CNCLWB: diff = p2->io_cancelled_write_bytes - p1->io_cancelled_write_bytes; goto test_diff;
- case IO_READ_RATE: diff = p2->io_rate_read_bps - p1->io_rate_read_bps; goto test_diff;
- case IO_WRITE_RATE: diff = p2->io_rate_write_bps - p1->io_rate_write_bps; goto test_diff;
- case IO_RATE: diff = (p2->io_rate_read_bps + p2->io_rate_write_bps) - (p1->io_rate_read_bps + p1->io_rate_write_bps); goto test_diff;
- #endif
+ return SPACESHIP_NUMBER(p2->m_psswp, p1->m_psswp);
+ case UTIME:
+ return SPACESHIP_NUMBER(p2->utime, p1->utime);
+ case CUTIME:
+ return SPACESHIP_NUMBER(p2->cutime, p1->cutime);
+ case STIME:
+ return SPACESHIP_NUMBER(p2->stime, p1->stime);
+ case CSTIME:
+ return SPACESHIP_NUMBER(p2->cstime, p1->cstime);
+ case RCHAR:
+ return SPACESHIP_NUMBER(p2->io_rchar, p1->io_rchar);
+ case WCHAR:
+ return SPACESHIP_NUMBER(p2->io_wchar, p1->io_wchar);
+ case SYSCR:
+ return SPACESHIP_NUMBER(p2->io_syscr, p1->io_syscr);
+ case SYSCW:
+ return SPACESHIP_NUMBER(p2->io_syscw, p1->io_syscw);
+ case RBYTES:
+ return SPACESHIP_NUMBER(p2->io_read_bytes, p1->io_read_bytes);
+ case WBYTES:
+ return SPACESHIP_NUMBER(p2->io_write_bytes, p1->io_write_bytes);
+ case CNCLWB:
+ return SPACESHIP_NUMBER(p2->io_cancelled_write_bytes, p1->io_cancelled_write_bytes);
+ case IO_READ_RATE:
+ return SPACESHIP_NUMBER(p2->io_rate_read_bps, p1->io_rate_read_bps);
+ case IO_WRITE_RATE:
+ return SPACESHIP_NUMBER(p2->io_rate_write_bps, p1->io_rate_write_bps);
+ case IO_RATE:
+ return SPACESHIP_NUMBER(p2->io_rate_read_bps + p2->io_rate_write_bps, p1->io_rate_read_bps + p1->io_rate_write_bps);
#ifdef HAVE_OPENVZ
case CTID:
- return (p2->ctid - p1->ctid);
+ return SPACESHIP_NULLSTR(p1->ctid, p2->ctid);
case VPID:
- return (p2->vpid - p1->vpid);
+ return SPACESHIP_NUMBER(p2->vpid, p1->vpid);
#endif
#ifdef HAVE_VSERVER
case VXID:
- return (p2->vxid - p1->vxid);
+ return SPACESHIP_NUMBER(p2->vxid, p1->vxid);
#endif
- #ifdef HAVE_CGROUP
case CGROUP:
- return strcmp(p1->cgroup ? p1->cgroup : "", p2->cgroup ? p2->cgroup : "");
- #endif
+ return SPACESHIP_NULLSTR(p1->cgroup, p2->cgroup);
case OOM:
- return ((int)p2->oom - (int)p1->oom);
+ return SPACESHIP_NUMBER(p2->oom, p1->oom);
#ifdef HAVE_DELAYACCT
case PERCENT_CPU_DELAY:
- return (p2->cpu_delay_percent > p1->cpu_delay_percent ? 1 : -1);
+ return SPACESHIP_NUMBER(p2->cpu_delay_percent, p1->cpu_delay_percent);
case PERCENT_IO_DELAY:
- return (p2->blkio_delay_percent > p1->blkio_delay_percent ? 1 : -1);
+ return SPACESHIP_NUMBER(p2->blkio_delay_percent, p1->blkio_delay_percent);
case PERCENT_SWAP_DELAY:
- return (p2->swapin_delay_percent > p1->swapin_delay_percent ? 1 : -1);
+ return SPACESHIP_NUMBER(p2->swapin_delay_percent, p1->swapin_delay_percent);
#endif
case IO_PRIORITY:
- return LinuxProcess_effectiveIOPriority(p1) - LinuxProcess_effectiveIOPriority(p2);
+ return SPACESHIP_NUMBER(LinuxProcess_effectiveIOPriority(p1), LinuxProcess_effectiveIOPriority(p2));
+ case CTXT:
+ return SPACESHIP_NUMBER(p2->ctxt_diff, p1->ctxt_diff);
+ case SECATTR:
+ return SPACESHIP_NULLSTR(p1->secattr, p2->secattr);
+ case PROC_COMM: {
+ const char *comm1 = p1->procComm ? p1->procComm : (Process_isKernelThread(p1) ? kthreadID : "");
+ const char *comm2 = p2->procComm ? p2->procComm : (Process_isKernelThread(p2) ? kthreadID : "");
+ return strcmp(comm1, comm2);
+ }
+ case PROC_EXE: {
+ const char *exe1 = p1->procExe ? (p1->procExe + p1->procExeBasenameOffset) : (Process_isKernelThread(p1) ? kthreadID : "");
+ const char *exe2 = p2->procExe ? (p2->procExe + p2->procExeBasenameOffset) : (Process_isKernelThread(p2) ? kthreadID : "");
+ return strcmp(exe1, exe2);
+ }
+ case CWD:
+ return SPACESHIP_NULLSTR(p1->cwd, p2->cwd);
default:
return Process_compare(v1, v2);
}
- test_diff:
- return (diff > 0) ? 1 : (diff < 0 ? -1 : 0);
}
-bool Process_isThread(Process* this) {
+bool Process_isThread(const Process* this) {
return (Process_isUserlandThread(this) || Process_isKernelThread(this));
}
+
+const ProcessClass LinuxProcess_class = {
+ .super = {
+ .extends = Class(Process),
+ .display = Process_display,
+ .delete = Process_delete,
+ .compare = LinuxProcess_compare
+ },
+ .writeField = LinuxProcess_writeField,
+ .getCommandStr = LinuxProcess_getCommandStr
+};

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