evlist.c 39.2 KB
Newer Older
1 2 3 4 5 6 7 8
/*
 * Copyright (C) 2011, Red Hat Inc, Arnaldo Carvalho de Melo <acme@redhat.com>
 *
 * Parts came from builtin-{top,stat,record}.c, see those files for further
 * copyright notes.
 *
 * Released under the GPL v2. (and only v2, not any later version)
 */
9
#include "util.h"
10
#include <api/fs/fs.h>
11
#include <poll.h>
12 13
#include "cpumap.h"
#include "thread_map.h"
14
#include "target.h"
15 16
#include "evlist.h"
#include "evsel.h"
A
Adrian Hunter 已提交
17
#include "debug.h"
18
#include <unistd.h>
19

20
#include "parse-events.h"
21
#include "parse-options.h"
22

23 24
#include <sys/mman.h>

25 26
#include <linux/bitops.h>
#include <linux/hash.h>
27
#include <linux/log2.h>
28

29 30 31
static void perf_evlist__mmap_put(struct perf_evlist *evlist, int idx);
static void __perf_evlist__munmap(struct perf_evlist *evlist, int idx);

32
#define FD(e, x, y) (*(int *)xyarray__entry(e->fd, x, y))
33
#define SID(e, x, y) xyarray__entry(e->sample_id, x, y)
34

35 36
void perf_evlist__init(struct perf_evlist *evlist, struct cpu_map *cpus,
		       struct thread_map *threads)
37 38 39 40 41 42
{
	int i;

	for (i = 0; i < PERF_EVLIST__HLIST_SIZE; ++i)
		INIT_HLIST_HEAD(&evlist->heads[i]);
	INIT_LIST_HEAD(&evlist->entries);
43
	perf_evlist__set_maps(evlist, cpus, threads);
44
	fdarray__init(&evlist->pollfd, 64);
45
	evlist->workload.pid = -1;
46 47
}

48
struct perf_evlist *perf_evlist__new(void)
49 50 51
{
	struct perf_evlist *evlist = zalloc(sizeof(*evlist));

52
	if (evlist != NULL)
53
		perf_evlist__init(evlist, NULL, NULL);
54 55 56 57

	return evlist;
}

58 59 60 61 62 63 64 65 66 67 68 69
struct perf_evlist *perf_evlist__new_default(void)
{
	struct perf_evlist *evlist = perf_evlist__new();

	if (evlist && perf_evlist__add_default(evlist)) {
		perf_evlist__delete(evlist);
		evlist = NULL;
	}

	return evlist;
}

70 71 72 73 74 75 76 77 78 79 80 81 82 83 84
/**
 * perf_evlist__set_id_pos - set the positions of event ids.
 * @evlist: selected event list
 *
 * Events with compatible sample types all have the same id_pos
 * and is_pos.  For convenience, put a copy on evlist.
 */
void perf_evlist__set_id_pos(struct perf_evlist *evlist)
{
	struct perf_evsel *first = perf_evlist__first(evlist);

	evlist->id_pos = first->id_pos;
	evlist->is_pos = first->is_pos;
}

85 86 87 88
static void perf_evlist__update_id_pos(struct perf_evlist *evlist)
{
	struct perf_evsel *evsel;

89
	evlist__for_each(evlist, evsel)
90 91 92 93 94
		perf_evsel__calc_id_pos(evsel);

	perf_evlist__set_id_pos(evlist);
}

95 96 97 98
static void perf_evlist__purge(struct perf_evlist *evlist)
{
	struct perf_evsel *pos, *n;

99
	evlist__for_each_safe(evlist, n, pos) {
100
		list_del_init(&pos->node);
101
		pos->evlist = NULL;
102 103 104 105 106 107
		perf_evsel__delete(pos);
	}

	evlist->nr_entries = 0;
}

108
void perf_evlist__exit(struct perf_evlist *evlist)
109
{
110
	zfree(&evlist->mmap);
111
	fdarray__exit(&evlist->pollfd);
112 113 114 115
}

void perf_evlist__delete(struct perf_evlist *evlist)
{
116
	perf_evlist__munmap(evlist);
117
	perf_evlist__close(evlist);
118
	cpu_map__put(evlist->cpus);
119
	thread_map__put(evlist->threads);
120 121
	evlist->cpus = NULL;
	evlist->threads = NULL;
122 123
	perf_evlist__purge(evlist);
	perf_evlist__exit(evlist);
124 125 126 127 128
	free(evlist);
}

void perf_evlist__add(struct perf_evlist *evlist, struct perf_evsel *entry)
{
129
	entry->evlist = evlist;
130
	list_add_tail(&entry->node, &evlist->entries);
131
	entry->idx = evlist->nr_entries;
132
	entry->tracking = !entry->idx;
133

134 135
	if (!evlist->nr_entries++)
		perf_evlist__set_id_pos(evlist);
136 137
}

138 139 140
void perf_evlist__splice_list_tail(struct perf_evlist *evlist,
				   struct list_head *list,
				   int nr_entries)
141
{
142 143
	bool set_id_pos = !evlist->nr_entries;

144 145
	list_splice_tail(list, &evlist->entries);
	evlist->nr_entries += nr_entries;
146 147
	if (set_id_pos)
		perf_evlist__set_id_pos(evlist);
148 149
}

150 151 152 153 154
void __perf_evlist__set_leader(struct list_head *list)
{
	struct perf_evsel *evsel, *leader;

	leader = list_entry(list->next, struct perf_evsel, node);
155 156 157
	evsel = list_entry(list->prev, struct perf_evsel, node);

	leader->nr_members = evsel->idx - leader->idx + 1;
158

159
	__evlist__for_each(list, evsel) {
160
		evsel->leader = leader;
161 162 163 164
	}
}

void perf_evlist__set_leader(struct perf_evlist *evlist)
165
{
166 167
	if (evlist->nr_entries) {
		evlist->nr_groups = evlist->nr_entries > 1 ? 1 : 0;
168
		__perf_evlist__set_leader(&evlist->entries);
169
	}
170 171
}

172 173 174 175 176 177
int perf_evlist__add_default(struct perf_evlist *evlist)
{
	struct perf_event_attr attr = {
		.type = PERF_TYPE_HARDWARE,
		.config = PERF_COUNT_HW_CPU_CYCLES,
	};
178 179 180
	struct perf_evsel *evsel;

	event_attr_init(&attr);
181

182
	evsel = perf_evsel__new(&attr);
183
	if (evsel == NULL)
184 185 186 187 188 189
		goto error;

	/* use strdup() because free(evsel) assumes name is allocated */
	evsel->name = strdup("cycles");
	if (!evsel->name)
		goto error_free;
190 191 192

	perf_evlist__add(evlist, evsel);
	return 0;
193 194 195 196
error_free:
	perf_evsel__delete(evsel);
error:
	return -ENOMEM;
197
}
198

199 200
static int perf_evlist__add_attrs(struct perf_evlist *evlist,
				  struct perf_event_attr *attrs, size_t nr_attrs)
201 202 203 204 205 206
{
	struct perf_evsel *evsel, *n;
	LIST_HEAD(head);
	size_t i;

	for (i = 0; i < nr_attrs; i++) {
207
		evsel = perf_evsel__new_idx(attrs + i, evlist->nr_entries + i);
208 209 210 211 212 213 214 215 216 217
		if (evsel == NULL)
			goto out_delete_partial_list;
		list_add_tail(&evsel->node, &head);
	}

	perf_evlist__splice_list_tail(evlist, &head, nr_attrs);

	return 0;

out_delete_partial_list:
218
	__evlist__for_each_safe(&head, n, evsel)
219 220 221 222
		perf_evsel__delete(evsel);
	return -1;
}

