diff options
Diffstat (limited to 'qa/src/chkputlogresult.c')
| -rw-r--r-- | qa/src/chkputlogresult.c | 183 |
1 files changed, 183 insertions, 0 deletions
diff --git a/qa/src/chkputlogresult.c b/qa/src/chkputlogresult.c new file mode 100644 index 0000000..17c2835 --- /dev/null +++ b/qa/src/chkputlogresult.c @@ -0,0 +1,183 @@ +/* + * Copyright (c) 1995-2001 Silicon Graphics, Inc. All Rights Reserved. + * Copyright (c) 2014 Ken McDonell. All Rights Reserved. + * + * Excercise __pmLogPutResult() and __pmLogPutResult2(). + */ + +#include <pcp/pmapi.h> +#include <pcp/impl.h> +#include <assert.h> + +int +main(int argc, char **argv) +{ + int c; + int i; + int sts; + int bflag = 0; + int errflag = 0; + char *metrics[] = { + "sampledso.long.one", + "sampledso.ulonglong.one", + "sampledso.float.one", + "sampledso.double.one", + "sampledso.string.hullo", + "sampledso.bin", + }; + int nmetric = sizeof(metrics)/sizeof(metrics[0]); + pmID *pmids; + pmDesc desc; + pmResult *rp; + __pmLogCtl ctl = { 0 }; + __pmPDU *pdp; + __pmTimeval epoch = { 0, 0 }; + int numinst; + int *ilist; + char **nlist; + + /* trim cmd name of leading directory components */ + __pmSetProgname(argv[0]); + + while ((c = getopt(argc, argv, "bD::?")) != EOF) { + switch (c) { + + case 'b': /* backwards compatibility */ + bflag++; + break; + + case 'D': /* debug flag */ + sts = __pmParseDebug(optarg); + if (sts < 0) { + fprintf(stderr, "%s: unrecognized debug flag specification (%s)\n", + pmProgname, optarg); + errflag++; + } + else + pmDebug |= sts; + break; + + case '?': + default: + errflag++; + break; + } + } + + if (errflag || optind != argc-1) { + fprintf(stderr, +"Usage: %s [options] archive\n\ +\n\ +Options:\n\ + -b backwards compatibility (use __pmLogPutResult() instead\n\ + __pmLogPutResult2(), the default\n\ + -D debugflag[,...]\n\ +", + pmProgname); + exit(1); + } + + if ((sts = pmNewContext(PM_CONTEXT_HOST, "local:")) < 0) { + fprintf(stderr, "%s: Cannot connect to PMCD on \"local:\": %s\n", + pmProgname, pmErrStr(sts)); + exit(1); + } + + if ((sts = __pmLogCreate("qatest", argv[optind], LOG_PDU_VERSION, &ctl)) != 0) { + fprintf(stderr, "%s: __pmLogCreate failed: %s\n", pmProgname, pmErrStr(sts)); + exit(1); + } + ctl.l_state = PM_LOG_STATE_INIT; + + /* + * make the archive label deterministic + */ + ctl.l_label.ill_pid = 1234; + ctl.l_label.ill_start.tv_sec = epoch.tv_sec; + ctl.l_label.ill_start.tv_usec = epoch.tv_usec; + strcpy(ctl.l_label.ill_hostname, "happycamper"); + strcpy(ctl.l_label.ill_tz, "UTC"); + + ctl.l_label.ill_vol = PM_LOG_VOL_TI; + if ((sts = __pmLogWriteLabel(ctl.l_tifp, &ctl.l_label)) != 0) { + fprintf(stderr, "%s: __pmLogWriteLabel TI failed: %s\n", pmProgname, pmErrStr(sts)); + exit(1); + } + ctl.l_label.ill_vol = PM_LOG_VOL_META; + if ((sts = __pmLogWriteLabel(ctl.l_mdfp, &ctl.l_label)) != 0) { + fprintf(stderr, "%s: __pmLogWriteLabel META failed: %s\n", pmProgname, pmErrStr(sts)); + exit(1); + } + ctl.l_label.ill_vol = 0; + if ((sts = __pmLogWriteLabel(ctl.l_mfp, &ctl.l_label)) != 0) { + fprintf(stderr, "%s: __pmLogWriteLabel VOL 0 failed: %s\n", pmProgname, pmErrStr(sts)); + exit(1); + } + + fflush(ctl.l_mfp); + fflush(ctl.l_mdfp); + __pmLogPutIndex(&ctl, &epoch); + + pmids = (pmID *)malloc(nmetric*sizeof(pmID)); + assert(pmids != NULL); + for (i = 0; i < nmetric; i++) { + if ((sts = pmLookupName(1, &metrics[i], &pmids[i])) != 1) { + fprintf(stderr, "%s: pmLookupName(\"%s\") failed: %s\n", pmProgname, metrics[i], pmErrStr(sts)); + exit(1); + } + printf("%s -> %s\n", metrics[i], pmIDStr(pmids[i])); + if ((sts = pmLookupDesc(pmids[i], &desc)) < 0) { + fprintf(stderr, "%s: pmLookupDesc(\"%s\") failed: %s\n", pmProgname, pmIDStr(pmids[i]), pmErrStr(sts)); + exit(1); + } + if ((sts = __pmLogPutDesc(&ctl, &desc, 1, &metrics[i])) < 0) { + fprintf(stderr, "%s: __pmLogPutDesc(\"%s\") failed: %s\n", pmProgname, pmIDStr(pmids[i]), pmErrStr(sts)); + exit(1); + } + if (desc.indom != PM_INDOM_NULL) { + if ((numinst = pmGetInDom(desc.indom, &ilist, &nlist)) < 0) { + printf("pmGetInDom: %s: %s\n", pmInDomStr(desc.indom), pmErrStr(numinst)); + exit(1); + } + if ((sts = __pmLogPutInDom(&ctl, desc.indom, &epoch, numinst, ilist, nlist)) < 0) { + fprintf(stderr, "%s: __pmLogPutInDom(...,indom=%s,numinst=%d,...) failed: %s\n", pmProgname, pmInDomStr(desc.indom), numinst, pmErrStr(sts)); + exit(1); + } + } + } + for (i = 0; i < nmetric; i++) { + if ((sts = pmFetch(i+1, pmids, &rp)) < 0) { + fprintf(stderr, "%s: pmFetch(%d, ...) failed: %s\n", pmProgname, i+1, pmErrStr(sts)); + exit(1); + } + rp->timestamp.tv_sec = ++epoch.tv_sec; + rp->timestamp.tv_usec = epoch.tv_usec; + if ((sts = __pmEncodeResult(fileno(ctl.l_mfp), rp, &pdp)) < 0) { + fprintf(stderr, "%s: __pmEncodeResult failed: %s\n", pmProgname, pmErrStr(sts)); + exit(1); + } + __pmOverrideLastFd(fileno(ctl.l_mfp)); + if (bflag) { + printf("__pmLogPutResult: %d metrics ...\n", i+1); + if ((sts = __pmLogPutResult(&ctl, pdp)) < 0) { + fprintf(stderr, "%s: __pmLogPutResult failed: %s\n", pmProgname, pmErrStr(sts)); + exit(1); + } + } + else { + printf("__pmLogPutResult2: %d metrics ...\n", i+1); + if ((sts = __pmLogPutResult2(&ctl, pdp)) < 0) { + fprintf(stderr, "%s: __pmLogPutResult2 failed: %s\n", pmProgname, pmErrStr(sts)); + exit(1); + } + } + __pmUnpinPDUBuf(pdp); + pmFreeResult(rp); + } + + fflush(ctl.l_mfp); + fflush(ctl.l_mdfp); + __pmLogPutIndex(&ctl, &epoch); + + return 0; +} |