diff options
Diffstat (limited to 'src/pmdas/aix/cpu_total.c')
| -rw-r--r-- | src/pmdas/aix/cpu_total.c | 133 |
1 files changed, 133 insertions, 0 deletions
diff --git a/src/pmdas/aix/cpu_total.c b/src/pmdas/aix/cpu_total.c new file mode 100644 index 0000000..bf3d118 --- /dev/null +++ b/src/pmdas/aix/cpu_total.c @@ -0,0 +1,133 @@ +/* + * Copyright (c) 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 "common.h" +#include <sys/m_param.h> + +static perfstat_cpu_total_t cpustat; +static int fetched; + +void +cpu_total_init(int first) +{ + if (!first) + /* TODO ... not sure if/when we'll use this re-init hook */ + return; +} + +void +cpu_total_prefetch(void) +{ + int i; + + fetched = 0; +} + +static __uint64_t +cpu_total_derived(pmdaMetric *mdesc, int inst) +{ + pmID pmid; + __pmID_int *ip = (__pmID_int *)&pmid; + __uint64_t val; + + pmid = mdesc->m_desc.pmid; + ip->domain = 0; + + switch (pmid) { + + default: + fprintf(stderr, "cpu_total_derived: Botch: no method for pmid %s\n", + pmIDStr(mdesc->m_desc.pmid)); + val = 0; + break; + } + +#ifdef PCP_DEBUG + if ((pmDebug & (DBG_TRACE_APPL0|DBG_TRACE_APPL2)) == (DBG_TRACE_APPL0|DBG_TRACE_APPL2)) { + /* desperate */ + fprintf(stderr, "cpu_total_derived: pmid %s inst %d val %llu\n", + pmIDStr(mdesc->m_desc.pmid), inst, val); + } +#endif + + return val; +} + +int +cpu_total_fetch(pmdaMetric *mdesc, int inst, pmAtomValue *atom) +{ + int offset; + + if (fetched == 0) { + int sts; + sts = perfstat_cpu_total(NULL, &cpustat, sizeof(perfstat_cpu_total_t), 1); + if (sts != 1) { + /* TODO - how to find/decode errors? */ + fprintf(stderr, "perfstat_cpu_total: failed %s\n", osstrerror()); + fetched = -1; + } + else + fetched = 1; + } + + if (fetched != 1) + return 0; + + offset = ((metricdesc_t *)mdesc->m_user)->md_offset; + if (offset == OFF_NOVALUES) + return 0; + + if (mdesc->m_desc.type == PM_TYPE_U64) { + if (offset == OFF_DERIVED) + atom->ull = cpu_total_derived(mdesc, inst); + else { + __uint64_t *ullp; + ullp = (__uint64_t *)&((char *)&cpustat)[offset]; + atom->ull = *ullp; + } + if (mdesc->m_desc.units.scaleTime == PM_TIME_MSEC) { + /* assumed to be CPU time */ + atom->ull *= 1000 / HZ; + } +#ifdef PCP_DEBUG + if ((pmDebug & (DBG_TRACE_APPL0|DBG_TRACE_APPL2)) == (DBG_TRACE_APPL0|DBG_TRACE_APPL2)) { + /* desperate */ + fprintf(stderr, "cpu_total_fetch: pmid %s inst %d val %llu\n", + pmIDStr(mdesc->m_desc.pmid), inst, atom->ull); + } +#endif + } + else { + if (offset == OFF_DERIVED) + atom->ul = (__uint32_t)cpu_total_derived(mdesc, inst); + else { + __uint32_t *ulp; + ulp = (__uint32_t *)&((char *)&cpustat)[offset]; + atom->ul = *ulp; + } + if (mdesc->m_desc.units.scaleTime == PM_TIME_MSEC) { + /* assumed to be CPU time */ + atom->ul *= 1000 / HZ; + } +#ifdef PCP_DEBUG + if ((pmDebug & (DBG_TRACE_APPL0|DBG_TRACE_APPL2)) == (DBG_TRACE_APPL0|DBG_TRACE_APPL2)) { + /* desperate */ + fprintf(stderr, "cpu_total_fetch: pmid %s inst %d val %lu\n", + pmIDStr(mdesc->m_desc.pmid), inst, atom->ul); + } +#endif + } + + return 1; +} |