[deliverable/linux.git] / tools / perf / util / db-export.c

/*
 * db-export.c: Support for exporting data suitable for import to a database
 * Copyright (c) 2014, Intel Corporation.
 *
 * This program is free software; you can redistribute it and/or modify it
 * under the terms and conditions of the GNU General Public License,
 * version 2, as published by the Free Software Foundation.
 *
 * This program is distributed in the hope it will be useful, but WITHOUT
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
 * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License for
 * more details.
 *
 */

#include <errno.h>

#include "evsel.h"
#include "machine.h"
#include "thread.h"
#include "comm.h"
#include "symbol.h"
#include "event.h"
#include "util.h"
#include "thread-stack.h"
#include "callchain.h"
#include "call-path.h"
#include "db-export.h"

struct deferred_export {
	struct list_head node;
	struct comm *comm;
};

static int db_export__deferred(struct db_export *dbe)
{
	struct deferred_export *de;
	int err;

	while (!list_empty(&dbe->deferred)) {
		de = list_entry(dbe->deferred.next, struct deferred_export,
				node);
		err = dbe->export_comm(dbe, de->comm);
		list_del(&de->node);
		free(de);
		if (err)
			return err;
	}

	return 0;
}

static void db_export__free_deferred(struct db_export *dbe)
{
	struct deferred_export *de;

	while (!list_empty(&dbe->deferred)) {
		de = list_entry(dbe->deferred.next, struct deferred_export,
				node);
		list_del(&de->node);
		free(de);
	}
}

static int db_export__defer_comm(struct db_export *dbe, struct comm *comm)
{
	struct deferred_export *de;

	de = zalloc(sizeof(struct deferred_export));
	if (!de)
		return -ENOMEM;

	de->comm = comm;
	list_add_tail(&de->node, &dbe->deferred);

	return 0;
}

int db_export__init(struct db_export *dbe)
{
	memset(dbe, 0, sizeof(struct db_export));
	INIT_LIST_HEAD(&dbe->deferred);
	return 0;
}

int db_export__flush(struct db_export *dbe)
{
	return db_export__deferred(dbe);
}

void db_export__exit(struct db_export *dbe)
{
	db_export__free_deferred(dbe);
	call_return_processor__free(dbe->crp);
	dbe->crp = NULL;
}

int db_export__evsel(struct db_export *dbe, struct perf_evsel *evsel)
{
	if (evsel->db_id)
		return 0;

	evsel->db_id = ++dbe->evsel_last_db_id;

	if (dbe->export_evsel)
		return dbe->export_evsel(dbe, evsel);

	return 0;
}

int db_export__machine(struct db_export *dbe, struct machine *machine)
{
	if (machine->db_id)
		return 0;

	machine->db_id = ++dbe->machine_last_db_id;

	if (dbe->export_machine)
		return dbe->export_machine(dbe, machine);

	return 0;
}

int db_export__thread(struct db_export *dbe, struct thread *thread,
		      struct machine *machine, struct comm *comm)
{
	struct thread *main_thread;
	u64 main_thread_db_id = 0;
	int err;

	if (thread->db_id)
		return 0;

	thread->db_id = ++dbe->thread_last_db_id;

	if (thread->pid_ != -1) {
		if (thread->pid_ == thread->tid) {
			main_thread = thread;
		} else {
			main_thread = machine__findnew_thread(machine,
							      thread->pid_,
							      thread->pid_);
			if (!main_thread)
				return -ENOMEM;
			err = db_export__thread(dbe, main_thread, machine,
						comm);
			if (err)
				goto out_put;
			if (comm) {
				err = db_export__comm_thread(dbe, comm, thread);
				if (err)
					goto out_put;
			}
		}
		main_thread_db_id = main_thread->db_id;
		if (main_thread != thread)
			thread__put(main_thread);
	}

	if (dbe->export_thread)
		return dbe->export_thread(dbe, thread, main_thread_db_id,
					  machine);

	return 0;

out_put:
	thread__put(main_thread);
	return err;
}

int db_export__comm(struct db_export *dbe, struct comm *comm,
		    struct thread *main_thread)
{
	int err;

