builtin-inject.c 22.5 KB
Newer Older
T
Tom Zanussi 已提交
1 2 3 4 5 6 7 8 9 10
/*
 * builtin-inject.c
 *
 * Builtin inject command: Examine the live mode (stdin) event stream
 * and repipe it to stdout while optionally injecting additional
 * events into it.
 */
#include "builtin.h"

#include "perf.h"
11 12 13
#include "util/color.h"
#include "util/evlist.h"
#include "util/evsel.h"
T
Tom Zanussi 已提交
14
#include "util/session.h"
15
#include "util/tool.h"
T
Tom Zanussi 已提交
16
#include "util/debug.h"
17
#include "util/build-id.h"
18
#include "util/data.h"
19
#include "util/auxtrace.h"
20
#include "util/jit.h"
T
Tom Zanussi 已提交
21

22
#include <subcmd/parse-options.h>
T
Tom Zanussi 已提交
23

24 25
#include <linux/list.h>

26
struct perf_inject {
27
	struct perf_tool	tool;
28
	struct perf_session	*session;
29 30
	bool			build_ids;
	bool			sched_stat;
31
	bool			have_auxtrace;
32
	bool			strip;
33
	bool			jit_mode;
34 35 36
	const char		*input_name;
	struct perf_data_file	output;
	u64			bytes_written;
37
	u64			aux_id;
38
	struct list_head	samples;
39
	struct itrace_synth_opts itrace_synth_opts;
40 41 42 43 44 45
};

struct event_entry {
	struct list_head node;
	u32		 tid;
	union perf_event event[0];
46
};
T
Tom Zanussi 已提交
47

48
static int output_bytes(struct perf_inject *inject, void *buf, size_t sz)
T
Tom Zanussi 已提交
49
{
50
	ssize_t size;
T
Tom Zanussi 已提交
51

52
	size = perf_data_file__write(&inject->output, buf, sz);
53 54
	if (size < 0)
		return -errno;
T
Tom Zanussi 已提交
55

56
	inject->bytes_written += size;
T
Tom Zanussi 已提交
57 58 59
	return 0;
}

60 61 62 63 64 65 66 67 68
static int perf_event__repipe_synth(struct perf_tool *tool,
				    union perf_event *event)
{
	struct perf_inject *inject = container_of(tool, struct perf_inject,
						  tool);

	return output_bytes(inject, event, event->header.size);
}

69 70 71 72 73 74 75
static int perf_event__repipe_oe_synth(struct perf_tool *tool,
				       union perf_event *event,
				       struct ordered_events *oe __maybe_unused)
{
	return perf_event__repipe_synth(tool, event);
}

76
#ifdef HAVE_JITDUMP
77 78 79 80 81 82 83 84
static int perf_event__drop_oe(struct perf_tool *tool __maybe_unused,
			       union perf_event *event __maybe_unused,
			       struct ordered_events *oe __maybe_unused)
{
	return 0;
}
#endif

85
static int perf_event__repipe_op2_synth(struct perf_tool *tool,
86
					union perf_event *event,
87 88
					struct perf_session *session
					__maybe_unused)
89
{
90
	return perf_event__repipe_synth(tool, event);
91 92
}

93 94 95
static int perf_event__repipe_attr(struct perf_tool *tool,
				   union perf_event *event,
				   struct perf_evlist **pevlist)
96
{
97 98
	struct perf_inject *inject = container_of(tool, struct perf_inject,
						  tool);
99
	int ret;
100 101

	ret = perf_event__process_attr(tool, event, pevlist);
102 103 104
	if (ret)
		return ret;

105
	if (!inject->output.is_pipe)
106 107
		return 0;

108
	return perf_event__repipe_synth(tool, event);
109 110
}

111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131
#ifdef HAVE_AUXTRACE_SUPPORT

static int copy_bytes(struct perf_inject *inject, int fd, off_t size)
{
	char buf[4096];
	ssize_t ssz;
	int ret;

	while (size > 0) {
		ssz = read(fd, buf, min(size, (off_t)sizeof(buf)));
		if (ssz < 0)
			return -errno;
		ret = output_bytes(inject, buf, ssz);
		if (ret)
			return ret;
		size -= ssz;
	}

	return 0;
}

