evlist.c 39.6 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
void perf_evlist__splice_list_tail(struct perf_evlist *evlist,
139
				   struct list_head *list)
140
{
141
	struct perf_evsel *evsel, *temp;
142

143 144 145 146
	__evlist__for_each_safe(list, temp, evsel) {
		list_del_init(&evsel->node);
		perf_evlist__add(evlist, evsel);
	}
147 148
}

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

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

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

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

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

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

	event_attr_init(&attr);
180

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

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

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

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

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

212
	perf_evlist__splice_list_tail(evlist, &head);
213 214 215 216

	return 0;

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

222 223 224 225 226 227 228 229 230 231 232
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);
}

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

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

	return NULL;
}

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

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

	return NULL;
}

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

	if (evsel == NULL)
		return -1;

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

275 276 277 278 279 280 281 282 283
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);
}

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

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

	evlist->enabled = false;
303 304
}

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

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

	evlist->enabled = true;
}

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

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

	if (!evsel->fd)
		return 0;

341 342
	for (cpu = 0; cpu < nr_cpus; cpu++) {
		for (thread = 0; thread < nr_threads; thread++) {
343 344 345 346 347 348 349 350 351 352 353 354 355
			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;
356 357
	int nr_cpus = cpu_map__nr(evlist->cpus);
	int nr_threads = perf_evlist__nr_threads(evlist, evsel);
358 359 360 361

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

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

373 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
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);
}

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

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

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

	return 0;
439
}
440

441 442 443 444 445 446 447 448 449 450 451 452 453 454 455 456
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;
}

457
int perf_evlist__add_pollfd(struct perf_evlist *evlist, int fd)
458
{
459 460 461 462 463 464
	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);
465

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

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

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

480 481 482
static void perf_evlist__id_hash(struct perf_evlist *evlist,
				 struct perf_evsel *evsel,
				 int cpu, int thread, u64 id)
483 484 485 486 487 488 489 490 491 492
{
	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]);
}

493 494 495 496 497 498 499 500 501 502
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)
503 504
{
	u64 read_data[4] = { 0, };
505
	int id_idx = 1; /* The first entry is the counter value */
506 507 508 509 510 511 512 513 514 515 516
	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! */
517

518 519 520 521 522 523 524
	/*
	 * 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;

525 526 527 528 529 530 531 532 533
	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;

534 535 536 537
	id = read_data[id_idx];

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

A
Adrian Hunter 已提交
541 542 543 544 545 546 547 548 549 550 551
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)
552
		sid->tid = thread_map__pid(evlist->threads, thread);
A
Adrian Hunter 已提交
553 554 555 556
	else
		sid->tid = -1;
}

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

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

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

	return NULL;
}

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

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

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

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

587 588
	return NULL;
}
589

590 591 592 593 594 595 596 597 598 599 600 601 602 603 604 605 606 607 608 609 610 611 612 613
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)
{
614
	struct perf_evsel *first = perf_evlist__first(evlist);
615 616 617 618 619 620
	struct hlist_head *head;
	struct perf_sample_id *sid;
	int hash;
	u64 id;

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

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

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

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

	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;
}

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

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

	head = perf_mmap__read_head(md);
659
	if (evlist->overwrite) {
660
		/*
661 662 663 664 665 666
		 * 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.
667
		 */
668 669 670 671 672 673 674 675 676
		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;
		}
677 678 679 680 681
	}

	if (old != head) {
		size_t size;

682
		event = (union perf_event *)&data[old & md->mask];
683 684 685 686 687 688 689 690 691
		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;
692
			void *dst = md->event_copy;
693 694 695 696 697 698 699 700 701

			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);

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

		old += size;
	}

	md->prev = old;
709

710 711
	return event;
}
712

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

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

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

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

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

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

		perf_mmap__write_tail(md, old);
	}
740

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

745 746 747 748 749 750 751 752 753 754 755 756 757 758 759 760 761 762 763 764 765 766 767 768 769 770 771 772
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)
{
}

773 774 775 776 777
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;
778
		atomic_set(&evlist->mmap[idx].refcnt, 0);
779
	}