	if (comm->db_id)
		return 0;

	comm->db_id = ++dbe->comm_last_db_id;

	if (dbe->export_comm) {
		if (main_thread->comm_set)
			err = dbe->export_comm(dbe, comm);
		else
			err = db_export__defer_comm(dbe, comm);
		if (err)
			return err;
	}

	return db_export__comm_thread(dbe, comm, main_thread);
}

int db_export__comm_thread(struct db_export *dbe, struct comm *comm,
			   struct thread *thread)
{
	u64 db_id;

	db_id = ++dbe->comm_thread_last_db_id;

	if (dbe->export_comm_thread)
		return dbe->export_comm_thread(dbe, db_id, comm, thread);

	return 0;
}

int db_export__dso(struct db_export *dbe, struct dso *dso,
		   struct machine *machine)
{
	if (dso->db_id)
		return 0;

	dso->db_id = ++dbe->dso_last_db_id;

	if (dbe->export_dso)
		return dbe->export_dso(dbe, dso, machine);

	return 0;
}

int db_export__symbol(struct db_export *dbe, struct symbol *sym,
		      struct dso *dso)
{
	u64 *sym_db_id = symbol__priv(sym);

	if (*sym_db_id)
		return 0;

	*sym_db_id = ++dbe->symbol_last_db_id;

	if (dbe->export_symbol)
		return dbe->export_symbol(dbe, sym, dso);

	return 0;
}

static struct thread *get_main_thread(struct machine *machine, struct thread *thread)
{
	if (thread->pid_ == thread->tid)
		return thread__get(thread);

	if (thread->pid_ == -1)
		return NULL;

	return machine__find_thread(machine, thread->pid_, thread->pid_);
}

static int db_ids_from_al(struct db_export *dbe, struct addr_location *al,
			  u64 *dso_db_id, u64 *sym_db_id, u64 *offset)
{
	int err;

	if (al->map) {
		struct dso *dso = al->map->dso;

		err = db_export__dso(dbe, dso, al->machine);
		if (err)
			return err;
		*dso_db_id = dso->db_id;

		if (!al->sym) {
			al->sym = symbol__new(al->addr, 0, 0, "unknown");
			if (al->sym)
				dso__insert_symbol(dso, al->map->type, al->sym);
		}

		if (al->sym) {
			u64 *db_id = symbol__priv(al->sym);

			err = db_export__symbol(dbe, al->sym, dso);
			if (err)
				return err;
			*sym_db_id = *db_id;
			*offset = al->addr - al->sym->start;
		}
	}

	return 0;
}

static struct call_path *call_path_from_sample(struct db_export *dbe,
					       struct machine *machine,
					       struct thread *thread,
					       struct perf_sample *sample,
					       struct perf_evsel *evsel)
{
	u64 kernel_start = machine__kernel_start(machine);
	struct call_path *current = &dbe->cpr->call_path;
	enum chain_order saved_order = callchain_param.order;
	int err;

	if (!symbol_conf.use_callchain || !sample->callchain)
		return NULL;

	/*
	 * Since the call path tree must be built starting with the root, we
	 * must use ORDER_CALL for call chain resolution, in order to process
	 * the callchain starting with the root node and ending with the leaf.
	 */
	callchain_param.order = ORDER_CALLER;
	err = thread__resolve_callchain(thread, &callchain_cursor, evsel,
					sample, NULL, NULL, PERF_MAX_STACK_DEPTH);
	if (err) {
		callchain_param.order = saved_order;
		return NULL;
	}
	callchain_cursor_commit(&callchain_cursor);

	while (1) {
		struct callchain_cursor_node *node;
		struct addr_location al;
		u64 dso_db_id = 0, sym_db_id = 0, offset = 0;

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

		node = callchain_cursor_current(&callchain_cursor);
		if (!node)
			break;
		/*
		 * Handle export of symbol and dso for this node by
		 * constructing an addr_location struct and then passing it to
		 * db_ids_from_al() to perform the export.
		 */
		al.sym = node->sym;
		al.map = node->map;
		al.machine = machine;
		al.addr = node->ip;

		if (al.map && !al.sym)
			al.sym = dso__find_symbol(al.map->dso, MAP__FUNCTION,
						  al.addr);

		db_ids_from_al(dbe, &al, &dso_db_id, &sym_db_id, &offset);

		/* add node to the call path tree if it doesn't exist */
		current = call_path__findnew(dbe->cpr, current,
					     al.sym, node->ip,
					     kernel_start);

		callchain_cursor_advance(&callchain_cursor);
	}

