@cryptotaxi247 / netdata-1
Code Commits Issues Pulls Sessions CI/CD
master
master
c 136 lines 5.17 KB
Raw
1 // SPDX-License-Identifier: GPL-3.0-or-later
2
3 #include "plugin_proc.h"
4
5 #define PLUGIN_PROC_MODULE_LOADAVG_NAME "/proc/loadavg"
6 #define CONFIG_SECTION_PLUGIN_PROC_LOADAVG "plugin:" PLUGIN_PROC_CONFIG_NAME ":" PLUGIN_PROC_MODULE_LOADAVG_NAME
7
8 // linux calculates this once every 5 seconds
9 #define MIN_LOADAVG_UPDATE_EVERY 5
10
11 static const RRDVAR_ACQUIRED *rd_pidmax = NULL;
12
13 void proc_loadavg_plugin_cleanup(void) {
14 // Cleanup any acquired RRDVARs
15 RRDSET *st = rrdset_find(localhost, "system.active_processes", true);
16 if (st && rd_pidmax) {
17 rrdvar_chart_variable_release(st, rd_pidmax);
18 rd_pidmax = NULL;
19 }
20 }
21
22 int do_proc_loadavg(int update_every, usec_t dt) {
23 static procfile *ff = NULL;
24 static int do_loadavg = -1, do_all_processes = -1;
25 static usec_t next_loadavg_dt = 0;
26
27 if(unlikely(!ff)) {
28 char filename[FILENAME_MAX + 1];
29 snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, "/proc/loadavg");
30
31 ff = procfile_open(inicfg_get(&netdata_config, CONFIG_SECTION_PLUGIN_PROC_LOADAVG, "filename to monitor", filename), " \t,:|/", PROCFILE_FLAG_DEFAULT);
32 if(unlikely(!ff))
33 return 1;
34 }
35
36 ff = procfile_readall(ff);
37 if(unlikely(!ff))
38 return 0; // we return 0, so that we will retry to open it next time
39
40 if(unlikely(do_loadavg == -1)) {
41 do_loadavg = inicfg_get_boolean(&netdata_config, CONFIG_SECTION_PLUGIN_PROC_LOADAVG, "enable load average", 1);
42 do_all_processes = inicfg_get_boolean(&netdata_config, CONFIG_SECTION_PLUGIN_PROC_LOADAVG, "enable total processes", 1);
43 }
44
45 if(unlikely(procfile_lines(ff) < 1)) {
46 collector_error("/proc/loadavg has no lines.");
47 return 1;
48 }
49 if(unlikely(procfile_linewords(ff, 0) < 6)) {
50 collector_error("/proc/loadavg has less than 6 words in it.");
51 return 1;
52 }
53
54 double load1 = strtod(procfile_lineword(ff, 0, 0), NULL);
55 double load5 = strtod(procfile_lineword(ff, 0, 1), NULL);
56 double load15 = strtod(procfile_lineword(ff, 0, 2), NULL);
57
58 //unsigned long long running_processes = str2ull(procfile_lineword(ff, 0, 3));
59 unsigned long long active_processes = str2ull(procfile_lineword(ff, 0, 4), NULL);
60
61 //get system pid_max
62 unsigned long long max_processes = os_get_system_pid_max();
63 //
64 //unsigned long long next_pid = str2ull(procfile_lineword(ff, 0, 5));
65
66 if(next_loadavg_dt <= dt) {
67 if(likely(do_loadavg)) {
68 static RRDSET *load_chart = NULL;
69 static RRDDIM *rd_load1 = NULL, *rd_load5 = NULL, *rd_load15 = NULL;
70
71 if(unlikely(!load_chart)) {
72 load_chart = rrdset_create_localhost(
73 "system"
74 , "load"
75 , NULL
76 , "load"
77 , NULL
78 , "System Load Average"
79 , "load"
80 , PLUGIN_PROC_NAME
81 , PLUGIN_PROC_MODULE_LOADAVG_NAME
82 , NETDATA_CHART_PRIO_SYSTEM_LOAD
83 , (update_every < MIN_LOADAVG_UPDATE_EVERY) ? MIN_LOADAVG_UPDATE_EVERY : update_every
84 , RRDSET_TYPE_LINE
85 );
86
87 rd_load1 = rrddim_add(load_chart, "load1", NULL, 1, 1000, RRD_ALGORITHM_ABSOLUTE);
88 rd_load5 = rrddim_add(load_chart, "load5", NULL, 1, 1000, RRD_ALGORITHM_ABSOLUTE);
89 rd_load15 = rrddim_add(load_chart, "load15", NULL, 1, 1000, RRD_ALGORITHM_ABSOLUTE);
90 }
91
92 rrddim_set_by_pointer(load_chart, rd_load1, (collected_number) (load1 * 1000));
93 rrddim_set_by_pointer(load_chart, rd_load5, (collected_number) (load5 * 1000));
94 rrddim_set_by_pointer(load_chart, rd_load15, (collected_number) (load15 * 1000));
95 rrdset_done(load_chart);
96
97 next_loadavg_dt = load_chart->update_every * USEC_PER_SEC;
98 }
99 else
100 next_loadavg_dt = MIN_LOADAVG_UPDATE_EVERY * USEC_PER_SEC;
101 }
102 else
103 next_loadavg_dt -= dt;
104
105
106 if(likely(do_all_processes)) {
107 static RRDSET *processes_chart = NULL;
108 static RRDDIM *rd_active = NULL;
109
110 if(unlikely(!processes_chart)) {
111 processes_chart = rrdset_create_localhost(
112 "system"
113 , "active_processes"
114 , NULL
115 , "processes"
116 , NULL
117 , "System Active Processes"
118 , "processes"
119 , PLUGIN_PROC_NAME
120 , PLUGIN_PROC_MODULE_LOADAVG_NAME
121 , NETDATA_CHART_PRIO_SYSTEM_ACTIVE_PROCESSES
122 , update_every
123 , RRDSET_TYPE_LINE
124 );
125
126 rd_active = rrddim_add(processes_chart, "active", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
127 rd_pidmax = rrdvar_chart_variable_add_and_acquire(processes_chart, "pidmax");
128 }
129
130 rrddim_set_by_pointer(processes_chart, rd_active, active_processes);
131 rrdvar_chart_variable_set(processes_chart, rd_pidmax, max_processes);
132 rrdset_done(processes_chart);
133 }
134
135 return 0;
136 }