summaryrefslogtreecommitdiff
path: root/qa/src/interp3.c
diff options
context:
space:
mode:
Diffstat (limited to 'qa/src/interp3.c')
-rw-r--r--qa/src/interp3.c425
1 files changed, 425 insertions, 0 deletions
diff --git a/qa/src/interp3.c b/qa/src/interp3.c
new file mode 100644
index 0000000..61c7b95
--- /dev/null
+++ b/qa/src/interp3.c
@@ -0,0 +1,425 @@
+/*
+ * Copyright (c) 1997-2001 Silicon Graphics, Inc. All Rights Reserved.
+ */
+
+/*
+ * exercise archive-based pmFetch and pmSetMode ops in interpolate mode
+ */
+
+#include <pcp/pmapi.h>
+#include <pcp/impl.h>
+
+static int vflag;
+static int tflag;
+static int numpmid;
+static pmID pmidlist[20];
+static char *namelist[20];
+static double delta = 500;
+
+static void
+cmpres(int n, pmResult *e, pmResult *g)
+{
+ int i;
+ int j;
+ int err = 0;
+
+ if (e->timestamp.tv_sec != g->timestamp.tv_sec ||
+ e->timestamp.tv_usec != g->timestamp.tv_usec) {
+ printf("[sample %d] pmResult.timestamp: expected %ld.%06ld, got %ld.%06ld\n",
+ n, (long)e->timestamp.tv_sec, (long)e->timestamp.tv_usec,
+ (long)g->timestamp.tv_sec, (long)g->timestamp.tv_usec);
+ goto FAILED;
+ }
+ if (e->numpmid != g->numpmid) {
+ printf("[sample %d] pmResult.numpmid: expected %d, got %d\n",
+ n, e->numpmid, g->numpmid);
+ goto FAILED;
+ }
+
+ for (i = 0; i < e->numpmid; i++) {
+ if (e->vset[i]->pmid != g->vset[i]->pmid) {
+ printf("[sample %d] pmResult.vset[%d].pmid: expected %s",
+ n, i, pmIDStr(e->vset[i]->pmid));
+ printf(" got %s\n", pmIDStr(g->vset[i]->pmid));
+ err++;
+ }
+ if (e->vset[i]->numval != g->vset[i]->numval) {
+ printf("[sample %d] pmResult.vset[%d].numval: expected %d, got %d\n",
+ n, i, e->vset[i]->numval, g->vset[i]->numval);
+ err++;
+ continue;
+ }
+ if (e->vset[i]->valfmt != g->vset[i]->valfmt) {
+ printf("[sample %d] pmResult.vset[%d].valfmt: expected %d, got %d\n",
+ n, i, e->vset[i]->valfmt, g->vset[i]->valfmt);
+ err++;
+ continue;
+ }
+ if (e->vset[i]->valfmt != PM_VAL_INSITU)
+ continue;
+ for (j = 0; j < e->vset[i]->numval; j++) {
+ if (e->vset[i]->vlist[j].inst != g->vset[i]->vlist[j].inst) {
+ printf("[sample %d] pmResult.vset[%d].vlist[%d].inst: expected %d, got %d\n",
+ n, i, j, e->vset[i]->vlist[j].inst, g->vset[i]->vlist[j].inst);
+ err++;
+ }
+ if (e->vset[i]->vlist[j].value.lval != g->vset[i]->vlist[j].value.lval) {
+ printf("[sample %d] pmResult.vset[%d].vlist[%d].lval: expected %d, got %d\n",
+ n, i, j, e->vset[i]->vlist[j].value.lval, g->vset[i]->vlist[j].value.lval);
+ err++;
+ }
+ }
+ }
+
+ if (err == 0)
+ return;
+
+FAILED:
+ printf("Expected ...\n");
+ __pmDumpResult(stdout, e);
+ printf("Got ...\n");
+ __pmDumpResult(stdout, g);
+}
+
+int
+main(int argc, char **argv)
+{
+ int c;
+ int sts;
+ int ctx[2];
+ int errflag = 0;
+ char *archive = "foo";
+ char *namespace = PM_NS_DEFAULT;
+ static char *usage = "[-a archive] [-n namespace] [-T] [-t delta] [-v]";
+ int i;
+ int j;
+ int k;
+ int n;
+ pmLogLabel loglabel;
+ pmResult *resp;
+ pmResult **resvec = (pmResult **)0;
+ int resnum = 0;
+ struct timeval when;
+ int done;
+
+ __pmSetProgname(argv[0]);
+
+ while ((c = getopt(argc, argv, "a:D:n:Tt:v")) != EOF) {
+ switch (c) {
+
+ case 'a': /* archive */
+ archive = optarg;
+ 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 'n': /* alternative name space file */
+ namespace = optarg;
+ break;
+
+ case 'v': /* verbose output */
+ vflag++;
+ break;
+
+ case 'T': /* trim namespace */
+ tflag++;
+ break;
+
+ case 't': /* sample interval */
+ delta = 1000 * atof(optarg);
+ break;
+
+ case '?':
+ default:
+ errflag++;
+ break;
+ }
+ }
+
+ if (errflag) {
+ printf("Usage: %s %s\n", pmProgname, usage);
+ exit(1);
+ }
+
+ if ((sts = pmLoadNameSpace(namespace)) < 0) {
+ printf("%s: Cannot load namespace from \"%s\": %s\n", pmProgname, namespace, pmErrStr(sts));
+ exit(1);
+ }
+
+ if ((ctx[0] = pmNewContext(PM_CONTEXT_ARCHIVE, archive)) < 0) {
+ printf("%s: Cannot connect to archive \"%s\": %s\n", pmProgname, archive, pmErrStr(ctx[0]));
+ exit(1);
+ }
+ if ((sts = pmGetArchiveLabel(&loglabel)) < 0) {
+ printf("%s: pmGetArchiveLabel(%d): %s\n", pmProgname, ctx[0], pmErrStr(sts));
+ exit(1);
+ }
+
+ when = loglabel.ll_start;
+ if ((sts = pmSetMode(PM_MODE_INTERP, &when, delta)) < 0) {
+ printf("%s: pmSetMode: %s\n", pmProgname, pmErrStr(sts));
+ exit(1);
+ }
+
+ if ((ctx[1] = pmDupContext()) < 0) {
+ printf("%s: Cannot dup context to archive \"%s\": %s\n", pmProgname, archive, pmErrStr(ctx[0]));
+ exit(1);
+ }
+ if ((sts = pmSetMode(PM_MODE_INTERP, &when, delta)) < 0) {
+ printf("%s: pmSetMode: %s\n", pmProgname, pmErrStr(sts));
+ exit(1);
+ }
+
+ pmUseContext(ctx[0]);
+ if (tflag)
+ pmTrimNameSpace();
+
+ /*
+ * metrics biased towards log "foo"
+ */
+ i = 0;
+ namelist[i++] = "sample.seconds";
+ namelist[i++] = "sample.colour";
+ namelist[i++] = "sample.drift";
+ namelist[i++] = "sample.lights";
+ namelist[i++] = "sampledso.milliseconds";
+ namelist[i++] = "sampledso.bin";
+ numpmid = i;
+
+ sts = pmLookupName(numpmid, namelist, pmidlist);
+ if (sts < 0) {
+ printf("pmLookupName: %s\n", pmErrStr(sts));
+ for (i = 0; i < numpmid; i++) {
+ if (pmidlist[i] == PM_ID_NULL)
+ printf(" %s - not known\n", namelist[i]);
+ }
+ }
+
+ printf("\nPass 1: forward scan\n");
+ __pmLogReads = 0;
+ for (;;) {
+ if ((sts = pmFetch(numpmid, pmidlist, &resp)) < 0) {
+ if (sts != PM_ERR_EOL)
+ printf("%s: pmFetch: %s\n", pmProgname, pmErrStr(sts));
+ break;
+ }
+ resnum++;
+ resvec = (pmResult **)realloc(resvec, resnum * sizeof(resvec[0]));
+ resvec[resnum - 1] = resp;
+ if (vflag)
+ __pmDumpResult(stdout, resp);
+ }
+#ifdef PCP_DEBUG
+ if (pmDebug & DBG_TRACE_APPL0)
+ fprintf(stderr, "%d pmLogReads\n", __pmLogReads);
+#endif
+ fflush(stderr);
+ printf("Found %d samples\n", resnum);
+ fflush(stdout);
+
+ printf("\nPass 2: backwards scan\n");
+ __pmLogReads = 0;
+ when = resvec[resnum - 1]->timestamp;
+ if ((sts = pmSetMode(PM_MODE_INTERP, &when, -delta)) < 0) {
+ printf("%s: pmSetMode: %s\n", pmProgname, pmErrStr(sts));
+ exit(1);
+ }
+
+ n = 0;
+ for (;;) {
+ if ((sts = pmFetch(numpmid, pmidlist, &resp)) < 0) {
+ if (sts != PM_ERR_EOL)
+ printf("%s: pmFetch: %s\n", pmProgname, pmErrStr(sts));
+ break;
+ }
+ n++;
+ cmpres(n, resvec[resnum - n], resp);
+ pmFreeResult(resp);
+ }
+#ifdef PCP_DEBUG
+ if (pmDebug & DBG_TRACE_APPL0)
+ fprintf(stderr, "%d pmLogReads\n", __pmLogReads);
+#endif
+ fflush(stderr);
+ printf("Found %d samples\n", n);
+ fflush(stdout);
+
+ printf("\nPass 3: concurrent forwards and backwards scans\n");
+ __pmLogReads = 0;
+ pmUseContext(ctx[0]);
+ when = loglabel.ll_start;
+ if ((sts = pmSetMode(PM_MODE_INTERP, &when, delta)) < 0) {
+ printf("%s: pmSetMode: %s\n", pmProgname, pmErrStr(sts));
+ exit(1);
+ }
+ pmUseContext(ctx[1]);
+ when = resvec[resnum - 1]->timestamp;
+ if ((sts = pmSetMode(PM_MODE_INTERP, &when, -delta)) < 0) {
+ printf("%s: pmSetMode: %s\n", pmProgname, pmErrStr(sts));
+ exit(1);
+ }
+
+ done = 0;
+ n = 0;
+ while (!done) {
+ pmUseContext(ctx[0]);
+ if ((sts = pmFetch(numpmid, pmidlist, &resp)) < 0) {
+ if (sts != PM_ERR_EOL)
+ printf("%s: pmFetch: %s\n", pmProgname, pmErrStr(sts));
+ done = 1;
+ }
+ else {
+ n++;
+ cmpres(n, resvec[n/2], resp);
+ pmFreeResult(resp);
+ }
+
+ pmUseContext(ctx[1]);
+ if ((sts = pmFetch(numpmid, pmidlist, &resp)) < 0) {
+ if (sts != PM_ERR_EOL)
+ printf("%s: pmFetch: %s\n", pmProgname, pmErrStr(sts));
+ done = 1;
+ }
+ else {
+ n++;
+ cmpres(n, resvec[resnum - n/2], resp);
+ pmFreeResult(resp);
+ }
+ }
+#ifdef PCP_DEBUG
+ if (pmDebug & DBG_TRACE_APPL0)
+ fprintf(stderr, "%d pmLogReads\n", __pmLogReads);
+#endif
+ fflush(stderr);
+ printf("Found %d samples\n", n);
+ fflush(stdout);
+
+ printf("\nPass 4: cascading forward scan, 100%%, 75%%, 50%%, 25%%, 0%%\n");
+ pmUseContext(ctx[0]);
+ for (k = 0; k < 5; k++) {
+ __pmLogReads = 0;
+ j = 0;
+ i = ( k * resnum ) / 4;
+ if (i >= resnum)
+ i = resnum - 1;
+ when = resvec[i]->timestamp;
+
+ if ((sts = pmSetMode(PM_MODE_INTERP, &when, delta)) < 0) {
+ printf("%s: pmSetMode: %s\n", pmProgname, pmErrStr(sts));
+ exit(1);
+ }
+
+ n = i;
+ for (;;) {
+ if ((sts = pmFetch(numpmid, pmidlist, &resp)) < 0) {
+ if (sts != PM_ERR_EOL)
+ printf("%s: pmFetch: %s\n", pmProgname, pmErrStr(sts));
+ break;
+ }
+ j++;
+ n++;
+ cmpres(j, resvec[n - 1], resp);
+ pmFreeResult(resp);
+ }
+#ifdef PCP_DEBUG
+ if (pmDebug & DBG_TRACE_APPL0)
+ fprintf(stderr, "%d pmLogReads\n", __pmLogReads);
+#endif
+ fflush(stderr);
+ printf("Found %d samples\n", j);
+ fflush(stdout);
+ }
+
+ printf("\nPass 5: cascading backward scan, 100%%, 75%%, 50%%, 25%%, 0%%\n");
+ pmUseContext(ctx[0]);
+ for (k = 0; k < 5; k++) {
+ __pmLogReads = 0;
+ j = 0;
+ i = resnum - ( k * resnum ) / 4 - 1;
+ if (i < 0)
+ i = 0;
+ when = resvec[i]->timestamp;
+ if ((sts = pmSetMode(PM_MODE_INTERP, &when, -delta)) < 0) {
+ printf("%s: pmSetMode: %s\n", pmProgname, pmErrStr(sts));
+ exit(1);
+ }
+
+ for (;;) {
+ if ((sts = pmFetch(numpmid, pmidlist, &resp)) < 0) {
+ if (sts != PM_ERR_EOL)
+ printf("%s: pmFetch: %s\n", pmProgname, pmErrStr(sts));
+ break;
+ }
+ cmpres(i, resvec[i], resp);
+ pmFreeResult(resp);
+ i--;
+ j++;
+ }
+#ifdef PCP_DEBUG
+ if (pmDebug & DBG_TRACE_APPL0)
+ fprintf(stderr, "%d pmLogReads\n", __pmLogReads);
+#endif
+ fflush(stderr);
+ printf("Found %d samples\n", j);
+ fflush(stdout);
+ }
+
+ printf("\nPass 6: cascading forward/reverse scan, 100%%, 75%%, 50%%, 25%%, 0%%\n");
+ pmUseContext(ctx[0]);
+ for (k = 4; k >= 0; k--) {
+ __pmLogReads = 0;
+ j = 0;
+ i = ( k * resnum ) / 4;
+ if (i >= resnum)
+ i = resnum - 1;
+
+ when = resvec[0]->timestamp;
+ if ((sts = pmSetMode(PM_MODE_INTERP, &when, delta)) < 0) {
+ printf("%s: pmSetMode: %s\n", pmProgname, pmErrStr(sts));
+ exit(1);
+ }
+
+ for (j = 0; j <= i; j++) {
+ if ((sts = pmFetch(numpmid, pmidlist, &resp)) < 0) {
+ printf("%s: pmFetch: %s\n", pmProgname, pmErrStr(sts));
+ exit(1);
+ }
+ cmpres(j+1, resvec[j], resp);
+ pmFreeResult(resp);
+ }
+
+ when = resvec[i]->timestamp;
+ if ((sts = pmSetMode(PM_MODE_INTERP, &when, -delta)) < 0) {
+ printf("%s: pmSetMode: %s\n", pmProgname, pmErrStr(sts));
+ exit(1);
+ }
+
+ for (j = i; j >= 0; j--) {
+ if ((sts = pmFetch(numpmid, pmidlist, &resp)) < 0) {
+ printf("%s: pmFetch: %s\n", pmProgname, pmErrStr(sts));
+ exit(1);
+ }
+ cmpres(j+1, resvec[j], resp);
+ pmFreeResult(resp);
+ }
+#ifdef PCP_DEBUG
+ if (pmDebug & DBG_TRACE_APPL0)
+ fprintf(stderr, "%d pmLogReads\n", __pmLogReads);
+#endif
+ fflush(stderr);
+ printf("Found %d samples\n", i+1);
+ }
+ printf("Pass 6 done\n");
+ fflush(stdout);
+
+ exit(0);
+}
generated by cgit v1.2.3 (git 2.39.1) at 2025-04-27 13:37:29 +0000