perf evlist: Factor out a function to propagate maps for a single evsel
[linux-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"
956fa571 10#include <api/fs/fs.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"
e3e1a54f 17#include "debug.h"
35b9d88e 18#include <unistd.h>
361c99a6 19
50d08e47 20#include "parse-events.h"
994a1f78 21#include "parse-options.h"
50d08e47 22
f8a95309
ACM
23#include <sys/mman.h>
24
70db7533
ACM
25#include <linux/bitops.h>
26#include <linux/hash.h>
0389cd1f 27#include <linux/log2.h>
70db7533 28
e4b356b5
ACM
29static void perf_evlist__mmap_put(struct perf_evlist *evlist, int idx);
30static void __perf_evlist__munmap(struct perf_evlist *evlist, int idx);
31
f8a95309 32#define FD(e, x, y) (*(int *)xyarray__entry(e->fd, x, y))
a91e5431 33#define SID(e, x, y) xyarray__entry(e->sample_id, x, y)
f8a95309 34
7e2ed097
ACM
35void perf_evlist__init(struct perf_evlist *evlist, struct cpu_map *cpus,
36 struct thread_map *threads)
ef1d1af2
ACM
37{
38 int i;
39
40 for (i = 0; i < PERF_EVLIST__HLIST_SIZE; ++i)
41 INIT_HLIST_HEAD(&evlist->heads[i]);
42 INIT_LIST_HEAD(&evlist->entries);
7e2ed097 43 perf_evlist__set_maps(evlist, cpus, threads);
1b85337d 44 fdarray__init(&evlist->pollfd, 64);
35b9d88e 45 evlist->workload.pid = -1;
ef1d1af2
ACM
46}
47
334fe7a3 48struct perf_evlist *perf_evlist__new(void)
361c99a6
ACM
49{
50 struct perf_evlist *evlist = zalloc(sizeof(*evlist));
51
ef1d1af2 52 if (evlist != NULL)
334fe7a3 53 perf_evlist__init(evlist, NULL, NULL);
361c99a6
ACM
54
55 return evlist;
56}
57
b22d54b0
JO
58struct perf_evlist *perf_evlist__new_default(void)
59{
60 struct perf_evlist *evlist = perf_evlist__new();
61
62 if (evlist && perf_evlist__add_default(evlist)) {
63 perf_evlist__delete(evlist);
64 evlist = NULL;
65 }
66
67 return evlist;
68}
69
75562573
AH
70/**
71 * perf_evlist__set_id_pos - set the positions of event ids.
72 * @evlist: selected event list
73 *
74 * Events with compatible sample types all have the same id_pos
75 * and is_pos. For convenience, put a copy on evlist.
76 */
77void perf_evlist__set_id_pos(struct perf_evlist *evlist)
78{
79 struct perf_evsel *first = perf_evlist__first(evlist);
80
81 evlist->id_pos = first->id_pos;
82 evlist->is_pos = first->is_pos;
83}
84
733cd2fe
AH
85static void perf_evlist__update_id_pos(struct perf_evlist *evlist)
86{
87 struct perf_evsel *evsel;
88
0050f7aa 89 evlist__for_each(evlist, evsel)
733cd2fe
AH
90 perf_evsel__calc_id_pos(evsel);
91
92 perf_evlist__set_id_pos(evlist);
93}
94
361c99a6
ACM
95static void perf_evlist__purge(struct perf_evlist *evlist)
96{
97 struct perf_evsel *pos, *n;
98
0050f7aa 99 evlist__for_each_safe(evlist, n, pos) {
361c99a6 100 list_del_init(&pos->node);
d49e4695 101 pos->evlist = NULL;
361c99a6
ACM
102 perf_evsel__delete(pos);
103 }
104
105 evlist->nr_entries = 0;
106}
107
ef1d1af2 108void perf_evlist__exit(struct perf_evlist *evlist)
361c99a6 109{
04662523 110 zfree(&evlist->mmap);
1b85337d 111 fdarray__exit(&evlist->pollfd);
ef1d1af2
ACM
112}
113
114void perf_evlist__delete(struct perf_evlist *evlist)
115{
983874d1 116 perf_evlist__munmap(evlist);
f26e1c7c 117 perf_evlist__close(evlist);
f30a79b0 118 cpu_map__put(evlist->cpus);
186fbb74 119 thread_map__put(evlist->threads);
03ad9747
ACM
120 evlist->cpus = NULL;
121 evlist->threads = NULL;
ef1d1af2
ACM
122 perf_evlist__purge(evlist);
123 perf_evlist__exit(evlist);
361c99a6
ACM
124 free(evlist);
125}
126
adc0c3e8
AH
127static void __perf_evlist__propagate_maps(struct perf_evlist *evlist,
128 struct perf_evsel *evsel)
129{
130 /*
131 * We already have cpus for evsel (via PMU sysfs) so
132 * keep it, if there's no target cpu list defined.
133 */
134 if (!evsel->own_cpus || evlist->has_user_cpus) {
135 cpu_map__put(evsel->cpus);
136 evsel->cpus = cpu_map__get(evlist->cpus);
137 } else if (evsel->cpus != evsel->own_cpus) {
138 cpu_map__put(evsel->cpus);
139 evsel->cpus = cpu_map__get(evsel->own_cpus);
140 }
141
142 thread_map__put(evsel->threads);
143 evsel->threads = thread_map__get(evlist->threads);
144}
145
146static void perf_evlist__propagate_maps(struct perf_evlist *evlist)
147{
148 struct perf_evsel *evsel;
149
150 evlist__for_each(evlist, evsel)
151 __perf_evlist__propagate_maps(evlist, evsel);
152}
153
361c99a6
ACM
154void perf_evlist__add(struct perf_evlist *evlist, struct perf_evsel *entry)
155{
d49e4695 156 entry->evlist = evlist;
361c99a6 157 list_add_tail(&entry->node, &evlist->entries);
ef503831 158 entry->idx = evlist->nr_entries;
60b0896c 159 entry->tracking = !entry->idx;
ef503831 160
75562573
AH
161 if (!evlist->nr_entries++)
162 perf_evlist__set_id_pos(evlist);
361c99a6
ACM
163}
164
0529bc1f 165void perf_evlist__splice_list_tail(struct perf_evlist *evlist,
f114d6ef 166 struct list_head *list)
50d08e47 167{
f114d6ef 168 struct perf_evsel *evsel, *temp;
75562573 169
f114d6ef
AH
170 __evlist__for_each_safe(list, temp, evsel) {
171 list_del_init(&evsel->node);
172 perf_evlist__add(evlist, evsel);
173 }
50d08e47
ACM
174}
175
63dab225
ACM
176void __perf_evlist__set_leader(struct list_head *list)
177{
178 struct perf_evsel *evsel, *leader;
179
180 leader = list_entry(list->next, struct perf_evsel, node);
97f63e4a
NK
181 evsel = list_entry(list->prev, struct perf_evsel, node);
182
183 leader->nr_members = evsel->idx - leader->idx + 1;
63dab225 184
0050f7aa 185 __evlist__for_each(list, evsel) {
74b2133d 186 evsel->leader = leader;
63dab225
ACM
187 }
188}
189
190void perf_evlist__set_leader(struct perf_evlist *evlist)
6a4bb04c 191{
97f63e4a
NK
192 if (evlist->nr_entries) {
193 evlist->nr_groups = evlist->nr_entries > 1 ? 1 : 0;
63dab225 194 __perf_evlist__set_leader(&evlist->entries);
97f63e4a 195 }
6a4bb04c
JO
196}
197
361c99a6
ACM
198int perf_evlist__add_default(struct perf_evlist *evlist)
199{
200 struct perf_event_attr attr = {
201 .type = PERF_TYPE_HARDWARE,
202 .config = PERF_COUNT_HW_CPU_CYCLES,
203 };
1aed2671
JR
204 struct perf_evsel *evsel;
205
206 event_attr_init(&attr);
361c99a6 207
ef503831 208 evsel = perf_evsel__new(&attr);
361c99a6 209 if (evsel == NULL)
cc2d86b0
SE
210 goto error;
211
212 /* use strdup() because free(evsel) assumes name is allocated */
213 evsel->name = strdup("cycles");
214 if (!evsel->name)
215 goto error_free;
361c99a6
ACM
216
217 perf_evlist__add(evlist, evsel);
218 return 0;
cc2d86b0
SE
219error_free:
220 perf_evsel__delete(evsel);
221error:
222 return -ENOMEM;
361c99a6 223}
5c581041 224
e60fc847
ACM
225static int perf_evlist__add_attrs(struct perf_evlist *evlist,
226 struct perf_event_attr *attrs, size_t nr_attrs)
50d08e47
ACM
227{
228 struct perf_evsel *evsel, *n;
229 LIST_HEAD(head);
230 size_t i;
231
232 for (i = 0; i < nr_attrs; i++) {
ef503831 233 evsel = perf_evsel__new_idx(attrs + i, evlist->nr_entries + i);
50d08e47
ACM
234 if (evsel == NULL)
235 goto out_delete_partial_list;
236 list_add_tail(&evsel->node, &head);
237 }
238
f114d6ef 239 perf_evlist__splice_list_tail(evlist, &head);
50d08e47
ACM
240
241 return 0;
242
243out_delete_partial_list:
0050f7aa 244 __evlist__for_each_safe(&head, n, evsel)
50d08e47
ACM
245 perf_evsel__delete(evsel);
246 return -1;
247}
248
79695e1b
ACM
249int __perf_evlist__add_default_attrs(struct perf_evlist *evlist,
250 struct perf_event_attr *attrs, size_t nr_attrs)
251{
252 size_t i;
253
254 for (i = 0; i < nr_attrs; i++)
255 event_attr_init(attrs + i);
256
257 return perf_evlist__add_attrs(evlist, attrs, nr_attrs);
258}
259
da378962
ACM
260struct perf_evsel *
261perf_evlist__find_tracepoint_by_id(struct perf_evlist *evlist, int id)
ee29be62
ACM
262{
263 struct perf_evsel *evsel;
264
0050f7aa 265 evlist__for_each(evlist, evsel) {
ee29be62
ACM
266 if (evsel->attr.type == PERF_TYPE_TRACEPOINT &&
267 (int)evsel->attr.config == id)
268 return evsel;
269 }
270
271 return NULL;
272}
273
a2f2804a
DA
274struct perf_evsel *
275perf_evlist__find_tracepoint_by_name(struct perf_evlist *evlist,
276 const char *name)
277{
278 struct perf_evsel *evsel;
279
0050f7aa 280 evlist__for_each(evlist, evsel) {
a2f2804a
DA
281 if ((evsel->attr.type == PERF_TYPE_TRACEPOINT) &&
282 (strcmp(evsel->name, name) == 0))
283 return evsel;
284 }
285
286 return NULL;
287}
288
39876e7d
ACM
289int perf_evlist__add_newtp(struct perf_evlist *evlist,
290 const char *sys, const char *name, void *handler)
291{
ef503831 292 struct perf_evsel *evsel = perf_evsel__newtp(sys, name);
39876e7d 293
39876e7d
ACM
294 if (evsel == NULL)
295 return -1;
296
744a9719 297 evsel->handler = handler;
39876e7d
ACM
298 perf_evlist__add(evlist, evsel);
299 return 0;
300}
301
bf8e8f4b
AH
302static int perf_evlist__nr_threads(struct perf_evlist *evlist,
303 struct perf_evsel *evsel)
304{
305 if (evsel->system_wide)
306 return 1;
307 else
308 return thread_map__nr(evlist->threads);
309}
310
4152ab37
ACM
311void perf_evlist__disable(struct perf_evlist *evlist)
312{
313 int cpu, thread;
314 struct perf_evsel *pos;
b3a319d5 315 int nr_cpus = cpu_map__nr(evlist->cpus);
bf8e8f4b 316 int nr_threads;
4152ab37 317
b3a319d5 318 for (cpu = 0; cpu < nr_cpus; cpu++) {
0050f7aa 319 evlist__for_each(evlist, pos) {
395c3070 320 if (!perf_evsel__is_group_leader(pos) || !pos->fd)
3fe4430d 321 continue;
bf8e8f4b 322 nr_threads = perf_evlist__nr_threads(evlist, pos);
b3a319d5 323 for (thread = 0; thread < nr_threads; thread++)
55da8005
NK
324 ioctl(FD(pos, cpu, thread),
325 PERF_EVENT_IOC_DISABLE, 0);
4152ab37
ACM
326 }
327 }
2b56bcfb
ACM
328
329 evlist->enabled = false;
4152ab37
ACM
330}
331
764e16a3
DA
332void perf_evlist__enable(struct perf_evlist *evlist)
333{
334 int cpu, thread;
335 struct perf_evsel *pos;
b3a319d5 336 int nr_cpus = cpu_map__nr(evlist->cpus);
bf8e8f4b 337 int nr_threads;
764e16a3 338
b3a319d5 339 for (cpu = 0; cpu < nr_cpus; cpu++) {
0050f7aa 340 evlist__for_each(evlist, pos) {
395c3070 341 if (!perf_evsel__is_group_leader(pos) || !pos->fd)
3fe4430d 342 continue;
bf8e8f4b 343 nr_threads = perf_evlist__nr_threads(evlist, pos);
b3a319d5 344 for (thread = 0; thread < nr_threads; thread++)
55da8005
NK
345 ioctl(FD(pos, cpu, thread),
346 PERF_EVENT_IOC_ENABLE, 0);
764e16a3
DA
347 }
348 }
2b56bcfb
ACM
349
350 evlist->enabled = true;
351}
352
353void perf_evlist__toggle_enable(struct perf_evlist *evlist)
354{
355 (evlist->enabled ? perf_evlist__disable : perf_evlist__enable)(evlist);
764e16a3
DA
356}
357
395c3070
AH
358int perf_evlist__disable_event(struct perf_evlist *evlist,
359 struct perf_evsel *evsel)
360{
361 int cpu, thread, err;
bf8e8f4b
AH
362 int nr_cpus = cpu_map__nr(evlist->cpus);
363 int nr_threads = perf_evlist__nr_threads(evlist, evsel);
395c3070
AH
364
365 if (!evsel->fd)
366 return 0;
367
bf8e8f4b
AH
368 for (cpu = 0; cpu < nr_cpus; cpu++) {
369 for (thread = 0; thread < nr_threads; thread++) {
395c3070
AH
370 err = ioctl(FD(evsel, cpu, thread),
371 PERF_EVENT_IOC_DISABLE, 0);
372 if (err)
373 return err;
374 }
375 }
376 return 0;
377}
378
379int perf_evlist__enable_event(struct perf_evlist *evlist,
380 struct perf_evsel *evsel)
381{
382 int cpu, thread, err;
bf8e8f4b
AH
383 int nr_cpus = cpu_map__nr(evlist->cpus);
384 int nr_threads = perf_evlist__nr_threads(evlist, evsel);
395c3070
AH
385
386 if (!evsel->fd)
387 return -EINVAL;
388
bf8e8f4b
AH
389 for (cpu = 0; cpu < nr_cpus; cpu++) {
390 for (thread = 0; thread < nr_threads; thread++) {
395c3070
AH
391 err = ioctl(FD(evsel, cpu, thread),
392 PERF_EVENT_IOC_ENABLE, 0);
393 if (err)
394 return err;
395 }
396 }
397 return 0;
398}
399
1c65056c
AH
400static int perf_evlist__enable_event_cpu(struct perf_evlist *evlist,
401 struct perf_evsel *evsel, int cpu)
402{
403 int thread, err;
404 int nr_threads = perf_evlist__nr_threads(evlist, evsel);
405
406 if (!evsel->fd)
407 return -EINVAL;
408
409 for (thread = 0; thread < nr_threads; thread++) {
410 err = ioctl(FD(evsel, cpu, thread),
411 PERF_EVENT_IOC_ENABLE, 0);
412 if (err)
413 return err;
414 }
415 return 0;
416}
417
418static int perf_evlist__enable_event_thread(struct perf_evlist *evlist,
419 struct perf_evsel *evsel,
420 int thread)
421{
422 int cpu, err;
423 int nr_cpus = cpu_map__nr(evlist->cpus);
424
425 if (!evsel->fd)
426 return -EINVAL;
427
428 for (cpu = 0; cpu < nr_cpus; cpu++) {
429 err = ioctl(FD(evsel, cpu, thread), PERF_EVENT_IOC_ENABLE, 0);
430 if (err)
431 return err;
432 }
433 return 0;
434}
435
436int perf_evlist__enable_event_idx(struct perf_evlist *evlist,
437 struct perf_evsel *evsel, int idx)
438{
439 bool per_cpu_mmaps = !cpu_map__empty(evlist->cpus);
440
441 if (per_cpu_mmaps)
442 return perf_evlist__enable_event_cpu(evlist, evsel, idx);
443 else
444 return perf_evlist__enable_event_thread(evlist, evsel, idx);
445}
446
ad6765dd 447int perf_evlist__alloc_pollfd(struct perf_evlist *evlist)
5c581041 448{
b3a319d5
NK
449 int nr_cpus = cpu_map__nr(evlist->cpus);
450 int nr_threads = thread_map__nr(evlist->threads);
bf8e8f4b
AH
451 int nfds = 0;
452 struct perf_evsel *evsel;
453
cba9b847 454 evlist__for_each(evlist, evsel) {
bf8e8f4b
AH
455 if (evsel->system_wide)
456 nfds += nr_cpus;
457 else
458 nfds += nr_cpus * nr_threads;
459 }
460
1b85337d
ACM
461 if (fdarray__available_entries(&evlist->pollfd) < nfds &&
462 fdarray__grow(&evlist->pollfd, nfds) < 0)
ad6765dd
ACM
463 return -ENOMEM;
464
465 return 0;
5c581041 466}
70082dd9 467
e4b356b5
ACM
468static int __perf_evlist__add_pollfd(struct perf_evlist *evlist, int fd, int idx)
469{
470 int pos = fdarray__add(&evlist->pollfd, fd, POLLIN | POLLERR | POLLHUP);
471 /*
472 * Save the idx so that when we filter out fds POLLHUP'ed we can
473 * close the associated evlist->mmap[] entry.
474 */
475 if (pos >= 0) {
476 evlist->pollfd.priv[pos].idx = idx;
477
478 fcntl(fd, F_SETFL, O_NONBLOCK);
479 }
480
481 return pos;
482}
483
ad6765dd 484int perf_evlist__add_pollfd(struct perf_evlist *evlist, int fd)
70082dd9 485{
e4b356b5
ACM
486 return __perf_evlist__add_pollfd(evlist, fd, -1);
487}
488
489static void perf_evlist__munmap_filtered(struct fdarray *fda, int fd)
490{
491 struct perf_evlist *evlist = container_of(fda, struct perf_evlist, pollfd);
1b85337d 492
e4b356b5 493 perf_evlist__mmap_put(evlist, fda->priv[fd].idx);
70082dd9 494}
70db7533 495
1ddec7f0
ACM
496int perf_evlist__filter_pollfd(struct perf_evlist *evlist, short revents_and_mask)
497{
e4b356b5
ACM
498 return fdarray__filter(&evlist->pollfd, revents_and_mask,
499 perf_evlist__munmap_filtered);
1ddec7f0
ACM
500}
501
f66a889d
ACM
502int perf_evlist__poll(struct perf_evlist *evlist, int timeout)
503{
1b85337d 504 return fdarray__poll(&evlist->pollfd, timeout);
f66a889d
ACM
505}
506
a91e5431
ACM
507static void perf_evlist__id_hash(struct perf_evlist *evlist,
508 struct perf_evsel *evsel,
509 int cpu, int thread, u64 id)
3d3b5e95
ACM
510{
511 int hash;
512 struct perf_sample_id *sid = SID(evsel, cpu, thread);
513
514 sid->id = id;
515 sid->evsel = evsel;
516 hash = hash_64(sid->id, PERF_EVLIST__HLIST_BITS);
517 hlist_add_head(&sid->node, &evlist->heads[hash]);
518}
519
a91e5431
ACM
520void perf_evlist__id_add(struct perf_evlist *evlist, struct perf_evsel *evsel,
521 int cpu, int thread, u64 id)
522{
523 perf_evlist__id_hash(evlist, evsel, cpu, thread, id);
524 evsel->id[evsel->ids++] = id;
525}
526
527static int perf_evlist__id_add_fd(struct perf_evlist *evlist,
528 struct perf_evsel *evsel,
529 int cpu, int thread, int fd)
f8a95309 530{
f8a95309 531 u64 read_data[4] = { 0, };
3d3b5e95 532 int id_idx = 1; /* The first entry is the counter value */
e2b5abe0
JO
533 u64 id;
534 int ret;
535
536 ret = ioctl(fd, PERF_EVENT_IOC_ID, &id);
537 if (!ret)
538 goto add;
539
540 if (errno != ENOTTY)
541 return -1;
542
543 /* Legacy way to get event id.. All hail to old kernels! */
f8a95309 544
c4861afe
JO
545 /*
546 * This way does not work with group format read, so bail
547 * out in that case.
548 */
549 if (perf_evlist__read_format(evlist) & PERF_FORMAT_GROUP)
550 return -1;
551
f8a95309
ACM
552 if (!(evsel->attr.read_format & PERF_FORMAT_ID) ||
553 read(fd, &read_data, sizeof(read_data)) == -1)
554 return -1;
555
556 if (evsel->attr.read_format & PERF_FORMAT_TOTAL_TIME_ENABLED)
557 ++id_idx;
558 if (evsel->attr.read_format & PERF_FORMAT_TOTAL_TIME_RUNNING)
559 ++id_idx;
560
e2b5abe0
JO
561 id = read_data[id_idx];
562
563 add:
564 perf_evlist__id_add(evlist, evsel, cpu, thread, id);
f8a95309
ACM
565 return 0;
566}
567
3c659eed
AH
568static void perf_evlist__set_sid_idx(struct perf_evlist *evlist,
569 struct perf_evsel *evsel, int idx, int cpu,
570 int thread)
571{
572 struct perf_sample_id *sid = SID(evsel, cpu, thread);
573 sid->idx = idx;
574 if (evlist->cpus && cpu >= 0)
575 sid->cpu = evlist->cpus->map[cpu];
576 else
577 sid->cpu = -1;
578 if (!evsel->system_wide && evlist->threads && thread >= 0)
e13798c7 579 sid->tid = thread_map__pid(evlist->threads, thread);
3c659eed
AH
580 else
581 sid->tid = -1;
582}
583
932a3594 584struct perf_sample_id *perf_evlist__id2sid(struct perf_evlist *evlist, u64 id)
70db7533
ACM
585{
586 struct hlist_head *head;
70db7533
ACM
587 struct perf_sample_id *sid;
588 int hash;
589
70db7533
ACM
590 hash = hash_64(id, PERF_EVLIST__HLIST_BITS);
591 head = &evlist->heads[hash];
592
b67bfe0d 593 hlist_for_each_entry(sid, head, node)
70db7533 594 if (sid->id == id)
932a3594
JO
595 return sid;
596
597 return NULL;
598}
599
600struct perf_evsel *perf_evlist__id2evsel(struct perf_evlist *evlist, u64 id)
601{
602 struct perf_sample_id *sid;
603
05169df5 604 if (evlist->nr_entries == 1 || !id)
932a3594
JO
605 return perf_evlist__first(evlist);
606
607 sid = perf_evlist__id2sid(evlist, id);
608 if (sid)
609 return sid->evsel;
30e68bcc
NK
610
611 if (!perf_evlist__sample_id_all(evlist))
0c21f736 612 return perf_evlist__first(evlist);
30e68bcc 613
70db7533
ACM
614 return NULL;
615}
04391deb 616
75562573
AH
617static int perf_evlist__event2id(struct perf_evlist *evlist,
618 union perf_event *event, u64 *id)
619{
620 const u64 *array = event->sample.array;
621 ssize_t n;
622
623 n = (event->header.size - sizeof(event->header)) >> 3;
624
625 if (event->header.type == PERF_RECORD_SAMPLE) {
626 if (evlist->id_pos >= n)
627 return -1;
628 *id = array[evlist->id_pos];
629 } else {
630 if (evlist->is_pos > n)
631 return -1;
632 n -= evlist->is_pos;
633 *id = array[n];
634 }
635 return 0;
636}
637
638static struct perf_evsel *perf_evlist__event2evsel(struct perf_evlist *evlist,
639 union perf_event *event)
640{
98be6966 641 struct perf_evsel *first = perf_evlist__first(evlist);
75562573
AH
642 struct hlist_head *head;
643 struct perf_sample_id *sid;
644 int hash;
645 u64 id;
646
647 if (evlist->nr_entries == 1)
98be6966
AH
648 return first;
649
650 if (!first->attr.sample_id_all &&
651 event->header.type != PERF_RECORD_SAMPLE)
652 return first;
75562573
AH
653
654 if (perf_evlist__event2id(evlist, event, &id))
655 return NULL;
656
657 /* Synthesized events have an id of zero */
658 if (!id)
98be6966 659 return first;
75562573
AH
660
661 hash = hash_64(id, PERF_EVLIST__HLIST_BITS);
662 head = &evlist->heads[hash];
663
664 hlist_for_each_entry(sid, head, node) {
665 if (sid->id == id)
666 return sid->evsel;
667 }
668 return NULL;
669}
670
aece948f 671union perf_event *perf_evlist__mmap_read(struct perf_evlist *evlist, int idx)
04391deb 672{
aece948f 673 struct perf_mmap *md = &evlist->mmap[idx];
7951722d 674 u64 head;
7b8283b5 675 u64 old = md->prev;
04391deb 676 unsigned char *data = md->base + page_size;
8115d60c 677 union perf_event *event = NULL;
04391deb 678
7951722d
SB
679 /*
680 * Check if event was unmapped due to a POLLHUP/POLLERR.
681 */
682 if (!atomic_read(&md->refcnt))
683 return NULL;
684
685 head = perf_mmap__read_head(md);
7bb41152 686 if (evlist->overwrite) {
04391deb 687 /*
7bb41152
ACM
688 * If we're further behind than half the buffer, there's a chance
689 * the writer will bite our tail and mess up the samples under us.
690 *
691 * If we somehow ended up ahead of the head, we got messed up.
692 *
693 * In either case, truncate and restart at head.
04391deb 694 */
7bb41152
ACM
695 int diff = head - old;
696 if (diff > md->mask / 2 || diff < 0) {
697 fprintf(stderr, "WARNING: failed to keep up with mmap data.\n");
698
699 /*
700 * head points to a known good entry, start there.
701 */
702 old = head;
703 }
04391deb
ACM
704 }
705
706 if (old != head) {
707 size_t size;
708
8115d60c 709 event = (union perf_event *)&data[old & md->mask];
04391deb
ACM
710 size = event->header.size;
711
712 /*
713 * Event straddles the mmap boundary -- header should always
714 * be inside due to u64 alignment of output.
715 */
716 if ((old & md->mask) + size != ((old + size) & md->mask)) {
717 unsigned int offset = old;
718 unsigned int len = min(sizeof(*event), size), cpy;
a65cb4b9 719 void *dst = md->event_copy;
04391deb
ACM
720
721 do {
722 cpy = min(md->mask + 1 - (offset & md->mask), len);
723 memcpy(dst, &data[offset & md->mask], cpy);
724 offset += cpy;
725 dst += cpy;
726 len -= cpy;
727 } while (len);
728
a65cb4b9 729 event = (union perf_event *) md->event_copy;
04391deb
ACM
730 }
731
732 old += size;
733 }
734
735 md->prev = old;
7bb41152 736
04391deb
ACM
737 return event;
738}
f8a95309 739
82396986
ACM
740static bool perf_mmap__empty(struct perf_mmap *md)
741{
b72e74d1 742 return perf_mmap__read_head(md) == md->prev && !md->auxtrace_mmap.base;
82396986
ACM
743}
744
745static void perf_evlist__mmap_get(struct perf_evlist *evlist, int idx)
746{
7143849a 747 atomic_inc(&evlist->mmap[idx].refcnt);
82396986
ACM
748}
749
750static void perf_evlist__mmap_put(struct perf_evlist *evlist, int idx)
751{
7143849a 752 BUG_ON(atomic_read(&evlist->mmap[idx].refcnt) == 0);
82396986 753
7143849a 754 if (atomic_dec_and_test(&evlist->mmap[idx].refcnt))
82396986
ACM
755 __perf_evlist__munmap(evlist, idx);
756}
757
8e50d384
ZZ
758void perf_evlist__mmap_consume(struct perf_evlist *evlist, int idx)
759{
82396986
ACM
760 struct perf_mmap *md = &evlist->mmap[idx];
761
8e50d384 762 if (!evlist->overwrite) {
7b8283b5 763 u64 old = md->prev;
8e50d384
ZZ
764
765 perf_mmap__write_tail(md, old);
766 }
82396986 767
7143849a 768 if (atomic_read(&md->refcnt) == 1 && perf_mmap__empty(md))
82396986 769 perf_evlist__mmap_put(evlist, idx);
8e50d384
ZZ
770}
771
718c602d
AH
772int __weak auxtrace_mmap__mmap(struct auxtrace_mmap *mm __maybe_unused,
773 struct auxtrace_mmap_params *mp __maybe_unused,
774 void *userpg __maybe_unused,
775 int fd __maybe_unused)
776{
777 return 0;
778}
779
780void __weak auxtrace_mmap__munmap(struct auxtrace_mmap *mm __maybe_unused)
781{
782}
783
784void __weak auxtrace_mmap_params__init(
785 struct auxtrace_mmap_params *mp __maybe_unused,
786 off_t auxtrace_offset __maybe_unused,
787 unsigned int auxtrace_pages __maybe_unused,
788 bool auxtrace_overwrite __maybe_unused)
789{
790}
791
792void __weak auxtrace_mmap_params__set_idx(
793 struct auxtrace_mmap_params *mp __maybe_unused,
794 struct perf_evlist *evlist __maybe_unused,
795 int idx __maybe_unused,
796 bool per_cpu __maybe_unused)
797{
798}
799
93edcbd9
AH
800static void __perf_evlist__munmap(struct perf_evlist *evlist, int idx)
801{
802 if (evlist->mmap[idx].base != NULL) {
803 munmap(evlist->mmap[idx].base, evlist->mmap_len);
804 evlist->mmap[idx].base = NULL;
7143849a 805 atomic_set(&evlist->mmap[idx].refcnt, 0);
93edcbd9 806 }
718c602d 807 auxtrace_mmap__munmap(&evlist->mmap[idx].auxtrace_mmap);
93edcbd9
AH
808}
809
7e2ed097 810void perf_evlist__munmap(struct perf_evlist *evlist)
f8a95309 811{
aece948f 812 int i;
f8a95309 813
983874d1
ACM
814 if (evlist->mmap == NULL)
815 return;
816
93edcbd9
AH
817 for (i = 0; i < evlist->nr_mmaps; i++)
818 __perf_evlist__munmap(evlist, i);
aece948f 819
04662523 820 zfree(&evlist->mmap);
f8a95309
ACM
821}
822
806fb630 823static int perf_evlist__alloc_mmap(struct perf_evlist *evlist)
f8a95309 824{
a14bb7a6 825 evlist->nr_mmaps = cpu_map__nr(evlist->cpus);
ec1e7e43 826 if (cpu_map__empty(evlist->cpus))
b3a319d5 827 evlist->nr_mmaps = thread_map__nr(evlist->threads);
aece948f 828 evlist->mmap = zalloc(evlist->nr_mmaps * sizeof(struct perf_mmap));
f8a95309
ACM
829 return evlist->mmap != NULL ? 0 : -ENOMEM;
830}
831
a8a8f3eb
AH
832struct mmap_params {
833 int prot;
834 int mask;
718c602d 835 struct auxtrace_mmap_params auxtrace_mp;
a8a8f3eb
AH
836};
837
838static int __perf_evlist__mmap(struct perf_evlist *evlist, int idx,
839 struct mmap_params *mp, int fd)
f8a95309 840{
82396986
ACM
841 /*
842 * The last one will be done at perf_evlist__mmap_consume(), so that we
843 * make sure we don't prevent tools from consuming every last event in
844 * the ring buffer.
845 *
846 * I.e. we can get the POLLHUP meaning that the fd doesn't exist
847 * anymore, but the last events for it are still in the ring buffer,
848 * waiting to be consumed.
849 *
850 * Tools can chose to ignore this at their own discretion, but the
851 * evlist layer can't just drop it when filtering events in
852 * perf_evlist__filter_pollfd().
853 */
7143849a 854 atomic_set(&evlist->mmap[idx].refcnt, 2);
aece948f 855 evlist->mmap[idx].prev = 0;
a8a8f3eb
AH
856 evlist->mmap[idx].mask = mp->mask;
857 evlist->mmap[idx].base = mmap(NULL, evlist->mmap_len, mp->prot,
f8a95309 858 MAP_SHARED, fd, 0);
301b195d 859 if (evlist->mmap[idx].base == MAP_FAILED) {
02635965
AH
860 pr_debug2("failed to mmap perf event ring buffer, error %d\n",
861 errno);
301b195d 862 evlist->mmap[idx].base = NULL;
f8a95309 863 return -1;
301b195d 864 }
ad6765dd 865
718c602d
AH
866 if (auxtrace_mmap__mmap(&evlist->mmap[idx].auxtrace_mmap,
867 &mp->auxtrace_mp, evlist->mmap[idx].base, fd))
868 return -1;
869
f8a95309
ACM
870 return 0;
871}
872
04e21314 873static int perf_evlist__mmap_per_evsel(struct perf_evlist *evlist, int idx,
a8a8f3eb
AH
874 struct mmap_params *mp, int cpu,
875 int thread, int *output)
aece948f
ACM
876{
877 struct perf_evsel *evsel;
04e21314 878
0050f7aa 879 evlist__for_each(evlist, evsel) {
bf8e8f4b
AH
880 int fd;
881
882 if (evsel->system_wide && thread)
883 continue;
884
885 fd = FD(evsel, cpu, thread);
04e21314
AH
886
887 if (*output == -1) {
888 *output = fd;
a8a8f3eb 889 if (__perf_evlist__mmap(evlist, idx, mp, *output) < 0)
04e21314
AH
890 return -1;
891 } else {
892 if (ioctl(fd, PERF_EVENT_IOC_SET_OUTPUT, *output) != 0)
893 return -1;
82396986
ACM
894
895 perf_evlist__mmap_get(evlist, idx);
04e21314
AH
896 }
897
f90d194a
AH
898 /*
899 * The system_wide flag causes a selected event to be opened
900 * always without a pid. Consequently it will never get a
901 * POLLHUP, but it is used for tracking in combination with
902 * other events, so it should not need to be polled anyway.
903 * Therefore don't add it for polling.
904 */
905 if (!evsel->system_wide &&
906 __perf_evlist__add_pollfd(evlist, fd, idx) < 0) {
82396986 907 perf_evlist__mmap_put(evlist, idx);
ad6765dd 908 return -1;
82396986 909 }
033fa713 910
3c659eed
AH
911 if (evsel->attr.read_format & PERF_FORMAT_ID) {
912 if (perf_evlist__id_add_fd(evlist, evsel, cpu, thread,
913 fd) < 0)
914 return -1;
915 perf_evlist__set_sid_idx(evlist, evsel, idx, cpu,
916 thread);
917 }
04e21314
AH
918 }
919
920 return 0;
921}
922
a8a8f3eb
AH
923static int perf_evlist__mmap_per_cpu(struct perf_evlist *evlist,
924 struct mmap_params *mp)
04e21314 925{
aece948f 926 int cpu, thread;
b3a319d5
NK
927 int nr_cpus = cpu_map__nr(evlist->cpus);
928 int nr_threads = thread_map__nr(evlist->threads);
aece948f 929
e3e1a54f 930 pr_debug2("perf event ring buffer mmapped per cpu\n");
b3a319d5 931 for (cpu = 0; cpu < nr_cpus; cpu++) {
aece948f
ACM
932 int output = -1;
933
718c602d
AH
934 auxtrace_mmap_params__set_idx(&mp->auxtrace_mp, evlist, cpu,
935 true);
936
b3a319d5 937 for (thread = 0; thread < nr_threads; thread++) {
a8a8f3eb
AH
938 if (perf_evlist__mmap_per_evsel(evlist, cpu, mp, cpu,
939 thread, &output))
04e21314 940 goto out_unmap;
aece948f
ACM
941 }
942 }
943
944 return 0;
945
946out_unmap:
93edcbd9
AH
947 for (cpu = 0; cpu < nr_cpus; cpu++)
948 __perf_evlist__munmap(evlist, cpu);
aece948f
ACM
949 return -1;
950}
951
a8a8f3eb
AH
952static int perf_evlist__mmap_per_thread(struct perf_evlist *evlist,
953 struct mmap_params *mp)
aece948f 954{
aece948f 955 int thread;
b3a319d5 956 int nr_threads = thread_map__nr(evlist->threads);
aece948f 957
e3e1a54f 958 pr_debug2("perf event ring buffer mmapped per thread\n");
b3a319d5 959 for (thread = 0; thread < nr_threads; thread++) {
aece948f
ACM
960 int output = -1;
961
718c602d
AH
962 auxtrace_mmap_params__set_idx(&mp->auxtrace_mp, evlist, thread,
963 false);
964
a8a8f3eb
AH
965 if (perf_evlist__mmap_per_evsel(evlist, thread, mp, 0, thread,
966 &output))
04e21314 967 goto out_unmap;
aece948f
ACM
968 }
969
970 return 0;
971
972out_unmap:
93edcbd9
AH
973 for (thread = 0; thread < nr_threads; thread++)
974 __perf_evlist__munmap(evlist, thread);
aece948f
ACM
975 return -1;
976}
977
994a1f78
JO
978static size_t perf_evlist__mmap_size(unsigned long pages)
979{
8185e881
ACM
980 if (pages == UINT_MAX) {
981 int max;
982
983 if (sysctl__read_int("kernel/perf_event_mlock_kb", &max) < 0) {
984 /*
985 * Pick a once upon a time good value, i.e. things look
986 * strange since we can't read a sysctl value, but lets not
987 * die yet...
988 */
989 max = 512;
990 } else {
991 max -= (page_size / 1024);
992 }
993
994 pages = (max * 1024) / page_size;
1be300f4
ACM
995 if (!is_power_of_2(pages))
996 pages = rounddown_pow_of_two(pages);
8185e881 997 } else if (!is_power_of_2(pages))
994a1f78
JO
998 return 0;
999
1000 return (pages + 1) * page_size;
1001}
1002
33c2dcfd
DA
1003static long parse_pages_arg(const char *str, unsigned long min,
1004 unsigned long max)
994a1f78 1005{
2fbe4abe 1006 unsigned long pages, val;
27050f53
JO
1007 static struct parse_tag tags[] = {
1008 { .tag = 'B', .mult = 1 },
1009 { .tag = 'K', .mult = 1 << 10 },
1010 { .tag = 'M', .mult = 1 << 20 },
1011 { .tag = 'G', .mult = 1 << 30 },
1012 { .tag = 0 },
1013 };
994a1f78 1014
8973504b 1015 if (str == NULL)
33c2dcfd 1016 return -EINVAL;
8973504b 1017
27050f53 1018 val = parse_tag_value(str, tags);
2fbe4abe 1019 if (val != (unsigned long) -1) {
27050f53
JO
1020 /* we got file size value */
1021 pages = PERF_ALIGN(val, page_size) / page_size;
27050f53
JO
1022 } else {
1023 /* we got pages count value */
1024 char *eptr;
1025 pages = strtoul(str, &eptr, 10);
33c2dcfd
DA
1026 if (*eptr != '\0')
1027 return -EINVAL;
994a1f78
JO
1028 }
1029
2bcab6c1 1030 if (pages == 0 && min == 0) {
33c2dcfd 1031 /* leave number of pages at 0 */
1dbfa938 1032 } else if (!is_power_of_2(pages)) {
33c2dcfd 1033 /* round pages up to next power of 2 */
91529834 1034 pages = roundup_pow_of_two(pages);
1dbfa938
AH
1035 if (!pages)
1036 return -EINVAL;
9639837e
DA
1037 pr_info("rounding mmap pages size to %lu bytes (%lu pages)\n",
1038 pages * page_size, pages);
2fbe4abe
AH
1039 }
1040
33c2dcfd
DA
1041 if (pages > max)
1042 return -EINVAL;
1043
1044 return pages;
1045}
1046
e9db1310 1047int __perf_evlist__parse_mmap_pages(unsigned int *mmap_pages, const char *str)
33c2dcfd 1048{
33c2dcfd
DA
1049 unsigned long max = UINT_MAX;
1050 long pages;
1051
f5ae9c42 1052 if (max > SIZE_MAX / page_size)
33c2dcfd
DA
1053 max = SIZE_MAX / page_size;
1054
1055 pages = parse_pages_arg(str, 1, max);
1056 if (pages < 0) {
1057 pr_err("Invalid argument for --mmap_pages/-m\n");
994a1f78
JO
1058 return -1;
1059 }
1060
1061 *mmap_pages = pages;
1062 return 0;
1063}
1064
e9db1310
AH
1065int perf_evlist__parse_mmap_pages(const struct option *opt, const char *str,
1066 int unset __maybe_unused)
1067{
1068 return __perf_evlist__parse_mmap_pages(opt->value, str);
1069}
1070
c83fa7f2 1071/**
718c602d 1072 * perf_evlist__mmap_ex - Create mmaps to receive events.
c83fa7f2
AH
1073 * @evlist: list of events
1074 * @pages: map length in pages
1075 * @overwrite: overwrite older events?
718c602d
AH
1076 * @auxtrace_pages - auxtrace map length in pages
1077 * @auxtrace_overwrite - overwrite older auxtrace data?
f8a95309 1078 *
c83fa7f2
AH
1079 * If @overwrite is %false the user needs to signal event consumption using
1080 * perf_mmap__write_tail(). Using perf_evlist__mmap_read() does this
1081 * automatically.
7e2ed097 1082 *
718c602d
AH
1083 * Similarly, if @auxtrace_overwrite is %false the user needs to signal data
1084 * consumption using auxtrace_mmap__write_tail().
1085 *
c83fa7f2 1086 * Return: %0 on success, negative error code otherwise.
f8a95309 1087 */
718c602d
AH
1088int perf_evlist__mmap_ex(struct perf_evlist *evlist, unsigned int pages,
1089 bool overwrite, unsigned int auxtrace_pages,
1090 bool auxtrace_overwrite)
f8a95309 1091{
aece948f 1092 struct perf_evsel *evsel;
7e2ed097
ACM
1093 const struct cpu_map *cpus = evlist->cpus;
1094 const struct thread_map *threads = evlist->threads;
a8a8f3eb
AH
1095 struct mmap_params mp = {
1096 .prot = PROT_READ | (overwrite ? 0 : PROT_WRITE),
1097 };
50a682ce 1098
7e2ed097 1099 if (evlist->mmap == NULL && perf_evlist__alloc_mmap(evlist) < 0)
f8a95309
ACM
1100 return -ENOMEM;
1101
1b85337d 1102 if (evlist->pollfd.entries == NULL && perf_evlist__alloc_pollfd(evlist) < 0)
f8a95309
ACM
1103 return -ENOMEM;
1104
1105 evlist->overwrite = overwrite;
994a1f78 1106 evlist->mmap_len = perf_evlist__mmap_size(pages);
2af68ef5 1107 pr_debug("mmap size %zuB\n", evlist->mmap_len);
a8a8f3eb 1108 mp.mask = evlist->mmap_len - page_size - 1;
f8a95309 1109
718c602d
AH
1110 auxtrace_mmap_params__init(&mp.auxtrace_mp, evlist->mmap_len,
1111 auxtrace_pages, auxtrace_overwrite);
1112
0050f7aa 1113 evlist__for_each(evlist, evsel) {
f8a95309 1114 if ((evsel->attr.read_format & PERF_FORMAT_ID) &&
a91e5431 1115 evsel->sample_id == NULL &&
a14bb7a6 1116 perf_evsel__alloc_id(evsel, cpu_map__nr(cpus), threads->nr) < 0)
f8a95309 1117 return -ENOMEM;
f8a95309
ACM
1118 }
1119
ec1e7e43 1120 if (cpu_map__empty(cpus))
a8a8f3eb 1121 return perf_evlist__mmap_per_thread(evlist, &mp);
f8a95309 1122
a8a8f3eb 1123 return perf_evlist__mmap_per_cpu(evlist, &mp);
f8a95309 1124}
7e2ed097 1125
718c602d
AH
1126int perf_evlist__mmap(struct perf_evlist *evlist, unsigned int pages,
1127 bool overwrite)
1128{
1129 return perf_evlist__mmap_ex(evlist, pages, overwrite, 0, false);
1130}
1131
602ad878 1132int perf_evlist__create_maps(struct perf_evlist *evlist, struct target *target)
7e2ed097 1133{
74bfd2b2
AH
1134 struct cpu_map *cpus;
1135 struct thread_map *threads;
7e2ed097 1136
74bfd2b2
AH
1137 threads = thread_map__new_str(target->pid, target->tid, target->uid);
1138
1139 if (!threads)
7e2ed097
ACM
1140 return -1;
1141
9c105fbc 1142 if (target__uses_dummy_map(target))
74bfd2b2 1143 cpus = cpu_map__dummy_new();
879d77d0 1144 else
74bfd2b2 1145 cpus = cpu_map__new(target->cpu_list);
7e2ed097 1146
74bfd2b2 1147 if (!cpus)
7e2ed097
ACM
1148 goto out_delete_threads;
1149
ec9a77a7
AH
1150 evlist->has_user_cpus = !!target->cpu_list;
1151
74bfd2b2 1152 perf_evlist__set_maps(evlist, cpus, threads);
d5bc056e
AH
1153
1154 return 0;
7e2ed097
ACM
1155
1156out_delete_threads:
74bfd2b2 1157 thread_map__put(threads);
7e2ed097
ACM
1158 return -1;
1159}
1160
d5bc056e
AH
1161void perf_evlist__set_maps(struct perf_evlist *evlist, struct cpu_map *cpus,
1162 struct thread_map *threads)
3de5cfb0 1163{
934e0f20
AH
1164 /*
1165 * Allow for the possibility that one or another of the maps isn't being
1166 * changed i.e. don't put it. Note we are assuming the maps that are
1167 * being applied are brand new and evlist is taking ownership of the
1168 * original reference count of 1. If that is not the case it is up to
1169 * the caller to increase the reference count.
1170 */
1171 if (cpus != evlist->cpus) {
1172 cpu_map__put(evlist->cpus);
1173 evlist->cpus = cpus;
1174 }
3de5cfb0 1175
934e0f20
AH
1176 if (threads != evlist->threads) {
1177 thread_map__put(evlist->threads);
1178 evlist->threads = threads;
1179 }
3de5cfb0 1180
ec9a77a7 1181 perf_evlist__propagate_maps(evlist);
3de5cfb0
JO
1182}
1183
23d4aad4 1184int perf_evlist__apply_filters(struct perf_evlist *evlist, struct perf_evsel **err_evsel)
0a102479 1185{
0a102479 1186 struct perf_evsel *evsel;
745cefc5
ACM
1187 int err = 0;
1188 const int ncpus = cpu_map__nr(evlist->cpus),
b3a319d5 1189 nthreads = thread_map__nr(evlist->threads);
0a102479 1190
0050f7aa 1191 evlist__for_each(evlist, evsel) {
745cefc5 1192 if (evsel->filter == NULL)
0a102479 1193 continue;
745cefc5 1194
d988d5ee
KL
1195 /*
1196 * filters only work for tracepoint event, which doesn't have cpu limit.
1197 * So evlist and evsel should always be same.
1198 */
f47805a2 1199 err = perf_evsel__apply_filter(evsel, ncpus, nthreads, evsel->filter);
23d4aad4
ACM
1200 if (err) {
1201 *err_evsel = evsel;
745cefc5 1202 break;
23d4aad4 1203 }
0a102479
FW
1204 }
1205
745cefc5
ACM
1206 return err;
1207}
1208
1209int perf_evlist__set_filter(struct perf_evlist *evlist, const char *filter)
1210{
1211 struct perf_evsel *evsel;
1212 int err = 0;
745cefc5 1213
0050f7aa 1214 evlist__for_each(evlist, evsel) {
94ad89bc 1215 err = perf_evsel__set_filter(evsel, filter);
745cefc5
ACM
1216 if (err)
1217 break;
1218 }
1219
1220 return err;
0a102479 1221}
74429964 1222
be199ada 1223int perf_evlist__set_filter_pids(struct perf_evlist *evlist, size_t npids, pid_t *pids)
cfd70a26
ACM
1224{
1225 char *filter;
be199ada
ACM
1226 int ret = -1;
1227 size_t i;
cfd70a26 1228
be199ada
ACM
1229 for (i = 0; i < npids; ++i) {
1230 if (i == 0) {
1231 if (asprintf(&filter, "common_pid != %d", pids[i]) < 0)
1232 return -1;
1233 } else {
1234 char *tmp;
1235
1236 if (asprintf(&tmp, "%s && common_pid != %d", filter, pids[i]) < 0)
1237 goto out_free;
1238
1239 free(filter);
1240 filter = tmp;
1241 }
1242 }
cfd70a26
ACM
1243
1244 ret = perf_evlist__set_filter(evlist, filter);
be199ada 1245out_free:
cfd70a26
ACM
1246 free(filter);
1247 return ret;
1248}
1249
be199ada
ACM
1250int perf_evlist__set_filter_pid(struct perf_evlist *evlist, pid_t pid)
1251{
1252 return perf_evlist__set_filter_pids(evlist, 1, &pid);
1253}
1254
0c21f736 1255bool perf_evlist__valid_sample_type(struct perf_evlist *evlist)
74429964 1256{
75562573 1257 struct perf_evsel *pos;
c2a70653 1258
75562573
AH
1259 if (evlist->nr_entries == 1)
1260 return true;
1261
1262 if (evlist->id_pos < 0 || evlist->is_pos < 0)
1263 return false;
1264
0050f7aa 1265 evlist__for_each(evlist, pos) {
75562573
AH
1266 if (pos->id_pos != evlist->id_pos ||
1267 pos->is_pos != evlist->is_pos)
c2a70653 1268 return false;
74429964
FW
1269 }
1270
c2a70653 1271 return true;
74429964
FW
1272}
1273
75562573 1274u64 __perf_evlist__combined_sample_type(struct perf_evlist *evlist)
c2a70653 1275{
75562573
AH
1276 struct perf_evsel *evsel;
1277
1278 if (evlist->combined_sample_type)
1279 return evlist->combined_sample_type;
1280
0050f7aa 1281 evlist__for_each(evlist, evsel)
75562573
AH
1282 evlist->combined_sample_type |= evsel->attr.sample_type;
1283
1284 return evlist->combined_sample_type;
1285}
1286
1287u64 perf_evlist__combined_sample_type(struct perf_evlist *evlist)
1288{
1289 evlist->combined_sample_type = 0;
1290 return __perf_evlist__combined_sample_type(evlist);
c2a70653
ACM
1291}
1292
98df858e
AK
1293u64 perf_evlist__combined_branch_type(struct perf_evlist *evlist)
1294{
1295 struct perf_evsel *evsel;
1296 u64 branch_type = 0;
1297
1298 evlist__for_each(evlist, evsel)
1299 branch_type |= evsel->attr.branch_sample_type;
1300 return branch_type;
1301}
1302
9ede473c
JO
1303bool perf_evlist__valid_read_format(struct perf_evlist *evlist)
1304{
1305 struct perf_evsel *first = perf_evlist__first(evlist), *pos = first;
1306 u64 read_format = first->attr.read_format;
1307 u64 sample_type = first->attr.sample_type;
1308
0050f7aa 1309 evlist__for_each(evlist, pos) {
9ede473c
JO
1310 if (read_format != pos->attr.read_format)
1311 return false;
1312 }
1313
1314 /* PERF_SAMPLE_READ imples PERF_FORMAT_ID. */
1315 if ((sample_type & PERF_SAMPLE_READ) &&
1316 !(read_format & PERF_FORMAT_ID)) {
1317 return false;
1318 }
1319
1320 return true;
1321}
1322
1323u64 perf_evlist__read_format(struct perf_evlist *evlist)
1324{
1325 struct perf_evsel *first = perf_evlist__first(evlist);
1326 return first->attr.read_format;
1327}
1328
0c21f736 1329u16 perf_evlist__id_hdr_size(struct perf_evlist *evlist)
81e36bff 1330{
0c21f736 1331 struct perf_evsel *first = perf_evlist__first(evlist);
81e36bff
ACM
1332 struct perf_sample *data;
1333 u64 sample_type;
1334 u16 size = 0;
1335
81e36bff
ACM
1336 if (!first->attr.sample_id_all)
1337 goto out;
1338
1339 sample_type = first->attr.sample_type;
1340
1341 if (sample_type & PERF_SAMPLE_TID)
1342 size += sizeof(data->tid) * 2;
1343
1344 if (sample_type & PERF_SAMPLE_TIME)
1345 size += sizeof(data->time);
1346
1347 if (sample_type & PERF_SAMPLE_ID)
1348 size += sizeof(data->id);
1349
1350 if (sample_type & PERF_SAMPLE_STREAM_ID)
1351 size += sizeof(data->stream_id);
1352
1353 if (sample_type & PERF_SAMPLE_CPU)
1354 size += sizeof(data->cpu) * 2;
75562573
AH
1355
1356 if (sample_type & PERF_SAMPLE_IDENTIFIER)
1357 size += sizeof(data->id);
81e36bff
ACM
1358out:
1359 return size;
1360}
1361
0c21f736 1362bool perf_evlist__valid_sample_id_all(struct perf_evlist *evlist)
74429964 1363{
0c21f736 1364 struct perf_evsel *first = perf_evlist__first(evlist), *pos = first;
c2a70653 1365
0050f7aa 1366 evlist__for_each_continue(evlist, pos) {
c2a70653
ACM
1367 if (first->attr.sample_id_all != pos->attr.sample_id_all)
1368 return false;
74429964
FW
1369 }
1370
c2a70653
ACM
1371 return true;
1372}
1373
0c21f736 1374bool perf_evlist__sample_id_all(struct perf_evlist *evlist)
c2a70653 1375{
0c21f736 1376 struct perf_evsel *first = perf_evlist__first(evlist);
c2a70653 1377 return first->attr.sample_id_all;
74429964 1378}
81cce8de
ACM
1379
1380void perf_evlist__set_selected(struct perf_evlist *evlist,
1381 struct perf_evsel *evsel)
1382{
1383 evlist->selected = evsel;
1384}
727ab04e 1385
a74b4b66
NK
1386void perf_evlist__close(struct perf_evlist *evlist)
1387{
1388 struct perf_evsel *evsel;
1389 int ncpus = cpu_map__nr(evlist->cpus);
1390 int nthreads = thread_map__nr(evlist->threads);
8ad9219e 1391 int n;
a74b4b66 1392
8ad9219e
SE
1393 evlist__for_each_reverse(evlist, evsel) {
1394 n = evsel->cpus ? evsel->cpus->nr : ncpus;
1395 perf_evsel__close(evsel, n, nthreads);
1396 }
a74b4b66
NK
1397}
1398
4112eb18
ACM
1399static int perf_evlist__create_syswide_maps(struct perf_evlist *evlist)
1400{
1401 int err = -ENOMEM;
1402
1403 /*
1404 * Try reading /sys/devices/system/cpu/online to get
1405 * an all cpus map.
1406 *
1407 * FIXME: -ENOMEM is the best we can do here, the cpu_map
1408 * code needs an overhaul to properly forward the
1409 * error, and we may not want to do that fallback to a
1410 * default cpu identity map :-\
1411 */
1412 evlist->cpus = cpu_map__new(NULL);
1413 if (evlist->cpus == NULL)
1414 goto out;
1415
1416 evlist->threads = thread_map__new_dummy();
1417 if (evlist->threads == NULL)
1418 goto out_free_cpus;
1419
1420 err = 0;
1421out:
1422 return err;
1423out_free_cpus:
f30a79b0 1424 cpu_map__put(evlist->cpus);
4112eb18
ACM
1425 evlist->cpus = NULL;
1426 goto out;
1427}
1428
6a4bb04c 1429int perf_evlist__open(struct perf_evlist *evlist)
727ab04e 1430{
6a4bb04c 1431 struct perf_evsel *evsel;
a74b4b66 1432 int err;
727ab04e 1433
4112eb18
ACM
1434 /*
1435 * Default: one fd per CPU, all threads, aka systemwide
1436 * as sys_perf_event_open(cpu = -1, thread = -1) is EINVAL
1437 */
1438 if (evlist->threads == NULL && evlist->cpus == NULL) {
1439 err = perf_evlist__create_syswide_maps(evlist);
1440 if (err < 0)
1441 goto out_err;
1442 }
1443
733cd2fe
AH
1444 perf_evlist__update_id_pos(evlist);
1445
0050f7aa 1446 evlist__for_each(evlist, evsel) {
6a4bb04c 1447 err = perf_evsel__open(evsel, evlist->cpus, evlist->threads);
727ab04e
ACM
1448 if (err < 0)
1449 goto out_err;
1450 }
1451
1452 return 0;
1453out_err:
a74b4b66 1454 perf_evlist__close(evlist);
41c21a68 1455 errno = -err;
727ab04e
ACM
1456 return err;
1457}
35b9d88e 1458
602ad878 1459int perf_evlist__prepare_workload(struct perf_evlist *evlist, struct target *target,
55e162ea 1460 const char *argv[], bool pipe_output,
735f7e0b 1461 void (*exec_error)(int signo, siginfo_t *info, void *ucontext))
35b9d88e
ACM
1462{
1463 int child_ready_pipe[2], go_pipe[2];
1464 char bf;
1465
1466 if (pipe(child_ready_pipe) < 0) {
1467 perror("failed to create 'ready' pipe");
1468 return -1;
1469 }
1470
1471 if (pipe(go_pipe) < 0) {
1472 perror("failed to create 'go' pipe");
1473 goto out_close_ready_pipe;
1474 }
1475
1476 evlist->workload.pid = fork();
1477 if (evlist->workload.pid < 0) {
1478 perror("failed to fork");
1479 goto out_close_pipes;
1480 }
1481
1482 if (!evlist->workload.pid) {
5f1c4225
ACM
1483 int ret;
1484
119fa3c9 1485 if (pipe_output)
35b9d88e
ACM
1486 dup2(2, 1);
1487
0817df08
DA
1488 signal(SIGTERM, SIG_DFL);
1489
35b9d88e
ACM
1490 close(child_ready_pipe[0]);
1491 close(go_pipe[1]);
1492 fcntl(go_pipe[0], F_SETFD, FD_CLOEXEC);
1493
35b9d88e
ACM
1494 /*
1495 * Tell the parent we're ready to go
1496 */
1497 close(child_ready_pipe[1]);
1498
1499 /*
1500 * Wait until the parent tells us to go.
1501 */
5f1c4225
ACM
1502 ret = read(go_pipe[0], &bf, 1);
1503 /*
1504 * The parent will ask for the execvp() to be performed by
1505 * writing exactly one byte, in workload.cork_fd, usually via
1506 * perf_evlist__start_workload().
1507 *
20f86fc1 1508 * For cancelling the workload without actually running it,
5f1c4225
ACM
1509 * the parent will just close workload.cork_fd, without writing
1510 * anything, i.e. read will return zero and we just exit()
1511 * here.
1512 */
1513 if (ret != 1) {
1514 if (ret == -1)
1515 perror("unable to read pipe");
1516 exit(ret);
1517 }
35b9d88e
ACM
1518
1519 execvp(argv[0], (char **)argv);
1520
735f7e0b 1521 if (exec_error) {
f33cbe72
ACM
1522 union sigval val;
1523
1524 val.sival_int = errno;
1525 if (sigqueue(getppid(), SIGUSR1, val))
1526 perror(argv[0]);
1527 } else
1528 perror(argv[0]);
35b9d88e
ACM
1529 exit(-1);
1530 }
1531
735f7e0b
ACM
1532 if (exec_error) {
1533 struct sigaction act = {
1534 .sa_flags = SA_SIGINFO,
1535 .sa_sigaction = exec_error,
1536 };
1537 sigaction(SIGUSR1, &act, NULL);
1538 }
1539
1aaf63b1
ACM
1540 if (target__none(target)) {
1541 if (evlist->threads == NULL) {
1542 fprintf(stderr, "FATAL: evlist->threads need to be set at this point (%s:%d).\n",
1543 __func__, __LINE__);
1544 goto out_close_pipes;
1545 }
e13798c7 1546 thread_map__set_pid(evlist->threads, 0, evlist->workload.pid);
1aaf63b1 1547 }
35b9d88e
ACM
1548
1549 close(child_ready_pipe[1]);
1550 close(go_pipe[0]);
1551 /*
1552 * wait for child to settle
1553 */
1554 if (read(child_ready_pipe[0], &bf, 1) == -1) {
1555 perror("unable to read pipe");
1556 goto out_close_pipes;
1557 }
1558
bcf3145f 1559 fcntl(go_pipe[1], F_SETFD, FD_CLOEXEC);
35b9d88e
ACM
1560 evlist->workload.cork_fd = go_pipe[1];
1561 close(child_ready_pipe[0]);
1562 return 0;
1563
1564out_close_pipes:
1565 close(go_pipe[0]);
1566 close(go_pipe[1]);
1567out_close_ready_pipe:
1568 close(child_ready_pipe[0]);
1569 close(child_ready_pipe[1]);
1570 return -1;
1571}
1572
1573int perf_evlist__start_workload(struct perf_evlist *evlist)
1574{
1575 if (evlist->workload.cork_fd > 0) {
b3824404 1576 char bf = 0;
bcf3145f 1577 int ret;
35b9d88e
ACM
1578 /*
1579 * Remove the cork, let it rip!
1580 */
bcf3145f
NK
1581 ret = write(evlist->workload.cork_fd, &bf, 1);
1582 if (ret < 0)
1583 perror("enable to write to pipe");
1584
1585 close(evlist->workload.cork_fd);
1586 return ret;
35b9d88e
ACM
1587 }
1588
1589 return 0;
1590}
cb0b29e0 1591
a3f698fe 1592int perf_evlist__parse_sample(struct perf_evlist *evlist, union perf_event *event,
0807d2d8 1593 struct perf_sample *sample)
cb0b29e0 1594{
75562573
AH
1595 struct perf_evsel *evsel = perf_evlist__event2evsel(evlist, event);
1596
1597 if (!evsel)
1598 return -EFAULT;
0807d2d8 1599 return perf_evsel__parse_sample(evsel, event, sample);
cb0b29e0 1600}
78f067b3
ACM
1601
1602size_t perf_evlist__fprintf(struct perf_evlist *evlist, FILE *fp)
1603{
1604 struct perf_evsel *evsel;
1605 size_t printed = 0;
1606
0050f7aa 1607 evlist__for_each(evlist, evsel) {
78f067b3
ACM
1608 printed += fprintf(fp, "%s%s", evsel->idx ? ", " : "",
1609 perf_evsel__name(evsel));
1610 }
1611
b2222139 1612 return printed + fprintf(fp, "\n");
78f067b3 1613}
6ef068cb 1614
a8f23d8f
ACM
1615int perf_evlist__strerror_open(struct perf_evlist *evlist __maybe_unused,
1616 int err, char *buf, size_t size)
1617{
1618 int printed, value;
6e81c74c 1619 char sbuf[STRERR_BUFSIZE], *emsg = strerror_r(err, sbuf, sizeof(sbuf));
a8f23d8f
ACM
1620
1621 switch (err) {
1622 case EACCES:
1623 case EPERM:
1624 printed = scnprintf(buf, size,
1625 "Error:\t%s.\n"
1626 "Hint:\tCheck /proc/sys/kernel/perf_event_paranoid setting.", emsg);
1627
1a47245d 1628 value = perf_event_paranoid();
a8f23d8f
ACM
1629
1630 printed += scnprintf(buf + printed, size - printed, "\nHint:\t");
1631
1632 if (value >= 2) {
1633 printed += scnprintf(buf + printed, size - printed,
1634 "For your workloads it needs to be <= 1\nHint:\t");
1635 }
1636 printed += scnprintf(buf + printed, size - printed,
5229e366 1637 "For system wide tracing it needs to be set to -1.\n");
a8f23d8f
ACM
1638
1639 printed += scnprintf(buf + printed, size - printed,
5229e366
ACM
1640 "Hint:\tTry: 'sudo sh -c \"echo -1 > /proc/sys/kernel/perf_event_paranoid\"'\n"
1641 "Hint:\tThe current value is %d.", value);
a8f23d8f
ACM
1642 break;
1643 default:
1644 scnprintf(buf, size, "%s", emsg);
1645 break;
1646 }
1647
1648 return 0;
1649}
a025e4f0 1650
956fa571
ACM
1651int perf_evlist__strerror_mmap(struct perf_evlist *evlist, int err, char *buf, size_t size)
1652{
1653 char sbuf[STRERR_BUFSIZE], *emsg = strerror_r(err, sbuf, sizeof(sbuf));
e965bea1 1654 int pages_attempted = evlist->mmap_len / 1024, pages_max_per_user, printed = 0;
956fa571
ACM
1655
1656 switch (err) {
1657 case EPERM:
e5d4a290 1658 sysctl__read_int("kernel/perf_event_mlock_kb", &pages_max_per_user);
e965bea1
ACM
1659 printed += scnprintf(buf + printed, size - printed,
1660 "Error:\t%s.\n"
956fa571 1661 "Hint:\tCheck /proc/sys/kernel/perf_event_mlock_kb (%d kB) setting.\n"
e965bea1 1662 "Hint:\tTried using %zd kB.\n",
e5d4a290 1663 emsg, pages_max_per_user, pages_attempted);
e965bea1
ACM
1664
1665 if (pages_attempted >= pages_max_per_user) {
1666 printed += scnprintf(buf + printed, size - printed,
1667 "Hint:\tTry 'sudo sh -c \"echo %d > /proc/sys/kernel/perf_event_mlock_kb\"', or\n",
1668 pages_max_per_user + pages_attempted);
1669 }
1670
1671 printed += scnprintf(buf + printed, size - printed,
1672 "Hint:\tTry using a smaller -m/--mmap-pages value.");
956fa571
ACM
1673 break;
1674 default:
1675 scnprintf(buf, size, "%s", emsg);
1676 break;
1677 }
1678
1679 return 0;
1680}
1681
a025e4f0
AH
1682void perf_evlist__to_front(struct perf_evlist *evlist,
1683 struct perf_evsel *move_evsel)
1684{
1685 struct perf_evsel *evsel, *n;
1686 LIST_HEAD(move);
1687
1688 if (move_evsel == perf_evlist__first(evlist))
1689 return;
1690
0050f7aa 1691 evlist__for_each_safe(evlist, n, evsel) {
a025e4f0
AH
1692 if (evsel->leader == move_evsel->leader)
1693 list_move_tail(&evsel->node, &move);
1694 }
1695
1696 list_splice(&move, &evlist->entries);
1697}
60b0896c
AH
1698
1699void perf_evlist__set_tracking_event(struct perf_evlist *evlist,
1700 struct perf_evsel *tracking_evsel)
1701{
1702 struct perf_evsel *evsel;
1703
1704 if (tracking_evsel->tracking)
1705 return;
1706
1707 evlist__for_each(evlist, evsel) {
1708 if (evsel != tracking_evsel)
1709 evsel->tracking = false;
1710 }
1711
1712 tracking_evsel->tracking = true;
1713}