[mirror_ubuntu-zesty-kernel.git] / tools / perf / util / evsel.c

/*
 * Copyright (C) 2011, Red Hat Inc, Arnaldo Carvalho de Melo <acme@redhat.com>
 *
 * Parts came from builtin-{top,stat,record}.c, see those files for further
 * copyright notes.
 *
 * Released under the GPL v2. (and only v2, not any later version)
 */

#include <byteswap.h>
#include "asm/bug.h"
#include "evsel.h"
#include "evlist.h"
#include "util.h"
#include "cpumap.h"
#include "thread_map.h"

#define FD(e, x, y) (*(int *)xyarray__entry(e->fd, x, y))

int __perf_evsel__sample_size(u64 sample_type)
{
	u64 mask = sample_type & PERF_SAMPLE_MASK;
	int size = 0;
	int i;

	for (i = 0; i < 64; i++) {
		if (mask & (1ULL << i))
			size++;
	}

	size *= sizeof(u64);

	return size;
}

void perf_evsel__init(struct perf_evsel *evsel,
		      struct perf_event_attr *attr, int idx)
{
	evsel->idx	   = idx;
	evsel->attr	   = *attr;
	INIT_LIST_HEAD(&evsel->node);
}

struct perf_evsel *perf_evsel__new(struct perf_event_attr *attr, int idx)
{
	struct perf_evsel *evsel = zalloc(sizeof(*evsel));

	if (evsel != NULL)
		perf_evsel__init(evsel, attr, idx);

	return evsel;
}

int perf_evsel__alloc_fd(struct perf_evsel *evsel, int ncpus, int nthreads)
{
	int cpu, thread;
	evsel->fd = xyarray__new(ncpus, nthreads, sizeof(int));

	if (evsel->fd) {
		for (cpu = 0; cpu < ncpus; cpu++) {
			for (thread = 0; thread < nthreads; thread++) {
				FD(evsel, cpu, thread) = -1;
			}
		}
	}

	return evsel->fd != NULL ? 0 : -ENOMEM;
}

int perf_evsel__alloc_id(struct perf_evsel *evsel, int ncpus, int nthreads)
{
	evsel->sample_id = xyarray__new(ncpus, nthreads, sizeof(struct perf_sample_id));
	if (evsel->sample_id == NULL)
		return -ENOMEM;

	evsel->id = zalloc(ncpus * nthreads * sizeof(u64));
	if (evsel->id == NULL) {
		xyarray__delete(evsel->sample_id);
		evsel->sample_id = NULL;
		return -ENOMEM;
	}

	return 0;
}

int perf_evsel__alloc_counts(struct perf_evsel *evsel, int ncpus)
{
	evsel->counts = zalloc((sizeof(*evsel->counts) +
				(ncpus * sizeof(struct perf_counts_values))));
	return evsel->counts != NULL ? 0 : -ENOMEM;
}

void perf_evsel__free_fd(struct perf_evsel *evsel)
{
	xyarray__delete(evsel->fd);
	evsel->fd = NULL;
}

void perf_evsel__free_id(struct perf_evsel *evsel)
{
	xyarray__delete(evsel->sample_id);
	evsel->sample_id = NULL;
	free(evsel->id);
	evsel->id = NULL;
}

void perf_evsel__close_fd(struct perf_evsel *evsel, int ncpus, int nthreads)
{
	int cpu, thread;

	for (cpu = 0; cpu < ncpus; cpu++)
		for (thread = 0; thread < nthreads; ++thread) {
			close(FD(evsel, cpu, thread));
			FD(evsel, cpu, thread) = -1;
		}
}

void perf_evsel__exit(struct perf_evsel *evsel)
{
	assert(list_empty(&evsel->node));
	xyarray__delete(evsel->fd);
	xyarray__delete(evsel->sample_id);
	free(evsel->id);
}

void perf_evsel__delete(struct perf_evsel *evsel)
{
	perf_evsel__exit(evsel);
	close_cgroup(evsel->cgrp);
	free(evsel->name);
	free(evsel);
}