	/* Reset the callchain order to its prior value. */
	callchain_param.order = saved_order;

	if (current == &dbe->cpr->call_path) {
		/* Bail because the callchain was empty. */
		return NULL;
	}

	return current;
}

int db_export__branch_type(struct db_export *dbe, u32 branch_type,
			   const char *name)
{
	if (dbe->export_branch_type)
		return dbe->export_branch_type(dbe, branch_type, name);

	return 0;
}

int db_export__sample(struct db_export *dbe, union perf_event *event,
		      struct perf_sample *sample, struct perf_evsel *evsel,
		      struct addr_location *al)
{
	struct thread* thread = al->thread;
	struct export_sample es = {
		.event = event,
		.sample = sample,
		.evsel = evsel,
		.al = al,
	};
	struct thread *main_thread;
	struct comm *comm = NULL;
	int err;

	err = db_export__evsel(dbe, evsel);
	if (err)
		return err;

	err = db_export__machine(dbe, al->machine);
	if (err)
		return err;

	main_thread = get_main_thread(al->machine, thread);
	if (main_thread)
		comm = machine__thread_exec_comm(al->machine, main_thread);

	err = db_export__thread(dbe, thread, al->machine, comm);
	if (err)
		goto out_put;

	if (comm) {
		err = db_export__comm(dbe, comm, main_thread);
		if (err)
			goto out_put;
		es.comm_db_id = comm->db_id;
	}

	es.db_id = ++dbe->sample_last_db_id;

	err = db_ids_from_al(dbe, al, &es.dso_db_id, &es.sym_db_id, &es.offset);
	if (err)
		goto out_put;

	if (dbe->cpr) {
		struct call_path *cp = call_path_from_sample(dbe, al->machine,
							     thread, sample,
							     evsel);
		if (cp) {
			db_export__call_path(dbe, cp);
			es.call_path_id = cp->db_id;
		}
	}

	if ((evsel->attr.sample_type & PERF_SAMPLE_ADDR) &&
	    sample_addr_correlates_sym(&evsel->attr)) {
		struct addr_location addr_al;

		thread__resolve(thread, &addr_al, sample);
		err = db_ids_from_al(dbe, &addr_al, &es.addr_dso_db_id,
				     &es.addr_sym_db_id, &es.addr_offset);
		if (err)
			goto out_put;
		if (dbe->crp) {
			err = thread_stack__process(thread, comm, sample, al,
						    &addr_al, es.db_id,
						    dbe->crp);
			if (err)
				goto out_put;
		}
	}

	if (dbe->export_sample)
		err = dbe->export_sample(dbe, &es);

out_put:
	thread__put(main_thread);
	return err;
}

static struct {
	u32 branch_type;
	const char *name;
} branch_types[] = {
	{0, "no branch"},
	{PERF_IP_FLAG_BRANCH | PERF_IP_FLAG_CALL, "call"},
	{PERF_IP_FLAG_BRANCH | PERF_IP_FLAG_RETURN, "return"},
	{PERF_IP_FLAG_BRANCH | PERF_IP_FLAG_CONDITIONAL, "conditional jump"},
	{PERF_IP_FLAG_BRANCH, "unconditional jump"},
	{PERF_IP_FLAG_BRANCH | PERF_IP_FLAG_CALL | PERF_IP_FLAG_INTERRUPT,
	 "software interrupt"},
	{PERF_IP_FLAG_BRANCH | PERF_IP_FLAG_RETURN | PERF_IP_FLAG_INTERRUPT,
	 "return from interrupt"},
	{PERF_IP_FLAG_BRANCH | PERF_IP_FLAG_CALL | PERF_IP_FLAG_SYSCALLRET,
	 "system call"},
	{PERF_IP_FLAG_BRANCH | PERF_IP_FLAG_RETURN | PERF_IP_FLAG_SYSCALLRET,
	 "return from system call"},
	{PERF_IP_FLAG_BRANCH | PERF_IP_FLAG_ASYNC, "asynchronous branch"},
	{PERF_IP_FLAG_BRANCH | PERF_IP_FLAG_CALL | PERF_IP_FLAG_ASYNC |
	 PERF_IP_FLAG_INTERRUPT, "hardware interrupt"},
	{PERF_IP_FLAG_BRANCH | PERF_IP_FLAG_TX_ABORT, "transaction abort"},
	{PERF_IP_FLAG_BRANCH | PERF_IP_FLAG_TRACE_BEGIN, "trace begin"},
	{PERF_IP_FLAG_BRANCH | PERF_IP_FLAG_TRACE_END, "trace end"},
	{0, NULL}
};

