Lines Matching refs:consumer
34 static struct task_struct *consumer; variable
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()
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()
459 sched_set_fifo(consumer); in ring_buffer_benchmark_init()
461 sched_set_fifo_low(consumer); in ring_buffer_benchmark_init()
463 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()