223 224 225 226 227 228 229 230 231 232 233
int __perf_evlist__add_default_attrs(struct perf_evlist *evlist,
				     struct perf_event_attr *attrs, size_t nr_attrs)
{
	size_t i;

	for (i = 0; i < nr_attrs; i++)
		event_attr_init(attrs + i);

	return perf_evlist__add_attrs(evlist, attrs, nr_attrs);
}

234 235
struct perf_evsel *
perf_evlist__find_tracepoint_by_id(struct perf_evlist *evlist, int id)
236 237 238
{
	struct perf_evsel *evsel;

239
	evlist__for_each(evlist, evsel) {
240 241 242 243 244 245 246 247
		if (evsel->attr.type   == PERF_TYPE_TRACEPOINT &&
		    (int)evsel->attr.config == id)
			return evsel;
	}

	return NULL;
}

248 249 250 251 252 253
struct perf_evsel *
perf_evlist__find_tracepoint_by_name(struct perf_evlist *evlist,
				     const char *name)
{
	struct perf_evsel *evsel;

254
	evlist__for_each(evlist, evsel) {
255 256 257 258 259 260 261 262
		if ((evsel->attr.type == PERF_TYPE_TRACEPOINT) &&
		    (strcmp(evsel->name, name) == 0))
			return evsel;
	}

	return NULL;
}

263 264 265
int perf_evlist__add_newtp(struct perf_evlist *evlist,
			   const char *sys, const char *name, void *handler)
{
266
	struct perf_evsel *evsel = perf_evsel__newtp(sys, name);
267 268 269 270

	if (evsel == NULL)
		return -1;

271
	evsel->handler = handler;
272 273 274 275
	perf_evlist__add(evlist, evsel);
	return 0;
}

276 277 278 279 280 281 282 283 284
static int perf_evlist__nr_threads(struct perf_evlist *evlist,
				   struct perf_evsel *evsel)
{
	if (evsel->system_wide)
		return 1;
	else
		return thread_map__nr(evlist->threads);
}

285 286 287 288
void perf_evlist__disable(struct perf_evlist *evlist)
{
	int cpu, thread;
	struct perf_evsel *pos;
289
	int nr_cpus = cpu_map__nr(evlist->cpus);
290
	int nr_threads;
291

292
	for (cpu = 0; cpu < nr_cpus; cpu++) {
293
		evlist__for_each(evlist, pos) {
294
			if (!perf_evsel__is_group_leader(pos) || !pos->fd)
295
				continue;
296
			nr_threads = perf_evlist__nr_threads(evlist, pos);
297
			for (thread = 0; thread < nr_threads; thread++)
298 299
				ioctl(FD(pos, cpu, thread),
				      PERF_EVENT_IOC_DISABLE, 0);
300 301
		}
	}
302 303

	evlist->enabled = false;
304 305
}

306 307 308 309
void perf_evlist__enable(struct perf_evlist *evlist)
{
	int cpu, thread;
	struct perf_evsel *pos;
310
	int nr_cpus = cpu_map__nr(evlist->cpus);
311
	int nr_threads;
312

313
	for (cpu = 0; cpu < nr_cpus; cpu++) {
314
		evlist__for_each(evlist, pos) {
315
			if (!perf_evsel__is_group_leader(pos) || !pos->fd)
316
				continue;
317
			nr_threads = perf_evlist__nr_threads(evlist, pos);
318
			for (thread = 0; thread < nr_threads; thread++)
319 320
				ioctl(FD(pos, cpu, thread),
				      PERF_EVENT_IOC_ENABLE, 0);
321 322
		}
	}
323 324 325 326 327 328 329

	evlist->enabled = true;
}

void perf_evlist__toggle_enable(struct perf_evlist *evlist)
{
	(evlist->enabled ? perf_evlist__disable : perf_evlist__enable)(evlist);
330 331
}

332 333 334 335
int perf_evlist__disable_event(struct perf_evlist *evlist,
			       struct perf_evsel *evsel)
{
	int cpu, thread, err;
336 337
	int nr_cpus = cpu_map__nr(evlist->cpus);
	int nr_threads = perf_evlist__nr_threads(evlist, evsel);
338 339 340 341

	if (!evsel->fd)
		return 0;

342 343
	for (cpu = 0; cpu < nr_cpus; cpu++) {
		for (thread = 0; thread < nr_threads; thread++) {
344 345 346 347 348 349 350 351 352 353 354 355 356
			err = ioctl(FD(evsel, cpu, thread),
				    PERF_EVENT_IOC_DISABLE, 0);
			if (err)
				return err;
		}
	}
	return 0;
}

int perf_evlist__enable_event(struct perf_evlist *evlist,
			      struct perf_evsel *evsel)
{
	int cpu, thread, err;
357 358
	int nr_cpus = cpu_map__nr(evlist->cpus);
	int nr_threads = perf_evlist__nr_threads(evlist, evsel);
359 360 361 362

	if (!evsel->fd)
		return -EINVAL;

363 364
	for (cpu = 0; cpu < nr_cpus; cpu++) {
		for (thread = 0; thread < nr_threads; thread++) {
365 366 367 368 369 370 371 372 373
			err = ioctl(FD(evsel, cpu, thread),
				    PERF_EVENT_IOC_ENABLE, 0);
			if (err)
				return err;
		}
	}
	return 0;
}

374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420
static int perf_evlist__enable_event_cpu(struct perf_evlist *evlist,
					 struct perf_evsel *evsel, int cpu)
{
	int thread, err;
	int nr_threads = perf_evlist__nr_threads(evlist, evsel);

	if (!evsel->fd)
		return -EINVAL;

	for (thread = 0; thread < nr_threads; thread++) {
		err = ioctl(FD(evsel, cpu, thread),
			    PERF_EVENT_IOC_ENABLE, 0);
		if (err)
			return err;
	}
	return 0;
}

static int perf_evlist__enable_event_thread(struct perf_evlist *evlist,
					    struct perf_evsel *evsel,
					    int thread)
{
	int cpu, err;
	int nr_cpus = cpu_map__nr(evlist->cpus);

	if (!evsel->fd)
		return -EINVAL;

	for (cpu = 0; cpu < nr_cpus; cpu++) {
		err = ioctl(FD(evsel, cpu, thread), PERF_EVENT_IOC_ENABLE, 0);
		if (err)
			return err;
	}
	return 0;
}

int perf_evlist__enable_event_idx(struct perf_evlist *evlist,
				  struct perf_evsel *evsel, int idx)
{
	bool per_cpu_mmaps = !cpu_map__empty(evlist->cpus);

	if (per_cpu_mmaps)
		return perf_evlist__enable_event_cpu(evlist, evsel, idx);
	else
		return perf_evlist__enable_event_thread(evlist, evsel, idx);
}

421
int perf_evlist__alloc_pollfd(struct perf_evlist *evlist)
422
{
423 424
	int nr_cpus = cpu_map__nr(evlist->cpus);
	int nr_threads = thread_map__nr(evlist->threads);
425 426 427
	int nfds = 0;
	struct perf_evsel *evsel;

428
	evlist__for_each(evlist, evsel) {
429 430 431 432 433 434
		if (evsel->system_wide)
			nfds += nr_cpus;
		else
			nfds += nr_cpus * nr_threads;
	}

435 436
	if (fdarray__available_entries(&evlist->pollfd) < nfds &&
	    fdarray__grow(&evlist->pollfd, nfds) < 0)
437 438 439
		return -ENOMEM;

	return 0;
440
}
441

