header.c 20.5 KB
Newer Older
1 2
#define _FILE_OFFSET_BITS 64

3
#include <sys/types.h>
4
#include <byteswap.h>
5 6 7
#include <unistd.h>
#include <stdio.h>
#include <stdlib.h>
8
#include <linux/list.h>
9
#include <linux/kernel.h>
10 11 12

#include "util.h"
#include "header.h"
13 14
#include "../perf.h"
#include "trace-event.h"
15
#include "session.h"
16
#include "symbol.h"
17
#include "debug.h"
18 19

/*
20
 * Create new perf.data header attribute:
21
 */
22
struct perf_header_attr *perf_header_attr__new(struct perf_event_attr *attr)
23 24 25
{
	struct perf_header_attr *self = malloc(sizeof(*self));

26 27 28 29 30 31 32 33 34 35
	if (self != NULL) {
		self->attr = *attr;
		self->ids  = 0;
		self->size = 1;
		self->id   = malloc(sizeof(u64));
		if (self->id == NULL) {
			free(self);
			self = NULL;
		}
	}
36 37 38 39

	return self;
}

40 41 42 43 44 45
void perf_header_attr__delete(struct perf_header_attr *self)
{
	free(self->id);
	free(self);
}

46
int perf_header_attr__add_id(struct perf_header_attr *self, u64 id)
47 48 49 50 51
{
	int pos = self->ids;

	self->ids++;
	if (self->ids > self->size) {
52 53 54 55 56 57 58 59
		int nsize = self->size * 2;
		u64 *nid = realloc(self->id, nsize * sizeof(u64));

		if (nid == NULL)
			return -1;

		self->size = nsize;
		self->id = nid;
60 61
	}
	self->id[pos] = id;
62
	return 0;
63 64
}

65
int perf_header__init(struct perf_header *self)
66
{
67 68 69
	self->size = 1;
	self->attr = malloc(sizeof(void *));
	return self->attr == NULL ? -ENOMEM : 0;
70 71
}

72
void perf_header__exit(struct perf_header *self)
73 74 75
{
	int i;
	for (i = 0; i < self->attrs; ++i)
76
                perf_header_attr__delete(self->attr[i]);
77 78 79
	free(self->attr);
}

80 81
int perf_header__add_attr(struct perf_header *self,
			  struct perf_header_attr *attr)
82 83
{
	if (self->frozen)
84
		return -1;
85

86
	if (self->attrs == self->size) {
87 88 89 90 91 92 93 94 95
		int nsize = self->size * 2;
		struct perf_header_attr **nattr;

		nattr = realloc(self->attr, nsize * sizeof(void *));
		if (nattr == NULL)
			return -1;

		self->size = nsize;
		self->attr = nattr;
96
	}
97 98

	self->attr[self->attrs++] = attr;
99
	return 0;
100 101
}

102 103 104
static int event_count;
static struct perf_trace_event_type *events;

105
int perf_header__push_event(u64 id, const char *name)
106
{
107
	if (strlen(name) > MAX_EVENT_NAME)
108
		pr_warning("Event %s will be truncated\n", name);
109 110 111

	if (!events) {
		events = malloc(sizeof(struct perf_trace_event_type));
112 113
		if (events == NULL)
			return -ENOMEM;
114
	} else {
115 116 117 118 119 120
		struct perf_trace_event_type *nevents;

		nevents = realloc(events, (event_count + 1) * sizeof(*events));
		if (nevents == NULL)
			return -ENOMEM;
		events = nevents;
121 122 123
	}
	memset(&events[event_count], 0, sizeof(struct perf_trace_event_type));
	events[event_count].event_id = id;
124
	strncpy(events[event_count].name, name, MAX_EVENT_NAME - 1);
125
	event_count++;
126
	return 0;
127 128 129 130 131 132 133 134 135 136 137 138
}

char *perf_header__find_event(u64 id)
{
	int i;
	for (i = 0 ; i < event_count; i++) {
		if (events[i].event_id == id)
			return events[i].name;
	}
	return NULL;
}

139 140 141 142 143
static const char *__perf_magic = "PERFFILE";

#define PERF_MAGIC	(*(u64 *)__perf_magic)

struct perf_file_attr {
144
	struct perf_event_attr	attr;
145 146 147
	struct perf_file_section	ids;
};

