summaryrefslogtreecommitdiffstats
path: root/collectors/diskspace.plugin
diff options
context:
space:
mode:
Diffstat (limited to 'collectors/diskspace.plugin')
-rw-r--r--collectors/diskspace.plugin/Makefile.am8
l---------collectors/diskspace.plugin/README.md1
-rw-r--r--collectors/diskspace.plugin/integrations/disk_space.md140
-rw-r--r--collectors/diskspace.plugin/metadata.yaml139
-rw-r--r--collectors/diskspace.plugin/plugin_diskspace.c945
5 files changed, 0 insertions, 1233 deletions
diff --git a/collectors/diskspace.plugin/Makefile.am b/collectors/diskspace.plugin/Makefile.am
deleted file mode 100644
index 161784b8f..000000000
--- a/collectors/diskspace.plugin/Makefile.am
+++ /dev/null
@@ -1,8 +0,0 @@
-# SPDX-License-Identifier: GPL-3.0-or-later
-
-AUTOMAKE_OPTIONS = subdir-objects
-MAINTAINERCLEANFILES = $(srcdir)/Makefile.in
-
-dist_noinst_DATA = \
- README.md \
- $(NULL)
diff --git a/collectors/diskspace.plugin/README.md b/collectors/diskspace.plugin/README.md
deleted file mode 120000
index c9f4e1c5e..000000000
--- a/collectors/diskspace.plugin/README.md
+++ /dev/null
@@ -1 +0,0 @@
-integrations/disk_space.md \ No newline at end of file
diff --git a/collectors/diskspace.plugin/integrations/disk_space.md b/collectors/diskspace.plugin/integrations/disk_space.md
deleted file mode 100644
index 1c937ed7f..000000000
--- a/collectors/diskspace.plugin/integrations/disk_space.md
+++ /dev/null
@@ -1,140 +0,0 @@
-<!--startmeta
-custom_edit_url: "https://github.com/netdata/netdata/edit/master/collectors/diskspace.plugin/README.md"
-meta_yaml: "https://github.com/netdata/netdata/edit/master/collectors/diskspace.plugin/metadata.yaml"
-sidebar_label: "Disk space"
-learn_status: "Published"
-learn_rel_path: "Data Collection/Linux Systems"
-most_popular: False
-message: "DO NOT EDIT THIS FILE DIRECTLY, IT IS GENERATED BY THE COLLECTOR'S metadata.yaml FILE"
-endmeta-->
-
-# Disk space
-
-
-<img src="https://netdata.cloud/img/hard-drive.svg" width="150"/>
-
-
-Plugin: diskspace.plugin
-Module: diskspace.plugin
-
-<img src="https://img.shields.io/badge/maintained%20by-Netdata-%2300ab44" />
-
-## Overview
-
-Monitor Disk space metrics for proficient storage management. Keep track of usage, free space, and error rates to prevent disk space issues.
-
-
-
-This collector is supported on all platforms.
-
-This collector supports collecting metrics from multiple instances of this integration, including remote instances.
-
-
-### Default Behavior
-
-#### Auto-Detection
-
-The plugin reads data from `/proc/self/mountinfo` and `/proc/diskstats file`.
-
-#### Limits
-
-The default configuration for this integration does not impose any limits on data collection.
-
-#### Performance Impact
-
-The default configuration for this integration is not expected to impose a significant performance impact on the system.
-
-
-## Metrics
-
-Metrics grouped by *scope*.
-
-The scope defines the instance that the metric belongs to. An instance is uniquely identified by a set of labels.
-
-
-
-### Per mount point
-
-
-
-Labels:
-
-| Label | Description |
-|:-----------|:----------------|
-| mount_point | Path used to mount a filesystem |
-| filesystem | The filesystem used to format a partition. |
-| mount_root | Root directory where mount points are present. |
-
-Metrics:
-
-| Metric | Dimensions | Unit |
-|:------|:----------|:----|
-| disk.space | avail, used, reserved_for_root | GiB |
-| disk.inodes | avail, used, reserved_for_root | inodes |
-
-
-
-## Alerts
-
-
-The following alerts are available:
-
-| Alert name | On metric | Description |
-|:------------|:----------|:------------|
-| [ disk_space_usage ](https://github.com/netdata/netdata/blob/master/health/health.d/disks.conf) | disk.space | disk ${label:mount_point} space utilization |
-| [ disk_inode_usage ](https://github.com/netdata/netdata/blob/master/health/health.d/disks.conf) | disk.inodes | disk ${label:mount_point} inode utilization |
-
-
-## Setup
-
-### Prerequisites
-
-No action required.
-
-### Configuration
-
-#### File
-
-The configuration file name for this integration is `netdata.conf`.
-Configuration for this specific integration is located in the `[plugin:proc:diskspace]` section within that file.
-
-The file format is a modified INI syntax. The general structure is:
-
-```ini
-[section1]
- option1 = some value
- option2 = some other value
-
-[section2]
- option3 = some third value
-```
-You can edit the configuration file using the `edit-config` script from the
-Netdata [config directory](https://github.com/netdata/netdata/blob/master/docs/configure/nodes.md#the-netdata-config-directory).
-
-```bash
-cd /etc/netdata 2>/dev/null || cd /opt/netdata/etc/netdata
-sudo ./edit-config netdata.conf
-```
-#### Options
-
-You can also specify per mount point `[plugin:proc:diskspace:mountpoint]`
-
-<details><summary>Config options</summary>
-
-| Name | Description | Default | Required |
-|:----|:-----------|:-------|:--------:|
-| update every | Data collection frequency. | 1 | no |
-| remove charts of unmounted disks | Remove chart when a device is unmounted on host. | yes | no |
-| check for new mount points every | Parse proc files frequency. | 15 | no |
-| exclude space metrics on paths | Do not show metrics (charts) for listed paths. This option accepts netdata simple pattern. | /proc/* /sys/* /var/run/user/* /run/user/* /snap/* /var/lib/docker/* | no |
-| exclude space metrics on filesystems | Do not show metrics (charts) for listed filesystems. This option accepts netdata simple pattern. | *gvfs *gluster* *s3fs *ipfs *davfs2 *httpfs *sshfs *gdfs *moosefs fusectl autofs | no |
-| exclude inode metrics on filesystems | Do not show metrics (charts) for listed filesystems. This option accepts netdata simple pattern. | msdosfs msdos vfat overlayfs aufs* *unionfs | no |
-| space usage for all disks | Define if plugin will show metrics for space usage. When value is set to `auto` plugin will try to access information to display if filesystem or path was not discarded with previous option. | auto | no |
-| inodes usage for all disks | Define if plugin will show metrics for inode usage. When value is set to `auto` plugin will try to access information to display if filesystem or path was not discarded with previous option. | auto | no |
-
-</details>
-
-#### Examples
-There are no configuration examples.
-
-
diff --git a/collectors/diskspace.plugin/metadata.yaml b/collectors/diskspace.plugin/metadata.yaml
deleted file mode 100644
index cb45edf34..000000000
--- a/collectors/diskspace.plugin/metadata.yaml
+++ /dev/null
@@ -1,139 +0,0 @@
-plugin_name: diskspace.plugin
-modules:
- - meta:
- plugin_name: diskspace.plugin
- module_name: diskspace.plugin
- monitored_instance:
- name: Disk space
- link: ""
- categories:
- - data-collection.linux-systems
- icon_filename: "hard-drive.svg"
- related_resources:
- integrations:
- list:
- - plugin_name: ebpf.plugin
- module_name: disk
- info_provided_to_referring_integrations:
- description: ""
- keywords:
- - disk
- - I/O
- - space
- - inode
- most_popular: false
- overview:
- data_collection:
- metrics_description: "Monitor Disk space metrics for proficient storage management. Keep track of usage, free space, and error rates to prevent disk space issues."
- method_description: ""
- supported_platforms:
- include: []
- exclude: []
- multi_instance: true
- additional_permissions:
- description: ""
- default_behavior:
- auto_detection:
- description: "The plugin reads data from `/proc/self/mountinfo` and `/proc/diskstats file`."
- limits:
- description: ""
- performance_impact:
- description: ""
- setup:
- prerequisites:
- list: []
- configuration:
- file:
- name: "netdata.conf"
- section_name: "[plugin:proc:diskspace]"
- description: "This is netdata main configuration file"
- options:
- description: "You can also specify per mount point `[plugin:proc:diskspace:mountpoint]`"
- folding:
- title: "Config options"
- enabled: true
- list:
- - name: update every
- description: Data collection frequency.
- default_value: 1
- required: false
- - name: remove charts of unmounted disks
- description: Remove chart when a device is unmounted on host.
- default_value: yes
- required: false
- - name: check for new mount points every
- description: Parse proc files frequency.
- default_value: 15
- required: false
- - name: exclude space metrics on paths
- description: Do not show metrics (charts) for listed paths. This option accepts netdata simple pattern.
- default_value: /proc/* /sys/* /var/run/user/* /run/user/* /snap/* /var/lib/docker/*
- required: false
- - name: exclude space metrics on filesystems
- description: Do not show metrics (charts) for listed filesystems. This option accepts netdata simple pattern.
- default_value: "*gvfs *gluster* *s3fs *ipfs *davfs2 *httpfs *sshfs *gdfs *moosefs fusectl autofs"
- required: false
- - name: exclude inode metrics on filesystems
- description: Do not show metrics (charts) for listed filesystems. This option accepts netdata simple pattern.
- default_value: msdosfs msdos vfat overlayfs aufs* *unionfs
- required: false
- - name: space usage for all disks
- description: Define if plugin will show metrics for space usage. When value is set to `auto` plugin will try to access information to display if filesystem or path was not discarded with previous option.
- default_value: auto
- required: false
- - name: inodes usage for all disks
- description: Define if plugin will show metrics for inode usage. When value is set to `auto` plugin will try to access information to display if filesystem or path was not discarded with previous option.
- default_value: auto
- required: false
- examples:
- folding:
- enabled: true
- title: ""
- list: []
- troubleshooting:
- problems:
- list: []
- alerts:
- - name: disk_space_usage
- link: https://github.com/netdata/netdata/blob/master/health/health.d/disks.conf
- metric: disk.space
- info: disk ${label:mount_point} space utilization
- os: "linux freebsd"
- - name: disk_inode_usage
- link: https://github.com/netdata/netdata/blob/master/health/health.d/disks.conf
- metric: disk.inodes
- info: disk ${label:mount_point} inode utilization
- os: "linux freebsd"
- metrics:
- folding:
- title: Metrics
- enabled: false
- description: ""
- availability: []
- scopes:
- - name: mount point
- description: ""
- labels:
- - name: mount_point
- description: Path used to mount a filesystem
- - name: filesystem
- description: The filesystem used to format a partition.
- - name: mount_root
- description: Root directory where mount points are present.
- metrics:
- - name: disk.space
- description: Disk Space Usage
- unit: "GiB"
- chart_type: stacked
- dimensions:
- - name: avail
- - name: used
- - name: reserved_for_root
- - name: disk.inodes
- description: Disk Files (inodes) Usage
- unit: "inodes"
- chart_type: stacked
- dimensions:
- - name: avail
- - name: used
- - name: reserved_for_root
diff --git a/collectors/diskspace.plugin/plugin_diskspace.c b/collectors/diskspace.plugin/plugin_diskspace.c
deleted file mode 100644
index 94257810c..000000000
--- a/collectors/diskspace.plugin/plugin_diskspace.c
+++ /dev/null
@@ -1,945 +0,0 @@
-// SPDX-License-Identifier: GPL-3.0-or-later
-
-#include "../proc.plugin/plugin_proc.h"
-
-#define PLUGIN_DISKSPACE_NAME "diskspace.plugin"
-
-#define DEFAULT_EXCLUDED_PATHS "/proc/* /sys/* /var/run/user/* /run/user/* /snap/* /var/lib/docker/*"
-#define DEFAULT_EXCLUDED_FILESYSTEMS "*gvfs *gluster* *s3fs *ipfs *davfs2 *httpfs *sshfs *gdfs *moosefs fusectl autofs"
-#define DEFAULT_EXCLUDED_FILESYSTEMS_INODES "msdosfs msdos vfat overlayfs aufs* *unionfs"
-#define CONFIG_SECTION_DISKSPACE "plugin:proc:diskspace"
-
-#define RRDFUNCTIONS_DISKSPACE_HELP "View mount point statistics"
-
-#define MAX_STAT_USEC 10000LU
-#define SLOW_UPDATE_EVERY 5
-
-static netdata_thread_t *diskspace_slow_thread = NULL;
-
-static struct mountinfo *disk_mountinfo_root = NULL;
-static int check_for_new_mountpoints_every = 15;
-static int cleanup_mount_points = 1;
-
-static inline void mountinfo_reload(int force) {
- static time_t last_loaded = 0;
- time_t now = now_realtime_sec();
-
- if(force || now - last_loaded >= check_for_new_mountpoints_every) {
- // mountinfo_free_all() can be called with NULL disk_mountinfo_root
- mountinfo_free_all(disk_mountinfo_root);
-
- // re-read mountinfo in case something changed
- disk_mountinfo_root = mountinfo_read(0);
-
- last_loaded = now;
- }
-}
-
-// Data to be stored in DICTIONARY dict_mountpoints used by do_disk_space_stats().
-// This DICTIONARY is used to lookup the settings of the mount point on each iteration.
-struct mount_point_metadata {
- int do_space;
- int do_inodes;
- int shown_error;
- int updated;
- int slow;
-
- bool function_ready;
-
- STRING *filesystem;
- STRING *mountroot;
-
- RRDLABELS *chart_labels;
-
- size_t collected; // the number of times this has been collected
-
- RRDSET *st_space;
- RRDDIM *rd_space_used;
- RRDDIM *rd_space_avail;
- RRDDIM *rd_space_reserved;
-
- RRDSET *st_inodes;
- RRDDIM *rd_inodes_used;
- RRDDIM *rd_inodes_avail;
- RRDDIM *rd_inodes_reserved;
-};
-
-static DICTIONARY *dict_mountpoints = NULL;
-
-#define rrdset_obsolete_and_pointer_null(st) do { if(st) { rrdset_is_obsolete___safe_from_collector_thread(st); (st) = NULL; } } while(st)
-
-int mount_point_cleanup(const char *name, void *entry, int slow) {
- (void)name;
-
- struct mount_point_metadata *mp = (struct mount_point_metadata *)entry;
- if(!mp) return 0;
-
- if (slow != mp->slow)
- return 0;
-
- if(likely(mp->updated)) {
- mp->updated = 0;
- return 0;
- }
-
- if(likely(cleanup_mount_points && mp->collected)) {
- mp->function_ready = false;
- mp->collected = 0;
- mp->updated = 0;
- mp->shown_error = 0;
-
- string_freez(mp->filesystem);
- string_freez(mp->mountroot);
-
- rrdset_obsolete_and_pointer_null(mp->st_space);
- rrdset_obsolete_and_pointer_null(mp->st_inodes);
-
- mp->rd_space_avail = NULL;
- mp->rd_space_used = NULL;
- mp->rd_space_reserved = NULL;
-
- mp->rd_inodes_avail = NULL;
- mp->rd_inodes_used = NULL;
- mp->rd_inodes_reserved = NULL;
- }
-
- return 0;
-}
-
-int mount_point_cleanup_cb(const DICTIONARY_ITEM *item, void *entry, void *data __maybe_unused) {
- const char *name = dictionary_acquired_item_name(item);
-
- return mount_point_cleanup(name, (struct mount_point_metadata *)entry, 0);
-}
-
-// a copy of basic mountinfo fields
-struct basic_mountinfo {
- char *persistent_id;
- char *root;
- char *mount_point;
- char *filesystem;
-
- struct basic_mountinfo *next;
-};
-
-static struct basic_mountinfo *slow_mountinfo_tmp_root = NULL;
-static netdata_mutex_t slow_mountinfo_mutex;
-
-static struct basic_mountinfo *basic_mountinfo_create_and_copy(struct mountinfo* mi)
-{
- struct basic_mountinfo *bmi = callocz(1, sizeof(struct basic_mountinfo));
-
- if (mi) {
- bmi->persistent_id = strdupz(mi->persistent_id);
- bmi->root = strdupz(mi->root);
- bmi->mount_point = strdupz(mi->mount_point);
- bmi->filesystem = strdupz(mi->filesystem);
- }
-
- return bmi;
-}
-
-static void add_basic_mountinfo(struct basic_mountinfo **root, struct mountinfo *mi)
-{
- if (!root)
- return;
-
- struct basic_mountinfo *bmi = basic_mountinfo_create_and_copy(mi);
-
- bmi->next = *root;
- *root = bmi;
-};
-
-static void free_basic_mountinfo(struct basic_mountinfo *bmi)
-{
- if (bmi) {
- freez(bmi->persistent_id);
- freez(bmi->root);
- freez(bmi->mount_point);
- freez(bmi->filesystem);
-
- freez(bmi);
- }
-};
-
-static void free_basic_mountinfo_list(struct basic_mountinfo *root)
-{
- struct basic_mountinfo *bmi = root, *next;
-
- while (bmi) {
- next = bmi->next;
- free_basic_mountinfo(bmi);
- bmi = next;
- }
-}
-
-static void calculate_values_and_show_charts(
- struct basic_mountinfo *mi,
- struct mount_point_metadata *m,
- struct statvfs *buff_statvfs,
- int update_every)
-{
- const char *family = mi->mount_point;
- const char *disk = mi->persistent_id;
-
- // logic found at get_fs_usage() in coreutils
- unsigned long bsize = (buff_statvfs->f_frsize) ? buff_statvfs->f_frsize : buff_statvfs->f_bsize;
-
- fsblkcnt_t bavail = buff_statvfs->f_bavail;
- fsblkcnt_t btotal = buff_statvfs->f_blocks;
- fsblkcnt_t bavail_root = buff_statvfs->f_bfree;
- fsblkcnt_t breserved_root = bavail_root - bavail;
- fsblkcnt_t bused = likely(btotal >= bavail_root) ? btotal - bavail_root : bavail_root - btotal;
-
-#ifdef NETDATA_INTERNAL_CHECKS
- if(unlikely(btotal != bavail + breserved_root + bused))
- collector_error("DISKSPACE: disk block statistics for '%s' (disk '%s') do not sum up: total = %llu, available = %llu, reserved = %llu, used = %llu", mi->mount_point, disk, (unsigned long long)btotal, (unsigned long long)bavail, (unsigned long long)breserved_root, (unsigned long long)bused);
-#endif
-
- // --------------------------------------------------------------------------
-
- fsfilcnt_t favail = buff_statvfs->f_favail;
- fsfilcnt_t ftotal = buff_statvfs->f_files;
- fsfilcnt_t favail_root = buff_statvfs->f_ffree;
- fsfilcnt_t freserved_root = favail_root - favail;
- fsfilcnt_t fused = ftotal - favail_root;
-
- if(m->do_inodes == CONFIG_BOOLEAN_AUTO && favail == (fsfilcnt_t)-1) {
- // this file system does not support inodes reporting
- // eg. cephfs
- m->do_inodes = CONFIG_BOOLEAN_NO;
- }
-
-#ifdef NETDATA_INTERNAL_CHECKS
- if(unlikely(btotal != bavail + breserved_root + bused))
- collector_error("DISKSPACE: disk inode statistics for '%s' (disk '%s') do not sum up: total = %llu, available = %llu, reserved = %llu, used = %llu", mi->mount_point, disk, (unsigned long long)ftotal, (unsigned long long)favail, (unsigned long long)freserved_root, (unsigned long long)fused);
-#endif
-
- int rendered = 0;
-
- if(m->do_space == CONFIG_BOOLEAN_YES || (m->do_space == CONFIG_BOOLEAN_AUTO &&
- (bavail || breserved_root || bused ||
- netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES))) {
- if(unlikely(!m->st_space) || m->st_space->update_every != update_every) {
- m->do_space = CONFIG_BOOLEAN_YES;
- m->st_space = rrdset_find_active_bytype_localhost("disk_space", disk);
- if(unlikely(!m->st_space || m->st_space->update_every != update_every)) {
- char title[4096 + 1];
- snprintfz(title, sizeof(title) - 1, "Disk Space Usage");
- m->st_space = rrdset_create_localhost(
- "disk_space"
- , disk
- , NULL
- , family
- , "disk.space"
- , title
- , "GiB"
- , PLUGIN_DISKSPACE_NAME
- , NULL
- , NETDATA_CHART_PRIO_DISKSPACE_SPACE
- , update_every
- , RRDSET_TYPE_STACKED
- );
- }
-
- rrdset_update_rrdlabels(m->st_space, m->chart_labels);
-
- m->rd_space_avail = rrddim_add(m->st_space, "avail", NULL, (collected_number)bsize, 1024 * 1024 * 1024, RRD_ALGORITHM_ABSOLUTE);
- m->rd_space_used = rrddim_add(m->st_space, "used", NULL, (collected_number)bsize, 1024 * 1024 * 1024, RRD_ALGORITHM_ABSOLUTE);
- m->rd_space_reserved = rrddim_add(m->st_space, "reserved_for_root", "reserved for root", (collected_number)bsize, 1024 * 1024 * 1024, RRD_ALGORITHM_ABSOLUTE);
- }
-
- rrddim_set_by_pointer(m->st_space, m->rd_space_avail, (collected_number)bavail);
- rrddim_set_by_pointer(m->st_space, m->rd_space_used, (collected_number)bused);
- rrddim_set_by_pointer(m->st_space, m->rd_space_reserved, (collected_number)breserved_root);
- rrdset_done(m->st_space);
-
- rendered++;
- }
-
- if(m->do_inodes == CONFIG_BOOLEAN_YES || (m->do_inodes == CONFIG_BOOLEAN_AUTO &&
- (favail || freserved_root || fused ||
- netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES))) {
- if(unlikely(!m->st_inodes) || m->st_inodes->update_every != update_every) {
- m->do_inodes = CONFIG_BOOLEAN_YES;
- m->st_inodes = rrdset_find_active_bytype_localhost("disk_inodes", disk);
- if(unlikely(!m->st_inodes) || m->st_inodes->update_every != update_every) {
- char title[4096 + 1];
- snprintfz(title, sizeof(title) - 1, "Disk Files (inodes) Usage");
- m->st_inodes = rrdset_create_localhost(
- "disk_inodes"
- , disk
- , NULL
- , family
- , "disk.inodes"
- , title
- , "inodes"
- , PLUGIN_DISKSPACE_NAME
- , NULL
- , NETDATA_CHART_PRIO_DISKSPACE_INODES
- , update_every
- , RRDSET_TYPE_STACKED
- );
- }
-
- rrdset_update_rrdlabels(m->st_inodes, m->chart_labels);
-
- m->rd_inodes_avail = rrddim_add(m->st_inodes, "avail", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
- m->rd_inodes_used = rrddim_add(m->st_inodes, "used", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
- m->rd_inodes_reserved = rrddim_add(m->st_inodes, "reserved_for_root", "reserved for root", 1, 1, RRD_ALGORITHM_ABSOLUTE);
- }
-
- rrddim_set_by_pointer(m->st_inodes, m->rd_inodes_avail, (collected_number)favail);
- rrddim_set_by_pointer(m->st_inodes, m->rd_inodes_used, (collected_number)fused);
- rrddim_set_by_pointer(m->st_inodes, m->rd_inodes_reserved, (collected_number)freserved_root);
- rrdset_done(m->st_inodes);
-
- rendered++;
- }
-
- m->function_ready = rendered > 0;
-
- if(likely(rendered))
- m->collected++;
-}
-
-static inline void do_disk_space_stats(struct mountinfo *mi, int update_every) {
- const char *disk = mi->persistent_id;
-
- static SIMPLE_PATTERN *excluded_mountpoints = NULL;
- static SIMPLE_PATTERN *excluded_filesystems = NULL;
- static SIMPLE_PATTERN *excluded_filesystems_inodes = NULL;
-
- usec_t slow_timeout = MAX_STAT_USEC * update_every;
-
- int do_space, do_inodes;
-
- if(unlikely(!dict_mountpoints)) {
- SIMPLE_PREFIX_MODE mode = SIMPLE_PATTERN_EXACT;
-
- if(config_move("plugin:proc:/proc/diskstats", "exclude space metrics on paths", CONFIG_SECTION_DISKSPACE, "exclude space metrics on paths") != -1) {
- // old configuration, enable backwards compatibility
- mode = SIMPLE_PATTERN_PREFIX;
- }
-
- excluded_mountpoints = simple_pattern_create(
- config_get(CONFIG_SECTION_DISKSPACE, "exclude space metrics on paths", DEFAULT_EXCLUDED_PATHS),
- NULL,
- mode,
- true);
-
- excluded_filesystems = simple_pattern_create(
- config_get(CONFIG_SECTION_DISKSPACE, "exclude space metrics on filesystems", DEFAULT_EXCLUDED_FILESYSTEMS),
- NULL,
- SIMPLE_PATTERN_EXACT,
- true);
-
- excluded_filesystems_inodes = simple_pattern_create(
- config_get(CONFIG_SECTION_DISKSPACE, "exclude inode metrics on filesystems", DEFAULT_EXCLUDED_FILESYSTEMS_INODES),
- NULL,
- SIMPLE_PATTERN_EXACT,
- true);
-
- dict_mountpoints = dictionary_create_advanced(DICT_OPTION_NONE, &dictionary_stats_category_collectors, 0);
- }
-
- struct mount_point_metadata *m = dictionary_get(dict_mountpoints, mi->mount_point);
- if(unlikely(!m)) {
- int slow = 0;
-
- int def_space = config_get_boolean_ondemand(CONFIG_SECTION_DISKSPACE, "space usage for all disks", CONFIG_BOOLEAN_AUTO);
- int def_inodes = config_get_boolean_ondemand(CONFIG_SECTION_DISKSPACE, "inodes usage for all disks", CONFIG_BOOLEAN_AUTO);
-
- if(unlikely(simple_pattern_matches(excluded_mountpoints, mi->mount_point))) {
- def_space = CONFIG_BOOLEAN_NO;
- def_inodes = CONFIG_BOOLEAN_NO;
- }
-
- if(unlikely(simple_pattern_matches(excluded_filesystems, mi->filesystem))) {
- def_space = CONFIG_BOOLEAN_NO;
- def_inodes = CONFIG_BOOLEAN_NO;
- }
- if (unlikely(simple_pattern_matches(excluded_filesystems_inodes, mi->filesystem))) {
- def_inodes = CONFIG_BOOLEAN_NO;
- }
-
- // check if the mount point is a directory #2407
- // but only when it is enabled by default #4491
- if(def_space != CONFIG_BOOLEAN_NO || def_inodes != CONFIG_BOOLEAN_NO) {
- usec_t start_time = now_monotonic_high_precision_usec();
- struct stat bs;
-
- if(stat(mi->mount_point, &bs) == -1) {
- collector_error("DISKSPACE: Cannot stat() mount point '%s' (disk '%s', filesystem '%s', root '%s')."
- , mi->mount_point
- , disk
- , mi->filesystem?mi->filesystem:""
- , mi->root?mi->root:""
- );
- def_space = CONFIG_BOOLEAN_NO;
- def_inodes = CONFIG_BOOLEAN_NO;
- }
- else {
- if((bs.st_mode & S_IFMT) != S_IFDIR) {
- collector_error("DISKSPACE: Mount point '%s' (disk '%s', filesystem '%s', root '%s') is not a directory."
- , mi->mount_point
- , disk
- , mi->filesystem?mi->filesystem:""
- , mi->root?mi->root:""
- );
- def_space = CONFIG_BOOLEAN_NO;
- def_inodes = CONFIG_BOOLEAN_NO;
- }
- }
-
- if ((now_monotonic_high_precision_usec() - start_time) > slow_timeout)
- slow = 1;
- }
-
- char var_name[4096 + 1];
- snprintfz(var_name, 4096, "plugin:proc:diskspace:%s", mi->mount_point);
-
- do_space = def_space;
- do_inodes = def_inodes;
-
- if (config_exists(var_name, "space usage"))
- do_space = config_get_boolean_ondemand(var_name, "space usage", def_space);
- if (config_exists(var_name, "inodes usage"))
- do_inodes = config_get_boolean_ondemand(var_name, "inodes usage", def_inodes);
-
- struct mount_point_metadata mp = {
- .do_space = do_space,
- .do_inodes = do_inodes,
- .shown_error = 0,
- .updated = 0,
- .slow = 0,
-
- .collected = 0,
-
- .st_space = NULL,
- .rd_space_avail = NULL,
- .rd_space_used = NULL,
- .rd_space_reserved = NULL,
-
- .st_inodes = NULL,
- .rd_inodes_avail = NULL,
- .rd_inodes_used = NULL,
- .rd_inodes_reserved = NULL
- };
-
- mp.filesystem = string_strdupz(mi->filesystem);
- mp.mountroot = string_strdupz(mi->root);
-
- mp.chart_labels = rrdlabels_create();
- rrdlabels_add(mp.chart_labels, "mount_point", mi->mount_point, RRDLABEL_SRC_AUTO);
- rrdlabels_add(mp.chart_labels, "filesystem", mi->filesystem, RRDLABEL_SRC_AUTO);
- rrdlabels_add(mp.chart_labels, "mount_root", mi->root, RRDLABEL_SRC_AUTO);
-
- m = dictionary_set(dict_mountpoints, mi->mount_point, &mp, sizeof(struct mount_point_metadata));
-
- m->slow = slow;
- }
-
- if (m->slow) {
- add_basic_mountinfo(&slow_mountinfo_tmp_root, mi);
- return;
- }
-
- m->updated = 1;
-
- if(unlikely(m->do_space == CONFIG_BOOLEAN_NO && m->do_inodes == CONFIG_BOOLEAN_NO))
- return;
-
- if (unlikely(
- mi->flags & MOUNTINFO_READONLY &&
- !(mi->flags & MOUNTINFO_IS_IN_SYSD_PROTECTED_LIST) &&
- !m->collected &&
- m->do_space != CONFIG_BOOLEAN_YES &&
- m->do_inodes != CONFIG_BOOLEAN_YES))
- return;
-
- usec_t start_time = now_monotonic_high_precision_usec();
- struct statvfs buff_statvfs;
-
- if (statvfs(mi->mount_point, &buff_statvfs) < 0) {
- if(!m->shown_error) {
- collector_error("DISKSPACE: failed to statvfs() mount point '%s' (disk '%s', filesystem '%s', root '%s')"
- , mi->mount_point
- , disk
- , mi->filesystem?mi->filesystem:""
- , mi->root?mi->root:""
- );
- m->shown_error = 1;
- }
- return;
- }
-
- if ((now_monotonic_high_precision_usec() - start_time) > slow_timeout)
- m->slow = 1;
-
- m->shown_error = 0;
-
- struct basic_mountinfo bmi;
- bmi.mount_point = mi->mount_point;
- bmi.persistent_id = mi->persistent_id;
- bmi.filesystem = mi->filesystem;
- bmi.root = mi->root;
-
- calculate_values_and_show_charts(&bmi, m, &buff_statvfs, update_every);
-}
-
-static inline void do_slow_disk_space_stats(struct basic_mountinfo *mi, int update_every) {
- struct mount_point_metadata *m = dictionary_get(dict_mountpoints, mi->mount_point);
-
- m->updated = 1;
-
- struct statvfs buff_statvfs;
- if (statvfs(mi->mount_point, &buff_statvfs) < 0) {
- if(!m->shown_error) {
- collector_error("DISKSPACE: failed to statvfs() mount point '%s' (disk '%s', filesystem '%s', root '%s')"
- , mi->mount_point
- , mi->persistent_id
- , mi->filesystem?mi->filesystem:""
- , mi->root?mi->root:""
- );
- m->shown_error = 1;
- }
- return;
- }
- m->shown_error = 0;
-
- calculate_values_and_show_charts(mi, m, &buff_statvfs, update_every);
-}
-
-static void diskspace_slow_worker_cleanup(void *ptr)
-{
- UNUSED(ptr);
-
- collector_info("cleaning up...");
-
- worker_unregister();
-}
-
-#define WORKER_JOB_SLOW_MOUNTPOINT 0
-#define WORKER_JOB_SLOW_CLEANUP 1
-
-struct slow_worker_data {
- netdata_thread_t *slow_thread;
- int update_every;
-};
-
-void *diskspace_slow_worker(void *ptr)
-{
- struct slow_worker_data *data = (struct slow_worker_data *)ptr;
-
- worker_register("DISKSPACE_SLOW");
- worker_register_job_name(WORKER_JOB_SLOW_MOUNTPOINT, "mountpoint");
- worker_register_job_name(WORKER_JOB_SLOW_CLEANUP, "cleanup");
-
- struct basic_mountinfo *slow_mountinfo_root = NULL;
-
- int slow_update_every = data->update_every > SLOW_UPDATE_EVERY ? data->update_every : SLOW_UPDATE_EVERY;
-
- netdata_thread_cleanup_push(diskspace_slow_worker_cleanup, data->slow_thread);
-
- usec_t step = slow_update_every * USEC_PER_SEC;
- usec_t real_step = USEC_PER_SEC;
- heartbeat_t hb;
- heartbeat_init(&hb);
-
- while(service_running(SERVICE_COLLECTORS)) {
- worker_is_idle();
- heartbeat_next(&hb, USEC_PER_SEC);
-
- if (real_step < step) {
- real_step += USEC_PER_SEC;
- continue;
- }
- real_step = USEC_PER_SEC;
-
- usec_t start_time = now_monotonic_high_precision_usec();
-
- if (!dict_mountpoints)
- continue;
-
- if(unlikely(!service_running(SERVICE_COLLECTORS))) break;
-
- // --------------------------------------------------------------------------
- // disk space metrics
-
- worker_is_busy(WORKER_JOB_SLOW_MOUNTPOINT);
-
- netdata_mutex_lock(&slow_mountinfo_mutex);
- free_basic_mountinfo_list(slow_mountinfo_root);
- slow_mountinfo_root = slow_mountinfo_tmp_root;
- slow_mountinfo_tmp_root = NULL;
- netdata_mutex_unlock(&slow_mountinfo_mutex);
-
- struct basic_mountinfo *bmi;
- for(bmi = slow_mountinfo_root; bmi; bmi = bmi->next) {
- do_slow_disk_space_stats(bmi, slow_update_every);
-
- if(unlikely(!service_running(SERVICE_COLLECTORS))) break;
- }
-
- if(unlikely(!service_running(SERVICE_COLLECTORS))) break;
-
- worker_is_busy(WORKER_JOB_SLOW_CLEANUP);
-
- for(bmi = slow_mountinfo_root; bmi; bmi = bmi->next) {
- struct mount_point_metadata *m = dictionary_get(dict_mountpoints, bmi->mount_point);
-
- if (m)
- mount_point_cleanup(bmi->mount_point, m, 1);
- }
-
- usec_t dt = now_monotonic_high_precision_usec() - start_time;
- if (dt > step) {
- slow_update_every = (dt / USEC_PER_SEC) * 3 / 2;
- if (slow_update_every % SLOW_UPDATE_EVERY)
- slow_update_every += SLOW_UPDATE_EVERY - slow_update_every % SLOW_UPDATE_EVERY;
- step = slow_update_every * USEC_PER_SEC;
- }
- }
-
- netdata_thread_cleanup_pop(1);
-
- free_basic_mountinfo_list(slow_mountinfo_root);
-
- return NULL;
-}
-
-static void diskspace_main_cleanup(void *ptr) {
- rrd_collector_finished();
- worker_unregister();
-
- struct netdata_static_thread *static_thread = (struct netdata_static_thread *)ptr;
- static_thread->enabled = NETDATA_MAIN_THREAD_EXITING;
-
- collector_info("cleaning up...");
-
- if (diskspace_slow_thread) {
- netdata_thread_join(*diskspace_slow_thread, NULL);
- freez(diskspace_slow_thread);
- }
-
- free_basic_mountinfo_list(slow_mountinfo_tmp_root);
-
- static_thread->enabled = NETDATA_MAIN_THREAD_EXITED;
-}
-
-#define WORKER_JOB_MOUNTINFO 0
-#define WORKER_JOB_MOUNTPOINT 1
-#define WORKER_JOB_CLEANUP 2
-
-#if WORKER_UTILIZATION_MAX_JOB_TYPES < 3
-#error WORKER_UTILIZATION_MAX_JOB_TYPES has to be at least 3
-#endif
-
-int diskspace_function_mount_points(BUFFER *wb, int timeout __maybe_unused, const char *function __maybe_unused,
- void *collector_data __maybe_unused,
- rrd_function_result_callback_t result_cb, void *result_cb_data,
- rrd_function_is_cancelled_cb_t is_cancelled_cb, void *is_cancelled_cb_data,
- rrd_function_register_canceller_cb_t register_canceller_cb __maybe_unused,
- void *register_canceller_cb_data __maybe_unused) {
-
- buffer_flush(wb);
- wb->content_type = CT_APPLICATION_JSON;
- buffer_json_initialize(wb, "\"", "\"", 0, true, BUFFER_JSON_OPTIONS_DEFAULT);
-
- buffer_json_member_add_string(wb, "hostname", rrdhost_hostname(localhost));
- buffer_json_member_add_uint64(wb, "status", HTTP_RESP_OK);
- buffer_json_member_add_string(wb, "type", "table");
- buffer_json_member_add_time_t(wb, "update_every", 1);
- buffer_json_member_add_string(wb, "help", RRDFUNCTIONS_DISKSPACE_HELP);
- buffer_json_member_add_array(wb, "data");
-
- double max_space_util = 0.0;
- double max_space_avail = 0.0;
- double max_space_used = 0.0;
- double max_space_reserved = 0.0;
-
- double max_inodes_util = 0.0;
- double max_inodes_avail = 0.0;
- double max_inodes_used = 0.0;
- double max_inodes_reserved = 0.0;
-
- struct mount_point_metadata *mp;
- dfe_start_write(dict_mountpoints, mp) {
- if (!mp->function_ready)
- continue;
-
- buffer_json_add_array_item_array(wb);
-
- buffer_json_add_array_item_string(wb, mp_dfe.name);
- buffer_json_add_array_item_string(wb, string2str(mp->filesystem));
- buffer_json_add_array_item_string(wb, string2str(mp->mountroot));
-
- double space_avail = rrddim_get_last_stored_value(mp->rd_space_avail, &max_space_avail, 1.0);
- double space_used = rrddim_get_last_stored_value(mp->rd_space_used, &max_space_used, 1.0);
- double space_reserved = rrddim_get_last_stored_value(mp->rd_space_reserved, &max_space_reserved, 1.0);
- double inodes_avail = rrddim_get_last_stored_value(mp->rd_inodes_avail, &max_inodes_avail, 1.0);
- double inodes_used = rrddim_get_last_stored_value(mp->rd_inodes_used, &max_inodes_used, 1.0);
- double inodes_reserved = rrddim_get_last_stored_value(mp->rd_inodes_reserved, &max_inodes_reserved, 1.0);
-
- double space_util = NAN;
- if (!isnan(space_avail) && !isnan(space_used)) {
- space_util = space_avail + space_used > 0 ? space_used * 100.0 / (space_avail + space_used) : 0;
- max_space_util = MAX(max_space_util, space_util);
- }
- double inodes_util = NAN;
- if (!isnan(inodes_avail) && !isnan(inodes_used)) {
- inodes_util = inodes_avail + inodes_used > 0 ? inodes_used * 100.0 / (inodes_avail + inodes_used) : 0;
- max_inodes_util = MAX(max_inodes_util, inodes_util);
- }
-
- buffer_json_add_array_item_double(wb, space_util);
- buffer_json_add_array_item_double(wb, space_avail);
- buffer_json_add_array_item_double(wb, space_used);
- buffer_json_add_array_item_double(wb, space_reserved);
-
- buffer_json_add_array_item_double(wb, inodes_util);
- buffer_json_add_array_item_double(wb, inodes_avail);
- buffer_json_add_array_item_double(wb, inodes_used);
- buffer_json_add_array_item_double(wb, inodes_reserved);
-
- buffer_json_array_close(wb);
- }
- dfe_done(mp);
-
- buffer_json_array_close(wb); // data
- buffer_json_member_add_object(wb, "columns");
- {
- size_t field_id = 0;
-
- buffer_rrdf_table_add_field(wb, field_id++, "Mountpoint", "Mountpoint Name",
- RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
- 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
- RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
- RRDF_FIELD_OPTS_VISIBLE | RRDF_FIELD_OPTS_UNIQUE_KEY | RRDF_FIELD_OPTS_STICKY | RRDF_FIELD_OPTS_FULL_WIDTH,
- NULL);
- buffer_rrdf_table_add_field(wb, field_id++, "Filesystem", "Mountpoint Filesystem",
- RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
- 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
- RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
- RRDF_FIELD_OPTS_VISIBLE | RRDF_FIELD_OPTS_UNIQUE_KEY,
- NULL);
- buffer_rrdf_table_add_field(wb, field_id++, "Root", "Mountpoint Root",
- RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
- 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
- RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
- RRDF_FIELD_OPTS_UNIQUE_KEY,
- NULL);
-
- buffer_rrdf_table_add_field(wb, field_id++, "Used%", "Space Utilization",
- RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
- 2, "%", max_space_util, RRDF_FIELD_SORT_DESCENDING, NULL,
- RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_NONE,
- RRDF_FIELD_OPTS_VISIBLE,
- NULL);
- buffer_rrdf_table_add_field(wb, field_id++, "Avail", "Space Avail",
- RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
- 2, "GiB", max_space_avail, RRDF_FIELD_SORT_DESCENDING, NULL,
- RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_NONE,
- RRDF_FIELD_OPTS_VISIBLE,
- NULL);
- buffer_rrdf_table_add_field(wb, field_id++, "Used", "Space Used",
- RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
- 2, "GiB", max_space_used, RRDF_FIELD_SORT_DESCENDING, NULL,
- RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_NONE,
- RRDF_FIELD_OPTS_VISIBLE,
- NULL);
- buffer_rrdf_table_add_field(wb, field_id++, "Reserved", "Space Reserved for root",
- RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
- 2, "GiB", max_space_reserved, RRDF_FIELD_SORT_DESCENDING, NULL,
- RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_NONE,
- RRDF_FIELD_OPTS_VISIBLE,
- NULL);
-
- buffer_rrdf_table_add_field(wb, field_id++, "iUsed%", "Inodes Utilization",
- RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
- 2, "%", max_inodes_util, RRDF_FIELD_SORT_DESCENDING, NULL,
- RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_NONE,
- RRDF_FIELD_OPTS_NONE,
- NULL);
- buffer_rrdf_table_add_field(wb, field_id++, "iAvail", "Inodes Avail",
- RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
- 2, "inodes", max_inodes_avail, RRDF_FIELD_SORT_DESCENDING, NULL,
- RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_NONE,
- RRDF_FIELD_OPTS_NONE,
- NULL);
- buffer_rrdf_table_add_field(wb, field_id++, "iUsed", "Inodes Used",
- RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
- 2, "inodes", max_inodes_used, RRDF_FIELD_SORT_DESCENDING, NULL,
- RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_NONE,
- RRDF_FIELD_OPTS_NONE,
- NULL);
- buffer_rrdf_table_add_field(wb, field_id++, "iReserved", "Inodes Reserved for root",
- RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
- 2, "inodes", max_inodes_reserved, RRDF_FIELD_SORT_DESCENDING, NULL,
- RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_NONE,
- RRDF_FIELD_OPTS_NONE,
- NULL);
- }
-
- buffer_json_object_close(wb); // columns
- buffer_json_member_add_string(wb, "default_sort_column", "Used%");
-
- buffer_json_member_add_object(wb, "charts");
- {
- buffer_json_member_add_object(wb, "Utilization");
- {
- buffer_json_member_add_string(wb, "name", "Utilization");
- buffer_json_member_add_string(wb, "type", "stacked-bar");
- buffer_json_member_add_array(wb, "columns");
- {
- buffer_json_add_array_item_string(wb, "Used%");
- }
- buffer_json_array_close(wb);
- }
- buffer_json_object_close(wb);
-
- buffer_json_member_add_object(wb, "Usage");
- {
- buffer_json_member_add_string(wb, "name", "Usage");
- buffer_json_member_add_string(wb, "type", "stacked-bar");
- buffer_json_member_add_array(wb, "columns");
- {
- buffer_json_add_array_item_string(wb, "Avail");
- buffer_json_add_array_item_string(wb, "Used");
- buffer_json_add_array_item_string(wb, "Reserved");
- }
- buffer_json_array_close(wb);
- }
- buffer_json_object_close(wb);
-
- buffer_json_member_add_object(wb, "Inodes");
- {
- buffer_json_member_add_string(wb, "name", "Inodes");
- buffer_json_member_add_string(wb, "type", "stacked-bar");
- buffer_json_member_add_array(wb, "columns");
- {
- buffer_json_add_array_item_string(wb, "iAvail");
- buffer_json_add_array_item_string(wb, "iUsed");
- buffer_json_add_array_item_string(wb, "iReserved");
- }
- buffer_json_array_close(wb);
- }
- buffer_json_object_close(wb);
- }
- buffer_json_object_close(wb); // charts
-
- buffer_json_member_add_array(wb, "default_charts");
- {
- buffer_json_add_array_item_array(wb);
- buffer_json_add_array_item_string(wb, "Utilization");
- buffer_json_add_array_item_string(wb, "Mountpoint");
- buffer_json_array_close(wb);
-
- buffer_json_add_array_item_array(wb);
- buffer_json_add_array_item_string(wb, "Usage");
- buffer_json_add_array_item_string(wb, "Mountpoint");
- buffer_json_array_close(wb);
- }
- buffer_json_array_close(wb);
-
- buffer_json_member_add_time_t(wb, "expires", now_realtime_sec() + 1);
- buffer_json_finalize(wb);
-
- int response = HTTP_RESP_OK;
- if(is_cancelled_cb && is_cancelled_cb(is_cancelled_cb_data)) {
- buffer_flush(wb);
- response = HTTP_RESP_CLIENT_CLOSED_REQUEST;
- }
-
- if(result_cb)
- result_cb(wb, response, result_cb_data);
-
- return response;
-}
-
-void *diskspace_main(void *ptr) {
- worker_register("DISKSPACE");
- worker_register_job_name(WORKER_JOB_MOUNTINFO, "mountinfo");
- worker_register_job_name(WORKER_JOB_MOUNTPOINT, "mountpoint");
- worker_register_job_name(WORKER_JOB_CLEANUP, "cleanup");
-
- rrd_collector_started();
- rrd_function_add(localhost, NULL, "mount-points", 10, RRDFUNCTIONS_DISKSPACE_HELP, true, diskspace_function_mount_points, NULL);
-
- netdata_thread_cleanup_push(diskspace_main_cleanup, ptr);
-
- cleanup_mount_points = config_get_boolean(CONFIG_SECTION_DISKSPACE, "remove charts of unmounted disks" , cleanup_mount_points);
-
- int update_every = (int)config_get_number(CONFIG_SECTION_DISKSPACE, "update every", localhost->rrd_update_every);
- if(update_every < localhost->rrd_update_every)
- update_every = localhost->rrd_update_every;
-
- check_for_new_mountpoints_every = (int)config_get_number(CONFIG_SECTION_DISKSPACE, "check for new mount points every", check_for_new_mountpoints_every);
- if(check_for_new_mountpoints_every < update_every)
- check_for_new_mountpoints_every = update_every;
-
- netdata_mutex_init(&slow_mountinfo_mutex);
-
- diskspace_slow_thread = mallocz(sizeof(netdata_thread_t));
-
- struct slow_worker_data slow_worker_data = {.slow_thread = diskspace_slow_thread, .update_every = update_every};
-
- netdata_thread_create(
- diskspace_slow_thread,
- "P[diskspace slow]",
- NETDATA_THREAD_OPTION_JOINABLE,
- diskspace_slow_worker,
- &slow_worker_data);
-
- usec_t step = update_every * USEC_PER_SEC;
- heartbeat_t hb;
- heartbeat_init(&hb);
- while(service_running(SERVICE_COLLECTORS)) {
- worker_is_idle();
- /* usec_t hb_dt = */ heartbeat_next(&hb, step);
-
- if(unlikely(!service_running(SERVICE_COLLECTORS))) break;
-
- // --------------------------------------------------------------------------
- // this is smart enough not to reload it every time
-
- worker_is_busy(WORKER_JOB_MOUNTINFO);
- mountinfo_reload(0);
-
- // --------------------------------------------------------------------------
- // disk space metrics
-
- netdata_mutex_lock(&slow_mountinfo_mutex);
- free_basic_mountinfo_list(slow_mountinfo_tmp_root);
- slow_mountinfo_tmp_root = NULL;
-
- struct mountinfo *mi;
- for(mi = disk_mountinfo_root; mi; mi = mi->next) {
- if(unlikely(mi->flags & (MOUNTINFO_IS_DUMMY | MOUNTINFO_IS_BIND)))
- continue;
-
- // exclude mounts made by ProtectHome and ProtectSystem systemd hardening options
- // https://github.com/netdata/netdata/issues/11498#issuecomment-950982878
- if(mi->flags & MOUNTINFO_READONLY && mi->flags & MOUNTINFO_IS_IN_SYSD_PROTECTED_LIST && !strcmp(mi->root, mi->mount_point))
- continue;
-
- worker_is_busy(WORKER_JOB_MOUNTPOINT);
- do_disk_space_stats(mi, update_every);
- if(unlikely(!service_running(SERVICE_COLLECTORS))) break;
- }
- netdata_mutex_unlock(&slow_mountinfo_mutex);
-
- if(unlikely(!service_running(SERVICE_COLLECTORS))) break;
-
- if(dict_mountpoints) {
- worker_is_busy(WORKER_JOB_CLEANUP);
- dictionary_walkthrough_read(dict_mountpoints, mount_point_cleanup_cb, NULL);
- }
-
- }
- worker_unregister();
-
- netdata_thread_cleanup_pop(1);
- return NULL;
-}