442 443 444 445 446 447 448 449 450 451 452 453 454 455 456 457
static int __perf_evlist__add_pollfd(struct perf_evlist *evlist, int fd, int idx)
{
	int pos = fdarray__add(&evlist->pollfd, fd, POLLIN | POLLERR | POLLHUP);
	/*
	 * Save the idx so that when we filter out fds POLLHUP'ed we can
	 * close the associated evlist->mmap[] entry.
	 */
	if (pos >= 0) {
		evlist->pollfd.priv[pos].idx = idx;

		fcntl(fd, F_SETFL, O_NONBLOCK);
	}

	return pos;
}

458
int perf_evlist__add_pollfd(struct perf_evlist *evlist, int fd)
459
{
460 461 462 463 464 465
	return __perf_evlist__add_pollfd(evlist, fd, -1);
}

static void perf_evlist__munmap_filtered(struct fdarray *fda, int fd)
{
	struct perf_evlist *evlist = container_of(fda, struct perf_evlist, pollfd);
466

467
	perf_evlist__mmap_put(evlist, fda->priv[fd].idx);
468
}
469

470 471
int perf_evlist__filter_pollfd(struct perf_evlist *evlist, short revents_and_mask)
{
472 473
	return fdarray__filter(&evlist->pollfd, revents_and_mask,
			       perf_evlist__munmap_filtered);
474 475
}

476 477
int perf_evlist__poll(struct perf_evlist *evlist, int timeout)
{
478
	return fdarray__poll(&evlist->pollfd, timeout);
479 480
}

481 482 483
static void perf_evlist__id_hash(struct perf_evlist *evlist,
				 struct perf_evsel *evsel,
				 int cpu, int thread, u64 id)
484 485 486 487 488 489 490 491 492 493
{
	int hash;
	struct perf_sample_id *sid = SID(evsel, cpu, thread);

	sid->id = id;
	sid->evsel = evsel;
	hash = hash_64(sid->id, PERF_EVLIST__HLIST_BITS);
	hlist_add_head(&sid->node, &evlist->heads[hash]);
}

494 495 496 497 498 499 500 501 502 503
void perf_evlist__id_add(struct perf_evlist *evlist, struct perf_evsel *evsel,
			 int cpu, int thread, u64 id)
{
	perf_evlist__id_hash(evlist, evsel, cpu, thread, id);
	evsel->id[evsel->ids++] = id;
}

static int perf_evlist__id_add_fd(struct perf_evlist *evlist,
				  struct perf_evsel *evsel,
				  int cpu, int thread, int fd)
504 505
{
	u64 read_data[4] = { 0, };
506
	int id_idx = 1; /* The first entry is the counter value */
507 508 509 510 511 512 513 514 515 516 517
	u64 id;
	int ret;

	ret = ioctl(fd, PERF_EVENT_IOC_ID, &id);
	if (!ret)
		goto add;

	if (errno != ENOTTY)
		return -1;

	/* Legacy way to get event id.. All hail to old kernels! */
518

519 520 521 522 523 524 525
	/*
	 * This way does not work with group format read, so bail
	 * out in that case.
	 */
	if (perf_evlist__read_format(evlist) & PERF_FORMAT_GROUP)
		return -1;

526 527 528 529 530 531 532 533 534
	if (!(evsel->attr.read_format & PERF_FORMAT_ID) ||
	    read(fd, &read_data, sizeof(read_data)) == -1)
		return -1;

	if (evsel->attr.read_format & PERF_FORMAT_TOTAL_TIME_ENABLED)
		++id_idx;
	if (evsel->attr.read_format & PERF_FORMAT_TOTAL_TIME_RUNNING)
		++id_idx;

535 536 537 538
	id = read_data[id_idx];

 add:
	perf_evlist__id_add(evlist, evsel, cpu, thread, id);
539 540 541
	return 0;
}

A
Adrian Hunter 已提交
542 543 544 545 546 547 548 549 550 551 552
static void perf_evlist__set_sid_idx(struct perf_evlist *evlist,
				     struct perf_evsel *evsel, int idx, int cpu,
				     int thread)
{
	struct perf_sample_id *sid = SID(evsel, cpu, thread);
	sid->idx = idx;
	if (evlist->cpus && cpu >= 0)
		sid->cpu = evlist->cpus->map[cpu];
	else
		sid->cpu = -1;
	if (!evsel->system_wide && evlist->threads && thread >= 0)
553
		sid->tid = thread_map__pid(evlist->threads, thread);
A
Adrian Hunter 已提交
554 555 556 557
	else
		sid->tid = -1;
}

558
struct perf_sample_id *perf_evlist__id2sid(struct perf_evlist *evlist, u64 id)
559 560 561 562 563 564 565 566
{
	struct hlist_head *head;
	struct perf_sample_id *sid;
	int hash;

	hash = hash_64(id, PERF_EVLIST__HLIST_BITS);
	head = &evlist->heads[hash];

567
	hlist_for_each_entry(sid, head, node)
568
		if (sid->id == id)
569 570 571 572 573 574 575 576 577
			return sid;

	return NULL;
}

struct perf_evsel *perf_evlist__id2evsel(struct perf_evlist *evlist, u64 id)
{
	struct perf_sample_id *sid;

578
	if (evlist->nr_entries == 1 || !id)
579 580 581 582 583
		return perf_evlist__first(evlist);

	sid = perf_evlist__id2sid(evlist, id);
	if (sid)
		return sid->evsel;
584 585

	if (!perf_evlist__sample_id_all(evlist))
586
		return perf_evlist__first(evlist);
587

588 589
	return NULL;
}
590

591 592 593 594 595 596 597 598 599 600 601 602 603 604 605 606 607 608 609 610 611 612 613 614
static int perf_evlist__event2id(struct perf_evlist *evlist,
				 union perf_event *event, u64 *id)
{
	const u64 *array = event->sample.array;
	ssize_t n;

	n = (event->header.size - sizeof(event->header)) >> 3;

	if (event->header.type == PERF_RECORD_SAMPLE) {
		if (evlist->id_pos >= n)
			return -1;
		*id = array[evlist->id_pos];
	} else {
		if (evlist->is_pos > n)
			return -1;
		n -= evlist->is_pos;
		*id = array[n];
	}
	return 0;
}

static struct perf_evsel *perf_evlist__event2evsel(struct perf_evlist *evlist,
						   union perf_event *event)
{
615
	struct perf_evsel *first = perf_evlist__first(evlist);
616 617 618 619 620 621
	struct hlist_head *head;
	struct perf_sample_id *sid;
	int hash;
	u64 id;

	if (evlist->nr_entries == 1)
622 623 624 625 626
		return first;

	if (!first->attr.sample_id_all &&
	    event->header.type != PERF_RECORD_SAMPLE)
		return first;
627 628 629 630 631 632

	if (perf_evlist__event2id(evlist, event, &id))
		return NULL;

	/* Synthesized events have an id of zero */
	if (!id)
633
		return first;
634 635 636 637 638 639 640 641 642 643 644

	hash = hash_64(id, PERF_EVLIST__HLIST_BITS);
	head = &evlist->heads[hash];

	hlist_for_each_entry(sid, head, node) {
		if (sid->id == id)
			return sid->evsel;
	}
	return NULL;
}

