builtin-inject.c 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870
  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. #include "perf.h"
  10. #include "util/color.h"
  11. #include "util/evlist.h"
  12. #include "util/evsel.h"
  13. #include "util/session.h"
  14. #include "util/tool.h"
  15. #include "util/debug.h"
  16. #include "util/build-id.h"
  17. #include "util/data.h"
  18. #include "util/auxtrace.h"
  19. #include "util/jit.h"
  20. #include <subcmd/parse-options.h>
  21. #include <linux/list.h>
  22. struct perf_inject {
  23. struct perf_tool tool;
  24. struct perf_session *session;
  25. bool build_ids;
  26. bool sched_stat;
  27. bool have_auxtrace;
  28. bool strip;
  29. bool jit_mode;
  30. const char *input_name;
  31. struct perf_data_file output;
  32. u64 bytes_written;
  33. u64 aux_id;
  34. struct list_head samples;
  35. struct itrace_synth_opts itrace_synth_opts;
  36. };
  37. struct event_entry {
  38. struct list_head node;
  39. u32 tid;
  40. union perf_event event[0];
  41. };
  42. static int output_bytes(struct perf_inject *inject, void *buf, size_t sz)
  43. {
  44. ssize_t size;
  45. size = perf_data_file__write(&inject->output, buf, sz);
  46. if (size < 0)
  47. return -errno;
  48. inject->bytes_written += size;
  49. return 0;
  50. }
  51. static int perf_event__repipe_synth(struct perf_tool *tool,
  52. union perf_event *event)
  53. {
  54. struct perf_inject *inject = container_of(tool, struct perf_inject,
  55. tool);
  56. return output_bytes(inject, event, event->header.size);
  57. }
  58. static int perf_event__repipe_oe_synth(struct perf_tool *tool,
  59. union perf_event *event,
  60. struct ordered_events *oe __maybe_unused)
  61. {
  62. return perf_event__repipe_synth(tool, event);
  63. }
  64. #ifdef HAVE_LIBELF_SUPPORT
  65. static int perf_event__drop_oe(struct perf_tool *tool __maybe_unused,
  66. union perf_event *event __maybe_unused,
  67. struct ordered_events *oe __maybe_unused)
  68. {
  69. return 0;
  70. }
  71. #endif
  72. static int perf_event__repipe_op2_synth(struct perf_tool *tool,
  73. union perf_event *event,
  74. struct perf_session *session
  75. __maybe_unused)
  76. {
  77. return perf_event__repipe_synth(tool, event);
  78. }
  79. static int perf_event__repipe_attr(struct perf_tool *tool,
  80. union perf_event *event,
  81. struct perf_evlist **pevlist)
  82. {
  83. struct perf_inject *inject = container_of(tool, struct perf_inject,
  84. tool);
  85. int ret;
  86. ret = perf_event__process_attr(tool, event, pevlist);
  87. if (ret)
  88. return ret;
  89. if (!inject->output.is_pipe)
  90. return 0;
  91. return perf_event__repipe_synth(tool, event);
  92. }
  93. #ifdef HAVE_AUXTRACE_SUPPORT
  94. static int copy_bytes(struct perf_inject *inject, int fd, off_t size)
  95. {
  96. char buf[4096];
  97. ssize_t ssz;
  98. int ret;
  99. while (size > 0) {
  100. ssz = read(fd, buf, min(size, (off_t)sizeof(buf)));
  101. if (ssz < 0)
  102. return -errno;
  103. ret = output_bytes(inject, buf, ssz);
  104. if (ret)
  105. return ret;
  106. size -= ssz;
  107. }
  108. return 0;
  109. }
  110. static s64 perf_event__repipe_auxtrace(struct perf_tool *tool,
  111. union perf_event *event,
  112. struct perf_session *session
  113. __maybe_unused)
  114. {
  115. struct perf_inject *inject = container_of(tool, struct perf_inject,
  116. tool);
  117. int ret;
  118. inject->have_auxtrace = true;
  119. if (!inject->output.is_pipe) {
  120. off_t offset;
  121. offset = lseek(inject->output.fd, 0, SEEK_CUR);
  122. if (offset == -1)
  123. return -errno;
  124. ret = auxtrace_index__auxtrace_event(&session->auxtrace_index,
  125. event, offset);
  126. if (ret < 0)
  127. return ret;
  128. }
  129. if (perf_data_file__is_pipe(session->file) || !session->one_mmap) {
  130. ret = output_bytes(inject, event, event->header.size);
  131. if (ret < 0)
  132. return ret;
  133. ret = copy_bytes(inject, perf_data_file__fd(session->file),
  134. event->auxtrace.size);
  135. } else {
  136. ret = output_bytes(inject, event,
  137. event->header.size + event->auxtrace.size);
  138. }
  139. if (ret < 0)
  140. return ret;
  141. return event->auxtrace.size;
  142. }
  143. #else
  144. static s64
  145. perf_event__repipe_auxtrace(struct perf_tool *tool __maybe_unused,
  146. union perf_event *event __maybe_unused,
  147. struct perf_session *session __maybe_unused)
  148. {
  149. pr_err("AUX area tracing not supported\n");
  150. return -EINVAL;
  151. }
  152. #endif
  153. static int perf_event__repipe(struct perf_tool *tool,
  154. union perf_event *event,
  155. struct perf_sample *sample __maybe_unused,
  156. struct machine *machine __maybe_unused)
  157. {
  158. return perf_event__repipe_synth(tool, event);
  159. }
  160. static int perf_event__drop(struct perf_tool *tool __maybe_unused,
  161. union perf_event *event __maybe_unused,
  162. struct perf_sample *sample __maybe_unused,
  163. struct machine *machine __maybe_unused)
  164. {
  165. return 0;
  166. }
  167. static int perf_event__drop_aux(struct perf_tool *tool,
  168. union perf_event *event __maybe_unused,
  169. struct perf_sample *sample,
  170. struct machine *machine __maybe_unused)
  171. {
  172. struct perf_inject *inject = container_of(tool, struct perf_inject, tool);
  173. if (!inject->aux_id)
  174. inject->aux_id = sample->id;
  175. return 0;
  176. }
  177. typedef int (*inject_handler)(struct perf_tool *tool,
  178. union perf_event *event,
  179. struct perf_sample *sample,
  180. struct perf_evsel *evsel,
  181. struct machine *machine);
  182. static int perf_event__repipe_sample(struct perf_tool *tool,
  183. union perf_event *event,
  184. struct perf_sample *sample,
  185. struct perf_evsel *evsel,
  186. struct machine *machine)
  187. {
  188. if (evsel->handler) {
  189. inject_handler f = evsel->handler;
  190. return f(tool, event, sample, evsel, machine);
  191. }
  192. build_id__mark_dso_hit(tool, event, sample, evsel, machine);
  193. return perf_event__repipe_synth(tool, event);
  194. }
  195. static int perf_event__repipe_mmap(struct perf_tool *tool,
  196. union perf_event *event,
  197. struct perf_sample *sample,
  198. struct machine *machine)
  199. {
  200. int err;
  201. err = perf_event__process_mmap(tool, event, sample, machine);
  202. perf_event__repipe(tool, event, sample, machine);
  203. return err;
  204. }
  205. #ifdef HAVE_LIBELF_SUPPORT
  206. static int perf_event__jit_repipe_mmap(struct perf_tool *tool,
  207. union perf_event *event,
  208. struct perf_sample *sample,
  209. struct machine *machine)
  210. {
  211. struct perf_inject *inject = container_of(tool, struct perf_inject, tool);
  212. u64 n = 0;
  213. /*
  214. * if jit marker, then inject jit mmaps and generate ELF images
  215. */
  216. if (!jit_process(inject->session, &inject->output, machine,
  217. event->mmap.filename, sample->pid, &n)) {
  218. inject->bytes_written += n;
  219. return 0;
  220. }
  221. return perf_event__repipe_mmap(tool, event, sample, machine);
  222. }
  223. #endif
  224. static int perf_event__repipe_mmap2(struct perf_tool *tool,
  225. union perf_event *event,
  226. struct perf_sample *sample,
  227. struct machine *machine)
  228. {
  229. int err;
  230. err = perf_event__process_mmap2(tool, event, sample, machine);
  231. perf_event__repipe(tool, event, sample, machine);
  232. return err;
  233. }
  234. #ifdef HAVE_LIBELF_SUPPORT
  235. static int perf_event__jit_repipe_mmap2(struct perf_tool *tool,
  236. union perf_event *event,
  237. struct perf_sample *sample,
  238. struct machine *machine)
  239. {
  240. struct perf_inject *inject = container_of(tool, struct perf_inject, tool);
  241. u64 n = 0;
  242. /*
  243. * if jit marker, then inject jit mmaps and generate ELF images
  244. */
  245. if (!jit_process(inject->session, &inject->output, machine,
  246. event->mmap2.filename, sample->pid, &n)) {
  247. inject->bytes_written += n;
  248. return 0;
  249. }
  250. return perf_event__repipe_mmap2(tool, event, sample, machine);
  251. }
  252. #endif
  253. static int perf_event__repipe_fork(struct perf_tool *tool,
  254. union perf_event *event,
  255. struct perf_sample *sample,
  256. struct machine *machine)
  257. {
  258. int err;
  259. err = perf_event__process_fork(tool, event, sample, machine);
  260. perf_event__repipe(tool, event, sample, machine);
  261. return err;
  262. }
  263. static int perf_event__repipe_comm(struct perf_tool *tool,
  264. union perf_event *event,
  265. struct perf_sample *sample,
  266. struct machine *machine)
  267. {
  268. int err;
  269. err = perf_event__process_comm(tool, event, sample, machine);
  270. perf_event__repipe(tool, event, sample, machine);
  271. return err;
  272. }
  273. static int perf_event__repipe_exit(struct perf_tool *tool,
  274. union perf_event *event,
  275. struct perf_sample *sample,
  276. struct machine *machine)
  277. {
  278. int err;
  279. err = perf_event__process_exit(tool, event, sample, machine);
  280. perf_event__repipe(tool, event, sample, machine);
  281. return err;
  282. }
  283. static int perf_event__repipe_tracing_data(struct perf_tool *tool,
  284. union perf_event *event,
  285. struct perf_session *session)
  286. {
  287. int err;
  288. perf_event__repipe_synth(tool, event);
  289. err = perf_event__process_tracing_data(tool, event, session);
  290. return err;
  291. }
  292. static int perf_event__repipe_id_index(struct perf_tool *tool,
  293. union perf_event *event,
  294. struct perf_session *session)
  295. {
  296. int err;
  297. perf_event__repipe_synth(tool, event);
  298. err = perf_event__process_id_index(tool, event, session);
  299. return err;
  300. }
  301. static int dso__read_build_id(struct dso *dso)
  302. {
  303. if (dso->has_build_id)
  304. return 0;
  305. if (filename__read_build_id(dso->long_name, dso->build_id,
  306. sizeof(dso->build_id)) > 0) {
  307. dso->has_build_id = true;
  308. return 0;
  309. }
  310. return -1;
  311. }
  312. static int dso__inject_build_id(struct dso *dso, struct perf_tool *tool,
  313. struct machine *machine)
  314. {
  315. u16 misc = PERF_RECORD_MISC_USER;
  316. int err;
  317. if (dso__read_build_id(dso) < 0) {
  318. pr_debug("no build_id found for %s\n", dso->long_name);
  319. return -1;
  320. }
  321. if (dso->kernel)
  322. misc = PERF_RECORD_MISC_KERNEL;
  323. err = perf_event__synthesize_build_id(tool, dso, misc, perf_event__repipe,
  324. machine);
  325. if (err) {
  326. pr_err("Can't synthesize build_id event for %s\n", dso->long_name);
  327. return -1;
  328. }
  329. return 0;
  330. }
  331. static int perf_event__inject_buildid(struct perf_tool *tool,
  332. union perf_event *event,
  333. struct perf_sample *sample,
  334. struct perf_evsel *evsel __maybe_unused,
  335. struct machine *machine)
  336. {
  337. struct addr_location al;
  338. struct thread *thread;
  339. u8 cpumode;
  340. cpumode = event->header.misc & PERF_RECORD_MISC_CPUMODE_MASK;
  341. thread = machine__findnew_thread(machine, sample->pid, sample->tid);
  342. if (thread == NULL) {
  343. pr_err("problem processing %d event, skipping it.\n",
  344. event->header.type);
  345. goto repipe;
  346. }
  347. thread__find_addr_map(thread, cpumode, MAP__FUNCTION, sample->ip, &al);
  348. if (al.map != NULL) {
  349. if (!al.map->dso->hit) {
  350. al.map->dso->hit = 1;
  351. if (map__load(al.map, NULL) >= 0) {
  352. dso__inject_build_id(al.map->dso, tool, machine);
  353. /*
  354. * If this fails, too bad, let the other side
  355. * account this as unresolved.
  356. */
  357. } else {
  358. #ifdef HAVE_LIBELF_SUPPORT
  359. pr_warning("no symbols found in %s, maybe "
  360. "install a debug package?\n",
  361. al.map->dso->long_name);
  362. #endif
  363. }
  364. }
  365. }
  366. thread__put(thread);
  367. repipe:
  368. perf_event__repipe(tool, event, sample, machine);
  369. return 0;
  370. }
  371. static int perf_inject__sched_process_exit(struct perf_tool *tool,
  372. union perf_event *event __maybe_unused,
  373. struct perf_sample *sample,
  374. struct perf_evsel *evsel __maybe_unused,
  375. struct machine *machine __maybe_unused)
  376. {
  377. struct perf_inject *inject = container_of(tool, struct perf_inject, tool);
  378. struct event_entry *ent;
  379. list_for_each_entry(ent, &inject->samples, node) {
  380. if (sample->tid == ent->tid) {
  381. list_del_init(&ent->node);
  382. free(ent);
  383. break;
  384. }
  385. }
  386. return 0;
  387. }
  388. static int perf_inject__sched_switch(struct perf_tool *tool,
  389. union perf_event *event,
  390. struct perf_sample *sample,
  391. struct perf_evsel *evsel,
  392. struct machine *machine)
  393. {
  394. struct perf_inject *inject = container_of(tool, struct perf_inject, tool);
  395. struct event_entry *ent;
  396. perf_inject__sched_process_exit(tool, event, sample, evsel, machine);
  397. ent = malloc(event->header.size + sizeof(struct event_entry));
  398. if (ent == NULL) {
  399. color_fprintf(stderr, PERF_COLOR_RED,
  400. "Not enough memory to process sched switch event!");
  401. return -1;
  402. }
  403. ent->tid = sample->tid;
  404. memcpy(&ent->event, event, event->header.size);
  405. list_add(&ent->node, &inject->samples);
  406. return 0;
  407. }
  408. static int perf_inject__sched_stat(struct perf_tool *tool,
  409. union perf_event *event __maybe_unused,
  410. struct perf_sample *sample,
  411. struct perf_evsel *evsel,
  412. struct machine *machine)
  413. {
  414. struct event_entry *ent;
  415. union perf_event *event_sw;
  416. struct perf_sample sample_sw;
  417. struct perf_inject *inject = container_of(tool, struct perf_inject, tool);
  418. u32 pid = perf_evsel__intval(evsel, sample, "pid");
  419. list_for_each_entry(ent, &inject->samples, node) {
  420. if (pid == ent->tid)
  421. goto found;
  422. }
  423. return 0;
  424. found:
  425. event_sw = &ent->event[0];
  426. perf_evsel__parse_sample(evsel, event_sw, &sample_sw);
  427. sample_sw.period = sample->period;
  428. sample_sw.time = sample->time;
  429. perf_event__synthesize_sample(event_sw, evsel->attr.sample_type,
  430. evsel->attr.read_format, &sample_sw,
  431. false);
  432. build_id__mark_dso_hit(tool, event_sw, &sample_sw, evsel, machine);
  433. return perf_event__repipe(tool, event_sw, &sample_sw, machine);
  434. }
  435. static void sig_handler(int sig __maybe_unused)
  436. {
  437. session_done = 1;
  438. }
  439. static int perf_evsel__check_stype(struct perf_evsel *evsel,
  440. u64 sample_type, const char *sample_msg)
  441. {
  442. struct perf_event_attr *attr = &evsel->attr;
  443. const char *name = perf_evsel__name(evsel);
  444. if (!(attr->sample_type & sample_type)) {
  445. pr_err("Samples for %s event do not have %s attribute set.",
  446. name, sample_msg);
  447. return -EINVAL;
  448. }
  449. return 0;
  450. }
  451. static int drop_sample(struct perf_tool *tool __maybe_unused,
  452. union perf_event *event __maybe_unused,
  453. struct perf_sample *sample __maybe_unused,
  454. struct perf_evsel *evsel __maybe_unused,
  455. struct machine *machine __maybe_unused)
  456. {
  457. return 0;
  458. }
  459. static void strip_init(struct perf_inject *inject)
  460. {
  461. struct perf_evlist *evlist = inject->session->evlist;
  462. struct perf_evsel *evsel;
  463. inject->tool.context_switch = perf_event__drop;
  464. evlist__for_each(evlist, evsel)
  465. evsel->handler = drop_sample;
  466. }
  467. static bool has_tracking(struct perf_evsel *evsel)
  468. {
  469. return evsel->attr.mmap || evsel->attr.mmap2 || evsel->attr.comm ||
  470. evsel->attr.task;
  471. }
  472. #define COMPAT_MASK (PERF_SAMPLE_ID | PERF_SAMPLE_TID | PERF_SAMPLE_TIME | \
  473. PERF_SAMPLE_ID | PERF_SAMPLE_CPU | PERF_SAMPLE_IDENTIFIER)
  474. /*
  475. * In order that the perf.data file is parsable, tracking events like MMAP need
  476. * their selected event to exist, except if there is only 1 selected event left
  477. * and it has a compatible sample type.
  478. */
  479. static bool ok_to_remove(struct perf_evlist *evlist,
  480. struct perf_evsel *evsel_to_remove)
  481. {
  482. struct perf_evsel *evsel;
  483. int cnt = 0;
  484. bool ok = false;
  485. if (!has_tracking(evsel_to_remove))
  486. return true;
  487. evlist__for_each(evlist, evsel) {
  488. if (evsel->handler != drop_sample) {
  489. cnt += 1;
  490. if ((evsel->attr.sample_type & COMPAT_MASK) ==
  491. (evsel_to_remove->attr.sample_type & COMPAT_MASK))
  492. ok = true;
  493. }
  494. }
  495. return ok && cnt == 1;
  496. }
  497. static void strip_fini(struct perf_inject *inject)
  498. {
  499. struct perf_evlist *evlist = inject->session->evlist;
  500. struct perf_evsel *evsel, *tmp;
  501. /* Remove non-synthesized evsels if possible */
  502. evlist__for_each_safe(evlist, tmp, evsel) {
  503. if (evsel->handler == drop_sample &&
  504. ok_to_remove(evlist, evsel)) {
  505. pr_debug("Deleting %s\n", perf_evsel__name(evsel));
  506. perf_evlist__remove(evlist, evsel);
  507. perf_evsel__delete(evsel);
  508. }
  509. }
  510. }
  511. static int __cmd_inject(struct perf_inject *inject)
  512. {
  513. int ret = -EINVAL;
  514. struct perf_session *session = inject->session;
  515. struct perf_data_file *file_out = &inject->output;
  516. int fd = perf_data_file__fd(file_out);
  517. u64 output_data_offset;
  518. signal(SIGINT, sig_handler);
  519. if (inject->build_ids || inject->sched_stat ||
  520. inject->itrace_synth_opts.set) {
  521. inject->tool.mmap = perf_event__repipe_mmap;
  522. inject->tool.mmap2 = perf_event__repipe_mmap2;
  523. inject->tool.fork = perf_event__repipe_fork;
  524. inject->tool.tracing_data = perf_event__repipe_tracing_data;
  525. }
  526. output_data_offset = session->header.data_offset;
  527. if (inject->build_ids) {
  528. inject->tool.sample = perf_event__inject_buildid;
  529. } else if (inject->sched_stat) {
  530. struct perf_evsel *evsel;
  531. evlist__for_each(session->evlist, evsel) {
  532. const char *name = perf_evsel__name(evsel);
  533. if (!strcmp(name, "sched:sched_switch")) {
  534. if (perf_evsel__check_stype(evsel, PERF_SAMPLE_TID, "TID"))
  535. return -EINVAL;
  536. evsel->handler = perf_inject__sched_switch;
  537. } else if (!strcmp(name, "sched:sched_process_exit"))
  538. evsel->handler = perf_inject__sched_process_exit;
  539. else if (!strncmp(name, "sched:sched_stat_", 17))
  540. evsel->handler = perf_inject__sched_stat;
  541. }
  542. } else if (inject->itrace_synth_opts.set) {
  543. session->itrace_synth_opts = &inject->itrace_synth_opts;
  544. inject->itrace_synth_opts.inject = true;
  545. inject->tool.comm = perf_event__repipe_comm;
  546. inject->tool.exit = perf_event__repipe_exit;
  547. inject->tool.id_index = perf_event__repipe_id_index;
  548. inject->tool.auxtrace_info = perf_event__process_auxtrace_info;
  549. inject->tool.auxtrace = perf_event__process_auxtrace;
  550. inject->tool.aux = perf_event__drop_aux;
  551. inject->tool.itrace_start = perf_event__drop_aux,
  552. inject->tool.ordered_events = true;
  553. inject->tool.ordering_requires_timestamps = true;
  554. /* Allow space in the header for new attributes */
  555. output_data_offset = 4096;
  556. if (inject->strip)
  557. strip_init(inject);
  558. }
  559. if (!inject->itrace_synth_opts.set)
  560. auxtrace_index__free(&session->auxtrace_index);
  561. if (!file_out->is_pipe)
  562. lseek(fd, output_data_offset, SEEK_SET);
  563. ret = perf_session__process_events(session);
  564. if (!file_out->is_pipe) {
  565. if (inject->build_ids) {
  566. perf_header__set_feat(&session->header,
  567. HEADER_BUILD_ID);
  568. if (inject->have_auxtrace)
  569. dsos__hit_all(session);
  570. }
  571. /*
  572. * The AUX areas have been removed and replaced with
  573. * synthesized hardware events, so clear the feature flag and
  574. * remove the evsel.
  575. */
  576. if (inject->itrace_synth_opts.set) {
  577. struct perf_evsel *evsel;
  578. perf_header__clear_feat(&session->header,
  579. HEADER_AUXTRACE);
  580. if (inject->itrace_synth_opts.last_branch)
  581. perf_header__set_feat(&session->header,
  582. HEADER_BRANCH_STACK);
  583. evsel = perf_evlist__id2evsel_strict(session->evlist,
  584. inject->aux_id);
  585. if (evsel) {
  586. pr_debug("Deleting %s\n",
  587. perf_evsel__name(evsel));
  588. perf_evlist__remove(session->evlist, evsel);
  589. perf_evsel__delete(evsel);
  590. }
  591. if (inject->strip)
  592. strip_fini(inject);
  593. }
  594. session->header.data_offset = output_data_offset;
  595. session->header.data_size = inject->bytes_written;
  596. perf_session__write_header(session, session->evlist, fd, true);
  597. }
  598. return ret;
  599. }
  600. #ifdef HAVE_LIBELF_SUPPORT
  601. static int
  602. jit_validate_events(struct perf_session *session)
  603. {
  604. struct perf_evsel *evsel;
  605. /*
  606. * check that all events use CLOCK_MONOTONIC
  607. */
  608. evlist__for_each(session->evlist, evsel) {
  609. if (evsel->attr.use_clockid == 0 || evsel->attr.clockid != CLOCK_MONOTONIC)
  610. return -1;
  611. }
  612. return 0;
  613. }
  614. #endif
  615. int cmd_inject(int argc, const char **argv, const char *prefix __maybe_unused)
  616. {
  617. struct perf_inject inject = {
  618. .tool = {
  619. .sample = perf_event__repipe_sample,
  620. .mmap = perf_event__repipe,
  621. .mmap2 = perf_event__repipe,
  622. .comm = perf_event__repipe,
  623. .fork = perf_event__repipe,
  624. .exit = perf_event__repipe,
  625. .lost = perf_event__repipe,
  626. .lost_samples = perf_event__repipe,
  627. .aux = perf_event__repipe,
  628. .itrace_start = perf_event__repipe,
  629. .context_switch = perf_event__repipe,
  630. .read = perf_event__repipe_sample,
  631. .throttle = perf_event__repipe,
  632. .unthrottle = perf_event__repipe,
  633. .attr = perf_event__repipe_attr,
  634. .tracing_data = perf_event__repipe_op2_synth,
  635. .auxtrace_info = perf_event__repipe_op2_synth,
  636. .auxtrace = perf_event__repipe_auxtrace,
  637. .auxtrace_error = perf_event__repipe_op2_synth,
  638. .finished_round = perf_event__repipe_oe_synth,
  639. .build_id = perf_event__repipe_op2_synth,
  640. .id_index = perf_event__repipe_op2_synth,
  641. },
  642. .input_name = "-",
  643. .samples = LIST_HEAD_INIT(inject.samples),
  644. .output = {
  645. .path = "-",
  646. .mode = PERF_DATA_MODE_WRITE,
  647. },
  648. };
  649. struct perf_data_file file = {
  650. .mode = PERF_DATA_MODE_READ,
  651. };
  652. int ret;
  653. struct option options[] = {
  654. OPT_BOOLEAN('b', "build-ids", &inject.build_ids,
  655. "Inject build-ids into the output stream"),
  656. OPT_STRING('i', "input", &inject.input_name, "file",
  657. "input file name"),
  658. OPT_STRING('o', "output", &inject.output.path, "file",
  659. "output file name"),
  660. OPT_BOOLEAN('s', "sched-stat", &inject.sched_stat,
  661. "Merge sched-stat and sched-switch for getting events "
  662. "where and how long tasks slept"),
  663. OPT_BOOLEAN('j', "jit", &inject.jit_mode, "merge jitdump files into perf.data file"),
  664. OPT_INCR('v', "verbose", &verbose,
  665. "be more verbose (show build ids, etc)"),
  666. OPT_STRING(0, "kallsyms", &symbol_conf.kallsyms_name, "file",
  667. "kallsyms pathname"),
  668. OPT_BOOLEAN('f', "force", &file.force, "don't complain, do it"),
  669. OPT_CALLBACK_OPTARG(0, "itrace", &inject.itrace_synth_opts,
  670. NULL, "opts", "Instruction Tracing options",
  671. itrace_parse_synth_opts),
  672. OPT_BOOLEAN(0, "strip", &inject.strip,
  673. "strip non-synthesized events (use with --itrace)"),
  674. OPT_END()
  675. };
  676. const char * const inject_usage[] = {
  677. "perf inject [<options>]",
  678. NULL
  679. };
  680. #ifndef HAVE_LIBELF_SUPPORT
  681. set_option_nobuild(options, 'j', "jit", "NO_LIBELF=1", true);
  682. #endif
  683. argc = parse_options(argc, argv, options, inject_usage, 0);
  684. /*
  685. * Any (unrecognized) arguments left?
  686. */
  687. if (argc)
  688. usage_with_options(inject_usage, options);
  689. if (inject.strip && !inject.itrace_synth_opts.set) {
  690. pr_err("--strip option requires --itrace option\n");
  691. return -1;
  692. }
  693. if (perf_data_file__open(&inject.output)) {
  694. perror("failed to create output file");
  695. return -1;
  696. }
  697. inject.tool.ordered_events = inject.sched_stat;
  698. file.path = inject.input_name;
  699. inject.session = perf_session__new(&file, true, &inject.tool);
  700. if (inject.session == NULL)
  701. return -1;
  702. if (inject.build_ids) {
  703. /*
  704. * to make sure the mmap records are ordered correctly
  705. * and so that the correct especially due to jitted code
  706. * mmaps. We cannot generate the buildid hit list and
  707. * inject the jit mmaps at the same time for now.
  708. */
  709. inject.tool.ordered_events = true;
  710. inject.tool.ordering_requires_timestamps = true;
  711. }
  712. #ifdef HAVE_LIBELF_SUPPORT
  713. if (inject.jit_mode) {
  714. /*
  715. * validate event is using the correct clockid
  716. */
  717. if (jit_validate_events(inject.session)) {
  718. fprintf(stderr, "error, jitted code must be sampled with perf record -k 1\n");
  719. return -1;
  720. }
  721. inject.tool.mmap2 = perf_event__jit_repipe_mmap2;
  722. inject.tool.mmap = perf_event__jit_repipe_mmap;
  723. inject.tool.ordered_events = true;
  724. inject.tool.ordering_requires_timestamps = true;
  725. /*
  726. * JIT MMAP injection injects all MMAP events in one go, so it
  727. * does not obey finished_round semantics.
  728. */
  729. inject.tool.finished_round = perf_event__drop_oe;
  730. }
  731. #endif
  732. ret = symbol__init(&inject.session->header.env);
  733. if (ret < 0)
  734. goto out_delete;
  735. ret = __cmd_inject(&inject);
  736. out_delete:
  737. perf_session__delete(inject.session);
  738. return ret;
  739. }