[deliverable/linux.git] / drivers / oprofile / cpu_buffer.c

/**
 * @file cpu_buffer.c
 *
 * @remark Copyright 2002 OProfile authors
 * @remark Read the file COPYING
 *
 * @author John Levon <levon@movementarian.org>
 * @author Barry Kasindorf <barry.kasindorf@amd.com>
 *
 * Each CPU has a local buffer that stores PC value/event
 * pairs. We also log context switches when we notice them.
 * Eventually each CPU's buffer is processed into the global
 * event buffer by sync_buffer().
 *
 * We use a local buffer for two reasons: an NMI or similar
 * interrupt cannot synchronise, and high sampling rates
 * would lead to catastrophic global synchronisation if
 * a global buffer was used.
 */

#include <linux/sched.h>
#include <linux/oprofile.h>
#include <linux/vmalloc.h>
#include <linux/errno.h>

#include "event_buffer.h"
#include "cpu_buffer.h"
#include "buffer_sync.h"
#include "oprof.h"

#define OP_BUFFER_FLAGS	0

/*
 * Read and write access is using spin locking. Thus, writing to the
 * buffer by NMI handler (x86) could occur also during critical
 * sections when reading the buffer. To avoid this, there are 2
 * buffers for independent read and write access. Read access is in
 * process context only, write access only in the NMI handler. If the
 * read buffer runs empty, both buffers are swapped atomically. There
 * is potentially a small window during swapping where the buffers are
 * disabled and samples could be lost.
 *
 * Using 2 buffers is a little bit overhead, but the solution is clear
 * and does not require changes in the ring buffer implementation. It
 * can be changed to a single buffer solution when the ring buffer
 * access is implemented as non-locking atomic code.
 */
static struct ring_buffer *op_ring_buffer_read;
static struct ring_buffer *op_ring_buffer_write;
DEFINE_PER_CPU(struct oprofile_cpu_buffer, cpu_buffer);

static void wq_sync_buffer(struct work_struct *work);

#define DEFAULT_TIMER_EXPIRE (HZ / 10)
static int work_enabled;

unsigned long oprofile_get_cpu_buffer_size(void)
{
	return oprofile_cpu_buffer_size;
}

void oprofile_cpu_buffer_inc_smpl_lost(void)
{
	struct oprofile_cpu_buffer *cpu_buf
		= &__get_cpu_var(cpu_buffer);

	cpu_buf->sample_lost_overflow++;
}

void free_cpu_buffers(void)
{
	if (op_ring_buffer_read)
		ring_buffer_free(op_ring_buffer_read);
	op_ring_buffer_read = NULL;
	if (op_ring_buffer_write)
		ring_buffer_free(op_ring_buffer_write);
	op_ring_buffer_write = NULL;
}

int alloc_cpu_buffers(void)
{
	int i;

	unsigned long buffer_size = oprofile_cpu_buffer_size;

	op_ring_buffer_read = ring_buffer_alloc(buffer_size, OP_BUFFER_FLAGS);
	if (!op_ring_buffer_read)
		goto fail;
	op_ring_buffer_write = ring_buffer_alloc(buffer_size, OP_BUFFER_FLAGS);
	if (!op_ring_buffer_write)
		goto fail;

	for_each_possible_cpu(i) {
		struct oprofile_cpu_buffer *b = &per_cpu(cpu_buffer, i);

		b->last_task = NULL;
		b->last_is_kernel = -1;
		b->tracing = 0;
		b->buffer_size = buffer_size;
		b->tail_pos = 0;
		b->head_pos = 0;
		b->sample_received = 0;
		b->sample_lost_overflow = 0;
		b->backtrace_aborted = 0;
		b->sample_invalid_eip = 0;
		b->cpu = i;
		INIT_DELAYED_WORK(&b->work, wq_sync_buffer);
	}
	return 0;

fail:
	free_cpu_buffers();
	return -ENOMEM;
}