148 149 150 151 152 153 154 155 156 157
void perf_header__set_feat(struct perf_header *self, int feat)
{
	set_bit(feat, self->adds_features);
}

bool perf_header__has_feat(const struct perf_header *self, int feat)
{
	return test_bit(feat, self->adds_features);
}

158
static int do_write(int fd, const void *buf, size_t size)
159 160 161 162 163
{
	while (size) {
		int ret = write(fd, buf, size);

		if (ret < 0)
164
			return -errno;
165 166 167 168

		size -= ret;
		buf += ret;
	}
169 170

	return 0;
171 172
}

173 174 175 176 177 178 179 180 181 182 183 184 185 186
#define NAME_ALIGN 64

static int write_padded(int fd, const void *bf, size_t count,
			size_t count_aligned)
{
	static const char zero_buf[NAME_ALIGN];
	int err = do_write(fd, bf, count);

	if (!err)
		err = do_write(fd, zero_buf, count_aligned - count);

	return err;
}

187 188 189 190 191 192
#define dsos__for_each_with_build_id(pos, head)	\
	list_for_each_entry(pos, head, node)	\
		if (!pos->has_build_id)		\
			continue;		\
		else

193
static int __dsos__write_buildid_table(struct list_head *head, u16 misc, int fd)
194
{
195 196
	struct dso *pos;

197
	dsos__for_each_with_build_id(pos, head) {
198
		int err;
199
		struct build_id_event b;
200
		size_t len;
201

202 203 204
		if (!pos->hit)
			continue;
		len = pos->long_name_len + 1;
O
OGAWA Hirofumi 已提交
205
		len = ALIGN(len, NAME_ALIGN);
206 207
		memset(&b, 0, sizeof(b));
		memcpy(&b.build_id, pos->build_id, sizeof(pos->build_id));
208
		b.header.misc = misc;
209
		b.header.size = sizeof(b) + len;
210 211 212
		err = do_write(fd, &b, sizeof(b));
		if (err < 0)
			return err;
213 214
		err = write_padded(fd, pos->long_name,
				   pos->long_name_len + 1, len);
215 216
		if (err < 0)
			return err;
217
	}
218 219

	return 0;
220 221
}

222 223
static int dsos__write_buildid_table(int fd)
{
224 225
	int err = __dsos__write_buildid_table(&dsos__kernel,
					      PERF_RECORD_MISC_KERNEL, fd);
226
	if (err == 0)
227 228
		err = __dsos__write_buildid_table(&dsos__user,
						  PERF_RECORD_MISC_USER, fd);
229 230 231
	return err;
}

232 233
int build_id_cache__add_s(const char *sbuild_id, const char *debugdir,
			  const char *name, bool is_kallsyms)
234 235 236
{
	const size_t size = PATH_MAX;
	char *filename = malloc(size),
237
	     *linkname = malloc(size), *targetname;
238 239 240 241 242
	int len, err = -1;

	if (filename == NULL || linkname == NULL)
		goto out_free;

243
	len = snprintf(filename, size, "%s%s%s",
244
		       debugdir, is_kallsyms ? "/" : "", name);
245 246 247
	if (mkdir_p(filename, 0755))
		goto out_free;

248
	snprintf(filename + len, sizeof(filename) - len, "/%s", sbuild_id);
249

250 251 252 253
	if (access(filename, F_OK)) {
		if (is_kallsyms) {
			 if (copyfile("/proc/kallsyms", filename))
				goto out_free;
254
		} else if (link(name, filename) && copyfile(name, filename))
255 256
			goto out_free;
	}
257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275

	len = snprintf(linkname, size, "%s/.build-id/%.2s",
		       debugdir, sbuild_id);

	if (access(linkname, X_OK) && mkdir_p(linkname, 0755))
		goto out_free;

	snprintf(linkname + len, size - len, "/%s", sbuild_id + 2);
	targetname = filename + strlen(debugdir) - 5;
	memcpy(targetname, "../..", 5);

	if (symlink(targetname, linkname) == 0)
		err = 0;
out_free:
	free(filename);
	free(linkname);
	return err;
}

