trace.c 99.6 KB
Newer Older
1 2 3 4 5 6 7 8 9 10 11 12 13
/*
 * ring buffer based function tracer
 *
 * Copyright (C) 2007-2008 Steven Rostedt <srostedt@redhat.com>
 * Copyright (C) 2008 Ingo Molnar <mingo@redhat.com>
 *
 * Originally taken from the RT patch by:
 *    Arnaldo Carvalho de Melo <acme@redhat.com>
 *
 * Based on code from the latency_tracer, that is:
 *  Copyright (C) 2004-2006 Ingo Molnar
 *  Copyright (C) 2004 William Lee Irwin III
 */
14
#include <linux/ring_buffer.h>
15
#include <generated/utsrelease.h>
16 17
#include <linux/stacktrace.h>
#include <linux/writeback.h>
18 19
#include <linux/kallsyms.h>
#include <linux/seq_file.h>
A
Alexey Dobriyan 已提交
20
#include <linux/smp_lock.h>
21
#include <linux/notifier.h>
22
#include <linux/irqflags.h>
23
#include <linux/debugfs.h>
24
#include <linux/pagemap.h>
25 26 27
#include <linux/hardirq.h>
#include <linux/linkage.h>
#include <linux/uaccess.h>
28
#include <linux/kprobes.h>
29 30 31
#include <linux/ftrace.h>
#include <linux/module.h>
#include <linux/percpu.h>
32
#include <linux/splice.h>
33
#include <linux/kdebug.h>
34
#include <linux/string.h>
35 36
#include <linux/ctype.h>
#include <linux/init.h>
37
#include <linux/poll.h>
38 39
#include <linux/gfp.h>
#include <linux/fs.h>
I
Ingo Molnar 已提交
40

41
#include "trace.h"
42
#include "trace_output.h"
43

44 45
#define TRACE_BUFFER_FLAGS	(RB_FL_OVERWRITE)

46 47 48 49
/*
 * On boot up, the ring buffer is set to the minimum size, so that
 * we do not waste memory on systems that are not using tracing.
 */
50
int ring_buffer_expanded;
51

52 53
/*
 * We need to change this state when a selftest is running.
54 55
 * A selftest will lurk into the ring-buffer to count the
 * entries inserted during the selftest although some concurrent
56
 * insertions into the ring-buffer such as trace_printk could occurred
57 58
 * at the same time, giving false positive or negative results.
 */
59
static bool __read_mostly tracing_selftest_running;
60

61 62 63
/*
 * If a tracer is running, we do not want to run SELFTEST.
 */
64
bool __read_mostly tracing_selftest_disabled;
65

66 67 68 69 70 71 72 73 74 75 76 77 78 79
/* For tracers that don't implement custom flags */
static struct tracer_opt dummy_tracer_opt[] = {
	{ }
};

static struct tracer_flags dummy_tracer_flags = {
	.val = 0,
	.opts = dummy_tracer_opt
};

static int dummy_set_flag(u32 old_flags, u32 bit, int set)
{
	return 0;
}
80 81 82 83 84 85 86

/*
 * Kill all tracing for good (never come back).
 * It is initialized to 1 but will turn to zero if the initialization
 * of the tracer is successful. But that is the only place that sets
 * this back to zero.
 */
87
static int tracing_disabled = 1;
88

89
DEFINE_PER_CPU(int, ftrace_cpu_disabled);
90 91 92 93

static inline void ftrace_disable_cpu(void)
{
	preempt_disable();
94
	__this_cpu_inc(per_cpu_var(ftrace_cpu_disabled));
95 96 97 98
}

static inline void ftrace_enable_cpu(void)
{
99
	__this_cpu_dec(per_cpu_var(ftrace_cpu_disabled));
100 101 102
	preempt_enable();
}

103
static cpumask_var_t __read_mostly	tracing_buffer_mask;
104

105 106 107
/* Define which cpu buffers are currently read in trace_pipe */
static cpumask_var_t			tracing_reader_cpumask;

108
#define for_each_tracing_cpu(cpu)	\
109
	for_each_cpu(cpu, tracing_buffer_mask)
110

111 112 113 114 115 116 117 118 119 120 121 122 123 124 125
/*
 * ftrace_dump_on_oops - variable to dump ftrace buffer on oops
 *
 * If there is an oops (or kernel panic) and the ftrace_dump_on_oops
 * is set, then ftrace_dump is called. This will output the contents
 * of the ftrace buffers to the console.  This is very useful for
 * capturing traces that lead to crashes and outputing it to a
 * serial console.
 *
 * It is default off, but you can enable it with either specifying
 * "ftrace_dump_on_oops" in the kernel command line, or setting
 * /proc/sys/kernel/ftrace_dump_on_oops to true.
 */
int ftrace_dump_on_oops;

126 127
static int tracing_set_tracer(const char *buf);

L
Li Zefan 已提交
128 129
#define MAX_TRACER_SIZE		100
static char bootup_tracer_buf[MAX_TRACER_SIZE] __initdata;
130
static char *default_bootup_tracer;
131

132
static int __init set_cmdline_ftrace(char *str)
133
{
L
Li Zefan 已提交
134
	strncpy(bootup_tracer_buf, str, MAX_TRACER_SIZE);
135
	default_bootup_tracer = bootup_tracer_buf;
136 137
	/* We are using ftrace early, expand it */
	ring_buffer_expanded = 1;
138 139
	return 1;
}
140
__setup("ftrace=", set_cmdline_ftrace);
141

142 143 144 145 146 147
static int __init set_ftrace_dump_on_oops(char *str)
{
	ftrace_dump_on_oops = 1;
	return 1;
}
__setup("ftrace_dump_on_oops", set_ftrace_dump_on_oops);
S
Steven Rostedt 已提交
148

149
unsigned long long ns2usecs(cycle_t nsec)
150 151 152 153 154 155
{
	nsec += 500;
	do_div(nsec, 1000);
	return nsec;
}

S
Steven Rostedt 已提交
156 157 158 159 160 161 162 163 164 165 166 167
/*
 * The global_trace is the descriptor that holds the tracing
 * buffers for the live tracing. For each CPU, it contains
 * a link list of pages that will store trace entries. The
 * page descriptor of the pages in the memory is used to hold
 * the link list by linking the lru item in the page descriptor
 * to each of the pages in the buffer per CPU.
 *
 * For each active CPU there is a data field that holds the
 * pages for the buffer for that CPU. Each CPU has the same number
 * of pages allocated for its buffer.
 */
168 169 170 171
static struct trace_array	global_trace;

static DEFINE_PER_CPU(struct trace_array_cpu, global_trace_cpu);

172 173
int filter_current_check_discard(struct ring_buffer *buffer,
				 struct ftrace_event_call *call, void *rec,
174 175
				 struct ring_buffer_event *event)
{
176
	return filter_check_discard(call, rec, buffer, event);
177
}
178
EXPORT_SYMBOL_GPL(filter_current_check_discard);
179

180 181 182 183 184 185 186 187 188 189 190 191 192
cycle_t ftrace_now(int cpu)
{
	u64 ts;

	/* Early boot up does not have a buffer yet */
	if (!global_trace.buffer)
		return trace_clock_local();

	ts = ring_buffer_time_stamp(global_trace.buffer, cpu);
	ring_buffer_normalize_time_stamp(global_trace.buffer, cpu, &ts);

	return ts;
}
193

S
Steven Rostedt 已提交
194 195 196 197 198 199 200 201 202 203
/*
 * The max_tr is used to snapshot the global_trace when a maximum
 * latency is reached. Some tracers will use this to store a maximum
 * trace while it continues examining live traces.
 *
 * The buffers for the max_tr are set up the same as the global_trace.
 * When a snapshot is taken, the link list of the max_tr is swapped
 * with the link list of the global_trace and the buffers are reset for
 * the global_trace so the tracing can continue.
 */
204 205
static struct trace_array	max_tr;

206
static DEFINE_PER_CPU(struct trace_array_cpu, max_tr_data);
207

S
Steven Rostedt 已提交
208
/* tracer_enabled is used to toggle activation of a tracer */
209
static int			tracer_enabled = 1;
S
Steven Rostedt 已提交
210

211 212 213 214 215 216 217 218 219 220 221 222 223
/**
 * tracing_is_enabled - return tracer_enabled status
 *
 * This function is used by other tracers to know the status
 * of the tracer_enabled flag.  Tracers may use this function
 * to know if it should enable their features when starting
 * up. See irqsoff tracer for an example (start_irqsoff_tracer).
 */
int tracing_is_enabled(void)
{
	return tracer_enabled;
}

S
Steven Rostedt 已提交
224
/*
225 226 227
 * trace_buf_size is the size in bytes that is allocated
 * for a buffer. Note, the number of bytes is always rounded
 * to page size.
228 229 230 231 232
 *
 * This number is purposely set to a low number of 16384.
 * If the dump on oops happens, it will be much appreciated
 * to not have to wait for all that output. Anyway this can be
 * boot time and run time configurable.
S
Steven Rostedt 已提交
233
 */
234
#define TRACE_BUF_SIZE_DEFAULT	1441792UL /* 16384 * 88 (sizeof(entry)) */
235

236
static unsigned long		trace_buf_size = TRACE_BUF_SIZE_DEFAULT;
237

S
Steven Rostedt 已提交
238
/* trace_types holds a link list of available tracers. */
239
static struct tracer		*trace_types __read_mostly;
S
Steven Rostedt 已提交
240 241

/* current_trace points to the tracer that is currently active */
242
static struct tracer		*current_trace __read_mostly;
S
Steven Rostedt 已提交
243 244 245 246 247 248 249

/*
 * trace_types_lock is used to protect the trace_types list.
 * This lock is also used to keep user access serialized.
 * Accesses from userspace will grab this lock while userspace
 * activities happen inside the kernel.
 */
250
static DEFINE_MUTEX(trace_types_lock);
S
Steven Rostedt 已提交
251 252

/* trace_wait is a waitqueue for tasks blocked on trace_poll */
253 254
static DECLARE_WAIT_QUEUE_HEAD(trace_wait);

255
/* trace_flags holds trace_options default values */
256
unsigned long trace_flags = TRACE_ITER_PRINT_PARENT | TRACE_ITER_PRINTK |
257 258
	TRACE_ITER_ANNOTATE | TRACE_ITER_CONTEXT_INFO | TRACE_ITER_SLEEP_TIME |
	TRACE_ITER_GRAPH_TIME;
259

260 261 262
static int trace_stop_count;
static DEFINE_SPINLOCK(tracing_start_lock);

S
Steven Rostedt 已提交
263 264 265 266 267 268
/**
 * trace_wake_up - wake up tasks waiting for trace input
 *
 * Simply wakes up any task that is blocked on the trace_wait
 * queue. These is used with trace_poll for tasks polling the trace.
 */
269 270
void trace_wake_up(void)
{
271 272 273 274
	int cpu;

	if (trace_flags & TRACE_ITER_BLOCK)
		return;
I
Ingo Molnar 已提交
275 276 277 278
	/*
	 * The runqueue_is_locked() can fail, but this is the best we
	 * have for now:
	 */
279 280
	cpu = get_cpu();
	if (!runqueue_is_locked(cpu))
281
		wake_up(&trace_wait);
282
	put_cpu();
283
}
284

285
static int __init set_buf_size(char *str)
286
{
287
	unsigned long buf_size;
288

289 290
	if (!str)
		return 0;
291
	buf_size = memparse(str, &str);
292
	/* nr_entries can not be zero */
293
	if (buf_size == 0)
294
		return 0;
295
	trace_buf_size = buf_size;
296 297
	return 1;
}
298
__setup("trace_buf_size=", set_buf_size);
299

S
Steven Rostedt 已提交
300 301 302 303 304
unsigned long nsecs_to_usecs(unsigned long nsecs)
{
	return nsecs / 1000;
}

S
Steven Rostedt 已提交
305
/* These must match the bit postions in trace_iterator_flags */
306 307 308 309 310
static const char *trace_options[] = {
	"print-parent",
	"sym-offset",
	"sym-addr",
	"verbose",
I
Ingo Molnar 已提交
311
	"raw",
312
	"hex",
I
Ingo Molnar 已提交
313
	"bin",
314
	"block",
I
Ingo Molnar 已提交
315
	"stacktrace",
316
	"trace_printk",
317
	"ftrace_preempt",
318
	"branch",
319
	"annotate",
320
	"userstacktrace",
321
	"sym-userobj",
322
	"printk-msg-only",
323
	"context-info",
324
	"latency-format",
325
	"sleep-time",
326
	"graph-time",
327 328 329
	NULL
};

330 331 332 333 334 335 336 337 338 339
static struct {
	u64 (*func)(void);
	const char *name;
} trace_clocks[] = {
	{ trace_clock_local,	"local" },
	{ trace_clock_global,	"global" },
};

int trace_clock_id;

340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416
/*
 * trace_parser_get_init - gets the buffer for trace parser
 */
int trace_parser_get_init(struct trace_parser *parser, int size)
{
	memset(parser, 0, sizeof(*parser));

	parser->buffer = kmalloc(size, GFP_KERNEL);
	if (!parser->buffer)
		return 1;

	parser->size = size;
	return 0;
}

/*
 * trace_parser_put - frees the buffer for trace parser
 */
void trace_parser_put(struct trace_parser *parser)
{
	kfree(parser->buffer);
}

/*
 * trace_get_user - reads the user input string separated by  space
 * (matched by isspace(ch))
 *
 * For each string found the 'struct trace_parser' is updated,
 * and the function returns.
 *
 * Returns number of bytes read.
 *
 * See kernel/trace/trace.h for 'struct trace_parser' details.
 */
int trace_get_user(struct trace_parser *parser, const char __user *ubuf,
	size_t cnt, loff_t *ppos)
{
	char ch;
	size_t read = 0;
	ssize_t ret;

	if (!*ppos)
		trace_parser_clear(parser);

	ret = get_user(ch, ubuf++);
	if (ret)
		goto out;

	read++;
	cnt--;

	/*
	 * The parser is not finished with the last write,
	 * continue reading the user input without skipping spaces.
	 */
	if (!parser->cont) {
		/* skip white space */
		while (cnt && isspace(ch)) {
			ret = get_user(ch, ubuf++);
			if (ret)
				goto out;
			read++;
			cnt--;
		}

		/* only spaces were written */
		if (isspace(ch)) {
			*ppos += read;
			ret = read;
			goto out;
		}

		parser->idx = 0;
	}

	/* read the non-space input */
	while (cnt && !isspace(ch)) {
417
		if (parser->idx < parser->size - 1)
418 419 420 421 422 423 424 425 426 427 428 429 430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 445
			parser->buffer[parser->idx++] = ch;
		else {
			ret = -EINVAL;
			goto out;
		}
		ret = get_user(ch, ubuf++);
		if (ret)
			goto out;
		read++;
		cnt--;
	}

	/* We either got finished input or we have to wait for another call. */
	if (isspace(ch)) {
		parser->buffer[parser->idx] = 0;
		parser->cont = false;
	} else {
		parser->cont = true;
		parser->buffer[parser->idx++] = ch;
	}

	*ppos += read;
	ret = read;

out:
	return ret;
}

446 447 448 449 450
ssize_t trace_seq_to_user(struct trace_seq *s, char __user *ubuf, size_t cnt)
{
	int len;
	int ret;

451 452 453
	if (!cnt)
		return 0;

454 455 456 457 458 459 460
	if (s->len <= s->readpos)
		return -EBUSY;

	len = s->len - s->readpos;
	if (cnt > len)
		cnt = len;
	ret = copy_to_user(ubuf, s->buffer + s->readpos, cnt);
461
	if (ret == cnt)
462 463
		return -EFAULT;

464 465
	cnt -= ret;

466
	s->readpos += cnt;
467
	return cnt;
S
Steven Rostedt 已提交
468 469
}

470
static ssize_t trace_seq_to_buffer(struct trace_seq *s, void *buf, size_t cnt)
471 472 473 474 475 476 477 478 479 480 481 482 483 484
{
	int len;
	void *ret;

	if (s->len <= s->readpos)
		return -EBUSY;

	len = s->len - s->readpos;
	if (cnt > len)
		cnt = len;
	ret = memcpy(buf, s->buffer + s->readpos, cnt);
	if (!ret)
		return -EFAULT;

485
	s->readpos += cnt;
486 487 488
	return cnt;
}

489 490 491 492 493 494
/*
 * ftrace_max_lock is used to protect the swapping of buffers
 * when taking a max snapshot. The buffers themselves are
 * protected by per_cpu spinlocks. But the action of the swap
 * needs its own lock.
 *
495
 * This is defined as a arch_spinlock_t in order to help
496 497 498 499 500 501
 * with performance when lockdep debugging is enabled.
 *
 * It is also used in other places outside the update_max_tr
 * so it needs to be defined outside of the
 * CONFIG_TRACER_MAX_TRACE.
 */
502
static arch_spinlock_t ftrace_max_lock =
503
	(arch_spinlock_t)__ARCH_SPIN_LOCK_UNLOCKED;
504 505 506 507 508 509 510 511 512 513 514 515 516 517

#ifdef CONFIG_TRACER_MAX_TRACE
unsigned long __read_mostly	tracing_max_latency;
unsigned long __read_mostly	tracing_thresh;

/*
 * Copy the new maximum trace into the separate maximum-trace
 * structure. (this way the maximum trace is permanently saved,
 * for later retrieval via /sys/kernel/debug/tracing/latency_trace)
 */
static void
__update_max_tr(struct trace_array *tr, struct task_struct *tsk, int cpu)
{
	struct trace_array_cpu *data = tr->data[cpu];
518
	struct trace_array_cpu *max_data = tr->data[cpu];
519 520 521 522

	max_tr.cpu = cpu;
	max_tr.time_start = data->preempt_timestamp;

523 524 525 526
	max_data = max_tr.data[cpu];
	max_data->saved_latency = tracing_max_latency;
	max_data->critical_start = data->critical_start;
	max_data->critical_end = data->critical_end;
527 528

	memcpy(data->comm, tsk->comm, TASK_COMM_LEN);
529 530 531 532 533
	max_data->pid = tsk->pid;
	max_data->uid = task_uid(tsk);
	max_data->nice = tsk->static_prio - 20 - MAX_RT_PRIO;
	max_data->policy = tsk->policy;
	max_data->rt_priority = tsk->rt_priority;
534 535 536 537 538

	/* record this tasks comm */
	tracing_record_cmdline(tsk);
}

S
Steven Rostedt 已提交
539 540 541 542 543 544 545 546 547
/**
 * update_max_tr - snapshot all trace buffers from global_trace to max_tr
 * @tr: tracer
 * @tsk: the task with the latency
 * @cpu: The cpu that initiated the trace.
 *
 * Flip the buffers between the @tr and the max_tr and record information
 * about which task was the cause of this latency.
 */
I
Ingo Molnar 已提交
548
void
549 550
update_max_tr(struct trace_array *tr, struct task_struct *tsk, int cpu)
{
551
	struct ring_buffer *buf = tr->buffer;
552

553 554 555
	if (trace_stop_count)
		return;

556
	WARN_ON_ONCE(!irqs_disabled());
557
	arch_spin_lock(&ftrace_max_lock);
558 559 560 561

	tr->buffer = max_tr.buffer;
	max_tr.buffer = buf;

562
	__update_max_tr(tr, tsk, cpu);
563
	arch_spin_unlock(&ftrace_max_lock);
564 565 566 567 568 569 570
}

/**
 * update_max_tr_single - only copy one trace over, and reset the rest
 * @tr - tracer
 * @tsk - task with the latency
 * @cpu - the cpu of the buffer to copy.
S
Steven Rostedt 已提交
571 572
 *
 * Flip the trace of a single CPU buffer between the @tr and the max_tr.
573
 */
I
Ingo Molnar 已提交
574
void
575 576
update_max_tr_single(struct trace_array *tr, struct task_struct *tsk, int cpu)
{
577
	int ret;
578

579 580 581
	if (trace_stop_count)
		return;

582
	WARN_ON_ONCE(!irqs_disabled());
583
	arch_spin_lock(&ftrace_max_lock);
584

585 586
	ftrace_disable_cpu();

587 588
	ret = ring_buffer_swap_cpu(max_tr.buffer, tr->buffer, cpu);

589 590 591 592 593 594 595 596 597 598 599
	if (ret == -EBUSY) {
		/*
		 * We failed to swap the buffer due to a commit taking
		 * place on this CPU. We fail to record, but we reset
		 * the max trace buffer (no one writes directly to it)
		 * and flag that it failed.
		 */
		trace_array_printk(&max_tr, _THIS_IP_,
			"Failed to swap buffers due to commit in progress\n");
	}

600 601
	ftrace_enable_cpu();

602
	WARN_ON_ONCE(ret && ret != -EAGAIN && ret != -EBUSY);
603 604

	__update_max_tr(tr, tsk, cpu);
605
	arch_spin_unlock(&ftrace_max_lock);
606
}
607
#endif /* CONFIG_TRACER_MAX_TRACE */
608

