src/proc_stat.c

   1 #include "common.h"
   2
   3 int do_proc_stat(int update_every, usec_t dt) {
   4     (void)dt;
   5
   6     static procfile *ff = NULL;
   7     static int do_cpu = -1, do_cpu_cores = -1, do_interrupts = -1, do_context = -1, do_forks = -1, do_processes = -1;
   8     static uint32_t hash_intr, hash_ctxt, hash_processes, hash_procs_running, hash_procs_blocked;
   9
  10     if(unlikely(do_cpu == -1)) {
  11         do_cpu          = config_get_boolean("plugin:proc:/proc/stat", "cpu utilization", 1);
  12         do_cpu_cores    = config_get_boolean("plugin:proc:/proc/stat", "per cpu core utilization", 1);
  13         do_interrupts   = config_get_boolean("plugin:proc:/proc/stat", "cpu interrupts", 1);
  14         do_context      = config_get_boolean("plugin:proc:/proc/stat", "context switches", 1);
  15         do_forks        = config_get_boolean("plugin:proc:/proc/stat", "processes started", 1);
  16         do_processes    = config_get_boolean("plugin:proc:/proc/stat", "processes running", 1);
  17
  18         hash_intr = simple_hash("intr");
  19         hash_ctxt = simple_hash("ctxt");
  20         hash_processes = simple_hash("processes");
  21         hash_procs_running = simple_hash("procs_running");
  22         hash_procs_blocked = simple_hash("procs_blocked");
  23     }
  24
  25     if(unlikely(!ff)) {
  26         char filename[FILENAME_MAX + 1];
  27         snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, "/proc/stat");
  28         ff = procfile_open(config_get("plugin:proc:/proc/stat", "filename to monitor", filename), " \t:", PROCFILE_FLAG_DEFAULT);
  29         if(unlikely(!ff)) return 1;
  30     }
  31
  32     ff = procfile_readall(ff);
  33     if(unlikely(!ff)) return 0; // we return 0, so that we will retry to open it next time
  34
  35     size_t lines = procfile_lines(ff), l;
  36     size_t words;
  37
  38     unsigned long long processes = 0, running = 0 , blocked = 0;
  39     RRDSET *st;
  40
  41     for(l = 0; l < lines ;l++) {
  42         char *row_key = procfile_lineword(ff, l, 0);
  43         uint32_t hash = simple_hash(row_key);
  44
  45         // faster strncmp(row_key, "cpu", 3) == 0
  46         if(likely(row_key[0] == 'c' && row_key[1] == 'p' && row_key[2] == 'u')) {
  47             words = procfile_linewords(ff, l);
  48             if(unlikely(words < 9)) {
  49                 error("Cannot read /proc/stat cpu line. Expected 9 params, read %zu.", words);
  50                 continue;
  51             }
  52
  53             char *id;
  54             unsigned long long user = 0, nice = 0, system = 0, idle = 0, iowait = 0, irq = 0, softirq = 0, steal = 0, guest = 0, guest_nice = 0;
  55
  56             id          = row_key;
  57             user        = str2ull(procfile_lineword(ff, l, 1));
  58             nice        = str2ull(procfile_lineword(ff, l, 2));
  59             system      = str2ull(procfile_lineword(ff, l, 3));
  60             idle        = str2ull(procfile_lineword(ff, l, 4));
  61             iowait      = str2ull(procfile_lineword(ff, l, 5));
  62             irq         = str2ull(procfile_lineword(ff, l, 6));
  63             softirq     = str2ull(procfile_lineword(ff, l, 7));
  64             steal       = str2ull(procfile_lineword(ff, l, 8));
  65
  66             guest       = str2ull(procfile_lineword(ff, l, 9));
  67             user -= guest;
  68
  69             guest_nice  = str2ull(procfile_lineword(ff, l, 10));
  70             nice -= guest_nice;
  71
  72             char *title, *type, *context, *family;
  73             long priority;
  74             int isthistotal;
  75
  76             if(unlikely(strcmp(id, "cpu")) == 0) {
  77                 title = "Total CPU utilization";
  78                 type = "system";
  79                 context = "system.cpu";
  80                 family = id;
  81                 priority = 100;
  82                 isthistotal = 1;
  83             }
  84             else {
  85                 title = "Core utilization";
  86                 type = "cpu";
  87                 context = "cpu.cpu";
  88                 family = "utilization";
  89                 priority = 1000;
  90                 isthistotal = 0;
  91             }
  92
  93             if(likely((isthistotal && do_cpu) || (!isthistotal && do_cpu_cores))) {
  94                 st = rrdset_find_bytype_localhost(type, id);
  95                 if(unlikely(!st)) {
  96                     st = rrdset_create(type, id, NULL, family, context, title, "percentage", priority, update_every, RRDSET_TYPE_STACKED);
  97
  98                     long multiplier = 1;
  99                     long divisor = 1; // sysconf(_SC_CLK_TCK);
 100
 101                     rrddim_add(st, "guest_nice", NULL, multiplier, divisor, RRDDIM_ALGORITHM_PCENT_OVER_DIFF_TOTAL);
 102                     rrddim_add(st, "guest", NULL, multiplier, divisor, RRDDIM_ALGORITHM_PCENT_OVER_DIFF_TOTAL);
 103                     rrddim_add(st, "steal", NULL, multiplier, divisor, RRDDIM_ALGORITHM_PCENT_OVER_DIFF_TOTAL);
 104                     rrddim_add(st, "softirq", NULL, multiplier, divisor, RRDDIM_ALGORITHM_PCENT_OVER_DIFF_TOTAL);
 105                     rrddim_add(st, "irq", NULL, multiplier, divisor, RRDDIM_ALGORITHM_PCENT_OVER_DIFF_TOTAL);
 106                     rrddim_add(st, "user", NULL, multiplier, divisor, RRDDIM_ALGORITHM_PCENT_OVER_DIFF_TOTAL);
 107                     rrddim_add(st, "system", NULL, multiplier, divisor, RRDDIM_ALGORITHM_PCENT_OVER_DIFF_TOTAL);
 108                     rrddim_add(st, "nice", NULL, multiplier, divisor, RRDDIM_ALGORITHM_PCENT_OVER_DIFF_TOTAL);
 109                     rrddim_add(st, "iowait", NULL, multiplier, divisor, RRDDIM_ALGORITHM_PCENT_OVER_DIFF_TOTAL);
 110
 111                     rrddim_add(st, "idle", NULL, multiplier, divisor, RRDDIM_ALGORITHM_PCENT_OVER_DIFF_TOTAL);
 112                     rrddim_hide(st, "idle");
 113                 }
 114                 else rrdset_next(st);
 115
 116                 rrddim_set(st, "user", user);
 117                 rrddim_set(st, "nice", nice);
 118                 rrddim_set(st, "system", system);
 119                 rrddim_set(st, "idle", idle);
 120                 rrddim_set(st, "iowait", iowait);
 121                 rrddim_set(st, "irq", irq);
 122                 rrddim_set(st, "softirq", softirq);
 123                 rrddim_set(st, "steal", steal);
 124                 rrddim_set(st, "guest", guest);
 125                 rrddim_set(st, "guest_nice", guest_nice);
 126                 rrdset_done(st);
 127             }
 128         }
 129         else if(unlikely(hash == hash_intr && strcmp(row_key, "intr") == 0)) {
 130             unsigned long long value = str2ull(procfile_lineword(ff, l, 1));
 131
 132             // --------------------------------------------------------------------
 133
 134             if(likely(do_interrupts)) {
 135                 st = rrdset_find_bytype_localhost("system", "intr");
 136                 if(unlikely(!st)) {
 137                     st = rrdset_create("system", "intr", NULL, "interrupts", NULL, "CPU Interrupts", "interrupts/s", 900, update_every, RRDSET_TYPE_LINE);
 138                     st->isdetail = 1;
 139
 140                     rrddim_add(st, "interrupts", NULL, 1, 1, RRDDIM_ALGORITHM_INCREMENTAL);
 141                 }
 142                 else rrdset_next(st);
 143
 144                 rrddim_set(st, "interrupts", value);
 145                 rrdset_done(st);
 146             }
 147         }
 148         else if(unlikely(hash == hash_ctxt && strcmp(row_key, "ctxt") == 0)) {
 149             unsigned long long value = str2ull(procfile_lineword(ff, l, 1));
 150
 151             // --------------------------------------------------------------------
 152
 153             if(likely(do_context)) {
 154                 st = rrdset_find_bytype_localhost("system", "ctxt");
 155                 if(unlikely(!st)) {
 156                     st = rrdset_create("system", "ctxt", NULL, "processes", NULL, "CPU Context Switches", "context switches/s", 800, update_every, RRDSET_TYPE_LINE);
 157
 158                     rrddim_add(st, "switches", NULL, 1, 1, RRDDIM_ALGORITHM_INCREMENTAL);
 159                 }
 160                 else rrdset_next(st);
 161
 162                 rrddim_set(st, "switches", value);
 163                 rrdset_done(st);
 164             }
 165         }
 166         else if(unlikely(hash == hash_processes && !processes && strcmp(row_key, "processes") == 0)) {
 167             processes = str2ull(procfile_lineword(ff, l, 1));
 168         }
 169         else if(unlikely(hash == hash_procs_running && !running && strcmp(row_key, "procs_running") == 0)) {
 170             running = str2ull(procfile_lineword(ff, l, 1));
 171         }
 172         else if(unlikely(hash == hash_procs_blocked && !blocked && strcmp(row_key, "procs_blocked") == 0)) {
 173             blocked = str2ull(procfile_lineword(ff, l, 1));
 174         }
 175     }
 176
 177     // --------------------------------------------------------------------
 178
 179     if(likely(do_forks)) {
 180         st = rrdset_find_bytype_localhost("system", "forks");
 181         if(unlikely(!st)) {
 182             st = rrdset_create("system", "forks", NULL, "processes", NULL, "Started Processes", "processes/s", 700, update_every, RRDSET_TYPE_LINE);
 183             st->isdetail = 1;
 184
 185             rrddim_add(st, "started", NULL, 1, 1, RRDDIM_ALGORITHM_INCREMENTAL);
 186         }
 187         else rrdset_next(st);
 188
 189         rrddim_set(st, "started", processes);
 190         rrdset_done(st);
 191     }
 192
 193     // --------------------------------------------------------------------
 194
 195     if(likely(do_processes)) {
 196         st = rrdset_find_bytype_localhost("system", "processes");
 197         if(unlikely(!st)) {
 198             st = rrdset_create("system", "processes", NULL, "processes", NULL, "System Processes", "processes", 600, update_every, RRDSET_TYPE_LINE);
 199
 200             rrddim_add(st, "running", NULL, 1, 1, RRDDIM_ALGORITHM_ABSOLUTE);
 201             rrddim_add(st, "blocked", NULL, -1, 1, RRDDIM_ALGORITHM_ABSOLUTE);
 202         }
 203         else rrdset_next(st);
 204
 205         rrddim_set(st, "running", running);
 206         rrddim_set(st, "blocked", blocked);
 207         rrdset_done(st);
 208     }
 209
 210     return 0;
 211 }