diff options
Diffstat (limited to 'qa/src/logcontrol.c')
| -rw-r--r-- | qa/src/logcontrol.c | 260 |
1 files changed, 260 insertions, 0 deletions
diff --git a/qa/src/logcontrol.c b/qa/src/logcontrol.c new file mode 100644 index 0000000..cd0ca1a --- /dev/null +++ b/qa/src/logcontrol.c @@ -0,0 +1,260 @@ +/* + * Copyright (c) 1997-2001 Silicon Graphics, Inc. All Rights Reserved. + */ + +/* + * Utility to control archive logging for metrics + */ + +#include <pcp/pmapi.h> +#include <pcp/impl.h> + +int +main(int argc, char **argv) +{ + int c; + int i; + int j; + int sts; + int ctlport; + int pid = PM_LOG_PRIMARY_PID; + int port = PM_LOG_NO_PORT; + int newstate; + int errflag = 0; + char *host = "localhost"; + char *namespace = NULL; + char *instance = (char *)0; + char *endnum; + int numpmid; + pmID *pmidlist; + char *control_arg; + int control; + char *state_arg; + int state; + pmResult *request; + pmDesc desc; + int inst; + pmResult *status; + int delta = 5000; + + __pmSetProgname(argv[0]); + + while ((c = getopt(argc, argv, "D:h:i:n:P:p:r:")) != 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 'h': /* hostname for PMCD to contact */ + host = optarg; + break; + + case 'i': /* instance identifier */ + instance = optarg; + break; + + case 'n': /* alternative name space file */ + namespace = optarg; + break; + + case 'P': /* port for pmlogger */ + port = (int)strtol(optarg, &endnum, 10); + if (*endnum != '\0') { + fprintf(stderr, "%s: -P requires numeric argument\n", pmProgname); + errflag++; + } + break; + + case 'p': /* pid for pmlogger */ + pid = (int)strtol(optarg, &endnum, 10); + if (*endnum != '\0') { + fprintf(stderr, "%s: -p requires numeric argument\n", pmProgname); + errflag++; + } + break; + + case 'r': /* logging delta */ + delta = (int)strtol(optarg, &endnum, 10); + if (*endnum != '\0') { + fprintf(stderr, "%s: -r requires numeric argument\n", pmProgname); + errflag++; + } + break; + + case '?': + default: + errflag++; + break; + } + } + + if (errflag || optind > argc-2) { +USAGE: + fprintf(stderr, +"Usage: %s [options] action metric ...\n" +"\n" +"Options\n" +" -D level set debug level\n" +" -h hostname contact PMCD at this host\n" +" -i instance apply only to this instance\n" +" -n namespace use and alternative name space\n" +" -P port port for pmlogger instance\n" +" -p pid pid for pmlogger instance\n" +" -r delta requested logging interval (msec)\n" +"\n" +"Actions\n" +" mandatory {on|off|maybe}\n" +" advisory {on|off}\n" +" enquire\n" + , pmProgname); + exit(1); + } + + control_arg = argv[optind++]; + if (strcmp("mandatory", control_arg) == 0) + control = PM_LOG_MANDATORY; + else if (strcmp("advisory", control_arg) == 0) + control = PM_LOG_ADVISORY; + else if (strcmp("enquire", control_arg) == 0) + control = PM_LOG_ENQUIRE; + else + goto USAGE; + + if (control == PM_LOG_ENQUIRE) + state = 0; + else { + state_arg = argv[optind++]; + if (strcmp("on", state_arg) == 0) + state = PM_LOG_ON; + else if (strcmp("off", state_arg) == 0) + state = PM_LOG_OFF; + else if (control == PM_LOG_MANDATORY && strcmp("maybe", state_arg) == 0) + state = PM_LOG_MAYBE; + else + goto USAGE; + } + + if (namespace != NULL && (sts = pmLoadNameSpace(namespace)) < 0) { + printf("%s: Cannot load namespace from \"%s\": %s\n", pmProgname, namespace, pmErrStr(sts)); + exit(1); + } + + if ((sts = pmNewContext(PM_CONTEXT_HOST, host)) < 0) { + printf("%s: Cannot connect to PMCD on host \"%s\": %s\n", pmProgname, host, pmErrStr(sts)); + exit(1); + } + + if ((sts = __pmConnectLogger(host, &pid, &port)) < 0) { + printf("%s: Cannot connect to pmlogger (%d) on host \"%s\": %s\n", + pmProgname, pid, host, pmErrStr(sts)); + exit(1); + } + ctlport = sts; + + numpmid = argc - optind; + pmidlist = (pmID *)malloc(numpmid * sizeof(pmID)); + + if ((sts = pmLookupName(numpmid, &argv[optind], pmidlist)) < 0) { + printf("pmLookupName: %s\n", pmErrStr(sts)); + exit(1); + } + for (i = 0; i < numpmid; i++) { + if (pmidlist[i] == PM_ID_NULL) { + printf("Error: metric %s is unknown\n", argv[optind+i]); + exit(1); + } + if (instance != (char *)0) { + if ((sts = pmLookupDesc(pmidlist[i], &desc)) < 0) { + printf("pmDesc(%s %s): %s\n", + argv[optind+i], pmIDStr(pmidlist[i]), pmErrStr(sts)); + exit(1); + } + if ((inst = pmLookupInDom(desc.indom, instance)) < 0) { + printf("pmLookupInDom(%s): %s\n", instance, pmErrStr(inst)); + exit(1); + } + if ((sts = pmDelProfile(desc.indom, 0, (int *)0)) < 0) { + printf("pmDelProfile(%s): %s\n", pmInDomStr(desc.indom), pmErrStr(inst)); + exit(1); + } + if ((sts = pmAddProfile(desc.indom, 1, &inst)) < 0) { + printf("pmAddProfile(%s): %s\n", pmInDomStr(desc.indom), pmErrStr(inst)); + exit(1); + } + } + } + + if ((sts = pmFetch(numpmid, pmidlist, &request)) < 0) { + printf("pmFetch: %s\n", pmErrStr(sts)); + exit(1); + } + + sts = __pmControlLog(ctlport, request, control, state, delta, &status); + if (sts < 0) { + printf("%s: %s\n", pmProgname, pmErrStr(sts)); + exit(1); + } + + for (i = 0; i < numpmid; i++) { + if ((sts = pmLookupDesc(pmidlist[i], &desc)) < 0) { + printf("pmDesc(%s): %s\n", pmIDStr(pmidlist[i]), pmErrStr(sts)); + goto done; + } + printf("%s", argv[optind+i]); + if (status->vset[i]->numval < 0) + printf(" Error: %s\n", pmErrStr(status->vset[i]->numval)); + else if (status->vset[i]->numval == 0) + printf(" No value?\n"); + else { + for (j = 0; j < status->vset[i]->numval; j++) { + pmValue *vp = &status->vset[i]->vlist[j]; + char *p; + if (status->vset[i]->numval > 1 || desc.indom != PM_INDOM_NULL) { + if (j == 0) + putchar('\n'); + printf(" inst [%d", vp->inst); + if (pmNameInDom(desc.indom, vp->inst, &p) < 0) + printf(" or ???]"); + else { + printf(" or \"%s\"]", p); + free(p); + } + } + newstate = PMLC_GET_STATE(vp->value.lval); + printf(" %d (%s %s", newstate, + PMLC_GET_MAND(vp->value.lval) ? "mand" : "adv", + PMLC_GET_ON(vp->value.lval) ? "on" : "off"); + if (PMLC_GET_ON(vp->value.lval)) + printf(", delta=%d msec", PMLC_GET_DELTA(vp->value.lval)); + if (PMLC_GET_INLOG(vp->value.lval)) + printf(", inlog"); + if (PMLC_GET_AVAIL(vp->value.lval)) + printf(", avail"); + printf(")\n"); + } + } + } + + free(pmidlist); + pmFreeResult(request); + pmFreeResult(status); + if ((sts = pmWhichContext()) < 0) { + printf("%s: pmWhichContext: %s\n", pmProgname, pmErrStr(sts)); + goto done; + } + pmDestroyContext(sts); + +done: + close(ctlport); + sleep(1); + + exit(0); +} |