[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.
 */
struct ring_buffer *op_ring_buffer_read;
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;

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;
}

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++;
}

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();
}

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 int oprofile_begin_trace(struct oprofile_cpu_buffer *cpu_buf)
{
	add_code(cpu_buf, CPU_TRACE_BEGIN);
	cpu_buf->tracing = 1;
	return 1;
}

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

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;
	}

	if (!oprofile_begin_trace(cpu_buf))
		return;

	/*
	 * 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_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	*/
	48	struct ring_buffer *op_ring_buffer_read;
	49	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
	57	void free_cpu_buffers(void)
	58	{
6dad828b RR	59	if (op_ring_buffer_read)
	60	ring_buffer_free(op_ring_buffer_read);
	61	op_ring_buffer_read = NULL;
	62	if (op_ring_buffer_write)
	63	ring_buffer_free(op_ring_buffer_write);
	64	op_ring_buffer_write = NULL;
1da177e4	65	}
77933d72	66
a5598ca0 CL	67	unsigned long oprofile_get_cpu_buffer_size(void)
a5598ca0 CL	68	{
bd2172f5	69	return oprofile_cpu_buffer_size;
a5598ca0 CL	70	}
	71
	72	void oprofile_cpu_buffer_inc_smpl_lost(void)
	73	{
	74	struct oprofile_cpu_buffer *cpu_buf
	75	= &__get_cpu_var(cpu_buffer);
	76
	77	cpu_buf->sample_lost_overflow++;
	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
211117ff	148	static inline int
25ad2913	149	add_sample(struct oprofile_cpu_buffer *cpu_buf,
6a18037d	150	unsigned long pc, unsigned long event)
1da177e4	151	{
6dad828b	152	struct op_entry entry;
211117ff	153	int ret;
6dad828b	154
6d2c53f3	155	ret = op_cpu_buffer_write_entry(&entry);
211117ff RR	156	if (ret)
211117ff RR	157	return ret;
6dad828b RR	158
	159	entry.sample->eip = pc;
	160	entry.sample->event = event;
	161
6d2c53f3	162	ret = op_cpu_buffer_write_commit(&entry);
211117ff RR	163	if (ret)
211117ff RR	164	return ret;
6dad828b	165
211117ff	166	return 0;
1da177e4 LT	167	}
1da177e4 LT	168
211117ff	169	static inline int
25ad2913	170	add_code(struct oprofile_cpu_buffer *buffer, unsigned long value)
1da177e4	171	{
211117ff	172	return add_sample(buffer, ESCAPE_CODE, value);
1da177e4 LT	173	}
1da177e4 LT	174
1da177e4 LT	175	/* This must be safe from any context. It's safe writing here
	176	* because of the head/tail separation of the writer and reader
	177	* of the CPU buffer.
	178	*
	179	* is_kernel is needed because on some architectures you cannot
	180	* tell if you are in kernel or user space simply by looking at
	181	* pc. We tag this in the buffer by generating kernel enter/exit
	182	* events whenever is_kernel changes
	183	*/
25ad2913	184	static int log_sample(struct oprofile_cpu_buffer *cpu_buf, unsigned long pc,
1da177e4 LT	185	int is_kernel, unsigned long event)
1da177e4 LT	186	{
25ad2913	187	struct task_struct *task;
1da177e4 LT	188
	189	cpu_buf->sample_received++;
	190
df9d177a PE	191	if (pc == ESCAPE_CODE) {
	192	cpu_buf->sample_invalid_eip++;
	193	return 0;
	194	}
	195
1da177e4 LT	196	is_kernel = !!is_kernel;
	197
	198	task = current;
	199
	200	/* notice a switch from user->kernel or vice versa */
	201	if (cpu_buf->last_is_kernel != is_kernel) {
	202	cpu_buf->last_is_kernel = is_kernel;
211117ff RR	203	if (add_code(cpu_buf, is_kernel))
211117ff RR	204	goto fail;
1da177e4 LT	205	}
	206
	207	/* notice a task switch */
	208	if (cpu_buf->last_task != task) {
	209	cpu_buf->last_task = task;
211117ff RR	210	if (add_code(cpu_buf, (unsigned long)task))
211117ff RR	211	goto fail;
1da177e4	212	}
6a18037d	213
211117ff RR	214	if (add_sample(cpu_buf, pc, event))
	215	goto fail;
	216
1da177e4	217	return 1;
211117ff RR	218
	219	fail:
	220	cpu_buf->sample_lost_overflow++;
	221	return 0;
1da177e4 LT	222	}
1da177e4 LT	223
345c2573	224	static int oprofile_begin_trace(struct oprofile_cpu_buffer *cpu_buf)
1da177e4	225	{
1da177e4 LT	226	add_code(cpu_buf, CPU_TRACE_BEGIN);
	227	cpu_buf->tracing = 1;
	228	return 1;
	229	}
	230
25ad2913	231	static void oprofile_end_trace(struct oprofile_cpu_buffer *cpu_buf)
1da177e4 LT	232	{
	233	cpu_buf->tracing = 0;
	234	}
	235
27357716 BR	236	void oprofile_add_ext_sample(unsigned long pc, struct pt_regs * const regs,
27357716 BR	237	unsigned long event, int is_kernel)
1da177e4	238	{
608dfddd	239	struct oprofile_cpu_buffer *cpu_buf = &__get_cpu_var(cpu_buffer);
1da177e4	240
bd2172f5	241	if (!oprofile_backtrace_depth) {
1da177e4 LT	242	log_sample(cpu_buf, pc, is_kernel, event);
	243	return;
	244	}
	245
	246	if (!oprofile_begin_trace(cpu_buf))
	247	return;
	248
fd13f6c8 RR	249	/*
	250	* if log_sample() fail we can't backtrace since we lost the
	251	* source of this event
	252	*/
1da177e4	253	if (log_sample(cpu_buf, pc, is_kernel, event))
bd2172f5	254	oprofile_ops.backtrace(regs, oprofile_backtrace_depth);
1da177e4 LT	255	oprofile_end_trace(cpu_buf);
	256	}
	257
27357716 BR	258	void oprofile_add_sample(struct pt_regs * const regs, unsigned long event)
	259	{
	260	int is_kernel = !user_mode(regs);
	261	unsigned long pc = profile_pc(regs);
	262
	263	oprofile_add_ext_sample(pc, regs, event, is_kernel);
	264	}
	265
852402cc RR	266	#ifdef CONFIG_OPROFILE_IBS
852402cc RR	267
e2fee276 RR	268	#define MAX_IBS_SAMPLE_SIZE 14
e2fee276 RR	269
cdc1834d RR	270	void oprofile_add_ibs_sample(struct pt_regs * const regs,
cdc1834d RR	271	unsigned int * const ibs_sample, int ibs_code)
345c2573	272	{
e2fee276 RR	273	int is_kernel = !user_mode(regs);
e2fee276 RR	274	struct oprofile_cpu_buffer *cpu_buf = &__get_cpu_var(cpu_buffer);
345c2573	275	struct task_struct *task;
211117ff	276	int fail = 0;
345c2573 BK	277
	278	cpu_buf->sample_received++;
	279
345c2573 BK	280	/* notice a switch from user->kernel or vice versa */
345c2573 BK	281	if (cpu_buf->last_is_kernel != is_kernel) {
211117ff RR	282	if (add_code(cpu_buf, is_kernel))
211117ff RR	283	goto fail;
345c2573	284	cpu_buf->last_is_kernel = is_kernel;
345c2573 BK	285	}
	286
	287	/* notice a task switch */
	288	if (!is_kernel) {
	289	task = current;
345c2573	290	if (cpu_buf->last_task != task) {
211117ff RR	291	if (add_code(cpu_buf, (unsigned long)task))
211117ff RR	292	goto fail;
345c2573	293	cpu_buf->last_task = task;
345c2573 BK	294	}
	295	}
	296
211117ff RR	297	fail = fail \|\| add_code(cpu_buf, ibs_code);
	298	fail = fail \|\| add_sample(cpu_buf, ibs_sample[0], ibs_sample[1]);
	299	fail = fail \|\| add_sample(cpu_buf, ibs_sample[2], ibs_sample[3]);
	300	fail = fail \|\| add_sample(cpu_buf, ibs_sample[4], ibs_sample[5]);
345c2573 BK	301
345c2573 BK	302	if (ibs_code == IBS_OP_BEGIN) {
211117ff RR	303	fail = fail \|\| add_sample(cpu_buf, ibs_sample[6], ibs_sample[7]);
	304	fail = fail \|\| add_sample(cpu_buf, ibs_sample[8], ibs_sample[9]);
	305	fail = fail \|\| add_sample(cpu_buf, ibs_sample[10], ibs_sample[11]);
345c2573 BK	306	}
345c2573 BK	307
211117ff RR	308	if (fail)
	309	goto fail;
	310
bd2172f5 RR	311	if (oprofile_backtrace_depth)
bd2172f5 RR	312	oprofile_ops.backtrace(regs, oprofile_backtrace_depth);
211117ff RR	313
	314	return;
	315
	316	fail:
	317	cpu_buf->sample_lost_overflow++;
	318	return;
345c2573 BK	319	}
345c2573 BK	320
852402cc RR	321	#endif
852402cc RR	322
1da177e4 LT	323	void oprofile_add_pc(unsigned long pc, int is_kernel, unsigned long event)
1da177e4 LT	324	{
608dfddd	325	struct oprofile_cpu_buffer *cpu_buf = &__get_cpu_var(cpu_buffer);
1da177e4 LT	326	log_sample(cpu_buf, pc, is_kernel, event);
	327	}
	328
1da177e4 LT	329	void oprofile_add_trace(unsigned long pc)
1da177e4 LT	330	{
608dfddd	331	struct oprofile_cpu_buffer *cpu_buf = &__get_cpu_var(cpu_buffer);
1da177e4 LT	332
	333	if (!cpu_buf->tracing)
	334	return;
	335
fd13f6c8 RR	336	/*
	337	* broken frame can give an eip with the same value as an
	338	* escape code, abort the trace if we get it
	339	*/
211117ff RR	340	if (pc == ESCAPE_CODE)
	341	goto fail;
	342
	343	if (add_sample(cpu_buf, pc, 0))
	344	goto fail;
1da177e4	345
211117ff RR	346	return;
	347	fail:
	348	cpu_buf->tracing = 0;
	349	cpu_buf->backtrace_aborted++;
	350	return;
1da177e4 LT	351	}
1da177e4 LT	352
1da177e4 LT	353	/*
	354	* This serves to avoid cpu buffer overflow, and makes sure
	355	* the task mortuary progresses
	356	*
	357	* By using schedule_delayed_work_on and then schedule_delayed_work
	358	* we guarantee this will stay on the correct cpu
	359	*/
c4028958	360	static void wq_sync_buffer(struct work_struct *work)
1da177e4	361	{
25ad2913	362	struct oprofile_cpu_buffer *b =
c4028958	363	container_of(work, struct oprofile_cpu_buffer, work.work);
1da177e4	364	if (b->cpu != smp_processor_id()) {
bd17b625	365	printk(KERN_DEBUG "WQ on CPU%d, prefer CPU%d\n",
1da177e4	366	smp_processor_id(), b->cpu);
4bd9b9dc CA	367
	368	if (!cpu_online(b->cpu)) {
	369	cancel_delayed_work(&b->work);
	370	return;
	371	}
1da177e4 LT	372	}
	373	sync_buffer(b->cpu);
	374
	375	/* don't re-add the work if we're shutting down */
	376	if (work_enabled)
	377	schedule_delayed_work(&b->work, DEFAULT_TIMER_EXPIRE);
	378	}