perf tools: Initial python binding
[linux-block.git] / tools / perf / util / evlist.c
CommitLineData
5c581041 1#include <poll.h>
361c99a6
ACM
2#include "evlist.h"
3#include "evsel.h"
4#include "util.h"
5
70db7533
ACM
6#include <linux/bitops.h>
7#include <linux/hash.h>
8
ef1d1af2
ACM
9void perf_evlist__init(struct perf_evlist *evlist)
10{
11 int i;
12
13 for (i = 0; i < PERF_EVLIST__HLIST_SIZE; ++i)
14 INIT_HLIST_HEAD(&evlist->heads[i]);
15 INIT_LIST_HEAD(&evlist->entries);
16}
17
361c99a6
ACM
18struct perf_evlist *perf_evlist__new(void)
19{
20 struct perf_evlist *evlist = zalloc(sizeof(*evlist));
21
ef1d1af2
ACM
22 if (evlist != NULL)
23 perf_evlist__init(evlist);
361c99a6
ACM
24
25 return evlist;
26}
27
28static void perf_evlist__purge(struct perf_evlist *evlist)
29{
30 struct perf_evsel *pos, *n;
31
32 list_for_each_entry_safe(pos, n, &evlist->entries, node) {
33 list_del_init(&pos->node);
34 perf_evsel__delete(pos);
35 }
36
37 evlist->nr_entries = 0;
38}
39
ef1d1af2 40void perf_evlist__exit(struct perf_evlist *evlist)
361c99a6 41{
70db7533 42 free(evlist->mmap);
5c581041 43 free(evlist->pollfd);
ef1d1af2
ACM
44 evlist->mmap = NULL;
45 evlist->pollfd = NULL;
46}
47
48void perf_evlist__delete(struct perf_evlist *evlist)
49{
50 perf_evlist__purge(evlist);
51 perf_evlist__exit(evlist);
361c99a6
ACM
52 free(evlist);
53}
54
55void perf_evlist__add(struct perf_evlist *evlist, struct perf_evsel *entry)
56{
57 list_add_tail(&entry->node, &evlist->entries);
58 ++evlist->nr_entries;
59}
60
61int perf_evlist__add_default(struct perf_evlist *evlist)
62{
63 struct perf_event_attr attr = {
64 .type = PERF_TYPE_HARDWARE,
65 .config = PERF_COUNT_HW_CPU_CYCLES,
66 };
67 struct perf_evsel *evsel = perf_evsel__new(&attr, 0);
68
69 if (evsel == NULL)
70 return -ENOMEM;
71
72 perf_evlist__add(evlist, evsel);
73 return 0;
74}
5c581041
ACM
75
76int perf_evlist__alloc_pollfd(struct perf_evlist *evlist, int ncpus, int nthreads)
77{
78 int nfds = ncpus * nthreads * evlist->nr_entries;
79 evlist->pollfd = malloc(sizeof(struct pollfd) * nfds);
80 return evlist->pollfd != NULL ? 0 : -ENOMEM;
81}
70082dd9
ACM
82
83void perf_evlist__add_pollfd(struct perf_evlist *evlist, int fd)
84{
85 fcntl(fd, F_SETFL, O_NONBLOCK);
86 evlist->pollfd[evlist->nr_fds].fd = fd;
87 evlist->pollfd[evlist->nr_fds].events = POLLIN;
88 evlist->nr_fds++;
89}
70db7533
ACM
90
91struct perf_evsel *perf_evlist__id2evsel(struct perf_evlist *evlist, u64 id)
92{
93 struct hlist_head *head;
94 struct hlist_node *pos;
95 struct perf_sample_id *sid;
96 int hash;
97
98 if (evlist->nr_entries == 1)
99 return list_entry(evlist->entries.next, struct perf_evsel, node);
100
101 hash = hash_64(id, PERF_EVLIST__HLIST_BITS);
102 head = &evlist->heads[hash];
103
104 hlist_for_each_entry(sid, pos, head, node)
105 if (sid->id == id)
106 return sid->evsel;
107 return NULL;
108}
04391deb 109
8115d60c 110union perf_event *perf_evlist__read_on_cpu(struct perf_evlist *evlist, int cpu)
04391deb
ACM
111{
112 /* XXX Move this to perf.c, making it generally available */
113 unsigned int page_size = sysconf(_SC_PAGE_SIZE);
114 struct perf_mmap *md = &evlist->mmap[cpu];
115 unsigned int head = perf_mmap__read_head(md);
116 unsigned int old = md->prev;
117 unsigned char *data = md->base + page_size;
8115d60c 118 union perf_event *event = NULL;
04391deb 119
7bb41152 120 if (evlist->overwrite) {
04391deb 121 /*
7bb41152
ACM
122 * If we're further behind than half the buffer, there's a chance
123 * the writer will bite our tail and mess up the samples under us.
124 *
125 * If we somehow ended up ahead of the head, we got messed up.
126 *
127 * In either case, truncate and restart at head.
04391deb 128 */
7bb41152
ACM
129 int diff = head - old;
130 if (diff > md->mask / 2 || diff < 0) {
131 fprintf(stderr, "WARNING: failed to keep up with mmap data.\n");
132
133 /*
134 * head points to a known good entry, start there.
135 */
136 old = head;
137 }
04391deb
ACM
138 }
139
140 if (old != head) {
141 size_t size;
142
8115d60c 143 event = (union perf_event *)&data[old & md->mask];
04391deb
ACM
144 size = event->header.size;
145
146 /*
147 * Event straddles the mmap boundary -- header should always
148 * be inside due to u64 alignment of output.
149 */
150 if ((old & md->mask) + size != ((old + size) & md->mask)) {
151 unsigned int offset = old;
152 unsigned int len = min(sizeof(*event), size), cpy;
153 void *dst = &evlist->event_copy;
154
155 do {
156 cpy = min(md->mask + 1 - (offset & md->mask), len);
157 memcpy(dst, &data[offset & md->mask], cpy);
158 offset += cpy;
159 dst += cpy;
160 len -= cpy;
161 } while (len);
162
163 event = &evlist->event_copy;
164 }
165
166 old += size;
167 }
168
169 md->prev = old;
7bb41152
ACM
170
171 if (!evlist->overwrite)
172 perf_mmap__write_tail(md, old);
173
04391deb
ACM
174 return event;
175}