src/proc_vmstat.c

   1 #include <inttypes.h>
   2 #include <stdio.h>
   3 #include <stdlib.h>
   4 #include <string.h>
   5 #include <unistd.h>
   6
   7 #include "common.h"
   8 #include "log.h"
   9 #include "config.h"
  10 #include "procfile.h"
  11 #include "rrd.h"
  12 #include "plugin_proc.h"
  13
  14 #define MAX_PROC_VMSTAT_LINE 4096
  15 #define MAX_PROC_VMSTAT_NAME 1024
  16
  17 int do_proc_vmstat(int update_every, unsigned long long dt) {
  18         static procfile *ff = NULL;
  19         static int do_swapio = -1, do_io = -1, do_pgfaults = -1;
  20
  21         if(do_swapio == -1)     do_swapio = config_get_boolean("plugin:proc:/proc/vmstat", "swap i/o", 1);
  22         if(do_io == -1)         do_io = config_get_boolean("plugin:proc:/proc/vmstat", "disk i/o", 1);
  23         if(do_pgfaults == -1)   do_pgfaults = config_get_boolean("plugin:proc:/proc/vmstat", "memory page faults", 1);
  24
  25         if(dt) {};
  26
  27         if(!ff) {
  28                 char filename[FILENAME_MAX + 1];
  29                 snprintf(filename, FILENAME_MAX, "%s%s", global_host_prefix, "/proc/vmstat");
  30                 ff = procfile_open(config_get("plugin:proc:/proc/vmstat", "filename to monitor", filename), " \t:", PROCFILE_FLAG_DEFAULT);
  31         }
  32         if(!ff) return 1;
  33
  34         ff = procfile_readall(ff);
  35         if(!ff) return 0; // we return 0, so that we will retry to open it next time
  36
  37         uint32_t lines = procfile_lines(ff), l;
  38         uint32_t words;
  39
  40         unsigned long long nr_free_pages = 0, nr_inactive_anon = 0, nr_active_anon = 0, nr_inactive_file = 0, nr_active_file = 0, nr_unevictable = 0, nr_mlock = 0,
  41                 nr_anon_pages = 0, nr_mapped = 0, nr_file_pages = 0, nr_dirty = 0, nr_writeback = 0, nr_slab_reclaimable = 0, nr_slab_unreclaimable = 0, nr_page_table_pages = 0,
  42                 nr_kernel_stack = 0, nr_unstable = 0, nr_bounce = 0, nr_vmscan_write = 0, nr_vmscan_immediate_reclaim = 0, nr_writeback_temp = 0, nr_isolated_anon = 0, nr_isolated_file = 0,
  43                 nr_shmem = 0, nr_dirtied = 0, nr_written = 0, nr_anon_transparent_hugepages = 0, nr_dirty_threshold = 0, nr_dirty_background_threshold = 0,
  44                 pgpgin = 0, pgpgout = 0, pswpin = 0, pswpout = 0, pgalloc_dma = 0, pgalloc_dma32 = 0, pgalloc_normal = 0, pgalloc_movable = 0, pgfree = 0, pgactivate = 0, pgdeactivate = 0,
  45                 pgfault = 0, pgmajfault = 0, pgrefill_dma = 0, pgrefill_dma32 = 0, pgrefill_normal = 0, pgrefill_movable = 0, pgsteal_kswapd_dma = 0, pgsteal_kswapd_dma32 = 0,
  46                 pgsteal_kswapd_normal = 0, pgsteal_kswapd_movable = 0, pgsteal_direct_dma = 0, pgsteal_direct_dma32 = 0, pgsteal_direct_normal = 0, pgsteal_direct_movable = 0,
  47                 pgscan_kswapd_dma = 0, pgscan_kswapd_dma32 = 0, pgscan_kswapd_normal = 0, pgscan_kswapd_movable = 0, pgscan_direct_dma = 0, pgscan_direct_dma32 = 0, pgscan_direct_normal = 0,
  48                 pgscan_direct_movable = 0, pginodesteal = 0, slabs_scanned = 0, kswapd_inodesteal = 0, kswapd_low_wmark_hit_quickly = 0, kswapd_high_wmark_hit_quickly = 0,
  49                 kswapd_skip_congestion_wait = 0, pageoutrun = 0, allocstall = 0, pgrotated = 0, compact_blocks_moved = 0, compact_pages_moved = 0, compact_pagemigrate_failed = 0,
  50                 compact_stall = 0, compact_fail = 0, compact_success = 0, htlb_buddy_alloc_success = 0, htlb_buddy_alloc_fail = 0, unevictable_pgs_culled = 0, unevictable_pgs_scanned = 0,
  51                 unevictable_pgs_rescued = 0, unevictable_pgs_mlocked = 0, unevictable_pgs_munlocked = 0, unevictable_pgs_cleared = 0, unevictable_pgs_stranded = 0, unevictable_pgs_mlockfreed = 0,
  52                 thp_fault_alloc = 0, thp_fault_fallback = 0, thp_collapse_alloc = 0, thp_collapse_alloc_failed = 0, thp_split = 0;
  53
  54         for(l = 0; l < lines ;l++) {
  55                 words = procfile_linewords(ff, l);
  56                 if(words < 2) {
  57                         if(words) error("Cannot read /proc/vmstat line %d. Expected 2 params, read %d.", l, words);
  58                         continue;
  59                 }
  60
  61                 char *name = procfile_lineword(ff, l, 0);
  62                 unsigned long long value = strtoull(procfile_lineword(ff, l, 1), NULL, 10);
  63
  64                      if(!nr_free_pages && strcmp(name, "nr_free_pages") == 0) nr_free_pages = value;
  65                 else if(!nr_inactive_anon && strcmp(name, "nr_inactive_anon") == 0) nr_inactive_anon = value;
  66                 else if(!nr_active_anon && strcmp(name, "nr_active_anon") == 0) nr_active_anon = value;
  67                 else if(!nr_inactive_file && strcmp(name, "nr_inactive_file") == 0) nr_inactive_file = value;
  68                 else if(!nr_active_file && strcmp(name, "nr_active_file") == 0) nr_active_file = value;
  69                 else if(!nr_unevictable && strcmp(name, "nr_unevictable") == 0) nr_unevictable = value;
  70                 else if(!nr_mlock && strcmp(name, "nr_mlock") == 0) nr_mlock = value;
  71                 else if(!nr_anon_pages && strcmp(name, "nr_anon_pages") == 0) nr_anon_pages = value;
  72                 else if(!nr_mapped && strcmp(name, "nr_mapped") == 0) nr_mapped = value;
  73                 else if(!nr_file_pages && strcmp(name, "nr_file_pages") == 0) nr_file_pages = value;
  74                 else if(!nr_dirty && strcmp(name, "nr_dirty") == 0) nr_dirty = value;
  75                 else if(!nr_writeback && strcmp(name, "nr_writeback") == 0) nr_writeback = value;
  76                 else if(!nr_slab_reclaimable && strcmp(name, "nr_slab_reclaimable") == 0) nr_slab_reclaimable = value;
  77                 else if(!nr_slab_unreclaimable && strcmp(name, "nr_slab_unreclaimable") == 0) nr_slab_unreclaimable = value;
  78                 else if(!nr_page_table_pages && strcmp(name, "nr_page_table_pages") == 0) nr_page_table_pages = value;
  79                 else if(!nr_kernel_stack && strcmp(name, "nr_kernel_stack") == 0) nr_kernel_stack = value;
  80                 else if(!nr_unstable && strcmp(name, "nr_unstable") == 0) nr_unstable = value;
  81                 else if(!nr_bounce && strcmp(name, "nr_bounce") == 0) nr_bounce = value;
  82                 else if(!nr_vmscan_write && strcmp(name, "nr_vmscan_write") == 0) nr_vmscan_write = value;
  83                 else if(!nr_vmscan_immediate_reclaim && strcmp(name, "nr_vmscan_immediate_reclaim") == 0) nr_vmscan_immediate_reclaim = value;
  84                 else if(!nr_writeback_temp && strcmp(name, "nr_writeback_temp") == 0) nr_writeback_temp = value;
  85                 else if(!nr_isolated_anon && strcmp(name, "nr_isolated_anon") == 0) nr_isolated_anon = value;
  86                 else if(!nr_isolated_file && strcmp(name, "nr_isolated_file") == 0) nr_isolated_file = value;
  87                 else if(!nr_shmem && strcmp(name, "nr_shmem") == 0) nr_shmem = value;
  88                 else if(!nr_dirtied && strcmp(name, "nr_dirtied") == 0) nr_dirtied = value;
  89                 else if(!nr_written && strcmp(name, "nr_written") == 0) nr_written = value;
  90                 else if(!nr_anon_transparent_hugepages && strcmp(name, "nr_anon_transparent_hugepages") == 0) nr_anon_transparent_hugepages = value;
  91                 else if(!nr_dirty_threshold && strcmp(name, "nr_dirty_threshold") == 0) nr_dirty_threshold = value;
  92                 else if(!nr_dirty_background_threshold && strcmp(name, "nr_dirty_background_threshold") == 0) nr_dirty_background_threshold = value;
  93                 else if(!pgpgin && strcmp(name, "pgpgin") == 0) pgpgin = value;
  94                 else if(!pgpgout && strcmp(name, "pgpgout") == 0) pgpgout = value;
  95                 else if(!pswpin && strcmp(name, "pswpin") == 0) pswpin = value;
  96                 else if(!pswpout && strcmp(name, "pswpout") == 0) pswpout = value;
  97                 else if(!pgalloc_dma && strcmp(name, "pgalloc_dma") == 0) pgalloc_dma = value;
  98                 else if(!pgalloc_dma32 && strcmp(name, "pgalloc_dma32") == 0) pgalloc_dma32 = value;
  99                 else if(!pgalloc_normal && strcmp(name, "pgalloc_normal") == 0) pgalloc_normal = value;
 100                 else if(!pgalloc_movable && strcmp(name, "pgalloc_movable") == 0) pgalloc_movable = value;
 101                 else if(!pgfree && strcmp(name, "pgfree") == 0) pgfree = value;
 102                 else if(!pgactivate && strcmp(name, "pgactivate") == 0) pgactivate = value;
 103                 else if(!pgdeactivate && strcmp(name, "pgdeactivate") == 0) pgdeactivate = value;
 104                 else if(!pgfault && strcmp(name, "pgfault") == 0) pgfault = value;
 105                 else if(!pgmajfault && strcmp(name, "pgmajfault") == 0) pgmajfault = value;
 106                 else if(!pgrefill_dma && strcmp(name, "pgrefill_dma") == 0) pgrefill_dma = value;
 107                 else if(!pgrefill_dma32 && strcmp(name, "pgrefill_dma32") == 0) pgrefill_dma32 = value;
 108                 else if(!pgrefill_normal && strcmp(name, "pgrefill_normal") == 0) pgrefill_normal = value;
 109                 else if(!pgrefill_movable && strcmp(name, "pgrefill_movable") == 0) pgrefill_movable = value;
 110                 else if(!pgsteal_kswapd_dma && strcmp(name, "pgsteal_kswapd_dma") == 0) pgsteal_kswapd_dma = value;
 111                 else if(!pgsteal_kswapd_dma32 && strcmp(name, "pgsteal_kswapd_dma32") == 0) pgsteal_kswapd_dma32 = value;
 112                 else if(!pgsteal_kswapd_normal && strcmp(name, "pgsteal_kswapd_normal") == 0) pgsteal_kswapd_normal = value;
 113                 else if(!pgsteal_kswapd_movable && strcmp(name, "pgsteal_kswapd_movable") == 0) pgsteal_kswapd_movable = value;
 114                 else if(!pgsteal_direct_dma && strcmp(name, "pgsteal_direct_dma") == 0) pgsteal_direct_dma = value;
 115                 else if(!pgsteal_direct_dma32 && strcmp(name, "pgsteal_direct_dma32") == 0) pgsteal_direct_dma32 = value;
 116                 else if(!pgsteal_direct_normal && strcmp(name, "pgsteal_direct_normal") == 0) pgsteal_direct_normal = value;
 117                 else if(!pgsteal_direct_movable && strcmp(name, "pgsteal_direct_movable") == 0) pgsteal_direct_movable = value;
 118                 else if(!pgscan_kswapd_dma && strcmp(name, "pgscan_kswapd_dma") == 0) pgscan_kswapd_dma = value;
 119                 else if(!pgscan_kswapd_dma32 && strcmp(name, "pgscan_kswapd_dma32") == 0) pgscan_kswapd_dma32 = value;
 120                 else if(!pgscan_kswapd_normal && strcmp(name, "pgscan_kswapd_normal") == 0) pgscan_kswapd_normal = value;
 121                 else if(!pgscan_kswapd_movable && strcmp(name, "pgscan_kswapd_movable") == 0) pgscan_kswapd_movable = value;
 122                 else if(!pgscan_direct_dma && strcmp(name, "pgscan_direct_dma") == 0) pgscan_direct_dma = value;
 123                 else if(!pgscan_direct_dma32 && strcmp(name, "pgscan_direct_dma32") == 0) pgscan_direct_dma32 = value;
 124                 else if(!pgscan_direct_normal && strcmp(name, "pgscan_direct_normal") == 0) pgscan_direct_normal = value;
 125                 else if(!pgscan_direct_movable && strcmp(name, "pgscan_direct_movable") == 0) pgscan_direct_movable = value;
 126                 else if(!pginodesteal && strcmp(name, "pginodesteal") == 0) pginodesteal = value;
 127                 else if(!slabs_scanned && strcmp(name, "slabs_scanned") == 0) slabs_scanned = value;
 128                 else if(!kswapd_inodesteal && strcmp(name, "kswapd_inodesteal") == 0) kswapd_inodesteal = value;
 129                 else if(!kswapd_low_wmark_hit_quickly && strcmp(name, "kswapd_low_wmark_hit_quickly") == 0) kswapd_low_wmark_hit_quickly = value;
 130                 else if(!kswapd_high_wmark_hit_quickly && strcmp(name, "kswapd_high_wmark_hit_quickly") == 0) kswapd_high_wmark_hit_quickly = value;
 131                 else if(!kswapd_skip_congestion_wait && strcmp(name, "kswapd_skip_congestion_wait") == 0) kswapd_skip_congestion_wait = value;
 132                 else if(!pageoutrun && strcmp(name, "pageoutrun") == 0) pageoutrun = value;
 133                 else if(!allocstall && strcmp(name, "allocstall") == 0) allocstall = value;
 134                 else if(!pgrotated && strcmp(name, "pgrotated") == 0) pgrotated = value;
 135                 else if(!compact_blocks_moved && strcmp(name, "compact_blocks_moved") == 0) compact_blocks_moved = value;
 136                 else if(!compact_pages_moved && strcmp(name, "compact_pages_moved") == 0) compact_pages_moved = value;
 137                 else if(!compact_pagemigrate_failed && strcmp(name, "compact_pagemigrate_failed") == 0) compact_pagemigrate_failed = value;
 138                 else if(!compact_stall && strcmp(name, "compact_stall") == 0) compact_stall = value;
 139                 else if(!compact_fail && strcmp(name, "compact_fail") == 0) compact_fail = value;
 140                 else if(!compact_success && strcmp(name, "compact_success") == 0) compact_success = value;
 141                 else if(!htlb_buddy_alloc_success && strcmp(name, "htlb_buddy_alloc_success") == 0) htlb_buddy_alloc_success = value;
 142                 else if(!htlb_buddy_alloc_fail && strcmp(name, "htlb_buddy_alloc_fail") == 0) htlb_buddy_alloc_fail = value;
 143                 else if(!unevictable_pgs_culled && strcmp(name, "unevictable_pgs_culled") == 0) unevictable_pgs_culled = value;
 144                 else if(!unevictable_pgs_scanned && strcmp(name, "unevictable_pgs_scanned") == 0) unevictable_pgs_scanned = value;
 145                 else if(!unevictable_pgs_rescued && strcmp(name, "unevictable_pgs_rescued") == 0) unevictable_pgs_rescued = value;
 146                 else if(!unevictable_pgs_mlocked && strcmp(name, "unevictable_pgs_mlocked") == 0) unevictable_pgs_mlocked = value;
 147                 else if(!unevictable_pgs_munlocked && strcmp(name, "unevictable_pgs_munlocked") == 0) unevictable_pgs_munlocked = value;
 148                 else if(!unevictable_pgs_cleared && strcmp(name, "unevictable_pgs_cleared") == 0) unevictable_pgs_cleared = value;
 149                 else if(!unevictable_pgs_stranded && strcmp(name, "unevictable_pgs_stranded") == 0) unevictable_pgs_stranded = value;
 150                 else if(!unevictable_pgs_mlockfreed && strcmp(name, "unevictable_pgs_mlockfreed") == 0) unevictable_pgs_mlockfreed = value;
 151                 else if(!thp_fault_alloc && strcmp(name, "thp_fault_alloc") == 0) thp_fault_alloc = value;
 152                 else if(!thp_fault_fallback && strcmp(name, "thp_fault_fallback") == 0) thp_fault_fallback = value;
 153                 else if(!thp_collapse_alloc && strcmp(name, "thp_collapse_alloc") == 0) thp_collapse_alloc = value;
 154                 else if(!thp_collapse_alloc_failed && strcmp(name, "thp_collapse_alloc_failed") == 0) thp_collapse_alloc_failed = value;
 155                 else if(!thp_split && strcmp(name, "thp_split") == 0) thp_split = value;
 156         }
 157
 158         RRDSET *st;
 159
 160         // --------------------------------------------------------------------
 161
 162         if(do_swapio) {
 163                 st = rrdset_find("system.swapio");
 164                 if(!st) {
 165                         st = rrdset_create("system", "swapio", NULL, "mem", "Swap I/O", "kilobytes/s", 250, update_every, RRDSET_TYPE_AREA);
 166
 167                         rrddim_add(st, "in",  NULL, sysconf(_SC_PAGESIZE), 1024 * update_every, RRDDIM_INCREMENTAL);
 168                         rrddim_add(st, "out", NULL, -sysconf(_SC_PAGESIZE), 1024 * update_every, RRDDIM_INCREMENTAL);
 169                 }
 170                 else rrdset_next(st);
 171
 172                 rrddim_set(st, "in", pswpin);
 173                 rrddim_set(st, "out", pswpout);
 174                 rrdset_done(st);
 175         }
 176
 177         // --------------------------------------------------------------------
 178
 179         if(do_io) {
 180                 st = rrdset_find("system.io");
 181                 if(!st) {
 182                         st = rrdset_create("system", "io", NULL, "disk", "Disk I/O", "kilobytes/s", 150, update_every, RRDSET_TYPE_AREA);
 183
 184                         rrddim_add(st, "in",  NULL,  1, 1 * update_every, RRDDIM_INCREMENTAL);
 185                         rrddim_add(st, "out", NULL, -1, 1 * update_every, RRDDIM_INCREMENTAL);
 186                 }
 187                 else rrdset_next(st);
 188
 189                 rrddim_set(st, "in", pgpgin);
 190                 rrddim_set(st, "out", pgpgout);
 191                 rrdset_done(st);
 192         }
 193
 194         // --------------------------------------------------------------------
 195
 196         if(do_pgfaults) {
 197                 st = rrdset_find("system.pgfaults");
 198                 if(!st) {
 199                         st = rrdset_create("system", "pgfaults", NULL, "mem", "Memory Page Faults", "page faults/s", 500, update_every, RRDSET_TYPE_LINE);
 200                         st->isdetail = 1;
 201
 202                         rrddim_add(st, "minor",  NULL,  1, 1 * update_every, RRDDIM_INCREMENTAL);
 203                         rrddim_add(st, "major", NULL, -1, 1 * update_every, RRDDIM_INCREMENTAL);
 204                 }
 205                 else rrdset_next(st);
 206
 207                 rrddim_set(st, "minor", pgfault);
 208                 rrddim_set(st, "major", pgmajfault);
 209                 rrdset_done(st);
 210         }
 211
 212         return 0;
 213 }
 214