132 133
static s64 perf_event__repipe_auxtrace(struct perf_tool *tool,
				       union perf_event *event,
134
				       struct perf_session *session)
135 136 137 138 139
{
	struct perf_inject *inject = container_of(tool, struct perf_inject,
						  tool);
	int ret;

140 141
	inject->have_auxtrace = true;

142 143 144 145 146 147 148 149 150 151 152 153
	if (!inject->output.is_pipe) {
		off_t offset;

		offset = lseek(inject->output.fd, 0, SEEK_CUR);
		if (offset == -1)
			return -errno;
		ret = auxtrace_index__auxtrace_event(&session->auxtrace_index,
						     event, offset);
		if (ret < 0)
			return ret;
	}

154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169
	if (perf_data_file__is_pipe(session->file) || !session->one_mmap) {
		ret = output_bytes(inject, event, event->header.size);
		if (ret < 0)
			return ret;
		ret = copy_bytes(inject, perf_data_file__fd(session->file),
				 event->auxtrace.size);
	} else {
		ret = output_bytes(inject, event,
				   event->header.size + event->auxtrace.size);
	}
	if (ret < 0)
		return ret;

	return event->auxtrace.size;
}

170 171 172 173 174 175 176 177 178 179 180 181 182
#else

static s64
perf_event__repipe_auxtrace(struct perf_tool *tool __maybe_unused,
			    union perf_event *event __maybe_unused,
			    struct perf_session *session __maybe_unused)
{
	pr_err("AUX area tracing not supported\n");
	return -EINVAL;
}

#endif

183
static int perf_event__repipe(struct perf_tool *tool,
184
			      union perf_event *event,
185
			      struct perf_sample *sample __maybe_unused,
186
			      struct machine *machine __maybe_unused)
187
{
188
	return perf_event__repipe_synth(tool, event);
189 190
}

191 192 193 194 195 196 197 198
static int perf_event__drop(struct perf_tool *tool __maybe_unused,
			    union perf_event *event __maybe_unused,
			    struct perf_sample *sample __maybe_unused,
			    struct machine *machine __maybe_unused)
{
	return 0;
}

199 200 201 202 203 204 205 206 207 208 209 210 211
static int perf_event__drop_aux(struct perf_tool *tool,
				union perf_event *event __maybe_unused,
				struct perf_sample *sample,
				struct machine *machine __maybe_unused)
{
	struct perf_inject *inject = container_of(tool, struct perf_inject, tool);

	if (!inject->aux_id)
		inject->aux_id = sample->id;

	return 0;
}

212 213 214 215 216 217
typedef int (*inject_handler)(struct perf_tool *tool,
			      union perf_event *event,
			      struct perf_sample *sample,
			      struct perf_evsel *evsel,
			      struct machine *machine);

218
static int perf_event__repipe_sample(struct perf_tool *tool,
219
				     union perf_event *event,
220 221 222
				     struct perf_sample *sample,
				     struct perf_evsel *evsel,
				     struct machine *machine)
223
{
224 225
	if (evsel->handler) {
		inject_handler f = evsel->handler;
226 227 228
		return f(tool, event, sample, evsel, machine);
	}

229 230
	build_id__mark_dso_hit(tool, event, sample, evsel, machine);

231
	return perf_event__repipe_synth(tool, event);
232 233
}

234
static int perf_event__repipe_mmap(struct perf_tool *tool,
235
				   union perf_event *event,
236
				   struct perf_sample *sample,
237
				   struct machine *machine)
T
Tom Zanussi 已提交
238 239 240
{
	int err;

241 242
	err = perf_event__process_mmap(tool, event, sample, machine);
	perf_event__repipe(tool, event, sample, machine);
T
Tom Zanussi 已提交
243 244 245 246

	return err;
}

247
#ifdef HAVE_JITDUMP
248 249 250 251 252 253 254
static int perf_event__jit_repipe_mmap(struct perf_tool *tool,
				       union perf_event *event,
				       struct perf_sample *sample,
				       struct machine *machine)
{
	struct perf_inject *inject = container_of(tool, struct perf_inject, tool);
	u64 n = 0;
255
	int ret;
256 257 258 259

