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
*self
)
167 if (self
->has_build_id
)
170 if (filename__read_build_id(self
->long_name
, self
->build_id
,
171 sizeof(self
->build_id
)) > 0) {
172 self
->has_build_id
= true;
179 static int dso__inject_build_id(struct dso
*self
, struct perf_tool
*tool
,
180 struct machine
*machine
)
182 u16 misc
= PERF_RECORD_MISC_USER
;
185 if (dso__read_build_id(self
) < 0) {
186 pr_debug("no build_id found for %s\n", self
->long_name
);
191 misc
= PERF_RECORD_MISC_KERNEL
;
193 err
= perf_event__synthesize_build_id(tool
, self
, misc
, perf_event__repipe
,
196 pr_err("Can't synthesize build_id event for %s\n", self
->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
);