void start_cpu_work(void)
{
	int i;

	work_enabled = 1;

	for_each_online_cpu(i) {
		struct oprofile_cpu_buffer *b = &per_cpu(cpu_buffer, i);

		/*
		 * Spread the work by 1 jiffy per cpu so they dont all
		 * fire at once.
		 */
		schedule_delayed_work_on(i, &b->work, DEFAULT_TIMER_EXPIRE + i);
	}
}

void end_cpu_work(void)
{
	int i;

	work_enabled = 0;

	for_each_online_cpu(i) {
		struct oprofile_cpu_buffer *b = &per_cpu(cpu_buffer, i);

		cancel_delayed_work(&b->work);
	}

	flush_scheduled_work();
}

int op_cpu_buffer_write_entry(struct op_entry *entry)
{
	entry->event = ring_buffer_lock_reserve(op_ring_buffer_write,
						sizeof(struct op_sample),
						&entry->irq_flags);
	if (entry->event)
		entry->sample = ring_buffer_event_data(entry->event);
	else
		entry->sample = NULL;

	if (!entry->sample)
		return -ENOMEM;

	return 0;
}

int op_cpu_buffer_write_commit(struct op_entry *entry)
{
	return ring_buffer_unlock_commit(op_ring_buffer_write, entry->event,
					 entry->irq_flags);
}

struct op_sample *op_cpu_buffer_read_entry(int cpu)
{
	struct ring_buffer_event *e;
	e = ring_buffer_consume(op_ring_buffer_read, cpu, NULL);
	if (e)
		return ring_buffer_event_data(e);
	if (ring_buffer_swap_cpu(op_ring_buffer_read,
				 op_ring_buffer_write,
				 cpu))
		return NULL;
	e = ring_buffer_consume(op_ring_buffer_read, cpu, NULL);
	if (e)
		return ring_buffer_event_data(e);
	return NULL;
}

unsigned long op_cpu_buffer_entries(int cpu)
{
	return ring_buffer_entries_cpu(op_ring_buffer_read, cpu)
		+ ring_buffer_entries_cpu(op_ring_buffer_write, cpu);
}

static inline int
add_sample(struct oprofile_cpu_buffer *cpu_buf,
	   unsigned long pc, unsigned long event)
{
	struct op_entry entry;
	int ret;

	ret = op_cpu_buffer_write_entry(&entry);
	if (ret)
		return ret;

	entry.sample->eip = pc;
	entry.sample->event = event;

	ret = op_cpu_buffer_write_commit(&entry);
	if (ret)
		return ret;

	return 0;
}

static inline int
add_code(struct oprofile_cpu_buffer *buffer, unsigned long value)
{
	return add_sample(buffer, ESCAPE_CODE, value);
}

/* This must be safe from any context. It's safe writing here
 * because of the head/tail separation of the writer and reader
 * of the CPU buffer.
 *
 * is_kernel is needed because on some architectures you cannot
 * tell if you are in kernel or user space simply by looking at
 * pc. We tag this in the buffer by generating kernel enter/exit
 * events whenever is_kernel changes
 */
static int log_sample(struct oprofile_cpu_buffer *cpu_buf, unsigned long pc,
		      int is_kernel, unsigned long event)
{
	struct task_struct *task;

	cpu_buf->sample_received++;

	if (pc == ESCAPE_CODE) {
		cpu_buf->sample_invalid_eip++;
		return 0;
	}

	is_kernel = !!is_kernel;

	task = current;

	/* notice a switch from user->kernel or vice versa */
	if (cpu_buf->last_is_kernel != is_kernel) {
		cpu_buf->last_is_kernel = is_kernel;
		if (add_code(cpu_buf, is_kernel))
			goto fail;
	}

	/* notice a task switch */
	if (cpu_buf->last_task != task) {
		cpu_buf->last_task = task;
		if (add_code(cpu_buf, (unsigned long)task))
			goto fail;
	}

	if (add_sample(cpu_buf, pc, event))
		goto fail;

	return 1;

fail:
	cpu_buf->sample_lost_overflow++;
	return 0;
}

