Lines Matching refs:session
40 static int perf_session__process_compressed_event(struct perf_session *session, in perf_session__process_compressed_event() argument
46 size_t mmap_len, decomp_len = session->header.env.comp_mmap_len; in perf_session__process_compressed_event()
47 struct decomp *decomp, *decomp_last = session->active_decomp->decomp_last; in perf_session__process_compressed_event()
74 decomp_size = zstd_decompress_stream(session->active_decomp->zstd_decomp, src, src_size, in perf_session__process_compressed_event()
84 if (session->active_decomp->decomp == NULL) in perf_session__process_compressed_event()
85 session->active_decomp->decomp = decomp; in perf_session__process_compressed_event()
87 session->active_decomp->decomp_last->next = decomp; in perf_session__process_compressed_event()
89 session->active_decomp->decomp_last = decomp; in perf_session__process_compressed_event()
99 static int perf_session__deliver_event(struct perf_session *session,
104 static int perf_session__open(struct perf_session *session, int repipe_fd) in perf_session__open() argument
106 struct perf_data *data = session->data; in perf_session__open()
108 if (perf_session__read_header(session, repipe_fd) < 0) { in perf_session__open()
116 if (perf_header__has_feat(&session->header, HEADER_STAT)) in perf_session__open()
119 if (!evlist__valid_sample_type(session->evlist)) { in perf_session__open()
124 if (!evlist__valid_sample_id_all(session->evlist)) { in perf_session__open()
129 if (!evlist__valid_read_format(session->evlist)) { in perf_session__open()
137 void perf_session__set_id_hdr_size(struct perf_session *session) in perf_session__set_id_hdr_size() argument
139 u16 id_hdr_size = evlist__id_hdr_size(session->evlist); in perf_session__set_id_hdr_size()
141 machines__set_id_hdr_size(&session->machines, id_hdr_size); in perf_session__set_id_hdr_size()
144 int perf_session__create_kernel_maps(struct perf_session *session) in perf_session__create_kernel_maps() argument
146 int ret = machine__create_kernel_maps(&session->machines.host); in perf_session__create_kernel_maps()
149 ret = machines__create_guest_kernel_maps(&session->machines); in perf_session__create_kernel_maps()
153 static void perf_session__destroy_kernel_maps(struct perf_session *session) in perf_session__destroy_kernel_maps() argument
155 machines__destroy_kernel_maps(&session->machines); in perf_session__destroy_kernel_maps()
158 static bool perf_session__has_comm_exec(struct perf_session *session) in perf_session__has_comm_exec() argument
162 evlist__for_each_entry(session->evlist, evsel) { in perf_session__has_comm_exec()
170 static void perf_session__set_comm_exec(struct perf_session *session) in perf_session__set_comm_exec() argument
172 bool comm_exec = perf_session__has_comm_exec(session); in perf_session__set_comm_exec()
174 machines__set_comm_exec(&session->machines, comm_exec); in perf_session__set_comm_exec()
180 struct perf_session *session = container_of(oe, struct perf_session, in ordered_events__deliver_event() local
183 return perf_session__deliver_event(session, event->event, in ordered_events__deliver_event()
184 session->tool, event->file_offset); in ordered_events__deliver_event()
192 struct perf_session *session = zalloc(sizeof(*session)); in __perf_session__new() local
194 if (!session) in __perf_session__new()
197 session->repipe = repipe; in __perf_session__new()
198 session->tool = tool; in __perf_session__new()
199 session->decomp_data.zstd_decomp = &session->zstd_data; in __perf_session__new()
200 session->active_decomp = &session->decomp_data; in __perf_session__new()
201 INIT_LIST_HEAD(&session->auxtrace_index); in __perf_session__new()
202 machines__init(&session->machines); in __perf_session__new()
203 ordered_events__init(&session->ordered_events, in __perf_session__new()
206 perf_env__init(&session->header.env); in __perf_session__new()
212 session->data = data; in __perf_session__new()
215 ret = perf_session__open(session, repipe_fd); in __perf_session__new()
224 perf_session__set_id_hdr_size(session); in __perf_session__new()
225 perf_session__set_comm_exec(session); in __perf_session__new()
228 evlist__init_trace_event_sample_raw(session->evlist); in __perf_session__new()
242 session->machines.host.env = &perf_env; in __perf_session__new()
245 session->machines.host.single_address_space = in __perf_session__new()
246 perf_env__single_address_space(session->machines.host.env); in __perf_session__new()
253 if (perf_session__create_kernel_maps(session) < 0) in __perf_session__new()
262 tool->ordered_events && !evlist__sample_id_all(session->evlist)) { in __perf_session__new()
267 return session; in __perf_session__new()
270 perf_session__delete(session); in __perf_session__new()
275 static void perf_session__delete_threads(struct perf_session *session) in perf_session__delete_threads() argument
277 machine__delete_threads(&session->machines.host); in perf_session__delete_threads()
295 void perf_session__delete(struct perf_session *session) in perf_session__delete() argument
297 if (session == NULL) in perf_session__delete()
299 auxtrace__free(session); in perf_session__delete()
300 auxtrace_index__free(&session->auxtrace_index); in perf_session__delete()
301 perf_session__destroy_kernel_maps(session); in perf_session__delete()
302 perf_session__delete_threads(session); in perf_session__delete()
303 perf_decomp__release_events(session->decomp_data.decomp); in perf_session__delete()
304 perf_env__exit(&session->header.env); in perf_session__delete()
305 machines__exit(&session->machines); in perf_session__delete()
306 if (session->data) { in perf_session__delete()
307 if (perf_data__is_read(session->data)) in perf_session__delete()
308 evlist__delete(session->evlist); in perf_session__delete()
309 perf_data__close(session->data); in perf_session__delete()
311 trace_event__cleanup(&session->tevent); in perf_session__delete()
312 free(session); in perf_session__delete()
315 static int process_event_synth_tracing_data_stub(struct perf_session *session in process_event_synth_tracing_data_stub()
391 static s64 process_event_auxtrace_stub(struct perf_session *session __maybe_unused, in process_event_auxtrace_stub()
395 if (perf_data__is_pipe(session->data)) in process_event_auxtrace_stub()
396 skipn(perf_data__fd(session->data), event->auxtrace.size); in process_event_auxtrace_stub()
400 static int process_event_op2_stub(struct perf_session *session __maybe_unused, in process_event_op2_stub()
409 int process_event_thread_map_stub(struct perf_session *session __maybe_unused, in process_event_thread_map_stub()
420 int process_event_cpu_map_stub(struct perf_session *session __maybe_unused, in process_event_cpu_map_stub()
431 int process_event_stat_config_stub(struct perf_session *session __maybe_unused, in process_event_stat_config_stub()
471 static int perf_session__process_compressed_event_stub(struct perf_session *session __maybe_unused, in perf_session__process_compressed_event_stub()
1571 static int perf_session__deliver_event(struct perf_session *session, in perf_session__deliver_event() argument
1577 int ret = evlist__parse_sample(session->evlist, event, &sample); in perf_session__deliver_event()
1584 ret = auxtrace__process_event(session, event, &sample, tool); in perf_session__deliver_event()
1590 ret = machines__deliver_event(&session->machines, session->evlist, in perf_session__deliver_event()
1594 auxtrace__dump_auxtrace_sample(session, &sample); in perf_session__deliver_event()
1599 static s64 perf_session__process_user_event(struct perf_session *session, in perf_session__process_user_event() argument
1603 struct ordered_events *oe = &session->ordered_events; in perf_session__process_user_event()
1604 struct perf_tool *tool = session->tool; in perf_session__process_user_event()
1606 int fd = perf_data__fd(session->data); in perf_session__process_user_event()
1611 dump_event(session->evlist, event, file_offset, &sample); in perf_session__process_user_event()
1616 err = tool->attr(tool, event, &session->evlist); in perf_session__process_user_event()
1618 perf_session__set_id_hdr_size(session); in perf_session__process_user_event()
1619 perf_session__set_comm_exec(session); in perf_session__process_user_event()
1623 return tool->event_update(tool, event, &session->evlist); in perf_session__process_user_event()
1636 if (!perf_data__is_pipe(session->data)) in perf_session__process_user_event()
1638 return tool->tracing_data(session, event); in perf_session__process_user_event()
1640 return tool->build_id(session, event); in perf_session__process_user_event()
1644 return tool->id_index(session, event); in perf_session__process_user_event()
1646 return tool->auxtrace_info(session, event); in perf_session__process_user_event()
1650 return tool->auxtrace(session, event); in perf_session__process_user_event()
1652 perf_session__auxtrace_error_inc(session, event); in perf_session__process_user_event()
1653 return tool->auxtrace_error(session, event); in perf_session__process_user_event()
1655 return tool->thread_map(session, event); in perf_session__process_user_event()
1657 return tool->cpu_map(session, event); in perf_session__process_user_event()
1659 return tool->stat_config(session, event); in perf_session__process_user_event()
1661 return tool->stat(session, event); in perf_session__process_user_event()
1663 return tool->stat_round(session, event); in perf_session__process_user_event()
1665 session->time_conv = event->time_conv; in perf_session__process_user_event()
1666 return tool->time_conv(session, event); in perf_session__process_user_event()
1668 return tool->feature(session, event); in perf_session__process_user_event()
1670 err = tool->compressed(session, event, file_offset); in perf_session__process_user_event()
1672 dump_event(session->evlist, event, file_offset, &sample); in perf_session__process_user_event()
1679 int perf_session__deliver_synth_event(struct perf_session *session, in perf_session__deliver_synth_event() argument
1683 struct evlist *evlist = session->evlist; in perf_session__deliver_synth_event()
1684 struct perf_tool *tool = session->tool; in perf_session__deliver_synth_event()
1689 return perf_session__process_user_event(session, event, 0); in perf_session__deliver_synth_event()
1691 return machines__deliver_event(&session->machines, evlist, event, sample, tool, 0); in perf_session__deliver_synth_event()
1703 int perf_session__peek_event(struct perf_session *session, off_t file_offset, in perf_session__peek_event() argument
1712 if (session->one_mmap && !session->header.needs_swap) { in perf_session__peek_event()
1713 event = file_offset - session->one_mmap_offset + in perf_session__peek_event()
1714 session->one_mmap_addr; in perf_session__peek_event()
1718 if (perf_data__is_pipe(session->data)) in perf_session__peek_event()
1721 fd = perf_data__fd(session->data); in perf_session__peek_event()
1733 if (session->header.needs_swap) in perf_session__peek_event()
1745 if (session->header.needs_swap) in perf_session__peek_event()
1746 event_swap(event, evlist__sample_id_all(session->evlist)); in perf_session__peek_event()
1751 evlist__parse_sample(session->evlist, event, sample)) in perf_session__peek_event()
1759 int perf_session__peek_events(struct perf_session *session, u64 offset, in perf_session__peek_events() argument
1768 err = perf_session__peek_event(session, offset, buf, in perf_session__peek_events()
1774 err = cb(session, event, offset, data); in perf_session__peek_events()
1787 static s64 perf_session__process_event(struct perf_session *session, in perf_session__process_event() argument
1790 struct evlist *evlist = session->evlist; in perf_session__process_event()
1791 struct perf_tool *tool = session->tool; in perf_session__process_event()
1794 if (session->header.needs_swap) in perf_session__process_event()
1803 return perf_session__process_user_event(session, event, file_offset); in perf_session__process_event()
1812 ret = perf_session__queue_event(session, event, timestamp, file_offset); in perf_session__process_event()
1817 return perf_session__deliver_event(session, event, tool, file_offset); in perf_session__process_event()
1827 struct thread *perf_session__findnew(struct perf_session *session, pid_t pid) in perf_session__findnew() argument
1829 return machine__findnew_thread(&session->machines.host, -1, pid); in perf_session__findnew()
1832 int perf_session__register_idle_thread(struct perf_session *session) in perf_session__register_idle_thread() argument
1834 struct thread *thread = machine__idle_thread(&session->machines.host); in perf_session__register_idle_thread()
1842 perf_session__warn_order(const struct perf_session *session) in perf_session__warn_order() argument
1844 const struct ordered_events *oe = &session->ordered_events; in perf_session__warn_order()
1848 evlist__for_each_entry(session->evlist, evsel) { in perf_session__warn_order()
1859 static void perf_session__warn_about_errors(const struct perf_session *session) in perf_session__warn_about_errors() argument
1861 const struct events_stats *stats = &session->evlist->stats; in perf_session__warn_about_errors()
1863 if (session->tool->lost == perf_event__process_lost && in perf_session__warn_about_errors()
1871 if (session->tool->lost_samples == perf_event__process_lost_samples) { in perf_session__warn_about_errors()
1883 if (session->tool->aux == perf_event__process_aux && in perf_session__warn_about_errors()
1890 if (session->tool->aux == perf_event__process_aux && in perf_session__warn_about_errors()
1907 if (session->tool->aux == perf_event__process_aux && in perf_session__warn_about_errors()
1942 perf_session__warn_order(session); in perf_session__warn_about_errors()
1964 static int perf_session__flush_thread_stacks(struct perf_session *session) in perf_session__flush_thread_stacks() argument
1966 return machines__for_each_thread(&session->machines, in perf_session__flush_thread_stacks()
1973 static int __perf_session__process_decomp_events(struct perf_session *session);
1975 static int __perf_session__process_pipe_events(struct perf_session *session) in __perf_session__process_pipe_events() argument
1977 struct ordered_events *oe = &session->ordered_events; in __perf_session__process_pipe_events()
1978 struct perf_tool *tool = session->tool; in __perf_session__process_pipe_events()
1998 err = perf_data__read(session->data, event, in __perf_session__process_pipe_events()
2008 if (session->header.needs_swap) in __perf_session__process_pipe_events()
2031 err = perf_data__read(session->data, p, in __perf_session__process_pipe_events()
2044 if ((skip = perf_session__process_event(session, event, head)) < 0) { in __perf_session__process_pipe_events()
2056 err = __perf_session__process_decomp_events(session); in __perf_session__process_pipe_events()
2067 err = auxtrace__flush_events(session, tool); in __perf_session__process_pipe_events()
2070 err = perf_session__flush_thread_stacks(session); in __perf_session__process_pipe_events()
2074 perf_session__warn_about_errors(session); in __perf_session__process_pipe_events()
2075 ordered_events__free(&session->ordered_events); in __perf_session__process_pipe_events()
2076 auxtrace__free_events(session); in __perf_session__process_pipe_events()
2122 static int __perf_session__process_decomp_events(struct perf_session *session) in __perf_session__process_decomp_events() argument
2126 struct decomp *decomp = session->active_decomp->decomp_last; in __perf_session__process_decomp_events()
2133 session->header.needs_swap); in __perf_session__process_decomp_events()
2141 (skip = perf_session__process_event(session, event, decomp->file_pos)) < 0) { in __perf_session__process_decomp_events()
2170 typedef s64 (*reader_cb_t)(struct perf_session *session,
2224 reader__mmap(struct reader *rd, struct perf_session *session) in reader__mmap() argument
2235 } else if (session->header.needs_swap) { in reader__mmap()
2258 if (session->one_mmap) { in reader__mmap()
2259 session->one_mmap_addr = buf; in reader__mmap()
2260 session->one_mmap_offset = rd->file_offset; in reader__mmap()
2272 reader__read_event(struct reader *rd, struct perf_session *session, in reader__read_event() argument
2281 session->header.needs_swap); in reader__read_event()
2293 (skip = rd->process(session, event, rd->file_pos)) < 0) { in reader__read_event()
2307 err = __perf_session__process_decomp_events(session); in reader__read_event()
2324 reader__process_events(struct reader *rd, struct perf_session *session, in reader__process_events() argument
2329 err = reader__init(rd, &session->one_mmap); in reader__process_events()
2333 session->active_decomp = &rd->decomp_data; in reader__process_events()
2336 err = reader__mmap(rd, session); in reader__process_events()
2341 err = reader__read_event(rd, session, prog); in reader__process_events()
2354 session->active_decomp = &session->decomp_data; in reader__process_events()
2358 static s64 process_simple(struct perf_session *session, in process_simple() argument
2362 return perf_session__process_event(session, event, file_offset); in process_simple()
2365 static int __perf_session__process_events(struct perf_session *session) in __perf_session__process_events() argument
2368 .fd = perf_data__fd(session->data), in __perf_session__process_events()
2369 .data_size = session->header.data_size, in __perf_session__process_events()
2370 .data_offset = session->header.data_offset, in __perf_session__process_events()
2372 .in_place_update = session->data->in_place_update, in __perf_session__process_events()
2374 struct ordered_events *oe = &session->ordered_events; in __perf_session__process_events()
2375 struct perf_tool *tool = session->tool; in __perf_session__process_events()
2386 err = reader__process_events(&rd, session, &prog); in __perf_session__process_events()
2393 err = auxtrace__flush_events(session, tool); in __perf_session__process_events()
2396 err = perf_session__flush_thread_stacks(session); in __perf_session__process_events()
2400 perf_session__warn_about_errors(session); in __perf_session__process_events()
2405 ordered_events__reinit(&session->ordered_events); in __perf_session__process_events()
2406 auxtrace__free_events(session); in __perf_session__process_events()
2408 session->one_mmap = false; in __perf_session__process_events()
2412 int perf_session__process_events(struct perf_session *session) in perf_session__process_events() argument
2414 if (perf_session__register_idle_thread(session) < 0) in perf_session__process_events()
2417 if (perf_data__is_pipe(session->data)) in perf_session__process_events()
2418 return __perf_session__process_pipe_events(session); in perf_session__process_events()
2420 return __perf_session__process_events(session); in perf_session__process_events()
2423 bool perf_session__has_traces(struct perf_session *session, const char *msg) in perf_session__has_traces() argument
2427 evlist__for_each_entry(session->evlist, evsel) { in perf_session__has_traces()
2465 size_t perf_session__fprintf_dsos(struct perf_session *session, FILE *fp) in perf_session__fprintf_dsos() argument
2467 return machines__fprintf_dsos(&session->machines, fp); in perf_session__fprintf_dsos()
2470 size_t perf_session__fprintf_dsos_buildid(struct perf_session *session, FILE *fp, in perf_session__fprintf_dsos_buildid() argument
2473 return machines__fprintf_dsos_buildid(&session->machines, fp, skip, parm); in perf_session__fprintf_dsos_buildid()
2476 size_t perf_session__fprintf_nr_events(struct perf_session *session, FILE *fp, in perf_session__fprintf_nr_events() argument
2482 if (perf_header__has_feat(&session->header, HEADER_AUXTRACE)) in perf_session__fprintf_nr_events()
2487 ret += events_stats__fprintf(&session->evlist->stats, fp, skip_empty); in perf_session__fprintf_nr_events()
2491 size_t perf_session__fprintf(struct perf_session *session, FILE *fp) in perf_session__fprintf() argument
2497 return machine__fprintf(&session->machines.host, fp); in perf_session__fprintf()
2500 struct evsel *perf_session__find_first_evtype(struct perf_session *session, in perf_session__find_first_evtype() argument
2505 evlist__for_each_entry(session->evlist, pos) { in perf_session__find_first_evtype()
2512 int perf_session__cpu_bitmap(struct perf_session *session, in perf_session__cpu_bitmap() argument
2517 int nr_cpus = min(session->header.env.nr_cpus_avail, MAX_NR_CPUS); in perf_session__cpu_bitmap()
2522 evsel = perf_session__find_first_evtype(session, i); in perf_session__cpu_bitmap()
2558 void perf_session__fprintf_info(struct perf_session *session, FILE *fp, in perf_session__fprintf_info() argument
2561 if (session == NULL || fp == NULL) in perf_session__fprintf_info()
2565 perf_header__fprintf_info(session, fp, full); in perf_session__fprintf_info()
2569 int perf_event__process_id_index(struct perf_session *session, in perf_event__process_id_index() argument
2572 struct evlist *evlist = session->evlist; in perf_event__process_id_index()