S
Steven Rostedt 已提交
609 610 611 612 613 614
/**
 * register_tracer - register a tracer with the ftrace system.
 * @type - the plugin for the tracer
 *
 * Register a new plugin tracer.
 */
615
int register_tracer(struct tracer *type)
616 617
__releases(kernel_lock)
__acquires(kernel_lock)
618 619 620 621 622 623 624 625 626
{
	struct tracer *t;
	int ret = 0;

	if (!type->name) {
		pr_info("Tracer must have a name\n");
		return -1;
	}

L
Li Zefan 已提交
627 628 629 630 631
	if (strlen(type->name) > MAX_TRACER_SIZE) {
		pr_info("Tracer has a name longer than %d\n", MAX_TRACER_SIZE);
		return -1;
	}

I
Ingo Molnar 已提交
632 633 634 635 636 637 638
	/*
	 * When this gets called we hold the BKL which means that
	 * preemption is disabled. Various trace selftests however
	 * need to disable and enable preemption for successful tests.
	 * So we drop the BKL here and grab it after the tests again.
	 */
	unlock_kernel();
639
	mutex_lock(&trace_types_lock);
I
Ingo Molnar 已提交
640

641 642
	tracing_selftest_running = true;

643 644 645
	for (t = trace_types; t; t = t->next) {
		if (strcmp(type->name, t->name) == 0) {
			/* already found */
L
Li Zefan 已提交
646
			pr_info("Tracer %s already registered\n",
647 648 649 650 651 652
				type->name);
			ret = -1;
			goto out;
		}
	}

653 654 655 656 657 658 659
	if (!type->set_flag)
		type->set_flag = &dummy_set_flag;
	if (!type->flags)
		type->flags = &dummy_tracer_flags;
	else
		if (!type->flags->opts)
			type->flags->opts = dummy_tracer_opt;
660 661 662
	if (!type->wait_pipe)
		type->wait_pipe = default_wait_pipe;

663

S
Steven Rostedt 已提交
664
#ifdef CONFIG_FTRACE_STARTUP_TEST
665
	if (type->selftest && !tracing_selftest_disabled) {
S
Steven Rostedt 已提交
666 667
		struct tracer *saved_tracer = current_trace;
		struct trace_array *tr = &global_trace;
668

S
Steven Rostedt 已提交
669 670 671 672 673 674 675
		/*
		 * Run a selftest on this tracer.
		 * Here we reset the trace buffer, and set the current
		 * tracer to be this tracer. The tracer can then run some
		 * internal tracing to verify that everything is in order.
		 * If we fail, we do not register this tracer.
		 */
676
		tracing_reset_online_cpus(tr);
I
Ingo Molnar 已提交
677

S
Steven Rostedt 已提交
678 679 680 681 682 683 684 685 686 687
		current_trace = type;
		/* the test is responsible for initializing and enabling */
		pr_info("Testing tracer %s: ", type->name);
		ret = type->selftest(type, tr);
		/* the test is responsible for resetting too */
		current_trace = saved_tracer;
		if (ret) {
			printk(KERN_CONT "FAILED!\n");
			goto out;
		}
S
Steven Rostedt 已提交
688
		/* Only reset on passing, to avoid touching corrupted buffers */
689
		tracing_reset_online_cpus(tr);
I
Ingo Molnar 已提交
690

S
Steven Rostedt 已提交
691 692 693 694
		printk(KERN_CONT "PASSED\n");
	}
#endif

695 696
	type->next = trace_types;
	trace_types = type;
S
Steven Rostedt 已提交
697

698
 out:
699
	tracing_selftest_running = false;
700 701
	mutex_unlock(&trace_types_lock);

S
Steven Rostedt 已提交
702 703 704
	if (ret || !default_bootup_tracer)
		goto out_unlock;

L
Li Zefan 已提交
705
	if (strncmp(default_bootup_tracer, type->name, MAX_TRACER_SIZE))
S
Steven Rostedt 已提交
706 707 708 709 710 711 712 713
		goto out_unlock;

	printk(KERN_INFO "Starting tracer '%s'\n", type->name);
	/* Do we want this tracer to start on bootup? */
	tracing_set_tracer(type->name);
	default_bootup_tracer = NULL;
	/* disable other selftests, since this will break it. */
	tracing_selftest_disabled = 1;
714
#ifdef CONFIG_FTRACE_STARTUP_TEST
S
Steven Rostedt 已提交
715 716
	printk(KERN_INFO "Disabling FTRACE selftests due to running tracer '%s'\n",
	       type->name);
717 718
#endif

S
Steven Rostedt 已提交
719
 out_unlock:
720
	lock_kernel();
721 722 723 724 725 726 727 728 729 730 731 732
	return ret;
}

void unregister_tracer(struct tracer *type)
{
	struct tracer **t;

	mutex_lock(&trace_types_lock);
	for (t = &trace_types; *t; t = &(*t)->next) {
		if (*t == type)
			goto found;
	}
L
Li Zefan 已提交
733
	pr_info("Tracer %s not registered\n", type->name);
734 735 736 737
	goto out;

 found:
	*t = (*t)->next;
738 739 740 741 742 743 744 745

	if (type == current_trace && tracer_enabled) {
		tracer_enabled = 0;
		tracing_stop();
		if (current_trace->stop)
			current_trace->stop(&global_trace);
		current_trace = &nop_trace;
	}
L
Li Zefan 已提交
746
out:
747 748 749
	mutex_unlock(&trace_types_lock);
}

750
static void __tracing_reset(struct trace_array *tr, int cpu)
751
{
752
	ftrace_disable_cpu();
753
	ring_buffer_reset_cpu(tr->buffer, cpu);
754
	ftrace_enable_cpu();
755 756
}

757 758 759 760 761 762 763 764 765 766 767 768 769
void tracing_reset(struct trace_array *tr, int cpu)
{
	struct ring_buffer *buffer = tr->buffer;

	ring_buffer_record_disable(buffer);

	/* Make sure all commits have finished */
	synchronize_sched();
	__tracing_reset(tr, cpu);

	ring_buffer_record_enable(buffer);
}

770 771
void tracing_reset_online_cpus(struct trace_array *tr)
{
772
	struct ring_buffer *buffer = tr->buffer;
773 774
	int cpu;

775 776 777 778 779
	ring_buffer_record_disable(buffer);

	/* Make sure all commits have finished */
	synchronize_sched();

780 781 782
	tr->time_start = ftrace_now(tr->cpu);

	for_each_online_cpu(cpu)
783
		__tracing_reset(tr, cpu);
784 785

	ring_buffer_record_enable(buffer);
786 787
}

788 789 790 791 792 793 794 795 796 797
void tracing_reset_current(int cpu)
{
	tracing_reset(&global_trace, cpu);
}

void tracing_reset_current_online_cpus(void)
{
	tracing_reset_online_cpus(&global_trace);
}

798
#define SAVED_CMDLINES 128
799
#define NO_CMDLINE_MAP UINT_MAX
800 801 802 803
static unsigned map_pid_to_cmdline[PID_MAX_DEFAULT+1];
static unsigned map_cmdline_to_pid[SAVED_CMDLINES];
static char saved_cmdlines[SAVED_CMDLINES][TASK_COMM_LEN];
static int cmdline_idx;
804
static arch_spinlock_t trace_cmdline_lock = __ARCH_SPIN_LOCK_UNLOCKED;
805 806

/* temporary disable recording */
807
static atomic_t trace_record_cmdline_disabled __read_mostly;
808 809 810

static void trace_init_cmdlines(void)
{
811 812
	memset(&map_pid_to_cmdline, NO_CMDLINE_MAP, sizeof(map_pid_to_cmdline));
	memset(&map_cmdline_to_pid, NO_CMDLINE_MAP, sizeof(map_cmdline_to_pid));
813 814 815
	cmdline_idx = 0;
}

816 817 818 819 820
int is_tracing_stopped(void)
{
	return trace_stop_count;
}

S
Steven Rostedt 已提交
821 822 823 824 825 826 827 828 829 830 831 832 833 834 835
/**
 * ftrace_off_permanent - disable all ftrace code permanently
 *
 * This should only be called when a serious anomally has
 * been detected.  This will turn off the function tracing,
 * ring buffers, and other tracing utilites. It takes no
 * locks and can be called from any context.
 */
void ftrace_off_permanent(void)
{
	tracing_disabled = 1;
	ftrace_stop();
	tracing_off_permanent();
}

836 837 838 839 840 841 842 843 844 845 846 847 848 849 850
/**
 * tracing_start - quick start of the tracer
 *
 * If tracing is enabled but was stopped by tracing_stop,
 * this will start the tracer back up.
 */
void tracing_start(void)
{
	struct ring_buffer *buffer;
	unsigned long flags;

	if (tracing_disabled)
		return;

	spin_lock_irqsave(&tracing_start_lock, flags);
851 852 853 854 855 856
	if (--trace_stop_count) {
		if (trace_stop_count < 0) {
			/* Someone screwed up their debugging */
			WARN_ON_ONCE(1);
			trace_stop_count = 0;
		}
857 858 859 860 861 862 863 864 865 866 867 868 869 870 871 872 873 874 875 876 877 878 879 880 881 882 883 884 885 886 887 888 889 890 891 892 893 894 895 896 897 898 899 900 901
		goto out;
	}


	buffer = global_trace.buffer;
	if (buffer)
		ring_buffer_record_enable(buffer);

	buffer = max_tr.buffer;
	if (buffer)
		ring_buffer_record_enable(buffer);

	ftrace_start();
 out:
	spin_unlock_irqrestore(&tracing_start_lock, flags);
}

/**
 * tracing_stop - quick stop of the tracer
 *
 * Light weight way to stop tracing. Use in conjunction with
 * tracing_start.
 */
void tracing_stop(void)
{
	struct ring_buffer *buffer;
	unsigned long flags;

	ftrace_stop();
	spin_lock_irqsave(&tracing_start_lock, flags);
	if (trace_stop_count++)
		goto out;

	buffer = global_trace.buffer;
	if (buffer)
		ring_buffer_record_disable(buffer);

	buffer = max_tr.buffer;
	if (buffer)
		ring_buffer_record_disable(buffer);

 out:
	spin_unlock_irqrestore(&tracing_start_lock, flags);
}

I
Ingo Molnar 已提交
902
void trace_stop_cmdline_recording(void);
903

I
Ingo Molnar 已提交
904
static void trace_save_cmdline(struct task_struct *tsk)
905
{
906
	unsigned pid, idx;
907 908 909 910 911 912 913 914 915 916

	if (!tsk->pid || unlikely(tsk->pid > PID_MAX_DEFAULT))
		return;

	/*
	 * It's not the end of the world if we don't get
	 * the lock, but we also don't want to spin
	 * nor do we want to disable interrupts,
	 * so if we miss here, then better luck next time.
	 */
917
	if (!arch_spin_trylock(&trace_cmdline_lock))
918 919 920
		return;

	idx = map_pid_to_cmdline[tsk->pid];
921
	if (idx == NO_CMDLINE_MAP) {
922 923
		idx = (cmdline_idx + 1) % SAVED_CMDLINES;

924 925 926 927 928 929 930 931 932
		/*
		 * Check whether the cmdline buffer at idx has a pid
		 * mapped. We are going to overwrite that entry so we
		 * need to clear the map_pid_to_cmdline. Otherwise we
		 * would read the new comm for the old pid.
		 */
		pid = map_cmdline_to_pid[idx];
		if (pid != NO_CMDLINE_MAP)
			map_pid_to_cmdline[pid] = NO_CMDLINE_MAP;
933

934
		map_cmdline_to_pid[idx] = tsk->pid;
935 936 937 938 939 940 941
		map_pid_to_cmdline[tsk->pid] = idx;

		cmdline_idx = idx;
	}

	memcpy(&saved_cmdlines[idx], tsk->comm, TASK_COMM_LEN);

942
	arch_spin_unlock(&trace_cmdline_lock);
943 944
}

945
void trace_find_cmdline(int pid, char comm[])
946 947 948
{
	unsigned map;

949 950 951 952
	if (!pid) {
		strcpy(comm, "<idle>");
		return;
	}
953

954 955 956 957
	if (pid > PID_MAX_DEFAULT) {
		strcpy(comm, "<...>");
		return;
	}
958

959
	preempt_disable();
960
	arch_spin_lock(&trace_cmdline_lock);
961
	map = map_pid_to_cmdline[pid];
962 963 964 965
	if (map != NO_CMDLINE_MAP)
		strcpy(comm, saved_cmdlines[map]);
	else
		strcpy(comm, "<...>");
966

967
	arch_spin_unlock(&trace_cmdline_lock);
968
	preempt_enable();
969 970
}

I
Ingo Molnar 已提交
971
void tracing_record_cmdline(struct task_struct *tsk)
972
{
973 974
	if (atomic_read(&trace_record_cmdline_disabled) || !tracer_enabled ||
	    !tracing_is_on())
975 976 977 978 979
		return;

	trace_save_cmdline(tsk);
}

980
void
981 982
tracing_generic_entry_update(struct trace_entry *entry, unsigned long flags,
			     int pc)
983 984 985
{
	struct task_struct *tsk = current;

986 987
	entry->preempt_count		= pc & 0xff;
	entry->pid			= (tsk) ? tsk->pid : 0;
988
	entry->lock_depth		= (tsk) ? tsk->lock_depth : 0;
989
	entry->flags =
990
#ifdef CONFIG_TRACE_IRQFLAGS_SUPPORT
991
		(irqs_disabled_flags(flags) ? TRACE_FLAG_IRQS_OFF : 0) |
992 993 994
#else
		TRACE_FLAG_IRQS_NOSUPPORT |
#endif
995 996 997 998
		((pc & HARDIRQ_MASK) ? TRACE_FLAG_HARDIRQ : 0) |
		((pc & SOFTIRQ_MASK) ? TRACE_FLAG_SOFTIRQ : 0) |
		(need_resched() ? TRACE_FLAG_NEED_RESCHED : 0);
}
999
EXPORT_SYMBOL_GPL(tracing_generic_entry_update);
1000

1001 1002 1003 1004 1005
struct ring_buffer_event *
trace_buffer_lock_reserve(struct ring_buffer *buffer,
			  int type,
			  unsigned long len,
			  unsigned long flags, int pc)
1006 1007 1008
{
	struct ring_buffer_event *event;

1009
	event = ring_buffer_lock_reserve(buffer, len);
1010 1011 1012 1013 1014 1015 1016 1017 1018 1019
	if (event != NULL) {
		struct trace_entry *ent = ring_buffer_event_data(event);

		tracing_generic_entry_update(ent, flags, pc);
		ent->type = type;
	}

	return event;
}

1020 1021 1022 1023 1024
static inline void
__trace_buffer_unlock_commit(struct ring_buffer *buffer,
			     struct ring_buffer_event *event,
			     unsigned long flags, int pc,
			     int wake)
1025
{
1026
	ring_buffer_unlock_commit(buffer, event);
1027

1028 1029
	ftrace_trace_stack(buffer, flags, 6, pc);
	ftrace_trace_userstack(buffer, flags, pc);
1030 1031 1032 1033 1034

	if (wake)
		trace_wake_up();
}

1035 1036 1037
void trace_buffer_unlock_commit(struct ring_buffer *buffer,
				struct ring_buffer_event *event,
				unsigned long flags, int pc)
1038
{
1039
	__trace_buffer_unlock_commit(buffer, event, flags, pc, 1);
1040 1041
}

1042
struct ring_buffer_event *
1043 1044
trace_current_buffer_lock_reserve(struct ring_buffer **current_rb,
				  int type, unsigned long len,
1045 1046
				  unsigned long flags, int pc)
{
1047 1048
	*current_rb = global_trace.buffer;
	return trace_buffer_lock_reserve(*current_rb,
1049 1050
					 type, len, flags, pc);
}
1051
EXPORT_SYMBOL_GPL(trace_current_buffer_lock_reserve);
1052

1053 1054
void trace_current_buffer_unlock_commit(struct ring_buffer *buffer,
					struct ring_buffer_event *event,
1055 1056
					unsigned long flags, int pc)
{
1057
	__trace_buffer_unlock_commit(buffer, event, flags, pc, 1);
1058
}
1059
EXPORT_SYMBOL_GPL(trace_current_buffer_unlock_commit);
1060

1061 1062 1063
void trace_nowake_buffer_unlock_commit(struct ring_buffer *buffer,
				       struct ring_buffer_event *event,
				       unsigned long flags, int pc)
1064
{
1065
	__trace_buffer_unlock_commit(buffer, event, flags, pc, 0);
1066
}
1067
EXPORT_SYMBOL_GPL(trace_nowake_buffer_unlock_commit);
1068

1069 1070
void trace_current_buffer_discard_commit(struct ring_buffer *buffer,
					 struct ring_buffer_event *event)
1071
{
1072
	ring_buffer_discard_commit(buffer, event);
1073
}
1074
EXPORT_SYMBOL_GPL(trace_current_buffer_discard_commit);
1075

I
Ingo Molnar 已提交
1076
void
1077
trace_function(struct trace_array *tr,
1078 1079
	       unsigned long ip, unsigned long parent_ip, unsigned long flags,
	       int pc)
1080
{
1081
	struct ftrace_event_call *call = &event_function;
1082
	struct ring_buffer *buffer = tr->buffer;
1083
	struct ring_buffer_event *event;
1084
	struct ftrace_entry *entry;
1085

1086
	/* If we are reading the ring buffer, don't trace */
1087
	if (unlikely(__this_cpu_read(per_cpu_var(ftrace_cpu_disabled))))
1088 1089
		return;

1090
	event = trace_buffer_lock_reserve(buffer, TRACE_FN, sizeof(*entry),
1091
					  flags, pc);
1092 1093 1094
	if (!event)
		return;
	entry	= ring_buffer_event_data(event);
1095 1096
	entry->ip			= ip;
	entry->parent_ip		= parent_ip;
1097

1098 1099
	if (!filter_check_discard(call, entry, buffer, event))
		ring_buffer_unlock_commit(buffer, event);
1100 1101
}

I
Ingo Molnar 已提交
1102
void
I
Ingo Molnar 已提交
1103
ftrace(struct trace_array *tr, struct trace_array_cpu *data,
1104 1105
       unsigned long ip, unsigned long parent_ip, unsigned long flags,
       int pc)
I
Ingo Molnar 已提交
1106 1107
{
	if (likely(!atomic_read(&data->disabled)))
1108
		trace_function(tr, ip, parent_ip, flags, pc);
I
Ingo Molnar 已提交
1109 1110
}

1111
#ifdef CONFIG_STACKTRACE
1112
static void __ftrace_trace_stack(struct ring_buffer *buffer,
1113 1114
				 unsigned long flags,
				 int skip, int pc)
I
Ingo Molnar 已提交
1115
{
1116
	struct ftrace_event_call *call = &event_kernel_stack;
1117
	struct ring_buffer_event *event;
1118
	struct stack_entry *entry;
I
Ingo Molnar 已提交
1119 1120
	struct stack_trace trace;

1121
	event = trace_buffer_lock_reserve(buffer, TRACE_STACK,
1122
					  sizeof(*entry), flags, pc);
1123 1124 1125
	if (!event)
		return;
	entry	= ring_buffer_event_data(event);
1126
	memset(&entry->caller, 0, sizeof(entry->caller));
I
Ingo Molnar 已提交
1127 1128 1129 1130

	trace.nr_entries	= 0;
	trace.max_entries	= FTRACE_STACK_ENTRIES;
	trace.skip		= skip;
1131
	trace.entries		= entry->caller;
I
Ingo Molnar 已提交
1132 1133

	save_stack_trace(&trace);
1134 1135
	if (!filter_check_discard(call, entry, buffer, event))
		ring_buffer_unlock_commit(buffer, event);
I
Ingo Molnar 已提交
1136 1137
}