276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332
static int build_id_cache__add_b(const u8 *build_id, size_t build_id_size,
				 const char *name, const char *debugdir,
				 bool is_kallsyms)
{
	char sbuild_id[BUILD_ID_SIZE * 2 + 1];

	build_id__sprintf(build_id, build_id_size, sbuild_id);

	return build_id_cache__add_s(sbuild_id, debugdir, name, is_kallsyms);
}

int build_id_cache__remove_s(const char *sbuild_id, const char *debugdir)
{
	const size_t size = PATH_MAX;
	char *filename = malloc(size),
	     *linkname = malloc(size);
	int err = -1;

	if (filename == NULL || linkname == NULL)
		goto out_free;

	snprintf(linkname, size, "%s/.build-id/%.2s/%s",
		 debugdir, sbuild_id, sbuild_id + 2);

	if (access(linkname, F_OK))
		goto out_free;

	if (readlink(linkname, filename, size) < 0)
		goto out_free;

	if (unlink(linkname))
		goto out_free;

	/*
	 * Since the link is relative, we must make it absolute:
	 */
	snprintf(linkname, size, "%s/.build-id/%.2s/%s",
		 debugdir, sbuild_id, filename);

	if (unlink(linkname))
		goto out_free;

	err = 0;
out_free:
	free(filename);
	free(linkname);
	return err;
}

static int dso__cache_build_id(struct dso *self, const char *debugdir)
{
	bool is_kallsyms = self->kernel && self->long_name[0] != '/';

	return build_id_cache__add_b(self->build_id, sizeof(self->build_id),
				     self->long_name, debugdir, is_kallsyms);
}

333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360
static int __dsos__cache_build_ids(struct list_head *head, const char *debugdir)
{
	struct dso *pos;
	int err = 0;

	dsos__for_each_with_build_id(pos, head)
		if (dso__cache_build_id(pos, debugdir))
			err = -1;

	return err;
}

static int dsos__cache_build_ids(void)
{
	int err_kernel, err_user;
	char debugdir[PATH_MAX];

	snprintf(debugdir, sizeof(debugdir), "%s/%s", getenv("HOME"),
		 DEBUG_CACHE_DIR);

	if (mkdir(debugdir, 0755) != 0 && errno != EEXIST)
		return -1;

	err_kernel = __dsos__cache_build_ids(&dsos__kernel, debugdir);
	err_user   = __dsos__cache_build_ids(&dsos__user, debugdir);
	return err_kernel || err_user ? -1 : 0;
}

361
static int perf_header__adds_write(struct perf_header *self, int fd)
362
{
363 364 365 366
	int nr_sections;
	struct perf_file_section *feat_sec;
	int sec_size;
	u64 sec_start;
367
	int idx = 0, err;
368

369
	if (dsos__read_build_ids(true))
370 371 372 373
		perf_header__set_feat(self, HEADER_BUILD_ID);

	nr_sections = bitmap_weight(self->adds_features, HEADER_FEAT_BITS);
	if (!nr_sections)
374
		return 0;
375 376

	feat_sec = calloc(sizeof(*feat_sec), nr_sections);
377 378
	if (feat_sec == NULL)
		return -ENOMEM;
379 380 381 382

	sec_size = sizeof(*feat_sec) * nr_sections;

	sec_start = self->data_offset + self->data_size;
383
	lseek(fd, sec_start + sec_size, SEEK_SET);
384

385
	if (perf_header__has_feat(self, HEADER_TRACE_INFO)) {
386 387 388 389
		struct perf_file_section *trace_sec;

		trace_sec = &feat_sec[idx++];

390
		/* Write trace info */
391
		trace_sec->offset = lseek(fd, 0, SEEK_CUR);
392
		read_tracing_data(fd, attrs, nr_counters);
393
		trace_sec->size = lseek(fd, 0, SEEK_CUR) - trace_sec->offset;
394
	}
395

396

397 398 399 400 401 402
	if (perf_header__has_feat(self, HEADER_BUILD_ID)) {
		struct perf_file_section *buildid_sec;

		buildid_sec = &feat_sec[idx++];

		/* Write build-ids */
403
		buildid_sec->offset = lseek(fd, 0, SEEK_CUR);
404 405 406 407 408
		err = dsos__write_buildid_table(fd);
		if (err < 0) {
			pr_debug("failed to write buildid table\n");
			goto out_free;
		}
409 410
		buildid_sec->size = lseek(fd, 0, SEEK_CUR) -
					  buildid_sec->offset;
411
		dsos__cache_build_ids();
412
	}
413

414
	lseek(fd, sec_start, SEEK_SET);
415 416 417 418
	err = do_write(fd, feat_sec, sec_size);
	if (err < 0)
		pr_debug("failed to write feature section\n");
out_free:
419
	free(feat_sec);
420
	return err;
421
}
422

