diff options
| author | infirit <[email protected]> | 2014-12-18 20:58:16 +0100 |
|---|---|---|
| committer | infirit <[email protected]> | 2014-12-18 21:04:53 +0100 |
| commit | 76eff089e1ba541cece59f6d2f5847f349448f89 (patch) | |
| tree | a45acda13ac9ff08b898a9f98638a1ee4edcaf45 /src/cgroups.cpp | |
| parent | 396b01dc3e3a704c0015874002b76a5ccda0678a (diff) | |
| download | mate-system-monitor-76eff089e1ba541cece59f6d2f5847f349448f89.tar.bz2 mate-system-monitor-76eff089e1ba541cece59f6d2f5847f349448f89.tar.xz | |
Add cgroup support in the process view
Add a new 'Control Group' column to the process view tab.
The format for the column is:
<path name> (controller name), <path name> (controller name)...
Processes that share the same path name across controllers
are colesced. For example if a process is in the /foo cgroup
for both the memory and cpu controllers, it would display as:
/foo (memory,cpu), ...
Taken from GSM commits:
2d33adcbc4347c112d57082956b4e199ff7132db Add cgroup support in the process view
645d38a218fedcbf9c7b674740bf213e02933820 Optimize cgroup updating
From: Jason Baron <[email protected]>
Diffstat (limited to 'src/cgroups.cpp')
| -rw-r--r-- | src/cgroups.cpp | 186 |
1 files changed, 186 insertions, 0 deletions
diff --git a/src/cgroups.cpp b/src/cgroups.cpp new file mode 100644 index 0000000..eafa1e3 --- /dev/null +++ b/src/cgroups.cpp @@ -0,0 +1,186 @@ +#include <config.h> + +#include <glib.h> +#include <glib/gi18n.h> + +#include "procman.h" +#include "util.h" + +gboolean +cgroups_enabled(void) +{ + static gboolean initialized = FALSE; + static gboolean has_cgroups; + + if (!initialized) { + initialized = TRUE; + has_cgroups = g_file_test("/proc/cgroups", G_FILE_TEST_EXISTS); + } + + return has_cgroups; +} + +void +append_cgroup_name(char *line, gchar **current_cgroup_name) +{ + gchar *controller, *path, *tmp, *path_plus_space; + int paren_offset, off, tmp_size; + + controller = g_strstr_len(line, -1, ":") + 1; + if (!controller) + return; + + path = g_strstr_len(controller, -1, ":") + 1; + if (!path) + return; + + *(path - 1) = '\0'; + g_strdelimit(controller, ",", '/'); + + if ((std::strcmp(path, "/") == 0) || (std::strncmp(controller, "name=", 5) == 0)) + return; + + if (*current_cgroup_name == NULL) { + *current_cgroup_name = g_strdup_printf("%s (%s)", path, controller); + return; + } + + /* add a space to the end of the path string */ + path_plus_space = g_strdup_printf("%s ", path); + + if ((tmp = g_strstr_len(*current_cgroup_name, -1, path_plus_space))) { + tmp_size = strlen(*current_cgroup_name) + strlen(controller) + 1; + paren_offset = g_strstr_len(tmp + strlen(path), -1, ")") - *current_cgroup_name; + *(*current_cgroup_name + paren_offset) = '\0'; + tmp = (gchar *)g_strnfill(tmp_size, '\0'); + off = g_strlcat(tmp, *current_cgroup_name, tmp_size); + *(tmp + off) = '/'; + off++; + off += g_strlcat(tmp + off, controller, tmp_size); + *(tmp + off) = ')'; + off++; + g_strlcat(tmp + off, *current_cgroup_name + paren_offset + 1, tmp_size); + } else + tmp = g_strdup_printf("%s, %s(%s)", *current_cgroup_name, path_plus_space, controller); + + g_free(path_plus_space); + g_free(*current_cgroup_name); + *current_cgroup_name = tmp; +} + +int +check_cgroup_changed(gchar *line, gchar *current_cgroup_set) +{ + /* check if line is contained in current_cgroup_set */ + gchar *controller, *path, *tmp, *found, *close_paren, *open_paren; + int ret = 0; + + controller = g_strstr_len(line, -1, ":") + 1; + if (!controller) + return 1; + + path = g_strstr_len(controller, -1, ":") + 1; + if (!path) + return 1; + + *(path - 1) = '\0'; + + if (std::strncmp(controller, "name=", 5) == 0) + goto out; + + /* if there are multiple controllers just report string has changed */ + if (g_strstr_len(controller, -1, ",")) { + ret = 1; + goto out; + } + + if (!current_cgroup_set) { + if (std::strcmp(path, "/") != 0) + ret = 1; + goto out; + } + + /* special case for root cgroup */ + tmp = current_cgroup_set; + if (std::strcmp(path, "/") == 0) { + while ((found = g_strstr_len(tmp, -1, controller))) { + close_paren = g_strstr_len(found, -1, ")"); + open_paren = g_strstr_len(found, -1, "("); + if (close_paren) { + if (!open_paren || (close_paren < open_paren)) { + ret = 1; + goto out; + } + } + tmp = found + strlen(controller); + } + goto out; + } + + tmp = current_cgroup_set; + while ((found = g_strstr_len(tmp, -1, path))) { + found = found + strlen(path); + close_paren = g_strstr_len(found, -1, ")"); + if (*found == ' ') { + if (g_strstr_len(found + 1, close_paren - found, controller)) + goto out; + } + tmp = close_paren + 1; + } + ret = 1; +out: + *(path - 1) = ':'; + return ret; +} + +void +get_process_cgroup_info(ProcInfo *info) +{ + gchar *path; + gchar *cgroup_name = NULL; + int cgroups_changed = 0; + gchar *text; + char **lines; + int i; + + if (!cgroups_enabled()) + return; + + /* read out of /proc/pid/cgroup */ + path = g_strdup_printf("/proc/%d/cgroup", info->pid); + if (!path) + return; + if(!g_file_get_contents(path, &text, NULL, NULL)) + goto out; + lines = g_strsplit(text, "\n", -1); + g_free(text); + if (!lines) + goto out; + + for (i = 0; lines[i] != NULL; i++) { + if (lines[i][0] == '\0') + continue; + if (check_cgroup_changed(lines[i], info->cgroup_name)) { + cgroups_changed = 1; + break; + } + } + + if (cgroups_changed) { + for (i = 0; lines[i] != NULL; i++) { + if (lines[i][0] == '\0') + continue; + append_cgroup_name(lines[i], &cgroup_name); + } + if (info->cgroup_name) + g_free(info->cgroup_name); + if (!cgroup_name) + info->cgroup_name = g_strdup(""); + else + info->cgroup_name = cgroup_name; + } + + g_strfreev(lines); +out: + g_free(path); +} |