34 static struct task_struct *consumer;  variable
55 MODULE_PARM_DESC(consumer_nice, "nice prio for consumer");
61 MODULE_PARM_DESC(consumer_fifo, "fifo prio for consumer");
267 		if (consumer && !(cnt % wakeup_interval))  in ring_buffer_producer()
268 			wake_up_process(consumer);  in ring_buffer_producer()
286 	if (consumer) {  in ring_buffer_producer()
293 		wake_up_process(consumer);  in ring_buffer_producer()
307 			trace_printk("Running Consumer at nice: %d\n",  in ring_buffer_producer()
310 			trace_printk("Running Consumer at SCHED_FIFO %d\n",  in ring_buffer_producer()
406 		if (consumer) {  in ring_buffer_producer_thread()
407 			wake_up_process(consumer);  in ring_buffer_producer_thread()
440 		consumer = kthread_create(ring_buffer_consumer_thread,  in ring_buffer_benchmark_init()
442 		ret = PTR_ERR(consumer);  in ring_buffer_benchmark_init()
443 		if (IS_ERR(consumer))  in ring_buffer_benchmark_init()
462 			sched_setscheduler(consumer, SCHED_FIFO, &param);  in ring_buffer_benchmark_init()
464 			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()