4 * Builtin inject command: Examine the live mode (stdin) event stream
5 * and repipe it to stdout while optionally injecting additional
11 #include "util/color.h"
12 #include "util/evlist.h"
13 #include "util/evsel.h"
14 #include "util/session.h"
15 #include "util/tool.h"
16 #include "util/debug.h"
17 #include "util/build-id.h"
18 #include "util/data.h"
20 #include "util/parse-options.h"
22 #include <linux/list.h>
25 struct perf_tool tool;
28 const char *input_name;
32 struct list_head samples;
36 struct list_head node;
38 union perf_event event[0];
41 static int perf_event__repipe_synth(struct perf_tool *tool,
42 union perf_event *event)
44 struct perf_inject *inject = container_of(tool, struct perf_inject, tool);
48 size = event->header.size;
51 int ret = write(inject->output, buf, size);
57 inject->bytes_written += ret;
63 static int perf_event__repipe_op2_synth(struct perf_tool *tool,
64 union perf_event *event,
65 struct perf_session *session
68 return perf_event__repipe_synth(tool, event);
71 static int perf_event__repipe_attr(struct perf_tool *tool,
72 union perf_event *event,
73 struct perf_evlist **pevlist)
77 ret = perf_event__process_attr(tool, event, pevlist);
81 return perf_event__repipe_synth(tool, event);
84 static int perf_event__repipe(struct perf_tool *tool,
85 union perf_event *event,
86 struct perf_sample *sample __maybe_unused,
87 struct machine *machine __maybe_unused)
89 return perf_event__repipe_synth(tool, event);
92 typedef int (*inject_handler)(struct perf_tool *tool,
93 union perf_event *event,
94 struct perf_sample *sample,
95 struct perf_evsel *evsel,
96 struct machine *machine);
98 static int perf_event__repipe_sample(struct perf_tool *tool,
99 union perf_event *event,
100 struct perf_sample *sample,
101 struct perf_evsel *evsel,
102 struct machine *machine)
104 if (evsel->handler.func) {
105 inject_handler f = evsel->handler.func;
106 return f(tool, event, sample, evsel, machine);
109 build_id__mark_dso_hit(tool, event, sample, evsel, machine);
111 return perf_event__repipe_synth(tool, event);
114 static int perf_event__repipe_mmap(struct perf_tool *tool,
115 union perf_event *event,
116 struct perf_sample *sample,
117 struct machine *machine)
121 err = perf_event__process_mmap(tool, event, sample, machine);
122 perf_event__repipe(tool, event, sample, machine);
127 static int perf_event__repipe_mmap2(struct perf_tool *tool,
128 union perf_event *event,
129 struct perf_sample *sample,
130 struct machine *machine)
134 err = perf_event__process_mmap2(tool, event, sample, machine);
135 perf_event__repipe(tool, event, sample, machine);
140 static int perf_event__repipe_fork(struct perf_tool *tool,
141 union perf_event *event,
142 struct perf_sample *sample,
143 struct machine *machine)
147 err = perf_event__process_fork(tool, event, sample, machine);
148 perf_event__repipe(tool, event, sample, machine);
153 static int perf_event__repipe_tracing_data(struct perf_tool *tool,
154 union perf_event *event,
155 struct perf_session *session)
159 perf_event__repipe_synth(tool, event);
160 err = perf_event__process_tracing_data(tool, event, session);
165 static int dso__read_build_id(struct dso *dso)
167 if (dso->has_build_id)
170 if (filename__read_build_id(dso->long_name, dso->build_id,
171 sizeof(dso->build_id)) > 0) {
172 dso->has_build_id = true;
179 static int dso__inject_build_id(struct dso *dso, struct perf_tool *tool,
180 struct machine *machine)
182 u16 misc = PERF_RECORD_MISC_USER;
185 if (dso__read_build_id(dso) < 0) {
186 pr_debug("no build_id found for %s\n", dso->long_name);
191 misc = PERF_RECORD_MISC_KERNEL;
193 err = perf_event__synthesize_build_id(tool, dso, misc, perf_event__repipe,
196 pr_err("Can't synthesize build_id event for %s\n", dso->long_name);
203 static int perf_event__inject_buildid(struct perf_tool *tool,
204 union perf_event *event,
205 struct perf_sample *sample,
206 struct perf_evsel *evsel __maybe_unused,
207 struct machine *machine)
209 struct addr_location al;
210 struct thread *thread;
213 cpumode = event->header.misc & PERF_RECORD_MISC_CPUMODE_MASK;
215 thread = machine__findnew_thread(machine, sample->pid, sample->pid);
216 if (thread == NULL) {
217 pr_err("problem processing %d event, skipping it.\n",
222 thread__find_addr_map(thread, machine, cpumode, MAP__FUNCTION,
225 if (al.map != NULL) {
226 if (!al.map->dso->hit) {
227 al.map->dso->hit = 1;
228 if (map__load(al.map, NULL) >= 0) {
229 dso__inject_build_id(al.map->dso, tool, machine);
231 * If this fails, too bad, let the other side
232 * account this as unresolved.
235 #ifdef HAVE_LIBELF_SUPPORT
236 pr_warning("no symbols found in %s, maybe "
237 "install a debug package?\n",
238 al.map->dso->long_name);
245 perf_event__repipe(tool, event, sample, machine);
249 static int perf_inject__sched_process_exit(struct perf_tool *tool,
250 union perf_event *event __maybe_unused,
251 struct perf_sample *sample,
252 struct perf_evsel *evsel __maybe_unused,
253 struct machine *machine __maybe_unused)
255 struct perf_inject *inject = container_of(tool, struct perf_inject, tool);
256 struct event_entry *ent;
258 list_for_each_entry(ent, &inject->samples, node) {
259 if (sample->tid == ent->tid) {
260 list_del_init(&ent->node);
269 static int perf_inject__sched_switch(struct perf_tool *tool,
270 union perf_event *event,
271 struct perf_sample *sample,
272 struct perf_evsel *evsel,
273 struct machine *machine)
275 struct perf_inject *inject = container_of(tool, struct perf_inject, tool);
276 struct event_entry *ent;
278 perf_inject__sched_process_exit(tool, event, sample, evsel, machine);
280 ent = malloc(event->header.size + sizeof(struct event_entry));
282 color_fprintf(stderr, PERF_COLOR_RED,
283 "Not enough memory to process sched switch event!");
287 ent->tid = sample->tid;
288 memcpy(&ent->event, event, event->header.size);
289 list_add(&ent->node, &inject->samples);
293 static int perf_inject__sched_stat(struct perf_tool *tool,
294 union perf_event *event __maybe_unused,
295 struct perf_sample *sample,
296 struct perf_evsel *evsel,
297 struct machine *machine)
299 struct event_entry *ent;
300 union perf_event *event_sw;
301 struct perf_sample sample_sw;
302 struct perf_inject *inject = container_of(tool, struct perf_inject, tool);
303 u32 pid = perf_evsel__intval(evsel, sample, "pid");
305 list_for_each_entry(ent, &inject->samples, node) {
312 event_sw = &ent->event[0];
313 perf_evsel__parse_sample(evsel, event_sw, &sample_sw);
315 sample_sw.period = sample->period;
316 sample_sw.time = sample->time;
317 perf_event__synthesize_sample(event_sw, evsel->attr.sample_type,
318 evsel->attr.sample_regs_user,
319 evsel->attr.read_format, &sample_sw,
321 build_id__mark_dso_hit(tool, event_sw, &sample_sw, evsel, machine);
322 return perf_event__repipe(tool, event_sw, &sample_sw, machine);
325 static void sig_handler(int sig __maybe_unused)
330 static int perf_evsel__check_stype(struct perf_evsel *evsel,
331 u64 sample_type, const char *sample_msg)
333 struct perf_event_attr *attr = &evsel->attr;
334 const char *name = perf_evsel__name(evsel);
336 if (!(attr->sample_type & sample_type)) {
337 pr_err("Samples for %s event do not have %s attribute set.",
345 static int __cmd_inject(struct perf_inject *inject)
347 struct perf_session *session;
349 struct perf_data_file file = {
350 .path = inject->input_name,
351 .mode = PERF_DATA_MODE_READ,
354 signal(SIGINT, sig_handler);
356 if (inject->build_ids || inject->sched_stat) {
357 inject->tool.mmap = perf_event__repipe_mmap;
358 inject->tool.mmap2 = perf_event__repipe_mmap2;
359 inject->tool.fork = perf_event__repipe_fork;
360 inject->tool.tracing_data = perf_event__repipe_tracing_data;
363 session = perf_session__new(&file, true, &inject->tool);
367 if (inject->build_ids) {
368 inject->tool.sample = perf_event__inject_buildid;
369 } else if (inject->sched_stat) {
370 struct perf_evsel *evsel;
372 inject->tool.ordered_samples = true;
374 list_for_each_entry(evsel, &session->evlist->entries, node) {
375 const char *name = perf_evsel__name(evsel);
377 if (!strcmp(name, "sched:sched_switch")) {
378 if (perf_evsel__check_stype(evsel, PERF_SAMPLE_TID, "TID"))
381 evsel->handler.func = perf_inject__sched_switch;
382 } else if (!strcmp(name, "sched:sched_process_exit"))
383 evsel->handler.func = perf_inject__sched_process_exit;
384 else if (!strncmp(name, "sched:sched_stat_", 17))
385 evsel->handler.func = perf_inject__sched_stat;
389 if (!inject->pipe_output)
390 lseek(inject->output, session->header.data_offset, SEEK_SET);
392 ret = perf_session__process_events(session, &inject->tool);
394 if (!inject->pipe_output) {
395 session->header.data_size = inject->bytes_written;
396 perf_session__write_header(session, session->evlist, inject->output, true);
399 perf_session__delete(session);
404 int cmd_inject(int argc, const char **argv, const char *prefix __maybe_unused)
406 struct perf_inject inject = {
408 .sample = perf_event__repipe_sample,
409 .mmap = perf_event__repipe,
410 .mmap2 = perf_event__repipe,
411 .comm = perf_event__repipe,
412 .fork = perf_event__repipe,
413 .exit = perf_event__repipe,
414 .lost = perf_event__repipe,
415 .read = perf_event__repipe_sample,
416 .throttle = perf_event__repipe,
417 .unthrottle = perf_event__repipe,
418 .attr = perf_event__repipe_attr,
419 .tracing_data = perf_event__repipe_op2_synth,
420 .finished_round = perf_event__repipe_op2_synth,
421 .build_id = perf_event__repipe_op2_synth,
424 .samples = LIST_HEAD_INIT(inject.samples),
426 const char *output_name = "-";
427 const struct option options[] = {
428 OPT_BOOLEAN('b', "build-ids", &inject.build_ids,
429 "Inject build-ids into the output stream"),
430 OPT_STRING('i', "input", &inject.input_name, "file",
432 OPT_STRING('o', "output", &output_name, "file",
434 OPT_BOOLEAN('s', "sched-stat", &inject.sched_stat,
435 "Merge sched-stat and sched-switch for getting events "
436 "where and how long tasks slept"),
437 OPT_INCR('v', "verbose", &verbose,
438 "be more verbose (show build ids, etc)"),
441 const char * const inject_usage[] = {
442 "perf inject [<options>]",
446 argc = parse_options(argc, argv, options, inject_usage, 0);
449 * Any (unrecognized) arguments left?
452 usage_with_options(inject_usage, options);
454 if (!strcmp(output_name, "-")) {
455 inject.pipe_output = 1;
456 inject.output = STDOUT_FILENO;
458 inject.output = open(output_name, O_CREAT | O_WRONLY | O_TRUNC,
460 if (inject.output < 0) {
461 perror("failed to create output file");
466 if (symbol__init() < 0)
469 return __cmd_inject(&inject);