1138 1139
void ftrace_trace_stack(struct ring_buffer *buffer, unsigned long flags,
			int skip, int pc)
1140 1141 1142 1143
{
	if (!(trace_flags & TRACE_ITER_STACKTRACE))
		return;

1144
	__ftrace_trace_stack(buffer, flags, skip, pc);
1145 1146
}

1147 1148
void __trace_stack(struct trace_array *tr, unsigned long flags, int skip,
		   int pc)
1149
{
1150
	__ftrace_trace_stack(tr->buffer, flags, skip, pc);
1151 1152
}

S
Steven Rostedt 已提交
1153 1154 1155 1156 1157 1158 1159 1160
/**
 * trace_dump_stack - record a stack back trace in the trace buffer
 */
void trace_dump_stack(void)
{
	unsigned long flags;

	if (tracing_disabled || tracing_selftest_running)
1161
		return;
S
Steven Rostedt 已提交
1162 1163 1164 1165 1166 1167 1168

	local_save_flags(flags);

	/* skipping 3 traces, seems to get us at the caller of this function */
	__ftrace_trace_stack(global_trace.buffer, flags, 3, preempt_count());
}

1169 1170
void
ftrace_trace_userstack(struct ring_buffer *buffer, unsigned long flags, int pc)
1171
{
1172
	struct ftrace_event_call *call = &event_user_stack;
1173
	struct ring_buffer_event *event;
1174 1175 1176 1177 1178 1179
	struct userstack_entry *entry;
	struct stack_trace trace;

	if (!(trace_flags & TRACE_ITER_USERSTACKTRACE))
		return;

1180
	event = trace_buffer_lock_reserve(buffer, TRACE_USER_STACK,
1181
					  sizeof(*entry), flags, pc);
1182 1183 1184 1185
	if (!event)
		return;
	entry	= ring_buffer_event_data(event);

1186
	entry->tgid		= current->tgid;
1187 1188 1189 1190 1191 1192 1193 1194
	memset(&entry->caller, 0, sizeof(entry->caller));

	trace.nr_entries	= 0;
	trace.max_entries	= FTRACE_STACK_ENTRIES;
	trace.skip		= 0;
	trace.entries		= entry->caller;

	save_stack_trace_user(&trace);
1195 1196
	if (!filter_check_discard(call, entry, buffer, event))
		ring_buffer_unlock_commit(buffer, event);
1197 1198
}

1199 1200
#ifdef UNUSED
static void __trace_userstack(struct trace_array *tr, unsigned long flags)
1201
{
1202
	ftrace_trace_userstack(tr, flags, preempt_count());
1203
}
1204
#endif /* UNUSED */
1205

1206 1207
#endif /* CONFIG_STACKTRACE */

1208
static void
1209
ftrace_trace_special(void *__tr,
1210 1211
		     unsigned long arg1, unsigned long arg2, unsigned long arg3,
		     int pc)
I
Ingo Molnar 已提交
1212
{
1213
	struct ftrace_event_call *call = &event_special;
1214
	struct ring_buffer_event *event;
I
Ingo Molnar 已提交
1215
	struct trace_array *tr = __tr;
1216
	struct ring_buffer *buffer = tr->buffer;
1217
	struct special_entry *entry;
I
Ingo Molnar 已提交
1218

1219
	event = trace_buffer_lock_reserve(buffer, TRACE_SPECIAL,
1220
					  sizeof(*entry), 0, pc);
1221 1222 1223
	if (!event)
		return;
	entry	= ring_buffer_event_data(event);
1224 1225 1226
	entry->arg1			= arg1;
	entry->arg2			= arg2;
	entry->arg3			= arg3;
1227 1228 1229

	if (!filter_check_discard(call, entry, buffer, event))
		trace_buffer_unlock_commit(buffer, event, 0, pc);
I
Ingo Molnar 已提交
1230 1231
}

1232 1233 1234 1235
void
__trace_special(void *__tr, void *__data,
		unsigned long arg1, unsigned long arg2, unsigned long arg3)
{
1236
	ftrace_trace_special(__tr, arg1, arg2, arg3, preempt_count());
1237 1238
}

1239 1240 1241 1242 1243
void
ftrace_special(unsigned long arg1, unsigned long arg2, unsigned long arg3)
{
	struct trace_array *tr = &global_trace;
	struct trace_array_cpu *data;
1244
	unsigned long flags;
1245
	int cpu;
1246
	int pc;
1247

S
Steven Rostedt 已提交
1248
	if (tracing_disabled)
1249 1250
		return;

1251
	pc = preempt_count();
1252
	local_irq_save(flags);
1253 1254 1255
	cpu = raw_smp_processor_id();
	data = tr->data[cpu];

1256
	if (likely(atomic_inc_return(&data->disabled) == 1))
1257
		ftrace_trace_special(tr, arg1, arg2, arg3, pc);
1258

1259 1260
	atomic_dec(&data->disabled);
	local_irq_restore(flags);
1261 1262
}

1263
/**
1264
 * trace_vbprintk - write binary msg to tracing buffer
1265 1266
 *
 */
1267
int trace_vbprintk(unsigned long ip, const char *fmt, va_list args)
1268
{
1269
	static arch_spinlock_t trace_buf_lock =
1270
		(arch_spinlock_t)__ARCH_SPIN_LOCK_UNLOCKED;
1271 1272
	static u32 trace_buf[TRACE_BUF_SIZE];

1273
	struct ftrace_event_call *call = &event_bprint;
1274
	struct ring_buffer_event *event;
1275
	struct ring_buffer *buffer;
1276 1277
	struct trace_array *tr = &global_trace;
	struct trace_array_cpu *data;
1278
	struct bprint_entry *entry;
1279
	unsigned long flags;
1280
	int disable;
1281 1282 1283 1284 1285 1286 1287 1288 1289 1290 1291 1292 1293 1294
	int resched;
	int cpu, len = 0, size, pc;

	if (unlikely(tracing_selftest_running || tracing_disabled))
		return 0;

	/* Don't pollute graph traces with trace_vprintk internals */
	pause_graph_tracing();

	pc = preempt_count();
	resched = ftrace_preempt_disable();
	cpu = raw_smp_processor_id();
	data = tr->data[cpu];

1295 1296
	disable = atomic_inc_return(&data->disabled);
	if (unlikely(disable != 1))
1297 1298
		goto out;

1299 1300
	/* Lockdep uses trace_printk for lock tracing */
	local_irq_save(flags);
1301
	arch_spin_lock(&trace_buf_lock);
1302 1303 1304 1305 1306 1307
	len = vbin_printf(trace_buf, TRACE_BUF_SIZE, fmt, args);

	if (len > TRACE_BUF_SIZE || len < 0)
		goto out_unlock;

	size = sizeof(*entry) + sizeof(u32) * len;
1308 1309 1310
	buffer = tr->buffer;
	event = trace_buffer_lock_reserve(buffer, TRACE_BPRINT, size,
					  flags, pc);
1311 1312 1313 1314 1315 1316 1317
	if (!event)
		goto out_unlock;
	entry = ring_buffer_event_data(event);
	entry->ip			= ip;
	entry->fmt			= fmt;

	memcpy(entry->buf, trace_buf, sizeof(u32) * len);
1318 1319
	if (!filter_check_discard(call, entry, buffer, event))
		ring_buffer_unlock_commit(buffer, event);
1320 1321

out_unlock:
1322
	arch_spin_unlock(&trace_buf_lock);
1323
	local_irq_restore(flags);
1324 1325

out:
1326
	atomic_dec_return(&data->disabled);
1327 1328 1329 1330 1331
	ftrace_preempt_enable(resched);
	unpause_graph_tracing();

	return len;
}
1332 1333
EXPORT_SYMBOL_GPL(trace_vbprintk);

1334 1335 1336 1337 1338 1339 1340 1341 1342 1343 1344 1345 1346 1347 1348 1349 1350
int trace_array_printk(struct trace_array *tr,
		       unsigned long ip, const char *fmt, ...)
{
	int ret;
	va_list ap;

	if (!(trace_flags & TRACE_ITER_PRINTK))
		return 0;

	va_start(ap, fmt);
	ret = trace_array_vprintk(tr, ip, fmt, ap);
	va_end(ap);
	return ret;
}

int trace_array_vprintk(struct trace_array *tr,
			unsigned long ip, const char *fmt, va_list args)
1351
{
1352
	static arch_spinlock_t trace_buf_lock = __ARCH_SPIN_LOCK_UNLOCKED;
1353 1354
	static char trace_buf[TRACE_BUF_SIZE];

1355
	struct ftrace_event_call *call = &event_print;
1356
	struct ring_buffer_event *event;
1357
	struct ring_buffer *buffer;
1358 1359 1360 1361
	struct trace_array_cpu *data;
	int cpu, len = 0, size, pc;
	struct print_entry *entry;
	unsigned long irq_flags;
1362
	int disable;
1363 1364 1365 1366 1367 1368 1369 1370 1371

	if (tracing_disabled || tracing_selftest_running)
		return 0;

	pc = preempt_count();
	preempt_disable_notrace();
	cpu = raw_smp_processor_id();
	data = tr->data[cpu];

1372 1373
	disable = atomic_inc_return(&data->disabled);
	if (unlikely(disable != 1))
1374 1375 1376 1377
		goto out;

	pause_graph_tracing();
	raw_local_irq_save(irq_flags);
1378
	arch_spin_lock(&trace_buf_lock);
1379
	len = vsnprintf(trace_buf, TRACE_BUF_SIZE, fmt, args);
1380 1381

	size = sizeof(*entry) + len + 1;
1382 1383 1384
	buffer = tr->buffer;
	event = trace_buffer_lock_reserve(buffer, TRACE_PRINT, size,
					  irq_flags, pc);
1385 1386 1387
	if (!event)
		goto out_unlock;
	entry = ring_buffer_event_data(event);
C
Carsten Emde 已提交
1388
	entry->ip = ip;
1389 1390

	memcpy(&entry->buf, trace_buf, len);
C
Carsten Emde 已提交
1391
	entry->buf[len] = '\0';
1392 1393
	if (!filter_check_discard(call, entry, buffer, event))
		ring_buffer_unlock_commit(buffer, event);
1394 1395

 out_unlock:
1396
	arch_spin_unlock(&trace_buf_lock);
1397 1398 1399
	raw_local_irq_restore(irq_flags);
	unpause_graph_tracing();
 out:
1400
	atomic_dec_return(&data->disabled);
1401 1402 1403 1404
	preempt_enable_notrace();

	return len;
}
1405 1406 1407

int trace_vprintk(unsigned long ip, const char *fmt, va_list args)
{
S
Steven Rostedt 已提交
1408
	return trace_array_vprintk(&global_trace, ip, fmt, args);
1409
}
1410 1411
EXPORT_SYMBOL_GPL(trace_vprintk);

1412 1413
enum trace_file_type {
	TRACE_FILE_LAT_FMT	= 1,
1414
	TRACE_FILE_ANNOTATE	= 2,
1415 1416
};

1417
static void trace_iterator_increment(struct trace_iterator *iter)
S
Steven Rostedt 已提交
1418
{
1419 1420 1421
	/* Don't allow ftrace to trace into the ring buffers */
	ftrace_disable_cpu();

S
Steven Rostedt 已提交
1422
	iter->idx++;
1423 1424 1425 1426
	if (iter->buffer_iter[iter->cpu])
		ring_buffer_read(iter->buffer_iter[iter->cpu], NULL);

	ftrace_enable_cpu();
S
Steven Rostedt 已提交
1427 1428
}

I
Ingo Molnar 已提交
1429
static struct trace_entry *
1430
peek_next_entry(struct trace_iterator *iter, int cpu, u64 *ts)
1431
{
1432 1433
	struct ring_buffer_event *event;
	struct ring_buffer_iter *buf_iter = iter->buffer_iter[cpu];
1434

1435 1436 1437 1438 1439 1440 1441 1442 1443 1444
	/* Don't allow ftrace to trace into the ring buffers */
	ftrace_disable_cpu();

	if (buf_iter)
		event = ring_buffer_iter_peek(buf_iter, ts);
	else
		event = ring_buffer_peek(iter->tr->buffer, cpu, ts);

	ftrace_enable_cpu();

1445
	return event ? ring_buffer_event_data(event) : NULL;
1446
}
1447

1448
static struct trace_entry *
1449
__find_next_entry(struct trace_iterator *iter, int *ent_cpu, u64 *ent_ts)
1450
{
1451
	struct ring_buffer *buffer = iter->tr->buffer;
1452
	struct trace_entry *ent, *next = NULL;
1453
	int cpu_file = iter->cpu_file;
1454
	u64 next_ts = 0, ts;
1455 1456 1457
	int next_cpu = -1;
	int cpu;

1458 1459 1460 1461 1462 1463 1464 1465 1466 1467 1468 1469 1470 1471
	/*
	 * If we are in a per_cpu trace file, don't bother by iterating over
	 * all cpu and peek directly.
	 */
	if (cpu_file > TRACE_PIPE_ALL_CPU) {
		if (ring_buffer_empty_cpu(buffer, cpu_file))
			return NULL;
		ent = peek_next_entry(iter, cpu_file, ent_ts);
		if (ent_cpu)
			*ent_cpu = cpu_file;

		return ent;
	}

1472
	for_each_tracing_cpu(cpu) {
1473

1474 1475
		if (ring_buffer_empty_cpu(buffer, cpu))
			continue;
1476

1477
		ent = peek_next_entry(iter, cpu, &ts);
1478

I
Ingo Molnar 已提交
1479 1480 1481
		/*
		 * Pick the entry with the smallest timestamp:
		 */
1482
		if (ent && (!next || ts < next_ts)) {
1483 1484
			next = ent;
			next_cpu = cpu;
1485
			next_ts = ts;
1486 1487 1488 1489 1490 1491
		}
	}

	if (ent_cpu)
		*ent_cpu = next_cpu;

1492 1493 1494
	if (ent_ts)
		*ent_ts = next_ts;

1495 1496 1497
	return next;
}

1498
/* Find the next real entry, without updating the iterator itself */
1499 1500
struct trace_entry *trace_find_next_entry(struct trace_iterator *iter,
					  int *ent_cpu, u64 *ent_ts)
1501
{
1502
	return __find_next_entry(iter, ent_cpu, ent_ts);
1503 1504 1505 1506 1507
}

/* Find the next real entry, and increment the iterator to the next entry */
static void *find_next_entry_inc(struct trace_iterator *iter)
{
1508
	iter->ent = __find_next_entry(iter, &iter->cpu, &iter->ts);
1509

1510
	if (iter->ent)
1511
		trace_iterator_increment(iter);
1512

1513
	return iter->ent ? iter : NULL;
1514
}
1515

I
Ingo Molnar 已提交
1516
static void trace_consume(struct trace_iterator *iter)
1517
{
1518 1519
	/* Don't allow ftrace to trace into the ring buffers */
	ftrace_disable_cpu();
1520
	ring_buffer_consume(iter->tr->buffer, iter->cpu, &iter->ts);
1521
	ftrace_enable_cpu();
1522 1523
}

I
Ingo Molnar 已提交
1524
static void *s_next(struct seq_file *m, void *v, loff_t *pos)
1525 1526 1527
{
	struct trace_iterator *iter = m->private;
	int i = (int)*pos;
I
Ingo Molnar 已提交
1528
	void *ent;
1529

1530 1531
	WARN_ON_ONCE(iter->leftover);

1532 1533 1534 1535 1536 1537 1538 1539 1540 1541 1542 1543 1544 1545 1546 1547 1548 1549 1550
	(*pos)++;

	/* can't go backwards */
	if (iter->idx > i)
		return NULL;

	if (iter->idx < 0)
		ent = find_next_entry_inc(iter);
	else
		ent = iter;

	while (ent && iter->idx < i)
		ent = find_next_entry_inc(iter);

	iter->pos = *pos;

	return ent;
}

1551 1552 1553 1554 1555 1556 1557 1558 1559 1560 1561 1562 1563 1564 1565 1566 1567 1568 1569 1570 1571 1572 1573 1574 1575 1576 1577 1578 1579 1580 1581
static void tracing_iter_reset(struct trace_iterator *iter, int cpu)
{
	struct trace_array *tr = iter->tr;
	struct ring_buffer_event *event;
	struct ring_buffer_iter *buf_iter;
	unsigned long entries = 0;
	u64 ts;

	tr->data[cpu]->skipped_entries = 0;

	if (!iter->buffer_iter[cpu])
		return;

	buf_iter = iter->buffer_iter[cpu];
	ring_buffer_iter_reset(buf_iter);

	/*
	 * We could have the case with the max latency tracers
	 * that a reset never took place on a cpu. This is evident
	 * by the timestamp being before the start of the buffer.
	 */
	while ((event = ring_buffer_iter_peek(buf_iter, &ts))) {
		if (ts >= iter->tr->time_start)
			break;
		entries++;
		ring_buffer_read(buf_iter, NULL);
	}

	tr->data[cpu]->skipped_entries = entries;
}

1582 1583 1584 1585 1586 1587 1588 1589 1590 1591
/*
 * No necessary locking here. The worst thing which can
 * happen is loosing events consumed at the same time
 * by a trace_pipe reader.
 * Other than that, we don't risk to crash the ring buffer
 * because it serializes the readers.
 *
 * The current tracer is copied to avoid a global locking
 * all around.
 */
1592 1593 1594
static void *s_start(struct seq_file *m, loff_t *pos)
{
	struct trace_iterator *iter = m->private;
1595
	static struct tracer *old_tracer;
1596
	int cpu_file = iter->cpu_file;
1597 1598
	void *p = NULL;
	loff_t l = 0;
1599
	int cpu;
1600

1601
	/* copy the tracer to avoid using a global lock all around */
1602
	mutex_lock(&trace_types_lock);
1603 1604 1605
	if (unlikely(old_tracer != current_trace && current_trace)) {
		old_tracer = current_trace;
		*iter->trace = *current_trace;
1606
	}
1607
	mutex_unlock(&trace_types_lock);
1608 1609 1610 1611 1612 1613 1614 1615

	atomic_inc(&trace_record_cmdline_disabled);

	if (*pos != iter->pos) {
		iter->ent = NULL;
		iter->cpu = 0;
		iter->idx = -1;

1616 1617
		ftrace_disable_cpu();

1618 1619
		if (cpu_file == TRACE_PIPE_ALL_CPU) {
			for_each_tracing_cpu(cpu)
1620
				tracing_iter_reset(iter, cpu);
1621
		} else
1622
			tracing_iter_reset(iter, cpu_file);
1623

1624 1625
		ftrace_enable_cpu();

1626 1627 1628 1629
		for (p = iter; p && l < *pos; p = s_next(m, p, &l))
			;

	} else {
1630 1631 1632 1633 1634 1635 1636 1637 1638 1639
		/*
		 * If we overflowed the seq_file before, then we want
		 * to just reuse the trace_seq buffer again.
		 */
		if (iter->leftover)
			p = iter;
		else {
			l = *pos - 1;
			p = s_next(m, p, &l);
		}
1640 1641
	}

1642
	trace_event_read_lock();
1643 1644 1645 1646 1647 1648
	return p;
}

static void s_stop(struct seq_file *m, void *p)
{
	atomic_dec(&trace_record_cmdline_disabled);
1649
	trace_event_read_unlock();
1650 1651
}

I
Ingo Molnar 已提交
1652
static void print_lat_help_header(struct seq_file *m)
1653
{
1654 1655 1656 1657 1658
	seq_puts(m, "#                  _------=> CPU#            \n");
	seq_puts(m, "#                 / _-----=> irqs-off        \n");
	seq_puts(m, "#                | / _----=> need-resched    \n");
	seq_puts(m, "#                || / _---=> hardirq/softirq \n");
	seq_puts(m, "#                ||| / _--=> preempt-depth   \n");
1659 1660 1661 1662
	seq_puts(m, "#                |||| /_--=> lock-depth       \n");
	seq_puts(m, "#                |||||/     delay             \n");
	seq_puts(m, "#  cmd     pid   |||||| time  |   caller      \n");
	seq_puts(m, "#     \\   /      ||||||   \\   |   /           \n");
1663 1664
}

I
Ingo Molnar 已提交
1665
static void print_func_help_header(struct seq_file *m)
1666
{
1667 1668
	seq_puts(m, "#           TASK-PID    CPU#    TIMESTAMP  FUNCTION\n");
	seq_puts(m, "#              | |       |          |         |\n");
1669 1670 1671
}