	/*
	 * if jit marker, then inject jit mmaps and generate ELF images
	 */
260 261 262 263 264
	ret = jit_process(inject->session, &inject->output, machine,
			  event->mmap.filename, sample->pid, &n);
	if (ret < 0)
		return ret;
	if (ret) {
265 266 267 268 269 270 271
		inject->bytes_written += n;
		return 0;
	}
	return perf_event__repipe_mmap(tool, event, sample, machine);
}
#endif

272 273 274 275 276 277 278 279 280 281 282 283 284
static int perf_event__repipe_mmap2(struct perf_tool *tool,
				   union perf_event *event,
				   struct perf_sample *sample,
				   struct machine *machine)
{
	int err;

	err = perf_event__process_mmap2(tool, event, sample, machine);
	perf_event__repipe(tool, event, sample, machine);

	return err;
}

285
#ifdef HAVE_JITDUMP
286 287 288 289 290 291 292
static int perf_event__jit_repipe_mmap2(struct perf_tool *tool,
					union perf_event *event,
					struct perf_sample *sample,
					struct machine *machine)
{
	struct perf_inject *inject = container_of(tool, struct perf_inject, tool);
	u64 n = 0;
293
	int ret;
294 295 296 297

	/*
	 * if jit marker, then inject jit mmaps and generate ELF images
	 */
298 299 300 301 302
	ret = jit_process(inject->session, &inject->output, machine,
			  event->mmap2.filename, sample->pid, &n);
	if (ret < 0)
		return ret;
	if (ret) {
303 304 305 306 307 308 309
		inject->bytes_written += n;
		return 0;
	}
	return perf_event__repipe_mmap2(tool, event, sample, machine);
}
#endif

310
static int perf_event__repipe_fork(struct perf_tool *tool,
311
				   union perf_event *event,
312
				   struct perf_sample *sample,
313
				   struct machine *machine)
T
Tom Zanussi 已提交
314 315 316
{
	int err;

317
	err = perf_event__process_fork(tool, event, sample, machine);
318
	perf_event__repipe(tool, event, sample, machine);
T
Tom Zanussi 已提交
319 320 321 322

	return err;
}

323 324 325 326 327 328 329 330 331 332 333 334 335
static int perf_event__repipe_comm(struct perf_tool *tool,
				   union perf_event *event,
				   struct perf_sample *sample,
				   struct machine *machine)
{
	int err;

	err = perf_event__process_comm(tool, event, sample, machine);
	perf_event__repipe(tool, event, sample, machine);

	return err;
}

336 337 338 339 340 341 342 343 344 345 346 347
static int perf_event__repipe_namespaces(struct perf_tool *tool,
					 union perf_event *event,
					 struct perf_sample *sample,
					 struct machine *machine)
{
	int err = perf_event__process_namespaces(tool, event, sample, machine);

	perf_event__repipe(tool, event, sample, machine);

	return err;
}

348 349 350 351 352 353 354 355 356 357 358 359 360
static int perf_event__repipe_exit(struct perf_tool *tool,
				   union perf_event *event,
				   struct perf_sample *sample,
				   struct machine *machine)
{
	int err;

	err = perf_event__process_exit(tool, event, sample, machine);
	perf_event__repipe(tool, event, sample, machine);

	return err;
}

361 362
static int perf_event__repipe_tracing_data(struct perf_tool *tool,
					   union perf_event *event,
363
					   struct perf_session *session)
T
Tom Zanussi 已提交
364 365 366
{
	int err;

367 368
	perf_event__repipe_synth(tool, event);
	err = perf_event__process_tracing_data(tool, event, session);
T
Tom Zanussi 已提交
369 370 371 372

	return err;
}

373 374 375 376 377 378 379 380 381 382 383 384
static int perf_event__repipe_id_index(struct perf_tool *tool,
				       union perf_event *event,
				       struct perf_session *session)
{
	int err;