423 424 425 426 427 428 429 430 431 432 433 434 435 436 437 438 439 440 441
int perf_header__write_pipe(int fd)
{
	struct perf_pipe_file_header f_header;
	int err;

	f_header = (struct perf_pipe_file_header){
		.magic	   = PERF_MAGIC,
		.size	   = sizeof(f_header),
	};

	err = do_write(fd, &f_header, sizeof(f_header));
	if (err < 0) {
		pr_debug("failed to write perf pipe header\n");
		return err;
	}

	return 0;
}

442
int perf_header__write(struct perf_header *self, int fd, bool at_exit)
443 444 445 446
{
	struct perf_file_header f_header;
	struct perf_file_attr   f_attr;
	struct perf_header_attr	*attr;
447
	int i, err;
448 449 450 451 452 453 454 455

	lseek(fd, sizeof(f_header), SEEK_SET);


	for (i = 0; i < self->attrs; i++) {
		attr = self->attr[i];

		attr->id_offset = lseek(fd, 0, SEEK_CUR);
456 457 458 459 460
		err = do_write(fd, attr->id, attr->ids * sizeof(u64));
		if (err < 0) {
			pr_debug("failed to write perf header\n");
			return err;
		}
461 462 463 464 465 466 467 468 469 470 471 472 473 474 475
	}


	self->attr_offset = lseek(fd, 0, SEEK_CUR);

	for (i = 0; i < self->attrs; i++) {
		attr = self->attr[i];

		f_attr = (struct perf_file_attr){
			.attr = attr->attr,
			.ids  = {
				.offset = attr->id_offset,
				.size   = attr->ids * sizeof(u64),
			}
		};
476 477 478 479 480
		err = do_write(fd, &f_attr, sizeof(f_attr));
		if (err < 0) {
			pr_debug("failed to write perf header attribute\n");
			return err;
		}
481 482
	}

483 484
	self->event_offset = lseek(fd, 0, SEEK_CUR);
	self->event_size = event_count * sizeof(struct perf_trace_event_type);
485 486 487 488 489 490 491
	if (events) {
		err = do_write(fd, events, self->event_size);
		if (err < 0) {
			pr_debug("failed to write perf header events\n");
			return err;
		}
	}
492

493 494
	self->data_offset = lseek(fd, 0, SEEK_CUR);

495 496 497 498 499
	if (at_exit) {
		err = perf_header__adds_write(self, fd);
		if (err < 0)
			return err;
	}
500

501 502 503 504 505 506 507 508 509 510 511 512
	f_header = (struct perf_file_header){
		.magic	   = PERF_MAGIC,
		.size	   = sizeof(f_header),
		.attr_size = sizeof(f_attr),
		.attrs = {
			.offset = self->attr_offset,
			.size   = self->attrs * sizeof(f_attr),
		},
		.data = {
			.offset = self->data_offset,
			.size	= self->data_size,
		},
513 514 515 516
		.event_types = {
			.offset = self->event_offset,
			.size	= self->event_size,
		},
517 518
	};

519
	memcpy(&f_header.adds_features, &self->adds_features, sizeof(self->adds_features));
520

521
	lseek(fd, 0, SEEK_SET);
522 523 524 525 526
	err = do_write(fd, &f_header, sizeof(f_header));
	if (err < 0) {
		pr_debug("failed to write perf header\n");
		return err;
	}
527
	lseek(fd, self->data_offset + self->data_size, SEEK_SET);
528 529

	self->frozen = 1;
530
	return 0;
531 532
}

533 534 535
static int perf_header__getbuffer64(struct perf_header *self,
				    int fd, void *buf, size_t size)
{
536
	if (do_read(fd, buf, size) <= 0)
537 538 539 540 541 542 543 544
		return -1;

	if (self->needs_swap)
		mem_bswap_64(buf, size);

	return 0;
}

545 546
int perf_header__process_sections(struct perf_header *self, int fd,
				  int (*process)(struct perf_file_section *self,
547
						 struct perf_header *ph,
548
						 int feat, int fd))
