evlist.c 19.5 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 10
#include "util.h"
#include "debugfs.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"
17
#include <unistd.h>
18

19 20
#include "parse-events.h"

21 22
#include <sys/mman.h>

23 24 25
#include <linux/bitops.h>
#include <linux/hash.h>

26
#define FD(e, x, y) (*(int *)xyarray__entry(e->fd, x, y))
27
#define SID(e, x, y) xyarray__entry(e->sample_id, x, y)
28

29 30
void perf_evlist__init(struct perf_evlist *evlist, struct cpu_map *cpus,
		       struct thread_map *threads)
31 32 33 34 35 36
{
	int i;

	for (i = 0; i < PERF_EVLIST__HLIST_SIZE; ++i)
		INIT_HLIST_HEAD(&evlist->heads[i]);
	INIT_LIST_HEAD(&evlist->entries);
37
	perf_evlist__set_maps(evlist, cpus, threads);
38
	evlist->workload.pid = -1;
39 40
}

41 42
struct perf_evlist *perf_evlist__new(struct cpu_map *cpus,
				     struct thread_map *threads)
43 44 45
{
	struct perf_evlist *evlist = zalloc(sizeof(*evlist));

46
	if (evlist != NULL)
47
		perf_evlist__init(evlist, cpus, threads);
48 49 50 51

	return evlist;
}

52 53
void perf_evlist__config(struct perf_evlist *evlist,
			struct perf_record_opts *opts)
54
{
55
	struct perf_evsel *evsel;
56 57 58 59 60 61
	/*
	 * Set the evsel leader links before we configure attributes,
	 * since some might depend on this info.
	 */
	if (opts->group)
		perf_evlist__set_leader(evlist);
62 63 64 65 66

	if (evlist->cpus->map[0] < 0)
		opts->no_inherit = true;

	list_for_each_entry(evsel, &evlist->entries, node) {
67
		perf_evsel__config(evsel, opts);
68 69

		if (evlist->nr_entries > 1)
70
			perf_evsel__set_sample_id(evsel);
71 72 73
	}
}

74 75 76 77 78 79 80 81 82 83 84 85
static void perf_evlist__purge(struct perf_evlist *evlist)
{
	struct perf_evsel *pos, *n;

	list_for_each_entry_safe(pos, n, &evlist->entries, node) {
		list_del_init(&pos->node);
		perf_evsel__delete(pos);
	}

	evlist->nr_entries = 0;
}

86
void perf_evlist__exit(struct perf_evlist *evlist)
87
{
88
	free(evlist->mmap);
89
	free(evlist->pollfd);
90 91 92 93 94 95 96 97
	evlist->mmap = NULL;
	evlist->pollfd = NULL;
}

void perf_evlist__delete(struct perf_evlist *evlist)
{
	perf_evlist__purge(evlist);
	perf_evlist__exit(evlist);
98 99 100 101 102 103 104 105 106
	free(evlist);
}

void perf_evlist__add(struct perf_evlist *evlist, struct perf_evsel *entry)
{
	list_add_tail(&entry->node, &evlist->entries);
	++evlist->nr_entries;
}

107 108 109
void perf_evlist__splice_list_tail(struct perf_evlist *evlist,
				   struct list_head *list,
				   int nr_entries)
110 111 112 113 114
{
	list_splice_tail(list, &evlist->entries);
	evlist->nr_entries += nr_entries;
}

115 116 117 118 119 120 121 122 123 124 125 126 127
void __perf_evlist__set_leader(struct list_head *list)
{
	struct perf_evsel *evsel, *leader;

	leader = list_entry(list->next, struct perf_evsel, node);

	list_for_each_entry(evsel, list, node) {
		if (evsel != leader)
			evsel->leader = leader;
	}
}

void perf_evlist__set_leader(struct perf_evlist *evlist)
128 129
{
	if (evlist->nr_entries)
130
		__perf_evlist__set_leader(&evlist->entries);
131 132
}

