diff options
Diffstat (limited to 'qa/src/interp2.c')
| -rw-r--r-- | qa/src/interp2.c | 198 |
1 files changed, 198 insertions, 0 deletions
diff --git a/qa/src/interp2.c b/qa/src/interp2.c new file mode 100644 index 0000000..11dff00 --- /dev/null +++ b/qa/src/interp2.c @@ -0,0 +1,198 @@ +/* + * Copyright (c) 1997-2001 Silicon Graphics, Inc. All Rights Reserved. + */ + +/* + * interp2 - random offset PM_MODE_INTERP exercises + */ + +#include <pcp/pmapi.h> +#include <pcp/impl.h> + +static void +mung(struct timeval *start, struct timeval *end, + int pct, struct timeval *mid) +{ + __int64_t sec, usec; + sec = (50 + pct * (__int64_t)end->tv_sec + (100 - pct) * (__int64_t)start->tv_sec) / 100; + usec = (50 + pct * (__int64_t)end->tv_usec + (100 - pct) * (__int64_t)start->tv_usec) / 100; + while (usec > 1000000) { + usec -= 1000000; + sec++; + } + while (usec < 0) { + usec += 1000000; + sec--; + } + mid->tv_sec = sec; + mid->tv_usec = usec; +} + +static void +printstamp(struct timeval *tp) +{ + static struct tm *tmp; + + tmp = localtime(&tp->tv_sec); + printf("%02d:%02d:%02d.%03d", tmp->tm_hour, tmp->tm_min, tmp->tm_sec, (int)(tp->tv_usec/1000)); +} + +int +main(int argc, char **argv) +{ + int c; + int sts; + int errflag = 0; + int ahtype = 0; + char *host = NULL; /* pander to gcc */ + pmLogLabel label; /* get hostname for archives */ + char *namespace = PM_NS_DEFAULT; + pmResult *result; + struct timeval tend; + struct timeval twant; + int msec; + int forw; + int back; + int pct; + int numpmid = 3; + pmID pmid[3]; + char *name[] = { "sample.seconds", "sample.drift", "sample.milliseconds" }; + + __pmSetProgname(argv[0]); + + while ((c = getopt(argc, argv, "a:D:n:?")) != EOF) { + switch (c) { + + case 'a': /* archive name */ + if (ahtype != 0) { + fprintf(stderr, "%s: at most one of -a and/or -h allowed\n", pmProgname); + errflag++; + } + ahtype = PM_CONTEXT_ARCHIVE; + host = 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 '?': + default: + errflag++; + break; + } + } + + if (errflag) { + fprintf(stderr, +"Usage: %s options ...\n\ +\n\ +Options\n\ + -a archive metrics source is an archive log\n\ + -D debug standard PCP debug flag\n\ + -n namespace use an alternative PMNS\n", + pmProgname); + exit(1); + } + + if ((sts = pmLoadNameSpace(namespace)) < 0) { + printf("%s: Cannot load namespace from \"%s\": %s\n", pmProgname, namespace, pmErrStr(sts)); + exit(1); + } + + if (ahtype == 0) { + fprintf(stderr, "%s: -a is not optional!\n", pmProgname); + exit(1); + } + if ((sts = pmNewContext(ahtype, host)) < 0) { + fprintf(stderr, "%s: Cannot open archive \"%s\": %s\n", + pmProgname, host, pmErrStr(sts)); + exit(1); + } + + if ((sts = pmGetArchiveLabel(&label)) < 0) { + fprintf(stderr, "%s: Cannot get archive label record: %s\n", + pmProgname, pmErrStr(sts)); + exit(1); + } + + sts = pmGetArchiveEnd(&tend); + if (sts < 0) { + printf("pmGetArchiveEnd: %s\n", pmErrStr(sts)); + exit(1); + } + + /* non-flag args are argv[optind] ... argv[argc-1] */ + if (optind < argc) { + numpmid = 0; + while (optind < argc && numpmid < 3) { + name[numpmid] = argv[optind]; + printf("metric[%d]: %s\n", numpmid, name[numpmid]); + optind++; + numpmid++; + } + } + + sts = pmLookupName(numpmid, name, pmid); + if (sts < 0) { + printf("pmLookupName: %s\n", pmErrStr(sts)); + exit(1); + } + + printf("start: "); + printstamp(&label.ll_start); + putchar('\n'); + printf("end: "); + printstamp(&tend); + putchar('\n'); + mung(&label.ll_start, &tend, 2, &twant); +#if 0 + msec = 1000 * (twant.tv_sec - label.ll_start.tv_sec) + + (twant.tv_usec - label.ll_start.tv_usec) / 1000; +#else + msec = 100; +#endif + printf("step: %d msec\n", msec); + for (pct = 0; pct <= 100; pct += 10) { + __pmLogReads = 0; + mung(&label.ll_start, &tend, pct, &twant); + printf("%3d%% ", pct); + printstamp(&twant); + forw = back = 0; + sts = pmSetMode(PM_MODE_INTERP, &twant, msec); + if (sts < 0) { + printf("pmSetMode: %s\n", pmErrStr(sts)); + exit(1); + } + while (pmFetch(numpmid, pmid, &result) >= 0) { + forw++; + pmFreeResult(result); + } + printf("%4d forw + ", forw); + sts = pmSetMode(PM_MODE_INTERP, &twant, -msec); + if (sts < 0) { + printf("pmSetMode: %s\n", pmErrStr(sts)); + exit(1); + } + while (pmFetch(numpmid, pmid, &result) >= 0) { + back++; + pmFreeResult(result); + } + printf("%4d back = %d, %d log reads\n", + back, forw + back, __pmLogReads); + } + + exit(0); +} |