34 static struct task_struct *consumer;  variable
55 MODULE_PARM_DESC(consumer_nice, "nice prio for consumer");
61 MODULE_PARM_DESC(consumer_fifo, "use fifo for consumer: 0 - disabled, 1 - low prio, 2 - fifo");
269 		if (consumer && !(cnt % wakeup_interval))  in ring_buffer_producer()
270 			wake_up_process(consumer);  in ring_buffer_producer()
288 	if (consumer) {  in ring_buffer_producer()
295 		wake_up_process(consumer);  in ring_buffer_producer()
309 			trace_printk("Running Consumer at SCHED_FIFO %s\n",  in ring_buffer_producer()
312 			trace_printk("Running Consumer at nice: %d\n",  in ring_buffer_producer()
408 		if (consumer) {  in ring_buffer_producer_thread()
409 			wake_up_process(consumer);  in ring_buffer_producer_thread()
442 		consumer = kthread_create(ring_buffer_consumer_thread,  in ring_buffer_benchmark_init()
444 		ret = PTR_ERR(consumer);  in ring_buffer_benchmark_init()
445 		if (IS_ERR(consumer))  in ring_buffer_benchmark_init()
461 			sched_set_fifo(consumer);  in ring_buffer_benchmark_init()
463 			sched_set_fifo_low(consumer);  in ring_buffer_benchmark_init()
465 			set_user_nice(consumer, consumer_nice);  in ring_buffer_benchmark_init()
478 	if (consumer)  in ring_buffer_benchmark_init()
479 		kthread_stop(consumer);  in ring_buffer_benchmark_init()
489 	if (consumer)  in ring_buffer_benchmark_exit()
490 		kthread_stop(consumer);  in ring_buffer_benchmark_exit()