645
union perf_event *perf_evlist__mmap_read(struct perf_evlist *evlist, int idx)
646
{
647
	struct perf_mmap *md = &evlist->mmap[idx];
648
	u64 head;
649
	u64 old = md->prev;
650
	unsigned char *data = md->base + page_size;
651
	union perf_event *event = NULL;
652

653 654 655 656 657 658 659
	/*
	 * Check if event was unmapped due to a POLLHUP/POLLERR.
	 */
	if (!atomic_read(&md->refcnt))
		return NULL;

	head = perf_mmap__read_head(md);
660
	if (evlist->overwrite) {
661
		/*
662 663 664 665 666 667
		 * If we're further behind than half the buffer, there's a chance
		 * the writer will bite our tail and mess up the samples under us.
		 *
		 * If we somehow ended up ahead of the head, we got messed up.
		 *
		 * In either case, truncate and restart at head.
668
		 */
669 670 671 672 673 674 675 676 677
		int diff = head - old;
		if (diff > md->mask / 2 || diff < 0) {
			fprintf(stderr, "WARNING: failed to keep up with mmap data.\n");

			/*
			 * head points to a known good entry, start there.
			 */
			old = head;
		}
678 679 680 681 682
	}

	if (old != head) {
		size_t size;

683
		event = (union perf_event *)&data[old & md->mask];
684 685 686 687 688 689 690 691 692
		size = event->header.size;

		/*
		 * Event straddles the mmap boundary -- header should always
		 * be inside due to u64 alignment of output.
		 */
		if ((old & md->mask) + size != ((old + size) & md->mask)) {
			unsigned int offset = old;
			unsigned int len = min(sizeof(*event), size), cpy;
693
			void *dst = md->event_copy;
694 695 696 697 698 699 700 701 702

			do {
				cpy = min(md->mask + 1 - (offset & md->mask), len);
				memcpy(dst, &data[offset & md->mask], cpy);
				offset += cpy;
				dst += cpy;
				len -= cpy;
			} while (len);

703
			event = (union perf_event *) md->event_copy;
704 705 706 707 708 709
		}

		old += size;
	}

	md->prev = old;
710

711 712
	return event;
}
713

714 715
static bool perf_mmap__empty(struct perf_mmap *md)
{
716
	return perf_mmap__read_head(md) == md->prev && !md->auxtrace_mmap.base;
717 718 719 720
}

static void perf_evlist__mmap_get(struct perf_evlist *evlist, int idx)
{
721
	atomic_inc(&evlist->mmap[idx].refcnt);
722 723 724 725
}

static void perf_evlist__mmap_put(struct perf_evlist *evlist, int idx)
{
726
	BUG_ON(atomic_read(&evlist->mmap[idx].refcnt) == 0);
727

728
	if (atomic_dec_and_test(&evlist->mmap[idx].refcnt))
729 730 731
		__perf_evlist__munmap(evlist, idx);
}

732 733
void perf_evlist__mmap_consume(struct perf_evlist *evlist, int idx)
{
734 735
	struct perf_mmap *md = &evlist->mmap[idx];

736
	if (!evlist->overwrite) {
737
		u64 old = md->prev;
738 739 740

		perf_mmap__write_tail(md, old);
	}
741

742
	if (atomic_read(&md->refcnt) == 1 && perf_mmap__empty(md))
743
		perf_evlist__mmap_put(evlist, idx);
744 745
}

746 747 748 749 750 751 752 753 754 755 756 757 758 759 760 761 762 763 764 765 766 767 768 769 770 771 772 773
int __weak auxtrace_mmap__mmap(struct auxtrace_mmap *mm __maybe_unused,
			       struct auxtrace_mmap_params *mp __maybe_unused,
			       void *userpg __maybe_unused,
			       int fd __maybe_unused)
{
	return 0;
}

void __weak auxtrace_mmap__munmap(struct auxtrace_mmap *mm __maybe_unused)
{
}

void __weak auxtrace_mmap_params__init(
			struct auxtrace_mmap_params *mp __maybe_unused,
			off_t auxtrace_offset __maybe_unused,
			unsigned int auxtrace_pages __maybe_unused,
			bool auxtrace_overwrite __maybe_unused)
{
}

void __weak auxtrace_mmap_params__set_idx(
			struct auxtrace_mmap_params *mp __maybe_unused,
			struct perf_evlist *evlist __maybe_unused,
			int idx __maybe_unused,
			bool per_cpu __maybe_unused)
{
}

774 775 776 777 778
static void __perf_evlist__munmap(struct perf_evlist *evlist, int idx)
{
	if (evlist->mmap[idx].base != NULL) {
		munmap(evlist->mmap[idx].base, evlist->mmap_len);
		evlist->mmap[idx].base = NULL;
779
		atomic_set(&evlist->mmap[idx].refcnt, 0);
780
	}
781
	auxtrace_mmap__munmap(&evlist->mmap[idx].auxtrace_mmap);
782 783
}

784
void perf_evlist__munmap(struct perf_evlist *evlist)
785
{
786
	int i;
787

788 789 790
	if (evlist->mmap == NULL)
		return;

791 792
	for (i = 0; i < evlist->nr_mmaps; i++)
		__perf_evlist__munmap(evlist, i);
793

794
	zfree(&evlist->mmap);
795 796
}

797
static int perf_evlist__alloc_mmap(struct perf_evlist *evlist)
798
{
799
	evlist->nr_mmaps = cpu_map__nr(evlist->cpus);
800
	if (cpu_map__empty(evlist->cpus))
801
		evlist->nr_mmaps = thread_map__nr(evlist->threads);
802
	evlist->mmap = zalloc(evlist->nr_mmaps * sizeof(struct perf_mmap));
803 804 805
	return evlist->mmap != NULL ? 0 : -ENOMEM;
}

806 807 808
struct mmap_params {
	int prot;
	int mask;
809
	struct auxtrace_mmap_params auxtrace_mp;
810 811 812 813
};

static int __perf_evlist__mmap(struct perf_evlist *evlist, int idx,
			       struct mmap_params *mp, int fd)
814
{
815 816 817 818 819 820 821 822 823 824 825 826 827
	/*
	 * The last one will be done at perf_evlist__mmap_consume(), so that we
	 * make sure we don't prevent tools from consuming every last event in
	 * the ring buffer.
	 *
	 * I.e. we can get the POLLHUP meaning that the fd doesn't exist
	 * anymore, but the last events for it are still in the ring buffer,
	 * waiting to be consumed.
	 *
	 * Tools can chose to ignore this at their own discretion, but the
	 * evlist layer can't just drop it when filtering events in
	 * perf_evlist__filter_pollfd().
	 */
828
	atomic_set(&evlist->mmap[idx].refcnt, 2);
829
	evlist->mmap[idx].prev = 0;
830 831
	evlist->mmap[idx].mask = mp->mask;
	evlist->mmap[idx].base = mmap(NULL, evlist->mmap_len, mp->prot,
832
				      MAP_SHARED, fd, 0);
833
	if (evlist->mmap[idx].base == MAP_FAILED) {
834 835
		pr_debug2("failed to mmap perf event ring buffer, error %d\n",
			  errno);
836
		evlist->mmap[idx].base = NULL;
837
		return -1;
838
	}
839

840 841 842 843
	if (auxtrace_mmap__mmap(&evlist->mmap[idx].auxtrace_mmap,
				&mp->auxtrace_mp, evlist->mmap[idx].base, fd))
		return -1;

844 845 846
	return 0;
}

847
static int perf_evlist__mmap_per_evsel(struct perf_evlist *evlist, int idx,
848 849
				       struct mmap_params *mp, int cpu,
				       int thread, int *output)