int db_export__branch_types(struct db_export *dbe)
{
	int i, err = 0;

	for (i = 0; branch_types[i].name ; i++) {
		err = db_export__branch_type(dbe, branch_types[i].branch_type,
					     branch_types[i].name);
		if (err)
			break;
	}
	return err;
}

int db_export__call_path(struct db_export *dbe, struct call_path *cp)
{
	int err;

	if (cp->db_id)
		return 0;

	if (cp->parent) {
		err = db_export__call_path(dbe, cp->parent);
		if (err)
			return err;
	}

	cp->db_id = ++dbe->call_path_last_db_id;

	if (dbe->export_call_path)
		return dbe->export_call_path(dbe, cp);

	return 0;
}

int db_export__call_return(struct db_export *dbe, struct call_return *cr)
{
	int err;

	if (cr->db_id)
		return 0;

	err = db_export__call_path(dbe, cr->cp);
	if (err)
		return err;

	cr->db_id = ++dbe->call_return_last_db_id;

	if (dbe->export_call_return)
		return dbe->export_call_return(dbe, cr);

	return 0;
}
Commit	Line	Data
0db15b1e AH	1	/*
	2	* db-export.c: Support for exporting data suitable for import to a database
	3	* Copyright (c) 2014, Intel Corporation.
	4	*
	5	* This program is free software; you can redistribute it and/or modify it
	6	* under the terms and conditions of the GNU General Public License,
	7	* version 2, as published by the Free Software Foundation.
	8	*
	9	* This program is distributed in the hope it will be useful, but WITHOUT
	10	* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
	11	* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
	12	* more details.
	13	*
	14	*/
	15
	16	#include <errno.h>
	17
	18	#include "evsel.h"
	19	#include "machine.h"
	20	#include "thread.h"
	21	#include "comm.h"
	22	#include "symbol.h"
	23	#include "event.h"
758008b2	24	#include "util.h"
88f50d60	25	#include "thread-stack.h"
0a3eba3a	26	#include "callchain.h"
451db126	27	#include "call-path.h"
0db15b1e AH	28	#include "db-export.h"
0db15b1e AH	29
758008b2 AH	30	struct deferred_export {
	31	struct list_head node;
	32	struct comm *comm;
	33	};
	34
	35	static int db_export__deferred(struct db_export *dbe)
	36	{
	37	struct deferred_export *de;
	38	int err;
	39
	40	while (!list_empty(&dbe->deferred)) {
	41	de = list_entry(dbe->deferred.next, struct deferred_export,
	42	node);
	43	err = dbe->export_comm(dbe, de->comm);
	44	list_del(&de->node);
	45	free(de);
	46	if (err)
	47	return err;
	48	}
	49
	50	return 0;
	51	}
	52
	53	static void db_export__free_deferred(struct db_export *dbe)
	54	{
	55	struct deferred_export *de;
	56
	57	while (!list_empty(&dbe->deferred)) {
	58	de = list_entry(dbe->deferred.next, struct deferred_export,
	59	node);
	60	list_del(&de->node);
	61	free(de);
	62	}
	63	}
	64
	65	static int db_export__defer_comm(struct db_export dbe, struct comm comm)
	66	{
	67	struct deferred_export *de;
	68
	69	de = zalloc(sizeof(struct deferred_export));
	70	if (!de)
	71	return -ENOMEM;
	72
	73	de->comm = comm;
	74	list_add_tail(&de->node, &dbe->deferred);
	75
	76	return 0;
	77	}
	78