I
Ingo Molnar 已提交
1672
static void
1673 1674 1675 1676 1677 1678
print_trace_header(struct seq_file *m, struct trace_iterator *iter)
{
	unsigned long sym_flags = (trace_flags & TRACE_ITER_SYM_MASK);
	struct trace_array *tr = iter->tr;
	struct trace_array_cpu *data = tr->data[tr->cpu];
	struct tracer *type = current_trace;
1679 1680 1681
	unsigned long entries = 0;
	unsigned long total = 0;
	unsigned long count;
1682
	const char *name = "preemption";
1683
	int cpu;
1684 1685 1686 1687

	if (type)
		name = type->name;

1688 1689 1690 1691 1692 1693 1694 1695 1696 1697 1698 1699 1700 1701 1702 1703 1704

	for_each_tracing_cpu(cpu) {
		count = ring_buffer_entries_cpu(tr->buffer, cpu);
		/*
		 * If this buffer has skipped entries, then we hold all
		 * entries for the trace and we need to ignore the
		 * ones before the time stamp.
		 */
		if (tr->data[cpu]->skipped_entries) {
			count -= tr->data[cpu]->skipped_entries;
			/* total is the same as the entries */
			total += count;
		} else
			total += count +
				ring_buffer_overrun_cpu(tr->buffer, cpu);
		entries += count;
	}
1705

1706
	seq_printf(m, "# %s latency trace v1.1.5 on %s\n",
1707
		   name, UTS_RELEASE);
1708
	seq_puts(m, "# -----------------------------------"
1709
		 "---------------------------------\n");
1710
	seq_printf(m, "# latency: %lu us, #%lu/%lu, CPU#%d |"
1711
		   " (M:%s VP:%d, KP:%d, SP:%d HP:%d",
S
Steven Rostedt 已提交
1712
		   nsecs_to_usecs(data->saved_latency),
1713
		   entries,
1714
		   total,
1715 1716 1717 1718 1719
		   tr->cpu,
#if defined(CONFIG_PREEMPT_NONE)
		   "server",
#elif defined(CONFIG_PREEMPT_VOLUNTARY)
		   "desktop",
1720
#elif defined(CONFIG_PREEMPT)
1721 1722 1723 1724 1725 1726 1727 1728 1729 1730 1731
		   "preempt",
#else
		   "unknown",
#endif
		   /* These are reserved for later use */
		   0, 0, 0, 0);
#ifdef CONFIG_SMP
	seq_printf(m, " #P:%d)\n", num_online_cpus());
#else
	seq_puts(m, ")\n");
#endif
1732 1733
	seq_puts(m, "#    -----------------\n");
	seq_printf(m, "#    | task: %.16s-%d "
1734 1735 1736
		   "(uid:%d nice:%ld policy:%ld rt_prio:%ld)\n",
		   data->comm, data->pid, data->uid, data->nice,
		   data->policy, data->rt_priority);
1737
	seq_puts(m, "#    -----------------\n");
1738 1739

	if (data->critical_start) {
1740
		seq_puts(m, "#  => started at: ");
S
Steven Rostedt 已提交
1741 1742
		seq_print_ip_sym(&iter->seq, data->critical_start, sym_flags);
		trace_print_seq(m, &iter->seq);
1743
		seq_puts(m, "\n#  => ended at:   ");
S
Steven Rostedt 已提交
1744 1745
		seq_print_ip_sym(&iter->seq, data->critical_end, sym_flags);
		trace_print_seq(m, &iter->seq);
1746
		seq_puts(m, "\n#\n");
1747 1748
	}

1749
	seq_puts(m, "#\n");
1750 1751
}

1752 1753 1754 1755
static void test_cpu_buff_start(struct trace_iterator *iter)
{
	struct trace_seq *s = &iter->seq;

1756 1757 1758 1759 1760 1761
	if (!(trace_flags & TRACE_ITER_ANNOTATE))
		return;

	if (!(iter->iter_flags & TRACE_FILE_ANNOTATE))
		return;

1762
	if (cpumask_test_cpu(iter->cpu, iter->started))
1763 1764
		return;

1765 1766 1767
	if (iter->tr->data[iter->cpu]->skipped_entries)
		return;

1768
	cpumask_set_cpu(iter->cpu, iter->started);
1769 1770 1771 1772 1773

	/* Don't print started cpu buffer for the first entry of the trace */
	if (iter->idx > 1)
		trace_seq_printf(s, "##### CPU %u buffer started ####\n",
				iter->cpu);
1774 1775
}

1776
static enum print_line_t print_trace_fmt(struct trace_iterator *iter)
1777
{
S
Steven Rostedt 已提交
1778
	struct trace_seq *s = &iter->seq;
1779
	unsigned long sym_flags = (trace_flags & TRACE_ITER_SYM_MASK);
I
Ingo Molnar 已提交
1780
	struct trace_entry *entry;
1781
	struct trace_event *event;
1782

I
Ingo Molnar 已提交
1783
	entry = iter->ent;
1784

1785 1786
	test_cpu_buff_start(iter);

1787
	event = ftrace_find_event(entry->type);
1788

1789
	if (trace_flags & TRACE_ITER_CONTEXT_INFO) {
1790 1791 1792 1793 1794 1795 1796
		if (iter->iter_flags & TRACE_FILE_LAT_FMT) {
			if (!trace_print_lat_context(iter))
				goto partial;
		} else {
			if (!trace_print_context(iter))
				goto partial;
		}
1797
	}
1798

1799
	if (event)
1800 1801 1802 1803
		return event->trace(iter, sym_flags);

	if (!trace_seq_printf(s, "Unknown type %d\n", entry->type))
		goto partial;
1804

1805
	return TRACE_TYPE_HANDLED;
1806 1807
partial:
	return TRACE_TYPE_PARTIAL_LINE;
1808 1809
}

1810
static enum print_line_t print_raw_fmt(struct trace_iterator *iter)
I
Ingo Molnar 已提交
1811 1812 1813
{
	struct trace_seq *s = &iter->seq;
	struct trace_entry *entry;
1814
	struct trace_event *event;
I
Ingo Molnar 已提交
1815 1816

	entry = iter->ent;
1817

1818
	if (trace_flags & TRACE_ITER_CONTEXT_INFO) {
1819 1820 1821
		if (!trace_seq_printf(s, "%d %d %llu ",
				      entry->pid, iter->cpu, iter->ts))
			goto partial;
1822
	}
I
Ingo Molnar 已提交
1823

1824
	event = ftrace_find_event(entry->type);
1825
	if (event)
1826 1827 1828 1829
		return event->raw(iter, 0);

	if (!trace_seq_printf(s, "%d ?\n", entry->type))
		goto partial;
1830

1831
	return TRACE_TYPE_HANDLED;
1832 1833
partial:
	return TRACE_TYPE_PARTIAL_LINE;
I
Ingo Molnar 已提交
1834 1835
}

1836
static enum print_line_t print_hex_fmt(struct trace_iterator *iter)
1837 1838 1839 1840
{
	struct trace_seq *s = &iter->seq;
	unsigned char newline = '\n';
	struct trace_entry *entry;
1841
	struct trace_event *event;
1842 1843

	entry = iter->ent;
1844

1845 1846 1847 1848 1849
	if (trace_flags & TRACE_ITER_CONTEXT_INFO) {
		SEQ_PUT_HEX_FIELD_RET(s, entry->pid);
		SEQ_PUT_HEX_FIELD_RET(s, iter->cpu);
		SEQ_PUT_HEX_FIELD_RET(s, iter->ts);
	}
1850

1851
	event = ftrace_find_event(entry->type);
1852
	if (event) {
1853
		enum print_line_t ret = event->hex(iter, 0);
1854 1855 1856
		if (ret != TRACE_TYPE_HANDLED)
			return ret;
	}
S
Steven Rostedt 已提交
1857

1858 1859
	SEQ_PUT_FIELD_RET(s, newline);

1860
	return TRACE_TYPE_HANDLED;
1861 1862
}

1863
static enum print_line_t print_bin_fmt(struct trace_iterator *iter)
I
Ingo Molnar 已提交
1864 1865 1866
{
	struct trace_seq *s = &iter->seq;
	struct trace_entry *entry;
1867
	struct trace_event *event;
I
Ingo Molnar 已提交
1868 1869

	entry = iter->ent;
1870

1871 1872
	if (trace_flags & TRACE_ITER_CONTEXT_INFO) {
		SEQ_PUT_FIELD_RET(s, entry->pid);
1873
		SEQ_PUT_FIELD_RET(s, iter->cpu);
1874 1875
		SEQ_PUT_FIELD_RET(s, iter->ts);
	}
I
Ingo Molnar 已提交
1876

1877
	event = ftrace_find_event(entry->type);
1878
	return event ? event->binary(iter, 0) : TRACE_TYPE_HANDLED;
I
Ingo Molnar 已提交
1879 1880
}

1881 1882 1883 1884
static int trace_empty(struct trace_iterator *iter)
{
	int cpu;

1885 1886 1887 1888 1889 1890 1891 1892 1893 1894 1895 1896 1897
	/* If we are looking at one CPU buffer, only check that one */
	if (iter->cpu_file != TRACE_PIPE_ALL_CPU) {
		cpu = iter->cpu_file;
		if (iter->buffer_iter[cpu]) {
			if (!ring_buffer_iter_empty(iter->buffer_iter[cpu]))
				return 0;
		} else {
			if (!ring_buffer_empty_cpu(iter->tr->buffer, cpu))
				return 0;
		}
		return 1;
	}

1898
	for_each_tracing_cpu(cpu) {
1899 1900 1901 1902 1903 1904 1905
		if (iter->buffer_iter[cpu]) {
			if (!ring_buffer_iter_empty(iter->buffer_iter[cpu]))
				return 0;
		} else {
			if (!ring_buffer_empty_cpu(iter->tr->buffer, cpu))
				return 0;
		}
1906
	}
1907

1908
	return 1;
1909 1910
}

1911
/*  Called with trace_event_read_lock() held. */
1912
static enum print_line_t print_trace_line(struct trace_iterator *iter)
I
Ingo Molnar 已提交
1913
{
1914 1915 1916 1917 1918 1919 1920
	enum print_line_t ret;

	if (iter->trace && iter->trace->print_line) {
		ret = iter->trace->print_line(iter);
		if (ret != TRACE_TYPE_UNHANDLED)
			return ret;
	}
1921

1922 1923 1924
	if (iter->ent->type == TRACE_BPRINT &&
			trace_flags & TRACE_ITER_PRINTK &&
			trace_flags & TRACE_ITER_PRINTK_MSGONLY)
1925
		return trace_print_bprintk_msg_only(iter);
1926

1927 1928 1929
	if (iter->ent->type == TRACE_PRINT &&
			trace_flags & TRACE_ITER_PRINTK &&
			trace_flags & TRACE_ITER_PRINTK_MSGONLY)
1930
		return trace_print_printk_msg_only(iter);
1931

I
Ingo Molnar 已提交
1932 1933 1934
	if (trace_flags & TRACE_ITER_BIN)
		return print_bin_fmt(iter);

1935 1936 1937
	if (trace_flags & TRACE_ITER_HEX)
		return print_hex_fmt(iter);

I
Ingo Molnar 已提交
1938 1939 1940 1941 1942 1943
	if (trace_flags & TRACE_ITER_RAW)
		return print_raw_fmt(iter);

	return print_trace_fmt(iter);
}

1944 1945 1946
static int s_show(struct seq_file *m, void *v)
{
	struct trace_iterator *iter = v;
1947
	int ret;
1948 1949 1950 1951 1952 1953

	if (iter->ent == NULL) {
		if (iter->tr) {
			seq_printf(m, "# tracer: %s\n", iter->trace->name);
			seq_puts(m, "#\n");
		}
1954 1955 1956
		if (iter->trace && iter->trace->print_header)
			iter->trace->print_header(m);
		else if (iter->iter_flags & TRACE_FILE_LAT_FMT) {
1957 1958 1959 1960 1961 1962 1963 1964 1965 1966
			/* print nothing if the buffers are empty */
			if (trace_empty(iter))
				return 0;
			print_trace_header(m, iter);
			if (!(trace_flags & TRACE_ITER_VERBOSE))
				print_lat_help_header(m);
		} else {
			if (!(trace_flags & TRACE_ITER_VERBOSE))
				print_func_help_header(m);
		}
1967 1968 1969 1970 1971 1972 1973 1974 1975 1976
	} else if (iter->leftover) {
		/*
		 * If we filled the seq_file buffer earlier, we
		 * want to just show it now.
		 */
		ret = trace_print_seq(m, &iter->seq);

		/* ret should this time be zero, but you never know */
		iter->leftover = ret;

1977
	} else {
I
Ingo Molnar 已提交
1978
		print_trace_line(iter);
1979 1980 1981 1982 1983 1984 1985 1986 1987
		ret = trace_print_seq(m, &iter->seq);
		/*
		 * If we overflow the seq_file buffer, then it will
		 * ask us for this data again at start up.
		 * Use that instead.
		 *  ret is 0 if seq_file write succeeded.
		 *        -1 otherwise.
		 */
		iter->leftover = ret;
1988 1989 1990 1991 1992
	}

	return 0;
}

J
James Morris 已提交
1993
static const struct seq_operations tracer_seq_ops = {
I
Ingo Molnar 已提交
1994 1995 1996 1997
	.start		= s_start,
	.next		= s_next,
	.stop		= s_stop,
	.show		= s_show,
1998 1999
};

I
Ingo Molnar 已提交
2000
static struct trace_iterator *
2001
__tracing_open(struct inode *inode, struct file *file)
2002
{
2003
	long cpu_file = (long) inode->i_private;
2004
	void *fail_ret = ERR_PTR(-ENOMEM);
2005
	struct trace_iterator *iter;
2006
	struct seq_file *m;
2007
	int cpu, ret;
2008

2009 2010
	if (tracing_disabled)
		return ERR_PTR(-ENODEV);
S
Steven Rostedt 已提交
2011

2012
	iter = kzalloc(sizeof(*iter), GFP_KERNEL);
2013 2014
	if (!iter)
		return ERR_PTR(-ENOMEM);
2015

2016 2017 2018 2019
	/*
	 * We make a copy of the current tracer to avoid concurrent
	 * changes on it while we are reading.
	 */
2020
	mutex_lock(&trace_types_lock);
2021
	iter->trace = kzalloc(sizeof(*iter->trace), GFP_KERNEL);
2022
	if (!iter->trace)
2023
		goto fail;
2024

2025 2026 2027
	if (current_trace)
		*iter->trace = *current_trace;

2028
	if (!zalloc_cpumask_var(&iter->started, GFP_KERNEL))
2029 2030
		goto fail;

2031 2032 2033
	if (current_trace && current_trace->print_max)
		iter->tr = &max_tr;
	else
2034
		iter->tr = &global_trace;
2035
	iter->pos = -1;
2036
	mutex_init(&iter->mutex);
2037
	iter->cpu_file = cpu_file;
2038

2039 2040
	/* Notify the tracer early; before we stop tracing. */
	if (iter->trace && iter->trace->open)
2041
		iter->trace->open(iter);
2042

2043 2044 2045 2046
	/* Annotate start of buffers if we had overruns */
	if (ring_buffer_overruns(iter->tr->buffer))
		iter->iter_flags |= TRACE_FILE_ANNOTATE;

2047 2048 2049
	/* stop the trace while dumping */
	tracing_stop();

2050 2051
	if (iter->cpu_file == TRACE_PIPE_ALL_CPU) {
		for_each_tracing_cpu(cpu) {
2052

2053 2054
			iter->buffer_iter[cpu] =
				ring_buffer_read_start(iter->tr->buffer, cpu);
2055
			tracing_iter_reset(iter, cpu);
2056 2057 2058
		}
	} else {
		cpu = iter->cpu_file;
2059
		iter->buffer_iter[cpu] =
2060
				ring_buffer_read_start(iter->tr->buffer, cpu);
2061
		tracing_iter_reset(iter, cpu);
2062 2063
	}

2064 2065 2066
	ret = seq_open(file, &tracer_seq_ops);
	if (ret < 0) {
		fail_ret = ERR_PTR(ret);
2067
		goto fail_buffer;
2068
	}
2069

2070 2071
	m = file->private_data;
	m->private = iter;
2072 2073 2074 2075

	mutex_unlock(&trace_types_lock);

	return iter;
2076 2077 2078 2079 2080 2081

 fail_buffer:
	for_each_tracing_cpu(cpu) {
		if (iter->buffer_iter[cpu])
			ring_buffer_read_finish(iter->buffer_iter[cpu]);
	}
2082
	free_cpumask_var(iter->started);
2083
	tracing_start();
2084
 fail:
2085
	mutex_unlock(&trace_types_lock);
2086
	kfree(iter->trace);
2087
	kfree(iter);
2088

2089
	return fail_ret;
2090 2091 2092 2093
}

int tracing_open_generic(struct inode *inode, struct file *filp)
{
S
Steven Rostedt 已提交
2094 2095 2096
	if (tracing_disabled)
		return -ENODEV;

2097 2098 2099 2100
	filp->private_data = inode->i_private;
	return 0;
}

2101
static int tracing_release(struct inode *inode, struct file *file)
2102 2103
{
	struct seq_file *m = (struct seq_file *)file->private_data;
2104
	struct trace_iterator *iter;
2105
	int cpu;
2106

2107 2108 2109 2110 2111
	if (!(file->f_mode & FMODE_READ))
		return 0;

	iter = m->private;

2112
	mutex_lock(&trace_types_lock);
2113 2114 2115 2116 2117
	for_each_tracing_cpu(cpu) {
		if (iter->buffer_iter[cpu])
			ring_buffer_read_finish(iter->buffer_iter[cpu]);
	}

2118 2119 2120 2121
	if (iter->trace && iter->trace->close)
		iter->trace->close(iter);

	/* reenable tracing if it was previously enabled */
2122
	tracing_start();
2123 2124 2125
	mutex_unlock(&trace_types_lock);

	seq_release(inode, file);
2126
	mutex_destroy(&iter->mutex);
2127
	free_cpumask_var(iter->started);
2128
	kfree(iter->trace);
2129 2130 2131 2132 2133 2134
	kfree(iter);
	return 0;
}

static int tracing_open(struct inode *inode, struct file *file)
{
2135 2136
	struct trace_iterator *iter;
	int ret = 0;
2137

2138 2139
	/* If this file was open for write, then erase contents */
	if ((file->f_mode & FMODE_WRITE) &&
2140
	    (file->f_flags & O_TRUNC)) {
2141
		long cpu = (long) inode->i_private;
2142

2143 2144 2145 2146 2147
		if (cpu == TRACE_PIPE_ALL_CPU)
			tracing_reset_online_cpus(&global_trace);
		else
			tracing_reset(&global_trace, cpu);
	}
2148

2149 2150 2151 2152 2153 2154 2155
	if (file->f_mode & FMODE_READ) {
		iter = __tracing_open(inode, file);
		if (IS_ERR(iter))
			ret = PTR_ERR(iter);
		else if (trace_flags & TRACE_ITER_LATENCY_FMT)
			iter->iter_flags |= TRACE_FILE_LAT_FMT;
	}
2156 2157 2158
	return ret;
}

I
Ingo Molnar 已提交
2159
static void *
2160 2161
t_next(struct seq_file *m, void *v, loff_t *pos)
{
L
Li Zefan 已提交
2162
	struct tracer *t = v;
2163 2164 2165 2166 2167 2168 2169 2170 2171 2172 2173

	(*pos)++;

	if (t)
		t = t->next;

	return t;
}

static void *t_start(struct seq_file *m, loff_t *pos)
{
L
Li Zefan 已提交
2174
	struct tracer *t;
2175 2176 2177
	loff_t l = 0;

	mutex_lock(&trace_types_lock);
L
Li Zefan 已提交
2178
	for (t = trace_types; t && l < *pos; t = t_next(m, t, &l))
2179 2180 2181 2182 2183 2184 2185 2186 2187 2188 2189 2190 2191 2192 2193 2194 2195 2196 2197 2198 2199 2200 2201 2202 2203 2204
		;

	return t;
}

static void t_stop(struct seq_file *m, void *p)
{
	mutex_unlock(&trace_types_lock);
}

static int t_show(struct seq_file *m, void *v)
{
	struct tracer *t = v;

	if (!t)
		return 0;

	seq_printf(m, "%s", t->name);
	if (t->next)
		seq_putc(m, ' ');
	else
		seq_putc(m, '\n');

	return 0;
}

