diff options
| author | Igor Pashev <pashev.igor@gmail.com> | 2014-10-26 12:33:50 +0400 |
|---|---|---|
| committer | Igor Pashev <pashev.igor@gmail.com> | 2014-10-26 12:33:50 +0400 |
| commit | 47e6e7c84f008a53061e661f31ae96629bc694ef (patch) | |
| tree | 648a07f3b5b9d67ce19b0fd72e8caa1175c98f1a /src/pmdas/linux/swapdev.c | |
| download | pcp-debian.tar.gz | |
Debian 3.9.10debian/3.9.10debian
Diffstat (limited to 'src/pmdas/linux/swapdev.c')
| -rw-r--r-- | src/pmdas/linux/swapdev.c | 72 |
1 files changed, 72 insertions, 0 deletions
diff --git a/src/pmdas/linux/swapdev.c b/src/pmdas/linux/swapdev.c new file mode 100644 index 0000000..0b5521e --- /dev/null +++ b/src/pmdas/linux/swapdev.c @@ -0,0 +1,72 @@ +/* + * Linux Swap Device Cluster + * + * Copyright (c) 2014 Red Hat. + * Copyright (c) 2000,2004 Silicon Graphics, Inc. All Rights Reserved. + * + * This program is free software; you can redistribute it and/or modify it + * under the terms of the GNU General Public License as published by the + * Free Software Foundation; either version 2 of the License, or (at your + * option) any later version. + * + * This program is distributed in the hope that it will be useful, but + * WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY + * or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License + * for more details. + */ + +#include "pmapi.h" +#include "impl.h" +#include "pmda.h" +#include "indom.h" +#include "swapdev.h" + +int +refresh_swapdev(pmInDom swapdev_indom) +{ + char buf[MAXPATHLEN]; + swapdev_t *swap; + FILE *fp; + char *path; + char *size; + char *used; + char *priority; + int sts; + + pmdaCacheOp(swapdev_indom, PMDA_CACHE_INACTIVE); + + if ((fp = linux_statsfile("/proc/swaps", buf, sizeof(buf))) == NULL) + return -oserror(); + + while (fgets(buf, sizeof(buf), fp) != NULL) { + if (buf[0] != '/') + continue; + if ((path = strtok(buf, " \t")) == 0) + continue; + if ((/*type: */ strtok(NULL, " \t")) == NULL || + (size = strtok(NULL, " \t")) == NULL || + (used = strtok(NULL, " \t")) == NULL || + (priority = strtok(NULL, " \t")) == NULL) + continue; + sts = pmdaCacheLookupName(swapdev_indom, path, NULL, (void **)&swap); + if (sts == PMDA_CACHE_ACTIVE) /* repeated line in /proc/swaps? */ + continue; + if (sts == PMDA_CACHE_INACTIVE) { /* re-activate an old swap device */ + pmdaCacheStore(swapdev_indom, PMDA_CACHE_ADD, path, swap); + } + else { /* new swap device */ + if ((swap = malloc(sizeof(swapdev_t))) == NULL) + continue; +#if PCP_DEBUG + if (pmDebug & DBG_TRACE_LIBPMDA) + fprintf(stderr, "refresh_swapdev: add \"%s\"\n", path); +#endif + pmdaCacheStore(swapdev_indom, PMDA_CACHE_ADD, path, swap); + } + sscanf(size, "%u", &swap->size); + sscanf(used, "%u", &swap->used); + sscanf(priority, "%d", &swap->priority); + } + fclose(fp); + return 0; +} |