perf record: Add clockid parameter
[deliverable/linux.git] / tools / perf / util / header.c
CommitLineData
a9072bc0 1#include "util.h"
7c6a1c65 2#include <sys/types.h>
ba21594c 3#include <byteswap.h>
7c6a1c65
PZ
4#include <unistd.h>
5#include <stdio.h>
6#include <stdlib.h>
8671dab9 7#include <linux/list.h>
ba21594c 8#include <linux/kernel.h>
b1e5a9be 9#include <linux/bitops.h>
fbe96f29 10#include <sys/utsname.h>
7c6a1c65 11
361c99a6 12#include "evlist.h"
a91e5431 13#include "evsel.h"
7c6a1c65 14#include "header.h"
03456a15
FW
15#include "../perf.h"
16#include "trace-event.h"
301a0b02 17#include "session.h"
8671dab9 18#include "symbol.h"
4778d2e4 19#include "debug.h"
fbe96f29 20#include "cpumap.h"
50a9667c 21#include "pmu.h"
7dbf4dcf 22#include "vdso.h"
a1ae5655 23#include "strbuf.h"
ebb296c2 24#include "build-id.h"
cc9784bd 25#include "data.h"
7c6a1c65 26
fbe96f29
SE
27static u32 header_argc;
28static const char **header_argv;
29
73323f54
SE
30/*
31 * magic2 = "PERFILE2"
32 * must be a numerical value to let the endianness
33 * determine the memory layout. That way we are able
34 * to detect endianness when reading the perf.data file
35 * back.
36 *
37 * we check for legacy (PERFFILE) format.
38 */
39static const char *__perf_magic1 = "PERFFILE";
40static const u64 __perf_magic2 = 0x32454c4946524550ULL;
41static const u64 __perf_magic2_sw = 0x50455246494c4532ULL;
7c6a1c65 42
73323f54 43#define PERF_MAGIC __perf_magic2
7c6a1c65 44
7c6a1c65 45struct perf_file_attr {
cdd6c482 46 struct perf_event_attr attr;
7c6a1c65
PZ
47 struct perf_file_section ids;
48};
49
1c0b04d1 50void perf_header__set_feat(struct perf_header *header, int feat)
8d06367f 51{
1c0b04d1 52 set_bit(feat, header->adds_features);
8d06367f
ACM
53}
54
1c0b04d1 55void perf_header__clear_feat(struct perf_header *header, int feat)
baa2f6ce 56{
1c0b04d1 57 clear_bit(feat, header->adds_features);
baa2f6ce
ACM
58}
59
1c0b04d1 60bool perf_header__has_feat(const struct perf_header *header, int feat)
8d06367f 61{
1c0b04d1 62 return test_bit(feat, header->adds_features);
8d06367f
ACM
63}
64
3726cc75 65static int do_write(int fd, const void *buf, size_t size)
7c6a1c65
PZ
66{
67 while (size) {
68 int ret = write(fd, buf, size);
69
70 if (ret < 0)
d5eed904 71 return -errno;
7c6a1c65
PZ
72
73 size -= ret;
74 buf += ret;
75 }
3726cc75
ACM
76
77 return 0;
7c6a1c65
PZ
78}
79
e195fac8 80int write_padded(int fd, const void *bf, size_t count, size_t count_aligned)
f92cb24c
ACM
81{
82 static const char zero_buf[NAME_ALIGN];
83 int err = do_write(fd, bf, count);
84
85 if (!err)
86 err = do_write(fd, zero_buf, count_aligned - count);
87
88 return err;
89}
90
fbe96f29
SE
91static int do_write_string(int fd, const char *str)
92{
93 u32 len, olen;
94 int ret;
95
96 olen = strlen(str) + 1;
9ac3e487 97 len = PERF_ALIGN(olen, NAME_ALIGN);
fbe96f29
SE
98
99 /* write len, incl. \0 */
100 ret = do_write(fd, &len, sizeof(len));
101 if (ret < 0)
102 return ret;
103
104 return write_padded(fd, str, olen, len);
105}
106
107static char *do_read_string(int fd, struct perf_header *ph)
108{
109 ssize_t sz, ret;
110 u32 len;
111 char *buf;
112
5323f60c 113 sz = readn(fd, &len, sizeof(len));
fbe96f29
SE
114 if (sz < (ssize_t)sizeof(len))
115 return NULL;
116
117 if (ph->needs_swap)
118 len = bswap_32(len);
119
120 buf = malloc(len);
121 if (!buf)
122 return NULL;
123
5323f60c 124 ret = readn(fd, buf, len);
fbe96f29
SE
125 if (ret == (ssize_t)len) {
126 /*
127 * strings are padded by zeroes
128 * thus the actual strlen of buf
129 * may be less than len
130 */
131 return buf;
132 }
133
134 free(buf);
135 return NULL;
136}
137
138int
139perf_header__set_cmdline(int argc, const char **argv)
140{
141 int i;
142
56e6f602
DA
143 /*
144 * If header_argv has already been set, do not override it.
145 * This allows a command to set the cmdline, parse args and
146 * then call another builtin function that implements a
147 * command -- e.g, cmd_kvm calling cmd_record.
148 */
149 if (header_argv)
150 return 0;
151
fbe96f29
SE
152 header_argc = (u32)argc;
153
154 /* do not include NULL termination */
155 header_argv = calloc(argc, sizeof(char *));
156 if (!header_argv)
157 return -ENOMEM;
158
159 /*
160 * must copy argv contents because it gets moved
161 * around during option parsing
162 */
163 for (i = 0; i < argc ; i++)
164 header_argv[i] = argv[i];
165
166 return 0;
167}
168
1d037ca1 169static int write_tracing_data(int fd, struct perf_header *h __maybe_unused,
fbe96f29
SE
170 struct perf_evlist *evlist)
171{
172 return read_tracing_data(fd, &evlist->entries);
173}
174
175
176static int write_build_id(int fd, struct perf_header *h,
1d037ca1 177 struct perf_evlist *evlist __maybe_unused)
fbe96f29
SE
178{
179 struct perf_session *session;
180 int err;
181
182 session = container_of(h, struct perf_session, header);
183
e20960c0
RR
184 if (!perf_session__read_build_ids(session, true))
185 return -1;
186
714c9c4a 187 err = perf_session__write_buildid_table(session, fd);
fbe96f29
SE
188 if (err < 0) {
189 pr_debug("failed to write buildid table\n");
190 return err;
191 }
73c5d224 192 perf_session__cache_build_ids(session);
fbe96f29
SE
193
194 return 0;
195}
196
1d037ca1
IT
197static int write_hostname(int fd, struct perf_header *h __maybe_unused,
198 struct perf_evlist *evlist __maybe_unused)
fbe96f29
SE
199{
200 struct utsname uts;
201 int ret;
202
203 ret = uname(&uts);
204 if (ret < 0)
205 return -1;
206
207 return do_write_string(fd, uts.nodename);
208}
209
1d037ca1
IT
210static int write_osrelease(int fd, struct perf_header *h __maybe_unused,
211 struct perf_evlist *evlist __maybe_unused)
fbe96f29
SE
212{
213 struct utsname uts;
214 int ret;
215
216 ret = uname(&uts);
217 if (ret < 0)
218 return -1;
219
220 return do_write_string(fd, uts.release);
221}
222
1d037ca1
IT
223static int write_arch(int fd, struct perf_header *h __maybe_unused,
224 struct perf_evlist *evlist __maybe_unused)
fbe96f29
SE
225{
226 struct utsname uts;
227 int ret;
228
229 ret = uname(&uts);
230 if (ret < 0)
231 return -1;
232
233 return do_write_string(fd, uts.machine);
234}
235
1d037ca1
IT
236static int write_version(int fd, struct perf_header *h __maybe_unused,
237 struct perf_evlist *evlist __maybe_unused)
fbe96f29
SE
238{
239 return do_write_string(fd, perf_version_string);
240}
241
493c3031 242static int __write_cpudesc(int fd, const char *cpuinfo_proc)
fbe96f29 243{
fbe96f29
SE
244 FILE *file;
245 char *buf = NULL;
246 char *s, *p;
493c3031 247 const char *search = cpuinfo_proc;
fbe96f29
SE
248 size_t len = 0;
249 int ret = -1;
250
251 if (!search)
252 return -1;
253
254 file = fopen("/proc/cpuinfo", "r");
255 if (!file)
256 return -1;
257
258 while (getline(&buf, &len, file) > 0) {
259 ret = strncmp(buf, search, strlen(search));
260 if (!ret)
261 break;
262 }
263
ed307758
WN
264 if (ret) {
265 ret = -1;
fbe96f29 266 goto done;
ed307758 267 }
fbe96f29
SE
268
269 s = buf;
270
271 p = strchr(buf, ':');
272 if (p && *(p+1) == ' ' && *(p+2))
273 s = p + 2;
274 p = strchr(s, '\n');
275 if (p)
276 *p = '\0';
277
278 /* squash extra space characters (branding string) */
279 p = s;
280 while (*p) {
281 if (isspace(*p)) {
282 char *r = p + 1;
283 char *q = r;
284 *p = ' ';
285 while (*q && isspace(*q))
286 q++;
287 if (q != (p+1))
288 while ((*r++ = *q++));
289 }
290 p++;
291 }
292 ret = do_write_string(fd, s);
293done:
294 free(buf);
295 fclose(file);
296 return ret;
297}
298
493c3031
WN
299static int write_cpudesc(int fd, struct perf_header *h __maybe_unused,
300 struct perf_evlist *evlist __maybe_unused)
301{
302#ifndef CPUINFO_PROC
303#define CPUINFO_PROC {"model name", }
304#endif
305 const char *cpuinfo_procs[] = CPUINFO_PROC;
306 unsigned int i;
307
308 for (i = 0; i < ARRAY_SIZE(cpuinfo_procs); i++) {
309 int ret;
310 ret = __write_cpudesc(fd, cpuinfo_procs[i]);
311 if (ret >= 0)
312 return ret;
313 }
314 return -1;
315}
316
317
1d037ca1
IT
318static int write_nrcpus(int fd, struct perf_header *h __maybe_unused,
319 struct perf_evlist *evlist __maybe_unused)
fbe96f29
SE
320{
321 long nr;
322 u32 nrc, nra;
323 int ret;
324
325 nr = sysconf(_SC_NPROCESSORS_CONF);
326 if (nr < 0)
327 return -1;
328
329 nrc = (u32)(nr & UINT_MAX);
330
331 nr = sysconf(_SC_NPROCESSORS_ONLN);
332 if (nr < 0)
333 return -1;
334
335 nra = (u32)(nr & UINT_MAX);
336
337 ret = do_write(fd, &nrc, sizeof(nrc));
338 if (ret < 0)
339 return ret;
340
341 return do_write(fd, &nra, sizeof(nra));
342}
343
1d037ca1 344static int write_event_desc(int fd, struct perf_header *h __maybe_unused,
fbe96f29
SE
345 struct perf_evlist *evlist)
346{
6606f873 347 struct perf_evsel *evsel;
74ba9e11 348 u32 nre, nri, sz;
fbe96f29
SE
349 int ret;
350
74ba9e11 351 nre = evlist->nr_entries;
fbe96f29
SE
352
353 /*
354 * write number of events
355 */
356 ret = do_write(fd, &nre, sizeof(nre));
357 if (ret < 0)
358 return ret;
359
360 /*
361 * size of perf_event_attr struct
362 */
6606f873 363 sz = (u32)sizeof(evsel->attr);
fbe96f29
SE
364 ret = do_write(fd, &sz, sizeof(sz));
365 if (ret < 0)
366 return ret;
367
0050f7aa 368 evlist__for_each(evlist, evsel) {
6606f873 369 ret = do_write(fd, &evsel->attr, sz);
fbe96f29
SE
370 if (ret < 0)
371 return ret;
372 /*
373 * write number of unique id per event
374 * there is one id per instance of an event
375 *
376 * copy into an nri to be independent of the
377 * type of ids,
378 */
6606f873 379 nri = evsel->ids;
fbe96f29
SE
380 ret = do_write(fd, &nri, sizeof(nri));
381 if (ret < 0)
382 return ret;
383
384 /*
385 * write event string as passed on cmdline
386 */
6606f873 387 ret = do_write_string(fd, perf_evsel__name(evsel));
fbe96f29
SE
388 if (ret < 0)
389 return ret;
390 /*
391 * write unique ids for this event
392 */
6606f873 393 ret = do_write(fd, evsel->id, evsel->ids * sizeof(u64));
fbe96f29
SE
394 if (ret < 0)
395 return ret;
396 }
397 return 0;
398}
399
1d037ca1
IT
400static int write_cmdline(int fd, struct perf_header *h __maybe_unused,
401 struct perf_evlist *evlist __maybe_unused)
fbe96f29
SE
402{
403 char buf[MAXPATHLEN];
404 char proc[32];
405 u32 i, n;
406 int ret;
407
408 /*
409 * actual atual path to perf binary
410 */
411 sprintf(proc, "/proc/%d/exe", getpid());
412 ret = readlink(proc, buf, sizeof(buf));
413 if (ret <= 0)
414 return -1;
415
416 /* readlink() does not add null termination */
417 buf[ret] = '\0';
418
419 /* account for binary path */
420 n = header_argc + 1;
421
422 ret = do_write(fd, &n, sizeof(n));
423 if (ret < 0)
424 return ret;
425
426 ret = do_write_string(fd, buf);
427 if (ret < 0)
428 return ret;
429
430 for (i = 0 ; i < header_argc; i++) {
431 ret = do_write_string(fd, header_argv[i]);
432 if (ret < 0)
433 return ret;
434 }
435 return 0;
436}
437
438#define CORE_SIB_FMT \
439 "/sys/devices/system/cpu/cpu%d/topology/core_siblings_list"
440#define THRD_SIB_FMT \
441 "/sys/devices/system/cpu/cpu%d/topology/thread_siblings_list"
442
443struct cpu_topo {
444 u32 core_sib;
445 u32 thread_sib;
446 char **core_siblings;
447 char **thread_siblings;
448};
449
450static int build_cpu_topo(struct cpu_topo *tp, int cpu)
451{
452 FILE *fp;
453 char filename[MAXPATHLEN];
454 char *buf = NULL, *p;
455 size_t len = 0;
c5885749 456 ssize_t sret;
fbe96f29
SE
457 u32 i = 0;
458 int ret = -1;
459
460 sprintf(filename, CORE_SIB_FMT, cpu);
461 fp = fopen(filename, "r");
462 if (!fp)
c5885749 463 goto try_threads;
fbe96f29 464
c5885749 465 sret = getline(&buf, &len, fp);
fbe96f29 466 fclose(fp);
c5885749
SE
467 if (sret <= 0)
468 goto try_threads;
fbe96f29
SE
469
470 p = strchr(buf, '\n');
471 if (p)
472 *p = '\0';
473
474 for (i = 0; i < tp->core_sib; i++) {
475 if (!strcmp(buf, tp->core_siblings[i]))
476 break;
477 }
478 if (i == tp->core_sib) {
479 tp->core_siblings[i] = buf;
480 tp->core_sib++;
481 buf = NULL;
482 len = 0;
483 }
c5885749 484 ret = 0;
fbe96f29 485
c5885749 486try_threads:
fbe96f29
SE
487 sprintf(filename, THRD_SIB_FMT, cpu);
488 fp = fopen(filename, "r");
489 if (!fp)
490 goto done;
491
492 if (getline(&buf, &len, fp) <= 0)
493 goto done;
494
495 p = strchr(buf, '\n');
496 if (p)
497 *p = '\0';
498
499 for (i = 0; i < tp->thread_sib; i++) {
500 if (!strcmp(buf, tp->thread_siblings[i]))
501 break;
502 }
503 if (i == tp->thread_sib) {
504 tp->thread_siblings[i] = buf;
505 tp->thread_sib++;
506 buf = NULL;
507 }
508 ret = 0;
509done:
510 if(fp)
511 fclose(fp);
512 free(buf);
513 return ret;
514}
515
516static void free_cpu_topo(struct cpu_topo *tp)
517{
518 u32 i;
519
520 if (!tp)
521 return;
522
523 for (i = 0 ; i < tp->core_sib; i++)
74cf249d 524 zfree(&tp->core_siblings[i]);
fbe96f29
SE
525
526 for (i = 0 ; i < tp->thread_sib; i++)
74cf249d 527 zfree(&tp->thread_siblings[i]);
fbe96f29
SE
528
529 free(tp);
530}
531
532static struct cpu_topo *build_cpu_topology(void)
533{
534 struct cpu_topo *tp;
535 void *addr;
536 u32 nr, i;
537 size_t sz;
538 long ncpus;
539 int ret = -1;
540
541 ncpus = sysconf(_SC_NPROCESSORS_CONF);
542 if (ncpus < 0)
543 return NULL;
544
545 nr = (u32)(ncpus & UINT_MAX);
546
547 sz = nr * sizeof(char *);
548
549 addr = calloc(1, sizeof(*tp) + 2 * sz);
550 if (!addr)
551 return NULL;
552
553 tp = addr;
554
555 addr += sizeof(*tp);
556 tp->core_siblings = addr;
557 addr += sz;
558 tp->thread_siblings = addr;
559
560 for (i = 0; i < nr; i++) {
561 ret = build_cpu_topo(tp, i);
562 if (ret < 0)
563 break;
564 }
565 if (ret) {
566 free_cpu_topo(tp);
567 tp = NULL;
568 }
569 return tp;
570}
571
1d037ca1
IT
572static int write_cpu_topology(int fd, struct perf_header *h __maybe_unused,
573 struct perf_evlist *evlist __maybe_unused)
fbe96f29
SE
574{
575 struct cpu_topo *tp;
576 u32 i;
577 int ret;
578
579 tp = build_cpu_topology();
580 if (!tp)
581 return -1;
582
583 ret = do_write(fd, &tp->core_sib, sizeof(tp->core_sib));
584 if (ret < 0)
585 goto done;
586
587 for (i = 0; i < tp->core_sib; i++) {
588 ret = do_write_string(fd, tp->core_siblings[i]);
589 if (ret < 0)
590 goto done;
591 }
592 ret = do_write(fd, &tp->thread_sib, sizeof(tp->thread_sib));
593 if (ret < 0)
594 goto done;
595
596 for (i = 0; i < tp->thread_sib; i++) {
597 ret = do_write_string(fd, tp->thread_siblings[i]);
598 if (ret < 0)
599 break;
600 }
601done:
602 free_cpu_topo(tp);
603 return ret;
604}
605
606
607
1d037ca1
IT
608static int write_total_mem(int fd, struct perf_header *h __maybe_unused,
609 struct perf_evlist *evlist __maybe_unused)
fbe96f29
SE
610{
611 char *buf = NULL;
612 FILE *fp;
613 size_t len = 0;
614 int ret = -1, n;
615 uint64_t mem;
616
617 fp = fopen("/proc/meminfo", "r");
618 if (!fp)
619 return -1;
620
621 while (getline(&buf, &len, fp) > 0) {
622 ret = strncmp(buf, "MemTotal:", 9);
623 if (!ret)
624 break;
625 }
626 if (!ret) {
627 n = sscanf(buf, "%*s %"PRIu64, &mem);
628 if (n == 1)
629 ret = do_write(fd, &mem, sizeof(mem));
ed307758
WN
630 } else
631 ret = -1;
fbe96f29
SE
632 free(buf);
633 fclose(fp);
634 return ret;
635}
636
637static int write_topo_node(int fd, int node)
638{
639 char str[MAXPATHLEN];
640 char field[32];
641 char *buf = NULL, *p;
642 size_t len = 0;
643 FILE *fp;
644 u64 mem_total, mem_free, mem;
645 int ret = -1;
646
647 sprintf(str, "/sys/devices/system/node/node%d/meminfo", node);
648 fp = fopen(str, "r");
649 if (!fp)
650 return -1;
651
652 while (getline(&buf, &len, fp) > 0) {
653 /* skip over invalid lines */
654 if (!strchr(buf, ':'))
655 continue;
a761a2d8 656 if (sscanf(buf, "%*s %*d %31s %"PRIu64, field, &mem) != 2)
fbe96f29
SE
657 goto done;
658 if (!strcmp(field, "MemTotal:"))
659 mem_total = mem;
660 if (!strcmp(field, "MemFree:"))
661 mem_free = mem;
662 }
663
664 fclose(fp);
5809fde0 665 fp = NULL;
fbe96f29
SE
666
667 ret = do_write(fd, &mem_total, sizeof(u64));
668 if (ret)
669 goto done;
670
671 ret = do_write(fd, &mem_free, sizeof(u64));
672 if (ret)
673 goto done;
674
675 ret = -1;
676 sprintf(str, "/sys/devices/system/node/node%d/cpulist", node);
677
678 fp = fopen(str, "r");
679 if (!fp)
680 goto done;
681
682 if (getline(&buf, &len, fp) <= 0)
683 goto done;
684
685 p = strchr(buf, '\n');
686 if (p)
687 *p = '\0';
688
689 ret = do_write_string(fd, buf);
690done:
691 free(buf);
5809fde0
TJ
692 if (fp)
693 fclose(fp);
fbe96f29
SE
694 return ret;
695}
696
1d037ca1
IT
697static int write_numa_topology(int fd, struct perf_header *h __maybe_unused,
698 struct perf_evlist *evlist __maybe_unused)
fbe96f29
SE
699{
700 char *buf = NULL;
701 size_t len = 0;
702 FILE *fp;
703 struct cpu_map *node_map = NULL;
704 char *c;
705 u32 nr, i, j;
706 int ret = -1;
707
708 fp = fopen("/sys/devices/system/node/online", "r");
709 if (!fp)
710 return -1;
711
712 if (getline(&buf, &len, fp) <= 0)
713 goto done;
714
715 c = strchr(buf, '\n');
716 if (c)
717 *c = '\0';
718
719 node_map = cpu_map__new(buf);
720 if (!node_map)
721 goto done;
722
723 nr = (u32)node_map->nr;
724
725 ret = do_write(fd, &nr, sizeof(nr));
726 if (ret < 0)
727 goto done;
728
729 for (i = 0; i < nr; i++) {
730 j = (u32)node_map->map[i];
731 ret = do_write(fd, &j, sizeof(j));
732 if (ret < 0)
733 break;
734
735 ret = write_topo_node(fd, i);
736 if (ret < 0)
737 break;
738 }
739done:
740 free(buf);
741 fclose(fp);
742 free(node_map);
743 return ret;
744}
745
50a9667c
RR
746/*
747 * File format:
748 *
749 * struct pmu_mappings {
750 * u32 pmu_num;
751 * struct pmu_map {
752 * u32 type;
753 * char name[];
754 * }[pmu_num];
755 * };
756 */
757
1d037ca1
IT
758static int write_pmu_mappings(int fd, struct perf_header *h __maybe_unused,
759 struct perf_evlist *evlist __maybe_unused)
50a9667c
RR
760{
761 struct perf_pmu *pmu = NULL;
762 off_t offset = lseek(fd, 0, SEEK_CUR);
763 __u32 pmu_num = 0;
5323f60c 764 int ret;
50a9667c
RR
765
766 /* write real pmu_num later */
5323f60c
NK
767 ret = do_write(fd, &pmu_num, sizeof(pmu_num));
768 if (ret < 0)
769 return ret;
50a9667c
RR
770
771 while ((pmu = perf_pmu__scan(pmu))) {
772 if (!pmu->name)
773 continue;
774 pmu_num++;
5323f60c
NK
775
776 ret = do_write(fd, &pmu->type, sizeof(pmu->type));
777 if (ret < 0)
778 return ret;
779
780 ret = do_write_string(fd, pmu->name);
781 if (ret < 0)
782 return ret;
50a9667c
RR
783 }
784
785 if (pwrite(fd, &pmu_num, sizeof(pmu_num), offset) != sizeof(pmu_num)) {
786 /* discard all */
787 lseek(fd, offset, SEEK_SET);
788 return -1;
789 }
790
791 return 0;
792}
793
a8bb559b
NK
794/*
795 * File format:
796 *
797 * struct group_descs {
798 * u32 nr_groups;
799 * struct group_desc {
800 * char name[];
801 * u32 leader_idx;
802 * u32 nr_members;
803 * }[nr_groups];
804 * };
805 */
806static int write_group_desc(int fd, struct perf_header *h __maybe_unused,
807 struct perf_evlist *evlist)
808{
809 u32 nr_groups = evlist->nr_groups;
810 struct perf_evsel *evsel;
811 int ret;
812
813 ret = do_write(fd, &nr_groups, sizeof(nr_groups));
814 if (ret < 0)
815 return ret;
816
0050f7aa 817 evlist__for_each(evlist, evsel) {
a8bb559b
NK
818 if (perf_evsel__is_group_leader(evsel) &&
819 evsel->nr_members > 1) {
820 const char *name = evsel->group_name ?: "{anon_group}";
821 u32 leader_idx = evsel->idx;
822 u32 nr_members = evsel->nr_members;
823
824 ret = do_write_string(fd, name);
825 if (ret < 0)
826 return ret;
827
828 ret = do_write(fd, &leader_idx, sizeof(leader_idx));
829 if (ret < 0)
830 return ret;
831
832 ret = do_write(fd, &nr_members, sizeof(nr_members));
833 if (ret < 0)
834 return ret;
835 }
836 }
837 return 0;
838}
839
fbe96f29
SE
840/*
841 * default get_cpuid(): nothing gets recorded
842 * actual implementation must be in arch/$(ARCH)/util/header.c
843 */
1d037ca1
IT
844int __attribute__ ((weak)) get_cpuid(char *buffer __maybe_unused,
845 size_t sz __maybe_unused)
fbe96f29
SE
846{
847 return -1;
848}
849
1d037ca1
IT
850static int write_cpuid(int fd, struct perf_header *h __maybe_unused,
851 struct perf_evlist *evlist __maybe_unused)
fbe96f29
SE
852{
853 char buffer[64];
854 int ret;
855
856 ret = get_cpuid(buffer, sizeof(buffer));
857 if (!ret)
858 goto write_it;
859
860 return -1;
861write_it:
862 return do_write_string(fd, buffer);
863}
864
1d037ca1
IT
865static int write_branch_stack(int fd __maybe_unused,
866 struct perf_header *h __maybe_unused,
867 struct perf_evlist *evlist __maybe_unused)
330aa675
SE
868{
869 return 0;
870}
871
7e94cfcc
NK
872static void print_hostname(struct perf_header *ph, int fd __maybe_unused,
873 FILE *fp)
fbe96f29 874{
7e94cfcc 875 fprintf(fp, "# hostname : %s\n", ph->env.hostname);
fbe96f29
SE
876}
877
7e94cfcc
NK
878static void print_osrelease(struct perf_header *ph, int fd __maybe_unused,
879 FILE *fp)
fbe96f29 880{
7e94cfcc 881 fprintf(fp, "# os release : %s\n", ph->env.os_release);
fbe96f29
SE
882}
883
7e94cfcc 884static void print_arch(struct perf_header *ph, int fd __maybe_unused, FILE *fp)
fbe96f29 885{
7e94cfcc 886 fprintf(fp, "# arch : %s\n", ph->env.arch);
fbe96f29
SE
887}
888
7e94cfcc
NK
889static void print_cpudesc(struct perf_header *ph, int fd __maybe_unused,
890 FILE *fp)
fbe96f29 891{
7e94cfcc 892 fprintf(fp, "# cpudesc : %s\n", ph->env.cpu_desc);
fbe96f29
SE
893}
894
7e94cfcc
NK
895static void print_nrcpus(struct perf_header *ph, int fd __maybe_unused,
896 FILE *fp)
fbe96f29 897{
7e94cfcc
NK
898 fprintf(fp, "# nrcpus online : %u\n", ph->env.nr_cpus_online);
899 fprintf(fp, "# nrcpus avail : %u\n", ph->env.nr_cpus_avail);
fbe96f29
SE
900}
901
7e94cfcc
NK
902static void print_version(struct perf_header *ph, int fd __maybe_unused,
903 FILE *fp)
fbe96f29 904{
7e94cfcc 905 fprintf(fp, "# perf version : %s\n", ph->env.version);
fbe96f29
SE
906}
907
7e94cfcc
NK
908static void print_cmdline(struct perf_header *ph, int fd __maybe_unused,
909 FILE *fp)
fbe96f29 910{
7e94cfcc 911 int nr, i;
fbe96f29 912 char *str;
fbe96f29 913
7e94cfcc
NK
914 nr = ph->env.nr_cmdline;
915 str = ph->env.cmdline;
fbe96f29
SE
916
917 fprintf(fp, "# cmdline : ");
918
919 for (i = 0; i < nr; i++) {
fbe96f29 920 fprintf(fp, "%s ", str);
7e94cfcc 921 str += strlen(str) + 1;
fbe96f29
SE
922 }
923 fputc('\n', fp);
924}
925
7e94cfcc
NK
926static void print_cpu_topology(struct perf_header *ph, int fd __maybe_unused,
927 FILE *fp)
fbe96f29 928{
7e94cfcc 929 int nr, i;
fbe96f29
SE
930 char *str;
931
7e94cfcc
NK
932 nr = ph->env.nr_sibling_cores;
933 str = ph->env.sibling_cores;
fbe96f29
SE
934
935 for (i = 0; i < nr; i++) {
fbe96f29 936 fprintf(fp, "# sibling cores : %s\n", str);
7e94cfcc 937 str += strlen(str) + 1;
fbe96f29
SE
938 }
939
7e94cfcc
NK
940 nr = ph->env.nr_sibling_threads;
941 str = ph->env.sibling_threads;
fbe96f29
SE
942
943 for (i = 0; i < nr; i++) {
fbe96f29 944 fprintf(fp, "# sibling threads : %s\n", str);
7e94cfcc 945 str += strlen(str) + 1;
fbe96f29
SE
946 }
947}
948
4e1b9c67 949static void free_event_desc(struct perf_evsel *events)
fbe96f29 950{
4e1b9c67
RR
951 struct perf_evsel *evsel;
952
953 if (!events)
954 return;
955
956 for (evsel = events; evsel->attr.size; evsel++) {
74cf249d
ACM
957 zfree(&evsel->name);
958 zfree(&evsel->id);
4e1b9c67
RR
959 }
960
961 free(events);
962}
963
964static struct perf_evsel *
965read_event_desc(struct perf_header *ph, int fd)
966{
967 struct perf_evsel *evsel, *events = NULL;
968 u64 *id;
fbe96f29 969 void *buf = NULL;
62db9068
SE
970 u32 nre, sz, nr, i, j;
971 ssize_t ret;
972 size_t msz;
fbe96f29
SE
973
974 /* number of events */
5323f60c 975 ret = readn(fd, &nre, sizeof(nre));
fbe96f29
SE
976 if (ret != (ssize_t)sizeof(nre))
977 goto error;
978
979 if (ph->needs_swap)
980 nre = bswap_32(nre);
981
5323f60c 982 ret = readn(fd, &sz, sizeof(sz));
fbe96f29
SE
983 if (ret != (ssize_t)sizeof(sz))
984 goto error;
985
986 if (ph->needs_swap)
987 sz = bswap_32(sz);
988
62db9068 989 /* buffer to hold on file attr struct */
fbe96f29
SE
990 buf = malloc(sz);
991 if (!buf)
992 goto error;
993
4e1b9c67
RR
994 /* the last event terminates with evsel->attr.size == 0: */
995 events = calloc(nre + 1, sizeof(*events));
996 if (!events)
997 goto error;
998
999 msz = sizeof(evsel->attr);
9fafd98f 1000 if (sz < msz)
fbe96f29
SE
1001 msz = sz;
1002
4e1b9c67
RR
1003 for (i = 0, evsel = events; i < nre; evsel++, i++) {
1004 evsel->idx = i;
fbe96f29 1005
62db9068
SE
1006 /*
1007 * must read entire on-file attr struct to
1008 * sync up with layout.
1009 */
5323f60c 1010 ret = readn(fd, buf, sz);
fbe96f29
SE
1011 if (ret != (ssize_t)sz)
1012 goto error;
1013
1014 if (ph->needs_swap)
1015 perf_event__attr_swap(buf);
1016
4e1b9c67 1017 memcpy(&evsel->attr, buf, msz);
fbe96f29 1018
5323f60c 1019 ret = readn(fd, &nr, sizeof(nr));
fbe96f29
SE
1020 if (ret != (ssize_t)sizeof(nr))
1021 goto error;
1022
0807d2d8 1023 if (ph->needs_swap) {
fbe96f29 1024 nr = bswap_32(nr);
0807d2d8
ACM
1025 evsel->needs_swap = true;
1026 }
fbe96f29 1027
4e1b9c67
RR
1028 evsel->name = do_read_string(fd, ph);
1029
1030 if (!nr)
1031 continue;
1032
1033 id = calloc(nr, sizeof(*id));
1034 if (!id)
1035 goto error;
1036 evsel->ids = nr;
1037 evsel->id = id;
1038
1039 for (j = 0 ; j < nr; j++) {
5323f60c 1040 ret = readn(fd, id, sizeof(*id));
4e1b9c67
RR
1041 if (ret != (ssize_t)sizeof(*id))
1042 goto error;
1043 if (ph->needs_swap)
1044 *id = bswap_64(*id);
1045 id++;
1046 }
1047 }
1048out:
04662523 1049 free(buf);
4e1b9c67
RR
1050 return events;
1051error:
1052 if (events)
1053 free_event_desc(events);
1054 events = NULL;
1055 goto out;
1056}
1057
1058static void print_event_desc(struct perf_header *ph, int fd, FILE *fp)
1059{
1060 struct perf_evsel *evsel, *events = read_event_desc(ph, fd);
1061 u32 j;
1062 u64 *id;
1063
1064 if (!events) {
1065 fprintf(fp, "# event desc: not available or unable to read\n");
1066 return;
1067 }
1068
1069 for (evsel = events; evsel->attr.size; evsel++) {
1070 fprintf(fp, "# event : name = %s, ", evsel->name);
fbe96f29
SE
1071
1072 fprintf(fp, "type = %d, config = 0x%"PRIx64
1073 ", config1 = 0x%"PRIx64", config2 = 0x%"PRIx64,
4e1b9c67
RR
1074 evsel->attr.type,
1075 (u64)evsel->attr.config,
1076 (u64)evsel->attr.config1,
1077 (u64)evsel->attr.config2);
fbe96f29
SE
1078
1079 fprintf(fp, ", excl_usr = %d, excl_kern = %d",
4e1b9c67
RR
1080 evsel->attr.exclude_user,
1081 evsel->attr.exclude_kernel);
fbe96f29 1082
78b961ff 1083 fprintf(fp, ", excl_host = %d, excl_guest = %d",
4e1b9c67
RR
1084 evsel->attr.exclude_host,
1085 evsel->attr.exclude_guest);
78b961ff 1086
4e1b9c67 1087 fprintf(fp, ", precise_ip = %d", evsel->attr.precise_ip);
78b961ff 1088
5c5e854b
SE
1089 fprintf(fp, ", attr_mmap2 = %d", evsel->attr.mmap2);
1090 fprintf(fp, ", attr_mmap = %d", evsel->attr.mmap);
1091 fprintf(fp, ", attr_mmap_data = %d", evsel->attr.mmap_data);
4e1b9c67 1092 if (evsel->ids) {
fbe96f29 1093 fprintf(fp, ", id = {");
4e1b9c67
RR
1094 for (j = 0, id = evsel->id; j < evsel->ids; j++, id++) {
1095 if (j)
1096 fputc(',', fp);
1097 fprintf(fp, " %"PRIu64, *id);
1098 }
fbe96f29 1099 fprintf(fp, " }");
4e1b9c67 1100 }
814c8c38
PZ
1101 if (evsel->attr.use_clockid)
1102 fprintf(fp, ", clockid = %d", evsel->attr.clockid);
1103
4e1b9c67 1104
fbe96f29
SE
1105 fputc('\n', fp);
1106 }
4e1b9c67
RR
1107
1108 free_event_desc(events);
fbe96f29
SE
1109}
1110
7e94cfcc 1111static void print_total_mem(struct perf_header *ph, int fd __maybe_unused,
1d037ca1 1112 FILE *fp)
fbe96f29 1113{
7e94cfcc 1114 fprintf(fp, "# total memory : %Lu kB\n", ph->env.total_mem);
fbe96f29
SE
1115}
1116
7e94cfcc 1117static void print_numa_topology(struct perf_header *ph, int fd __maybe_unused,
1d037ca1 1118 FILE *fp)
fbe96f29 1119{
fbe96f29 1120 u32 nr, c, i;
7e94cfcc 1121 char *str, *tmp;
fbe96f29
SE
1122 uint64_t mem_total, mem_free;
1123
1124 /* nr nodes */
7e94cfcc
NK
1125 nr = ph->env.nr_numa_nodes;
1126 str = ph->env.numa_nodes;
fbe96f29
SE
1127
1128 for (i = 0; i < nr; i++) {
fbe96f29 1129 /* node number */
7e94cfcc
NK
1130 c = strtoul(str, &tmp, 0);
1131 if (*tmp != ':')
fbe96f29
SE
1132 goto error;
1133
7e94cfcc
NK
1134 str = tmp + 1;
1135 mem_total = strtoull(str, &tmp, 0);
1136 if (*tmp != ':')
fbe96f29
SE
1137 goto error;
1138
7e94cfcc
NK
1139 str = tmp + 1;
1140 mem_free = strtoull(str, &tmp, 0);
1141 if (*tmp != ':')
fbe96f29
SE
1142 goto error;
1143
fbe96f29
SE
1144 fprintf(fp, "# node%u meminfo : total = %"PRIu64" kB,"
1145 " free = %"PRIu64" kB\n",
7e94cfcc 1146 c, mem_total, mem_free);
fbe96f29 1147
7e94cfcc 1148 str = tmp + 1;
fbe96f29 1149 fprintf(fp, "# node%u cpu list : %s\n", c, str);
1234471e
NK
1150
1151 str += strlen(str) + 1;
fbe96f29
SE
1152 }
1153 return;
1154error:
1155 fprintf(fp, "# numa topology : not available\n");
1156}
1157
7e94cfcc 1158static void print_cpuid(struct perf_header *ph, int fd __maybe_unused, FILE *fp)
fbe96f29 1159{
7e94cfcc 1160 fprintf(fp, "# cpuid : %s\n", ph->env.cpuid);
fbe96f29
SE
1161}
1162
1d037ca1 1163static void print_branch_stack(struct perf_header *ph __maybe_unused,
7e94cfcc 1164 int fd __maybe_unused, FILE *fp)
330aa675
SE
1165{
1166 fprintf(fp, "# contains samples with branch stack\n");
1167}
1168
7e94cfcc
NK
1169static void print_pmu_mappings(struct perf_header *ph, int fd __maybe_unused,
1170 FILE *fp)
50a9667c
RR
1171{
1172 const char *delimiter = "# pmu mappings: ";
7e94cfcc 1173 char *str, *tmp;
50a9667c
RR
1174 u32 pmu_num;
1175 u32 type;
1176
7e94cfcc 1177 pmu_num = ph->env.nr_pmu_mappings;
50a9667c
RR
1178 if (!pmu_num) {
1179 fprintf(fp, "# pmu mappings: not available\n");
1180 return;
1181 }
1182
7e94cfcc
NK
1183 str = ph->env.pmu_mappings;
1184
50a9667c 1185 while (pmu_num) {
7e94cfcc
NK
1186 type = strtoul(str, &tmp, 0);
1187 if (*tmp != ':')
1188 goto error;
1189
1190 str = tmp + 1;
1191 fprintf(fp, "%s%s = %" PRIu32, delimiter, str, type);
be4a2ded 1192
50a9667c 1193 delimiter = ", ";
7e94cfcc
NK
1194 str += strlen(str) + 1;
1195 pmu_num--;
50a9667c
RR
1196 }
1197
1198 fprintf(fp, "\n");
1199
1200 if (!pmu_num)
1201 return;
1202error:
1203 fprintf(fp, "# pmu mappings: unable to read\n");
1204}
1205
a8bb559b
NK
1206static void print_group_desc(struct perf_header *ph, int fd __maybe_unused,
1207 FILE *fp)
1208{
1209 struct perf_session *session;
1210 struct perf_evsel *evsel;
1211 u32 nr = 0;
1212
1213 session = container_of(ph, struct perf_session, header);
1214
0050f7aa 1215 evlist__for_each(session->evlist, evsel) {
a8bb559b
NK
1216 if (perf_evsel__is_group_leader(evsel) &&
1217 evsel->nr_members > 1) {
1218 fprintf(fp, "# group: %s{%s", evsel->group_name ?: "",
1219 perf_evsel__name(evsel));
1220
1221 nr = evsel->nr_members - 1;
1222 } else if (nr) {
1223 fprintf(fp, ",%s", perf_evsel__name(evsel));
1224
1225 if (--nr == 0)
1226 fprintf(fp, "}\n");
1227 }
1228 }
1229}
1230
08d95bd2
RR
1231static int __event_process_build_id(struct build_id_event *bev,
1232 char *filename,
1233 struct perf_session *session)
1234{
1235 int err = -1;
8fa7d87f 1236 struct dsos *dsos;
08d95bd2
RR
1237 struct machine *machine;
1238 u16 misc;
1239 struct dso *dso;
1240 enum dso_kernel_type dso_type;
1241
1242 machine = perf_session__findnew_machine(session, bev->pid);
1243 if (!machine)
1244 goto out;
1245
1246 misc = bev->header.misc & PERF_RECORD_MISC_CPUMODE_MASK;
1247
1248 switch (misc) {
1249 case PERF_RECORD_MISC_KERNEL:
1250 dso_type = DSO_TYPE_KERNEL;
8fa7d87f 1251 dsos = &machine->kernel_dsos;
08d95bd2
RR
1252 break;
1253 case PERF_RECORD_MISC_GUEST_KERNEL:
1254 dso_type = DSO_TYPE_GUEST_KERNEL;
8fa7d87f 1255 dsos = &machine->kernel_dsos;
08d95bd2
RR
1256 break;
1257 case PERF_RECORD_MISC_USER:
1258 case PERF_RECORD_MISC_GUEST_USER:
1259 dso_type = DSO_TYPE_USER;
8fa7d87f 1260 dsos = &machine->user_dsos;
08d95bd2
RR
1261 break;
1262 default:
1263 goto out;
1264 }
1265
8fa7d87f 1266 dso = __dsos__findnew(dsos, filename);
08d95bd2
RR
1267 if (dso != NULL) {
1268 char sbuild_id[BUILD_ID_SIZE * 2 + 1];
1269
1270 dso__set_build_id(dso, &bev->build_id);
1271
e746b3ea 1272 if (!is_kernel_module(filename))
08d95bd2
RR
1273 dso->kernel = dso_type;
1274
1275 build_id__sprintf(dso->build_id, sizeof(dso->build_id),
1276 sbuild_id);
1277 pr_debug("build id event received for %s: %s\n",
1278 dso->long_name, sbuild_id);
1279 }
1280
1281 err = 0;
1282out:
1283 return err;
1284}
1285
1286static int perf_header__read_build_ids_abi_quirk(struct perf_header *header,
1287 int input, u64 offset, u64 size)
1288{
1289 struct perf_session *session = container_of(header, struct perf_session, header);
1290 struct {
1291 struct perf_event_header header;
9ac3e487 1292 u8 build_id[PERF_ALIGN(BUILD_ID_SIZE, sizeof(u64))];
08d95bd2
RR
1293 char filename[0];
1294 } old_bev;
1295 struct build_id_event bev;
1296 char filename[PATH_MAX];
1297 u64 limit = offset + size;
1298
1299 while (offset < limit) {
1300 ssize_t len;
1301
5323f60c 1302 if (readn(input, &old_bev, sizeof(old_bev)) != sizeof(old_bev))
08d95bd2
RR
1303 return -1;
1304
1305 if (header->needs_swap)
1306 perf_event_header__bswap(&old_bev.header);
1307
1308 len = old_bev.header.size - sizeof(old_bev);
5323f60c 1309 if (readn(input, filename, len) != len)
08d95bd2
RR
1310 return -1;
1311
1312 bev.header = old_bev.header;
1313
1314 /*
1315 * As the pid is the missing value, we need to fill
1316 * it properly. The header.misc value give us nice hint.
1317 */
1318 bev.pid = HOST_KERNEL_ID;
1319 if (bev.header.misc == PERF_RECORD_MISC_GUEST_USER ||
1320 bev.header.misc == PERF_RECORD_MISC_GUEST_KERNEL)
1321 bev.pid = DEFAULT_GUEST_KERNEL_ID;
1322
1323 memcpy(bev.build_id, old_bev.build_id, sizeof(bev.build_id));
1324 __event_process_build_id(&bev, filename, session);
1325
1326 offset += bev.header.size;
1327 }
1328
1329 return 0;
1330}
1331
1332static int perf_header__read_build_ids(struct perf_header *header,
1333 int input, u64 offset, u64 size)
1334{
1335 struct perf_session *session = container_of(header, struct perf_session, header);
1336 struct build_id_event bev;
1337 char filename[PATH_MAX];
1338 u64 limit = offset + size, orig_offset = offset;
1339 int err = -1;
1340
1341 while (offset < limit) {
1342 ssize_t len;
1343
5323f60c 1344 if (readn(input, &bev, sizeof(bev)) != sizeof(bev))
08d95bd2
RR
1345 goto out;
1346
1347 if (header->needs_swap)
1348 perf_event_header__bswap(&bev.header);
1349
1350 len = bev.header.size - sizeof(bev);
5323f60c 1351 if (readn(input, filename, len) != len)
08d95bd2
RR
1352 goto out;
1353 /*
1354 * The a1645ce1 changeset:
1355 *
1356 * "perf: 'perf kvm' tool for monitoring guest performance from host"
1357 *
1358 * Added a field to struct build_id_event that broke the file
1359 * format.
1360 *
1361 * Since the kernel build-id is the first entry, process the
1362 * table using the old format if the well known
1363 * '[kernel.kallsyms]' string for the kernel build-id has the
1364 * first 4 characters chopped off (where the pid_t sits).
1365 */
1366 if (memcmp(filename, "nel.kallsyms]", 13) == 0) {
1367 if (lseek(input, orig_offset, SEEK_SET) == (off_t)-1)
1368 return -1;
1369 return perf_header__read_build_ids_abi_quirk(header, input, offset, size);
1370 }
1371
1372 __event_process_build_id(&bev, filename, session);
1373
1374 offset += bev.header.size;
1375 }
1376 err = 0;
1377out:
1378 return err;
1379}
1380
3d7eb86b
NK
1381static int process_tracing_data(struct perf_file_section *section __maybe_unused,
1382 struct perf_header *ph __maybe_unused,
1383 int fd, void *data)
f1c67db7 1384{
3dce2ce3
NK
1385 ssize_t ret = trace_report(fd, data, false);
1386 return ret < 0 ? -1 : 0;
f1c67db7
RR
1387}
1388
1389static int process_build_id(struct perf_file_section *section,
3d7eb86b 1390 struct perf_header *ph, int fd,
1d037ca1 1391 void *data __maybe_unused)
f1c67db7
RR
1392{
1393 if (perf_header__read_build_ids(ph, fd, section->offset, section->size))
1394 pr_debug("Failed to read buildids, continuing...\n");
1395 return 0;
1396}
1397
a1ae5655 1398static int process_hostname(struct perf_file_section *section __maybe_unused,
3d7eb86b
NK
1399 struct perf_header *ph, int fd,
1400 void *data __maybe_unused)
a1ae5655
NK
1401{
1402 ph->env.hostname = do_read_string(fd, ph);
1403 return ph->env.hostname ? 0 : -ENOMEM;
1404}
1405
1406static int process_osrelease(struct perf_file_section *section __maybe_unused,
3d7eb86b
NK
1407 struct perf_header *ph, int fd,
1408 void *data __maybe_unused)
a1ae5655
NK
1409{
1410 ph->env.os_release = do_read_string(fd, ph);
1411 return ph->env.os_release ? 0 : -ENOMEM;
1412}
1413
1414static int process_version(struct perf_file_section *section __maybe_unused,
3d7eb86b
NK
1415 struct perf_header *ph, int fd,
1416 void *data __maybe_unused)
a1ae5655
NK
1417{
1418 ph->env.version = do_read_string(fd, ph);
1419 return ph->env.version ? 0 : -ENOMEM;
1420}
1421
1422static int process_arch(struct perf_file_section *section __maybe_unused,
3d7eb86b
NK
1423 struct perf_header *ph, int fd,
1424 void *data __maybe_unused)
a1ae5655
NK
1425{
1426 ph->env.arch = do_read_string(fd, ph);
1427 return ph->env.arch ? 0 : -ENOMEM;
1428}
1429
1430static int process_nrcpus(struct perf_file_section *section __maybe_unused,
3d7eb86b
NK
1431 struct perf_header *ph, int fd,
1432 void *data __maybe_unused)
a1ae5655 1433{
727ebd54 1434 ssize_t ret;
a1ae5655
NK
1435 u32 nr;
1436
5323f60c 1437 ret = readn(fd, &nr, sizeof(nr));
a1ae5655
NK
1438 if (ret != sizeof(nr))
1439 return -1;
1440
1441 if (ph->needs_swap)
1442 nr = bswap_32(nr);
1443
1444 ph->env.nr_cpus_online = nr;
1445
5323f60c 1446 ret = readn(fd, &nr, sizeof(nr));
a1ae5655
NK
1447 if (ret != sizeof(nr))
1448 return -1;
1449
1450 if (ph->needs_swap)
1451 nr = bswap_32(nr);
1452
1453 ph->env.nr_cpus_avail = nr;
1454 return 0;
1455}
1456
1457static int process_cpudesc(struct perf_file_section *section __maybe_unused,
3d7eb86b
NK
1458 struct perf_header *ph, int fd,
1459 void *data __maybe_unused)
a1ae5655
NK
1460{
1461 ph->env.cpu_desc = do_read_string(fd, ph);
1462 return ph->env.cpu_desc ? 0 : -ENOMEM;
1463}
1464
1465static int process_cpuid(struct perf_file_section *section __maybe_unused,
3d7eb86b
NK
1466 struct perf_header *ph, int fd,
1467 void *data __maybe_unused)
a1ae5655
NK
1468{
1469 ph->env.cpuid = do_read_string(fd, ph);
1470 return ph->env.cpuid ? 0 : -ENOMEM;
1471}
1472
1473static int process_total_mem(struct perf_file_section *section __maybe_unused,
3d7eb86b
NK
1474 struct perf_header *ph, int fd,
1475 void *data __maybe_unused)
a1ae5655
NK
1476{
1477 uint64_t mem;
727ebd54 1478 ssize_t ret;
a1ae5655 1479
5323f60c 1480 ret = readn(fd, &mem, sizeof(mem));
a1ae5655
NK
1481 if (ret != sizeof(mem))
1482 return -1;
1483
1484 if (ph->needs_swap)
1485 mem = bswap_64(mem);
1486
1487 ph->env.total_mem = mem;
1488 return 0;
1489}
1490
7c2f7afd
RR
1491static struct perf_evsel *
1492perf_evlist__find_by_index(struct perf_evlist *evlist, int idx)
1493{
1494 struct perf_evsel *evsel;
1495
0050f7aa 1496 evlist__for_each(evlist, evsel) {
7c2f7afd
RR
1497 if (evsel->idx == idx)
1498 return evsel;
1499 }
1500
1501 return NULL;
1502}
1503
1504static void
3d7eb86b
NK
1505perf_evlist__set_event_name(struct perf_evlist *evlist,
1506 struct perf_evsel *event)
7c2f7afd
RR
1507{
1508 struct perf_evsel *evsel;
1509
1510 if (!event->name)
1511 return;
1512
1513 evsel = perf_evlist__find_by_index(evlist, event->idx);
1514 if (!evsel)
1515 return;
1516
1517 if (evsel->name)
1518 return;
1519
1520 evsel->name = strdup(event->name);
1521}
1522
1523static int
1d037ca1 1524process_event_desc(struct perf_file_section *section __maybe_unused,
3d7eb86b 1525 struct perf_header *header, int fd,
1d037ca1 1526 void *data __maybe_unused)
7c2f7afd 1527{
3d7eb86b 1528 struct perf_session *session;
7c2f7afd
RR
1529 struct perf_evsel *evsel, *events = read_event_desc(header, fd);
1530
1531 if (!events)
1532 return 0;
1533
3d7eb86b 1534 session = container_of(header, struct perf_session, header);
7c2f7afd
RR
1535 for (evsel = events; evsel->attr.size; evsel++)
1536 perf_evlist__set_event_name(session->evlist, evsel);
1537
1538 free_event_desc(events);
1539
1540 return 0;
1541}
1542
a1ae5655 1543static int process_cmdline(struct perf_file_section *section __maybe_unused,
3d7eb86b
NK
1544 struct perf_header *ph, int fd,
1545 void *data __maybe_unused)
a1ae5655 1546{
727ebd54 1547 ssize_t ret;
a1ae5655
NK
1548 char *str;
1549 u32 nr, i;
1550 struct strbuf sb;
1551
5323f60c 1552 ret = readn(fd, &nr, sizeof(nr));
a1ae5655
NK
1553 if (ret != sizeof(nr))
1554 return -1;
1555
1556 if (ph->needs_swap)
1557 nr = bswap_32(nr);
1558
1559 ph->env.nr_cmdline = nr;
1560 strbuf_init(&sb, 128);
1561
1562 for (i = 0; i < nr; i++) {
1563 str = do_read_string(fd, ph);
1564 if (!str)
1565 goto error;
1566
1567 /* include a NULL character at the end */
1568 strbuf_add(&sb, str, strlen(str) + 1);
1569 free(str);
1570 }
1571 ph->env.cmdline = strbuf_detach(&sb, NULL);
1572 return 0;
1573
1574error:
1575 strbuf_release(&sb);
1576 return -1;
1577}
1578
1579static int process_cpu_topology(struct perf_file_section *section __maybe_unused,
3d7eb86b
NK
1580 struct perf_header *ph, int fd,
1581 void *data __maybe_unused)
a1ae5655 1582{
727ebd54 1583 ssize_t ret;
a1ae5655
NK
1584 u32 nr, i;
1585 char *str;
1586 struct strbuf sb;
1587
5323f60c 1588 ret = readn(fd, &nr, sizeof(nr));
a1ae5655
NK
1589 if (ret != sizeof(nr))
1590 return -1;
1591
1592 if (ph->needs_swap)
1593 nr = bswap_32(nr);
1594
1595 ph->env.nr_sibling_cores = nr;
1596 strbuf_init(&sb, 128);
1597
1598 for (i = 0; i < nr; i++) {
1599 str = do_read_string(fd, ph);
1600 if (!str)
1601 goto error;
1602
1603 /* include a NULL character at the end */
1604 strbuf_add(&sb, str, strlen(str) + 1);
1605 free(str);
1606 }
1607 ph->env.sibling_cores = strbuf_detach(&sb, NULL);
1608
5323f60c 1609 ret = readn(fd, &nr, sizeof(nr));
a1ae5655
NK
1610 if (ret != sizeof(nr))
1611 return -1;
1612
1613 if (ph->needs_swap)
1614 nr = bswap_32(nr);
1615
1616 ph->env.nr_sibling_threads = nr;
1617
1618 for (i = 0; i < nr; i++) {
1619 str = do_read_string(fd, ph);
1620 if (!str)
1621 goto error;
1622
1623 /* include a NULL character at the end */
1624 strbuf_add(&sb, str, strlen(str) + 1);
1625 free(str);
1626 }
1627 ph->env.sibling_threads = strbuf_detach(&sb, NULL);
1628 return 0;
1629
1630error:
1631 strbuf_release(&sb);
1632 return -1;
1633}
1634
1635static int process_numa_topology(struct perf_file_section *section __maybe_unused,
3d7eb86b
NK
1636 struct perf_header *ph, int fd,
1637 void *data __maybe_unused)
a1ae5655 1638{
727ebd54 1639 ssize_t ret;
a1ae5655
NK
1640 u32 nr, node, i;
1641 char *str;
1642 uint64_t mem_total, mem_free;
1643 struct strbuf sb;
1644
1645 /* nr nodes */
5323f60c 1646 ret = readn(fd, &nr, sizeof(nr));
a1ae5655
NK
1647 if (ret != sizeof(nr))
1648 goto error;
1649
1650 if (ph->needs_swap)
1651 nr = bswap_32(nr);
1652
1653 ph->env.nr_numa_nodes = nr;
1654 strbuf_init(&sb, 256);
1655
1656 for (i = 0; i < nr; i++) {
1657 /* node number */
5323f60c 1658 ret = readn(fd, &node, sizeof(node));
a1ae5655
NK
1659 if (ret != sizeof(node))
1660 goto error;
1661
5323f60c 1662 ret = readn(fd, &mem_total, sizeof(u64));
a1ae5655
NK
1663 if (ret != sizeof(u64))
1664 goto error;
1665
5323f60c 1666 ret = readn(fd, &mem_free, sizeof(u64));
a1ae5655
NK
1667 if (ret != sizeof(u64))
1668 goto error;
1669
1670 if (ph->needs_swap) {
1671 node = bswap_32(node);
1672 mem_total = bswap_64(mem_total);
1673 mem_free = bswap_64(mem_free);
1674 }
1675
1676 strbuf_addf(&sb, "%u:%"PRIu64":%"PRIu64":",
1677 node, mem_total, mem_free);
1678
1679 str = do_read_string(fd, ph);
1680 if (!str)
1681 goto error;
1682
1683 /* include a NULL character at the end */
1684 strbuf_add(&sb, str, strlen(str) + 1);
1685 free(str);
1686 }
1687 ph->env.numa_nodes = strbuf_detach(&sb, NULL);
1688 return 0;
1689
1690error:
1691 strbuf_release(&sb);
1692 return -1;
1693}
1694
1695static int process_pmu_mappings(struct perf_file_section *section __maybe_unused,
3d7eb86b
NK
1696 struct perf_header *ph, int fd,
1697 void *data __maybe_unused)
a1ae5655 1698{
727ebd54 1699 ssize_t ret;
a1ae5655
NK
1700 char *name;
1701 u32 pmu_num;
1702 u32 type;
1703 struct strbuf sb;
1704
5323f60c 1705 ret = readn(fd, &pmu_num, sizeof(pmu_num));
a1ae5655
NK
1706 if (ret != sizeof(pmu_num))
1707 return -1;
1708
1709 if (ph->needs_swap)
1710 pmu_num = bswap_32(pmu_num);
1711
1712 if (!pmu_num) {
1713 pr_debug("pmu mappings not available\n");
1714 return 0;
1715 }
1716
1717 ph->env.nr_pmu_mappings = pmu_num;
1718 strbuf_init(&sb, 128);
1719
1720 while (pmu_num) {
5323f60c 1721 if (readn(fd, &type, sizeof(type)) != sizeof(type))
a1ae5655
NK
1722 goto error;
1723 if (ph->needs_swap)
1724 type = bswap_32(type);
1725
1726 name = do_read_string(fd, ph);
1727 if (!name)
1728 goto error;
1729
1730 strbuf_addf(&sb, "%u:%s", type, name);
1731 /* include a NULL character at the end */
1732 strbuf_add(&sb, "", 1);
1733
1734 free(name);
1735 pmu_num--;
1736 }
1737 ph->env.pmu_mappings = strbuf_detach(&sb, NULL);
1738 return 0;
1739
1740error:
1741 strbuf_release(&sb);
1742 return -1;
1743}
1744
a8bb559b
NK
1745static int process_group_desc(struct perf_file_section *section __maybe_unused,
1746 struct perf_header *ph, int fd,
1747 void *data __maybe_unused)
1748{
1749 size_t ret = -1;
1750 u32 i, nr, nr_groups;
1751 struct perf_session *session;
1752 struct perf_evsel *evsel, *leader = NULL;
1753 struct group_desc {
1754 char *name;
1755 u32 leader_idx;
1756 u32 nr_members;
1757 } *desc;
1758
1759 if (readn(fd, &nr_groups, sizeof(nr_groups)) != sizeof(nr_groups))
1760 return -1;
1761
1762 if (ph->needs_swap)
1763 nr_groups = bswap_32(nr_groups);
1764
1765 ph->env.nr_groups = nr_groups;
1766 if (!nr_groups) {
1767 pr_debug("group desc not available\n");
1768 return 0;
1769 }
1770
1771 desc = calloc(nr_groups, sizeof(*desc));
1772 if (!desc)
1773 return -1;
1774
1775 for (i = 0; i < nr_groups; i++) {
1776 desc[i].name = do_read_string(fd, ph);
1777 if (!desc[i].name)
1778 goto out_free;
1779
1780 if (readn(fd, &desc[i].leader_idx, sizeof(u32)) != sizeof(u32))
1781 goto out_free;
1782
1783 if (readn(fd, &desc[i].nr_members, sizeof(u32)) != sizeof(u32))
1784 goto out_free;
1785
1786 if (ph->needs_swap) {
1787 desc[i].leader_idx = bswap_32(desc[i].leader_idx);
1788 desc[i].nr_members = bswap_32(desc[i].nr_members);
1789 }
1790 }
1791
1792 /*
1793 * Rebuild group relationship based on the group_desc
1794 */
1795 session = container_of(ph, struct perf_session, header);
1796 session->evlist->nr_groups = nr_groups;
1797
1798 i = nr = 0;
0050f7aa 1799 evlist__for_each(session->evlist, evsel) {
a8bb559b
NK
1800 if (evsel->idx == (int) desc[i].leader_idx) {
1801 evsel->leader = evsel;
1802 /* {anon_group} is a dummy name */
210e812f 1803 if (strcmp(desc[i].name, "{anon_group}")) {
a8bb559b 1804 evsel->group_name = desc[i].name;
210e812f
NK
1805 desc[i].name = NULL;
1806 }
a8bb559b
NK
1807 evsel->nr_members = desc[i].nr_members;
1808
1809 if (i >= nr_groups || nr > 0) {
1810 pr_debug("invalid group desc\n");
1811 goto out_free;
1812 }
1813
1814 leader = evsel;
1815 nr = evsel->nr_members - 1;
1816 i++;
1817 } else if (nr) {
1818 /* This is a group member */
1819 evsel->leader = leader;
1820
1821 nr--;
1822 }
1823 }
1824
1825 if (i != nr_groups || nr != 0) {
1826 pr_debug("invalid group desc\n");
1827 goto out_free;
1828 }
1829
1830 ret = 0;
1831out_free:
50a2740b 1832 for (i = 0; i < nr_groups; i++)
74cf249d 1833 zfree(&desc[i].name);
a8bb559b
NK
1834 free(desc);
1835
1836 return ret;
1837}
1838
fbe96f29
SE
1839struct feature_ops {
1840 int (*write)(int fd, struct perf_header *h, struct perf_evlist *evlist);
1841 void (*print)(struct perf_header *h, int fd, FILE *fp);
f1c67db7 1842 int (*process)(struct perf_file_section *section,
3d7eb86b 1843 struct perf_header *h, int fd, void *data);
fbe96f29
SE
1844 const char *name;
1845 bool full_only;
1846};
1847
8cdfa78a
RR
1848#define FEAT_OPA(n, func) \
1849 [n] = { .name = #n, .write = write_##func, .print = print_##func }
f1c67db7
RR
1850#define FEAT_OPP(n, func) \
1851 [n] = { .name = #n, .write = write_##func, .print = print_##func, \
1852 .process = process_##func }
8cdfa78a 1853#define FEAT_OPF(n, func) \
f1c67db7 1854 [n] = { .name = #n, .write = write_##func, .print = print_##func, \
a1ae5655 1855 .process = process_##func, .full_only = true }
8cdfa78a
RR
1856
1857/* feature_ops not implemented: */
2eeaaa09
SE
1858#define print_tracing_data NULL
1859#define print_build_id NULL
fbe96f29
SE
1860
1861static const struct feature_ops feat_ops[HEADER_LAST_FEATURE] = {
2eeaaa09 1862 FEAT_OPP(HEADER_TRACING_DATA, tracing_data),
f1c67db7 1863 FEAT_OPP(HEADER_BUILD_ID, build_id),
a1ae5655
NK
1864 FEAT_OPP(HEADER_HOSTNAME, hostname),
1865 FEAT_OPP(HEADER_OSRELEASE, osrelease),
1866 FEAT_OPP(HEADER_VERSION, version),
1867 FEAT_OPP(HEADER_ARCH, arch),
1868 FEAT_OPP(HEADER_NRCPUS, nrcpus),
1869 FEAT_OPP(HEADER_CPUDESC, cpudesc),
37e9d750 1870 FEAT_OPP(HEADER_CPUID, cpuid),
a1ae5655 1871 FEAT_OPP(HEADER_TOTAL_MEM, total_mem),
7c2f7afd 1872 FEAT_OPP(HEADER_EVENT_DESC, event_desc),
a1ae5655 1873 FEAT_OPP(HEADER_CMDLINE, cmdline),
8cdfa78a
RR
1874 FEAT_OPF(HEADER_CPU_TOPOLOGY, cpu_topology),
1875 FEAT_OPF(HEADER_NUMA_TOPOLOGY, numa_topology),
330aa675 1876 FEAT_OPA(HEADER_BRANCH_STACK, branch_stack),
a1ae5655 1877 FEAT_OPP(HEADER_PMU_MAPPINGS, pmu_mappings),
a8bb559b 1878 FEAT_OPP(HEADER_GROUP_DESC, group_desc),
fbe96f29
SE
1879};
1880
1881struct header_print_data {
1882 FILE *fp;
1883 bool full; /* extended list of headers */
1884};
1885
1886static int perf_file_section__fprintf_info(struct perf_file_section *section,
1887 struct perf_header *ph,
1888 int feat, int fd, void *data)
1889{
1890 struct header_print_data *hd = data;
1891
1892 if (lseek(fd, section->offset, SEEK_SET) == (off_t)-1) {
1893 pr_debug("Failed to lseek to %" PRIu64 " offset for feature "
1894 "%d, continuing...\n", section->offset, feat);
1895 return 0;
1896 }
b1e5a9be 1897 if (feat >= HEADER_LAST_FEATURE) {
fbe96f29 1898 pr_warning("unknown feature %d\n", feat);
f7a8a133 1899 return 0;
fbe96f29
SE
1900 }
1901 if (!feat_ops[feat].print)
1902 return 0;
1903
1904 if (!feat_ops[feat].full_only || hd->full)
1905 feat_ops[feat].print(ph, fd, hd->fp);
1906 else
1907 fprintf(hd->fp, "# %s info available, use -I to display\n",
1908 feat_ops[feat].name);
1909
1910 return 0;
1911}
1912
1913int perf_header__fprintf_info(struct perf_session *session, FILE *fp, bool full)
1914{
1915 struct header_print_data hd;
1916 struct perf_header *header = &session->header;
cc9784bd 1917 int fd = perf_data_file__fd(session->file);
fbe96f29
SE
1918 hd.fp = fp;
1919 hd.full = full;
1920
1921 perf_header__process_sections(header, fd, &hd,
1922 perf_file_section__fprintf_info);
1923 return 0;
1924}
1925
fbe96f29
SE
1926static int do_write_feat(int fd, struct perf_header *h, int type,
1927 struct perf_file_section **p,
1928 struct perf_evlist *evlist)
1929{
1930 int err;
1931 int ret = 0;
1932
1933 if (perf_header__has_feat(h, type)) {
b1e5a9be
RR
1934 if (!feat_ops[type].write)
1935 return -1;
fbe96f29
SE
1936
1937 (*p)->offset = lseek(fd, 0, SEEK_CUR);
1938
1939 err = feat_ops[type].write(fd, h, evlist);
1940 if (err < 0) {
1941 pr_debug("failed to write feature %d\n", type);
1942
1943 /* undo anything written */
1944 lseek(fd, (*p)->offset, SEEK_SET);
1945
1946 return -1;
1947 }
1948 (*p)->size = lseek(fd, 0, SEEK_CUR) - (*p)->offset;
1949 (*p)++;
1950 }
1951 return ret;
1952}
1953
1c0b04d1 1954static int perf_header__adds_write(struct perf_header *header,
361c99a6 1955 struct perf_evlist *evlist, int fd)
2ba08250 1956{
9e827dd0 1957 int nr_sections;
fbe96f29 1958 struct perf_file_section *feat_sec, *p;
9e827dd0
FW
1959 int sec_size;
1960 u64 sec_start;
b1e5a9be 1961 int feat;
fbe96f29 1962 int err;
9e827dd0 1963
1c0b04d1 1964 nr_sections = bitmap_weight(header->adds_features, HEADER_FEAT_BITS);
9e827dd0 1965 if (!nr_sections)
d5eed904 1966 return 0;
9e827dd0 1967
91b98804 1968 feat_sec = p = calloc(nr_sections, sizeof(*feat_sec));
d5eed904
ACM
1969 if (feat_sec == NULL)
1970 return -ENOMEM;
9e827dd0
FW
1971
1972 sec_size = sizeof(*feat_sec) * nr_sections;
1973
8d541e97 1974 sec_start = header->feat_offset;
f887f301 1975 lseek(fd, sec_start + sec_size, SEEK_SET);
2ba08250 1976
b1e5a9be
RR
1977 for_each_set_bit(feat, header->adds_features, HEADER_FEAT_BITS) {
1978 if (do_write_feat(fd, header, feat, &p, evlist))
1979 perf_header__clear_feat(header, feat);
1980 }
9e827dd0 1981
f887f301 1982 lseek(fd, sec_start, SEEK_SET);
fbe96f29
SE
1983 /*
1984 * may write more than needed due to dropped feature, but
1985 * this is okay, reader will skip the mising entries
1986 */
d5eed904
ACM
1987 err = do_write(fd, feat_sec, sec_size);
1988 if (err < 0)
1989 pr_debug("failed to write feature section\n");
9e827dd0 1990 free(feat_sec);
d5eed904 1991 return err;
9e827dd0 1992}
2ba08250 1993
8dc58101
TZ
1994int perf_header__write_pipe(int fd)
1995{
1996 struct perf_pipe_file_header f_header;
1997 int err;
1998
1999 f_header = (struct perf_pipe_file_header){
2000 .magic = PERF_MAGIC,
2001 .size = sizeof(f_header),
2002 };
2003
2004 err = do_write(fd, &f_header, sizeof(f_header));
2005 if (err < 0) {
2006 pr_debug("failed to write perf pipe header\n");
2007 return err;
2008 }
2009
2010 return 0;
2011}
2012
a91e5431
ACM
2013int perf_session__write_header(struct perf_session *session,
2014 struct perf_evlist *evlist,
2015 int fd, bool at_exit)
7c6a1c65
PZ
2016{
2017 struct perf_file_header f_header;
2018 struct perf_file_attr f_attr;
1c0b04d1 2019 struct perf_header *header = &session->header;
563aecb2 2020 struct perf_evsel *evsel;
944d62ba 2021 u64 attr_offset;
a91e5431 2022 int err;
7c6a1c65
PZ
2023
2024 lseek(fd, sizeof(f_header), SEEK_SET);
2025
0050f7aa 2026 evlist__for_each(session->evlist, evsel) {
6606f873
RR
2027 evsel->id_offset = lseek(fd, 0, SEEK_CUR);
2028 err = do_write(fd, evsel->id, evsel->ids * sizeof(u64));
d5eed904
ACM
2029 if (err < 0) {
2030 pr_debug("failed to write perf header\n");
2031 return err;
2032 }
7c6a1c65
PZ
2033 }
2034
944d62ba 2035 attr_offset = lseek(fd, 0, SEEK_CUR);
7c6a1c65 2036
0050f7aa 2037 evlist__for_each(evlist, evsel) {
7c6a1c65 2038 f_attr = (struct perf_file_attr){
6606f873 2039 .attr = evsel->attr,
7c6a1c65 2040 .ids = {
6606f873
RR
2041 .offset = evsel->id_offset,
2042 .size = evsel->ids * sizeof(u64),
7c6a1c65
PZ
2043 }
2044 };
d5eed904
ACM
2045 err = do_write(fd, &f_attr, sizeof(f_attr));
2046 if (err < 0) {
2047 pr_debug("failed to write perf header attribute\n");
2048 return err;
2049 }
7c6a1c65
PZ
2050 }
2051
d645c442
AH
2052 if (!header->data_offset)
2053 header->data_offset = lseek(fd, 0, SEEK_CUR);
8d541e97 2054 header->feat_offset = header->data_offset + header->data_size;
7c6a1c65 2055
d5eed904 2056 if (at_exit) {
1c0b04d1 2057 err = perf_header__adds_write(header, evlist, fd);
d5eed904
ACM
2058 if (err < 0)
2059 return err;
2060 }
9e827dd0 2061
7c6a1c65
PZ
2062 f_header = (struct perf_file_header){
2063 .magic = PERF_MAGIC,
2064 .size = sizeof(f_header),
2065 .attr_size = sizeof(f_attr),
2066 .attrs = {
944d62ba 2067 .offset = attr_offset,
a91e5431 2068 .size = evlist->nr_entries * sizeof(f_attr),
7c6a1c65
PZ
2069 },
2070 .data = {
1c0b04d1
ACM
2071 .offset = header->data_offset,
2072 .size = header->data_size,
7c6a1c65 2073 },
44b3c578 2074 /* event_types is ignored, store zeros */
7c6a1c65
PZ
2075 };
2076
1c0b04d1 2077 memcpy(&f_header.adds_features, &header->adds_features, sizeof(header->adds_features));
2ba08250 2078
7c6a1c65 2079 lseek(fd, 0, SEEK_SET);
d5eed904
ACM
2080 err = do_write(fd, &f_header, sizeof(f_header));
2081 if (err < 0) {
2082 pr_debug("failed to write perf header\n");
2083 return err;
2084 }
1c0b04d1 2085 lseek(fd, header->data_offset + header->data_size, SEEK_SET);
7c6a1c65 2086
d5eed904 2087 return 0;
7c6a1c65
PZ
2088}
2089
1c0b04d1 2090static int perf_header__getbuffer64(struct perf_header *header,
ba21594c
ACM
2091 int fd, void *buf, size_t size)
2092{
1e7972cc 2093 if (readn(fd, buf, size) <= 0)
ba21594c
ACM
2094 return -1;
2095
1c0b04d1 2096 if (header->needs_swap)
ba21594c
ACM
2097 mem_bswap_64(buf, size);
2098
2099 return 0;
2100}
2101
1c0b04d1 2102int perf_header__process_sections(struct perf_header *header, int fd,
fbe96f29 2103 void *data,
1c0b04d1 2104 int (*process)(struct perf_file_section *section,
b1e5a9be
RR
2105 struct perf_header *ph,
2106 int feat, int fd, void *data))
2ba08250 2107{
b1e5a9be 2108 struct perf_file_section *feat_sec, *sec;
9e827dd0
FW
2109 int nr_sections;
2110 int sec_size;
b1e5a9be
RR
2111 int feat;
2112 int err;
9e827dd0 2113
1c0b04d1 2114 nr_sections = bitmap_weight(header->adds_features, HEADER_FEAT_BITS);
9e827dd0 2115 if (!nr_sections)
37562eac 2116 return 0;
9e827dd0 2117
91b98804 2118 feat_sec = sec = calloc(nr_sections, sizeof(*feat_sec));
9e827dd0 2119 if (!feat_sec)
37562eac 2120 return -1;
9e827dd0
FW
2121
2122 sec_size = sizeof(*feat_sec) * nr_sections;
2123
8d541e97 2124 lseek(fd, header->feat_offset, SEEK_SET);
9e827dd0 2125
b1e5a9be
RR
2126 err = perf_header__getbuffer64(header, fd, feat_sec, sec_size);
2127 if (err < 0)
769885f3 2128 goto out_free;
9e827dd0 2129
b1e5a9be
RR
2130 for_each_set_bit(feat, header->adds_features, HEADER_LAST_FEATURE) {
2131 err = process(sec++, header, feat, fd, data);
2132 if (err < 0)
2133 goto out_free;
2ba08250 2134 }
b1e5a9be 2135 err = 0;
769885f3 2136out_free:
37562eac
ACM
2137 free(feat_sec);
2138 return err;
769885f3 2139}
4778d2e4 2140
114382a0
SE
2141static const int attr_file_abi_sizes[] = {
2142 [0] = PERF_ATTR_SIZE_VER0,
2143 [1] = PERF_ATTR_SIZE_VER1,
239cc478 2144 [2] = PERF_ATTR_SIZE_VER2,
0f6a3015 2145 [3] = PERF_ATTR_SIZE_VER3,
6a21c0b5 2146 [4] = PERF_ATTR_SIZE_VER4,
114382a0
SE
2147 0,
2148};
2149
2150/*
2151 * In the legacy file format, the magic number is not used to encode endianness.
2152 * hdr_sz was used to encode endianness. But given that hdr_sz can vary based
2153 * on ABI revisions, we need to try all combinations for all endianness to
2154 * detect the endianness.
2155 */
2156static int try_all_file_abis(uint64_t hdr_sz, struct perf_header *ph)
73323f54 2157{
114382a0
SE
2158 uint64_t ref_size, attr_size;
2159 int i;
73323f54 2160
114382a0
SE
2161 for (i = 0 ; attr_file_abi_sizes[i]; i++) {
2162 ref_size = attr_file_abi_sizes[i]
2163 + sizeof(struct perf_file_section);
2164 if (hdr_sz != ref_size) {
2165 attr_size = bswap_64(hdr_sz);
2166 if (attr_size != ref_size)
2167 continue;
73323f54 2168
114382a0
SE
2169 ph->needs_swap = true;
2170 }
2171 pr_debug("ABI%d perf.data file detected, need_swap=%d\n",
2172 i,
2173 ph->needs_swap);
2174 return 0;
2175 }
2176 /* could not determine endianness */
2177 return -1;
2178}
73323f54 2179
114382a0
SE
2180#define PERF_PIPE_HDR_VER0 16
2181
2182static const size_t attr_pipe_abi_sizes[] = {
2183 [0] = PERF_PIPE_HDR_VER0,
2184 0,
2185};
2186
2187/*
2188 * In the legacy pipe format, there is an implicit assumption that endiannesss
2189 * between host recording the samples, and host parsing the samples is the
2190 * same. This is not always the case given that the pipe output may always be
2191 * redirected into a file and analyzed on a different machine with possibly a
2192 * different endianness and perf_event ABI revsions in the perf tool itself.
2193 */
2194static int try_all_pipe_abis(uint64_t hdr_sz, struct perf_header *ph)
2195{
2196 u64 attr_size;
2197 int i;
2198
2199 for (i = 0 ; attr_pipe_abi_sizes[i]; i++) {
2200 if (hdr_sz != attr_pipe_abi_sizes[i]) {
2201 attr_size = bswap_64(hdr_sz);
2202 if (attr_size != hdr_sz)
2203 continue;
73323f54
SE
2204
2205 ph->needs_swap = true;
2206 }
114382a0 2207 pr_debug("Pipe ABI%d perf.data file detected\n", i);
73323f54
SE
2208 return 0;
2209 }
114382a0
SE
2210 return -1;
2211}
2212
e84ba4e2
FT
2213bool is_perf_magic(u64 magic)
2214{
2215 if (!memcmp(&magic, __perf_magic1, sizeof(magic))
2216 || magic == __perf_magic2
2217 || magic == __perf_magic2_sw)
2218 return true;
2219
2220 return false;
2221}
2222
114382a0
SE
2223static int check_magic_endian(u64 magic, uint64_t hdr_sz,
2224 bool is_pipe, struct perf_header *ph)
2225{
2226 int ret;
2227
2228 /* check for legacy format */
2229 ret = memcmp(&magic, __perf_magic1, sizeof(magic));
2230 if (ret == 0) {
2a08c3ec 2231 ph->version = PERF_HEADER_VERSION_1;
114382a0
SE
2232 pr_debug("legacy perf.data format\n");
2233 if (is_pipe)
2234 return try_all_pipe_abis(hdr_sz, ph);
2235
2236 return try_all_file_abis(hdr_sz, ph);
2237 }
2238 /*
2239 * the new magic number serves two purposes:
2240 * - unique number to identify actual perf.data files
2241 * - encode endianness of file
2242 */
f7913971 2243 ph->version = PERF_HEADER_VERSION_2;
73323f54 2244
114382a0
SE
2245 /* check magic number with one endianness */
2246 if (magic == __perf_magic2)
73323f54
SE
2247 return 0;
2248
114382a0
SE
2249 /* check magic number with opposite endianness */
2250 if (magic != __perf_magic2_sw)
73323f54
SE
2251 return -1;
2252
2253 ph->needs_swap = true;
2254
2255 return 0;
2256}
2257
1c0b04d1 2258int perf_file_header__read(struct perf_file_header *header,
37562eac
ACM
2259 struct perf_header *ph, int fd)
2260{
727ebd54 2261 ssize_t ret;
73323f54 2262
37562eac 2263 lseek(fd, 0, SEEK_SET);
37562eac 2264
73323f54
SE
2265 ret = readn(fd, header, sizeof(*header));
2266 if (ret <= 0)
37562eac
ACM
2267 return -1;
2268
114382a0
SE
2269 if (check_magic_endian(header->magic,
2270 header->attr_size, false, ph) < 0) {
2271 pr_debug("magic/endian check failed\n");
73323f54 2272 return -1;
114382a0 2273 }
ba21594c 2274
73323f54 2275 if (ph->needs_swap) {
1c0b04d1 2276 mem_bswap_64(header, offsetof(struct perf_file_header,
73323f54 2277 adds_features));
ba21594c
ACM
2278 }
2279
1c0b04d1 2280 if (header->size != sizeof(*header)) {
37562eac 2281 /* Support the previous format */
1c0b04d1
ACM
2282 if (header->size == offsetof(typeof(*header), adds_features))
2283 bitmap_zero(header->adds_features, HEADER_FEAT_BITS);
37562eac
ACM
2284 else
2285 return -1;
d327fa43 2286 } else if (ph->needs_swap) {
d327fa43
DA
2287 /*
2288 * feature bitmap is declared as an array of unsigned longs --
2289 * not good since its size can differ between the host that
2290 * generated the data file and the host analyzing the file.
2291 *
2292 * We need to handle endianness, but we don't know the size of
2293 * the unsigned long where the file was generated. Take a best
2294 * guess at determining it: try 64-bit swap first (ie., file
2295 * created on a 64-bit host), and check if the hostname feature
2296 * bit is set (this feature bit is forced on as of fbe96f2).
2297 * If the bit is not, undo the 64-bit swap and try a 32-bit
2298 * swap. If the hostname bit is still not set (e.g., older data
2299 * file), punt and fallback to the original behavior --
2300 * clearing all feature bits and setting buildid.
2301 */
80c0120a
DA
2302 mem_bswap_64(&header->adds_features,
2303 BITS_TO_U64(HEADER_FEAT_BITS));
d327fa43
DA
2304
2305 if (!test_bit(HEADER_HOSTNAME, header->adds_features)) {
80c0120a
DA
2306 /* unswap as u64 */
2307 mem_bswap_64(&header->adds_features,
2308 BITS_TO_U64(HEADER_FEAT_BITS));
2309
2310 /* unswap as u32 */
2311 mem_bswap_32(&header->adds_features,
2312 BITS_TO_U32(HEADER_FEAT_BITS));
d327fa43
DA
2313 }
2314
2315 if (!test_bit(HEADER_HOSTNAME, header->adds_features)) {
2316 bitmap_zero(header->adds_features, HEADER_FEAT_BITS);
2317 set_bit(HEADER_BUILD_ID, header->adds_features);
2318 }
4778d2e4 2319 }
9e827dd0 2320
1c0b04d1 2321 memcpy(&ph->adds_features, &header->adds_features,
ba21594c 2322 sizeof(ph->adds_features));
37562eac 2323
1c0b04d1
ACM
2324 ph->data_offset = header->data.offset;
2325 ph->data_size = header->data.size;
8d541e97 2326 ph->feat_offset = header->data.offset + header->data.size;
37562eac
ACM
2327 return 0;
2328}
2329
1c0b04d1 2330static int perf_file_section__process(struct perf_file_section *section,
ba21594c 2331 struct perf_header *ph,
da378962 2332 int feat, int fd, void *data)
37562eac 2333{
1c0b04d1 2334 if (lseek(fd, section->offset, SEEK_SET) == (off_t)-1) {
9486aa38 2335 pr_debug("Failed to lseek to %" PRIu64 " offset for feature "
1c0b04d1 2336 "%d, continuing...\n", section->offset, feat);
37562eac
ACM
2337 return 0;
2338 }
2339
b1e5a9be
RR
2340 if (feat >= HEADER_LAST_FEATURE) {
2341 pr_debug("unknown feature %d, continuing...\n", feat);
2342 return 0;
2343 }
2344
f1c67db7
RR
2345 if (!feat_ops[feat].process)
2346 return 0;
37562eac 2347
3d7eb86b 2348 return feat_ops[feat].process(section, ph, fd, data);
37562eac 2349}
2ba08250 2350
1c0b04d1 2351static int perf_file_header__read_pipe(struct perf_pipe_file_header *header,
454c407e
TZ
2352 struct perf_header *ph, int fd,
2353 bool repipe)
7c6a1c65 2354{
727ebd54 2355 ssize_t ret;
73323f54
SE
2356
2357 ret = readn(fd, header, sizeof(*header));
2358 if (ret <= 0)
2359 return -1;
2360
114382a0
SE
2361 if (check_magic_endian(header->magic, header->size, true, ph) < 0) {
2362 pr_debug("endian/magic failed\n");
8dc58101 2363 return -1;
114382a0
SE
2364 }
2365
2366 if (ph->needs_swap)
2367 header->size = bswap_64(header->size);
8dc58101 2368
1c0b04d1 2369 if (repipe && do_write(STDOUT_FILENO, header, sizeof(*header)) < 0)
454c407e
TZ
2370 return -1;
2371
8dc58101
TZ
2372 return 0;
2373}
2374
d4339569 2375static int perf_header__read_pipe(struct perf_session *session)
8dc58101 2376{
1c0b04d1 2377 struct perf_header *header = &session->header;
8dc58101
TZ
2378 struct perf_pipe_file_header f_header;
2379
cc9784bd
JO
2380 if (perf_file_header__read_pipe(&f_header, header,
2381 perf_data_file__fd(session->file),
454c407e 2382 session->repipe) < 0) {
8dc58101
TZ
2383 pr_debug("incompatible file format\n");
2384 return -EINVAL;
2385 }
2386
8dc58101
TZ
2387 return 0;
2388}
2389
69996df4
SE
2390static int read_attr(int fd, struct perf_header *ph,
2391 struct perf_file_attr *f_attr)
2392{
2393 struct perf_event_attr *attr = &f_attr->attr;
2394 size_t sz, left;
2395 size_t our_sz = sizeof(f_attr->attr);
727ebd54 2396 ssize_t ret;
69996df4
SE
2397
2398 memset(f_attr, 0, sizeof(*f_attr));
2399
2400 /* read minimal guaranteed structure */
2401 ret = readn(fd, attr, PERF_ATTR_SIZE_VER0);
2402 if (ret <= 0) {
2403 pr_debug("cannot read %d bytes of header attr\n",
2404 PERF_ATTR_SIZE_VER0);
2405 return -1;
2406 }
2407
2408 /* on file perf_event_attr size */
2409 sz = attr->size;
114382a0 2410
69996df4
SE
2411 if (ph->needs_swap)
2412 sz = bswap_32(sz);
2413
2414 if (sz == 0) {
2415 /* assume ABI0 */
2416 sz = PERF_ATTR_SIZE_VER0;
2417 } else if (sz > our_sz) {
2418 pr_debug("file uses a more recent and unsupported ABI"
2419 " (%zu bytes extra)\n", sz - our_sz);
2420 return -1;
2421 }
2422 /* what we have not yet read and that we know about */
2423 left = sz - PERF_ATTR_SIZE_VER0;
2424 if (left) {
2425 void *ptr = attr;
2426 ptr += PERF_ATTR_SIZE_VER0;
2427
2428 ret = readn(fd, ptr, left);
2429 }
2430 /* read perf_file_section, ids are read in caller */
2431 ret = readn(fd, &f_attr->ids, sizeof(f_attr->ids));
2432
2433 return ret <= 0 ? -1 : 0;
2434}
2435
831394bd
NK
2436static int perf_evsel__prepare_tracepoint_event(struct perf_evsel *evsel,
2437 struct pevent *pevent)
cb9dd49e 2438{
831394bd 2439 struct event_format *event;
cb9dd49e
ACM
2440 char bf[128];
2441
831394bd
NK
2442 /* already prepared */
2443 if (evsel->tp_format)
2444 return 0;
2445
3dce2ce3
NK
2446 if (pevent == NULL) {
2447 pr_debug("broken or missing trace data\n");
2448 return -1;
2449 }
2450
831394bd 2451 event = pevent_find_event(pevent, evsel->attr.config);
cb9dd49e
ACM
2452 if (event == NULL)
2453 return -1;
2454
831394bd
NK
2455 if (!evsel->name) {
2456 snprintf(bf, sizeof(bf), "%s:%s", event->system, event->name);
2457 evsel->name = strdup(bf);
2458 if (evsel->name == NULL)
2459 return -1;
2460 }
cb9dd49e 2461
fcf65bf1 2462 evsel->tp_format = event;
cb9dd49e
ACM
2463 return 0;
2464}
2465
831394bd
NK
2466static int perf_evlist__prepare_tracepoint_events(struct perf_evlist *evlist,
2467 struct pevent *pevent)
cb9dd49e
ACM
2468{
2469 struct perf_evsel *pos;
2470
0050f7aa 2471 evlist__for_each(evlist, pos) {
831394bd
NK
2472 if (pos->attr.type == PERF_TYPE_TRACEPOINT &&
2473 perf_evsel__prepare_tracepoint_event(pos, pevent))
cb9dd49e
ACM
2474 return -1;
2475 }
2476
2477 return 0;
2478}
2479
d4339569 2480int perf_session__read_header(struct perf_session *session)
8dc58101 2481{
cc9784bd 2482 struct perf_data_file *file = session->file;
1c0b04d1 2483 struct perf_header *header = &session->header;
ba21594c 2484 struct perf_file_header f_header;
7c6a1c65
PZ
2485 struct perf_file_attr f_attr;
2486 u64 f_id;
7c6a1c65 2487 int nr_attrs, nr_ids, i, j;
cc9784bd 2488 int fd = perf_data_file__fd(file);
7c6a1c65 2489
334fe7a3 2490 session->evlist = perf_evlist__new();
a91e5431
ACM
2491 if (session->evlist == NULL)
2492 return -ENOMEM;
2493
cc9784bd 2494 if (perf_data_file__is_pipe(file))
d4339569 2495 return perf_header__read_pipe(session);
8dc58101 2496
69996df4 2497 if (perf_file_header__read(&f_header, header, fd) < 0)
4dc0a04b 2498 return -EINVAL;
7c6a1c65 2499
b314e5cf
NK
2500 /*
2501 * Sanity check that perf.data was written cleanly; data size is
2502 * initialized to 0 and updated only if the on_exit function is run.
2503 * If data size is still 0 then the file contains only partial
2504 * information. Just warn user and process it as much as it can.
2505 */
2506 if (f_header.data.size == 0) {
2507 pr_warning("WARNING: The %s file's data size field is 0 which is unexpected.\n"
2508 "Was the 'perf record' command properly terminated?\n",
cc9784bd 2509 file->path);
b314e5cf
NK
2510 }
2511
69996df4 2512 nr_attrs = f_header.attrs.size / f_header.attr_size;
7c6a1c65
PZ
2513 lseek(fd, f_header.attrs.offset, SEEK_SET);
2514
2515 for (i = 0; i < nr_attrs; i++) {
a91e5431 2516 struct perf_evsel *evsel;
1c222bce 2517 off_t tmp;
7c6a1c65 2518
69996df4 2519 if (read_attr(fd, header, &f_attr) < 0)
769885f3 2520 goto out_errno;
ba21594c 2521
eda3913b
DA
2522 if (header->needs_swap)
2523 perf_event__attr_swap(&f_attr.attr);
2524
1c222bce 2525 tmp = lseek(fd, 0, SEEK_CUR);
ef503831 2526 evsel = perf_evsel__new(&f_attr.attr);
7c6a1c65 2527
a91e5431
ACM
2528 if (evsel == NULL)
2529 goto out_delete_evlist;
0807d2d8
ACM
2530
2531 evsel->needs_swap = header->needs_swap;
a91e5431
ACM
2532 /*
2533 * Do it before so that if perf_evsel__alloc_id fails, this
2534 * entry gets purged too at perf_evlist__delete().
2535 */
2536 perf_evlist__add(session->evlist, evsel);
7c6a1c65
PZ
2537
2538 nr_ids = f_attr.ids.size / sizeof(u64);
a91e5431
ACM
2539 /*
2540 * We don't have the cpu and thread maps on the header, so
2541 * for allocating the perf_sample_id table we fake 1 cpu and
2542 * hattr->ids threads.
2543 */
2544 if (perf_evsel__alloc_id(evsel, 1, nr_ids))
2545 goto out_delete_evlist;
2546
7c6a1c65
PZ
2547 lseek(fd, f_attr.ids.offset, SEEK_SET);
2548
2549 for (j = 0; j < nr_ids; j++) {
1c0b04d1 2550 if (perf_header__getbuffer64(header, fd, &f_id, sizeof(f_id)))
769885f3 2551 goto out_errno;
7c6a1c65 2552
a91e5431 2553 perf_evlist__id_add(session->evlist, evsel, 0, j, f_id);
7c6a1c65 2554 }
11deb1f9 2555
7c6a1c65
PZ
2556 lseek(fd, tmp, SEEK_SET);
2557 }
2558
d04b35f8
ACM
2559 symbol_conf.nr_events = nr_attrs;
2560
29f5ffd3 2561 perf_header__process_sections(header, fd, &session->tevent,
fbe96f29 2562 perf_file_section__process);
4778d2e4 2563
831394bd 2564 if (perf_evlist__prepare_tracepoint_events(session->evlist,
29f5ffd3 2565 session->tevent.pevent))
cb9dd49e
ACM
2566 goto out_delete_evlist;
2567
4dc0a04b 2568 return 0;
769885f3
ACM
2569out_errno:
2570 return -errno;
a91e5431
ACM
2571
2572out_delete_evlist:
2573 perf_evlist__delete(session->evlist);
2574 session->evlist = NULL;
2575 return -ENOMEM;
7c6a1c65 2576}
0d3a5c88 2577
45694aa7 2578int perf_event__synthesize_attr(struct perf_tool *tool,
f4d83436 2579 struct perf_event_attr *attr, u32 ids, u64 *id,
743eb868 2580 perf_event__handler_t process)
2c46dbb5 2581{
8115d60c 2582 union perf_event *ev;
2c46dbb5
TZ
2583 size_t size;
2584 int err;
2585
2586 size = sizeof(struct perf_event_attr);
9ac3e487 2587 size = PERF_ALIGN(size, sizeof(u64));
2c46dbb5
TZ
2588 size += sizeof(struct perf_event_header);
2589 size += ids * sizeof(u64);
2590
2591 ev = malloc(size);
2592
ce47dc56
CS
2593 if (ev == NULL)
2594 return -ENOMEM;
2595
2c46dbb5
TZ
2596 ev->attr.attr = *attr;
2597 memcpy(ev->attr.id, id, ids * sizeof(u64));
2598
2599 ev->attr.header.type = PERF_RECORD_HEADER_ATTR;
f4d83436 2600 ev->attr.header.size = (u16)size;
2c46dbb5 2601
f4d83436
RR
2602 if (ev->attr.header.size == size)
2603 err = process(tool, ev, NULL, NULL);
2604 else
2605 err = -E2BIG;
2c46dbb5
TZ
2606
2607 free(ev);
2608
2609 return err;
2610}
2611
45694aa7 2612int perf_event__synthesize_attrs(struct perf_tool *tool,
d20deb64 2613 struct perf_session *session,
a91e5431 2614 perf_event__handler_t process)
2c46dbb5 2615{
6606f873 2616 struct perf_evsel *evsel;
a91e5431 2617 int err = 0;
2c46dbb5 2618
0050f7aa 2619 evlist__for_each(session->evlist, evsel) {
6606f873
RR
2620 err = perf_event__synthesize_attr(tool, &evsel->attr, evsel->ids,
2621 evsel->id, process);
2c46dbb5
TZ
2622 if (err) {
2623 pr_debug("failed to create perf header attribute\n");
2624 return err;
2625 }
2626 }
2627
2628 return err;
2629}
2630
47c3d109
AH
2631int perf_event__process_attr(struct perf_tool *tool __maybe_unused,
2632 union perf_event *event,
10d0f086 2633 struct perf_evlist **pevlist)
2c46dbb5 2634{
f4d83436 2635 u32 i, ids, n_ids;
a91e5431 2636 struct perf_evsel *evsel;
10d0f086 2637 struct perf_evlist *evlist = *pevlist;
2c46dbb5 2638
10d0f086 2639 if (evlist == NULL) {
334fe7a3 2640 *pevlist = evlist = perf_evlist__new();
10d0f086 2641 if (evlist == NULL)
a91e5431
ACM
2642 return -ENOMEM;
2643 }
2644
ef503831 2645 evsel = perf_evsel__new(&event->attr.attr);
a91e5431 2646 if (evsel == NULL)
2c46dbb5
TZ
2647 return -ENOMEM;
2648
10d0f086 2649 perf_evlist__add(evlist, evsel);
a91e5431 2650
8115d60c
ACM
2651 ids = event->header.size;
2652 ids -= (void *)&event->attr.id - (void *)event;
2c46dbb5 2653 n_ids = ids / sizeof(u64);
a91e5431
ACM
2654 /*
2655 * We don't have the cpu and thread maps on the header, so
2656 * for allocating the perf_sample_id table we fake 1 cpu and
2657 * hattr->ids threads.
2658 */
2659 if (perf_evsel__alloc_id(evsel, 1, n_ids))
2660 return -ENOMEM;
2c46dbb5
TZ
2661
2662 for (i = 0; i < n_ids; i++) {
10d0f086 2663 perf_evlist__id_add(evlist, evsel, 0, i, event->attr.id[i]);
2c46dbb5
TZ
2664 }
2665
7e0d6fc9
AH
2666 symbol_conf.nr_events = evlist->nr_entries;
2667
2c46dbb5
TZ
2668 return 0;
2669}
cd19a035 2670
45694aa7 2671int perf_event__synthesize_tracing_data(struct perf_tool *tool, int fd,
d20deb64 2672 struct perf_evlist *evlist,
743eb868 2673 perf_event__handler_t process)
9215545e 2674{
8115d60c 2675 union perf_event ev;
29208e57 2676 struct tracing_data *tdata;
9215545e 2677 ssize_t size = 0, aligned_size = 0, padding;
1d037ca1 2678 int err __maybe_unused = 0;
9215545e 2679
29208e57
JO
2680 /*
2681 * We are going to store the size of the data followed
2682 * by the data contents. Since the fd descriptor is a pipe,
2683 * we cannot seek back to store the size of the data once
2684 * we know it. Instead we:
2685 *
2686 * - write the tracing data to the temp file
2687 * - get/write the data size to pipe
2688 * - write the tracing data from the temp file
2689 * to the pipe
2690 */
2691 tdata = tracing_data_get(&evlist->entries, fd, true);
2692 if (!tdata)
2693 return -1;
2694
9215545e
TZ
2695 memset(&ev, 0, sizeof(ev));
2696
2697 ev.tracing_data.header.type = PERF_RECORD_HEADER_TRACING_DATA;
29208e57 2698 size = tdata->size;
9ac3e487 2699 aligned_size = PERF_ALIGN(size, sizeof(u64));
9215545e
TZ
2700 padding = aligned_size - size;
2701 ev.tracing_data.header.size = sizeof(ev.tracing_data);
2702 ev.tracing_data.size = aligned_size;
2703
45694aa7 2704 process(tool, &ev, NULL, NULL);
9215545e 2705
29208e57
JO
2706 /*
2707 * The put function will copy all the tracing data
2708 * stored in temp file to the pipe.
2709 */
2710 tracing_data_put(tdata);
2711
9215545e
TZ
2712 write_padded(fd, NULL, 0, padding);
2713
2714 return aligned_size;
2715}
2716
47c3d109
AH
2717int perf_event__process_tracing_data(struct perf_tool *tool __maybe_unused,
2718 union perf_event *event,
8115d60c 2719 struct perf_session *session)
9215545e 2720{
8115d60c 2721 ssize_t size_read, padding, size = event->tracing_data.size;
cc9784bd
JO
2722 int fd = perf_data_file__fd(session->file);
2723 off_t offset = lseek(fd, 0, SEEK_CUR);
9215545e
TZ
2724 char buf[BUFSIZ];
2725
2726 /* setup for reading amidst mmap */
cc9784bd 2727 lseek(fd, offset + sizeof(struct tracing_data_event),
9215545e
TZ
2728 SEEK_SET);
2729
29f5ffd3 2730 size_read = trace_report(fd, &session->tevent,
da378962 2731 session->repipe);
9ac3e487 2732 padding = PERF_ALIGN(size_read, sizeof(u64)) - size_read;
9215545e 2733
cc9784bd 2734 if (readn(fd, buf, padding) < 0) {
2caa48a2
ACM
2735 pr_err("%s: reading input file", __func__);
2736 return -1;
2737 }
454c407e
TZ
2738 if (session->repipe) {
2739 int retw = write(STDOUT_FILENO, buf, padding);
2caa48a2
ACM
2740 if (retw <= 0 || retw != padding) {
2741 pr_err("%s: repiping tracing data padding", __func__);
2742 return -1;
2743 }
454c407e 2744 }
9215545e 2745
2caa48a2
ACM
2746 if (size_read + padding != size) {
2747 pr_err("%s: tracing data size mismatch", __func__);
2748 return -1;
2749 }
9215545e 2750
831394bd 2751 perf_evlist__prepare_tracepoint_events(session->evlist,
29f5ffd3 2752 session->tevent.pevent);
8b6ee4c5 2753
9215545e
TZ
2754 return size_read + padding;
2755}
c7929e47 2756
45694aa7 2757int perf_event__synthesize_build_id(struct perf_tool *tool,
d20deb64 2758 struct dso *pos, u16 misc,
8115d60c 2759 perf_event__handler_t process,
743eb868 2760 struct machine *machine)
c7929e47 2761{
8115d60c 2762 union perf_event ev;
c7929e47
TZ
2763 size_t len;
2764 int err = 0;
2765
2766 if (!pos->hit)
2767 return err;
2768
2769 memset(&ev, 0, sizeof(ev));
2770
2771 len = pos->long_name_len + 1;
9ac3e487 2772 len = PERF_ALIGN(len, NAME_ALIGN);
c7929e47
TZ
2773 memcpy(&ev.build_id.build_id, pos->build_id, sizeof(pos->build_id));
2774 ev.build_id.header.type = PERF_RECORD_HEADER_BUILD_ID;
2775 ev.build_id.header.misc = misc;
23346f21 2776 ev.build_id.pid = machine->pid;
c7929e47
TZ
2777 ev.build_id.header.size = sizeof(ev.build_id) + len;
2778 memcpy(&ev.build_id.filename, pos->long_name, pos->long_name_len);
2779
45694aa7 2780 err = process(tool, &ev, NULL, machine);
c7929e47
TZ
2781
2782 return err;
2783}
2784
1d037ca1 2785int perf_event__process_build_id(struct perf_tool *tool __maybe_unused,
d20deb64 2786 union perf_event *event,
8115d60c 2787 struct perf_session *session)
c7929e47 2788{
8115d60c
ACM
2789 __event_process_build_id(&event->build_id,
2790 event->build_id.filename,
a1645ce1 2791 session);
c7929e47
TZ
2792 return 0;
2793}
This page took 0.352761 seconds and 5 git commands to generate.