Lines Matching refs:consumer
32 static struct task_struct *consumer; variable
250 if (consumer && !(cnt % wakeup_interval)) in ring_buffer_producer()
251 wake_up_process(consumer); in ring_buffer_producer()
270 if (consumer) { in ring_buffer_producer()
279 wake_up_process(consumer); in ring_buffer_producer()
395 if (consumer) { in ring_buffer_producer_thread()
397 wake_up_process(consumer); in ring_buffer_producer_thread()
424 consumer = kthread_create(ring_buffer_consumer_thread, in ring_buffer_benchmark_init()
426 ret = PTR_ERR(consumer); in ring_buffer_benchmark_init()
427 if (IS_ERR(consumer)) in ring_buffer_benchmark_init()
446 sched_setscheduler(consumer, SCHED_FIFO, ¶m); in ring_buffer_benchmark_init()
448 set_user_nice(consumer, consumer_nice); in ring_buffer_benchmark_init()
462 if (consumer) in ring_buffer_benchmark_init()
463 kthread_stop(consumer); in ring_buffer_benchmark_init()
473 if (consumer) in ring_buffer_benchmark_exit()
474 kthread_stop(consumer); in ring_buffer_benchmark_exit()