780
	auxtrace_mmap__munmap(&evlist->mmap[idx].auxtrace_mmap);
781 782
}

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

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

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

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

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

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

static int __perf_evlist__mmap(struct perf_evlist *evlist, int idx,
			       struct mmap_params *mp, int fd)
813
{
814 815 816 817 818 819 820 821 822 823 824 825 826
	/*
	 * 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().
	 */
827
	atomic_set(&evlist->mmap[idx].refcnt, 2);
828
	evlist->mmap[idx].prev = 0;
829 830
	evlist->mmap[idx].mask = mp->mask;
	evlist->mmap[idx].base = mmap(NULL, evlist->mmap_len, mp->prot,
831
				      MAP_SHARED, fd, 0);
832
	if (evlist->mmap[idx].base == MAP_FAILED) {
833 834
		pr_debug2("failed to mmap perf event ring buffer, error %d\n",
			  errno);
835
		evlist->mmap[idx].base = NULL;
836
		return -1;
837
	}
838

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

843 844 845
	return 0;
}

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

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

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

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

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

			perf_evlist__mmap_get(evlist, idx);
869 870
		}

871 872 873 874 875 876 877 878 879
		/*
		 * 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) {
880
			perf_evlist__mmap_put(evlist, idx);
881
			return -1;
882
		}
883

A
Adrian Hunter 已提交
884 885 886 887 888 889 890
		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);
		}
891 892 893 894 895
	}

	return 0;
}

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

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

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

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

	return 0;

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

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

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

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

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

	return 0;

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

951 952
static size_t perf_evlist__mmap_size(unsigned long pages)
{
953 954 955 956 957 958 959 960 961 962 963 964 965 966 967
	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;
968 969
		if (!is_power_of_2(pages))
			pages = rounddown_pow_of_two(pages);
970
	} else if (!is_power_of_2(pages))
971 972 973 974 975
		return 0;

	return (pages + 1) * page_size;
}

976 977
static long parse_pages_arg(const char *str, unsigned long min,
			    unsigned long max)
978
{
979
	unsigned long pages, val;
980 981 982 983 984 985 986
	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 },
	};
987

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

991
	val = parse_tag_value(str, tags);
992
	if (val != (unsigned long) -1) {
993 994 995 996 997 998
		/* 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);
999 1000
		if (*eptr != '\0')
			return -EINVAL;
1001 1002
	}

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

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

	return pages;
}

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

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

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

	*mmap_pages = pages;
	return 0;
}

1038 1039 1040 1041 1042 1043
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);
}

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

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

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

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

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

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

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

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

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

1105
static void perf_evlist__propagate_maps(struct perf_evlist *evlist)
1106 1107 1108 1109 1110 1111 1112 1113
{
	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.
		 */
A
Adrian Hunter 已提交
1114
		if (!evsel->own_cpus || evlist->has_user_cpus) {
1115 1116
			cpu_map__put(evsel->cpus);
			evsel->cpus = cpu_map__get(evlist->cpus);
A
Adrian Hunter 已提交
1117 1118 1119
		} else if (evsel->cpus != evsel->own_cpus) {
			cpu_map__put(evsel->cpus);
			evsel->cpus = cpu_map__get(evsel->own_cpus);
1120
		}
1121

1122
		thread_map__put(evsel->threads);
1123
		evsel->threads = thread_map__get(evlist->threads);
1124 1125 1126
	}
}

1127
int perf_evlist__create_maps(struct perf_evlist *evlist, struct target *target)
1128
{
1129 1130
	struct cpu_map *cpus;
	struct thread_map *threads;
1131

1132 1133 1134
	threads = thread_map__new_str(target->pid, target->tid, target->uid);

	if (!threads)
1135 1136
		return -1;

1137
	if (target__uses_dummy_map(target))
1138
		cpus = cpu_map__dummy_new();
1139
	else
1140
		cpus = cpu_map__new(target->cpu_list);
1141

1142
	if (!cpus)
1143 1144
		goto out_delete_threads;

1145 1146
	evlist->has_user_cpus = !!target->cpu_list;

1147
	perf_evlist__set_maps(evlist, cpus, threads);
1148 1149

	return 0;
1150 1151

out_delete_threads:
1152
	thread_map__put(threads);
1153 1154 1155
	return -1;
}