133 134 135 136 137 138
int perf_evlist__add_default(struct perf_evlist *evlist)
{
	struct perf_event_attr attr = {
		.type = PERF_TYPE_HARDWARE,
		.config = PERF_COUNT_HW_CPU_CYCLES,
	};
139 140 141
	struct perf_evsel *evsel;

	event_attr_init(&attr);
142

143
	evsel = perf_evsel__new(&attr, 0);
144
	if (evsel == NULL)
145 146 147 148 149 150
		goto error;

	/* use strdup() because free(evsel) assumes name is allocated */
	evsel->name = strdup("cycles");
	if (!evsel->name)
		goto error_free;
151 152 153

	perf_evlist__add(evlist, evsel);
	return 0;
154 155 156 157
error_free:
	perf_evsel__delete(evsel);
error:
	return -ENOMEM;
158
}
159

160 161
static int perf_evlist__add_attrs(struct perf_evlist *evlist,
				  struct perf_event_attr *attrs, size_t nr_attrs)
162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183
{
	struct perf_evsel *evsel, *n;
	LIST_HEAD(head);
	size_t i;

	for (i = 0; i < nr_attrs; i++) {
		evsel = perf_evsel__new(attrs + i, evlist->nr_entries + i);
		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:
	list_for_each_entry_safe(evsel, n, &head, node)
		perf_evsel__delete(evsel);
	return -1;
}

184 185 186 187 188 189 190 191 192 193 194
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);
}

195 196
struct perf_evsel *
perf_evlist__find_tracepoint_by_id(struct perf_evlist *evlist, int id)
197 198 199 200 201 202 203 204 205 206 207 208
{
	struct perf_evsel *evsel;

	list_for_each_entry(evsel, &evlist->entries, node) {
		if (evsel->attr.type   == PERF_TYPE_TRACEPOINT &&
		    (int)evsel->attr.config == id)
			return evsel;
	}

	return NULL;
}

209 210 211 212 213 214 215 216 217 218 219 220 221 222
int perf_evlist__add_newtp(struct perf_evlist *evlist,
			   const char *sys, const char *name, void *handler)
{
	struct perf_evsel *evsel;

	evsel = perf_evsel__newtp(sys, name, evlist->nr_entries);
	if (evsel == NULL)
		return -1;

	evsel->handler.func = handler;
	perf_evlist__add(evlist, evsel);
	return 0;
}

223 224 225 226 227 228 229
void perf_evlist__disable(struct perf_evlist *evlist)
{
	int cpu, thread;
	struct perf_evsel *pos;

	for (cpu = 0; cpu < evlist->cpus->nr; cpu++) {
		list_for_each_entry(pos, &evlist->entries, node) {
230
			if (!perf_evsel__is_group_leader(pos))
231
				continue;
232
			for (thread = 0; thread < evlist->threads->nr; thread++)
233 234
				ioctl(FD(pos, cpu, thread),
				      PERF_EVENT_IOC_DISABLE, 0);
235 236 237 238
		}
	}
}

239 240 241 242 243
void perf_evlist__enable(struct perf_evlist *evlist)
{
	int cpu, thread;
	struct perf_evsel *pos;

244
	for (cpu = 0; cpu < cpu_map__nr(evlist->cpus); cpu++) {
245
		list_for_each_entry(pos, &evlist->entries, node) {
246
			if (!perf_evsel__is_group_leader(pos))
247
				continue;
248
			for (thread = 0; thread < evlist->threads->nr; thread++)
249 250
				ioctl(FD(pos, cpu, thread),
				      PERF_EVENT_IOC_ENABLE, 0);
251 252 253 254
		}
	}
}

255
static int perf_evlist__alloc_pollfd(struct perf_evlist *evlist)
256
{
257
	int nfds = cpu_map__nr(evlist->cpus) * evlist->threads->nr * evlist->nr_entries;
258 259 260
	evlist->pollfd = malloc(sizeof(struct pollfd) * nfds);
	return evlist->pollfd != NULL ? 0 : -ENOMEM;
}
261 262 263 264 265 266 267 268

