src/proc_meminfo.c

   1 #include "common.h"
   2
   3 int do_proc_meminfo(int update_every, usec_t dt) {
   4     (void)dt;
   5
   6     static procfile *ff = NULL;
   7     static int do_ram = -1, do_swap = -1, do_hwcorrupt = -1, do_committed = -1, do_writeback = -1, do_kernel = -1, do_slab = -1;
   8     static uint32_t MemTotal_hash = 0,
   9             MemFree_hash = 0,
  10             Buffers_hash = 0,
  11             Cached_hash = 0,
  12             //SwapCached_hash = 0,
  13             //Active_hash = 0,
  14             //Inactive_hash = 0,
  15             //ActiveAnon_hash = 0,
  16             //InactiveAnon_hash = 0,
  17             //ActiveFile_hash = 0,
  18             //InactiveFile_hash = 0,
  19             //Unevictable_hash = 0,
  20             //Mlocked_hash = 0,
  21             SwapTotal_hash = 0,
  22             SwapFree_hash = 0,
  23             Dirty_hash = 0,
  24             Writeback_hash = 0,
  25             //AnonPages_hash = 0,
  26             //Mapped_hash = 0,
  27             //Shmem_hash = 0,
  28             Slab_hash = 0,
  29             SReclaimable_hash = 0,
  30             SUnreclaim_hash = 0,
  31             KernelStack_hash = 0,
  32             PageTables_hash = 0,
  33             NFS_Unstable_hash = 0,
  34             Bounce_hash = 0,
  35             WritebackTmp_hash = 0,
  36             //CommitLimit_hash = 0,
  37             Committed_AS_hash = 0,
  38             //VmallocTotal_hash = 0,
  39             VmallocUsed_hash = 0,
  40             //VmallocChunk_hash = 0,
  41             //AnonHugePages_hash = 0,
  42             //HugePages_Total_hash = 0,
  43             //HugePages_Free_hash = 0,
  44             //HugePages_Rsvd_hash = 0,
  45             //HugePages_Surp_hash = 0,
  46             //Hugepagesize_hash = 0,
  47             //DirectMap4k_hash = 0,
  48             //DirectMap2M_hash = 0,
  49             HardwareCorrupted_hash = 0;
  50
  51     if(unlikely(do_ram == -1)) {
  52         do_ram          = config_get_boolean("plugin:proc:/proc/meminfo", "system ram", 1);
  53         do_swap         = config_get_boolean_ondemand("plugin:proc:/proc/meminfo", "system swap", CONFIG_ONDEMAND_ONDEMAND);
  54         do_hwcorrupt    = config_get_boolean_ondemand("plugin:proc:/proc/meminfo", "hardware corrupted ECC", CONFIG_ONDEMAND_ONDEMAND);
  55         do_committed    = config_get_boolean("plugin:proc:/proc/meminfo", "committed memory", 1);
  56         do_writeback    = config_get_boolean("plugin:proc:/proc/meminfo", "writeback memory", 1);
  57         do_kernel       = config_get_boolean("plugin:proc:/proc/meminfo", "kernel memory", 1);
  58         do_slab         = config_get_boolean("plugin:proc:/proc/meminfo", "slab memory", 1);
  59
  60         MemTotal_hash = simple_hash("MemTotal");
  61         MemFree_hash = simple_hash("MemFree");
  62         Buffers_hash = simple_hash("Buffers");
  63         Cached_hash = simple_hash("Cached");
  64         //SwapCached_hash = simple_hash("SwapCached");
  65         //Active_hash = simple_hash("Active");
  66         //Inactive_hash = simple_hash("Inactive");
  67         //ActiveAnon_hash = simple_hash("ActiveAnon");
  68         //InactiveAnon_hash = simple_hash("InactiveAnon");
  69         //ActiveFile_hash = simple_hash("ActiveFile");
  70         //InactiveFile_hash = simple_hash("InactiveFile");
  71         //Unevictable_hash = simple_hash("Unevictable");
  72         //Mlocked_hash = simple_hash("Mlocked");
  73         SwapTotal_hash = simple_hash("SwapTotal");
  74         SwapFree_hash = simple_hash("SwapFree");
  75         Dirty_hash = simple_hash("Dirty");
  76         Writeback_hash = simple_hash("Writeback");
  77         //AnonPages_hash = simple_hash("AnonPages");
  78         //Mapped_hash = simple_hash("Mapped");
  79         //Shmem_hash = simple_hash("Shmem");
  80         Slab_hash = simple_hash("Slab");
  81         SReclaimable_hash = simple_hash("SReclaimable");
  82         SUnreclaim_hash = simple_hash("SUnreclaim");
  83         KernelStack_hash = simple_hash("KernelStack");
  84         PageTables_hash = simple_hash("PageTables");
  85         NFS_Unstable_hash = simple_hash("NFS_Unstable");
  86         Bounce_hash = simple_hash("Bounce");
  87         WritebackTmp_hash = simple_hash("WritebackTmp");
  88         //CommitLimit_hash = simple_hash("CommitLimit");
  89         Committed_AS_hash = simple_hash("Committed_AS");
  90         //VmallocTotal_hash = simple_hash("VmallocTotal");
  91         VmallocUsed_hash = simple_hash("VmallocUsed");
  92         //VmallocChunk_hash = simple_hash("VmallocChunk");
  93         HardwareCorrupted_hash = simple_hash("HardwareCorrupted");
  94         //AnonHugePages_hash = simple_hash("AnonHugePages");
  95         //HugePages_Total_hash = simple_hash("HugePages_Total");
  96         //HugePages_Free_hash = simple_hash("HugePages_Free");
  97         //HugePages_Rsvd_hash = simple_hash("HugePages_Rsvd");
  98         //HugePages_Surp_hash = simple_hash("HugePages_Surp");
  99         //Hugepagesize_hash = simple_hash("Hugepagesize");
 100         //DirectMap4k_hash = simple_hash("DirectMap4k");
 101         //DirectMap2M_hash = simple_hash("DirectMap2M");
 102     }
 103
 104     if(unlikely(!ff)) {
 105         char filename[FILENAME_MAX + 1];
 106         snprintfz(filename, FILENAME_MAX, "%s%s", global_host_prefix, "/proc/meminfo");
 107         ff = procfile_open(config_get("plugin:proc:/proc/meminfo", "filename to monitor", filename), " \t:", PROCFILE_FLAG_DEFAULT);
 108         if(unlikely(!ff))
 109             return 1;
 110     }
 111
 112     ff = procfile_readall(ff);
 113     if(unlikely(!ff))
 114         return 0; // we return 0, so that we will retry to open it next time
 115
 116     uint32_t lines = procfile_lines(ff), l;
 117
 118     int hwcorrupted = 0;
 119
 120     unsigned long long MemTotal = 0,
 121             MemFree = 0,
 122             Buffers = 0,
 123             Cached = 0,
 124             //SwapCached = 0,
 125             //Active = 0,
 126             //Inactive = 0,
 127             //ActiveAnon = 0,
 128             //InactiveAnon = 0,
 129             //ActiveFile = 0,
 130             //InactiveFile = 0,
 131             //Unevictable = 0,
 132             //Mlocked = 0,
 133             SwapTotal = 0,
 134             SwapFree = 0,
 135             Dirty = 0,
 136             Writeback = 0,
 137             //AnonPages = 0,
 138             //Mapped = 0,
 139             //Shmem = 0,
 140             Slab = 0,
 141             SReclaimable = 0,
 142             SUnreclaim = 0,
 143             KernelStack = 0,
 144             PageTables = 0,
 145             NFS_Unstable = 0,
 146             Bounce = 0,
 147             WritebackTmp = 0,
 148             //CommitLimit = 0,
 149             Committed_AS = 0,
 150             //VmallocTotal = 0,
 151             VmallocUsed = 0,
 152             //VmallocChunk = 0,
 153             //AnonHugePages = 0,
 154             //HugePages_Total = 0,
 155             //HugePages_Free = 0,
 156             //HugePages_Rsvd = 0,
 157             //HugePages_Surp = 0,
 158             //Hugepagesize = 0,
 159             //DirectMap4k = 0,
 160             //DirectMap2M = 0,
 161             HardwareCorrupted = 0;
 162
 163     for(l = 0; l < lines ;l++) {
 164         uint32_t words = procfile_linewords(ff, l);
 165         if(unlikely(words < 2)) continue;
 166
 167         char *name = procfile_lineword(ff, l, 0);
 168         uint32_t hash = simple_hash(name);
 169         unsigned long long value = strtoull(procfile_lineword(ff, l, 1), NULL, 10);
 170
 171              if(hash == MemTotal_hash && strcmp(name, "MemTotal") == 0) MemTotal = value;
 172         else if(hash == MemFree_hash && strcmp(name, "MemFree") == 0) MemFree = value;
 173         else if(hash == Buffers_hash && strcmp(name, "Buffers") == 0) Buffers = value;
 174         else if(hash == Cached_hash && strcmp(name, "Cached") == 0) Cached = value;
 175         //else if(hash == SwapCached_hash && strcmp(name, "SwapCached") == 0) SwapCached = value;
 176         //else if(hash == Active_hash && strcmp(name, "Active") == 0) Active = value;
 177         //else if(hash == Inactive_hash && strcmp(name, "Inactive") == 0) Inactive = value;
 178         //else if(hash == ActiveAnon_hash && strcmp(name, "ActiveAnon") == 0) ActiveAnon = value;
 179         //else if(hash == InactiveAnon_hash && strcmp(name, "InactiveAnon") == 0) InactiveAnon = value;
 180         //else if(hash == ActiveFile_hash && strcmp(name, "ActiveFile") == 0) ActiveFile = value;
 181         //else if(hash == InactiveFile_hash && strcmp(name, "InactiveFile") == 0) InactiveFile = value;
 182         //else if(hash == Unevictable_hash && strcmp(name, "Unevictable") == 0) Unevictable = value;
 183         //else if(hash == Mlocked_hash && strcmp(name, "Mlocked") == 0) Mlocked = value;
 184         else if(hash == SwapTotal_hash && strcmp(name, "SwapTotal") == 0) SwapTotal = value;
 185         else if(hash == SwapFree_hash && strcmp(name, "SwapFree") == 0) SwapFree = value;
 186         else if(hash == Dirty_hash && strcmp(name, "Dirty") == 0) Dirty = value;
 187         else if(hash == Writeback_hash && strcmp(name, "Writeback") == 0) Writeback = value;
 188         //else if(hash == AnonPages_hash && strcmp(name, "AnonPages") == 0) AnonPages = value;
 189         //else if(hash == Mapped_hash && strcmp(name, "Mapped") == 0) Mapped = value;
 190         //else if(hash == Shmem_hash && strcmp(name, "Shmem") == 0) Shmem = value;
 191         else if(hash == Slab_hash && strcmp(name, "Slab") == 0) Slab = value;
 192         else if(hash == SReclaimable_hash && strcmp(name, "SReclaimable") == 0) SReclaimable = value;
 193         else if(hash == SUnreclaim_hash && strcmp(name, "SUnreclaim") == 0) SUnreclaim = value;
 194         else if(hash == KernelStack_hash && strcmp(name, "KernelStack") == 0) KernelStack = value;
 195         else if(hash == PageTables_hash && strcmp(name, "PageTables") == 0) PageTables = value;
 196         else if(hash == NFS_Unstable_hash && strcmp(name, "NFS_Unstable") == 0) NFS_Unstable = value;
 197         else if(hash == Bounce_hash && strcmp(name, "Bounce") == 0) Bounce = value;
 198         else if(hash == WritebackTmp_hash && strcmp(name, "WritebackTmp") == 0) WritebackTmp = value;
 199         //else if(hash == CommitLimit_hash && strcmp(name, "CommitLimit") == 0) CommitLimit = value;
 200         else if(hash == Committed_AS_hash && strcmp(name, "Committed_AS") == 0) Committed_AS = value;
 201         //else if(hash == VmallocTotal_hash && strcmp(name, "VmallocTotal") == 0) VmallocTotal = value;
 202         else if(hash == VmallocUsed_hash && strcmp(name, "VmallocUsed") == 0) VmallocUsed = value;
 203         //else if(hash == VmallocChunk_hash && strcmp(name, "VmallocChunk") == 0) VmallocChunk = value;
 204         else if(hash == HardwareCorrupted_hash && strcmp(name, "HardwareCorrupted") == 0) { HardwareCorrupted = value; hwcorrupted = 1; }
 205         //else if(hash == AnonHugePages_hash && strcmp(name, "AnonHugePages") == 0) AnonHugePages = value;
 206         //else if(hash == HugePages_Total_hash && strcmp(name, "HugePages_Total") == 0) HugePages_Total = value;
 207         //else if(hash == HugePages_Free_hash && strcmp(name, "HugePages_Free") == 0) HugePages_Free = value;
 208         //else if(hash == HugePages_Rsvd_hash && strcmp(name, "HugePages_Rsvd") == 0) HugePages_Rsvd = value;
 209         //else if(hash == HugePages_Surp_hash && strcmp(name, "HugePages_Surp") == 0) HugePages_Surp = value;
 210         //else if(hash == Hugepagesize_hash && strcmp(name, "Hugepagesize") == 0) Hugepagesize = value;
 211         //else if(hash == DirectMap4k_hash && strcmp(name, "DirectMap4k") == 0) DirectMap4k = value;
 212         //else if(hash == DirectMap2M_hash && strcmp(name, "DirectMap2M") == 0) DirectMap2M = value;
 213     }
 214
 215     RRDSET *st;
 216
 217     // --------------------------------------------------------------------
 218
 219     // http://stackoverflow.com/questions/3019748/how-to-reliably-measure-available-memory-in-linux
 220     unsigned long long MemUsed = MemTotal - MemFree - Cached - Buffers;
 221
 222     if(do_ram) {
 223         st = rrdset_find("system.ram");
 224         if(!st) {
 225             st = rrdset_create("system", "ram", NULL, "ram", NULL, "System RAM", "MB", 200, update_every, RRDSET_TYPE_STACKED);
 226
 227             rrddim_add(st, "free",    NULL, 1, 1024, RRDDIM_ABSOLUTE);
 228             rrddim_add(st, "used",    NULL, 1, 1024, RRDDIM_ABSOLUTE);
 229             rrddim_add(st, "cached",  NULL, 1, 1024, RRDDIM_ABSOLUTE);
 230             rrddim_add(st, "buffers", NULL, 1, 1024, RRDDIM_ABSOLUTE);
 231         }
 232         else rrdset_next(st);
 233
 234         rrddim_set(st, "free", MemFree);
 235         rrddim_set(st, "used", MemUsed);
 236         rrddim_set(st, "cached", Cached);
 237         rrddim_set(st, "buffers", Buffers);
 238         rrdset_done(st);
 239     }
 240
 241     // --------------------------------------------------------------------
 242
 243     unsigned long long SwapUsed = SwapTotal - SwapFree;
 244
 245     if(SwapTotal || SwapUsed || SwapFree || do_swap == CONFIG_ONDEMAND_YES) {
 246         do_swap = CONFIG_ONDEMAND_YES;
 247
 248         st = rrdset_find("system.swap");
 249         if(!st) {
 250             st = rrdset_create("system", "swap", NULL, "swap", NULL, "System Swap", "MB", 201, update_every, RRDSET_TYPE_STACKED);
 251             st->isdetail = 1;
 252
 253             rrddim_add(st, "free",    NULL, 1, 1024, RRDDIM_ABSOLUTE);
 254             rrddim_add(st, "used",    NULL, 1, 1024, RRDDIM_ABSOLUTE);
 255         }
 256         else rrdset_next(st);
 257
 258         rrddim_set(st, "used", SwapUsed);
 259         rrddim_set(st, "free", SwapFree);
 260         rrdset_done(st);
 261     }
 262
 263     // --------------------------------------------------------------------
 264
 265     if(hwcorrupted && do_hwcorrupt && HardwareCorrupted > 0) {
 266         do_hwcorrupt = CONFIG_ONDEMAND_YES;
 267
 268         st = rrdset_find("mem.hwcorrupt");
 269         if(!st) {
 270             st = rrdset_create("mem", "hwcorrupt", NULL, "errors", NULL, "Hardware Corrupted ECC", "MB", 9000, update_every, RRDSET_TYPE_LINE);
 271             st->isdetail = 1;
 272
 273             rrddim_add(st, "HardwareCorrupted", NULL, 1, 1024, RRDDIM_ABSOLUTE);
 274         }
 275         else rrdset_next(st);
 276
 277         rrddim_set(st, "HardwareCorrupted", HardwareCorrupted);
 278         rrdset_done(st);
 279     }
 280
 281     // --------------------------------------------------------------------
 282
 283     if(do_committed) {
 284         st = rrdset_find("mem.committed");
 285         if(!st) {
 286             st = rrdset_create("mem", "committed", NULL, "system", NULL, "Committed (Allocated) Memory", "MB", 5000, update_every, RRDSET_TYPE_AREA);
 287             st->isdetail = 1;
 288
 289             rrddim_add(st, "Committed_AS", NULL, 1, 1024, RRDDIM_ABSOLUTE);
 290         }
 291         else rrdset_next(st);
 292
 293         rrddim_set(st, "Committed_AS", Committed_AS);
 294         rrdset_done(st);
 295     }
 296
 297     // --------------------------------------------------------------------
 298
 299     if(do_writeback) {
 300         st = rrdset_find("mem.writeback");
 301         if(!st) {
 302             st = rrdset_create("mem", "writeback", NULL, "kernel", NULL, "Writeback Memory", "MB", 4000, update_every, RRDSET_TYPE_LINE);
 303             st->isdetail = 1;
 304
 305             rrddim_add(st, "Dirty", NULL, 1, 1024, RRDDIM_ABSOLUTE);
 306             rrddim_add(st, "Writeback", NULL, 1, 1024, RRDDIM_ABSOLUTE);
 307             rrddim_add(st, "FuseWriteback", NULL, 1, 1024, RRDDIM_ABSOLUTE);
 308             rrddim_add(st, "NfsWriteback", NULL, 1, 1024, RRDDIM_ABSOLUTE);
 309             rrddim_add(st, "Bounce", NULL, 1, 1024, RRDDIM_ABSOLUTE);
 310         }
 311         else rrdset_next(st);
 312
 313         rrddim_set(st, "Dirty", Dirty);
 314         rrddim_set(st, "Writeback", Writeback);
 315         rrddim_set(st, "FuseWriteback", WritebackTmp);
 316         rrddim_set(st, "NfsWriteback", NFS_Unstable);
 317         rrddim_set(st, "Bounce", Bounce);
 318         rrdset_done(st);
 319     }
 320
 321     // --------------------------------------------------------------------
 322
 323     if(do_kernel) {
 324         st = rrdset_find("mem.kernel");
 325         if(!st) {
 326             st = rrdset_create("mem", "kernel", NULL, "kernel", NULL, "Memory Used by Kernel", "MB", 6000, update_every, RRDSET_TYPE_STACKED);
 327             st->isdetail = 1;
 328
 329             rrddim_add(st, "Slab", NULL, 1, 1024, RRDDIM_ABSOLUTE);
 330             rrddim_add(st, "KernelStack", NULL, 1, 1024, RRDDIM_ABSOLUTE);
 331             rrddim_add(st, "PageTables", NULL, 1, 1024, RRDDIM_ABSOLUTE);
 332             rrddim_add(st, "VmallocUsed", NULL, 1, 1024, RRDDIM_ABSOLUTE);
 333         }
 334         else rrdset_next(st);
 335
 336         rrddim_set(st, "KernelStack", KernelStack);
 337         rrddim_set(st, "Slab", Slab);
 338         rrddim_set(st, "PageTables", PageTables);
 339         rrddim_set(st, "VmallocUsed", VmallocUsed);
 340         rrdset_done(st);
 341     }
 342
 343     // --------------------------------------------------------------------
 344
 345     if(do_slab) {
 346         st = rrdset_find("mem.slab");
 347         if(!st) {
 348             st = rrdset_create("mem", "slab", NULL, "slab", NULL, "Reclaimable Kernel Memory", "MB", 6500, update_every, RRDSET_TYPE_STACKED);
 349             st->isdetail = 1;
 350
 351             rrddim_add(st, "reclaimable", NULL, 1, 1024, RRDDIM_ABSOLUTE);
 352             rrddim_add(st, "unreclaimable", NULL, 1, 1024, RRDDIM_ABSOLUTE);
 353         }
 354         else rrdset_next(st);
 355
 356         rrddim_set(st, "reclaimable", SReclaimable);
 357         rrddim_set(st, "unreclaimable", SUnreclaim);
 358         rrdset_done(st);
 359     }
 360
 361     return 0;
 362 }
 363