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