builtin-stat.c 63.8 KB
Newer Older
1
// SPDX-License-Identifier: GPL-2.0-only
2
/*
3 4 5 6 7 8
 * builtin-stat.c
 *
 * Builtin stat command: Give a precise performance counters summary
 * overview about any workload, CPU or specific PID.
 *
 * Sample output:
9

10
   $ perf stat ./hackbench 10
11

12
  Time: 0.118
13

14
  Performance counter stats for './hackbench 10':
15

16 17 18 19 20 21 22 23 24 25 26 27 28
       1708.761321 task-clock                #   11.037 CPUs utilized
            41,190 context-switches          #    0.024 M/sec
             6,735 CPU-migrations            #    0.004 M/sec
            17,318 page-faults               #    0.010 M/sec
     5,205,202,243 cycles                    #    3.046 GHz
     3,856,436,920 stalled-cycles-frontend   #   74.09% frontend cycles idle
     1,600,790,871 stalled-cycles-backend    #   30.75% backend  cycles idle
     2,603,501,247 instructions              #    0.50  insns per cycle
                                             #    1.48  stalled cycles per insn
       484,357,498 branches                  #  283.455 M/sec
         6,388,934 branch-misses             #    1.32% of all branches

        0.154822978  seconds time elapsed
29

30
 *
31
 * Copyright (C) 2008-2011, Red Hat Inc, Ingo Molnar <mingo@redhat.com>
32 33 34 35 36 37 38 39
 *
 * Improvements and fixes by:
 *
 *   Arjan van de Ven <arjan@linux.intel.com>
 *   Yanmin Zhang <yanmin.zhang@intel.com>
 *   Wu Fengguang <fengguang.wu@intel.com>
 *   Mike Galbraith <efault@gmx.de>
 *   Paul Mackerras <paulus@samba.org>
40
 *   Jaswinder Singh Rajput <jaswinder@kernel.org>
41 42
 */

43
#include "builtin.h"
44
#include "perf.h"
45
#include "util/cgroup.h"
46
#include <subcmd/parse-options.h>
47
#include "util/parse-events.h"
48
#include "util/pmu.h"
49
#include "util/event.h"
50
#include "util/evlist.h"
51
#include "util/evsel.h"
52
#include "util/debug.h"
53
#include "util/color.h"
54
#include "util/stat.h"
55
#include "util/header.h"
56
#include "util/cpumap.h"
57
#include "util/thread_map.h"
58
#include "util/counts.h"
59
#include "util/group.h"
J
Jiri Olsa 已提交
60
#include "util/session.h"
J
Jiri Olsa 已提交
61
#include "util/tool.h"
62
#include "util/string2.h"
63
#include "util/metricgroup.h"
64
#include "util/synthetic-events.h"
65
#include "util/target.h"
66
#include "util/time-utils.h"
67
#include "util/top.h"
68
#include "util/affinity.h"
69
#include "util/pfm.h"
J
Jiri Olsa 已提交
70
#include "asm/bug.h"
71

72
#include <linux/time64.h>
73
#include <linux/zalloc.h>
74
#include <api/fs/fs.h>
75
#include <errno.h>
76
#include <signal.h>
77
#include <stdlib.h>
78
#include <sys/prctl.h>
79
#include <inttypes.h>
80
#include <locale.h>
81
#include <math.h>
82 83
#include <sys/types.h>
#include <sys/stat.h>
84
#include <sys/wait.h>
85
#include <unistd.h>
86 87
#include <sys/time.h>
#include <sys/resource.h>
88
#include <linux/err.h>
89

90
#include <linux/ctype.h>
91
#include <perf/evlist.h>
92

S
Stephane Eranian 已提交
93
#define DEFAULT_SEPARATOR	" "
94
#define FREEZE_ON_SMI_PATH	"devices/cpu/freeze_on_smi"
S
Stephane Eranian 已提交
95

96
static void print_counters(struct timespec *ts, int argc, const char **argv);
97

98
/* Default events used for perf stat -T */
99 100
static const char *transaction_attrs = {
	"task-clock,"
101 102 103 104 105 106 107 108 109 110 111
	"{"
	"instructions,"
	"cycles,"
	"cpu/cycles-t/,"
	"cpu/tx-start/,"
	"cpu/el-start/,"
	"cpu/cycles-ct/"
	"}"
};

/* More limited version when the CPU does not have all events. */
112 113
static const char * transaction_limited_attrs = {
	"task-clock,"
114 115 116 117 118 119 120 121
	"{"
	"instructions,"
	"cycles,"
	"cpu/cycles-t/,"
	"cpu/tx-start/"
	"}"
};

122 123 124 125 126 127 128 129 130
static const char * topdown_attrs[] = {
	"topdown-total-slots",
	"topdown-slots-retired",
	"topdown-recovery-bubbles",
	"topdown-fetch-bubbles",
	"topdown-slots-issued",
	NULL,
};

131 132 133 134 135 136 137 138
static const char *smi_cost_attrs = {
	"{"
	"msr/aperf/,"
	"msr/smi/,"
	"cycles"
	"}"
};

139
static struct evlist	*evsel_list;
140

141
static struct target target = {
142 143
	.uid	= UINT_MAX,
};
144

145 146
#define METRIC_ONLY_LEN 20

147
static volatile pid_t		child_pid			= -1;
148
static int			detailed_run			=  0;
149
static bool			transaction_run;
150
static bool			topdown_run			= false;
151 152
static bool			smi_cost			= false;
static bool			smi_reset			= false;
S
Stephane Eranian 已提交
153
static int			big_num_opt			=  -1;
154
static bool			group				= false;
155 156 157
static const char		*pre_cmd			= NULL;
static const char		*post_cmd			= NULL;
static bool			sync_run			= false;
158
static bool			forever				= false;
159
static bool			force_metric_only		= false;
160
static struct timespec		ref_time;
J
Jiri Olsa 已提交
161
static bool			append_file;
162
static bool			interval_count;
J
Jiri Olsa 已提交
163 164
static const char		*output_name;
static int			output_fd;
165

J
Jiri Olsa 已提交
166 167
struct perf_stat {
	bool			 record;
168
	struct perf_data	 data;
J
Jiri Olsa 已提交
169 170
	struct perf_session	*session;
	u64			 bytes_written;
J
Jiri Olsa 已提交
171
	struct perf_tool	 tool;
172
	bool			 maps_allocated;
173
	struct perf_cpu_map	*cpus;
174
	struct perf_thread_map *threads;
175
	enum aggr_mode		 aggr_mode;
J
Jiri Olsa 已提交
176 177 178 179 180
};

static struct perf_stat		perf_stat;
#define STAT_RECORD		perf_stat.record

181 182
static volatile int done = 0;

183
static struct perf_stat_config stat_config = {
184 185 186 187 188 189
	.aggr_mode		= AGGR_GLOBAL,
	.scale			= true,
	.unit_width		= 4, /* strlen("unit") */
	.run_count		= 1,
	.metric_only_len	= METRIC_ONLY_LEN,
	.walltime_nsecs_stats	= &walltime_nsecs_stats,
190
	.big_num		= true,
191 192
	.ctl_fd			= -1,
	.ctl_fd_ack		= -1
193 194
};

195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247
static bool cpus_map_matched(struct evsel *a, struct evsel *b)
{
	if (!a->core.cpus && !b->core.cpus)
		return true;

	if (!a->core.cpus || !b->core.cpus)
		return false;

	if (a->core.cpus->nr != b->core.cpus->nr)
		return false;

	for (int i = 0; i < a->core.cpus->nr; i++) {
		if (a->core.cpus->map[i] != b->core.cpus->map[i])
			return false;
	}

	return true;
}

static void evlist__check_cpu_maps(struct evlist *evlist)
{
	struct evsel *evsel, *pos, *leader;
	char buf[1024];

	evlist__for_each_entry(evlist, evsel) {
		leader = evsel->leader;

		/* Check that leader matches cpus with each member. */
		if (leader == evsel)
			continue;
		if (cpus_map_matched(leader, evsel))
			continue;

		/* If there's mismatch disable the group and warn user. */
		WARN_ONCE(1, "WARNING: grouped events cpus do not match, disabling group:\n");
		evsel__group_desc(leader, buf, sizeof(buf));
		pr_warning("  %s\n", buf);

		if (verbose) {
			cpu_map__snprint(leader->core.cpus, buf, sizeof(buf));
			pr_warning("     %s: %s\n", leader->name, buf);
			cpu_map__snprint(evsel->core.cpus, buf, sizeof(buf));
			pr_warning("     %s: %s\n", evsel->name, buf);
		}

		for_each_group_evsel(pos, leader) {
			pos->leader = pos;
			pos->core.nr_members = 0;
		}
		evsel->leader->core.nr_members = 0;
	}
}

248 249 250 251 252
static inline void diff_timespec(struct timespec *r, struct timespec *a,
				 struct timespec *b)
{
	r->tv_sec = a->tv_sec - b->tv_sec;
	if (a->tv_nsec < b->tv_nsec) {
253
		r->tv_nsec = a->tv_nsec + NSEC_PER_SEC - b->tv_nsec;
254 255 256 257 258 259
		r->tv_sec--;
	} else {
		r->tv_nsec = a->tv_nsec - b->tv_nsec ;
	}
}

260 261
static void perf_stat__reset_stats(void)
{
262 263
	int i;

264
	perf_evlist__reset_stats(evsel_list);
265
	perf_stat__reset_shadow_stats();
266 267 268

	for (i = 0; i < stat_config.stats_num; i++)
		perf_stat__reset_shadow_per_stat(&stat_config.stats[i]);
269 270
}

271 272 273 274
static int process_synthesized_event(struct perf_tool *tool __maybe_unused,
				     union perf_event *event,
				     struct perf_sample *sample __maybe_unused,
				     struct machine *machine __maybe_unused)
J
Jiri Olsa 已提交
275
{
276
	if (perf_data__write(&perf_stat.data, event, event->header.size) < 0) {
J
Jiri Olsa 已提交
277 278 279 280
		pr_err("failed to write perf data, error: %m\n");
		return -1;
	}

281
	perf_stat.bytes_written += event->header.size;
J
Jiri Olsa 已提交
282 283 284
	return 0;
}

285
static int write_stat_round_event(u64 tm, u64 type)
286
{
287
	return perf_event__synthesize_stat_round(NULL, tm, type,
288 289 290 291 292 293 294
						 process_synthesized_event,
						 NULL);
}