void perf_evlist__add_pollfd(struct perf_evlist *evlist, int fd)
{
	fcntl(fd, F_SETFL, O_NONBLOCK);
	evlist->pollfd[evlist->nr_fds].fd = fd;
	evlist->pollfd[evlist->nr_fds].events = POLLIN;
	evlist->nr_fds++;
}
269

270 271 272
static void perf_evlist__id_hash(struct perf_evlist *evlist,
				 struct perf_evsel *evsel,
				 int cpu, int thread, u64 id)
273 274 275 276 277 278 279 280 281 282
{
	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]);
}

283 284 285 286 287 288 289 290 291 292
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)
293 294
{
	u64 read_data[4] = { 0, };
295
	int id_idx = 1; /* The first entry is the counter value */
296 297 298 299 300 301 302 303 304 305

	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;

306
	perf_evlist__id_add(evlist, evsel, cpu, thread, read_data[id_idx]);
307 308 309
	return 0;
}

310 311 312 313 314 315 316 317
struct perf_evsel *perf_evlist__id2evsel(struct perf_evlist *evlist, u64 id)
{
	struct hlist_head *head;
	struct hlist_node *pos;
	struct perf_sample_id *sid;
	int hash;

	if (evlist->nr_entries == 1)
318
		return perf_evlist__first(evlist);
319 320 321 322 323 324 325

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

	hlist_for_each_entry(sid, pos, head, node)
		if (sid->id == id)
			return sid->evsel;
326 327

	if (!perf_evlist__sample_id_all(evlist))
328
		return perf_evlist__first(evlist);
329

330 331
	return NULL;
}
332

333
union perf_event *perf_evlist__mmap_read(struct perf_evlist *evlist, int idx)
334
{
335
	struct perf_mmap *md = &evlist->mmap[idx];
336 337 338
	unsigned int head = perf_mmap__read_head(md);
	unsigned int old = md->prev;
	unsigned char *data = md->base + page_size;
339
	union perf_event *event = NULL;
340

341
	if (evlist->overwrite) {
342
		/*
343 344 345 346 347 348
		 * 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.
349
		 */
350 351 352 353 354 355 356 357 358
		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;
		}
359 360 361 362 363
	}

	if (old != head) {
		size_t size;

364
		event = (union perf_event *)&data[old & md->mask];
365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390
		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;
			void *dst = &evlist->event_copy;

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

			event = &evlist->event_copy;
		}

		old += size;
	}

	md->prev = old;
391 392 393 394

	if (!evlist->overwrite)
		perf_mmap__write_tail(md, old);

395 396
	return event;
}
397

398
void perf_evlist__munmap(struct perf_evlist *evlist)
399
{
400
	int i;
401

402 403 404 405
	for (i = 0; i < evlist->nr_mmaps; i++) {
		if (evlist->mmap[i].base != NULL) {
			munmap(evlist->mmap[i].base, evlist->mmap_len);
			evlist->mmap[i].base = NULL;
406 407
		}
	}
408 409 410

	free(evlist->mmap);
	evlist->mmap = NULL;
411 412
}

413
static int perf_evlist__alloc_mmap(struct perf_evlist *evlist)
414
{
415 416
	evlist->nr_mmaps = cpu_map__nr(evlist->cpus);
	if (cpu_map__all(evlist->cpus))
417 418
		evlist->nr_mmaps = evlist->threads->nr;
	evlist->mmap = zalloc(evlist->nr_mmaps * sizeof(struct perf_mmap));
419 420 421
	return evlist->mmap != NULL ? 0 : -ENOMEM;
}

422
static int __perf_evlist__mmap(struct perf_evlist *evlist,
423
			       int idx, int prot, int mask, int fd)
424
{
425 426 427
	evlist->mmap[idx].prev = 0;
	evlist->mmap[idx].mask = mask;
	evlist->mmap[idx].base = mmap(NULL, evlist->mmap_len, prot,
428
				      MAP_SHARED, fd, 0);
429 430
	if (evlist->mmap[idx].base == MAP_FAILED) {
		evlist->mmap[idx].base = NULL;
431
		return -1;
432
	}
433 434 435 436 437

	perf_evlist__add_pollfd(evlist, fd);
	return 0;
}

