adulau/aha
1
0
Fork 0
mirror of https://github.com/adulau/aha.git synced 2024-12-29 12:16:20 +00:00
Code Issues Projects Releases Packages Wiki Activity

ftrace: make use of tracing_cpumask

Browse source 
Signed-off-by: Ingo Molnar <mingo@elte.hu>
Signed-off-by: Thomas Gleixner <tglx@linutronix.de>
This commit is contained in:
Ingo Molnar 2008-05-12 21:20:52 +02:00 committed by Thomas Gleixner
parent c7078de1aa
commit 36dfe9252b
1 changed files with 64 additions and 31 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

95
kernel/trace/trace.c
View file

@ -70,23 +70,6 @@ static DECLARE_WAIT_QUEUE_HEAD(trace_wait);
unsigned long trace_flags = TRACE_ITER_PRINT_PARENT; unsigned long trace_flags = TRACE_ITER_PRINT_PARENT;
/*
* Only trace on a CPU if the bitmask is set:
*/
static cpumask_t tracing_cpumask __read_mostly = CPU_MASK_ALL;
/*
* 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:
*/
static char mask_str[NR_CPUS];
void trace_wake_up(void) void trace_wake_up(void)
{ {
/* /*
@ -1776,19 +1759,46 @@ static struct file_operations show_traces_fops = {
.release = seq_release, .release = seq_release,
}; };
/*
* Only trace on a CPU if the bitmask is set:
*/
static cpumask_t tracing_cpumask = CPU_MASK_ALL;
/*
* When tracing/tracing_cpu_mask is modified then this holds
* the new bitmask we are about to install:
*/
static cpumask_t tracing_cpumask_new;
/*
* 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];
static ssize_t static ssize_t
tracing_cpumask_read(struct file *filp, char __user *ubuf, tracing_cpumask_read(struct file *filp, char __user *ubuf,
size_t count, loff_t *ppos) size_t count, loff_t *ppos)
{ {
int err; int len;
count = min(count, (size_t)NR_CPUS);
mutex_lock(&tracing_cpumask_update_lock); mutex_lock(&tracing_cpumask_update_lock);
cpumask_scnprintf(mask_str, NR_CPUS, tracing_cpumask);
err = copy_to_user(ubuf, mask_str, count); len = cpumask_scnprintf(mask_str, count, tracing_cpumask);
if (err) if (count - len < 2) {
count = -EFAULT; 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:
mutex_unlock(&tracing_cpumask_update_lock); mutex_unlock(&tracing_cpumask_update_lock);
return count; return count;
@ -1798,16 +1808,40 @@ static ssize_t
tracing_cpumask_write(struct file *filp, const char __user *ubuf, tracing_cpumask_write(struct file *filp, const char __user *ubuf,
size_t count, loff_t *ppos) size_t count, loff_t *ppos)
{ {
int err; int err, cpu;
mutex_lock(&tracing_cpumask_update_lock); mutex_lock(&tracing_cpumask_update_lock);
err = cpumask_parse_user(ubuf, count, tracing_cpumask); err = cpumask_parse_user(ubuf, count, tracing_cpumask_new);
if (err)
goto err_unlock;
spin_lock_irq(&ftrace_max_lock);
for_each_possible_cpu(cpu) {
/*
* Increase/decrease the disabled counter if we are
* about to flip a bit in the cpumask:
*/
if (cpu_isset(cpu, tracing_cpumask) &&
!cpu_isset(cpu, tracing_cpumask_new)) {
atomic_inc(&global_trace.data[cpu]->disabled);
}
if (!cpu_isset(cpu, tracing_cpumask) &&
cpu_isset(cpu, tracing_cpumask_new)) {
atomic_dec(&global_trace.data[cpu]->disabled);
}
}
spin_unlock_irq(&ftrace_max_lock);
tracing_cpumask = tracing_cpumask_new;
mutex_unlock(&tracing_cpumask_update_lock); mutex_unlock(&tracing_cpumask_update_lock);
if (err)
return err;
return count; return count;
err_unlock:
mutex_unlock(&tracing_cpumask_update_lock);
return err;
} }
static struct file_operations tracing_cpumask_fops = { static struct file_operations tracing_cpumask_fops = {
@ -1846,8 +1880,7 @@ tracing_iter_ctrl_read(struct file *filp, char __user *ubuf,
r += sprintf(buf + r, "\n"); r += sprintf(buf + r, "\n");
WARN_ON(r >= len + 2); WARN_ON(r >= len + 2);
r = simple_read_from_buffer(ubuf, cnt, ppos, r = simple_read_from_buffer(ubuf, cnt, ppos, buf, r);
buf, r);
kfree(buf); kfree(buf);