perf tools: Introduce tools/lib/lk library
[linux-2.6-block.git] / tools / perf / util / evlist.c
CommitLineData
f8a95309
ACM
1/*
2 * Copyright (C) 2011, Red Hat Inc, Arnaldo Carvalho de Melo <acme@redhat.com>
3 *
4 * Parts came from builtin-{top,stat,record}.c, see those files for further
5 * copyright notes.
6 *
7 * Released under the GPL v2. (and only v2, not any later version)
8 */
a8c9ae18 9#include "util.h"
85c66be1 10#include <lk/debugfs.h>
5c581041 11#include <poll.h>
f8a95309
ACM
12#include "cpumap.h"
13#include "thread_map.h"
12864b31 14#include "target.h"
361c99a6
ACM
15#include "evlist.h"
16#include "evsel.h"
35b9d88e 17#include <unistd.h>
361c99a6 18
50d08e47
ACM
19#include "parse-events.h"
20
f8a95309
ACM
21#include <sys/mman.h>
22
70db7533
ACM
23#include <linux/bitops.h>
24#include <linux/hash.h>
25
f8a95309 26#define FD(e, x, y) (*(int *)xyarray__entry(e->fd, x, y))
a91e5431 27#define SID(e, x, y) xyarray__entry(e->sample_id, x, y)
f8a95309 28
7e2ed097
ACM
29void perf_evlist__init(struct perf_evlist *evlist, struct cpu_map *cpus,
30 struct thread_map *threads)
ef1d1af2
ACM
31{
32 int i;
33
34 for (i = 0; i < PERF_EVLIST__HLIST_SIZE; ++i)
35 INIT_HLIST_HEAD(&evlist->heads[i]);
36 INIT_LIST_HEAD(&evlist->entries);
7e2ed097 37 perf_evlist__set_maps(evlist, cpus, threads);
35b9d88e 38 evlist->workload.pid = -1;
ef1d1af2
ACM
39}
40
7e2ed097
ACM
41struct perf_evlist *perf_evlist__new(struct cpu_map *cpus,
42 struct thread_map *threads)
361c99a6
ACM
43{
44 struct perf_evlist *evlist = zalloc(sizeof(*evlist));
45
ef1d1af2 46 if (evlist != NULL)
7e2ed097 47 perf_evlist__init(evlist, cpus, threads);
361c99a6
ACM
48
49 return evlist;
50}
51
f77a9518
ACM
52void perf_evlist__config(struct perf_evlist *evlist,
53 struct perf_record_opts *opts)
0f82ebc4 54{
cac21425 55 struct perf_evsel *evsel;
f77a9518
ACM
56 /*
57 * Set the evsel leader links before we configure attributes,
58 * since some might depend on this info.
59 */
60 if (opts->group)
61 perf_evlist__set_leader(evlist);
0f82ebc4
ACM
62
63 if (evlist->cpus->map[0] < 0)
64 opts->no_inherit = true;
65
66 list_for_each_entry(evsel, &evlist->entries, node) {
cac21425 67 perf_evsel__config(evsel, opts);
0f82ebc4
ACM
68
69 if (evlist->nr_entries > 1)
3a5afaec 70 perf_evsel__set_sample_id(evsel);
0f82ebc4
ACM
71 }
72}
73
361c99a6
ACM
74static void perf_evlist__purge(struct perf_evlist *evlist)
75{
76 struct perf_evsel *pos, *n;
77
78 list_for_each_entry_safe(pos, n, &evlist->entries, node) {
79 list_del_init(&pos->node);
80 perf_evsel__delete(pos);
81 }
82
83 evlist->nr_entries = 0;
84}
85
ef1d1af2 86void perf_evlist__exit(struct perf_evlist *evlist)
361c99a6 87{
70db7533 88 free(evlist->mmap);
5c581041 89 free(evlist->pollfd);
ef1d1af2
ACM
90 evlist->mmap = NULL;
91 evlist->pollfd = NULL;
92}
93
94void perf_evlist__delete(struct perf_evlist *evlist)
95{
96 perf_evlist__purge(evlist);
97 perf_evlist__exit(evlist);
361c99a6
ACM
98 free(evlist);
99}
100
101void perf_evlist__add(struct perf_evlist *evlist, struct perf_evsel *entry)
102{
103 list_add_tail(&entry->node, &evlist->entries);
104 ++evlist->nr_entries;
105}
106
0529bc1f
JO
107void perf_evlist__splice_list_tail(struct perf_evlist *evlist,
108 struct list_head *list,
109 int nr_entries)
50d08e47
ACM
110{
111 list_splice_tail(list, &evlist->entries);
112 evlist->nr_entries += nr_entries;
113}
114
63dab225
ACM
115void __perf_evlist__set_leader(struct list_head *list)
116{
117 struct perf_evsel *evsel, *leader;
118
119 leader = list_entry(list->next, struct perf_evsel, node);
97f63e4a
NK
120 evsel = list_entry(list->prev, struct perf_evsel, node);
121
122 leader->nr_members = evsel->idx - leader->idx + 1;
63dab225
ACM
123
124 list_for_each_entry(evsel, list, node) {
74b2133d 125 evsel->leader = leader;
63dab225
ACM
126 }
127}
128
129void perf_evlist__set_leader(struct perf_evlist *evlist)
6a4bb04c 130{
97f63e4a
NK
131 if (evlist->nr_entries) {
132 evlist->nr_groups = evlist->nr_entries > 1 ? 1 : 0;
63dab225 133 __perf_evlist__set_leader(&evlist->entries);
97f63e4a 134 }
6a4bb04c
JO
135}
136
361c99a6
ACM
137int perf_evlist__add_default(struct perf_evlist *evlist)
138{
139 struct perf_event_attr attr = {
140 .type = PERF_TYPE_HARDWARE,
141 .config = PERF_COUNT_HW_CPU_CYCLES,
142 };
1aed2671
JR
143 struct perf_evsel *evsel;
144
145 event_attr_init(&attr);
361c99a6 146
1aed2671 147 evsel = perf_evsel__new(&attr, 0);
361c99a6 148 if (evsel == NULL)
cc2d86b0
SE
149 goto error;
150
151 /* use strdup() because free(evsel) assumes name is allocated */
152 evsel->name = strdup("cycles");
153 if (!evsel->name)
154 goto error_free;
361c99a6
ACM
155
156 perf_evlist__add(evlist, evsel);
157 return 0;
cc2d86b0
SE
158error_free:
159 perf_evsel__delete(evsel);
160error:
161 return -ENOMEM;
361c99a6 162}
5c581041 163
e60fc847
ACM
164static int perf_evlist__add_attrs(struct perf_evlist *evlist,
165 struct perf_event_attr *attrs, size_t nr_attrs)
50d08e47
ACM
166{
167 struct perf_evsel *evsel, *n;
168 LIST_HEAD(head);
169 size_t i;
170
171 for (i = 0; i < nr_attrs; i++) {
172 evsel = perf_evsel__new(attrs + i, evlist->nr_entries + i);
173 if (evsel == NULL)
174 goto out_delete_partial_list;
175 list_add_tail(&evsel->node, &head);
176 }
177
178 perf_evlist__splice_list_tail(evlist, &head, nr_attrs);
179
180 return 0;
181
182out_delete_partial_list:
183 list_for_each_entry_safe(evsel, n, &head, node)
184 perf_evsel__delete(evsel);
185 return -1;
186}
187
79695e1b
ACM
188int __perf_evlist__add_default_attrs(struct perf_evlist *evlist,
189 struct perf_event_attr *attrs, size_t nr_attrs)
190{
191 size_t i;
192
193 for (i = 0; i < nr_attrs; i++)
194 event_attr_init(attrs + i);
195
196 return perf_evlist__add_attrs(evlist, attrs, nr_attrs);
197}
198
da378962
ACM
199struct perf_evsel *
200perf_evlist__find_tracepoint_by_id(struct perf_evlist *evlist, int id)
ee29be62
ACM
201{
202 struct perf_evsel *evsel;
203
204 list_for_each_entry(evsel, &evlist->entries, node) {
205 if (evsel->attr.type == PERF_TYPE_TRACEPOINT &&
206 (int)evsel->attr.config == id)
207 return evsel;
208 }
209
210 return NULL;
211}
212
39876e7d
ACM
213int perf_evlist__add_newtp(struct perf_evlist *evlist,
214 const char *sys, const char *name, void *handler)
215{
216 struct perf_evsel *evsel;
217
218 evsel = perf_evsel__newtp(sys, name, evlist->nr_entries);
219 if (evsel == NULL)
220 return -1;
221
222 evsel->handler.func = handler;
223 perf_evlist__add(evlist, evsel);
224 return 0;
225}
226
4152ab37
ACM
227void perf_evlist__disable(struct perf_evlist *evlist)
228{
229 int cpu, thread;
230 struct perf_evsel *pos;
231
232 for (cpu = 0; cpu < evlist->cpus->nr; cpu++) {
233 list_for_each_entry(pos, &evlist->entries, node) {
823254ed 234 if (!perf_evsel__is_group_leader(pos))
3fe4430d 235 continue;
4152ab37 236 for (thread = 0; thread < evlist->threads->nr; thread++)
55da8005
NK
237 ioctl(FD(pos, cpu, thread),
238 PERF_EVENT_IOC_DISABLE, 0);
4152ab37
ACM
239 }
240 }
241}
242
764e16a3
DA
243void perf_evlist__enable(struct perf_evlist *evlist)
244{
245 int cpu, thread;
246 struct perf_evsel *pos;
247
a14bb7a6 248 for (cpu = 0; cpu < cpu_map__nr(evlist->cpus); cpu++) {
764e16a3 249 list_for_each_entry(pos, &evlist->entries, node) {
823254ed 250 if (!perf_evsel__is_group_leader(pos))
3fe4430d 251 continue;
764e16a3 252 for (thread = 0; thread < evlist->threads->nr; thread++)
55da8005
NK
253 ioctl(FD(pos, cpu, thread),
254 PERF_EVENT_IOC_ENABLE, 0);
764e16a3
DA
255 }
256 }
257}
258
806fb630 259static int perf_evlist__alloc_pollfd(struct perf_evlist *evlist)
5c581041 260{
a14bb7a6 261 int nfds = cpu_map__nr(evlist->cpus) * evlist->threads->nr * evlist->nr_entries;
5c581041
ACM
262 evlist->pollfd = malloc(sizeof(struct pollfd) * nfds);
263 return evlist->pollfd != NULL ? 0 : -ENOMEM;
264}
70082dd9
ACM
265
266void perf_evlist__add_pollfd(struct perf_evlist *evlist, int fd)
267{
268 fcntl(fd, F_SETFL, O_NONBLOCK);
269 evlist->pollfd[evlist->nr_fds].fd = fd;
270 evlist->pollfd[evlist->nr_fds].events = POLLIN;
271 evlist->nr_fds++;
272}
70db7533 273
a91e5431
ACM
274static void perf_evlist__id_hash(struct perf_evlist *evlist,
275 struct perf_evsel *evsel,
276 int cpu, int thread, u64 id)
3d3b5e95
ACM
277{
278 int hash;
279 struct perf_sample_id *sid = SID(evsel, cpu, thread);
280
281 sid->id = id;
282 sid->evsel = evsel;
283 hash = hash_64(sid->id, PERF_EVLIST__HLIST_BITS);
284 hlist_add_head(&sid->node, &evlist->heads[hash]);
285}
286
a91e5431
ACM
287void perf_evlist__id_add(struct perf_evlist *evlist, struct perf_evsel *evsel,
288 int cpu, int thread, u64 id)
289{
290 perf_evlist__id_hash(evlist, evsel, cpu, thread, id);
291 evsel->id[evsel->ids++] = id;
292}
293
294static int perf_evlist__id_add_fd(struct perf_evlist *evlist,
295 struct perf_evsel *evsel,
296 int cpu, int thread, int fd)
f8a95309 297{
f8a95309 298 u64 read_data[4] = { 0, };
3d3b5e95 299 int id_idx = 1; /* The first entry is the counter value */
f8a95309
ACM
300
301 if (!(evsel->attr.read_format & PERF_FORMAT_ID) ||
302 read(fd, &read_data, sizeof(read_data)) == -1)
303 return -1;
304
305 if (evsel->attr.read_format & PERF_FORMAT_TOTAL_TIME_ENABLED)
306 ++id_idx;
307 if (evsel->attr.read_format & PERF_FORMAT_TOTAL_TIME_RUNNING)
308 ++id_idx;
309
a91e5431 310 perf_evlist__id_add(evlist, evsel, cpu, thread, read_data[id_idx]);
f8a95309
ACM
311 return 0;
312}
313
70db7533
ACM
314struct perf_evsel *perf_evlist__id2evsel(struct perf_evlist *evlist, u64 id)
315{
316 struct hlist_head *head;
317 struct hlist_node *pos;
318 struct perf_sample_id *sid;
319 int hash;
320
321 if (evlist->nr_entries == 1)
0c21f736 322 return perf_evlist__first(evlist);
70db7533
ACM
323
324 hash = hash_64(id, PERF_EVLIST__HLIST_BITS);
325 head = &evlist->heads[hash];
326
327 hlist_for_each_entry(sid, pos, head, node)
328 if (sid->id == id)
329 return sid->evsel;
30e68bcc
NK
330
331 if (!perf_evlist__sample_id_all(evlist))
0c21f736 332 return perf_evlist__first(evlist);
30e68bcc 333
70db7533
ACM
334 return NULL;
335}
04391deb 336
aece948f 337union perf_event *perf_evlist__mmap_read(struct perf_evlist *evlist, int idx)
04391deb 338{
aece948f 339 struct perf_mmap *md = &evlist->mmap[idx];
04391deb
ACM
340 unsigned int head = perf_mmap__read_head(md);
341 unsigned int old = md->prev;
342 unsigned char *data = md->base + page_size;
8115d60c 343 union perf_event *event = NULL;
04391deb 344
7bb41152 345 if (evlist->overwrite) {
04391deb 346 /*
7bb41152
ACM
347 * If we're further behind than half the buffer, there's a chance
348 * the writer will bite our tail and mess up the samples under us.
349 *
350 * If we somehow ended up ahead of the head, we got messed up.
351 *
352 * In either case, truncate and restart at head.
04391deb 353 */
7bb41152
ACM
354 int diff = head - old;
355 if (diff > md->mask / 2 || diff < 0) {
356 fprintf(stderr, "WARNING: failed to keep up with mmap data.\n");
357
358 /*
359 * head points to a known good entry, start there.
360 */
361 old = head;
362 }
04391deb
ACM
363 }
364
365 if (old != head) {
366 size_t size;
367
8115d60c 368 event = (union perf_event *)&data[old & md->mask];
04391deb
ACM
369 size = event->header.size;
370
371 /*
372 * Event straddles the mmap boundary -- header should always
373 * be inside due to u64 alignment of output.
374 */
375 if ((old & md->mask) + size != ((old + size) & md->mask)) {
376 unsigned int offset = old;
377 unsigned int len = min(sizeof(*event), size), cpy;
0479b8b9 378 void *dst = &md->event_copy;
04391deb
ACM
379
380 do {
381 cpy = min(md->mask + 1 - (offset & md->mask), len);
382 memcpy(dst, &data[offset & md->mask], cpy);
383 offset += cpy;
384 dst += cpy;
385 len -= cpy;
386 } while (len);
387
0479b8b9 388 event = &md->event_copy;
04391deb
ACM
389 }
390
391 old += size;
392 }
393
394 md->prev = old;
7bb41152
ACM
395
396 if (!evlist->overwrite)
397 perf_mmap__write_tail(md, old);
398
04391deb
ACM
399 return event;
400}
f8a95309 401
7e2ed097 402void perf_evlist__munmap(struct perf_evlist *evlist)
f8a95309 403{
aece948f 404 int i;
f8a95309 405
aece948f
ACM
406 for (i = 0; i < evlist->nr_mmaps; i++) {
407 if (evlist->mmap[i].base != NULL) {
408 munmap(evlist->mmap[i].base, evlist->mmap_len);
409 evlist->mmap[i].base = NULL;
f8a95309
ACM
410 }
411 }
aece948f
ACM
412
413 free(evlist->mmap);
414 evlist->mmap = NULL;
f8a95309
ACM
415}
416
806fb630 417static int perf_evlist__alloc_mmap(struct perf_evlist *evlist)
f8a95309 418{
a14bb7a6
ACM
419 evlist->nr_mmaps = cpu_map__nr(evlist->cpus);
420 if (cpu_map__all(evlist->cpus))
aece948f
ACM
421 evlist->nr_mmaps = evlist->threads->nr;
422 evlist->mmap = zalloc(evlist->nr_mmaps * sizeof(struct perf_mmap));
f8a95309
ACM
423 return evlist->mmap != NULL ? 0 : -ENOMEM;
424}
425
bccdaba0 426static int __perf_evlist__mmap(struct perf_evlist *evlist,
aece948f 427 int idx, int prot, int mask, int fd)
f8a95309 428{
aece948f
ACM
429 evlist->mmap[idx].prev = 0;
430 evlist->mmap[idx].mask = mask;
431 evlist->mmap[idx].base = mmap(NULL, evlist->mmap_len, prot,
f8a95309 432 MAP_SHARED, fd, 0);
301b195d
NE
433 if (evlist->mmap[idx].base == MAP_FAILED) {
434 evlist->mmap[idx].base = NULL;
f8a95309 435 return -1;
301b195d 436 }
f8a95309
ACM
437
438 perf_evlist__add_pollfd(evlist, fd);
439 return 0;
440}
441
aece948f
ACM
442static int perf_evlist__mmap_per_cpu(struct perf_evlist *evlist, int prot, int mask)
443{
444 struct perf_evsel *evsel;
445 int cpu, thread;
446
447 for (cpu = 0; cpu < evlist->cpus->nr; cpu++) {
448 int output = -1;
449
450 for (thread = 0; thread < evlist->threads->nr; thread++) {
451 list_for_each_entry(evsel, &evlist->entries, node) {
452 int fd = FD(evsel, cpu, thread);
453
454 if (output == -1) {
455 output = fd;
bccdaba0 456 if (__perf_evlist__mmap(evlist, cpu,
aece948f
ACM
457 prot, mask, output) < 0)
458 goto out_unmap;
459 } else {
460 if (ioctl(fd, PERF_EVENT_IOC_SET_OUTPUT, output) != 0)
461 goto out_unmap;
462 }
463
464 if ((evsel->attr.read_format & PERF_FORMAT_ID) &&
465 perf_evlist__id_add_fd(evlist, evsel, cpu, thread, fd) < 0)
466 goto out_unmap;
467 }
468 }
469 }
470
471 return 0;
472
473out_unmap:
474 for (cpu = 0; cpu < evlist->cpus->nr; cpu++) {
475 if (evlist->mmap[cpu].base != NULL) {
476 munmap(evlist->mmap[cpu].base, evlist->mmap_len);
477 evlist->mmap[cpu].base = NULL;
478 }
479 }
480 return -1;
481}
482
483static int perf_evlist__mmap_per_thread(struct perf_evlist *evlist, int prot, int mask)
484{
485 struct perf_evsel *evsel;
486 int thread;
487
488 for (thread = 0; thread < evlist->threads->nr; thread++) {
489 int output = -1;
490
491 list_for_each_entry(evsel, &evlist->entries, node) {
492 int fd = FD(evsel, 0, thread);
493
494 if (output == -1) {
495 output = fd;
bccdaba0 496 if (__perf_evlist__mmap(evlist, thread,
aece948f
ACM
497 prot, mask, output) < 0)
498 goto out_unmap;
499 } else {
500 if (ioctl(fd, PERF_EVENT_IOC_SET_OUTPUT, output) != 0)
501 goto out_unmap;
502 }
503
504 if ((evsel->attr.read_format & PERF_FORMAT_ID) &&
505 perf_evlist__id_add_fd(evlist, evsel, 0, thread, fd) < 0)
506 goto out_unmap;
507 }
508 }
509
510 return 0;
511
512out_unmap:
513 for (thread = 0; thread < evlist->threads->nr; thread++) {
514 if (evlist->mmap[thread].base != NULL) {
515 munmap(evlist->mmap[thread].base, evlist->mmap_len);
516 evlist->mmap[thread].base = NULL;
517 }
518 }
519 return -1;
520}
521
f8a95309
ACM
522/** perf_evlist__mmap - Create per cpu maps to receive events
523 *
524 * @evlist - list of events
f8a95309
ACM
525 * @pages - map length in pages
526 * @overwrite - overwrite older events?
527 *
528 * If overwrite is false the user needs to signal event consuption using:
529 *
530 * struct perf_mmap *m = &evlist->mmap[cpu];
531 * unsigned int head = perf_mmap__read_head(m);
532 *
533 * perf_mmap__write_tail(m, head)
7e2ed097
ACM
534 *
535 * Using perf_evlist__read_on_cpu does this automatically.
f8a95309 536 */
50a682ce
ACM
537int perf_evlist__mmap(struct perf_evlist *evlist, unsigned int pages,
538 bool overwrite)
f8a95309 539{
aece948f 540 struct perf_evsel *evsel;
7e2ed097
ACM
541 const struct cpu_map *cpus = evlist->cpus;
542 const struct thread_map *threads = evlist->threads;
50a682ce
ACM
543 int prot = PROT_READ | (overwrite ? 0 : PROT_WRITE), mask;
544
545 /* 512 kiB: default amount of unprivileged mlocked memory */
546 if (pages == UINT_MAX)
547 pages = (512 * 1024) / page_size;
41d0d933
NE
548 else if (!is_power_of_2(pages))
549 return -EINVAL;
50a682ce
ACM
550
551 mask = pages * page_size - 1;
f8a95309 552
7e2ed097 553 if (evlist->mmap == NULL && perf_evlist__alloc_mmap(evlist) < 0)
f8a95309
ACM
554 return -ENOMEM;
555
7e2ed097 556 if (evlist->pollfd == NULL && perf_evlist__alloc_pollfd(evlist) < 0)
f8a95309
ACM
557 return -ENOMEM;
558
559 evlist->overwrite = overwrite;
560 evlist->mmap_len = (pages + 1) * page_size;
f8a95309
ACM
561
562 list_for_each_entry(evsel, &evlist->entries, node) {
563 if ((evsel->attr.read_format & PERF_FORMAT_ID) &&
a91e5431 564 evsel->sample_id == NULL &&
a14bb7a6 565 perf_evsel__alloc_id(evsel, cpu_map__nr(cpus), threads->nr) < 0)
f8a95309 566 return -ENOMEM;
f8a95309
ACM
567 }
568
a14bb7a6 569 if (cpu_map__all(cpus))
aece948f 570 return perf_evlist__mmap_per_thread(evlist, prot, mask);
f8a95309 571
aece948f 572 return perf_evlist__mmap_per_cpu(evlist, prot, mask);
f8a95309 573}
7e2ed097 574
b809ac10
NK
575int perf_evlist__create_maps(struct perf_evlist *evlist,
576 struct perf_target *target)
7e2ed097 577{
b809ac10
NK
578 evlist->threads = thread_map__new_str(target->pid, target->tid,
579 target->uid);
7e2ed097
ACM
580
581 if (evlist->threads == NULL)
582 return -1;
583
879d77d0 584 if (perf_target__has_task(target))
d67356e7 585 evlist->cpus = cpu_map__dummy_new();
d1cb9fce
NK
586 else if (!perf_target__has_cpu(target) && !target->uses_mmap)
587 evlist->cpus = cpu_map__dummy_new();
879d77d0
NK
588 else
589 evlist->cpus = cpu_map__new(target->cpu_list);
7e2ed097
ACM
590
591 if (evlist->cpus == NULL)
592 goto out_delete_threads;
593
594 return 0;
595
596out_delete_threads:
597 thread_map__delete(evlist->threads);
598 return -1;
599}
600
601void perf_evlist__delete_maps(struct perf_evlist *evlist)
602{
603 cpu_map__delete(evlist->cpus);
604 thread_map__delete(evlist->threads);
605 evlist->cpus = NULL;
606 evlist->threads = NULL;
607}
0a102479 608
1491a632 609int perf_evlist__apply_filters(struct perf_evlist *evlist)
0a102479 610{
0a102479 611 struct perf_evsel *evsel;
745cefc5
ACM
612 int err = 0;
613 const int ncpus = cpu_map__nr(evlist->cpus),
614 nthreads = evlist->threads->nr;
0a102479
FW
615
616 list_for_each_entry(evsel, &evlist->entries, node) {
745cefc5 617 if (evsel->filter == NULL)
0a102479 618 continue;
745cefc5
ACM
619
620 err = perf_evsel__set_filter(evsel, ncpus, nthreads, evsel->filter);
621 if (err)
622 break;
0a102479
FW
623 }
624
745cefc5
ACM
625 return err;
626}
627
628int perf_evlist__set_filter(struct perf_evlist *evlist, const char *filter)
629{
630 struct perf_evsel *evsel;
631 int err = 0;
632 const int ncpus = cpu_map__nr(evlist->cpus),
633 nthreads = evlist->threads->nr;
634
635 list_for_each_entry(evsel, &evlist->entries, node) {
636 err = perf_evsel__set_filter(evsel, ncpus, nthreads, filter);
637 if (err)
638 break;
639 }
640
641 return err;
0a102479 642}
74429964 643
0c21f736 644bool perf_evlist__valid_sample_type(struct perf_evlist *evlist)
74429964 645{
0c21f736 646 struct perf_evsel *first = perf_evlist__first(evlist), *pos = first;
c2a70653
ACM
647
648 list_for_each_entry_continue(pos, &evlist->entries, node) {
649 if (first->attr.sample_type != pos->attr.sample_type)
650 return false;
74429964
FW
651 }
652
c2a70653 653 return true;
74429964
FW
654}
655
0c21f736 656u64 perf_evlist__sample_type(struct perf_evlist *evlist)
c2a70653 657{
0c21f736 658 struct perf_evsel *first = perf_evlist__first(evlist);
c2a70653
ACM
659 return first->attr.sample_type;
660}
661
0c21f736 662u16 perf_evlist__id_hdr_size(struct perf_evlist *evlist)
81e36bff 663{
0c21f736 664 struct perf_evsel *first = perf_evlist__first(evlist);
81e36bff
ACM
665 struct perf_sample *data;
666 u64 sample_type;
667 u16 size = 0;
668
81e36bff
ACM
669 if (!first->attr.sample_id_all)
670 goto out;
671
672 sample_type = first->attr.sample_type;
673
674 if (sample_type & PERF_SAMPLE_TID)
675 size += sizeof(data->tid) * 2;
676
677 if (sample_type & PERF_SAMPLE_TIME)
678 size += sizeof(data->time);
679
680 if (sample_type & PERF_SAMPLE_ID)
681 size += sizeof(data->id);
682
683 if (sample_type & PERF_SAMPLE_STREAM_ID)
684 size += sizeof(data->stream_id);
685
686 if (sample_type & PERF_SAMPLE_CPU)
687 size += sizeof(data->cpu) * 2;
688out:
689 return size;
690}
691
0c21f736 692bool perf_evlist__valid_sample_id_all(struct perf_evlist *evlist)
74429964 693{
0c21f736 694 struct perf_evsel *first = perf_evlist__first(evlist), *pos = first;
c2a70653
ACM
695
696 list_for_each_entry_continue(pos, &evlist->entries, node) {
697 if (first->attr.sample_id_all != pos->attr.sample_id_all)
698 return false;
74429964
FW
699 }
700
c2a70653
ACM
701 return true;
702}
703
0c21f736 704bool perf_evlist__sample_id_all(struct perf_evlist *evlist)
c2a70653 705{
0c21f736 706 struct perf_evsel *first = perf_evlist__first(evlist);
c2a70653 707 return first->attr.sample_id_all;
74429964 708}
81cce8de
ACM
709
710void perf_evlist__set_selected(struct perf_evlist *evlist,
711 struct perf_evsel *evsel)
712{
713 evlist->selected = evsel;
714}
727ab04e 715
6a4bb04c 716int perf_evlist__open(struct perf_evlist *evlist)
727ab04e 717{
6a4bb04c 718 struct perf_evsel *evsel;
727ab04e
ACM
719 int err, ncpus, nthreads;
720
727ab04e 721 list_for_each_entry(evsel, &evlist->entries, node) {
6a4bb04c 722 err = perf_evsel__open(evsel, evlist->cpus, evlist->threads);
727ab04e
ACM
723 if (err < 0)
724 goto out_err;
725 }
726
727 return 0;
728out_err:
729 ncpus = evlist->cpus ? evlist->cpus->nr : 1;
730 nthreads = evlist->threads ? evlist->threads->nr : 1;
731
732 list_for_each_entry_reverse(evsel, &evlist->entries, node)
733 perf_evsel__close(evsel, ncpus, nthreads);
734
41c21a68 735 errno = -err;
727ab04e
ACM
736 return err;
737}
35b9d88e
ACM
738
739int perf_evlist__prepare_workload(struct perf_evlist *evlist,
740 struct perf_record_opts *opts,
741 const char *argv[])
742{
743 int child_ready_pipe[2], go_pipe[2];
744 char bf;
745
746 if (pipe(child_ready_pipe) < 0) {
747 perror("failed to create 'ready' pipe");
748 return -1;
749 }
750
751 if (pipe(go_pipe) < 0) {
752 perror("failed to create 'go' pipe");
753 goto out_close_ready_pipe;
754 }
755
756 evlist->workload.pid = fork();
757 if (evlist->workload.pid < 0) {
758 perror("failed to fork");
759 goto out_close_pipes;
760 }
761
762 if (!evlist->workload.pid) {
763 if (opts->pipe_output)
764 dup2(2, 1);
765
766 close(child_ready_pipe[0]);
767 close(go_pipe[1]);
768 fcntl(go_pipe[0], F_SETFD, FD_CLOEXEC);
769
770 /*
771 * Do a dummy execvp to get the PLT entry resolved,
772 * so we avoid the resolver overhead on the real
773 * execvp call.
774 */
775 execvp("", (char **)argv);
776
777 /*
778 * Tell the parent we're ready to go
779 */
780 close(child_ready_pipe[1]);
781
782 /*
783 * Wait until the parent tells us to go.
784 */
785 if (read(go_pipe[0], &bf, 1) == -1)
786 perror("unable to read pipe");
787
788 execvp(argv[0], (char **)argv);
789
790 perror(argv[0]);
791 kill(getppid(), SIGUSR1);
792 exit(-1);
793 }
794
d67356e7 795 if (perf_target__none(&opts->target))
35b9d88e
ACM
796 evlist->threads->map[0] = evlist->workload.pid;
797
798 close(child_ready_pipe[1]);
799 close(go_pipe[0]);
800 /*
801 * wait for child to settle
802 */
803 if (read(child_ready_pipe[0], &bf, 1) == -1) {
804 perror("unable to read pipe");
805 goto out_close_pipes;
806 }
807
808 evlist->workload.cork_fd = go_pipe[1];
809 close(child_ready_pipe[0]);
810 return 0;
811
812out_close_pipes:
813 close(go_pipe[0]);
814 close(go_pipe[1]);
815out_close_ready_pipe:
816 close(child_ready_pipe[0]);
817 close(child_ready_pipe[1]);
818 return -1;
819}
820
821int perf_evlist__start_workload(struct perf_evlist *evlist)
822{
823 if (evlist->workload.cork_fd > 0) {
824 /*
825 * Remove the cork, let it rip!
826 */
827 return close(evlist->workload.cork_fd);
828 }
829
830 return 0;
831}
cb0b29e0 832
a3f698fe 833int perf_evlist__parse_sample(struct perf_evlist *evlist, union perf_event *event,
0807d2d8 834 struct perf_sample *sample)
cb0b29e0 835{
0c21f736 836 struct perf_evsel *evsel = perf_evlist__first(evlist);
0807d2d8 837 return perf_evsel__parse_sample(evsel, event, sample);
cb0b29e0 838}
78f067b3
ACM
839
840size_t perf_evlist__fprintf(struct perf_evlist *evlist, FILE *fp)
841{
842 struct perf_evsel *evsel;
843 size_t printed = 0;
844
845 list_for_each_entry(evsel, &evlist->entries, node) {
846 printed += fprintf(fp, "%s%s", evsel->idx ? ", " : "",
847 perf_evsel__name(evsel));
848 }
849
850 return printed + fprintf(fp, "\n");;
851}