J
James Morris 已提交
2205
static const struct seq_operations show_traces_seq_ops = {
I
Ingo Molnar 已提交
2206 2207 2208 2209
	.start		= t_start,
	.next		= t_next,
	.stop		= t_stop,
	.show		= t_show,
2210 2211 2212 2213
};

static int show_traces_open(struct inode *inode, struct file *file)
{
S
Steven Rostedt 已提交
2214 2215 2216
	if (tracing_disabled)
		return -ENODEV;

L
Li Zefan 已提交
2217
	return seq_open(file, &show_traces_seq_ops);
2218 2219
}

2220 2221 2222 2223 2224 2225 2226
static ssize_t
tracing_write_stub(struct file *filp, const char __user *ubuf,
		   size_t count, loff_t *ppos)
{
	return count;
}

2227
static const struct file_operations tracing_fops = {
I
Ingo Molnar 已提交
2228 2229
	.open		= tracing_open,
	.read		= seq_read,
2230
	.write		= tracing_write_stub,
I
Ingo Molnar 已提交
2231 2232
	.llseek		= seq_lseek,
	.release	= tracing_release,
2233 2234
};

2235
static const struct file_operations show_traces_fops = {
I
Ingo Molnar 已提交
2236 2237 2238 2239 2240
	.open		= show_traces_open,
	.read		= seq_read,
	.release	= seq_release,
};

2241 2242 2243
/*
 * Only trace on a CPU if the bitmask is set:
 */
2244
static cpumask_var_t tracing_cpumask;
2245 2246 2247 2248 2249 2250 2251 2252 2253 2254 2255 2256 2257

/*
 * The tracer itself will not take this lock, but still we want
 * to provide a consistent cpumask to user-space:
 */
static DEFINE_MUTEX(tracing_cpumask_update_lock);

/*
 * Temporary storage for the character representation of the
 * CPU bitmask (and one more byte for the newline):
 */
static char mask_str[NR_CPUS + 1];

I
Ingo Molnar 已提交
2258 2259 2260 2261
static ssize_t
tracing_cpumask_read(struct file *filp, char __user *ubuf,
		     size_t count, loff_t *ppos)
{
2262
	int len;
I
Ingo Molnar 已提交
2263 2264

	mutex_lock(&tracing_cpumask_update_lock);
2265

2266
	len = cpumask_scnprintf(mask_str, count, tracing_cpumask);
2267 2268 2269 2270 2271 2272 2273 2274
	if (count - len < 2) {
		count = -EINVAL;
		goto out_err;
	}
	len += sprintf(mask_str + len, "\n");
	count = simple_read_from_buffer(ubuf, count, ppos, mask_str, NR_CPUS+1);

out_err:
I
Ingo Molnar 已提交
2275 2276 2277 2278 2279 2280 2281 2282 2283
	mutex_unlock(&tracing_cpumask_update_lock);

	return count;
}

static ssize_t
tracing_cpumask_write(struct file *filp, const char __user *ubuf,
		      size_t count, loff_t *ppos)
{
2284
	int err, cpu;
2285 2286 2287 2288
	cpumask_var_t tracing_cpumask_new;

	if (!alloc_cpumask_var(&tracing_cpumask_new, GFP_KERNEL))
		return -ENOMEM;
I
Ingo Molnar 已提交
2289

2290
	err = cpumask_parse_user(ubuf, count, tracing_cpumask_new);
I
Ingo Molnar 已提交
2291
	if (err)
2292 2293
		goto err_unlock;

2294 2295
	mutex_lock(&tracing_cpumask_update_lock);

2296
	local_irq_disable();
2297
	arch_spin_lock(&ftrace_max_lock);
2298
	for_each_tracing_cpu(cpu) {
2299 2300 2301 2302
		/*
		 * Increase/decrease the disabled counter if we are
		 * about to flip a bit in the cpumask:
		 */
2303 2304
		if (cpumask_test_cpu(cpu, tracing_cpumask) &&
				!cpumask_test_cpu(cpu, tracing_cpumask_new)) {
2305 2306
			atomic_inc(&global_trace.data[cpu]->disabled);
		}
2307 2308
		if (!cpumask_test_cpu(cpu, tracing_cpumask) &&
				cpumask_test_cpu(cpu, tracing_cpumask_new)) {
2309 2310 2311
			atomic_dec(&global_trace.data[cpu]->disabled);
		}
	}
2312
	arch_spin_unlock(&ftrace_max_lock);
2313
	local_irq_enable();
2314

2315
	cpumask_copy(tracing_cpumask, tracing_cpumask_new);
2316 2317

	mutex_unlock(&tracing_cpumask_update_lock);
2318
	free_cpumask_var(tracing_cpumask_new);
I
Ingo Molnar 已提交
2319 2320

	return count;
2321 2322

err_unlock:
2323
	free_cpumask_var(tracing_cpumask_new);
2324 2325

	return err;
I
Ingo Molnar 已提交
2326 2327
}

2328
static const struct file_operations tracing_cpumask_fops = {
I
Ingo Molnar 已提交
2329 2330 2331
	.open		= tracing_open_generic,
	.read		= tracing_cpumask_read,
	.write		= tracing_cpumask_write,
2332 2333
};

L
Li Zefan 已提交
2334
static int tracing_trace_options_show(struct seq_file *m, void *v)
2335
{
2336 2337 2338
	struct tracer_opt *trace_opts;
	u32 tracer_flags;
	int i;
2339

2340 2341 2342 2343
	mutex_lock(&trace_types_lock);
	tracer_flags = current_trace->flags->val;
	trace_opts = current_trace->flags->opts;

2344 2345
	for (i = 0; trace_options[i]; i++) {
		if (trace_flags & (1 << i))
L
Li Zefan 已提交
2346
			seq_printf(m, "%s\n", trace_options[i]);
2347
		else
L
Li Zefan 已提交
2348
			seq_printf(m, "no%s\n", trace_options[i]);
2349 2350
	}

2351 2352
	for (i = 0; trace_opts[i].name; i++) {
		if (tracer_flags & trace_opts[i].bit)
L
Li Zefan 已提交
2353
			seq_printf(m, "%s\n", trace_opts[i].name);
2354
		else
L
Li Zefan 已提交
2355
			seq_printf(m, "no%s\n", trace_opts[i].name);
2356
	}
2357
	mutex_unlock(&trace_types_lock);
2358

L
Li Zefan 已提交
2359
	return 0;
2360 2361
}

L
Li Zefan 已提交
2362 2363 2364 2365 2366
static int __set_tracer_option(struct tracer *trace,
			       struct tracer_flags *tracer_flags,
			       struct tracer_opt *opts, int neg)
{
	int ret;
2367

L
Li Zefan 已提交
2368 2369 2370 2371 2372 2373 2374 2375 2376
	ret = trace->set_flag(tracer_flags->val, opts->bit, !neg);
	if (ret)
		return ret;

	if (neg)
		tracer_flags->val &= ~opts->bit;
	else
		tracer_flags->val |= opts->bit;
	return 0;
2377 2378
}

2379 2380 2381
/* Try to assign a tracer specific option */
static int set_tracer_option(struct tracer *trace, char *cmp, int neg)
{
2382
	struct tracer_flags *tracer_flags = trace->flags;
2383
	struct tracer_opt *opts = NULL;
L
Li Zefan 已提交
2384
	int i;
2385

2386 2387
	for (i = 0; tracer_flags->opts[i].name; i++) {
		opts = &tracer_flags->opts[i];
2388

L
Li Zefan 已提交
2389 2390 2391
		if (strcmp(cmp, opts->name) == 0)
			return __set_tracer_option(trace, trace->flags,
						   opts, neg);
2392 2393
	}

L
Li Zefan 已提交
2394
	return -EINVAL;
2395 2396
}

2397 2398 2399 2400 2401 2402 2403 2404 2405 2406 2407 2408
static void set_tracer_flags(unsigned int mask, int enabled)
{
	/* do nothing if flag is already set */
	if (!!(trace_flags & mask) == !!enabled)
		return;

	if (enabled)
		trace_flags |= mask;
	else
		trace_flags &= ~mask;
}

2409
static ssize_t
2410
tracing_trace_options_write(struct file *filp, const char __user *ubuf,
2411 2412 2413
			size_t cnt, loff_t *ppos)
{
	char buf[64];
L
Li Zefan 已提交
2414
	char *cmp;
2415
	int neg = 0;
2416
	int ret;
2417 2418
	int i;

S
Steven Rostedt 已提交
2419 2420
	if (cnt >= sizeof(buf))
		return -EINVAL;
2421 2422 2423 2424 2425

	if (copy_from_user(&buf, ubuf, cnt))
		return -EFAULT;

	buf[cnt] = 0;
L
Li Zefan 已提交
2426
	cmp = strstrip(buf);
2427

L
Li Zefan 已提交
2428
	if (strncmp(cmp, "no", 2) == 0) {
2429 2430 2431 2432 2433
		neg = 1;
		cmp += 2;
	}

	for (i = 0; trace_options[i]; i++) {
L
Li Zefan 已提交
2434
		if (strcmp(cmp, trace_options[i]) == 0) {
2435
			set_tracer_flags(1 << i, !neg);
2436 2437 2438
			break;
		}
	}
2439 2440 2441

	/* If no option could be set, test the specific tracer options */
	if (!trace_options[i]) {
2442
		mutex_lock(&trace_types_lock);
2443
		ret = set_tracer_option(current_trace, cmp, neg);
2444
		mutex_unlock(&trace_types_lock);
2445 2446 2447
		if (ret)
			return ret;
	}
2448

2449
	*ppos += cnt;
2450 2451 2452 2453

	return cnt;
}

L
Li Zefan 已提交
2454 2455 2456 2457 2458 2459 2460
static int tracing_trace_options_open(struct inode *inode, struct file *file)
{
	if (tracing_disabled)
		return -ENODEV;
	return single_open(file, tracing_trace_options_show, NULL);
}

2461
static const struct file_operations tracing_iter_fops = {
L
Li Zefan 已提交
2462 2463 2464 2465
	.open		= tracing_trace_options_open,
	.read		= seq_read,
	.llseek		= seq_lseek,
	.release	= single_release,
2466
	.write		= tracing_trace_options_write,
2467 2468
};

I
Ingo Molnar 已提交
2469 2470
static const char readme_msg[] =
	"tracing mini-HOWTO:\n\n"
2471 2472
	"# mount -t debugfs nodev /sys/kernel/debug\n\n"
	"# cat /sys/kernel/debug/tracing/available_tracers\n"
2473
	"wakeup preemptirqsoff preemptoff irqsoff function sched_switch nop\n\n"
2474
	"# cat /sys/kernel/debug/tracing/current_tracer\n"
2475
	"nop\n"
2476 2477
	"# echo sched_switch > /sys/kernel/debug/tracing/current_tracer\n"
	"# cat /sys/kernel/debug/tracing/current_tracer\n"
I
Ingo Molnar 已提交
2478
	"sched_switch\n"
2479
	"# cat /sys/kernel/debug/tracing/trace_options\n"
I
Ingo Molnar 已提交
2480
	"noprint-parent nosym-offset nosym-addr noverbose\n"
2481 2482 2483 2484
	"# echo print-parent > /sys/kernel/debug/tracing/trace_options\n"
	"# echo 1 > /sys/kernel/debug/tracing/tracing_enabled\n"
	"# cat /sys/kernel/debug/tracing/trace > /tmp/trace.txt\n"
	"# echo 0 > /sys/kernel/debug/tracing/tracing_enabled\n"
I
Ingo Molnar 已提交
2485 2486 2487 2488 2489 2490 2491 2492 2493 2494
;

static ssize_t
tracing_readme_read(struct file *filp, char __user *ubuf,
		       size_t cnt, loff_t *ppos)
{
	return simple_read_from_buffer(ubuf, cnt, ppos,
					readme_msg, strlen(readme_msg));
}

2495
static const struct file_operations tracing_readme_fops = {
I
Ingo Molnar 已提交
2496 2497
	.open		= tracing_open_generic,
	.read		= tracing_readme_read,
I
Ingo Molnar 已提交
2498 2499
};

2500 2501 2502 2503 2504 2505 2506 2507 2508 2509 2510 2511 2512 2513 2514 2515 2516 2517 2518 2519 2520 2521 2522 2523 2524 2525 2526 2527 2528 2529 2530 2531 2532 2533 2534 2535 2536 2537 2538 2539 2540 2541 2542 2543 2544 2545 2546 2547 2548 2549
static ssize_t
tracing_saved_cmdlines_read(struct file *file, char __user *ubuf,
				size_t cnt, loff_t *ppos)
{
	char *buf_comm;
	char *file_buf;
	char *buf;
	int len = 0;
	int pid;
	int i;

	file_buf = kmalloc(SAVED_CMDLINES*(16+TASK_COMM_LEN), GFP_KERNEL);
	if (!file_buf)
		return -ENOMEM;

	buf_comm = kmalloc(TASK_COMM_LEN, GFP_KERNEL);
	if (!buf_comm) {
		kfree(file_buf);
		return -ENOMEM;
	}

	buf = file_buf;

	for (i = 0; i < SAVED_CMDLINES; i++) {
		int r;

		pid = map_cmdline_to_pid[i];
		if (pid == -1 || pid == NO_CMDLINE_MAP)
			continue;

		trace_find_cmdline(pid, buf_comm);
		r = sprintf(buf, "%d %s\n", pid, buf_comm);
		buf += r;
		len += r;
	}

	len = simple_read_from_buffer(ubuf, cnt, ppos,
				      file_buf, len);

	kfree(file_buf);
	kfree(buf_comm);

	return len;
}

static const struct file_operations tracing_saved_cmdlines_fops = {
    .open       = tracing_open_generic,
    .read       = tracing_saved_cmdlines_read,
};

2550 2551 2552 2553 2554 2555 2556
static ssize_t
tracing_ctrl_read(struct file *filp, char __user *ubuf,
		  size_t cnt, loff_t *ppos)
{
	char buf[64];
	int r;

2557
	r = sprintf(buf, "%u\n", tracer_enabled);
I
Ingo Molnar 已提交
2558
	return simple_read_from_buffer(ubuf, cnt, ppos, buf, r);
2559 2560 2561 2562 2563 2564 2565 2566
}

static ssize_t
tracing_ctrl_write(struct file *filp, const char __user *ubuf,
		   size_t cnt, loff_t *ppos)
{
	struct trace_array *tr = filp->private_data;
	char buf[64];
2567
	unsigned long val;
2568
	int ret;
2569

S
Steven Rostedt 已提交
2570 2571
	if (cnt >= sizeof(buf))
		return -EINVAL;
2572 2573 2574 2575 2576 2577

	if (copy_from_user(&buf, ubuf, cnt))
		return -EFAULT;

	buf[cnt] = 0;

2578 2579 2580
	ret = strict_strtoul(buf, 10, &val);
	if (ret < 0)
		return ret;
2581 2582 2583 2584

	val = !!val;

	mutex_lock(&trace_types_lock);
2585 2586
	if (tracer_enabled ^ val) {
		if (val) {
2587
			tracer_enabled = 1;
2588 2589 2590 2591
			if (current_trace->start)
				current_trace->start(tr);
			tracing_start();
		} else {
2592
			tracer_enabled = 0;
2593 2594 2595 2596
			tracing_stop();
			if (current_trace->stop)
				current_trace->stop(tr);
		}
2597 2598 2599
	}
	mutex_unlock(&trace_types_lock);

2600
	*ppos += cnt;
2601 2602 2603 2604 2605 2606 2607 2608

	return cnt;
}

static ssize_t
tracing_set_trace_read(struct file *filp, char __user *ubuf,
		       size_t cnt, loff_t *ppos)
{
L
Li Zefan 已提交
2609
	char buf[MAX_TRACER_SIZE+2];
2610 2611 2612 2613 2614 2615 2616 2617 2618
	int r;

	mutex_lock(&trace_types_lock);
	if (current_trace)
		r = sprintf(buf, "%s\n", current_trace->name);
	else
		r = sprintf(buf, "\n");
	mutex_unlock(&trace_types_lock);

I
Ingo Molnar 已提交
2619
	return simple_read_from_buffer(ubuf, cnt, ppos, buf, r);
2620 2621
}

2622 2623 2624 2625 2626 2627
int tracer_init(struct tracer *t, struct trace_array *tr)
{
	tracing_reset_online_cpus(tr);
	return t->init(tr);
}

2628 2629 2630 2631 2632 2633
static int tracing_resize_ring_buffer(unsigned long size)
{
	int ret;

	/*
	 * If kernel or user changes the size of the ring buffer
2634 2635
	 * we use the size that was given, and we can forget about
	 * expanding it later.
2636 2637 2638 2639 2640 2641 2642 2643 2644 2645 2646 2647 2648 2649
	 */
	ring_buffer_expanded = 1;

	ret = ring_buffer_resize(global_trace.buffer, size);
	if (ret < 0)
		return ret;

	ret = ring_buffer_resize(max_tr.buffer, size);
	if (ret < 0) {
		int r;

		r = ring_buffer_resize(global_trace.buffer,
				       global_trace.entries);
		if (r < 0) {
2650 2651 2652 2653 2654 2655 2656 2657 2658 2659 2660 2661 2662 2663
			/*
			 * AARGH! We are left with different
			 * size max buffer!!!!
			 * The max buffer is our "snapshot" buffer.
			 * When a tracer needs a snapshot (one of the
			 * latency tracers), it swaps the max buffer
			 * with the saved snap shot. We succeeded to
			 * update the size of the main buffer, but failed to
			 * update the size of the max buffer. But when we tried
			 * to reset the main buffer to the original size, we
			 * failed there too. This is very unlikely to
			 * happen, but if it does, warn and kill all
			 * tracing.
			 */
2664 2665 2666 2667 2668 2669 2670 2671 2672 2673 2674
			WARN_ON(1);
			tracing_disabled = 1;
		}
		return ret;
	}

	global_trace.entries = size;

	return ret;
}

2675 2676 2677 2678 2679 2680 2681 2682 2683 2684 2685 2686 2687 2688
/**
 * tracing_update_buffers - used by tracing facility to expand ring buffers
 *
 * To save on memory when the tracing is never used on a system with it
 * configured in. The ring buffers are set to a minimum size. But once
 * a user starts to use the tracing facility, then they need to grow
 * to their default size.
 *
 * This function is to be called when a tracer is about to be used.
 */
int tracing_update_buffers(void)
{
	int ret = 0;

2689
	mutex_lock(&trace_types_lock);
2690 2691
	if (!ring_buffer_expanded)
		ret = tracing_resize_ring_buffer(trace_buf_size);
2692
	mutex_unlock(&trace_types_lock);
2693 2694 2695 2696

	return ret;
}

2697 2698 2699 2700 2701 2702 2703 2704
struct trace_option_dentry;

static struct trace_option_dentry *
create_trace_option_files(struct tracer *tracer);

static void
destroy_trace_option_files(struct trace_option_dentry *topts);

2705
static int tracing_set_tracer(const char *buf)
2706
{
2707
	static struct trace_option_dentry *topts;
2708 2709
	struct trace_array *tr = &global_trace;
	struct tracer *t;
2710
	int ret = 0;
2711

2712 2713
	mutex_lock(&trace_types_lock);

2714 2715 2716
	if (!ring_buffer_expanded) {
		ret = tracing_resize_ring_buffer(trace_buf_size);
		if (ret < 0)
2717
			goto out;
2718 2719 2720
		ret = 0;
	}

2721 2722 2723 2724
	for (t = trace_types; t; t = t->next) {
		if (strcmp(t->name, buf) == 0)
			break;
	}
2725 2726 2727 2728 2729
	if (!t) {
		ret = -EINVAL;
		goto out;
	}
	if (t == current_trace)
2730 2731
		goto out;

2732
	trace_branch_disable();
2733 2734 2735
	if (current_trace && current_trace->reset)
		current_trace->reset(tr);

2736 2737
	destroy_trace_option_files(topts);

2738
	current_trace = t;
2739 2740 2741

	topts = create_trace_option_files(current_trace);

2742
	if (t->init) {
2743
		ret = tracer_init(t, tr);
2744 2745 2746
		if (ret)
			goto out;
	}
2747

2748
	trace_branch_enable(tr);
2749 2750 2751
 out:
	mutex_unlock(&trace_types_lock);

2752 2753 2754 2755 2756 2757 2758
	return ret;
}