int __perf_evsel__read_on_cpu(struct perf_evsel *evsel,
			      int cpu, int thread, bool scale)
{
	struct perf_counts_values count;
	size_t nv = scale ? 3 : 1;

	if (FD(evsel, cpu, thread) < 0)
		return -EINVAL;

	if (evsel->counts == NULL && perf_evsel__alloc_counts(evsel, cpu + 1) < 0)
		return -ENOMEM;

	if (readn(FD(evsel, cpu, thread), &count, nv * sizeof(u64)) < 0)
		return -errno;

	if (scale) {
		if (count.run == 0)
			count.val = 0;
		else if (count.run < count.ena)
			count.val = (u64)((double)count.val * count.ena / count.run + 0.5);
	} else
		count.ena = count.run = 0;

	evsel->counts->cpu[cpu] = count;
	return 0;
}

int __perf_evsel__read(struct perf_evsel *evsel,
		       int ncpus, int nthreads, bool scale)
{
	size_t nv = scale ? 3 : 1;
	int cpu, thread;
	struct perf_counts_values *aggr = &evsel->counts->aggr, count;

	aggr->val = aggr->ena = aggr->run = 0;

	for (cpu = 0; cpu < ncpus; cpu++) {
		for (thread = 0; thread < nthreads; thread++) {
			if (FD(evsel, cpu, thread) < 0)
				continue;

			if (readn(FD(evsel, cpu, thread),
				  &count, nv * sizeof(u64)) < 0)
				return -errno;

			aggr->val += count.val;
			if (scale) {
				aggr->ena += count.ena;
				aggr->run += count.run;
			}
		}
	}

	evsel->counts->scaled = 0;
	if (scale) {
		if (aggr->run == 0) {
			evsel->counts->scaled = -1;
			aggr->val = 0;
			return 0;
		}

		if (aggr->run < aggr->ena) {
			evsel->counts->scaled = 1;
			aggr->val = (u64)((double)aggr->val * aggr->ena / aggr->run + 0.5);
		}
	} else
		aggr->ena = aggr->run = 0;

	return 0;
}

static int __perf_evsel__open(struct perf_evsel *evsel, struct cpu_map *cpus,
			      struct thread_map *threads, bool group)
{
	int cpu, thread;
	unsigned long flags = 0;
	int pid = -1;

	if (evsel->fd == NULL &&
	    perf_evsel__alloc_fd(evsel, cpus->nr, threads->nr) < 0)
		return -1;

	if (evsel->cgrp) {
		flags = PERF_FLAG_PID_CGROUP;
		pid = evsel->cgrp->fd;
	}

	for (cpu = 0; cpu < cpus->nr; cpu++) {
		int group_fd = -1;

		for (thread = 0; thread < threads->nr; thread++) {

			if (!evsel->cgrp)
				pid = threads->map[thread];

			FD(evsel, cpu, thread) = sys_perf_event_open(&evsel->attr,
								     pid,
								     cpus->map[cpu],
								     group_fd, flags);
			if (FD(evsel, cpu, thread) < 0)
				goto out_close;

			if (group && group_fd == -1)
				group_fd = FD(evsel, cpu, thread);
		}
	}

	return 0;

out_close:
	do {
		while (--thread >= 0) {
			close(FD(evsel, cpu, thread));
			FD(evsel, cpu, thread) = -1;
		}
		thread = threads->nr;
	} while (--cpu >= 0);
	return -1;
}

static struct {
	struct cpu_map map;
	int cpus[1];
} empty_cpu_map = {
	.map.nr	= 1,
	.cpus	= { -1, },
};

static struct {
	struct thread_map map;
	int threads[1];
} empty_thread_map = {
	.map.nr	 = 1,
	.threads = { -1, },
};

