/** * collectd - src/vmem.c * Copyright (C) 2008-2010 Florian octo Forster * * Permission is hereby granted, free of charge, to any person obtaining a * copy of this software and associated documentation files (the "Software"), * to deal in the Software without restriction, including without limitation * the rights to use, copy, modify, merge, publish, distribute, sublicense, * and/or sell copies of the Software, and to permit persons to whom the * Software is furnished to do so, subject to the following conditions: * * The above copyright notice and this permission notice shall be included in * all copies or substantial portions of the Software. * * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER * DEALINGS IN THE SOFTWARE. * * Authors: * Florian octo Forster **/ #include "collectd.h" #include "plugin.h" #include "utils/common/common.h" #if KERNEL_LINUX static const char *config_keys[] = {"Verbose"}; static int config_keys_num = STATIC_ARRAY_SIZE(config_keys); static int verbose_output; /* #endif KERNEL_LINUX */ #else #error "No applicable input method." #endif /* HAVE_LIBSTATGRAB */ static void submit(const char *plugin_instance, const char *type, const char *type_instance, value_t *values, int values_len) { value_list_t vl = VALUE_LIST_INIT; vl.values = values; vl.values_len = values_len; sstrncpy(vl.plugin, "vmem", sizeof(vl.plugin)); if (plugin_instance != NULL) sstrncpy(vl.plugin_instance, plugin_instance, sizeof(vl.plugin_instance)); sstrncpy(vl.type, type, sizeof(vl.type)); if (type_instance != NULL) sstrncpy(vl.type_instance, type_instance, sizeof(vl.type_instance)); plugin_dispatch_values(&vl); } /* void vmem_submit */ static void submit_two(const char *plugin_instance, const char *type, const char *type_instance, derive_t c0, derive_t c1) { value_t values[] = { {.derive = c0}, {.derive = c1}, }; submit(plugin_instance, type, type_instance, values, STATIC_ARRAY_SIZE(values)); } /* void submit_one */ static void submit_one(const char *plugin_instance, const char *type, const char *type_instance, value_t value) { submit(plugin_instance, type, type_instance, &value, 1); } /* void submit_one */ static int vmem_config(const char *key, const char *value) { if (strcasecmp("Verbose", key) == 0) { if (IS_TRUE(value)) verbose_output = 1; else verbose_output = 0; } else { return -1; } return 0; } /* int vmem_config */ static int vmem_read(void) { #if KERNEL_LINUX derive_t pgpgin = 0; derive_t pgpgout = 0; int pgpgvalid = 0; derive_t pswpin = 0; derive_t pswpout = 0; int pswpvalid = 0; derive_t pgfault = 0; derive_t pgmajfault = 0; int pgfaultvalid = 0; FILE *fh; char buffer[1024]; fh = fopen("/proc/vmstat", "r"); if (fh == NULL) { ERROR("vmem plugin: fopen (/proc/vmstat) failed: %s", STRERRNO); return -1; } while (fgets(buffer, sizeof(buffer), fh) != NULL) { char *fields[4]; int fields_num; char *key; char *endptr; derive_t counter; gauge_t gauge; fields_num = strsplit(buffer, fields, STATIC_ARRAY_SIZE(fields)); if (fields_num != 2) continue; key = fields[0]; endptr = NULL; counter = strtoll(fields[1], &endptr, 10); if (fields[1] == endptr) continue; endptr = NULL; gauge = strtod(fields[1], &endptr); if (fields[1] == endptr) continue; /* * Number of pages * * The total number of {inst} pages, e. g dirty pages. */ if (strncmp("nr_", key, strlen("nr_")) == 0) { char *inst = key + strlen("nr_"); if (strcmp(inst, "dirtied") == 0 || strcmp(inst, "written") == 0) { value_t value = {.derive = counter}; submit_one(NULL, "vmpage_action", inst, value); } else { value_t value = {.gauge = gauge}; submit_one(NULL, "vmpage_number", inst, value); } } /* * Page in and page outs. For memory and swap. */ else if (strcmp("pgpgin", key) == 0) { pgpgin = counter; pgpgvalid |= 0x01; } else if (strcmp("pgpgout", key) == 0) { pgpgout = counter; pgpgvalid |= 0x02; } else if (strcmp("pswpin", key) == 0) { pswpin = counter; pswpvalid |= 0x01; } else if (strcmp("pswpout", key) == 0) { pswpout = counter; pswpvalid |= 0x02; } /* * Pagefaults */ else if (strcmp("pgfault", key) == 0) { pgfault = counter; pgfaultvalid |= 0x01; } else if (strcmp("pgmajfault", key) == 0) { pgmajfault = counter; pgfaultvalid |= 0x02; } /* * Skip the other statistics if verbose output is disabled. */ else if (verbose_output == 0) continue; /* * Number of page allocations, refills, steals and scans. This is collected * ``per zone'', i. e. for DMA, DMA32, normal and possibly highmem. */ else if (strncmp("pgalloc_", key, strlen("pgalloc_")) == 0) { char *inst = key + strlen("pgalloc_"); value_t value = {.derive = counter}; submit_one(inst, "vmpage_action", "alloc", value); } else if (strncmp("pgrefill_", key, strlen("pgrefill_")) == 0) { char *inst = key + strlen("pgrefill_"); value_t value = {.derive = counter}; submit_one(inst, "vmpage_action", "refill", value); } else if (strncmp("pgsteal_kswapd_", key, strlen("pgsteal_kswapd_")) == 0) { char *inst = key + strlen("pgsteal_kswapd_"); value_t value = {.derive = counter}; submit_one(inst, "vmpage_action", "steal_kswapd", value); } else if (strncmp("pgsteal_direct_", key, strlen("pgsteal_direct_")) == 0) { char *inst = key + strlen("pgsteal_direct_"); value_t value = {.derive = counter}; submit_one(inst, "vmpage_action", "steal_direct", value); } /* For backwards compatibility (somewhen before 4.2.3) */ else if (strncmp("pgsteal_", key, strlen("pgsteal_")) == 0) { char *inst = key + strlen("pgsteal_"); value_t value = {.derive = counter}; submit_one(inst, "vmpage_action", "steal", value); } else if (strncmp("pgscan_kswapd_", key, strlen("pgscan_kswapd_")) == 0) { char *inst = key + strlen("pgscan_kswapd_"); value_t value = {.derive = counter}; submit_one(inst, "vmpage_action", "scan_kswapd", value); } else if (strncmp("pgscan_direct_", key, strlen("pgscan_direct_")) == 0) { char *inst = key + strlen("pgscan_direct_"); value_t value = {.derive = counter}; submit_one(inst, "vmpage_action", "scan_direct", value); } /* * Page action * * number of pages moved to the active or inactive lists and freed, i. e. * removed from either list. */ else if (strcmp("pgfree", key) == 0) { value_t value = {.derive = counter}; submit_one(NULL, "vmpage_action", "free", value); } else if (strcmp("pgactivate", key) == 0) { value_t value = {.derive = counter}; submit_one(NULL, "vmpage_action", "activate", value); } else if (strcmp("pgdeactivate", key) == 0) { value_t value = {.derive = counter}; submit_one(NULL, "vmpage_action", "deactivate", value); } } /* while (fgets) */ fclose(fh); fh = NULL; if (pgfaultvalid == 0x03) submit_two(NULL, "vmpage_faults", NULL, pgfault, pgmajfault); if (pgpgvalid == 0x03) submit_two(NULL, "vmpage_io", "memory", pgpgin, pgpgout); if (pswpvalid == 0x03) submit_two(NULL, "vmpage_io", "swap", pswpin, pswpout); #endif /* KERNEL_LINUX */ return 0; } /* int vmem_read */ void module_register(void) { plugin_register_config("vmem", vmem_config, config_keys, config_keys_num); plugin_register_read("vmem", vmem_read); } /* void module_register */