static ssize_t
tracing_set_trace_write(struct file *filp, const char __user *ubuf,
			size_t cnt, loff_t *ppos)
{
L
Li Zefan 已提交
2759
	char buf[MAX_TRACER_SIZE+1];
2760 2761
	int i;
	size_t ret;
2762 2763 2764
	int err;

	ret = cnt;
2765

L
Li Zefan 已提交
2766 2767
	if (cnt > MAX_TRACER_SIZE)
		cnt = MAX_TRACER_SIZE;
2768 2769 2770 2771 2772 2773 2774 2775 2776 2777

	if (copy_from_user(&buf, ubuf, cnt))
		return -EFAULT;

	buf[cnt] = 0;

	/* strip ending whitespace. */
	for (i = cnt - 1; i > 0 && isspace(buf[i]); i--)
		buf[i] = 0;

2778 2779 2780
	err = tracing_set_tracer(buf);
	if (err)
		return err;
2781

2782
	*ppos += ret;
2783

2784
	return ret;
2785 2786 2787 2788 2789 2790 2791 2792 2793 2794
}

static ssize_t
tracing_max_lat_read(struct file *filp, char __user *ubuf,
		     size_t cnt, loff_t *ppos)
{
	unsigned long *ptr = filp->private_data;
	char buf[64];
	int r;

S
Steven Rostedt 已提交
2795
	r = snprintf(buf, sizeof(buf), "%ld\n",
2796
		     *ptr == (unsigned long)-1 ? -1 : nsecs_to_usecs(*ptr));
S
Steven Rostedt 已提交
2797 2798
	if (r > sizeof(buf))
		r = sizeof(buf);
I
Ingo Molnar 已提交
2799
	return simple_read_from_buffer(ubuf, cnt, ppos, buf, r);
2800 2801 2802 2803 2804 2805
}

static ssize_t
tracing_max_lat_write(struct file *filp, const char __user *ubuf,
		      size_t cnt, loff_t *ppos)
{
2806
	unsigned long *ptr = filp->private_data;
2807
	char buf[64];
2808
	unsigned long val;
2809
	int ret;
2810

S
Steven Rostedt 已提交
2811 2812
	if (cnt >= sizeof(buf))
		return -EINVAL;
2813 2814 2815 2816 2817 2818

	if (copy_from_user(&buf, ubuf, cnt))
		return -EFAULT;

	buf[cnt] = 0;

2819 2820 2821
	ret = strict_strtoul(buf, 10, &val);
	if (ret < 0)
		return ret;
2822 2823 2824 2825 2826 2827

	*ptr = val * 1000;

	return cnt;
}

2828 2829
static int tracing_open_pipe(struct inode *inode, struct file *filp)
{
2830
	long cpu_file = (long) inode->i_private;
2831
	struct trace_iterator *iter;
2832
	int ret = 0;
2833 2834 2835 2836

	if (tracing_disabled)
		return -ENODEV;

2837 2838 2839 2840 2841 2842 2843 2844 2845 2846 2847 2848 2849 2850 2851 2852
	mutex_lock(&trace_types_lock);

	/* We only allow one reader per cpu */
	if (cpu_file == TRACE_PIPE_ALL_CPU) {
		if (!cpumask_empty(tracing_reader_cpumask)) {
			ret = -EBUSY;
			goto out;
		}
		cpumask_setall(tracing_reader_cpumask);
	} else {
		if (!cpumask_test_cpu(cpu_file, tracing_reader_cpumask))
			cpumask_set_cpu(cpu_file, tracing_reader_cpumask);
		else {
			ret = -EBUSY;
			goto out;
		}
2853 2854 2855 2856
	}

	/* create a buffer to store the information to pass to userspace */
	iter = kzalloc(sizeof(*iter), GFP_KERNEL);
2857 2858 2859 2860
	if (!iter) {
		ret = -ENOMEM;
		goto out;
	}
2861

2862 2863 2864 2865 2866 2867 2868 2869 2870 2871 2872 2873
	/*
	 * We make a copy of the current tracer to avoid concurrent
	 * changes on it while we are reading.
	 */
	iter->trace = kmalloc(sizeof(*iter->trace), GFP_KERNEL);
	if (!iter->trace) {
		ret = -ENOMEM;
		goto fail;
	}
	if (current_trace)
		*iter->trace = *current_trace;

2874
	if (!alloc_cpumask_var(&iter->started, GFP_KERNEL)) {
2875
		ret = -ENOMEM;
2876
		goto fail;
2877 2878
	}

2879
	/* trace pipe does not show start of buffer */
2880
	cpumask_setall(iter->started);
2881

2882 2883 2884
	if (trace_flags & TRACE_ITER_LATENCY_FMT)
		iter->iter_flags |= TRACE_FILE_LAT_FMT;

2885
	iter->cpu_file = cpu_file;
2886
	iter->tr = &global_trace;
2887
	mutex_init(&iter->mutex);
2888 2889
	filp->private_data = iter;

2890 2891 2892
	if (iter->trace->pipe_open)
		iter->trace->pipe_open(iter);

2893 2894 2895
out:
	mutex_unlock(&trace_types_lock);
	return ret;
2896 2897 2898 2899 2900 2901

fail:
	kfree(iter->trace);
	kfree(iter);
	mutex_unlock(&trace_types_lock);
	return ret;
2902 2903 2904 2905 2906 2907
}

static int tracing_release_pipe(struct inode *inode, struct file *file)
{
	struct trace_iterator *iter = file->private_data;

2908 2909 2910 2911 2912 2913 2914
	mutex_lock(&trace_types_lock);

	if (iter->cpu_file == TRACE_PIPE_ALL_CPU)
		cpumask_clear(tracing_reader_cpumask);
	else
		cpumask_clear_cpu(iter->cpu_file, tracing_reader_cpumask);

S
Steven Rostedt 已提交
2915

2916
	if (iter->trace->pipe_close)
S
Steven Rostedt 已提交
2917 2918
		iter->trace->pipe_close(iter);

2919 2920
	mutex_unlock(&trace_types_lock);

2921
	free_cpumask_var(iter->started);
2922 2923
	mutex_destroy(&iter->mutex);
	kfree(iter->trace);
2924 2925 2926 2927 2928
	kfree(iter);

	return 0;
}

2929 2930 2931 2932 2933 2934 2935 2936 2937 2938
static unsigned int
tracing_poll_pipe(struct file *filp, poll_table *poll_table)
{
	struct trace_iterator *iter = filp->private_data;

	if (trace_flags & TRACE_ITER_BLOCK) {
		/*
		 * Always select as readable when in blocking mode
		 */
		return POLLIN | POLLRDNORM;
I
Ingo Molnar 已提交
2939
	} else {
2940 2941 2942 2943 2944 2945 2946 2947 2948 2949
		if (!trace_empty(iter))
			return POLLIN | POLLRDNORM;
		poll_wait(filp, &trace_wait, poll_table);
		if (!trace_empty(iter))
			return POLLIN | POLLRDNORM;

		return 0;
	}
}

2950 2951 2952 2953 2954 2955 2956 2957 2958 2959 2960 2961 2962 2963 2964 2965 2966 2967 2968 2969 2970 2971 2972 2973 2974 2975 2976 2977 2978 2979 2980 2981

void default_wait_pipe(struct trace_iterator *iter)
{
	DEFINE_WAIT(wait);

	prepare_to_wait(&trace_wait, &wait, TASK_INTERRUPTIBLE);

	if (trace_empty(iter))
		schedule();

	finish_wait(&trace_wait, &wait);
}

/*
 * This is a make-shift waitqueue.
 * A tracer might use this callback on some rare cases:
 *
 *  1) the current tracer might hold the runqueue lock when it wakes up
 *     a reader, hence a deadlock (sched, function, and function graph tracers)
 *  2) the function tracers, trace all functions, we don't want
 *     the overhead of calling wake_up and friends
 *     (and tracing them too)
 *
 *     Anyway, this is really very primitive wakeup.
 */
void poll_wait_pipe(struct trace_iterator *iter)
{
	set_current_state(TASK_INTERRUPTIBLE);
	/* sleep for 100 msecs, and try again. */
	schedule_timeout(HZ / 10);
}

2982 2983
/* Must be called with trace_types_lock mutex held. */
static int tracing_wait_pipe(struct file *filp)
2984 2985 2986 2987
{
	struct trace_iterator *iter = filp->private_data;

	while (trace_empty(iter)) {
2988

2989
		if ((filp->f_flags & O_NONBLOCK)) {
2990
			return -EAGAIN;
2991
		}
2992

2993
		mutex_unlock(&iter->mutex);
2994

2995
		iter->trace->wait_pipe(iter);
2996

2997
		mutex_lock(&iter->mutex);
2998

2999
		if (signal_pending(current))
3000
			return -EINTR;
3001 3002 3003 3004 3005 3006 3007 3008 3009 3010 3011 3012 3013 3014

		/*
		 * We block until we read something and tracing is disabled.
		 * We still block if tracing is disabled, but we have never
		 * read anything. This allows a user to cat this file, and
		 * then enable tracing. But after we have read something,
		 * we give an EOF when tracing is again disabled.
		 *
		 * iter->pos will be 0 if we haven't read anything.
		 */
		if (!tracer_enabled && iter->pos)
			break;
	}

3015 3016 3017 3018 3019 3020 3021 3022 3023 3024 3025
	return 1;
}

/*
 * Consumer reader.
 */
static ssize_t
tracing_read_pipe(struct file *filp, char __user *ubuf,
		  size_t cnt, loff_t *ppos)
{
	struct trace_iterator *iter = filp->private_data;
3026
	static struct tracer *old_tracer;
3027 3028 3029 3030 3031 3032 3033
	ssize_t sret;

	/* return any leftover data */
	sret = trace_seq_to_user(&iter->seq, ubuf, cnt);
	if (sret != -EBUSY)
		return sret;

3034
	trace_seq_init(&iter->seq);
3035

3036
	/* copy the tracer to avoid using a global lock all around */
3037
	mutex_lock(&trace_types_lock);
3038 3039 3040 3041 3042 3043 3044 3045 3046 3047 3048 3049
	if (unlikely(old_tracer != current_trace && current_trace)) {
		old_tracer = current_trace;
		*iter->trace = *current_trace;
	}
	mutex_unlock(&trace_types_lock);

	/*
	 * Avoid more than one consumer on a single file descriptor
	 * This is just a matter of traces coherency, the ring buffer itself
	 * is protected.
	 */
	mutex_lock(&iter->mutex);
3050 3051 3052 3053 3054 3055 3056 3057 3058 3059 3060
	if (iter->trace->read) {
		sret = iter->trace->read(iter, filp, ubuf, cnt, ppos);
		if (sret)
			goto out;
	}

waitagain:
	sret = tracing_wait_pipe(filp);
	if (sret <= 0)
		goto out;

3061
	/* stop when tracing is finished */
3062 3063
	if (trace_empty(iter)) {
		sret = 0;
3064
		goto out;
3065
	}
3066 3067 3068 3069

	if (cnt >= PAGE_SIZE)
		cnt = PAGE_SIZE - 1;

3070 3071 3072 3073
	/* reset all but tr, trace, and overruns */
	memset(&iter->seq, 0,
	       sizeof(struct trace_iterator) -
	       offsetof(struct trace_iterator, seq));
3074
	iter->pos = -1;
3075

3076
	trace_event_read_lock();
S
Steven Rostedt 已提交
3077
	while (find_next_entry_inc(iter) != NULL) {
3078
		enum print_line_t ret;
S
Steven Rostedt 已提交
3079 3080
		int len = iter->seq.len;

I
Ingo Molnar 已提交
3081
		ret = print_trace_line(iter);
3082
		if (ret == TRACE_TYPE_PARTIAL_LINE) {
S
Steven Rostedt 已提交
3083 3084
			/* don't print partial lines */
			iter->seq.len = len;
3085
			break;
S
Steven Rostedt 已提交
3086
		}
3087 3088
		if (ret != TRACE_TYPE_NO_CONSUME)
			trace_consume(iter);
3089 3090 3091 3092

		if (iter->seq.len >= cnt)
			break;
	}
3093
	trace_event_read_unlock();
3094 3095

	/* Now copy what we have to the user */
3096 3097
	sret = trace_seq_to_user(&iter->seq, ubuf, cnt);
	if (iter->seq.readpos >= iter->seq.len)
3098
		trace_seq_init(&iter->seq);
P
Pekka Paalanen 已提交
3099 3100 3101 3102 3103

	/*
	 * If there was nothing to send to user, inspite of consuming trace
	 * entries, go back to wait for more entries.
	 */
3104
	if (sret == -EBUSY)
P
Pekka Paalanen 已提交
3105
		goto waitagain;
3106

3107
out:
3108
	mutex_unlock(&iter->mutex);
3109

3110
	return sret;
3111 3112
}

3113 3114 3115 3116 3117 3118 3119 3120 3121 3122 3123 3124
static void tracing_pipe_buf_release(struct pipe_inode_info *pipe,
				     struct pipe_buffer *buf)
{
	__free_page(buf->page);
}

static void tracing_spd_release_pipe(struct splice_pipe_desc *spd,
				     unsigned int idx)
{
	__free_page(spd->pages[idx]);
}

3125
static const struct pipe_buf_operations tracing_pipe_buf_ops = {
S
Steven Rostedt 已提交
3126 3127 3128 3129 3130 3131 3132
	.can_merge		= 0,
	.map			= generic_pipe_buf_map,
	.unmap			= generic_pipe_buf_unmap,
	.confirm		= generic_pipe_buf_confirm,
	.release		= tracing_pipe_buf_release,
	.steal			= generic_pipe_buf_steal,
	.get			= generic_pipe_buf_get,
3133 3134
};

S
Steven Rostedt 已提交
3135
static size_t
3136
tracing_fill_pipe_page(size_t rem, struct trace_iterator *iter)
S
Steven Rostedt 已提交
3137 3138 3139 3140 3141 3142 3143 3144 3145 3146 3147 3148 3149 3150 3151 3152 3153 3154 3155
{
	size_t count;
	int ret;

	/* Seq buffer is page-sized, exactly what we need. */
	for (;;) {
		count = iter->seq.len;
		ret = print_trace_line(iter);
		count = iter->seq.len - count;
		if (rem < count) {
			rem = 0;
			iter->seq.len -= count;
			break;
		}
		if (ret == TRACE_TYPE_PARTIAL_LINE) {
			iter->seq.len -= count;
			break;
		}

3156 3157
		if (ret != TRACE_TYPE_NO_CONSUME)
			trace_consume(iter);
S
Steven Rostedt 已提交
3158 3159 3160 3161 3162 3163 3164 3165 3166 3167 3168
		rem -= count;
		if (!find_next_entry_inc(iter))	{
			rem = 0;
			iter->ent = NULL;
			break;
		}
	}

	return rem;
}

3169 3170 3171 3172 3173 3174 3175 3176 3177 3178
static ssize_t tracing_splice_read_pipe(struct file *filp,
					loff_t *ppos,
					struct pipe_inode_info *pipe,
					size_t len,
					unsigned int flags)
{
	struct page *pages[PIPE_BUFFERS];
	struct partial_page partial[PIPE_BUFFERS];
	struct trace_iterator *iter = filp->private_data;
	struct splice_pipe_desc spd = {
S
Steven Rostedt 已提交
3179 3180 3181 3182 3183 3184
		.pages		= pages,
		.partial	= partial,
		.nr_pages	= 0, /* This gets updated below. */
		.flags		= flags,
		.ops		= &tracing_pipe_buf_ops,
		.spd_release	= tracing_spd_release_pipe,
3185
	};
3186
	static struct tracer *old_tracer;
3187
	ssize_t ret;
S
Steven Rostedt 已提交
3188
	size_t rem;
3189 3190
	unsigned int i;

3191
	/* copy the tracer to avoid using a global lock all around */
3192
	mutex_lock(&trace_types_lock);
3193 3194 3195 3196 3197 3198 3199
	if (unlikely(old_tracer != current_trace && current_trace)) {
		old_tracer = current_trace;
		*iter->trace = *current_trace;
	}
	mutex_unlock(&trace_types_lock);

	mutex_lock(&iter->mutex);
3200 3201 3202 3203 3204

	if (iter->trace->splice_read) {
		ret = iter->trace->splice_read(iter, filp,
					       ppos, pipe, len, flags);
		if (ret)
S
Steven Rostedt 已提交
3205
			goto out_err;
3206 3207 3208 3209
	}

	ret = tracing_wait_pipe(filp);
	if (ret <= 0)
S
Steven Rostedt 已提交
3210
		goto out_err;
3211 3212 3213

	if (!iter->ent && !find_next_entry_inc(iter)) {
		ret = -EFAULT;
S
Steven Rostedt 已提交
3214
		goto out_err;
3215 3216
	}

3217 3218
	trace_event_read_lock();

3219 3220 3221
	/* Fill as many pages as possible. */
	for (i = 0, rem = len; i < PIPE_BUFFERS && rem; i++) {
		pages[i] = alloc_page(GFP_KERNEL);
S
Steven Rostedt 已提交
3222 3223
		if (!pages[i])
			break;
3224

3225
		rem = tracing_fill_pipe_page(rem, iter);
3226 3227 3228 3229 3230 3231 3232 3233 3234 3235 3236 3237

		/* Copy the data into the page, so we can start over. */
		ret = trace_seq_to_buffer(&iter->seq,
					  page_address(pages[i]),
					  iter->seq.len);
		if (ret < 0) {
			__free_page(pages[i]);
			break;
		}
		partial[i].offset = 0;
		partial[i].len = iter->seq.len;

3238
		trace_seq_init(&iter->seq);
3239 3240
	}

3241
	trace_event_read_unlock();
3242
	mutex_unlock(&iter->mutex);
3243 3244 3245 3246 3247

	spd.nr_pages = i;

	return splice_to_pipe(pipe, &spd);

S
Steven Rostedt 已提交
3248
out_err:
3249
	mutex_unlock(&iter->mutex);
3250 3251 3252 3253

	return ret;
}

3254 3255 3256 3257 3258
static ssize_t
tracing_entries_read(struct file *filp, char __user *ubuf,
		     size_t cnt, loff_t *ppos)
{
	struct trace_array *tr = filp->private_data;
3259
	char buf[96];
3260 3261
	int r;

3262 3263 3264 3265 3266 3267 3268 3269 3270
	mutex_lock(&trace_types_lock);
	if (!ring_buffer_expanded)
		r = sprintf(buf, "%lu (expanded: %lu)\n",
			    tr->entries >> 10,
			    trace_buf_size >> 10);
	else
		r = sprintf(buf, "%lu\n", tr->entries >> 10);
	mutex_unlock(&trace_types_lock);

3271 3272 3273 3274 3275 3276 3277 3278 3279
	return simple_read_from_buffer(ubuf, cnt, ppos, buf, r);
}

static ssize_t
tracing_entries_write(struct file *filp, const char __user *ubuf,
		      size_t cnt, loff_t *ppos)
{
	unsigned long val;
	char buf[64];
S
Steven Rostedt 已提交
3280
	int ret, cpu;
3281

S
Steven Rostedt 已提交
3282 3283
	if (cnt >= sizeof(buf))
		return -EINVAL;
3284 3285 3286 3287 3288 3289

	if (copy_from_user(&buf, ubuf, cnt))
		return -EFAULT;

	buf[cnt] = 0;

3290 3291 3292
	ret = strict_strtoul(buf, 10, &val);
	if (ret < 0)
		return ret;
3293 3294 3295 3296 3297 3298 3299

	/* must have at least 1 entry */
	if (!val)
		return -EINVAL;

	mutex_lock(&trace_types_lock);

S
Steven Rostedt 已提交
3300
	tracing_stop();
3301

S
Steven Rostedt 已提交
3302 3303 3304 3305 3306 3307 3308 3309
	/* disable all cpu buffers */
	for_each_tracing_cpu(cpu) {
		if (global_trace.data[cpu])
			atomic_inc(&global_trace.data[cpu]->disabled);
		if (max_tr.data[cpu])
			atomic_inc(&max_tr.data[cpu]->disabled);
	}

3310 3311 3312
	/* value is in KB */
	val <<= 10;

3313
	if (val != global_trace.entries) {
3314
		ret = tracing_resize_ring_buffer(val);
3315 3316
		if (ret < 0) {
			cnt = ret;
S
Steven Rostedt 已提交
3317 3318
			goto out;
		}
3319 3320
	}

3321
	*ppos += cnt;
3322

3323 3324 3325
	/* If check pages failed, return ENOMEM */
	if (tracing_disabled)
		cnt = -ENOMEM;
3326
 out:
S
Steven Rostedt 已提交
3327 3328 3329 3330 3331 3332 3333
	for_each_tracing_cpu(cpu) {
		if (global_trace.data[cpu])
			atomic_dec(&global_trace.data[cpu]->disabled);
		if (max_tr.data[cpu])
			atomic_dec(&max_tr.data[cpu]->disabled);
	}

S
Steven Rostedt 已提交
3334
	tracing_start();
3335 3336 3337 3338 3339 3340
	max_tr.entries = global_trace.entries;
	mutex_unlock(&trace_types_lock);

	return cnt;
}