static inline void oprofile_begin_trace(struct oprofile_cpu_buffer *cpu_buf)
{
	add_code(cpu_buf, CPU_TRACE_BEGIN);
	cpu_buf->tracing = 1;
}

static inline void oprofile_end_trace(struct oprofile_cpu_buffer *cpu_buf)
{
	cpu_buf->tracing = 0;
}

static inline void
__oprofile_add_ext_sample(unsigned long pc, struct pt_regs * const regs,
			  unsigned long event, int is_kernel)
{
	struct oprofile_cpu_buffer *cpu_buf = &__get_cpu_var(cpu_buffer);

	if (!oprofile_backtrace_depth) {
		log_sample(cpu_buf, pc, is_kernel, event);
		return;
	}

	oprofile_begin_trace(cpu_buf);

	/*
	 * if log_sample() fail we can't backtrace since we lost the
	 * source of this event
	 */
	if (log_sample(cpu_buf, pc, is_kernel, event))
		oprofile_ops.backtrace(regs, oprofile_backtrace_depth);

	oprofile_end_trace(cpu_buf);
}

void oprofile_add_ext_sample(unsigned long pc, struct pt_regs * const regs,
			     unsigned long event, int is_kernel)
{
	__oprofile_add_ext_sample(pc, regs, event, is_kernel);
}

void oprofile_add_sample(struct pt_regs * const regs, unsigned long event)
{
	int is_kernel = !user_mode(regs);
	unsigned long pc = profile_pc(regs);

	__oprofile_add_ext_sample(pc, regs, event, is_kernel);
}

#ifdef CONFIG_OPROFILE_IBS

#define MAX_IBS_SAMPLE_SIZE 14

void oprofile_add_ibs_sample(struct pt_regs * const regs,
			     unsigned int * const ibs_sample, int ibs_code)
{
	int is_kernel = !user_mode(regs);
	struct oprofile_cpu_buffer *cpu_buf = &__get_cpu_var(cpu_buffer);
	struct task_struct *task;
	int fail = 0;

	cpu_buf->sample_received++;

	/* notice a switch from user->kernel or vice versa */
	if (cpu_buf->last_is_kernel != is_kernel) {
		if (add_code(cpu_buf, is_kernel))
			goto fail;
		cpu_buf->last_is_kernel = is_kernel;
	}

	/* notice a task switch */
	if (!is_kernel) {
		task = current;
		if (cpu_buf->last_task != task) {
			if (add_code(cpu_buf, (unsigned long)task))
				goto fail;
			cpu_buf->last_task = task;
		}
	}

	fail = fail || add_code(cpu_buf, ibs_code);
	fail = fail || add_sample(cpu_buf, ibs_sample[0], ibs_sample[1]);
	fail = fail || add_sample(cpu_buf, ibs_sample[2], ibs_sample[3]);
	fail = fail || add_sample(cpu_buf, ibs_sample[4], ibs_sample[5]);

	if (ibs_code == IBS_OP_BEGIN) {
		fail = fail || add_sample(cpu_buf, ibs_sample[6], ibs_sample[7]);
		fail = fail || add_sample(cpu_buf, ibs_sample[8], ibs_sample[9]);
		fail = fail || add_sample(cpu_buf, ibs_sample[10], ibs_sample[11]);
	}

	if (fail)
		goto fail;

	if (oprofile_backtrace_depth)
		oprofile_ops.backtrace(regs, oprofile_backtrace_depth);

	return;

fail:
	cpu_buf->sample_lost_overflow++;
	return;
}

#endif

void oprofile_add_pc(unsigned long pc, int is_kernel, unsigned long event)
{
	struct oprofile_cpu_buffer *cpu_buf = &__get_cpu_var(cpu_buffer);
	log_sample(cpu_buf, pc, is_kernel, event);
}

