Lines Matching refs:consumer
34 static struct task_struct *consumer; variable
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()
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()