diff options
Diffstat (limited to 'src/pmdas/aix/netif.c')
| -rw-r--r-- | src/pmdas/aix/netif.c | 190 |
1 files changed, 190 insertions, 0 deletions
diff --git a/src/pmdas/aix/netif.c b/src/pmdas/aix/netif.c new file mode 100644 index 0000000..01e0ac6 --- /dev/null +++ b/src/pmdas/aix/netif.c @@ -0,0 +1,190 @@ +/* + * 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" + +static int nnetif; +static int nnetif_alloc; +static int *fetched; +static perfstat_netinterface_t *netifstat; + +void +netif_init(int first) +{ + perfstat_id_t id; + int i; + + if (!first) + /* TODO ... not sure if/when we'll use this re-init hook */ + return; + + nnetif = perfstat_netinterface(NULL, NULL, sizeof(perfstat_netinterface_t), 0); + if ((fetched = (int *)malloc(nnetif * sizeof(int))) == NULL) { + fprintf(stderr, "netif_init: fetched malloc[%d] failed: %s\n", + nnetif * sizeof(int), osstrerror()); + exit(1); + } + if ((netifstat = (perfstat_netinterface_t *)malloc(nnetif * sizeof(perfstat_netinterface_t))) == NULL) { + fprintf(stderr, "netif_init: netifstat malloc[%d] failed: %s\n", + nnetif * sizeof(perfstat_netinterface_t), osstrerror()); + exit(1); + } + nnetif_alloc = nnetif; + + /* + * set up instance domain + */ + strcpy(id.name, ""); + nnetif = perfstat_netinterface(&id, netifstat, sizeof(perfstat_netinterface_t), nnetif_alloc); + + indomtab[NETIF_INDOM].it_numinst = nnetif; + indomtab[NETIF_INDOM].it_set = (pmdaInstid *)malloc(nnetif * sizeof(pmdaInstid)); + if (indomtab[NETIF_INDOM].it_set == NULL) { + fprintf(stderr, "netif_init: indomtab malloc[%d] failed: %s\n", + nnetif * sizeof(pmdaInstid), osstrerror()); + exit(1); + } + for (i = 0; i < nnetif; i++) { + indomtab[NETIF_INDOM].it_set[i].i_inst = i; + indomtab[NETIF_INDOM].it_set[i].i_name = strdup(netifstat[i].name); + } + +#ifdef PCP_DEBUG + if ((pmDebug & (DBG_TRACE_APPL0|DBG_TRACE_APPL2)) == (DBG_TRACE_APPL0|DBG_TRACE_APPL2)) { + /* desperate */ + fprintf(stderr, "netif_init: nnetif=%d\n", nnetif); + } +#endif +} + +void +netif_prefetch(void) +{ + int i; + + for (i = 0; i < nnetif_alloc; i++) + fetched[i] = 0; +} + +static __uint64_t +netif_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) { + case PMDA_PMID(0,58): /* hinv.nnetif */ + val = nnetif; + break; + + case PMDA_PMID(0,65): /* network.interface.total.packets */ + val = netifstat[inst].ipackets + netifstat[inst].opackets; + break; + + case PMDA_PMID(0,66): /* network.interface.total.bytes */ + val = netifstat[inst].ibytes + netifstat[inst].obytes; + break; + + default: + fprintf(stderr, "netif_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, "netif_derived: pmid %s inst %d val %llu\n", + pmIDStr(mdesc->m_desc.pmid), inst, val); + } +#endif + + return val; +} + +int +netif_fetch(pmdaMetric *mdesc, int inst, pmAtomValue *atom) +{ + int offset; + + if (fetched[inst] == 0) { + int sts; + int i; + perfstat_id_t id; + + strcpy(id.name, ""); + sts = perfstat_netinterface(&id, netifstat, sizeof(perfstat_netinterface_t), nnetif_alloc); + + /* TODO ... + * - if sts != nnetif, the number of network interfaces has changed, + * need to set fetched[i] to -1 for the missing ones + * - is sts > nnetif possible? worse, if the number of network + * interfaces is > nnetif_alloc what should we do? + * - possibly reshape the instance domain? + * - error handling? + */ + + for (i = 0; i < nnetif; i++) { + fetched[i] = 1; + } + } + + /* hinv.nnetif is a singular metric ... so no "instance" for this one */ + if (inst != PM_IN_NULL && fetched[inst] != 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 = netif_derived(mdesc, inst); + else { + __uint64_t *ullp; + ullp = (__uint64_t *)&((char *)&netifstat[inst])[offset]; + atom->ull = *ullp; + } +#ifdef PCP_DEBUG + if ((pmDebug & (DBG_TRACE_APPL0|DBG_TRACE_APPL2)) == (DBG_TRACE_APPL0|DBG_TRACE_APPL2)) { + /* desperate */ + fprintf(stderr, "netif_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)netif_derived(mdesc, inst); + else { + __uint32_t *ulp; + ulp = (__uint32_t *)&((char *)&netifstat[inst])[offset]; + atom->ul = *ulp; + } +#ifdef PCP_DEBUG + if ((pmDebug & (DBG_TRACE_APPL0|DBG_TRACE_APPL2)) == (DBG_TRACE_APPL0|DBG_TRACE_APPL2)) { + /* desperate */ + fprintf(stderr, "netif_fetch: pmid %s inst %d val %lu\n", + pmIDStr(mdesc->m_desc.pmid), inst, atom->ul); + } +#endif + } + + return 1; +} |