src/proc_net_dev.c

   1 #include "common.h"
   2
   3 struct netdev {
   4     char *name;
   5     uint32_t hash;
   6     size_t len;
   7
   8     // flags
   9     int configured;
  10     int enabled;
  11
  12     int do_bandwidth;
  13     int do_packets;
  14     int do_errors;
  15     int do_drops;
  16     int do_fifo;
  17     int do_compressed;
  18     int do_events;
  19
  20     // data collected
  21     unsigned long long rbytes;
  22     unsigned long long rpackets;
  23     unsigned long long rerrors;
  24     unsigned long long rdrops;
  25     unsigned long long rfifo;
  26     unsigned long long rframe;
  27     unsigned long long rcompressed;
  28     unsigned long long rmulticast;
  29
  30     unsigned long long tbytes;
  31     unsigned long long tpackets;
  32     unsigned long long terrors;
  33     unsigned long long tdrops;
  34     unsigned long long tfifo;
  35     unsigned long long tcollisions;
  36     unsigned long long tcarrier;
  37     unsigned long long tcompressed;
  38
  39     // charts
  40     RRDSET *st_bandwidth;
  41     RRDSET *st_packets;
  42     RRDSET *st_errors;
  43     RRDSET *st_drops;
  44     RRDSET *st_fifo;
  45     RRDSET *st_compressed;
  46     RRDSET *st_events;
  47
  48     // dimensions
  49     RRDDIM *rd_rbytes;
  50     RRDDIM *rd_rpackets;
  51     RRDDIM *rd_rerrors;
  52     RRDDIM *rd_rdrops;
  53     RRDDIM *rd_rfifo;
  54     RRDDIM *rd_rframe;
  55     RRDDIM *rd_rcompressed;
  56     RRDDIM *rd_rmulticast;
  57
  58     RRDDIM *rd_tbytes;
  59     RRDDIM *rd_tpackets;
  60     RRDDIM *rd_terrors;
  61     RRDDIM *rd_tdrops;
  62     RRDDIM *rd_tfifo;
  63     RRDDIM *rd_tcollisions;
  64     RRDDIM *rd_tcarrier;
  65     RRDDIM *rd_tcompressed;
  66
  67     struct netdev *next;
  68 };
  69
  70 static struct netdev *netdev_root = NULL;
  71
  72 static struct netdev *get_netdev(const char *name) {
  73     static struct netdev *last = NULL;
  74     struct netdev *d;
  75
  76     uint32_t hash = simple_hash(name);
  77
  78     // search it, from the last position to the end
  79     for(d = last ; d ; d = d->next) {
  80         if(unlikely(hash == d->hash && !strcmp(name, d->name))) {
  81             last = d->next;
  82             return d;
  83         }
  84     }
  85
  86     // search it from the beginning to the last position we used
  87     for(d = netdev_root ; d != last ; d = d->next) {
  88         if(unlikely(hash == d->hash && !strcmp(name, d->name))) {
  89             last = d->next;
  90             return d;
  91         }
  92     }
  93
  94     // create a new one
  95     d = callocz(1, sizeof(struct netdev));
  96     d->name = strdupz(name);
  97     d->hash = simple_hash(d->name);
  98     d->len = strlen(d->name);
  99
 100     // link it to the end
 101     if(netdev_root) {
 102         struct netdev *e;
 103         for(e = netdev_root; e->next ; e = e->next) ;
 104         e->next = d;
 105     }
 106     else
 107         netdev_root = d;
 108
 109     return d;
 110 }
 111
 112 int do_proc_net_dev(int update_every, usec_t dt) {
 113     (void)dt;
 114     static SIMPLE_PATTERN *disabled_list = NULL;
 115     static procfile *ff = NULL;
 116     static int enable_new_interfaces = -1;
 117     static int do_bandwidth = -1, do_packets = -1, do_errors = -1, do_drops = -1, do_fifo = -1, do_compressed = -1, do_events = -1;
 118
 119     if(unlikely(enable_new_interfaces == -1)) {
 120         enable_new_interfaces = config_get_boolean_ondemand("plugin:proc:/proc/net/dev", "enable new interfaces detected at runtime", CONFIG_ONDEMAND_ONDEMAND);
 121
 122         do_bandwidth    = config_get_boolean_ondemand("plugin:proc:/proc/net/dev", "bandwidth for all interfaces", CONFIG_ONDEMAND_ONDEMAND);
 123         do_packets      = config_get_boolean_ondemand("plugin:proc:/proc/net/dev", "packets for all interfaces", CONFIG_ONDEMAND_ONDEMAND);
 124         do_errors       = config_get_boolean_ondemand("plugin:proc:/proc/net/dev", "errors for all interfaces", CONFIG_ONDEMAND_ONDEMAND);
 125         do_drops        = config_get_boolean_ondemand("plugin:proc:/proc/net/dev", "drops for all interfaces", CONFIG_ONDEMAND_ONDEMAND);
 126         do_fifo         = config_get_boolean_ondemand("plugin:proc:/proc/net/dev", "fifo for all interfaces", CONFIG_ONDEMAND_ONDEMAND);
 127         do_compressed   = config_get_boolean_ondemand("plugin:proc:/proc/net/dev", "compressed packets for all interfaces", CONFIG_ONDEMAND_ONDEMAND);
 128         do_events       = config_get_boolean_ondemand("plugin:proc:/proc/net/dev", "frames, collisions, carrier counters for all interfaces", CONFIG_ONDEMAND_ONDEMAND);
 129
 130         disabled_list = simple_pattern_create(
 131                 config_get("plugin:proc:/proc/net/dev", "disable by default interfaces matching", "lo fireqos* *-ifb")
 132                 , SIMPLE_PATTERN_EXACT);
 133     }
 134
 135     if(unlikely(!ff)) {
 136         char filename[FILENAME_MAX + 1];
 137         snprintfz(filename, FILENAME_MAX, "%s%s", global_host_prefix, "/proc/net/dev");
 138         ff = procfile_open(config_get("plugin:proc:/proc/net/dev", "filename to monitor", filename), " \t,:|", PROCFILE_FLAG_DEFAULT);
 139         if(unlikely(!ff)) return 1;
 140     }
 141
 142     ff = procfile_readall(ff);
 143     if(unlikely(!ff)) return 0; // we return 0, so that we will retry to open it next time
 144
 145     size_t lines = procfile_lines(ff), l;
 146     for(l = 2; l < lines ;l++) {
 147         // require 17 words on each line
 148         if(unlikely(procfile_linewords(ff, l) < 17)) continue;
 149
 150         struct netdev *d = get_netdev(procfile_lineword(ff, l, 0));
 151
 152         if(unlikely(!d->configured)) {
 153             // this is the first time we see this interface
 154
 155             // remember we configured it
 156             d->configured = 1;
 157
 158             d->enabled = enable_new_interfaces;
 159
 160             if(d->enabled)
 161                 d->enabled = !simple_pattern_matches(disabled_list, d->name);
 162
 163             char var_name[512 + 1];
 164             snprintfz(var_name, 512, "plugin:proc:/proc/net/dev:%s", d->name);
 165             d->enabled = config_get_boolean_ondemand(var_name, "enabled", d->enabled);
 166
 167             if(d->enabled == CONFIG_ONDEMAND_NO)
 168                 continue;
 169
 170             d->do_bandwidth = config_get_boolean_ondemand(var_name, "bandwidth", do_bandwidth);
 171             d->do_packets = config_get_boolean_ondemand(var_name, "packets", do_packets);
 172             d->do_errors = config_get_boolean_ondemand(var_name, "errors", do_errors);
 173             d->do_drops = config_get_boolean_ondemand(var_name, "drops", do_drops);
 174             d->do_fifo = config_get_boolean_ondemand(var_name, "fifo", do_fifo);
 175             d->do_compressed = config_get_boolean_ondemand(var_name, "compressed", do_compressed);
 176             d->do_events = config_get_boolean_ondemand(var_name, "events", do_events);
 177         }
 178
 179         if(unlikely(!d->enabled))
 180             continue;
 181
 182         d->rbytes      = str2ull(procfile_lineword(ff, l, 1));
 183         d->rpackets    = str2ull(procfile_lineword(ff, l, 2));
 184         d->rerrors     = str2ull(procfile_lineword(ff, l, 3));
 185         d->rdrops      = str2ull(procfile_lineword(ff, l, 4));
 186         d->rfifo       = str2ull(procfile_lineword(ff, l, 5));
 187         d->rframe      = str2ull(procfile_lineword(ff, l, 6));
 188         d->rcompressed = str2ull(procfile_lineword(ff, l, 7));
 189         d->rmulticast  = str2ull(procfile_lineword(ff, l, 8));
 190
 191         d->tbytes      = str2ull(procfile_lineword(ff, l, 9));
 192         d->tpackets    = str2ull(procfile_lineword(ff, l, 10));
 193         d->terrors     = str2ull(procfile_lineword(ff, l, 11));
 194         d->tdrops      = str2ull(procfile_lineword(ff, l, 12));
 195         d->tfifo       = str2ull(procfile_lineword(ff, l, 13));
 196         d->tcollisions = str2ull(procfile_lineword(ff, l, 14));
 197         d->tcarrier    = str2ull(procfile_lineword(ff, l, 15));
 198         d->tcompressed = str2ull(procfile_lineword(ff, l, 16));
 199
 200         // --------------------------------------------------------------------
 201
 202         if(unlikely((d->do_bandwidth == CONFIG_ONDEMAND_ONDEMAND && (d->rbytes || d->tbytes))))
 203             d->do_bandwidth = CONFIG_ONDEMAND_YES;
 204
 205         if(d->do_bandwidth == CONFIG_ONDEMAND_YES) {
 206             if(unlikely(!d->st_bandwidth)) {
 207                 d->st_bandwidth = rrdset_find_bytype("net", d->name);
 208
 209                 if(!d->st_bandwidth)
 210                     d->st_bandwidth = rrdset_create("net", d->name, NULL, d->name, "net.net", "Bandwidth", "kilobits/s", 7000, update_every, RRDSET_TYPE_AREA);
 211
 212                 d->rd_rbytes = rrddim_add(d->st_bandwidth, "received", NULL, 8, 1024, RRDDIM_INCREMENTAL);
 213                 d->rd_tbytes = rrddim_add(d->st_bandwidth, "sent", NULL, -8, 1024, RRDDIM_INCREMENTAL);
 214             }
 215             else rrdset_next(d->st_bandwidth);
 216
 217             rrddim_set_by_pointer(d->st_bandwidth, d->rd_rbytes, d->rbytes);
 218             rrddim_set_by_pointer(d->st_bandwidth, d->rd_tbytes, d->tbytes);
 219             rrdset_done(d->st_bandwidth);
 220         }
 221
 222         // --------------------------------------------------------------------
 223
 224         if(unlikely((d->do_packets == CONFIG_ONDEMAND_ONDEMAND && (d->rpackets || d->tpackets || d->rmulticast))))
 225             d->do_packets = CONFIG_ONDEMAND_YES;
 226
 227         if(d->do_packets == CONFIG_ONDEMAND_YES) {
 228             if(unlikely(!d->st_packets)) {
 229                 d->st_packets = rrdset_find_bytype("net_packets", d->name);
 230
 231                 if(!d->st_packets)
 232                     d->st_packets = rrdset_create("net_packets", d->name, NULL, d->name, "net.packets", "Packets", "packets/s", 7001, update_every, RRDSET_TYPE_LINE);
 233
 234                 d->st_packets->isdetail = 1;
 235
 236                 d->rd_rpackets = rrddim_add(d->st_packets, "received", NULL, 1, 1, RRDDIM_INCREMENTAL);
 237                 d->rd_tpackets = rrddim_add(d->st_packets, "sent", NULL, -1, 1, RRDDIM_INCREMENTAL);
 238                 d->rd_rmulticast = rrddim_add(d->st_packets, "multicast", NULL, 1, 1, RRDDIM_INCREMENTAL);
 239             }
 240             else rrdset_next(d->st_packets);
 241
 242             rrddim_set_by_pointer(d->st_packets, d->rd_rpackets, d->rpackets);
 243             rrddim_set_by_pointer(d->st_packets, d->rd_tpackets, d->tpackets);
 244             rrddim_set_by_pointer(d->st_packets, d->rd_rmulticast, d->rmulticast);
 245             rrdset_done(d->st_packets);
 246         }
 247
 248         // --------------------------------------------------------------------
 249
 250         if(unlikely((d->do_errors == CONFIG_ONDEMAND_ONDEMAND && (d->rerrors || d->terrors))))
 251             d->do_errors = CONFIG_ONDEMAND_YES;
 252
 253         if(d->do_errors == CONFIG_ONDEMAND_YES) {
 254             if(unlikely(!d->st_errors)) {
 255                 d->st_errors = rrdset_find_bytype("net_errors", d->name);
 256
 257                 if(!d->st_errors)
 258                     d->st_errors = rrdset_create("net_errors", d->name, NULL, d->name, "net.errors", "Interface Errors", "errors/s", 7002, update_every, RRDSET_TYPE_LINE);
 259
 260                 d->st_errors->isdetail = 1;
 261
 262                 d->rd_rerrors = rrddim_add(d->st_errors, "inbound", NULL, 1, 1, RRDDIM_INCREMENTAL);
 263                 d->rd_terrors = rrddim_add(d->st_errors, "outbound", NULL, -1, 1, RRDDIM_INCREMENTAL);
 264             }
 265             else rrdset_next(d->st_errors);
 266
 267             rrddim_set_by_pointer(d->st_errors, d->rd_rerrors, d->rerrors);
 268             rrddim_set_by_pointer(d->st_errors, d->rd_terrors, d->terrors);
 269             rrdset_done(d->st_errors);
 270         }
 271
 272         // --------------------------------------------------------------------
 273
 274         if(unlikely((d->do_drops == CONFIG_ONDEMAND_ONDEMAND && (d->rdrops || d->tdrops))))
 275             d->do_drops = CONFIG_ONDEMAND_YES;
 276
 277         if(d->do_drops == CONFIG_ONDEMAND_YES) {
 278             if(unlikely(!d->st_drops)) {
 279                 d->st_drops = rrdset_find_bytype("net_drops", d->name);
 280
 281                 if(!d->st_drops)
 282                     d->st_drops = rrdset_create("net_drops", d->name, NULL, d->name, "net.drops", "Interface Drops", "drops/s", 7003, update_every, RRDSET_TYPE_LINE);
 283
 284                 d->st_drops->isdetail = 1;
 285
 286                 d->rd_rdrops = rrddim_add(d->st_drops, "inbound", NULL, 1, 1, RRDDIM_INCREMENTAL);
 287                 d->rd_tdrops = rrddim_add(d->st_drops, "outbound", NULL, -1, 1, RRDDIM_INCREMENTAL);
 288             }
 289             else rrdset_next(d->st_drops);
 290
 291             rrddim_set_by_pointer(d->st_drops, d->rd_rdrops, d->rdrops);
 292             rrddim_set_by_pointer(d->st_drops, d->rd_tdrops, d->tdrops);
 293             rrdset_done(d->st_drops);
 294         }
 295
 296         // --------------------------------------------------------------------
 297
 298         if(unlikely((d->do_fifo == CONFIG_ONDEMAND_ONDEMAND && (d->rfifo || d->tfifo))))
 299             d->do_fifo = CONFIG_ONDEMAND_YES;
 300
 301         if(d->do_fifo == CONFIG_ONDEMAND_YES) {
 302             if(unlikely(!d->st_fifo)) {
 303                 d->st_fifo = rrdset_find_bytype("net_fifo", d->name);
 304
 305                 if(!d->st_fifo)
 306                     d->st_fifo = rrdset_create("net_fifo", d->name, NULL, d->name, "net.fifo", "Interface FIFO Buffer Errors", "errors", 7004, update_every, RRDSET_TYPE_LINE);
 307
 308                 d->st_fifo->isdetail = 1;
 309
 310                 d->rd_rfifo = rrddim_add(d->st_fifo, "receive", NULL, 1, 1, RRDDIM_INCREMENTAL);
 311                 d->rd_tfifo = rrddim_add(d->st_fifo, "transmit", NULL, -1, 1, RRDDIM_INCREMENTAL);
 312             }
 313             else rrdset_next(d->st_fifo);
 314
 315             rrddim_set_by_pointer(d->st_fifo, d->rd_rfifo, d->rfifo);
 316             rrddim_set_by_pointer(d->st_fifo, d->rd_tfifo, d->tfifo);
 317             rrdset_done(d->st_fifo);
 318         }
 319
 320         // --------------------------------------------------------------------
 321
 322         if(unlikely((d->do_compressed == CONFIG_ONDEMAND_ONDEMAND && (d->rcompressed || d->tcompressed))))
 323             d->do_compressed = CONFIG_ONDEMAND_YES;
 324
 325         if(d->do_compressed == CONFIG_ONDEMAND_YES) {
 326             if(unlikely(!d->st_compressed)) {
 327                 d->st_compressed = rrdset_find_bytype("net_compressed", d->name);
 328                 if(!d->st_compressed)
 329                     d->st_compressed = rrdset_create("net_compressed", d->name, NULL, d->name, "net.compressed", "Compressed Packets", "packets/s", 7005, update_every, RRDSET_TYPE_LINE);
 330
 331                 d->st_compressed->isdetail = 1;
 332
 333                 d->rd_rcompressed = rrddim_add(d->st_compressed, "received", NULL, 1, 1, RRDDIM_INCREMENTAL);
 334                 d->rd_tcompressed = rrddim_add(d->st_compressed, "sent", NULL, -1, 1, RRDDIM_INCREMENTAL);
 335             }
 336             else rrdset_next(d->st_compressed);
 337
 338             rrddim_set_by_pointer(d->st_compressed, d->rd_rcompressed, d->rcompressed);
 339             rrddim_set_by_pointer(d->st_compressed, d->rd_tcompressed, d->tcompressed);
 340             rrdset_done(d->st_compressed);
 341         }
 342
 343         // --------------------------------------------------------------------
 344
 345         if(unlikely((d->do_events == CONFIG_ONDEMAND_ONDEMAND && (d->rframe || d->tcollisions || d->tcarrier))))
 346             d->do_events = CONFIG_ONDEMAND_YES;
 347
 348         if(d->do_events == CONFIG_ONDEMAND_YES) {
 349             if(unlikely(!d->st_events)) {
 350                 d->st_events = rrdset_find_bytype("net_events", d->name);
 351                 if(!d->st_events)
 352                     d->st_events = rrdset_create("net_events", d->name, NULL, d->name, "net.events", "Network Interface Events", "events/s", 7006, update_every, RRDSET_TYPE_LINE);
 353
 354                 d->st_events->isdetail = 1;
 355
 356                 d->rd_rframe      = rrddim_add(d->st_events, "frames", NULL, 1, 1, RRDDIM_INCREMENTAL);
 357                 d->rd_tcollisions = rrddim_add(d->st_events, "collisions", NULL, -1, 1, RRDDIM_INCREMENTAL);
 358                 d->rd_tcarrier    = rrddim_add(d->st_events, "carrier", NULL, -1, 1, RRDDIM_INCREMENTAL);
 359             }
 360             else rrdset_next(d->st_events);
 361
 362             rrddim_set_by_pointer(d->st_events, d->rd_rframe,      d->rframe);
 363             rrddim_set_by_pointer(d->st_events, d->rd_tcollisions, d->tcollisions);
 364             rrddim_set_by_pointer(d->st_events, d->rd_tcarrier,    d->tcarrier);
 365             rrdset_done(d->st_events);
 366         }
 367     }
 368
 369     return 0;
 370 }