src/proc_net_netstat.c

   1 #include <inttypes.h>
   2 #include <stdio.h>
   3 #include <stdlib.h>
   4 #include <string.h>
   5
   6 #include "common.h"
   7 #include "log.h"
   8 #include "config.h"
   9 #include "procfile.h"
  10 #include "rrd.h"
  11 #include "plugin_proc.h"
  12
  13 int do_proc_net_netstat(int update_every, unsigned long long dt) {
  14         static int do_bandwidth = -1, do_inerrors = -1, do_mcast = -1, do_bcast = -1, do_mcast_p = -1, do_bcast_p = -1;
  15         static procfile *ff = NULL;
  16
  17         if(do_bandwidth == -1)  do_bandwidth    = config_get_boolean("plugin:proc:/proc/net/netstat", "bandwidth", 1);
  18         if(do_inerrors == -1)   do_inerrors             = config_get_boolean("plugin:proc:/proc/net/netstat", "input errors", 1);
  19         if(do_mcast == -1)              do_mcast                = config_get_boolean("plugin:proc:/proc/net/netstat", "multicast bandwidth", 1);
  20         if(do_bcast == -1)              do_bcast                = config_get_boolean("plugin:proc:/proc/net/netstat", "broadcast bandwidth", 1);
  21         if(do_mcast_p == -1)    do_mcast_p              = config_get_boolean("plugin:proc:/proc/net/netstat", "multicast packets", 1);
  22         if(do_bcast_p == -1)    do_bcast_p              = config_get_boolean("plugin:proc:/proc/net/netstat", "broadcast packets", 1);
  23
  24         if(dt) {};
  25
  26         if(!ff) {
  27                 char filename[FILENAME_MAX + 1];
  28                 snprintf(filename, FILENAME_MAX, "%s%s", global_host_prefix, "/proc/net/netstat");
  29                 ff = procfile_open(config_get("plugin:proc:/proc/net/netstat", "filename to monitor", filename), " \t:", PROCFILE_FLAG_DEFAULT);
  30         }
  31         if(!ff) return 1;
  32
  33         ff = procfile_readall(ff);
  34         if(!ff) return 0; // we return 0, so that we will retry to open it next time
  35
  36         uint32_t lines = procfile_lines(ff), l;
  37         uint32_t words;
  38
  39         for(l = 0; l < lines ;l++) {
  40                 if(strcmp(procfile_lineword(ff, l, 0), "IpExt") == 0) {
  41                         l++; // we need the next line
  42
  43                         if(strcmp(procfile_lineword(ff, l, 0), "IpExt") != 0) {
  44                                 error("Cannot read IpExt line from /proc/net/netstat.");
  45                                 break;
  46                         }
  47                         words = procfile_linewords(ff, l);
  48                         if(words < 12) {
  49                                 error("Cannot read /proc/net/netstat IpExt line. Expected 12 params, read %d.", words);
  50                                 continue;
  51                         }
  52
  53                         unsigned long long
  54                                 InNoRoutes = 0, InTruncatedPkts = 0,
  55                                 InOctets = 0,  InMcastPkts = 0,  InBcastPkts = 0,  InMcastOctets = 0,  InBcastOctets = 0,
  56                                 OutOctets = 0, OutMcastPkts = 0, OutBcastPkts = 0, OutMcastOctets = 0, OutBcastOctets = 0;
  57
  58                         InNoRoutes                      = strtoull(procfile_lineword(ff, l, 1), NULL, 10);
  59                         InTruncatedPkts         = strtoull(procfile_lineword(ff, l, 2), NULL, 10);
  60                         InMcastPkts             = strtoull(procfile_lineword(ff, l, 3), NULL, 10);
  61                         OutMcastPkts            = strtoull(procfile_lineword(ff, l, 4), NULL, 10);
  62                         InBcastPkts             = strtoull(procfile_lineword(ff, l, 5), NULL, 10);
  63                         OutBcastPkts            = strtoull(procfile_lineword(ff, l, 6), NULL, 10);
  64                         InOctets                        = strtoull(procfile_lineword(ff, l, 7), NULL, 10);
  65                         OutOctets                       = strtoull(procfile_lineword(ff, l, 8), NULL, 10);
  66                         InMcastOctets           = strtoull(procfile_lineword(ff, l, 9), NULL, 10);
  67                         OutMcastOctets          = strtoull(procfile_lineword(ff, l, 10), NULL, 10);
  68                         InBcastOctets           = strtoull(procfile_lineword(ff, l, 11), NULL, 10);
  69                         OutBcastOctets          = strtoull(procfile_lineword(ff, l, 12), NULL, 10);
  70
  71                         RRDSET *st;
  72
  73                         // --------------------------------------------------------------------
  74
  75                         if(do_bandwidth) {
  76                                 st = rrdset_find("system.ipv4");
  77                                 if(!st) {
  78                                         st = rrdset_create("system", "ipv4", NULL, "ipv4", "IPv4 Bandwidth", "kilobits/s", 2000, update_every, RRDSET_TYPE_AREA);
  79
  80                                         rrddim_add(st, "received", NULL, 8, 1024 * update_every, RRDDIM_INCREMENTAL);
  81                                         rrddim_add(st, "sent", NULL, -8, 1024 * update_every, RRDDIM_INCREMENTAL);
  82                                 }
  83                                 else rrdset_next(st);
  84
  85                                 rrddim_set(st, "sent", OutOctets);
  86                                 rrddim_set(st, "received", InOctets);
  87                                 rrdset_done(st);
  88                         }
  89
  90                         // --------------------------------------------------------------------
  91
  92                         if(do_inerrors) {
  93                                 st = rrdset_find("ipv4.inerrors");
  94                                 if(!st) {
  95                                         st = rrdset_create("ipv4", "inerrors", NULL, "ipv4", "IPv4 Input Errors", "packets/s", 4000, update_every, RRDSET_TYPE_LINE);
  96                                         st->isdetail = 1;
  97
  98                                         rrddim_add(st, "noroutes", NULL, 1, 1 * update_every, RRDDIM_INCREMENTAL);
  99                                         rrddim_add(st, "trunkated", NULL, 1, 1 * update_every, RRDDIM_INCREMENTAL);
 100                                 }
 101                                 else rrdset_next(st);
 102
 103                                 rrddim_set(st, "noroutes", InNoRoutes);
 104                                 rrddim_set(st, "trunkated", InTruncatedPkts);
 105                                 rrdset_done(st);
 106                         }
 107
 108                         // --------------------------------------------------------------------
 109
 110                         if(do_mcast) {
 111                                 st = rrdset_find("ipv4.mcast");
 112                                 if(!st) {
 113                                         st = rrdset_create("ipv4", "mcast", NULL, "ipv4", "IPv4 Multicast Bandwidth", "kilobits/s", 9000, update_every, RRDSET_TYPE_AREA);
 114                                         st->isdetail = 1;
 115
 116                                         rrddim_add(st, "received", NULL, 8, 1024 * update_every, RRDDIM_INCREMENTAL);
 117                                         rrddim_add(st, "sent", NULL, -8, 1024 * update_every, RRDDIM_INCREMENTAL);
 118                                 }
 119                                 else rrdset_next(st);
 120
 121                                 rrddim_set(st, "sent", OutMcastOctets);
 122                                 rrddim_set(st, "received", InMcastOctets);
 123                                 rrdset_done(st);
 124                         }
 125
 126                         // --------------------------------------------------------------------
 127
 128                         if(do_bcast) {
 129                                 st = rrdset_find("ipv4.bcast");
 130                                 if(!st) {
 131                                         st = rrdset_create("ipv4", "bcast", NULL, "ipv4", "IPv4 Broadcast Bandwidth", "kilobits/s", 8000, update_every, RRDSET_TYPE_AREA);
 132                                         st->isdetail = 1;
 133
 134                                         rrddim_add(st, "received", NULL, 8, 1024 * update_every, RRDDIM_INCREMENTAL);
 135                                         rrddim_add(st, "sent", NULL, -8, 1024 * update_every, RRDDIM_INCREMENTAL);
 136                                 }
 137                                 else rrdset_next(st);
 138
 139                                 rrddim_set(st, "sent", OutBcastOctets);
 140                                 rrddim_set(st, "received", InBcastOctets);
 141                                 rrdset_done(st);
 142                         }
 143
 144                         // --------------------------------------------------------------------
 145
 146                         if(do_mcast_p) {
 147                                 st = rrdset_find("ipv4.mcastpkts");
 148                                 if(!st) {
 149                                         st = rrdset_create("ipv4", "mcastpkts", NULL, "ipv4", "IPv4 Multicast Packets", "packets/s", 9500, update_every, RRDSET_TYPE_LINE);
 150                                         st->isdetail = 1;
 151
 152                                         rrddim_add(st, "received", NULL, 1, 1 * update_every, RRDDIM_INCREMENTAL);
 153                                         rrddim_add(st, "sent", NULL, -1, 1 * update_every, RRDDIM_INCREMENTAL);
 154                                 }
 155                                 else rrdset_next(st);
 156
 157                                 rrddim_set(st, "sent", OutMcastPkts);
 158                                 rrddim_set(st, "received", InMcastPkts);
 159                                 rrdset_done(st);
 160                         }
 161
 162                         // --------------------------------------------------------------------
 163
 164                         if(do_bcast_p) {
 165                                 st = rrdset_find("ipv4.bcastpkts");
 166                                 if(!st) {
 167                                         st = rrdset_create("ipv4", "bcastpkts", NULL, "ipv4", "IPv4 Broadcast Packets", "packets/s", 8500, update_every, RRDSET_TYPE_LINE);
 168                                         st->isdetail = 1;
 169
 170                                         rrddim_add(st, "received", NULL, 1, 1 * update_every, RRDDIM_INCREMENTAL);
 171                                         rrddim_add(st, "sent", NULL, -1, 1 * update_every, RRDDIM_INCREMENTAL);
 172                                 }
 173                                 else rrdset_next(st);
 174
 175                                 rrddim_set(st, "sent", OutBcastPkts);
 176                                 rrddim_set(st, "received", InBcastPkts);
 177                                 rrdset_done(st);
 178                         }
 179                 }
 180         }
 181
 182         return 0;
 183 }