438 439 440 441 442 443 444 445 446 447 448 449 450 451
static int perf_evlist__mmap_per_cpu(struct perf_evlist *evlist, int prot, int mask)
{
	struct perf_evsel *evsel;
	int cpu, thread;

	for (cpu = 0; cpu < evlist->cpus->nr; cpu++) {
		int output = -1;

		for (thread = 0; thread < evlist->threads->nr; thread++) {
			list_for_each_entry(evsel, &evlist->entries, node) {
				int fd = FD(evsel, cpu, thread);

				if (output == -1) {
					output = fd;
452
					if (__perf_evlist__mmap(evlist, cpu,
453 454 455 456 457 458 459 460 461 462 463 464 465 466 467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491
								prot, mask, output) < 0)
						goto out_unmap;
				} else {
					if (ioctl(fd, PERF_EVENT_IOC_SET_OUTPUT, output) != 0)
						goto out_unmap;
				}

				if ((evsel->attr.read_format & PERF_FORMAT_ID) &&
				    perf_evlist__id_add_fd(evlist, evsel, cpu, thread, fd) < 0)
					goto out_unmap;
			}
		}
	}

	return 0;

out_unmap:
	for (cpu = 0; cpu < evlist->cpus->nr; cpu++) {
		if (evlist->mmap[cpu].base != NULL) {
			munmap(evlist->mmap[cpu].base, evlist->mmap_len);
			evlist->mmap[cpu].base = NULL;
		}
	}
	return -1;
}

static int perf_evlist__mmap_per_thread(struct perf_evlist *evlist, int prot, int mask)
{
	struct perf_evsel *evsel;
	int thread;

	for (thread = 0; thread < evlist->threads->nr; thread++) {
		int output = -1;

		list_for_each_entry(evsel, &evlist->entries, node) {
			int fd = FD(evsel, 0, thread);

			if (output == -1) {
				output = fd;
492
				if (__perf_evlist__mmap(evlist, thread,
493 494 495 496 497 498 499 500 501 502 503 504 505 506 507 508 509 510 511 512 513 514 515 516 517
							prot, mask, output) < 0)
					goto out_unmap;
			} else {
				if (ioctl(fd, PERF_EVENT_IOC_SET_OUTPUT, output) != 0)
					goto out_unmap;
			}

			if ((evsel->attr.read_format & PERF_FORMAT_ID) &&
			    perf_evlist__id_add_fd(evlist, evsel, 0, thread, fd) < 0)
				goto out_unmap;
		}
	}

	return 0;

out_unmap:
	for (thread = 0; thread < evlist->threads->nr; thread++) {
		if (evlist->mmap[thread].base != NULL) {
			munmap(evlist->mmap[thread].base, evlist->mmap_len);
			evlist->mmap[thread].base = NULL;
		}
	}
	return -1;
}

518 519 520 521 522 523 524 525 526 527 528 529
/** perf_evlist__mmap - Create per cpu maps to receive events
 *
 * @evlist - list of events
 * @pages - map length in pages
 * @overwrite - overwrite older events?
 *
 * If overwrite is false the user needs to signal event consuption using:
 *
 *	struct perf_mmap *m = &evlist->mmap[cpu];
 *	unsigned int head = perf_mmap__read_head(m);
 *
 *	perf_mmap__write_tail(m, head)
530 531
 *
 * Using perf_evlist__read_on_cpu does this automatically.
532
 */
533 534
int perf_evlist__mmap(struct perf_evlist *evlist, unsigned int pages,
		      bool overwrite)
