Debian 3.9.10debian/3.9.10debian

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);
+}