1156 1157
void perf_evlist__set_maps(struct perf_evlist *evlist, struct cpu_map *cpus,
			   struct thread_map *threads)
1158
{
1159 1160 1161 1162 1163 1164 1165 1166 1167 1168 1169
	/*
	 * Allow for the possibility that one or another of the maps isn't being
	 * changed i.e. don't put it.  Note we are assuming the maps that are
	 * being applied are brand new and evlist is taking ownership of the
	 * original reference count of 1.  If that is not the case it is up to
	 * the caller to increase the reference count.
	 */
	if (cpus != evlist->cpus) {
		cpu_map__put(evlist->cpus);
		evlist->cpus = cpus;
	}
1170

1171 1172 1173 1174
	if (threads != evlist->threads) {
		thread_map__put(evlist->threads);
		evlist->threads = threads;
	}
1175

1176
	perf_evlist__propagate_maps(evlist);
1177 1178
}

1179
int perf_evlist__apply_filters(struct perf_evlist *evlist, struct perf_evsel **err_evsel)
1180 1181
{
	struct perf_evsel *evsel;
1182 1183
	int err = 0;
	const int ncpus = cpu_map__nr(evlist->cpus),
1184
		  nthreads = thread_map__nr(evlist->threads);
1185

1186
	evlist__for_each(evlist, evsel) {
1187
		if (evsel->filter == NULL)
1188
			continue;
1189

1190 1191 1192 1193
		/*
		 * filters only work for tracepoint event, which doesn't have cpu limit.
		 * So evlist and evsel should always be same.
		 */
1194
		err = perf_evsel__apply_filter(evsel, ncpus, nthreads, evsel->filter);
1195 1196
		if (err) {
			*err_evsel = evsel;
1197
			break;
1198
		}
1199 1200
	}

1201 1202 1203 1204 1205 1206 1207 1208
	return err;
}

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

1209
	evlist__for_each(evlist, evsel) {
1210
		err = perf_evsel__set_filter(evsel, filter);
1211 1212 1213 1214 1215
		if (err)
			break;
	}

	return err;
1216
}
1217

1218
int perf_evlist__set_filter_pids(struct perf_evlist *evlist, size_t npids, pid_t *pids)
1219 1220
{
	char *filter;
1221 1222
	int ret = -1;
	size_t i;
1223

1224 1225 1226 1227 1228 1229 1230 1231 1232 1233 1234 1235 1236 1237
	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;
		}
	}
1238 1239

	ret = perf_evlist__set_filter(evlist, filter);
1240
out_free:
1241 1242 1243 1244
	free(filter);
	return ret;
}

1245 1246 1247 1248 1249
int perf_evlist__set_filter_pid(struct perf_evlist *evlist, pid_t pid)
{
	return perf_evlist__set_filter_pids(evlist, 1, &pid);
}

1250
bool perf_evlist__valid_sample_type(struct perf_evlist *evlist)
1251
{
1252
	struct perf_evsel *pos;
1253

1254 1255 1256 1257 1258 1259
	if (evlist->nr_entries == 1)
		return true;

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

1260
	evlist__for_each(evlist, pos) {
1261 1262
		if (pos->id_pos != evlist->id_pos ||
		    pos->is_pos != evlist->is_pos)
1263
			return false;
1264 1265
	}

1266
	return true;
1267 1268
}

1269
u64 __perf_evlist__combined_sample_type(struct perf_evlist *evlist)
1270
{
1271 1272 1273 1274 1275
	struct perf_evsel *evsel;

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

1276
	evlist__for_each(evlist, evsel)
1277 1278 1279 1280 1281 1282 1283 1284 1285
		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);
1286 1287
}

1288 1289 1290 1291 1292 1293 1294 1295 1296 1297
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;
}

1298 1299 1300 1301 1302 1303
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;

1304
	evlist__for_each(evlist, pos) {
1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323
		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;
}