int perf_evsel__open(struct perf_evsel *evsel, struct cpu_map *cpus,
		     struct thread_map *threads, bool group)
{
	if (cpus == NULL) {
		/* Work around old compiler warnings about strict aliasing */
		cpus = &empty_cpu_map.map;
	}

	if (threads == NULL)
		threads = &empty_thread_map.map;

	return __perf_evsel__open(evsel, cpus, threads, group);
}

int perf_evsel__open_per_cpu(struct perf_evsel *evsel,
			     struct cpu_map *cpus, bool group)
{
	return __perf_evsel__open(evsel, cpus, &empty_thread_map.map, group);
}

int perf_evsel__open_per_thread(struct perf_evsel *evsel,
				struct thread_map *threads, bool group)
{
	return __perf_evsel__open(evsel, &empty_cpu_map.map, threads, group);
}

static int perf_event__parse_id_sample(const union perf_event *event, u64 type,
				       struct perf_sample *sample)
{
	const u64 *array = event->sample.array;

	array += ((event->header.size -
		   sizeof(event->header)) / sizeof(u64)) - 1;

	if (type & PERF_SAMPLE_CPU) {
		u32 *p = (u32 *)array;
		sample->cpu = *p;
		array--;
	}

	if (type & PERF_SAMPLE_STREAM_ID) {
		sample->stream_id = *array;
		array--;
	}

	if (type & PERF_SAMPLE_ID) {
		sample->id = *array;
		array--;
	}

	if (type & PERF_SAMPLE_TIME) {
		sample->time = *array;
		array--;
	}

	if (type & PERF_SAMPLE_TID) {
		u32 *p = (u32 *)array;
		sample->pid = p[0];
		sample->tid = p[1];
	}

	return 0;
}

static bool sample_overlap(const union perf_event *event,
			   const void *offset, u64 size)
{
	const void *base = event;

	if (offset + size > base + event->header.size)
		return true;

	return false;
}

int perf_event__parse_sample(const union perf_event *event, u64 type,
			     int sample_size, bool sample_id_all,
			     struct perf_sample *data, bool swapped)
{
	const u64 *array;

	/*
	 * used for cross-endian analysis. See git commit 65014ab3
	 * for why this goofiness is needed.
	 */
	union {
		u64 val64;
		u32 val32[2];
	} u;


	data->cpu = data->pid = data->tid = -1;
	data->stream_id = data->id = data->time = -1ULL;

	if (event->header.type != PERF_RECORD_SAMPLE) {
		if (!sample_id_all)
			return 0;
		return perf_event__parse_id_sample(event, type, data);
	}

	array = event->sample.array;

	if (sample_size + sizeof(event->header) > event->header.size)
		return -EFAULT;

	if (type & PERF_SAMPLE_IP) {
		data->ip = event->ip.ip;
		array++;
	}

	if (type & PERF_SAMPLE_TID) {
		u.val64 = *array;
		if (swapped) {
			/* undo swap of u64, then swap on individual u32s */
			u.val64 = bswap_64(u.val64);
			u.val32[0] = bswap_32(u.val32[0]);
			u.val32[1] = bswap_32(u.val32[1]);
		}

		data->pid = u.val32[0];
		data->tid = u.val32[1];
		array++;
	}

	if (type & PERF_SAMPLE_TIME) {
		data->time = *array;
		array++;
	}

	data->addr = 0;
	if (type & PERF_SAMPLE_ADDR) {
		data->addr = *array;
		array++;
	}

	data->id = -1ULL;
	if (type & PERF_SAMPLE_ID) {
		data->id = *array;
		array++;
	}

	if (type & PERF_SAMPLE_STREAM_ID) {
		data->stream_id = *array;
		array++;
	}

	if (type & PERF_SAMPLE_CPU) {

		u.val64 = *array;
		if (swapped) {
			/* undo swap of u64, then swap on individual u32s */
			u.val64 = bswap_64(u.val64);
			u.val32[0] = bswap_32(u.val32[0]);
		}

		data->cpu = u.val32[0];
		array++;
	}