3341 3342 3343 3344 3345 3346 3347 3348 3349 3350
static int mark_printk(const char *fmt, ...)
{
	int ret;
	va_list args;
	va_start(args, fmt);
	ret = trace_vprintk(0, fmt, args);
	va_end(args);
	return ret;
}

3351 3352 3353 3354 3355 3356
static ssize_t
tracing_mark_write(struct file *filp, const char __user *ubuf,
					size_t cnt, loff_t *fpos)
{
	char *buf;

S
Steven Rostedt 已提交
3357
	if (tracing_disabled)
3358 3359 3360 3361 3362
		return -EINVAL;

	if (cnt > TRACE_BUF_SIZE)
		cnt = TRACE_BUF_SIZE;

C
Carsten Emde 已提交
3363
	buf = kmalloc(cnt + 2, GFP_KERNEL);
3364 3365 3366 3367 3368 3369 3370
	if (buf == NULL)
		return -ENOMEM;

	if (copy_from_user(buf, ubuf, cnt)) {
		kfree(buf);
		return -EFAULT;
	}
C
Carsten Emde 已提交
3371 3372 3373 3374 3375
	if (buf[cnt-1] != '\n') {
		buf[cnt] = '\n';
		buf[cnt+1] = '\0';
	} else
		buf[cnt] = '\0';
3376

3377
	cnt = mark_printk("%s", buf);
3378 3379 3380 3381 3382 3383
	kfree(buf);
	*fpos += cnt;

	return cnt;
}

L
Li Zefan 已提交
3384
static int tracing_clock_show(struct seq_file *m, void *v)
3385 3386 3387 3388
{
	int i;

	for (i = 0; i < ARRAY_SIZE(trace_clocks); i++)
L
Li Zefan 已提交
3389
		seq_printf(m,
3390 3391 3392
			"%s%s%s%s", i ? " " : "",
			i == trace_clock_id ? "[" : "", trace_clocks[i].name,
			i == trace_clock_id ? "]" : "");
L
Li Zefan 已提交
3393
	seq_putc(m, '\n');
3394

L
Li Zefan 已提交
3395
	return 0;
3396 3397 3398 3399 3400 3401 3402 3403 3404 3405 3406 3407 3408 3409 3410 3411 3412 3413 3414 3415 3416 3417 3418 3419 3420 3421 3422 3423 3424 3425 3426 3427 3428 3429 3430 3431 3432 3433 3434 3435 3436
}

static ssize_t tracing_clock_write(struct file *filp, const char __user *ubuf,
				   size_t cnt, loff_t *fpos)
{
	char buf[64];
	const char *clockstr;
	int i;

	if (cnt >= sizeof(buf))
		return -EINVAL;

	if (copy_from_user(&buf, ubuf, cnt))
		return -EFAULT;

	buf[cnt] = 0;

	clockstr = strstrip(buf);

	for (i = 0; i < ARRAY_SIZE(trace_clocks); i++) {
		if (strcmp(trace_clocks[i].name, clockstr) == 0)
			break;
	}
	if (i == ARRAY_SIZE(trace_clocks))
		return -EINVAL;

	trace_clock_id = i;

	mutex_lock(&trace_types_lock);

	ring_buffer_set_clock(global_trace.buffer, trace_clocks[i].func);
	if (max_tr.buffer)
		ring_buffer_set_clock(max_tr.buffer, trace_clocks[i].func);

	mutex_unlock(&trace_types_lock);

	*fpos += cnt;

	return cnt;
}

L
Li Zefan 已提交
3437 3438 3439 3440 3441 3442 3443
static int tracing_clock_open(struct inode *inode, struct file *file)
{
	if (tracing_disabled)
		return -ENODEV;
	return single_open(file, tracing_clock_show, NULL);
}

3444
static const struct file_operations tracing_max_lat_fops = {
I
Ingo Molnar 已提交
3445 3446 3447
	.open		= tracing_open_generic,
	.read		= tracing_max_lat_read,
	.write		= tracing_max_lat_write,
3448 3449
};

3450
static const struct file_operations tracing_ctrl_fops = {
I
Ingo Molnar 已提交
3451 3452 3453
	.open		= tracing_open_generic,
	.read		= tracing_ctrl_read,
	.write		= tracing_ctrl_write,
3454 3455
};

3456
static const struct file_operations set_tracer_fops = {
I
Ingo Molnar 已提交
3457 3458 3459
	.open		= tracing_open_generic,
	.read		= tracing_set_trace_read,
	.write		= tracing_set_trace_write,
3460 3461
};

3462
static const struct file_operations tracing_pipe_fops = {
I
Ingo Molnar 已提交
3463
	.open		= tracing_open_pipe,
3464
	.poll		= tracing_poll_pipe,
I
Ingo Molnar 已提交
3465
	.read		= tracing_read_pipe,
3466
	.splice_read	= tracing_splice_read_pipe,
I
Ingo Molnar 已提交
3467
	.release	= tracing_release_pipe,
3468 3469
};

3470
static const struct file_operations tracing_entries_fops = {
3471 3472 3473 3474 3475
	.open		= tracing_open_generic,
	.read		= tracing_entries_read,
	.write		= tracing_entries_write,
};

3476
static const struct file_operations tracing_mark_fops = {
3477
	.open		= tracing_open_generic,
3478 3479 3480
	.write		= tracing_mark_write,
};

3481
static const struct file_operations trace_clock_fops = {
L
Li Zefan 已提交
3482 3483 3484 3485
	.open		= tracing_clock_open,
	.read		= seq_read,
	.llseek		= seq_lseek,
	.release	= single_release,
3486 3487 3488
	.write		= tracing_clock_write,
};

3489 3490 3491 3492 3493 3494 3495 3496 3497 3498 3499 3500 3501 3502 3503 3504 3505 3506 3507 3508 3509
struct ftrace_buffer_info {
	struct trace_array	*tr;
	void			*spare;
	int			cpu;
	unsigned int		read;
};

static int tracing_buffers_open(struct inode *inode, struct file *filp)
{
	int cpu = (int)(long)inode->i_private;
	struct ftrace_buffer_info *info;

	if (tracing_disabled)
		return -ENODEV;

	info = kzalloc(sizeof(*info), GFP_KERNEL);
	if (!info)
		return -ENOMEM;

	info->tr	= &global_trace;
	info->cpu	= cpu;
3510
	info->spare	= NULL;
3511 3512 3513 3514 3515
	/* Force reading ring buffer for first read */
	info->read	= (unsigned int)-1;

	filp->private_data = info;

3516
	return nonseekable_open(inode, filp);
3517 3518 3519 3520 3521 3522 3523 3524 3525 3526 3527
}

static ssize_t
tracing_buffers_read(struct file *filp, char __user *ubuf,
		     size_t count, loff_t *ppos)
{
	struct ftrace_buffer_info *info = filp->private_data;
	unsigned int pos;
	ssize_t ret;
	size_t size;

3528 3529 3530
	if (!count)
		return 0;

3531 3532 3533 3534 3535
	if (!info->spare)
		info->spare = ring_buffer_alloc_read_page(info->tr->buffer);
	if (!info->spare)
		return -ENOMEM;

3536 3537 3538 3539 3540 3541 3542 3543 3544 3545 3546 3547 3548 3549 3550 3551 3552 3553 3554 3555 3556 3557 3558 3559
	/* Do we have previous read data to read? */
	if (info->read < PAGE_SIZE)
		goto read;

	info->read = 0;

	ret = ring_buffer_read_page(info->tr->buffer,
				    &info->spare,
				    count,
				    info->cpu, 0);
	if (ret < 0)
		return 0;

	pos = ring_buffer_page_len(info->spare);

	if (pos < PAGE_SIZE)
		memset(info->spare + pos, 0, PAGE_SIZE - pos);

read:
	size = PAGE_SIZE - info->read;
	if (size > count)
		size = count;

	ret = copy_to_user(ubuf, info->spare + info->read, size);
3560
	if (ret == size)
3561
		return -EFAULT;
3562 3563
	size -= ret;

3564 3565 3566 3567 3568 3569 3570 3571 3572 3573
	*ppos += size;
	info->read += size;

	return size;
}

static int tracing_buffers_release(struct inode *inode, struct file *file)
{
	struct ftrace_buffer_info *info = file->private_data;

3574 3575
	if (info->spare)
		ring_buffer_free_read_page(info->tr->buffer, info->spare);
3576 3577 3578 3579 3580 3581 3582 3583 3584 3585 3586 3587 3588 3589 3590 3591 3592 3593 3594 3595 3596 3597 3598 3599 3600 3601 3602 3603 3604 3605 3606 3607 3608 3609 3610 3611 3612 3613 3614
	kfree(info);

	return 0;
}

struct buffer_ref {
	struct ring_buffer	*buffer;
	void			*page;
	int			ref;
};

static void buffer_pipe_buf_release(struct pipe_inode_info *pipe,
				    struct pipe_buffer *buf)
{
	struct buffer_ref *ref = (struct buffer_ref *)buf->private;

	if (--ref->ref)
		return;

	ring_buffer_free_read_page(ref->buffer, ref->page);
	kfree(ref);
	buf->private = 0;
}

static int buffer_pipe_buf_steal(struct pipe_inode_info *pipe,
				 struct pipe_buffer *buf)
{
	return 1;
}

static void buffer_pipe_buf_get(struct pipe_inode_info *pipe,
				struct pipe_buffer *buf)
{
	struct buffer_ref *ref = (struct buffer_ref *)buf->private;

	ref->ref++;
}

/* Pipe buffer operations for a buffer. */
3615
static const struct pipe_buf_operations buffer_pipe_buf_ops = {
3616 3617 3618 3619 3620 3621 3622 3623 3624 3625 3626 3627 3628 3629 3630 3631 3632 3633 3634 3635 3636 3637 3638 3639 3640 3641 3642 3643 3644 3645 3646 3647 3648 3649 3650 3651 3652 3653 3654 3655 3656 3657
	.can_merge		= 0,
	.map			= generic_pipe_buf_map,
	.unmap			= generic_pipe_buf_unmap,
	.confirm		= generic_pipe_buf_confirm,
	.release		= buffer_pipe_buf_release,
	.steal			= buffer_pipe_buf_steal,
	.get			= buffer_pipe_buf_get,
};

/*
 * Callback from splice_to_pipe(), if we need to release some pages
 * at the end of the spd in case we error'ed out in filling the pipe.
 */
static void buffer_spd_release(struct splice_pipe_desc *spd, unsigned int i)
{
	struct buffer_ref *ref =
		(struct buffer_ref *)spd->partial[i].private;

	if (--ref->ref)
		return;

	ring_buffer_free_read_page(ref->buffer, ref->page);
	kfree(ref);
	spd->partial[i].private = 0;
}

static ssize_t
tracing_buffers_splice_read(struct file *file, loff_t *ppos,
			    struct pipe_inode_info *pipe, size_t len,
			    unsigned int flags)
{
	struct ftrace_buffer_info *info = file->private_data;
	struct partial_page partial[PIPE_BUFFERS];
	struct page *pages[PIPE_BUFFERS];
	struct splice_pipe_desc spd = {
		.pages		= pages,
		.partial	= partial,
		.flags		= flags,
		.ops		= &buffer_pipe_buf_ops,
		.spd_release	= buffer_spd_release,
	};
	struct buffer_ref *ref;
3658
	int entries, size, i;
3659 3660
	size_t ret;

3661 3662 3663 3664 3665 3666 3667 3668 3669 3670 3671 3672
	if (*ppos & (PAGE_SIZE - 1)) {
		WARN_ONCE(1, "Ftrace: previous read must page-align\n");
		return -EINVAL;
	}

	if (len & (PAGE_SIZE - 1)) {
		WARN_ONCE(1, "Ftrace: splice_read should page-align\n");
		if (len < PAGE_SIZE)
			return -EINVAL;
		len &= PAGE_MASK;
	}

3673 3674 3675
	entries = ring_buffer_entries_cpu(info->tr->buffer, info->cpu);

	for (i = 0; i < PIPE_BUFFERS && len && entries; i++, len -= PAGE_SIZE) {
3676 3677 3678 3679 3680 3681 3682
		struct page *page;
		int r;

		ref = kzalloc(sizeof(*ref), GFP_KERNEL);
		if (!ref)
			break;

3683
		ref->ref = 1;
3684 3685 3686 3687 3688 3689 3690 3691
		ref->buffer = info->tr->buffer;
		ref->page = ring_buffer_alloc_read_page(ref->buffer);
		if (!ref->page) {
			kfree(ref);
			break;
		}

		r = ring_buffer_read_page(ref->buffer, &ref->page,
3692
					  len, info->cpu, 1);
3693 3694 3695 3696 3697 3698 3699 3700 3701 3702 3703 3704 3705 3706 3707 3708 3709 3710 3711 3712 3713 3714
		if (r < 0) {
			ring_buffer_free_read_page(ref->buffer,
						   ref->page);
			kfree(ref);
			break;
		}

		/*
		 * zero out any left over data, this is going to
		 * user land.
		 */
		size = ring_buffer_page_len(ref->page);
		if (size < PAGE_SIZE)
			memset(ref->page + size, 0, PAGE_SIZE - size);

		page = virt_to_page(ref->page);

		spd.pages[i] = page;
		spd.partial[i].len = PAGE_SIZE;
		spd.partial[i].offset = 0;
		spd.partial[i].private = (unsigned long)ref;
		spd.nr_pages++;
3715
		*ppos += PAGE_SIZE;
3716 3717

		entries = ring_buffer_entries_cpu(info->tr->buffer, info->cpu);
3718 3719 3720 3721 3722 3723 3724 3725 3726 3727 3728 3729 3730 3731 3732 3733 3734 3735 3736 3737 3738 3739 3740 3741 3742 3743 3744
	}

	spd.nr_pages = i;

	/* did we read anything? */
	if (!spd.nr_pages) {
		if (flags & SPLICE_F_NONBLOCK)
			ret = -EAGAIN;
		else
			ret = 0;
		/* TODO: block */
		return ret;
	}

	ret = splice_to_pipe(pipe, &spd);

	return ret;
}

static const struct file_operations tracing_buffers_fops = {
	.open		= tracing_buffers_open,
	.read		= tracing_buffers_read,
	.release	= tracing_buffers_release,
	.splice_read	= tracing_buffers_splice_read,
	.llseek		= no_llseek,
};

3745 3746 3747 3748 3749 3750 3751 3752 3753
static ssize_t
tracing_stats_read(struct file *filp, char __user *ubuf,
		   size_t count, loff_t *ppos)
{
	unsigned long cpu = (unsigned long)filp->private_data;
	struct trace_array *tr = &global_trace;
	struct trace_seq *s;
	unsigned long cnt;

3754
	s = kmalloc(sizeof(*s), GFP_KERNEL);
3755
	if (!s)
3756
		return -ENOMEM;
3757 3758 3759 3760 3761 3762 3763 3764 3765 3766 3767 3768 3769 3770 3771 3772 3773 3774 3775 3776 3777 3778 3779 3780

	trace_seq_init(s);

	cnt = ring_buffer_entries_cpu(tr->buffer, cpu);
	trace_seq_printf(s, "entries: %ld\n", cnt);

	cnt = ring_buffer_overrun_cpu(tr->buffer, cpu);
	trace_seq_printf(s, "overrun: %ld\n", cnt);

	cnt = ring_buffer_commit_overrun_cpu(tr->buffer, cpu);
	trace_seq_printf(s, "commit overrun: %ld\n", cnt);

	count = simple_read_from_buffer(ubuf, count, ppos, s->buffer, s->len);

	kfree(s);

	return count;
}

static const struct file_operations tracing_stats_fops = {
	.open		= tracing_open_generic,
	.read		= tracing_stats_read,
};

3781 3782
#ifdef CONFIG_DYNAMIC_FTRACE

S
Steven Rostedt 已提交
3783 3784 3785 3786 3787
int __weak ftrace_arch_read_dyn_info(char *buf, int size)
{
	return 0;
}

3788
static ssize_t
S
Steven Rostedt 已提交
3789
tracing_read_dyn_info(struct file *filp, char __user *ubuf,
3790 3791
		  size_t cnt, loff_t *ppos)
{
S
Steven Rostedt 已提交
3792 3793
	static char ftrace_dyn_info_buffer[1024];
	static DEFINE_MUTEX(dyn_info_mutex);
3794
	unsigned long *p = filp->private_data;
S
Steven Rostedt 已提交
3795
	char *buf = ftrace_dyn_info_buffer;
S
Steven Rostedt 已提交
3796
	int size = ARRAY_SIZE(ftrace_dyn_info_buffer);
3797 3798
	int r;

S
Steven Rostedt 已提交
3799 3800
	mutex_lock(&dyn_info_mutex);
	r = sprintf(buf, "%ld ", *p);
I
Ingo Molnar 已提交
3801

S
Steven Rostedt 已提交
3802
	r += ftrace_arch_read_dyn_info(buf+r, (size-1)-r);
S
Steven Rostedt 已提交
3803 3804 3805 3806 3807 3808 3809
	buf[r++] = '\n';

	r = simple_read_from_buffer(ubuf, cnt, ppos, buf, r);

	mutex_unlock(&dyn_info_mutex);

	return r;
3810 3811
}

3812
static const struct file_operations tracing_dyn_info_fops = {
I
Ingo Molnar 已提交
3813
	.open		= tracing_open_generic,
S
Steven Rostedt 已提交
3814
	.read		= tracing_read_dyn_info,
3815 3816 3817 3818 3819 3820 3821 3822 3823 3824 3825 3826
};
#endif

static struct dentry *d_tracer;

struct dentry *tracing_init_dentry(void)
{
	static int once;

	if (d_tracer)
		return d_tracer;

3827 3828 3829
	if (!debugfs_initialized())
		return NULL;

3830 3831 3832 3833 3834 3835 3836 3837 3838 3839 3840
	d_tracer = debugfs_create_dir("tracing", NULL);

	if (!d_tracer && !once) {
		once = 1;
		pr_warning("Could not create debugfs directory 'tracing'\n");
		return NULL;
	}

	return d_tracer;
}

3841 3842 3843 3844 3845 3846 3847 3848 3849 3850 3851 3852 3853 3854 3855 3856 3857 3858 3859 3860 3861 3862 3863 3864 3865 3866 3867 3868 3869
static struct dentry *d_percpu;

struct dentry *tracing_dentry_percpu(void)
{
	static int once;
	struct dentry *d_tracer;

	if (d_percpu)
		return d_percpu;

	d_tracer = tracing_init_dentry();

	if (!d_tracer)
		return NULL;

	d_percpu = debugfs_create_dir("per_cpu", d_tracer);

	if (!d_percpu && !once) {
		once = 1;
		pr_warning("Could not create debugfs directory 'per_cpu'\n");
		return NULL;
	}

	return d_percpu;
}

static void tracing_init_debugfs_percpu(long cpu)
{
	struct dentry *d_percpu = tracing_dentry_percpu();
3870
	struct dentry *d_cpu;
3871 3872
	/* strlen(cpu) + MAX(log10(cpu)) + '\0' */
	char cpu_dir[7];
3873 3874 3875 3876

	if (cpu > 999 || cpu < 0)
		return;

3877 3878 3879 3880 3881 3882
	sprintf(cpu_dir, "cpu%ld", cpu);
	d_cpu = debugfs_create_dir(cpu_dir, d_percpu);
	if (!d_cpu) {
		pr_warning("Could not create debugfs '%s' entry\n", cpu_dir);
		return;
	}
3883

3884
	/* per cpu trace_pipe */
3885 3886
	trace_create_file("trace_pipe", 0444, d_cpu,
			(void *) cpu, &tracing_pipe_fops);
3887 3888

	/* per cpu trace */
3889 3890
	trace_create_file("trace", 0644, d_cpu,
			(void *) cpu, &tracing_fops);
3891

3892 3893
	trace_create_file("trace_pipe_raw", 0444, d_cpu,
			(void *) cpu, &tracing_buffers_fops);
3894

3895 3896
	trace_create_file("stats", 0444, d_cpu,
			(void *) cpu, &tracing_stats_fops);
3897 3898
}