850 851
{
	struct perf_evsel *evsel;
852

853
	evlist__for_each(evlist, evsel) {
854 855 856 857 858 859
		int fd;

		if (evsel->system_wide && thread)
			continue;

		fd = FD(evsel, cpu, thread);
860 861 862

		if (*output == -1) {
			*output = fd;
863
			if (__perf_evlist__mmap(evlist, idx, mp, *output) < 0)
864 865 866 867
				return -1;
		} else {
			if (ioctl(fd, PERF_EVENT_IOC_SET_OUTPUT, *output) != 0)
				return -1;
868 869

			perf_evlist__mmap_get(evlist, idx);
870 871
		}

872 873 874 875 876 877 878 879 880
		/*
		 * The system_wide flag causes a selected event to be opened
		 * always without a pid.  Consequently it will never get a
		 * POLLHUP, but it is used for tracking in combination with
		 * other events, so it should not need to be polled anyway.
		 * Therefore don't add it for polling.
		 */
		if (!evsel->system_wide &&
		    __perf_evlist__add_pollfd(evlist, fd, idx) < 0) {
881
			perf_evlist__mmap_put(evlist, idx);
882
			return -1;
883
		}
884

A
Adrian Hunter 已提交
885 886 887 888 889 890 891
		if (evsel->attr.read_format & PERF_FORMAT_ID) {
			if (perf_evlist__id_add_fd(evlist, evsel, cpu, thread,
						   fd) < 0)
				return -1;
			perf_evlist__set_sid_idx(evlist, evsel, idx, cpu,
						 thread);
		}
892 893 894 895 896
	}

	return 0;
}

897 898
static int perf_evlist__mmap_per_cpu(struct perf_evlist *evlist,
				     struct mmap_params *mp)
899
{
900
	int cpu, thread;
901 902
	int nr_cpus = cpu_map__nr(evlist->cpus);
	int nr_threads = thread_map__nr(evlist->threads);
903

A
Adrian Hunter 已提交
904
	pr_debug2("perf event ring buffer mmapped per cpu\n");
905
	for (cpu = 0; cpu < nr_cpus; cpu++) {
906 907
		int output = -1;

908 909 910
		auxtrace_mmap_params__set_idx(&mp->auxtrace_mp, evlist, cpu,
					      true);

911
		for (thread = 0; thread < nr_threads; thread++) {
912 913
			if (perf_evlist__mmap_per_evsel(evlist, cpu, mp, cpu,
							thread, &output))
914
				goto out_unmap;
915 916 917 918 919 920
		}
	}

	return 0;

out_unmap:
921 922
	for (cpu = 0; cpu < nr_cpus; cpu++)
		__perf_evlist__munmap(evlist, cpu);
923 924 925
	return -1;
}

926 927
static int perf_evlist__mmap_per_thread(struct perf_evlist *evlist,
					struct mmap_params *mp)
928 929
{
	int thread;
930
	int nr_threads = thread_map__nr(evlist->threads);
931

A
Adrian Hunter 已提交
932
	pr_debug2("perf event ring buffer mmapped per thread\n");
933
	for (thread = 0; thread < nr_threads; thread++) {
934 935
		int output = -1;

936 937 938
		auxtrace_mmap_params__set_idx(&mp->auxtrace_mp, evlist, thread,
					      false);

939 940
		if (perf_evlist__mmap_per_evsel(evlist, thread, mp, 0, thread,
						&output))
941
			goto out_unmap;
942 943 944 945 946
	}

	return 0;

out_unmap:
947 948
	for (thread = 0; thread < nr_threads; thread++)
		__perf_evlist__munmap(evlist, thread);
949 950 951
	return -1;
}

952 953
static size_t perf_evlist__mmap_size(unsigned long pages)
{
954 955 956 957 958 959 960 961 962 963 964 965 966 967 968
	if (pages == UINT_MAX) {
		int max;

		if (sysctl__read_int("kernel/perf_event_mlock_kb", &max) < 0) {
			/*
			 * Pick a once upon a time good value, i.e. things look
			 * strange since we can't read a sysctl value, but lets not
			 * die yet...
			 */
			max = 512;
		} else {
			max -= (page_size / 1024);
		}

		pages = (max * 1024) / page_size;
969 970
		if (!is_power_of_2(pages))
			pages = rounddown_pow_of_two(pages);
971
	} else if (!is_power_of_2(pages))
972 973 974 975 976
		return 0;

	return (pages + 1) * page_size;
}

977 978
static long parse_pages_arg(const char *str, unsigned long min,
			    unsigned long max)
979
{
980
	unsigned long pages, val;
981 982 983 984 985 986 987
	static struct parse_tag tags[] = {
		{ .tag  = 'B', .mult = 1       },
		{ .tag  = 'K', .mult = 1 << 10 },
		{ .tag  = 'M', .mult = 1 << 20 },
		{ .tag  = 'G', .mult = 1 << 30 },
		{ .tag  = 0 },
	};
988

989
	if (str == NULL)
990
		return -EINVAL;
991

992
	val = parse_tag_value(str, tags);
993
	if (val != (unsigned long) -1) {
994 995 996 997 998 999
		/* we got file size value */
		pages = PERF_ALIGN(val, page_size) / page_size;
	} else {
		/* we got pages count value */
		char *eptr;
		pages = strtoul(str, &eptr, 10);
1000 1001
		if (*eptr != '\0')
			return -EINVAL;
1002 1003
	}

1004
	if (pages == 0 && min == 0) {
1005
		/* leave number of pages at 0 */
1006
	} else if (!is_power_of_2(pages)) {
1007
		/* round pages up to next power of 2 */
1008
		pages = roundup_pow_of_two(pages);
1009 1010
		if (!pages)
			return -EINVAL;
1011 1012
		pr_info("rounding mmap pages size to %lu bytes (%lu pages)\n",
			pages * page_size, pages);
1013 1014
	}

1015 1016 1017 1018 1019 1020
	if (pages > max)
		return -EINVAL;

	return pages;
}

1021
int __perf_evlist__parse_mmap_pages(unsigned int *mmap_pages, const char *str)
1022 1023 1024 1025
{
	unsigned long max = UINT_MAX;
	long pages;

A
Adrian Hunter 已提交
1026
	if (max > SIZE_MAX / page_size)
1027 1028 1029 1030 1031
		max = SIZE_MAX / page_size;

	pages = parse_pages_arg(str, 1, max);
	if (pages < 0) {
		pr_err("Invalid argument for --mmap_pages/-m\n");
1032 1033 1034 1035 1036 1037 1038
		return -1;
	}

	*mmap_pages = pages;
	return 0;
}

1039 1040 1041 1042 1043 1044
int perf_evlist__parse_mmap_pages(const struct option *opt, const char *str,
				  int unset __maybe_unused)
{
	return __perf_evlist__parse_mmap_pages(opt->value, str);
}

1045
/**
1046
 * perf_evlist__mmap_ex - Create mmaps to receive events.
1047 1048 1049
 * @evlist: list of events
 * @pages: map length in pages
 * @overwrite: overwrite older events?
1050 1051
 * @auxtrace_pages - auxtrace map length in pages
 * @auxtrace_overwrite - overwrite older auxtrace data?
1052
 *
1053 1054 1055
 * If @overwrite is %false the user needs to signal event consumption using
 * perf_mmap__write_tail().  Using perf_evlist__mmap_read() does this
 * automatically.
1056
 *
1057 1058 1059
 * Similarly, if @auxtrace_overwrite is %false the user needs to signal data
 * consumption using auxtrace_mmap__write_tail().
 *
1060
 * Return: %0 on success, negative error code otherwise.
1061
 */
1062 1063 1064
int perf_evlist__mmap_ex(struct perf_evlist *evlist, unsigned int pages,
			 bool overwrite, unsigned int auxtrace_pages,
			 bool auxtrace_overwrite)
