evlist.c 19.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 <lk/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
void __perf_evlist__set_leader(struct list_head *list)
{
	struct perf_evsel *evsel, *leader;

	leader = list_entry(list->next, struct perf_evsel, node);
120 121 122
	evsel = list_entry(list->prev, struct perf_evsel, node);

	leader->nr_members = evsel->idx - leader->idx + 1;
123 124

	list_for_each_entry(evsel, list, node) {
125
		evsel->leader = leader;
126 127 128 129
	}
}

void perf_evlist__set_leader(struct perf_evlist *evlist)
130
{
131 132
	if (evlist->nr_entries) {
		evlist->nr_groups = evlist->nr_entries > 1 ? 1 : 0;
133
		__perf_evlist__set_leader(&evlist->entries);
134
	}
135 136
}

137 138 139 140 141 142
int perf_evlist__add_default(struct perf_evlist *evlist)
{
	struct perf_event_attr attr = {
		.type = PERF_TYPE_HARDWARE,
		.config = PERF_COUNT_HW_CPU_CYCLES,
	};
143 144 145
	struct perf_evsel *evsel;

	event_attr_init(&attr);
146

147
	evsel = perf_evsel__new(&attr, 0);
148
	if (evsel == NULL)
149 150 151 152 153 154
		goto error;

	/* use strdup() because free(evsel) assumes name is allocated */
	evsel->name = strdup("cycles");
	if (!evsel->name)
		goto error_free;
155 156 157

	perf_evlist__add(evlist, evsel);
	return 0;
158 159 160 161
error_free:
	perf_evsel__delete(evsel);
error:
	return -ENOMEM;
162
}
163

164 165
static int perf_evlist__add_attrs(struct perf_evlist *evlist,
				  struct perf_event_attr *attrs, size_t nr_attrs)
166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187
{
	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;
}

188 189 190 191 192 193 194 195 196 197 198
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);
}

199 200
struct perf_evsel *
perf_evlist__find_tracepoint_by_id(struct perf_evlist *evlist, int id)
201 202 203 204 205 206 207 208 209 210 211 212
{
	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;
}

213 214 215 216 217 218 219 220 221 222 223 224 225 226
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;
}

227 228 229 230 231 232 233
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) {
234
			if (!perf_evsel__is_group_leader(pos))
235
				continue;
236
			for (thread = 0; thread < evlist->threads->nr; thread++)
237 238
				ioctl(FD(pos, cpu, thread),
				      PERF_EVENT_IOC_DISABLE, 0);
239 240 241 242
		}
	}
}

243 244 245 246 247
void perf_evlist__enable(struct perf_evlist *evlist)
{
	int cpu, thread;
	struct perf_evsel *pos;

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

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

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

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

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

	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;

310
	perf_evlist__id_add(evlist, evsel, cpu, thread, read_data[id_idx]);
311 312 313
	return 0;
}

314 315 316 317 318 319 320 321
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)
322
		return perf_evlist__first(evlist);
323 324 325 326 327 328 329

	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;
330 331

	if (!perf_evlist__sample_id_all(evlist))
332
		return perf_evlist__first(evlist);
333

334 335
	return NULL;
}
336

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

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

	if (old != head) {
		size_t size;

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

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

388
			event = &md->event_copy;
389 390 391 392 393 394
		}

		old += size;
	}

	md->prev = old;
395 396 397 398

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

399 400
	return event;
}
401

402
void perf_evlist__munmap(struct perf_evlist *evlist)
403
{
404
	int i;
405

406 407 408 409
	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;
410 411
		}
	}
412 413 414

	free(evlist->mmap);
	evlist->mmap = NULL;
415 416
}

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

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

	perf_evlist__add_pollfd(evlist, fd);
	return 0;
}