549
{
550 551 552 553
	struct perf_file_section *feat_sec;
	int nr_sections;
	int sec_size;
	int idx = 0;
554
	int err = -1, feat = 1;
555 556 557

	nr_sections = bitmap_weight(self->adds_features, HEADER_FEAT_BITS);
	if (!nr_sections)
558
		return 0;
559 560 561

	feat_sec = calloc(sizeof(*feat_sec), nr_sections);
	if (!feat_sec)
562
		return -1;
563 564 565

	sec_size = sizeof(*feat_sec) * nr_sections;

566
	lseek(fd, self->data_offset + self->data_size, SEEK_SET);
567

568
	if (perf_header__getbuffer64(self, fd, feat_sec, sec_size))
569
		goto out_free;
570

571
	err = 0;
572 573 574
	while (idx < nr_sections && feat < HEADER_LAST_FEATURE) {
		if (perf_header__has_feat(self, feat)) {
			struct perf_file_section *sec = &feat_sec[idx++];
575

576
			err = process(sec, self, feat, fd);
577 578 579 580
			if (err < 0)
				break;
		}
		++feat;
581
	}
582
out_free:
583 584
	free(feat_sec);
	return err;
585
}
586

587 588 589 590 591
int perf_file_header__read(struct perf_file_header *self,
			   struct perf_header *ph, int fd)
{
	lseek(fd, 0, SEEK_SET);

592
	if (do_read(fd, self, sizeof(*self)) <= 0 ||
593
	    memcmp(&self->magic, __perf_magic, sizeof(self->magic)))
594 595
		return -1;

596 597 598 599 600 601 602 603 604 605 606
	if (self->attr_size != sizeof(struct perf_file_attr)) {
		u64 attr_size = bswap_64(self->attr_size);

		if (attr_size != sizeof(struct perf_file_attr))
			return -1;

		mem_bswap_64(self, offsetof(struct perf_file_header,
					    adds_features));
		ph->needs_swap = true;
	}

607 608 609 610 611 612
	if (self->size != sizeof(*self)) {
		/* Support the previous format */
		if (self->size == offsetof(typeof(*self), adds_features))
			bitmap_zero(self->adds_features, HEADER_FEAT_BITS);
		else
			return -1;
613
	}
614

615
	memcpy(&ph->adds_features, &self->adds_features,
616 617 618 619 620 621 622 623 624 625 626 627
	       sizeof(ph->adds_features));
	/*
	 * FIXME: hack that assumes that if we need swap the perf.data file
	 * may be coming from an arch with a different word-size, ergo different
	 * DEFINE_BITMAP format, investigate more later, but for now its mostly
	 * safe to assume that we have a build-id section. Trace files probably
	 * have several other issues in this realm anyway...
	 */
	if (ph->needs_swap) {
		memset(&ph->adds_features, 0, sizeof(ph->adds_features));
		perf_header__set_feat(ph, HEADER_BUILD_ID);
	}
628 629

	ph->event_offset = self->event_types.offset;
630 631
	ph->event_size   = self->event_types.size;
	ph->data_offset  = self->data.offset;
632 633 634 635 636
	ph->data_size	 = self->data.size;
	return 0;
}

static int perf_file_section__process(struct perf_file_section *self,
637
				      struct perf_header *ph,
638 639
				      int feat, int fd)
{
640
	if (lseek(fd, self->offset, SEEK_SET) == (off_t)-1) {
641 642 643 644 645 646 647 648 649 650 651
		pr_debug("Failed to lseek to %Ld offset for feature %d, "
			 "continuing...\n", self->offset, feat);
		return 0;
	}

	switch (feat) {
	case HEADER_TRACE_INFO:
		trace_report(fd);
		break;

	case HEADER_BUILD_ID:
652
		if (perf_header__read_build_ids(ph, fd, self->offset, self->size))
653 654 655 656 657 658 659 660
			pr_debug("Failed to read buildids, continuing...\n");
		break;
	default:
		pr_debug("unknown feature %d, continuing...\n", feat);
	}

	return 0;
}
661

662 663
static int perf_file_header__read_pipe(struct perf_pipe_file_header *self,
				       struct perf_header *ph, int fd)
