Linux Audio

Check our new training course

Loading...
v4.17
 
   1/*
   2 * builtin-top.c
   3 *
   4 * Builtin top command: Display a continuously updated profile of
   5 * any workload, CPU or specific PID.
   6 *
   7 * Copyright (C) 2008, Red Hat Inc, Ingo Molnar <mingo@redhat.com>
   8 *		 2011, Red Hat Inc, Arnaldo Carvalho de Melo <acme@redhat.com>
   9 *
  10 * Improvements and fixes by:
  11 *
  12 *   Arjan van de Ven <arjan@linux.intel.com>
  13 *   Yanmin Zhang <yanmin.zhang@intel.com>
  14 *   Wu Fengguang <fengguang.wu@intel.com>
  15 *   Mike Galbraith <efault@gmx.de>
  16 *   Paul Mackerras <paulus@samba.org>
  17 *
  18 * Released under the GPL v2. (and only v2, not any later version)
  19 */
  20#include "builtin.h"
  21
  22#include "perf.h"
  23
  24#include "util/annotate.h"
 
  25#include "util/config.h"
  26#include "util/color.h"
  27#include "util/drv_configs.h"
  28#include "util/evlist.h"
  29#include "util/evsel.h"
 
  30#include "util/event.h"
  31#include "util/machine.h"
 
 
  32#include "util/session.h"
  33#include "util/symbol.h"
  34#include "util/thread.h"
  35#include "util/thread_map.h"
  36#include "util/top.h"
 
  37#include <linux/rbtree.h>
  38#include <subcmd/parse-options.h>
  39#include "util/parse-events.h"
 
  40#include "util/cpumap.h"
  41#include "util/xyarray.h"
  42#include "util/sort.h"
 
  43#include "util/term.h"
  44#include "util/intlist.h"
  45#include "util/parse-branch-options.h"
  46#include "arch/common.h"
 
  47
  48#include "util/debug.h"
 
  49
  50#include <assert.h>
  51#include <elf.h>
  52#include <fcntl.h>
  53
  54#include <stdio.h>
  55#include <termios.h>
  56#include <unistd.h>
  57#include <inttypes.h>
  58
  59#include <errno.h>
  60#include <time.h>
  61#include <sched.h>
  62#include <signal.h>
  63
  64#include <sys/syscall.h>
  65#include <sys/ioctl.h>
  66#include <poll.h>
  67#include <sys/prctl.h>
  68#include <sys/wait.h>
  69#include <sys/uio.h>
  70#include <sys/utsname.h>
  71#include <sys/mman.h>
  72
  73#include <linux/stringify.h>
  74#include <linux/time64.h>
  75#include <linux/types.h>
 
  76
  77#include "sane_ctype.h"
  78
  79static volatile int done;
  80static volatile int resize;
  81
  82#define HEADER_LINE_NR  5
  83
  84static void perf_top__update_print_entries(struct perf_top *top)
  85{
  86	top->print_entries = top->winsize.ws_row - HEADER_LINE_NR;
  87}
  88
  89static void winch_sig(int sig __maybe_unused)
  90{
  91	resize = 1;
  92}
  93
  94static void perf_top__resize(struct perf_top *top)
  95{
  96	get_term_dimensions(&top->winsize);
  97	perf_top__update_print_entries(top);
  98}
  99
 100static int perf_top__parse_source(struct perf_top *top, struct hist_entry *he)
 101{
 102	struct perf_evsel *evsel = hists_to_evsel(he->hists);
 103	struct symbol *sym;
 104	struct annotation *notes;
 105	struct map *map;
 106	int err = -1;
 107
 108	if (!he || !he->ms.sym)
 109		return -1;
 110
 
 
 111	sym = he->ms.sym;
 112	map = he->ms.map;
 113
 114	/*
 115	 * We can't annotate with just /proc/kallsyms
 116	 */
 117	if (map->dso->symtab_type == DSO_BINARY_TYPE__KALLSYMS &&
 118	    !dso__is_kcore(map->dso)) {
 119		pr_err("Can't annotate %s: No vmlinux file was found in the "
 120		       "path\n", sym->name);
 121		sleep(1);
 122		return -1;
 123	}
 124
 125	notes = symbol__annotation(sym);
 126	if (notes->src != NULL) {
 127		pthread_mutex_lock(&notes->lock);
 128		goto out_assign;
 129	}
 130
 131	pthread_mutex_lock(&notes->lock);
 132
 133	if (symbol__alloc_hist(sym) < 0) {
 134		pthread_mutex_unlock(&notes->lock);
 135		pr_err("Not enough memory for annotating '%s' symbol!\n",
 136		       sym->name);
 137		sleep(1);
 138		return err;
 139	}
 140
 141	err = symbol__annotate(sym, map, evsel, 0, NULL);
 142	if (err == 0) {
 143out_assign:
 144		top->sym_filter_entry = he;
 145	} else {
 146		char msg[BUFSIZ];
 147		symbol__strerror_disassemble(sym, map, err, msg, sizeof(msg));
 148		pr_err("Couldn't annotate %s: %s\n", sym->name, msg);
 149	}
 150
 151	pthread_mutex_unlock(&notes->lock);
 152	return err;
 153}
 154
 155static void __zero_source_counters(struct hist_entry *he)
 156{
 157	struct symbol *sym = he->ms.sym;
 158	symbol__annotate_zero_histograms(sym);
 159}
 160
 161static void ui__warn_map_erange(struct map *map, struct symbol *sym, u64 ip)
 162{
 163	struct utsname uts;
 164	int err = uname(&uts);
 165
 166	ui__warning("Out of bounds address found:\n\n"
 167		    "Addr:   %" PRIx64 "\n"
 168		    "DSO:    %s %c\n"
 169		    "Map:    %" PRIx64 "-%" PRIx64 "\n"
 170		    "Symbol: %" PRIx64 "-%" PRIx64 " %c %s\n"
 171		    "Arch:   %s\n"
 172		    "Kernel: %s\n"
 173		    "Tools:  %s\n\n"
 174		    "Not all samples will be on the annotation output.\n\n"
 175		    "Please report to linux-kernel@vger.kernel.org\n",
 176		    ip, map->dso->long_name, dso__symtab_origin(map->dso),
 177		    map->start, map->end, sym->start, sym->end,
 178		    sym->binding == STB_GLOBAL ? 'g' :
 179		    sym->binding == STB_LOCAL  ? 'l' : 'w', sym->name,
 180		    err ? "[unknown]" : uts.machine,
 181		    err ? "[unknown]" : uts.release, perf_version_string);
 182	if (use_browser <= 0)
 183		sleep(5);
 184
 185	map->erange_warned = true;
 186}
 187
 188static void perf_top__record_precise_ip(struct perf_top *top,
 189					struct hist_entry *he,
 190					struct perf_sample *sample,
 191					int counter, u64 ip)
 192{
 193	struct annotation *notes;
 194	struct symbol *sym = he->ms.sym;
 195	int err = 0;
 196
 197	if (sym == NULL || (use_browser == 0 &&
 198			    (top->sym_filter_entry == NULL ||
 199			     top->sym_filter_entry->ms.sym != sym)))
 200		return;
 201
 202	notes = symbol__annotation(sym);
 203
 204	if (pthread_mutex_trylock(&notes->lock))
 205		return;
 206
 207	err = hist_entry__inc_addr_samples(he, sample, counter, ip);
 208
 209	pthread_mutex_unlock(&notes->lock);
 210
 211	if (unlikely(err)) {
 212		/*
 213		 * This function is now called with he->hists->lock held.
 214		 * Release it before going to sleep.
 215		 */
 216		pthread_mutex_unlock(&he->hists->lock);
 217
 218		if (err == -ERANGE && !he->ms.map->erange_warned)
 219			ui__warn_map_erange(he->ms.map, sym, ip);
 220		else if (err == -ENOMEM) {
 221			pr_err("Not enough memory for annotating '%s' symbol!\n",
 222			       sym->name);
 223			sleep(1);
 224		}
 225
 226		pthread_mutex_lock(&he->hists->lock);
 227	}
 228}
 229
 230static void perf_top__show_details(struct perf_top *top)
 231{
 232	struct hist_entry *he = top->sym_filter_entry;
 233	struct perf_evsel *evsel = hists_to_evsel(he->hists);
 234	struct annotation *notes;
 235	struct symbol *symbol;
 236	int more;
 237
 238	if (!he)
 239		return;
 240
 
 
 241	symbol = he->ms.sym;
 242	notes = symbol__annotation(symbol);
 243
 244	pthread_mutex_lock(&notes->lock);
 245
 246	symbol__calc_percent(symbol, evsel);
 247
 248	if (notes->src == NULL)
 249		goto out_unlock;
 250
 251	printf("Showing %s for %s\n", perf_evsel__name(top->sym_evsel), symbol->name);
 252	printf("  Events  Pcnt (>=%d%%)\n", top->sym_pcnt_filter);
 253
 254	more = symbol__annotate_printf(symbol, he->ms.map, top->sym_evsel,
 255				       0, top->sym_pcnt_filter, top->print_entries, 4);
 256
 257	if (top->evlist->enabled) {
 258		if (top->zero)
 259			symbol__annotate_zero_histogram(symbol, top->sym_evsel->idx);
 260		else
 261			symbol__annotate_decay_histogram(symbol, top->sym_evsel->idx);
 262	}
 263	if (more != 0)
 264		printf("%d lines not displayed, maybe increase display entries [e]\n", more);
 265out_unlock:
 266	pthread_mutex_unlock(&notes->lock);
 267}
 268
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 269static void perf_top__print_sym_table(struct perf_top *top)
 270{
 271	char bf[160];
 272	int printed = 0;
 273	const int win_width = top->winsize.ws_col - 1;
 274	struct perf_evsel *evsel = top->sym_evsel;
 275	struct hists *hists = evsel__hists(evsel);
 276
 277	puts(CONSOLE_CLEAR);
 278
 279	perf_top__header_snprintf(top, bf, sizeof(bf));
 280	printf("%s\n", bf);
 281
 282	perf_top__reset_sample_counters(top);
 283
 284	printf("%-*.*s\n", win_width, win_width, graph_dotted_line);
 285
 286	if (!top->record_opts.overwrite &&
 287	    (hists->stats.nr_lost_warned !=
 288	    hists->stats.nr_events[PERF_RECORD_LOST])) {
 289		hists->stats.nr_lost_warned =
 290			      hists->stats.nr_events[PERF_RECORD_LOST];
 291		color_fprintf(stdout, PERF_COLOR_RED,
 292			      "WARNING: LOST %d chunks, Check IO/CPU overload",
 293			      hists->stats.nr_lost_warned);
 294		++printed;
 295	}
 296
 297	if (top->sym_filter_entry) {
 298		perf_top__show_details(top);
 299		return;
 300	}
 301
 302	if (top->evlist->enabled) {
 303		if (top->zero) {
 304			hists__delete_entries(hists);
 305		} else {
 306			hists__decay_entries(hists, top->hide_user_symbols,
 307					     top->hide_kernel_symbols);
 308		}
 309	}
 310
 311	hists__collapse_resort(hists, NULL);
 312	perf_evsel__output_resort(evsel, NULL);
 313
 314	hists__output_recalc_col_len(hists, top->print_entries - printed);
 315	putchar('\n');
 316	hists__fprintf(hists, false, top->print_entries - printed, win_width,
 317		       top->min_percent, stdout, symbol_conf.use_callchain);
 318}
 319
 320static void prompt_integer(int *target, const char *msg)
 321{
 322	char *buf = malloc(0), *p;
 323	size_t dummy = 0;
 324	int tmp;
 325
 326	fprintf(stdout, "\n%s: ", msg);
 327	if (getline(&buf, &dummy, stdin) < 0)
 328		return;
 329
 330	p = strchr(buf, '\n');
 331	if (p)
 332		*p = 0;
 333
 334	p = buf;
 335	while(*p) {
 336		if (!isdigit(*p))
 337			goto out_free;
 338		p++;
 339	}
 340	tmp = strtoul(buf, NULL, 10);
 341	*target = tmp;
 342out_free:
 343	free(buf);
 344}
 345
 346static void prompt_percent(int *target, const char *msg)
 347{
 348	int tmp = 0;
 349
 350	prompt_integer(&tmp, msg);
 351	if (tmp >= 0 && tmp <= 100)
 352		*target = tmp;
 353}
 354
 355static void perf_top__prompt_symbol(struct perf_top *top, const char *msg)
 356{
 357	char *buf = malloc(0), *p;
 358	struct hist_entry *syme = top->sym_filter_entry, *n, *found = NULL;
 359	struct hists *hists = evsel__hists(top->sym_evsel);
 360	struct rb_node *next;
 361	size_t dummy = 0;
 362
 363	/* zero counters of active symbol */
 364	if (syme) {
 365		__zero_source_counters(syme);
 366		top->sym_filter_entry = NULL;
 367	}
 368
 369	fprintf(stdout, "\n%s: ", msg);
 370	if (getline(&buf, &dummy, stdin) < 0)
 371		goto out_free;
 372
 373	p = strchr(buf, '\n');
 374	if (p)
 375		*p = 0;
 376
 377	next = rb_first(&hists->entries);
 378	while (next) {
 379		n = rb_entry(next, struct hist_entry, rb_node);
 380		if (n->ms.sym && !strcmp(buf, n->ms.sym->name)) {
 381			found = n;
 382			break;
 383		}
 384		next = rb_next(&n->rb_node);
 385	}
 386
 387	if (!found) {
 388		fprintf(stderr, "Sorry, %s is not active.\n", buf);
 389		sleep(1);
 390	} else
 391		perf_top__parse_source(top, found);
 392
 393out_free:
 394	free(buf);
 395}
 396
 397static void perf_top__print_mapped_keys(struct perf_top *top)
 398{
 399	char *name = NULL;
 400
 401	if (top->sym_filter_entry) {
 402		struct symbol *sym = top->sym_filter_entry->ms.sym;
 403		name = sym->name;
 404	}
 405
 406	fprintf(stdout, "\nMapped keys:\n");
 407	fprintf(stdout, "\t[d]     display refresh delay.             \t(%d)\n", top->delay_secs);
 408	fprintf(stdout, "\t[e]     display entries (lines).           \t(%d)\n", top->print_entries);
 409
 410	if (top->evlist->nr_entries > 1)
 411		fprintf(stdout, "\t[E]     active event counter.              \t(%s)\n", perf_evsel__name(top->sym_evsel));
 412
 413	fprintf(stdout, "\t[f]     profile display filter (count).    \t(%d)\n", top->count_filter);
 414
 415	fprintf(stdout, "\t[F]     annotate display filter (percent). \t(%d%%)\n", top->sym_pcnt_filter);
 416	fprintf(stdout, "\t[s]     annotate symbol.                   \t(%s)\n", name?: "NULL");
 417	fprintf(stdout, "\t[S]     stop annotation.\n");
 418
 419	fprintf(stdout,
 420		"\t[K]     hide kernel symbols.             \t(%s)\n",
 421		top->hide_kernel_symbols ? "yes" : "no");
 422	fprintf(stdout,
 423		"\t[U]     hide user symbols.               \t(%s)\n",
 424		top->hide_user_symbols ? "yes" : "no");
 425	fprintf(stdout, "\t[z]     toggle sample zeroing.             \t(%d)\n", top->zero ? 1 : 0);
 426	fprintf(stdout, "\t[qQ]    quit.\n");
 427}
 428
 429static int perf_top__key_mapped(struct perf_top *top, int c)
 430{
 431	switch (c) {
 432		case 'd':
 433		case 'e':
 434		case 'f':
 435		case 'z':
 436		case 'q':
 437		case 'Q':
 438		case 'K':
 439		case 'U':
 440		case 'F':
 441		case 's':
 442		case 'S':
 443			return 1;
 444		case 'E':
 445			return top->evlist->nr_entries > 1 ? 1 : 0;
 446		default:
 447			break;
 448	}
 449
 450	return 0;
 451}
 452
 453static bool perf_top__handle_keypress(struct perf_top *top, int c)
 454{
 455	bool ret = true;
 456
 457	if (!perf_top__key_mapped(top, c)) {
 458		struct pollfd stdin_poll = { .fd = 0, .events = POLLIN };
 459		struct termios save;
 460
 461		perf_top__print_mapped_keys(top);
 462		fprintf(stdout, "\nEnter selection, or unmapped key to continue: ");
 463		fflush(stdout);
 464
 465		set_term_quiet_input(&save);
 466
 467		poll(&stdin_poll, 1, -1);
 468		c = getc(stdin);
 469
 470		tcsetattr(0, TCSAFLUSH, &save);
 471		if (!perf_top__key_mapped(top, c))
 472			return ret;
 473	}
 474
 475	switch (c) {
 476		case 'd':
 477			prompt_integer(&top->delay_secs, "Enter display delay");
 478			if (top->delay_secs < 1)
 479				top->delay_secs = 1;
 480			break;
 481		case 'e':
 482			prompt_integer(&top->print_entries, "Enter display entries (lines)");
 483			if (top->print_entries == 0) {
 484				perf_top__resize(top);
 485				signal(SIGWINCH, winch_sig);
 486			} else {
 487				signal(SIGWINCH, SIG_DFL);
 488			}
 489			break;
 490		case 'E':
 491			if (top->evlist->nr_entries > 1) {
 492				/* Select 0 as the default event: */
 493				int counter = 0;
 494
 495				fprintf(stderr, "\nAvailable events:");
 496
 497				evlist__for_each_entry(top->evlist, top->sym_evsel)
 498					fprintf(stderr, "\n\t%d %s", top->sym_evsel->idx, perf_evsel__name(top->sym_evsel));
 499
 500				prompt_integer(&counter, "Enter details event counter");
 501
 502				if (counter >= top->evlist->nr_entries) {
 503					top->sym_evsel = perf_evlist__first(top->evlist);
 504					fprintf(stderr, "Sorry, no such event, using %s.\n", perf_evsel__name(top->sym_evsel));
 505					sleep(1);
 506					break;
 507				}
 508				evlist__for_each_entry(top->evlist, top->sym_evsel)
 509					if (top->sym_evsel->idx == counter)
 510						break;
 511			} else
 512				top->sym_evsel = perf_evlist__first(top->evlist);
 513			break;
 514		case 'f':
 515			prompt_integer(&top->count_filter, "Enter display event count filter");
 516			break;
 517		case 'F':
 518			prompt_percent(&top->sym_pcnt_filter,
 519				       "Enter details display event filter (percent)");
 520			break;
 521		case 'K':
 522			top->hide_kernel_symbols = !top->hide_kernel_symbols;
 523			break;
 524		case 'q':
 525		case 'Q':
 526			printf("exiting.\n");
 527			if (top->dump_symtab)
 528				perf_session__fprintf_dsos(top->session, stderr);
 529			ret = false;
 530			break;
 531		case 's':
 532			perf_top__prompt_symbol(top, "Enter details symbol");
 533			break;
 534		case 'S':
 535			if (!top->sym_filter_entry)
 536				break;
 537			else {
 538				struct hist_entry *syme = top->sym_filter_entry;
 539
 540				top->sym_filter_entry = NULL;
 541				__zero_source_counters(syme);
 542			}
 543			break;
 544		case 'U':
 545			top->hide_user_symbols = !top->hide_user_symbols;
 546			break;
 547		case 'z':
 548			top->zero = !top->zero;
 549			break;
 550		default:
 551			break;
 552	}
 553
 554	return ret;
 555}
 556
 557static void perf_top__sort_new_samples(void *arg)
 558{
 559	struct perf_top *t = arg;
 560	struct perf_evsel *evsel = t->sym_evsel;
 561	struct hists *hists;
 562
 563	perf_top__reset_sample_counters(t);
 564
 565	if (t->evlist->selected != NULL)
 566		t->sym_evsel = t->evlist->selected;
 567
 568	hists = evsel__hists(evsel);
 569
 570	if (t->evlist->enabled) {
 571		if (t->zero) {
 572			hists__delete_entries(hists);
 573		} else {
 574			hists__decay_entries(hists, t->hide_user_symbols,
 575					     t->hide_kernel_symbols);
 576		}
 577	}
 578
 579	hists__collapse_resort(hists, NULL);
 580	perf_evsel__output_resort(evsel, NULL);
 
 
 581}
 582
 583static void *display_thread_tui(void *arg)
 584{
 585	struct perf_evsel *pos;
 586	struct perf_top *top = arg;
 587	const char *help = "For a higher level overview, try: perf top --sort comm,dso";
 588	struct hist_browser_timer hbt = {
 589		.timer		= perf_top__sort_new_samples,
 590		.arg		= top,
 591		.refresh	= top->delay_secs,
 592	};
 593
 594	/* In order to read symbols from other namespaces perf to  needs to call
 595	 * setns(2).  This isn't permitted if the struct_fs has multiple users.
 596	 * unshare(2) the fs so that we may continue to setns into namespaces
 597	 * that we're observing.
 598	 */
 599	unshare(CLONE_FS);
 600
 
 
 601	perf_top__sort_new_samples(top);
 602
 603	/*
 604	 * Initialize the uid_filter_str, in the future the TUI will allow
 605	 * Zooming in/out UIDs. For now juse use whatever the user passed
 606	 * via --uid.
 607	 */
 608	evlist__for_each_entry(top->evlist, pos) {
 609		struct hists *hists = evsel__hists(pos);
 610		hists->uid_filter_str = top->record_opts.target.uid_str;
 611	}
 612
 613	perf_evlist__tui_browse_hists(top->evlist, help, &hbt,
 614				      top->min_percent,
 615				      &top->session->header.env,
 616				      !top->record_opts.overwrite);
 
 617
 618	done = 1;
 619	return NULL;
 620}
 621
 622static void display_sig(int sig __maybe_unused)
 623{
 624	done = 1;
 625}
 626
 627static void display_setup_sig(void)
 628{
 629	signal(SIGSEGV, sighandler_dump_stack);
 630	signal(SIGFPE, sighandler_dump_stack);
 631	signal(SIGINT,  display_sig);
 632	signal(SIGQUIT, display_sig);
 633	signal(SIGTERM, display_sig);
 634}
 635
 636static void *display_thread(void *arg)
 637{
 638	struct pollfd stdin_poll = { .fd = 0, .events = POLLIN };
 639	struct termios save;
 640	struct perf_top *top = arg;
 641	int delay_msecs, c;
 642
 643	/* In order to read symbols from other namespaces perf to  needs to call
 644	 * setns(2).  This isn't permitted if the struct_fs has multiple users.
 645	 * unshare(2) the fs so that we may continue to setns into namespaces
 646	 * that we're observing.
 647	 */
 648	unshare(CLONE_FS);
 649
 
 
 650	display_setup_sig();
 651	pthread__unblock_sigwinch();
 652repeat:
 653	delay_msecs = top->delay_secs * MSEC_PER_SEC;
 654	set_term_quiet_input(&save);
 655	/* trash return*/
 656	getc(stdin);
 657
 658	while (!done) {
 659		perf_top__print_sym_table(top);
 660		/*
 661		 * Either timeout expired or we got an EINTR due to SIGWINCH,
 662		 * refresh screen in both cases.
 663		 */
 664		switch (poll(&stdin_poll, 1, delay_msecs)) {
 665		case 0:
 666			continue;
 667		case -1:
 668			if (errno == EINTR)
 669				continue;
 670			__fallthrough;
 671		default:
 672			c = getc(stdin);
 673			tcsetattr(0, TCSAFLUSH, &save);
 674
 675			if (perf_top__handle_keypress(top, c))
 676				goto repeat;
 677			done = 1;
 678		}
 679	}
 680
 681	tcsetattr(0, TCSAFLUSH, &save);
 682	return NULL;
 683}
 684
 685static int hist_iter__top_callback(struct hist_entry_iter *iter,
 686				   struct addr_location *al, bool single,
 687				   void *arg)
 688{
 689	struct perf_top *top = arg;
 690	struct hist_entry *he = iter->he;
 691	struct perf_evsel *evsel = iter->evsel;
 692
 693	if (perf_hpp_list.sym && single)
 694		perf_top__record_precise_ip(top, he, iter->sample, evsel->idx, al->addr);
 695
 696	hist__account_cycles(iter->sample->branch_stack, al, iter->sample,
 697		     !(top->record_opts.branch_stack & PERF_SAMPLE_BRANCH_ANY));
 698	return 0;
 699}
 700
 701static void perf_event__process_sample(struct perf_tool *tool,
 702				       const union perf_event *event,
 703				       struct perf_evsel *evsel,
 704				       struct perf_sample *sample,
 705				       struct machine *machine)
 706{
 707	struct perf_top *top = container_of(tool, struct perf_top, tool);
 708	struct addr_location al;
 709	int err;
 710
 711	if (!machine && perf_guest) {
 712		static struct intlist *seen;
 713
 714		if (!seen)
 715			seen = intlist__new(NULL);
 716
 717		if (!intlist__has_entry(seen, sample->pid)) {
 718			pr_err("Can't find guest [%d]'s kernel information\n",
 719				sample->pid);
 720			intlist__add(seen, sample->pid);
 721		}
 722		return;
 723	}
 724
 725	if (!machine) {
 726		pr_err("%u unprocessable samples recorded.\r",
 727		       top->session->evlist->stats.nr_unprocessable_samples++);
 728		return;
 729	}
 730
 731	if (event->header.misc & PERF_RECORD_MISC_EXACT_IP)
 732		top->exact_samples++;
 733
 734	if (machine__resolve(machine, &al, sample) < 0)
 735		return;
 736
 737	if (!machine->kptr_restrict_warned &&
 738	    symbol_conf.kptr_restrict &&
 739	    al.cpumode == PERF_RECORD_MISC_KERNEL) {
 740		if (!perf_evlist__exclude_kernel(top->session->evlist)) {
 741			ui__warning(
 742"Kernel address maps (/proc/{kallsyms,modules}) are restricted.\n\n"
 743"Check /proc/sys/kernel/kptr_restrict.\n\n"
 744"Kernel%s samples will not be resolved.\n",
 745			  al.map && !RB_EMPTY_ROOT(&al.map->dso->symbols[MAP__FUNCTION]) ?
 746			  " modules" : "");
 747			if (use_browser <= 0)
 748				sleep(5);
 749		}
 750		machine->kptr_restrict_warned = true;
 751	}
 752
 753	if (al.sym == NULL) {
 754		const char *msg = "Kernel samples will not be resolved.\n";
 755		/*
 756		 * As we do lazy loading of symtabs we only will know if the
 757		 * specified vmlinux file is invalid when we actually have a
 758		 * hit in kernel space and then try to load it. So if we get
 759		 * here and there are _no_ symbols in the DSO backing the
 760		 * kernel map, bail out.
 761		 *
 762		 * We may never get here, for instance, if we use -K/
 763		 * --hide-kernel-symbols, even if the user specifies an
 764		 * invalid --vmlinux ;-)
 765		 */
 766		if (!machine->kptr_restrict_warned && !top->vmlinux_warned &&
 767		    al.map == machine->vmlinux_maps[MAP__FUNCTION] &&
 768		    RB_EMPTY_ROOT(&al.map->dso->symbols[MAP__FUNCTION])) {
 769			if (symbol_conf.vmlinux_name) {
 770				char serr[256];
 771				dso__strerror_load(al.map->dso, serr, sizeof(serr));
 772				ui__warning("The %s file can't be used: %s\n%s",
 773					    symbol_conf.vmlinux_name, serr, msg);
 774			} else {
 775				ui__warning("A vmlinux file was not found.\n%s",
 776					    msg);
 777			}
 778
 779			if (use_browser <= 0)
 780				sleep(5);
 781			top->vmlinux_warned = true;
 782		}
 783	}
 784
 785	if (al.sym == NULL || !al.sym->idle) {
 786		struct hists *hists = evsel__hists(evsel);
 787		struct hist_entry_iter iter = {
 788			.evsel		= evsel,
 789			.sample 	= sample,
 790			.add_entry_cb 	= hist_iter__top_callback,
 791		};
 792
 793		if (symbol_conf.cumulate_callchain)
 794			iter.ops = &hist_iter_cumulative;
 795		else
 796			iter.ops = &hist_iter_normal;
 797
 798		pthread_mutex_lock(&hists->lock);
 799
 800		err = hist_entry_iter__add(&iter, &al, top->max_stack, top);
 801		if (err < 0)
 802			pr_err("Problem incrementing symbol period, skipping event\n");
 803
 804		pthread_mutex_unlock(&hists->lock);
 805	}
 806
 807	addr_location__put(&al);
 808}
 809
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 810static void perf_top__mmap_read_idx(struct perf_top *top, int idx)
 811{
 812	struct record_opts *opts = &top->record_opts;
 813	struct perf_evlist *evlist = top->evlist;
 814	struct perf_sample sample;
 815	struct perf_evsel *evsel;
 816	struct perf_mmap *md;
 817	struct perf_session *session = top->session;
 818	union perf_event *event;
 819	struct machine *machine;
 820	int ret;
 821
 822	md = opts->overwrite ? &evlist->overwrite_mmap[idx] : &evlist->mmap[idx];
 823	if (perf_mmap__read_init(md) < 0)
 824		return;
 825
 826	while ((event = perf_mmap__read_event(md)) != NULL) {
 827		ret = perf_evlist__parse_sample(evlist, event, &sample);
 828		if (ret) {
 829			pr_err("Can't parse sample, err = %d\n", ret);
 830			goto next_event;
 831		}
 832
 833		evsel = perf_evlist__id2evsel(session->evlist, sample.id);
 834		assert(evsel != NULL);
 835
 836		if (event->header.type == PERF_RECORD_SAMPLE)
 837			++top->samples;
 838
 839		switch (sample.cpumode) {
 840		case PERF_RECORD_MISC_USER:
 841			++top->us_samples;
 842			if (top->hide_user_symbols)
 843				goto next_event;
 844			machine = &session->machines.host;
 845			break;
 846		case PERF_RECORD_MISC_KERNEL:
 847			++top->kernel_samples;
 848			if (top->hide_kernel_symbols)
 849				goto next_event;
 850			machine = &session->machines.host;
 851			break;
 852		case PERF_RECORD_MISC_GUEST_KERNEL:
 853			++top->guest_kernel_samples;
 854			machine = perf_session__find_machine(session,
 855							     sample.pid);
 856			break;
 857		case PERF_RECORD_MISC_GUEST_USER:
 858			++top->guest_us_samples;
 859			/*
 860			 * TODO: we don't process guest user from host side
 861			 * except simple counting.
 862			 */
 863			goto next_event;
 864		default:
 865			if (event->header.type == PERF_RECORD_SAMPLE)
 866				goto next_event;
 867			machine = &session->machines.host;
 868			break;
 869		}
 870
 
 
 
 871
 872		if (event->header.type == PERF_RECORD_SAMPLE) {
 873			perf_event__process_sample(&top->tool, event, evsel,
 874						   &sample, machine);
 875		} else if (event->header.type < PERF_RECORD_MAX) {
 876			hists__inc_nr_events(evsel__hists(evsel), event->header.type);
 877			machine__process_event(machine, event, &sample);
 878		} else
 879			++session->evlist->stats.nr_unknown_events;
 880next_event:
 881		perf_mmap__consume(md);
 
 
 
 
 
 
 
 882	}
 883
 884	perf_mmap__read_done(md);
 885}
 886
 887static void perf_top__mmap_read(struct perf_top *top)
 888{
 889	bool overwrite = top->record_opts.overwrite;
 890	struct perf_evlist *evlist = top->evlist;
 891	unsigned long long start, end;
 892	int i;
 893
 894	start = rdclock();
 895	if (overwrite)
 896		perf_evlist__toggle_bkw_mmap(evlist, BKW_MMAP_DATA_PENDING);
 897
 898	for (i = 0; i < top->evlist->nr_mmaps; i++)
 899		perf_top__mmap_read_idx(top, i);
 900
 901	if (overwrite) {
 902		perf_evlist__toggle_bkw_mmap(evlist, BKW_MMAP_EMPTY);
 903		perf_evlist__toggle_bkw_mmap(evlist, BKW_MMAP_RUNNING);
 904	}
 905	end = rdclock();
 906
 907	if ((end - start) > (unsigned long long)top->delay_secs * NSEC_PER_SEC)
 908		ui__warning("Too slow to read ring buffer.\n"
 909			    "Please try increasing the period (-c) or\n"
 910			    "decreasing the freq (-F) or\n"
 911			    "limiting the number of CPUs (-C)\n");
 912}
 913
 914/*
 915 * Check per-event overwrite term.
 916 * perf top should support consistent term for all events.
 917 * - All events don't have per-event term
 918 *   E.g. "cpu/cpu-cycles/,cpu/instructions/"
 919 *   Nothing change, return 0.
 920 * - All events have same per-event term
 921 *   E.g. "cpu/cpu-cycles,no-overwrite/,cpu/instructions,no-overwrite/
 922 *   Using the per-event setting to replace the opts->overwrite if
 923 *   they are different, then return 0.
 924 * - Events have different per-event term
 925 *   E.g. "cpu/cpu-cycles,overwrite/,cpu/instructions,no-overwrite/"
 926 *   Return -1
 927 * - Some of the event set per-event term, but some not.
 928 *   E.g. "cpu/cpu-cycles/,cpu/instructions,no-overwrite/"
 929 *   Return -1
 930 */
 931static int perf_top__overwrite_check(struct perf_top *top)
 932{
 933	struct record_opts *opts = &top->record_opts;
 934	struct perf_evlist *evlist = top->evlist;
 935	struct perf_evsel_config_term *term;
 936	struct list_head *config_terms;
 937	struct perf_evsel *evsel;
 938	int set, overwrite = -1;
 939
 940	evlist__for_each_entry(evlist, evsel) {
 941		set = -1;
 942		config_terms = &evsel->config_terms;
 943		list_for_each_entry(term, config_terms, list) {
 944			if (term->type == PERF_EVSEL__CONFIG_TERM_OVERWRITE)
 945				set = term->val.overwrite ? 1 : 0;
 946		}
 947
 948		/* no term for current and previous event (likely) */
 949		if ((overwrite < 0) && (set < 0))
 950			continue;
 951
 952		/* has term for both current and previous event, compare */
 953		if ((overwrite >= 0) && (set >= 0) && (overwrite != set))
 954			return -1;
 955
 956		/* no term for current event but has term for previous one */
 957		if ((overwrite >= 0) && (set < 0))
 958			return -1;
 959
 960		/* has term for current event */
 961		if ((overwrite < 0) && (set >= 0)) {
 962			/* if it's first event, set overwrite */
 963			if (evsel == perf_evlist__first(evlist))
 964				overwrite = set;
 965			else
 966				return -1;
 967		}
 968	}
 969
 970	if ((overwrite >= 0) && (opts->overwrite != overwrite))
 971		opts->overwrite = overwrite;
 972
 973	return 0;
 974}
 975
 976static int perf_top_overwrite_fallback(struct perf_top *top,
 977				       struct perf_evsel *evsel)
 978{
 979	struct record_opts *opts = &top->record_opts;
 980	struct perf_evlist *evlist = top->evlist;
 981	struct perf_evsel *counter;
 982
 983	if (!opts->overwrite)
 984		return 0;
 985
 986	/* only fall back when first event fails */
 987	if (evsel != perf_evlist__first(evlist))
 988		return 0;
 989
 990	evlist__for_each_entry(evlist, counter)
 991		counter->attr.write_backward = false;
 992	opts->overwrite = false;
 993	pr_debug2("fall back to non-overwrite mode\n");
 994	return 1;
 995}
 996
 997static int perf_top__start_counters(struct perf_top *top)
 998{
 999	char msg[BUFSIZ];
1000	struct perf_evsel *counter;
1001	struct perf_evlist *evlist = top->evlist;
1002	struct record_opts *opts = &top->record_opts;
1003
1004	if (perf_top__overwrite_check(top)) {
1005		ui__error("perf top only support consistent per-event "
1006			  "overwrite setting for all events\n");
1007		goto out_err;
1008	}
1009
1010	perf_evlist__config(evlist, opts, &callchain_param);
1011
1012	evlist__for_each_entry(evlist, counter) {
1013try_again:
1014		if (perf_evsel__open(counter, top->evlist->cpus,
1015				     top->evlist->threads) < 0) {
1016
1017			/*
1018			 * Specially handle overwrite fall back.
1019			 * Because perf top is the only tool which has
1020			 * overwrite mode by default, support
1021			 * both overwrite and non-overwrite mode, and
1022			 * require consistent mode for all events.
1023			 *
1024			 * May move it to generic code with more tools
1025			 * have similar attribute.
1026			 */
1027			if (perf_missing_features.write_backward &&
1028			    perf_top_overwrite_fallback(top, counter))
1029				goto try_again;
1030
1031			if (perf_evsel__fallback(counter, errno, msg, sizeof(msg))) {
1032				if (verbose > 0)
1033					ui__warning("%s\n", msg);
1034				goto try_again;
1035			}
1036
1037			perf_evsel__open_strerror(counter, &opts->target,
1038						  errno, msg, sizeof(msg));
1039			ui__error("%s\n", msg);
1040			goto out_err;
1041		}
1042	}
1043
1044	if (perf_evlist__mmap(evlist, opts->mmap_pages) < 0) {
1045		ui__error("Failed to mmap with %d (%s)\n",
1046			    errno, str_error_r(errno, msg, sizeof(msg)));
1047		goto out_err;
1048	}
1049
1050	return 0;
1051
1052out_err:
1053	return -1;
1054}
1055
1056static int callchain_param__setup_sample_type(struct callchain_param *callchain)
1057{
1058	if (!perf_hpp_list.sym) {
1059		if (callchain->enabled) {
1060			ui__error("Selected -g but \"sym\" not present in --sort/-s.");
1061			return -EINVAL;
1062		}
1063	} else if (callchain->mode != CHAIN_NONE) {
1064		if (callchain_register_param(callchain) < 0) {
1065			ui__error("Can't register callchain params.\n");
1066			return -EINVAL;
1067		}
1068	}
1069
1070	return 0;
1071}
1072
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1073static int __cmd_top(struct perf_top *top)
1074{
1075	char msg[512];
1076	struct perf_evsel *pos;
1077	struct perf_evsel_config_term *err_term;
1078	struct perf_evlist *evlist = top->evlist;
1079	struct record_opts *opts = &top->record_opts;
1080	pthread_t thread;
1081	int ret;
1082
1083	top->session = perf_session__new(NULL, false, NULL);
1084	if (top->session == NULL)
1085		return -1;
1086
1087	if (!objdump_path) {
1088		ret = perf_env__lookup_objdump(&top->session->header.env);
1089		if (ret)
1090			goto out_delete;
1091	}
1092
1093	ret = callchain_param__setup_sample_type(&callchain_param);
1094	if (ret)
1095		goto out_delete;
1096
1097	if (perf_session__register_idle_thread(top->session) < 0)
1098		goto out_delete;
1099
1100	if (top->nr_threads_synthesize > 1)
1101		perf_set_multithreaded();
1102
 
 
 
 
 
 
 
 
 
 
 
1103	machine__synthesize_threads(&top->session->machines.host, &opts->target,
1104				    top->evlist->threads, false,
1105				    opts->proc_map_timeout,
1106				    top->nr_threads_synthesize);
1107
1108	if (top->nr_threads_synthesize > 1)
1109		perf_set_singlethreaded();
1110
1111	if (perf_hpp_list.socket) {
1112		ret = perf_env__read_cpu_topology_map(&perf_env);
1113		if (ret < 0)
1114			goto out_err_cpu_topo;
 
 
 
 
 
1115	}
1116
1117	ret = perf_top__start_counters(top);
1118	if (ret)
1119		goto out_delete;
1120
1121	ret = perf_evlist__apply_drv_configs(evlist, &pos, &err_term);
1122	if (ret) {
1123		pr_err("failed to set config \"%s\" on event %s with %d (%s)\n",
1124			err_term->val.drv_cfg, perf_evsel__name(pos), errno,
1125			str_error_r(errno, msg, sizeof(msg)));
1126		goto out_delete;
1127	}
1128
1129	top->session->evlist = top->evlist;
1130	perf_session__set_id_hdr_size(top->session);
1131
1132	/*
1133	 * When perf is starting the traced process, all the events (apart from
1134	 * group members) have enable_on_exec=1 set, so don't spoil it by
1135	 * prematurely enabling them.
1136	 *
1137	 * XXX 'top' still doesn't start workloads like record, trace, but should,
1138	 * so leave the check here.
1139	 */
1140        if (!target__none(&opts->target))
1141                perf_evlist__enable(top->evlist);
1142
1143	/* Wait for a minimal set of events before starting the snapshot */
1144	perf_evlist__poll(top->evlist, 100);
1145
1146	perf_top__mmap_read(top);
1147
1148	ret = -1;
 
 
 
 
 
1149	if (pthread_create(&thread, NULL, (use_browser > 0 ? display_thread_tui :
1150							    display_thread), top)) {
1151		ui__error("Could not create display thread.\n");
1152		goto out_delete;
1153	}
1154
1155	if (top->realtime_prio) {
1156		struct sched_param param;
1157
1158		param.sched_priority = top->realtime_prio;
1159		if (sched_setscheduler(0, SCHED_FIFO, &param)) {
1160			ui__error("Could not set realtime priority.\n");
1161			goto out_join;
1162		}
1163	}
1164
 
 
 
 
 
1165	while (!done) {
1166		u64 hits = top->samples;
1167
1168		perf_top__mmap_read(top);
1169
1170		if (opts->overwrite || (hits == top->samples))
1171			ret = perf_evlist__poll(top->evlist, 100);
1172
1173		if (resize) {
1174			perf_top__resize(top);
1175			resize = 0;
1176		}
1177	}
1178
1179	ret = 0;
1180out_join:
1181	pthread_join(thread, NULL);
1182out_delete:
1183	perf_session__delete(top->session);
1184	top->session = NULL;
1185
1186	return ret;
1187
1188out_err_cpu_topo: {
1189	char errbuf[BUFSIZ];
1190	const char *err = str_error_r(-ret, errbuf, sizeof(errbuf));
1191
1192	ui__error("Could not read the CPU topology map: %s\n", err);
1193	goto out_delete;
1194}
1195}
1196
1197static int
1198callchain_opt(const struct option *opt, const char *arg, int unset)
1199{
1200	symbol_conf.use_callchain = true;
1201	return record_callchain_opt(opt, arg, unset);
1202}
1203
1204static int
1205parse_callchain_opt(const struct option *opt, const char *arg, int unset)
1206{
1207	struct callchain_param *callchain = opt->value;
1208
1209	callchain->enabled = !unset;
1210	callchain->record_mode = CALLCHAIN_FP;
1211
1212	/*
1213	 * --no-call-graph
1214	 */
1215	if (unset) {
1216		symbol_conf.use_callchain = false;
1217		callchain->record_mode = CALLCHAIN_NONE;
1218		return 0;
1219	}
1220
1221	return parse_callchain_top_opt(arg);
1222}
1223
1224static int perf_top_config(const char *var, const char *value, void *cb __maybe_unused)
1225{
1226	if (!strcmp(var, "top.call-graph")) {
1227		var = "call-graph.record-mode";
1228		return perf_default_config(var, value, cb);
1229	}
1230	if (!strcmp(var, "top.children")) {
1231		symbol_conf.cumulate_callchain = perf_config_bool(var, value);
1232		return 0;
1233	}
1234
1235	return 0;
1236}
1237
1238static int
1239parse_percent_limit(const struct option *opt, const char *arg,
1240		    int unset __maybe_unused)
1241{
1242	struct perf_top *top = opt->value;
1243
1244	top->min_percent = strtof(arg, NULL);
1245	return 0;
1246}
1247
1248const char top_callchain_help[] = CALLCHAIN_RECORD_HELP CALLCHAIN_REPORT_HELP
1249	"\n\t\t\t\tDefault: fp,graph,0.5,caller,function";
1250
1251int cmd_top(int argc, const char **argv)
1252{
1253	char errbuf[BUFSIZ];
1254	struct perf_top top = {
1255		.count_filter	     = 5,
1256		.delay_secs	     = 2,
1257		.record_opts = {
1258			.mmap_pages	= UINT_MAX,
1259			.user_freq	= UINT_MAX,
1260			.user_interval	= ULLONG_MAX,
1261			.freq		= 4000, /* 4 KHz */
1262			.target		= {
1263				.uses_mmap   = true,
1264			},
1265			.proc_map_timeout    = 500,
1266			.overwrite	= 1,
 
 
 
 
 
 
 
 
1267		},
1268		.max_stack	     = sysctl_perf_event_max_stack,
1269		.sym_pcnt_filter     = 5,
1270		.nr_threads_synthesize = UINT_MAX,
1271	};
1272	struct record_opts *opts = &top.record_opts;
1273	struct target *target = &opts->target;
1274	const struct option options[] = {
1275	OPT_CALLBACK('e', "event", &top.evlist, "event",
1276		     "event selector. use 'perf list' to list available events",
1277		     parse_events_option),
1278	OPT_U64('c', "count", &opts->user_interval, "event period to sample"),
1279	OPT_STRING('p', "pid", &target->pid, "pid",
1280		    "profile events on existing process id"),
1281	OPT_STRING('t', "tid", &target->tid, "tid",
1282		    "profile events on existing thread id"),
1283	OPT_BOOLEAN('a', "all-cpus", &target->system_wide,
1284			    "system-wide collection from all CPUs"),
1285	OPT_STRING('C', "cpu", &target->cpu_list, "cpu",
1286		    "list of cpus to monitor"),
1287	OPT_STRING('k', "vmlinux", &symbol_conf.vmlinux_name,
1288		   "file", "vmlinux pathname"),
1289	OPT_BOOLEAN(0, "ignore-vmlinux", &symbol_conf.ignore_vmlinux,
1290		    "don't load vmlinux even if found"),
 
 
1291	OPT_BOOLEAN('K', "hide_kernel_symbols", &top.hide_kernel_symbols,
1292		    "hide kernel symbols"),
1293	OPT_CALLBACK('m', "mmap-pages", &opts->mmap_pages, "pages",
1294		     "number of mmap data pages",
1295		     perf_evlist__parse_mmap_pages),
1296	OPT_INTEGER('r', "realtime", &top.realtime_prio,
1297		    "collect data with this RT SCHED_FIFO priority"),
1298	OPT_INTEGER('d', "delay", &top.delay_secs,
1299		    "number of seconds to delay between refreshes"),
1300	OPT_BOOLEAN('D', "dump-symtab", &top.dump_symtab,
1301			    "dump the symbol table used for profiling"),
1302	OPT_INTEGER('f', "count-filter", &top.count_filter,
1303		    "only display functions with more events than this"),
1304	OPT_BOOLEAN(0, "group", &opts->group,
1305			    "put the counters into a counter group"),
1306	OPT_BOOLEAN('i', "no-inherit", &opts->no_inherit,
1307		    "child tasks do not inherit counters"),
1308	OPT_STRING(0, "sym-annotate", &top.sym_filter, "symbol name",
1309		    "symbol to annotate"),
1310	OPT_BOOLEAN('z', "zero", &top.zero, "zero history across updates"),
1311	OPT_CALLBACK('F', "freq", &top.record_opts, "freq or 'max'",
1312		     "profile at this frequency",
1313		      record__parse_freq),
1314	OPT_INTEGER('E', "entries", &top.print_entries,
1315		    "display this many functions"),
1316	OPT_BOOLEAN('U', "hide_user_symbols", &top.hide_user_symbols,
1317		    "hide user symbols"),
1318	OPT_BOOLEAN(0, "tui", &top.use_tui, "Use the TUI interface"),
1319	OPT_BOOLEAN(0, "stdio", &top.use_stdio, "Use the stdio interface"),
1320	OPT_INCR('v', "verbose", &verbose,
1321		    "be more verbose (show counter open errors, etc)"),
1322	OPT_STRING('s', "sort", &sort_order, "key[,key2...]",
1323		   "sort by key(s): pid, comm, dso, symbol, parent, cpu, srcline, ..."
1324		   " Please refer the man page for the complete list."),
1325	OPT_STRING(0, "fields", &field_order, "key[,keys...]",
1326		   "output field(s): overhead, period, sample plus all of sort keys"),
1327	OPT_BOOLEAN('n', "show-nr-samples", &symbol_conf.show_nr_samples,
1328		    "Show a column with the number of samples"),
1329	OPT_CALLBACK_NOOPT('g', NULL, &callchain_param,
1330			   NULL, "enables call-graph recording and display",
1331			   &callchain_opt),
1332	OPT_CALLBACK(0, "call-graph", &callchain_param,
1333		     "record_mode[,record_size],print_type,threshold[,print_limit],order,sort_key[,branch]",
1334		     top_callchain_help, &parse_callchain_opt),
1335	OPT_BOOLEAN(0, "children", &symbol_conf.cumulate_callchain,
1336		    "Accumulate callchains of children and show total overhead as well"),
1337	OPT_INTEGER(0, "max-stack", &top.max_stack,
1338		    "Set the maximum stack depth when parsing the callchain. "
1339		    "Default: kernel.perf_event_max_stack or " __stringify(PERF_MAX_STACK_DEPTH)),
1340	OPT_CALLBACK(0, "ignore-callees", NULL, "regex",
1341		   "ignore callees of these functions in call graphs",
1342		   report_parse_ignore_callees_opt),
1343	OPT_BOOLEAN(0, "show-total-period", &symbol_conf.show_total_period,
1344		    "Show a column with the sum of periods"),
1345	OPT_STRING(0, "dsos", &symbol_conf.dso_list_str, "dso[,dso...]",
1346		   "only consider symbols in these dsos"),
1347	OPT_STRING(0, "comms", &symbol_conf.comm_list_str, "comm[,comm...]",
1348		   "only consider symbols in these comms"),
1349	OPT_STRING(0, "symbols", &symbol_conf.sym_list_str, "symbol[,symbol...]",
1350		   "only consider these symbols"),
1351	OPT_BOOLEAN(0, "source", &symbol_conf.annotate_src,
1352		    "Interleave source code with assembly code (default)"),
1353	OPT_BOOLEAN(0, "asm-raw", &symbol_conf.annotate_asm_raw,
1354		    "Display raw encoding of assembly instructions (default)"),
1355	OPT_BOOLEAN(0, "demangle-kernel", &symbol_conf.demangle_kernel,
1356		    "Enable kernel symbol demangling"),
1357	OPT_STRING(0, "objdump", &objdump_path, "path",
 
1358		    "objdump binary to use for disassembly and annotations"),
1359	OPT_STRING('M', "disassembler-style", &disassembler_style, "disassembler style",
1360		   "Specify disassembler style (e.g. -M intel for intel syntax)"),
1361	OPT_STRING('u', "uid", &target->uid_str, "user", "user to profile"),
1362	OPT_CALLBACK(0, "percent-limit", &top, "percent",
1363		     "Don't show entries under that percent", parse_percent_limit),
1364	OPT_CALLBACK(0, "percentage", NULL, "relative|absolute",
1365		     "How to display percentage of filtered entries", parse_filter_percentage),
1366	OPT_STRING('w', "column-widths", &symbol_conf.col_width_list_str,
1367		   "width[,width...]",
1368		   "don't try to adjust column width, use these fixed values"),
1369	OPT_UINTEGER(0, "proc-map-timeout", &opts->proc_map_timeout,
1370			"per thread proc mmap processing timeout in ms"),
1371	OPT_CALLBACK_NOOPT('b', "branch-any", &opts->branch_stack,
1372		     "branch any", "sample any taken branches",
1373		     parse_branch_stack),
1374	OPT_CALLBACK('j', "branch-filter", &opts->branch_stack,
1375		     "branch filter mask", "branch stack filter modes",
1376		     parse_branch_stack),
1377	OPT_BOOLEAN(0, "raw-trace", &symbol_conf.raw_trace,
1378		    "Show raw trace event output (do not use print fmt or plugins)"),
1379	OPT_BOOLEAN(0, "hierarchy", &symbol_conf.report_hierarchy,
1380		    "Show entries in a hierarchy"),
 
 
1381	OPT_BOOLEAN(0, "force", &symbol_conf.force, "don't complain, do it"),
1382	OPT_UINTEGER(0, "num-thread-synthesize", &top.nr_threads_synthesize,
1383			"number of thread to run event synthesize"),
 
 
 
1384	OPT_END()
1385	};
 
1386	const char * const top_usage[] = {
1387		"perf top [<options>]",
1388		NULL
1389	};
1390	int status = hists__init();
1391
1392	if (status < 0)
1393		return status;
1394
1395	top.evlist = perf_evlist__new();
 
 
 
1396	if (top.evlist == NULL)
1397		return -ENOMEM;
1398
1399	status = perf_config(perf_top_config, &top);
1400	if (status)
1401		return status;
1402
1403	argc = parse_options(argc, argv, options, top_usage, 0);
1404	if (argc)
1405		usage_with_options(top_usage, options);
1406
1407	if (!top.evlist->nr_entries &&
1408	    perf_evlist__add_default(top.evlist) < 0) {
1409		pr_err("Not enough memory for event selector list\n");
1410		goto out_delete_evlist;
1411	}
1412
 
 
 
 
1413	if (symbol_conf.report_hierarchy) {
1414		/* disable incompatible options */
1415		symbol_conf.event_group = false;
1416		symbol_conf.cumulate_callchain = false;
1417
1418		if (field_order) {
1419			pr_err("Error: --hierarchy and --fields options cannot be used together\n");
1420			parse_options_usage(top_usage, options, "fields", 0);
1421			parse_options_usage(NULL, options, "hierarchy", 0);
1422			goto out_delete_evlist;
1423		}
1424	}
1425
 
 
 
1426	sort__mode = SORT_MODE__TOP;
1427	/* display thread wants entries to be collapsed in a different tree */
1428	perf_hpp_list.need_collapse = 1;
1429
1430	if (top.use_stdio)
1431		use_browser = 0;
1432	else if (top.use_tui)
1433		use_browser = 1;
1434
1435	setup_browser(false);
1436
1437	if (setup_sorting(top.evlist) < 0) {
1438		if (sort_order)
1439			parse_options_usage(top_usage, options, "s", 1);
1440		if (field_order)
1441			parse_options_usage(sort_order ? NULL : top_usage,
1442					    options, "fields", 0);
1443		goto out_delete_evlist;
1444	}
1445
1446	status = target__validate(target);
1447	if (status) {
1448		target__strerror(target, status, errbuf, BUFSIZ);
1449		ui__warning("%s\n", errbuf);
1450	}
1451
1452	status = target__parse_uid(target);
1453	if (status) {
1454		int saved_errno = errno;
1455
1456		target__strerror(target, status, errbuf, BUFSIZ);
1457		ui__error("%s\n", errbuf);
1458
1459		status = -saved_errno;
1460		goto out_delete_evlist;
1461	}
1462
1463	if (target__none(target))
1464		target->system_wide = true;
1465
1466	if (perf_evlist__create_maps(top.evlist, target) < 0) {
1467		ui__error("Couldn't create thread/CPU maps: %s\n",
1468			  errno == ENOENT ? "No such process" : str_error_r(errno, errbuf, sizeof(errbuf)));
1469		goto out_delete_evlist;
1470	}
1471
1472	symbol_conf.nr_events = top.evlist->nr_entries;
1473
1474	if (top.delay_secs < 1)
1475		top.delay_secs = 1;
1476
1477	if (record_opts__config(opts)) {
1478		status = -EINVAL;
1479		goto out_delete_evlist;
1480	}
1481
1482	top.sym_evsel = perf_evlist__first(top.evlist);
1483
1484	if (!callchain_param.enabled) {
1485		symbol_conf.cumulate_callchain = false;
1486		perf_hpp__cancel_cumulate();
1487	}
1488
1489	if (symbol_conf.cumulate_callchain && !callchain_param.order_set)
1490		callchain_param.order = ORDER_CALLER;
1491
1492	status = symbol__annotation_init();
1493	if (status < 0)
1494		goto out_delete_evlist;
1495
1496	annotation_config__init();
1497
1498	symbol_conf.try_vmlinux_path = (symbol_conf.vmlinux_name == NULL);
1499	if (symbol__init(NULL) < 0)
1500		return -1;
 
1501
1502	sort__setup_elide(stdout);
1503
1504	get_term_dimensions(&top.winsize);
1505	if (top.print_entries == 0) {
1506		perf_top__update_print_entries(&top);
1507		signal(SIGWINCH, winch_sig);
1508	}
1509
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1510	status = __cmd_top(&top);
1511
 
 
 
1512out_delete_evlist:
1513	perf_evlist__delete(top.evlist);
 
1514
1515	return status;
1516}
v5.4
   1// SPDX-License-Identifier: GPL-2.0-only
   2/*
   3 * builtin-top.c
   4 *
   5 * Builtin top command: Display a continuously updated profile of
   6 * any workload, CPU or specific PID.
   7 *
   8 * Copyright (C) 2008, Red Hat Inc, Ingo Molnar <mingo@redhat.com>
   9 *		 2011, Red Hat Inc, Arnaldo Carvalho de Melo <acme@redhat.com>
  10 *
  11 * Improvements and fixes by:
  12 *
  13 *   Arjan van de Ven <arjan@linux.intel.com>
  14 *   Yanmin Zhang <yanmin.zhang@intel.com>
  15 *   Wu Fengguang <fengguang.wu@intel.com>
  16 *   Mike Galbraith <efault@gmx.de>
  17 *   Paul Mackerras <paulus@samba.org>
 
 
  18 */
  19#include "builtin.h"
  20
  21#include "perf.h"
  22
  23#include "util/annotate.h"
  24#include "util/bpf-event.h"
  25#include "util/config.h"
  26#include "util/color.h"
  27#include "util/dso.h"
  28#include "util/evlist.h"
  29#include "util/evsel.h"
  30#include "util/evsel_config.h"
  31#include "util/event.h"
  32#include "util/machine.h"
  33#include "util/map.h"
  34#include "util/mmap.h"
  35#include "util/session.h"
  36#include "util/symbol.h"
  37#include "util/synthetic-events.h"
 
  38#include "util/top.h"
  39#include "util/util.h"
  40#include <linux/rbtree.h>
  41#include <subcmd/parse-options.h>
  42#include "util/parse-events.h"
  43#include "util/callchain.h"
  44#include "util/cpumap.h"
 
  45#include "util/sort.h"
  46#include "util/string2.h"
  47#include "util/term.h"
  48#include "util/intlist.h"
  49#include "util/parse-branch-options.h"
  50#include "arch/common.h"
  51#include "ui/ui.h"
  52
  53#include "util/debug.h"
  54#include "util/ordered-events.h"
  55
  56#include <assert.h>
  57#include <elf.h>
  58#include <fcntl.h>
  59
  60#include <stdio.h>
  61#include <termios.h>
  62#include <unistd.h>
  63#include <inttypes.h>
  64
  65#include <errno.h>
  66#include <time.h>
  67#include <sched.h>
  68#include <signal.h>
  69
  70#include <sys/syscall.h>
  71#include <sys/ioctl.h>
  72#include <poll.h>
  73#include <sys/prctl.h>
  74#include <sys/wait.h>
  75#include <sys/uio.h>
  76#include <sys/utsname.h>
  77#include <sys/mman.h>
  78
  79#include <linux/stringify.h>
  80#include <linux/time64.h>
  81#include <linux/types.h>
  82#include <linux/err.h>
  83
  84#include <linux/ctype.h>
  85
  86static volatile int done;
  87static volatile int resize;
  88
  89#define HEADER_LINE_NR  5
  90
  91static void perf_top__update_print_entries(struct perf_top *top)
  92{
  93	top->print_entries = top->winsize.ws_row - HEADER_LINE_NR;
  94}
  95
  96static void winch_sig(int sig __maybe_unused)
  97{
  98	resize = 1;
  99}
 100
 101static void perf_top__resize(struct perf_top *top)
 102{
 103	get_term_dimensions(&top->winsize);
 104	perf_top__update_print_entries(top);
 105}
 106
 107static int perf_top__parse_source(struct perf_top *top, struct hist_entry *he)
 108{
 109	struct evsel *evsel;
 110	struct symbol *sym;
 111	struct annotation *notes;
 112	struct map *map;
 113	int err = -1;
 114
 115	if (!he || !he->ms.sym)
 116		return -1;
 117
 118	evsel = hists_to_evsel(he->hists);
 119
 120	sym = he->ms.sym;
 121	map = he->ms.map;
 122
 123	/*
 124	 * We can't annotate with just /proc/kallsyms
 125	 */
 126	if (map->dso->symtab_type == DSO_BINARY_TYPE__KALLSYMS &&
 127	    !dso__is_kcore(map->dso)) {
 128		pr_err("Can't annotate %s: No vmlinux file was found in the "
 129		       "path\n", sym->name);
 130		sleep(1);
 131		return -1;
 132	}
 133
 134	notes = symbol__annotation(sym);
 
 
 
 
 
 135	pthread_mutex_lock(&notes->lock);
 136
 137	if (!symbol__hists(sym, top->evlist->core.nr_entries)) {
 138		pthread_mutex_unlock(&notes->lock);
 139		pr_err("Not enough memory for annotating '%s' symbol!\n",
 140		       sym->name);
 141		sleep(1);
 142		return err;
 143	}
 144
 145	err = symbol__annotate(sym, map, evsel, 0, &top->annotation_opts, NULL);
 146	if (err == 0) {
 
 147		top->sym_filter_entry = he;
 148	} else {
 149		char msg[BUFSIZ];
 150		symbol__strerror_disassemble(sym, map, err, msg, sizeof(msg));
 151		pr_err("Couldn't annotate %s: %s\n", sym->name, msg);
 152	}
 153
 154	pthread_mutex_unlock(&notes->lock);
 155	return err;
 156}
 157
 158static void __zero_source_counters(struct hist_entry *he)
 159{
 160	struct symbol *sym = he->ms.sym;
 161	symbol__annotate_zero_histograms(sym);
 162}
 163
 164static void ui__warn_map_erange(struct map *map, struct symbol *sym, u64 ip)
 165{
 166	struct utsname uts;
 167	int err = uname(&uts);
 168
 169	ui__warning("Out of bounds address found:\n\n"
 170		    "Addr:   %" PRIx64 "\n"
 171		    "DSO:    %s %c\n"
 172		    "Map:    %" PRIx64 "-%" PRIx64 "\n"
 173		    "Symbol: %" PRIx64 "-%" PRIx64 " %c %s\n"
 174		    "Arch:   %s\n"
 175		    "Kernel: %s\n"
 176		    "Tools:  %s\n\n"
 177		    "Not all samples will be on the annotation output.\n\n"
 178		    "Please report to linux-kernel@vger.kernel.org\n",
 179		    ip, map->dso->long_name, dso__symtab_origin(map->dso),
 180		    map->start, map->end, sym->start, sym->end,
 181		    sym->binding == STB_GLOBAL ? 'g' :
 182		    sym->binding == STB_LOCAL  ? 'l' : 'w', sym->name,
 183		    err ? "[unknown]" : uts.machine,
 184		    err ? "[unknown]" : uts.release, perf_version_string);
 185	if (use_browser <= 0)
 186		sleep(5);
 187
 188	map->erange_warned = true;
 189}
 190
 191static void perf_top__record_precise_ip(struct perf_top *top,
 192					struct hist_entry *he,
 193					struct perf_sample *sample,
 194					struct evsel *evsel, u64 ip)
 195{
 196	struct annotation *notes;
 197	struct symbol *sym = he->ms.sym;
 198	int err = 0;
 199
 200	if (sym == NULL || (use_browser == 0 &&
 201			    (top->sym_filter_entry == NULL ||
 202			     top->sym_filter_entry->ms.sym != sym)))
 203		return;
 204
 205	notes = symbol__annotation(sym);
 206
 207	if (pthread_mutex_trylock(&notes->lock))
 208		return;
 209
 210	err = hist_entry__inc_addr_samples(he, sample, evsel, ip);
 211
 212	pthread_mutex_unlock(&notes->lock);
 213
 214	if (unlikely(err)) {
 215		/*
 216		 * This function is now called with he->hists->lock held.
 217		 * Release it before going to sleep.
 218		 */
 219		pthread_mutex_unlock(&he->hists->lock);
 220
 221		if (err == -ERANGE && !he->ms.map->erange_warned)
 222			ui__warn_map_erange(he->ms.map, sym, ip);
 223		else if (err == -ENOMEM) {
 224			pr_err("Not enough memory for annotating '%s' symbol!\n",
 225			       sym->name);
 226			sleep(1);
 227		}
 228
 229		pthread_mutex_lock(&he->hists->lock);
 230	}
 231}
 232
 233static void perf_top__show_details(struct perf_top *top)
 234{
 235	struct hist_entry *he = top->sym_filter_entry;
 236	struct evsel *evsel;
 237	struct annotation *notes;
 238	struct symbol *symbol;
 239	int more;
 240
 241	if (!he)
 242		return;
 243
 244	evsel = hists_to_evsel(he->hists);
 245
 246	symbol = he->ms.sym;
 247	notes = symbol__annotation(symbol);
 248
 249	pthread_mutex_lock(&notes->lock);
 250
 251	symbol__calc_percent(symbol, evsel);
 252
 253	if (notes->src == NULL)
 254		goto out_unlock;
 255
 256	printf("Showing %s for %s\n", perf_evsel__name(top->sym_evsel), symbol->name);
 257	printf("  Events  Pcnt (>=%d%%)\n", top->annotation_opts.min_pcnt);
 258
 259	more = symbol__annotate_printf(symbol, he->ms.map, top->sym_evsel, &top->annotation_opts);
 
 260
 261	if (top->evlist->enabled) {
 262		if (top->zero)
 263			symbol__annotate_zero_histogram(symbol, top->sym_evsel->idx);
 264		else
 265			symbol__annotate_decay_histogram(symbol, top->sym_evsel->idx);
 266	}
 267	if (more != 0)
 268		printf("%d lines not displayed, maybe increase display entries [e]\n", more);
 269out_unlock:
 270	pthread_mutex_unlock(&notes->lock);
 271}
 272
 273static void perf_top__resort_hists(struct perf_top *t)
 274{
 275	struct evlist *evlist = t->evlist;
 276	struct evsel *pos;
 277
 278	evlist__for_each_entry(evlist, pos) {
 279		struct hists *hists = evsel__hists(pos);
 280
 281		/*
 282		 * unlink existing entries so that they can be linked
 283		 * in a correct order in hists__match() below.
 284		 */
 285		hists__unlink(hists);
 286
 287		if (evlist->enabled) {
 288			if (t->zero) {
 289				hists__delete_entries(hists);
 290			} else {
 291				hists__decay_entries(hists, t->hide_user_symbols,
 292						     t->hide_kernel_symbols);
 293			}
 294		}
 295
 296		hists__collapse_resort(hists, NULL);
 297
 298		/* Non-group events are considered as leader */
 299		if (symbol_conf.event_group &&
 300		    !perf_evsel__is_group_leader(pos)) {
 301			struct hists *leader_hists = evsel__hists(pos->leader);
 302
 303			hists__match(leader_hists, hists);
 304			hists__link(leader_hists, hists);
 305		}
 306	}
 307
 308	evlist__for_each_entry(evlist, pos) {
 309		perf_evsel__output_resort(pos, NULL);
 310	}
 311}
 312
 313static void perf_top__print_sym_table(struct perf_top *top)
 314{
 315	char bf[160];
 316	int printed = 0;
 317	const int win_width = top->winsize.ws_col - 1;
 318	struct evsel *evsel = top->sym_evsel;
 319	struct hists *hists = evsel__hists(evsel);
 320
 321	puts(CONSOLE_CLEAR);
 322
 323	perf_top__header_snprintf(top, bf, sizeof(bf));
 324	printf("%s\n", bf);
 325
 
 
 326	printf("%-*.*s\n", win_width, win_width, graph_dotted_line);
 327
 328	if (!top->record_opts.overwrite &&
 329	    (hists->stats.nr_lost_warned !=
 330	    hists->stats.nr_events[PERF_RECORD_LOST])) {
 331		hists->stats.nr_lost_warned =
 332			      hists->stats.nr_events[PERF_RECORD_LOST];
 333		color_fprintf(stdout, PERF_COLOR_RED,
 334			      "WARNING: LOST %d chunks, Check IO/CPU overload",
 335			      hists->stats.nr_lost_warned);
 336		++printed;
 337	}
 338
 339	if (top->sym_filter_entry) {
 340		perf_top__show_details(top);
 341		return;
 342	}
 343
 344	perf_top__resort_hists(top);
 
 
 
 
 
 
 
 
 
 
 345
 346	hists__output_recalc_col_len(hists, top->print_entries - printed);
 347	putchar('\n');
 348	hists__fprintf(hists, false, top->print_entries - printed, win_width,
 349		       top->min_percent, stdout, !symbol_conf.use_callchain);
 350}
 351
 352static void prompt_integer(int *target, const char *msg)
 353{
 354	char *buf = malloc(0), *p;
 355	size_t dummy = 0;
 356	int tmp;
 357
 358	fprintf(stdout, "\n%s: ", msg);
 359	if (getline(&buf, &dummy, stdin) < 0)
 360		return;
 361
 362	p = strchr(buf, '\n');
 363	if (p)
 364		*p = 0;
 365
 366	p = buf;
 367	while(*p) {
 368		if (!isdigit(*p))
 369			goto out_free;
 370		p++;
 371	}
 372	tmp = strtoul(buf, NULL, 10);
 373	*target = tmp;
 374out_free:
 375	free(buf);
 376}
 377
 378static void prompt_percent(int *target, const char *msg)
 379{
 380	int tmp = 0;
 381
 382	prompt_integer(&tmp, msg);
 383	if (tmp >= 0 && tmp <= 100)
 384		*target = tmp;
 385}
 386
 387static void perf_top__prompt_symbol(struct perf_top *top, const char *msg)
 388{
 389	char *buf = malloc(0), *p;
 390	struct hist_entry *syme = top->sym_filter_entry, *n, *found = NULL;
 391	struct hists *hists = evsel__hists(top->sym_evsel);
 392	struct rb_node *next;
 393	size_t dummy = 0;
 394
 395	/* zero counters of active symbol */
 396	if (syme) {
 397		__zero_source_counters(syme);
 398		top->sym_filter_entry = NULL;
 399	}
 400
 401	fprintf(stdout, "\n%s: ", msg);
 402	if (getline(&buf, &dummy, stdin) < 0)
 403		goto out_free;
 404
 405	p = strchr(buf, '\n');
 406	if (p)
 407		*p = 0;
 408
 409	next = rb_first_cached(&hists->entries);
 410	while (next) {
 411		n = rb_entry(next, struct hist_entry, rb_node);
 412		if (n->ms.sym && !strcmp(buf, n->ms.sym->name)) {
 413			found = n;
 414			break;
 415		}
 416		next = rb_next(&n->rb_node);
 417	}
 418
 419	if (!found) {
 420		fprintf(stderr, "Sorry, %s is not active.\n", buf);
 421		sleep(1);
 422	} else
 423		perf_top__parse_source(top, found);
 424
 425out_free:
 426	free(buf);
 427}
 428
 429static void perf_top__print_mapped_keys(struct perf_top *top)
 430{
 431	char *name = NULL;
 432
 433	if (top->sym_filter_entry) {
 434		struct symbol *sym = top->sym_filter_entry->ms.sym;
 435		name = sym->name;
 436	}
 437
 438	fprintf(stdout, "\nMapped keys:\n");
 439	fprintf(stdout, "\t[d]     display refresh delay.             \t(%d)\n", top->delay_secs);
 440	fprintf(stdout, "\t[e]     display entries (lines).           \t(%d)\n", top->print_entries);
 441
 442	if (top->evlist->core.nr_entries > 1)
 443		fprintf(stdout, "\t[E]     active event counter.              \t(%s)\n", perf_evsel__name(top->sym_evsel));
 444
 445	fprintf(stdout, "\t[f]     profile display filter (count).    \t(%d)\n", top->count_filter);
 446
 447	fprintf(stdout, "\t[F]     annotate display filter (percent). \t(%d%%)\n", top->annotation_opts.min_pcnt);
 448	fprintf(stdout, "\t[s]     annotate symbol.                   \t(%s)\n", name?: "NULL");
 449	fprintf(stdout, "\t[S]     stop annotation.\n");
 450
 451	fprintf(stdout,
 452		"\t[K]     hide kernel symbols.             \t(%s)\n",
 453		top->hide_kernel_symbols ? "yes" : "no");
 454	fprintf(stdout,
 455		"\t[U]     hide user symbols.               \t(%s)\n",
 456		top->hide_user_symbols ? "yes" : "no");
 457	fprintf(stdout, "\t[z]     toggle sample zeroing.             \t(%d)\n", top->zero ? 1 : 0);
 458	fprintf(stdout, "\t[qQ]    quit.\n");
 459}
 460
 461static int perf_top__key_mapped(struct perf_top *top, int c)
 462{
 463	switch (c) {
 464		case 'd':
 465		case 'e':
 466		case 'f':
 467		case 'z':
 468		case 'q':
 469		case 'Q':
 470		case 'K':
 471		case 'U':
 472		case 'F':
 473		case 's':
 474		case 'S':
 475			return 1;
 476		case 'E':
 477			return top->evlist->core.nr_entries > 1 ? 1 : 0;
 478		default:
 479			break;
 480	}
 481
 482	return 0;
 483}
 484
 485static bool perf_top__handle_keypress(struct perf_top *top, int c)
 486{
 487	bool ret = true;
 488
 489	if (!perf_top__key_mapped(top, c)) {
 490		struct pollfd stdin_poll = { .fd = 0, .events = POLLIN };
 491		struct termios save;
 492
 493		perf_top__print_mapped_keys(top);
 494		fprintf(stdout, "\nEnter selection, or unmapped key to continue: ");
 495		fflush(stdout);
 496
 497		set_term_quiet_input(&save);
 498
 499		poll(&stdin_poll, 1, -1);
 500		c = getc(stdin);
 501
 502		tcsetattr(0, TCSAFLUSH, &save);
 503		if (!perf_top__key_mapped(top, c))
 504			return ret;
 505	}
 506
 507	switch (c) {
 508		case 'd':
 509			prompt_integer(&top->delay_secs, "Enter display delay");
 510			if (top->delay_secs < 1)
 511				top->delay_secs = 1;
 512			break;
 513		case 'e':
 514			prompt_integer(&top->print_entries, "Enter display entries (lines)");
 515			if (top->print_entries == 0) {
 516				perf_top__resize(top);
 517				signal(SIGWINCH, winch_sig);
 518			} else {
 519				signal(SIGWINCH, SIG_DFL);
 520			}
 521			break;
 522		case 'E':
 523			if (top->evlist->core.nr_entries > 1) {
 524				/* Select 0 as the default event: */
 525				int counter = 0;
 526
 527				fprintf(stderr, "\nAvailable events:");
 528
 529				evlist__for_each_entry(top->evlist, top->sym_evsel)
 530					fprintf(stderr, "\n\t%d %s", top->sym_evsel->idx, perf_evsel__name(top->sym_evsel));
 531
 532				prompt_integer(&counter, "Enter details event counter");
 533
 534				if (counter >= top->evlist->core.nr_entries) {
 535					top->sym_evsel = evlist__first(top->evlist);
 536					fprintf(stderr, "Sorry, no such event, using %s.\n", perf_evsel__name(top->sym_evsel));
 537					sleep(1);
 538					break;
 539				}
 540				evlist__for_each_entry(top->evlist, top->sym_evsel)
 541					if (top->sym_evsel->idx == counter)
 542						break;
 543			} else
 544				top->sym_evsel = evlist__first(top->evlist);
 545			break;
 546		case 'f':
 547			prompt_integer(&top->count_filter, "Enter display event count filter");
 548			break;
 549		case 'F':
 550			prompt_percent(&top->annotation_opts.min_pcnt,
 551				       "Enter details display event filter (percent)");
 552			break;
 553		case 'K':
 554			top->hide_kernel_symbols = !top->hide_kernel_symbols;
 555			break;
 556		case 'q':
 557		case 'Q':
 558			printf("exiting.\n");
 559			if (top->dump_symtab)
 560				perf_session__fprintf_dsos(top->session, stderr);
 561			ret = false;
 562			break;
 563		case 's':
 564			perf_top__prompt_symbol(top, "Enter details symbol");
 565			break;
 566		case 'S':
 567			if (!top->sym_filter_entry)
 568				break;
 569			else {
 570				struct hist_entry *syme = top->sym_filter_entry;
 571
 572				top->sym_filter_entry = NULL;
 573				__zero_source_counters(syme);
 574			}
 575			break;
 576		case 'U':
 577			top->hide_user_symbols = !top->hide_user_symbols;
 578			break;
 579		case 'z':
 580			top->zero = !top->zero;
 581			break;
 582		default:
 583			break;
 584	}
 585
 586	return ret;
 587}
 588
 589static void perf_top__sort_new_samples(void *arg)
 590{
 591	struct perf_top *t = arg;
 
 
 
 
 592
 593	if (t->evlist->selected != NULL)
 594		t->sym_evsel = t->evlist->selected;
 595
 596	perf_top__resort_hists(t);
 597
 598	if (t->lost || t->drop)
 599		pr_warning("Too slow to read ring buffer (change period (-c/-F) or limit CPUs (-C)\n");
 600}
 
 
 
 
 
 601
 602static void stop_top(void)
 603{
 604	session_done = 1;
 605	done = 1;
 606}
 607
 608static void *display_thread_tui(void *arg)
 609{
 610	struct evsel *pos;
 611	struct perf_top *top = arg;
 612	const char *help = "For a higher level overview, try: perf top --sort comm,dso";
 613	struct hist_browser_timer hbt = {
 614		.timer		= perf_top__sort_new_samples,
 615		.arg		= top,
 616		.refresh	= top->delay_secs,
 617	};
 618
 619	/* In order to read symbols from other namespaces perf to  needs to call
 620	 * setns(2).  This isn't permitted if the struct_fs has multiple users.
 621	 * unshare(2) the fs so that we may continue to setns into namespaces
 622	 * that we're observing.
 623	 */
 624	unshare(CLONE_FS);
 625
 626	prctl(PR_SET_NAME, "perf-top-UI", 0, 0, 0);
 627
 628	perf_top__sort_new_samples(top);
 629
 630	/*
 631	 * Initialize the uid_filter_str, in the future the TUI will allow
 632	 * Zooming in/out UIDs. For now just use whatever the user passed
 633	 * via --uid.
 634	 */
 635	evlist__for_each_entry(top->evlist, pos) {
 636		struct hists *hists = evsel__hists(pos);
 637		hists->uid_filter_str = top->record_opts.target.uid_str;
 638	}
 639
 640	perf_evlist__tui_browse_hists(top->evlist, help, &hbt,
 641				      top->min_percent,
 642				      &top->session->header.env,
 643				      !top->record_opts.overwrite,
 644				      &top->annotation_opts);
 645
 646	stop_top();
 647	return NULL;
 648}
 649
 650static void display_sig(int sig __maybe_unused)
 651{
 652	stop_top();
 653}
 654
 655static void display_setup_sig(void)
 656{
 657	signal(SIGSEGV, sighandler_dump_stack);
 658	signal(SIGFPE, sighandler_dump_stack);
 659	signal(SIGINT,  display_sig);
 660	signal(SIGQUIT, display_sig);
 661	signal(SIGTERM, display_sig);
 662}
 663
 664static void *display_thread(void *arg)
 665{
 666	struct pollfd stdin_poll = { .fd = 0, .events = POLLIN };
 667	struct termios save;
 668	struct perf_top *top = arg;
 669	int delay_msecs, c;
 670
 671	/* In order to read symbols from other namespaces perf to  needs to call
 672	 * setns(2).  This isn't permitted if the struct_fs has multiple users.
 673	 * unshare(2) the fs so that we may continue to setns into namespaces
 674	 * that we're observing.
 675	 */
 676	unshare(CLONE_FS);
 677
 678	prctl(PR_SET_NAME, "perf-top-UI", 0, 0, 0);
 679
 680	display_setup_sig();
 681	pthread__unblock_sigwinch();
 682repeat:
 683	delay_msecs = top->delay_secs * MSEC_PER_SEC;
 684	set_term_quiet_input(&save);
 685	/* trash return*/
 686	getc(stdin);
 687
 688	while (!done) {
 689		perf_top__print_sym_table(top);
 690		/*
 691		 * Either timeout expired or we got an EINTR due to SIGWINCH,
 692		 * refresh screen in both cases.
 693		 */
 694		switch (poll(&stdin_poll, 1, delay_msecs)) {
 695		case 0:
 696			continue;
 697		case -1:
 698			if (errno == EINTR)
 699				continue;
 700			__fallthrough;
 701		default:
 702			c = getc(stdin);
 703			tcsetattr(0, TCSAFLUSH, &save);
 704
 705			if (perf_top__handle_keypress(top, c))
 706				goto repeat;
 707			stop_top();
 708		}
 709	}
 710
 711	tcsetattr(0, TCSAFLUSH, &save);
 712	return NULL;
 713}
 714
 715static int hist_iter__top_callback(struct hist_entry_iter *iter,
 716				   struct addr_location *al, bool single,
 717				   void *arg)
 718{
 719	struct perf_top *top = arg;
 720	struct hist_entry *he = iter->he;
 721	struct evsel *evsel = iter->evsel;
 722
 723	if (perf_hpp_list.sym && single)
 724		perf_top__record_precise_ip(top, he, iter->sample, evsel, al->addr);
 725
 726	hist__account_cycles(iter->sample->branch_stack, al, iter->sample,
 727		     !(top->record_opts.branch_stack & PERF_SAMPLE_BRANCH_ANY));
 728	return 0;
 729}
 730
 731static void perf_event__process_sample(struct perf_tool *tool,
 732				       const union perf_event *event,
 733				       struct evsel *evsel,
 734				       struct perf_sample *sample,
 735				       struct machine *machine)
 736{
 737	struct perf_top *top = container_of(tool, struct perf_top, tool);
 738	struct addr_location al;
 739	int err;
 740
 741	if (!machine && perf_guest) {
 742		static struct intlist *seen;
 743
 744		if (!seen)
 745			seen = intlist__new(NULL);
 746
 747		if (!intlist__has_entry(seen, sample->pid)) {
 748			pr_err("Can't find guest [%d]'s kernel information\n",
 749				sample->pid);
 750			intlist__add(seen, sample->pid);
 751		}
 752		return;
 753	}
 754
 755	if (!machine) {
 756		pr_err("%u unprocessable samples recorded.\r",
 757		       top->session->evlist->stats.nr_unprocessable_samples++);
 758		return;
 759	}
 760
 761	if (event->header.misc & PERF_RECORD_MISC_EXACT_IP)
 762		top->exact_samples++;
 763
 764	if (machine__resolve(machine, &al, sample) < 0)
 765		return;
 766
 767	if (!machine->kptr_restrict_warned &&
 768	    symbol_conf.kptr_restrict &&
 769	    al.cpumode == PERF_RECORD_MISC_KERNEL) {
 770		if (!perf_evlist__exclude_kernel(top->session->evlist)) {
 771			ui__warning(
 772"Kernel address maps (/proc/{kallsyms,modules}) are restricted.\n\n"
 773"Check /proc/sys/kernel/kptr_restrict and /proc/sys/kernel/perf_event_paranoid.\n\n"
 774"Kernel%s samples will not be resolved.\n",
 775			  al.map && map__has_symbols(al.map) ?
 776			  " modules" : "");
 777			if (use_browser <= 0)
 778				sleep(5);
 779		}
 780		machine->kptr_restrict_warned = true;
 781	}
 782
 783	if (al.sym == NULL && al.map != NULL) {
 784		const char *msg = "Kernel samples will not be resolved.\n";
 785		/*
 786		 * As we do lazy loading of symtabs we only will know if the
 787		 * specified vmlinux file is invalid when we actually have a
 788		 * hit in kernel space and then try to load it. So if we get
 789		 * here and there are _no_ symbols in the DSO backing the
 790		 * kernel map, bail out.
 791		 *
 792		 * We may never get here, for instance, if we use -K/
 793		 * --hide-kernel-symbols, even if the user specifies an
 794		 * invalid --vmlinux ;-)
 795		 */
 796		if (!machine->kptr_restrict_warned && !top->vmlinux_warned &&
 797		    __map__is_kernel(al.map) && map__has_symbols(al.map)) {
 
 798			if (symbol_conf.vmlinux_name) {
 799				char serr[256];
 800				dso__strerror_load(al.map->dso, serr, sizeof(serr));
 801				ui__warning("The %s file can't be used: %s\n%s",
 802					    symbol_conf.vmlinux_name, serr, msg);
 803			} else {
 804				ui__warning("A vmlinux file was not found.\n%s",
 805					    msg);
 806			}
 807
 808			if (use_browser <= 0)
 809				sleep(5);
 810			top->vmlinux_warned = true;
 811		}
 812	}
 813
 814	if (al.sym == NULL || !al.sym->idle) {
 815		struct hists *hists = evsel__hists(evsel);
 816		struct hist_entry_iter iter = {
 817			.evsel		= evsel,
 818			.sample 	= sample,
 819			.add_entry_cb 	= hist_iter__top_callback,
 820		};
 821
 822		if (symbol_conf.cumulate_callchain)
 823			iter.ops = &hist_iter_cumulative;
 824		else
 825			iter.ops = &hist_iter_normal;
 826
 827		pthread_mutex_lock(&hists->lock);
 828
 829		err = hist_entry_iter__add(&iter, &al, top->max_stack, top);
 830		if (err < 0)
 831			pr_err("Problem incrementing symbol period, skipping event\n");
 832
 833		pthread_mutex_unlock(&hists->lock);
 834	}
 835
 836	addr_location__put(&al);
 837}
 838
 839static void
 840perf_top__process_lost(struct perf_top *top, union perf_event *event,
 841		       struct evsel *evsel)
 842{
 843	struct hists *hists = evsel__hists(evsel);
 844
 845	top->lost += event->lost.lost;
 846	top->lost_total += event->lost.lost;
 847	hists->stats.total_lost += event->lost.lost;
 848}
 849
 850static void
 851perf_top__process_lost_samples(struct perf_top *top,
 852			       union perf_event *event,
 853			       struct evsel *evsel)
 854{
 855	struct hists *hists = evsel__hists(evsel);
 856
 857	top->lost += event->lost_samples.lost;
 858	top->lost_total += event->lost_samples.lost;
 859	hists->stats.total_lost_samples += event->lost_samples.lost;
 860}
 861
 862static u64 last_timestamp;
 863
 864static void perf_top__mmap_read_idx(struct perf_top *top, int idx)
 865{
 866	struct record_opts *opts = &top->record_opts;
 867	struct evlist *evlist = top->evlist;
 868	struct mmap *md;
 
 
 
 869	union perf_event *event;
 
 
 870
 871	md = opts->overwrite ? &evlist->overwrite_mmap[idx] : &evlist->mmap[idx];
 872	if (perf_mmap__read_init(md) < 0)
 873		return;
 874
 875	while ((event = perf_mmap__read_event(md)) != NULL) {
 876		int ret;
 
 
 
 
 877
 878		ret = perf_evlist__parse_sample_timestamp(evlist, event, &last_timestamp);
 879		if (ret && ret != -1)
 
 
 
 
 
 
 
 
 
 
 880			break;
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 881
 882		ret = ordered_events__queue(top->qe.in, event, last_timestamp, 0);
 883		if (ret)
 884			break;
 885
 
 
 
 
 
 
 
 
 
 886		perf_mmap__consume(md);
 887
 888		if (top->qe.rotate) {
 889			pthread_mutex_lock(&top->qe.mutex);
 890			top->qe.rotate = false;
 891			pthread_cond_signal(&top->qe.cond);
 892			pthread_mutex_unlock(&top->qe.mutex);
 893		}
 894	}
 895
 896	perf_mmap__read_done(md);
 897}
 898
 899static void perf_top__mmap_read(struct perf_top *top)
 900{
 901	bool overwrite = top->record_opts.overwrite;
 902	struct evlist *evlist = top->evlist;
 
 903	int i;
 904
 
 905	if (overwrite)
 906		perf_evlist__toggle_bkw_mmap(evlist, BKW_MMAP_DATA_PENDING);
 907
 908	for (i = 0; i < top->evlist->core.nr_mmaps; i++)
 909		perf_top__mmap_read_idx(top, i);
 910
 911	if (overwrite) {
 912		perf_evlist__toggle_bkw_mmap(evlist, BKW_MMAP_EMPTY);
 913		perf_evlist__toggle_bkw_mmap(evlist, BKW_MMAP_RUNNING);
 914	}
 
 
 
 
 
 
 
 915}
 916
 917/*
 918 * Check per-event overwrite term.
 919 * perf top should support consistent term for all events.
 920 * - All events don't have per-event term
 921 *   E.g. "cpu/cpu-cycles/,cpu/instructions/"
 922 *   Nothing change, return 0.
 923 * - All events have same per-event term
 924 *   E.g. "cpu/cpu-cycles,no-overwrite/,cpu/instructions,no-overwrite/
 925 *   Using the per-event setting to replace the opts->overwrite if
 926 *   they are different, then return 0.
 927 * - Events have different per-event term
 928 *   E.g. "cpu/cpu-cycles,overwrite/,cpu/instructions,no-overwrite/"
 929 *   Return -1
 930 * - Some of the event set per-event term, but some not.
 931 *   E.g. "cpu/cpu-cycles/,cpu/instructions,no-overwrite/"
 932 *   Return -1
 933 */
 934static int perf_top__overwrite_check(struct perf_top *top)
 935{
 936	struct record_opts *opts = &top->record_opts;
 937	struct evlist *evlist = top->evlist;
 938	struct perf_evsel_config_term *term;
 939	struct list_head *config_terms;
 940	struct evsel *evsel;
 941	int set, overwrite = -1;
 942
 943	evlist__for_each_entry(evlist, evsel) {
 944		set = -1;
 945		config_terms = &evsel->config_terms;
 946		list_for_each_entry(term, config_terms, list) {
 947			if (term->type == PERF_EVSEL__CONFIG_TERM_OVERWRITE)
 948				set = term->val.overwrite ? 1 : 0;
 949		}
 950
 951		/* no term for current and previous event (likely) */
 952		if ((overwrite < 0) && (set < 0))
 953			continue;
 954
 955		/* has term for both current and previous event, compare */
 956		if ((overwrite >= 0) && (set >= 0) && (overwrite != set))
 957			return -1;
 958
 959		/* no term for current event but has term for previous one */
 960		if ((overwrite >= 0) && (set < 0))
 961			return -1;
 962
 963		/* has term for current event */
 964		if ((overwrite < 0) && (set >= 0)) {
 965			/* if it's first event, set overwrite */
 966			if (evsel == evlist__first(evlist))
 967				overwrite = set;
 968			else
 969				return -1;
 970		}
 971	}
 972
 973	if ((overwrite >= 0) && (opts->overwrite != overwrite))
 974		opts->overwrite = overwrite;
 975
 976	return 0;
 977}
 978
 979static int perf_top_overwrite_fallback(struct perf_top *top,
 980				       struct evsel *evsel)
 981{
 982	struct record_opts *opts = &top->record_opts;
 983	struct evlist *evlist = top->evlist;
 984	struct evsel *counter;
 985
 986	if (!opts->overwrite)
 987		return 0;
 988
 989	/* only fall back when first event fails */
 990	if (evsel != evlist__first(evlist))
 991		return 0;
 992
 993	evlist__for_each_entry(evlist, counter)
 994		counter->core.attr.write_backward = false;
 995	opts->overwrite = false;
 996	pr_debug2("fall back to non-overwrite mode\n");
 997	return 1;
 998}
 999