442 443 444 445 446 447 448 449 450 451 452 453 454 455
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;
456
					if (__perf_evlist__mmap(evlist, cpu,
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 492 493 494 495
								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;
496
				if (__perf_evlist__mmap(evlist, thread,
497 498 499 500 501 502 503 504 505 506 507 508 509 510 511 512 513 514 515 516 517 518 519 520 521
							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;
}

522 523 524 525 526 527 528 529 530 531 532 533
/** 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)
534 535
 *
 * Using perf_evlist__read_on_cpu does this automatically.
536
 */
537 538
int perf_evlist__mmap(struct perf_evlist *evlist, unsigned int pages,
		      bool overwrite)
539
{
540
	struct perf_evsel *evsel;
541 542
	const struct cpu_map *cpus = evlist->cpus;
	const struct thread_map *threads = evlist->threads;
543 544 545 546 547
	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;
548 549
	else if (!is_power_of_2(pages))
		return -EINVAL;
550 551

	mask = pages * page_size - 1;
552

553
	if (evlist->mmap == NULL && perf_evlist__alloc_mmap(evlist) < 0)
554 555
		return -ENOMEM;

556
	if (evlist->pollfd == NULL && perf_evlist__alloc_pollfd(evlist) < 0)
557 558 559 560 561 562 563
		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) &&
564
		    evsel->sample_id == NULL &&
565
		    perf_evsel__alloc_id(evsel, cpu_map__nr(cpus), threads->nr) < 0)
566 567 568
			return -ENOMEM;
	}

569
	if (cpu_map__all(cpus))
570
		return perf_evlist__mmap_per_thread(evlist, prot, mask);
571

572
	return perf_evlist__mmap_per_cpu(evlist, prot, mask);
573
}
574

575 576
int perf_evlist__create_maps(struct perf_evlist *evlist,
			     struct perf_target *target)
577
{
578 579
	evlist->threads = thread_map__new_str(target->pid, target->tid,
					      target->uid);
580 581 582 583

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

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

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

609
int perf_evlist__apply_filters(struct perf_evlist *evlist)
610 611
{
	struct perf_evsel *evsel;
612 613 614
	int err = 0;
	const int ncpus = cpu_map__nr(evlist->cpus),
		  nthreads = evlist->threads->nr;
615 616

	list_for_each_entry(evsel, &evlist->entries, node) {
617
		if (evsel->filter == NULL)
618
			continue;
619 620 621 622

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

625 626 627 628 629 630 631 632 633 634 635 636 637 638 639 640 641
	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;
642
}
643

644
bool perf_evlist__valid_sample_type(struct perf_evlist *evlist)
645
{
646
	struct perf_evsel *first = perf_evlist__first(evlist), *pos = first;
647 648 649 650

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

653
	return true;
654 655
}

656
u64 perf_evlist__sample_type(struct perf_evlist *evlist)
657
{
658
	struct perf_evsel *first = perf_evlist__first(evlist);
659 660 661
	return first->attr.sample_type;
}

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

692
bool perf_evlist__valid_sample_id_all(struct perf_evlist *evlist)
693
{
694
	struct perf_evsel *first = perf_evlist__first(evlist), *pos = first;
695 696 697 698

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

701 702 703
	return true;
}

704
bool perf_evlist__sample_id_all(struct perf_evlist *evlist)
705
{
706
	struct perf_evsel *first = perf_evlist__first(evlist);
707
	return first->attr.sample_id_all;
708
}
709 710 711 712 713 714

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

716
int perf_evlist__open(struct perf_evlist *evlist)
717
{
718
	struct perf_evsel *evsel;
719 720 721
	int err, ncpus, nthreads;

	list_for_each_entry(evsel, &evlist->entries, node) {
722
		err = perf_evsel__open(evsel, evlist->cpus, evlist->threads);
723 724 725 726 727 728 729 730 731 732 733 734
		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);

735
	errno = -err;
736 737
	return err;
}
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 791 792 793 794

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

795
	if (perf_target__none(&opts->target))
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 828 829 830 831
		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;
}
832

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

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