0db15b1e AH	79	int db_export__init(struct db_export *dbe)
	80	{
	81	memset(dbe, 0, sizeof(struct db_export));
758008b2	82	INIT_LIST_HEAD(&dbe->deferred);
0db15b1e AH	83	return 0;
	84	}
	85
758008b2 AH	86	int db_export__flush(struct db_export *dbe)
	87	{
	88	return db_export__deferred(dbe);
	89	}
	90
88f50d60	91	void db_export__exit(struct db_export *dbe)
0db15b1e	92	{
758008b2	93	db_export__free_deferred(dbe);
88f50d60 AH	94	call_return_processor__free(dbe->crp);
88f50d60 AH	95	dbe->crp = NULL;
0db15b1e AH	96	}
	97
	98	int db_export__evsel(struct db_export dbe, struct perf_evsel evsel)
	99	{
	100	if (evsel->db_id)
	101	return 0;
	102
	103	evsel->db_id = ++dbe->evsel_last_db_id;
	104
	105	if (dbe->export_evsel)
	106	return dbe->export_evsel(dbe, evsel);
	107
	108	return 0;
	109	}
	110
	111	int db_export__machine(struct db_export dbe, struct machine machine)
	112	{
	113	if (machine->db_id)
	114	return 0;
	115
	116	machine->db_id = ++dbe->machine_last_db_id;
	117
	118	if (dbe->export_machine)
	119	return dbe->export_machine(dbe, machine);
	120
	121	return 0;
	122	}
	123
	124	int db_export__thread(struct db_export dbe, struct thread thread,
	125	struct machine machine, struct comm comm)
	126	{
b91fc39f	127	struct thread *main_thread;
0db15b1e AH	128	u64 main_thread_db_id = 0;
	129	int err;
	130
	131	if (thread->db_id)
	132	return 0;
	133
	134	thread->db_id = ++dbe->thread_last_db_id;
	135
	136	if (thread->pid_ != -1) {
0db15b1e AH	137	if (thread->pid_ == thread->tid) {
	138	main_thread = thread;
	139	} else {
	140	main_thread = machine__findnew_thread(machine,
	141	thread->pid_,
	142	thread->pid_);
	143	if (!main_thread)
	144	return -ENOMEM;
	145	err = db_export__thread(dbe, main_thread, machine,
	146	comm);
	147	if (err)
b91fc39f	148	goto out_put;
0db15b1e AH	149	if (comm) {
	150	err = db_export__comm_thread(dbe, comm, thread);
	151	if (err)
b91fc39f	152	goto out_put;
0db15b1e AH	153	}
	154	}
	155	main_thread_db_id = main_thread->db_id;
b91fc39f ACM	156	if (main_thread != thread)
b91fc39f ACM	157	thread__put(main_thread);
0db15b1e AH	158	}
	159
	160	if (dbe->export_thread)
	161	return dbe->export_thread(dbe, thread, main_thread_db_id,
	162	machine);
	163
	164	return 0;
b91fc39f ACM	165
	166	out_put:
	167	thread__put(main_thread);
	168	return err;
0db15b1e AH	169	}
	170
	171	int db_export__comm(struct db_export dbe, struct comm comm,
	172	struct thread *main_thread)
	173	{
	174	int err;
	175
	176	if (comm->db_id)
	177	return 0;
	178
	179	comm->db_id = ++dbe->comm_last_db_id;
	180
	181	if (dbe->export_comm) {
758008b2 AH	182	if (main_thread->comm_set)
	183	err = dbe->export_comm(dbe, comm);
	184	else
	185	err = db_export__defer_comm(dbe, comm);
0db15b1e AH	186	if (err)
	187	return err;
	188	}
	189
	190	return db_export__comm_thread(dbe, comm, main_thread);
	191	}
	192
	193	int db_export__comm_thread(struct db_export dbe, struct comm comm,
	194	struct thread *thread)
	195	{
	196	u64 db_id;
	197
	198	db_id = ++dbe->comm_thread_last_db_id;
	199
	200	if (dbe->export_comm_thread)
	201	return dbe->export_comm_thread(dbe, db_id, comm, thread);
	202
	203	return 0;
	204	}
	205
	206	int db_export__dso(struct db_export dbe, struct dso dso,
	207	struct machine *machine)
	208	{
	209	if (dso->db_id)
	210	return 0;
	211
	212	dso->db_id = ++dbe->dso_last_db_id;
	213
	214	if (dbe->export_dso)
	215	return dbe->export_dso(dbe, dso, machine);
	216
	217	return 0;
	218	}
	219
	220	int db_export__symbol(struct db_export dbe, struct symbol sym,
	221	struct dso *dso)
	222	{
	223	u64 *sym_db_id = symbol__priv(sym);
	224
	225	if (*sym_db_id)
	226	return 0;
	227
	228	*sym_db_id = ++dbe->symbol_last_db_id;
	229
	230	if (dbe->export_symbol)
	231	return dbe->export_symbol(dbe, sym, dso);
	232
	233	return 0;
	234	}
	235
	236	static struct thread get_main_thread(struct machine machine, struct thread *thread)
	237	{
	238	if (thread->pid_ == thread->tid)
427cde32	239	return thread__get(thread);
0db15b1e AH	240
	241	if (thread->pid_ == -1)
	242	return NULL;
	243
	244	return machine__find_thread(machine, thread->pid_, thread->pid_);
	245	}
	246
	247	static int db_ids_from_al(struct db_export dbe, struct addr_location al,
	248	u64 dso_db_id, u64 sym_db_id, u64 *offset)
	249	{
	250	int err;
	251
	252	if (al->map) {
	253	struct dso *dso = al->map->dso;
	254
	255	err = db_export__dso(dbe, dso, al->machine);
	256	if (err)
	257	return err;
	258	*dso_db_id = dso->db_id;
	259
	260	if (!al->sym) {
	261	al->sym = symbol__new(al->addr, 0, 0, "unknown");
	262	if (al->sym)
bd0a51dd	263	dso__insert_symbol(dso, al->map->type, al->sym);
0db15b1e AH	264	}
	265
	266	if (al->sym) {
	267	u64 *db_id = symbol__priv(al->sym);
	268
	269	err = db_export__symbol(dbe, al->sym, dso);
	270	if (err)
	271	return err;
	272	sym_db_id = db_id;
	273	*offset = al->addr - al->sym->start;
	274	}
	275	}
	276
	277	return 0;
	278	}
	279
