[net-next-2.6.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->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;

	return op_cpu_buffer_write_commit(&entry);
}

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

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)
		return;

fail:
	cpu_buf->sample_lost_overflow++;
}

#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;
1da177e4 LT	100	b->sample_received = 0;
1da177e4 LT	101	b->sample_lost_overflow = 0;
df9d177a PE	102	b->backtrace_aborted = 0;
df9d177a PE	103	b->sample_invalid_eip = 0;
1da177e4	104	b->cpu = i;
c4028958	105	INIT_DELAYED_WORK(&b->work, wq_sync_buffer);
1da177e4 LT	106	}
	107	return 0;
	108
	109	fail:
	110	free_cpu_buffers();
	111	return -ENOMEM;
	112	}
1da177e4 LT	113
	114	void start_cpu_work(void)
	115	{
	116	int i;
	117
	118	work_enabled = 1;
	119
	120	for_each_online_cpu(i) {
608dfddd	121	struct oprofile_cpu_buffer *b = &per_cpu(cpu_buffer, i);
1da177e4 LT	122
	123	/*
	124	* Spread the work by 1 jiffy per cpu so they dont all
	125	* fire at once.
	126	*/
	127	schedule_delayed_work_on(i, &b->work, DEFAULT_TIMER_EXPIRE + i);
	128	}
	129	}
	130
1da177e4 LT	131	void end_cpu_work(void)
	132	{
	133	int i;
	134
	135	work_enabled = 0;
	136
	137	for_each_online_cpu(i) {
608dfddd	138	struct oprofile_cpu_buffer *b = &per_cpu(cpu_buffer, i);
1da177e4 LT	139
	140	cancel_delayed_work(&b->work);
	141	}
	142
	143	flush_scheduled_work();
	144	}
	145
9966718d RR	146	int op_cpu_buffer_write_entry(struct op_entry *entry)
	147	{
	148	entry->event = ring_buffer_lock_reserve(op_ring_buffer_write,
	149	sizeof(struct op_sample),
	150	&entry->irq_flags);
	151	if (entry->event)
	152	entry->sample = ring_buffer_event_data(entry->event);
	153	else
	154	entry->sample = NULL;
	155
	156	if (!entry->sample)
	157	return -ENOMEM;
	158
	159	return 0;
	160	}
	161
	162	int op_cpu_buffer_write_commit(struct op_entry *entry)
	163	{
	164	return ring_buffer_unlock_commit(op_ring_buffer_write, entry->event,
	165	entry->irq_flags);
	166	}
	167
	168	struct op_sample *op_cpu_buffer_read_entry(int cpu)
	169	{
	170	struct ring_buffer_event *e;
	171	e = ring_buffer_consume(op_ring_buffer_read, cpu, NULL);
	172	if (e)
	173	return ring_buffer_event_data(e);
	174	if (ring_buffer_swap_cpu(op_ring_buffer_read,
	175	op_ring_buffer_write,
	176	cpu))
	177	return NULL;
	178	e = ring_buffer_consume(op_ring_buffer_read, cpu, NULL);
	179	if (e)
	180	return ring_buffer_event_data(e);
	181	return NULL;
	182	}
	183
	184	unsigned long op_cpu_buffer_entries(int cpu)
	185	{
	186	return ring_buffer_entries_cpu(op_ring_buffer_read, cpu)
	187	+ ring_buffer_entries_cpu(op_ring_buffer_write, cpu);
	188	}
	189
211117ff	190	static inline int
25ad2913	191	add_sample(struct oprofile_cpu_buffer *cpu_buf,
6a18037d	192	unsigned long pc, unsigned long event)
1da177e4	193	{
6dad828b	194	struct op_entry entry;
211117ff	195	int ret;
6dad828b	196
6d2c53f3	197	ret = op_cpu_buffer_write_entry(&entry);
211117ff RR	198	if (ret)
211117ff RR	199	return ret;
6dad828b RR	200
	201	entry.sample->eip = pc;
	202	entry.sample->event = event;
	203
3967e93e	204	return op_cpu_buffer_write_commit(&entry);
1da177e4 LT	205	}
1da177e4 LT	206
211117ff	207	static inline int
25ad2913	208	add_code(struct oprofile_cpu_buffer *buffer, unsigned long value)
1da177e4	209	{
211117ff	210	return add_sample(buffer, ESCAPE_CODE, value);
1da177e4 LT	211	}
1da177e4 LT	212
1da177e4 LT	213	/* This must be safe from any context. It's safe writing here
	214	* because of the head/tail separation of the writer and reader
	215	* of the CPU buffer.
	216	*
	217	* is_kernel is needed because on some architectures you cannot
	218	* tell if you are in kernel or user space simply by looking at
	219	* pc. We tag this in the buffer by generating kernel enter/exit
	220	* events whenever is_kernel changes
	221	*/
