1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
|
// SPDX-License-Identifier: GPL-3.0-or-later
#include "plugin_macos.h"
static struct macos_module {
const char *name;
const char *dim;
int enabled;
int (*func)(int update_every, usec_t dt);
RRDDIM *rd;
} macos_modules[] = {
{.name = "sysctl", .dim = "sysctl", .enabled = 1, .func = do_macos_sysctl},
{.name = "mach system management interface", .dim = "mach_smi", .enabled = 1, .func = do_macos_mach_smi},
{.name = "iokit", .dim = "iokit", .enabled = 1, .func = do_macos_iokit},
// the terminator of this array
{.name = NULL, .dim = NULL, .enabled = 0, .func = NULL}
};
#if WORKER_UTILIZATION_MAX_JOB_TYPES < 3
#error WORKER_UTILIZATION_MAX_JOB_TYPES has to be at least 3
#endif
static void macos_main_cleanup(void *pptr)
{
struct netdata_static_thread *static_thread = CLEANUP_FUNCTION_GET_PTR(pptr);
if(!static_thread) return;
static_thread->enabled = NETDATA_MAIN_THREAD_EXITING;
collector_info("cleaning up...");
worker_unregister();
static_thread->enabled = NETDATA_MAIN_THREAD_EXITED;
}
void *macos_main(void *ptr)
{
CLEANUP_FUNCTION_REGISTER(macos_main_cleanup) cleanup_ptr = ptr;
worker_register("MACOS");
// check the enabled status for each module
for (int i = 0; macos_modules[i].name; i++) {
struct macos_module *pm = &macos_modules[i];
pm->enabled = config_get_boolean("plugin:macos", pm->name, pm->enabled);
pm->rd = NULL;
worker_register_job_name(i, macos_modules[i].dim);
}
heartbeat_t hb;
heartbeat_init(&hb, localhost->rrd_update_every * USEC_PER_SEC);
while(service_running(SERVICE_COLLECTORS)) {
worker_is_idle();
usec_t hb_dt = heartbeat_next(&hb);
if (!service_running(SERVICE_COLLECTORS))
break;
for (int i = 0; macos_modules[i].name; i++) {
struct macos_module *pm = &macos_modules[i];
if (unlikely(!pm->enabled))
continue;
netdata_log_debug(D_PROCNETDEV_LOOP, "macos calling %s.", pm->name);
worker_is_busy(i);
pm->enabled = !pm->func(localhost->rrd_update_every, hb_dt);
if (!service_running(SERVICE_COLLECTORS))
break;
}
}
return NULL;
}
|