void oprofile_add_trace(unsigned long pc)
{
	struct oprofile_cpu_buffer *cpu_buf = &__get_cpu_var(cpu_buffer);

	if (!cpu_buf->tracing)
		return;

	/*
	 * broken frame can give an eip with the same value as an
	 * escape code, abort the trace if we get it
	 */
	if (pc == ESCAPE_CODE)
		goto fail;

	if (add_sample(cpu_buf, pc, 0))
		goto fail;

	return;
fail:
	cpu_buf->tracing = 0;
	cpu_buf->backtrace_aborted++;
	return;
}

/*
 * This serves to avoid cpu buffer overflow, and makes sure
 * the task mortuary progresses
 *
 * By using schedule_delayed_work_on and then schedule_delayed_work
 * we guarantee this will stay on the correct cpu
 */
static void wq_sync_buffer(struct work_struct *work)
{
	struct oprofile_cpu_buffer *b =
		container_of(work, struct oprofile_cpu_buffer, work.work);
	if (b->cpu != smp_processor_id()) {
		printk(KERN_DEBUG "WQ on CPU%d, prefer CPU%d\n",
		       smp_processor_id(), b->cpu);

		if (!cpu_online(b->cpu)) {
			cancel_delayed_work(&b->work);
			return;
		}
	}
	sync_buffer(b->cpu);

	/* don't re-add the work if we're shutting down */
	if (work_enabled)
		schedule_delayed_work(&b->work, DEFAULT_TIMER_EXPIRE);
}
Commit	Line	Data
1da177e4 LT	1	/**
	2	* @file cpu_buffer.c
	3	*
	4	* @remark Copyright 2002 OProfile authors
	5	* @remark Read the file COPYING
	6	*
	7	* @author John Levon <levon@movementarian.org>
345c2573	8	* @author Barry Kasindorf <barry.kasindorf@amd.com>
1da177e4 LT	9	*
	10	* Each CPU has a local buffer that stores PC value/event
	11	* pairs. We also log context switches when we notice them.
	12	* Eventually each CPU's buffer is processed into the global
	13	* event buffer by sync_buffer().
	14	*
	15	* We use a local buffer for two reasons: an NMI or similar
	16	* interrupt cannot synchronise, and high sampling rates
	17	* would lead to catastrophic global synchronisation if
	18	* a global buffer was used.
	19	*/
	20
	21	#include <linux/sched.h>
	22	#include <linux/oprofile.h>
	23	#include <linux/vmalloc.h>
	24	#include <linux/errno.h>
6a18037d	25
1da177e4 LT	26	#include "event_buffer.h"
	27	#include "cpu_buffer.h"
	28	#include "buffer_sync.h"
	29	#include "oprof.h"
	30
6dad828b RR	31	#define OP_BUFFER_FLAGS 0
	32
	33	/*
	34	* Read and write access is using spin locking. Thus, writing to the
	35	* buffer by NMI handler (x86) could occur also during critical
	36	* sections when reading the buffer. To avoid this, there are 2
	37	* buffers for independent read and write access. Read access is in
	38	* process context only, write access only in the NMI handler. If the
	39	* read buffer runs empty, both buffers are swapped atomically. There
	40	* is potentially a small window during swapping where the buffers are
	41	* disabled and samples could be lost.
	42	*
	43	* Using 2 buffers is a little bit overhead, but the solution is clear
	44	* and does not require changes in the ring buffer implementation. It
	45	* can be changed to a single buffer solution when the ring buffer
	46	* access is implemented as non-locking atomic code.
	47	*/
9966718d RR	48	static struct ring_buffer *op_ring_buffer_read;
9966718d RR	49	static struct ring_buffer *op_ring_buffer_write;
8b8b4988	50	DEFINE_PER_CPU(struct oprofile_cpu_buffer, cpu_buffer);
1da177e4	51
c4028958	52	static void wq_sync_buffer(struct work_struct *work);
1da177e4 LT	53
	54	#define DEFAULT_TIMER_EXPIRE (HZ / 10)
	55	static int work_enabled;
	56