1000static int perf_top__start_counters(struct perf_top *top)
1001{
1002	char msg[BUFSIZ];
1003	struct evsel *counter;
1004	struct evlist *evlist = top->evlist;
1005	struct record_opts *opts = &top->record_opts;
1006
1007	if (perf_top__overwrite_check(top)) {
1008		ui__error("perf top only support consistent per-event "
1009			  "overwrite setting for all events\n");
1010		goto out_err;
1011	}
1012
1013	perf_evlist__config(evlist, opts, &callchain_param);
1014
1015	evlist__for_each_entry(evlist, counter) {
1016try_again:
1017		if (evsel__open(counter, top->evlist->core.cpus,
1018				     top->evlist->core.threads) < 0) {
1019
1020			/*
1021			 * Specially handle overwrite fall back.
1022			 * Because perf top is the only tool which has
1023			 * overwrite mode by default, support
1024			 * both overwrite and non-overwrite mode, and
1025			 * require consistent mode for all events.
1026			 *
1027			 * May move it to generic code with more tools
1028			 * have similar attribute.
1029			 */
1030			if (perf_missing_features.write_backward &&
1031			    perf_top_overwrite_fallback(top, counter))
1032				goto try_again;
1033
1034			if (perf_evsel__fallback(counter, errno, msg, sizeof(msg))) {
1035				if (verbose > 0)
1036					ui__warning("%s\n", msg);
1037				goto try_again;
1038			}
1039
1040			perf_evsel__open_strerror(counter, &opts->target,
1041						  errno, msg, sizeof(msg));
1042			ui__error("%s\n", msg);
1043			goto out_err;
1044		}
1045	}
1046
1047	if (evlist__mmap(evlist, opts->mmap_pages) < 0) {
1048		ui__error("Failed to mmap with %d (%s)\n",
1049			    errno, str_error_r(errno, msg, sizeof(msg)));
1050		goto out_err;
1051	}
1052
1053	return 0;
1054
1055out_err:
1056	return -1;
1057}
1058
1059static int callchain_param__setup_sample_type(struct callchain_param *callchain)
1060{
1061	if (callchain->mode != CHAIN_NONE) {
 
 
 
 
 
1062		if (callchain_register_param(callchain) < 0) {
1063			ui__error("Can't register callchain params.\n");
1064			return -EINVAL;
1065		}
1066	}
1067
1068	return 0;
1069}
1070
1071static struct ordered_events *rotate_queues(struct perf_top *top)
1072{
1073	struct ordered_events *in = top->qe.in;
1074
1075	if (top->qe.in == &top->qe.data[1])
1076		top->qe.in = &top->qe.data[0];
1077	else
1078		top->qe.in = &top->qe.data[1];
1079
1080	return in;
1081}
1082
1083static void *process_thread(void *arg)
1084{
1085	struct perf_top *top = arg;
1086
1087	while (!done) {
1088		struct ordered_events *out, *in = top->qe.in;
1089
1090		if (!in->nr_events) {
1091			usleep(100);
1092			continue;
1093		}
1094
1095		out = rotate_queues(top);
1096
1097		pthread_mutex_lock(&top->qe.mutex);
1098		top->qe.rotate = true;
1099		pthread_cond_wait(&top->qe.cond, &top->qe.mutex);
1100		pthread_mutex_unlock(&top->qe.mutex);
1101
1102		if (ordered_events__flush(out, OE_FLUSH__TOP))
1103			pr_err("failed to process events\n");
1104	}
1105
1106	return NULL;
1107}
1108
1109/*
1110 * Allow only 'top->delay_secs' seconds behind samples.
1111 */
1112static int should_drop(struct ordered_event *qevent, struct perf_top *top)
1113{
1114	union perf_event *event = qevent->event;
1115	u64 delay_timestamp;
1116
1117	if (event->header.type != PERF_RECORD_SAMPLE)
1118		return false;
1119
1120	delay_timestamp = qevent->timestamp + top->delay_secs * NSEC_PER_SEC;
1121	return delay_timestamp < last_timestamp;
1122}
1123
1124static int deliver_event(struct ordered_events *qe,
1125			 struct ordered_event *qevent)
1126{
1127	struct perf_top *top = qe->data;
1128	struct evlist *evlist = top->evlist;
1129	struct perf_session *session = top->session;
1130	union perf_event *event = qevent->event;
1131	struct perf_sample sample;
1132	struct evsel *evsel;
1133	struct machine *machine;
1134	int ret = -1;
1135
1136	if (should_drop(qevent, top)) {
1137		top->drop++;
1138		top->drop_total++;
1139		return 0;
1140	}
1141
1142	ret = perf_evlist__parse_sample(evlist, event, &sample);
1143	if (ret) {
1144		pr_err("Can't parse sample, err = %d\n", ret);
1145		goto next_event;
1146	}
1147
1148	evsel = perf_evlist__id2evsel(session->evlist, sample.id);
1149	assert(evsel != NULL);
1150
1151	if (event->header.type == PERF_RECORD_SAMPLE) {
1152		if (evswitch__discard(&top->evswitch, evsel))
1153			return 0;
1154		++top->samples;
1155	}
1156
1157	switch (sample.cpumode) {
1158	case PERF_RECORD_MISC_USER:
1159		++top->us_samples;
1160		if (top->hide_user_symbols)
1161			goto next_event;
1162		machine = &session->machines.host;
1163		break;
1164	case PERF_RECORD_MISC_KERNEL:
1165		++top->kernel_samples;
1166		if (top->hide_kernel_symbols)
1167			goto next_event;
1168		machine = &session->machines.host;
1169		break;
1170	case PERF_RECORD_MISC_GUEST_KERNEL:
1171		++top->guest_kernel_samples;
1172		machine = perf_session__find_machine(session,
1173						     sample.pid);
1174		break;
1175	case PERF_RECORD_MISC_GUEST_USER:
1176		++top->guest_us_samples;
1177		/*
1178		 * TODO: we don't process guest user from host side
1179		 * except simple counting.
1180		 */
1181		goto next_event;
1182	default:
1183		if (event->header.type == PERF_RECORD_SAMPLE)
1184			goto next_event;
1185		machine = &session->machines.host;
1186		break;
1187	}
1188
1189	if (event->header.type == PERF_RECORD_SAMPLE) {
1190		perf_event__process_sample(&top->tool, event, evsel,
1191					   &sample, machine);
1192	} else if (event->header.type == PERF_RECORD_LOST) {
1193		perf_top__process_lost(top, event, evsel);
1194	} else if (event->header.type == PERF_RECORD_LOST_SAMPLES) {
1195		perf_top__process_lost_samples(top, event, evsel);
1196	} else if (event->header.type < PERF_RECORD_MAX) {
1197		hists__inc_nr_events(evsel__hists(evsel), event->header.type);
1198		machine__process_event(machine, event, &sample);
1199	} else
1200		++session->evlist->stats.nr_unknown_events;
1201
1202	ret = 0;
1203next_event:
1204	return ret;
1205}
1206
1207static void init_process_thread(struct perf_top *top)
1208{
1209	ordered_events__init(&top->qe.data[0], deliver_event, top);
1210	ordered_events__init(&top->qe.data[1], deliver_event, top);
1211	ordered_events__set_copy_on_queue(&top->qe.data[0], true);
1212	ordered_events__set_copy_on_queue(&top->qe.data[1], true);
1213	top->qe.in = &top->qe.data[0];
1214	pthread_mutex_init(&top->qe.mutex, NULL);
1215	pthread_cond_init(&top->qe.cond, NULL);
1216}
1217
1218static int __cmd_top(struct perf_top *top)
1219{
 
 
 
 
1220	struct record_opts *opts = &top->record_opts;
1221	pthread_t thread, thread_process;
1222	int ret;
1223
1224	if (!top->annotation_opts.objdump_path) {
1225		ret = perf_env__lookup_objdump(&top->session->header.env,
1226					       &top->annotation_opts.objdump_path);
 
 
 
1227		if (ret)
1228			return ret;
1229	}
1230
1231	ret = callchain_param__setup_sample_type(&callchain_param);
1232	if (ret)
1233		return ret;
1234
1235	if (perf_session__register_idle_thread(top->session) < 0)
1236		return ret;
1237
1238	if (top->nr_threads_synthesize > 1)
1239		perf_set_multithreaded();
1240
1241	init_process_thread(top);
1242
1243	if (opts->record_namespaces)
1244		top->tool.namespace_events = true;
1245
1246	ret = perf_event__synthesize_bpf_events(top->session, perf_event__process,
1247						&top->session->machines.host,
1248						&top->record_opts);
1249	if (ret < 0)
1250		pr_debug("Couldn't synthesize BPF events: Pre-existing BPF programs won't have symbols resolved.\n");
1251
1252	machine__synthesize_threads(&top->session->machines.host, &opts->target,
1253				    top->evlist->core.threads, false,
 
1254				    top->nr_threads_synthesize);
1255
1256	if (top->nr_threads_synthesize > 1)
1257		perf_set_singlethreaded();
1258
1259	if (perf_hpp_list.socket) {
1260		ret = perf_env__read_cpu_topology_map(&perf_env);
1261		if (ret < 0) {
1262			char errbuf[BUFSIZ];
1263			const char *err = str_error_r(-ret, errbuf, sizeof(errbuf));
1264
1265			ui__error("Could not read the CPU topology map: %s\n", err);
1266			return ret;
1267		}
1268	}
1269
1270	ret = perf_top__start_counters(top);
1271	if (ret)
1272		return ret;
 
 
 
 
 
 
 
 
1273
1274	top->session->evlist = top->evlist;
1275	perf_session__set_id_hdr_size(top->session);
1276
1277	/*
1278	 * When perf is starting the traced process, all the events (apart from
1279	 * group members) have enable_on_exec=1 set, so don't spoil it by
1280	 * prematurely enabling them.
1281	 *
1282	 * XXX 'top' still doesn't start workloads like record, trace, but should,
1283	 * so leave the check here.
1284	 */
1285        if (!target__none(&opts->target))
1286		evlist__enable(top->evlist);
 
 
 
 
 
1287
1288	ret = -1;
1289	if (pthread_create(&thread_process, NULL, process_thread, top)) {
1290		ui__error("Could not create process thread.\n");
1291		return ret;
1292	}
1293
1294	if (pthread_create(&thread, NULL, (use_browser > 0 ? display_thread_tui :
1295							    display_thread), top)) {
1296		ui__error("Could not create display thread.\n");
1297		goto out_join_thread;
1298	}
1299
1300	if (top->realtime_prio) {
1301		struct sched_param param;
1302
1303		param.sched_priority = top->realtime_prio;
1304		if (sched_setscheduler(0, SCHED_FIFO, &param)) {
1305			ui__error("Could not set realtime priority.\n");
1306			goto out_join;
1307		}
1308	}
1309
1310	/* Wait for a minimal set of events before starting the snapshot */
1311	evlist__poll(top->evlist, 100);
1312
1313	perf_top__mmap_read(top);
1314
1315	while (!done) {
1316		u64 hits = top->samples;
1317
1318		perf_top__mmap_read(top);
1319
1320		if (opts->overwrite || (hits == top->samples))
1321			ret = evlist__poll(top->evlist, 100);
1322
1323		if (resize) {
1324			perf_top__resize(top);
1325			resize = 0;
1326		}
1327	}
1328
1329	ret = 0;
1330out_join:
1331	pthread_join(thread, NULL);
1332out_join_thread:
1333	pthread_cond_signal(&top->qe.cond);
1334	pthread_join(thread_process, NULL);
 
1335	return ret;
 
 
 
 
 
 
 
 
1336}
1337
1338static int
1339callchain_opt(const struct option *opt, const char *arg, int unset)
1340{
1341	symbol_conf.use_callchain = true;
1342	return record_callchain_opt(opt, arg, unset);
1343}
1344
1345static int
1346parse_callchain_opt(const struct option *opt, const char *arg, int unset)
1347{
1348	struct callchain_param *callchain = opt->value;
1349
1350	callchain->enabled = !unset;
1351	callchain->record_mode = CALLCHAIN_FP;
1352
1353	/*
1354	 * --no-call-graph
1355	 */
1356	if (unset) {
1357		symbol_conf.use_callchain = false;
1358		callchain->record_mode = CALLCHAIN_NONE;
1359		return 0;
1360	}
1361
1362	return parse_callchain_top_opt(arg);
1363}
1364
1365static int perf_top_config(const char *var, const char *value, void *cb __maybe_unused)
1366{
1367	if (!strcmp(var, "top.call-graph")) {
1368		var = "call-graph.record-mode";
1369		return perf_default_config(var, value, cb);
1370	}
1371	if (!strcmp(var, "top.children")) {
1372		symbol_conf.cumulate_callchain = perf_config_bool(var, value);
1373		return 0;
1374	}
1375
1376	return 0;
1377}
1378
1379static int
1380parse_percent_limit(const struct option *opt, const char *arg,
1381		    int unset __maybe_unused)
1382{
1383	struct perf_top *top = opt->value;
1384
1385	top->min_percent = strtof(arg, NULL);
1386	return 0;
1387}
1388
1389const char top_callchain_help[] = CALLCHAIN_RECORD_HELP CALLCHAIN_REPORT_HELP
1390	"\n\t\t\t\tDefault: fp,graph,0.5,caller,function";
1391
1392int cmd_top(int argc, const char **argv)
1393{
1394	char errbuf[BUFSIZ];
1395	struct perf_top top = {
1396		.count_filter	     = 5,
1397		.delay_secs	     = 2,
1398		.record_opts = {
1399			.mmap_pages	= UINT_MAX,
1400			.user_freq	= UINT_MAX,
1401			.user_interval	= ULLONG_MAX,
1402			.freq		= 4000, /* 4 KHz */
1403			.target		= {
1404				.uses_mmap   = true,
1405			},
1406			/*
1407			 * FIXME: This will lose PERF_RECORD_MMAP and other metadata
1408			 * when we pause, fix that and reenable. Probably using a
1409			 * separate evlist with a dummy event, i.e. a non-overwrite
1410			 * ring buffer just for metadata events, while PERF_RECORD_SAMPLE
1411			 * stays in overwrite mode. -acme
1412			 * */
1413			.overwrite	= 0,
1414			.sample_time	= true,
1415			.sample_time_set = true,
1416		},
1417		.max_stack	     = sysctl__max_stack(),
1418		.annotation_opts     = annotation__default_options,
1419		.nr_threads_synthesize = UINT_MAX,
1420	};
1421	struct record_opts *opts = &top.record_opts;
1422	struct target *target = &opts->target;
1423	const struct option options[] = {
1424	OPT_CALLBACK('e', "event", &top.evlist, "event",
1425		     "event selector. use 'perf list' to list available events",
1426		     parse_events_option),
1427	OPT_U64('c', "count", &opts->user_interval, "event period to sample"),
1428	OPT_STRING('p', "pid", &target->pid, "pid",
1429		    "profile events on existing process id"),
1430	OPT_STRING('t', "tid", &target->tid, "tid",
1431		    "profile events on existing thread id"),
1432	OPT_BOOLEAN('a', "all-cpus", &target->system_wide,
1433			    "system-wide collection from all CPUs"),
1434	OPT_STRING('C', "cpu", &target->cpu_list, "cpu",
1435		    "list of cpus to monitor"),
1436	OPT_STRING('k', "vmlinux", &symbol_conf.vmlinux_name,
1437		   "file", "vmlinux pathname"),
1438	OPT_BOOLEAN(0, "ignore-vmlinux", &symbol_conf.ignore_vmlinux,
1439		    "don't load vmlinux even if found"),
1440	OPT_STRING(0, "kallsyms", &symbol_conf.kallsyms_name,
1441		   "file", "kallsyms pathname"),
1442	OPT_BOOLEAN('K', "hide_kernel_symbols", &top.hide_kernel_symbols,
1443		    "hide kernel symbols"),
1444	OPT_CALLBACK('m', "mmap-pages", &opts->mmap_pages, "pages",
1445		     "number of mmap data pages",
1446		     perf_evlist__parse_mmap_pages),
1447	OPT_INTEGER('r', "realtime", &top.realtime_prio,
1448		    "collect data with this RT SCHED_FIFO priority"),
1449	OPT_INTEGER('d', "delay", &top.delay_secs,
1450		    "number of seconds to delay between refreshes"),
1451	OPT_BOOLEAN('D', "dump-symtab", &top.dump_symtab,
1452			    "dump the symbol table used for profiling"),
1453	OPT_INTEGER('f', "count-filter", &top.count_filter,
1454		    "only display functions with more events than this"),
1455	OPT_BOOLEAN(0, "group", &opts->group,
1456			    "put the counters into a counter group"),
1457	OPT_BOOLEAN('i', "no-inherit", &opts->no_inherit,
1458		    "child tasks do not inherit counters"),
1459	OPT_STRING(0, "sym-annotate", &top.sym_filter, "symbol name",
1460		    "symbol to annotate"),
1461	OPT_BOOLEAN('z', "zero", &top.zero, "zero history across updates"),
1462	OPT_CALLBACK('F', "freq", &top.record_opts, "freq or 'max'",
1463		     "profile at this frequency",
1464		      record__parse_freq),
1465	OPT_INTEGER('E', "entries", &top.print_entries,
1466		    "display this many functions"),
1467	OPT_BOOLEAN('U', "hide_user_symbols", &top.hide_user_symbols,
1468		    "hide user symbols"),
1469	OPT_BOOLEAN(0, "tui", &top.use_tui, "Use the TUI interface"),
1470	OPT_BOOLEAN(0, "stdio", &top.use_stdio, "Use the stdio interface"),
1471	OPT_INCR('v', "verbose", &verbose,
1472		    "be more verbose (show counter open errors, etc)"),
1473	OPT_STRING('s', "sort", &sort_order, "key[,key2...]",
1474		   "sort by key(s): pid, comm, dso, symbol, parent, cpu, srcline, ..."
1475		   " Please refer the man page for the complete list."),
1476	OPT_STRING(0, "fields", &field_order, "key[,keys...]",
1477		   "output field(s): overhead, period, sample plus all of sort keys"),
1478	OPT_BOOLEAN('n', "show-nr-samples", &symbol_conf.show_nr_samples,
1479		    "Show a column with the number of samples"),
1480	OPT_CALLBACK_NOOPT('g', NULL, &callchain_param,
1481			   NULL, "enables call-graph recording and display",
1482			   &callchain_opt),
1483	OPT_CALLBACK(0, "call-graph", &callchain_param,
1484		     "record_mode[,record_size],print_type,threshold[,print_limit],order,sort_key[,branch]",
1485		     top_callchain_help, &parse_callchain_opt),
1486	OPT_BOOLEAN(0, "children", &symbol_conf.cumulate_callchain,
1487		    "Accumulate callchains of children and show total overhead as well"),
1488	OPT_INTEGER(0, "max-stack", &top.max_stack,
1489		    "Set the maximum stack depth when parsing the callchain. "
1490		    "Default: kernel.perf_event_max_stack or " __stringify(PERF_MAX_STACK_DEPTH)),
1491	OPT_CALLBACK(0, "ignore-callees", NULL, "regex",
1492		   "ignore callees of these functions in call graphs",
1493		   report_parse_ignore_callees_opt),
1494	OPT_BOOLEAN(0, "show-total-period", &symbol_conf.show_total_period,
1495		    "Show a column with the sum of periods"),
1496	OPT_STRING(0, "dsos", &symbol_conf.dso_list_str, "dso[,dso...]",
1497		   "only consider symbols in these dsos"),
1498	OPT_STRING(0, "comms", &symbol_conf.comm_list_str, "comm[,comm...]",
1499		   "only consider symbols in these comms"),
1500	OPT_STRING(0, "symbols", &symbol_conf.sym_list_str, "symbol[,symbol...]",
1501		   "only consider these symbols"),
1502	OPT_BOOLEAN(0, "source", &top.annotation_opts.annotate_src,
1503		    "Interleave source code with assembly code (default)"),
1504	OPT_BOOLEAN(0, "asm-raw", &top.annotation_opts.show_asm_raw,
1505		    "Display raw encoding of assembly instructions (default)"),
1506	OPT_BOOLEAN(0, "demangle-kernel", &symbol_conf.demangle_kernel,
1507		    "Enable kernel symbol demangling"),
1508	OPT_BOOLEAN(0, "no-bpf-event", &top.record_opts.no_bpf_event, "do not record bpf events"),
1509	OPT_STRING(0, "objdump", &top.annotation_opts.objdump_path, "path",
1510		    "objdump binary to use for disassembly and annotations"),
1511	OPT_STRING('M', "disassembler-style", &top.annotation_opts.disassembler_style, "disassembler style",
1512		   "Specify disassembler style (e.g. -M intel for intel syntax)"),
1513	OPT_STRING('u', "uid", &target->uid_str, "user", "user to profile"),
1514	OPT_CALLBACK(0, "percent-limit", &top, "percent",
1515		     "Don't show entries under that percent", parse_percent_limit),
1516	OPT_CALLBACK(0, "percentage", NULL, "relative|absolute",
1517		     "How to display percentage of filtered entries", parse_filter_percentage),
1518	OPT_STRING('w', "column-widths", &symbol_conf.col_width_list_str,
1519		   "width[,width...]",
1520		   "don't try to adjust column width, use these fixed values"),
1521	OPT_UINTEGER(0, "proc-map-timeout", &proc_map_timeout,
1522			"per thread proc mmap processing timeout in ms"),
1523	OPT_CALLBACK_NOOPT('b', "branch-any", &opts->branch_stack,
1524		     "branch any", "sample any taken branches",
1525		     parse_branch_stack),
1526	OPT_CALLBACK('j', "branch-filter", &opts->branch_stack,
1527		     "branch filter mask", "branch stack filter modes",
1528		     parse_branch_stack),
1529	OPT_BOOLEAN(0, "raw-trace", &symbol_conf.raw_trace,
1530		    "Show raw trace event output (do not use print fmt or plugins)"),
1531	OPT_BOOLEAN(0, "hierarchy", &symbol_conf.report_hierarchy,
1532		    "Show entries in a hierarchy"),
1533	OPT_BOOLEAN(0, "overwrite", &top.record_opts.overwrite,
1534		    "Use a backward ring buffer, default: no"),
1535	OPT_BOOLEAN(0, "force", &symbol_conf.force, "don't complain, do it"),
1536	OPT_UINTEGER(0, "num-thread-synthesize", &top.nr_threads_synthesize,
1537			"number of thread to run event synthesize"),
1538	OPT_BOOLEAN(0, "namespaces", &opts->record_namespaces,
1539		    "Record namespaces events"),
1540	OPTS_EVSWITCH(&top.evswitch),
1541	OPT_END()
1542	};
1543	struct evlist *sb_evlist = NULL;
1544	const char * const top_usage[] = {
1545		"perf top [<options>]",
1546		NULL
1547	};
1548	int status = hists__init();
1549
1550	if (status < 0)
1551		return status;
1552
1553	top.annotation_opts.min_pcnt = 5;
1554	top.annotation_opts.context  = 4;
1555
1556	top.evlist = evlist__new();
1557	if (top.evlist == NULL)
1558		return -ENOMEM;
1559
1560	status = perf_config(perf_top_config, &top);
1561	if (status)
1562		return status;
1563
1564	argc = parse_options(argc, argv, options, top_usage, 0);
1565	if (argc)
1566		usage_with_options(top_usage, options);
1567
1568	if (!top.evlist->core.nr_entries &&
1569	    perf_evlist__add_default(top.evlist) < 0) {
1570		pr_err("Not enough memory for event selector list\n");
1571		goto out_delete_evlist;
1572	}
1573
1574	status = evswitch__init(&top.evswitch, top.evlist, stderr);
1575	if (status)
1576		goto out_delete_evlist;
1577
1578	if (symbol_conf.report_hierarchy) {
1579		/* disable incompatible options */
1580		symbol_conf.event_group = false;
1581		symbol_conf.cumulate_callchain = false;
1582
1583		if (field_order) {
1584			pr_err("Error: --hierarchy and --fields options cannot be used together\n");
1585			parse_options_usage(top_usage, options, "fields", 0);
1586			parse_options_usage(NULL, options, "hierarchy", 0);
1587			goto out_delete_evlist;
1588		}
1589	}
1590
1591	if (opts->branch_stack && callchain_param.enabled)
1592		symbol_conf.show_branchflag_count = true;
1593
1594	sort__mode = SORT_MODE__TOP;
1595	/* display thread wants entries to be collapsed in a different tree */
1596	perf_hpp_list.need_collapse = 1;
1597
1598	if (top.use_stdio)
1599		use_browser = 0;
1600	else if (top.use_tui)
1601		use_browser = 1;
1602
1603	setup_browser(false);
1604
1605	if (setup_sorting(top.evlist) < 0) {
1606		if (sort_order)
1607			parse_options_usage(top_usage, options, "s", 1);
1608		if (field_order)
1609			parse_options_usage(sort_order ? NULL : top_usage,
1610					    options, "fields", 0);
1611		goto out_delete_evlist;
1612	}
1613
1614	status = target__validate(target);
1615	if (status) {
1616		target__strerror(target, status, errbuf, BUFSIZ);
1617		ui__warning("%s\n", errbuf);
1618	}
1619
1620	status = target__parse_uid(target);
1621	if (status) {
1622		int saved_errno = errno;
1623
1624		target__strerror(target, status, errbuf, BUFSIZ);
1625		ui__error("%s\n", errbuf);
1626
1627		status = -saved_errno;
1628		goto out_delete_evlist;
1629	}
1630
1631	if (target__none(target))
1632		target->system_wide = true;
1633
1634	if (perf_evlist__create_maps(top.evlist, target) < 0) {
1635		ui__error("Couldn't create thread/CPU maps: %s\n",
1636			  errno == ENOENT ? "No such process" : str_error_r(errno, errbuf, sizeof(errbuf)));
1637		goto out_delete_evlist;
1638	}
1639
 
 
1640	if (top.delay_secs < 1)
1641		top.delay_secs = 1;
1642
1643	if (record_opts__config(opts)) {
1644		status = -EINVAL;
1645		goto out_delete_evlist;
1646	}
1647
1648	top.sym_evsel = evlist__first(top.evlist);
1649
1650	if (!callchain_param.enabled) {
1651		symbol_conf.cumulate_callchain = false;
1652		perf_hpp__cancel_cumulate();
1653	}
1654
1655	if (symbol_conf.cumulate_callchain && !callchain_param.order_set)
1656		callchain_param.order = ORDER_CALLER;
1657
1658	status = symbol__annotation_init();
1659	if (status < 0)
1660		goto out_delete_evlist;
1661
1662	annotation_config__init();
1663
1664	symbol_conf.try_vmlinux_path = (symbol_conf.vmlinux_name == NULL);
1665	status = symbol__init(NULL);
1666	if (status < 0)
1667		goto out_delete_evlist;
1668
1669	sort__setup_elide(stdout);
1670
1671	get_term_dimensions(&top.winsize);
1672	if (top.print_entries == 0) {
1673		perf_top__update_print_entries(&top);
1674		signal(SIGWINCH, winch_sig);
1675	}
1676
1677	top.session = perf_session__new(NULL, false, NULL);
1678	if (IS_ERR(top.session)) {
1679		status = PTR_ERR(top.session);
1680		goto out_delete_evlist;
1681	}
1682
1683	if (!top.record_opts.no_bpf_event)
1684		bpf_event__add_sb_event(&sb_evlist, &perf_env);
1685
1686	if (perf_evlist__start_sb_thread(sb_evlist, target)) {
1687		pr_debug("Couldn't start the BPF side band thread:\nBPF programs starting from now on won't be annotatable\n");
1688		opts->no_bpf_event = true;
1689	}
1690
1691	status = __cmd_top(&top);
1692
1693	if (!opts->no_bpf_event)
1694		perf_evlist__stop_sb_thread(sb_evlist);
1695
1696out_delete_evlist:
1697	evlist__delete(top.evlist);
1698	perf_session__delete(top.session);
1699
1700	return status;
1701}