664
{
665 666 667 668 669 670 671 672 673 674 675 676 677 678 679 680 681 682 683 684 685 686 687 688 689 690 691 692 693 694 695 696 697 698
	if (do_read(fd, self, sizeof(*self)) <= 0 ||
	    memcmp(&self->magic, __perf_magic, sizeof(self->magic)))
		return -1;

	if (self->size != sizeof(*self)) {
		u64 size = bswap_64(self->size);

		if (size != sizeof(*self))
			return -1;

		ph->needs_swap = true;
	}

	return 0;
}

static int perf_header__read_pipe(struct perf_session *session, int fd)
{
	struct perf_header *self = &session->header;
	struct perf_pipe_file_header f_header;

	if (perf_file_header__read_pipe(&f_header, self, fd) < 0) {
		pr_debug("incompatible file format\n");
		return -EINVAL;
	}

	session->fd = fd;

	return 0;
}

int perf_header__read(struct perf_session *session, int fd)
{
	struct perf_header *self = &session->header;
699
	struct perf_file_header	f_header;
700 701 702 703
	struct perf_file_attr	f_attr;
	u64			f_id;
	int nr_attrs, nr_ids, i, j;

704 705 706
	if (session->fd_pipe)
		return perf_header__read_pipe(session, fd);

707 708 709 710
	if (perf_file_header__read(&f_header, self, fd) < 0) {
		pr_debug("incompatible file format\n");
		return -EINVAL;
	}
711 712 713 714 715 716

	nr_attrs = f_header.attrs.size / sizeof(f_attr);
	lseek(fd, f_header.attrs.offset, SEEK_SET);

	for (i = 0; i < nr_attrs; i++) {
		struct perf_header_attr *attr;
717
		off_t tmp;
718

719
		if (perf_header__getbuffer64(self, fd, &f_attr, sizeof(f_attr)))
720
			goto out_errno;
721

722
		tmp = lseek(fd, 0, SEEK_CUR);
723 724

		attr = perf_header_attr__new(&f_attr.attr);
725
		if (attr == NULL)
726
			 return -ENOMEM;
727 728 729 730 731

		nr_ids = f_attr.ids.size / sizeof(u64);
		lseek(fd, f_attr.ids.offset, SEEK_SET);

		for (j = 0; j < nr_ids; j++) {
732
			if (perf_header__getbuffer64(self, fd, &f_id, sizeof(f_id)))
733
				goto out_errno;
734

735 736 737 738 739 740 741 742
			if (perf_header_attr__add_id(attr, f_id) < 0) {
				perf_header_attr__delete(attr);
				return -ENOMEM;
			}
		}
		if (perf_header__add_attr(self, attr) < 0) {
			perf_header_attr__delete(attr);
			return -ENOMEM;
743
		}
744

745 746 747
		lseek(fd, tmp, SEEK_SET);
	}

748 749 750
	if (f_header.event_types.size) {
		lseek(fd, f_header.event_types.offset, SEEK_SET);
		events = malloc(f_header.event_types.size);
751 752
		if (events == NULL)
			return -ENOMEM;
753 754
		if (perf_header__getbuffer64(self, fd, events,
					     f_header.event_types.size))
755
			goto out_errno;
756 757
		event_count =  f_header.event_types.size / sizeof(struct perf_trace_event_type);
	}
758

759
	perf_header__process_sections(self, fd, perf_file_section__process);
760

761
	lseek(fd, self->data_offset, SEEK_SET);
762 763

	self->frozen = 1;
764
	return 0;
765 766
out_errno:
	return -errno;
767
}
768 769 770 771 772 773 774 775 776 777 778 779 780 781 782 783 784 785

u64 perf_header__sample_type(struct perf_header *header)
{
	u64 type = 0;
	int i;

	for (i = 0; i < header->attrs; i++) {
		struct perf_header_attr *attr = header->attr[i];

		if (!type)
			type = attr->attr.sample_type;
		else if (type != attr->attr.sample_type)
			die("non matching sample_type");
	}

	return type;
}

