2009-05-06 06:47:18 +04:00
|
|
|
/*
|
|
|
|
* ring buffer tester and benchmark
|
|
|
|
*
|
|
|
|
* Copyright (C) 2009 Steven Rostedt <srostedt@redhat.com>
|
|
|
|
*/
|
|
|
|
#include <linux/ring_buffer.h>
|
|
|
|
#include <linux/completion.h>
|
|
|
|
#include <linux/kthread.h>
|
|
|
|
#include <linux/module.h>
|
|
|
|
#include <linux/time.h>
|
2010-01-05 09:34:50 +03:00
|
|
|
#include <asm/local.h>
|
2009-05-06 06:47:18 +04:00
|
|
|
|
|
|
|
struct rb_page {
|
|
|
|
u64 ts;
|
|
|
|
local_t commit;
|
|
|
|
char data[4080];
|
|
|
|
};
|
|
|
|
|
|
|
|
/* run time and sleep time in seconds */
|
|
|
|
#define RUN_TIME 10
|
|
|
|
#define SLEEP_TIME 10
|
|
|
|
|
|
|
|
/* number of events for writer to wake up the reader */
|
|
|
|
static int wakeup_interval = 100;
|
|
|
|
|
|
|
|
static int reader_finish;
|
|
|
|
static struct completion read_start;
|
|
|
|
static struct completion read_done;
|
|
|
|
|
|
|
|
static struct ring_buffer *buffer;
|
|
|
|
static struct task_struct *producer;
|
|
|
|
static struct task_struct *consumer;
|
|
|
|
static unsigned long read;
|
|
|
|
|
|
|
|
static int disable_reader;
|
|
|
|
module_param(disable_reader, uint, 0644);
|
|
|
|
MODULE_PARM_DESC(disable_reader, "only run producer");
|
|
|
|
|
2009-11-12 01:14:07 +03:00
|
|
|
static int write_iteration = 50;
|
|
|
|
module_param(write_iteration, uint, 0644);
|
|
|
|
MODULE_PARM_DESC(write_iteration, "# of writes between timestamp readings");
|
|
|
|
|
2009-11-25 21:22:21 +03:00
|
|
|
static int producer_nice = 19;
|
|
|
|
static int consumer_nice = 19;
|
|
|
|
|
|
|
|
static int producer_fifo = -1;
|
|
|
|
static int consumer_fifo = -1;
|
|
|
|
|
|
|
|
module_param(producer_nice, uint, 0644);
|
|
|
|
MODULE_PARM_DESC(producer_nice, "nice prio for producer");
|
|
|
|
|
|
|
|
module_param(consumer_nice, uint, 0644);
|
|
|
|
MODULE_PARM_DESC(consumer_nice, "nice prio for consumer");
|
|
|
|
|
|
|
|
module_param(producer_fifo, uint, 0644);
|
|
|
|
MODULE_PARM_DESC(producer_fifo, "fifo prio for producer");
|
|
|
|
|
|
|
|
module_param(consumer_fifo, uint, 0644);
|
|
|
|
MODULE_PARM_DESC(consumer_fifo, "fifo prio for consumer");
|
|
|
|
|
2009-05-06 06:47:18 +04:00
|
|
|
static int read_events;
|
|
|
|
|
|
|
|
static int kill_test;
|
|
|
|
|
|
|
|
#define KILL_TEST() \
|
|
|
|
do { \
|
|
|
|
if (!kill_test) { \
|
|
|
|
kill_test = 1; \
|
|
|
|
WARN_ON(1); \
|
|
|
|
} \
|
|
|
|
} while (0)
|
|
|
|
|
|
|
|
enum event_status {
|
|
|
|
EVENT_FOUND,
|
|
|
|
EVENT_DROPPED,
|
|
|
|
};
|
|
|
|
|
|
|
|
static enum event_status read_event(int cpu)
|
|
|
|
{
|
|
|
|
struct ring_buffer_event *event;
|
|
|
|
int *entry;
|
|
|
|
u64 ts;
|
|
|
|
|
ring-buffer: Add place holder recording of dropped events
Currently, when the ring buffer drops events, it does not record
the fact that it did so. It does inform the writer that the event
was dropped by returning a NULL event, but it does not put in any
place holder where the event was dropped.
This is not a trivial thing to add because the ring buffer mostly
runs in overwrite (flight recorder) mode. That is, when the ring
buffer is full, new data will overwrite old data.
In a produce/consumer mode, where new data is simply dropped when
the ring buffer is full, it is trivial to add the placeholder
for dropped events. When there's more room to write new data, then
a special event can be added to notify the reader about the dropped
events.
But in overwrite mode, any new write can overwrite events. A place
holder can not be inserted into the ring buffer since there never
may be room. A reader could also come in at anytime and miss the
placeholder.
Luckily, the way the ring buffer works, the read side can find out
if events were lost or not, and how many events. Everytime a write
takes place, if it overwrites the header page (the next read) it
updates a "overrun" variable that keeps track of the number of
lost events. When a reader swaps out a page from the ring buffer,
it can record this number, perfom the swap, and then check to
see if the number changed, and take the diff if it has, which would be
the number of events dropped. This can be stored by the reader
and returned to callers of the reader.
Since the reader page swap will fail if the writer moved the head
page since the time the reader page set up the swap, this gives room
to record the overruns without worrying about races. If the reader
sets up the pages, records the overrun, than performs the swap,
if the swap succeeds, then the overrun variable has not been
updated since the setup before the swap.
For binary readers of the ring buffer, a flag is set in the header
of each sub page (sub buffer) of the ring buffer. This flag is embedded
in the size field of the data on the sub buffer, in the 31st bit (the size
can be 32 or 64 bits depending on the architecture), but only 27
bits needs to be used for the actual size (less actually).
We could add a new field in the sub buffer header to also record the
number of events dropped since the last read, but this will change the
format of the binary ring buffer a bit too much. Perhaps this change can
be made if the information on the number of events dropped is considered
important enough.
Note, the notification of dropped events is only used by consuming reads
or peeking at the ring buffer. Iterating over the ring buffer does not
keep this information because the necessary data is only available when
a page swap is made, and the iterator does not swap out pages.
Cc: Robert Richter <robert.richter@amd.com>
Cc: Andi Kleen <andi@firstfloor.org>
Cc: Li Zefan <lizf@cn.fujitsu.com>
Cc: Arnaldo Carvalho de Melo <acme@redhat.com>
Cc: "Luis Claudio R. Goncalves" <lclaudio@uudg.org>
Cc: Frederic Weisbecker <fweisbec@gmail.com>
Signed-off-by: Steven Rostedt <rostedt@goodmis.org>
2010-03-31 21:21:56 +04:00
|
|
|
event = ring_buffer_consume(buffer, cpu, &ts, NULL);
|
2009-05-06 06:47:18 +04:00
|
|
|
if (!event)
|
|
|
|
return EVENT_DROPPED;
|
|
|
|
|
|
|
|
entry = ring_buffer_event_data(event);
|
|
|
|
if (*entry != cpu) {
|
|
|
|
KILL_TEST();
|
|
|
|
return EVENT_DROPPED;
|
|
|
|
}
|
|
|
|
|
|
|
|
read++;
|
|
|
|
return EVENT_FOUND;
|
|
|
|
}
|
|
|
|
|
|
|
|
static enum event_status read_page(int cpu)
|
|
|
|
{
|
|
|
|
struct ring_buffer_event *event;
|
|
|
|
struct rb_page *rpage;
|
|
|
|
unsigned long commit;
|
|
|
|
void *bpage;
|
|
|
|
int *entry;
|
|
|
|
int ret;
|
|
|
|
int inc;
|
|
|
|
int i;
|
|
|
|
|
2011-05-04 04:56:42 +04:00
|
|
|
bpage = ring_buffer_alloc_read_page(buffer, cpu);
|
2009-05-06 20:40:51 +04:00
|
|
|
if (!bpage)
|
|
|
|
return EVENT_DROPPED;
|
|
|
|
|
2009-05-06 06:47:18 +04:00
|
|
|
ret = ring_buffer_read_page(buffer, &bpage, PAGE_SIZE, cpu, 1);
|
|
|
|
if (ret >= 0) {
|
|
|
|
rpage = bpage;
|
2010-04-27 21:26:58 +04:00
|
|
|
/* The commit may have missed event flags set, clear them */
|
|
|
|
commit = local_read(&rpage->commit) & 0xfffff;
|
2009-05-06 06:47:18 +04:00
|
|
|
for (i = 0; i < commit && !kill_test; i += inc) {
|
|
|
|
|
|
|
|
if (i >= (PAGE_SIZE - offsetof(struct rb_page, data))) {
|
|
|
|
KILL_TEST();
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
|
|
|
|
inc = -1;
|
|
|
|
event = (void *)&rpage->data[i];
|
|
|
|
switch (event->type_len) {
|
|
|
|
case RINGBUF_TYPE_PADDING:
|
2009-06-16 19:46:09 +04:00
|
|
|
/* failed writes may be discarded events */
|
|
|
|
if (!event->time_delta)
|
|
|
|
KILL_TEST();
|
|
|
|
inc = event->array[0] + 4;
|
2009-05-06 06:47:18 +04:00
|
|
|
break;
|
|
|
|
case RINGBUF_TYPE_TIME_EXTEND:
|
|
|
|
inc = 8;
|
|
|
|
break;
|
|
|
|
case 0:
|
|
|
|
entry = ring_buffer_event_data(event);
|
|
|
|
if (*entry != cpu) {
|
|
|
|
KILL_TEST();
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
read++;
|
|
|
|
if (!event->array[0]) {
|
|
|
|
KILL_TEST();
|
|
|
|
break;
|
|
|
|
}
|
2009-06-16 19:46:09 +04:00
|
|
|
inc = event->array[0] + 4;
|
2009-05-06 06:47:18 +04:00
|
|
|
break;
|
|
|
|
default:
|
|
|
|
entry = ring_buffer_event_data(event);
|
|
|
|
if (*entry != cpu) {
|
|
|
|
KILL_TEST();
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
read++;
|
|
|
|
inc = ((event->type_len + 1) * 4);
|
|
|
|
}
|
|
|
|
if (kill_test)
|
|
|
|
break;
|
|
|
|
|
|
|
|
if (inc <= 0) {
|
|
|
|
KILL_TEST();
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
ring_buffer_free_read_page(buffer, bpage);
|
|
|
|
|
|
|
|
if (ret < 0)
|
|
|
|
return EVENT_DROPPED;
|
|
|
|
return EVENT_FOUND;
|
|
|
|
}
|
|
|
|
|
|
|
|
static void ring_buffer_consumer(void)
|
|
|
|
{
|
|
|
|
/* toggle between reading pages and events */
|
|
|
|
read_events ^= 1;
|
|
|
|
|
|
|
|
read = 0;
|
|
|
|
while (!reader_finish && !kill_test) {
|
|
|
|
int found;
|
|
|
|
|
|
|
|
do {
|
|
|
|
int cpu;
|
|
|
|
|
|
|
|
found = 0;
|
|
|
|
for_each_online_cpu(cpu) {
|
|
|
|
enum event_status stat;
|
|
|
|
|
|
|
|
if (read_events)
|
|
|
|
stat = read_event(cpu);
|
|
|
|
else
|
|
|
|
stat = read_page(cpu);
|
|
|
|
|
|
|
|
if (kill_test)
|
|
|
|
break;
|
|
|
|
if (stat == EVENT_FOUND)
|
|
|
|
found = 1;
|
|
|
|
}
|
|
|
|
} while (found && !kill_test);
|
|
|
|
|
|
|
|
set_current_state(TASK_INTERRUPTIBLE);
|
|
|
|
if (reader_finish)
|
|
|
|
break;
|
|
|
|
|
|
|
|
schedule();
|
|
|
|
__set_current_state(TASK_RUNNING);
|
|
|
|
}
|
|
|
|
reader_finish = 0;
|
|
|
|
complete(&read_done);
|
|
|
|
}
|
|
|
|
|
|
|
|
static void ring_buffer_producer(void)
|
|
|
|
{
|
|
|
|
struct timeval start_tv;
|
|
|
|
struct timeval end_tv;
|
|
|
|
unsigned long long time;
|
|
|
|
unsigned long long entries;
|
|
|
|
unsigned long long overruns;
|
|
|
|
unsigned long missed = 0;
|
|
|
|
unsigned long hit = 0;
|
|
|
|
unsigned long avg;
|
|
|
|
int cnt = 0;
|
|
|
|
|
|
|
|
/*
|
|
|
|
* Hammer the buffer for 10 secs (this may
|
|
|
|
* make the system stall)
|
|
|
|
*/
|
2009-06-18 01:01:09 +04:00
|
|
|
trace_printk("Starting ring buffer hammer\n");
|
2009-05-06 06:47:18 +04:00
|
|
|
do_gettimeofday(&start_tv);
|
|
|
|
do {
|
|
|
|
struct ring_buffer_event *event;
|
|
|
|
int *entry;
|
2009-11-12 01:14:07 +03:00
|
|
|
int i;
|
|
|
|
|
|
|
|
for (i = 0; i < write_iteration; i++) {
|
|
|
|
event = ring_buffer_lock_reserve(buffer, 10);
|
|
|
|
if (!event) {
|
|
|
|
missed++;
|
|
|
|
} else {
|
|
|
|
hit++;
|
|
|
|
entry = ring_buffer_event_data(event);
|
|
|
|
*entry = smp_processor_id();
|
|
|
|
ring_buffer_unlock_commit(buffer, event);
|
|
|
|
}
|
2009-05-06 06:47:18 +04:00
|
|
|
}
|
|
|
|
do_gettimeofday(&end_tv);
|
|
|
|
|
2009-05-07 22:20:28 +04:00
|
|
|
cnt++;
|
|
|
|
if (consumer && !(cnt % wakeup_interval))
|
2009-05-06 06:47:18 +04:00
|
|
|
wake_up_process(consumer);
|
|
|
|
|
2009-05-07 22:20:28 +04:00
|
|
|
#ifndef CONFIG_PREEMPT
|
2009-05-07 19:13:42 +04:00
|
|
|
/*
|
|
|
|
* If we are a non preempt kernel, the 10 second run will
|
|
|
|
* stop everything while it runs. Instead, we will call
|
|
|
|
* cond_resched and also add any time that was lost by a
|
|
|
|
* rescedule.
|
2009-05-07 22:20:28 +04:00
|
|
|
*
|
|
|
|
* Do a cond resched at the same frequency we would wake up
|
|
|
|
* the reader.
|
2009-05-07 19:13:42 +04:00
|
|
|
*/
|
2009-05-07 22:20:28 +04:00
|
|
|
if (cnt % wakeup_interval)
|
|
|
|
cond_resched();
|
|
|
|
#endif
|
2009-05-07 02:36:59 +04:00
|
|
|
|
2009-05-06 06:47:18 +04:00
|
|
|
} while (end_tv.tv_sec < (start_tv.tv_sec + RUN_TIME) && !kill_test);
|
2009-06-18 01:01:09 +04:00
|
|
|
trace_printk("End ring buffer hammer\n");
|
2009-05-06 06:47:18 +04:00
|
|
|
|
|
|
|
if (consumer) {
|
|
|
|
/* Init both completions here to avoid races */
|
|
|
|
init_completion(&read_start);
|
|
|
|
init_completion(&read_done);
|
|
|
|
/* the completions must be visible before the finish var */
|
|
|
|
smp_wmb();
|
|
|
|
reader_finish = 1;
|
|
|
|
/* finish var visible before waking up the consumer */
|
|
|
|
smp_wmb();
|
|
|
|
wake_up_process(consumer);
|
|
|
|
wait_for_completion(&read_done);
|
|
|
|
}
|
|
|
|
|
|
|
|
time = end_tv.tv_sec - start_tv.tv_sec;
|
2009-05-08 18:56:33 +04:00
|
|
|
time *= USEC_PER_SEC;
|
2009-05-06 06:47:18 +04:00
|
|
|
time += (long long)((long)end_tv.tv_usec - (long)start_tv.tv_usec);
|
|
|
|
|
|
|
|
entries = ring_buffer_entries(buffer);
|
|
|
|
overruns = ring_buffer_overruns(buffer);
|
|
|
|
|
|
|
|
if (kill_test)
|
2009-06-18 01:01:09 +04:00
|
|
|
trace_printk("ERROR!\n");
|
2009-11-25 21:22:21 +03:00
|
|
|
|
|
|
|
if (!disable_reader) {
|
|
|
|
if (consumer_fifo < 0)
|
|
|
|
trace_printk("Running Consumer at nice: %d\n",
|
|
|
|
consumer_nice);
|
|
|
|
else
|
|
|
|
trace_printk("Running Consumer at SCHED_FIFO %d\n",
|
|
|
|
consumer_fifo);
|
|
|
|
}
|
|
|
|
if (producer_fifo < 0)
|
|
|
|
trace_printk("Running Producer at nice: %d\n",
|
|
|
|
producer_nice);
|
|
|
|
else
|
|
|
|
trace_printk("Running Producer at SCHED_FIFO %d\n",
|
|
|
|
producer_fifo);
|
|
|
|
|
|
|
|
/* Let the user know that the test is running at low priority */
|
|
|
|
if (producer_fifo < 0 && consumer_fifo < 0 &&
|
|
|
|
producer_nice == 19 && consumer_nice == 19)
|
|
|
|
trace_printk("WARNING!!! This test is running at lowest priority.\n");
|
|
|
|
|
2009-06-18 01:01:09 +04:00
|
|
|
trace_printk("Time: %lld (usecs)\n", time);
|
|
|
|
trace_printk("Overruns: %lld\n", overruns);
|
2009-05-06 06:47:18 +04:00
|
|
|
if (disable_reader)
|
2009-06-18 01:01:09 +04:00
|
|
|
trace_printk("Read: (reader disabled)\n");
|
2009-05-06 06:47:18 +04:00
|
|
|
else
|
2009-06-18 01:01:09 +04:00
|
|
|
trace_printk("Read: %ld (by %s)\n", read,
|
2009-05-06 06:47:18 +04:00
|
|
|
read_events ? "events" : "pages");
|
2009-06-18 01:01:09 +04:00
|
|
|
trace_printk("Entries: %lld\n", entries);
|
|
|
|
trace_printk("Total: %lld\n", entries + overruns + read);
|
|
|
|
trace_printk("Missed: %ld\n", missed);
|
|
|
|
trace_printk("Hit: %ld\n", hit);
|
2009-05-06 06:47:18 +04:00
|
|
|
|
2009-05-08 18:56:33 +04:00
|
|
|
/* Convert time from usecs to millisecs */
|
|
|
|
do_div(time, USEC_PER_MSEC);
|
2009-05-06 06:47:18 +04:00
|
|
|
if (time)
|
|
|
|
hit /= (long)time;
|
|
|
|
else
|
2009-06-18 01:01:09 +04:00
|
|
|
trace_printk("TIME IS ZERO??\n");
|
2009-05-06 06:47:18 +04:00
|
|
|
|
2009-06-18 01:01:09 +04:00
|
|
|
trace_printk("Entries per millisec: %ld\n", hit);
|
2009-05-06 06:47:18 +04:00
|
|
|
|
|
|
|
if (hit) {
|
2009-05-08 18:56:33 +04:00
|
|
|
/* Calculate the average time in nanosecs */
|
|
|
|
avg = NSEC_PER_MSEC / hit;
|
2009-06-18 01:01:09 +04:00
|
|
|
trace_printk("%ld ns per entry\n", avg);
|
2009-05-06 06:47:18 +04:00
|
|
|
}
|
2009-05-08 03:52:20 +04:00
|
|
|
|
|
|
|
if (missed) {
|
|
|
|
if (time)
|
|
|
|
missed /= (long)time;
|
|
|
|
|
2009-06-18 01:01:09 +04:00
|
|
|
trace_printk("Total iterations per millisec: %ld\n",
|
|
|
|
hit + missed);
|
2009-05-08 03:52:20 +04:00
|
|
|
|
2009-05-08 19:03:57 +04:00
|
|
|
/* it is possible that hit + missed will overflow and be zero */
|
|
|
|
if (!(hit + missed)) {
|
2009-06-18 01:01:09 +04:00
|
|
|
trace_printk("hit + missed overflowed and totalled zero!\n");
|
2009-05-08 19:03:57 +04:00
|
|
|
hit--; /* make it non zero */
|
|
|
|
}
|
|
|
|
|
2009-05-08 18:56:33 +04:00
|
|
|
/* Caculate the average time in nanosecs */
|
|
|
|
avg = NSEC_PER_MSEC / (hit + missed);
|
2009-06-18 01:01:09 +04:00
|
|
|
trace_printk("%ld ns per entry\n", avg);
|
2009-05-08 03:52:20 +04:00
|
|
|
}
|
2009-05-06 06:47:18 +04:00
|
|
|
}
|
|
|
|
|
|
|
|
static void wait_to_die(void)
|
|
|
|
{
|
|
|
|
set_current_state(TASK_INTERRUPTIBLE);
|
|
|
|
while (!kthread_should_stop()) {
|
|
|
|
schedule();
|
|
|
|
set_current_state(TASK_INTERRUPTIBLE);
|
|
|
|
}
|
|
|
|
__set_current_state(TASK_RUNNING);
|
|
|
|
}
|
|
|
|
|
|
|
|
static int ring_buffer_consumer_thread(void *arg)
|
|
|
|
{
|
|
|
|
while (!kthread_should_stop() && !kill_test) {
|
|
|
|
complete(&read_start);
|
|
|
|
|
|
|
|
ring_buffer_consumer();
|
|
|
|
|
|
|
|
set_current_state(TASK_INTERRUPTIBLE);
|
|
|
|
if (kthread_should_stop() || kill_test)
|
|
|
|
break;
|
|
|
|
|
|
|
|
schedule();
|
|
|
|
__set_current_state(TASK_RUNNING);
|
|
|
|
}
|
|
|
|
__set_current_state(TASK_RUNNING);
|
|
|
|
|
|
|
|
if (kill_test)
|
|
|
|
wait_to_die();
|
|
|
|
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
static int ring_buffer_producer_thread(void *arg)
|
|
|
|
{
|
|
|
|
init_completion(&read_start);
|
|
|
|
|
|
|
|
while (!kthread_should_stop() && !kill_test) {
|
|
|
|
ring_buffer_reset(buffer);
|
|
|
|
|
|
|
|
if (consumer) {
|
|
|
|
smp_wmb();
|
|
|
|
wake_up_process(consumer);
|
|
|
|
wait_for_completion(&read_start);
|
|
|
|
}
|
|
|
|
|
|
|
|
ring_buffer_producer();
|
|
|
|
|
2009-06-18 01:01:09 +04:00
|
|
|
trace_printk("Sleeping for 10 secs\n");
|
2009-05-06 06:47:18 +04:00
|
|
|
set_current_state(TASK_INTERRUPTIBLE);
|
|
|
|
schedule_timeout(HZ * SLEEP_TIME);
|
|
|
|
__set_current_state(TASK_RUNNING);
|
|
|
|
}
|
|
|
|
|
|
|
|
if (kill_test)
|
|
|
|
wait_to_die();
|
|
|
|
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
static int __init ring_buffer_benchmark_init(void)
|
|
|
|
{
|
|
|
|
int ret;
|
|
|
|
|
|
|
|
/* make a one meg buffer in overwite mode */
|
|
|
|
buffer = ring_buffer_alloc(1000000, RB_FL_OVERWRITE);
|
|
|
|
if (!buffer)
|
|
|
|
return -ENOMEM;
|
|
|
|
|
|
|
|
if (!disable_reader) {
|
|
|
|
consumer = kthread_create(ring_buffer_consumer_thread,
|
|
|
|
NULL, "rb_consumer");
|
|
|
|
ret = PTR_ERR(consumer);
|
|
|
|
if (IS_ERR(consumer))
|
|
|
|
goto out_fail;
|
|
|
|
}
|
|
|
|
|
|
|
|
producer = kthread_run(ring_buffer_producer_thread,
|
|
|
|
NULL, "rb_producer");
|
|
|
|
ret = PTR_ERR(producer);
|
|
|
|
|
|
|
|
if (IS_ERR(producer))
|
|
|
|
goto out_kill;
|
|
|
|
|
2009-11-23 10:03:09 +03:00
|
|
|
/*
|
|
|
|
* Run them as low-prio background tasks by default:
|
|
|
|
*/
|
2009-11-25 21:22:21 +03:00
|
|
|
if (!disable_reader) {
|
|
|
|
if (consumer_fifo >= 0) {
|
|
|
|
struct sched_param param = {
|
|
|
|
.sched_priority = consumer_fifo
|
|
|
|
};
|
|
|
|
sched_setscheduler(consumer, SCHED_FIFO, ¶m);
|
|
|
|
} else
|
|
|
|
set_user_nice(consumer, consumer_nice);
|
|
|
|
}
|
|
|
|
|
|
|
|
if (producer_fifo >= 0) {
|
|
|
|
struct sched_param param = {
|
|
|
|
.sched_priority = consumer_fifo
|
|
|
|
};
|
|
|
|
sched_setscheduler(producer, SCHED_FIFO, ¶m);
|
|
|
|
} else
|
|
|
|
set_user_nice(producer, producer_nice);
|
2009-11-23 10:03:09 +03:00
|
|
|
|
2009-05-06 06:47:18 +04:00
|
|
|
return 0;
|
|
|
|
|
|
|
|
out_kill:
|
|
|
|
if (consumer)
|
|
|
|
kthread_stop(consumer);
|
|
|
|
|
|
|
|
out_fail:
|
|
|
|
ring_buffer_free(buffer);
|
|
|
|
return ret;
|
|
|
|
}
|
|
|
|
|
|
|
|
static void __exit ring_buffer_benchmark_exit(void)
|
|
|
|
{
|
|
|
|
kthread_stop(producer);
|
|
|
|
if (consumer)
|
|
|
|
kthread_stop(consumer);
|
|
|
|
ring_buffer_free(buffer);
|
|
|
|
}
|
|
|
|
|
|
|
|
module_init(ring_buffer_benchmark_init);
|
|
|
|
module_exit(ring_buffer_benchmark_exit);
|
|
|
|
|
|
|
|
MODULE_AUTHOR("Steven Rostedt");
|
|
|
|
MODULE_DESCRIPTION("ring_buffer_benchmark");
|
|
|
|
MODULE_LICENSE("GPL");
|