Date: Tue, 29 May 2018 20:28:34 +0000 (UTC) From: Matt Macy <mmacy@FreeBSD.org> To: src-committers@freebsd.org, svn-src-all@freebsd.org, svn-src-head@freebsd.org Subject: svn commit: r334350 - in head/usr.sbin: . pmc Message-ID: <201805292028.w4TKSYiN044618@repo.freebsd.org>
next in thread | raw e-mail | index | archive | help
Author: mmacy Date: Tue May 29 20:28:34 2018 New Revision: 334350 URL: https://svnweb.freebsd.org/changeset/base/334350 Log: pmc: Add new sub-command structured "pmc" utility This will manage pmc functionality with a more manageable structure of subcommands rather than the gradually accreted spaghetti logic of overlapping flags that exists in pmcstat. This is intended to ultimately have all the same functionality as pmcannotate+pmccontrol+pmcstat. Currently it just has "stat" and "system-stat" - counters for the process itself and counters for the system as a whole respectively (i.e. system-stat includes kernel threads). Note that the rusage results (page faults/context switches/ user/sys) for stat-system will not account for the system as a whole - only for the child process specified on the command line. Implementing stat was suggested by mjg@ and the output is based on that from Linux's "perf stat". % pmc stat -- make -j32 buildkernel -DNO_MODULES -ss > /dev/null 9598393 page faults # 0.674 M/sec 387085 voluntary csw # 0.027 M/sec 106989 involuntary csw # 0.008 M/sec 2763965982317 cycles 2542953049760 instructions # 0.920 inst/cycle 511562750157 branches 12917006881 branch-misses # 2.525% 17944429878 cache-references # 0.007 refs/inst 2205119560 cache-misses # 12.289% 43.74 real # 2019.72% cpu 795.09 user # 1817.72% cpu 88.35 sys # 202.00% cpu % make -j32 buildkernel -DNO_MODULES -ss > /dev/null & % sudo pmc stat-system cat ^C 103 page faults # 0.811 M/sec 4 voluntary csw # 0.031 M/sec 0 involuntary csw # 0.000 M/sec 2843639070514 cycles 2606171217438 instructions # 0.916 inst/cycle 522450422783 branches 13092862839 branch-misses # 2.506% 18592101113 cache-references # 0.007 refs/inst 2562878667 cache-misses # 13.785% 44.85 real # 0.00% cpu 0.00 user # 0.00% cpu 0.00 sys # 0.00% cpu Added: head/usr.sbin/pmc/ head/usr.sbin/pmc/Makefile (contents, props changed) head/usr.sbin/pmc/cmd_pmc.h (contents, props changed) head/usr.sbin/pmc/cmd_pmc_stat.c (contents, props changed) head/usr.sbin/pmc/pmc.c (contents, props changed) head/usr.sbin/pmc/pmc_util.c (contents, props changed) Modified: head/usr.sbin/Makefile Modified: head/usr.sbin/Makefile ============================================================================== --- head/usr.sbin/Makefile Tue May 29 20:09:35 2018 (r334349) +++ head/usr.sbin/Makefile Tue May 29 20:28:34 2018 (r334350) @@ -179,6 +179,7 @@ SUBDIR.${MK_OPENSSL}+= keyserv SUBDIR.${MK_PC_SYSINSTALL}+= pc-sysinstall SUBDIR.${MK_PF}+= ftp-proxy SUBDIR.${MK_PKGBOOTSTRAP}+= pkg +SUBDIR.${MK_PMC}+= pmc SUBDIR.${MK_PMC}+= pmcannotate SUBDIR.${MK_PMC}+= pmccontrol SUBDIR.${MK_PMC}+= pmcstat Added: head/usr.sbin/pmc/Makefile ============================================================================== --- /dev/null 00:00:00 1970 (empty, because file is newly added) +++ head/usr.sbin/pmc/Makefile Tue May 29 20:28:34 2018 (r334350) @@ -0,0 +1,12 @@ +# +# $FreeBSD$ +# + +PROG= pmc +MAN= + +LIBADD= kvm pmc m ncursesw pmcstat elf + +SRCS= pmc.c pmc_util.c cmd_pmc_stat.c + +.include <bsd.prog.mk> Added: head/usr.sbin/pmc/cmd_pmc.h ============================================================================== --- /dev/null 00:00:00 1970 (empty, because file is newly added) +++ head/usr.sbin/pmc/cmd_pmc.h Tue May 29 20:28:34 2018 (r334350) @@ -0,0 +1,52 @@ +/*- + * SPDX-License-Identifier: BSD-2-Clause-FreeBSD + * + * Copyright (c) 2018, Matthew Macy + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions + * are met: + * 1. Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * 2. Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * + * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND + * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE + * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE + * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE + * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL + * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS + * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) + * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT + * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY + * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF + * SUCH DAMAGE. + * + * $FreeBSD$ + * + */ +#ifndef _CMD_PMC_H_ +#define _CMD_PMC_H_ + +#define DEFAULT_DISPLAY_HEIGHT 256 /* file virtual height */ +#define DEFAULT_DISPLAY_WIDTH 1024 /* file virtual width */ + +extern int pmc_displayheight; +extern int pmc_displaywidth; +extern int pmc_kq; +extern struct pmcstat_args pmc_args; + +typedef int (*cmd_disp_t)(int, char **); + +int cmd_pmc_stat(int, char **); +int cmd_pmc_stat_system(int, char **); + +int pmc_util_get_pid(struct pmcstat_args *); +void pmc_util_start_pmcs(struct pmcstat_args *); +void pmc_util_cleanup(struct pmcstat_args *); +void pmc_util_shutdown_logging(struct pmcstat_args *args); +void pmc_util_kill_process(struct pmcstat_args *args); + +#endif Added: head/usr.sbin/pmc/cmd_pmc_stat.c ============================================================================== --- /dev/null 00:00:00 1970 (empty, because file is newly added) +++ head/usr.sbin/pmc/cmd_pmc_stat.c Tue May 29 20:28:34 2018 (r334350) @@ -0,0 +1,478 @@ +/*- + * SPDX-License-Identifier: BSD-2-Clause-FreeBSD + * + * Copyright (c) 2018, Matthew Macy + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions + * are met: + * 1. Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * 2. Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * + * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND + * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE + * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE + * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE + * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL + * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS + * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) + * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT + * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY + * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF + * SUCH DAMAGE. + * + */ + +#include <sys/cdefs.h> +__FBSDID("$FreeBSD$"); + +#include <sys/param.h> +#include <sys/cpuset.h> +#include <sys/event.h> +#include <sys/queue.h> +#include <sys/socket.h> +#include <sys/stat.h> +#include <sys/sysctl.h> +#include <sys/time.h> +#include <sys/ttycom.h> +#include <sys/user.h> +#include <sys/wait.h> + +#include <assert.h> +#include <curses.h> +#include <err.h> +#include <errno.h> +#include <fcntl.h> +#include <getopt.h> +#include <kvm.h> +#include <libgen.h> +#include <limits.h> +#include <locale.h> +#include <math.h> +#include <pmc.h> +#include <pmclog.h> +#include <regex.h> +#include <signal.h> +#include <stdarg.h> +#include <stdint.h> +#include <stdio.h> +#include <stdlib.h> +#include <string.h> +#include <sysexits.h> +#include <unistd.h> + +#include <libpmcstat.h> +#include "cmd_pmc.h" + +/* + * Return the frequency of the kernel's statistics clock. + */ +static int +getstathz(void) +{ + int mib[2]; + size_t size; + struct clockinfo clockrate; + + mib[0] = CTL_KERN; + mib[1] = KERN_CLOCKRATE; + size = sizeof clockrate; + if (sysctl(mib, 2, &clockrate, &size, NULL, 0) == -1) + err(1, "sysctl kern.clockrate"); + return clockrate.stathz; +} + +#define STAT_MODE_NPMCS 6 +static struct timespec before_ts; +#define CYCLES 0 +#define INST 1 +#define BR 2 +#define IAP_START BR +#define BR_MISS 3 +#define CACHE 4 +#define CACHE_MISS 5 +static const char *pmc_stat_mode_names[] = { + "cycles", + "instructions", + "branches", + "branch-misses", + "cache-references", + "cache-misses", +}; + +static int pmcstat_sockpair[NSOCKPAIRFD]; + +static void +usage(void) +{ + errx(EX_USAGE, + "\t get basic stats from command line program\n" + "\t -j <eventlist>, --events <eventlist> comma-delimited list of event specifiers\n" + ); +} + +static void +showtime(FILE *out, struct timespec *before, struct timespec *after, + struct rusage *ru) +{ + char decimal_point; + uint64_t real, user, sys; + + (void)setlocale(LC_NUMERIC, ""); + decimal_point = localeconv()->decimal_point[0]; + + after->tv_sec -= before->tv_sec; + after->tv_nsec -= before->tv_nsec; + if (after->tv_nsec < 0) + after->tv_sec--, after->tv_nsec += 1000000000; + + real = (after->tv_sec * 1000000000 + after->tv_nsec) / 1000; + user = ru->ru_utime.tv_sec * 1000000 + ru->ru_utime.tv_usec; + sys = ru->ru_stime.tv_sec * 1000000 + ru->ru_stime.tv_usec; + fprintf(out, "%13jd%c%02ld real\t\t\t#\t%2.02f%% cpu\n", + (intmax_t)after->tv_sec, decimal_point, + after->tv_nsec / 10000000, 100 * (double)(sys + user + 1) / (double)(real + 1)); + fprintf(out, "%13jd%c%02ld user\t\t\t#\t%2.2f%% cpu\n", + (intmax_t)ru->ru_utime.tv_sec, decimal_point, + ru->ru_utime.tv_usec / 10000, 100 * (double)(user + 1) / (double)(real + 1)); + fprintf(out, "%13jd%c%02ld sys\t\t\t#\t%2.02f%% cpu\n", + (intmax_t)ru->ru_stime.tv_sec, decimal_point, + ru->ru_stime.tv_usec / 10000, 100 * (double)(sys + 1) / (double)(real + 1)); +} + +static const char *stat_mode_cntrs[STAT_MODE_NPMCS]; +static const char *stat_mode_names[STAT_MODE_NPMCS]; + +static void +pmc_stat_setup_stat(int system_mode, const char *arg) +{ + const char *new_cntrs[STAT_MODE_NPMCS]; + static const char **pmc_stat_mode_cntrs; + struct pmcstat_ev *ev; + char *counters, *counter; + int i, c, start, newcnt; + cpuset_t cpumask, rootmask; + + if (cpuset_getaffinity(CPU_LEVEL_ROOT, CPU_WHICH_PID, -1, + sizeof(rootmask), &rootmask) == -1) + err(EX_OSERR, "ERROR: Cannot determine the root set of CPUs"); + CPU_COPY(&rootmask, &cpumask); + + if (pmc_pmu_stat_mode(&pmc_stat_mode_cntrs) != 0) + errx(EX_USAGE, "ERROR: hwmpc.ko not loaded or stat not supported on host."); + if (system_mode && geteuid() != 0) + errx(EX_USAGE, "ERROR: system mode counters can only be used as root"); + counters = NULL; + for (i = 0; i < STAT_MODE_NPMCS; i++) { + stat_mode_cntrs[i] = pmc_stat_mode_cntrs[i]; + stat_mode_names[i] = pmc_stat_mode_names[i]; + } + if (arg) { + counters = strdup(arg); + newcnt = 0; + while ((counter = strsep(&counters, ",")) != NULL && + newcnt < STAT_MODE_NPMCS - IAP_START) { + new_cntrs[newcnt++] = counter; + if (pmc_pmu_sample_rate_get(counter) == DEFAULT_SAMPLE_COUNT) + errx(EX_USAGE, "ERROR: %s not recognized on host", counter); + } + start = IAP_START + STAT_MODE_NPMCS - newcnt; + for (i = 0; i < newcnt; i++) { + stat_mode_cntrs[start + i] = new_cntrs[i]; + stat_mode_names[start + i] = new_cntrs[i]; + } + } + if (system_mode) + pmc_args.pa_flags |= FLAG_HAS_SYSTEM_PMCS; + else + pmc_args.pa_flags |= FLAG_HAS_PROCESS_PMCS; + pmc_args.pa_flags |= FLAG_HAS_COUNTING_PMCS; + pmc_args.pa_flags |= FLAG_HAS_COMMANDLINE | FLAG_HAS_TARGET; + pmc_args.pa_flags |= FLAG_HAS_PIPE; + pmc_args.pa_required |= FLAG_HAS_COMMANDLINE | FLAG_HAS_TARGET | FLAG_HAS_OUTPUT_LOGFILE; + pmc_args.pa_outputpath = strdup("/dev/null"); + pmc_args.pa_logfd = pmcstat_open_log(pmc_args.pa_outputpath, + PMCSTAT_OPEN_FOR_WRITE); + for (i = 0; i < STAT_MODE_NPMCS; i++) { + if ((ev = malloc(sizeof(*ev))) == NULL) + errx(EX_SOFTWARE, "ERROR: Out of memory."); + if (system_mode) + ev->ev_mode = PMC_MODE_SC; + else + ev->ev_mode = PMC_MODE_TC; + ev->ev_spec = strdup(stat_mode_cntrs[i]); + if (ev->ev_spec == NULL) + errx(EX_SOFTWARE, "ERROR: Out of memory."); + c = strcspn(strdup(stat_mode_cntrs[i]), ", \t"); + ev->ev_name = malloc(c + 1); + if (ev->ev_name == NULL) + errx(EX_SOFTWARE, "ERROR: Out of memory."); + (void)strncpy(ev->ev_name, stat_mode_cntrs[i], c); + *(ev->ev_name + c) = '\0'; + + ev->ev_count = -1; + ev->ev_flags = 0; + ev->ev_flags |= PMC_F_DESCENDANTS; + ev->ev_cumulative = 1; + + ev->ev_saved = 0LL; + ev->ev_pmcid = PMC_ID_INVALID; + STAILQ_INSERT_TAIL(&pmc_args.pa_events, ev, ev_next); + if (system_mode) { + ev->ev_cpu = CPU_FFS(&cpumask) - 1; + CPU_CLR(ev->ev_cpu, &cpumask); + pmcstat_clone_event_descriptor(ev, &cpumask, &pmc_args); + CPU_SET(ev->ev_cpu, &cpumask); + } else + ev->ev_cpu = PMC_CPU_ANY; + + } + if (clock_gettime(CLOCK_MONOTONIC, &before_ts)) + err(1, "clock_gettime"); +} + +static void +pmc_stat_print_stat(struct rusage *ru) +{ + struct pmcstat_ev *ev; + struct timespec after; + uint64_t cvals[STAT_MODE_NPMCS]; + uint64_t ticks, value; + int hz, i; + + hz = getstathz(); + ticks = hz * (ru->ru_utime.tv_sec + ru->ru_stime.tv_sec) + + hz * (ru->ru_utime.tv_usec + ru->ru_stime.tv_usec) / 1000000; + if (clock_gettime(CLOCK_MONOTONIC, &after)) + err(1, "clock_gettime"); + bzero(&cvals, sizeof(cvals)); + STAILQ_FOREACH(ev, &pmc_args.pa_events, ev_next) { + if (pmc_read(ev->ev_pmcid, &value) < 0) + err(EX_OSERR, "ERROR: Cannot read pmc \"%s\"", + ev->ev_name); + for (i = 0; i < STAT_MODE_NPMCS; i++) + if (strcmp(ev->ev_name, stat_mode_cntrs[i]) == 0) + cvals[i] += value; + } + + /* + * If our round-off on the tick calculation still puts us at 0, + * then always assume at least one tick. + */ + if (ticks == 0) + ticks = 1; + fprintf(pmc_args.pa_printfile, "%16ld %s\t\t#\t%02.03f M/sec\n", + ru->ru_minflt, "page faults", ((double)ru->ru_minflt / (double)ticks) / hz); + fprintf(pmc_args.pa_printfile, "%16ld %s\t\t#\t%02.03f M/sec\n", + ru->ru_nvcsw, "voluntary csw", ((double)ru->ru_nvcsw / (double)ticks) / hz); + fprintf(pmc_args.pa_printfile, "%16ld %s\t#\t%02.03f M/sec\n", + ru->ru_nivcsw, "involuntary csw", ((double)ru->ru_nivcsw / (double)ticks) / hz); + + fprintf(pmc_args.pa_printfile, "%16ld %s\n", cvals[CYCLES], stat_mode_names[CYCLES]); + fprintf(pmc_args.pa_printfile, "%16ld %s\t\t#\t%01.03f inst/cycle\n", cvals[INST], stat_mode_names[INST], + (double)cvals[INST] / cvals[CYCLES]); + fprintf(pmc_args.pa_printfile, "%16ld %s\n", cvals[BR], stat_mode_names[BR]); + if (stat_mode_names[BR_MISS] == pmc_stat_mode_names[BR_MISS]) + fprintf(pmc_args.pa_printfile, "%16ld %s\t\t#\t%.03f%%\n", + cvals[BR_MISS], stat_mode_names[BR_MISS], + 100 * ((double)cvals[BR_MISS] / cvals[BR])); + else + fprintf(pmc_args.pa_printfile, "%16ld %s\n", + cvals[BR_MISS], stat_mode_names[BR_MISS]); + fprintf(pmc_args.pa_printfile, "%16ld %s%s", cvals[CACHE], stat_mode_names[CACHE], + stat_mode_names[CACHE] != pmc_stat_mode_names[CACHE] ? "\n" : ""); + if (stat_mode_names[CACHE] == pmc_stat_mode_names[CACHE]) + fprintf(pmc_args.pa_printfile, "\t#\t%.03f refs/inst\n", + ((double)cvals[CACHE] / cvals[INST])); + fprintf(pmc_args.pa_printfile, "%16ld %s%s", cvals[CACHE_MISS], stat_mode_names[CACHE_MISS], + stat_mode_names[CACHE_MISS] != pmc_stat_mode_names[CACHE_MISS] ? "\n" : ""); + if (stat_mode_names[CACHE_MISS] == pmc_stat_mode_names[CACHE_MISS]) + fprintf(pmc_args.pa_printfile, "\t\t#\t%.03f%%\n", + 100 * ((double)cvals[CACHE_MISS] / cvals[CACHE])); + + + showtime(pmc_args.pa_printfile, &before_ts, &after, ru); +} + + +static struct option longopts[] = { + {"events", required_argument, NULL, 'j'}, + {NULL, 0, NULL, 0} +}; + +static int +pmc_stat_internal(int argc, char **argv, int system_mode) +{ + const char *event; + struct sigaction sa; + struct kevent kev; + struct rusage ru; + struct winsize ws; + struct pmcstat_ev *ev; + int c, option, runstate, do_print, do_read; + int waitstatus, ru_valid; + + ru_valid = do_print = do_read = 0; + event = NULL; + while ((option = getopt_long(argc, argv, "j:", longopts, NULL)) != -1) { + switch (option) { + case 'j': + event = strdup(optarg); + break; + case '?': + default: + usage(); + } + } + pmc_args.pa_argc = (argc -= optind); + pmc_args.pa_argv = (argv += optind); + if (argc == 0) + usage(); + pmc_args.pa_flags |= FLAG_HAS_COMMANDLINE; + pmc_stat_setup_stat(system_mode, event); + + EV_SET(&kev, SIGINT, EVFILT_SIGNAL, EV_ADD, 0, 0, NULL); + if (kevent(pmc_kq, &kev, 1, NULL, 0, NULL) < 0) + err(EX_OSERR, "ERROR: Cannot register kevent for SIGINT"); + + EV_SET(&kev, SIGIO, EVFILT_SIGNAL, EV_ADD, 0, 0, NULL); + if (kevent(pmc_kq, &kev, 1, NULL, 0, NULL) < 0) + err(EX_OSERR, "ERROR: Cannot register kevent for SIGIO"); + + STAILQ_FOREACH(ev, &pmc_args.pa_events, ev_next) { + if (pmc_allocate(ev->ev_spec, ev->ev_mode, + ev->ev_flags, ev->ev_cpu, &ev->ev_pmcid) < 0) + err(EX_OSERR, + "ERROR: Cannot allocate %s-mode pmc with specification \"%s\"", + PMC_IS_SYSTEM_MODE(ev->ev_mode) ? + "system" : "process", ev->ev_spec); + + if (PMC_IS_SAMPLING_MODE(ev->ev_mode) && + pmc_set(ev->ev_pmcid, ev->ev_count) < 0) + err(EX_OSERR, + "ERROR: Cannot set sampling count for PMC \"%s\"", + ev->ev_name); + } + + /* + * An exec() failure of a forked child is signalled by the + * child sending the parent a SIGCHLD. We don't register an + * actual signal handler for SIGCHLD, but instead use our + * kqueue to pick up the signal. + */ + EV_SET(&kev, SIGCHLD, EVFILT_SIGNAL, EV_ADD, 0, 0, NULL); + if (kevent(pmc_kq, &kev, 1, NULL, 0, NULL) < 0) + err(EX_OSERR, "ERROR: Cannot register kevent for SIGCHLD"); + + pmcstat_create_process(pmcstat_sockpair, &pmc_args, pmc_kq); + + if (SLIST_EMPTY(&pmc_args.pa_targets)) + errx(EX_DATAERR, + "ERROR: No matching target processes."); + if (pmc_args.pa_flags & FLAG_HAS_PROCESS_PMCS) + pmcstat_attach_pmcs(&pmc_args); + + /* start the pmcs */ + pmc_util_start_pmcs(&pmc_args); + + /* start the (commandline) process if needed */ + pmcstat_start_process(pmcstat_sockpair); + + /* Handle SIGINT using the kqueue loop */ + sa.sa_handler = SIG_IGN; + sa.sa_flags = 0; + (void)sigemptyset(&sa.sa_mask); + + if (sigaction(SIGINT, &sa, NULL) < 0) + err(EX_OSERR, "ERROR: Cannot install signal handler"); + + /* + * loop till either the target process (if any) exits, or we + * are killed by a SIGINT or we reached the time duration. + */ + runstate = PMCSTAT_RUNNING; + do_print = do_read = 0; + do { + if ((c = kevent(pmc_kq, NULL, 0, &kev, 1, NULL)) <= 0) { + if (errno != EINTR) + err(EX_OSERR, "ERROR: kevent failed"); + else + continue; + } + if (kev.flags & EV_ERROR) + errc(EX_OSERR, kev.data, "ERROR: kevent failed"); + + switch (kev.filter) { + case EVFILT_PROC: /* target has exited */ + if (wait4(pmc_util_get_pid(&pmc_args), &waitstatus, 0, &ru) > 0) { + getrusage(RUSAGE_CHILDREN, &ru); + ru_valid = 1; + } + do_print = 1; + break; + + case EVFILT_READ: /* log file data is present */ + do_read = 0; + break; + + case EVFILT_SIGNAL: + if (kev.ident == SIGCHLD) { + /* + * The child process sends us a + * SIGCHLD if its exec() failed. We + * wait for it to exit and then exit + * ourselves. + */ + (void)wait(&c); + runstate = PMCSTAT_FINISHED; + } else if (kev.ident == SIGIO) { + /* + * We get a SIGIO if a PMC loses all + * of its targets, or if logfile + * writes encounter an error. + */ + if (wait4(pmc_util_get_pid(&pmc_args), &waitstatus, 0, &ru) > 0) { + getrusage(RUSAGE_CHILDREN, &ru); + ru_valid = 1; + } + runstate = pmcstat_close_log(&pmc_args); + do_print = 1; /* print PMCs at exit */ + } else if (kev.ident == SIGINT) { + /* Kill the child process if we started it */ + if (pmc_args.pa_flags & FLAG_HAS_COMMANDLINE) + pmc_util_kill_process(&pmc_args); + runstate = pmcstat_close_log(&pmc_args); + } else if (kev.ident == SIGWINCH) { + if (ioctl(fileno(pmc_args.pa_printfile), + TIOCGWINSZ, &ws) < 0) + err(EX_OSERR, + "ERROR: Cannot determine window size"); + pmc_displayheight = ws.ws_row - 1; + pmc_displaywidth = ws.ws_col - 1; + } else + assert(0); + + break; + } + } while (runstate != PMCSTAT_FINISHED); + if (!ru_valid) + warnx("couldn't get rusage"); + pmc_stat_print_stat(&ru); + pmc_util_cleanup(&pmc_args); + return (0); +} + +int +cmd_pmc_stat(int argc, char **argv) +{ + return (pmc_stat_internal(argc, argv, 0)); +} + +int +cmd_pmc_stat_system(int argc, char **argv) +{ + return (pmc_stat_internal(argc, argv, 1)); +} Added: head/usr.sbin/pmc/pmc.c ============================================================================== --- /dev/null 00:00:00 1970 (empty, because file is newly added) +++ head/usr.sbin/pmc/pmc.c Tue May 29 20:28:34 2018 (r334350) @@ -0,0 +1,114 @@ +/*- + * SPDX-License-Identifier: BSD-2-Clause-FreeBSD + * + * Copyright (c) 2018, Matthew Macy + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions + * are met: + * 1. Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * 2. Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * + * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND + * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE + * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE + * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE + * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL + * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS + * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) + * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT + * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY + * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF + * SUCH DAMAGE. + * + * $FreeBSD$ + * + */ + +#include <sys/types.h> +#include <sys/errno.h> +#include <sys/sysctl.h> +#include <stddef.h> +#include <stdlib.h> +#include <err.h> +#include <limits.h> +#include <string.h> +#include <pmc.h> +#include <pmclog.h> +#include <libpmcstat.h> +#include <sysexits.h> +#include <unistd.h> + +#include <libpmcstat.h> +#include "cmd_pmc.h" + +int pmc_displayheight = DEFAULT_DISPLAY_HEIGHT; +int pmc_displaywidth = DEFAULT_DISPLAY_WIDTH; +int pmc_kq; +struct pmcstat_args pmc_args; + +struct pmcstat_pmcs pmcstat_pmcs = LIST_HEAD_INITIALIZER(pmcstat_pmcs); + +struct pmcstat_image_hash_list pmcstat_image_hash[PMCSTAT_NHASH]; + +struct pmcstat_process_hash_list pmcstat_process_hash[PMCSTAT_NHASH]; + +struct cmd_handler { + const char *ch_name; + cmd_disp_t ch_fn; +}; + +static struct cmd_handler disp_table[] = { + {"stat", cmd_pmc_stat}, + {"stat-system", cmd_pmc_stat_system}, + {NULL, NULL} +}; + +static void +usage(void) +{ + errx(EX_USAGE, + "\t pmc management utility\n" + "\t stat <program> run program and print stats\n" + "\t stat-system <program> run program and print system wide stats for duration of execution\n" + ); +} + +static cmd_disp_t +disp_lookup(char *name) +{ + struct cmd_handler *hnd; + + for (hnd = disp_table; hnd->ch_name != NULL; hnd++) + if (strcmp(hnd->ch_name, name) == 0) + return (hnd->ch_fn); + return (NULL); +} + +int +main(int argc, char **argv) +{ + cmd_disp_t disp; + + pmc_args.pa_printfile = stderr; + STAILQ_INIT(&pmc_args.pa_events); + SLIST_INIT(&pmc_args.pa_targets); + if (argc == 1) + usage(); + if ((disp = disp_lookup(argv[1])) == NULL) + usage(); + argc--; + argv++; + + /* Allocate a kqueue */ + if ((pmc_kq = kqueue()) < 0) + err(EX_OSERR, "ERROR: Cannot allocate kqueue"); + if (pmc_init() < 0) + err(EX_UNAVAILABLE, + "ERROR: Initialization of the pmc(3) library failed" + ); + return (disp(argc, argv)); +} Added: head/usr.sbin/pmc/pmc_util.c ============================================================================== --- /dev/null 00:00:00 1970 (empty, because file is newly added) +++ head/usr.sbin/pmc/pmc_util.c Tue May 29 20:28:34 2018 (r334350) @@ -0,0 +1,169 @@ +/*- + * SPDX-License-Identifier: BSD-2-Clause-FreeBSD + * + * Copyright (c) 2003-2008, Joseph Koshy + * Copyright (c) 2007 The FreeBSD Foundation + * All rights reserved. + * Copyright (c) 2018, Matthew Macy + * + * Portions of this software were developed by A. Joseph Koshy under + * sponsorship from the FreeBSD Foundation and Google, Inc. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions + * are met: + * 1. Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * 2. Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * + * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND + * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE + * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE + * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE + * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL + * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS + * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) + * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT + * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY + * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF + * SUCH DAMAGE. + */ + +#include <sys/cdefs.h> +__FBSDID("$FreeBSD$"); + +#include <sys/param.h> +#include <sys/cpuset.h> +#include <sys/event.h> +#include <sys/queue.h> +#include <sys/socket.h> +#include <sys/stat.h> +#include <sys/sysctl.h> +#include <sys/time.h> +#include <sys/ttycom.h> +#include <sys/user.h> +#include <sys/wait.h> + +#include <assert.h> +#include <curses.h> +#include <err.h> +#include <errno.h> +#include <fcntl.h> +#include <getopt.h> +#include <kvm.h> +#include <libgen.h> +#include <limits.h> +#include <locale.h> +#include <math.h> +#include <pmc.h> +#include <pmclog.h> +#include <regex.h> +#include <signal.h> +#include <stdarg.h> +#include <stdint.h> +#include <stdio.h> +#include <stdlib.h> +#include <string.h> +#include <sysexits.h> +#include <unistd.h> + +#include <libpmcstat.h> +#include "cmd_pmc.h" + +static struct pmcstat_stats pmcstat_stats; /* statistics */ + +static struct pmc_plugins plugins[] = { + { + .pl_name = "none", + }, + { + .pl_name = NULL + } +}; + +int +pmc_util_get_pid(struct pmcstat_args *args) +{ + struct pmcstat_target *pt; + + assert(args->pa_flags & FLAG_HAS_COMMANDLINE); + + /* + * If a command line was specified, it would be the very first + * in the list, before any other processes specified by -t. + */ + pt = SLIST_FIRST(&args->pa_targets); + return (pt->pt_pid); +} + +void +pmc_util_kill_process(struct pmcstat_args *args) +{ + struct pmcstat_target *pt; + + assert(args->pa_flags & FLAG_HAS_COMMANDLINE); + + /* + * If a command line was specified, it would be the very first + * in the list, before any other processes specified by -t. + */ + pt = SLIST_FIRST(&args->pa_targets); + assert(pt != NULL); + + if (kill(pt->pt_pid, SIGINT) != 0) + err(EX_OSERR, "ERROR: cannot signal child process"); +} + +void +pmc_util_shutdown_logging(struct pmcstat_args *args) +{ + pmcstat_shutdown_logging(args, plugins, &pmcstat_stats); +} + +void +pmc_util_cleanup(struct pmcstat_args *args) +{ + struct pmcstat_ev *ev; + + /* release allocated PMCs. */ + STAILQ_FOREACH(ev, &args->pa_events, ev_next) + if (ev->ev_pmcid != PMC_ID_INVALID) { + if (pmc_stop(ev->ev_pmcid) < 0) + err(EX_OSERR, + "ERROR: cannot stop pmc 0x%x \"%s\"", + ev->ev_pmcid, ev->ev_name); + if (pmc_release(ev->ev_pmcid) < 0) + err(EX_OSERR, + "ERROR: cannot release pmc 0x%x \"%s\"", + ev->ev_pmcid, ev->ev_name); + } + /* de-configure the log file if present. */ + if (args->pa_flags & (FLAG_HAS_PIPE | FLAG_HAS_OUTPUT_LOGFILE)) + (void)pmc_configure_logfile(-1); + + if (args->pa_logparser) { + pmclog_close(args->pa_logparser); + args->pa_logparser = NULL; + } + pmc_util_shutdown_logging(args); +} + +void +pmc_util_start_pmcs(struct pmcstat_args *args) +{ + struct pmcstat_ev *ev; + + STAILQ_FOREACH(ev, &args->pa_events, ev_next) { + + assert(ev->ev_pmcid != PMC_ID_INVALID); + + if (pmc_start(ev->ev_pmcid) < 0) { + warn("ERROR: Cannot start pmc 0x%x \"%s\"", + ev->ev_pmcid, ev->ev_name); + pmc_util_cleanup(args); + exit(EX_OSERR); + } + } +}
Want to link to this message? Use this URL: <https://mail-archive.FreeBSD.org/cgi/mid.cgi?201805292028.w4TKSYiN044618>