	perf_event__repipe_synth(tool, event);
	err = perf_event__process_id_index(tool, event, session);

	return err;
}

385
static int dso__read_build_id(struct dso *dso)
T
Tom Zanussi 已提交
386
{
387
	if (dso->has_build_id)
388
		return 0;
T
Tom Zanussi 已提交
389

390 391 392
	if (filename__read_build_id(dso->long_name, dso->build_id,
				    sizeof(dso->build_id)) > 0) {
		dso->has_build_id = true;
393 394
		return 0;
	}
T
Tom Zanussi 已提交
395

396 397
	return -1;
}
T
Tom Zanussi 已提交
398

399
static int dso__inject_build_id(struct dso *dso, struct perf_tool *tool,
400
				struct machine *machine)
401 402 403
{
	u16 misc = PERF_RECORD_MISC_USER;
	int err;
T
Tom Zanussi 已提交
404

405 406
	if (dso__read_build_id(dso) < 0) {
		pr_debug("no build_id found for %s\n", dso->long_name);
407 408
		return -1;
	}
T
Tom Zanussi 已提交
409

410
	if (dso->kernel)
411
		misc = PERF_RECORD_MISC_KERNEL;
T
Tom Zanussi 已提交
412

413
	err = perf_event__synthesize_build_id(tool, dso, misc, perf_event__repipe,
414
					      machine);
415
	if (err) {
416
		pr_err("Can't synthesize build_id event for %s\n", dso->long_name);
T
Tom Zanussi 已提交
417 418 419 420 421 422
		return -1;
	}

	return 0;
}

423
static int perf_event__inject_buildid(struct perf_tool *tool,
424
				      union perf_event *event,
425
				      struct perf_sample *sample,
426
				      struct perf_evsel *evsel __maybe_unused,
427
				      struct machine *machine)
T
Tom Zanussi 已提交
428 429 430 431
{
	struct addr_location al;
	struct thread *thread;

432
	thread = machine__findnew_thread(machine, sample->pid, sample->tid);
T
Tom Zanussi 已提交
433 434 435 436 437 438
	if (thread == NULL) {
		pr_err("problem processing %d event, skipping it.\n",
		       event->header.type);
		goto repipe;
	}

439
	thread__find_addr_map(thread, sample->cpumode, MAP__FUNCTION, sample->ip, &al);
T
Tom Zanussi 已提交
440 441 442 443

	if (al.map != NULL) {
		if (!al.map->dso->hit) {
			al.map->dso->hit = 1;
444
			if (map__load(al.map) >= 0) {
445
				dso__inject_build_id(al.map->dso, tool, machine);
446 447 448 449
				/*
				 * If this fails, too bad, let the other side
				 * account this as unresolved.
				 */
450
			} else {
451
#ifdef HAVE_LIBELF_SUPPORT
T
Tom Zanussi 已提交
452 453 454
				pr_warning("no symbols found in %s, maybe "
					   "install a debug package?\n",
					   al.map->dso->long_name);
455 456
#endif
			}
T
Tom Zanussi 已提交
457 458 459
		}
	}

460
	thread__put(thread);
T
Tom Zanussi 已提交
461
repipe:
462
	perf_event__repipe(tool, event, sample, machine);
463
	return 0;
T
Tom Zanussi 已提交
464 465
}

466 467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494 495 496 497 498 499 500 501 502 503 504 505 506 507 508 509 510 511 512 513 514 515 516 517 518 519 520 521 522 523 524 525 526 527 528 529 530 531 532 533 534
static int perf_inject__sched_process_exit(struct perf_tool *tool,
					   union perf_event *event __maybe_unused,
					   struct perf_sample *sample,
					   struct perf_evsel *evsel __maybe_unused,
					   struct machine *machine __maybe_unused)
{
	struct perf_inject *inject = container_of(tool, struct perf_inject, tool);
	struct event_entry *ent;

	list_for_each_entry(ent, &inject->samples, node) {
		if (sample->tid == ent->tid) {
			list_del_init(&ent->node);
			free(ent);
			break;
		}
	}

	return 0;
}