535
{
536
	struct perf_evsel *evsel;
537 538
	const struct cpu_map *cpus = evlist->cpus;
	const struct thread_map *threads = evlist->threads;
539 540 541 542 543
	int prot = PROT_READ | (overwrite ? 0 : PROT_WRITE), mask;

        /* 512 kiB: default amount of unprivileged mlocked memory */
        if (pages == UINT_MAX)
                pages = (512 * 1024) / page_size;
544 545
	else if (!is_power_of_2(pages))
		return -EINVAL;
546 547

	mask = pages * page_size - 1;
548

549
	if (evlist->mmap == NULL && perf_evlist__alloc_mmap(evlist) < 0)
550 551
		return -ENOMEM;

552
	if (evlist->pollfd == NULL && perf_evlist__alloc_pollfd(evlist) < 0)
553 554 555 556 557 558 559
		return -ENOMEM;

	evlist->overwrite = overwrite;
	evlist->mmap_len = (pages + 1) * page_size;

	list_for_each_entry(evsel, &evlist->entries, node) {
		if ((evsel->attr.read_format & PERF_FORMAT_ID) &&
560
		    evsel->sample_id == NULL &&
561
		    perf_evsel__alloc_id(evsel, cpu_map__nr(cpus), threads->nr) < 0)
562 563 564
			return -ENOMEM;
	}

565
	if (cpu_map__all(cpus))
566
		return perf_evlist__mmap_per_thread(evlist, prot, mask);
567

568
	return perf_evlist__mmap_per_cpu(evlist, prot, mask);
569
}
570

571 572
int perf_evlist__create_maps(struct perf_evlist *evlist,
			     struct perf_target *target)
573
{
574 575
	evlist->threads = thread_map__new_str(target->pid, target->tid,
					      target->uid);
576 577 578 579

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

580
	if (perf_target__has_task(target))
581
		evlist->cpus = cpu_map__dummy_new();
N
Namhyung Kim 已提交
582 583
	else if (!perf_target__has_cpu(target) && !target->uses_mmap)
		evlist->cpus = cpu_map__dummy_new();
584 585
	else
		evlist->cpus = cpu_map__new(target->cpu_list);
586 587 588 589 590 591 592 593 594 595 596 597 598 599 600 601 602 603

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

	return 0;

out_delete_threads:
	thread_map__delete(evlist->threads);
	return -1;
}

void perf_evlist__delete_maps(struct perf_evlist *evlist)
{
	cpu_map__delete(evlist->cpus);
	thread_map__delete(evlist->threads);
	evlist->cpus	= NULL;
	evlist->threads = NULL;
}
604

605
int perf_evlist__apply_filters(struct perf_evlist *evlist)
606 607
{
	struct perf_evsel *evsel;
608 609 610
	int err = 0;
	const int ncpus = cpu_map__nr(evlist->cpus),
		  nthreads = evlist->threads->nr;
611 612

	list_for_each_entry(evsel, &evlist->entries, node) {
613
		if (evsel->filter == NULL)
614
			continue;
615 616 617 618

		err = perf_evsel__set_filter(evsel, ncpus, nthreads, evsel->filter);
		if (err)
			break;
619 620
	}

621 622 623 624 625 626 627 628 629 630 631 632 633 634 635 636 637
	return err;
}

int perf_evlist__set_filter(struct perf_evlist *evlist, const char *filter)
{
	struct perf_evsel *evsel;
	int err = 0;
	const int ncpus = cpu_map__nr(evlist->cpus),
		  nthreads = evlist->threads->nr;

	list_for_each_entry(evsel, &evlist->entries, node) {
		err = perf_evsel__set_filter(evsel, ncpus, nthreads, filter);
		if (err)
			break;
	}

	return err;
638
}
639

640
bool perf_evlist__valid_sample_type(struct perf_evlist *evlist)
641
{
642
	struct perf_evsel *first = perf_evlist__first(evlist), *pos = first;
643 644 645 646

	list_for_each_entry_continue(pos, &evlist->entries, node) {
		if (first->attr.sample_type != pos->attr.sample_type)
			return false;
647 648
	}

649
	return true;
650 651
}

652
u64 perf_evlist__sample_type(struct perf_evlist *evlist)
653
{
654
	struct perf_evsel *first = perf_evlist__first(evlist);
655 656 657
	return first->attr.sample_type;
}