	if (type & PERF_SAMPLE_PERIOD) {
		data->period = *array;
		array++;
	}

	if (type & PERF_SAMPLE_READ) {
		fprintf(stderr, "PERF_SAMPLE_READ is unsuported for now\n");
		return -1;
	}

	if (type & PERF_SAMPLE_CALLCHAIN) {
		if (sample_overlap(event, array, sizeof(data->callchain->nr)))
			return -EFAULT;

		data->callchain = (struct ip_callchain *)array;

		if (sample_overlap(event, array, data->callchain->nr))
			return -EFAULT;

		array += 1 + data->callchain->nr;
	}

	if (type & PERF_SAMPLE_RAW) {
		const u64 *pdata;

		u.val64 = *array;
		if (WARN_ONCE(swapped,
			      "Endianness of raw data not corrected!\n")) {
			/* undo swap of u64, then swap on individual u32s */
			u.val64 = bswap_64(u.val64);
			u.val32[0] = bswap_32(u.val32[0]);
			u.val32[1] = bswap_32(u.val32[1]);
		}

		if (sample_overlap(event, array, sizeof(u32)))
			return -EFAULT;

		data->raw_size = u.val32[0];
		pdata = (void *) array + sizeof(u32);

		if (sample_overlap(event, pdata, data->raw_size))
			return -EFAULT;

		data->raw_data = (void *) pdata;
	}

	return 0;
}
Commit	Line	Data
f8a95309 ACM	1	/*
	2	* Copyright (C) 2011, Red Hat Inc, Arnaldo Carvalho de Melo <acme@redhat.com>
	3	*
	4	* Parts came from builtin-{top,stat,record}.c, see those files for further
	5	* copyright notes.
	6	*
	7	* Released under the GPL v2. (and only v2, not any later version)
	8	*/
	9
936be503 DA	10	#include <byteswap.h>
936be503 DA	11	#include "asm/bug.h"
69aad6f1	12	#include "evsel.h"
70082dd9	13	#include "evlist.h"
69aad6f1	14	#include "util.h"
86bd5e86	15	#include "cpumap.h"
fd78260b	16	#include "thread_map.h"
69aad6f1	17
c52b12ed ACM	18	#define FD(e, x, y) ((int )xyarray__entry(e->fd, x, y))
c52b12ed ACM	19
c2a70653 ACM	20	int __perf_evsel__sample_size(u64 sample_type)
	21	{
	22	u64 mask = sample_type & PERF_SAMPLE_MASK;
	23	int size = 0;
	24	int i;
	25
	26	for (i = 0; i < 64; i++) {
	27	if (mask & (1ULL << i))
	28	size++;
	29	}
	30
	31	size *= sizeof(u64);
	32
	33	return size;
	34	}
	35
ef1d1af2 ACM	36	void perf_evsel__init(struct perf_evsel *evsel,
	37	struct perf_event_attr *attr, int idx)
	38	{
	39	evsel->idx = idx;
	40	evsel->attr = *attr;
	41	INIT_LIST_HEAD(&evsel->node);
	42	}
	43
23a2f3ab	44	struct perf_evsel perf_evsel__new(struct perf_event_attr attr, int idx)
69aad6f1 ACM	45	{
	46	struct perf_evsel evsel = zalloc(sizeof(evsel));
	47
ef1d1af2 ACM	48	if (evsel != NULL)
ef1d1af2 ACM	49	perf_evsel__init(evsel, attr, idx);
69aad6f1 ACM	50
	51	return evsel;
	52	}
	53
	54	int perf_evsel__alloc_fd(struct perf_evsel *evsel, int ncpus, int nthreads)
	55	{
4af4c955	56	int cpu, thread;
69aad6f1	57	evsel->fd = xyarray__new(ncpus, nthreads, sizeof(int));
4af4c955 DA	58
	59	if (evsel->fd) {
	60	for (cpu = 0; cpu < ncpus; cpu++) {
	61	for (thread = 0; thread < nthreads; thread++) {
	62	FD(evsel, cpu, thread) = -1;
	63	}
	64	}
	65	}
	66
69aad6f1 ACM	67	return evsel->fd != NULL ? 0 : -ENOMEM;
	68	}
	69
