Lines Matching refs:inject
3 * builtin-inject.c
5 * Builtin inject command: Examine the live mode (stdin) event stream
140 static int output_bytes(struct perf_inject *inject, void *buf, size_t sz)
144 size = perf_data__write(&inject->output, buf, sz);
148 inject->bytes_written += size;
155 struct perf_inject *inject = container_of(tool, struct perf_inject,
158 return output_bytes(inject, event, event->header.size);
195 struct perf_inject *inject = container_of(tool, struct perf_inject,
203 if (!inject->is_pipe)
218 static int copy_bytes(struct perf_inject *inject, struct perf_data *data, off_t size)
228 ret = output_bytes(inject, buf, ssz);
241 struct perf_inject *inject = container_of(tool, struct perf_inject,
245 inject->have_auxtrace = true;
247 if (!inject->output.is_pipe) {
250 offset = lseek(inject->output.file.fd, 0, SEEK_CUR);
260 ret = output_bytes(inject, event, event->header.size);
263 ret = copy_bytes(inject, session->data,
266 ret = output_bytes(inject, event,
308 struct perf_inject *inject = container_of(tool, struct perf_inject, tool);
310 if (!inject->aux_id)
311 inject->aux_id = sample->id;
317 perf_inject__cut_auxtrace_sample(struct perf_inject *inject,
325 if (inject->event_copy == NULL) {
326 inject->event_copy = malloc(PERF_SAMPLE_MAX_SIZE);
327 if (!inject->event_copy)
330 ev = (union perf_event *)inject->event_copy;
356 struct perf_inject *inject = container_of(tool, struct perf_inject,
366 if (inject->itrace_synth_opts.set && sample->aux_sample.size) {
367 event = perf_inject__cut_auxtrace_sample(inject, event, sample);
394 struct perf_inject *inject = container_of(tool, struct perf_inject, tool);
399 * if jit marker, then inject jit mmaps and generate ELF images
401 ret = jit_process(inject->session, &inject->output, machine,
406 inject->bytes_written += n;
494 /* mark it not to inject build-id */
509 struct perf_inject *inject = container_of(tool, struct perf_inject, tool);
514 * if jit marker, then inject jit mmaps and generate ELF images
516 ret = jit_process(inject->session, &inject->output, machine,
521 inject->bytes_written += n;
546 /* mark it not to inject build-id */
690 static bool perf_inject__lookup_known_build_id(struct perf_inject *inject,
696 strlist__for_each_entry(pos, inject->known_build_ids) {
719 struct perf_inject *inject = container_of(tool, struct perf_inject,
728 if (inject->known_build_ids != NULL &&
729 perf_inject__lookup_known_build_id(inject, dso))
786 struct perf_inject *inject = container_of(tool, struct perf_inject, tool);
789 list_for_each_entry(ent, &inject->samples, node) {
806 struct perf_inject *inject = container_of(tool, struct perf_inject, tool);
820 list_add(&ent->node, &inject->samples);
834 struct perf_inject *inject = container_of(tool, struct perf_inject, tool);
837 list_for_each_entry(ent, &inject->samples, node) {
1040 struct perf_inject *inject = container_of(tool, struct perf_inject, tool);
1042 return perf_event__process_attr(tool, event, &inject->session->evlist);
1047 struct perf_inject *inject = container_of(gs, struct perf_inject, guest_session);
1079 ret = perf_event__synthesize_attr(&inject->tool, &attr, evsel->core.ids,
1088 sid = evlist__id2sid(inject->session->evlist, id_array[i]);
1116 static int synthesize_id_index(struct perf_inject *inject, size_t new_cnt)
1118 struct perf_session *session = inject->session;
1123 return __perf_event__synthesize_id_index(&inject->tool, perf_event__repipe,
1169 struct perf_inject *inject = container_of(tool, struct perf_inject, tool);
1171 return perf_event__process_build_id(inject->session, event);
1174 static int synthesize_build_id(struct perf_inject *inject, struct dso *dso, pid_t machine_pid)
1176 struct machine *machine = perf_session__findnew_machine(inject->session, machine_pid);
1186 return perf_event__synthesize_build_id(&inject->tool, dso, cpumode,
1192 struct perf_inject *inject = container_of(gs, struct perf_inject, guest_session);
1198 perf_header__set_feat(&inject->session->header, HEADER_BUILD_ID);
1201 ret = synthesize_build_id(inject, dso, gs->machine_pid);
1225 char tmp_file_name[] = "/tmp/perf-inject-guest_session-XXXXXX";
1342 struct perf_inject *inject = container_of(gs, struct perf_inject, guest_session);
1344 get_tsc_conv(&gs->host_tc, &inject->session->time_conv);
1462 struct perf_inject *inject = container_of(gs, struct perf_inject, guest_session);
1551 ret = evlist__append_id_sample(inject->session->evlist, ev, sample);
1562 ret = output_bytes(inject, ev, ev->header.size);
1578 struct perf_inject *inject = container_of(tool, struct perf_inject, tool);
1581 ret = guest_session__inject_events(&inject->guest_session, sample->time);
1590 struct perf_inject *inject = container_of(session->tool, struct perf_inject, tool);
1591 struct guest_session *gs = &inject->guest_session;
1619 ret = synthesize_id_index(inject, gs->session->evlist->core.nr_entries);
1642 * which flushes host events to file up until the last flush time. Then inject
1650 struct perf_inject *inject = container_of(tool, struct perf_inject, tool);
1657 ret = guest_session__inject_events(&inject->guest_session, timestamp);
1669 struct perf_inject *inject = container_of(tool, struct perf_inject, tool);
1671 struct guest_session *gs = &inject->guest_session;
1727 static void strip_init(struct perf_inject *inject)
1729 struct evlist *evlist = inject->session->evlist;
1732 inject->tool.context_switch = perf_event__drop;
1740 struct perf_inject *inject = opt->value;
1747 inject->itrace_synth_opts.set = true;
1748 inject->itrace_synth_opts.vm_time_correlation = true;
1749 inject->in_place_update = true;
1756 inject->itrace_synth_opts.vm_tm_corr_dry_run = true;
1757 inject->in_place_update_dry_run = true;
1763 inject->itrace_synth_opts.vm_tm_corr_args = strdup(args);
1765 return inject->itrace_synth_opts.vm_tm_corr_args ? 0 : -ENOMEM;
1770 struct perf_inject *inject = opt->value;
1771 struct guest_session *gs = &inject->guest_session;
1791 inject->output.is_dir = true;
1797 if (!inject->guest_session.machine_pid)
1827 struct perf_inject *inject = data;
1829 inject->secs[feat] = *section;
1833 static int save_section_info(struct perf_inject *inject)
1835 struct perf_header *header = &inject->session->header;
1836 int fd = perf_data__fd(inject->session->data);
1838 return perf_header__process_sections(header, fd, inject, save_section_info_cb);
1894 static int feat_copy(struct perf_inject *inject, int feat, struct feat_writer *fw)
1896 int fd = perf_data__fd(inject->session->data);
1897 u64 offs = inject->secs[feat].offset;
1898 size_t sz = inject->secs[feat].size;
1917 struct perf_inject *inject;
1923 struct perf_inject *inject = inj_fc->inject;
1926 if (!inject->secs[feat].offset ||
1930 ret = feat_copy(inject, feat, fw);
1937 static int copy_kcore_dir(struct perf_inject *inject)
1943 inject->input_name, inject->output.path);
1954 struct perf_inject *inject = container_of(gs, struct perf_inject, guest_session);
1959 gs->perf_data_file, inject->output.path, gs->machine_pid);
1968 static int output_fd(struct perf_inject *inject)
1970 return inject->in_place_update ? -1 : perf_data__fd(&inject->output);
1973 static int __cmd_inject(struct perf_inject *inject)
1976 struct guest_session *gs = &inject->guest_session;
1977 struct perf_session *session = inject->session;
1978 int fd = output_fd(inject);
1983 if (inject->build_ids || inject->sched_stat ||
1984 inject->itrace_synth_opts.set || inject->build_id_all) {
1985 inject->tool.mmap = perf_event__repipe_mmap;
1986 inject->tool.mmap2 = perf_event__repipe_mmap2;
1987 inject->tool.fork = perf_event__repipe_fork;
1989 inject->tool.tracing_data = perf_event__repipe_tracing_data;
1995 if (inject->build_id_all) {
1996 inject->tool.mmap = perf_event__repipe_buildid_mmap;
1997 inject->tool.mmap2 = perf_event__repipe_buildid_mmap2;
1998 } else if (inject->build_ids) {
1999 inject->tool.sample = perf_event__inject_buildid;
2000 } else if (inject->sched_stat) {
2018 } else if (inject->itrace_synth_opts.vm_time_correlation) {
2019 session->itrace_synth_opts = &inject->itrace_synth_opts;
2020 memset(&inject->tool, 0, sizeof(inject->tool));
2021 inject->tool.id_index = perf_event__process_id_index;
2022 inject->tool.auxtrace_info = perf_event__process_auxtrace_info;
2023 inject->tool.auxtrace = perf_event__process_auxtrace;
2024 inject->tool.auxtrace_error = perf_event__process_auxtrace_error;
2025 inject->tool.ordered_events = true;
2026 inject->tool.ordering_requires_timestamps = true;
2027 } else if (inject->itrace_synth_opts.set) {
2028 session->itrace_synth_opts = &inject->itrace_synth_opts;
2029 inject->itrace_synth_opts.inject = true;
2030 inject->tool.comm = perf_event__repipe_comm;
2031 inject->tool.namespaces = perf_event__repipe_namespaces;
2032 inject->tool.exit = perf_event__repipe_exit;
2033 inject->tool.id_index = perf_event__process_id_index;
2034 inject->tool.auxtrace_info = perf_event__process_auxtrace_info;
2035 inject->tool.auxtrace = perf_event__process_auxtrace;
2036 inject->tool.aux = perf_event__drop_aux;
2037 inject->tool.itrace_start = perf_event__drop_aux;
2038 inject->tool.aux_output_hw_id = perf_event__drop_aux;
2039 inject->tool.ordered_events = true;
2040 inject->tool.ordering_requires_timestamps = true;
2043 if (inject->strip)
2044 strip_init(inject);
2052 inject->tool.mmap = host__repipe;
2053 inject->tool.mmap2 = host__repipe;
2054 inject->tool.comm = host__repipe;
2055 inject->tool.fork = host__repipe;
2056 inject->tool.exit = host__repipe;
2057 inject->tool.lost = host__repipe;
2058 inject->tool.context_switch = host__repipe;
2059 inject->tool.ksymbol = host__repipe;
2060 inject->tool.text_poke = host__repipe;
2066 inject->tool.finished_init = host__finished_init;
2068 inject->tool.finished_round = host__finished_round,
2070 inject->tool.context_switch = host__context_switch;
2075 inject->tool.ordered_events = true;
2076 inject->tool.ordering_requires_timestamps = true;
2088 if (!inject->itrace_synth_opts.set)
2091 if (!inject->is_pipe && !inject->in_place_update)
2110 if (!inject->is_pipe && !inject->in_place_update) {
2113 .inject = inject,
2116 if (inject->build_ids)
2124 inject->have_auxtrace && !inject->itrace_synth_opts.set)
2130 if (inject->itrace_synth_opts.set) {
2133 if (inject->itrace_synth_opts.last_branch ||
2134 inject->itrace_synth_opts.add_last_branch)
2139 session->header.data_size = inject->bytes_written;
2142 if (inject->copy_kcore_dir) {
2143 ret = copy_kcore_dir(inject);
2163 struct perf_inject inject = {
2205 .samples = LIST_HEAD_INIT(inject.samples),
2221 OPT_BOOLEAN('b', "build-ids", &inject.build_ids,
2223 OPT_BOOLEAN(0, "buildid-all", &inject.build_id_all,
2228 OPT_STRING('i', "input", &inject.input_name, "file",
2230 OPT_STRING('o', "output", &inject.output.path, "file",
2232 OPT_BOOLEAN('s', "sched-stat", &inject.sched_stat,
2236 OPT_BOOLEAN('j', "jit", &inject.jit_mode, "merge jitdump files into perf.data file"),
2247 OPT_CALLBACK_OPTARG(0, "itrace", &inject.itrace_synth_opts,
2251 OPT_BOOLEAN(0, "strip", &inject.strip,
2253 OPT_CALLBACK_OPTARG(0, "vm-time-correlation", &inject, NULL, "opts",
2256 OPT_CALLBACK_OPTARG(0, "guest-data", &inject, NULL, "opts",
2257 "inject events from a guest perf.data file",
2265 "perf inject [<options>]",
2279 if (inject.strip && !inject.itrace_synth_opts.set) {
2287 if (inject.in_place_update) {
2288 if (!strcmp(inject.input_name, "-")) {
2292 if (strcmp(inject.output.path, "-")) {
2296 if (!data.force && !inject.in_place_update_dry_run) {
2301 if (!inject.in_place_update_dry_run)
2304 if (strcmp(inject.output.path, "-") && !inject.strip &&
2305 has_kcore_dir(inject.input_name)) {
2306 inject.output.is_dir = true;
2307 inject.copy_kcore_dir = true;
2309 if (perf_data__open(&inject.output)) {
2315 data.path = inject.input_name;
2316 if (!strcmp(inject.input_name, "-") || inject.output.is_pipe) {
2317 inject.is_pipe = true;
2323 if (strcmp(inject.input_name, "-"))
2327 inject.session = __perf_session__new(&data, repipe,
2328 output_fd(&inject),
2329 &inject.tool);
2330 if (IS_ERR(inject.session)) {
2331 ret = PTR_ERR(inject.session);
2335 if (zstd_init(&(inject.session->zstd_data), 0) < 0)
2339 ret = save_section_info(&inject);
2343 if (!data.is_pipe && inject.output.is_pipe) {
2344 ret = perf_header__write_pipe(perf_data__fd(&inject.output));
2350 ret = perf_event__synthesize_for_pipe(&inject.tool,
2351 inject.session,
2352 &inject.output,
2358 if (inject.build_ids && !inject.build_id_all) {
2363 * inject the jit mmaps at the same time for now.
2365 inject.tool.ordered_events = true;
2366 inject.tool.ordering_requires_timestamps = true;
2368 inject.known_build_ids =
2371 if (inject.known_build_ids == NULL) {
2378 if (inject.sched_stat) {
2379 inject.tool.ordered_events = true;
2383 if (inject.jit_mode) {
2384 inject.tool.mmap2 = perf_event__jit_repipe_mmap2;
2385 inject.tool.mmap = perf_event__jit_repipe_mmap;
2386 inject.tool.ordered_events = true;
2387 inject.tool.ordering_requires_timestamps = true;
2392 inject.tool.finished_round = perf_event__drop_oe;
2395 ret = symbol__init(&inject.session->header.env);
2399 ret = __cmd_inject(&inject);
2401 guest_session__exit(&inject.guest_session);
2404 strlist__delete(inject.known_build_ids);
2405 zstd_fini(&(inject.session->zstd_data));
2406 perf_session__delete(inject.session);
2408 if (!inject.in_place_update)
2409 perf_data__close(&inject.output);
2410 free(inject.itrace_synth_opts.vm_tm_corr_args);
2411 free(inject.event_copy);
2412 free(inject.guest_session.ev.event_buf);