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