70db7533 ACM	70	int perf_evsel__alloc_id(struct perf_evsel *evsel, int ncpus, int nthreads)
70db7533 ACM	71	{
a91e5431 ACM	72	evsel->sample_id = xyarray__new(ncpus, nthreads, sizeof(struct perf_sample_id));
	73	if (evsel->sample_id == NULL)
	74	return -ENOMEM;
	75
	76	evsel->id = zalloc(ncpus * nthreads * sizeof(u64));
	77	if (evsel->id == NULL) {
	78	xyarray__delete(evsel->sample_id);
	79	evsel->sample_id = NULL;
	80	return -ENOMEM;
	81	}
	82
	83	return 0;
70db7533 ACM	84	}
70db7533 ACM	85
c52b12ed ACM	86	int perf_evsel__alloc_counts(struct perf_evsel *evsel, int ncpus)
	87	{
	88	evsel->counts = zalloc((sizeof(*evsel->counts) +
	89	(ncpus * sizeof(struct perf_counts_values))));
	90	return evsel->counts != NULL ? 0 : -ENOMEM;
	91	}
	92
69aad6f1 ACM	93	void perf_evsel__free_fd(struct perf_evsel *evsel)
	94	{
	95	xyarray__delete(evsel->fd);
	96	evsel->fd = NULL;
	97	}
	98
70db7533 ACM	99	void perf_evsel__free_id(struct perf_evsel *evsel)
70db7533 ACM	100	{
a91e5431 ACM	101	xyarray__delete(evsel->sample_id);
	102	evsel->sample_id = NULL;
	103	free(evsel->id);
70db7533 ACM	104	evsel->id = NULL;
	105	}
	106
c52b12ed ACM	107	void perf_evsel__close_fd(struct perf_evsel *evsel, int ncpus, int nthreads)
	108	{
	109	int cpu, thread;
	110
	111	for (cpu = 0; cpu < ncpus; cpu++)
	112	for (thread = 0; thread < nthreads; ++thread) {
	113	close(FD(evsel, cpu, thread));
	114	FD(evsel, cpu, thread) = -1;
	115	}
	116	}
	117
