perf kvm stat report: Unify the title bar output
[deliverable/linux.git] / tools / perf / builtin-inject.c
CommitLineData
454c407e
TZ
1/*
2 * builtin-inject.c
3 *
4 * Builtin inject command: Examine the live mode (stdin) event stream
5 * and repipe it to stdout while optionally injecting additional
6 * events into it.
7 */
8#include "builtin.h"
9
10#include "perf.h"
26a031e1
AV
11#include "util/color.h"
12#include "util/evlist.h"
13#include "util/evsel.h"
454c407e 14#include "util/session.h"
45694aa7 15#include "util/tool.h"
454c407e 16#include "util/debug.h"
54a3cf59 17#include "util/build-id.h"
f5fc1412 18#include "util/data.h"
454c407e
TZ
19
20#include "util/parse-options.h"
21
26a031e1
AV
22#include <linux/list.h>
23
5ded57ac 24struct perf_inject {
3406912c 25 struct perf_tool tool;
1cb8bdcc 26 struct perf_session *session;
3406912c
JO
27 bool build_ids;
28 bool sched_stat;
29 const char *input_name;
30 struct perf_data_file output;
31 u64 bytes_written;
32 struct list_head samples;
26a031e1
AV
33};
34
35struct event_entry {
36 struct list_head node;
37 u32 tid;
38 union perf_event event[0];
5ded57ac 39};
454c407e 40
e558a5bd 41static int perf_event__repipe_synth(struct perf_tool *tool,
63c2c9f8 42 union perf_event *event)
454c407e 43{
e558a5bd 44 struct perf_inject *inject = container_of(tool, struct perf_inject, tool);
3406912c 45 ssize_t size;
454c407e 46
3406912c
JO
47 size = perf_data_file__write(&inject->output, event,
48 event->header.size);
49 if (size < 0)
50 return -errno;
454c407e 51
3406912c 52 inject->bytes_written += size;
454c407e
TZ
53 return 0;
54}
55
45694aa7 56static int perf_event__repipe_op2_synth(struct perf_tool *tool,
743eb868 57 union perf_event *event,
1d037ca1
IT
58 struct perf_session *session
59 __maybe_unused)
743eb868 60{
63c2c9f8 61 return perf_event__repipe_synth(tool, event);
743eb868
ACM
62}
63
47c3d109
AH
64static int perf_event__repipe_attr(struct perf_tool *tool,
65 union perf_event *event,
66 struct perf_evlist **pevlist)
10d0f086 67{
89c97d93
AH
68 struct perf_inject *inject = container_of(tool, struct perf_inject,
69 tool);
1a1ed1ba 70 int ret;
47c3d109
AH
71
72 ret = perf_event__process_attr(tool, event, pevlist);
1a1ed1ba
SE
73 if (ret)
74 return ret;
75
a261e4a0 76 if (!inject->output.is_pipe)
89c97d93
AH
77 return 0;
78
47c3d109 79 return perf_event__repipe_synth(tool, event);
10d0f086
ACM
80}
81
45694aa7 82static int perf_event__repipe(struct perf_tool *tool,
d20deb64 83 union perf_event *event,
1d037ca1 84 struct perf_sample *sample __maybe_unused,
63c2c9f8 85 struct machine *machine __maybe_unused)
640c03ce 86{
63c2c9f8 87 return perf_event__repipe_synth(tool, event);
640c03ce
ACM
88}
89
26a031e1
AV
90typedef int (*inject_handler)(struct perf_tool *tool,
91 union perf_event *event,
92 struct perf_sample *sample,
93 struct perf_evsel *evsel,
94 struct machine *machine);
95
45694aa7 96static int perf_event__repipe_sample(struct perf_tool *tool,
d20deb64 97 union perf_event *event,
26a031e1
AV
98 struct perf_sample *sample,
99 struct perf_evsel *evsel,
100 struct machine *machine)
9e69c210 101{
744a9719
ACM
102 if (evsel->handler) {
103 inject_handler f = evsel->handler;
26a031e1
AV
104 return f(tool, event, sample, evsel, machine);
105 }
106
54a3cf59
AV
107 build_id__mark_dso_hit(tool, event, sample, evsel, machine);
108
63c2c9f8 109 return perf_event__repipe_synth(tool, event);
9e69c210
ACM
110}
111
45694aa7 112static int perf_event__repipe_mmap(struct perf_tool *tool,
d20deb64 113 union perf_event *event,
8115d60c 114 struct perf_sample *sample,
743eb868 115 struct machine *machine)
454c407e
TZ
116{
117 int err;
118
45694aa7
ACM
119 err = perf_event__process_mmap(tool, event, sample, machine);
120 perf_event__repipe(tool, event, sample, machine);
454c407e
TZ
121
122 return err;
123}
124
5c5e854b
SE
125static int perf_event__repipe_mmap2(struct perf_tool *tool,
126 union perf_event *event,
127 struct perf_sample *sample,
128 struct machine *machine)
129{
130 int err;
131
132 err = perf_event__process_mmap2(tool, event, sample, machine);
133 perf_event__repipe(tool, event, sample, machine);
134
135 return err;
136}
137
f62d3f0f 138static int perf_event__repipe_fork(struct perf_tool *tool,
d20deb64 139 union perf_event *event,
8115d60c 140 struct perf_sample *sample,
743eb868 141 struct machine *machine)
454c407e
TZ
142{
143 int err;
144
f62d3f0f 145 err = perf_event__process_fork(tool, event, sample, machine);
45694aa7 146 perf_event__repipe(tool, event, sample, machine);
454c407e
TZ
147
148 return err;
149}
150
47c3d109
AH
151static int perf_event__repipe_tracing_data(struct perf_tool *tool,
152 union perf_event *event,
8115d60c 153 struct perf_session *session)
454c407e
TZ
154{
155 int err;
156
47c3d109
AH
157 perf_event__repipe_synth(tool, event);
158 err = perf_event__process_tracing_data(tool, event, session);
454c407e
TZ
159
160 return err;
161}
162
c824c433 163static int dso__read_build_id(struct dso *dso)
454c407e 164{
c824c433 165 if (dso->has_build_id)
090f7204 166 return 0;
454c407e 167
c824c433
ACM
168 if (filename__read_build_id(dso->long_name, dso->build_id,
169 sizeof(dso->build_id)) > 0) {
170 dso->has_build_id = true;
090f7204
ACM
171 return 0;
172 }
454c407e 173
090f7204
ACM
174 return -1;
175}
454c407e 176
c824c433 177static int dso__inject_build_id(struct dso *dso, struct perf_tool *tool,
743eb868 178 struct machine *machine)
090f7204
ACM
179{
180 u16 misc = PERF_RECORD_MISC_USER;
090f7204 181 int err;
454c407e 182
c824c433
ACM
183 if (dso__read_build_id(dso) < 0) {
184 pr_debug("no build_id found for %s\n", dso->long_name);
090f7204
ACM
185 return -1;
186 }
454c407e 187
c824c433 188 if (dso->kernel)
090f7204 189 misc = PERF_RECORD_MISC_KERNEL;
454c407e 190
c824c433 191 err = perf_event__synthesize_build_id(tool, dso, misc, perf_event__repipe,
743eb868 192 machine);
090f7204 193 if (err) {
c824c433 194 pr_err("Can't synthesize build_id event for %s\n", dso->long_name);
454c407e
TZ
195 return -1;
196 }
197
198 return 0;
199}
200
45694aa7 201static int perf_event__inject_buildid(struct perf_tool *tool,
d20deb64 202 union perf_event *event,
8115d60c 203 struct perf_sample *sample,
1d037ca1 204 struct perf_evsel *evsel __maybe_unused,
743eb868 205 struct machine *machine)
454c407e
TZ
206{
207 struct addr_location al;
208 struct thread *thread;
209 u8 cpumode;
454c407e
TZ
210
211 cpumode = event->header.misc & PERF_RECORD_MISC_CPUMODE_MASK;
212
13ce34df 213 thread = machine__findnew_thread(machine, sample->pid, sample->tid);
454c407e
TZ
214 if (thread == NULL) {
215 pr_err("problem processing %d event, skipping it.\n",
216 event->header.type);
454c407e
TZ
217 goto repipe;
218 }
219
743eb868 220 thread__find_addr_map(thread, machine, cpumode, MAP__FUNCTION,
ef89325f 221 sample->ip, &al);
454c407e
TZ
222
223 if (al.map != NULL) {
224 if (!al.map->dso->hit) {
225 al.map->dso->hit = 1;
090f7204 226 if (map__load(al.map, NULL) >= 0) {
45694aa7 227 dso__inject_build_id(al.map->dso, tool, machine);
090f7204
ACM
228 /*
229 * If this fails, too bad, let the other side
230 * account this as unresolved.
231 */
393be2e3 232 } else {
89fe808a 233#ifdef HAVE_LIBELF_SUPPORT
454c407e
TZ
234 pr_warning("no symbols found in %s, maybe "
235 "install a debug package?\n",
236 al.map->dso->long_name);
393be2e3
NK
237#endif
238 }
454c407e
TZ
239 }
240 }
241
242repipe:
45694aa7 243 perf_event__repipe(tool, event, sample, machine);
090f7204 244 return 0;
454c407e
TZ
245}
246
26a031e1
AV
247static int perf_inject__sched_process_exit(struct perf_tool *tool,
248 union perf_event *event __maybe_unused,
249 struct perf_sample *sample,
250 struct perf_evsel *evsel __maybe_unused,
251 struct machine *machine __maybe_unused)
252{
253 struct perf_inject *inject = container_of(tool, struct perf_inject, tool);
254 struct event_entry *ent;
255
256 list_for_each_entry(ent, &inject->samples, node) {
257 if (sample->tid == ent->tid) {
258 list_del_init(&ent->node);
259 free(ent);
260 break;
261 }
262 }
263
264 return 0;
265}
266
267static int perf_inject__sched_switch(struct perf_tool *tool,
268 union perf_event *event,
269 struct perf_sample *sample,
270 struct perf_evsel *evsel,
271 struct machine *machine)
272{
273 struct perf_inject *inject = container_of(tool, struct perf_inject, tool);
274 struct event_entry *ent;
275
276 perf_inject__sched_process_exit(tool, event, sample, evsel, machine);
277
278 ent = malloc(event->header.size + sizeof(struct event_entry));
279 if (ent == NULL) {
280 color_fprintf(stderr, PERF_COLOR_RED,
281 "Not enough memory to process sched switch event!");
282 return -1;
283 }
284
285 ent->tid = sample->tid;
286 memcpy(&ent->event, event, event->header.size);
287 list_add(&ent->node, &inject->samples);
288 return 0;
289}
290
291static int perf_inject__sched_stat(struct perf_tool *tool,
292 union perf_event *event __maybe_unused,
293 struct perf_sample *sample,
294 struct perf_evsel *evsel,
295 struct machine *machine)
296{
297 struct event_entry *ent;
298 union perf_event *event_sw;
299 struct perf_sample sample_sw;
300 struct perf_inject *inject = container_of(tool, struct perf_inject, tool);
301 u32 pid = perf_evsel__intval(evsel, sample, "pid");
302
303 list_for_each_entry(ent, &inject->samples, node) {
304 if (pid == ent->tid)
305 goto found;
306 }
307
308 return 0;
309found:
310 event_sw = &ent->event[0];
311 perf_evsel__parse_sample(evsel, event_sw, &sample_sw);
312
313 sample_sw.period = sample->period;
314 sample_sw.time = sample->time;
315 perf_event__synthesize_sample(event_sw, evsel->attr.sample_type,
d03f2170
AH
316 evsel->attr.read_format, &sample_sw,
317 false);
54a3cf59 318 build_id__mark_dso_hit(tool, event_sw, &sample_sw, evsel, machine);
26a031e1
AV
319 return perf_event__repipe(tool, event_sw, &sample_sw, machine);
320}
321
1d037ca1 322static void sig_handler(int sig __maybe_unused)
454c407e
TZ
323{
324 session_done = 1;
325}
326
26a031e1
AV
327static int perf_evsel__check_stype(struct perf_evsel *evsel,
328 u64 sample_type, const char *sample_msg)
329{
330 struct perf_event_attr *attr = &evsel->attr;
331 const char *name = perf_evsel__name(evsel);
332
333 if (!(attr->sample_type & sample_type)) {
334 pr_err("Samples for %s event do not have %s attribute set.",
335 name, sample_msg);
336 return -EINVAL;
337 }
338
339 return 0;
340}
341
5ded57ac 342static int __cmd_inject(struct perf_inject *inject)
454c407e 343{
454c407e 344 int ret = -EINVAL;
1cb8bdcc 345 struct perf_session *session = inject->session;
3406912c 346 struct perf_data_file *file_out = &inject->output;
454c407e
TZ
347
348 signal(SIGINT, sig_handler);
349
54a3cf59 350 if (inject->build_ids || inject->sched_stat) {
5ded57ac 351 inject->tool.mmap = perf_event__repipe_mmap;
5c5e854b 352 inject->tool.mmap2 = perf_event__repipe_mmap2;
f62d3f0f 353 inject->tool.fork = perf_event__repipe_fork;
5ded57ac 354 inject->tool.tracing_data = perf_event__repipe_tracing_data;
454c407e
TZ
355 }
356
54a3cf59
AV
357 if (inject->build_ids) {
358 inject->tool.sample = perf_event__inject_buildid;
359 } else if (inject->sched_stat) {
26a031e1
AV
360 struct perf_evsel *evsel;
361
0a8cb85c 362 inject->tool.ordered_events = true;
26a031e1 363
0050f7aa 364 evlist__for_each(session->evlist, evsel) {
26a031e1
AV
365 const char *name = perf_evsel__name(evsel);
366
367 if (!strcmp(name, "sched:sched_switch")) {
368 if (perf_evsel__check_stype(evsel, PERF_SAMPLE_TID, "TID"))
369 return -EINVAL;
370
744a9719 371 evsel->handler = perf_inject__sched_switch;
26a031e1 372 } else if (!strcmp(name, "sched:sched_process_exit"))
744a9719 373 evsel->handler = perf_inject__sched_process_exit;
26a031e1 374 else if (!strncmp(name, "sched:sched_stat_", 17))
744a9719 375 evsel->handler = perf_inject__sched_stat;
26a031e1
AV
376 }
377 }
378
3406912c
JO
379 if (!file_out->is_pipe)
380 lseek(file_out->fd, session->header.data_offset, SEEK_SET);
e558a5bd 381
5ded57ac 382 ret = perf_session__process_events(session, &inject->tool);
454c407e 383
3406912c 384 if (!file_out->is_pipe) {
e38b43c3
AH
385 if (inject->build_ids)
386 perf_header__set_feat(&session->header,
387 HEADER_BUILD_ID);
e558a5bd 388 session->header.data_size = inject->bytes_written;
3406912c 389 perf_session__write_header(session, session->evlist, file_out->fd, true);
e558a5bd
AV
390 }
391
454c407e
TZ
392 return ret;
393}
394
1d037ca1 395int cmd_inject(int argc, const char **argv, const char *prefix __maybe_unused)
454c407e 396{
5ded57ac
ACM
397 struct perf_inject inject = {
398 .tool = {
399 .sample = perf_event__repipe_sample,
400 .mmap = perf_event__repipe,
5c5e854b 401 .mmap2 = perf_event__repipe,
5ded57ac
ACM
402 .comm = perf_event__repipe,
403 .fork = perf_event__repipe,
404 .exit = perf_event__repipe,
405 .lost = perf_event__repipe,
406 .read = perf_event__repipe_sample,
407 .throttle = perf_event__repipe,
408 .unthrottle = perf_event__repipe,
409 .attr = perf_event__repipe_attr,
47c3d109 410 .tracing_data = perf_event__repipe_op2_synth,
a609bda7 411 .finished_round = perf_event__repipe_op2_synth,
5ded57ac
ACM
412 .build_id = perf_event__repipe_op2_synth,
413 },
e558a5bd 414 .input_name = "-",
26a031e1 415 .samples = LIST_HEAD_INIT(inject.samples),
3406912c
JO
416 .output = {
417 .path = "-",
418 .mode = PERF_DATA_MODE_WRITE,
419 },
5ded57ac 420 };
1cb8bdcc
NK
421 struct perf_data_file file = {
422 .mode = PERF_DATA_MODE_READ,
423 };
424 int ret;
425
5ded57ac
ACM
426 const struct option options[] = {
427 OPT_BOOLEAN('b', "build-ids", &inject.build_ids,
428 "Inject build-ids into the output stream"),
e558a5bd
AV
429 OPT_STRING('i', "input", &inject.input_name, "file",
430 "input file name"),
3406912c 431 OPT_STRING('o', "output", &inject.output.path, "file",
e558a5bd 432 "output file name"),
26a031e1
AV
433 OPT_BOOLEAN('s', "sched-stat", &inject.sched_stat,
434 "Merge sched-stat and sched-switch for getting events "
435 "where and how long tasks slept"),
5ded57ac
ACM
436 OPT_INCR('v', "verbose", &verbose,
437 "be more verbose (show build ids, etc)"),
a7a2b8b4
AH
438 OPT_STRING(0, "kallsyms", &symbol_conf.kallsyms_name, "file",
439 "kallsyms pathname"),
5ded57ac
ACM
440 OPT_END()
441 };
002439e8
ACM
442 const char * const inject_usage[] = {
443 "perf inject [<options>]",
444 NULL
445 };
5ded57ac 446
002439e8 447 argc = parse_options(argc, argv, options, inject_usage, 0);
454c407e
TZ
448
449 /*
450 * Any (unrecognized) arguments left?
451 */
452 if (argc)
002439e8 453 usage_with_options(inject_usage, options);
454c407e 454
3406912c
JO
455 if (perf_data_file__open(&inject.output)) {
456 perror("failed to create output file");
457 return -1;
e558a5bd
AV
458 }
459
1cb8bdcc
NK
460 file.path = inject.input_name;
461 inject.session = perf_session__new(&file, true, &inject.tool);
462 if (inject.session == NULL)
463 return -ENOMEM;
464
0a7e6d1b 465 if (symbol__init(&inject.session->header.env) < 0)
454c407e
TZ
466 return -1;
467
1cb8bdcc
NK
468 ret = __cmd_inject(&inject);
469
470 perf_session__delete(inject.session);
471
472 return ret;
454c407e 473}
This page took 0.223786 seconds and 5 git commands to generate.