#define WRITE_STAT_ROUND_EVENT(time, interval) \
	write_stat_round_event(time, PERF_STAT_ROUND_TYPE__ ## interval)

295
#define SID(e, x, y) xyarray__entry(e->core.sample_id, x, y)
296

297 298
static int evsel__write_stat_event(struct evsel *counter, u32 cpu, u32 thread,
				   struct perf_counts_values *count)
299 300 301 302 303 304 305
{
	struct perf_sample_id *sid = SID(counter, cpu, thread);

	return perf_event__synthesize_stat(NULL, cpu, thread, sid->id, count,
					   process_synthesized_event, NULL);
}

306
static int read_single_counter(struct evsel *counter, int cpu,
307 308 309 310 311 312 313 314 315 316
			       int thread, struct timespec *rs)
{
	if (counter->tool_event == PERF_TOOL_DURATION_TIME) {
		u64 val = rs->tv_nsec + rs->tv_sec*1000000000ULL;
		struct perf_counts_values *count =
			perf_counts(counter->counts, cpu, thread);
		count->ena = count->run = val;
		count->val = val;
		return 0;
	}
317
	return evsel__read_counter(counter, cpu, thread);
318 319
}

320 321 322 323
/*
 * Read out the results of a single counter:
 * do not aggregate counts across CPUs in system-wide mode
 */
A
Andi Kleen 已提交
324
static int read_counter_cpu(struct evsel *counter, struct timespec *rs, int cpu)
325
{
326
	int nthreads = perf_thread_map__nr(evsel_list->core.threads);
A
Andi Kleen 已提交
327
	int thread;
328

329 330 331
	if (!counter->supported)
		return -ENOENT;

332
	if (counter->core.system_wide)
333 334 335
		nthreads = 1;

	for (thread = 0; thread < nthreads; thread++) {
A
Andi Kleen 已提交
336 337 338 339 340 341
		struct perf_counts_values *count;

		count = perf_counts(counter->counts, cpu, thread);

		/*
		 * The leader's group read loads data into its group members
342
		 * (via evsel__read_counter()) and sets their count->loaded.
A
Andi Kleen 已提交
343 344 345 346 347 348 349 350
		 */
		if (!perf_counts__is_loaded(counter->counts, cpu, thread) &&
		    read_single_counter(counter, cpu, thread, rs)) {
			counter->counts->scaled = -1;
			perf_counts(counter->counts, cpu, thread)->ena = 0;
			perf_counts(counter->counts, cpu, thread)->run = 0;
			return -1;
		}
351

A
Andi Kleen 已提交
352
		perf_counts__set_loaded(counter->counts, cpu, thread, false);
353

A
Andi Kleen 已提交
354
		if (STAT_RECORD) {
355
			if (evsel__write_stat_event(counter, cpu, thread, count)) {
A
Andi Kleen 已提交
356 357
				pr_err("failed to write stat event\n");
				return -1;
358
			}
A
Andi Kleen 已提交
359
		}
360

A
Andi Kleen 已提交
361 362 363
		if (verbose > 1) {
			fprintf(stat_config.output,
				"%s: %d: %" PRIu64 " %" PRIu64 " %" PRIu64 "\n",
364
					evsel__name(counter),
A
Andi Kleen 已提交
365 366
					cpu,
					count->val, count->ena, count->run);
367
		}
368
	}
369 370

	return 0;
371 372
}

373
static int read_affinity_counters(struct timespec *rs)
374
{
375
	struct evsel *counter;
A
Andi Kleen 已提交
376 377 378 379
	struct affinity affinity;
	int i, ncpus, cpu;

	if (affinity__setup(&affinity) < 0)
380
		return -1;
A
Andi Kleen 已提交
381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399

	ncpus = perf_cpu_map__nr(evsel_list->core.all_cpus);
	if (!target__has_cpu(&target) || target__has_per_thread(&target))
		ncpus = 1;
	evlist__for_each_cpu(evsel_list, i, cpu) {
		if (i >= ncpus)
			break;
		affinity__set(&affinity, cpu);

		evlist__for_each_entry(evsel_list, counter) {
			if (evsel__cpu_iter_skip(counter, cpu))
				continue;
			if (!counter->err) {
				counter->err = read_counter_cpu(counter, rs,
								counter->cpu_iter - 1);
			}
		}
	}
	affinity__cleanup(&affinity);
400 401 402 403 404 405 406
	return 0;
}

static void read_counters(struct timespec *rs)
{
	struct evsel *counter;

407
	if (!stat_config.stop_read_counter && (read_affinity_counters(rs) < 0))
408
		return;
409

410
	evlist__for_each_entry(evsel_list, counter) {
A
Andi Kleen 已提交
411
		if (counter->err)
412
			pr_debug("failed to read counter %s\n", counter->name);
A
Andi Kleen 已提交
413
		if (counter->err == 0 && perf_stat_process_counter(&stat_config, counter))
414
			pr_warning("failed to process counter %s\n", counter->name);
A
Andi Kleen 已提交
415
		counter->err = 0;
416
	}
417 418
}

419 420 421 422 423 424 425 426 427 428 429 430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449 450 451 452 453 454 455 456 457 458
static int runtime_stat_new(struct perf_stat_config *config, int nthreads)
{
	int i;

	config->stats = calloc(nthreads, sizeof(struct runtime_stat));
	if (!config->stats)
		return -1;

	config->stats_num = nthreads;

	for (i = 0; i < nthreads; i++)
		runtime_stat__init(&config->stats[i]);

	return 0;
}

static void runtime_stat_delete(struct perf_stat_config *config)
{
	int i;

	if (!config->stats)
		return;

	for (i = 0; i < config->stats_num; i++)
		runtime_stat__exit(&config->stats[i]);

	zfree(&config->stats);
}

static void runtime_stat_reset(struct perf_stat_config *config)
{
	int i;

	if (!config->stats)
		return;

	for (i = 0; i < config->stats_num; i++)
		perf_stat__reset_shadow_per_stat(&config->stats[i]);
}

459
static void process_interval(void)
460 461 462
{
	struct timespec ts, rs;

463 464 465
	clock_gettime(CLOCK_MONOTONIC, &ts);
	diff_timespec(&rs, &ts, &ref_time);

466
	perf_stat__reset_shadow_per_stat(&rt_stat);
467
	runtime_stat_reset(&stat_config);
468 469
	read_counters(&rs);

470
	if (STAT_RECORD) {
471
		if (WRITE_STAT_ROUND_EVENT(rs.tv_sec * NSEC_PER_SEC + rs.tv_nsec, INTERVAL))
472 473 474
			pr_err("failed to write stat round event\n");
	}

475
	init_stats(&walltime_nsecs_stats);
476
	update_stats(&walltime_nsecs_stats, stat_config.interval * 1000000ULL);
477
	print_counters(&rs, 0, NULL);
478 479
}

480 481 482 483 484 485 486 487 488 489
static bool handle_interval(unsigned int interval, int *times)
{
	if (interval) {
		process_interval();
		if (interval_count && !(--(*times)))
			return true;
	}
	return false;
}

J
Jiri Olsa 已提交
490
static void enable_counters(void)
491
{
492 493 494 495 496 497 498
	if (stat_config.initial_delay < 0) {
		pr_info(EVLIST_DISABLED_MSG);
		return;
	}

	if (stat_config.initial_delay > 0) {
		pr_info(EVLIST_DISABLED_MSG);
499
		usleep(stat_config.initial_delay * USEC_PER_MSEC);
500
	}
J
Jiri Olsa 已提交
501 502 503 504 505 506

	/*
	 * We need to enable counters only if:
	 * - we don't have tracee (attaching to task or cpu)
	 * - we have initial delay configured
	 */
507
	if (!target__none(&target) || stat_config.initial_delay) {
508
		evlist__enable(evsel_list);
509 510 511
		if (stat_config.initial_delay > 0)
			pr_info(EVLIST_ENABLED_MSG);
	}
512 513
}

514 515 516 517 518 519 520 521
static void disable_counters(void)
{
	/*
	 * If we don't have tracee (attaching to task or cpu), counters may
	 * still be running. To get accurate group ratios, we must stop groups
	 * from counting before reading their constituent counters.
	 */
	if (!target__none(&target))
522
		evlist__disable(evsel_list);
523 524
}

525
static volatile int workload_exec_errno;
526 527 528 529 530 531

/*
 * perf_evlist__prepare_workload will send a SIGUSR1
 * if the fork fails, since we asked by setting its
 * want_signal to true.
 */
532 533
static void workload_exec_failed_signal(int signo __maybe_unused, siginfo_t *info,
					void *ucontext __maybe_unused)
534
{
535
	workload_exec_errno = info->si_value.sival_int;
536 537
}

538
static bool evsel__should_store_id(struct evsel *counter)
539
{
540
	return STAT_RECORD || counter->core.attr.read_format & PERF_FORMAT_ID;
541 542
}

543
static bool is_target_alive(struct target *_target,
544
			    struct perf_thread_map *threads)
545 546 547 548 549 550 551 552 553 554 555 556 557 558 559 560 561 562 563 564
{
	struct stat st;
	int i;

	if (!target__has_task(_target))
		return true;

	for (i = 0; i < threads->nr; i++) {
		char path[PATH_MAX];

		scnprintf(path, PATH_MAX, "%s/%d", procfs__mountpoint(),
			  threads->map[i].pid);

		if (!stat(path, &st))
			return true;
	}

	return false;
}

565 566 567 568 569 570 571 572 573 574 575 576 577 578 579 580 581 582 583 584 585 586 587 588 589 590 591 592 593 594 595 596 597 598 599 600 601 602 603 604 605 606
static void process_evlist(struct evlist *evlist, unsigned int interval)
{
	enum evlist_ctl_cmd cmd = EVLIST_CTL_CMD_UNSUPPORTED;

	if (evlist__ctlfd_process(evlist, &cmd) > 0) {
		switch (cmd) {
		case EVLIST_CTL_CMD_ENABLE:
			pr_info(EVLIST_ENABLED_MSG);
			if (interval)
				process_interval();
			break;
		case EVLIST_CTL_CMD_DISABLE:
			if (interval)
				process_interval();
			pr_info(EVLIST_DISABLED_MSG);
			break;
		case EVLIST_CTL_CMD_ACK:
		case EVLIST_CTL_CMD_UNSUPPORTED:
		default:
			break;
		}
	}
}

static void compute_tts(struct timespec *time_start, struct timespec *time_stop,
			int *time_to_sleep)
{
	int tts = *time_to_sleep;
	struct timespec time_diff;

	diff_timespec(&time_diff, time_stop, time_start);

	tts -= time_diff.tv_sec * MSEC_PER_SEC +
	       time_diff.tv_nsec / NSEC_PER_MSEC;

	if (tts < 0)
		tts = 0;

	*time_to_sleep = tts;
}

static int dispatch_events(bool forks, int timeout, int interval, int *times)
607 608
{
	int child_exited = 0, status = 0;
609 610 611 612 613 614 615 616 617 618 619
	int time_to_sleep, sleep_time;
	struct timespec time_start, time_stop;

	if (interval)
		sleep_time = interval;
	else if (timeout)
		sleep_time = timeout;
	else
		sleep_time = 1000;

	time_to_sleep = sleep_time;
620 621 622 623 624 625 626 627 628 629

	while (!done) {
		if (forks)
			child_exited = waitpid(child_pid, &status, WNOHANG);
		else
			child_exited = !is_target_alive(&target, evsel_list->core.threads) ? 1 : 0;

		if (child_exited)
			break;

630 631 632 633 634 635 636 637 638 639
		clock_gettime(CLOCK_MONOTONIC, &time_start);
		if (!(evlist__poll(evsel_list, time_to_sleep) > 0)) { /* poll timeout or EINTR */
			if (timeout || handle_interval(interval, times))
				break;
			time_to_sleep = sleep_time;
		} else { /* fd revent */
			process_evlist(evsel_list, interval);
			clock_gettime(CLOCK_MONOTONIC, &time_stop);
			compute_tts(&time_start, &time_stop, &time_to_sleep);
		}
640 641 642 643 644
	}

	return status;
}

645 646 647 648 649 650 651 652 653 654 655 656 657 658 659 660 661 662
enum counter_recovery {
	COUNTER_SKIP,
	COUNTER_RETRY,
	COUNTER_FATAL,
};

static enum counter_recovery stat_handle_error(struct evsel *counter)
{
	char msg[BUFSIZ];
	/*
	 * PPC returns ENXIO for HW counters until 2.6.37
	 * (behavior changed with commit b0a873e).
	 */
	if (errno == EINVAL || errno == ENOSYS ||
	    errno == ENOENT || errno == EOPNOTSUPP ||
	    errno == ENXIO) {
		if (verbose > 0)
			ui__warning("%s event is not supported by the kernel.\n",
663
				    evsel__name(counter));
664
		counter->supported = false;
665 666 667 668 669
		/*
		 * errored is a sticky flag that means one of the counter's
		 * cpu event had a problem and needs to be reexamined.
		 */
		counter->errored = true;
670 671 672 673

		if ((counter->leader != counter) ||
		    !(counter->leader->core.nr_members > 1))
			return COUNTER_SKIP;
674
	} else if (evsel__fallback(counter, errno, msg, sizeof(msg))) {
675 676 677 678 679 680 681 682 683 684 685 686 687 688 689 690 691
		if (verbose > 0)
			ui__warning("%s\n", msg);
		return COUNTER_RETRY;
	} else if (target__has_per_thread(&target) &&
		   evsel_list->core.threads &&
		   evsel_list->core.threads->err_thread != -1) {
		/*
		 * For global --per-thread case, skip current
		 * error thread.
		 */
		if (!thread_map__remove(evsel_list->core.threads,
					evsel_list->core.threads->err_thread)) {
			evsel_list->core.threads->err_thread = -1;
			return COUNTER_RETRY;
		}
	}

692
	evsel__open_strerror(counter, &target, errno, msg, sizeof(msg));
693 694 695 696 697 698 699
	ui__error("%s\n", msg);

	if (child_pid != -1)
		kill(child_pid, SIGTERM);
	return COUNTER_FATAL;
}

700
static int __run_perf_stat(int argc, const char **argv, int run_idx)
701
{
702
	int interval = stat_config.interval;
703
	int times = stat_config.times;
704
	int timeout = stat_config.timeout;
705
	char msg[BUFSIZ];
706
	unsigned long long t0, t1;
707
	struct evsel *counter;
708
	size_t l;
709
	int status = 0;
710
	const bool forks = (argc > 0);
711
	bool is_pipe = STAT_RECORD ? perf_stat.data.is_pipe : false;
712 713 714
	struct affinity affinity;
	int i, cpu;
	bool second_pass = false;
715

716
	if (forks) {
717
		if (perf_evlist__prepare_workload(evsel_list, &target, argv, is_pipe,
718
						  workload_exec_failed_signal) < 0) {
719 720
			perror("failed to prepare workload");
			return -1;
721
		}
722
		child_pid = evsel_list->workload.pid;
723 724
	}

725
	if (group)
726
		perf_evlist__set_leader(evsel_list);
727

728 729 730 731 732 733 734 735 736 737 738
	if (affinity__setup(&affinity) < 0)
		return -1;

	evlist__for_each_cpu (evsel_list, i, cpu) {
		affinity__set(&affinity, cpu);

		evlist__for_each_entry(evsel_list, counter) {
			if (evsel__cpu_iter_skip(counter, cpu))
				continue;
			if (counter->reset_group || counter->errored)
				continue;
739
try_again:
740 741 742 743 744 745 746 747 748 749 750 751 752 753 754 755 756 757 758 759 760 761 762 763 764 765 766 767 768 769
			if (create_perf_stat_counter(counter, &stat_config, &target,
						     counter->cpu_iter - 1) < 0) {

				/*
				 * Weak group failed. We cannot just undo this here
				 * because earlier CPUs might be in group mode, and the kernel
				 * doesn't support mixing group and non group reads. Defer
				 * it to later.
				 * Don't close here because we're in the wrong affinity.
				 */
				if ((errno == EINVAL || errno == EBADF) &&
				    counter->leader != counter &&
				    counter->weak_group) {
					perf_evlist__reset_weak_group(evsel_list, counter, false);
					assert(counter->reset_group);
					second_pass = true;
					continue;
				}

				switch (stat_handle_error(counter)) {
				case COUNTER_FATAL:
					return -1;
				case COUNTER_RETRY:
					goto try_again;
				case COUNTER_SKIP:
					continue;
				default:
					break;
				}

770
			}
771 772 773
			counter->supported = true;
		}
	}
774

775 776 777 778 779 780 781 782 783 784 785 786 787 788 789
	if (second_pass) {
		/*
		 * Now redo all the weak group after closing them,
		 * and also close errored counters.
		 */

		evlist__for_each_cpu(evsel_list, i, cpu) {
			affinity__set(&affinity, cpu);
			/* First close errored or weak retry */
			evlist__for_each_entry(evsel_list, counter) {
				if (!counter->reset_group && !counter->errored)
					continue;
				if (evsel__cpu_iter_skip_no_inc(counter, cpu))
					continue;
				perf_evsel__close_cpu(&counter->core, counter->cpu_iter);
790
			}
791 792 793 794 795 796 797 798 799
			/* Now reopen weak */
			evlist__for_each_entry(evsel_list, counter) {
				if (!counter->reset_group && !counter->errored)
					continue;
				if (evsel__cpu_iter_skip(counter, cpu))
					continue;
				if (!counter->reset_group)
					continue;
try_again_reset:
800
				pr_debug2("reopening weak %s\n", evsel__name(counter));
801 802 803 804 805 806 807 808 809 810 811 812 813 814 815 816 817 818 819 820 821 822 823 824
				if (create_perf_stat_counter(counter, &stat_config, &target,
							     counter->cpu_iter - 1) < 0) {

					switch (stat_handle_error(counter)) {
					case COUNTER_FATAL:
						return -1;
					case COUNTER_RETRY:
						goto try_again_reset;
					case COUNTER_SKIP:
						continue;
					default:
						break;
					}
				}
				counter->supported = true;
			}
		}
	}
	affinity__cleanup(&affinity);

	evlist__for_each_entry(evsel_list, counter) {
		if (!counter->supported) {
			perf_evsel__free_fd(&counter->core);
			continue;
825
		}
826 827

		l = strlen(counter->unit);
828 829
		if (l > stat_config.unit_width)
			stat_config.unit_width = l;
830

831
		if (evsel__should_store_id(counter) &&
832
		    evsel__store_ids(counter, evsel_list))
833
			return -1;
834
	}
835

836
	if (perf_evlist__apply_filters(evsel_list, &counter)) {
837
		pr_err("failed to set filter \"%s\" on event %s with %d (%s)\n",
838
			counter->filter, evsel__name(counter), errno,
839
			str_error_r(errno, msg, sizeof(msg)));
840 841 842
		return -1;
	}

J
Jiri Olsa 已提交
843
	if (STAT_RECORD) {
844
		int err, fd = perf_data__fd(&perf_stat.data);
J
Jiri Olsa 已提交
845

846
		if (is_pipe) {
847
			err = perf_header__write_pipe(perf_data__fd(&perf_stat.data));
848 849 850 851 852
		} else {
			err = perf_session__write_header(perf_stat.session, evsel_list,
							 fd, false);
		}

J
Jiri Olsa 已提交
853 854
		if (err < 0)
			return err;
855

856 857
		err = perf_event__synthesize_stat_events(&stat_config, NULL, evsel_list,
							 process_synthesized_event, is_pipe);
858 859
		if (err < 0)
			return err;
J
Jiri Olsa 已提交
860 861
	}

862 863 864 865
	/*
	 * Enable counters and exec the command:
	 */
	t0 = rdclock();
866
	clock_gettime(CLOCK_MONOTONIC, &ref_time);
867

868
	if (forks) {
869
		perf_evlist__start_workload(evsel_list);
J
Jiri Olsa 已提交
870
		enable_counters();
871

872
		if (interval || timeout || evlist__ctlfd_initialized(evsel_list))
873
			status = dispatch_events(forks, timeout, interval, &times);
874 875 876
		if (child_pid != -1) {
			if (timeout)
				kill(child_pid, SIGTERM);
877
			wait4(child_pid, &status, 0, &stat_config.ru_data);
878
		}
879

880
		if (workload_exec_errno) {
881
			const char *emsg = str_error_r(workload_exec_errno, msg, sizeof(msg));
882
			pr_err("Workload failed: %s\n", emsg);
883
			return -1;
884
		}
885

886 887
		if (WIFSIGNALED(status))
			psignal(WTERMSIG(status), argv[0]);
888
	} else {
J
Jiri Olsa 已提交
889
		enable_counters();
890
		status = dispatch_events(forks, timeout, interval, &times);
891
	}
892

893 894
	disable_counters();

895 896
	t1 = rdclock();

897 898
	if (stat_config.walltime_run_table)
		stat_config.walltime_run[run_idx] = t1 - t0;
899

900
	if (interval && stat_config.summary) {
901
		stat_config.interval = 0;
902
		stat_config.stop_read_counter = true;
903 904 905 906 907 908 909 910 911 912 913 914
		init_stats(&walltime_nsecs_stats);
		update_stats(&walltime_nsecs_stats, t1 - t0);

		if (stat_config.aggr_mode == AGGR_GLOBAL)
			perf_evlist__save_aggr_prev_raw_counts(evsel_list);

		perf_evlist__copy_prev_raw_counts(evsel_list);
		perf_evlist__reset_prev_raw_counts(evsel_list);
		runtime_stat_reset(&stat_config);
		perf_stat__reset_shadow_per_stat(&rt_stat);
	} else
		update_stats(&walltime_nsecs_stats, t1 - t0);
915

916 917 918 919 920 921
	/*
	 * Closing a group leader splits the group, and as we only disable
	 * group leaders, results in remaining events becoming enabled. To
	 * avoid arbitrary skew, we must read all counters before closing any
	 * group leaders.
	 */
922
	read_counters(&(struct timespec) { .tv_nsec = t1-t0 });
923 924 925 926 927 928

	/*
	 * We need to keep evsel_list alive, because it's processed
	 * later the evsel_list will be closed after.
	 */
	if (!STAT_RECORD)
929
		evlist__close(evsel_list);
930

931 932 933
	return WEXITSTATUS(status);
}

934
static int run_perf_stat(int argc, const char **argv, int run_idx)
935 936 937 938 939 940 941 942 943 944 945 946
{
	int ret;

	if (pre_cmd) {
		ret = system(pre_cmd);
		if (ret)
			return ret;
	}

	if (sync_run)
		sync();

947
	ret = __run_perf_stat(argc, argv, run_idx);
948 949 950 951 952 953 954 955 956 957 958 959
	if (ret)
		return ret;

	if (post_cmd) {
		ret = system(post_cmd);
		if (ret)
			return ret;
	}

	return ret;
}

960 961
static void print_counters(struct timespec *ts, int argc, const char **argv)
{
962 963 964 965
	/* Do not print anything if we record to the pipe. */
	if (STAT_RECORD && perf_stat.data.is_pipe)
		return;

966
	perf_evlist__print_counters(evsel_list, &stat_config, &target,
967
				    ts, argc, argv);
968 969
}

970 971
static volatile int signr = -1;

972
static void skip_signal(int signo)
973
{
974
	if ((child_pid == -1) || stat_config.interval)
975 976
		done = 1;

977
	signr = signo;
978 979 980 981 982 983 984
	/*
	 * render child_pid harmless
	 * won't send SIGTERM to a random
	 * process in case of race condition
	 * and fast PID recycling
	 */
	child_pid = -1;
985 986 987 988
}

static void sig_atexit(void)
{
989 990 991 992 993 994 995 996 997 998 999 1000
	sigset_t set, oset;

	/*
	 * avoid race condition with SIGCHLD handler
	 * in skip_signal() which is modifying child_pid
	 * goal is to avoid send SIGTERM to a random
	 * process
	 */
	sigemptyset(&set);
	sigaddset(&set, SIGCHLD);
	sigprocmask(SIG_BLOCK, &set, &oset);

1001 1002 1003
	if (child_pid != -1)
		kill(child_pid, SIGTERM);

1004 1005
	sigprocmask(SIG_SETMASK, &oset, NULL);

1006 1007 1008 1009 1010
	if (signr == -1)
		return;

	signal(signr, SIG_DFL);
	kill(getpid(), signr);
1011 1012
}

1013 1014 1015 1016 1017
void perf_stat__set_big_num(int set)
{
	stat_config.big_num = (set != 0);
}

1018 1019
static int stat__set_big_num(const struct option *opt __maybe_unused,
			     const char *s __maybe_unused, int unset)
S
Stephane Eranian 已提交
1020 1021
{
	big_num_opt = unset ? 0 : 1;
1022
	perf_stat__set_big_num(!unset);
S
Stephane Eranian 已提交
1023 1024 1025
	return 0;
}

1026 1027 1028 1029
static int enable_metric_only(const struct option *opt __maybe_unused,
			      const char *s __maybe_unused, int unset)
{
	force_metric_only = true;
1030
	stat_config.metric_only = !unset;
1031 1032 1033
	return 0;
}

1034 1035 1036 1037
static int parse_metric_groups(const struct option *opt,
			       const char *str,
			       int unset __maybe_unused)
{
1038 1039 1040 1041
	return metricgroup__parse_groups(opt, str,
					 stat_config.metric_no_group,
					 stat_config.metric_no_merge,
					 &stat_config.metric_events);
1042 1043
}

1044 1045 1046 1047 1048 1049 1050 1051 1052 1053 1054 1055 1056 1057 1058 1059 1060 1061 1062 1063 1064 1065 1066 1067 1068 1069 1070
static int parse_control_option(const struct option *opt,
				const char *str,
				int unset __maybe_unused)
{
	char *comma = NULL, *endptr = NULL;
	struct perf_stat_config *config = (struct perf_stat_config *)opt->value;

	if (strncmp(str, "fd:", 3))
		return -EINVAL;

	config->ctl_fd = strtoul(&str[3], &endptr, 0);
	if (endptr == &str[3])
		return -EINVAL;

	comma = strchr(str, ',');
	if (comma) {
		if (endptr != comma)
			return -EINVAL;

		config->ctl_fd_ack = strtoul(comma + 1, &endptr, 0);
		if (endptr == comma + 1 || *endptr != '\0')
			return -EINVAL;
	}

	return 0;
}

1071
static struct option stat_options[] = {
J
Jiri Olsa 已提交
1072 1073 1074 1075 1076 1077 1078
	OPT_BOOLEAN('T', "transaction", &transaction_run,
		    "hardware transaction statistics"),
	OPT_CALLBACK('e', "event", &evsel_list, "event",
		     "event selector. use 'perf list' to list available events",
		     parse_events_option),
	OPT_CALLBACK(0, "filter", &evsel_list, "filter",
		     "event filter", parse_filter),
1079
	OPT_BOOLEAN('i', "no-inherit", &stat_config.no_inherit,
J
Jiri Olsa 已提交
1080 1081 1082 1083 1084 1085 1086 1087 1088
		    "child tasks do not inherit counters"),
	OPT_STRING('p', "pid", &target.pid, "pid",
		   "stat events on existing process id"),
	OPT_STRING('t', "tid", &target.tid, "tid",
		   "stat events on existing thread id"),
	OPT_BOOLEAN('a', "all-cpus", &target.system_wide,
		    "system-wide collection from all CPUs"),
	OPT_BOOLEAN('g', "group", &group,
		    "put the counters into a counter group"),
A
Andi Kleen 已提交
1089 1090
	OPT_BOOLEAN(0, "scale", &stat_config.scale,
		    "Use --no-scale to disable counter scaling for multiplexing"),
J
Jiri Olsa 已提交
1091 1092
	OPT_INCR('v', "verbose", &verbose,
		    "be more verbose (show counter open errors, etc)"),
1093
	OPT_INTEGER('r', "repeat", &stat_config.run_count,
J
Jiri Olsa 已提交
1094
		    "repeat command and print average + stddev (max: 100, forever: 0)"),
1095
	OPT_BOOLEAN(0, "table", &stat_config.walltime_run_table,
1096
		    "display details about each run (only with -r option)"),
1097
	OPT_BOOLEAN('n', "null", &stat_config.null_run,
J
Jiri Olsa 已提交
1098 1099 1100 1101 1102 1103 1104 1105 1106 1107 1108 1109
		    "null run - dont start any counters"),
	OPT_INCR('d', "detailed", &detailed_run,
		    "detailed run - start a lot of events"),
	OPT_BOOLEAN('S', "sync", &sync_run,
		    "call sync() before starting a run"),
	OPT_CALLBACK_NOOPT('B', "big-num", NULL, NULL,
			   "print large numbers with thousands\' separators",
			   stat__set_big_num),
	OPT_STRING('C', "cpu", &target.cpu_list, "cpu",
		    "list of cpus to monitor in system-wide"),
	OPT_SET_UINT('A', "no-aggr", &stat_config.aggr_mode,
		    "disable CPU count aggregation", AGGR_NONE),
1110
	OPT_BOOLEAN(0, "no-merge", &stat_config.no_merge, "Do not merge identical named events"),
1111
	OPT_STRING('x', "field-separator", &stat_config.csv_sep, "separator",
J
Jiri Olsa 已提交
1112 1113 1114 1115 1116 1117 1118 1119 1120 1121 1122 1123
		   "print counts with custom separator"),
	OPT_CALLBACK('G', "cgroup", &evsel_list, "name",
		     "monitor event in cgroup name only", parse_cgroups),
	OPT_STRING('o', "output", &output_name, "file", "output file name"),
	OPT_BOOLEAN(0, "append", &append_file, "append to the output file"),
	OPT_INTEGER(0, "log-fd", &output_fd,
		    "log output to fd, instead of stderr"),
	OPT_STRING(0, "pre", &pre_cmd, "command",
			"command to run prior to the measured command"),
	OPT_STRING(0, "post", &post_cmd, "command",
			"command to run after to the measured command"),
	OPT_UINTEGER('I', "interval-print", &stat_config.interval,
1124 1125
		    "print counts at regular interval in ms "
		    "(overhead is possible for values <= 100ms)"),
1126 1127
	OPT_INTEGER(0, "interval-count", &stat_config.times,
		    "print counts for fixed number of times"),
1128
	OPT_BOOLEAN(0, "interval-clear", &stat_config.interval_clear,
1129
		    "clear screen in between new interval"),
1130 1131
	OPT_UINTEGER(0, "timeout", &stat_config.timeout,
		    "stop workload and print counts after a timeout period in ms (>= 10ms)"),
J
Jiri Olsa 已提交
1132 1133
	OPT_SET_UINT(0, "per-socket", &stat_config.aggr_mode,
		     "aggregate counts per processor socket", AGGR_SOCKET),
1134 1135
	OPT_SET_UINT(0, "per-die", &stat_config.aggr_mode,
		     "aggregate counts per processor die", AGGR_DIE),
J
Jiri Olsa 已提交
1136 1137 1138 1139
	OPT_SET_UINT(0, "per-core", &stat_config.aggr_mode,
		     "aggregate counts per physical processor core", AGGR_CORE),
	OPT_SET_UINT(0, "per-thread", &stat_config.aggr_mode,
		     "aggregate counts per thread", AGGR_THREAD),
1140 1141
	OPT_SET_UINT(0, "per-node", &stat_config.aggr_mode,
		     "aggregate counts per numa node", AGGR_NODE),
1142 1143
	OPT_INTEGER('D', "delay", &stat_config.initial_delay,
		    "ms to wait before starting measurement after program start (-1: start with events disabled)"),
1144
	OPT_CALLBACK_NOOPT(0, "metric-only", &stat_config.metric_only, NULL,
1145
			"Only print computed metrics. No raw values", enable_metric_only),
1146 1147 1148 1149
	OPT_BOOLEAN(0, "metric-no-group", &stat_config.metric_no_group,
		       "don't group metric events, impacts multiplexing"),
	OPT_BOOLEAN(0, "metric-no-merge", &stat_config.metric_no_merge,
		       "don't try to share events between metrics in a group"),
1150 1151
	OPT_BOOLEAN(0, "topdown", &topdown_run,
			"measure topdown level 1 statistics"),
1152 1153
	OPT_BOOLEAN(0, "smi-cost", &smi_cost,
			"measure SMI cost"),
1154 1155 1156
	OPT_CALLBACK('M', "metrics", &evsel_list, "metric/metric group list",
		     "monitor specified metrics or metric groups (separated by ,)",
		     parse_metric_groups),
1157 1158 1159 1160 1161 1162
	OPT_BOOLEAN_FLAG(0, "all-kernel", &stat_config.all_kernel,
			 "Configure all used events to run in kernel space.",
			 PARSE_OPT_EXCLUSIVE),
	OPT_BOOLEAN_FLAG(0, "all-user", &stat_config.all_user,
			 "Configure all used events to run in user space.",
			 PARSE_OPT_EXCLUSIVE),
1163 1164 1165 1166
	OPT_BOOLEAN(0, "percore-show-thread", &stat_config.percore_show_thread,
		    "Use with 'percore' event qualifier to show the event "
		    "counts of one hardware thread by sum up total hardware "
		    "threads of same physical core"),
1167 1168
	OPT_BOOLEAN(0, "summary", &stat_config.summary,
		       "print summary for interval mode"),
1169 1170 1171 1172 1173
#ifdef HAVE_LIBPFM
	OPT_CALLBACK(0, "pfm-events", &evsel_list, "event",
		"libpfm4 event selector. use 'perf list' to list available events",
		parse_libpfm_events_option),
#endif
1174 1175 1176 1177
	OPT_CALLBACK(0, "control", &stat_config, "fd:ctl-fd[,ack-fd]",
		     "Listen on ctl-fd descriptor for command to control measurement ('enable': enable events, 'disable': disable events).\n"
		     "\t\t\t  Optionally send control command completion ('ack\\n') to ack-fd descriptor.",
		      parse_control_option),
J
Jiri Olsa 已提交
1178 1179 1180
	OPT_END()
};

1181
static int perf_stat__get_socket(struct perf_stat_config *config __maybe_unused,
1182
				 struct perf_cpu_map *map, int cpu)
1183 1184 1185 1186
{
	return cpu_map__get_socket(map, cpu, NULL);
}

1187
static int perf_stat__get_die(struct perf_stat_config *config __maybe_unused,
1188
			      struct perf_cpu_map *map, int cpu)
1189 1190 1191 1192
{
	return cpu_map__get_die(map, cpu, NULL);
}

1193
static int perf_stat__get_core(struct perf_stat_config *config __maybe_unused,
1194
			       struct perf_cpu_map *map, int cpu)
1195 1196 1197 1198
{
	return cpu_map__get_core(map, cpu, NULL);
}

1199 1200 1201 1202 1203 1204
static int perf_stat__get_node(struct perf_stat_config *config __maybe_unused,
			       struct perf_cpu_map *map, int cpu)
{
	return cpu_map__get_node(map, cpu, NULL);
}

1205
static int perf_stat__get_aggr(struct perf_stat_config *config,
1206
			       aggr_get_id_t get_id, struct perf_cpu_map *map, int idx)
1207 1208 1209 1210 1211 1212 1213 1214
{
	int cpu;

	if (idx >= map->nr)
		return -1;

	cpu = map->map[idx];

1215 1216
	if (config->cpus_aggr_map->map[cpu] == -1)
		config->cpus_aggr_map->map[cpu] = get_id(config, map, idx);
1217

1218
	return config->cpus_aggr_map->map[cpu];
1219 1220
}

1221
static int perf_stat__get_socket_cached(struct perf_stat_config *config,
1222
					struct perf_cpu_map *map, int idx)
1223
{
1224
	return perf_stat__get_aggr(config, perf_stat__get_socket, map, idx);
1225 1226
}

1227
static int perf_stat__get_die_cached(struct perf_stat_config *config,
1228
					struct perf_cpu_map *map, int idx)
1229 1230 1231 1232
{
	return perf_stat__get_aggr(config, perf_stat__get_die, map, idx);
}

1233
static int perf_stat__get_core_cached(struct perf_stat_config *config,
1234
				      struct perf_cpu_map *map, int idx)
1235
{
1236
	return perf_stat__get_aggr(config, perf_stat__get_core, map, idx);
1237 1238
}

1239 1240 1241 1242 1243 1244
static int perf_stat__get_node_cached(struct perf_stat_config *config,
				      struct perf_cpu_map *map, int idx)
{
	return perf_stat__get_aggr(config, perf_stat__get_node, map, idx);
}

1245 1246
static bool term_percore_set(void)
{
1247
	struct evsel *counter;
1248 1249 1250 1251 1252 1253 1254 1255 1256

	evlist__for_each_entry(evsel_list, counter) {
		if (counter->percore)
			return true;
	}

	return false;
}

1257 1258
static int perf_stat_init_aggr_mode(void)
{
1259 1260
	int nr;

1261
	switch (stat_config.aggr_mode) {
1262
	case AGGR_SOCKET:
1263
		if (cpu_map__build_socket_map(evsel_list->core.cpus, &stat_config.aggr_map)) {
1264 1265 1266
			perror("cannot build socket map");
			return -1;
		}
1267
		stat_config.aggr_get_id = perf_stat__get_socket_cached;
1268
		break;
1269
	case AGGR_DIE:
1270
		if (cpu_map__build_die_map(evsel_list->core.cpus, &stat_config.aggr_map)) {
1271 1272 1273 1274 1275
			perror("cannot build die map");
			return -1;
		}
		stat_config.aggr_get_id = perf_stat__get_die_cached;
		break;
1276
	case AGGR_CORE:
1277
		if (cpu_map__build_core_map(evsel_list->core.cpus, &stat_config.aggr_map)) {
1278 1279 1280
			perror("cannot build core map");
			return -1;
		}
1281
		stat_config.aggr_get_id = perf_stat__get_core_cached;
1282
		break;
1283 1284 1285 1286 1287 1288 1289
	case AGGR_NODE:
		if (cpu_map__build_node_map(evsel_list->core.cpus, &stat_config.aggr_map)) {
			perror("cannot build core map");
			return -1;
		}
		stat_config.aggr_get_id = perf_stat__get_node_cached;
		break;
1290
	case AGGR_NONE:
1291
		if (term_percore_set()) {
1292
			if (cpu_map__build_core_map(evsel_list->core.cpus,
1293 1294 1295 1296 1297 1298 1299
						    &stat_config.aggr_map)) {
				perror("cannot build core map");
				return -1;
			}
			stat_config.aggr_get_id = perf_stat__get_core_cached;
		}
		break;
1300
	case AGGR_GLOBAL:
1301
	case AGGR_THREAD:
J
Jiri Olsa 已提交
1302
	case AGGR_UNSET:
1303 1304 1305
	default:
		break;
	}
1306 1307 1308 1309 1310 1311

	/*
	 * The evsel_list->cpus is the base we operate on,
	 * taking the highest cpu number to be the size of
	 * the aggregation translate cpumap.
	 */
1312
	nr = perf_cpu_map__max(evsel_list->core.cpus);
1313
	stat_config.cpus_aggr_map = perf_cpu_map__empty_new(nr + 1);
1314
	return stat_config.cpus_aggr_map ? 0 : -ENOMEM;
1315 1316
}

1317 1318
static void perf_stat__exit_aggr_mode(void)
{
1319 1320
	perf_cpu_map__put(stat_config.aggr_map);
	perf_cpu_map__put(stat_config.cpus_aggr_map);
1321 1322
	stat_config.aggr_map = NULL;
	stat_config.cpus_aggr_map = NULL;
1323 1324
}

1325
static inline int perf_env__get_cpu(struct perf_env *env, struct perf_cpu_map *map, int idx)
1326 1327 1328 1329 1330 1331 1332 1333
{
	int cpu;

	if (idx > map->nr)
		return -1;

	cpu = map->map[idx];

1334
	if (cpu >= env->nr_cpus_avail)
1335 1336 1337 1338 1339
		return -1;

	return cpu;
}

1340
static int perf_env__get_socket(struct perf_cpu_map *map, int idx, void *data)
1341 1342 1343 1344 1345 1346 1347
{
	struct perf_env *env = data;
	int cpu = perf_env__get_cpu(env, map, idx);

	return cpu == -1 ? -1 : env->cpu[cpu].socket_id;
}

1348
static int perf_env__get_die(struct perf_cpu_map *map, int idx, void *data)
1349 1350 1351 1352 1353 1354 1355 1356 1357 1358 1359 1360 1361 1362 1363 1364 1365 1366 1367 1368 1369 1370 1371
{
	struct perf_env *env = data;
	int die_id = -1, cpu = perf_env__get_cpu(env, map, idx);

	if (cpu != -1) {
		/*
		 * Encode socket in bit range 15:8
		 * die_id is relative to socket,
		 * we need a global id. So we combine
		 * socket + die id
		 */
		if (WARN_ONCE(env->cpu[cpu].socket_id >> 8, "The socket id number is too big.\n"))
			return -1;

		if (WARN_ONCE(env->cpu[cpu].die_id >> 8, "The die id number is too big.\n"))
			return -1;

		die_id = (env->cpu[cpu].socket_id << 8) | (env->cpu[cpu].die_id & 0xff);
	}

	return die_id;
}

1372
static int perf_env__get_core(struct perf_cpu_map *map, int idx, void *data)
1373 1374 1375 1376 1377 1378
{
	struct perf_env *env = data;
	int core = -1, cpu = perf_env__get_cpu(env, map, idx);

	if (cpu != -1) {
		/*
1379 1380 1381
		 * Encode socket in bit range 31:24
		 * encode die id in bit range 23:16
		 * core_id is relative to socket and die,
1382
		 * we need a global id. So we combine
1383
		 * socket + die id + core id
1384
		 */
1385 1386 1387 1388 1389 1390 1391 1392 1393 1394 1395 1396
		if (WARN_ONCE(env->cpu[cpu].socket_id >> 8, "The socket id number is too big.\n"))
			return -1;

		if (WARN_ONCE(env->cpu[cpu].die_id >> 8, "The die id number is too big.\n"))
			return -1;

		if (WARN_ONCE(env->cpu[cpu].core_id >> 16, "The core id number is too big.\n"))
			return -1;

		core = (env->cpu[cpu].socket_id << 24) |
		       (env->cpu[cpu].die_id << 16) |
		       (env->cpu[cpu].core_id & 0xffff);
1397 1398 1399 1400 1401
	}

	return core;
}

1402 1403 1404 1405 1406 1407 1408
static int perf_env__get_node(struct perf_cpu_map *map, int idx, void *data)
{
	int cpu = perf_env__get_cpu(data, map, idx);

	return perf_env__numa_node(data, cpu);
}

1409 1410
static int perf_env__build_socket_map(struct perf_env *env, struct perf_cpu_map *cpus,
				      struct perf_cpu_map **sockp)
1411 1412 1413 1414
{
	return cpu_map__build_map(cpus, sockp, perf_env__get_socket, env);
}

1415 1416
static int perf_env__build_die_map(struct perf_env *env, struct perf_cpu_map *cpus,
				   struct perf_cpu_map **diep)
1417 1418 1419 1420
{
	return cpu_map__build_map(cpus, diep, perf_env__get_die, env);
}

1421 1422
static int perf_env__build_core_map(struct perf_env *env, struct perf_cpu_map *cpus,
				    struct perf_cpu_map **corep)
1423 1424 1425 1426
{
	return cpu_map__build_map(cpus, corep, perf_env__get_core, env);
}

1427 1428 1429 1430 1431 1432
static int perf_env__build_node_map(struct perf_env *env, struct perf_cpu_map *cpus,
				    struct perf_cpu_map **nodep)
{
	return cpu_map__build_map(cpus, nodep, perf_env__get_node, env);
}

1433
static int perf_stat__get_socket_file(struct perf_stat_config *config __maybe_unused,
1434
				      struct perf_cpu_map *map, int idx)
1435 1436 1437
{
	return perf_env__get_socket(map, idx, &perf_stat.session->header.env);
}
1438
static int perf_stat__get_die_file(struct perf_stat_config *config __maybe_unused,
1439
				   struct perf_cpu_map *map, int idx)
1440 1441 1442
{
	return perf_env__get_die(map, idx, &perf_stat.session->header.env);
}
1443

1444
static int perf_stat__get_core_file(struct perf_stat_config *config __maybe_unused,
1445
				    struct perf_cpu_map *map, int idx)
1446 1447 1448 1449
{
	return perf_env__get_core(map, idx, &perf_stat.session->header.env);
}

1450 1451 1452 1453 1454 1455
static int perf_stat__get_node_file(struct perf_stat_config *config __maybe_unused,
				    struct perf_cpu_map *map, int idx)
{
	return perf_env__get_node(map, idx, &perf_stat.session->header.env);
}

1456 1457 1458 1459 1460 1461
static int perf_stat_init_aggr_mode_file(struct perf_stat *st)
{
	struct perf_env *env = &st->session->header.env;

	switch (stat_config.aggr_mode) {
	case AGGR_SOCKET:
1462
		if (perf_env__build_socket_map(env, evsel_list->core.cpus, &stat_config.aggr_map)) {
1463 1464 1465
			perror("cannot build socket map");
			return -1;
		}
1466
		stat_config.aggr_get_id = perf_stat__get_socket_file;
1467
		break;
1468
	case AGGR_DIE:
1469
		if (perf_env__build_die_map(env, evsel_list->core.cpus, &stat_config.aggr_map)) {
1470 1471 1472 1473 1474
			perror("cannot build die map");
			return -1;
		}
		stat_config.aggr_get_id = perf_stat__get_die_file;
		break;
1475
	case AGGR_CORE:
1476
		if (perf_env__build_core_map(env, evsel_list->core.cpus, &stat_config.aggr_map)) {
1477 1478 1479
			perror("cannot build core map");
			return -1;
		}
1480
		stat_config.aggr_get_id = perf_stat__get_core_file;
1481
		break;
1482 1483 1484 1485 1486 1487 1488
	case AGGR_NODE:
		if (perf_env__build_node_map(env, evsel_list->core.cpus, &stat_config.aggr_map)) {
			perror("cannot build core map");
			return -1;
		}
		stat_config.aggr_get_id = perf_stat__get_node_file;
		break;
1489 1490 1491 1492 1493 1494 1495 1496 1497 1498 1499
	case AGGR_NONE:
	case AGGR_GLOBAL:
	case AGGR_THREAD:
	case AGGR_UNSET:
	default:
		break;
	}

	return 0;
}

1500 1501 1502 1503 1504 1505 1506 1507 1508 1509 1510 1511 1512 1513 1514 1515 1516 1517 1518 1519 1520 1521 1522 1523 1524 1525 1526 1527 1528 1529 1530 1531 1532 1533 1534 1535 1536 1537 1538 1539 1540 1541 1542 1543 1544 1545 1546 1547 1548
static int topdown_filter_events(const char **attr, char **str, bool use_group)
{
	int off = 0;
	int i;
	int len = 0;
	char *s;

	for (i = 0; attr[i]; i++) {
		if (pmu_have_event("cpu", attr[i])) {
			len += strlen(attr[i]) + 1;
			attr[i - off] = attr[i];
		} else
			off++;
	}
	attr[i - off] = NULL;

	*str = malloc(len + 1 + 2);
	if (!*str)
		return -1;
	s = *str;
	if (i - off == 0) {
		*s = 0;
		return 0;
	}
	if (use_group)
		*s++ = '{';
	for (i = 0; attr[i]; i++) {
		strcpy(s, attr[i]);
		s += strlen(s);
		*s++ = ',';
	}
	if (use_group) {
		s[-1] = '}';
		*s = 0;
	} else
		s[-1] = 0;
	return 0;
}

__weak bool arch_topdown_check_group(bool *warn)
{
	*warn = false;
	return false;
}

__weak void arch_topdown_group_warn(void)
{
}

1549 1550 1551 1552 1553 1554
/*
 * Add default attributes, if there were no attributes specified or
 * if -d/--detailed, -d -d or -d -d -d is used:
 */
static int add_default_attributes(void)
{
1555
	int err;
1556
	struct perf_event_attr default_attrs0[] = {
1557 1558 1559 1560 1561 1562 1563

  { .type = PERF_TYPE_SOFTWARE, .config = PERF_COUNT_SW_TASK_CLOCK		},
  { .type = PERF_TYPE_SOFTWARE, .config = PERF_COUNT_SW_CONTEXT_SWITCHES	},
  { .type = PERF_TYPE_SOFTWARE, .config = PERF_COUNT_SW_CPU_MIGRATIONS		},
  { .type = PERF_TYPE_SOFTWARE, .config = PERF_COUNT_SW_PAGE_FAULTS		},

  { .type = PERF_TYPE_HARDWARE, .config = PERF_COUNT_HW_CPU_CYCLES		},
1564 1565
};
	struct perf_event_attr frontend_attrs[] = {
1566
  { .type = PERF_TYPE_HARDWARE, .config = PERF_COUNT_HW_STALLED_CYCLES_FRONTEND	},
1567 1568
};
	struct perf_event_attr backend_attrs[] = {
1569
  { .type = PERF_TYPE_HARDWARE, .config = PERF_COUNT_HW_STALLED_CYCLES_BACKEND	},
1570 1571
};
	struct perf_event_attr default_attrs1[] = {
1572 1573 1574 1575 1576 1577 1578 1579 1580 1581 1582 1583 1584 1585 1586 1587 1588 1589 1590 1591 1592 1593 1594 1595 1596 1597 1598 1599 1600 1601 1602 1603 1604 1605 1606 1607 1608 1609 1610 1611 1612 1613 1614 1615 1616 1617 1618 1619 1620 1621 1622 1623 1624 1625 1626 1627 1628 1629 1630 1631 1632 1633 1634 1635 1636 1637 1638 1639 1640 1641 1642 1643 1644 1645 1646 1647 1648 1649 1650 1651 1652 1653 1654 1655 1656 1657 1658 1659 1660 1661 1662 1663 1664 1665 1666 1667
  { .type = PERF_TYPE_HARDWARE, .config = PERF_COUNT_HW_INSTRUCTIONS		},
  { .type = PERF_TYPE_HARDWARE, .config = PERF_COUNT_HW_BRANCH_INSTRUCTIONS	},
  { .type = PERF_TYPE_HARDWARE, .config = PERF_COUNT_HW_BRANCH_MISSES		},

};

/*
 * Detailed stats (-d), covering the L1 and last level data caches:
 */
	struct perf_event_attr detailed_attrs[] = {

  { .type = PERF_TYPE_HW_CACHE,
    .config =
	 PERF_COUNT_HW_CACHE_L1D		<<  0  |
	(PERF_COUNT_HW_CACHE_OP_READ		<<  8) |
	(PERF_COUNT_HW_CACHE_RESULT_ACCESS	<< 16)				},

  { .type = PERF_TYPE_HW_CACHE,
    .config =
	 PERF_COUNT_HW_CACHE_L1D		<<  0  |
	(PERF_COUNT_HW_CACHE_OP_READ		<<  8) |
	(PERF_COUNT_HW_CACHE_RESULT_MISS	<< 16)				},

  { .type = PERF_TYPE_HW_CACHE,
    .config =
	 PERF_COUNT_HW_CACHE_LL			<<  0  |
	(PERF_COUNT_HW_CACHE_OP_READ		<<  8) |
	(PERF_COUNT_HW_CACHE_RESULT_ACCESS	<< 16)				},

  { .type = PERF_TYPE_HW_CACHE,
    .config =
	 PERF_COUNT_HW_CACHE_LL			<<  0  |
	(PERF_COUNT_HW_CACHE_OP_READ		<<  8) |
	(PERF_COUNT_HW_CACHE_RESULT_MISS	<< 16)				},
};

/*
 * Very detailed stats (-d -d), covering the instruction cache and the TLB caches:
 */
	struct perf_event_attr very_detailed_attrs[] = {

  { .type = PERF_TYPE_HW_CACHE,
    .config =
	 PERF_COUNT_HW_CACHE_L1I		<<  0  |
	(PERF_COUNT_HW_CACHE_OP_READ		<<  8) |
	(PERF_COUNT_HW_CACHE_RESULT_ACCESS	<< 16)				},

  { .type = PERF_TYPE_HW_CACHE,
    .config =
	 PERF_COUNT_HW_CACHE_L1I		<<  0  |
	(PERF_COUNT_HW_CACHE_OP_READ		<<  8) |
	(PERF_COUNT_HW_CACHE_RESULT_MISS	<< 16)				},

  { .type = PERF_TYPE_HW_CACHE,
    .config =
	 PERF_COUNT_HW_CACHE_DTLB		<<  0  |
	(PERF_COUNT_HW_CACHE_OP_READ		<<  8) |
	(PERF_COUNT_HW_CACHE_RESULT_ACCESS	<< 16)				},

  { .type = PERF_TYPE_HW_CACHE,
    .config =
	 PERF_COUNT_HW_CACHE_DTLB		<<  0  |
	(PERF_COUNT_HW_CACHE_OP_READ		<<  8) |
	(PERF_COUNT_HW_CACHE_RESULT_MISS	<< 16)				},

  { .type = PERF_TYPE_HW_CACHE,
    .config =
	 PERF_COUNT_HW_CACHE_ITLB		<<  0  |
	(PERF_COUNT_HW_CACHE_OP_READ		<<  8) |
	(PERF_COUNT_HW_CACHE_RESULT_ACCESS	<< 16)				},

  { .type = PERF_TYPE_HW_CACHE,
    .config =
	 PERF_COUNT_HW_CACHE_ITLB		<<  0  |
	(PERF_COUNT_HW_CACHE_OP_READ		<<  8) |
	(PERF_COUNT_HW_CACHE_RESULT_MISS	<< 16)				},

};

/*
 * Very, very detailed stats (-d -d -d), adding prefetch events:
 */
	struct perf_event_attr very_very_detailed_attrs[] = {

  { .type = PERF_TYPE_HW_CACHE,
    .config =
	 PERF_COUNT_HW_CACHE_L1D		<<  0  |
	(PERF_COUNT_HW_CACHE_OP_PREFETCH	<<  8) |
	(PERF_COUNT_HW_CACHE_RESULT_ACCESS	<< 16)				},

  { .type = PERF_TYPE_HW_CACHE,
    .config =
	 PERF_COUNT_HW_CACHE_L1D		<<  0  |
	(PERF_COUNT_HW_CACHE_OP_PREFETCH	<<  8) |
	(PERF_COUNT_HW_CACHE_RESULT_MISS	<< 16)				},
};
1668
	struct parse_events_error errinfo;
1669

1670
	/* Set attrs if no event is selected and !null_run: */
1671
	if (stat_config.null_run)
1672 1673
		return 0;

1674
	bzero(&errinfo, sizeof(errinfo));
1675
	if (transaction_run) {
1676 1677 1678 1679 1680 1681 1682 1683 1684
		/* Handle -T as -M transaction. Once platform specific metrics
		 * support has been added to the json files, all archictures
		 * will use this approach. To determine transaction support
		 * on an architecture test for such a metric name.
		 */
		if (metricgroup__has_metric("transaction")) {
			struct option opt = { .value = &evsel_list };

			return metricgroup__parse_groups(&opt, "transaction",
1685 1686
							 stat_config.metric_no_group,
							stat_config.metric_no_merge,
1687
							 &stat_config.metric_events);
1688 1689
		}

1690 1691
		if (pmu_have_event("cpu", "cycles-ct") &&
		    pmu_have_event("cpu", "el-start"))
1692 1693
			err = parse_events(evsel_list, transaction_attrs,
					   &errinfo);
1694
		else
1695 1696 1697
			err = parse_events(evsel_list,
					   transaction_limited_attrs,
					   &errinfo);
1698
		if (err) {
1699
			fprintf(stderr, "Cannot set up transaction events\n");
1700
			parse_events_print_error(&errinfo, transaction_attrs);
1701 1702 1703 1704 1705
			return -1;
		}
		return 0;
	}

1706 1707 1708 1709 1710 1711 1712 1713 1714 1715 1716 1717 1718 1719 1720 1721 1722 1723 1724
	if (smi_cost) {
		int smi;

		if (sysfs__read_int(FREEZE_ON_SMI_PATH, &smi) < 0) {
			fprintf(stderr, "freeze_on_smi is not supported.\n");
			return -1;
		}

		if (!smi) {
			if (sysfs__write_int(FREEZE_ON_SMI_PATH, 1) < 0) {
				fprintf(stderr, "Failed to set freeze_on_smi.\n");
				return -1;
			}
			smi_reset = true;
		}

		if (pmu_have_event("msr", "aperf") &&
		    pmu_have_event("msr", "smi")) {
			if (!force_metric_only)
1725
				stat_config.metric_only = true;
1726
			err = parse_events(evsel_list, smi_cost_attrs, &errinfo);
1727 1728 1729
		} else {
			fprintf(stderr, "To measure SMI cost, it needs "
				"msr/aperf/, msr/smi/ and cpu/cycles/ support\n");
1730
			parse_events_print_error(&errinfo, smi_cost_attrs);
1731 1732 1733
			return -1;
		}
		if (err) {
1734
			parse_events_print_error(&errinfo, smi_cost_attrs);
1735 1736 1737 1738 1739 1740
			fprintf(stderr, "Cannot set up SMI cost events\n");
			return -1;
		}
		return 0;
	}

1741 1742 1743 1744 1745 1746 1747 1748 1749 1750 1751 1752 1753 1754 1755 1756
	if (topdown_run) {
		char *str = NULL;
		bool warn = false;

		if (stat_config.aggr_mode != AGGR_GLOBAL &&
		    stat_config.aggr_mode != AGGR_CORE) {
			pr_err("top down event configuration requires --per-core mode\n");
			return -1;
		}
		stat_config.aggr_mode = AGGR_CORE;
		if (nr_cgroups || !target__has_cpu(&target)) {
			pr_err("top down event configuration requires system-wide mode (-a)\n");
			return -1;
		}

		if (!force_metric_only)
1757
			stat_config.metric_only = true;
1758 1759 1760 1761 1762 1763 1764 1765
		if (topdown_filter_events(topdown_attrs, &str,
				arch_topdown_check_group(&warn)) < 0) {
			pr_err("Out of memory\n");
			return -1;
		}
		if (topdown_attrs[0] && str) {
			if (warn)
				arch_topdown_group_warn();
1766
			err = parse_events(evsel_list, str, &errinfo);
1767 1768 1769 1770
			if (err) {
				fprintf(stderr,
					"Cannot set up top down events %s: %d\n",
					str, err);
1771
				parse_events_print_error(&errinfo, str);
1772
				free(str);
1773 1774 1775 1776 1777 1778 1779 1780 1781
				return -1;
			}
		} else {
			fprintf(stderr, "System does not support topdown\n");
			return -1;
		}
		free(str);
	}

1782
	if (!evsel_list->core.nr_entries) {
1783 1784 1785
		if (target__has_cpu(&target))
			default_attrs0[0].config = PERF_COUNT_SW_CPU_CLOCK;

1786
		if (evlist__add_default_attrs(evsel_list, default_attrs0) < 0)
1787 1788
			return -1;
		if (pmu_have_event("cpu", "stalled-cycles-frontend")) {
1789
			if (evlist__add_default_attrs(evsel_list, frontend_attrs) < 0)
1790 1791 1792
				return -1;
		}
		if (pmu_have_event("cpu", "stalled-cycles-backend")) {
1793
			if (evlist__add_default_attrs(evsel_list, backend_attrs) < 0)
1794 1795
				return -1;
		}
1796
		if (evlist__add_default_attrs(evsel_list, default_attrs1) < 0)
1797
			return -1;
1798 1799 1800 1801 1802 1803 1804 1805
	}

	/* Detailed events get appended to the event list: */

	if (detailed_run <  1)
		return 0;

	/* Append detailed run extra attributes: */
1806
	if (evlist__add_default_attrs(evsel_list, detailed_attrs) < 0)
1807
		return -1;
1808 1809 1810 1811 1812

	if (detailed_run < 2)
		return 0;

	/* Append very detailed run extra attributes: */
1813
	if (evlist__add_default_attrs(evsel_list, very_detailed_attrs) < 0)
1814
		return -1;
1815 1816 1817 1818 1819

	if (detailed_run < 3)
		return 0;

	/* Append very, very detailed run extra attributes: */
1820
	return evlist__add_default_attrs(evsel_list, very_very_detailed_attrs);
1821 1822
}

J
Jiri Olsa 已提交
1823
static const char * const stat_record_usage[] = {
J
Jiri Olsa 已提交
1824 1825 1826 1827
	"perf stat record [<options>]",
	NULL,
};

1828 1829 1830 1831 1832 1833 1834
static void init_features(struct perf_session *session)
{
	int feat;

	for (feat = HEADER_FIRST_FEATURE; feat < HEADER_LAST_FEATURE; feat++)
		perf_header__set_feat(&session->header, feat);

1835
	perf_header__clear_feat(&session->header, HEADER_DIR_FORMAT);
1836 1837 1838 1839 1840 1841
	perf_header__clear_feat(&session->header, HEADER_BUILD_ID);
	perf_header__clear_feat(&session->header, HEADER_TRACING_DATA);
	perf_header__clear_feat(&session->header, HEADER_BRANCH_STACK);
	perf_header__clear_feat(&session->header, HEADER_AUXTRACE);
}

J
Jiri Olsa 已提交
1842 1843 1844
static int __cmd_record(int argc, const char **argv)
{
	struct perf_session *session;
1845
	struct perf_data *data = &perf_stat.data;
J
Jiri Olsa 已提交
1846

J
Jiri Olsa 已提交
1847
	argc = parse_options(argc, argv, stat_options, stat_record_usage,
J
Jiri Olsa 已提交
1848 1849 1850
			     PARSE_OPT_STOP_AT_NON_OPTION);

	if (output_name)
J
Jiri Olsa 已提交
1851
		data->path = output_name;
J
Jiri Olsa 已提交
1852

1853
	if (stat_config.run_count != 1 || forever) {
1854 1855 1856 1857
		pr_err("Cannot use -r option with perf stat record.\n");
		return -1;
	}

1858
	session = perf_session__new(data, false, NULL);
1859 1860 1861
	if (IS_ERR(session)) {
		pr_err("Perf session creation failed\n");
		return PTR_ERR(session);
J
Jiri Olsa 已提交
1862 1863
	}

1864 1865
	init_features(session);

J
Jiri Olsa 已提交
1866 1867 1868 1869 1870 1871
	session->evlist   = evsel_list;
	perf_stat.session = session;
	perf_stat.record  = true;
	return argc;
}

1872 1873
static int process_stat_round_event(struct perf_session *session,
				    union perf_event *event)
1874
{
1875
	struct perf_record_stat_round *stat_round = &event->stat_round;
1876
	struct evsel *counter;
1877 1878 1879 1880
	struct timespec tsh, *ts = NULL;
	const char **argv = session->header.env.cmdline_argv;
	int argc = session->header.env.nr_cmdline;

1881
	evlist__for_each_entry(evsel_list, counter)
1882 1883
		perf_stat_process_counter(&stat_config, counter);

1884 1885
	if (stat_round->type == PERF_STAT_ROUND_TYPE__FINAL)
		update_stats(&walltime_nsecs_stats, stat_round->time);
1886

1887
	if (stat_config.interval && stat_round->time) {
1888 1889
		tsh.tv_sec  = stat_round->time / NSEC_PER_SEC;
		tsh.tv_nsec = stat_round->time % NSEC_PER_SEC;
1890 1891 1892 1893 1894 1895 1896
		ts = &tsh;
	}

	print_counters(ts, argc, argv);
	return 0;
}

1897
static
1898 1899
int process_stat_config_event(struct perf_session *session,
			      union perf_event *event)
1900
{
1901
	struct perf_tool *tool = session->tool;
1902 1903
	struct perf_stat *st = container_of(tool, struct perf_stat, tool);

1904
	perf_event__read_stat_config(&stat_config, &event->stat_config);
1905

1906
	if (perf_cpu_map__empty(st->cpus)) {
1907 1908 1909 1910 1911 1912 1913 1914
		if (st->aggr_mode != AGGR_UNSET)
			pr_warning("warning: processing task data, aggregation mode not set\n");
		return 0;
	}

	if (st->aggr_mode != AGGR_UNSET)
		stat_config.aggr_mode = st->aggr_mode;

1915
	if (perf_stat.data.is_pipe)
1916 1917 1918 1919
		perf_stat_init_aggr_mode();
	else
		perf_stat_init_aggr_mode_file(st);

1920 1921 1922
	return 0;
}

1923 1924 1925 1926 1927 1928 1929 1930
static int set_maps(struct perf_stat *st)
{
	if (!st->cpus || !st->threads)
		return 0;

	if (WARN_ONCE(st->maps_allocated, "stats double allocation\n"))
		return -EINVAL;

1931
	perf_evlist__set_maps(&evsel_list->core, st->cpus, st->threads);
1932 1933 1934 1935 1936 1937 1938 1939 1940

	if (perf_evlist__alloc_stats(evsel_list, true))
		return -ENOMEM;

	st->maps_allocated = true;
	return 0;
}

static
1941 1942
int process_thread_map_event(struct perf_session *session,
			     union perf_event *event)
1943
{
1944
	struct perf_tool *tool = session->tool;
1945 1946 1947 1948 1949 1950 1951 1952 1953 1954 1955 1956 1957 1958 1959
	struct perf_stat *st = container_of(tool, struct perf_stat, tool);

	if (st->threads) {
		pr_warning("Extra thread map event, ignoring.\n");
		return 0;
	}

	st->threads = thread_map__new_event(&event->thread_map);
	if (!st->threads)
		return -ENOMEM;

	return set_maps(st);
}

static
1960 1961
int process_cpu_map_event(struct perf_session *session,
			  union perf_event *event)
1962
{
1963
	struct perf_tool *tool = session->tool;
1964
	struct perf_stat *st = container_of(tool, struct perf_stat, tool);
1965
	struct perf_cpu_map *cpus;
1966 1967 1968 1969 1970 1971 1972 1973 1974 1975 1976 1977 1978 1979

	if (st->cpus) {
		pr_warning("Extra cpu map event, ignoring.\n");
		return 0;
	}

	cpus = cpu_map__new_data(&event->cpu_map.data);
	if (!cpus)
		return -ENOMEM;

	st->cpus = cpus;
	return set_maps(st);
}

J
Jiri Olsa 已提交
1980
static const char * const stat_report_usage[] = {
J
Jiri Olsa 已提交
1981 1982 1983 1984 1985 1986 1987
	"perf stat report [<options>]",
	NULL,
};

static struct perf_stat perf_stat = {
	.tool = {
		.attr		= perf_event__process_attr,
1988
		.event_update	= perf_event__process_event_update,
1989 1990
		.thread_map	= process_thread_map_event,
		.cpu_map	= process_cpu_map_event,
1991
		.stat_config	= process_stat_config_event,
1992 1993
		.stat		= perf_event__process_stat_event,
		.stat_round	= process_stat_round_event,
J
Jiri Olsa 已提交
1994
	},
1995
	.aggr_mode = AGGR_UNSET,
J
Jiri Olsa 已提交
1996 1997 1998 1999 2000 2001 2002
};

static int __cmd_report(int argc, const char **argv)
{
	struct perf_session *session;
	const struct option options[] = {
	OPT_STRING('i', "input", &input_name, "file", "input file name"),
2003 2004
	OPT_SET_UINT(0, "per-socket", &perf_stat.aggr_mode,
		     "aggregate counts per processor socket", AGGR_SOCKET),
2005 2006
	OPT_SET_UINT(0, "per-die", &perf_stat.aggr_mode,
		     "aggregate counts per processor die", AGGR_DIE),
2007 2008
	OPT_SET_UINT(0, "per-core", &perf_stat.aggr_mode,
		     "aggregate counts per physical processor core", AGGR_CORE),
2009 2010
	OPT_SET_UINT(0, "per-node", &perf_stat.aggr_mode,
		     "aggregate counts per numa node", AGGR_NODE),
2011 2012
	OPT_SET_UINT('A', "no-aggr", &perf_stat.aggr_mode,
		     "disable CPU count aggregation", AGGR_NONE),
J
Jiri Olsa 已提交
2013 2014 2015 2016 2017
	OPT_END()
	};
	struct stat st;
	int ret;

J
Jiri Olsa 已提交
2018
	argc = parse_options(argc, argv, options, stat_report_usage, 0);
J
Jiri Olsa 已提交
2019 2020 2021 2022 2023 2024 2025 2026

	if (!input_name || !strlen(input_name)) {
		if (!fstat(STDIN_FILENO, &st) && S_ISFIFO(st.st_mode))
			input_name = "-";
		else
			input_name = "perf.data";
	}

J
Jiri Olsa 已提交
2027 2028
	perf_stat.data.path = input_name;
	perf_stat.data.mode = PERF_DATA_MODE_READ;
J
Jiri Olsa 已提交
2029

2030
	session = perf_session__new(&perf_stat.data, false, &perf_stat.tool);
2031 2032
	if (IS_ERR(session))
		return PTR_ERR(session);
J
Jiri Olsa 已提交
2033 2034 2035 2036 2037 2038 2039 2040 2041 2042 2043 2044 2045

	perf_stat.session  = session;
	stat_config.output = stderr;
	evsel_list         = session->evlist;

	ret = perf_session__process_events(session);
	if (ret)
		return ret;

	perf_session__delete(session);
	return 0;
}

2046 2047 2048 2049 2050 2051 2052 2053 2054 2055 2056 2057 2058 2059 2060 2061 2062
static void setup_system_wide(int forks)
{
	/*
	 * Make system wide (-a) the default target if
	 * no target was specified and one of following
	 * conditions is met:
	 *
	 *   - there's no workload specified
	 *   - there is workload specified but all requested
	 *     events are system wide events
	 */
	if (!target__none(&target))
		return;

	if (!forks)
		target.system_wide = true;
	else {
2063
		struct evsel *counter;
2064 2065

		evlist__for_each_entry(evsel_list, counter) {
2066
			if (!counter->core.system_wide)
2067 2068 2069
				return;
		}

2070
		if (evsel_list->core.nr_entries)
2071 2072 2073 2074
			target.system_wide = true;
	}
}

2075
int cmd_stat(int argc, const char **argv)
2076
{
2077 2078 2079 2080
	const char * const stat_usage[] = {
		"perf stat [<options>] [<command>]",
		NULL
	};
2081
	int status = -EINVAL, run_idx;
2082
	const char *mode;
2083
	FILE *output = stderr;
2084
	unsigned int interval, timeout;
J
Jiri Olsa 已提交
2085
	const char * const stat_subcommands[] = { "record", "report" };
2086

2087 2088
	setlocale(LC_ALL, "");

2089
	evsel_list = evlist__new();
2090 2091 2092
	if (evsel_list == NULL)
		return -ENOMEM;

2093
	parse_events__shrink_config_terms();
2094 2095 2096 2097 2098 2099

	/* String-parsing callback-based options would segfault when negated */
	set_option_flag(stat_options, 'e', "event", PARSE_OPT_NONEG);
	set_option_flag(stat_options, 'M', "metrics", PARSE_OPT_NONEG);
	set_option_flag(stat_options, 'G', "cgroup", PARSE_OPT_NONEG);

J
Jiri Olsa 已提交
2100 2101 2102
	argc = parse_options_subcommand(argc, argv, stat_options, stat_subcommands,
					(const char **) stat_usage,
					PARSE_OPT_STOP_AT_NON_OPTION);
2103
	perf_stat__collect_metric_expr(evsel_list);
2104
	perf_stat__init_shadow_stats();
J
Jiri Olsa 已提交
2105

2106 2107 2108 2109
	if (stat_config.csv_sep) {
		stat_config.csv_output = true;
		if (!strcmp(stat_config.csv_sep, "\\t"))
			stat_config.csv_sep = "\t";
2110
	} else
2111
		stat_config.csv_sep = DEFAULT_SEPARATOR;
2112

J
Jiri Olsa 已提交
2113 2114 2115 2116
	if (argc && !strncmp(argv[0], "rec", 3)) {
		argc = __cmd_record(argc, argv);
		if (argc < 0)
			return -1;
J
Jiri Olsa 已提交
2117 2118
	} else if (argc && !strncmp(argv[0], "rep", 3))
		return __cmd_report(argc, argv);
S
Stephane Eranian 已提交
2119

2120
	interval = stat_config.interval;
2121
	timeout = stat_config.timeout;
2122

J
Jiri Olsa 已提交
2123 2124 2125 2126
	/*
	 * For record command the -o is already taken care of.
	 */
	if (!STAT_RECORD && output_name && strcmp(output_name, "-"))
2127 2128
		output = NULL;

2129 2130
	if (output_name && output_fd) {
		fprintf(stderr, "cannot use both --output and --log-fd\n");
J
Jiri Olsa 已提交
2131 2132
		parse_options_usage(stat_usage, stat_options, "o", 1);
		parse_options_usage(NULL, stat_options, "log-fd", 0);
2133
		goto out;
2134
	}
2135

2136
	if (stat_config.metric_only && stat_config.aggr_mode == AGGR_THREAD) {
2137 2138 2139 2140
		fprintf(stderr, "--metric-only is not supported with --per-thread\n");
		goto out;
	}

2141
	if (stat_config.metric_only && stat_config.run_count > 1) {
2142 2143 2144 2145
		fprintf(stderr, "--metric-only is not supported with -r\n");
		goto out;
	}

2146
	if (stat_config.walltime_run_table && stat_config.run_count <= 1) {
2147 2148 2149 2150 2151 2152
		fprintf(stderr, "--table is only supported with -r\n");
		parse_options_usage(stat_usage, stat_options, "r", 1);
		parse_options_usage(NULL, stat_options, "table", 0);
		goto out;
	}

2153 2154
	if (output_fd < 0) {
		fprintf(stderr, "argument to --log-fd must be a > 0\n");
J
Jiri Olsa 已提交
2155
		parse_options_usage(stat_usage, stat_options, "log-fd", 0);
2156
		goto out;
2157 2158
	}

2159 2160 2161 2162 2163 2164 2165
	if (!output) {
		struct timespec tm;
		mode = append_file ? "a" : "w";

		output = fopen(output_name, mode);
		if (!output) {
			perror("failed to create output file");
2166
			return -1;
2167 2168 2169
		}
		clock_gettime(CLOCK_REALTIME, &tm);
		fprintf(output, "# started on %s\n", ctime(&tm.tv_sec));
2170
	} else if (output_fd > 0) {
2171 2172 2173 2174 2175 2176
		mode = append_file ? "a" : "w";
		output = fdopen(output_fd, mode);
		if (!output) {
			perror("Failed opening logfd");
			return -errno;
		}
2177 2178
	}

2179 2180
	stat_config.output = output;

S
Stephane Eranian 已提交
2181 2182 2183
	/*
	 * let the spreadsheet do the pretty-printing
	 */
2184
	if (stat_config.csv_output) {
J
Jim Cromie 已提交
2185
		/* User explicitly passed -B? */
S
Stephane Eranian 已提交
2186 2187
		if (big_num_opt == 1) {
			fprintf(stderr, "-B option not supported with -x\n");
J
Jiri Olsa 已提交
2188 2189
			parse_options_usage(stat_usage, stat_options, "B", 1);
			parse_options_usage(NULL, stat_options, "x", 1);
2190
			goto out;
S
Stephane Eranian 已提交
2191
		} else /* Nope, so disable big number formatting */
2192
			stat_config.big_num = false;
S
Stephane Eranian 已提交
2193
	} else if (big_num_opt == 0) /* User passed --no-big-num */
2194
		stat_config.big_num = false;
S
Stephane Eranian 已提交
2195

2196
	setup_system_wide(argc);
2197

2198 2199 2200 2201
	/*
	 * Display user/system times only for single
	 * run and when there's specified tracee.
	 */
2202
	if ((stat_config.run_count == 1) && target__none(&target))
2203
		stat_config.ru_display = true;
2204

2205
	if (stat_config.run_count < 0) {
2206
		pr_err("Run count must be a positive number\n");
J
Jiri Olsa 已提交
2207
		parse_options_usage(stat_usage, stat_options, "r", 1);
2208
		goto out;
2209
	} else if (stat_config.run_count == 0) {
2210
		forever = true;
2211
		stat_config.run_count = 1;
2212
	}
2213

2214 2215 2216
	if (stat_config.walltime_run_table) {
		stat_config.walltime_run = zalloc(stat_config.run_count * sizeof(stat_config.walltime_run[0]));
		if (!stat_config.walltime_run) {
2217 2218 2219 2220 2221
			pr_err("failed to setup -r option");
			goto out;
		}
	}

2222 2223 2224 2225 2226 2227 2228 2229 2230 2231
	if ((stat_config.aggr_mode == AGGR_THREAD) &&
		!target__has_task(&target)) {
		if (!target.system_wide || target.cpu_list) {
			fprintf(stderr, "The --per-thread option is only "
				"available when monitoring via -p -t -a "
				"options or only --per-thread.\n");
			parse_options_usage(NULL, stat_options, "p", 1);
			parse_options_usage(NULL, stat_options, "t", 1);
			goto out;
		}
2232 2233 2234 2235 2236 2237
	}

	/*
	 * no_aggr, cgroup are for system-wide only
	 * --per-thread is aggregated per thread, we dont mix it with cpu mode
	 */
2238 2239
	if (((stat_config.aggr_mode != AGGR_GLOBAL &&
	      stat_config.aggr_mode != AGGR_THREAD) || nr_cgroups) &&
2240
	    !target__has_cpu(&target)) {
S
Stephane Eranian 已提交
2241 2242 2243
		fprintf(stderr, "both cgroup and no-aggregation "
			"modes only available in system-wide mode\n");

J
Jiri Olsa 已提交
2244 2245 2246
		parse_options_usage(stat_usage, stat_options, "G", 1);
		parse_options_usage(NULL, stat_options, "A", 1);
		parse_options_usage(NULL, stat_options, "a", 1);
2247
		goto out;
2248 2249
	}

2250 2251
	if (add_default_attributes())
		goto out;
2252

2253
	target__validate(&target);
2254

2255 2256 2257
	if ((stat_config.aggr_mode == AGGR_THREAD) && (target.system_wide))
		target.per_thread = true;

2258
	if (perf_evlist__create_maps(evsel_list, &target) < 0) {
2259
		if (target__has_task(&target)) {
2260
			pr_err("Problems finding threads of monitor\n");
J
Jiri Olsa 已提交
2261 2262
			parse_options_usage(stat_usage, stat_options, "p", 1);
			parse_options_usage(NULL, stat_options, "t", 1);
2263
		} else if (target__has_cpu(&target)) {
2264
			perror("failed to parse CPUs map");
J
Jiri Olsa 已提交
2265 2266
			parse_options_usage(stat_usage, stat_options, "C", 1);
			parse_options_usage(NULL, stat_options, "a", 1);
2267 2268
		}
		goto out;
2269
	}
2270

2271 2272
	evlist__check_cpu_maps(evsel_list);

2273 2274 2275 2276
	/*
	 * Initialize thread_map with comm names,
	 * so we could print it out on output.
	 */
2277
	if (stat_config.aggr_mode == AGGR_THREAD) {
2278
		thread_map__read_comms(evsel_list->core.threads);
2279 2280
		if (target.system_wide) {
			if (runtime_stat_new(&stat_config,
2281
				perf_thread_map__nr(evsel_list->core.threads))) {
2282 2283 2284 2285
				goto out;
			}
		}
	}
2286

2287 2288 2289
	if (stat_config.aggr_mode == AGGR_NODE)
		cpu__setup_cpunode_map();

2290 2291 2292 2293 2294 2295 2296 2297 2298
	if (stat_config.times && interval)
		interval_count = true;
	else if (stat_config.times && !interval) {
		pr_err("interval-count option should be used together with "
				"interval-print.\n");
		parse_options_usage(stat_usage, stat_options, "interval-count", 0);
		parse_options_usage(stat_usage, stat_options, "I", 1);
		goto out;
	}
2299

2300 2301 2302 2303 2304 2305 2306 2307 2308 2309 2310 2311 2312 2313 2314 2315 2316
	if (timeout && timeout < 100) {
		if (timeout < 10) {
			pr_err("timeout must be >= 10ms.\n");
			parse_options_usage(stat_usage, stat_options, "timeout", 0);
			goto out;
		} else
			pr_warning("timeout < 100ms. "
				   "The overhead percentage could be high in some cases. "
				   "Please proceed with caution.\n");
	}
	if (timeout && interval) {
		pr_err("timeout option is not supported with interval-print.\n");
		parse_options_usage(stat_usage, stat_options, "timeout", 0);
		parse_options_usage(stat_usage, stat_options, "I", 1);
		goto out;
	}

2317
	if (perf_evlist__alloc_stats(evsel_list, interval))
2318
		goto out;
2319

2320
	if (perf_stat_init_aggr_mode())
2321
		goto out;
2322

2323 2324 2325 2326 2327 2328 2329 2330 2331 2332 2333
	/*
	 * Set sample_type to PERF_SAMPLE_IDENTIFIER, which should be harmless
	 * while avoiding that older tools show confusing messages.
	 *
	 * However for pipe sessions we need to keep it zero,
	 * because script's perf_evsel__check_attr is triggered
	 * by attr->sample_type != 0, and we can't run it on
	 * stat sessions.
	 */
	stat_config.identifier = !(STAT_RECORD && perf_stat.data.is_pipe);

I
Ingo Molnar 已提交
2334 2335 2336 2337 2338 2339
	/*
	 * We dont want to block the signals - that would cause
	 * child tasks to inherit that and Ctrl-C would not work.
	 * What we want is for Ctrl-C to work in the exec()-ed
	 * task, but being ignored by perf stat itself:
	 */
2340
	atexit(sig_atexit);
2341 2342
	if (!forever)
		signal(SIGINT,  skip_signal);
2343
	signal(SIGCHLD, skip_signal);
I
Ingo Molnar 已提交
2344 2345 2346
	signal(SIGALRM, skip_signal);
	signal(SIGABRT, skip_signal);

2347 2348 2349
	if (evlist__initialize_ctlfd(evsel_list, stat_config.ctl_fd, stat_config.ctl_fd_ack))
		goto out;

2350
	status = 0;
2351 2352
	for (run_idx = 0; forever || run_idx < stat_config.run_count; run_idx++) {
		if (stat_config.run_count != 1 && verbose > 0)
2353 2354
			fprintf(output, "[ perf stat: executing run #%d ... ]\n",
				run_idx + 1);
I
Ingo Molnar 已提交
2355

2356 2357 2358
		if (run_idx != 0)
			perf_evlist__reset_prev_raw_counts(evsel_list);

2359
		status = run_perf_stat(argc, argv, run_idx);
2360
		if (forever && status != -1 && !interval) {
2361
			print_counters(NULL, argc, argv);
2362
			perf_stat__reset_stats();
2363
		}
2364 2365
	}

2366
	if (!forever && status != -1 && (!interval || stat_config.summary))
2367
		print_counters(NULL, argc, argv);
2368

2369 2370
	evlist__finalize_ctlfd(evsel_list);

J
Jiri Olsa 已提交
2371 2372 2373 2374 2375 2376 2377 2378
	if (STAT_RECORD) {
		/*
		 * We synthesize the kernel mmap record just so that older tools
		 * don't emit warnings about not being able to resolve symbols
		 * due to /proc/sys/kernel/kptr_restrict settings and instear provide
		 * a saner message about no samples being in the perf.data file.
		 *
		 * This also serves to suppress a warning about f_header.data.size == 0
2379 2380 2381 2382
		 * in header.c at the moment 'perf stat record' gets introduced, which
		 * is not really needed once we start adding the stat specific PERF_RECORD_
		 * records, but the need to suppress the kptr_restrict messages in older
		 * tools remain  -acme
J
Jiri Olsa 已提交
2383
		 */
2384
		int fd = perf_data__fd(&perf_stat.data);
J
Jiri Olsa 已提交
2385 2386 2387 2388 2389 2390 2391 2392
		int err = perf_event__synthesize_kernel_mmap((void *)&perf_stat,
							     process_synthesized_event,
							     &perf_stat.session->machines.host);
		if (err) {
			pr_warning("Couldn't synthesize the kernel mmap record, harmless, "
				   "older tools may produce warnings about this file\n.");
		}

2393 2394 2395 2396 2397
		if (!interval) {
			if (WRITE_STAT_ROUND_EVENT(walltime_nsecs_stats.max, FINAL))
				pr_err("failed to write stat round event\n");
		}

2398
		if (!perf_stat.data.is_pipe) {
2399 2400 2401
			perf_stat.session->header.data_size += perf_stat.bytes_written;
			perf_session__write_header(perf_stat.session, evsel_list, fd, true);
		}
J
Jiri Olsa 已提交
2402

2403
		evlist__close(evsel_list);
J
Jiri Olsa 已提交
2404 2405 2406
		perf_session__delete(perf_stat.session);
	}

2407
	perf_stat__exit_aggr_mode();
2408
	perf_evlist__free_stats(evsel_list);
2409
out:
2410
	zfree(&stat_config.walltime_run);
2411

2412 2413 2414
	if (smi_cost && smi_reset)
		sysfs__write_int(FREEZE_ON_SMI_PATH, 0);

2415
	evlist__delete(evsel_list);
2416

2417
	metricgroup__rblist_exit(&stat_config.metric_events);
2418 2419
	runtime_stat_delete(&stat_config);

2420
	return status;
2421
}