ef1d1af2	118	void perf_evsel__exit(struct perf_evsel *evsel)
69aad6f1 ACM	119	{
	120	assert(list_empty(&evsel->node));
	121	xyarray__delete(evsel->fd);
a91e5431 ACM	122	xyarray__delete(evsel->sample_id);
a91e5431 ACM	123	free(evsel->id);
ef1d1af2 ACM	124	}
	125
	126	void perf_evsel__delete(struct perf_evsel *evsel)
	127	{
	128	perf_evsel__exit(evsel);
023695d9	129	close_cgroup(evsel->cgrp);
f0c55bcf	130	free(evsel->name);
69aad6f1 ACM	131	free(evsel);
69aad6f1 ACM	132	}
c52b12ed ACM	133
	134	int __perf_evsel__read_on_cpu(struct perf_evsel *evsel,
	135	int cpu, int thread, bool scale)
	136	{
	137	struct perf_counts_values count;
	138	size_t nv = scale ? 3 : 1;
	139
	140	if (FD(evsel, cpu, thread) < 0)
	141	return -EINVAL;
	142
4eed11d5 ACM	143	if (evsel->counts == NULL && perf_evsel__alloc_counts(evsel, cpu + 1) < 0)
	144	return -ENOMEM;
	145
c52b12ed ACM	146	if (readn(FD(evsel, cpu, thread), &count, nv * sizeof(u64)) < 0)
	147	return -errno;
	148
	149	if (scale) {
	150	if (count.run == 0)
	151	count.val = 0;
	152	else if (count.run < count.ena)
	153	count.val = (u64)((double)count.val * count.ena / count.run + 0.5);
	154	} else
	155	count.ena = count.run = 0;
	156
	157	evsel->counts->cpu[cpu] = count;
	158	return 0;
	159	}
	160
	161	int __perf_evsel__read(struct perf_evsel *evsel,
	162	int ncpus, int nthreads, bool scale)
	163	{
	164	size_t nv = scale ? 3 : 1;
	165	int cpu, thread;
	166	struct perf_counts_values *aggr = &evsel->counts->aggr, count;
	167
52bcd994	168	aggr->val = aggr->ena = aggr->run = 0;
c52b12ed ACM	169
	170	for (cpu = 0; cpu < ncpus; cpu++) {
	171	for (thread = 0; thread < nthreads; thread++) {
	172	if (FD(evsel, cpu, thread) < 0)
	173	continue;
	174
	175	if (readn(FD(evsel, cpu, thread),
	176	&count, nv * sizeof(u64)) < 0)
	177	return -errno;
	178
	179	aggr->val += count.val;
	180	if (scale) {
	181	aggr->ena += count.ena;
	182	aggr->run += count.run;
	183	}
	184	}
	185	}
	186
	187	evsel->counts->scaled = 0;
	188	if (scale) {
	189	if (aggr->run == 0) {
	190	evsel->counts->scaled = -1;
	191	aggr->val = 0;
	192	return 0;
	193	}
	194
	195	if (aggr->run < aggr->ena) {
	196	evsel->counts->scaled = 1;
	197	aggr->val = (u64)((double)aggr->val * aggr->ena / aggr->run + 0.5);
	198	}
	199	} else
	200	aggr->ena = aggr->run = 0;
	201
	202	return 0;
	203	}
48290609	204
0252208e	205	static int __perf_evsel__open(struct perf_evsel evsel, struct cpu_map cpus,
5d2cd909	206	struct thread_map *threads, bool group)
48290609	207	{
0252208e	208	int cpu, thread;
023695d9 SE	209	unsigned long flags = 0;
023695d9 SE	210	int pid = -1;
48290609	211
0252208e ACM	212	if (evsel->fd == NULL &&
0252208e ACM	213	perf_evsel__alloc_fd(evsel, cpus->nr, threads->nr) < 0)
4eed11d5 ACM	214	return -1;
4eed11d5 ACM	215
023695d9 SE	216	if (evsel->cgrp) {
	217	flags = PERF_FLAG_PID_CGROUP;
	218	pid = evsel->cgrp->fd;
	219	}
	220
86bd5e86	221	for (cpu = 0; cpu < cpus->nr; cpu++) {
f08199d3	222	int group_fd = -1;
9d04f178	223
0252208e	224	for (thread = 0; thread < threads->nr; thread++) {
023695d9 SE	225
	226	if (!evsel->cgrp)
	227	pid = threads->map[thread];
	228
0252208e	229	FD(evsel, cpu, thread) = sys_perf_event_open(&evsel->attr,
023695d9	230	pid,
f08199d3	231	cpus->map[cpu],
023695d9	232	group_fd, flags);
0252208e ACM	233	if (FD(evsel, cpu, thread) < 0)
0252208e ACM	234	goto out_close;
f08199d3 ACM	235
	236	if (group && group_fd == -1)
	237	group_fd = FD(evsel, cpu, thread);
0252208e	238	}
48290609 ACM	239	}
	240
	241	return 0;
	242
	243	out_close:
0252208e ACM	244	do {
	245	while (--thread >= 0) {
	246	close(FD(evsel, cpu, thread));
	247	FD(evsel, cpu, thread) = -1;
	248	}
	249	thread = threads->nr;
	250	} while (--cpu >= 0);
48290609 ACM	251	return -1;
	252	}
	253
