2 * Copyright (C) 2011, Red Hat Inc, Arnaldo Carvalho de Melo <acme@redhat.com>
4 * Parts came from builtin-{top,stat,record}.c, see those files for further
7 * Released under the GPL v2. (and only v2, not any later version)
13 #include "thread_map.h"
18 #include "parse-events.h"
22 #include <linux/bitops.h>
23 #include <linux/hash.h>
25 #define FD(e, x, y) (*(int *)xyarray__entry(e->fd, x, y))
26 #define SID(e, x, y) xyarray__entry(e->sample_id, x, y)
28 void perf_evlist__init(struct perf_evlist *evlist, struct cpu_map *cpus,
29 struct thread_map *threads)
33 for (i = 0; i < PERF_EVLIST__HLIST_SIZE; ++i)
34 INIT_HLIST_HEAD(&evlist->heads[i]);
35 INIT_LIST_HEAD(&evlist->entries);
36 perf_evlist__set_maps(evlist, cpus, threads);
37 evlist->workload.pid = -1;
40 struct perf_evlist *perf_evlist__new(struct cpu_map *cpus,
41 struct thread_map *threads)
43 struct perf_evlist *evlist = zalloc(sizeof(*evlist));
46 perf_evlist__init(evlist, cpus, threads);
51 void perf_evlist__config_attrs(struct perf_evlist *evlist,
52 struct perf_record_opts *opts)
54 struct perf_evsel *evsel, *first;
56 if (evlist->cpus->map[0] < 0)
57 opts->no_inherit = true;
59 first = list_entry(evlist->entries.next, struct perf_evsel, node);
61 list_for_each_entry(evsel, &evlist->entries, node) {
62 perf_evsel__config(evsel, opts, first);
64 if (evlist->nr_entries > 1)
65 evsel->attr.sample_type |= PERF_SAMPLE_ID;
69 static void perf_evlist__purge(struct perf_evlist *evlist)
71 struct perf_evsel *pos, *n;
73 list_for_each_entry_safe(pos, n, &evlist->entries, node) {
74 list_del_init(&pos->node);
75 perf_evsel__delete(pos);
78 evlist->nr_entries = 0;
81 void perf_evlist__exit(struct perf_evlist *evlist)
86 evlist->pollfd = NULL;
89 void perf_evlist__delete(struct perf_evlist *evlist)
91 perf_evlist__purge(evlist);
92 perf_evlist__exit(evlist);
96 void perf_evlist__add(struct perf_evlist *evlist, struct perf_evsel *entry)
98 list_add_tail(&entry->node, &evlist->entries);
102 void perf_evlist__splice_list_tail(struct perf_evlist *evlist,
103 struct list_head *list,
106 list_splice_tail(list, &evlist->entries);
107 evlist->nr_entries += nr_entries;
110 int perf_evlist__add_default(struct perf_evlist *evlist)
112 struct perf_event_attr attr = {
113 .type = PERF_TYPE_HARDWARE,
114 .config = PERF_COUNT_HW_CPU_CYCLES,
116 struct perf_evsel *evsel;
118 event_attr_init(&attr);
120 evsel = perf_evsel__new(&attr, 0);
124 /* use strdup() because free(evsel) assumes name is allocated */
125 evsel->name = strdup("cycles");
129 perf_evlist__add(evlist, evsel);
132 perf_evsel__delete(evsel);
137 int perf_evlist__add_attrs(struct perf_evlist *evlist,
138 struct perf_event_attr *attrs, size_t nr_attrs)
140 struct perf_evsel *evsel, *n;
144 for (i = 0; i < nr_attrs; i++) {
145 evsel = perf_evsel__new(attrs + i, evlist->nr_entries + i);
147 goto out_delete_partial_list;
148 list_add_tail(&evsel->node, &head);
151 perf_evlist__splice_list_tail(evlist, &head, nr_attrs);
155 out_delete_partial_list:
156 list_for_each_entry_safe(evsel, n, &head, node)
157 perf_evsel__delete(evsel);
161 static int trace_event__id(const char *evname)
163 char *filename, *colon;
166 if (asprintf(&filename, "%s/%s/id", tracing_events_path, evname) < 0)
169 colon = strrchr(filename, ':');
173 fd = open(filename, O_RDONLY);
176 if (read(fd, id, sizeof(id)) > 0)
185 int perf_evlist__add_tracepoints(struct perf_evlist *evlist,
186 const char *tracepoints[],
187 size_t nr_tracepoints)
191 struct perf_event_attr *attrs = zalloc(nr_tracepoints * sizeof(*attrs));
196 for (i = 0; i < nr_tracepoints; i++) {
197 err = trace_event__id(tracepoints[i]);
202 attrs[i].type = PERF_TYPE_TRACEPOINT;
203 attrs[i].config = err;
204 attrs[i].sample_type = (PERF_SAMPLE_RAW | PERF_SAMPLE_TIME |
206 attrs[i].sample_period = 1;
209 err = perf_evlist__add_attrs(evlist, attrs, nr_tracepoints);
215 static struct perf_evsel *
216 perf_evlist__find_tracepoint_by_id(struct perf_evlist *evlist, int id)
218 struct perf_evsel *evsel;
220 list_for_each_entry(evsel, &evlist->entries, node) {
221 if (evsel->attr.type == PERF_TYPE_TRACEPOINT &&
222 (int)evsel->attr.config == id)
229 int perf_evlist__set_tracepoints_handlers(struct perf_evlist *evlist,
230 const struct perf_evsel_str_handler *assocs,
233 struct perf_evsel *evsel;
237 for (i = 0; i < nr_assocs; i++) {
238 err = trace_event__id(assocs[i].name);
242 evsel = perf_evlist__find_tracepoint_by_id(evlist, err);
247 if (evsel->handler.func != NULL)
249 evsel->handler.func = assocs[i].handler;
257 void perf_evlist__disable(struct perf_evlist *evlist)
260 struct perf_evsel *pos;
262 for (cpu = 0; cpu < evlist->cpus->nr; cpu++) {
263 list_for_each_entry(pos, &evlist->entries, node) {
264 for (thread = 0; thread < evlist->threads->nr; thread++)
265 ioctl(FD(pos, cpu, thread), PERF_EVENT_IOC_DISABLE);
270 void perf_evlist__enable(struct perf_evlist *evlist)
273 struct perf_evsel *pos;
275 for (cpu = 0; cpu < evlist->cpus->nr; cpu++) {
276 list_for_each_entry(pos, &evlist->entries, node) {
277 for (thread = 0; thread < evlist->threads->nr; thread++)
278 ioctl(FD(pos, cpu, thread), PERF_EVENT_IOC_ENABLE);
283 static int perf_evlist__alloc_pollfd(struct perf_evlist *evlist)
285 int nfds = evlist->cpus->nr * evlist->threads->nr * evlist->nr_entries;
286 evlist->pollfd = malloc(sizeof(struct pollfd) * nfds);
287 return evlist->pollfd != NULL ? 0 : -ENOMEM;
290 void perf_evlist__add_pollfd(struct perf_evlist *evlist, int fd)
292 fcntl(fd, F_SETFL, O_NONBLOCK);
293 evlist->pollfd[evlist->nr_fds].fd = fd;
294 evlist->pollfd[evlist->nr_fds].events = POLLIN;
298 static void perf_evlist__id_hash(struct perf_evlist *evlist,
299 struct perf_evsel *evsel,
300 int cpu, int thread, u64 id)
303 struct perf_sample_id *sid = SID(evsel, cpu, thread);
307 hash = hash_64(sid->id, PERF_EVLIST__HLIST_BITS);
308 hlist_add_head(&sid->node, &evlist->heads[hash]);
311 void perf_evlist__id_add(struct perf_evlist *evlist, struct perf_evsel *evsel,
312 int cpu, int thread, u64 id)
314 perf_evlist__id_hash(evlist, evsel, cpu, thread, id);
315 evsel->id[evsel->ids++] = id;
318 static int perf_evlist__id_add_fd(struct perf_evlist *evlist,
319 struct perf_evsel *evsel,
320 int cpu, int thread, int fd)
322 u64 read_data[4] = { 0, };
323 int id_idx = 1; /* The first entry is the counter value */
325 if (!(evsel->attr.read_format & PERF_FORMAT_ID) ||
326 read(fd, &read_data, sizeof(read_data)) == -1)
329 if (evsel->attr.read_format & PERF_FORMAT_TOTAL_TIME_ENABLED)
331 if (evsel->attr.read_format & PERF_FORMAT_TOTAL_TIME_RUNNING)
334 perf_evlist__id_add(evlist, evsel, cpu, thread, read_data[id_idx]);
338 struct perf_evsel *perf_evlist__id2evsel(struct perf_evlist *evlist, u64 id)
340 struct hlist_head *head;
341 struct hlist_node *pos;
342 struct perf_sample_id *sid;
345 if (evlist->nr_entries == 1)
346 return list_entry(evlist->entries.next, struct perf_evsel, node);
348 hash = hash_64(id, PERF_EVLIST__HLIST_BITS);
349 head = &evlist->heads[hash];
351 hlist_for_each_entry(sid, pos, head, node)
355 if (!perf_evlist__sample_id_all(evlist))
356 return list_entry(evlist->entries.next, struct perf_evsel, node);
361 union perf_event *perf_evlist__mmap_read(struct perf_evlist *evlist, int idx)
363 /* XXX Move this to perf.c, making it generally available */
364 unsigned int page_size = sysconf(_SC_PAGE_SIZE);
365 struct perf_mmap *md = &evlist->mmap[idx];
366 unsigned int head = perf_mmap__read_head(md);
367 unsigned int old = md->prev;
368 unsigned char *data = md->base + page_size;
369 union perf_event *event = NULL;
371 if (evlist->overwrite) {
373 * If we're further behind than half the buffer, there's a chance
374 * the writer will bite our tail and mess up the samples under us.
376 * If we somehow ended up ahead of the head, we got messed up.
378 * In either case, truncate and restart at head.
380 int diff = head - old;
381 if (diff > md->mask / 2 || diff < 0) {
382 fprintf(stderr, "WARNING: failed to keep up with mmap data.\n");
385 * head points to a known good entry, start there.
394 event = (union perf_event *)&data[old & md->mask];
395 size = event->header.size;
398 * Event straddles the mmap boundary -- header should always
399 * be inside due to u64 alignment of output.
401 if ((old & md->mask) + size != ((old + size) & md->mask)) {
402 unsigned int offset = old;
403 unsigned int len = min(sizeof(*event), size), cpy;
404 void *dst = &evlist->event_copy;
407 cpy = min(md->mask + 1 - (offset & md->mask), len);
408 memcpy(dst, &data[offset & md->mask], cpy);
414 event = &evlist->event_copy;
422 if (!evlist->overwrite)
423 perf_mmap__write_tail(md, old);
428 void perf_evlist__munmap(struct perf_evlist *evlist)
432 for (i = 0; i < evlist->nr_mmaps; i++) {
433 if (evlist->mmap[i].base != NULL) {
434 munmap(evlist->mmap[i].base, evlist->mmap_len);
435 evlist->mmap[i].base = NULL;
443 static int perf_evlist__alloc_mmap(struct perf_evlist *evlist)
445 evlist->nr_mmaps = evlist->cpus->nr;
446 if (evlist->cpus->map[0] == -1)
447 evlist->nr_mmaps = evlist->threads->nr;
448 evlist->mmap = zalloc(evlist->nr_mmaps * sizeof(struct perf_mmap));
449 return evlist->mmap != NULL ? 0 : -ENOMEM;
452 static int __perf_evlist__mmap(struct perf_evlist *evlist,
453 int idx, int prot, int mask, int fd)
455 evlist->mmap[idx].prev = 0;
456 evlist->mmap[idx].mask = mask;
457 evlist->mmap[idx].base = mmap(NULL, evlist->mmap_len, prot,
459 if (evlist->mmap[idx].base == MAP_FAILED) {
460 evlist->mmap[idx].base = NULL;
464 perf_evlist__add_pollfd(evlist, fd);
468 static int perf_evlist__mmap_per_cpu(struct perf_evlist *evlist, int prot, int mask)
470 struct perf_evsel *evsel;
473 for (cpu = 0; cpu < evlist->cpus->nr; cpu++) {
476 for (thread = 0; thread < evlist->threads->nr; thread++) {
477 list_for_each_entry(evsel, &evlist->entries, node) {
478 int fd = FD(evsel, cpu, thread);
482 if (__perf_evlist__mmap(evlist, cpu,
483 prot, mask, output) < 0)
486 if (ioctl(fd, PERF_EVENT_IOC_SET_OUTPUT, output) != 0)
490 if ((evsel->attr.read_format & PERF_FORMAT_ID) &&
491 perf_evlist__id_add_fd(evlist, evsel, cpu, thread, fd) < 0)
500 for (cpu = 0; cpu < evlist->cpus->nr; cpu++) {
501 if (evlist->mmap[cpu].base != NULL) {
502 munmap(evlist->mmap[cpu].base, evlist->mmap_len);
503 evlist->mmap[cpu].base = NULL;
509 static int perf_evlist__mmap_per_thread(struct perf_evlist *evlist, int prot, int mask)
511 struct perf_evsel *evsel;
514 for (thread = 0; thread < evlist->threads->nr; thread++) {
517 list_for_each_entry(evsel, &evlist->entries, node) {
518 int fd = FD(evsel, 0, thread);
522 if (__perf_evlist__mmap(evlist, thread,
523 prot, mask, output) < 0)
526 if (ioctl(fd, PERF_EVENT_IOC_SET_OUTPUT, output) != 0)
530 if ((evsel->attr.read_format & PERF_FORMAT_ID) &&
531 perf_evlist__id_add_fd(evlist, evsel, 0, thread, fd) < 0)
539 for (thread = 0; thread < evlist->threads->nr; thread++) {
540 if (evlist->mmap[thread].base != NULL) {
541 munmap(evlist->mmap[thread].base, evlist->mmap_len);
542 evlist->mmap[thread].base = NULL;
548 /** perf_evlist__mmap - Create per cpu maps to receive events
550 * @evlist - list of events
551 * @pages - map length in pages
552 * @overwrite - overwrite older events?
554 * If overwrite is false the user needs to signal event consuption using:
556 * struct perf_mmap *m = &evlist->mmap[cpu];
557 * unsigned int head = perf_mmap__read_head(m);
559 * perf_mmap__write_tail(m, head)
561 * Using perf_evlist__read_on_cpu does this automatically.
563 int perf_evlist__mmap(struct perf_evlist *evlist, unsigned int pages,
566 unsigned int page_size = sysconf(_SC_PAGE_SIZE);
567 struct perf_evsel *evsel;
568 const struct cpu_map *cpus = evlist->cpus;
569 const struct thread_map *threads = evlist->threads;
570 int prot = PROT_READ | (overwrite ? 0 : PROT_WRITE), mask;
572 /* 512 kiB: default amount of unprivileged mlocked memory */
573 if (pages == UINT_MAX)
574 pages = (512 * 1024) / page_size;
575 else if (!is_power_of_2(pages))
578 mask = pages * page_size - 1;
580 if (evlist->mmap == NULL && perf_evlist__alloc_mmap(evlist) < 0)
583 if (evlist->pollfd == NULL && perf_evlist__alloc_pollfd(evlist) < 0)
586 evlist->overwrite = overwrite;
587 evlist->mmap_len = (pages + 1) * page_size;
589 list_for_each_entry(evsel, &evlist->entries, node) {
590 if ((evsel->attr.read_format & PERF_FORMAT_ID) &&
591 evsel->sample_id == NULL &&
592 perf_evsel__alloc_id(evsel, cpus->nr, threads->nr) < 0)
596 if (evlist->cpus->map[0] == -1)
597 return perf_evlist__mmap_per_thread(evlist, prot, mask);
599 return perf_evlist__mmap_per_cpu(evlist, prot, mask);
602 int perf_evlist__create_maps(struct perf_evlist *evlist, const char *target_pid,
603 const char *target_tid, uid_t uid, const char *cpu_list)
605 evlist->threads = thread_map__new_str(target_pid, target_tid, uid);
607 if (evlist->threads == NULL)
610 if (uid != UINT_MAX || (cpu_list == NULL && target_tid))
611 evlist->cpus = cpu_map__dummy_new();
613 evlist->cpus = cpu_map__new(cpu_list);
615 if (evlist->cpus == NULL)
616 goto out_delete_threads;
621 thread_map__delete(evlist->threads);
625 void perf_evlist__delete_maps(struct perf_evlist *evlist)
627 cpu_map__delete(evlist->cpus);
628 thread_map__delete(evlist->threads);
630 evlist->threads = NULL;
633 int perf_evlist__set_filters(struct perf_evlist *evlist)
635 const struct thread_map *threads = evlist->threads;
636 const struct cpu_map *cpus = evlist->cpus;
637 struct perf_evsel *evsel;
644 list_for_each_entry(evsel, &evlist->entries, node) {
645 filter = evsel->filter;
648 for (cpu = 0; cpu < cpus->nr; cpu++) {
649 for (thread = 0; thread < threads->nr; thread++) {
650 fd = FD(evsel, cpu, thread);
651 err = ioctl(fd, PERF_EVENT_IOC_SET_FILTER, filter);
661 bool perf_evlist__valid_sample_type(const struct perf_evlist *evlist)
663 struct perf_evsel *pos, *first;
665 pos = first = list_entry(evlist->entries.next, struct perf_evsel, node);
667 list_for_each_entry_continue(pos, &evlist->entries, node) {
668 if (first->attr.sample_type != pos->attr.sample_type)
675 u64 perf_evlist__sample_type(const struct perf_evlist *evlist)
677 struct perf_evsel *first;
679 first = list_entry(evlist->entries.next, struct perf_evsel, node);
680 return first->attr.sample_type;
683 u16 perf_evlist__id_hdr_size(const struct perf_evlist *evlist)
685 struct perf_evsel *first;
686 struct perf_sample *data;
690 first = list_entry(evlist->entries.next, struct perf_evsel, node);
692 if (!first->attr.sample_id_all)
695 sample_type = first->attr.sample_type;
697 if (sample_type & PERF_SAMPLE_TID)
698 size += sizeof(data->tid) * 2;
700 if (sample_type & PERF_SAMPLE_TIME)
701 size += sizeof(data->time);
703 if (sample_type & PERF_SAMPLE_ID)
704 size += sizeof(data->id);
706 if (sample_type & PERF_SAMPLE_STREAM_ID)
707 size += sizeof(data->stream_id);
709 if (sample_type & PERF_SAMPLE_CPU)
710 size += sizeof(data->cpu) * 2;
715 bool perf_evlist__valid_sample_id_all(const struct perf_evlist *evlist)
717 struct perf_evsel *pos, *first;
719 pos = first = list_entry(evlist->entries.next, struct perf_evsel, node);
721 list_for_each_entry_continue(pos, &evlist->entries, node) {
722 if (first->attr.sample_id_all != pos->attr.sample_id_all)
729 bool perf_evlist__sample_id_all(const struct perf_evlist *evlist)
731 struct perf_evsel *first;
733 first = list_entry(evlist->entries.next, struct perf_evsel, node);
734 return first->attr.sample_id_all;
737 void perf_evlist__set_selected(struct perf_evlist *evlist,
738 struct perf_evsel *evsel)
740 evlist->selected = evsel;
743 int perf_evlist__open(struct perf_evlist *evlist, bool group)
745 struct perf_evsel *evsel, *first;
746 int err, ncpus, nthreads;
748 first = list_entry(evlist->entries.next, struct perf_evsel, node);
750 list_for_each_entry(evsel, &evlist->entries, node) {
751 struct xyarray *group_fd = NULL;
753 if (group && evsel != first)
754 group_fd = first->fd;
756 err = perf_evsel__open(evsel, evlist->cpus, evlist->threads,
764 ncpus = evlist->cpus ? evlist->cpus->nr : 1;
765 nthreads = evlist->threads ? evlist->threads->nr : 1;
767 list_for_each_entry_reverse(evsel, &evlist->entries, node)
768 perf_evsel__close(evsel, ncpus, nthreads);
774 int perf_evlist__prepare_workload(struct perf_evlist *evlist,
775 struct perf_record_opts *opts,
778 int child_ready_pipe[2], go_pipe[2];
781 if (pipe(child_ready_pipe) < 0) {
782 perror("failed to create 'ready' pipe");
786 if (pipe(go_pipe) < 0) {
787 perror("failed to create 'go' pipe");
788 goto out_close_ready_pipe;
791 evlist->workload.pid = fork();
792 if (evlist->workload.pid < 0) {
793 perror("failed to fork");
794 goto out_close_pipes;
797 if (!evlist->workload.pid) {
798 if (opts->pipe_output)
801 close(child_ready_pipe[0]);
803 fcntl(go_pipe[0], F_SETFD, FD_CLOEXEC);
806 * Do a dummy execvp to get the PLT entry resolved,
807 * so we avoid the resolver overhead on the real
810 execvp("", (char **)argv);
813 * Tell the parent we're ready to go
815 close(child_ready_pipe[1]);
818 * Wait until the parent tells us to go.
820 if (read(go_pipe[0], &bf, 1) == -1)
821 perror("unable to read pipe");
823 execvp(argv[0], (char **)argv);
826 kill(getppid(), SIGUSR1);
830 if (!opts->system_wide && !opts->target_tid && !opts->target_pid)
831 evlist->threads->map[0] = evlist->workload.pid;
833 close(child_ready_pipe[1]);
836 * wait for child to settle
838 if (read(child_ready_pipe[0], &bf, 1) == -1) {
839 perror("unable to read pipe");
840 goto out_close_pipes;
843 evlist->workload.cork_fd = go_pipe[1];
844 close(child_ready_pipe[0]);
850 out_close_ready_pipe:
851 close(child_ready_pipe[0]);
852 close(child_ready_pipe[1]);
856 int perf_evlist__start_workload(struct perf_evlist *evlist)
858 if (evlist->workload.cork_fd > 0) {
860 * Remove the cork, let it rip!
862 return close(evlist->workload.cork_fd);