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