0252208e ACM	254	static struct {
	255	struct cpu_map map;
	256	int cpus[1];
	257	} empty_cpu_map = {
	258	.map.nr = 1,
	259	.cpus = { -1, },
	260	};
	261
	262	static struct {
	263	struct thread_map map;
	264	int threads[1];
	265	} empty_thread_map = {
	266	.map.nr = 1,
	267	.threads = { -1, },
	268	};
	269
f08199d3	270	int perf_evsel__open(struct perf_evsel evsel, struct cpu_map cpus,
5d2cd909	271	struct thread_map *threads, bool group)
48290609	272	{
0252208e ACM	273	if (cpus == NULL) {
	274	/* Work around old compiler warnings about strict aliasing */
	275	cpus = &empty_cpu_map.map;
48290609 ACM	276	}
48290609 ACM	277
0252208e ACM	278	if (threads == NULL)
0252208e ACM	279	threads = &empty_thread_map.map;
48290609	280
5d2cd909	281	return __perf_evsel__open(evsel, cpus, threads, group);
48290609 ACM	282	}
48290609 ACM	283
f08199d3	284	int perf_evsel__open_per_cpu(struct perf_evsel *evsel,
5d2cd909	285	struct cpu_map *cpus, bool group)
48290609	286	{
5d2cd909	287	return __perf_evsel__open(evsel, cpus, &empty_thread_map.map, group);
0252208e	288	}
48290609	289
f08199d3	290	int perf_evsel__open_per_thread(struct perf_evsel *evsel,
5d2cd909	291	struct thread_map *threads, bool group)
0252208e	292	{
5d2cd909	293	return __perf_evsel__open(evsel, &empty_cpu_map.map, threads, group);
48290609	294	}
70082dd9	295
8115d60c ACM	296	static int perf_event__parse_id_sample(const union perf_event *event, u64 type,
8115d60c ACM	297	struct perf_sample *sample)
d0dd74e8 ACM	298	{
	299	const u64 *array = event->sample.array;
	300
	301	array += ((event->header.size -
	302	sizeof(event->header)) / sizeof(u64)) - 1;
	303
	304	if (type & PERF_SAMPLE_CPU) {
	305	u32 p = (u32 )array;
	306	sample->cpu = *p;
	307	array--;
	308	}
	309
	310	if (type & PERF_SAMPLE_STREAM_ID) {
	311	sample->stream_id = *array;
	312	array--;
	313	}
	314
	315	if (type & PERF_SAMPLE_ID) {
	316	sample->id = *array;
	317	array--;
	318	}
	319
	320	if (type & PERF_SAMPLE_TIME) {
	321	sample->time = *array;
	322	array--;
	323	}
	324
	325	if (type & PERF_SAMPLE_TID) {
	326	u32 p = (u32 )array;
	327	sample->pid = p[0];
	328	sample->tid = p[1];
	329	}
	330
	331	return 0;
	332	}
	333
98e1da90 FW	334	static bool sample_overlap(const union perf_event *event,
	335	const void *offset, u64 size)
	336	{
	337	const void *base = event;
	338
	339	if (offset + size > base + event->header.size)
	340	return true;
	341
	342	return false;
	343	}
	344
