Lines Matching refs:session
38 static int perf_session__process_compressed_event(struct perf_session *session, in perf_session__process_compressed_event() argument
44 size_t mmap_len, decomp_len = session->header.env.comp_mmap_len; in perf_session__process_compressed_event()
45 struct decomp *decomp, *decomp_last = session->decomp_last; in perf_session__process_compressed_event()
72 decomp_size = zstd_decompress_stream(&(session->zstd_data), src, src_size, in perf_session__process_compressed_event()
82 if (session->decomp == NULL) { in perf_session__process_compressed_event()
83 session->decomp = decomp; in perf_session__process_compressed_event()
84 session->decomp_last = decomp; in perf_session__process_compressed_event()
86 session->decomp_last->next = decomp; in perf_session__process_compressed_event()
87 session->decomp_last = decomp; in perf_session__process_compressed_event()
98 static int perf_session__deliver_event(struct perf_session *session,
103 static int perf_session__open(struct perf_session *session) in perf_session__open() argument
105 struct perf_data *data = session->data; in perf_session__open()
107 if (perf_session__read_header(session) < 0) { in perf_session__open()
115 if (perf_header__has_feat(&session->header, HEADER_STAT)) in perf_session__open()
118 if (!evlist__valid_sample_type(session->evlist)) { in perf_session__open()
123 if (!evlist__valid_sample_id_all(session->evlist)) { in perf_session__open()
128 if (!perf_evlist__valid_read_format(session->evlist)) { in perf_session__open()
136 void perf_session__set_id_hdr_size(struct perf_session *session) in perf_session__set_id_hdr_size() argument
138 u16 id_hdr_size = perf_evlist__id_hdr_size(session->evlist); in perf_session__set_id_hdr_size()
140 machines__set_id_hdr_size(&session->machines, id_hdr_size); in perf_session__set_id_hdr_size()
143 int perf_session__create_kernel_maps(struct perf_session *session) in perf_session__create_kernel_maps() argument
145 int ret = machine__create_kernel_maps(&session->machines.host); in perf_session__create_kernel_maps()
148 ret = machines__create_guest_kernel_maps(&session->machines); in perf_session__create_kernel_maps()
152 static void perf_session__destroy_kernel_maps(struct perf_session *session) in perf_session__destroy_kernel_maps() argument
154 machines__destroy_kernel_maps(&session->machines); in perf_session__destroy_kernel_maps()
157 static bool perf_session__has_comm_exec(struct perf_session *session) in perf_session__has_comm_exec() argument
161 evlist__for_each_entry(session->evlist, evsel) { in perf_session__has_comm_exec()
169 static void perf_session__set_comm_exec(struct perf_session *session) in perf_session__set_comm_exec() argument
171 bool comm_exec = perf_session__has_comm_exec(session); in perf_session__set_comm_exec()
173 machines__set_comm_exec(&session->machines, comm_exec); in perf_session__set_comm_exec()
179 struct perf_session *session = container_of(oe, struct perf_session, in ordered_events__deliver_event() local
182 return perf_session__deliver_event(session, event->event, in ordered_events__deliver_event()
183 session->tool, event->file_offset); in ordered_events__deliver_event()
190 struct perf_session *session = zalloc(sizeof(*session)); in perf_session__new() local
192 if (!session) in perf_session__new()
195 session->repipe = repipe; in perf_session__new()
196 session->tool = tool; in perf_session__new()
197 INIT_LIST_HEAD(&session->auxtrace_index); in perf_session__new()
198 machines__init(&session->machines); in perf_session__new()
199 ordered_events__init(&session->ordered_events, in perf_session__new()
202 perf_env__init(&session->header.env); in perf_session__new()
208 session->data = data; in perf_session__new()
211 ret = perf_session__open(session); in perf_session__new()
220 perf_session__set_id_hdr_size(session); in perf_session__new()
221 perf_session__set_comm_exec(session); in perf_session__new()
224 perf_evlist__init_trace_event_sample_raw(session->evlist); in perf_session__new()
238 session->machines.host.env = &perf_env; in perf_session__new()
241 session->machines.host.single_address_space = in perf_session__new()
242 perf_env__single_address_space(session->machines.host.env); in perf_session__new()
249 if (perf_session__create_kernel_maps(session) < 0) in perf_session__new()
258 tool->ordered_events && !evlist__sample_id_all(session->evlist)) { in perf_session__new()
263 return session; in perf_session__new()
266 perf_session__delete(session); in perf_session__new()
271 static void perf_session__delete_threads(struct perf_session *session) in perf_session__delete_threads() argument
273 machine__delete_threads(&session->machines.host); in perf_session__delete_threads()
276 static void perf_session__release_decomp_events(struct perf_session *session) in perf_session__release_decomp_events() argument
280 next = session->decomp; in perf_session__release_decomp_events()
291 void perf_session__delete(struct perf_session *session) in perf_session__delete() argument
293 if (session == NULL) in perf_session__delete()
295 auxtrace__free(session); in perf_session__delete()
296 auxtrace_index__free(&session->auxtrace_index); in perf_session__delete()
297 perf_session__destroy_kernel_maps(session); in perf_session__delete()
298 perf_session__delete_threads(session); in perf_session__delete()
299 perf_session__release_decomp_events(session); in perf_session__delete()
300 perf_env__exit(&session->header.env); in perf_session__delete()
301 machines__exit(&session->machines); in perf_session__delete()
302 if (session->data) in perf_session__delete()
303 perf_data__close(session->data); in perf_session__delete()
304 free(session); in perf_session__delete()
307 static int process_event_synth_tracing_data_stub(struct perf_session *session in process_event_synth_tracing_data_stub()
383 static s64 process_event_auxtrace_stub(struct perf_session *session __maybe_unused, in process_event_auxtrace_stub()
387 if (perf_data__is_pipe(session->data)) in process_event_auxtrace_stub()
388 skipn(perf_data__fd(session->data), event->auxtrace.size); in process_event_auxtrace_stub()
392 static int process_event_op2_stub(struct perf_session *session __maybe_unused, in process_event_op2_stub()
401 int process_event_thread_map_stub(struct perf_session *session __maybe_unused, in process_event_thread_map_stub()
412 int process_event_cpu_map_stub(struct perf_session *session __maybe_unused, in process_event_cpu_map_stub()
423 int process_event_stat_config_stub(struct perf_session *session __maybe_unused, in process_event_stat_config_stub()
453 static int perf_session__process_compressed_event_stub(struct perf_session *session __maybe_unused, in perf_session__process_compressed_event_stub()
1533 static int perf_session__deliver_event(struct perf_session *session, in perf_session__deliver_event() argument
1541 ret = perf_evlist__parse_sample(session->evlist, event, &sample); in perf_session__deliver_event()
1547 ret = auxtrace__process_event(session, event, &sample, tool); in perf_session__deliver_event()
1553 ret = machines__deliver_event(&session->machines, session->evlist, in perf_session__deliver_event()
1557 auxtrace__dump_auxtrace_sample(session, &sample); in perf_session__deliver_event()
1562 static s64 perf_session__process_user_event(struct perf_session *session, in perf_session__process_user_event() argument
1566 struct ordered_events *oe = &session->ordered_events; in perf_session__process_user_event()
1567 struct perf_tool *tool = session->tool; in perf_session__process_user_event()
1569 int fd = perf_data__fd(session->data); in perf_session__process_user_event()
1574 dump_event(session->evlist, event, file_offset, &sample); in perf_session__process_user_event()
1579 err = tool->attr(tool, event, &session->evlist); in perf_session__process_user_event()
1581 perf_session__set_id_hdr_size(session); in perf_session__process_user_event()
1582 perf_session__set_comm_exec(session); in perf_session__process_user_event()
1586 return tool->event_update(tool, event, &session->evlist); in perf_session__process_user_event()
1599 if (!perf_data__is_pipe(session->data)) in perf_session__process_user_event()
1601 return tool->tracing_data(session, event); in perf_session__process_user_event()
1603 return tool->build_id(session, event); in perf_session__process_user_event()
1607 return tool->id_index(session, event); in perf_session__process_user_event()
1609 return tool->auxtrace_info(session, event); in perf_session__process_user_event()
1613 return tool->auxtrace(session, event); in perf_session__process_user_event()
1615 perf_session__auxtrace_error_inc(session, event); in perf_session__process_user_event()
1616 return tool->auxtrace_error(session, event); in perf_session__process_user_event()
1618 return tool->thread_map(session, event); in perf_session__process_user_event()
1620 return tool->cpu_map(session, event); in perf_session__process_user_event()
1622 return tool->stat_config(session, event); in perf_session__process_user_event()
1624 return tool->stat(session, event); in perf_session__process_user_event()
1626 return tool->stat_round(session, event); in perf_session__process_user_event()
1628 session->time_conv = event->time_conv; in perf_session__process_user_event()
1629 return tool->time_conv(session, event); in perf_session__process_user_event()
1631 return tool->feature(session, event); in perf_session__process_user_event()
1633 err = tool->compressed(session, event, file_offset); in perf_session__process_user_event()
1635 dump_event(session->evlist, event, file_offset, &sample); in perf_session__process_user_event()
1642 int perf_session__deliver_synth_event(struct perf_session *session, in perf_session__deliver_synth_event() argument
1646 struct evlist *evlist = session->evlist; in perf_session__deliver_synth_event()
1647 struct perf_tool *tool = session->tool; in perf_session__deliver_synth_event()
1652 return perf_session__process_user_event(session, event, 0); in perf_session__deliver_synth_event()
1654 return machines__deliver_event(&session->machines, evlist, event, sample, tool, 0); in perf_session__deliver_synth_event()
1666 int perf_session__peek_event(struct perf_session *session, off_t file_offset, in perf_session__peek_event() argument
1675 if (session->one_mmap && !session->header.needs_swap) { in perf_session__peek_event()
1676 event = file_offset - session->one_mmap_offset + in perf_session__peek_event()
1677 session->one_mmap_addr; in perf_session__peek_event()
1681 if (perf_data__is_pipe(session->data)) in perf_session__peek_event()
1684 fd = perf_data__fd(session->data); in perf_session__peek_event()
1696 if (session->header.needs_swap) in perf_session__peek_event()
1708 if (session->header.needs_swap) in perf_session__peek_event()
1709 event_swap(event, evlist__sample_id_all(session->evlist)); in perf_session__peek_event()
1714 perf_evlist__parse_sample(session->evlist, event, sample)) in perf_session__peek_event()
1722 int perf_session__peek_events(struct perf_session *session, u64 offset, in perf_session__peek_events() argument
1731 err = perf_session__peek_event(session, offset, buf, in perf_session__peek_events()
1737 err = cb(session, event, offset, data); in perf_session__peek_events()
1750 static s64 perf_session__process_event(struct perf_session *session, in perf_session__process_event() argument
1753 struct evlist *evlist = session->evlist; in perf_session__process_event()
1754 struct perf_tool *tool = session->tool; in perf_session__process_event()
1757 if (session->header.needs_swap) in perf_session__process_event()
1766 return perf_session__process_user_event(session, event, file_offset); in perf_session__process_event()
1775 ret = perf_session__queue_event(session, event, timestamp, file_offset); in perf_session__process_event()
1780 return perf_session__deliver_event(session, event, tool, file_offset); in perf_session__process_event()
1790 struct thread *perf_session__findnew(struct perf_session *session, pid_t pid) in perf_session__findnew() argument
1792 return machine__findnew_thread(&session->machines.host, -1, pid); in perf_session__findnew()
1802 int perf_session__register_idle_thread(struct perf_session *session) in perf_session__register_idle_thread() argument
1807 thread = machine__findnew_thread(&session->machines.host, 0, 0); in perf_session__register_idle_thread()
1824 perf_session__warn_order(const struct perf_session *session) in perf_session__warn_order() argument
1826 const struct ordered_events *oe = &session->ordered_events; in perf_session__warn_order()
1830 evlist__for_each_entry(session->evlist, evsel) { in perf_session__warn_order()
1841 static void perf_session__warn_about_errors(const struct perf_session *session) in perf_session__warn_about_errors() argument
1843 const struct events_stats *stats = &session->evlist->stats; in perf_session__warn_about_errors()
1845 if (session->tool->lost == perf_event__process_lost && in perf_session__warn_about_errors()
1853 if (session->tool->lost_samples == perf_event__process_lost_samples) { in perf_session__warn_about_errors()
1865 if (session->tool->aux == perf_event__process_aux && in perf_session__warn_about_errors()
1872 if (session->tool->aux == perf_event__process_aux && in perf_session__warn_about_errors()
1917 perf_session__warn_order(session); in perf_session__warn_about_errors()
1939 static int perf_session__flush_thread_stacks(struct perf_session *session) in perf_session__flush_thread_stacks() argument
1941 return machines__for_each_thread(&session->machines, in perf_session__flush_thread_stacks()
1948 static int __perf_session__process_decomp_events(struct perf_session *session);
1950 static int __perf_session__process_pipe_events(struct perf_session *session) in __perf_session__process_pipe_events() argument
1952 struct ordered_events *oe = &session->ordered_events; in __perf_session__process_pipe_events()
1953 struct perf_tool *tool = session->tool; in __perf_session__process_pipe_events()
1954 int fd = perf_data__fd(session->data); in __perf_session__process_pipe_events()
1983 if (session->header.needs_swap) in __perf_session__process_pipe_events()
2018 if ((skip = perf_session__process_event(session, event, head)) < 0) { in __perf_session__process_pipe_events()
2030 err = __perf_session__process_decomp_events(session); in __perf_session__process_pipe_events()
2041 err = auxtrace__flush_events(session, tool); in __perf_session__process_pipe_events()
2044 err = perf_session__flush_thread_stacks(session); in __perf_session__process_pipe_events()
2048 perf_session__warn_about_errors(session); in __perf_session__process_pipe_events()
2049 ordered_events__free(&session->ordered_events); in __perf_session__process_pipe_events()
2050 auxtrace__free_events(session); in __perf_session__process_pipe_events()
2096 static int __perf_session__process_decomp_events(struct perf_session *session) in __perf_session__process_decomp_events() argument
2100 struct decomp *decomp = session->decomp_last; in __perf_session__process_decomp_events()
2107 session->header.needs_swap); in __perf_session__process_decomp_events()
2115 (skip = perf_session__process_event(session, event, file_pos)) < 0) { in __perf_session__process_decomp_events()
2144 typedef s64 (*reader_cb_t)(struct perf_session *session,
2156 reader__process_events(struct reader *rd, struct perf_session *session, in reader__process_events() argument
2178 session->one_mmap = true; in reader__process_events()
2186 if (session->header.needs_swap) { in reader__process_events()
2201 if (session->one_mmap) { in reader__process_events()
2202 session->one_mmap_addr = buf; in reader__process_events()
2203 session->one_mmap_offset = file_offset; in reader__process_events()
2207 event = fetch_mmaped_event(head, mmap_size, buf, session->header.needs_swap); in reader__process_events()
2228 (skip = rd->process(session, event, file_pos)) < 0) { in reader__process_events()
2242 err = __perf_session__process_decomp_events(session); in reader__process_events()
2258 static s64 process_simple(struct perf_session *session, in process_simple() argument
2262 return perf_session__process_event(session, event, file_offset); in process_simple()
2265 static int __perf_session__process_events(struct perf_session *session) in __perf_session__process_events() argument
2268 .fd = perf_data__fd(session->data), in __perf_session__process_events()
2269 .data_size = session->header.data_size, in __perf_session__process_events()
2270 .data_offset = session->header.data_offset, in __perf_session__process_events()
2273 struct ordered_events *oe = &session->ordered_events; in __perf_session__process_events()
2274 struct perf_tool *tool = session->tool; in __perf_session__process_events()
2285 err = reader__process_events(&rd, session, &prog); in __perf_session__process_events()
2292 err = auxtrace__flush_events(session, tool); in __perf_session__process_events()
2295 err = perf_session__flush_thread_stacks(session); in __perf_session__process_events()
2299 perf_session__warn_about_errors(session); in __perf_session__process_events()
2304 ordered_events__reinit(&session->ordered_events); in __perf_session__process_events()
2305 auxtrace__free_events(session); in __perf_session__process_events()
2306 session->one_mmap = false; in __perf_session__process_events()
2310 int perf_session__process_events(struct perf_session *session) in perf_session__process_events() argument
2312 if (perf_session__register_idle_thread(session) < 0) in perf_session__process_events()
2315 if (perf_data__is_pipe(session->data)) in perf_session__process_events()
2316 return __perf_session__process_pipe_events(session); in perf_session__process_events()
2318 return __perf_session__process_events(session); in perf_session__process_events()
2321 bool perf_session__has_traces(struct perf_session *session, const char *msg) in perf_session__has_traces() argument
2325 evlist__for_each_entry(session->evlist, evsel) { in perf_session__has_traces()
2363 size_t perf_session__fprintf_dsos(struct perf_session *session, FILE *fp) in perf_session__fprintf_dsos() argument
2365 return machines__fprintf_dsos(&session->machines, fp); in perf_session__fprintf_dsos()
2368 size_t perf_session__fprintf_dsos_buildid(struct perf_session *session, FILE *fp, in perf_session__fprintf_dsos_buildid() argument
2371 return machines__fprintf_dsos_buildid(&session->machines, fp, skip, parm); in perf_session__fprintf_dsos_buildid()
2374 size_t perf_session__fprintf_nr_events(struct perf_session *session, FILE *fp) in perf_session__fprintf_nr_events() argument
2379 if (perf_header__has_feat(&session->header, HEADER_AUXTRACE)) in perf_session__fprintf_nr_events()
2384 ret += events_stats__fprintf(&session->evlist->stats, fp); in perf_session__fprintf_nr_events()
2388 size_t perf_session__fprintf(struct perf_session *session, FILE *fp) in perf_session__fprintf() argument
2394 return machine__fprintf(&session->machines.host, fp); in perf_session__fprintf()
2397 struct evsel *perf_session__find_first_evtype(struct perf_session *session, in perf_session__find_first_evtype() argument
2402 evlist__for_each_entry(session->evlist, pos) { in perf_session__find_first_evtype()
2409 int perf_session__cpu_bitmap(struct perf_session *session, in perf_session__cpu_bitmap() argument
2414 int nr_cpus = min(session->header.env.nr_cpus_avail, MAX_NR_CPUS); in perf_session__cpu_bitmap()
2419 evsel = perf_session__find_first_evtype(session, i); in perf_session__cpu_bitmap()
2455 void perf_session__fprintf_info(struct perf_session *session, FILE *fp, in perf_session__fprintf_info() argument
2458 if (session == NULL || fp == NULL) in perf_session__fprintf_info()
2462 perf_header__fprintf_info(session, fp, full); in perf_session__fprintf_info()
2466 int perf_event__process_id_index(struct perf_session *session, in perf_event__process_id_index() argument
2469 struct evlist *evlist = session->evlist; in perf_event__process_id_index()