1324
u16 perf_evlist__id_hdr_size(struct perf_evlist *evlist)
1325
{
1326
	struct perf_evsel *first = perf_evlist__first(evlist);
1327 1328 1329 1330 1331 1332 1333 1334 1335 1336 1337 1338 1339 1340 1341 1342 1343 1344 1345 1346 1347 1348 1349
	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;
1350 1351 1352

	if (sample_type & PERF_SAMPLE_IDENTIFIER)
		size += sizeof(data->id);
1353 1354 1355 1356
out:
	return size;
}

1357
bool perf_evlist__valid_sample_id_all(struct perf_evlist *evlist)
1358
{
1359
	struct perf_evsel *first = perf_evlist__first(evlist), *pos = first;
1360

1361
	evlist__for_each_continue(evlist, pos) {
1362 1363
		if (first->attr.sample_id_all != pos->attr.sample_id_all)
			return false;
1364 1365
	}

1366 1367 1368
	return true;
}

1369
bool perf_evlist__sample_id_all(struct perf_evlist *evlist)
1370
{
1371
	struct perf_evsel *first = perf_evlist__first(evlist);
1372
	return first->attr.sample_id_all;
1373
}
1374 1375 1376 1377 1378 1379

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

1381 1382 1383 1384 1385
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);
1386
	int n;
1387

1388 1389 1390 1391
	evlist__for_each_reverse(evlist, evsel) {
		n = evsel->cpus ? evsel->cpus->nr : ncpus;
		perf_evsel__close(evsel, n, nthreads);
	}
1392 1393
}

1394 1395 1396 1397 1398 1399 1400 1401 1402 1403 1404 1405 1406 1407 1408 1409 1410 1411 1412 1413 1414 1415 1416 1417 1418
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:
1419
	cpu_map__put(evlist->cpus);
1420 1421 1422 1423
	evlist->cpus = NULL;
	goto out;
}

1424
int perf_evlist__open(struct perf_evlist *evlist)
1425
{
1426
	struct perf_evsel *evsel;
1427
	int err;
1428

1429 1430 1431 1432 1433 1434 1435 1436 1437 1438
	/*
	 * 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;
	}

1439 1440
	perf_evlist__update_id_pos(evlist);

1441
	evlist__for_each(evlist, evsel) {
1442
		err = perf_evsel__open(evsel, evlist->cpus, evlist->threads);
1443 1444 1445 1446 1447 1448
		if (err < 0)
			goto out_err;
	}

	return 0;
out_err:
1449
	perf_evlist__close(evlist);
1450
	errno = -err;
1451 1452
	return err;
}
1453

1454
int perf_evlist__prepare_workload(struct perf_evlist *evlist, struct target *target,
1455
				  const char *argv[], bool pipe_output,
1456
				  void (*exec_error)(int signo, siginfo_t *info, void *ucontext))
1457 1458 1459 1460 1461 1462 1463 1464 1465 1466 1467 1468 1469 1470 1471 1472 1473 1474 1475 1476 1477
{
	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) {
1478 1479
		int ret;

1480
		if (pipe_output)
1481 1482
			dup2(2, 1);

1483 1484
		signal(SIGTERM, SIG_DFL);

1485 1486 1487 1488 1489 1490 1491 1492 1493 1494 1495 1496
		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.
		 */
1497 1498 1499 1500 1501 1502
		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().
		 *
1503
		 * For cancelling the workload without actually running it,
1504 1505 1506 1507 1508 1509 1510 1511 1512
		 * 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);
		}
1513 1514 1515

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

1516
		if (exec_error) {
1517 1518 1519 1520 1521 1522 1523
			union sigval val;

			val.sival_int = errno;
			if (sigqueue(getppid(), SIGUSR1, val))
				perror(argv[0]);
		} else
			perror(argv[0]);
1524 1525 1526
		exit(-1);
	}

1527 1528 1529 1530 1531 1532 1533 1534
	if (exec_error) {
		struct sigaction act = {
			.sa_flags     = SA_SIGINFO,
			.sa_sigaction = exec_error,
		};
		sigaction(SIGUSR1, &act, NULL);
	}