8115d60c	345	int perf_event__parse_sample(const union perf_event *event, u64 type,
a2854124	346	int sample_size, bool sample_id_all,
936be503	347	struct perf_sample *data, bool swapped)
d0dd74e8 ACM	348	{
	349	const u64 *array;
	350
936be503 DA	351	/*
	352	* used for cross-endian analysis. See git commit 65014ab3
	353	* for why this goofiness is needed.
	354	*/
	355	union {
	356	u64 val64;
	357	u32 val32[2];
	358	} u;
	359
	360
d0dd74e8 ACM	361	data->cpu = data->pid = data->tid = -1;
	362	data->stream_id = data->id = data->time = -1ULL;
	363
	364	if (event->header.type != PERF_RECORD_SAMPLE) {
	365	if (!sample_id_all)
	366	return 0;
8115d60c	367	return perf_event__parse_id_sample(event, type, data);
d0dd74e8 ACM	368	}
	369
	370	array = event->sample.array;
	371
a2854124 FW	372	if (sample_size + sizeof(event->header) > event->header.size)
	373	return -EFAULT;
	374
d0dd74e8 ACM	375	if (type & PERF_SAMPLE_IP) {
	376	data->ip = event->ip.ip;
	377	array++;
	378	}
	379
	380	if (type & PERF_SAMPLE_TID) {
936be503 DA	381	u.val64 = *array;
	382	if (swapped) {
	383	/* undo swap of u64, then swap on individual u32s */
	384	u.val64 = bswap_64(u.val64);
	385	u.val32[0] = bswap_32(u.val32[0]);
	386	u.val32[1] = bswap_32(u.val32[1]);
	387	}
	388
	389	data->pid = u.val32[0];
	390	data->tid = u.val32[1];
d0dd74e8 ACM	391	array++;
	392	}
	393
	394	if (type & PERF_SAMPLE_TIME) {
	395	data->time = *array;
	396	array++;
	397	}
	398
7cec0922	399	data->addr = 0;
d0dd74e8 ACM	400	if (type & PERF_SAMPLE_ADDR) {
	401	data->addr = *array;
	402	array++;
	403	}
	404
	405	data->id = -1ULL;
	406	if (type & PERF_SAMPLE_ID) {
	407	data->id = *array;
	408	array++;
	409	}
	410
	411	if (type & PERF_SAMPLE_STREAM_ID) {
	412	data->stream_id = *array;
	413	array++;
	414	}
	415
	416	if (type & PERF_SAMPLE_CPU) {
936be503 DA	417
	418	u.val64 = *array;
	419	if (swapped) {
	420	/* undo swap of u64, then swap on individual u32s */
	421	u.val64 = bswap_64(u.val64);
	422	u.val32[0] = bswap_32(u.val32[0]);
	423	}
	424
	425	data->cpu = u.val32[0];
d0dd74e8 ACM	426	array++;
	427	}
	428
	429	if (type & PERF_SAMPLE_PERIOD) {
	430	data->period = *array;
	431	array++;
	432	}
	433
	434	if (type & PERF_SAMPLE_READ) {
	435	fprintf(stderr, "PERF_SAMPLE_READ is unsuported for now\n");
	436	return -1;
	437	}
	438
	439	if (type & PERF_SAMPLE_CALLCHAIN) {
98e1da90 FW	440	if (sample_overlap(event, array, sizeof(data->callchain->nr)))
	441	return -EFAULT;
	442
d0dd74e8	443	data->callchain = (struct ip_callchain *)array;
98e1da90 FW	444
	445	if (sample_overlap(event, array, data->callchain->nr))
	446	return -EFAULT;
	447
d0dd74e8 ACM	448	array += 1 + data->callchain->nr;
	449	}
	450
	451	if (type & PERF_SAMPLE_RAW) {
8e303f20 JO	452	const u64 *pdata;
8e303f20 JO	453
936be503 DA	454	u.val64 = *array;
	455	if (WARN_ONCE(swapped,
	456	"Endianness of raw data not corrected!\n")) {
	457	/* undo swap of u64, then swap on individual u32s */
	458	u.val64 = bswap_64(u.val64);
	459	u.val32[0] = bswap_32(u.val32[0]);
	460	u.val32[1] = bswap_32(u.val32[1]);
	461	}
98e1da90 FW	462
	463	if (sample_overlap(event, array, sizeof(u32)))
	464	return -EFAULT;
	465
936be503	466	data->raw_size = u.val32[0];
8e303f20	467	pdata = (void *) array + sizeof(u32);
98e1da90	468
8e303f20	469	if (sample_overlap(event, pdata, data->raw_size))
98e1da90 FW	470	return -EFAULT;
98e1da90 FW	471
8e303f20	472	data->raw_data = (void *) pdata;
d0dd74e8 ACM	473	}
	474
	475	return 0;
	476	}