0a3eba3a CP	280	static struct call_path call_path_from_sample(struct db_export dbe,
	281	struct machine *machine,
	282	struct thread *thread,
	283	struct perf_sample *sample,
	284	struct perf_evsel *evsel)
	285	{
	286	u64 kernel_start = machine__kernel_start(machine);
	287	struct call_path *current = &dbe->cpr->call_path;
	288	enum chain_order saved_order = callchain_param.order;
	289	int err;
	290
	291	if (!symbol_conf.use_callchain \|\| !sample->callchain)
	292	return NULL;
	293
	294	/*
	295	* Since the call path tree must be built starting with the root, we
	296	* must use ORDER_CALL for call chain resolution, in order to process
	297	* the callchain starting with the root node and ending with the leaf.
	298	*/
	299	callchain_param.order = ORDER_CALLER;
	300	err = thread__resolve_callchain(thread, &callchain_cursor, evsel,
fe176085	301	sample, NULL, NULL, PERF_MAX_STACK_DEPTH);
0a3eba3a CP	302	if (err) {
	303	callchain_param.order = saved_order;
	304	return NULL;
	305	}
	306	callchain_cursor_commit(&callchain_cursor);
	307
	308	while (1) {
	309	struct callchain_cursor_node *node;
	310	struct addr_location al;
	311	u64 dso_db_id = 0, sym_db_id = 0, offset = 0;
	312
	313	memset(&al, 0, sizeof(al));
	314
	315	node = callchain_cursor_current(&callchain_cursor);
	316	if (!node)
	317	break;
	318	/*
	319	* Handle export of symbol and dso for this node by
	320	* constructing an addr_location struct and then passing it to
	321	* db_ids_from_al() to perform the export.
	322	*/
	323	al.sym = node->sym;
	324	al.map = node->map;
	325	al.machine = machine;
7a2544c0	326	al.addr = node->ip;
0a3eba3a	327
83302e79 CP	328	if (al.map && !al.sym)
	329	al.sym = dso__find_symbol(al.map->dso, MAP__FUNCTION,
	330	al.addr);
	331
0a3eba3a CP	332	db_ids_from_al(dbe, &al, &dso_db_id, &sym_db_id, &offset);
	333
	334	/* add node to the call path tree if it doesn't exist */
	335	current = call_path__findnew(dbe->cpr, current,
	336	al.sym, node->ip,
	337	kernel_start);
	338
	339	callchain_cursor_advance(&callchain_cursor);
	340	}
	341
	342	/* Reset the callchain order to its prior value. */
	343	callchain_param.order = saved_order;
	344
	345	if (current == &dbe->cpr->call_path) {
	346	/* Bail because the callchain was empty. */
	347	return NULL;
	348	}
	349
	350	return current;
	351	}
	352