1065
{
1066
	struct perf_evsel *evsel;
1067 1068
	const struct cpu_map *cpus = evlist->cpus;
	const struct thread_map *threads = evlist->threads;
1069 1070 1071
	struct mmap_params mp = {
		.prot = PROT_READ | (overwrite ? 0 : PROT_WRITE),
	};
1072

1073
	if (evlist->mmap == NULL && perf_evlist__alloc_mmap(evlist) < 0)
1074 1075
		return -ENOMEM;

1076
	if (evlist->pollfd.entries == NULL && perf_evlist__alloc_pollfd(evlist) < 0)
1077 1078 1079
		return -ENOMEM;

	evlist->overwrite = overwrite;
1080
	evlist->mmap_len = perf_evlist__mmap_size(pages);
1081
	pr_debug("mmap size %zuB\n", evlist->mmap_len);
1082
	mp.mask = evlist->mmap_len - page_size - 1;
1083

1084 1085 1086
	auxtrace_mmap_params__init(&mp.auxtrace_mp, evlist->mmap_len,
				   auxtrace_pages, auxtrace_overwrite);

1087
	evlist__for_each(evlist, evsel) {
1088
		if ((evsel->attr.read_format & PERF_FORMAT_ID) &&
1089
		    evsel->sample_id == NULL &&
1090
		    perf_evsel__alloc_id(evsel, cpu_map__nr(cpus), threads->nr) < 0)
1091 1092 1093
			return -ENOMEM;
	}

1094
	if (cpu_map__empty(cpus))
1095
		return perf_evlist__mmap_per_thread(evlist, &mp);
1096

1097
	return perf_evlist__mmap_per_cpu(evlist, &mp);
1098
}
1099

1100 1101 1102 1103 1104 1105
int perf_evlist__mmap(struct perf_evlist *evlist, unsigned int pages,
		      bool overwrite)
{
	return perf_evlist__mmap_ex(evlist, pages, overwrite, 0, false);
}

1106
static int perf_evlist__propagate_maps(struct perf_evlist *evlist,
1107
				       bool has_user_cpus)
1108 1109 1110 1111 1112 1113 1114 1115
{
	struct perf_evsel *evsel;

	evlist__for_each(evlist, evsel) {
		/*
		 * We already have cpus for evsel (via PMU sysfs) so
		 * keep it, if there's no target cpu list defined.
		 */
1116
		if (!evsel->cpus || has_user_cpus) {
1117 1118
			cpu_map__put(evsel->cpus);
			evsel->cpus = cpu_map__get(evlist->cpus);
1119
		}
1120

1121 1122
		evsel->threads = thread_map__get(evlist->threads);

1123 1124
		if ((evlist->cpus && !evsel->cpus) ||
		    (evlist->threads && !evsel->threads))
1125 1126 1127 1128 1129 1130
			return -ENOMEM;
	}

	return 0;
}

1131
int perf_evlist__create_maps(struct perf_evlist *evlist, struct target *target)
1132
{
1133 1134
	evlist->threads = thread_map__new_str(target->pid, target->tid,
					      target->uid);
1135 1136 1137 1138

	if (evlist->threads == NULL)
		return -1;

1139
	if (target__uses_dummy_map(target))
N
Namhyung Kim 已提交
1140
		evlist->cpus = cpu_map__dummy_new();
1141 1142
	else
		evlist->cpus = cpu_map__new(target->cpu_list);
1143 1144 1145 1146

	if (evlist->cpus == NULL)
		goto out_delete_threads;

1147
	return perf_evlist__propagate_maps(evlist, !!target->cpu_list);
1148 1149

out_delete_threads:
1150
	thread_map__put(evlist->threads);
1151
	evlist->threads = NULL;
1152 1153 1154
	return -1;
}

1155 1156 1157 1158
int perf_evlist__set_maps(struct perf_evlist *evlist,
			  struct cpu_map *cpus,
			  struct thread_map *threads)
{
1159
	cpu_map__put(evlist->cpus);
1160 1161
	evlist->cpus = cpus;

1162
	thread_map__put(evlist->threads);
1163 1164 1165 1166 1167
	evlist->threads = threads;

	return perf_evlist__propagate_maps(evlist, false);
}

1168
int perf_evlist__apply_filters(struct perf_evlist *evlist, struct perf_evsel **err_evsel)
1169 1170
{
	struct perf_evsel *evsel;
1171 1172
	int err = 0;
	const int ncpus = cpu_map__nr(evlist->cpus),
1173
		  nthreads = thread_map__nr(evlist->threads);
1174

1175
	evlist__for_each(evlist, evsel) {
1176
		if (evsel->filter == NULL)
1177
			continue;
1178

1179 1180 1181 1182
		/*
		 * filters only work for tracepoint event, which doesn't have cpu limit.
		 * So evlist and evsel should always be same.
		 */
1183
		err = perf_evsel__apply_filter(evsel, ncpus, nthreads, evsel->filter);
1184 1185
		if (err) {
			*err_evsel = evsel;
1186
			break;
1187
		}
1188 1189
	}

1190 1191 1192 1193 1194 1195 1196 1197
	return err;
}

int perf_evlist__set_filter(struct perf_evlist *evlist, const char *filter)
{
	struct perf_evsel *evsel;
	int err = 0;

1198
	evlist__for_each(evlist, evsel) {
1199
		err = perf_evsel__set_filter(evsel, filter);
1200 1201 1202 1203 1204
		if (err)
			break;
	}

	return err;
1205
}
1206

1207
int perf_evlist__set_filter_pids(struct perf_evlist *evlist, size_t npids, pid_t *pids)
1208 1209
{
	char *filter;
1210 1211
	int ret = -1;
	size_t i;
1212

1213 1214 1215 1216 1217 1218 1219 1220 1221 1222 1223 1224 1225 1226
	for (i = 0; i < npids; ++i) {
		if (i == 0) {
			if (asprintf(&filter, "common_pid != %d", pids[i]) < 0)
				return -1;
		} else {
			char *tmp;

			if (asprintf(&tmp, "%s && common_pid != %d", filter, pids[i]) < 0)
				goto out_free;

			free(filter);
			filter = tmp;
		}
	}
1227 1228

	ret = perf_evlist__set_filter(evlist, filter);
1229
out_free:
1230 1231 1232 1233
	free(filter);
	return ret;
}

1234 1235 1236 1237 1238
int perf_evlist__set_filter_pid(struct perf_evlist *evlist, pid_t pid)
{
	return perf_evlist__set_filter_pids(evlist, 1, &pid);
}

1239
bool perf_evlist__valid_sample_type(struct perf_evlist *evlist)
1240
{
1241
	struct perf_evsel *pos;
1242

1243 1244 1245 1246 1247 1248
	if (evlist->nr_entries == 1)
		return true;

	if (evlist->id_pos < 0 || evlist->is_pos < 0)
		return false;

1249
	evlist__for_each(evlist, pos) {
1250 1251
		if (pos->id_pos != evlist->id_pos ||
		    pos->is_pos != evlist->is_pos)
1252
			return false;
1253 1254
	}

1255
	return true;
1256 1257
}

1258
u64 __perf_evlist__combined_sample_type(struct perf_evlist *evlist)
1259
{
1260 1261 1262 1263 1264
	struct perf_evsel *evsel;

	if (evlist->combined_sample_type)
		return evlist->combined_sample_type;

1265
	evlist__for_each(evlist, evsel)
1266 1267 1268 1269 1270 1271 1272 1273 1274
		evlist->combined_sample_type |= evsel->attr.sample_type;

	return evlist->combined_sample_type;
}

u64 perf_evlist__combined_sample_type(struct perf_evlist *evlist)
{
	evlist->combined_sample_type = 0;
	return __perf_evlist__combined_sample_type(evlist);
1275 1276
}