25ad2913	222	static int log_sample(struct oprofile_cpu_buffer *cpu_buf, unsigned long pc,
1da177e4 LT	223	int is_kernel, unsigned long event)
1da177e4 LT	224	{
25ad2913	225	struct task_struct *task;
1da177e4 LT	226
	227	cpu_buf->sample_received++;
	228
df9d177a PE	229	if (pc == ESCAPE_CODE) {
	230	cpu_buf->sample_invalid_eip++;
	231	return 0;
	232	}
	233
1da177e4 LT	234	is_kernel = !!is_kernel;
	235
	236	task = current;
	237
	238	/* notice a switch from user->kernel or vice versa */
	239	if (cpu_buf->last_is_kernel != is_kernel) {
	240	cpu_buf->last_is_kernel = is_kernel;
211117ff RR	241	if (add_code(cpu_buf, is_kernel))
211117ff RR	242	goto fail;
1da177e4 LT	243	}
	244
	245	/* notice a task switch */
	246	if (cpu_buf->last_task != task) {
	247	cpu_buf->last_task = task;
211117ff RR	248	if (add_code(cpu_buf, (unsigned long)task))
211117ff RR	249	goto fail;
1da177e4	250	}
6a18037d	251
211117ff RR	252	if (add_sample(cpu_buf, pc, event))
	253	goto fail;
	254
1da177e4	255	return 1;
211117ff RR	256
	257	fail:
	258	cpu_buf->sample_lost_overflow++;
	259	return 0;
1da177e4 LT	260	}
1da177e4 LT	261
6352d92d	262	static inline void oprofile_begin_trace(struct oprofile_cpu_buffer *cpu_buf)
1da177e4	263	{
1da177e4 LT	264	add_code(cpu_buf, CPU_TRACE_BEGIN);
1da177e4 LT	265	cpu_buf->tracing = 1;
1da177e4 LT	266	}
1da177e4 LT	267
6352d92d	268	static inline void oprofile_end_trace(struct oprofile_cpu_buffer *cpu_buf)
1da177e4 LT	269	{
	270	cpu_buf->tracing = 0;
	271	}
	272
d45d23be RR	273	static inline void
	274	__oprofile_add_ext_sample(unsigned long pc, struct pt_regs * const regs,
	275	unsigned long event, int is_kernel)
1da177e4	276	{
608dfddd	277	struct oprofile_cpu_buffer *cpu_buf = &__get_cpu_var(cpu_buffer);
1da177e4	278
bd2172f5	279	if (!oprofile_backtrace_depth) {
1da177e4 LT	280	log_sample(cpu_buf, pc, is_kernel, event);
	281	return;
	282	}
	283
6352d92d	284	oprofile_begin_trace(cpu_buf);
1da177e4	285
fd13f6c8 RR	286	/*
	287	* if log_sample() fail we can't backtrace since we lost the
	288	* source of this event
	289	*/
1da177e4	290	if (log_sample(cpu_buf, pc, is_kernel, event))
bd2172f5	291	oprofile_ops.backtrace(regs, oprofile_backtrace_depth);
6352d92d	292
1da177e4 LT	293	oprofile_end_trace(cpu_buf);
	294	}
	295
d45d23be RR	296	void oprofile_add_ext_sample(unsigned long pc, struct pt_regs * const regs,
	297	unsigned long event, int is_kernel)
	298	{
	299	__oprofile_add_ext_sample(pc, regs, event, is_kernel);
	300	}
	301