1535 1536 1537 1538 1539 1540
	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;
		}
1541
		thread_map__set_pid(evlist->threads, 0, evlist->workload.pid);
1542
	}
1543 1544 1545 1546 1547 1548 1549 1550 1551 1552 1553

	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;
	}

1554
	fcntl(go_pipe[1], F_SETFD, FD_CLOEXEC);
1555 1556 1557 1558 1559 1560 1561 1562 1563 1564 1565 1566 1567 1568 1569 1570
	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) {
1571
		char bf = 0;
1572
		int ret;
1573 1574 1575
		/*
		 * Remove the cork, let it rip!
		 */
1576 1577 1578 1579 1580 1581
		ret = write(evlist->workload.cork_fd, &bf, 1);
		if (ret < 0)
			perror("enable to write to pipe");

		close(evlist->workload.cork_fd);
		return ret;
1582 1583 1584 1585
	}

	return 0;
}
1586

1587
int perf_evlist__parse_sample(struct perf_evlist *evlist, union perf_event *event,
1588
			      struct perf_sample *sample)
1589
{
1590 1591 1592 1593
	struct perf_evsel *evsel = perf_evlist__event2evsel(evlist, event);

	if (!evsel)
		return -EFAULT;
1594
	return perf_evsel__parse_sample(evsel, event, sample);
1595
}
1596 1597 1598 1599 1600 1601

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

1602
	evlist__for_each(evlist, evsel) {
1603 1604 1605 1606
		printed += fprintf(fp, "%s%s", evsel->idx ? ", " : "",
				   perf_evsel__name(evsel));
	}

1607
	return printed + fprintf(fp, "\n");
1608
}
1609

1610 1611 1612 1613
int perf_evlist__strerror_open(struct perf_evlist *evlist __maybe_unused,
			       int err, char *buf, size_t size)
{
	int printed, value;
1614
	char sbuf[STRERR_BUFSIZE], *emsg = strerror_r(err, sbuf, sizeof(sbuf));
1615 1616 1617 1618 1619 1620 1621 1622

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

1623
		value = perf_event_paranoid();
1624 1625 1626 1627 1628 1629 1630 1631

		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,
1632
				     "For system wide tracing it needs to be set to -1.\n");
1633 1634

		printed += scnprintf(buf + printed, size - printed,
1635 1636
				    "Hint:\tTry: 'sudo sh -c \"echo -1 > /proc/sys/kernel/perf_event_paranoid\"'\n"
				    "Hint:\tThe current value is %d.", value);
1637 1638 1639 1640 1641 1642 1643 1644
		break;
	default:
		scnprintf(buf, size, "%s", emsg);
		break;
	}

	return 0;
}
1645

1646 1647 1648
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));
1649
	int pages_attempted = evlist->mmap_len / 1024, pages_max_per_user, printed = 0;
1650 1651 1652

	switch (err) {
	case EPERM:
1653
		sysctl__read_int("kernel/perf_event_mlock_kb", &pages_max_per_user);
1654 1655
		printed += scnprintf(buf + printed, size - printed,
				     "Error:\t%s.\n"
1656
				     "Hint:\tCheck /proc/sys/kernel/perf_event_mlock_kb (%d kB) setting.\n"
1657
				     "Hint:\tTried using %zd kB.\n",
1658
				     emsg, pages_max_per_user, pages_attempted);
1659 1660 1661 1662 1663 1664 1665 1666 1667

		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.");
1668 1669 1670 1671 1672 1673 1674 1675 1676
		break;
	default:
		scnprintf(buf, size, "%s", emsg);
		break;
	}

	return 0;
}

1677 1678 1679 1680 1681 1682 1683 1684 1685
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;

1686
	evlist__for_each_safe(evlist, n, evsel) {
1687 1688 1689 1690 1691 1692
		if (evsel->leader == move_evsel->leader)
			list_move_tail(&evsel->node, &move);
	}

	list_splice(&move, &evlist->entries);
}
1693 1694 1695 1696 1697 1698 1699 1700 1701 1702 1703 1704 1705 1706 1707 1708

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;
}