1277 1278 1279 1280 1281 1282 1283 1284 1285 1286
u64 perf_evlist__combined_branch_type(struct perf_evlist *evlist)
{
	struct perf_evsel *evsel;
	u64 branch_type = 0;

	evlist__for_each(evlist, evsel)
		branch_type |= evsel->attr.branch_sample_type;
	return branch_type;
}

1287 1288 1289 1290 1291 1292
bool perf_evlist__valid_read_format(struct perf_evlist *evlist)
{
	struct perf_evsel *first = perf_evlist__first(evlist), *pos = first;
	u64 read_format = first->attr.read_format;
	u64 sample_type = first->attr.sample_type;

1293
	evlist__for_each(evlist, pos) {
1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306 1307 1308 1309 1310 1311 1312
		if (read_format != pos->attr.read_format)
			return false;
	}

	/* PERF_SAMPLE_READ imples PERF_FORMAT_ID. */
	if ((sample_type & PERF_SAMPLE_READ) &&
	    !(read_format & PERF_FORMAT_ID)) {
		return false;
	}

	return true;
}

u64 perf_evlist__read_format(struct perf_evlist *evlist)
{
	struct perf_evsel *first = perf_evlist__first(evlist);
	return first->attr.read_format;
}

1313
u16 perf_evlist__id_hdr_size(struct perf_evlist *evlist)
1314
{
1315
	struct perf_evsel *first = perf_evlist__first(evlist);
1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328 1329 1330 1331 1332 1333 1334 1335 1336 1337 1338
	struct perf_sample *data;
	u64 sample_type;
	u16 size = 0;

	if (!first->attr.sample_id_all)
		goto out;

	sample_type = first->attr.sample_type;

	if (sample_type & PERF_SAMPLE_TID)
		size += sizeof(data->tid) * 2;

       if (sample_type & PERF_SAMPLE_TIME)
		size += sizeof(data->time);

	if (sample_type & PERF_SAMPLE_ID)
		size += sizeof(data->id);

	if (sample_type & PERF_SAMPLE_STREAM_ID)
		size += sizeof(data->stream_id);

	if (sample_type & PERF_SAMPLE_CPU)
		size += sizeof(data->cpu) * 2;
1339 1340 1341

	if (sample_type & PERF_SAMPLE_IDENTIFIER)
		size += sizeof(data->id);
1342 1343 1344 1345
out:
	return size;
}

1346
bool perf_evlist__valid_sample_id_all(struct perf_evlist *evlist)
1347
{
1348
	struct perf_evsel *first = perf_evlist__first(evlist), *pos = first;
1349

1350
	evlist__for_each_continue(evlist, pos) {
1351 1352
		if (first->attr.sample_id_all != pos->attr.sample_id_all)
			return false;
1353 1354
	}

1355 1356 1357
	return true;
}

1358
bool perf_evlist__sample_id_all(struct perf_evlist *evlist)
1359
{
1360
	struct perf_evsel *first = perf_evlist__first(evlist);
1361
	return first->attr.sample_id_all;
1362
}
1363 1364 1365 1366 1367 1368

void perf_evlist__set_selected(struct perf_evlist *evlist,
			       struct perf_evsel *evsel)
{
	evlist->selected = evsel;
}
1369

1370 1371 1372 1373 1374
void perf_evlist__close(struct perf_evlist *evlist)
{
	struct perf_evsel *evsel;
	int ncpus = cpu_map__nr(evlist->cpus);
	int nthreads = thread_map__nr(evlist->threads);
1375
	int n;
1376

1377 1378 1379 1380
	evlist__for_each_reverse(evlist, evsel) {
		n = evsel->cpus ? evsel->cpus->nr : ncpus;
		perf_evsel__close(evsel, n, nthreads);
	}
1381 1382
}

1383 1384 1385 1386 1387 1388 1389 1390 1391 1392 1393 1394 1395 1396 1397 1398 1399 1400 1401 1402 1403 1404 1405 1406 1407
static int perf_evlist__create_syswide_maps(struct perf_evlist *evlist)
{
	int err = -ENOMEM;

	/*
	 * Try reading /sys/devices/system/cpu/online to get
	 * an all cpus map.
	 *
	 * FIXME: -ENOMEM is the best we can do here, the cpu_map
	 * code needs an overhaul to properly forward the
	 * error, and we may not want to do that fallback to a
	 * default cpu identity map :-\
	 */
	evlist->cpus = cpu_map__new(NULL);
	if (evlist->cpus == NULL)
		goto out;

	evlist->threads = thread_map__new_dummy();
	if (evlist->threads == NULL)
		goto out_free_cpus;

	err = 0;
out:
	return err;
out_free_cpus:
1408
	cpu_map__put(evlist->cpus);
1409 1410 1411 1412
	evlist->cpus = NULL;
	goto out;
}

1413
int perf_evlist__open(struct perf_evlist *evlist)
1414
{
1415
	struct perf_evsel *evsel;
1416
	int err;
1417

1418 1419 1420 1421 1422 1423 1424 1425 1426 1427
	/*
	 * Default: one fd per CPU, all threads, aka systemwide
	 * as sys_perf_event_open(cpu = -1, thread = -1) is EINVAL
	 */
	if (evlist->threads == NULL && evlist->cpus == NULL) {
		err = perf_evlist__create_syswide_maps(evlist);
		if (err < 0)
			goto out_err;
	}

1428 1429
	perf_evlist__update_id_pos(evlist);

1430
	evlist__for_each(evlist, evsel) {
1431
		err = perf_evsel__open(evsel, evlist->cpus, evlist->threads);
1432 1433 1434 1435 1436 1437
		if (err < 0)
			goto out_err;
	}

	return 0;
out_err:
1438
	perf_evlist__close(evlist);
1439
	errno = -err;
1440 1441
	return err;
}
1442

1443
int perf_evlist__prepare_workload(struct perf_evlist *evlist, struct target *target,
1444
				  const char *argv[], bool pipe_output,
1445
				  void (*exec_error)(int signo, siginfo_t *info, void *ucontext))