a5598ca0 CL	57	unsigned long oprofile_get_cpu_buffer_size(void)
a5598ca0 CL	58	{
bd2172f5	59	return oprofile_cpu_buffer_size;
a5598ca0 CL	60	}
	61
	62	void oprofile_cpu_buffer_inc_smpl_lost(void)
	63	{
	64	struct oprofile_cpu_buffer *cpu_buf
	65	= &__get_cpu_var(cpu_buffer);
	66
	67	cpu_buf->sample_lost_overflow++;
	68	}
	69
30015776 RR	70	void free_cpu_buffers(void)
	71	{
	72	if (op_ring_buffer_read)
	73	ring_buffer_free(op_ring_buffer_read);
	74	op_ring_buffer_read = NULL;
	75	if (op_ring_buffer_write)
	76	ring_buffer_free(op_ring_buffer_write);
	77	op_ring_buffer_write = NULL;
	78	}
	79
1da177e4 LT	80	int alloc_cpu_buffers(void)
	81	{
	82	int i;
6a18037d	83
bd2172f5	84	unsigned long buffer_size = oprofile_cpu_buffer_size;
6a18037d	85
6dad828b RR	86	op_ring_buffer_read = ring_buffer_alloc(buffer_size, OP_BUFFER_FLAGS);
	87	if (!op_ring_buffer_read)
	88	goto fail;
	89	op_ring_buffer_write = ring_buffer_alloc(buffer_size, OP_BUFFER_FLAGS);
	90	if (!op_ring_buffer_write)
	91	goto fail;
	92
4bd9b9dc	93	for_each_possible_cpu(i) {
608dfddd	94	struct oprofile_cpu_buffer *b = &per_cpu(cpu_buffer, i);
6a18037d	95
1da177e4 LT	96	b->last_task = NULL;
	97	b->last_is_kernel = -1;
	98	b->tracing = 0;
	99	b->buffer_size = buffer_size;
	100	b->tail_pos = 0;
	101	b->head_pos = 0;
	102	b->sample_received = 0;
	103	b->sample_lost_overflow = 0;
df9d177a PE	104	b->backtrace_aborted = 0;
df9d177a PE	105	b->sample_invalid_eip = 0;
1da177e4	106	b->cpu = i;
c4028958	107	INIT_DELAYED_WORK(&b->work, wq_sync_buffer);
1da177e4 LT	108	}
	109	return 0;
	110
	111	fail:
	112	free_cpu_buffers();
	113	return -ENOMEM;
	114	}
1da177e4 LT	115
	116	void start_cpu_work(void)
	117	{
	118	int i;
	119
	120	work_enabled = 1;
	121
	122	for_each_online_cpu(i) {
608dfddd	123	struct oprofile_cpu_buffer *b = &per_cpu(cpu_buffer, i);
1da177e4 LT	124
	125	/*
	126	* Spread the work by 1 jiffy per cpu so they dont all
	127	* fire at once.
	128	*/
	129	schedule_delayed_work_on(i, &b->work, DEFAULT_TIMER_EXPIRE + i);
	130	}
	131	}
	132
1da177e4 LT	133	void end_cpu_work(void)
	134	{
	135	int i;
	136
	137	work_enabled = 0;
	138
	139	for_each_online_cpu(i) {
608dfddd	140	struct oprofile_cpu_buffer *b = &per_cpu(cpu_buffer, i);
1da177e4 LT	141
	142	cancel_delayed_work(&b->work);
	143	}
	144
	145	flush_scheduled_work();
	146	}
	147