27357716 BR	302	void oprofile_add_sample(struct pt_regs * const regs, unsigned long event)
	303	{
	304	int is_kernel = !user_mode(regs);
	305	unsigned long pc = profile_pc(regs);
	306
d45d23be	307	__oprofile_add_ext_sample(pc, regs, event, is_kernel);
27357716 BR	308	}
27357716 BR	309
852402cc RR	310	#ifdef CONFIG_OPROFILE_IBS
852402cc RR	311
cdc1834d RR	312	void oprofile_add_ibs_sample(struct pt_regs * const regs,
cdc1834d RR	313	unsigned int * const ibs_sample, int ibs_code)
345c2573	314	{
e2fee276 RR	315	int is_kernel = !user_mode(regs);
e2fee276 RR	316	struct oprofile_cpu_buffer *cpu_buf = &__get_cpu_var(cpu_buffer);
345c2573	317	struct task_struct *task;
211117ff	318	int fail = 0;
345c2573 BK	319
	320	cpu_buf->sample_received++;
	321
345c2573 BK	322	/* notice a switch from user->kernel or vice versa */
345c2573 BK	323	if (cpu_buf->last_is_kernel != is_kernel) {
211117ff RR	324	if (add_code(cpu_buf, is_kernel))
211117ff RR	325	goto fail;
345c2573	326	cpu_buf->last_is_kernel = is_kernel;
345c2573 BK	327	}
	328
	329	/* notice a task switch */
	330	if (!is_kernel) {
	331	task = current;
345c2573	332	if (cpu_buf->last_task != task) {
211117ff RR	333	if (add_code(cpu_buf, (unsigned long)task))
211117ff RR	334	goto fail;
345c2573	335	cpu_buf->last_task = task;
345c2573 BK	336	}
	337	}
	338
211117ff RR	339	fail = fail \|\| add_code(cpu_buf, ibs_code);
	340	fail = fail \|\| add_sample(cpu_buf, ibs_sample[0], ibs_sample[1]);
	341	fail = fail \|\| add_sample(cpu_buf, ibs_sample[2], ibs_sample[3]);
	342	fail = fail \|\| add_sample(cpu_buf, ibs_sample[4], ibs_sample[5]);
345c2573 BK	343
345c2573 BK	344	if (ibs_code == IBS_OP_BEGIN) {
211117ff RR	345	fail = fail \|\| add_sample(cpu_buf, ibs_sample[6], ibs_sample[7]);
	346	fail = fail \|\| add_sample(cpu_buf, ibs_sample[8], ibs_sample[9]);
	347	fail = fail \|\| add_sample(cpu_buf, ibs_sample[10], ibs_sample[11]);
345c2573 BK	348	}
345c2573 BK	349
8350c787 RR	350	if (!fail)
8350c787 RR	351	return;
211117ff RR	352
	353	fail:
	354	cpu_buf->sample_lost_overflow++;
345c2573 BK	355	}
345c2573 BK	356
852402cc RR	357	#endif
852402cc RR	358
1da177e4 LT	359	void oprofile_add_pc(unsigned long pc, int is_kernel, unsigned long event)
1da177e4 LT	360	{
608dfddd	361	struct oprofile_cpu_buffer *cpu_buf = &__get_cpu_var(cpu_buffer);
1da177e4 LT	362	log_sample(cpu_buf, pc, is_kernel, event);
	363	}
	364
1da177e4 LT	365	void oprofile_add_trace(unsigned long pc)
1da177e4 LT	366	{
608dfddd	367	struct oprofile_cpu_buffer *cpu_buf = &__get_cpu_var(cpu_buffer);
1da177e4 LT	368
	369	if (!cpu_buf->tracing)
	370	return;
	371
fd13f6c8 RR	372	/*
	373	* broken frame can give an eip with the same value as an
	374	* escape code, abort the trace if we get it
	375	*/
211117ff RR	376	if (pc == ESCAPE_CODE)
	377	goto fail;
	378
	379	if (add_sample(cpu_buf, pc, 0))
	380	goto fail;
1da177e4	381
211117ff RR	382	return;
	383	fail:
	384	cpu_buf->tracing = 0;
	385	cpu_buf->backtrace_aborted++;
	386	return;
1da177e4 LT	387	}
1da177e4 LT	388
1da177e4 LT	389	/*
	390	* This serves to avoid cpu buffer overflow, and makes sure
	391	* the task mortuary progresses
	392	*
	393	* By using schedule_delayed_work_on and then schedule_delayed_work
	394	* we guarantee this will stay on the correct cpu
	395	*/
c4028958	396	static void wq_sync_buffer(struct work_struct *work)
1da177e4	397	{
25ad2913	398	struct oprofile_cpu_buffer *b =
c4028958	399	container_of(work, struct oprofile_cpu_buffer, work.work);
1da177e4	400	if (b->cpu != smp_processor_id()) {
bd17b625	401	printk(KERN_DEBUG "WQ on CPU%d, prefer CPU%d\n",
1da177e4	402	smp_processor_id(), b->cpu);
4bd9b9dc CA	403
	404	if (!cpu_online(b->cpu)) {
	405	cancel_delayed_work(&b->work);
	406	return;
	407	}
1da177e4 LT	408	}
	409	sync_buffer(b->cpu);
	410
	411	/* don't re-add the work if we're shutting down */
	412	if (work_enabled)
	413	schedule_delayed_work(&b->work, DEFAULT_TIMER_EXPIRE);
	414	}