1446 1447 1448 1449 1450 1451 1452 1453 1454 1455 1456 1457 1458 1459 1460 1461 1462 1463 1464 1465 1466
{
	int child_ready_pipe[2], go_pipe[2];
	char bf;

	if (pipe(child_ready_pipe) < 0) {
		perror("failed to create 'ready' pipe");
		return -1;
	}

	if (pipe(go_pipe) < 0) {
		perror("failed to create 'go' pipe");
		goto out_close_ready_pipe;
	}

	evlist->workload.pid = fork();
	if (evlist->workload.pid < 0) {
		perror("failed to fork");
		goto out_close_pipes;
	}

	if (!evlist->workload.pid) {
1467 1468
		int ret;

1469
		if (pipe_output)
1470 1471
			dup2(2, 1);

1472 1473
		signal(SIGTERM, SIG_DFL);

1474 1475 1476 1477 1478 1479 1480 1481 1482 1483 1484 1485
		close(child_ready_pipe[0]);
		close(go_pipe[1]);
		fcntl(go_pipe[0], F_SETFD, FD_CLOEXEC);

		/*
		 * Tell the parent we're ready to go
		 */
		close(child_ready_pipe[1]);

		/*
		 * Wait until the parent tells us to go.
		 */
1486 1487 1488 1489 1490 1491
		ret = read(go_pipe[0], &bf, 1);
		/*
		 * The parent will ask for the execvp() to be performed by
		 * writing exactly one byte, in workload.cork_fd, usually via
		 * perf_evlist__start_workload().
		 *
1492
		 * For cancelling the workload without actually running it,
1493 1494 1495 1496 1497 1498 1499 1500 1501
		 * the parent will just close workload.cork_fd, without writing
		 * anything, i.e. read will return zero and we just exit()
		 * here.
		 */
		if (ret != 1) {
			if (ret == -1)
				perror("unable to read pipe");
			exit(ret);
		}
1502 1503 1504

		execvp(argv[0], (char **)argv);

1505
		if (exec_error) {
1506 1507 1508 1509 1510 1511 1512
			union sigval val;

			val.sival_int = errno;
			if (sigqueue(getppid(), SIGUSR1, val))
				perror(argv[0]);
		} else
			perror(argv[0]);
1513 1514 1515
		exit(-1);
	}

1516 1517 1518 1519 1520 1521 1522 1523
	if (exec_error) {
		struct sigaction act = {
			.sa_flags     = SA_SIGINFO,
			.sa_sigaction = exec_error,
		};
		sigaction(SIGUSR1, &act, NULL);
	}

1524 1525 1526 1527 1528 1529
	if (target__none(target)) {
		if (evlist->threads == NULL) {
			fprintf(stderr, "FATAL: evlist->threads need to be set at this point (%s:%d).\n",
				__func__, __LINE__);
			goto out_close_pipes;
		}
1530
		thread_map__set_pid(evlist->threads, 0, evlist->workload.pid);
1531
	}
1532 1533 1534 1535 1536 1537 1538 1539 1540 1541 1542

	close(child_ready_pipe[1]);
	close(go_pipe[0]);
	/*
	 * wait for child to settle
	 */
	if (read(child_ready_pipe[0], &bf, 1) == -1) {
		perror("unable to read pipe");
		goto out_close_pipes;
	}

1543
	fcntl(go_pipe[1], F_SETFD, FD_CLOEXEC);
1544 1545 1546 1547 1548 1549 1550 1551 1552 1553 1554 1555 1556 1557 1558 1559
	evlist->workload.cork_fd = go_pipe[1];
	close(child_ready_pipe[0]);
	return 0;

out_close_pipes:
	close(go_pipe[0]);
	close(go_pipe[1]);
out_close_ready_pipe:
	close(child_ready_pipe[0]);
	close(child_ready_pipe[1]);
	return -1;
}

int perf_evlist__start_workload(struct perf_evlist *evlist)
{
	if (evlist->workload.cork_fd > 0) {
1560
		char bf = 0;
1561
		int ret;
1562 1563 1564
		/*
		 * Remove the cork, let it rip!
		 */
1565 1566 1567 1568 1569 1570
		ret = write(evlist->workload.cork_fd, &bf, 1);
		if (ret < 0)
			perror("enable to write to pipe");

		close(evlist->workload.cork_fd);
		return ret;
1571 1572 1573 1574
	}

	return 0;
}
1575

1576
int perf_evlist__parse_sample(struct perf_evlist *evlist, union perf_event *event,
1577
			      struct perf_sample *sample)
1578
{
1579 1580 1581 1582
	struct perf_evsel *evsel = perf_evlist__event2evsel(evlist, event);

	if (!evsel)
		return -EFAULT;
1583
	return perf_evsel__parse_sample(evsel, event, sample);
1584
}
1585 1586 1587 1588 1589 1590

size_t perf_evlist__fprintf(struct perf_evlist *evlist, FILE *fp)
{
	struct perf_evsel *evsel;
	size_t printed = 0;

1591
	evlist__for_each(evlist, evsel) {
1592 1593 1594 1595
		printed += fprintf(fp, "%s%s", evsel->idx ? ", " : "",
				   perf_evsel__name(evsel));
	}

1596
	return printed + fprintf(fp, "\n");
1597
}
1598

1599 1600 1601 1602
int perf_evlist__strerror_open(struct perf_evlist *evlist __maybe_unused,
			       int err, char *buf, size_t size)
{
	int printed, value;
1603
	char sbuf[STRERR_BUFSIZE], *emsg = strerror_r(err, sbuf, sizeof(sbuf));
1604 1605 1606 1607 1608 1609 1610 1611

	switch (err) {
	case EACCES:
	case EPERM:
		printed = scnprintf(buf, size,
				    "Error:\t%s.\n"
				    "Hint:\tCheck /proc/sys/kernel/perf_event_paranoid setting.", emsg);

1612
		value = perf_event_paranoid();
1613 1614 1615 1616 1617 1618 1619 1620

		printed += scnprintf(buf + printed, size - printed, "\nHint:\t");

		if (value >= 2) {
			printed += scnprintf(buf + printed, size - printed,
					     "For your workloads it needs to be <= 1\nHint:\t");
		}
		printed += scnprintf(buf + printed, size - printed,
1621
				     "For system wide tracing it needs to be set to -1.\n");
1622 1623

		printed += scnprintf(buf + printed, size - printed,
1624 1625
				    "Hint:\tTry: 'sudo sh -c \"echo -1 > /proc/sys/kernel/perf_event_paranoid\"'\n"
				    "Hint:\tThe current value is %d.", value);
1626 1627 1628 1629 1630 1631 1632 1633
		break;
	default:
		scnprintf(buf, size, "%s", emsg);
		break;
	}

	return 0;
}
1634

1635 1636 1637
int perf_evlist__strerror_mmap(struct perf_evlist *evlist, int err, char *buf, size_t size)
{
	char sbuf[STRERR_BUFSIZE], *emsg = strerror_r(err, sbuf, sizeof(sbuf));
1638
	int pages_attempted = evlist->mmap_len / 1024, pages_max_per_user, printed = 0;
1639 1640 1641

	switch (err) {
	case EPERM:
1642
		sysctl__read_int("kernel/perf_event_mlock_kb", &pages_max_per_user);
1643 1644
		printed += scnprintf(buf + printed, size - printed,
				     "Error:\t%s.\n"
1645
				     "Hint:\tCheck /proc/sys/kernel/perf_event_mlock_kb (%d kB) setting.\n"
1646
				     "Hint:\tTried using %zd kB.\n",
1647
				     emsg, pages_max_per_user, pages_attempted);
1648 1649 1650 1651 1652 1653 1654 1655 1656

		if (pages_attempted >= pages_max_per_user) {
			printed += scnprintf(buf + printed, size - printed,
					     "Hint:\tTry 'sudo sh -c \"echo %d > /proc/sys/kernel/perf_event_mlock_kb\"', or\n",
					     pages_max_per_user + pages_attempted);
		}

		printed += scnprintf(buf + printed, size - printed,
				     "Hint:\tTry using a smaller -m/--mmap-pages value.");
1657 1658 1659 1660 1661 1662 1663 1664 1665
		break;
	default:
		scnprintf(buf, size, "%s", emsg);
		break;
	}

	return 0;
}

1666 1667 1668 1669 1670 1671 1672 1673 1674
void perf_evlist__to_front(struct perf_evlist *evlist,
			   struct perf_evsel *move_evsel)
{
	struct perf_evsel *evsel, *n;
	LIST_HEAD(move);

	if (move_evsel == perf_evlist__first(evlist))
		return;

1675
	evlist__for_each_safe(evlist, n, evsel) {
1676 1677 1678 1679 1680 1681
		if (evsel->leader == move_evsel->leader)
			list_move_tail(&evsel->node, &move);
	}

	list_splice(&move, &evlist->entries);
}
1682 1683 1684 1685 1686 1687 1688 1689 1690 1691 1692 1693 1694 1695 1696 1697

void perf_evlist__set_tracking_event(struct perf_evlist *evlist,
				     struct perf_evsel *tracking_evsel)
{
	struct perf_evsel *evsel;

	if (tracking_evsel->tracking)
		return;

	evlist__for_each(evlist, evsel) {
		if (evsel != tracking_evsel)
			evsel->tracking = false;
	}

	tracking_evsel->tracking = true;
}