Debian 3.9.10debian/3.9.10debian

1 files changed, 425 insertions, 0 deletions

diff --git a/qa/src/xarch.c b/qa/src/xarch.c
new file mode 100644
index 0000000..cc34de4
--- /dev/null
+++ b/qa/src/xarch.c
@@ -0,0 +1,425 @@
+/*
+ * Copyright (c) 1995-2002 Silicon Graphics, Inc.  All Rights Reserved.
+ */
+
+/*
+ * exercise archive-based pmFetch and pmSetMode ops
+ */
+
+#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 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 = "[-D N] [-a archive] [-n namespace] [-v] [metric ...]";
+    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:tv")) != 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 '?':
+	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.tv_sec = 0;
+    when.tv_usec = 0;
+    if ((sts = pmSetMode(PM_MODE_FORW, &when, 0)) < 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_FORW, &when, 0)) < 0) {
+        printf("%s: pmSetMode: %s\n", pmProgname, pmErrStr(sts));
+        exit(1);
+    }
+
+    pmUseContext(ctx[0]);
+    if (tflag)
+	pmTrimNameSpace();
+
+    i = 0;
+    while (optind < argc - 1) {
+	if (i == 20) {
+	    fprintf(stderr, "%s: Too many metrics, re-build me\n", pmProgname);
+	    exit(1);
+	}
+	namelist[i++] = argv[optind]++;
+    }
+
+    if (i == 0) {
+	/*
+	 * default metrics biased towards log "foo"
+	 */
+	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");
+    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);
+    }
+    fflush(stderr);
+    printf("Found %d samples\n", resnum);
+    fflush(stdout);
+
+    printf("\nPass 2: backwards scan\n");
+    when.tv_sec = 0x7fffffff;
+    when.tv_usec = 0;
+    if ((sts = pmSetMode(PM_MODE_BACK, &when, 0)) < 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);
+    }
+    fflush(stderr);
+    printf("Found %d samples\n", n);
+    fflush(stdout);
+
+    printf("\nPass 3: concurrent forwards and backwards scans\n");
+    pmUseContext(ctx[0]);
+    when.tv_sec = 0;
+    when.tv_usec = 0;
+    if ((sts = pmSetMode(PM_MODE_FORW, &when, 0)) < 0) {
+	printf("%s: pmSetMode: %s\n", pmProgname, pmErrStr(sts));
+	exit(1);
+    }
+    pmUseContext(ctx[1]);
+    when.tv_sec = 0x7fffffff;
+    when.tv_usec = 0;
+    if ((sts = pmSetMode(PM_MODE_BACK, &when, 0)) < 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);
+	}
+    }
+    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++) {
+	j = 0;
+	if (resnum > 0) {
+	    i = ( k * resnum ) / 4;
+	    if (i <= resnum - 1) {
+		when = resvec[i]->timestamp;
+		when.tv_usec--;
+		if (when.tv_usec < 0) {
+		    when.tv_usec = 0;
+		    when.tv_sec--;
+		}
+	    }
+	    else {
+		when = resvec[resnum - 1]->timestamp;
+		when.tv_usec++;
+		if (when.tv_usec >= 1000000) {
+		    when.tv_usec = 0;
+		    when.tv_sec++;
+		}
+	    }
+	    if ((sts = pmSetMode(PM_MODE_FORW, &when, 0)) < 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);
+	    }
+	    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++) {
+	j = 0;
+	if (resnum > 0) {
+	    i = resnum - ( k * resnum ) / 4 - 1;
+	    if (i < 0)
+		i = 0;
+	    if (i > 0) {
+		when = resvec[i]->timestamp;
+		when.tv_usec++;
+		if (when.tv_usec >= 1000000) {
+		    when.tv_usec = 0;
+		    when.tv_sec++;
+		}
+	    }
+	    else {
+		when = resvec[0]->timestamp;
+		when.tv_usec--;
+		if (when.tv_usec < 0) {
+		    when.tv_usec = 0;
+		    when.tv_sec--;
+		}
+	    }
+	    if ((sts = pmSetMode(PM_MODE_BACK, &when, 0)) < 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++;
+	    }
+	    fflush(stderr);
+	}
+	printf("Found %d samples\n", j);
+	fflush(stdout);
+    }
+
+    printf("\nPass 6: EOL tests, forwards and backwards\n");
+    when = loglabel.ll_start;
+    when.tv_sec--;
+    if ((sts = pmSetMode(PM_MODE_BACK, &when, 0)) < 0) {
+	printf("%s: pmSetMode: %s\n", pmProgname, pmErrStr(sts));
+	exit(1);
+    }
+    if ((sts = pmFetchArchive(&resp)) < 0) {
+	if (sts != PM_ERR_EOL)
+	    printf("%s: pmFetchArchive: %s\n", pmProgname, pmErrStr(sts));
+    }
+    else {
+	printf("%s: pmFetchArchive: unexpected success before start of log\n", pmProgname);
+	__pmDumpResult(stdout, resp);
+	pmFreeResult(resp);
+    }
+
+    when.tv_sec = 0x7fffffff;
+    when.tv_usec = 0;
+    if ((sts = pmSetMode(PM_MODE_FORW, &when, 0)) < 0) {
+	printf("%s: pmSetMode: %s\n", pmProgname, pmErrStr(sts));
+	exit(1);
+    }
+    if ((sts = pmFetchArchive(&resp)) < 0) {
+	if (sts != PM_ERR_EOL)
+	    printf("%s: pmFetchArchive: %s\n", pmProgname, pmErrStr(sts));
+    }
+    else {
+	printf("%s: pmFetchArchive: unexpected success after end of log\n", pmProgname);
+	__pmDumpResult(stdout, resp);
+	pmFreeResult(resp);
+    }
+
+    exit(0);
+}