658
u16 perf_evlist__id_hdr_size(struct perf_evlist *evlist)
659
{
660
	struct perf_evsel *first = perf_evlist__first(evlist);
661 662 663 664 665 666 667 668 669 670 671 672 673 674 675 676 677 678 679 680 681 682 683 684 685 686 687
	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;
out:
	return size;
}

688
bool perf_evlist__valid_sample_id_all(struct perf_evlist *evlist)
689
{
690
	struct perf_evsel *first = perf_evlist__first(evlist), *pos = first;
691 692 693 694

	list_for_each_entry_continue(pos, &evlist->entries, node) {
		if (first->attr.sample_id_all != pos->attr.sample_id_all)
			return false;
695 696
	}

697 698 699
	return true;
}

700
bool perf_evlist__sample_id_all(struct perf_evlist *evlist)
701
{
702
	struct perf_evsel *first = perf_evlist__first(evlist);
703
	return first->attr.sample_id_all;
704
}
705 706 707 708 709 710

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

712
int perf_evlist__open(struct perf_evlist *evlist)
713
{
714
	struct perf_evsel *evsel;
715 716 717
	int err, ncpus, nthreads;

	list_for_each_entry(evsel, &evlist->entries, node) {
718
		err = perf_evsel__open(evsel, evlist->cpus, evlist->threads);
719 720 721 722 723 724 725 726 727 728 729 730
		if (err < 0)
			goto out_err;
	}

	return 0;
out_err:
	ncpus = evlist->cpus ? evlist->cpus->nr : 1;
	nthreads = evlist->threads ? evlist->threads->nr : 1;

	list_for_each_entry_reverse(evsel, &evlist->entries, node)
		perf_evsel__close(evsel, ncpus, nthreads);

731
	errno = -err;
732 733
	return err;
}
734 735 736 737 738 739 740 741 742 743 744 745 746 747 748 749 750 751 752 753 754 755 756 757 758 759 760 761 762 763 764 765 766 767 768 769 770 771 772 773 774 775 776 777 778 779 780 781 782 783 784 785 786 787 788 789 790

int perf_evlist__prepare_workload(struct perf_evlist *evlist,
				  struct perf_record_opts *opts,
				  const char *argv[])
{
	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) {
		if (opts->pipe_output)
			dup2(2, 1);

		close(child_ready_pipe[0]);
		close(go_pipe[1]);
		fcntl(go_pipe[0], F_SETFD, FD_CLOEXEC);

		/*
		 * Do a dummy execvp to get the PLT entry resolved,
		 * so we avoid the resolver overhead on the real
		 * execvp call.
		 */
		execvp("", (char **)argv);

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

		/*
		 * Wait until the parent tells us to go.
		 */
		if (read(go_pipe[0], &bf, 1) == -1)
			perror("unable to read pipe");

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

		perror(argv[0]);
		kill(getppid(), SIGUSR1);
		exit(-1);
	}

791
	if (perf_target__none(&opts->target))
792 793 794 795 796 797 798 799 800 801 802 803 804 805 806 807 808 809 810 811 812 813 814 815 816 817 818 819 820 821 822 823 824 825 826 827
		evlist->threads->map[0] = evlist->workload.pid;

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

	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) {
		/*
		 * Remove the cork, let it rip!
		 */
		return close(evlist->workload.cork_fd);
	}

	return 0;
}
828

829
int perf_evlist__parse_sample(struct perf_evlist *evlist, union perf_event *event,
830
			      struct perf_sample *sample)
831
{
832
	struct perf_evsel *evsel = perf_evlist__first(evlist);
833
	return perf_evsel__parse_sample(evsel, event, sample);
834
}
835 836 837 838 839 840 841 842 843 844 845 846 847

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

	list_for_each_entry(evsel, &evlist->entries, node) {
		printed += fprintf(fp, "%s%s", evsel->idx ? ", " : "",
				   perf_evsel__name(evsel));
	}

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