static int perf_inject__sched_switch(struct perf_tool *tool,
				     union perf_event *event,
				     struct perf_sample *sample,
				     struct perf_evsel *evsel,
				     struct machine *machine)
{
	struct perf_inject *inject = container_of(tool, struct perf_inject, tool);
	struct event_entry *ent;

	perf_inject__sched_process_exit(tool, event, sample, evsel, machine);

	ent = malloc(event->header.size + sizeof(struct event_entry));
	if (ent == NULL) {
		color_fprintf(stderr, PERF_COLOR_RED,
			     "Not enough memory to process sched switch event!");
		return -1;
	}

	ent->tid = sample->tid;
	memcpy(&ent->event, event, event->header.size);
	list_add(&ent->node, &inject->samples);
	return 0;
}

static int perf_inject__sched_stat(struct perf_tool *tool,
				   union perf_event *event __maybe_unused,
				   struct perf_sample *sample,
				   struct perf_evsel *evsel,
				   struct machine *machine)
{
	struct event_entry *ent;
	union perf_event *event_sw;
	struct perf_sample sample_sw;
	struct perf_inject *inject = container_of(tool, struct perf_inject, tool);
	u32 pid = perf_evsel__intval(evsel, sample, "pid");

	list_for_each_entry(ent, &inject->samples, node) {
		if (pid == ent->tid)
			goto found;
	}

	return 0;
found:
	event_sw = &ent->event[0];
	perf_evsel__parse_sample(evsel, event_sw, &sample_sw);

	sample_sw.period = sample->period;
	sample_sw.time	 = sample->time;
	perf_event__synthesize_sample(event_sw, evsel->attr.sample_type,
535 536
				      evsel->attr.read_format, &sample_sw,
				      false);
537
	build_id__mark_dso_hit(tool, event_sw, &sample_sw, evsel, machine);
538 539 540
	return perf_event__repipe(tool, event_sw, &sample_sw, machine);
}

541
static void sig_handler(int sig __maybe_unused)
T
Tom Zanussi 已提交
542 543 544 545
{
	session_done = 1;
}

546 547 548 549 550 551 552 553 554 555 556 557 558 559 560
static int perf_evsel__check_stype(struct perf_evsel *evsel,
				   u64 sample_type, const char *sample_msg)
{
	struct perf_event_attr *attr = &evsel->attr;
	const char *name = perf_evsel__name(evsel);

	if (!(attr->sample_type & sample_type)) {
		pr_err("Samples for %s event do not have %s attribute set.",
			name, sample_msg);
		return -EINVAL;
	}

	return 0;
}

561 562 563 564 565 566 567 568 569 570 571 572 573 574 575 576
static int drop_sample(struct perf_tool *tool __maybe_unused,
		       union perf_event *event __maybe_unused,
		       struct perf_sample *sample __maybe_unused,
		       struct perf_evsel *evsel __maybe_unused,
		       struct machine *machine __maybe_unused)
{
	return 0;
}

static void strip_init(struct perf_inject *inject)
{
	struct perf_evlist *evlist = inject->session->evlist;
	struct perf_evsel *evsel;

	inject->tool.context_switch = perf_event__drop;

577
	evlist__for_each_entry(evlist, evsel)
578 579 580 581 582 583 584 585 586 587 588 589 590 591 592 593 594 595 596 597 598 599 600 601 602 603 604
		evsel->handler = drop_sample;
}

static bool has_tracking(struct perf_evsel *evsel)
{
	return evsel->attr.mmap || evsel->attr.mmap2 || evsel->attr.comm ||
	       evsel->attr.task;
}

#define COMPAT_MASK (PERF_SAMPLE_ID | PERF_SAMPLE_TID | PERF_SAMPLE_TIME | \
		     PERF_SAMPLE_ID | PERF_SAMPLE_CPU | PERF_SAMPLE_IDENTIFIER)

/*
 * In order that the perf.data file is parsable, tracking events like MMAP need
 * their selected event to exist, except if there is only 1 selected event left
 * and it has a compatible sample type.
 */
