diff options
Diffstat (limited to 'qa/src/chkconnect.c')
| -rw-r--r-- | qa/src/chkconnect.c | 180 |
1 files changed, 180 insertions, 0 deletions
diff --git a/qa/src/chkconnect.c b/qa/src/chkconnect.c new file mode 100644 index 0000000..03e211b --- /dev/null +++ b/qa/src/chkconnect.c @@ -0,0 +1,180 @@ +/* + * Copyright (c) 1997-2001 Silicon Graphics, Inc. All Rights Reserved. + */ + +#include <unistd.h> +#include <ctype.h> +#include <pcp/pmapi.h> +#include <pcp/impl.h> + +int +main(int argc, char **argv) +{ + int j; + int numpmid; + int numval; + char *namelist[20]; + pmID pmidlist[20]; + pmResult *result; + int c; + int sts; + int i; + int errflag = 0; + char *host = "localhost"; + char *namespace = PM_NS_DEFAULT; + char *endnum; + int iter = 100; + +#ifdef PCP_DEBUG + static char *debug = "[-D N]"; +#else + static char *debug = ""; +#endif + static char *usage = "[-h hostname] [-i iterations] [-n namespace]"; + + __pmSetProgname(argv[0]); + + while ((c = getopt(argc, argv, "D:h:i:n:")) != EOF) { + switch (c) { + +#ifdef PCP_DEBUG + 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; +#endif + + case 'h': /* hostname for PMCD to contact */ + host = optarg; + break; + + case 'i': /* iteration count */ + iter = (int)strtol(optarg, &endnum, 10); + if (*endnum != '\0') { + fprintf(stderr, "%s: -i requires numeric argument\n", pmProgname); + errflag++; + } + break; + + case 'n': /* alternative name space file */ + namespace = optarg; + break; + + case '?': + default: + errflag++; + break; + } + } + + if (errflag) { + fprintf(stderr, "Usage: %s %s%s\n", pmProgname, debug, usage); + exit(1); + } + + if ((sts = pmLoadNameSpace(namespace)) < 0) { + fprintf(stderr, "pmLoadNameSpace(%s): %s\n", namespace, pmErrStr(sts)); + exit(1); + } + + i = 0; + namelist[i++] = "sample.control"; + namelist[i++] = "sampledso.control"; + namelist[i++] = "sampledso.control"; + namelist[i++] = "pmcd.control.debug"; + namelist[i++] = "sample.control"; + namelist[i++] = "pmcd.control.debug"; + namelist[i++] = "sampledso.control"; + namelist[i++] = "pmcd.control.debug"; + namelist[i++] = "sample.control"; + namelist[i++] = "sampledso.control"; + namelist[i++] = "pmcd.control.debug"; + namelist[i++] = "sample.control"; + numpmid = i; + sts = pmLookupName(numpmid, namelist, pmidlist); + if (sts < 0) { + fprintf(stderr, "pmLookupName: %s\n", pmErrStr(sts)); + for (i = 0; i < numpmid; i++) { + if (pmidlist[i] == PM_ID_NULL) + printf(" %s - not known\n", namelist[i]); + } + exit(1); + } + + for (i = 0; i < iter; i++) { + sts = pmNewContext(PM_CONTEXT_HOST, host); + if (sts < 0) { + fprintf(stderr, "pmNewContext: [iteration %d] %s\n", i, pmErrStr(sts)); + exit(1); + } + else if (sts != i * 2) + fprintf(stderr, "Error: [iteration %d] pmNewContext handle expected %d, got %d\n", i, i * 2, sts); + + numpmid = 1 + lrand48() % 12; + if ((sts = pmFetch(numpmid, pmidlist, &result)) < 0) { + fprintf(stderr, "pmFetch: [iteration %d] %s\n", i, pmErrStr(sts)); + exit(1); + } + numval = 0; + for (j = 0; j < result->numpmid; j++) { + if (result->vset[j]->numval >= 0) + numval += result->vset[j]->numval; + } + if (numval != numpmid) { + fprintf(stderr, "Error: [iteration %d] pmFetch numval expected %d, got %d\n", i, numpmid, numval); + } + pmFreeResult(result); + + sts = pmDupContext(); + if (sts < 0) { + fprintf(stderr, "pmDupContext: [iteration %d] %s\n", i, pmErrStr(sts)); + exit(1); + } + else if (sts != i * 2 + 1) + fprintf(stderr, "Error: [iteration %d] pmDupContext handle expected %d, got %d\n", i, i * 2 + 1, sts); + + numpmid = 1 + lrand48() % 12; + if ((sts = pmFetch(numpmid, pmidlist, &result)) < 0) { + fprintf(stderr, "pmFetch: [iteration %d, dup context] %s\n", i, pmErrStr(sts)); + exit(1); + } + numval = 0; + for (j = 0; j < result->numpmid; j++) { + if (result->vset[j]->numval >= 0) + numval += result->vset[j]->numval; + } + if (numval != numpmid) { + fprintf(stderr, "Error: [iteration %d] pmFetch numval expected %d, got %d\n", i, numpmid, numval); + } + pmFreeResult(result); + + if ((sts = pmReconnectContext(i)) < 0) { + fprintf(stderr, "pmReconnectContext: [iteration %d] %s\n", i, pmErrStr(sts)); + exit(1); + } + + numpmid = 1 + lrand48() % 12; + if ((sts = pmFetch(numpmid, pmidlist, &result)) < 0) { + fprintf(stderr, "pmFetch: [iteration %d, recon] %s\n", i, pmErrStr(sts)); + exit(1); + } + numval = 0; + for (j = 0; j < result->numpmid; j++) { + if (result->vset[j]->numval >= 0) + numval += result->vset[j]->numval; + } + if (numval != numpmid) { + fprintf(stderr, "Error: [iteration %d, recon] pmFetch numval expected %d, got %d\n", i, numpmid, numval); + } + pmFreeResult(result); + + } + + return 0; +} |