9966718d RR	148	int op_cpu_buffer_write_entry(struct op_entry *entry)
	149	{
	150	entry->event = ring_buffer_lock_reserve(op_ring_buffer_write,
	151	sizeof(struct op_sample),
	152	&entry->irq_flags);
	153	if (entry->event)
	154	entry->sample = ring_buffer_event_data(entry->event);
	155	else
	156	entry->sample = NULL;
	157
	158	if (!entry->sample)
	159	return -ENOMEM;
	160
	161	return 0;
	162	}
	163
	164	int op_cpu_buffer_write_commit(struct op_entry *entry)
	165	{
	166	return ring_buffer_unlock_commit(op_ring_buffer_write, entry->event,
	167	entry->irq_flags);
	168	}
	169
	170	struct op_sample *op_cpu_buffer_read_entry(int cpu)
	171	{
	172	struct ring_buffer_event *e;
	173	e = ring_buffer_consume(op_ring_buffer_read, cpu, NULL);
	174	if (e)
	175	return ring_buffer_event_data(e);
	176	if (ring_buffer_swap_cpu(op_ring_buffer_read,
	177	op_ring_buffer_write,
	178	cpu))
	179	return NULL;
	180	e = ring_buffer_consume(op_ring_buffer_read, cpu, NULL);
	181	if (e)
	182	return ring_buffer_event_data(e);
	183	return NULL;
	184	}
	185
	186	unsigned long op_cpu_buffer_entries(int cpu)
	187	{
	188	return ring_buffer_entries_cpu(op_ring_buffer_read, cpu)
	189	+ ring_buffer_entries_cpu(op_ring_buffer_write, cpu);
	190	}
	191
211117ff	192	static inline int
25ad2913	193	add_sample(struct oprofile_cpu_buffer *cpu_buf,
6a18037d	194	unsigned long pc, unsigned long event)
1da177e4	195	{
6dad828b	196	struct op_entry entry;
211117ff	197	int ret;
6dad828b	198
6d2c53f3	199	ret = op_cpu_buffer_write_entry(&entry);
211117ff RR	200	if (ret)
211117ff RR	201	return ret;
6dad828b RR	202
	203	entry.sample->eip = pc;
	204	entry.sample->event = event;
	205
6d2c53f3	206	ret = op_cpu_buffer_write_commit(&entry);
211117ff RR	207	if (ret)
211117ff RR	208	return ret;
6dad828b	209
211117ff	210	return 0;
1da177e4 LT	211	}
1da177e4 LT	212
211117ff	213	static inline int
25ad2913	214	add_code(struct oprofile_cpu_buffer *buffer, unsigned long value)
1da177e4	215	{
211117ff	216	return add_sample(buffer, ESCAPE_CODE, value);
1da177e4 LT	217	}
1da177e4 LT	218
1da177e4 LT	219	/* This must be safe from any context. It's safe writing here
	220	* because of the head/tail separation of the writer and reader
	221	* of the CPU buffer.
	222	*
	223	* is_kernel is needed because on some architectures you cannot
	224	* tell if you are in kernel or user space simply by looking at
	225	* pc. We tag this in the buffer by generating kernel enter/exit
	226	* events whenever is_kernel changes
	227	*/
25ad2913	228	static int log_sample(struct oprofile_cpu_buffer *cpu_buf, unsigned long pc,
1da177e4 LT	229	int is_kernel, unsigned long event)
1da177e4 LT	230	{
25ad2913	231	struct task_struct *task;
1da177e4 LT	232
	233	cpu_buf->sample_received++;
	234
df9d177a PE	235	if (pc == ESCAPE_CODE) {
	236	cpu_buf->sample_invalid_eip++;
	237	return 0;
	238	}
	239
1da177e4 LT	240	is_kernel = !!is_kernel;
	241
	242	task = current;
	243
	244	/* notice a switch from user->kernel or vice versa */
	245	if (cpu_buf->last_is_kernel != is_kernel) {
	246	cpu_buf->last_is_kernel = is_kernel;
211117ff RR	247	if (add_code(cpu_buf, is_kernel))
211117ff RR	248	goto fail;
1da177e4 LT	249	}
	250
	251	/* notice a task switch */
	252	if (cpu_buf->last_task != task) {
	253	cpu_buf->last_task = task;
211117ff RR	254	if (add_code(cpu_buf, (unsigned long)task))
211117ff RR	255	goto fail;
1da177e4	256	}
6a18037d	257
211117ff RR	258	if (add_sample(cpu_buf, pc, event))
	259	goto fail;
	260
1da177e4	261	return 1;
211117ff RR	262
	263	fail:
	264	cpu_buf->sample_lost_overflow++;
	265	return 0;
1da177e4 LT	266	}
1da177e4 LT	267
6352d92d	268	static inline void oprofile_begin_trace(struct oprofile_cpu_buffer *cpu_buf)
1da177e4	269	{
1da177e4 LT	270	add_code(cpu_buf, CPU_TRACE_BEGIN);
1da177e4 LT	271	cpu_buf->tracing = 1;
1da177e4 LT	272	}
1da177e4 LT	273
6352d92d	274	static inline void oprofile_end_trace(struct oprofile_cpu_buffer *cpu_buf)
1da177e4 LT	275	{
	276	cpu_buf->tracing = 0;
	277	}
	278
