1 files changed, 115 insertions, 0 deletions
diff --git a/src/collectors/common-contexts/system-processes.h b/src/collectors/common-contexts/system-processes.h
new file mode 100644
index 000000000..1b886d65f
--- /dev/null
+++ b/src/collectors/common-contexts/system-processes.h
@@ -0,0 +1,115 @@
+// SPDX-License-Identifier: GPL-3.0-or-later
+
+#ifndef NETDATA_SYSTEM_PROCESSES_H
+#define NETDATA_SYSTEM_PROCESSES_H
+
+#include "common-contexts.h"
+
+#define _system_process_chart() \
+    rrdset_create_localhost( \
+        "system" \
+        , "processes" \
+        , NULL  \
+        , "processes" \
+        , NULL \
+        , "System Processes" \
+        , "processes" \
+        , _COMMON_PLUGIN_NAME \
+        , _COMMON_PLUGIN_MODULE_NAME \
+        , NETDATA_CHART_PRIO_SYSTEM_PROCESSES \
+        , update_every \
+        , RRDSET_TYPE_LINE \
+        )
+
+#if defined(OS_WINDOWS)
+static inline void common_system_processes(uint64_t running, int update_every) {
+    static RRDSET *st_processes = NULL;
+    static RRDDIM *rd_running = NULL;
+
+    if(unlikely(!st_processes)) {
+        st_processes = _system_process_chart();
+
+        rd_running = rrddim_add(st_processes, "running", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
+    }
+
+    rrddim_set_by_pointer(st_processes, rd_running, running);
+    rrdset_done(st_processes);
+}
+
+// EBPF COUNTER PART
+static inline void common_system_threads(uint64_t threads, int update_every) {
+    static RRDSET *st_threads = NULL;
+    static RRDDIM *rd_threads = NULL;
+
+    if(unlikely(!st_threads)) {
+        st_threads = rrdset_create_localhost(
+            "system"
+            , "threads"
+            , NULL
+            , "processes"
+            , NULL
+            , "Threads"
+            , "threads"
+            , _COMMON_PLUGIN_NAME
+            , _COMMON_PLUGIN_MODULE_NAME
+            , NETDATA_CHART_PRIO_WINDOWS_THREADS
+            , update_every
+            , RRDSET_TYPE_LINE
+            );
+
+        rd_threads = rrddim_add(st_threads, "threads", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
+    }
+
+    rrddim_set_by_pointer(st_threads, rd_threads, threads);
+    rrdset_done(st_threads);
+}
+#endif
+
+#if defined(OS_LINUX)
+static inline void common_system_processes(uint64_t running, uint64_t blocked, int update_every) {
+    static RRDSET *st_processes = NULL;
+    static RRDDIM *rd_running = NULL;
+    static RRDDIM *rd_blocked = NULL;
+
+    if(unlikely(!st_processes)) {
+        st_processes = _system_process_chart();
+
+        rd_running = rrddim_add(st_processes, "running", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
+        rd_blocked = rrddim_add(st_processes, "blocked", NULL, -1, 1, RRD_ALGORITHM_ABSOLUTE);
+    }
+
+    rrddim_set_by_pointer(st_processes, rd_running, (collected_number)running);
+    rrddim_set_by_pointer(st_processes, rd_blocked, (collected_number)blocked);
+    rrdset_done(st_processes);
+}
+#endif
+
+static inline void common_system_context_switch(uint64_t value, int update_every) {
+    static RRDSET *st_ctxt = NULL;
+    static RRDDIM *rd_switches = NULL;
+
+    if(unlikely(!st_ctxt)) {
+        st_ctxt = rrdset_create_localhost(
+         "system"
+        , "ctxt"
+        , NULL
+        , "processes"
+        , NULL
+        , "CPU Context Switches"
+        , "context switches/s"
+        , _COMMON_PLUGIN_NAME
+        , _COMMON_PLUGIN_MODULE_NAME
+        , NETDATA_CHART_PRIO_SYSTEM_CTXT
+        , update_every
+        , RRDSET_TYPE_LINE
+        );
+
+        rd_switches = rrddim_add(st_ctxt, "switches", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
+    }
+
+    rrddim_set_by_pointer(st_ctxt, rd_switches,  (collected_number)value);
+    rrdset_done(st_ctxt);
+}
+
+
+#endif //NETDATA_SYSTEM_PROCESSES_H