summaryrefslogtreecommitdiff
path: root/qa/src/torture_logmeta.c
diff options
context:
space:
mode:
Diffstat (limited to 'qa/src/torture_logmeta.c')
-rw-r--r--qa/src/torture_logmeta.c350
1 files changed, 350 insertions, 0 deletions
diff --git a/qa/src/torture_logmeta.c b/qa/src/torture_logmeta.c
new file mode 100644
index 0000000..0e74f20
--- /dev/null
+++ b/qa/src/torture_logmeta.c
@@ -0,0 +1,350 @@
+/*
+ * Copyright (c) 1995-2001 Silicon Graphics, Inc. All Rights Reserved.
+ * Copyright (c) 2011 Ken McDonell. All Rights Reserved.
+ */
+
+#include <pcp/pmapi.h>
+#include <pcp/impl.h>
+
+int
+main(int argc, char **argv)
+{
+ int c;
+ int i;
+ int sts = 0; /* pander to gcc */
+ int fault = 0;
+ int errflag = 0;
+ char *offset = NULL;
+ pmLogLabel label; /* get hostname for archives */
+ int tzh; /* initial timezone handle */
+ char local[MAXHOSTNAMELEN];
+ char *endnum;
+ struct timeval startTime;
+ struct timeval endTime;
+ struct timeval appStart;
+ struct timeval appEnd;
+ struct timeval appOffset;
+ int *instlist;
+ char **namelist;
+ char *name;
+ int xinst = -1;
+ char *xname = NULL;
+ char *xxname = NULL;
+ pmInDom indom[3]; /* null, good, bad */
+
+ /* trim cmd name of leading directory components */
+ __pmSetProgname(argv[0]);
+
+ while ((c = getopt(argc, argv, "fD:O:?")) != EOF) {
+ switch (c) {
+
+ 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 'f': /* fault injection mode */
+ fault = 1;
+ break;
+
+ case 'O': /* sample offset time */
+ offset = optarg;
+ break;
+
+ case '?':
+ default:
+ errflag++;
+ break;
+ }
+ }
+
+ if (errflag || optind != argc-4) {
+ fprintf(stderr,
+"Usage: %s [options] archive domain good-serial bad-serial\n\
+\n\
+Options:\n\
+ -f fault injection mode ... only do good archive ops\n\
+ -O offset initial offset into the time window\n",
+ pmProgname);
+ exit(1);
+ }
+ indom[0] = PM_INDOM_NULL;
+ indom[1] = pmInDom_build(atoi(argv[optind+1]), atoi(argv[optind+2]));
+ indom[2] = pmInDom_build(atoi(argv[optind+1]), atoi(argv[optind+3]));
+
+ /*
+ * once per context type ... invalid, localhost, archive
+ */
+ for (c = 0; c < 3; c++) {
+ if (fault && c != 2)
+ continue;
+ if (c == 0) {
+ /* invalid context, none created yet */
+ sts = -1;
+ }
+ else if (c == 1) {
+ /* pmcd on localhost */
+ (void)gethostname(local, MAXHOSTNAMELEN);
+ local[MAXHOSTNAMELEN-1] = '\0';
+ if ((sts = pmNewContext(PM_CONTEXT_HOST, local)) < 0) {
+ fprintf(stderr, "%s: Cannot connect to PMCD on host \"%s\": %s\n",
+ pmProgname, local, pmErrStr(sts));
+ exit(1);
+ }
+ }
+ else if (c == 2) {
+ if ((sts = pmNewContext(PM_CONTEXT_ARCHIVE, argv[optind])) < 0) {
+ fprintf(stderr, "%s: Cannot open archive \"%s\": %s\n",
+ pmProgname, argv[optind], pmErrStr(sts));
+ exit(1);
+ }
+ }
+ fprintf(stderr, "\n=== iteration %d context %d ===\n", c, sts);
+
+ if (c == 2) {
+ if ((sts = pmGetArchiveLabel(&label)) < 0) {
+ fprintf(stderr, "%s: Cannot get archive label record: %s\n",
+ pmProgname, pmErrStr(sts));
+ exit(1);
+ }
+ startTime = label.ll_start;
+ if ((sts = pmGetArchiveEnd(&endTime)) < 0) {
+ fprintf(stderr, "%s: Cannot locate end of archive: %s\n",
+ pmProgname, pmErrStr(sts));
+ exit(1);
+ }
+ if ((tzh = pmNewContextZone()) < 0) {
+ fprintf(stderr, "%s: Cannot set context timezone: %s\n",
+ pmProgname, pmErrStr(tzh));
+ exit(1);
+ }
+ sts = pmParseTimeWindow(NULL, NULL, NULL, offset, &startTime,
+ &endTime, &appStart, &appEnd, &appOffset,
+ &endnum);
+ if (sts < 0) {
+ fprintf(stderr, "%s: illegal time window specification\n%s",
+ pmProgname, endnum);
+ exit(1);
+ }
+ if ((sts = pmSetMode(PM_MODE_FORW, &appOffset, 0)) < 0) {
+ fprintf(stderr, "%s: pmSetMode: %s\n",
+ pmProgname, pmErrStr(sts));
+ exit(1);
+ }
+ }
+
+ /*
+ * routines to be tested ...
+ *
+ * PMAPI
+ * [y] pmGetInDomArchive
+ * [y] pmLookupInDomArchive
+ * [y] pmNameInDomArchive
+ *
+ * internal
+ * [ ] __pmLogPutDesc
+ * [ ] __pmLogPutInDom
+ * [ ] __pmLogPutIndex
+ * [ ] __pmLogLookupDesc
+ * [y] __pmLogGetInDom
+ * [y] __pmLogLookupInDom
+ * [y] __pmLogNameInDom
+ */
+
+ /* once per indom ... null, good and bad */
+ for (i = 0; i < 3; i++) {
+ if (fault && i != 1)
+ continue;
+ if (i == 0) {
+ /* tests that do not use the indom ... */
+ ;
+ }
+
+ if ((sts = pmGetInDomArchive(indom[i], &instlist, &namelist)) < 0) {
+ fprintf(stderr, "pmGetInDomArchive(%s) -> ", pmInDomStr(indom[i]));
+ fprintf(stderr, "%s\n", pmErrStr(sts));
+ }
+ else {
+ int j;
+ fprintf(stderr, "pmGetInDomArchive(%s) -> ", pmInDomStr(indom[i]));
+ fprintf(stderr, "%d\n", sts);
+ for (j = 0; j < sts; j++)
+ fprintf(stderr, " [%d] %s\n", instlist[j], namelist[j]);
+ if (xname == NULL) {
+ char *q;
+ xname = strdup(namelist[0]);
+ for (q = xname; *q; q++) {
+ if (*q == ' ') {
+ xxname = strdup(xname);
+ xxname[q-xname] = '\0';
+ break;
+ }
+ }
+ }
+ free(instlist);
+ free(namelist);
+ }
+
+ if (!fault) {
+ if ((sts = pmLookupInDomArchive(indom[i], "foobar")) < 0) {
+ fprintf(stderr, "pmLookupInDomArchive(%s, foobar) -> ", pmInDomStr(indom[i]));
+ fprintf(stderr, "%s\n", pmErrStr(sts));
+ }
+ else {
+ fprintf(stderr, "pmLookupInDomArchive(%s, foobar) -> ", pmInDomStr(indom[i]));
+ fprintf(stderr, "%d\n", sts);
+ }
+ }
+
+ if (xname != NULL) {
+ if ((sts = pmLookupInDomArchive(indom[i], xname)) < 0) {
+ fprintf(stderr, "pmLookupInDomArchive(%s, %s) -> ", pmInDomStr(indom[i]), xname);
+ fprintf(stderr, "%s\n", pmErrStr(sts));
+ }
+ else {
+ fprintf(stderr, "pmLookupInDomArchive(%s, %s) -> ", pmInDomStr(indom[i]), xname);
+ fprintf(stderr, "%d\n", sts);
+ if (xinst == -1)
+ xinst = sts;
+ }
+ }
+
+ if (xxname != NULL) {
+ if ((sts = pmLookupInDomArchive(indom[i], xxname)) < 0) {
+ fprintf(stderr, "pmLookupInDomArchive(%s, %s) -> ", pmInDomStr(indom[i]), xxname);
+ fprintf(stderr, "%s\n", pmErrStr(sts));
+ }
+ else {
+ fprintf(stderr, "pmLookupInDomArchive(%s, %s) -> ", pmInDomStr(indom[i]), xxname);
+ fprintf(stderr, "%d\n", sts);
+ }
+ }
+
+ if (!fault) {
+ if ((sts = pmNameInDomArchive(indom[i], 1234567, &name)) < 0) {
+ fprintf(stderr, "pmNameInDomArchive(%s, 1234567) -> ", pmInDomStr(indom[i]));
+ fprintf(stderr, "%s\n", pmErrStr(sts));
+ }
+ else {
+ fprintf(stderr, "pmNameInDomArchive(%s, 1234567) -> ", pmInDomStr(indom[i]));
+ fprintf(stderr, "%s\n", name);
+ free(name);
+ }
+ }
+
+ if (xinst != -1) {
+ if ((sts = pmNameInDomArchive(indom[i], xinst, &name)) < 0) {
+ fprintf(stderr, "pmNameInDomArchive(%s, %d) -> ", pmInDomStr(indom[i]), xinst);
+ fprintf(stderr, "%s\n", pmErrStr(sts));
+ }
+ else {
+ fprintf(stderr, "pmNameInDomArchive(%s, %d) -> ", pmInDomStr(indom[i]), xinst);
+ fprintf(stderr, "%s\n", name);
+ free(name);
+ }
+ }
+
+ if ((sts = pmWhichContext()) >= 0) {
+ __pmContext *ctxp;
+ ctxp = __pmHandleToPtr(sts);
+ if (ctxp != NULL && ctxp->c_archctl != NULL) {
+ __pmTimeval now;
+ int iter;
+ for (iter=0; iter < 2; iter++) {
+ /*
+ * use -O time (defaults to start time) on first
+ * iteration, then half the time between there
+ * and the end
+ */
+ if (fault && iter != 1)
+ continue;
+ if (iter == 0) {
+ now.tv_sec = appOffset.tv_sec;
+ now.tv_usec = appOffset.tv_usec;
+ }
+ else {
+ /*
+ * danger! need to promote arithmetic to 64-bit
+ * for platforms where tv_sec is 32-bit and
+ * tv_sec + tv_sec => overflow
+ */
+ now.tv_sec = ((__int64_t)appOffset.tv_sec+(__int64_t)appEnd.tv_sec)/2;
+ now.tv_usec = ((__int64_t)appOffset.tv_usec+(__int64_t)appEnd.tv_usec)/2;
+ }
+ if ((sts = __pmLogGetInDom(ctxp->c_archctl->ac_log, indom[i], &now, &instlist, &namelist)) < 0) {
+ fprintf(stderr, "__pmLogGetInDom(%s) -> ", pmInDomStr(indom[i]));
+ fprintf(stderr, "%s\n", pmErrStr(sts));
+ }
+ else {
+ int j;
+ fprintf(stderr, "__pmLogGetInDom(%s) -> ", pmInDomStr(indom[i]));
+ fprintf(stderr, "%d\n", sts);
+ for (j = 0; j < sts; j++)
+ fprintf(stderr, " [%d] %s\n", instlist[j], namelist[j]);
+ }
+ if (!fault) {
+ if ((sts = __pmLogLookupInDom(ctxp->c_archctl->ac_log, indom[i], &now, "foobar")) < 0) {
+ fprintf(stderr, "__pmLogLookupInDom(%s, foobar) -> ", pmInDomStr(indom[i]));
+ fprintf(stderr, "%s\n", pmErrStr(sts));
+ }
+ else {
+ fprintf(stderr, "__pmLogLookupInDom(%s, foobar) -> ", pmInDomStr(indom[i]));
+ fprintf(stderr, "%d\n", sts);
+ }
+ }
+ if (xname != NULL) {
+ if ((sts = __pmLogLookupInDom(ctxp->c_archctl->ac_log, indom[i], &now, xname)) < 0) {
+ fprintf(stderr, "__pmLogLookupInDom(%s, %s) -> ", pmInDomStr(indom[i]), xname);
+ fprintf(stderr, "%s\n", pmErrStr(sts));
+ }
+ else {
+ fprintf(stderr, "__pmLogLookupInDom(%s, %s) -> ", pmInDomStr(indom[i]), xname);
+ fprintf(stderr, "%d\n", sts);
+ }
+ }
+ if (xxname != NULL) {
+ if ((sts = __pmLogLookupInDom(ctxp->c_archctl->ac_log, indom[i], &now, xxname)) < 0) {
+ fprintf(stderr, "__pmLogLookupInDom(%s, %s) -> ", pmInDomStr(indom[i]), xxname);
+ fprintf(stderr, "%s\n", pmErrStr(sts));
+ }
+ else {
+ fprintf(stderr, "__pmLogLookupInDom(%s, %s) -> ", pmInDomStr(indom[i]), xxname);
+ fprintf(stderr, "%d\n", sts);
+ }
+ }
+ if (!fault) {
+ if ((sts = __pmLogNameInDom(ctxp->c_archctl->ac_log, indom[i], &now, 1234567, &name)) < 0) {
+ fprintf(stderr, "__pmLogNameInDom(%s, 1234567) -> ", pmInDomStr(indom[i]));
+ fprintf(stderr, "%s\n", pmErrStr(sts));
+ }
+ else {
+ fprintf(stderr, "__pmLogNameInDom(%s, 1234567) -> ", pmInDomStr(indom[i]));
+ fprintf(stderr, "%s\n", name);
+ }
+ }
+ if (xinst != -1) {
+ if ((sts = __pmLogNameInDom(ctxp->c_archctl->ac_log, indom[i], &now, xinst, &name)) < 0) {
+ fprintf(stderr, "__pmLogNameInDom(%s, %d) -> ", pmInDomStr(indom[i]), xinst);
+ fprintf(stderr, "%s\n", pmErrStr(sts));
+ }
+ else {
+ fprintf(stderr, "__pmLogNameInDom(%s, %d) -> ", pmInDomStr(indom[i]), xinst);
+ fprintf(stderr, "%s\n", name);
+ }
+ }
+ }
+ }
+ }
+
+ }
+
+ }
+
+ return 0;
+}
generated by cgit v1.2.3 (git 2.39.1) at 2024-06-10 06:18:33 +0000