src/proc_net_stat_conntrack.c

   1 #include "common.h"
   2
   3 #define RRD_TYPE_NET_STAT_NETFILTER     "netfilter"
   4 #define RRD_TYPE_NET_STAT_CONNTRACK     "conntrack"
   5 #define RRD_TYPE_NET_STAT_CONNTRACK_LEN strlen(RRD_TYPE_NET_STAT_CONNTRACK)
   6
   7 int do_proc_net_stat_conntrack(int update_every, unsigned long long dt) {
   8     static procfile *ff = NULL;
   9     static int do_sockets = -1, do_new = -1, do_changes = -1, do_expect = -1, do_search = -1, do_errors = -1;
  10
  11     if(do_sockets == -1)    do_sockets = config_get_boolean("plugin:proc:/proc/net/stat/nf_conntrack", "netfilter connections", 1);
  12     if(do_new == -1)        do_new = config_get_boolean("plugin:proc:/proc/net/stat/nf_conntrack", "netfilter new connections", 1);
  13     if(do_changes == -1)    do_changes = config_get_boolean("plugin:proc:/proc/net/stat/nf_conntrack", "netfilter connection changes", 1);
  14     if(do_expect == -1)     do_expect = config_get_boolean("plugin:proc:/proc/net/stat/nf_conntrack", "netfilter connection expectations", 1);
  15     if(do_search == -1)     do_search = config_get_boolean("plugin:proc:/proc/net/stat/nf_conntrack", "netfilter connection searches", 1);
  16     if(do_errors == -1)     do_errors = config_get_boolean("plugin:proc:/proc/net/stat/nf_conntrack", "netfilter errors", 1);
  17
  18     if(dt) {};
  19
  20     if(!ff) {
  21         char filename[FILENAME_MAX + 1];
  22         snprintfz(filename, FILENAME_MAX, "%s%s", global_host_prefix, "/proc/net/stat/nf_conntrack");
  23         ff = procfile_open(config_get("plugin:proc:/proc/net/stat/nf_conntrack", "filename to monitor", filename), " \t:", PROCFILE_FLAG_DEFAULT);
  24     }
  25     if(!ff) return 1;
  26
  27     ff = procfile_readall(ff);
  28     if(!ff) return 0; // we return 0, so that we will retry to open it next time
  29
  30     uint32_t lines = procfile_lines(ff), l;
  31     uint32_t words;
  32
  33     unsigned long long aentries = 0, asearched = 0, afound = 0, anew = 0, ainvalid = 0, aignore = 0, adelete = 0, adelete_list = 0,
  34         ainsert = 0, ainsert_failed = 0, adrop = 0, aearly_drop = 0, aicmp_error = 0, aexpect_new = 0, aexpect_create = 0, aexpect_delete = 0, asearch_restart = 0;
  35
  36     for(l = 1; l < lines ;l++) {
  37         words = procfile_linewords(ff, l);
  38         if(words < 17) {
  39             if(words) error("Cannot read /proc/net/stat/nf_conntrack line. Expected 17 params, read %u.", words);
  40             continue;
  41         }
  42
  43         unsigned long long tentries = 0, tsearched = 0, tfound = 0, tnew = 0, tinvalid = 0, tignore = 0, tdelete = 0, tdelete_list = 0, tinsert = 0, tinsert_failed = 0, tdrop = 0, tearly_drop = 0, ticmp_error = 0, texpect_new = 0, texpect_create = 0, texpect_delete = 0, tsearch_restart = 0;
  44
  45         tentries        = strtoull(procfile_lineword(ff, l, 0), NULL, 16);
  46         tsearched       = strtoull(procfile_lineword(ff, l, 1), NULL, 16);
  47         tfound          = strtoull(procfile_lineword(ff, l, 2), NULL, 16);
  48         tnew            = strtoull(procfile_lineword(ff, l, 3), NULL, 16);
  49         tinvalid        = strtoull(procfile_lineword(ff, l, 4), NULL, 16);
  50         tignore         = strtoull(procfile_lineword(ff, l, 5), NULL, 16);
  51         tdelete         = strtoull(procfile_lineword(ff, l, 6), NULL, 16);
  52         tdelete_list    = strtoull(procfile_lineword(ff, l, 7), NULL, 16);
  53         tinsert         = strtoull(procfile_lineword(ff, l, 8), NULL, 16);
  54         tinsert_failed  = strtoull(procfile_lineword(ff, l, 9), NULL, 16);
  55         tdrop           = strtoull(procfile_lineword(ff, l, 10), NULL, 16);
  56         tearly_drop     = strtoull(procfile_lineword(ff, l, 11), NULL, 16);
  57         ticmp_error     = strtoull(procfile_lineword(ff, l, 12), NULL, 16);
  58         texpect_new     = strtoull(procfile_lineword(ff, l, 13), NULL, 16);
  59         texpect_create  = strtoull(procfile_lineword(ff, l, 14), NULL, 16);
  60         texpect_delete  = strtoull(procfile_lineword(ff, l, 15), NULL, 16);
  61         tsearch_restart = strtoull(procfile_lineword(ff, l, 16), NULL, 16);
  62
  63         if(!aentries) aentries =  tentries;
  64
  65         // sum all the cpus together
  66         asearched           += tsearched;       // conntrack.search
  67         afound              += tfound;          // conntrack.search
  68         anew                += tnew;            // conntrack.new
  69         ainvalid            += tinvalid;        // conntrack.new
  70         aignore             += tignore;         // conntrack.new
  71         adelete             += tdelete;         // conntrack.changes
  72         adelete_list        += tdelete_list;    // conntrack.changes
  73         ainsert             += tinsert;         // conntrack.changes
  74         ainsert_failed      += tinsert_failed;  // conntrack.errors
  75         adrop               += tdrop;           // conntrack.errors
  76         aearly_drop         += tearly_drop;     // conntrack.errors
  77         aicmp_error         += ticmp_error;     // conntrack.errors
  78         aexpect_new         += texpect_new;     // conntrack.expect
  79         aexpect_create      += texpect_create;  // conntrack.expect
  80         aexpect_delete      += texpect_delete;  // conntrack.expect
  81         asearch_restart     += tsearch_restart; // conntrack.search
  82     }
  83
  84     RRDSET *st;
  85
  86     // --------------------------------------------------------------------
  87
  88     if(do_sockets) {
  89         st = rrdset_find(RRD_TYPE_NET_STAT_NETFILTER "." RRD_TYPE_NET_STAT_CONNTRACK "_sockets");
  90         if(!st) {
  91             st = rrdset_create(RRD_TYPE_NET_STAT_NETFILTER, RRD_TYPE_NET_STAT_CONNTRACK "_sockets", NULL, RRD_TYPE_NET_STAT_CONNTRACK, NULL, "Connection Tracker Connections", "active connections", 1000, update_every, RRDSET_TYPE_LINE);
  92
  93             rrddim_add(st, "connections", NULL, 1, 1, RRDDIM_ABSOLUTE);
  94         }
  95         else rrdset_next(st);
  96
  97         rrddim_set(st, "connections", aentries);
  98         rrdset_done(st);
  99     }
 100
 101     // --------------------------------------------------------------------
 102
 103     if(do_new) {
 104         st = rrdset_find(RRD_TYPE_NET_STAT_NETFILTER "." RRD_TYPE_NET_STAT_CONNTRACK "_new");
 105         if(!st) {
 106             st = rrdset_create(RRD_TYPE_NET_STAT_NETFILTER, RRD_TYPE_NET_STAT_CONNTRACK "_new", NULL, RRD_TYPE_NET_STAT_CONNTRACK, NULL, "Connection Tracker New Connections", "connections/s", 1001, update_every, RRDSET_TYPE_LINE);
 107
 108             rrddim_add(st, "new", NULL, 1, 1, RRDDIM_INCREMENTAL);
 109             rrddim_add(st, "ignore", NULL, -1, 1, RRDDIM_INCREMENTAL);
 110             rrddim_add(st, "invalid", NULL, -1, 1, RRDDIM_INCREMENTAL);
 111         }
 112         else rrdset_next(st);
 113
 114         rrddim_set(st, "new", anew);
 115         rrddim_set(st, "ignore", aignore);
 116         rrddim_set(st, "invalid", ainvalid);
 117         rrdset_done(st);
 118     }
 119
 120     // --------------------------------------------------------------------
 121
 122     if(do_changes) {
 123         st = rrdset_find(RRD_TYPE_NET_STAT_NETFILTER "." RRD_TYPE_NET_STAT_CONNTRACK "_changes");
 124         if(!st) {
 125             st = rrdset_create(RRD_TYPE_NET_STAT_NETFILTER, RRD_TYPE_NET_STAT_CONNTRACK "_changes", NULL, RRD_TYPE_NET_STAT_CONNTRACK, NULL, "Connection Tracker Changes", "changes/s", 1002, update_every, RRDSET_TYPE_LINE);
 126             st->isdetail = 1;
 127
 128             rrddim_add(st, "inserted", NULL, 1, 1, RRDDIM_INCREMENTAL);
 129             rrddim_add(st, "deleted", NULL, -1, 1, RRDDIM_INCREMENTAL);
 130             rrddim_add(st, "delete_list", NULL, -1, 1, RRDDIM_INCREMENTAL);
 131         }
 132         else rrdset_next(st);
 133
 134         rrddim_set(st, "inserted", ainsert);
 135         rrddim_set(st, "deleted", adelete);
 136         rrddim_set(st, "delete_list", adelete_list);
 137         rrdset_done(st);
 138     }
 139
 140     // --------------------------------------------------------------------
 141
 142     if(do_expect) {
 143         st = rrdset_find(RRD_TYPE_NET_STAT_NETFILTER "." RRD_TYPE_NET_STAT_CONNTRACK "_expect");
 144         if(!st) {
 145             st = rrdset_create(RRD_TYPE_NET_STAT_NETFILTER, RRD_TYPE_NET_STAT_CONNTRACK "_expect", NULL, RRD_TYPE_NET_STAT_CONNTRACK, NULL, "Connection Tracker Expectations", "expectations/s", 1003, update_every, RRDSET_TYPE_LINE);
 146             st->isdetail = 1;
 147
 148             rrddim_add(st, "created", NULL, 1, 1, RRDDIM_INCREMENTAL);
 149             rrddim_add(st, "deleted", NULL, -1, 1, RRDDIM_INCREMENTAL);
 150             rrddim_add(st, "new", NULL, 1, 1, RRDDIM_INCREMENTAL);
 151         }
 152         else rrdset_next(st);
 153
 154         rrddim_set(st, "created", aexpect_create);
 155         rrddim_set(st, "deleted", aexpect_delete);
 156         rrddim_set(st, "new", aexpect_new);
 157         rrdset_done(st);
 158     }
 159
 160     // --------------------------------------------------------------------
 161
 162     if(do_search) {
 163         st = rrdset_find(RRD_TYPE_NET_STAT_NETFILTER "." RRD_TYPE_NET_STAT_CONNTRACK "_search");
 164         if(!st) {
 165             st = rrdset_create(RRD_TYPE_NET_STAT_NETFILTER, RRD_TYPE_NET_STAT_CONNTRACK "_search", NULL, RRD_TYPE_NET_STAT_CONNTRACK, NULL, "Connection Tracker Searches", "searches/s", 1010, update_every, RRDSET_TYPE_LINE);
 166             st->isdetail = 1;
 167
 168             rrddim_add(st, "searched", NULL, 1, 1, RRDDIM_INCREMENTAL);
 169             rrddim_add(st, "restarted", NULL, -1, 1, RRDDIM_INCREMENTAL);
 170             rrddim_add(st, "found", NULL, 1, 1, RRDDIM_INCREMENTAL);
 171         }
 172         else rrdset_next(st);
 173
 174         rrddim_set(st, "searched", asearched);
 175         rrddim_set(st, "restarted", asearch_restart);
 176         rrddim_set(st, "found", afound);
 177         rrdset_done(st);
 178     }
 179
 180     // --------------------------------------------------------------------
 181
 182     if(do_errors) {
 183         st = rrdset_find(RRD_TYPE_NET_STAT_NETFILTER "." RRD_TYPE_NET_STAT_CONNTRACK "_errors");
 184         if(!st) {
 185             st = rrdset_create(RRD_TYPE_NET_STAT_NETFILTER, RRD_TYPE_NET_STAT_CONNTRACK "_errors", NULL, RRD_TYPE_NET_STAT_CONNTRACK, NULL, "Connection Tracker Errors", "events/s", 1005, update_every, RRDSET_TYPE_LINE);
 186             st->isdetail = 1;
 187
 188             rrddim_add(st, "icmp_error", NULL, 1, 1, RRDDIM_INCREMENTAL);
 189             rrddim_add(st, "insert_failed", NULL, -1, 1, RRDDIM_INCREMENTAL);
 190             rrddim_add(st, "drop", NULL, -1, 1, RRDDIM_INCREMENTAL);
 191             rrddim_add(st, "early_drop", NULL, -1, 1, RRDDIM_INCREMENTAL);
 192         }
 193         else rrdset_next(st);
 194
 195         rrddim_set(st, "icmp_error", aicmp_error);
 196         rrddim_set(st, "insert_failed", ainsert_failed);
 197         rrddim_set(st, "drop", adrop);
 198         rrddim_set(st, "early_drop", aearly_drop);
 199         rrdset_done(st);
 200     }
 201
 202     return 0;
 203 }