Lines Matching refs:consumer
32 static struct task_struct *consumer; variable
265 if (consumer && !(cnt % wakeup_interval)) in ring_buffer_producer()
266 wake_up_process(consumer); in ring_buffer_producer()
284 if (consumer) { in ring_buffer_producer()
291 wake_up_process(consumer); in ring_buffer_producer()
404 if (consumer) { in ring_buffer_producer_thread()
405 wake_up_process(consumer); in ring_buffer_producer_thread()
438 consumer = kthread_create(ring_buffer_consumer_thread, in ring_buffer_benchmark_init()
440 ret = PTR_ERR(consumer); in ring_buffer_benchmark_init()
441 if (IS_ERR(consumer)) in ring_buffer_benchmark_init()
460 sched_setscheduler(consumer, SCHED_FIFO, ¶m); in ring_buffer_benchmark_init()
462 set_user_nice(consumer, consumer_nice); in ring_buffer_benchmark_init()
476 if (consumer) in ring_buffer_benchmark_init()
477 kthread_stop(consumer); in ring_buffer_benchmark_init()
487 if (consumer) in ring_buffer_benchmark_exit()
488 kthread_stop(consumer); in ring_buffer_benchmark_exit()