diff options
Diffstat (limited to 'src/dbpmda/src/pmda.c')
| -rw-r--r-- | src/dbpmda/src/pmda.c | 840 |
1 files changed, 840 insertions, 0 deletions
diff --git a/src/dbpmda/src/pmda.c b/src/dbpmda/src/pmda.c new file mode 100644 index 0000000..d9b454b --- /dev/null +++ b/src/dbpmda/src/pmda.c @@ -0,0 +1,840 @@ +/* + * Copyright (c) 2013 Red Hat. + * Copyright (c) 1995,2003,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 <sys/stat.h> +#include "pmapi.h" +#include "impl.h" + +#ifdef HAVE_VALUES_H +#include <values.h> +#endif +#include <float.h> +#ifdef HAVE_SYS_SOCKET_H +#include <sys/socket.h> +#endif +#ifdef HAVE_SYS_UN_H +#include <sys/un.h> +#endif + +#include "./dbpmda.h" +#include "./lex.h" +#include "./gram.h" + +static __pmTimeval now = { 0, 0 }; + +int infd; +int outfd; +char *myPmdaName = 0; + +extern int _creds_timeout; + +#ifndef HAVE_STRTOLL +/* + * cheap hack ...won't work for large values! + */ +static __int64_t +strtoll(char *p, char **endp, int base) +{ + return (__int64_t)strtol(p, endp, base); +} +#endif + +#ifndef HAVE_STRTOULL +/* + * cheap hack ...won't work for large values! + */ +static __uint64_t +strtoull(char *p, char **endp, int base) +{ + return (__uint64_t)strtoul(p, endp, base); +} +#endif + +/* version exchange - get a credentials PDU from 2.0 agents */ + +static int +agent_creds(__pmPDU *pb) +{ + int i; + int sts = 0; + int version = UNKNOWN_VERSION; + int credcount = 0; + int sender = 0; + int vflag = 0; + __pmCred *credlist = NULL; + + if ((sts = __pmDecodeCreds(pb, &sender, &credcount, &credlist)) < 0) + return sts; + + for (i = 0; i < credcount; i++) { +#ifdef PCP_DEBUG + if (pmDebug & DBG_TRACE_CONTEXT) + fprintf(stderr, "agent_creds: doing cred #%d from PID %d\n", i+1, sender); +#endif + switch(credlist[i].c_type) { + case CVERSION: + version = credlist[i].c_vala; + vflag = 1; +#ifdef PCP_DEBUG + if (pmDebug & DBG_TRACE_CONTEXT) + fprintf(stderr, "agent_creds: version cred (%u)\n", version); +#endif + break; + } + } + + if (credlist) + free(credlist); + + if (((sts = __pmSetVersionIPC(infd, version)) < 0) || + ((sts = __pmSetVersionIPC(outfd, version)) < 0)) + return sts; + + if (vflag) { /* complete the version exchange - respond to agent */ + __pmCred handshake[1]; + + handshake[0].c_type = CVERSION; + handshake[0].c_vala = PDU_VERSION; + handshake[0].c_valb = 0; + handshake[0].c_valc = 0; + if ((sts = __pmSendCreds(outfd, (int)getpid(), 1, handshake)) < 0) + return sts; + } + + return 0; +} + +static void +pmdaversion(void) +{ + int sts; + __pmPDU *ack; + int pinpdu; + + pinpdu = sts = __pmGetPDU(infd, ANY_SIZE, _creds_timeout, &ack); + if (sts == PDU_CREDS) { + if ((sts = agent_creds(ack)) < 0) { + fprintf(stderr, "Warning: version exchange failed " + "for PMDA %s: %s\n", myPmdaName, pmErrStr(sts)); + } + } + else { + if (sts < 0) + fprintf(stderr, "__pmGetPDU(%d): %s\n", infd, pmErrStr(sts)); + else + fprintf(stderr, "pmdaversion: expecting PDU_CREDS, got PDU type %d\n", sts); + fprintf(stderr, "Warning: no version exchange with PMDA %s\n", + myPmdaName); + } + if (pinpdu > 0) + __pmUnpinPDUBuf(ack); +} + +void +openpmda(char *fname) +{ + int i; + struct stat buf; + + if (stat(fname, &buf) < 0) { + fprintf(stderr, "openpmda: %s: %s\n", fname, osstrerror()); + return; + } + + closepmda(); + free(param.argv[0]); + param.argv[0] = strdup(fname); + param.argc--; + printf("Start %s PMDA: %s", basename(param.argv[0]), fname); + for (i = 1; i < param.argc; i++) + printf(" %s", param.argv[i]); + putchar('\n'); + + if (__pmProcessCreate(param.argv, &infd, &outfd) < (pid_t)0) { + fprintf(stderr, "openpmda: create process: %s\n", osstrerror()); + } + else { + connmode = CONN_DAEMON; + reset_profile(); + if (myPmdaName != NULL) + free(myPmdaName); + myPmdaName = strdup(fname); + pmdaversion(); + } +} + +#ifdef HAVE_STRUCT_SOCKADDR_UN +void +open_unix_socket(char *fname) +{ + int fd; + struct stat buf; + struct sockaddr_un s_un; + int len; + + if (stat(fname, &buf) < 0) { + fprintf(stderr, "opensocket: %s: %s\n", fname, osstrerror()); + return; + } + + fd = socket(AF_UNIX, SOCK_STREAM, 0); + if (fd < 0) { + fprintf(stderr, "opensocket: socket: %s\n", netstrerror()); + return; + } + + memset(&s_un, 0, sizeof(s_un)); + s_un.sun_family = AF_UNIX; + strncpy(s_un.sun_path, fname, strlen(fname)); + len = (int)offsetof(struct sockaddr_un, sun_path) + (int)strlen(s_un.sun_path); + + closepmda(); + + if (connect(fd, (struct sockaddr *)&s_un, len) < 0) { + fprintf(stderr, "opensocket: connect: %s\n", netstrerror()); + close(fd); + return; + } + + infd = fd; + outfd = fd; + + printf("Connect to PMDA on socket %s\n", fname); + + connmode = CONN_DAEMON; + reset_profile(); + if (myPmdaName != NULL) + free(myPmdaName); + myPmdaName = strdup(fname); + pmdaversion(); +} +#else +void +open_unix_socket(char *fname) +{ + __pmNotifyErr(LOG_CRIT, "UNIX domain sockets unsupported\n"); +} +#endif + +static void +open_socket(int port, int family, const char *protocol) +{ + __pmSockAddr *addr; + int fd, sts; + char socket[64]; + + fd = (family == AF_INET) ? __pmCreateSocket() : __pmCreateIPv6Socket(); + if (fd < 0) { + fprintf(stderr, "opensocket: socket: %s\n", netstrerror()); + return; + } + + addr = __pmLoopBackAddress(family); + if (addr == NULL) { + fprintf(stderr, "opensocket: loopback: %s\n", netstrerror()); + __pmCloseSocket(fd); + return; + } + + closepmda(); + + __pmSockAddrSetPort(addr, port); + sts = __pmConnect(fd, addr, __pmSockAddrSize()); + __pmSockAddrFree(addr); + + if (sts < 0) { + fprintf(stderr, "opensocket: connect: %s\n", netstrerror()); + __pmCloseSocket(fd); + return; + } + + infd = fd; + outfd = fd; + + sprintf(socket, "%s port %d", protocol, port); + printf("Connect to PMDA on %s\n", socket); + + connmode = CONN_DAEMON; + reset_profile(); + if (myPmdaName != NULL) + free(myPmdaName); + myPmdaName = strdup(socket); + pmdaversion(); +} + +void +open_inet_socket(int port) +{ + open_socket(port, AF_INET, "inet"); +} + +void +open_ipv6_socket(int port) +{ + open_socket(port, AF_INET6, "ipv6"); +} + +void +closepmda(void) +{ + if (connmode != NO_CONN) { + /* End of context logic mimics PMCD, no error checking is needed. */ + __pmSendError(outfd, FROM_ANON, PM_ERR_NOTCONN); + close(outfd); + close(infd); + __pmResetIPC(infd); + connmode = NO_CONN; + if (myPmdaName != NULL) { + free(myPmdaName); + myPmdaName = NULL; + } + } +} + + +int +dopmda_desc(pmID pmid, pmDesc *desc, int print) +{ + int sts; + __pmPDU *pb; + int i; + int pinpdu; + + if ((sts = __pmSendDescReq(outfd, FROM_ANON, pmid)) >= 0) { + if ((pinpdu = sts = __pmGetPDU(infd, ANY_SIZE, TIMEOUT_NEVER, &pb)) == PDU_DESC) { + if ((sts = __pmDecodeDesc(pb, desc)) >= 0) { + if (print) + __pmPrintDesc(stdout, desc); +#ifdef PCP_DEBUG + else if (pmDebug & DBG_TRACE_PDU) + __pmPrintDesc(stdout, desc); +#endif + } + else + printf("Error: __pmDecodeDesc() failed: %s\n", pmErrStr(sts)); + } + else if (sts == PDU_ERROR) { + if ((i = __pmDecodeError(pb, &sts)) >= 0) + printf("Error PDU: %s\n", pmErrStr(sts)); + else + printf("Error: __pmDecodeError() failed: %s\n", pmErrStr(i)); + } + else if (sts == 0) + printf("Error: __pmGetPDU() failed: PDU empty, PMDA may have died\n"); + else + printf("Error: __pmGetPDU() failed: wrong PDU (%x)\n", sts); + + if (pinpdu > 0) + __pmUnpinPDUBuf(pb); + } + else + printf("Error: __pmSendDescReq() failed: %s\n", pmErrStr(sts)); + + return sts; +} + +void +dopmda(int pdu) +{ + int sts; + pmDesc desc; + pmDesc *desc_list = NULL; + pmResult *result = NULL; + __pmInResult *inresult; + __pmPDU *pb; + int i; + int j; + int ident; + int length; + char *buffer; + struct timeval start; + struct timeval end; + char name[32]; + char **namelist; + int *statuslist; + int numnames; + pmID pmid; + int pinpdu; + + if (timer != 0) + __pmtimevalNow(&start); + + switch (pdu) { + + case PDU_DESC_REQ: + printf("PMID: %s\n", pmIDStr(param.pmid)); + sts = dopmda_desc(param.pmid, &desc, 1); + break; + + case PDU_FETCH: + printf("PMID(s):"); + for (i = 0; i < param.numpmid; i++) + printf(" %s", pmIDStr(param.pmidlist[i])); + putchar('\n'); + + if (get_desc) { + desc_list = (pmDesc *)malloc(param.numpmid * sizeof(pmDesc)); + if (desc_list == NULL) { + printf("Error: PDU fetch() failed: %s\n", pmErrStr(ENOMEM)); + return; + } + for (i = 0; i < param.numpmid; i++) { + if ((sts = dopmda_desc(param.pmidlist[i], &desc_list[i], 0)) < 0) { + free(desc_list); + return; + } + } + } + + sts = 0; + if (profile_changed) { + if ((sts = __pmSendProfile(outfd, FROM_ANON, 0, profile)) < 0) + printf("Error: __pmSendProfile() failed: %s\n", pmErrStr(sts)); + else + profile_changed = 0; + } + if (sts >= 0) { + if ((sts = __pmSendFetch(outfd, FROM_ANON, 0, NULL, param.numpmid, param.pmidlist)) >= 0) { + if ((pinpdu = sts = __pmGetPDU(infd, ANY_SIZE, TIMEOUT_NEVER, &pb)) == PDU_RESULT) { + if ((sts = __pmDecodeResult(pb, &result)) >= 0) { + if (get_desc) + _dbDumpResult(stdout, result, desc_list); + else + __pmDumpResult(stdout, result); + pmFreeResult(result); + } + else + printf("Error: __pmDecodeResult() failed: %s\n", pmErrStr(sts)); + } + else if (sts == PDU_ERROR) { + if ((i = __pmDecodeError(pb, &sts)) >= 0) + printf("Error PDU: %s\n", pmErrStr(sts)); + else + printf("Error: __pmDecodeError() failed: %s\n", pmErrStr(i)); + } + else if (sts == 0) + printf("Error: __pmGetPDU() failed: PDU empty, PMDA may have died\n"); + else + printf("Error: __pmGetPDU() failed: wrong PDU (%x)\n", sts); + + if (pinpdu > 0) + __pmUnpinPDUBuf(pb); + } + else + printf("Error: __pmSendFetch() failed: %s\n", pmErrStr(sts)); + } + if (desc_list) + free(desc_list); + break; + + case PDU_INSTANCE_REQ: + printf("pmInDom: %s\n", pmInDomStr(param.indom)); + if ((sts = __pmSendInstanceReq(outfd, FROM_ANON, &now, param.indom, param.number, param.name)) >= 0) { + if ((pinpdu = sts = __pmGetPDU(infd, ANY_SIZE, TIMEOUT_NEVER, &pb)) == PDU_INSTANCE) { + if ((sts = __pmDecodeInstance(pb, &inresult)) >= 0) { + printindom(stdout, inresult); + __pmFreeInResult(inresult); + } + else + printf("Error: __pmDecodeInstance() failed: %s\n", pmErrStr(sts)); + } + else if (sts == PDU_ERROR) { + if ((i = __pmDecodeError(pb, &sts)) >= 0) + printf("Error PDU: %s\n", pmErrStr(sts)); + else + printf("Error: __pmDecodeError() failed: %s\n", pmErrStr(i)); + } + else + printf("Error: __pmGetPDU() failed: %s\n", pmErrStr(sts)); + + if (pinpdu > 0) + __pmUnpinPDUBuf(pb); + } + else + printf("Error: __pmSendInstanceReq() failed: %s\n", pmErrStr(sts)); + break; + + case PDU_RESULT: + printf("PMID: %s\n", pmIDStr(param.pmid)); + + printf("Getting description...\n"); + + if ((sts = dopmda_desc(param.pmid, &desc, 0)) < 0) + return; + + if (profile_changed) { + printf("Sending Profile...\n"); + if ((sts = __pmSendProfile(outfd, FROM_ANON, 0, profile)) < 0) { + printf("Error: __pmSendProfile() failed: %s\n", pmErrStr(sts)); + return; + } + else + profile_changed = 0; + } + + printf("Getting Result Structure...\n"); + pinpdu = 0; + if ((sts = __pmSendFetch(outfd, FROM_ANON, 0, NULL, + 1, &(desc.pmid))) >= 0) { + if ((pinpdu = sts = __pmGetPDU(infd, ANY_SIZE, TIMEOUT_NEVER, + &pb)) == PDU_RESULT) { + if ((sts = __pmDecodeResult(pb, &result)) < 0) + printf("Error: __pmDecodeResult() failed: %s\n", + pmErrStr(sts)); +#ifdef PCP_DEBUG + else if (pmDebug & DBG_TRACE_FETCH) + __pmDumpResult(stdout, result); +#endif + } + else if (sts == PDU_ERROR) { + if ((i = __pmDecodeError(pb, &sts)) >= 0) + printf("Error PDU: %s\n", pmErrStr(sts)); + else + printf("Error: __pmDecodeError() failed: %s\n", pmErrStr(i)); + } + else + printf("Error: __pmGetPDU() failed: %s\n", pmErrStr(sts)); + } + else + printf("Error: __pmSendFetch() failed: %s\n", pmErrStr(sts)); + /* + * pb is still pinned, and result may contain pointers into + * a second PDU buffer from __pmDecodeResult() ... need to + * ensure all PDU buffers are unpinned once we're done with + * result or giving up + */ + + if (sts < 0) { + if (pinpdu > 0) + __pmUnpinPDUBuf(pb); + return; + } + + if ((sts = fillResult(result, desc.type)) < 0) { + pmFreeResult(result); + __pmUnpinPDUBuf(pb); + return; + } + + printf("Sending Result...\n"); + sts = __pmSendResult(outfd, FROM_ANON, result); + pmFreeResult(result); + __pmUnpinPDUBuf(pb); + if (sts >= 0) { + if ((pinpdu = sts = __pmGetPDU(infd, ANY_SIZE, TIMEOUT_NEVER, + &pb)) == PDU_ERROR) { + if ((i = __pmDecodeError(pb, &sts)) >= 0) { + if (sts < 0) + printf("Error PDU: %s\n", pmErrStr(sts)); + } + else + printf("Error: __pmDecodeError() failed: %s\n", pmErrStr(i)); + } + else + printf("Error: __pmGetPDU() failed: %s\n", pmErrStr(sts)); + + if (pinpdu > 0) + __pmUnpinPDUBuf(pb); + } + else + printf("Error: __pmSendResult() failed: %s\n", pmErrStr(sts)); + + break; + + case PDU_TEXT_REQ: + if (param.number == PM_TEXT_PMID) { + printf("PMID: %s\n", pmIDStr(param.pmid)); + ident = param.pmid; + } + else { + printf("pmInDom: %s\n", pmInDomStr(param.indom)); + ident = param.indom; + } + + for (j = 0; j < 2; j++) { + + if (j == 0) + param.number |= PM_TEXT_ONELINE; + else { + param.number &= ~PM_TEXT_ONELINE; + param.number |= PM_TEXT_HELP; + } + + if ((sts = __pmSendTextReq(outfd, FROM_ANON, ident, param.number)) >= 0) { + if ((pinpdu = sts = __pmGetPDU(infd, ANY_SIZE, TIMEOUT_NEVER, &pb)) == PDU_TEXT) { + if ((sts = __pmDecodeText(pb, &i, &buffer)) >= 0) { + if (j == 0) { + if (*buffer != '\0') + printf("[%s]\n", buffer); + else + printf("[<no one line help text specified>]\n"); + } + else if (*buffer != '\0') + printf("%s\n", buffer); + else + printf("<no help text specified>\n"); + free(buffer); + } + else + printf("Error: __pmDecodeText() failed: %s\n", pmErrStr(sts)); + } + else if (sts == PDU_ERROR) { + if ((i = __pmDecodeError(pb, &sts)) >= 0) + printf("Error PDU: %s\n", pmErrStr(sts)); + else + printf("Error: __pmDecodeError() failed: %s\n", pmErrStr(i)); + } + else + printf("Error: __pmGetPDU() failed: %s\n", pmErrStr(sts)); + if (pinpdu > 0) + __pmUnpinPDUBuf(pb); + + } + else + printf("Error: __pmSendTextReq() failed: %s\n", pmErrStr(sts)); + + } + break; + + case PDU_PMNS_IDS: + printf("PMID: %s\n", pmIDStr(param.pmid)); + if ((sts = __pmSendIDList(outfd, FROM_ANON, 1, ¶m.pmid, 0)) >= 0) { + if ((pinpdu = sts = __pmGetPDU(infd, ANY_SIZE, TIMEOUT_NEVER, &pb)) == PDU_PMNS_NAMES) { + if ((sts = __pmDecodeNameList(pb, &numnames, &namelist, NULL)) >= 0) { + for (i = 0; i < sts; i++) { + printf(" %s\n", namelist[i]); + } + free(namelist); + } + else + printf("Error: __pmDecodeNameList() failed: %s\n", pmErrStr(sts)); + } + else if (sts == PDU_ERROR) { + if ((i = __pmDecodeError(pb, &sts)) >= 0) + printf("Error PDU: %s\n", pmErrStr(sts)); + else + printf("Error: __pmDecodeError() failed: %s\n", pmErrStr(i)); + } + else + printf("Error: __pmGetPDU() failed: %s\n", pmErrStr(sts)); + + if (pinpdu > 0) + __pmUnpinPDUBuf(pb); + } + else + printf("Error: __pmSendIDList() failed: %s\n", pmErrStr(sts)); + break; + + case PDU_PMNS_NAMES: + printf("Metric: %s\n", param.name); + if ((sts = __pmSendNameList(outfd, FROM_ANON, 1, ¶m.name, NULL)) >= 0) { + if ((pinpdu = sts = __pmGetPDU(infd, ANY_SIZE, TIMEOUT_NEVER, &pb)) == PDU_PMNS_IDS) { + int xsts; + + if ((sts = __pmDecodeIDList(pb, 1, &pmid, &xsts)) >= 0) + printf(" %s\n", pmIDStr(pmid)); + else + printf("Error: __pmDecodeIDList() failed: %s\n", pmErrStr(sts)); + } + else if (sts == PDU_ERROR) { + if ((i = __pmDecodeError(pb, &sts)) >= 0) + printf("Error PDU: %s\n", pmErrStr(sts)); + else + printf("Error: __pmDecodeError() failed: %s\n", pmErrStr(i)); + } + else + printf("Error: __pmGetPDU() failed: %s\n", pmErrStr(sts)); + + if (pinpdu > 0) + __pmUnpinPDUBuf(pb); + } + else + printf("Error: __pmSendIDList() failed: %s\n", pmErrStr(sts)); + break; + + case PDU_PMNS_CHILD: + printf("Metric: %s\n", param.name); + if ((sts = __pmSendChildReq(outfd, FROM_ANON, param.name, 1)) >= 0) { + if ((pinpdu = sts = __pmGetPDU(infd, ANY_SIZE, TIMEOUT_NEVER, &pb)) == PDU_PMNS_NAMES) { + if ((sts = __pmDecodeNameList(pb, &numnames, &namelist, &statuslist)) >= 0) { + for (i = 0; i < numnames; i++) { + printf(" %8.8s %s\n", statuslist[i] == 1 ? "non-leaf" : "leaf", namelist[i]); + } + free(namelist); + free(statuslist); + } + else + printf("Error: __pmDecodeNameList() failed: %s\n", pmErrStr(sts)); + } + else if (sts == PDU_ERROR) { + if ((i = __pmDecodeError(pb, &sts)) >= 0) + printf("Error PDU: %s\n", pmErrStr(sts)); + else + printf("Error: __pmDecodeError() failed: %s\n", pmErrStr(i)); + } + else + printf("Error: __pmGetPDU() failed: %s\n", pmErrStr(sts)); + + if (pinpdu > 0) + __pmUnpinPDUBuf(pb); + } + else + printf("Error: __pmSendChildReq() failed: %s\n", pmErrStr(sts)); + break; + + case PDU_PMNS_TRAVERSE: + printf("Metric: %s\n", param.name); + if ((sts = __pmSendTraversePMNSReq(outfd, FROM_ANON, param.name)) >= 0) { + if ((pinpdu = sts = __pmGetPDU(infd, ANY_SIZE, TIMEOUT_NEVER, &pb)) == PDU_PMNS_NAMES) { + if ((sts = __pmDecodeNameList(pb, &numnames, &namelist, NULL)) >= 0) { + for (i = 0; i < numnames; i++) { + printf(" %s\n", namelist[i]); + } + free(namelist); + } + else + printf("Error: __pmDecodeNameList() failed: %s\n", pmErrStr(sts)); + } + else if (sts == PDU_ERROR) { + if ((i = __pmDecodeError(pb, &sts)) >= 0) + printf("Error PDU: %s\n", pmErrStr(sts)); + else + printf("Error: __pmDecodeError() failed: %s\n", pmErrStr(i)); + } + else + printf("Error: __pmGetPDU() failed: %s\n", pmErrStr(sts)); + + if (pinpdu > 0) + __pmUnpinPDUBuf(pb); + } + else + printf("Error: __pmSendTraversePMNS() failed: %s\n", pmErrStr(sts)); + break; + + case PDU_AUTH: + j = param.number; /* attribute key */ + buffer = param.name; /* attribute value */ + length = !buffer ? 0 : strlen(buffer) + 1; /* value length */ + i = 0; /* client ID */ + + __pmAttrKeyStr_r(j, name, sizeof(name)-1); + name[sizeof(name)-1] = '\0'; + + printf("Attribute: %s=%s\n", name, buffer ? buffer : "''"); + if ((sts = __pmSendAuth(outfd, 0 /* context */, j, buffer, length)) >= 0) + printf("Success\n"); + else + printf("Error: __pmSendAuth() failed: %s\n", pmErrStr(sts)); + break; + + default: + printf("Error: Daemon PDU (%s) botch!\n", __pmPDUTypeStr(pdu)); + sts = PDU_ERROR; + break; + } + + if (sts >= 0 && timer != 0) { + __pmtimevalNow(&end); + printf("Timer: %f seconds\n", __pmtimevalSub(&end, &start)); + } +} + +int +fillResult(pmResult *result, int type) +{ + int i; + int sts = 0; + pmAtomValue atom; + pmValueSet *vsp; + char *endbuf = NULL; + + switch(type) { + case PM_TYPE_32: + atom.l = (int)strtol(param.name, &endbuf, 10); + break; + case PM_TYPE_U32: + atom.ul = (unsigned int)strtoul(param.name, &endbuf, 10); + break; + case PM_TYPE_64: + atom.ll = strtoll(param.name, &endbuf, 10); + break; + case PM_TYPE_U64: + atom.ull = strtoull(param.name, &endbuf, 10); + break; + case PM_TYPE_FLOAT: + atom.d = strtod(param.name, &endbuf); + if (atom.d < FLT_MIN || atom.d > FLT_MAX) + sts = -ERANGE; + else { + atom.f = atom.d; + } + break; + case PM_TYPE_DOUBLE: + atom.d = strtod(param.name, &endbuf); + break; + case PM_TYPE_STRING: + atom.cp = (char *)malloc(strlen(param.name) + 1); + if (atom.cp == NULL) + sts = -ENOMEM; + else { + strcpy(atom.cp, param.name); + endbuf = ""; + } + break; + default: + printf("Error: dbpmda does not support storing into %s metrics\n", pmTypeStr(type)); + sts = PM_ERR_TYPE; + } + + if (sts < 0) { + if (sts != PM_ERR_TYPE) + printf("Error: Decoding value: %s\n", pmErrStr(sts)); + } + else if (endbuf != NULL && *endbuf != '\0') { + printf("Error: Value \"%s\" is incompatible with metric type (PM_TYPE_%s)\n", + param.name, pmTypeStr(type)); + sts = PM_ERR_VALUE; + } + + if (sts >= 0) { + vsp = result->vset[0]; + + if (vsp->numval == 0) { + printf("Error: %s not available!\n", pmIDStr(param.pmid)); + return PM_ERR_VALUE; + } + + if (vsp->numval < 0) { + printf("Error: %s: %s\n", pmIDStr(param.pmid), pmErrStr(vsp->numval)); + return vsp->numval; + } + + for (i = 0; i < vsp->numval; i++) { + if (vsp->numval > 1) + printf("%s [%d]: ", pmIDStr(param.pmid), i); + else + printf("%s: ", pmIDStr(param.pmid)); + + pmPrintValue(stdout, vsp->valfmt, type, &vsp->vlist[i], 1); + vsp->valfmt = __pmStuffValue(&atom, &vsp->vlist[i], type); + printf(" -> "); + pmPrintValue(stdout, vsp->valfmt, type, &vsp->vlist[i], 1); + putchar('\n'); + } + } + + return sts; +} + |