src/proc_net_rpc_nfs.c

   1 #include "common.h"
   2
   3 struct nfs_procs {
   4     char name[30];
   5     unsigned long long value;
   6     int present;
   7 };
   8
   9 struct nfs_procs nfs_proc2_values[] = {
  10     { "null", 0ULL, 0 },
  11     { "getattr", 0ULL, 0 },
  12     { "setattr", 0ULL, 0 },
  13     { "root", 0ULL, 0 },
  14     { "lookup", 0ULL, 0 },
  15     { "readlink", 0ULL, 0 },
  16     { "read", 0ULL, 0 },
  17     { "wrcache", 0ULL, 0 },
  18     { "write", 0ULL, 0 },
  19     { "create", 0ULL, 0 },
  20     { "remove", 0ULL, 0 },
  21     { "rename", 0ULL, 0 },
  22     { "link", 0ULL, 0 },
  23     { "symlink", 0ULL, 0 },
  24     { "mkdir", 0ULL, 0 },
  25     { "rmdir", 0ULL, 0 },
  26     { "readdir", 0ULL, 0 },
  27     { "fsstat", 0ULL, 0 },
  28
  29     /* termination */
  30     { "", 0ULL, 0 }
  31 };
  32
  33 struct nfs_procs nfs_proc3_values[] = {
  34     { "null", 0ULL, 0 },
  35     { "getattr", 0ULL, 0 },
  36     { "setattr", 0ULL, 0 },
  37     { "lookup", 0ULL, 0 },
  38     { "access", 0ULL, 0 },
  39     { "readlink", 0ULL, 0 },
  40     { "read", 0ULL, 0 },
  41     { "write", 0ULL, 0 },
  42     { "create", 0ULL, 0 },
  43     { "mkdir", 0ULL, 0 },
  44     { "symlink", 0ULL, 0 },
  45     { "mknod", 0ULL, 0 },
  46     { "remove", 0ULL, 0 },
  47     { "rmdir", 0ULL, 0 },
  48     { "rename", 0ULL, 0 },
  49     { "link", 0ULL, 0 },
  50     { "readdir", 0ULL, 0 },
  51     { "readdirplus", 0ULL, 0 },
  52     { "fsstat", 0ULL, 0 },
  53     { "fsinfo", 0ULL, 0 },
  54     { "pathconf", 0ULL, 0 },
  55     { "commit", 0ULL, 0 },
  56
  57     /* termination */
  58     { "", 0ULL, 0 }
  59 };
  60
  61 struct nfs_procs nfs_proc4_values[] = {
  62     { "null", 0ULL, 0 },
  63     { "read", 0ULL, 0 },
  64     { "write", 0ULL, 0 },
  65     { "commit", 0ULL, 0 },
  66     { "open", 0ULL, 0 },
  67     { "open_conf", 0ULL, 0 },
  68     { "open_noat", 0ULL, 0 },
  69     { "open_dgrd", 0ULL, 0 },
  70     { "close", 0ULL, 0 },
  71     { "setattr", 0ULL, 0 },
  72     { "fsinfo", 0ULL, 0 },
  73     { "renew", 0ULL, 0 },
  74     { "setclntid", 0ULL, 0 },
  75     { "confirm", 0ULL, 0 },
  76     { "lock", 0ULL, 0 },
  77     { "lockt", 0ULL, 0 },
  78     { "locku", 0ULL, 0 },
  79     { "access", 0ULL, 0 },
  80     { "getattr", 0ULL, 0 },
  81     { "lookup", 0ULL, 0 },
  82     { "lookup_root", 0ULL, 0 },
  83     { "remove", 0ULL, 0 },
  84     { "rename", 0ULL, 0 },
  85     { "link", 0ULL, 0 },
  86     { "symlink", 0ULL, 0 },
  87     { "create", 0ULL, 0 },
  88     { "pathconf", 0ULL, 0 },
  89     { "statfs", 0ULL, 0 },
  90     { "readlink", 0ULL, 0 },
  91     { "readdir", 0ULL, 0 },
  92     { "server_caps", 0ULL, 0 },
  93     { "delegreturn", 0ULL, 0 },
  94     { "getacl", 0ULL, 0 },
  95     { "setacl", 0ULL, 0 },
  96     { "fs_locations", 0ULL, 0 },
  97     { "rel_lkowner", 0ULL, 0 },
  98     { "secinfo", 0ULL, 0 },
  99     { "fsid_present", 0ULL, 0 },
 100
 101     /* nfsv4.1 client ops */
 102     { "exchange_id", 0ULL, 0 },
 103     { "create_session", 0ULL, 0 },
 104     { "destroy_session", 0ULL, 0 },
 105     { "sequence", 0ULL, 0 },
 106     { "get_lease_time", 0ULL, 0 },
 107     { "reclaim_comp", 0ULL, 0 },
 108     { "layoutget", 0ULL, 0 },
 109     { "getdevinfo", 0ULL, 0 },
 110     { "layoutcommit", 0ULL, 0 },
 111     { "layoutreturn", 0ULL, 0 },
 112     { "secinfo_no", 0ULL, 0 },
 113     { "test_stateid", 0ULL, 0 },
 114     { "free_stateid", 0ULL, 0 },
 115     { "getdevicelist", 0ULL, 0 },
 116     { "bind_conn_to_ses", 0ULL, 0 },
 117     { "destroy_clientid", 0ULL, 0 },
 118
 119     /* nfsv4.2 client ops */
 120     { "seek", 0ULL, 0 },
 121     { "allocate", 0ULL, 0 },
 122     { "deallocate", 0ULL, 0 },
 123     { "layoutstats", 0ULL, 0 },
 124     { "clone", 0ULL, 0 },
 125
 126     /* termination */
 127     { "", 0ULL, 0 }
 128 };
 129
 130 int do_proc_net_rpc_nfs(int update_every, usec_t dt) {
 131     (void)dt;
 132
 133     static procfile *ff = NULL;
 134     static int do_net = -1, do_rpc = -1, do_proc2 = -1, do_proc3 = -1, do_proc4 = -1;
 135     static int proc2_warning = 0, proc3_warning = 0, proc4_warning = 0;
 136
 137     if(!ff) {
 138         char filename[FILENAME_MAX + 1];
 139         snprintfz(filename, FILENAME_MAX, "%s%s", global_host_prefix, "/proc/net/rpc/nfs");
 140         ff = procfile_open(config_get("plugin:proc:/proc/net/rpc/nfs", "filename to monitor", filename), " \t", PROCFILE_FLAG_DEFAULT);
 141     }
 142     if(!ff) return 1;
 143
 144     ff = procfile_readall(ff);
 145     if(!ff) return 0; // we return 0, so that we will retry to open it next time
 146
 147     if(do_net == -1) do_net = config_get_boolean("plugin:proc:/proc/net/rpc/nfs", "network", 1);
 148     if(do_rpc == -1) do_rpc = config_get_boolean("plugin:proc:/proc/net/rpc/nfs", "rpc", 1);
 149     if(do_proc2 == -1) do_proc2 = config_get_boolean("plugin:proc:/proc/net/rpc/nfs", "NFS v2 procedures", 1);
 150     if(do_proc3 == -1) do_proc3 = config_get_boolean("plugin:proc:/proc/net/rpc/nfs", "NFS v3 procedures", 1);
 151     if(do_proc4 == -1) do_proc4 = config_get_boolean("plugin:proc:/proc/net/rpc/nfs", "NFS v4 procedures", 1);
 152
 153     // if they are enabled, reset them to 1
 154     // later we do them =2 to avoid doing strsame() for all lines
 155     if(do_net) do_net = 1;
 156     if(do_rpc) do_rpc = 1;
 157     if(do_proc2) do_proc2 = 1;
 158     if(do_proc3) do_proc3 = 1;
 159     if(do_proc4) do_proc4 = 1;
 160
 161     size_t lines = procfile_lines(ff), l;
 162
 163     char *type;
 164     unsigned long long net_count = 0, net_udp_count = 0, net_tcp_count = 0, net_tcp_connections = 0;
 165     unsigned long long rpc_calls = 0, rpc_retransmits = 0, rpc_auth_refresh = 0;
 166
 167     for(l = 0; l < lines ;l++) {
 168         size_t words = procfile_linewords(ff, l);
 169         if(!words) continue;
 170
 171         type        = procfile_lineword(ff, l, 0);
 172
 173         if(do_net == 1 && strsame(type, "net") == 0) {
 174             if(words < 5) {
 175                 error("%s line of /proc/net/rpc/nfs has %zu words, expected %d", type, words, 5);
 176                 continue;
 177             }
 178
 179             net_count = str2ull(procfile_lineword(ff, l, 1));
 180             net_udp_count = str2ull(procfile_lineword(ff, l, 2));
 181             net_tcp_count = str2ull(procfile_lineword(ff, l, 3));
 182             net_tcp_connections = str2ull(procfile_lineword(ff, l, 4));
 183
 184             unsigned long long sum = net_count + net_udp_count + net_tcp_count + net_tcp_connections;
 185             if(sum == 0ULL) do_net = -1;
 186             else do_net = 2;
 187         }
 188         else if(do_rpc == 1 && strsame(type, "rpc") == 0) {
 189             if(words < 4) {
 190                 error("%s line of /proc/net/rpc/nfs has %zu words, expected %d", type, words, 6);
 191                 continue;
 192             }
 193
 194             rpc_calls = str2ull(procfile_lineword(ff, l, 1));
 195             rpc_retransmits = str2ull(procfile_lineword(ff, l, 2));
 196             rpc_auth_refresh = str2ull(procfile_lineword(ff, l, 3));
 197
 198             unsigned long long sum = rpc_calls + rpc_retransmits + rpc_auth_refresh;
 199             if(sum == 0ULL) do_rpc = -1;
 200             else do_rpc = 2;
 201         }
 202         else if(do_proc2 == 1 && strsame(type, "proc2") == 0) {
 203             // the first number is the count of numbers present
 204             // so we start for word 2
 205
 206             unsigned long long sum = 0;
 207             unsigned int i, j;
 208             for(i = 0, j = 2; j < words && nfs_proc2_values[i].name[0] ; i++, j++) {
 209                 nfs_proc2_values[i].value = str2ull(procfile_lineword(ff, l, j));
 210                 nfs_proc2_values[i].present = 1;
 211                 sum += nfs_proc2_values[i].value;
 212             }
 213
 214             if(sum == 0ULL) {
 215                 if(!proc2_warning) {
 216                     error("Disabling /proc/net/rpc/nfs v2 procedure calls chart. It seems unused on this machine. It will be enabled automatically when found with data in it.");
 217                     proc2_warning = 1;
 218                 }
 219                 do_proc2 = 0;
 220             }
 221             else do_proc2 = 2;
 222         }
 223         else if(do_proc3 == 1 && strsame(type, "proc3") == 0) {
 224             // the first number is the count of numbers present
 225             // so we start for word 2
 226
 227             unsigned long long sum = 0;
 228             unsigned int i, j;
 229             for(i = 0, j = 2; j < words && nfs_proc3_values[i].name[0] ; i++, j++) {
 230                 nfs_proc3_values[i].value = str2ull(procfile_lineword(ff, l, j));
 231                 nfs_proc3_values[i].present = 1;
 232                 sum += nfs_proc3_values[i].value;
 233             }
 234
 235             if(sum == 0ULL) {
 236                 if(!proc3_warning) {
 237                     info("Disabling /proc/net/rpc/nfs v3 procedure calls chart. It seems unused on this machine. It will be enabled automatically when found with data in it.");
 238                     proc3_warning = 1;
 239                 }
 240                 do_proc3 = 0;
 241             }
 242             else do_proc3 = 2;
 243         }
 244         else if(do_proc4 == 1 && strsame(type, "proc4") == 0) {
 245             // the first number is the count of numbers present
 246             // so we start for word 2
 247
 248             unsigned long long sum = 0;
 249             unsigned int i, j;
 250             for(i = 0, j = 2; j < words && nfs_proc4_values[i].name[0] ; i++, j++) {
 251                 nfs_proc4_values[i].value = str2ull(procfile_lineword(ff, l, j));
 252                 nfs_proc4_values[i].present = 1;
 253                 sum += nfs_proc4_values[i].value;
 254             }
 255
 256             if(sum == 0ULL) {
 257                 if(!proc4_warning) {
 258                     info("Disabling /proc/net/rpc/nfs v4 procedure calls chart. It seems unused on this machine. It will be enabled automatically when found with data in it.");
 259                     proc4_warning = 1;
 260                 }
 261                 do_proc4 = 0;
 262             }
 263             else do_proc4 = 2;
 264         }
 265     }
 266
 267     RRDSET *st;
 268
 269     // --------------------------------------------------------------------
 270
 271     if(do_net == 2) {
 272         st = rrdset_find_bytype("nfs", "net");
 273         if(!st) {
 274             st = rrdset_create("nfs", "net", NULL, "network", NULL, "NFS Client Network", "operations/s", 5007, update_every, RRDSET_TYPE_STACKED);
 275             st->isdetail = 1;
 276
 277             rrddim_add(st, "udp", NULL, 1, 1, RRDDIM_INCREMENTAL);
 278             rrddim_add(st, "tcp", NULL, 1, 1, RRDDIM_INCREMENTAL);
 279         }
 280         else rrdset_next(st);
 281
 282         // ignore net_count, net_tcp_connections
 283         if(net_count) {};
 284         if(net_tcp_connections) {};
 285
 286         rrddim_set(st, "udp", net_udp_count);
 287         rrddim_set(st, "tcp", net_tcp_count);
 288         rrdset_done(st);
 289     }
 290
 291     // --------------------------------------------------------------------
 292
 293     if(do_rpc == 2) {
 294         st = rrdset_find_bytype("nfs", "rpc");
 295         if(!st) {
 296             st = rrdset_create("nfs", "rpc", NULL, "rpc", NULL, "NFS Client Remote Procedure Calls Statistics", "calls/s", 5008, update_every, RRDSET_TYPE_LINE);
 297             st->isdetail = 1;
 298
 299             rrddim_add(st, "calls", NULL, 1, 1, RRDDIM_INCREMENTAL);
 300             rrddim_add(st, "retransmits", NULL, -1, 1, RRDDIM_INCREMENTAL);
 301             rrddim_add(st, "auth_refresh", NULL, -1, 1, RRDDIM_INCREMENTAL);
 302         }
 303         else rrdset_next(st);
 304
 305         rrddim_set(st, "calls", rpc_calls);
 306         rrddim_set(st, "retransmits", rpc_retransmits);
 307         rrddim_set(st, "auth_refresh", rpc_auth_refresh);
 308         rrdset_done(st);
 309     }
 310
 311     // --------------------------------------------------------------------
 312
 313     if(do_proc2 == 2) {
 314         unsigned int i;
 315         st = rrdset_find_bytype("nfs", "proc2");
 316         if(!st) {
 317             st = rrdset_create("nfs", "proc2", NULL, "nfsv2rpc", NULL, "NFS v2 Client Remote Procedure Calls", "calls/s", 5009, update_every, RRDSET_TYPE_STACKED);
 318
 319             for(i = 0; nfs_proc2_values[i].present ; i++)
 320                 rrddim_add(st, nfs_proc2_values[i].name, NULL, 1, 1, RRDDIM_INCREMENTAL);
 321         }
 322         else rrdset_next(st);
 323
 324         for(i = 0; nfs_proc2_values[i].present ; i++)
 325             rrddim_set(st, nfs_proc2_values[i].name, nfs_proc2_values[i].value);
 326
 327         rrdset_done(st);
 328     }
 329
 330     // --------------------------------------------------------------------
 331
 332     if(do_proc3 == 2) {
 333         unsigned int i;
 334         st = rrdset_find_bytype("nfs", "proc3");
 335         if(!st) {
 336             st = rrdset_create("nfs", "proc3", NULL, "nfsv3rpc", NULL, "NFS v3 Client Remote Procedure Calls", "calls/s", 5010, update_every, RRDSET_TYPE_STACKED);
 337
 338             for(i = 0; nfs_proc3_values[i].present ; i++)
 339                 rrddim_add(st, nfs_proc3_values[i].name, NULL, 1, 1, RRDDIM_INCREMENTAL);
 340         }
 341         else rrdset_next(st);
 342
 343         for(i = 0; nfs_proc3_values[i].present ; i++)
 344             rrddim_set(st, nfs_proc3_values[i].name, nfs_proc3_values[i].value);
 345
 346         rrdset_done(st);
 347     }
 348
 349     // --------------------------------------------------------------------
 350
 351     if(do_proc4 == 2) {
 352         unsigned int i;
 353         st = rrdset_find_bytype("nfs", "proc4");
 354         if(!st) {
 355             st = rrdset_create("nfs", "proc4", NULL, "nfsv4rpc", NULL, "NFS v4 Client Remote Procedure Calls", "calls/s", 5011, update_every, RRDSET_TYPE_STACKED);
 356
 357             for(i = 0; nfs_proc4_values[i].present ; i++)
 358                 rrddim_add(st, nfs_proc4_values[i].name, NULL, 1, 1, RRDDIM_INCREMENTAL);
 359         }
 360         else rrdset_next(st);
 361
 362         for(i = 0; nfs_proc4_values[i].present ; i++)
 363             rrddim_set(st, nfs_proc4_values[i].name, nfs_proc4_values[i].value);
 364
 365         rrdset_done(st);
 366     }
 367
 368     return 0;
 369 }