2015-07-12 18:47:43 +00:00
|
|
|
/*
|
|
|
|
htop - DarwinProcessList.c
|
|
|
|
(C) 2014 Hisham H. Muhammad
|
2021-09-22 09:33:00 +00:00
|
|
|
Released under the GNU GPLv2+, see the COPYING file
|
2015-07-12 18:47:43 +00:00
|
|
|
in the source distribution for its full text.
|
|
|
|
*/
|
|
|
|
|
2021-04-29 18:13:36 +00:00
|
|
|
#include "darwin/DarwinProcessList.h"
|
2015-07-12 18:47:43 +00:00
|
|
|
|
2020-11-17 14:17:19 +00:00
|
|
|
#include <errno.h>
|
2020-11-17 14:10:44 +00:00
|
|
|
#include <libproc.h>
|
|
|
|
#include <stdbool.h>
|
|
|
|
#include <stdio.h>
|
2015-07-12 18:47:43 +00:00
|
|
|
#include <stdlib.h>
|
|
|
|
#include <string.h>
|
2015-07-13 06:17:14 +00:00
|
|
|
#include <unistd.h>
|
2015-07-14 02:02:40 +00:00
|
|
|
#include <utmpx.h>
|
2020-11-17 14:10:44 +00:00
|
|
|
#include <sys/mman.h>
|
2018-03-25 20:04:16 +00:00
|
|
|
#include <sys/sysctl.h>
|
2020-11-17 14:10:44 +00:00
|
|
|
|
|
|
|
#include "CRT.h"
|
|
|
|
#include "ProcessList.h"
|
2021-04-29 18:13:36 +00:00
|
|
|
#include "darwin/DarwinProcess.h"
|
|
|
|
#include "darwin/Platform.h"
|
2021-03-03 22:00:34 +00:00
|
|
|
#include "generic/openzfs_sysctl.h"
|
2020-11-17 14:10:44 +00:00
|
|
|
#include "zfs/ZfsArcStats.h"
|
|
|
|
|
2018-03-25 20:04:16 +00:00
|
|
|
|
|
|
|
struct kern {
|
2020-10-31 21:14:27 +00:00
|
|
|
short int version[3];
|
2018-03-25 20:04:16 +00:00
|
|
|
};
|
|
|
|
|
2020-11-17 14:10:44 +00:00
|
|
|
static void GetKernelVersion(struct kern* k) {
|
2018-03-25 20:04:16 +00:00
|
|
|
static short int version_[3] = {0};
|
|
|
|
if (!version_[0]) {
|
|
|
|
// just in case it fails someday
|
|
|
|
version_[0] = version_[1] = version_[2] = -1;
|
|
|
|
char str[256] = {0};
|
|
|
|
size_t size = sizeof(str);
|
|
|
|
int ret = sysctlbyname("kern.osrelease", str, &size, NULL, 0);
|
2020-10-31 21:14:27 +00:00
|
|
|
if (ret == 0) {
|
|
|
|
sscanf(str, "%hd.%hd.%hd", &version_[0], &version_[1], &version_[2]);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
memcpy(k->version, version_, sizeof(version_));
|
2018-03-25 20:04:16 +00:00
|
|
|
}
|
|
|
|
|
2018-04-05 22:41:22 +00:00
|
|
|
/* compare the given os version with the one installed returns:
|
|
|
|
0 if equals the installed version
|
|
|
|
positive value if less than the installed version
|
|
|
|
negative value if more than the installed version
|
|
|
|
*/
|
2020-11-17 14:10:44 +00:00
|
|
|
static int CompareKernelVersion(short int major, short int minor, short int component) {
|
2020-10-31 21:14:27 +00:00
|
|
|
struct kern k;
|
|
|
|
GetKernelVersion(&k);
|
|
|
|
|
|
|
|
if (k.version[0] != major) {
|
|
|
|
return k.version[0] - major;
|
|
|
|
}
|
|
|
|
if (k.version[1] != minor) {
|
|
|
|
return k.version[1] - minor;
|
|
|
|
}
|
|
|
|
if (k.version[2] != component) {
|
|
|
|
return k.version[2] - component;
|
|
|
|
}
|
|
|
|
|
|
|
|
return 0;
|
2018-03-25 20:04:16 +00:00
|
|
|
}
|
2015-07-12 18:47:43 +00:00
|
|
|
|
2020-11-17 14:10:44 +00:00
|
|
|
static void ProcessList_getHostInfo(host_basic_info_data_t* p) {
|
2015-07-13 06:17:14 +00:00
|
|
|
mach_msg_type_number_t info_size = HOST_BASIC_INFO_COUNT;
|
|
|
|
|
2020-10-31 19:52:20 +00:00
|
|
|
if (0 != host_info(mach_host_self(), HOST_BASIC_INFO, (host_info_t)p, &info_size)) {
|
2020-12-19 20:25:18 +00:00
|
|
|
CRT_fatalError("Unable to retrieve host info");
|
2015-07-13 06:17:14 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-11-17 14:10:44 +00:00
|
|
|
static void ProcessList_freeCPULoadInfo(processor_cpu_load_info_t* p) {
|
2020-10-31 19:52:20 +00:00
|
|
|
if (NULL != p && NULL != *p) {
|
2020-10-31 21:14:27 +00:00
|
|
|
if (0 != munmap(*p, vm_page_size)) {
|
2020-12-19 20:25:18 +00:00
|
|
|
CRT_fatalError("Unable to free old CPU load information");
|
2020-10-31 21:14:27 +00:00
|
|
|
}
|
|
|
|
*p = NULL;
|
2015-07-13 21:53:46 +00:00
|
|
|
}
|
2015-07-13 22:09:18 +00:00
|
|
|
}
|
|
|
|
|
2020-11-17 14:10:44 +00:00
|
|
|
static unsigned ProcessList_allocateCPULoadInfo(processor_cpu_load_info_t* p) {
|
2015-07-13 22:09:18 +00:00
|
|
|
mach_msg_type_number_t info_size = sizeof(processor_cpu_load_info_t);
|
|
|
|
unsigned cpu_count;
|
|
|
|
|
2015-07-14 16:46:16 +00:00
|
|
|
// TODO Improving the accuracy of the load counts woule help a lot.
|
2020-10-31 21:14:27 +00:00
|
|
|
if (0 != host_processor_info(mach_host_self(), PROCESSOR_CPU_LOAD_INFO, &cpu_count, (processor_info_array_t*)p, &info_size)) {
|
2020-12-19 20:25:18 +00:00
|
|
|
CRT_fatalError("Unable to retrieve CPU info");
|
2015-07-13 06:17:14 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
return cpu_count;
|
|
|
|
}
|
|
|
|
|
2020-11-17 14:10:44 +00:00
|
|
|
static void ProcessList_getVMStats(vm_statistics_t p) {
|
2020-10-31 21:14:27 +00:00
|
|
|
mach_msg_type_number_t info_size = HOST_VM_INFO_COUNT;
|
2015-07-14 02:02:40 +00:00
|
|
|
|
2020-10-31 21:14:27 +00:00
|
|
|
if (host_statistics(mach_host_self(), HOST_VM_INFO, (host_info_t)p, &info_size) != 0) {
|
2020-12-19 20:25:18 +00:00
|
|
|
CRT_fatalError("Unable to retrieve VM statistics");
|
2020-10-31 21:14:27 +00:00
|
|
|
}
|
2015-07-14 02:02:40 +00:00
|
|
|
}
|
|
|
|
|
2020-11-17 14:10:44 +00:00
|
|
|
static struct kinfo_proc* ProcessList_getKInfoProcs(size_t* count) {
|
2015-07-13 06:17:14 +00:00
|
|
|
int mib[4] = { CTL_KERN, KERN_PROC, KERN_PROC_ALL, 0 };
|
2020-10-31 22:28:02 +00:00
|
|
|
struct kinfo_proc* processes = NULL;
|
2015-07-13 06:17:14 +00:00
|
|
|
|
2020-11-17 14:17:19 +00:00
|
|
|
for (int retry = 3; retry > 0; retry--) {
|
|
|
|
size_t size = 0;
|
|
|
|
if (sysctl(mib, 4, NULL, &size, NULL, 0) < 0 || size == 0) {
|
|
|
|
CRT_fatalError("Unable to get size of kproc_infos");
|
|
|
|
}
|
2015-07-13 06:17:14 +00:00
|
|
|
|
2020-11-17 14:17:19 +00:00
|
|
|
processes = xRealloc(processes, size);
|
2015-07-13 06:17:14 +00:00
|
|
|
|
2020-11-17 14:17:19 +00:00
|
|
|
if (sysctl(mib, 4, processes, &size, NULL, 0) == 0) {
|
|
|
|
*count = size / sizeof(struct kinfo_proc);
|
|
|
|
return processes;
|
|
|
|
}
|
2015-07-13 06:17:14 +00:00
|
|
|
|
2020-11-17 14:17:19 +00:00
|
|
|
if (errno != ENOMEM)
|
|
|
|
break;
|
|
|
|
}
|
2015-07-13 06:17:14 +00:00
|
|
|
|
2020-11-17 14:17:19 +00:00
|
|
|
CRT_fatalError("Unable to get kinfo_procs");
|
2015-07-13 06:17:14 +00:00
|
|
|
}
|
|
|
|
|
PCP: support for 'dynamic columns' added at runtime
Implements support for arbitrary Performance Co-Pilot
metrics with per-process instance domains to form new
htop columns. The column-to-metric mappings are setup
using configuration files which will be documented via
man pages as part of a follow-up commit.
We provide an initial set of column configurations so
as to provide new capabilities to pcp-htop: including
configs for containers, open fd counts, scheduler run
queue time, tcp/udp bytes/calls sent/recv, delay acct,
virtual machine guests, detailed virtual memory, swap.
Note there is a change to the configuration file path
resolution algorithm introduced for 'dynamic meters'.
First, look in any custom PCP_HTOP_DIR location. Then
iterate, in priority order, users home directory, then
local sysadmins files in /etc/pcp/htop, then readonly
configuration files below /usr/share/pcp/htop. This
final location becomes the preferred place for our own
shipped meter and column files.
The Settings file (htoprc) writing code is updated to
not using the numeric identifier for dynamic columns.
The same strategy used for dynamic meters is used here
where we write Dynamic(name) so the name can be setup
once more at start. Regular (static) columns writing
to htoprc - i.e. numerically indexed - is unchanged.
2021-07-11 01:11:29 +00:00
|
|
|
ProcessList* ProcessList_new(UsersTable* usersTable, Hashtable* dynamicMeters, Hashtable* dynamicColumns, Hashtable* pidMatchList, uid_t userId) {
|
2016-02-02 14:53:02 +00:00
|
|
|
DarwinProcessList* this = xCalloc(1, sizeof(DarwinProcessList));
|
2015-07-13 06:17:14 +00:00
|
|
|
|
PCP: support for 'dynamic columns' added at runtime
Implements support for arbitrary Performance Co-Pilot
metrics with per-process instance domains to form new
htop columns. The column-to-metric mappings are setup
using configuration files which will be documented via
man pages as part of a follow-up commit.
We provide an initial set of column configurations so
as to provide new capabilities to pcp-htop: including
configs for containers, open fd counts, scheduler run
queue time, tcp/udp bytes/calls sent/recv, delay acct,
virtual machine guests, detailed virtual memory, swap.
Note there is a change to the configuration file path
resolution algorithm introduced for 'dynamic meters'.
First, look in any custom PCP_HTOP_DIR location. Then
iterate, in priority order, users home directory, then
local sysadmins files in /etc/pcp/htop, then readonly
configuration files below /usr/share/pcp/htop. This
final location becomes the preferred place for our own
shipped meter and column files.
The Settings file (htoprc) writing code is updated to
not using the numeric identifier for dynamic columns.
The same strategy used for dynamic meters is used here
where we write Dynamic(name) so the name can be setup
once more at start. Regular (static) columns writing
to htoprc - i.e. numerically indexed - is unchanged.
2021-07-11 01:11:29 +00:00
|
|
|
ProcessList_init(&this->super, Class(DarwinProcess), usersTable, dynamicMeters, dynamicColumns, pidMatchList, userId);
|
2015-07-14 02:02:40 +00:00
|
|
|
|
|
|
|
/* Initialize the CPU information */
|
2021-06-12 16:17:28 +00:00
|
|
|
this->super.activeCPUs = ProcessList_allocateCPULoadInfo(&this->prev_load);
|
|
|
|
// TODO: support offline CPUs and hot swapping
|
|
|
|
this->super.existingCPUs = this->super.activeCPUs;
|
2015-07-13 21:53:46 +00:00
|
|
|
ProcessList_getHostInfo(&this->host_info);
|
2015-07-13 22:09:18 +00:00
|
|
|
ProcessList_allocateCPULoadInfo(&this->curr_load);
|
2015-07-13 06:17:14 +00:00
|
|
|
|
2015-07-14 02:02:40 +00:00
|
|
|
/* Initialize the VM statistics */
|
|
|
|
ProcessList_getVMStats(&this->vm_stats);
|
|
|
|
|
2019-07-07 21:30:37 +00:00
|
|
|
/* Initialize the ZFS kstats, if zfs.kext loaded */
|
2019-09-03 18:21:33 +00:00
|
|
|
openzfs_sysctl_init(&this->zfs);
|
2019-07-07 23:27:00 +00:00
|
|
|
openzfs_sysctl_updateArcStats(&this->zfs);
|
2019-07-07 21:30:37 +00:00
|
|
|
|
2015-07-14 02:02:40 +00:00
|
|
|
this->super.kernelThreads = 0;
|
|
|
|
this->super.userlandThreads = 0;
|
|
|
|
this->super.totalTasks = 0;
|
|
|
|
this->super.runningTasks = 0;
|
|
|
|
|
2015-07-13 06:17:14 +00:00
|
|
|
return &this->super;
|
2015-07-12 18:47:43 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
void ProcessList_delete(ProcessList* this) {
|
|
|
|
ProcessList_done(this);
|
|
|
|
free(this);
|
|
|
|
}
|
|
|
|
|
2020-10-13 14:03:37 +00:00
|
|
|
void ProcessList_goThroughEntries(ProcessList* super, bool pauseProcessUpdate) {
|
2020-10-31 21:14:27 +00:00
|
|
|
DarwinProcessList* dpl = (DarwinProcessList*)super;
|
|
|
|
bool preExisting = true;
|
|
|
|
struct kinfo_proc* ps;
|
|
|
|
size_t count;
|
|
|
|
DarwinProcess* proc;
|
|
|
|
|
|
|
|
/* Update the global data (CPU times and VM stats) */
|
|
|
|
ProcessList_freeCPULoadInfo(&dpl->prev_load);
|
|
|
|
dpl->prev_load = dpl->curr_load;
|
|
|
|
ProcessList_allocateCPULoadInfo(&dpl->curr_load);
|
|
|
|
ProcessList_getVMStats(&dpl->vm_stats);
|
|
|
|
openzfs_sysctl_updateArcStats(&dpl->zfs);
|
|
|
|
|
|
|
|
// in pause mode only gather global data for meters (CPU/memory/...)
|
|
|
|
if (pauseProcessUpdate) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Get the time difference */
|
|
|
|
dpl->global_diff = 0;
|
2021-06-12 16:17:28 +00:00
|
|
|
for (unsigned int i = 0; i < dpl->super.existingCPUs; ++i) {
|
2020-10-31 21:14:27 +00:00
|
|
|
for (size_t j = 0; j < CPU_STATE_MAX; ++j) {
|
|
|
|
dpl->global_diff += dpl->curr_load[i].cpu_ticks[j] - dpl->prev_load[i].cpu_ticks[j];
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2021-08-22 14:47:11 +00:00
|
|
|
const double time_interval_ns = Platform_schedulerTicksToNanoseconds(dpl->global_diff) / (double) dpl->super.activeCPUs;
|
2020-12-09 04:12:44 +00:00
|
|
|
|
2020-10-31 21:14:27 +00:00
|
|
|
/* Clear the thread counts */
|
|
|
|
super->kernelThreads = 0;
|
|
|
|
super->userlandThreads = 0;
|
|
|
|
super->totalTasks = 0;
|
|
|
|
super->runningTasks = 0;
|
|
|
|
|
|
|
|
/* We use kinfo_procs for initial data since :
|
|
|
|
*
|
|
|
|
* 1) They always succeed.
|
|
|
|
* 2) The contain the basic information.
|
|
|
|
*
|
|
|
|
* We attempt to fill-in additional information with libproc.
|
|
|
|
*/
|
|
|
|
ps = ProcessList_getKInfoProcs(&count);
|
|
|
|
|
|
|
|
for (size_t i = 0; i < count; ++i) {
|
|
|
|
proc = (DarwinProcess*)ProcessList_getProcess(super, ps[i].kp_proc.p_pid, &preExisting, DarwinProcess_new);
|
|
|
|
|
|
|
|
DarwinProcess_setFromKInfoProc(&proc->super, &ps[i], preExisting);
|
2021-08-20 21:52:07 +00:00
|
|
|
DarwinProcess_setFromLibprocPidinfo(proc, dpl, time_interval_ns);
|
2020-10-31 21:14:27 +00:00
|
|
|
|
2021-06-18 18:42:04 +00:00
|
|
|
if (proc->super.st_uid != ps[i].kp_eproc.e_ucred.cr_uid) {
|
|
|
|
proc->super.st_uid = ps[i].kp_eproc.e_ucred.cr_uid;
|
|
|
|
proc->super.user = UsersTable_getRef(super->usersTable, proc->super.st_uid);
|
|
|
|
}
|
|
|
|
|
2020-10-31 21:14:27 +00:00
|
|
|
// Disabled for High Sierra due to bug in macOS High Sierra
|
|
|
|
bool isScanThreadSupported = ! ( CompareKernelVersion(17, 0, 0) >= 0 && CompareKernelVersion(17, 5, 0) < 0);
|
|
|
|
|
|
|
|
if (isScanThreadSupported) {
|
|
|
|
DarwinProcess_scanThreads(proc);
|
|
|
|
}
|
|
|
|
|
|
|
|
super->totalTasks += 1;
|
|
|
|
|
|
|
|
if (!preExisting) {
|
|
|
|
ProcessList_add(super, &proc->super);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
free(ps);
|
2015-07-12 18:47:43 +00:00
|
|
|
}
|
2021-06-12 20:04:37 +00:00
|
|
|
|
|
|
|
bool ProcessList_isCPUonline(const ProcessList* super, unsigned int id) {
|
|
|
|
assert(id < super->existingCPUs);
|
|
|
|
|
|
|
|
// TODO: support offline CPUs and hot swapping
|
|
|
|
(void) super; (void) id;
|
|
|
|
|
|
|
|
return true;
|
|
|
|
}
|