786
struct perf_event_attr *
787 788 789 790 791 792 793 794 795 796 797 798 799 800 801 802
perf_header__find_attr(u64 id, struct perf_header *header)
{
	int i;

	for (i = 0; i < header->attrs; i++) {
		struct perf_header_attr *attr = header->attr[i];
		int j;

		for (j = 0; j < attr->ids; j++) {
			if (attr->id[j] == id)
				return &attr->attr;
		}
	}

	return NULL;
}
803 804 805 806 807 808 809 810 811 812 813 814 815 816 817 818 819 820 821 822 823 824 825 826 827 828 829 830 831 832 833 834 835 836 837 838 839 840 841 842 843 844 845 846 847 848 849 850 851 852 853 854 855 856 857 858 859 860 861 862 863 864 865 866 867 868 869 870 871 872 873 874 875 876 877 878 879 880 881

int event__synthesize_attr(struct perf_event_attr *attr, u16 ids, u64 *id,
			   event__handler_t process,
			   struct perf_session *session)
{
	event_t *ev;
	size_t size;
	int err;

	size = sizeof(struct perf_event_attr);
	size = ALIGN(size, sizeof(u64));
	size += sizeof(struct perf_event_header);
	size += ids * sizeof(u64);

	ev = malloc(size);

	ev->attr.attr = *attr;
	memcpy(ev->attr.id, id, ids * sizeof(u64));

	ev->attr.header.type = PERF_RECORD_HEADER_ATTR;
	ev->attr.header.size = size;

	err = process(ev, session);

	free(ev);

	return err;
}

int event__synthesize_attrs(struct perf_header *self,
			    event__handler_t process,
			    struct perf_session *session)
{
	struct perf_header_attr	*attr;
	int i, err = 0;

	for (i = 0; i < self->attrs; i++) {
		attr = self->attr[i];

		err = event__synthesize_attr(&attr->attr, attr->ids, attr->id,
					     process, session);
		if (err) {
			pr_debug("failed to create perf header attribute\n");
			return err;
		}
	}

	return err;
}

int event__process_attr(event_t *self, struct perf_session *session)
{
	struct perf_header_attr *attr;
	unsigned int i, ids, n_ids;

	attr = perf_header_attr__new(&self->attr.attr);
	if (attr == NULL)
		return -ENOMEM;

	ids = self->header.size;
	ids -= (void *)&self->attr.id - (void *)self;
	n_ids = ids / sizeof(u64);

	for (i = 0; i < n_ids; i++) {
		if (perf_header_attr__add_id(attr, self->attr.id[i]) < 0) {
			perf_header_attr__delete(attr);
			return -ENOMEM;
		}
	}

	if (perf_header__add_attr(&session->header, attr) < 0) {
		perf_header_attr__delete(attr);
		return -ENOMEM;
	}

	perf_session__update_sample_type(session);

	return 0;
}
882 883 884 885 886 887 888 889 890 891 892 893 894 895 896 897 898 899 900 901 902 903 904 905 906 907 908 909 910 911 912 913 914 915 916 917 918 919 920 921 922 923 924 925 926 927 928 929 930 931 932 933 934 935 936

int event__synthesize_event_type(u64 event_id, char *name,
				 event__handler_t process,
				 struct perf_session *session)
{
	event_t ev;
	size_t size = 0;
	int err = 0;

	memset(&ev, 0, sizeof(ev));

	ev.event_type.event_type.event_id = event_id;
	memset(ev.event_type.event_type.name, 0, MAX_EVENT_NAME);
	strncpy(ev.event_type.event_type.name, name, MAX_EVENT_NAME - 1);

	ev.event_type.header.type = PERF_RECORD_HEADER_EVENT_TYPE;
	size = strlen(name);
	size = ALIGN(size, sizeof(u64));
	ev.event_type.header.size = sizeof(ev.event_type) -
		(sizeof(ev.event_type.event_type.name) - size);

	err = process(&ev, session);

	return err;
}

int event__synthesize_event_types(event__handler_t process,
				  struct perf_session *session)
{
	struct perf_trace_event_type *type;
	int i, err = 0;

	for (i = 0; i < event_count; i++) {
		type = &events[i];

		err = event__synthesize_event_type(type->event_id, type->name,
						   process, session);
		if (err) {
			pr_debug("failed to create perf header event type\n");
			return err;
		}
	}

	return err;
}

int event__process_event_type(event_t *self,
			      struct perf_session *session __unused)
{
	if (perf_header__push_event(self->event_type.event_type.event_id,
				    self->event_type.event_type.name) < 0)
		return -ENOMEM;

	return 0;
}