f2bff007 AH	353	int db_export__branch_type(struct db_export *dbe, u32 branch_type,
	354	const char *name)
	355	{
	356	if (dbe->export_branch_type)
	357	return dbe->export_branch_type(dbe, branch_type, name);
	358
	359	return 0;
	360	}
	361
0db15b1e AH	362	int db_export__sample(struct db_export dbe, union perf_event event,
0db15b1e AH	363	struct perf_sample sample, struct perf_evsel evsel,
7327259d	364	struct addr_location *al)
0db15b1e	365	{
7327259d	366	struct thread* thread = al->thread;
0db15b1e AH	367	struct export_sample es = {
	368	.event = event,
	369	.sample = sample,
	370	.evsel = evsel,
0db15b1e AH	371	.al = al,
	372	};
	373	struct thread *main_thread;
	374	struct comm *comm = NULL;
	375	int err;
	376
	377	err = db_export__evsel(dbe, evsel);
	378	if (err)
	379	return err;
	380
	381	err = db_export__machine(dbe, al->machine);
	382	if (err)
	383	return err;
	384
	385	main_thread = get_main_thread(al->machine, thread);
	386	if (main_thread)
	387	comm = machine__thread_exec_comm(al->machine, main_thread);
	388
	389	err = db_export__thread(dbe, thread, al->machine, comm);
	390	if (err)
427cde32	391	goto out_put;
0db15b1e AH	392
	393	if (comm) {
	394	err = db_export__comm(dbe, comm, main_thread);
	395	if (err)
427cde32	396	goto out_put;
0db15b1e AH	397	es.comm_db_id = comm->db_id;
	398	}
	399
	400	es.db_id = ++dbe->sample_last_db_id;
	401
	402	err = db_ids_from_al(dbe, al, &es.dso_db_id, &es.sym_db_id, &es.offset);
	403	if (err)
427cde32	404	goto out_put;
0db15b1e	405
0a3eba3a CP	406	if (dbe->cpr) {
	407	struct call_path *cp = call_path_from_sample(dbe, al->machine,
	408	thread, sample,
	409	evsel);
568850ea	410	if (cp) {
0a3eba3a	411	db_export__call_path(dbe, cp);
568850ea CP	412	es.call_path_id = cp->db_id;
568850ea CP	413	}
0a3eba3a CP	414	}
0a3eba3a CP	415
0db15b1e AH	416	if ((evsel->attr.sample_type & PERF_SAMPLE_ADDR) &&
	417	sample_addr_correlates_sym(&evsel->attr)) {
	418	struct addr_location addr_al;
	419
c2740a87	420	thread__resolve(thread, &addr_al, sample);
0db15b1e AH	421	err = db_ids_from_al(dbe, &addr_al, &es.addr_dso_db_id,
	422	&es.addr_sym_db_id, &es.addr_offset);
	423	if (err)
427cde32	424	goto out_put;
88f50d60 AH	425	if (dbe->crp) {
	426	err = thread_stack__process(thread, comm, sample, al,
	427	&addr_al, es.db_id,
	428	dbe->crp);
	429	if (err)
427cde32	430	goto out_put;
88f50d60	431	}
0db15b1e AH	432	}
	433
	434	if (dbe->export_sample)
427cde32	435	err = dbe->export_sample(dbe, &es);
0db15b1e	436
427cde32 AH	437	out_put:
	438	thread__put(main_thread);
	439	return err;
0db15b1e	440	}
f2bff007 AH	441
	442	static struct {
	443	u32 branch_type;
	444	const char *name;
	445	} branch_types[] = {
	446	{0, "no branch"},
	447	{PERF_IP_FLAG_BRANCH \| PERF_IP_FLAG_CALL, "call"},
	448	{PERF_IP_FLAG_BRANCH \| PERF_IP_FLAG_RETURN, "return"},
	449	{PERF_IP_FLAG_BRANCH \| PERF_IP_FLAG_CONDITIONAL, "conditional jump"},
	450	{PERF_IP_FLAG_BRANCH, "unconditional jump"},
	451	{PERF_IP_FLAG_BRANCH \| PERF_IP_FLAG_CALL \| PERF_IP_FLAG_INTERRUPT,
	452	"software interrupt"},
	453	{PERF_IP_FLAG_BRANCH \| PERF_IP_FLAG_RETURN \| PERF_IP_FLAG_INTERRUPT,
	454	"return from interrupt"},
	455	{PERF_IP_FLAG_BRANCH \| PERF_IP_FLAG_CALL \| PERF_IP_FLAG_SYSCALLRET,
	456	"system call"},
	457	{PERF_IP_FLAG_BRANCH \| PERF_IP_FLAG_RETURN \| PERF_IP_FLAG_SYSCALLRET,
	458	"return from system call"},
	459	{PERF_IP_FLAG_BRANCH \| PERF_IP_FLAG_ASYNC, "asynchronous branch"},
	460	{PERF_IP_FLAG_BRANCH \| PERF_IP_FLAG_CALL \| PERF_IP_FLAG_ASYNC \|
	461	PERF_IP_FLAG_INTERRUPT, "hardware interrupt"},
	462	{PERF_IP_FLAG_BRANCH \| PERF_IP_FLAG_TX_ABORT, "transaction abort"},
	463	{PERF_IP_FLAG_BRANCH \| PERF_IP_FLAG_TRACE_BEGIN, "trace begin"},
	464	{PERF_IP_FLAG_BRANCH \| PERF_IP_FLAG_TRACE_END, "trace end"},
	465	{0, NULL}
	466	};
	467
	468	int db_export__branch_types(struct db_export *dbe)
	469	{
	470	int i, err = 0;
	471
	472	for (i = 0; branch_types[i].name ; i++) {
	473	err = db_export__branch_type(dbe, branch_types[i].branch_type,
	474	branch_types[i].name);
	475	if (err)
	476	break;
	477	}
	478	return err;
	479	}
88f50d60 AH	480
	481	int db_export__call_path(struct db_export dbe, struct call_path cp)
	482	{
	483	int err;
	484
	485	if (cp->db_id)
	486	return 0;
	487
	488	if (cp->parent) {
	489	err = db_export__call_path(dbe, cp->parent);
	490	if (err)
	491	return err;
	492	}
	493
	494	cp->db_id = ++dbe->call_path_last_db_id;
	495
	496	if (dbe->export_call_path)
	497	return dbe->export_call_path(dbe, cp);
	498
	499	return 0;
	500	}
	501
	502	int db_export__call_return(struct db_export dbe, struct call_return cr)
	503	{
	504	int err;
	505
	506	if (cr->db_id)
	507	return 0;
	508
	509	err = db_export__call_path(dbe, cr->cp);
	510	if (err)
	511	return err;
	512
	513	cr->db_id = ++dbe->call_return_last_db_id;
	514
	515	if (dbe->export_call_return)
	516	return dbe->export_call_return(dbe, cr);
	517
	518	return 0;
	519	}