d45d23be RR	279	static inline void
	280	__oprofile_add_ext_sample(unsigned long pc, struct pt_regs * const regs,
	281	unsigned long event, int is_kernel)
1da177e4	282	{
608dfddd	283	struct oprofile_cpu_buffer *cpu_buf = &__get_cpu_var(cpu_buffer);
1da177e4	284
bd2172f5	285	if (!oprofile_backtrace_depth) {
1da177e4 LT	286	log_sample(cpu_buf, pc, is_kernel, event);
	287	return;
	288	}
	289
6352d92d	290	oprofile_begin_trace(cpu_buf);
1da177e4	291
fd13f6c8 RR	292	/*
	293	* if log_sample() fail we can't backtrace since we lost the
	294	* source of this event
	295	*/
1da177e4	296	if (log_sample(cpu_buf, pc, is_kernel, event))
bd2172f5	297	oprofile_ops.backtrace(regs, oprofile_backtrace_depth);
6352d92d	298
1da177e4 LT	299	oprofile_end_trace(cpu_buf);
	300	}
	301
d45d23be RR	302	void oprofile_add_ext_sample(unsigned long pc, struct pt_regs * const regs,
	303	unsigned long event, int is_kernel)
	304	{
	305	__oprofile_add_ext_sample(pc, regs, event, is_kernel);
	306	}
	307