S
Steven Rostedt 已提交
3899 3900 3901 3902 3903
#ifdef CONFIG_FTRACE_SELFTEST
/* Let selftest have access to static functions in this file */
#include "trace_selftest.c"
#endif

3904 3905 3906 3907 3908 3909 3910 3911 3912 3913 3914 3915 3916 3917 3918 3919 3920 3921 3922 3923 3924 3925 3926 3927 3928 3929 3930 3931 3932 3933 3934 3935 3936 3937 3938 3939 3940 3941 3942 3943 3944 3945
struct trace_option_dentry {
	struct tracer_opt		*opt;
	struct tracer_flags		*flags;
	struct dentry			*entry;
};

static ssize_t
trace_options_read(struct file *filp, char __user *ubuf, size_t cnt,
			loff_t *ppos)
{
	struct trace_option_dentry *topt = filp->private_data;
	char *buf;

	if (topt->flags->val & topt->opt->bit)
		buf = "1\n";
	else
		buf = "0\n";

	return simple_read_from_buffer(ubuf, cnt, ppos, buf, 2);
}

static ssize_t
trace_options_write(struct file *filp, const char __user *ubuf, size_t cnt,
			 loff_t *ppos)
{
	struct trace_option_dentry *topt = filp->private_data;
	unsigned long val;
	char buf[64];
	int ret;

	if (cnt >= sizeof(buf))
		return -EINVAL;

	if (copy_from_user(&buf, ubuf, cnt))
		return -EFAULT;

	buf[cnt] = 0;

	ret = strict_strtoul(buf, 10, &val);
	if (ret < 0)
		return ret;

L
Li Zefan 已提交
3946 3947
	if (val != 0 && val != 1)
		return -EINVAL;
3948

L
Li Zefan 已提交
3949
	if (!!(topt->flags->val & topt->opt->bit) != val) {
3950
		mutex_lock(&trace_types_lock);
L
Li Zefan 已提交
3951
		ret = __set_tracer_option(current_trace, topt->flags,
3952
					  topt->opt, !val);
3953 3954 3955 3956 3957 3958 3959 3960 3961 3962 3963 3964 3965 3966 3967 3968 3969
		mutex_unlock(&trace_types_lock);
		if (ret)
			return ret;
	}

	*ppos += cnt;

	return cnt;
}


static const struct file_operations trace_options_fops = {
	.open = tracing_open_generic,
	.read = trace_options_read,
	.write = trace_options_write,
};

3970 3971 3972 3973 3974 3975 3976 3977 3978 3979 3980 3981 3982 3983 3984 3985 3986 3987 3988 3989 3990 3991 3992 3993 3994 3995 3996 3997 3998 3999 4000 4001 4002 4003 4004 4005
static ssize_t
trace_options_core_read(struct file *filp, char __user *ubuf, size_t cnt,
			loff_t *ppos)
{
	long index = (long)filp->private_data;
	char *buf;

	if (trace_flags & (1 << index))
		buf = "1\n";
	else
		buf = "0\n";

	return simple_read_from_buffer(ubuf, cnt, ppos, buf, 2);
}

static ssize_t
trace_options_core_write(struct file *filp, const char __user *ubuf, size_t cnt,
			 loff_t *ppos)
{
	long index = (long)filp->private_data;
	char buf[64];
	unsigned long val;
	int ret;

	if (cnt >= sizeof(buf))
		return -EINVAL;

	if (copy_from_user(&buf, ubuf, cnt))
		return -EFAULT;

	buf[cnt] = 0;

	ret = strict_strtoul(buf, 10, &val);
	if (ret < 0)
		return ret;

4006
	if (val != 0 && val != 1)
4007
		return -EINVAL;
4008
	set_tracer_flags(1 << index, val);
4009 4010 4011 4012 4013 4014 4015 4016 4017 4018 4019 4020

	*ppos += cnt;

	return cnt;
}

static const struct file_operations trace_options_core_fops = {
	.open = tracing_open_generic,
	.read = trace_options_core_read,
	.write = trace_options_core_write,
};

4021 4022 4023 4024 4025 4026 4027 4028 4029 4030 4031 4032 4033 4034 4035 4036
struct dentry *trace_create_file(const char *name,
				 mode_t mode,
				 struct dentry *parent,
				 void *data,
				 const struct file_operations *fops)
{
	struct dentry *ret;

	ret = debugfs_create_file(name, mode, parent, data, fops);
	if (!ret)
		pr_warning("Could not create debugfs '%s' entry\n", name);

	return ret;
}


4037 4038 4039 4040 4041 4042 4043 4044 4045 4046 4047 4048 4049 4050 4051 4052 4053 4054 4055 4056 4057
static struct dentry *trace_options_init_dentry(void)
{
	struct dentry *d_tracer;
	static struct dentry *t_options;

	if (t_options)
		return t_options;

	d_tracer = tracing_init_dentry();
	if (!d_tracer)
		return NULL;

	t_options = debugfs_create_dir("options", d_tracer);
	if (!t_options) {
		pr_warning("Could not create debugfs directory 'options'\n");
		return NULL;
	}

	return t_options;
}

4058 4059 4060 4061 4062 4063 4064 4065 4066 4067 4068 4069 4070 4071
static void
create_trace_option_file(struct trace_option_dentry *topt,
			 struct tracer_flags *flags,
			 struct tracer_opt *opt)
{
	struct dentry *t_options;

	t_options = trace_options_init_dentry();
	if (!t_options)
		return;

	topt->flags = flags;
	topt->opt = opt;

4072
	topt->entry = trace_create_file(opt->name, 0644, t_options, topt,
4073 4074 4075 4076 4077 4078 4079 4080 4081 4082 4083 4084 4085 4086 4087 4088 4089 4090 4091 4092 4093 4094 4095 4096 4097
				    &trace_options_fops);

}

static struct trace_option_dentry *
create_trace_option_files(struct tracer *tracer)
{
	struct trace_option_dentry *topts;
	struct tracer_flags *flags;
	struct tracer_opt *opts;
	int cnt;

	if (!tracer)
		return NULL;

	flags = tracer->flags;

	if (!flags || !flags->opts)
		return NULL;

	opts = flags->opts;

	for (cnt = 0; opts[cnt].name; cnt++)
		;

4098
	topts = kcalloc(cnt + 1, sizeof(*topts), GFP_KERNEL);
4099 4100 4101 4102 4103 4104 4105 4106 4107 4108 4109 4110 4111 4112 4113 4114 4115 4116 4117 4118 4119 4120 4121 4122 4123 4124
	if (!topts)
		return NULL;

	for (cnt = 0; opts[cnt].name; cnt++)
		create_trace_option_file(&topts[cnt], flags,
					 &opts[cnt]);

	return topts;
}

static void
destroy_trace_option_files(struct trace_option_dentry *topts)
{
	int cnt;

	if (!topts)
		return;

	for (cnt = 0; topts[cnt].opt; cnt++) {
		if (topts[cnt].entry)
			debugfs_remove(topts[cnt].entry);
	}

	kfree(topts);
}

4125 4126 4127 4128 4129 4130 4131 4132 4133
static struct dentry *
create_trace_option_core_file(const char *option, long index)
{
	struct dentry *t_options;

	t_options = trace_options_init_dentry();
	if (!t_options)
		return NULL;

4134
	return trace_create_file(option, 0644, t_options, (void *)index,
4135 4136 4137 4138 4139 4140 4141 4142 4143 4144 4145 4146
				    &trace_options_core_fops);
}

static __init void create_trace_options_dir(void)
{
	struct dentry *t_options;
	int i;

	t_options = trace_options_init_dentry();
	if (!t_options)
		return;

4147 4148
	for (i = 0; trace_options[i]; i++)
		create_trace_option_core_file(trace_options[i], i);
4149 4150
}

4151
static __init int tracer_init_debugfs(void)
4152 4153
{
	struct dentry *d_tracer;
4154
	int cpu;
4155 4156 4157

	d_tracer = tracing_init_dentry();

4158 4159
	trace_create_file("tracing_enabled", 0644, d_tracer,
			&global_trace, &tracing_ctrl_fops);
4160

4161 4162
	trace_create_file("trace_options", 0644, d_tracer,
			NULL, &tracing_iter_fops);
4163

4164 4165 4166 4167 4168
	trace_create_file("tracing_cpumask", 0644, d_tracer,
			NULL, &tracing_cpumask_fops);

	trace_create_file("trace", 0644, d_tracer,
			(void *) TRACE_PIPE_ALL_CPU, &tracing_fops);
4169

4170 4171 4172
	trace_create_file("available_tracers", 0444, d_tracer,
			&global_trace, &show_traces_fops);

4173
	trace_create_file("current_tracer", 0644, d_tracer,
4174 4175
			&global_trace, &set_tracer_fops);

4176
#ifdef CONFIG_TRACER_MAX_TRACE
4177 4178 4179 4180 4181
	trace_create_file("tracing_max_latency", 0644, d_tracer,
			&tracing_max_latency, &tracing_max_lat_fops);

	trace_create_file("tracing_thresh", 0644, d_tracer,
			&tracing_thresh, &tracing_max_lat_fops);
4182
#endif
4183

4184
	trace_create_file("README", 0444, d_tracer,
4185 4186 4187
			NULL, &tracing_readme_fops);

	trace_create_file("trace_pipe", 0444, d_tracer,
4188
			(void *) TRACE_PIPE_ALL_CPU, &tracing_pipe_fops);
4189 4190 4191 4192 4193 4194

	trace_create_file("buffer_size_kb", 0644, d_tracer,
			&global_trace, &tracing_entries_fops);

	trace_create_file("trace_marker", 0220, d_tracer,
			NULL, &tracing_mark_fops);
4195

4196 4197
	trace_create_file("saved_cmdlines", 0444, d_tracer,
			NULL, &tracing_saved_cmdlines_fops);
4198

4199 4200 4201
	trace_create_file("trace_clock", 0644, d_tracer, NULL,
			  &trace_clock_fops);

4202
#ifdef CONFIG_DYNAMIC_FTRACE
4203 4204
	trace_create_file("dyn_ftrace_total_info", 0444, d_tracer,
			&ftrace_update_tot_cnt, &tracing_dyn_info_fops);
4205
#endif
I
Ingo Molnar 已提交
4206 4207 4208
#ifdef CONFIG_SYSPROF_TRACER
	init_tracer_sysprof_debugfs(d_tracer);
#endif
4209

4210 4211
	create_trace_options_dir();

4212 4213 4214
	for_each_tracing_cpu(cpu)
		tracing_init_debugfs_percpu(cpu);

4215
	return 0;
4216 4217
}

4218 4219 4220
static int trace_panic_handler(struct notifier_block *this,
			       unsigned long event, void *unused)
{
4221 4222
	if (ftrace_dump_on_oops)
		ftrace_dump();
4223 4224 4225 4226 4227 4228 4229 4230 4231 4232 4233 4234 4235 4236 4237
	return NOTIFY_OK;
}

static struct notifier_block trace_panic_notifier = {
	.notifier_call  = trace_panic_handler,
	.next           = NULL,
	.priority       = 150   /* priority: INT_MAX >= x >= 0 */
};

static int trace_die_handler(struct notifier_block *self,
			     unsigned long val,
			     void *data)
{
	switch (val) {
	case DIE_OOPS:
4238 4239
		if (ftrace_dump_on_oops)
			ftrace_dump();
4240 4241 4242 4243 4244 4245 4246 4247 4248 4249 4250 4251 4252 4253 4254 4255 4256 4257 4258 4259 4260 4261 4262
		break;
	default:
		break;
	}
	return NOTIFY_OK;
}

static struct notifier_block trace_die_notifier = {
	.notifier_call = trace_die_handler,
	.priority = 200
};

/*
 * printk is set to max of 1024, we really don't need it that big.
 * Nothing should be printing 1000 characters anyway.
 */
#define TRACE_MAX_PRINT		1000

/*
 * Define here KERN_TRACE so that we have one place to modify
 * it if we decide to change what log level the ftrace dump
 * should be at.
 */
4263
#define KERN_TRACE		KERN_EMERG
4264 4265 4266 4267 4268 4269 4270 4271 4272 4273 4274 4275 4276

static void
trace_printk_seq(struct trace_seq *s)
{
	/* Probably should print a warning here. */
	if (s->len >= 1000)
		s->len = 1000;

	/* should be zero ended, but we are paranoid. */
	s->buffer[s->len] = 0;

	printk(KERN_TRACE "%s", s->buffer);

4277
	trace_seq_init(s);
4278 4279
}

4280
static void __ftrace_dump(bool disable_tracing)
4281
{
4282
	static arch_spinlock_t ftrace_dump_lock =
4283
		(arch_spinlock_t)__ARCH_SPIN_LOCK_UNLOCKED;
4284 4285
	/* use static because iter can be a bit big for the stack */
	static struct trace_iterator iter;
4286
	unsigned int old_userobj;
4287
	static int dump_ran;
4288 4289
	unsigned long flags;
	int cnt = 0, cpu;
4290 4291

	/* only one dump */
4292
	local_irq_save(flags);
4293
	arch_spin_lock(&ftrace_dump_lock);
4294 4295 4296 4297 4298
	if (dump_ran)
		goto out;

	dump_ran = 1;

4299
	tracing_off();
4300 4301 4302

	if (disable_tracing)
		ftrace_kill();
4303

4304 4305 4306 4307
	for_each_tracing_cpu(cpu) {
		atomic_inc(&global_trace.data[cpu]->disabled);
	}

4308 4309
	old_userobj = trace_flags & TRACE_ITER_SYM_USEROBJ;

4310 4311 4312
	/* don't look at user memory in panic mode */
	trace_flags &= ~TRACE_ITER_SYM_USEROBJ;

4313 4314
	printk(KERN_TRACE "Dumping ftrace buffer:\n");

4315
	/* Simulate the iterator */
4316 4317
	iter.tr = &global_trace;
	iter.trace = current_trace;
4318
	iter.cpu_file = TRACE_PIPE_ALL_CPU;
4319 4320 4321 4322 4323 4324 4325 4326 4327 4328 4329 4330 4331 4332 4333 4334 4335 4336 4337 4338 4339 4340 4341

	/*
	 * We need to stop all tracing on all CPUS to read the
	 * the next buffer. This is a bit expensive, but is
	 * not done often. We fill all what we can read,
	 * and then release the locks again.
	 */

	while (!trace_empty(&iter)) {

		if (!cnt)
			printk(KERN_TRACE "---------------------------------\n");

		cnt++;

		/* reset all but tr, trace, and overruns */
		memset(&iter.seq, 0,
		       sizeof(struct trace_iterator) -
		       offsetof(struct trace_iterator, seq));
		iter.iter_flags |= TRACE_FILE_LAT_FMT;
		iter.pos = -1;

		if (find_next_entry_inc(&iter) != NULL) {
4342 4343 4344 4345 4346
			int ret;

			ret = print_trace_line(&iter);
			if (ret != TRACE_TYPE_NO_CONSUME)
				trace_consume(&iter);
4347 4348 4349 4350 4351 4352 4353 4354 4355 4356
		}

		trace_printk_seq(&iter.seq);
	}

	if (!cnt)
		printk(KERN_TRACE "   (ftrace buffer empty)\n");
	else
		printk(KERN_TRACE "---------------------------------\n");

4357 4358 4359 4360 4361 4362 4363 4364 4365 4366
	/* Re-enable tracing if requested */
	if (!disable_tracing) {
		trace_flags |= old_userobj;

		for_each_tracing_cpu(cpu) {
			atomic_dec(&global_trace.data[cpu]->disabled);
		}
		tracing_on();
	}

4367
 out:
4368
	arch_spin_unlock(&ftrace_dump_lock);
4369
	local_irq_restore(flags);
4370 4371
}

4372 4373 4374 4375 4376 4377
/* By default: disable tracing after the dump */
void ftrace_dump(void)
{
	__ftrace_dump(true);
}

4378
__init static int tracer_alloc_buffers(void)
4379
{
4380
	int ring_buf_size;
4381
	int i;
4382
	int ret = -ENOMEM;
4383

4384 4385 4386 4387 4388
	if (!alloc_cpumask_var(&tracing_buffer_mask, GFP_KERNEL))
		goto out;

	if (!alloc_cpumask_var(&tracing_cpumask, GFP_KERNEL))
		goto out_free_buffer_mask;
4389

4390
	if (!zalloc_cpumask_var(&tracing_reader_cpumask, GFP_KERNEL))
4391 4392
		goto out_free_tracing_cpumask;

4393 4394 4395 4396 4397 4398
	/* To save memory, keep the ring buffer size to its minimum */
	if (ring_buffer_expanded)
		ring_buf_size = trace_buf_size;
	else
		ring_buf_size = 1;

4399 4400 4401 4402
	cpumask_copy(tracing_buffer_mask, cpu_possible_mask);
	cpumask_copy(tracing_cpumask, cpu_all_mask);

	/* TODO: make the number of buffers hot pluggable with CPUS */
4403
	global_trace.buffer = ring_buffer_alloc(ring_buf_size,
4404 4405 4406 4407
						   TRACE_BUFFER_FLAGS);
	if (!global_trace.buffer) {
		printk(KERN_ERR "tracer: failed to allocate ring buffer!\n");
		WARN_ON(1);
4408
		goto out_free_cpumask;
4409
	}
4410
	global_trace.entries = ring_buffer_size(global_trace.buffer);
4411

4412

4413
#ifdef CONFIG_TRACER_MAX_TRACE
4414
	max_tr.buffer = ring_buffer_alloc(ring_buf_size,
4415 4416 4417 4418 4419
					     TRACE_BUFFER_FLAGS);
	if (!max_tr.buffer) {
		printk(KERN_ERR "tracer: failed to allocate max ring buffer!\n");
		WARN_ON(1);
		ring_buffer_free(global_trace.buffer);
4420
		goto out_free_cpumask;
4421
	}
4422 4423
	max_tr.entries = ring_buffer_size(max_tr.buffer);
	WARN_ON(max_tr.entries != global_trace.entries);
4424
#endif
4425

4426
	/* Allocate the first page for all buffers */
4427
	for_each_tracing_cpu(i) {
4428
		global_trace.data[i] = &per_cpu(global_trace_cpu, i);
4429
		max_tr.data[i] = &per_cpu(max_tr_data, i);
4430
	}
4431 4432 4433

	trace_init_cmdlines();

4434
	register_tracer(&nop_trace);
4435
	current_trace = &nop_trace;
4436 4437 4438
#ifdef CONFIG_BOOT_TRACER
	register_tracer(&boot_tracer);
#endif
S
Steven Rostedt 已提交
4439 4440
	/* All seems OK, enable tracing */
	tracing_disabled = 0;
4441

4442 4443 4444 4445
	atomic_notifier_chain_register(&panic_notifier_list,
				       &trace_panic_notifier);

	register_die_notifier(&trace_die_notifier);
4446 4447

	return 0;
4448

4449
out_free_cpumask:
4450 4451
	free_cpumask_var(tracing_reader_cpumask);
out_free_tracing_cpumask:
4452 4453 4454 4455 4456
	free_cpumask_var(tracing_cpumask);
out_free_buffer_mask:
	free_cpumask_var(tracing_buffer_mask);
out:
	return ret;
4457
}
4458 4459 4460 4461 4462 4463 4464 4465 4466 4467 4468 4469 4470 4471 4472 4473 4474 4475 4476 4477

__init static int clear_boot_tracer(void)
{
	/*
	 * The default tracer at boot buffer is an init section.
	 * This function is called in lateinit. If we did not
	 * find the boot tracer, then clear it out, to prevent
	 * later registration from accessing the buffer that is
	 * about to be freed.
	 */
	if (!default_bootup_tracer)
		return 0;

	printk(KERN_INFO "ftrace bootup tracer '%s' not registered.\n",
	       default_bootup_tracer);
	default_bootup_tracer = NULL;

	return 0;
}

4478 4479
early_initcall(tracer_alloc_buffers);
fs_initcall(tracer_init_debugfs);
4480
late_initcall(clear_boot_tracer);