static bool ok_to_remove(struct perf_evlist *evlist,
			 struct perf_evsel *evsel_to_remove)
{
	struct perf_evsel *evsel;
	int cnt = 0;
	bool ok = false;

	if (!has_tracking(evsel_to_remove))
		return true;

605
	evlist__for_each_entry(evlist, evsel) {
606 607 608 609 610 611 612 613 614 615 616 617 618 619 620 621 622
		if (evsel->handler != drop_sample) {
			cnt += 1;
			if ((evsel->attr.sample_type & COMPAT_MASK) ==
			    (evsel_to_remove->attr.sample_type & COMPAT_MASK))
				ok = true;
		}
	}

	return ok && cnt == 1;
}

static void strip_fini(struct perf_inject *inject)
{
	struct perf_evlist *evlist = inject->session->evlist;
	struct perf_evsel *evsel, *tmp;

	/* Remove non-synthesized evsels if possible */
623
	evlist__for_each_entry_safe(evlist, tmp, evsel) {
624 625 626 627 628 629 630 631 632
		if (evsel->handler == drop_sample &&
		    ok_to_remove(evlist, evsel)) {
			pr_debug("Deleting %s\n", perf_evsel__name(evsel));
			perf_evlist__remove(evlist, evsel);
			perf_evsel__delete(evsel);
		}
	}
}

633
static int __cmd_inject(struct perf_inject *inject)
T
Tom Zanussi 已提交
634 635
{
	int ret = -EINVAL;
636
	struct perf_session *session = inject->session;
637
	struct perf_data_file *file_out = &inject->output;
638
	int fd = perf_data_file__fd(file_out);
639
	u64 output_data_offset;
T
Tom Zanussi 已提交
640 641 642

	signal(SIGINT, sig_handler);

643 644
	if (inject->build_ids || inject->sched_stat ||
	    inject->itrace_synth_opts.set) {
645
		inject->tool.mmap	  = perf_event__repipe_mmap;
646
		inject->tool.mmap2	  = perf_event__repipe_mmap2;
647
		inject->tool.fork	  = perf_event__repipe_fork;
648
		inject->tool.tracing_data = perf_event__repipe_tracing_data;
T
Tom Zanussi 已提交
649 650
	}

651 652
	output_data_offset = session->header.data_offset;

653 654 655
	if (inject->build_ids) {
		inject->tool.sample = perf_event__inject_buildid;
	} else if (inject->sched_stat) {
656 657
		struct perf_evsel *evsel;

658
		evlist__for_each_entry(session->evlist, evsel) {
659 660 661 662 663 664
			const char *name = perf_evsel__name(evsel);

			if (!strcmp(name, "sched:sched_switch")) {
				if (perf_evsel__check_stype(evsel, PERF_SAMPLE_TID, "TID"))
					return -EINVAL;

665
				evsel->handler = perf_inject__sched_switch;
666
			} else if (!strcmp(name, "sched:sched_process_exit"))
667
				evsel->handler = perf_inject__sched_process_exit;
668
			else if (!strncmp(name, "sched:sched_stat_", 17))
669
				evsel->handler = perf_inject__sched_stat;
670
		}
671 672 673 674
	} else if (inject->itrace_synth_opts.set) {
		session->itrace_synth_opts = &inject->itrace_synth_opts;
		inject->itrace_synth_opts.inject = true;
		inject->tool.comm	    = perf_event__repipe_comm;
675
		inject->tool.namespaces	    = perf_event__repipe_namespaces;
676 677 678 679
		inject->tool.exit	    = perf_event__repipe_exit;
		inject->tool.id_index	    = perf_event__repipe_id_index;
		inject->tool.auxtrace_info  = perf_event__process_auxtrace_info;
		inject->tool.auxtrace	    = perf_event__process_auxtrace;
680 681
		inject->tool.aux	    = perf_event__drop_aux;
		inject->tool.itrace_start   = perf_event__drop_aux,
682 683 684 685
		inject->tool.ordered_events = true;
		inject->tool.ordering_requires_timestamps = true;
		/* Allow space in the header for new attributes */
		output_data_offset = 4096;
686 687
		if (inject->strip)
			strip_init(inject);
688 689
	}

690 691 692
	if (!inject->itrace_synth_opts.set)
		auxtrace_index__free(&session->auxtrace_index);

693
	if (!file_out->is_pipe)
694
		lseek(fd, output_data_offset, SEEK_SET);
A
Andrew Vagin 已提交
695

696
	ret = perf_session__process_events(session);
697 698
	if (ret)
		return ret;
T
Tom Zanussi 已提交
699

700
	if (!file_out->is_pipe) {
701
		if (inject->build_ids)
702 703
			perf_header__set_feat(&session->header,
					      HEADER_BUILD_ID);
704 705 706 707 708 709 710
		/*
		 * Keep all buildids when there is unprocessed AUX data because
		 * it is not known which ones the AUX trace hits.
		 */
		if (perf_header__has_feat(&session->header, HEADER_BUILD_ID) &&
		    inject->have_auxtrace && !inject->itrace_synth_opts.set)
			dsos__hit_all(session);
711 712
		/*
		 * The AUX areas have been removed and replaced with
713 714
		 * synthesized hardware events, so clear the feature flag and
		 * remove the evsel.
715
		 */
716
		if (inject->itrace_synth_opts.set) {
717 718
			struct perf_evsel *evsel;

719 720
			perf_header__clear_feat(&session->header,
						HEADER_AUXTRACE);
721 722 723
			if (inject->itrace_synth_opts.last_branch)
				perf_header__set_feat(&session->header,
						      HEADER_BRANCH_STACK);
724 725 726 727 728 729 730 731
			evsel = perf_evlist__id2evsel_strict(session->evlist,
							     inject->aux_id);
			if (evsel) {
				pr_debug("Deleting %s\n",
					 perf_evsel__name(evsel));
				perf_evlist__remove(session->evlist, evsel);
				perf_evsel__delete(evsel);
			}
732 733
			if (inject->strip)
				strip_fini(inject);
734
		}
735
		session->header.data_offset = output_data_offset;
A
Andrew Vagin 已提交
736
		session->header.data_size = inject->bytes_written;
737
		perf_session__write_header(session, session->evlist, fd, true);
A
Andrew Vagin 已提交
738 739
	}

T
Tom Zanussi 已提交
740 741 742
	return ret;
}

