evlist.c 41 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815
  1. /*
  2. * Copyright (C) 2011, Red Hat Inc, Arnaldo Carvalho de Melo <acme@redhat.com>
  3. *
  4. * Parts came from builtin-{top,stat,record}.c, see those files for further
  5. * copyright notes.
  6. *
  7. * Released under the GPL v2. (and only v2, not any later version)
  8. */
  9. #include "util.h"
  10. #include <api/fs/fs.h>
  11. #include <errno.h>
  12. #include <inttypes.h>
  13. #include <poll.h>
  14. #include "cpumap.h"
  15. #include "thread_map.h"
  16. #include "target.h"
  17. #include "evlist.h"
  18. #include "evsel.h"
  19. #include "debug.h"
  20. #include "units.h"
  21. #include "asm/bug.h"
  22. #include <signal.h>
  23. #include <unistd.h>
  24. #include "parse-events.h"
  25. #include <subcmd/parse-options.h>
  26. #include <sys/ioctl.h>
  27. #include <sys/mman.h>
  28. #include <linux/bitops.h>
  29. #include <linux/hash.h>
  30. #include <linux/log2.h>
  31. #include <linux/err.h>
  32. #define FD(e, x, y) (*(int *)xyarray__entry(e->fd, x, y))
  33. #define SID(e, x, y) xyarray__entry(e->sample_id, x, y)
  34. void perf_evlist__init(struct perf_evlist *evlist, struct cpu_map *cpus,
  35. struct thread_map *threads)
  36. {
  37. int i;
  38. for (i = 0; i < PERF_EVLIST__HLIST_SIZE; ++i)
  39. INIT_HLIST_HEAD(&evlist->heads[i]);
  40. INIT_LIST_HEAD(&evlist->entries);
  41. perf_evlist__set_maps(evlist, cpus, threads);
  42. fdarray__init(&evlist->pollfd, 64);
  43. evlist->workload.pid = -1;
  44. evlist->bkw_mmap_state = BKW_MMAP_NOTREADY;
  45. }
  46. struct perf_evlist *perf_evlist__new(void)
  47. {
  48. struct perf_evlist *evlist = zalloc(sizeof(*evlist));
  49. if (evlist != NULL)
  50. perf_evlist__init(evlist, NULL, NULL);
  51. return evlist;
  52. }
  53. struct perf_evlist *perf_evlist__new_default(void)
  54. {
  55. struct perf_evlist *evlist = perf_evlist__new();
  56. if (evlist && perf_evlist__add_default(evlist)) {
  57. perf_evlist__delete(evlist);
  58. evlist = NULL;
  59. }
  60. return evlist;
  61. }
  62. struct perf_evlist *perf_evlist__new_dummy(void)
  63. {
  64. struct perf_evlist *evlist = perf_evlist__new();
  65. if (evlist && perf_evlist__add_dummy(evlist)) {
  66. perf_evlist__delete(evlist);
  67. evlist = NULL;
  68. }
  69. return evlist;
  70. }
  71. /**
  72. * perf_evlist__set_id_pos - set the positions of event ids.
  73. * @evlist: selected event list
  74. *
  75. * Events with compatible sample types all have the same id_pos
  76. * and is_pos. For convenience, put a copy on evlist.
  77. */
  78. void perf_evlist__set_id_pos(struct perf_evlist *evlist)
  79. {
  80. struct perf_evsel *first = perf_evlist__first(evlist);
  81. evlist->id_pos = first->id_pos;
  82. evlist->is_pos = first->is_pos;
  83. }
  84. static void perf_evlist__update_id_pos(struct perf_evlist *evlist)
  85. {
  86. struct perf_evsel *evsel;
  87. evlist__for_each_entry(evlist, evsel)
  88. perf_evsel__calc_id_pos(evsel);
  89. perf_evlist__set_id_pos(evlist);
  90. }
  91. static void perf_evlist__purge(struct perf_evlist *evlist)
  92. {
  93. struct perf_evsel *pos, *n;
  94. evlist__for_each_entry_safe(evlist, n, pos) {
  95. list_del_init(&pos->node);
  96. pos->evlist = NULL;
  97. perf_evsel__delete(pos);
  98. }
  99. evlist->nr_entries = 0;
  100. }
  101. void perf_evlist__exit(struct perf_evlist *evlist)
  102. {
  103. zfree(&evlist->mmap);
  104. zfree(&evlist->overwrite_mmap);
  105. fdarray__exit(&evlist->pollfd);
  106. }
  107. void perf_evlist__delete(struct perf_evlist *evlist)
  108. {
  109. if (evlist == NULL)
  110. return;
  111. perf_evlist__munmap(evlist);
  112. perf_evlist__close(evlist);
  113. cpu_map__put(evlist->cpus);
  114. thread_map__put(evlist->threads);
  115. evlist->cpus = NULL;
  116. evlist->threads = NULL;
  117. perf_evlist__purge(evlist);
  118. perf_evlist__exit(evlist);
  119. free(evlist);
  120. }
  121. static void __perf_evlist__propagate_maps(struct perf_evlist *evlist,
  122. struct perf_evsel *evsel)
  123. {
  124. /*
  125. * We already have cpus for evsel (via PMU sysfs) so
  126. * keep it, if there's no target cpu list defined.
  127. */
  128. if (!evsel->own_cpus || evlist->has_user_cpus) {
  129. cpu_map__put(evsel->cpus);
  130. evsel->cpus = cpu_map__get(evlist->cpus);
  131. } else if (evsel->cpus != evsel->own_cpus) {
  132. cpu_map__put(evsel->cpus);
  133. evsel->cpus = cpu_map__get(evsel->own_cpus);
  134. }
  135. thread_map__put(evsel->threads);
  136. evsel->threads = thread_map__get(evlist->threads);
  137. }
  138. static void perf_evlist__propagate_maps(struct perf_evlist *evlist)
  139. {
  140. struct perf_evsel *evsel;
  141. evlist__for_each_entry(evlist, evsel)
  142. __perf_evlist__propagate_maps(evlist, evsel);
  143. }
  144. void perf_evlist__add(struct perf_evlist *evlist, struct perf_evsel *entry)
  145. {
  146. entry->evlist = evlist;
  147. list_add_tail(&entry->node, &evlist->entries);
  148. entry->idx = evlist->nr_entries;
  149. entry->tracking = !entry->idx;
  150. if (!evlist->nr_entries++)
  151. perf_evlist__set_id_pos(evlist);
  152. __perf_evlist__propagate_maps(evlist, entry);
  153. }
  154. void perf_evlist__remove(struct perf_evlist *evlist, struct perf_evsel *evsel)
  155. {
  156. evsel->evlist = NULL;
  157. list_del_init(&evsel->node);
  158. evlist->nr_entries -= 1;
  159. }
  160. void perf_evlist__splice_list_tail(struct perf_evlist *evlist,
  161. struct list_head *list)
  162. {
  163. struct perf_evsel *evsel, *temp;
  164. __evlist__for_each_entry_safe(list, temp, evsel) {
  165. list_del_init(&evsel->node);
  166. perf_evlist__add(evlist, evsel);
  167. }
  168. }
  169. void __perf_evlist__set_leader(struct list_head *list)
  170. {
  171. struct perf_evsel *evsel, *leader;
  172. leader = list_entry(list->next, struct perf_evsel, node);
  173. evsel = list_entry(list->prev, struct perf_evsel, node);
  174. leader->nr_members = evsel->idx - leader->idx + 1;
  175. __evlist__for_each_entry(list, evsel) {
  176. evsel->leader = leader;
  177. }
  178. }
  179. void perf_evlist__set_leader(struct perf_evlist *evlist)
  180. {
  181. if (evlist->nr_entries) {
  182. evlist->nr_groups = evlist->nr_entries > 1 ? 1 : 0;
  183. __perf_evlist__set_leader(&evlist->entries);
  184. }
  185. }
  186. void perf_event_attr__set_max_precise_ip(struct perf_event_attr *attr)
  187. {
  188. attr->precise_ip = 3;
  189. while (attr->precise_ip != 0) {
  190. int fd = sys_perf_event_open(attr, 0, -1, -1, 0);
  191. if (fd != -1) {
  192. close(fd);
  193. break;
  194. }
  195. --attr->precise_ip;
  196. }
  197. }
  198. int __perf_evlist__add_default(struct perf_evlist *evlist, bool precise)
  199. {
  200. struct perf_evsel *evsel = perf_evsel__new_cycles(precise);
  201. if (evsel == NULL)
  202. return -ENOMEM;
  203. perf_evlist__add(evlist, evsel);
  204. return 0;
  205. }
  206. int perf_evlist__add_dummy(struct perf_evlist *evlist)
  207. {
  208. struct perf_event_attr attr = {
  209. .type = PERF_TYPE_SOFTWARE,
  210. .config = PERF_COUNT_SW_DUMMY,
  211. .size = sizeof(attr), /* to capture ABI version */
  212. };
  213. struct perf_evsel *evsel = perf_evsel__new_idx(&attr, evlist->nr_entries);
  214. if (evsel == NULL)
  215. return -ENOMEM;
  216. perf_evlist__add(evlist, evsel);
  217. return 0;
  218. }
  219. static int perf_evlist__add_attrs(struct perf_evlist *evlist,
  220. struct perf_event_attr *attrs, size_t nr_attrs)
  221. {
  222. struct perf_evsel *evsel, *n;
  223. LIST_HEAD(head);
  224. size_t i;
  225. for (i = 0; i < nr_attrs; i++) {
  226. evsel = perf_evsel__new_idx(attrs + i, evlist->nr_entries + i);
  227. if (evsel == NULL)
  228. goto out_delete_partial_list;
  229. list_add_tail(&evsel->node, &head);
  230. }
  231. perf_evlist__splice_list_tail(evlist, &head);
  232. return 0;
  233. out_delete_partial_list:
  234. __evlist__for_each_entry_safe(&head, n, evsel)
  235. perf_evsel__delete(evsel);
  236. return -1;
  237. }
  238. int __perf_evlist__add_default_attrs(struct perf_evlist *evlist,
  239. struct perf_event_attr *attrs, size_t nr_attrs)
  240. {
  241. size_t i;
  242. for (i = 0; i < nr_attrs; i++)
  243. event_attr_init(attrs + i);
  244. return perf_evlist__add_attrs(evlist, attrs, nr_attrs);
  245. }
  246. struct perf_evsel *
  247. perf_evlist__find_tracepoint_by_id(struct perf_evlist *evlist, int id)
  248. {
  249. struct perf_evsel *evsel;
  250. evlist__for_each_entry(evlist, evsel) {
  251. if (evsel->attr.type == PERF_TYPE_TRACEPOINT &&
  252. (int)evsel->attr.config == id)
  253. return evsel;
  254. }
  255. return NULL;
  256. }
  257. struct perf_evsel *
  258. perf_evlist__find_tracepoint_by_name(struct perf_evlist *evlist,
  259. const char *name)
  260. {
  261. struct perf_evsel *evsel;
  262. evlist__for_each_entry(evlist, evsel) {
  263. if ((evsel->attr.type == PERF_TYPE_TRACEPOINT) &&
  264. (strcmp(evsel->name, name) == 0))
  265. return evsel;
  266. }
  267. return NULL;
  268. }
  269. int perf_evlist__add_newtp(struct perf_evlist *evlist,
  270. const char *sys, const char *name, void *handler)
  271. {
  272. struct perf_evsel *evsel = perf_evsel__newtp(sys, name);
  273. if (IS_ERR(evsel))
  274. return -1;
  275. evsel->handler = handler;
  276. perf_evlist__add(evlist, evsel);
  277. return 0;
  278. }
  279. static int perf_evlist__nr_threads(struct perf_evlist *evlist,
  280. struct perf_evsel *evsel)
  281. {
  282. if (evsel->system_wide)
  283. return 1;
  284. else
  285. return thread_map__nr(evlist->threads);
  286. }
  287. void perf_evlist__disable(struct perf_evlist *evlist)
  288. {
  289. struct perf_evsel *pos;
  290. evlist__for_each_entry(evlist, pos) {
  291. if (!perf_evsel__is_group_leader(pos) || !pos->fd)
  292. continue;
  293. perf_evsel__disable(pos);
  294. }
  295. evlist->enabled = false;
  296. }
  297. void perf_evlist__enable(struct perf_evlist *evlist)
  298. {
  299. struct perf_evsel *pos;
  300. evlist__for_each_entry(evlist, pos) {
  301. if (!perf_evsel__is_group_leader(pos) || !pos->fd)
  302. continue;
  303. perf_evsel__enable(pos);
  304. }
  305. evlist->enabled = true;
  306. }
  307. void perf_evlist__toggle_enable(struct perf_evlist *evlist)
  308. {
  309. (evlist->enabled ? perf_evlist__disable : perf_evlist__enable)(evlist);
  310. }
  311. static int perf_evlist__enable_event_cpu(struct perf_evlist *evlist,
  312. struct perf_evsel *evsel, int cpu)
  313. {
  314. int thread;
  315. int nr_threads = perf_evlist__nr_threads(evlist, evsel);
  316. if (!evsel->fd)
  317. return -EINVAL;
  318. for (thread = 0; thread < nr_threads; thread++) {
  319. int err = ioctl(FD(evsel, cpu, thread), PERF_EVENT_IOC_ENABLE, 0);
  320. if (err)
  321. return err;
  322. }
  323. return 0;
  324. }
  325. static int perf_evlist__enable_event_thread(struct perf_evlist *evlist,
  326. struct perf_evsel *evsel,
  327. int thread)
  328. {
  329. int cpu;
  330. int nr_cpus = cpu_map__nr(evlist->cpus);
  331. if (!evsel->fd)
  332. return -EINVAL;
  333. for (cpu = 0; cpu < nr_cpus; cpu++) {
  334. int err = ioctl(FD(evsel, cpu, thread), PERF_EVENT_IOC_ENABLE, 0);
  335. if (err)
  336. return err;
  337. }
  338. return 0;
  339. }
  340. int perf_evlist__enable_event_idx(struct perf_evlist *evlist,
  341. struct perf_evsel *evsel, int idx)
  342. {
  343. bool per_cpu_mmaps = !cpu_map__empty(evlist->cpus);
  344. if (per_cpu_mmaps)
  345. return perf_evlist__enable_event_cpu(evlist, evsel, idx);
  346. else
  347. return perf_evlist__enable_event_thread(evlist, evsel, idx);
  348. }
  349. int perf_evlist__alloc_pollfd(struct perf_evlist *evlist)
  350. {
  351. int nr_cpus = cpu_map__nr(evlist->cpus);
  352. int nr_threads = thread_map__nr(evlist->threads);
  353. int nfds = 0;
  354. struct perf_evsel *evsel;
  355. evlist__for_each_entry(evlist, evsel) {
  356. if (evsel->system_wide)
  357. nfds += nr_cpus;
  358. else
  359. nfds += nr_cpus * nr_threads;
  360. }
  361. if (fdarray__available_entries(&evlist->pollfd) < nfds &&
  362. fdarray__grow(&evlist->pollfd, nfds) < 0)
  363. return -ENOMEM;
  364. return 0;
  365. }
  366. static int __perf_evlist__add_pollfd(struct perf_evlist *evlist, int fd,
  367. struct perf_mmap *map, short revent)
  368. {
  369. int pos = fdarray__add(&evlist->pollfd, fd, revent | POLLERR | POLLHUP);
  370. /*
  371. * Save the idx so that when we filter out fds POLLHUP'ed we can
  372. * close the associated evlist->mmap[] entry.
  373. */
  374. if (pos >= 0) {
  375. evlist->pollfd.priv[pos].ptr = map;
  376. fcntl(fd, F_SETFL, O_NONBLOCK);
  377. }
  378. return pos;
  379. }
  380. int perf_evlist__add_pollfd(struct perf_evlist *evlist, int fd)
  381. {
  382. return __perf_evlist__add_pollfd(evlist, fd, NULL, POLLIN);
  383. }
  384. static void perf_evlist__munmap_filtered(struct fdarray *fda, int fd,
  385. void *arg __maybe_unused)
  386. {
  387. struct perf_mmap *map = fda->priv[fd].ptr;
  388. if (map)
  389. perf_mmap__put(map);
  390. }
  391. int perf_evlist__filter_pollfd(struct perf_evlist *evlist, short revents_and_mask)
  392. {
  393. return fdarray__filter(&evlist->pollfd, revents_and_mask,
  394. perf_evlist__munmap_filtered, NULL);
  395. }
  396. int perf_evlist__poll(struct perf_evlist *evlist, int timeout)
  397. {
  398. return fdarray__poll(&evlist->pollfd, timeout);
  399. }
  400. static void perf_evlist__id_hash(struct perf_evlist *evlist,
  401. struct perf_evsel *evsel,
  402. int cpu, int thread, u64 id)
  403. {
  404. int hash;
  405. struct perf_sample_id *sid = SID(evsel, cpu, thread);
  406. sid->id = id;
  407. sid->evsel = evsel;
  408. hash = hash_64(sid->id, PERF_EVLIST__HLIST_BITS);
  409. hlist_add_head(&sid->node, &evlist->heads[hash]);
  410. }
  411. void perf_evlist__id_add(struct perf_evlist *evlist, struct perf_evsel *evsel,
  412. int cpu, int thread, u64 id)
  413. {
  414. perf_evlist__id_hash(evlist, evsel, cpu, thread, id);
  415. evsel->id[evsel->ids++] = id;
  416. }
  417. int perf_evlist__id_add_fd(struct perf_evlist *evlist,
  418. struct perf_evsel *evsel,
  419. int cpu, int thread, int fd)
  420. {
  421. u64 read_data[4] = { 0, };
  422. int id_idx = 1; /* The first entry is the counter value */
  423. u64 id;
  424. int ret;
  425. ret = ioctl(fd, PERF_EVENT_IOC_ID, &id);
  426. if (!ret)
  427. goto add;
  428. if (errno != ENOTTY)
  429. return -1;
  430. /* Legacy way to get event id.. All hail to old kernels! */
  431. /*
  432. * This way does not work with group format read, so bail
  433. * out in that case.
  434. */
  435. if (perf_evlist__read_format(evlist) & PERF_FORMAT_GROUP)
  436. return -1;
  437. if (!(evsel->attr.read_format & PERF_FORMAT_ID) ||
  438. read(fd, &read_data, sizeof(read_data)) == -1)
  439. return -1;
  440. if (evsel->attr.read_format & PERF_FORMAT_TOTAL_TIME_ENABLED)
  441. ++id_idx;
  442. if (evsel->attr.read_format & PERF_FORMAT_TOTAL_TIME_RUNNING)
  443. ++id_idx;
  444. id = read_data[id_idx];
  445. add:
  446. perf_evlist__id_add(evlist, evsel, cpu, thread, id);
  447. return 0;
  448. }
  449. static void perf_evlist__set_sid_idx(struct perf_evlist *evlist,
  450. struct perf_evsel *evsel, int idx, int cpu,
  451. int thread)
  452. {
  453. struct perf_sample_id *sid = SID(evsel, cpu, thread);
  454. sid->idx = idx;
  455. if (evlist->cpus && cpu >= 0)
  456. sid->cpu = evlist->cpus->map[cpu];
  457. else
  458. sid->cpu = -1;
  459. if (!evsel->system_wide && evlist->threads && thread >= 0)
  460. sid->tid = thread_map__pid(evlist->threads, thread);
  461. else
  462. sid->tid = -1;
  463. }
  464. struct perf_sample_id *perf_evlist__id2sid(struct perf_evlist *evlist, u64 id)
  465. {
  466. struct hlist_head *head;
  467. struct perf_sample_id *sid;
  468. int hash;
  469. hash = hash_64(id, PERF_EVLIST__HLIST_BITS);
  470. head = &evlist->heads[hash];
  471. hlist_for_each_entry(sid, head, node)
  472. if (sid->id == id)
  473. return sid;
  474. return NULL;
  475. }
  476. struct perf_evsel *perf_evlist__id2evsel(struct perf_evlist *evlist, u64 id)
  477. {
  478. struct perf_sample_id *sid;
  479. if (evlist->nr_entries == 1 || !id)
  480. return perf_evlist__first(evlist);
  481. sid = perf_evlist__id2sid(evlist, id);
  482. if (sid)
  483. return sid->evsel;
  484. if (!perf_evlist__sample_id_all(evlist))
  485. return perf_evlist__first(evlist);
  486. return NULL;
  487. }
  488. struct perf_evsel *perf_evlist__id2evsel_strict(struct perf_evlist *evlist,
  489. u64 id)
  490. {
  491. struct perf_sample_id *sid;
  492. if (!id)
  493. return NULL;
  494. sid = perf_evlist__id2sid(evlist, id);
  495. if (sid)
  496. return sid->evsel;
  497. return NULL;
  498. }
  499. static int perf_evlist__event2id(struct perf_evlist *evlist,
  500. union perf_event *event, u64 *id)
  501. {
  502. const u64 *array = event->sample.array;
  503. ssize_t n;
  504. n = (event->header.size - sizeof(event->header)) >> 3;
  505. if (event->header.type == PERF_RECORD_SAMPLE) {
  506. if (evlist->id_pos >= n)
  507. return -1;
  508. *id = array[evlist->id_pos];
  509. } else {
  510. if (evlist->is_pos > n)
  511. return -1;
  512. n -= evlist->is_pos;
  513. *id = array[n];
  514. }
  515. return 0;
  516. }
  517. struct perf_evsel *perf_evlist__event2evsel(struct perf_evlist *evlist,
  518. union perf_event *event)
  519. {
  520. struct perf_evsel *first = perf_evlist__first(evlist);
  521. struct hlist_head *head;
  522. struct perf_sample_id *sid;
  523. int hash;
  524. u64 id;
  525. if (evlist->nr_entries == 1)
  526. return first;
  527. if (!first->attr.sample_id_all &&
  528. event->header.type != PERF_RECORD_SAMPLE)
  529. return first;
  530. if (perf_evlist__event2id(evlist, event, &id))
  531. return NULL;
  532. /* Synthesized events have an id of zero */
  533. if (!id)
  534. return first;
  535. hash = hash_64(id, PERF_EVLIST__HLIST_BITS);
  536. head = &evlist->heads[hash];
  537. hlist_for_each_entry(sid, head, node) {
  538. if (sid->id == id)
  539. return sid->evsel;
  540. }
  541. return NULL;
  542. }
  543. static int perf_evlist__set_paused(struct perf_evlist *evlist, bool value)
  544. {
  545. int i;
  546. if (!evlist->overwrite_mmap)
  547. return 0;
  548. for (i = 0; i < evlist->nr_mmaps; i++) {
  549. int fd = evlist->overwrite_mmap[i].fd;
  550. int err;
  551. if (fd < 0)
  552. continue;
  553. err = ioctl(fd, PERF_EVENT_IOC_PAUSE_OUTPUT, value ? 1 : 0);
  554. if (err)
  555. return err;
  556. }
  557. return 0;
  558. }
  559. static int perf_evlist__pause(struct perf_evlist *evlist)
  560. {
  561. return perf_evlist__set_paused(evlist, true);
  562. }
  563. static int perf_evlist__resume(struct perf_evlist *evlist)
  564. {
  565. return perf_evlist__set_paused(evlist, false);
  566. }
  567. union perf_event *perf_evlist__mmap_read_forward(struct perf_evlist *evlist, int idx)
  568. {
  569. struct perf_mmap *md = &evlist->mmap[idx];
  570. /*
  571. * Check messup is required for forward overwritable ring buffer:
  572. * memory pointed by md->prev can be overwritten in this case.
  573. * No need for read-write ring buffer: kernel stop outputting when
  574. * it hit md->prev (perf_mmap__consume()).
  575. */
  576. return perf_mmap__read_forward(md);
  577. }
  578. union perf_event *perf_evlist__mmap_read_backward(struct perf_evlist *evlist, int idx)
  579. {
  580. struct perf_mmap *md = &evlist->mmap[idx];
  581. /*
  582. * No need to check messup for backward ring buffer:
  583. * We can always read arbitrary long data from a backward
  584. * ring buffer unless we forget to pause it before reading.
  585. */
  586. return perf_mmap__read_backward(md);
  587. }
  588. union perf_event *perf_evlist__mmap_read(struct perf_evlist *evlist, int idx)
  589. {
  590. return perf_evlist__mmap_read_forward(evlist, idx);
  591. }
  592. void perf_evlist__mmap_read_catchup(struct perf_evlist *evlist, int idx)
  593. {
  594. perf_mmap__read_catchup(&evlist->mmap[idx]);
  595. }
  596. void perf_evlist__mmap_consume(struct perf_evlist *evlist, int idx)
  597. {
  598. perf_mmap__consume(&evlist->mmap[idx], false);
  599. }
  600. static void perf_evlist__munmap_nofree(struct perf_evlist *evlist)
  601. {
  602. int i;
  603. if (evlist->mmap)
  604. for (i = 0; i < evlist->nr_mmaps; i++)
  605. perf_mmap__munmap(&evlist->mmap[i]);
  606. if (evlist->overwrite_mmap)
  607. for (i = 0; i < evlist->nr_mmaps; i++)
  608. perf_mmap__munmap(&evlist->overwrite_mmap[i]);
  609. }
  610. void perf_evlist__munmap(struct perf_evlist *evlist)
  611. {
  612. perf_evlist__munmap_nofree(evlist);
  613. zfree(&evlist->mmap);
  614. zfree(&evlist->overwrite_mmap);
  615. }
  616. static struct perf_mmap *perf_evlist__alloc_mmap(struct perf_evlist *evlist)
  617. {
  618. int i;
  619. struct perf_mmap *map;
  620. evlist->nr_mmaps = cpu_map__nr(evlist->cpus);
  621. if (cpu_map__empty(evlist->cpus))
  622. evlist->nr_mmaps = thread_map__nr(evlist->threads);
  623. map = zalloc(evlist->nr_mmaps * sizeof(struct perf_mmap));
  624. if (!map)
  625. return NULL;
  626. for (i = 0; i < evlist->nr_mmaps; i++) {
  627. map[i].fd = -1;
  628. /*
  629. * When the perf_mmap() call is made we grab one refcount, plus
  630. * one extra to let perf_evlist__mmap_consume() get the last
  631. * events after all real references (perf_mmap__get()) are
  632. * dropped.
  633. *
  634. * Each PERF_EVENT_IOC_SET_OUTPUT points to this mmap and
  635. * thus does perf_mmap__get() on it.
  636. */
  637. refcount_set(&map[i].refcnt, 0);
  638. }
  639. return map;
  640. }
  641. static bool
  642. perf_evlist__should_poll(struct perf_evlist *evlist __maybe_unused,
  643. struct perf_evsel *evsel)
  644. {
  645. if (evsel->attr.write_backward)
  646. return false;
  647. return true;
  648. }
  649. static int perf_evlist__mmap_per_evsel(struct perf_evlist *evlist, int idx,
  650. struct mmap_params *mp, int cpu_idx,
  651. int thread, int *_output, int *_output_overwrite)
  652. {
  653. struct perf_evsel *evsel;
  654. int revent;
  655. int evlist_cpu = cpu_map__cpu(evlist->cpus, cpu_idx);
  656. evlist__for_each_entry(evlist, evsel) {
  657. struct perf_mmap *maps = evlist->mmap;
  658. int *output = _output;
  659. int fd;
  660. int cpu;
  661. mp->prot = PROT_READ | PROT_WRITE;
  662. if (evsel->attr.write_backward) {
  663. output = _output_overwrite;
  664. maps = evlist->overwrite_mmap;
  665. if (!maps) {
  666. maps = perf_evlist__alloc_mmap(evlist);
  667. if (!maps)
  668. return -1;
  669. evlist->overwrite_mmap = maps;
  670. if (evlist->bkw_mmap_state == BKW_MMAP_NOTREADY)
  671. perf_evlist__toggle_bkw_mmap(evlist, BKW_MMAP_RUNNING);
  672. }
  673. mp->prot &= ~PROT_WRITE;
  674. }
  675. if (evsel->system_wide && thread)
  676. continue;
  677. cpu = cpu_map__idx(evsel->cpus, evlist_cpu);
  678. if (cpu == -1)
  679. continue;
  680. fd = FD(evsel, cpu, thread);
  681. if (*output == -1) {
  682. *output = fd;
  683. if (perf_mmap__mmap(&maps[idx], mp, *output) < 0)
  684. return -1;
  685. } else {
  686. if (ioctl(fd, PERF_EVENT_IOC_SET_OUTPUT, *output) != 0)
  687. return -1;
  688. perf_mmap__get(&maps[idx]);
  689. }
  690. revent = perf_evlist__should_poll(evlist, evsel) ? POLLIN : 0;
  691. /*
  692. * The system_wide flag causes a selected event to be opened
  693. * always without a pid. Consequently it will never get a
  694. * POLLHUP, but it is used for tracking in combination with
  695. * other events, so it should not need to be polled anyway.
  696. * Therefore don't add it for polling.
  697. */
  698. if (!evsel->system_wide &&
  699. __perf_evlist__add_pollfd(evlist, fd, &maps[idx], revent) < 0) {
  700. perf_mmap__put(&maps[idx]);
  701. return -1;
  702. }
  703. if (evsel->attr.read_format & PERF_FORMAT_ID) {
  704. if (perf_evlist__id_add_fd(evlist, evsel, cpu, thread,
  705. fd) < 0)
  706. return -1;
  707. perf_evlist__set_sid_idx(evlist, evsel, idx, cpu,
  708. thread);
  709. }
  710. }
  711. return 0;
  712. }
  713. static int perf_evlist__mmap_per_cpu(struct perf_evlist *evlist,
  714. struct mmap_params *mp)
  715. {
  716. int cpu, thread;
  717. int nr_cpus = cpu_map__nr(evlist->cpus);
  718. int nr_threads = thread_map__nr(evlist->threads);
  719. pr_debug2("perf event ring buffer mmapped per cpu\n");
  720. for (cpu = 0; cpu < nr_cpus; cpu++) {
  721. int output = -1;
  722. int output_overwrite = -1;
  723. auxtrace_mmap_params__set_idx(&mp->auxtrace_mp, evlist, cpu,
  724. true);
  725. for (thread = 0; thread < nr_threads; thread++) {
  726. if (perf_evlist__mmap_per_evsel(evlist, cpu, mp, cpu,
  727. thread, &output, &output_overwrite))
  728. goto out_unmap;
  729. }
  730. }
  731. return 0;
  732. out_unmap:
  733. perf_evlist__munmap_nofree(evlist);
  734. return -1;
  735. }
  736. static int perf_evlist__mmap_per_thread(struct perf_evlist *evlist,
  737. struct mmap_params *mp)
  738. {
  739. int thread;
  740. int nr_threads = thread_map__nr(evlist->threads);
  741. pr_debug2("perf event ring buffer mmapped per thread\n");
  742. for (thread = 0; thread < nr_threads; thread++) {
  743. int output = -1;
  744. int output_overwrite = -1;
  745. auxtrace_mmap_params__set_idx(&mp->auxtrace_mp, evlist, thread,
  746. false);
  747. if (perf_evlist__mmap_per_evsel(evlist, thread, mp, 0, thread,
  748. &output, &output_overwrite))
  749. goto out_unmap;
  750. }
  751. return 0;
  752. out_unmap:
  753. perf_evlist__munmap_nofree(evlist);
  754. return -1;
  755. }
  756. unsigned long perf_event_mlock_kb_in_pages(void)
  757. {
  758. unsigned long pages;
  759. int max;
  760. if (sysctl__read_int("kernel/perf_event_mlock_kb", &max) < 0) {
  761. /*
  762. * Pick a once upon a time good value, i.e. things look
  763. * strange since we can't read a sysctl value, but lets not
  764. * die yet...
  765. */
  766. max = 512;
  767. } else {
  768. max -= (page_size / 1024);
  769. }
  770. pages = (max * 1024) / page_size;
  771. if (!is_power_of_2(pages))
  772. pages = rounddown_pow_of_two(pages);
  773. return pages;
  774. }
  775. size_t perf_evlist__mmap_size(unsigned long pages)
  776. {
  777. if (pages == UINT_MAX)
  778. pages = perf_event_mlock_kb_in_pages();
  779. else if (!is_power_of_2(pages))
  780. return 0;
  781. return (pages + 1) * page_size;
  782. }
  783. static long parse_pages_arg(const char *str, unsigned long min,
  784. unsigned long max)
  785. {
  786. unsigned long pages, val;
  787. static struct parse_tag tags[] = {
  788. { .tag = 'B', .mult = 1 },
  789. { .tag = 'K', .mult = 1 << 10 },
  790. { .tag = 'M', .mult = 1 << 20 },
  791. { .tag = 'G', .mult = 1 << 30 },
  792. { .tag = 0 },
  793. };
  794. if (str == NULL)
  795. return -EINVAL;
  796. val = parse_tag_value(str, tags);
  797. if (val != (unsigned long) -1) {
  798. /* we got file size value */
  799. pages = PERF_ALIGN(val, page_size) / page_size;
  800. } else {
  801. /* we got pages count value */
  802. char *eptr;
  803. pages = strtoul(str, &eptr, 10);
  804. if (*eptr != '\0')
  805. return -EINVAL;
  806. }
  807. if (pages == 0 && min == 0) {
  808. /* leave number of pages at 0 */
  809. } else if (!is_power_of_2(pages)) {
  810. char buf[100];
  811. /* round pages up to next power of 2 */
  812. pages = roundup_pow_of_two(pages);
  813. if (!pages)
  814. return -EINVAL;
  815. unit_number__scnprintf(buf, sizeof(buf), pages * page_size);
  816. pr_info("rounding mmap pages size to %s (%lu pages)\n",
  817. buf, pages);
  818. }
  819. if (pages > max)
  820. return -EINVAL;
  821. return pages;
  822. }
  823. int __perf_evlist__parse_mmap_pages(unsigned int *mmap_pages, const char *str)
  824. {
  825. unsigned long max = UINT_MAX;
  826. long pages;
  827. if (max > SIZE_MAX / page_size)
  828. max = SIZE_MAX / page_size;
  829. pages = parse_pages_arg(str, 1, max);
  830. if (pages < 0) {
  831. pr_err("Invalid argument for --mmap_pages/-m\n");
  832. return -1;
  833. }
  834. *mmap_pages = pages;
  835. return 0;
  836. }
  837. int perf_evlist__parse_mmap_pages(const struct option *opt, const char *str,
  838. int unset __maybe_unused)
  839. {
  840. return __perf_evlist__parse_mmap_pages(opt->value, str);
  841. }
  842. /**
  843. * perf_evlist__mmap_ex - Create mmaps to receive events.
  844. * @evlist: list of events
  845. * @pages: map length in pages
  846. * @overwrite: overwrite older events?
  847. * @auxtrace_pages - auxtrace map length in pages
  848. * @auxtrace_overwrite - overwrite older auxtrace data?
  849. *
  850. * If @overwrite is %false the user needs to signal event consumption using
  851. * perf_mmap__write_tail(). Using perf_evlist__mmap_read() does this
  852. * automatically.
  853. *
  854. * Similarly, if @auxtrace_overwrite is %false the user needs to signal data
  855. * consumption using auxtrace_mmap__write_tail().
  856. *
  857. * Return: %0 on success, negative error code otherwise.
  858. */
  859. int perf_evlist__mmap_ex(struct perf_evlist *evlist, unsigned int pages,
  860. unsigned int auxtrace_pages,
  861. bool auxtrace_overwrite)
  862. {
  863. struct perf_evsel *evsel;
  864. const struct cpu_map *cpus = evlist->cpus;
  865. const struct thread_map *threads = evlist->threads;
  866. /*
  867. * Delay setting mp.prot: set it before calling perf_mmap__mmap.
  868. * Its value is decided by evsel's write_backward.
  869. * So &mp should not be passed through const pointer.
  870. */
  871. struct mmap_params mp;
  872. if (!evlist->mmap)
  873. evlist->mmap = perf_evlist__alloc_mmap(evlist);
  874. if (!evlist->mmap)
  875. return -ENOMEM;
  876. if (evlist->pollfd.entries == NULL && perf_evlist__alloc_pollfd(evlist) < 0)
  877. return -ENOMEM;
  878. evlist->mmap_len = perf_evlist__mmap_size(pages);
  879. pr_debug("mmap size %zuB\n", evlist->mmap_len);
  880. mp.mask = evlist->mmap_len - page_size - 1;
  881. auxtrace_mmap_params__init(&mp.auxtrace_mp, evlist->mmap_len,
  882. auxtrace_pages, auxtrace_overwrite);
  883. evlist__for_each_entry(evlist, evsel) {
  884. if ((evsel->attr.read_format & PERF_FORMAT_ID) &&
  885. evsel->sample_id == NULL &&
  886. perf_evsel__alloc_id(evsel, cpu_map__nr(cpus), threads->nr) < 0)
  887. return -ENOMEM;
  888. }
  889. if (cpu_map__empty(cpus))
  890. return perf_evlist__mmap_per_thread(evlist, &mp);
  891. return perf_evlist__mmap_per_cpu(evlist, &mp);
  892. }
  893. int perf_evlist__mmap(struct perf_evlist *evlist, unsigned int pages)
  894. {
  895. return perf_evlist__mmap_ex(evlist, pages, 0, false);
  896. }
  897. int perf_evlist__create_maps(struct perf_evlist *evlist, struct target *target)
  898. {
  899. struct cpu_map *cpus;
  900. struct thread_map *threads;
  901. threads = thread_map__new_str(target->pid, target->tid, target->uid,
  902. target->per_thread);
  903. if (!threads)
  904. return -1;
  905. if (target__uses_dummy_map(target))
  906. cpus = cpu_map__dummy_new();
  907. else
  908. cpus = cpu_map__new(target->cpu_list);
  909. if (!cpus)
  910. goto out_delete_threads;
  911. evlist->has_user_cpus = !!target->cpu_list;
  912. perf_evlist__set_maps(evlist, cpus, threads);
  913. return 0;
  914. out_delete_threads:
  915. thread_map__put(threads);
  916. return -1;
  917. }
  918. void perf_evlist__set_maps(struct perf_evlist *evlist, struct cpu_map *cpus,
  919. struct thread_map *threads)
  920. {
  921. /*
  922. * Allow for the possibility that one or another of the maps isn't being
  923. * changed i.e. don't put it. Note we are assuming the maps that are
  924. * being applied are brand new and evlist is taking ownership of the
  925. * original reference count of 1. If that is not the case it is up to
  926. * the caller to increase the reference count.
  927. */
  928. if (cpus != evlist->cpus) {
  929. cpu_map__put(evlist->cpus);
  930. evlist->cpus = cpu_map__get(cpus);
  931. }
  932. if (threads != evlist->threads) {
  933. thread_map__put(evlist->threads);
  934. evlist->threads = thread_map__get(threads);
  935. }
  936. perf_evlist__propagate_maps(evlist);
  937. }
  938. void __perf_evlist__set_sample_bit(struct perf_evlist *evlist,
  939. enum perf_event_sample_format bit)
  940. {
  941. struct perf_evsel *evsel;
  942. evlist__for_each_entry(evlist, evsel)
  943. __perf_evsel__set_sample_bit(evsel, bit);
  944. }
  945. void __perf_evlist__reset_sample_bit(struct perf_evlist *evlist,
  946. enum perf_event_sample_format bit)
  947. {
  948. struct perf_evsel *evsel;
  949. evlist__for_each_entry(evlist, evsel)
  950. __perf_evsel__reset_sample_bit(evsel, bit);
  951. }
  952. int perf_evlist__apply_filters(struct perf_evlist *evlist, struct perf_evsel **err_evsel)
  953. {
  954. struct perf_evsel *evsel;
  955. int err = 0;
  956. evlist__for_each_entry(evlist, evsel) {
  957. if (evsel->filter == NULL)
  958. continue;
  959. /*
  960. * filters only work for tracepoint event, which doesn't have cpu limit.
  961. * So evlist and evsel should always be same.
  962. */
  963. err = perf_evsel__apply_filter(evsel, evsel->filter);
  964. if (err) {
  965. *err_evsel = evsel;
  966. break;
  967. }
  968. }
  969. return err;
  970. }
  971. int perf_evlist__set_filter(struct perf_evlist *evlist, const char *filter)
  972. {
  973. struct perf_evsel *evsel;
  974. int err = 0;
  975. evlist__for_each_entry(evlist, evsel) {
  976. if (evsel->attr.type != PERF_TYPE_TRACEPOINT)
  977. continue;
  978. err = perf_evsel__set_filter(evsel, filter);
  979. if (err)
  980. break;
  981. }
  982. return err;
  983. }
  984. int perf_evlist__set_filter_pids(struct perf_evlist *evlist, size_t npids, pid_t *pids)
  985. {
  986. char *filter;
  987. int ret = -1;
  988. size_t i;
  989. for (i = 0; i < npids; ++i) {
  990. if (i == 0) {
  991. if (asprintf(&filter, "common_pid != %d", pids[i]) < 0)
  992. return -1;
  993. } else {
  994. char *tmp;
  995. if (asprintf(&tmp, "%s && common_pid != %d", filter, pids[i]) < 0)
  996. goto out_free;
  997. free(filter);
  998. filter = tmp;
  999. }
  1000. }
  1001. ret = perf_evlist__set_filter(evlist, filter);
  1002. out_free:
  1003. free(filter);
  1004. return ret;
  1005. }
  1006. int perf_evlist__set_filter_pid(struct perf_evlist *evlist, pid_t pid)
  1007. {
  1008. return perf_evlist__set_filter_pids(evlist, 1, &pid);
  1009. }
  1010. bool perf_evlist__valid_sample_type(struct perf_evlist *evlist)
  1011. {
  1012. struct perf_evsel *pos;
  1013. if (evlist->nr_entries == 1)
  1014. return true;
  1015. if (evlist->id_pos < 0 || evlist->is_pos < 0)
  1016. return false;
  1017. evlist__for_each_entry(evlist, pos) {
  1018. if (pos->id_pos != evlist->id_pos ||
  1019. pos->is_pos != evlist->is_pos)
  1020. return false;
  1021. }
  1022. return true;
  1023. }
  1024. u64 __perf_evlist__combined_sample_type(struct perf_evlist *evlist)
  1025. {
  1026. struct perf_evsel *evsel;
  1027. if (evlist->combined_sample_type)
  1028. return evlist->combined_sample_type;
  1029. evlist__for_each_entry(evlist, evsel)
  1030. evlist->combined_sample_type |= evsel->attr.sample_type;
  1031. return evlist->combined_sample_type;
  1032. }
  1033. u64 perf_evlist__combined_sample_type(struct perf_evlist *evlist)
  1034. {
  1035. evlist->combined_sample_type = 0;
  1036. return __perf_evlist__combined_sample_type(evlist);
  1037. }
  1038. u64 perf_evlist__combined_branch_type(struct perf_evlist *evlist)
  1039. {
  1040. struct perf_evsel *evsel;
  1041. u64 branch_type = 0;
  1042. evlist__for_each_entry(evlist, evsel)
  1043. branch_type |= evsel->attr.branch_sample_type;
  1044. return branch_type;
  1045. }
  1046. bool perf_evlist__valid_read_format(struct perf_evlist *evlist)
  1047. {
  1048. struct perf_evsel *first = perf_evlist__first(evlist), *pos = first;
  1049. u64 read_format = first->attr.read_format;
  1050. u64 sample_type = first->attr.sample_type;
  1051. evlist__for_each_entry(evlist, pos) {
  1052. if (read_format != pos->attr.read_format)
  1053. return false;
  1054. }
  1055. /* PERF_SAMPLE_READ imples PERF_FORMAT_ID. */
  1056. if ((sample_type & PERF_SAMPLE_READ) &&
  1057. !(read_format & PERF_FORMAT_ID)) {
  1058. return false;
  1059. }
  1060. return true;
  1061. }
  1062. u64 perf_evlist__read_format(struct perf_evlist *evlist)
  1063. {
  1064. struct perf_evsel *first = perf_evlist__first(evlist);
  1065. return first->attr.read_format;
  1066. }
  1067. u16 perf_evlist__id_hdr_size(struct perf_evlist *evlist)
  1068. {
  1069. struct perf_evsel *first = perf_evlist__first(evlist);
  1070. struct perf_sample *data;
  1071. u64 sample_type;
  1072. u16 size = 0;
  1073. if (!first->attr.sample_id_all)
  1074. goto out;
  1075. sample_type = first->attr.sample_type;
  1076. if (sample_type & PERF_SAMPLE_TID)
  1077. size += sizeof(data->tid) * 2;
  1078. if (sample_type & PERF_SAMPLE_TIME)
  1079. size += sizeof(data->time);
  1080. if (sample_type & PERF_SAMPLE_ID)
  1081. size += sizeof(data->id);
  1082. if (sample_type & PERF_SAMPLE_STREAM_ID)
  1083. size += sizeof(data->stream_id);
  1084. if (sample_type & PERF_SAMPLE_CPU)
  1085. size += sizeof(data->cpu) * 2;
  1086. if (sample_type & PERF_SAMPLE_IDENTIFIER)
  1087. size += sizeof(data->id);
  1088. out:
  1089. return size;
  1090. }
  1091. bool perf_evlist__valid_sample_id_all(struct perf_evlist *evlist)
  1092. {
  1093. struct perf_evsel *first = perf_evlist__first(evlist), *pos = first;
  1094. evlist__for_each_entry_continue(evlist, pos) {
  1095. if (first->attr.sample_id_all != pos->attr.sample_id_all)
  1096. return false;
  1097. }
  1098. return true;
  1099. }
  1100. bool perf_evlist__sample_id_all(struct perf_evlist *evlist)
  1101. {
  1102. struct perf_evsel *first = perf_evlist__first(evlist);
  1103. return first->attr.sample_id_all;
  1104. }
  1105. void perf_evlist__set_selected(struct perf_evlist *evlist,
  1106. struct perf_evsel *evsel)
  1107. {
  1108. evlist->selected = evsel;
  1109. }
  1110. void perf_evlist__close(struct perf_evlist *evlist)
  1111. {
  1112. struct perf_evsel *evsel;
  1113. evlist__for_each_entry_reverse(evlist, evsel)
  1114. perf_evsel__close(evsel);
  1115. }
  1116. static int perf_evlist__create_syswide_maps(struct perf_evlist *evlist)
  1117. {
  1118. struct cpu_map *cpus;
  1119. struct thread_map *threads;
  1120. int err = -ENOMEM;
  1121. /*
  1122. * Try reading /sys/devices/system/cpu/online to get
  1123. * an all cpus map.
  1124. *
  1125. * FIXME: -ENOMEM is the best we can do here, the cpu_map
  1126. * code needs an overhaul to properly forward the
  1127. * error, and we may not want to do that fallback to a
  1128. * default cpu identity map :-\
  1129. */
  1130. cpus = cpu_map__new(NULL);
  1131. if (!cpus)
  1132. goto out;
  1133. threads = thread_map__new_dummy();
  1134. if (!threads)
  1135. goto out_put;
  1136. perf_evlist__set_maps(evlist, cpus, threads);
  1137. out:
  1138. return err;
  1139. out_put:
  1140. cpu_map__put(cpus);
  1141. goto out;
  1142. }
  1143. int perf_evlist__open(struct perf_evlist *evlist)
  1144. {
  1145. struct perf_evsel *evsel;
  1146. int err;
  1147. /*
  1148. * Default: one fd per CPU, all threads, aka systemwide
  1149. * as sys_perf_event_open(cpu = -1, thread = -1) is EINVAL
  1150. */
  1151. if (evlist->threads == NULL && evlist->cpus == NULL) {
  1152. err = perf_evlist__create_syswide_maps(evlist);
  1153. if (err < 0)
  1154. goto out_err;
  1155. }
  1156. perf_evlist__update_id_pos(evlist);
  1157. evlist__for_each_entry(evlist, evsel) {
  1158. err = perf_evsel__open(evsel, evsel->cpus, evsel->threads);
  1159. if (err < 0)
  1160. goto out_err;
  1161. }
  1162. return 0;
  1163. out_err:
  1164. perf_evlist__close(evlist);
  1165. errno = -err;
  1166. return err;
  1167. }
  1168. int perf_evlist__prepare_workload(struct perf_evlist *evlist, struct target *target,
  1169. const char *argv[], bool pipe_output,
  1170. void (*exec_error)(int signo, siginfo_t *info, void *ucontext))
  1171. {
  1172. int child_ready_pipe[2], go_pipe[2];
  1173. char bf;
  1174. if (pipe(child_ready_pipe) < 0) {
  1175. perror("failed to create 'ready' pipe");
  1176. return -1;
  1177. }
  1178. if (pipe(go_pipe) < 0) {
  1179. perror("failed to create 'go' pipe");
  1180. goto out_close_ready_pipe;
  1181. }
  1182. evlist->workload.pid = fork();
  1183. if (evlist->workload.pid < 0) {
  1184. perror("failed to fork");
  1185. goto out_close_pipes;
  1186. }
  1187. if (!evlist->workload.pid) {
  1188. int ret;
  1189. if (pipe_output)
  1190. dup2(2, 1);
  1191. signal(SIGTERM, SIG_DFL);
  1192. close(child_ready_pipe[0]);
  1193. close(go_pipe[1]);
  1194. fcntl(go_pipe[0], F_SETFD, FD_CLOEXEC);
  1195. /*
  1196. * Tell the parent we're ready to go
  1197. */
  1198. close(child_ready_pipe[1]);
  1199. /*
  1200. * Wait until the parent tells us to go.
  1201. */
  1202. ret = read(go_pipe[0], &bf, 1);
  1203. /*
  1204. * The parent will ask for the execvp() to be performed by
  1205. * writing exactly one byte, in workload.cork_fd, usually via
  1206. * perf_evlist__start_workload().
  1207. *
  1208. * For cancelling the workload without actually running it,
  1209. * the parent will just close workload.cork_fd, without writing
  1210. * anything, i.e. read will return zero and we just exit()
  1211. * here.
  1212. */
  1213. if (ret != 1) {
  1214. if (ret == -1)
  1215. perror("unable to read pipe");
  1216. exit(ret);
  1217. }
  1218. execvp(argv[0], (char **)argv);
  1219. if (exec_error) {
  1220. union sigval val;
  1221. val.sival_int = errno;
  1222. if (sigqueue(getppid(), SIGUSR1, val))
  1223. perror(argv[0]);
  1224. } else
  1225. perror(argv[0]);
  1226. exit(-1);
  1227. }
  1228. if (exec_error) {
  1229. struct sigaction act = {
  1230. .sa_flags = SA_SIGINFO,
  1231. .sa_sigaction = exec_error,
  1232. };
  1233. sigaction(SIGUSR1, &act, NULL);
  1234. }
  1235. if (target__none(target)) {
  1236. if (evlist->threads == NULL) {
  1237. fprintf(stderr, "FATAL: evlist->threads need to be set at this point (%s:%d).\n",
  1238. __func__, __LINE__);
  1239. goto out_close_pipes;
  1240. }
  1241. thread_map__set_pid(evlist->threads, 0, evlist->workload.pid);
  1242. }
  1243. close(child_ready_pipe[1]);
  1244. close(go_pipe[0]);
  1245. /*
  1246. * wait for child to settle
  1247. */
  1248. if (read(child_ready_pipe[0], &bf, 1) == -1) {
  1249. perror("unable to read pipe");
  1250. goto out_close_pipes;
  1251. }
  1252. fcntl(go_pipe[1], F_SETFD, FD_CLOEXEC);
  1253. evlist->workload.cork_fd = go_pipe[1];
  1254. close(child_ready_pipe[0]);
  1255. return 0;
  1256. out_close_pipes:
  1257. close(go_pipe[0]);
  1258. close(go_pipe[1]);
  1259. out_close_ready_pipe:
  1260. close(child_ready_pipe[0]);
  1261. close(child_ready_pipe[1]);
  1262. return -1;
  1263. }
  1264. int perf_evlist__start_workload(struct perf_evlist *evlist)
  1265. {
  1266. if (evlist->workload.cork_fd > 0) {
  1267. char bf = 0;
  1268. int ret;
  1269. /*
  1270. * Remove the cork, let it rip!
  1271. */
  1272. ret = write(evlist->workload.cork_fd, &bf, 1);
  1273. if (ret < 0)
  1274. perror("unable to write to pipe");
  1275. close(evlist->workload.cork_fd);
  1276. return ret;
  1277. }
  1278. return 0;
  1279. }
  1280. int perf_evlist__parse_sample(struct perf_evlist *evlist, union perf_event *event,
  1281. struct perf_sample *sample)
  1282. {
  1283. struct perf_evsel *evsel = perf_evlist__event2evsel(evlist, event);
  1284. if (!evsel)
  1285. return -EFAULT;
  1286. return perf_evsel__parse_sample(evsel, event, sample);
  1287. }
  1288. int perf_evlist__parse_sample_timestamp(struct perf_evlist *evlist,
  1289. union perf_event *event,
  1290. u64 *timestamp)
  1291. {
  1292. struct perf_evsel *evsel = perf_evlist__event2evsel(evlist, event);
  1293. if (!evsel)
  1294. return -EFAULT;
  1295. return perf_evsel__parse_sample_timestamp(evsel, event, timestamp);
  1296. }
  1297. size_t perf_evlist__fprintf(struct perf_evlist *evlist, FILE *fp)
  1298. {
  1299. struct perf_evsel *evsel;
  1300. size_t printed = 0;
  1301. evlist__for_each_entry(evlist, evsel) {
  1302. printed += fprintf(fp, "%s%s", evsel->idx ? ", " : "",
  1303. perf_evsel__name(evsel));
  1304. }
  1305. return printed + fprintf(fp, "\n");
  1306. }
  1307. int perf_evlist__strerror_open(struct perf_evlist *evlist,
  1308. int err, char *buf, size_t size)
  1309. {
  1310. int printed, value;
  1311. char sbuf[STRERR_BUFSIZE], *emsg = str_error_r(err, sbuf, sizeof(sbuf));
  1312. switch (err) {
  1313. case EACCES:
  1314. case EPERM:
  1315. printed = scnprintf(buf, size,
  1316. "Error:\t%s.\n"
  1317. "Hint:\tCheck /proc/sys/kernel/perf_event_paranoid setting.", emsg);
  1318. value = perf_event_paranoid();
  1319. printed += scnprintf(buf + printed, size - printed, "\nHint:\t");
  1320. if (value >= 2) {
  1321. printed += scnprintf(buf + printed, size - printed,
  1322. "For your workloads it needs to be <= 1\nHint:\t");
  1323. }
  1324. printed += scnprintf(buf + printed, size - printed,
  1325. "For system wide tracing it needs to be set to -1.\n");
  1326. printed += scnprintf(buf + printed, size - printed,
  1327. "Hint:\tTry: 'sudo sh -c \"echo -1 > /proc/sys/kernel/perf_event_paranoid\"'\n"
  1328. "Hint:\tThe current value is %d.", value);
  1329. break;
  1330. case EINVAL: {
  1331. struct perf_evsel *first = perf_evlist__first(evlist);
  1332. int max_freq;
  1333. if (sysctl__read_int("kernel/perf_event_max_sample_rate", &max_freq) < 0)
  1334. goto out_default;
  1335. if (first->attr.sample_freq < (u64)max_freq)
  1336. goto out_default;
  1337. printed = scnprintf(buf, size,
  1338. "Error:\t%s.\n"
  1339. "Hint:\tCheck /proc/sys/kernel/perf_event_max_sample_rate.\n"
  1340. "Hint:\tThe current value is %d and %" PRIu64 " is being requested.",
  1341. emsg, max_freq, first->attr.sample_freq);
  1342. break;
  1343. }
  1344. default:
  1345. out_default:
  1346. scnprintf(buf, size, "%s", emsg);
  1347. break;
  1348. }
  1349. return 0;
  1350. }
  1351. int perf_evlist__strerror_mmap(struct perf_evlist *evlist, int err, char *buf, size_t size)
  1352. {
  1353. char sbuf[STRERR_BUFSIZE], *emsg = str_error_r(err, sbuf, sizeof(sbuf));
  1354. int pages_attempted = evlist->mmap_len / 1024, pages_max_per_user, printed = 0;
  1355. switch (err) {
  1356. case EPERM:
  1357. sysctl__read_int("kernel/perf_event_mlock_kb", &pages_max_per_user);
  1358. printed += scnprintf(buf + printed, size - printed,
  1359. "Error:\t%s.\n"
  1360. "Hint:\tCheck /proc/sys/kernel/perf_event_mlock_kb (%d kB) setting.\n"
  1361. "Hint:\tTried using %zd kB.\n",
  1362. emsg, pages_max_per_user, pages_attempted);
  1363. if (pages_attempted >= pages_max_per_user) {
  1364. printed += scnprintf(buf + printed, size - printed,
  1365. "Hint:\tTry 'sudo sh -c \"echo %d > /proc/sys/kernel/perf_event_mlock_kb\"', or\n",
  1366. pages_max_per_user + pages_attempted);
  1367. }
  1368. printed += scnprintf(buf + printed, size - printed,
  1369. "Hint:\tTry using a smaller -m/--mmap-pages value.");
  1370. break;
  1371. default:
  1372. scnprintf(buf, size, "%s", emsg);
  1373. break;
  1374. }
  1375. return 0;
  1376. }
  1377. void perf_evlist__to_front(struct perf_evlist *evlist,
  1378. struct perf_evsel *move_evsel)
  1379. {
  1380. struct perf_evsel *evsel, *n;
  1381. LIST_HEAD(move);
  1382. if (move_evsel == perf_evlist__first(evlist))
  1383. return;
  1384. evlist__for_each_entry_safe(evlist, n, evsel) {
  1385. if (evsel->leader == move_evsel->leader)
  1386. list_move_tail(&evsel->node, &move);
  1387. }
  1388. list_splice(&move, &evlist->entries);
  1389. }
  1390. void perf_evlist__set_tracking_event(struct perf_evlist *evlist,
  1391. struct perf_evsel *tracking_evsel)
  1392. {
  1393. struct perf_evsel *evsel;
  1394. if (tracking_evsel->tracking)
  1395. return;
  1396. evlist__for_each_entry(evlist, evsel) {
  1397. if (evsel != tracking_evsel)
  1398. evsel->tracking = false;
  1399. }
  1400. tracking_evsel->tracking = true;
  1401. }
  1402. struct perf_evsel *
  1403. perf_evlist__find_evsel_by_str(struct perf_evlist *evlist,
  1404. const char *str)
  1405. {
  1406. struct perf_evsel *evsel;
  1407. evlist__for_each_entry(evlist, evsel) {
  1408. if (!evsel->name)
  1409. continue;
  1410. if (strcmp(str, evsel->name) == 0)
  1411. return evsel;
  1412. }
  1413. return NULL;
  1414. }
  1415. void perf_evlist__toggle_bkw_mmap(struct perf_evlist *evlist,
  1416. enum bkw_mmap_state state)
  1417. {
  1418. enum bkw_mmap_state old_state = evlist->bkw_mmap_state;
  1419. enum action {
  1420. NONE,
  1421. PAUSE,
  1422. RESUME,
  1423. } action = NONE;
  1424. if (!evlist->overwrite_mmap)
  1425. return;
  1426. switch (old_state) {
  1427. case BKW_MMAP_NOTREADY: {
  1428. if (state != BKW_MMAP_RUNNING)
  1429. goto state_err;;
  1430. break;
  1431. }
  1432. case BKW_MMAP_RUNNING: {
  1433. if (state != BKW_MMAP_DATA_PENDING)
  1434. goto state_err;
  1435. action = PAUSE;
  1436. break;
  1437. }
  1438. case BKW_MMAP_DATA_PENDING: {
  1439. if (state != BKW_MMAP_EMPTY)
  1440. goto state_err;
  1441. break;
  1442. }
  1443. case BKW_MMAP_EMPTY: {
  1444. if (state != BKW_MMAP_RUNNING)
  1445. goto state_err;
  1446. action = RESUME;
  1447. break;
  1448. }
  1449. default:
  1450. WARN_ONCE(1, "Shouldn't get there\n");
  1451. }
  1452. evlist->bkw_mmap_state = state;
  1453. switch (action) {
  1454. case PAUSE:
  1455. perf_evlist__pause(evlist);
  1456. break;
  1457. case RESUME:
  1458. perf_evlist__resume(evlist);
  1459. break;
  1460. case NONE:
  1461. default:
  1462. break;
  1463. }
  1464. state_err:
  1465. return;
  1466. }
  1467. bool perf_evlist__exclude_kernel(struct perf_evlist *evlist)
  1468. {
  1469. struct perf_evsel *evsel;
  1470. evlist__for_each_entry(evlist, evsel) {
  1471. if (!evsel->attr.exclude_kernel)
  1472. return false;
  1473. }
  1474. return true;
  1475. }