summaryrefslogtreecommitdiff
path: root/qa/src/proc_test.c
diff options
context:
space:
mode:
Diffstat (limited to 'qa/src/proc_test.c')
-rw-r--r--qa/src/proc_test.c624
1 files changed, 624 insertions, 0 deletions
diff --git a/qa/src/proc_test.c b/qa/src/proc_test.c
new file mode 100644
index 0000000..a8a5ec1
--- /dev/null
+++ b/qa/src/proc_test.c
@@ -0,0 +1,624 @@
+/*
+ * Copyright (c) 1997-2001 Silicon Graphics, Inc. All Rights Reserved.
+ */
+
+/*
+ * Test Plan
+ * ---------
+ *
+ * 0. Agent has associated PMNS, testable say thru PMNS functions.
+ *
+ * Test the agent exported functions using the PMAPI:
+ * (We could call the agent functions directly but we might as well test
+ * that the whole package is working - i.e. communication via pmcd).
+ *
+ * 1. proc_desc - pmGetDesc
+ * 2. proc_text - pmLookupText, pmLookupInDomText
+ * 3. proc_instance - pmGetInDom, pmNameInDom, pmLookupInDom
+ * 4. proc_profile - pmAddProfile, pmDelProfile
+ * 5. proc_fetch - pmFetch
+ * 6. proc_store - pmStore
+ *
+ * Not used: proc_control
+ *
+ *
+ * Method
+ * ------
+ *
+ * 1. desc
+ * a. Test that all specified metrics can have their desc retrieved without error
+ * b. Test that all spec. metrics have the same indom.
+ * Note: ideally we would want to make sure that all the desc values returned are
+ * correct but that means basically just duplicating the agent's code.
+ *
+ * 3. instance
+ * a. Output the instance map, name-->inst, inst-->name
+ * This output can be tested by a script to look for certain
+ * processes.
+ * b. Verify that names and ids are consistent with each other.
+ *
+ * 4.5. profile/fetch
+ * a. Profile is set correctly - look at context dump
+ * b. Fetch on profile and ensure that the results only have the specified
+ * instances.
+ * Note: ideally we would to ensure that the values returned are correct.
+ * This, however, would be a tricky thing for a lot of metrics.
+ * The metrics are continually changing for the processes.
+ *
+ * 6. store
+ * a. Ensure it fails appropriately.
+ *
+ * TODO
+ * ----
+ * 0, 2,
+ *
+ */
+
+#include <ctype.h>
+#include <sys/wait.h>
+#include <pcp/pmapi.h>
+#include <pcp/impl.h>
+
+#ifdef HAVE_PROCFS
+#ifdef IS_NETBSD
+#include <miscfs/procfs/procfs.h>
+#else
+#include <sys/procfs.h>
+#endif
+
+#define MAXMETRICS 1024
+
+int verbose = 0;
+char *host = "localhost";
+char *pmnsfile = PM_NS_DEFAULT;
+int nmetrics;
+char *metrics[MAXMETRICS];
+pmID pmids[MAXMETRICS];
+pmInDom indom;
+int iterations = 1;
+int all_n;
+int *all_inst;
+char **all_names;
+pid_t child_pid;
+int is_hotproc = 0;
+int refresh = 1;
+
+/* format of an entry in /proc */
+char proc_fmt[8]; /* export for procfs fname conversions */
+
+
+/*
+ * getargs
+ */
+
+void
+getargs(int argc, char **argv)
+{
+#ifdef PCP_DEBUG
+ static char *debug = "[-D N]";
+#else
+ static char *debug = "";
+#endif
+ static char *usage = " [-h hostname] [-n pmnsfile] "
+ "[-i iterations] [-t refresh] [-v] "
+ "metric [metric ...]";
+ int errflag = 0;
+ char *endnum;
+ int c;
+ int i;
+ int sts;
+
+ __pmSetProgname(argv[0]);
+
+ while ((c = getopt(argc, argv, "D:h:n:i:t:v")) != 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': /* iterations */
+ iterations = (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 */
+ pmnsfile = optarg;
+ break;
+
+ case 't':
+ refresh = (int)strtol(optarg, &endnum, 10);
+ if (*endnum != '\0') {
+ fprintf(stderr, "%s: -t requires numeric argument\n", pmProgname);
+ errflag++;
+ }
+ break;
+
+ case 'v':
+ verbose = 1;
+ break;
+
+ case '?':
+ default:
+ errflag++;
+ break;
+ }
+ }
+
+ if (errflag) {
+USAGE:
+ fprintf(stderr, "Usage: %s %s%s\n", pmProgname, debug, usage);
+ exit(1);
+ }
+
+ /* non-flag args are argv[optind] ... argv[argc-1] */
+ if (optind >= argc)
+ goto USAGE;
+
+ /* note metrics and dump them out */
+ for (i = 0; i < argc - optind; i++) {
+ metrics[i] = argv[optind+i];
+ if (strncmp(metrics[i], "hotproc.", 8) == 0) {
+ if (i > 0 && !is_hotproc) {
+ printf("%s: Error: all metrics should be from same agent\n",
+ pmProgname);
+ exit(1);
+ }
+ is_hotproc = 1;
+ }
+ else if (strncmp(metrics[i], "proc.", 5) == 0) {
+ if (i > 0 && is_hotproc) {
+ printf("%s: Error: all metrics should be from same agent\n",
+ pmProgname);
+ exit(1);
+ }
+ is_hotproc = 0;
+ }
+ else {
+ printf("%s: Error: all metrics should be from "
+ "proc or hotproc agent: %s\n", pmProgname, metrics[i]);
+ exit(1);
+ }
+ printf("metrics[%d] = <%s>\n", i, metrics[i]);
+ }
+ nmetrics = i;
+
+ if (nmetrics <= 0)
+ goto USAGE;
+}
+
+
+void
+print_banner_start(char *msg)
+{
+ int len = strlen(msg);
+ int i;
+
+ printf("\n");
+ for (i = 0; i < len+14; i++) printf("=");
+ printf("\n");
+ printf("=== Test: %s ===\n", msg);
+ for (i = 0; i < len+14; i++) printf("=");
+ printf("\n");
+
+}
+
+void
+print_banner_end(char *msg)
+{
+ int len = strlen(msg);
+ int i;
+
+ printf("\n");
+ for (i = 0; i < len+21; i++) printf("=");
+ printf("\n");
+ printf("=== End Of Test: %s ===\n", msg);
+ for (i = 0; i < len+21; i++) printf("=");
+ printf("\n");
+
+}
+
+static void
+set_proc_fmt(void)
+{
+ DIR *procdir;
+ const char *procfs = "/proc";
+ struct dirent *directp;
+ int ndigit;
+ int proc_entry_len; /* number of chars in procfs entry */
+
+ if ((procdir = opendir(procfs)) == NULL) {
+ perror(procfs);
+ return;
+ }
+ proc_entry_len = -1;
+ for (rewinddir(procdir); (directp = readdir(procdir));) {
+ if (!isdigit((int)directp->d_name[0]))
+ continue;
+ ndigit = (int)strlen(directp->d_name);
+ if (proc_entry_len == -1) {
+ proc_entry_len = ndigit;
+ sprintf(proc_fmt, "%%0%dd", proc_entry_len);
+ }
+ else if (ndigit != proc_entry_len) {
+ /*
+ * different lengths, so not fixed width ... this is the
+ * Linux way
+ */
+ sprintf(proc_fmt, "%%d");
+ break;
+ }
+ }
+ closedir(procdir);
+}
+
+/*
+ * 0.
+ * Does NOT really verify PMNS
+ * get pmids for rest of pm functions
+ */
+void
+test_PMNS(void)
+{
+ int sts;
+ int i;
+
+ print_banner_start("PMNS");
+ if ((sts = pmLookupName(nmetrics, metrics, pmids)) < 0) {
+ printf("pmLookupName: %s\n", pmErrStr(sts));
+ for (i = 0; i < nmetrics; i++) {
+ if (pmids[i] == PM_ID_NULL)
+ printf(" %s - not known\n", metrics[i]);
+ }
+ exit(1);
+ }
+ print_banner_end("PMNS");
+
+}
+
+/*
+ * 1. check all the descriptors
+ */
+void
+test_desc(void)
+{
+ int sts;
+ int i;
+ pmDesc desc;
+
+ print_banner_start("desc");
+
+ /* test if possible to get one of them and get its indom */
+ if ((sts = pmLookupDesc(pmids[0], &desc)) < 0) {
+ fprintf(stderr, "pmLookupDesc: %s\n", pmErrStr(sts));
+ fprintf(stderr, "Associated metric = %s (%s)\n", metrics[0], pmIDStr(pmids[0]));
+ exit(1);
+ }
+ indom = desc.indom;
+ for (i=0; i < nmetrics; i++) {
+ if ((sts = pmLookupDesc(pmids[i], &desc)) < 0) {
+ fprintf(stderr, "pmLookupDesc: %s\n", pmErrStr(sts));
+ fprintf(stderr, "Associated metric = %s (%s)\n", metrics[i], pmIDStr(pmids[i]));
+ exit(1);
+ }
+ if (desc.indom != indom) {
+ fprintf(stderr, "metric <%s> has indom = %d, different to metric <%s> indom = %d\n",
+ metrics[i], desc.indom, metrics[0], indom);
+ fprintf(stderr, "This test requires all metrics have the same indom\n");
+ exit(1);
+ }
+ }
+
+ print_banner_end("desc");
+
+}
+
+
+/*
+ * 3.
+ * Test out proc_instance
+ * Using pmGetInDom(), pmNameInDom(), pmLookupInDom()
+ * Now get metrics for the entire instance domain
+ *
+ * Does some sanity checks on names and ids
+ */
+
+void
+test_instance(void)
+{
+ int sts;
+ int i;
+
+ print_banner_start("instance");
+ if (indom == PM_INDOM_NULL)
+ return;
+
+ fflush(stdout);
+ if ((child_pid=fork()) == 0) {
+ /* child sleeps and then exits */
+ sleep(2*refresh+1);
+ exit(0);
+ }
+ printf("cpid=%" FMT_PID "\n", child_pid);
+
+ if (is_hotproc) {
+ /* sleep so that hotprocs can update active list */
+ sleep(2*refresh);
+ }
+ printf("\n--- GetInDom ---\n");
+ sts = pmGetInDom(indom, &all_inst, &all_names);
+ if (sts < 0) {
+ printf("%s: pmGetInDom: %s\n", pmProgname, pmErrStr(sts));
+ exit(1);
+ }
+ else
+ all_n = sts;
+
+ /* print the instance id's (i.e. pids) match the first field in the name */
+ for (i=0; i < all_n; i++) {
+ int inst;
+ if (verbose)
+ printf(" instance map [%d \"%s\"]\n", all_inst[i], all_names[i]);
+
+ /* e.g. inst=0, name="00000 sched" */
+ if (sscanf(all_names[i], proc_fmt, &inst) != 1) {
+ printf("%s: Error: cannot get PID from instname\n", pmProgname);
+ printf("%s: <id,name> = <%ld,\"%s\">\n", pmProgname,
+ (long)all_inst[i], all_names[i]);
+ exit(1);
+ }
+ if (inst != all_inst[i]) {
+ printf("%s: Error: instname is wrong\n", pmProgname);
+ printf("%s: <id,name> = <%ld,\"%s\"> != %d (fmt=%s)\n", pmProgname,
+ (long)all_inst[i], all_names[i], inst, proc_fmt);
+ exit(1);
+ }
+ }
+
+ /* parent waits for child to exit */
+ /* so that the the following lookups will NOT be able to find it */
+ wait(&sts);
+
+
+ printf("\n--- LookupInDom ---\n");
+ for (i = 0; i < all_n; i++) {
+ int inst, x;
+ sts = pmLookupInDom(indom, all_names[i]);
+ if (sts < 0) {
+ if (sts == PM_ERR_INST) {
+ if (all_inst[i] == child_pid)
+ printf(" Death of child detected, pid=%" FMT_PID "\n", child_pid);
+ /* ignore deaths */
+ continue;
+ }
+ else {
+ printf("%s: pmLookupInDom: %s\n", pmProgname, pmErrStr(sts));
+ exit(1);
+ }
+ }
+ inst = sts;
+ if (verbose)
+ printf(" instance lookup \"%s\" --> %d\n", all_names[i], inst);
+ sscanf(all_names[i], proc_fmt, &x);
+ if (x != inst) {
+ printf("%s: Error: inst is wrong, expect: %d got: %d\n",
+ pmProgname, inst, x);
+ printf("%s: Expected=%d, Actual=%d\n", pmProgname, x, inst);
+ exit(1);
+ }
+ }/*for*/
+
+ printf("\n--- NameInDom ---\n");
+ for (i = 0; i < all_n; i++) {
+ char *name;
+ char x[100];
+
+ sts = pmNameInDom(indom, all_inst[i], &name);
+ if (sts < 0) {
+ if (sts == PM_ERR_INST) {
+ if (all_inst[i] == child_pid)
+ printf(" Death of child detected\n");
+ /* ignore deaths */
+ continue;
+ }
+ else {
+ printf("%s: pmNameInDom: %s\n", pmProgname, pmErrStr(sts));
+ exit(1);
+ }
+ }
+ if (verbose)
+ printf(" instance name %d --> \"%s\"\n", all_inst[i], name);
+ sprintf(x, proc_fmt, all_inst[i]);
+ if (strncmp(name, x, strlen(x)) != 0 ||
+ (name[strlen(x)] != '\0' && name[strlen(x)] != ' ')) {
+ /* try w/out leading zeroes */
+ char *q;
+ sprintf(x, "%d", all_inst[i]);
+ for (q = name; *q && *q == '0'; q++)
+ ;
+ if (strncmp(q, x, strlen(x)) != 0 ||
+ (q[strlen(x)] != '\0' && q[strlen(x)] != ' ')) {
+ printf("%s: Error: name is wrong\n", pmProgname);
+ printf("%s: Expected=\"%s\", Actual=\"%s\"\n", pmProgname, x, name);
+ exit(1);
+ }
+ }
+ free(name);
+ }/*for*/
+
+ print_banner_end("instance");
+}
+
+
+/*
+ * Tests 4. and 5.
+ * Set up an explicit profile of ourself and our parent
+ * If any of the metrics are not in the proc indom, we'll get no values back.
+ * Checks if profile is being handled correctly.
+ * Checks if fetch is using profile correctly.
+ */
+void
+test_prof_fetch(void)
+{
+ int sts;
+ int i;
+ int pids[2];
+ pmResult *result1, *result2;
+
+ print_banner_start("profile/fetch");
+
+ pids[0] = (int)getpid();
+ pids[1] = (int)getppid();
+ pmDelProfile(indom, 0, NULL);
+ pmAddProfile(indom, 2, pids);
+
+ printf("\n--- Check profile in context dump... ---\n");
+ if ((sts = pmWhichContext()) < 0) {
+ printf("%s: pmWhichContext: %s\n", pmProgname, pmErrStr(sts));
+ exit(1);
+ }
+ __pmDumpContext(stdout, sts, PM_INDOM_NULL);
+ printf("--- End Check profile in context dump... ---\n");
+
+ printf("\n--- Fetch Over Restricted Instance Domain ... ---\n");
+ for (i=0; i < iterations; i++) {
+ int j,k;
+
+ sts = pmFetch(nmetrics, pmids, &result1);
+ if (sts < 0) {
+ printf("%s: iteration %d : %s\n", pmProgname, i, pmErrStr(sts));
+ exit(1);
+ }
+ __pmDumpResult(stdout, result1);
+
+
+ for (j = 0; j < result1->numpmid; j++) {
+ pmValueSet *set = result1->vset[j];
+
+ if (set->numval != 2) {
+ printf("%s: Error: num of inst == %d\n", pmProgname, set->numval);
+ }
+
+ for (k = 0; k < set->numval; k++) {
+ pmValue *val = &set->vlist[k];
+ if (val->inst != pids[0] && val->inst != pids[1]) {
+ printf("%s: Error: inst ids do not match pids\n", pmProgname);
+ exit(1);
+ }
+ }
+ }
+
+ pmFreeResult(result1);
+ }
+ printf("--- End Fetch Over Restricted Instance Domain ... ---\n");
+
+
+
+ printf("\n--- Fetch Over Entire Instance Domain ... ---\n");
+ if (indom != PM_INDOM_NULL) {
+ pmDelProfile(indom, 0, NULL);
+ pmAddProfile(indom, all_n, all_inst);
+ }
+ sts = pmFetch(nmetrics, pmids, &result2);
+ if (sts < 0) {
+ printf("%s: fetch all %d instances : %s\n", pmProgname, all_n, pmErrStr(sts));
+ exit(1);
+ }
+ __pmDumpResult(stdout, result2);
+ pmFreeResult(result2);
+ printf("--- End Fetch Over Entire Instance Domain ... ---\n");
+
+ print_banner_end("profile/fetch");
+
+}
+
+void
+test_store(void)
+{
+ int sts;
+ pmResult *result;
+
+ print_banner_start("store");
+
+ sts = pmFetch(nmetrics, pmids, &result);
+ if (sts < 0) {
+ printf("%s: fetch failed : %s\n", pmProgname, pmErrStr(sts));
+ exit(1);
+ }
+ if ((sts = pmStore(result)) != -EACCES && sts != PM_ERR_PERMISSION) {
+ printf("%s: Error: pmStore did not fail correctly\n", pmProgname);
+ printf("Expected: %s\n", pmErrStr(-EACCES));
+ printf("or: %s\n", pmErrStr(PM_ERR_PERMISSION));
+ printf("Got: %s\n", pmErrStr(sts));
+ exit(1);
+ }
+ pmFreeResult(result);
+
+ print_banner_end("store");
+}
+
+/*
+ * main
+ */
+int
+main(int argc, char **argv)
+{
+ int sts;
+
+ set_proc_fmt();
+ printf("pid=%" FMT_PID " ppid=%" FMT_PID "\n", getpid(), getppid());
+ getargs(argc, argv);
+
+ if (pmnsfile != PM_NS_DEFAULT) {
+ if ((sts = pmLoadNameSpace(pmnsfile)) < 0) {
+ printf("%s: Cannot load pmnsfile from \"%s\": %s\n",
+ pmProgname, pmnsfile, 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);
+ }
+
+ test_PMNS();
+ test_desc();
+ test_instance();
+ test_prof_fetch();
+ if (!is_hotproc)
+ test_store();
+
+ if ((sts = pmWhichContext()) < 0) {
+ printf("%s: pmWhichContext: %s\n", pmProgname, pmErrStr(sts));
+ exit(1);
+ }
+ pmDestroyContext(sts);
+
+ exit(0);
+}
+#else
+int
+main(int argc, char **argv)
+{
+ printf("No /proc pseudo filesystem on this platform\n");
+ exit(1);
+}
+#endif /* HAVE_PROCFS */
generated by cgit v1.2.3 (git 2.39.1) at 2024-06-02 08:43:43 +0000