743
int cmd_inject(int argc, const char **argv)
T
Tom Zanussi 已提交
744
{
745 746 747 748
	struct perf_inject inject = {
		.tool = {
			.sample		= perf_event__repipe_sample,
			.mmap		= perf_event__repipe,
749
			.mmap2		= perf_event__repipe,
750 751 752 753
			.comm		= perf_event__repipe,
			.fork		= perf_event__repipe,
			.exit		= perf_event__repipe,
			.lost		= perf_event__repipe,
754
			.lost_samples	= perf_event__repipe,
755
			.aux		= perf_event__repipe,
756
			.itrace_start	= perf_event__repipe,
757
			.context_switch	= perf_event__repipe,
758 759 760 761
			.read		= perf_event__repipe_sample,
			.throttle	= perf_event__repipe,
			.unthrottle	= perf_event__repipe,
			.attr		= perf_event__repipe_attr,
762
			.tracing_data	= perf_event__repipe_op2_synth,
763 764 765
			.auxtrace_info	= perf_event__repipe_op2_synth,
			.auxtrace	= perf_event__repipe_auxtrace,
			.auxtrace_error	= perf_event__repipe_op2_synth,
766
			.time_conv	= perf_event__repipe_op2_synth,
767
			.finished_round	= perf_event__repipe_oe_synth,
768
			.build_id	= perf_event__repipe_op2_synth,
A
Adrian Hunter 已提交
769
			.id_index	= perf_event__repipe_op2_synth,
770
		},
A
Andrew Vagin 已提交
771
		.input_name  = "-",
772
		.samples = LIST_HEAD_INIT(inject.samples),
773 774 775 776
		.output = {
			.path = "-",
			.mode = PERF_DATA_MODE_WRITE,
		},
777
	};
778 779 780 781 782
	struct perf_data_file file = {
		.mode = PERF_DATA_MODE_READ,
	};
	int ret;

783
	struct option options[] = {
784 785
		OPT_BOOLEAN('b', "build-ids", &inject.build_ids,
			    "Inject build-ids into the output stream"),
A
Andrew Vagin 已提交
786 787
		OPT_STRING('i', "input", &inject.input_name, "file",
			   "input file name"),
788
		OPT_STRING('o', "output", &inject.output.path, "file",
A
Andrew Vagin 已提交
789
			   "output file name"),
790 791 792
		OPT_BOOLEAN('s', "sched-stat", &inject.sched_stat,
			    "Merge sched-stat and sched-switch for getting events "
			    "where and how long tasks slept"),
793
#ifdef HAVE_JITDUMP
794
		OPT_BOOLEAN('j', "jit", &inject.jit_mode, "merge jitdump files into perf.data file"),
795
#endif
796 797
		OPT_INCR('v', "verbose", &verbose,
			 "be more verbose (show build ids, etc)"),
798 799
		OPT_STRING(0, "kallsyms", &symbol_conf.kallsyms_name, "file",
			   "kallsyms pathname"),
800
		OPT_BOOLEAN('f', "force", &file.force, "don't complain, do it"),
801 802 803
		OPT_CALLBACK_OPTARG(0, "itrace", &inject.itrace_synth_opts,
				    NULL, "opts", "Instruction Tracing options",
				    itrace_parse_synth_opts),
804 805
		OPT_BOOLEAN(0, "strip", &inject.strip,
			    "strip non-synthesized events (use with --itrace)"),
806 807
		OPT_END()
	};
808 809 810 811
	const char * const inject_usage[] = {
		"perf inject [<options>]",
		NULL
	};
812
#ifndef HAVE_JITDUMP
813 814
	set_option_nobuild(options, 'j', "jit", "NO_LIBELF=1", true);
#endif
815
	argc = parse_options(argc, argv, options, inject_usage, 0);
T
Tom Zanussi 已提交
816 817 818 819 820

	/*
	 * Any (unrecognized) arguments left?
	 */
	if (argc)
821
		usage_with_options(inject_usage, options);
T
Tom Zanussi 已提交
822

823 824 825 826 827
	if (inject.strip && !inject.itrace_synth_opts.set) {
		pr_err("--strip option requires --itrace option\n");
		return -1;
	}

828 829 830
	if (perf_data_file__open(&inject.output)) {
		perror("failed to create output file");
		return -1;
A
Andrew Vagin 已提交
831 832
	}

833 834
	inject.tool.ordered_events = inject.sched_stat;

835 836 837
	file.path = inject.input_name;
	inject.session = perf_session__new(&file, true, &inject.tool);
	if (inject.session == NULL)
838
		return -1;
839

840 841 842 843 844 845 846 847 848 849
	if (inject.build_ids) {
		/*
		 * to make sure the mmap records are ordered correctly
		 * and so that the correct especially due to jitted code
		 * mmaps. We cannot generate the buildid hit list and
		 * inject the jit mmaps at the same time for now.
		 */
		inject.tool.ordered_events = true;
		inject.tool.ordering_requires_timestamps = true;
	}
850
#ifdef HAVE_JITDUMP
851 852 853 854 855 856 857 858 859 860 861 862
	if (inject.jit_mode) {
		inject.tool.mmap2	   = perf_event__jit_repipe_mmap2;
		inject.tool.mmap	   = perf_event__jit_repipe_mmap;
		inject.tool.ordered_events = true;
		inject.tool.ordering_requires_timestamps = true;
		/*
		 * JIT MMAP injection injects all MMAP events in one go, so it
		 * does not obey finished_round semantics.
		 */
		inject.tool.finished_round = perf_event__drop_oe;
	}
#endif
863 864 865
	ret = symbol__init(&inject.session->header.env);
	if (ret < 0)
		goto out_delete;
T
Tom Zanussi 已提交
866

867 868
	ret = __cmd_inject(&inject);

869
out_delete:
870 871
	perf_session__delete(inject.session);
	return ret;
T
Tom Zanussi 已提交
872
}