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
 115     static procfile *ff = NULL;
 116     static int enable_new_interfaces = -1, enable_ifb_interfaces = -1, enable_veth_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         enable_ifb_interfaces = config_get_boolean_ondemand("plugin:proc:/proc/net/dev", "enable ifb interfaces", CONFIG_ONDEMAND_NO);
 122         enable_veth_interfaces = config_get_boolean_ondemand("plugin:proc:/proc/net/dev", "enable veth interfaces", enable_new_interfaces);
 123
 124         do_bandwidth    = config_get_boolean_ondemand("plugin:proc:/proc/net/dev", "bandwidth for all interfaces", CONFIG_ONDEMAND_ONDEMAND);
 125         do_packets      = config_get_boolean_ondemand("plugin:proc:/proc/net/dev", "packets for all interfaces", CONFIG_ONDEMAND_ONDEMAND);
 126         do_errors       = config_get_boolean_ondemand("plugin:proc:/proc/net/dev", "errors for all interfaces", CONFIG_ONDEMAND_ONDEMAND);
 127         do_drops        = config_get_boolean_ondemand("plugin:proc:/proc/net/dev", "drops for all interfaces", CONFIG_ONDEMAND_ONDEMAND);
 128         do_fifo         = config_get_boolean_ondemand("plugin:proc:/proc/net/dev", "fifo for all interfaces", CONFIG_ONDEMAND_ONDEMAND);
 129         do_compressed   = config_get_boolean_ondemand("plugin:proc:/proc/net/dev", "compressed packets for all interfaces", CONFIG_ONDEMAND_ONDEMAND);
 130         do_events       = config_get_boolean_ondemand("plugin:proc:/proc/net/dev", "frames, collisions, carrier counters for all interfaces", CONFIG_ONDEMAND_ONDEMAND);
 131     }
 132
 133     if(unlikely(!ff)) {
 134         char filename[FILENAME_MAX + 1];
 135         snprintfz(filename, FILENAME_MAX, "%s%s", global_host_prefix, "/proc/net/dev");
 136         ff = procfile_open(config_get("plugin:proc:/proc/net/dev", "filename to monitor", filename), " \t,:|", PROCFILE_FLAG_DEFAULT);
 137         if(unlikely(!ff)) return 1;
 138     }
 139
 140     ff = procfile_readall(ff);
 141     if(unlikely(!ff)) return 0; // we return 0, so that we will retry to open it next time
 142
 143     uint32_t lines = procfile_lines(ff), l;
 144     for(l = 2; l < lines ;l++) {
 145         // require 17 words on each line
 146         if(unlikely(procfile_linewords(ff, l) < 17)) continue;
 147
 148         struct netdev *d = get_netdev(procfile_lineword(ff, l, 0));
 149
 150         if(unlikely(!d->configured)) {
 151             // this is the first time we see this interface
 152
 153             // remember we configured it
 154             d->configured = 1;
 155
 156             // start with the default enabled flag
 157             d->enabled = enable_new_interfaces;
 158             if(d->enabled) {
 159                 if(unlikely(!strcmp(d->name, "lo")))
 160                     d->enabled = CONFIG_ONDEMAND_NO;
 161                 else if(unlikely(!strncmp(d->name, "veth", 4)))
 162                     d->enabled = enable_veth_interfaces;
 163                 else if(unlikely(d->len >= 4 && strcmp(&d->name[d->len - 4], "-ifb") == 0))
 164                     d->enabled = enable_ifb_interfaces;
 165             }
 166
 167             char var_name[512 + 1];
 168             snprintfz(var_name, 512, "plugin:proc:/proc/net/dev:%s", d->name);
 169             d->enabled = config_get_boolean_ondemand(var_name, "enabled", d->enabled);
 170
 171             if(d->enabled == CONFIG_ONDEMAND_NO)
 172                 continue;
 173
 174             d->do_bandwidth = config_get_boolean_ondemand(var_name, "bandwidth", do_bandwidth);
 175             d->do_packets = config_get_boolean_ondemand(var_name, "packets", do_packets);
 176             d->do_errors = config_get_boolean_ondemand(var_name, "errors", do_errors);
 177             d->do_drops = config_get_boolean_ondemand(var_name, "drops", do_drops);
 178             d->do_fifo = config_get_boolean_ondemand(var_name, "fifo", do_fifo);
 179             d->do_compressed = config_get_boolean_ondemand(var_name, "compressed", do_compressed);
 180             d->do_events = config_get_boolean_ondemand(var_name, "events", do_events);
 181         }
 182
 183         if(unlikely(!d->enabled))
 184             continue;
 185
 186         d->rbytes      = strtoull(procfile_lineword(ff, l, 1), NULL, 10);
 187         d->rpackets    = strtoull(procfile_lineword(ff, l, 2), NULL, 10);
 188         d->rerrors     = strtoull(procfile_lineword(ff, l, 3), NULL, 10);
 189         d->rdrops      = strtoull(procfile_lineword(ff, l, 4), NULL, 10);
 190         d->rfifo       = strtoull(procfile_lineword(ff, l, 5), NULL, 10);
 191         d->rframe      = strtoull(procfile_lineword(ff, l, 6), NULL, 10);
 192         d->rcompressed = strtoull(procfile_lineword(ff, l, 7), NULL, 10);
 193         d->rmulticast  = strtoull(procfile_lineword(ff, l, 8), NULL, 10);
 194
 195         d->tbytes      = strtoull(procfile_lineword(ff, l, 9), NULL, 10);
 196         d->tpackets    = strtoull(procfile_lineword(ff, l, 10), NULL, 10);
 197         d->terrors     = strtoull(procfile_lineword(ff, l, 11), NULL, 10);
 198         d->tdrops      = strtoull(procfile_lineword(ff, l, 12), NULL, 10);
 199         d->tfifo       = strtoull(procfile_lineword(ff, l, 13), NULL, 10);
 200         d->tcollisions = strtoull(procfile_lineword(ff, l, 14), NULL, 10);
 201         d->tcarrier    = strtoull(procfile_lineword(ff, l, 15), NULL, 10);
 202         d->tcompressed = strtoull(procfile_lineword(ff, l, 16), NULL, 10);
 203
 204         // --------------------------------------------------------------------
 205
 206         if(unlikely((d->do_bandwidth == CONFIG_ONDEMAND_ONDEMAND && (d->rbytes || d->tbytes))))
 207             d->do_bandwidth = CONFIG_ONDEMAND_YES;
 208
 209         if(d->do_bandwidth == CONFIG_ONDEMAND_YES) {
 210             if(unlikely(!d->st_bandwidth)) {
 211                 d->st_bandwidth = rrdset_find_bytype("net", d->name);
 212
 213                 if(!d->st_bandwidth) {
 214                     d->st_bandwidth = rrdset_create("net", d->name, NULL, d->name, "net.net", "Bandwidth", "kilobits/s", 7000, update_every, RRDSET_TYPE_AREA);
 215                     d->rd_rbytes = rrddim_add(d->st_bandwidth, "received", NULL, 8, 1024, RRDDIM_INCREMENTAL);
 216                     d->rd_tbytes = rrddim_add(d->st_bandwidth, "sent", NULL, -8, 1024, RRDDIM_INCREMENTAL);
 217                 }
 218             }
 219             else rrdset_next(d->st_bandwidth);
 220
 221             rrddim_set_by_pointer(d->st_bandwidth, d->rd_rbytes, d->rbytes);
 222             rrddim_set_by_pointer(d->st_bandwidth, d->rd_tbytes, d->tbytes);
 223             rrdset_done(d->st_bandwidth);
 224         }
 225
 226         // --------------------------------------------------------------------
 227
 228         if(unlikely((d->do_packets == CONFIG_ONDEMAND_ONDEMAND && (d->rpackets || d->tpackets || d->rmulticast))))
 229             d->do_packets = CONFIG_ONDEMAND_YES;
 230
 231         if(d->do_packets == CONFIG_ONDEMAND_YES) {
 232             if(unlikely(!d->st_packets)) {
 233                 d->st_packets = rrdset_find_bytype("net_packets", d->name);
 234
 235                 if(!d->st_packets) {
 236                     d->st_packets = rrdset_create("net_packets", d->name, NULL, d->name, "net.packets", "Packets", "packets/s", 7001, update_every, RRDSET_TYPE_LINE);
 237                     d->st_packets->isdetail = 1;
 238
 239                     d->rd_rpackets = rrddim_add(d->st_packets, "received", NULL, 1, 1, RRDDIM_INCREMENTAL);
 240                     d->rd_tpackets = rrddim_add(d->st_packets, "sent", NULL, -1, 1, RRDDIM_INCREMENTAL);
 241                     d->rd_rmulticast = rrddim_add(d->st_packets, "multicast", NULL, 1, 1, RRDDIM_INCREMENTAL);
 242                 }
 243             }
 244             else rrdset_next(d->st_packets);
 245
 246             rrddim_set_by_pointer(d->st_packets, d->rd_rpackets, d->rpackets);
 247             rrddim_set_by_pointer(d->st_packets, d->rd_tpackets, d->tpackets);
 248             rrddim_set_by_pointer(d->st_packets, d->rd_rmulticast, d->rmulticast);
 249             rrdset_done(d->st_packets);
 250         }
 251
 252         // --------------------------------------------------------------------
 253
 254         if(unlikely((d->do_errors == CONFIG_ONDEMAND_ONDEMAND && (d->rerrors || d->terrors))))
 255             d->do_errors = CONFIG_ONDEMAND_YES;
 256
 257         if(d->do_errors == CONFIG_ONDEMAND_YES) {
 258             if(unlikely(!d->st_errors)) {
 259                 d->st_errors = rrdset_find_bytype("net_errors", d->name);
 260
 261                 if(!d->st_errors) {
 262                     d->st_errors = rrdset_create("net_errors", d->name, NULL, d->name, "net.errors", "Interface Errors", "errors/s", 7002, update_every, RRDSET_TYPE_LINE);
 263                     d->st_errors->isdetail = 1;
 264
 265                     d->rd_rerrors = rrddim_add(d->st_errors, "inbound", NULL, 1, 1, RRDDIM_INCREMENTAL);
 266                     d->rd_terrors = rrddim_add(d->st_errors, "outbound", NULL, -1, 1, RRDDIM_INCREMENTAL);
 267                 }
 268             }
 269             else rrdset_next(d->st_errors);
 270
 271             rrddim_set_by_pointer(d->st_errors, d->rd_rerrors, d->rerrors);
 272             rrddim_set_by_pointer(d->st_errors, d->rd_terrors, d->terrors);
 273             rrdset_done(d->st_errors);
 274         }
 275
 276         // --------------------------------------------------------------------
 277
 278         if(unlikely((d->do_drops == CONFIG_ONDEMAND_ONDEMAND && (d->rdrops || d->tdrops))))
 279             d->do_drops = CONFIG_ONDEMAND_YES;
 280
 281         if(d->do_drops == CONFIG_ONDEMAND_YES) {
 282             if(unlikely(!d->st_drops)) {
 283                 d->st_drops = rrdset_find_bytype("net_drops", d->name);
 284
 285                 if(!d->st_drops) {
 286                     d->st_drops = rrdset_create("net_drops", d->name, NULL, d->name, "net.drops", "Interface Drops", "drops/s", 7003, update_every, RRDSET_TYPE_LINE);
 287                     d->st_drops->isdetail = 1;
 288
 289                     d->rd_rdrops = rrddim_add(d->st_drops, "inbound", NULL, 1, 1, RRDDIM_INCREMENTAL);
 290                     d->rd_tdrops = rrddim_add(d->st_drops, "outbound", NULL, -1, 1, RRDDIM_INCREMENTAL);
 291                 }
 292             }
 293             else rrdset_next(d->st_drops);
 294
 295             rrddim_set_by_pointer(d->st_drops, d->rd_rdrops, d->rdrops);
 296             rrddim_set_by_pointer(d->st_drops, d->rd_tdrops, d->tdrops);
 297             rrdset_done(d->st_drops);
 298         }
 299
 300         // --------------------------------------------------------------------
 301
 302         if(unlikely((d->do_fifo == CONFIG_ONDEMAND_ONDEMAND && (d->rfifo || d->tfifo))))
 303             d->do_fifo = CONFIG_ONDEMAND_YES;
 304
 305         if(d->do_fifo == CONFIG_ONDEMAND_YES) {
 306             if(unlikely(!d->st_fifo)) {
 307                 d->st_fifo = rrdset_find_bytype("net_fifo", d->name);
 308
 309                 if(!d->st_fifo) {
 310                     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);
 311                     d->st_fifo->isdetail = 1;
 312
 313                     d->rd_rfifo = rrddim_add(d->st_fifo, "receive", NULL, 1, 1, RRDDIM_INCREMENTAL);
 314                     d->rd_tfifo = rrddim_add(d->st_fifo, "transmit", NULL, -1, 1, RRDDIM_INCREMENTAL);
 315                 }
 316             }
 317             else rrdset_next(d->st_fifo);
 318
 319             rrddim_set_by_pointer(d->st_fifo, d->rd_rfifo, d->rfifo);
 320             rrddim_set_by_pointer(d->st_fifo, d->rd_tfifo, d->tfifo);
 321             rrdset_done(d->st_fifo);
 322         }
 323
 324         // --------------------------------------------------------------------
 325
 326         if(unlikely((d->do_compressed == CONFIG_ONDEMAND_ONDEMAND && (d->rcompressed || d->tcompressed))))
 327             d->do_compressed = CONFIG_ONDEMAND_YES;
 328
 329         if(d->do_compressed == CONFIG_ONDEMAND_YES) {
 330             if(unlikely(!d->st_compressed)) {
 331                 d->st_compressed = rrdset_find_bytype("net_compressed", d->name);
 332                 if(!d->st_compressed) {
 333                     d->st_compressed = rrdset_create("net_compressed", d->name, NULL, d->name, "net.compressed", "Compressed Packets", "packets/s", 7005, update_every, RRDSET_TYPE_LINE);
 334                     d->st_compressed->isdetail = 1;
 335
 336                     d->rd_rcompressed = rrddim_add(d->st_compressed, "received", NULL, 1, 1, RRDDIM_INCREMENTAL);
 337                     d->rd_tcompressed = rrddim_add(d->st_compressed, "sent", NULL, -1, 1, RRDDIM_INCREMENTAL);
 338                 }
 339             }
 340             else rrdset_next(d->st_compressed);
 341
 342             rrddim_set_by_pointer(d->st_compressed, d->rd_rcompressed, d->rcompressed);
 343             rrddim_set_by_pointer(d->st_compressed, d->rd_tcompressed, d->tcompressed);
 344             rrdset_done(d->st_compressed);
 345         }
 346
 347         // --------------------------------------------------------------------
 348
 349         if(unlikely((d->do_events == CONFIG_ONDEMAND_ONDEMAND && (d->rframe || d->tcollisions || d->tcarrier))))
 350             d->do_events = CONFIG_ONDEMAND_YES;
 351
 352         if(d->do_events == CONFIG_ONDEMAND_YES) {
 353             if(unlikely(!d->st_events)) {
 354                 d->st_events = rrdset_find_bytype("net_events", d->name);
 355                 if(!d->st_events) {
 356                     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);
 357                     d->st_events->isdetail = 1;
 358
 359                     d->rd_rframe      = rrddim_add(d->st_events, "frames", NULL, 1, 1, RRDDIM_INCREMENTAL);
 360                     d->rd_tcollisions = rrddim_add(d->st_events, "collisions", NULL, -1, 1, RRDDIM_INCREMENTAL);
 361                     d->rd_tcarrier    = rrddim_add(d->st_events, "carrier", NULL, -1, 1, RRDDIM_INCREMENTAL);
 362                 }
 363             }
 364             else rrdset_next(d->st_events);
 365
 366             rrddim_set_by_pointer(d->st_events, d->rd_rframe,      d->rframe);
 367             rrddim_set_by_pointer(d->st_events, d->rd_tcollisions, d->tcollisions);
 368             rrddim_set_by_pointer(d->st_events, d->rd_tcarrier,    d->tcarrier);
 369             rrdset_done(d->st_events);
 370         }
 371     }
 372
 373     return 0;
 374 }