]> git.proxmox.com Git - mirror_ubuntu-artful-kernel.git/blame - tools/perf/util/session.c
Merge commit 'v2.6.35' into perf/core
[mirror_ubuntu-artful-kernel.git] / tools / perf / util / session.c
CommitLineData
b8f46c5a
XG
1#define _FILE_OFFSET_BITS 64
2
94c744b6
ACM
3#include <linux/kernel.h>
4
ba21594c 5#include <byteswap.h>
94c744b6
ACM
6#include <unistd.h>
7#include <sys/types.h>
a41794cd 8#include <sys/mman.h>
94c744b6
ACM
9
10#include "session.h"
a328626b 11#include "sort.h"
94c744b6
ACM
12#include "util.h"
13
14static int perf_session__open(struct perf_session *self, bool force)
15{
16 struct stat input_stat;
17
8dc58101
TZ
18 if (!strcmp(self->filename, "-")) {
19 self->fd_pipe = true;
20 self->fd = STDIN_FILENO;
21
22 if (perf_header__read(self, self->fd) < 0)
23 pr_err("incompatible file format");
24
25 return 0;
26 }
27
f887f301 28 self->fd = open(self->filename, O_RDONLY);
94c744b6 29 if (self->fd < 0) {
0f2c3de2
AI
30 int err = errno;
31
32 pr_err("failed to open %s: %s", self->filename, strerror(err));
33 if (err == ENOENT && !strcmp(self->filename, "perf.data"))
94c744b6
ACM
34 pr_err(" (try 'perf record' first)");
35 pr_err("\n");
36 return -errno;
37 }
38
39 if (fstat(self->fd, &input_stat) < 0)
40 goto out_close;
41
42 if (!force && input_stat.st_uid && (input_stat.st_uid != geteuid())) {
43 pr_err("file %s not owned by current user or root\n",
44 self->filename);
45 goto out_close;
46 }
47
48 if (!input_stat.st_size) {
49 pr_info("zero-sized file (%s), nothing to do!\n",
50 self->filename);
51 goto out_close;
52 }
53
8dc58101 54 if (perf_header__read(self, self->fd) < 0) {
94c744b6
ACM
55 pr_err("incompatible file format");
56 goto out_close;
57 }
58
59 self->size = input_stat.st_size;
60 return 0;
61
62out_close:
63 close(self->fd);
64 self->fd = -1;
65 return -1;
66}
67
8dc58101
TZ
68void perf_session__update_sample_type(struct perf_session *self)
69{
70 self->sample_type = perf_header__sample_type(&self->header);
71}
72
a1645ce1
ZY
73int perf_session__create_kernel_maps(struct perf_session *self)
74{
d118f8ba 75 int ret = machine__create_kernel_maps(&self->host_machine);
a1645ce1 76
a1645ce1 77 if (ret >= 0)
d118f8ba 78 ret = machines__create_guest_kernel_maps(&self->machines);
a1645ce1
ZY
79 return ret;
80}
81
454c407e 82struct perf_session *perf_session__new(const char *filename, int mode, bool force, bool repipe)
94c744b6 83{
b3165f41 84 size_t len = filename ? strlen(filename) + 1 : 0;
94c744b6
ACM
85 struct perf_session *self = zalloc(sizeof(*self) + len);
86
87 if (self == NULL)
88 goto out;
89
90 if (perf_header__init(&self->header) < 0)
4aa65636 91 goto out_free;
94c744b6
ACM
92
93 memcpy(self->filename, filename, len);
b3165f41 94 self->threads = RB_ROOT;
720a3aeb 95 INIT_LIST_HEAD(&self->dead_threads);
1c02c4d2 96 self->hists_tree = RB_ROOT;
b3165f41 97 self->last_match = NULL;
ec913369 98 self->mmap_window = 32;
23346f21 99 self->machines = RB_ROOT;
454c407e 100 self->repipe = repipe;
c61e52ee 101 INIT_LIST_HEAD(&self->ordered_samples.samples_head);
1f626bc3 102 machine__init(&self->host_machine, "", HOST_KERNEL_ID);
94c744b6 103
64abebf7
ACM
104 if (mode == O_RDONLY) {
105 if (perf_session__open(self, force) < 0)
106 goto out_delete;
107 } else if (mode == O_WRONLY) {
108 /*
109 * In O_RDONLY mode this will be performed when reading the
110 * kernel MMAP event, in event__process_mmap().
111 */
112 if (perf_session__create_kernel_maps(self) < 0)
113 goto out_delete;
114 }
d549c769 115
8dc58101 116 perf_session__update_sample_type(self);
94c744b6
ACM
117out:
118 return self;
4aa65636 119out_free:
94c744b6
ACM
120 free(self);
121 return NULL;
4aa65636
ACM
122out_delete:
123 perf_session__delete(self);
124 return NULL;
94c744b6
ACM
125}
126
d65a458b
ACM
127static void perf_session__delete_dead_threads(struct perf_session *self)
128{
129 struct thread *n, *t;
130
131 list_for_each_entry_safe(t, n, &self->dead_threads, node) {
132 list_del(&t->node);
133 thread__delete(t);
134 }
135}
136
137static void perf_session__delete_threads(struct perf_session *self)
138{
139 struct rb_node *nd = rb_first(&self->threads);
140
141 while (nd) {
142 struct thread *t = rb_entry(nd, struct thread, rb_node);
143
144 rb_erase(&t->rb_node, &self->threads);
145 nd = rb_next(nd);
146 thread__delete(t);
147 }
148}
149
94c744b6
ACM
150void perf_session__delete(struct perf_session *self)
151{
152 perf_header__exit(&self->header);
d65a458b
ACM
153 perf_session__delete_dead_threads(self);
154 perf_session__delete_threads(self);
155 machine__exit(&self->host_machine);
94c744b6
ACM
156 close(self->fd);
157 free(self);
158}
a328626b 159
720a3aeb
ACM
160void perf_session__remove_thread(struct perf_session *self, struct thread *th)
161{
162 rb_erase(&th->rb_node, &self->threads);
163 /*
164 * We may have references to this thread, for instance in some hist_entry
165 * instances, so just move them to a separate list.
166 */
167 list_add_tail(&th->node, &self->dead_threads);
168}
169
a328626b
ACM
170static bool symbol__match_parent_regex(struct symbol *sym)
171{
172 if (sym->name && !regexec(&parent_regex, sym->name, 0, NULL, 0))
173 return 1;
174
175 return 0;
176}
177
b3c9ac08
ACM
178struct map_symbol *perf_session__resolve_callchain(struct perf_session *self,
179 struct thread *thread,
180 struct ip_callchain *chain,
181 struct symbol **parent)
a328626b
ACM
182{
183 u8 cpumode = PERF_RECORD_MISC_USER;
a328626b 184 unsigned int i;
ad5b217b 185 struct map_symbol *syms = calloc(chain->nr, sizeof(*syms));
a328626b 186
ad5b217b
ACM
187 if (!syms)
188 return NULL;
a328626b
ACM
189
190 for (i = 0; i < chain->nr; i++) {
191 u64 ip = chain->ips[i];
192 struct addr_location al;
193
194 if (ip >= PERF_CONTEXT_MAX) {
195 switch (ip) {
196 case PERF_CONTEXT_HV:
197 cpumode = PERF_RECORD_MISC_HYPERVISOR; break;
198 case PERF_CONTEXT_KERNEL:
199 cpumode = PERF_RECORD_MISC_KERNEL; break;
200 case PERF_CONTEXT_USER:
201 cpumode = PERF_RECORD_MISC_USER; break;
202 default:
203 break;
204 }
205 continue;
206 }
207
a1645ce1 208 al.filtered = false;
a328626b 209 thread__find_addr_location(thread, self, cpumode,
a1645ce1 210 MAP__FUNCTION, thread->pid, ip, &al, NULL);
a328626b
ACM
211 if (al.sym != NULL) {
212 if (sort__has_parent && !*parent &&
213 symbol__match_parent_regex(al.sym))
214 *parent = al.sym;
d599db3f 215 if (!symbol_conf.use_callchain)
a328626b 216 break;
b3c9ac08
ACM
217 syms[i].map = al.map;
218 syms[i].sym = al.sym;
a328626b
ACM
219 }
220 }
221
222 return syms;
223}
06aae590
ACM
224
225static int process_event_stub(event_t *event __used,
226 struct perf_session *session __used)
227{
228 dump_printf(": unhandled!\n");
229 return 0;
230}
231
d6b17beb
FW
232static int process_finished_round_stub(event_t *event __used,
233 struct perf_session *session __used,
234 struct perf_event_ops *ops __used)
235{
236 dump_printf(": unhandled!\n");
237 return 0;
238}
239
240static int process_finished_round(event_t *event,
241 struct perf_session *session,
242 struct perf_event_ops *ops);
243
06aae590
ACM
244static void perf_event_ops__fill_defaults(struct perf_event_ops *handler)
245{
55aa640f
ACM
246 if (handler->sample == NULL)
247 handler->sample = process_event_stub;
248 if (handler->mmap == NULL)
249 handler->mmap = process_event_stub;
250 if (handler->comm == NULL)
251 handler->comm = process_event_stub;
252 if (handler->fork == NULL)
253 handler->fork = process_event_stub;
254 if (handler->exit == NULL)
255 handler->exit = process_event_stub;
256 if (handler->lost == NULL)
257 handler->lost = process_event_stub;
258 if (handler->read == NULL)
259 handler->read = process_event_stub;
260 if (handler->throttle == NULL)
261 handler->throttle = process_event_stub;
262 if (handler->unthrottle == NULL)
263 handler->unthrottle = process_event_stub;
2c46dbb5
TZ
264 if (handler->attr == NULL)
265 handler->attr = process_event_stub;
cd19a035
TZ
266 if (handler->event_type == NULL)
267 handler->event_type = process_event_stub;
9215545e
TZ
268 if (handler->tracing_data == NULL)
269 handler->tracing_data = process_event_stub;
c7929e47
TZ
270 if (handler->build_id == NULL)
271 handler->build_id = process_event_stub;
d6b17beb
FW
272 if (handler->finished_round == NULL) {
273 if (handler->ordered_samples)
274 handler->finished_round = process_finished_round;
275 else
276 handler->finished_round = process_finished_round_stub;
277 }
06aae590
ACM
278}
279
ba21594c
ACM
280void mem_bswap_64(void *src, int byte_size)
281{
282 u64 *m = src;
283
284 while (byte_size > 0) {
285 *m = bswap_64(*m);
286 byte_size -= sizeof(u64);
287 ++m;
288 }
289}
290
291static void event__all64_swap(event_t *self)
292{
293 struct perf_event_header *hdr = &self->header;
294 mem_bswap_64(hdr + 1, self->header.size - sizeof(*hdr));
295}
296
297static void event__comm_swap(event_t *self)
298{
299 self->comm.pid = bswap_32(self->comm.pid);
300 self->comm.tid = bswap_32(self->comm.tid);
301}
302
303static void event__mmap_swap(event_t *self)
304{
305 self->mmap.pid = bswap_32(self->mmap.pid);
306 self->mmap.tid = bswap_32(self->mmap.tid);
307 self->mmap.start = bswap_64(self->mmap.start);
308 self->mmap.len = bswap_64(self->mmap.len);
309 self->mmap.pgoff = bswap_64(self->mmap.pgoff);
310}
311
312static void event__task_swap(event_t *self)
313{
314 self->fork.pid = bswap_32(self->fork.pid);
315 self->fork.tid = bswap_32(self->fork.tid);
316 self->fork.ppid = bswap_32(self->fork.ppid);
317 self->fork.ptid = bswap_32(self->fork.ptid);
318 self->fork.time = bswap_64(self->fork.time);
319}
320
321static void event__read_swap(event_t *self)
322{
323 self->read.pid = bswap_32(self->read.pid);
324 self->read.tid = bswap_32(self->read.tid);
325 self->read.value = bswap_64(self->read.value);
326 self->read.time_enabled = bswap_64(self->read.time_enabled);
327 self->read.time_running = bswap_64(self->read.time_running);
328 self->read.id = bswap_64(self->read.id);
329}
330
2c46dbb5
TZ
331static void event__attr_swap(event_t *self)
332{
333 size_t size;
334
335 self->attr.attr.type = bswap_32(self->attr.attr.type);
336 self->attr.attr.size = bswap_32(self->attr.attr.size);
337 self->attr.attr.config = bswap_64(self->attr.attr.config);
338 self->attr.attr.sample_period = bswap_64(self->attr.attr.sample_period);
339 self->attr.attr.sample_type = bswap_64(self->attr.attr.sample_type);
340 self->attr.attr.read_format = bswap_64(self->attr.attr.read_format);
341 self->attr.attr.wakeup_events = bswap_32(self->attr.attr.wakeup_events);
342 self->attr.attr.bp_type = bswap_32(self->attr.attr.bp_type);
343 self->attr.attr.bp_addr = bswap_64(self->attr.attr.bp_addr);
344 self->attr.attr.bp_len = bswap_64(self->attr.attr.bp_len);
345
346 size = self->header.size;
347 size -= (void *)&self->attr.id - (void *)self;
348 mem_bswap_64(self->attr.id, size);
349}
350
cd19a035
TZ
351static void event__event_type_swap(event_t *self)
352{
353 self->event_type.event_type.event_id =
354 bswap_64(self->event_type.event_type.event_id);
355}
356
9215545e
TZ
357static void event__tracing_data_swap(event_t *self)
358{
359 self->tracing_data.size = bswap_32(self->tracing_data.size);
360}
361
ba21594c
ACM
362typedef void (*event__swap_op)(event_t *self);
363
364static event__swap_op event__swap_ops[] = {
365 [PERF_RECORD_MMAP] = event__mmap_swap,
366 [PERF_RECORD_COMM] = event__comm_swap,
367 [PERF_RECORD_FORK] = event__task_swap,
368 [PERF_RECORD_EXIT] = event__task_swap,
369 [PERF_RECORD_LOST] = event__all64_swap,
370 [PERF_RECORD_READ] = event__read_swap,
371 [PERF_RECORD_SAMPLE] = event__all64_swap,
2c46dbb5 372 [PERF_RECORD_HEADER_ATTR] = event__attr_swap,
cd19a035 373 [PERF_RECORD_HEADER_EVENT_TYPE] = event__event_type_swap,
9215545e 374 [PERF_RECORD_HEADER_TRACING_DATA] = event__tracing_data_swap,
c7929e47 375 [PERF_RECORD_HEADER_BUILD_ID] = NULL,
8dc58101 376 [PERF_RECORD_HEADER_MAX] = NULL,
ba21594c
ACM
377};
378
c61e52ee
FW
379struct sample_queue {
380 u64 timestamp;
381 struct sample_event *event;
382 struct list_head list;
383};
384
c61e52ee
FW
385static void flush_sample_queue(struct perf_session *s,
386 struct perf_event_ops *ops)
387{
388 struct list_head *head = &s->ordered_samples.samples_head;
d6b17beb 389 u64 limit = s->ordered_samples.next_flush;
c61e52ee
FW
390 struct sample_queue *tmp, *iter;
391
d6b17beb 392 if (!ops->ordered_samples || !limit)
c61e52ee
FW
393 return;
394
395 list_for_each_entry_safe(iter, tmp, head, list) {
396 if (iter->timestamp > limit)
397 return;
398
399 if (iter == s->ordered_samples.last_inserted)
400 s->ordered_samples.last_inserted = NULL;
401
402 ops->sample((event_t *)iter->event, s);
403
404 s->ordered_samples.last_flush = iter->timestamp;
405 list_del(&iter->list);
406 free(iter->event);
407 free(iter);
408 }
409}
410
d6b17beb
FW
411/*
412 * When perf record finishes a pass on every buffers, it records this pseudo
413 * event.
414 * We record the max timestamp t found in the pass n.
415 * Assuming these timestamps are monotonic across cpus, we know that if
416 * a buffer still has events with timestamps below t, they will be all
417 * available and then read in the pass n + 1.
418 * Hence when we start to read the pass n + 2, we can safely flush every
419 * events with timestamps below t.
420 *
421 * ============ PASS n =================
422 * CPU 0 | CPU 1
423 * |
424 * cnt1 timestamps | cnt2 timestamps
425 * 1 | 2
426 * 2 | 3
427 * - | 4 <--- max recorded
428 *
429 * ============ PASS n + 1 ==============
430 * CPU 0 | CPU 1
431 * |
432 * cnt1 timestamps | cnt2 timestamps
433 * 3 | 5
434 * 4 | 6
435 * 5 | 7 <---- max recorded
436 *
437 * Flush every events below timestamp 4
438 *
439 * ============ PASS n + 2 ==============
440 * CPU 0 | CPU 1
441 * |
442 * cnt1 timestamps | cnt2 timestamps
443 * 6 | 8
444 * 7 | 9
445 * - | 10
446 *
447 * Flush every events below timestamp 7
448 * etc...
449 */
450static int process_finished_round(event_t *event __used,
451 struct perf_session *session,
452 struct perf_event_ops *ops)
453{
454 flush_sample_queue(session, ops);
455 session->ordered_samples.next_flush = session->ordered_samples.max_timestamp;
456
457 return 0;
458}
459
c61e52ee
FW
460static void __queue_sample_end(struct sample_queue *new, struct list_head *head)
461{
462 struct sample_queue *iter;
463
464 list_for_each_entry_reverse(iter, head, list) {
465 if (iter->timestamp < new->timestamp) {
466 list_add(&new->list, &iter->list);
467 return;
468 }
469 }
470
471 list_add(&new->list, head);
472}
473
474static void __queue_sample_before(struct sample_queue *new,
475 struct sample_queue *iter,
476 struct list_head *head)
477{
478 list_for_each_entry_continue_reverse(iter, head, list) {
479 if (iter->timestamp < new->timestamp) {
480 list_add(&new->list, &iter->list);
481 return;
482 }
483 }
484
485 list_add(&new->list, head);
486}
487
488static void __queue_sample_after(struct sample_queue *new,
489 struct sample_queue *iter,
490 struct list_head *head)
491{
492 list_for_each_entry_continue(iter, head, list) {
493 if (iter->timestamp > new->timestamp) {
494 list_add_tail(&new->list, &iter->list);
495 return;
496 }
497 }
498 list_add_tail(&new->list, head);
499}
500
501/* The queue is ordered by time */
502static void __queue_sample_event(struct sample_queue *new,
503 struct perf_session *s)
504{
505 struct sample_queue *last_inserted = s->ordered_samples.last_inserted;
506 struct list_head *head = &s->ordered_samples.samples_head;
507
508
509 if (!last_inserted) {
510 __queue_sample_end(new, head);
511 return;
512 }
513
514 /*
515 * Most of the time the current event has a timestamp
516 * very close to the last event inserted, unless we just switched
517 * to another event buffer. Having a sorting based on a list and
518 * on the last inserted event that is close to the current one is
519 * probably more efficient than an rbtree based sorting.
520 */
521 if (last_inserted->timestamp >= new->timestamp)
522 __queue_sample_before(new, last_inserted, head);
523 else
524 __queue_sample_after(new, last_inserted, head);
525}
526
527static int queue_sample_event(event_t *event, struct sample_data *data,
d6b17beb 528 struct perf_session *s)
c61e52ee
FW
529{
530 u64 timestamp = data->time;
531 struct sample_queue *new;
c61e52ee
FW
532
533
c61e52ee
FW
534 if (timestamp < s->ordered_samples.last_flush) {
535 printf("Warning: Timestamp below last timeslice flush\n");
536 return -EINVAL;
537 }
538
539 new = malloc(sizeof(*new));
540 if (!new)
541 return -ENOMEM;
542
543 new->timestamp = timestamp;
544
545 new->event = malloc(event->header.size);
546 if (!new->event) {
547 free(new);
548 return -ENOMEM;
549 }
550
551 memcpy(new->event, event, event->header.size);
552
553 __queue_sample_event(new, s);
554 s->ordered_samples.last_inserted = new;
555
d6b17beb
FW
556 if (new->timestamp > s->ordered_samples.max_timestamp)
557 s->ordered_samples.max_timestamp = new->timestamp;
c61e52ee
FW
558
559 return 0;
560}
561
562static int perf_session__process_sample(event_t *event, struct perf_session *s,
563 struct perf_event_ops *ops)
564{
565 struct sample_data data;
566
567 if (!ops->ordered_samples)
568 return ops->sample(event, s);
569
570 bzero(&data, sizeof(struct sample_data));
571 event__parse_sample(event, s->sample_type, &data);
572
d6b17beb 573 queue_sample_event(event, &data, s);
c61e52ee
FW
574
575 return 0;
576}
577
06aae590
ACM
578static int perf_session__process_event(struct perf_session *self,
579 event_t *event,
580 struct perf_event_ops *ops,
ba21594c 581 u64 offset, u64 head)
06aae590
ACM
582{
583 trace_event(event);
584
8dc58101 585 if (event->header.type < PERF_RECORD_HEADER_MAX) {
ba21594c 586 dump_printf("%#Lx [%#x]: PERF_RECORD_%s",
0d755034 587 offset + head, event->header.size,
06aae590 588 event__name[event->header.type]);
cee75ac7 589 hists__inc_nr_events(&self->hists, event->header.type);
06aae590
ACM
590 }
591
ba21594c
ACM
592 if (self->header.needs_swap && event__swap_ops[event->header.type])
593 event__swap_ops[event->header.type](event);
594
06aae590
ACM
595 switch (event->header.type) {
596 case PERF_RECORD_SAMPLE:
c61e52ee 597 return perf_session__process_sample(event, self, ops);
06aae590 598 case PERF_RECORD_MMAP:
55aa640f 599 return ops->mmap(event, self);
06aae590 600 case PERF_RECORD_COMM:
55aa640f 601 return ops->comm(event, self);
06aae590 602 case PERF_RECORD_FORK:
55aa640f 603 return ops->fork(event, self);
06aae590 604 case PERF_RECORD_EXIT:
55aa640f 605 return ops->exit(event, self);
06aae590 606 case PERF_RECORD_LOST:
55aa640f 607 return ops->lost(event, self);
06aae590 608 case PERF_RECORD_READ:
55aa640f 609 return ops->read(event, self);
06aae590 610 case PERF_RECORD_THROTTLE:
55aa640f 611 return ops->throttle(event, self);
06aae590 612 case PERF_RECORD_UNTHROTTLE:
55aa640f 613 return ops->unthrottle(event, self);
2c46dbb5
TZ
614 case PERF_RECORD_HEADER_ATTR:
615 return ops->attr(event, self);
cd19a035
TZ
616 case PERF_RECORD_HEADER_EVENT_TYPE:
617 return ops->event_type(event, self);
9215545e
TZ
618 case PERF_RECORD_HEADER_TRACING_DATA:
619 /* setup for reading amidst mmap */
620 lseek(self->fd, offset + head, SEEK_SET);
621 return ops->tracing_data(event, self);
c7929e47
TZ
622 case PERF_RECORD_HEADER_BUILD_ID:
623 return ops->build_id(event, self);
d6b17beb
FW
624 case PERF_RECORD_FINISHED_ROUND:
625 return ops->finished_round(event, self, ops);
06aae590 626 default:
c8446b9b 627 ++self->hists.stats.nr_unknown_events;
06aae590
ACM
628 return -1;
629 }
630}
631
ba21594c
ACM
632void perf_event_header__bswap(struct perf_event_header *self)
633{
634 self->type = bswap_32(self->type);
635 self->misc = bswap_16(self->misc);
636 self->size = bswap_16(self->size);
637}
638
06aae590
ACM
639static struct thread *perf_session__register_idle_thread(struct perf_session *self)
640{
641 struct thread *thread = perf_session__findnew(self, 0);
642
643 if (thread == NULL || thread__set_comm(thread, "swapper")) {
644 pr_err("problem inserting idle task.\n");
645 thread = NULL;
646 }
647
648 return thread;
649}
650
8dc58101
TZ
651int do_read(int fd, void *buf, size_t size)
652{
653 void *buf_start = buf;
654
655 while (size) {
656 int ret = read(fd, buf, size);
657
658 if (ret <= 0)
659 return ret;
660
661 size -= ret;
662 buf += ret;
663 }
664
665 return buf - buf_start;
666}
667
668#define session_done() (*(volatile int *)(&session_done))
669volatile int session_done;
670
671static int __perf_session__process_pipe_events(struct perf_session *self,
672 struct perf_event_ops *ops)
673{
674 event_t event;
675 uint32_t size;
676 int skip = 0;
677 u64 head;
678 int err;
679 void *p;
680
681 perf_event_ops__fill_defaults(ops);
682
683 head = 0;
684more:
685 err = do_read(self->fd, &event, sizeof(struct perf_event_header));
686 if (err <= 0) {
687 if (err == 0)
688 goto done;
689
690 pr_err("failed to read event header\n");
691 goto out_err;
692 }
693
694 if (self->header.needs_swap)
695 perf_event_header__bswap(&event.header);
696
697 size = event.header.size;
698 if (size == 0)
699 size = 8;
700
701 p = &event;
702 p += sizeof(struct perf_event_header);
703
794e43b5
TZ
704 if (size - sizeof(struct perf_event_header)) {
705 err = do_read(self->fd, p,
706 size - sizeof(struct perf_event_header));
707 if (err <= 0) {
708 if (err == 0) {
709 pr_err("unexpected end of event stream\n");
710 goto done;
711 }
8dc58101 712
794e43b5
TZ
713 pr_err("failed to read event data\n");
714 goto out_err;
715 }
8dc58101
TZ
716 }
717
718 if (size == 0 ||
719 (skip = perf_session__process_event(self, &event, ops,
720 0, head)) < 0) {
721 dump_printf("%#Lx [%#x]: skipping unknown header type: %d\n",
722 head, event.header.size, event.header.type);
723 /*
724 * assume we lost track of the stream, check alignment, and
725 * increment a single u64 in the hope to catch on again 'soon'.
726 */
727 if (unlikely(head & 7))
728 head &= ~7ULL;
729
730 size = 8;
731 }
732
733 head += size;
734
735 dump_printf("\n%#Lx [%#x]: event: %d\n",
736 head, event.header.size, event.header.type);
737
738 if (skip > 0)
739 head += skip;
740
741 if (!session_done())
742 goto more;
743done:
744 err = 0;
745out_err:
746 return err;
747}
748
6122e4e4
ACM
749int __perf_session__process_events(struct perf_session *self,
750 u64 data_offset, u64 data_size,
751 u64 file_size, struct perf_event_ops *ops)
06aae590 752{
ba21594c
ACM
753 int err, mmap_prot, mmap_flags;
754 u64 head, shift;
755 u64 offset = 0;
06aae590
ACM
756 size_t page_size;
757 event_t *event;
758 uint32_t size;
759 char *buf;
5f4d3f88
ACM
760 struct ui_progress *progress = ui_progress__new("Processing events...",
761 self->size);
762 if (progress == NULL)
763 return -1;
06aae590 764
06aae590
ACM
765 perf_event_ops__fill_defaults(ops);
766
1b75962e 767 page_size = sysconf(_SC_PAGESIZE);
06aae590 768
6122e4e4 769 head = data_offset;
06aae590
ACM
770 shift = page_size * (head / page_size);
771 offset += shift;
772 head -= shift;
773
ba21594c
ACM
774 mmap_prot = PROT_READ;
775 mmap_flags = MAP_SHARED;
776
777 if (self->header.needs_swap) {
778 mmap_prot |= PROT_WRITE;
779 mmap_flags = MAP_PRIVATE;
780 }
06aae590 781remap:
ba21594c
ACM
782 buf = mmap(NULL, page_size * self->mmap_window, mmap_prot,
783 mmap_flags, self->fd, offset);
06aae590
ACM
784 if (buf == MAP_FAILED) {
785 pr_err("failed to mmap file\n");
786 err = -errno;
787 goto out_err;
788 }
789
790more:
791 event = (event_t *)(buf + head);
5f4d3f88 792 ui_progress__update(progress, offset);
06aae590 793
ba21594c
ACM
794 if (self->header.needs_swap)
795 perf_event_header__bswap(&event->header);
06aae590
ACM
796 size = event->header.size;
797 if (size == 0)
798 size = 8;
799
800 if (head + event->header.size >= page_size * self->mmap_window) {
801 int munmap_ret;
802
803 shift = page_size * (head / page_size);
804
805 munmap_ret = munmap(buf, page_size * self->mmap_window);
806 assert(munmap_ret == 0);
807
808 offset += shift;
809 head -= shift;
810 goto remap;
811 }
812
813 size = event->header.size;
814
ba21594c 815 dump_printf("\n%#Lx [%#x]: event: %d\n",
0d755034 816 offset + head, event->header.size, event->header.type);
06aae590
ACM
817
818 if (size == 0 ||
819 perf_session__process_event(self, event, ops, offset, head) < 0) {
ba21594c 820 dump_printf("%#Lx [%#x]: skipping unknown header type: %d\n",
0d755034 821 offset + head, event->header.size,
06aae590
ACM
822 event->header.type);
823 /*
824 * assume we lost track of the stream, check alignment, and
825 * increment a single u64 in the hope to catch on again 'soon'.
826 */
827 if (unlikely(head & 7))
828 head &= ~7ULL;
829
830 size = 8;
831 }
832
833 head += size;
834
6122e4e4 835 if (offset + head >= data_offset + data_size)
06aae590
ACM
836 goto done;
837
6122e4e4 838 if (offset + head < file_size)
06aae590
ACM
839 goto more;
840done:
841 err = 0;
c61e52ee 842 /* do the final flush for ordered samples */
d6b17beb 843 self->ordered_samples.next_flush = ULLONG_MAX;
c61e52ee 844 flush_sample_queue(self, ops);
06aae590 845out_err:
5f4d3f88 846 ui_progress__delete(progress);
06aae590
ACM
847 return err;
848}
27295592 849
6122e4e4
ACM
850int perf_session__process_events(struct perf_session *self,
851 struct perf_event_ops *ops)
852{
853 int err;
854
855 if (perf_session__register_idle_thread(self) == NULL)
856 return -ENOMEM;
857
8dc58101
TZ
858 if (!self->fd_pipe)
859 err = __perf_session__process_events(self,
860 self->header.data_offset,
861 self->header.data_size,
862 self->size, ops);
863 else
864 err = __perf_session__process_pipe_events(self, ops);
88ca895d 865
6122e4e4
ACM
866 return err;
867}
868
d549c769 869bool perf_session__has_traces(struct perf_session *self, const char *msg)
27295592
ACM
870{
871 if (!(self->sample_type & PERF_SAMPLE_RAW)) {
d549c769
ACM
872 pr_err("No trace sample to read. Did you call 'perf %s'?\n", msg);
873 return false;
27295592
ACM
874 }
875
d549c769 876 return true;
27295592 877}
56b03f3c 878
a1645ce1 879int perf_session__set_kallsyms_ref_reloc_sym(struct map **maps,
56b03f3c
ACM
880 const char *symbol_name,
881 u64 addr)
882{
883 char *bracket;
9de89fe7 884 enum map_type i;
a1645ce1
ZY
885 struct ref_reloc_sym *ref;
886
887 ref = zalloc(sizeof(struct ref_reloc_sym));
888 if (ref == NULL)
889 return -ENOMEM;
56b03f3c 890
a1645ce1
ZY
891 ref->name = strdup(symbol_name);
892 if (ref->name == NULL) {
893 free(ref);
56b03f3c 894 return -ENOMEM;
a1645ce1 895 }
56b03f3c 896
a1645ce1 897 bracket = strchr(ref->name, ']');
56b03f3c
ACM
898 if (bracket)
899 *bracket = '\0';
900
a1645ce1 901 ref->addr = addr;
9de89fe7
ACM
902
903 for (i = 0; i < MAP__NR_TYPES; ++i) {
a1645ce1
ZY
904 struct kmap *kmap = map__kmap(maps[i]);
905 kmap->ref_reloc_sym = ref;
9de89fe7
ACM
906 }
907
56b03f3c
ACM
908 return 0;
909}
1f626bc3
ACM
910
911size_t perf_session__fprintf_dsos(struct perf_session *self, FILE *fp)
912{
913 return __dsos__fprintf(&self->host_machine.kernel_dsos, fp) +
914 __dsos__fprintf(&self->host_machine.user_dsos, fp) +
915 machines__fprintf_dsos(&self->machines, fp);
916}
f869097e
ACM
917
918size_t perf_session__fprintf_dsos_buildid(struct perf_session *self, FILE *fp,
919 bool with_hits)
920{
921 size_t ret = machine__fprintf_dsos_buildid(&self->host_machine, fp, with_hits);
922 return ret + machines__fprintf_dsos_buildid(&self->machines, fp, with_hits);
923}