27357716 BR	308	void oprofile_add_sample(struct pt_regs * const regs, unsigned long event)
	309	{
	310	int is_kernel = !user_mode(regs);
	311	unsigned long pc = profile_pc(regs);
	312
d45d23be	313	__oprofile_add_ext_sample(pc, regs, event, is_kernel);
27357716 BR	314	}
27357716 BR	315
852402cc RR	316	#ifdef CONFIG_OPROFILE_IBS
852402cc RR	317
e2fee276 RR	318	#define MAX_IBS_SAMPLE_SIZE 14
e2fee276 RR	319
cdc1834d RR	320	void oprofile_add_ibs_sample(struct pt_regs * const regs,
cdc1834d RR	321	unsigned int * const ibs_sample, int ibs_code)
345c2573	322	{
e2fee276 RR	323	int is_kernel = !user_mode(regs);
e2fee276 RR	324	struct oprofile_cpu_buffer *cpu_buf = &__get_cpu_var(cpu_buffer);
345c2573	325	struct task_struct *task;
211117ff	326	int fail = 0;
345c2573 BK	327
	328	cpu_buf->sample_received++;
	329
345c2573 BK	330	/* notice a switch from user->kernel or vice versa */
345c2573 BK	331	if (cpu_buf->last_is_kernel != is_kernel) {
211117ff RR	332	if (add_code(cpu_buf, is_kernel))
211117ff RR	333	goto fail;
345c2573	334	cpu_buf->last_is_kernel = is_kernel;
345c2573 BK	335	}
	336
	337	/* notice a task switch */
	338	if (!is_kernel) {
	339	task = current;
345c2573	340	if (cpu_buf->last_task != task) {
211117ff RR	341	if (add_code(cpu_buf, (unsigned long)task))
211117ff RR	342	goto fail;
345c2573	343	cpu_buf->last_task = task;
345c2573 BK	344	}
	345	}
	346
211117ff RR	347	fail = fail \|\| add_code(cpu_buf, ibs_code);
	348	fail = fail \|\| add_sample(cpu_buf, ibs_sample[0], ibs_sample[1]);
	349	fail = fail \|\| add_sample(cpu_buf, ibs_sample[2], ibs_sample[3]);
	350	fail = fail \|\| add_sample(cpu_buf, ibs_sample[4], ibs_sample[5]);
345c2573 BK	351
345c2573 BK	352	if (ibs_code == IBS_OP_BEGIN) {
211117ff RR	353	fail = fail \|\| add_sample(cpu_buf, ibs_sample[6], ibs_sample[7]);
	354	fail = fail \|\| add_sample(cpu_buf, ibs_sample[8], ibs_sample[9]);
	355	fail = fail \|\| add_sample(cpu_buf, ibs_sample[10], ibs_sample[11]);
345c2573 BK	356	}
345c2573 BK	357
211117ff RR	358	if (fail)
	359	goto fail;
	360
bd2172f5 RR	361	if (oprofile_backtrace_depth)
bd2172f5 RR	362	oprofile_ops.backtrace(regs, oprofile_backtrace_depth);
211117ff RR	363
	364	return;
	365
	366	fail:
	367	cpu_buf->sample_lost_overflow++;
	368	return;
345c2573 BK	369	}
345c2573 BK	370
852402cc RR	371	#endif
852402cc RR	372
1da177e4 LT	373	void oprofile_add_pc(unsigned long pc, int is_kernel, unsigned long event)
1da177e4 LT	374	{
608dfddd	375	struct oprofile_cpu_buffer *cpu_buf = &__get_cpu_var(cpu_buffer);
1da177e4 LT	376	log_sample(cpu_buf, pc, is_kernel, event);
	377	}
	378
1da177e4 LT	379	void oprofile_add_trace(unsigned long pc)
1da177e4 LT	380	{
608dfddd	381	struct oprofile_cpu_buffer *cpu_buf = &__get_cpu_var(cpu_buffer);
1da177e4 LT	382
	383	if (!cpu_buf->tracing)
	384	return;
	385
fd13f6c8 RR	386	/*
	387	* broken frame can give an eip with the same value as an
	388	* escape code, abort the trace if we get it
	389	*/
211117ff RR	390	if (pc == ESCAPE_CODE)
	391	goto fail;
	392
	393	if (add_sample(cpu_buf, pc, 0))
	394	goto fail;
1da177e4	395
211117ff RR	396	return;
	397	fail:
	398	cpu_buf->tracing = 0;
	399	cpu_buf->backtrace_aborted++;
	400	return;
1da177e4 LT	401	}
1da177e4 LT	402
1da177e4 LT	403	/*
	404	* This serves to avoid cpu buffer overflow, and makes sure
	405	* the task mortuary progresses
	406	*
	407	* By using schedule_delayed_work_on and then schedule_delayed_work
	408	* we guarantee this will stay on the correct cpu
	409	*/
c4028958	410	static void wq_sync_buffer(struct work_struct *work)
1da177e4	411	{
25ad2913	412	struct oprofile_cpu_buffer *b =
c4028958	413	container_of(work, struct oprofile_cpu_buffer, work.work);
1da177e4	414	if (b->cpu != smp_processor_id()) {
bd17b625	415	printk(KERN_DEBUG "WQ on CPU%d, prefer CPU%d\n",
1da177e4	416	smp_processor_id(), b->cpu);
4bd9b9dc CA	417
	418	if (!cpu_online(b->cpu)) {
	419	cancel_delayed_work(&b->work);
	420	return;
	421	}
1da177e4 LT	422	}
	423	sync_buffer(b->cpu);
	424
	425	/* don't re-add the work if we're shutting down */
	426	if (work_enabled)
	427	schedule_delayed_work(&b->work, DEFAULT_TIMER_EXPIRE);
	428	}