Searched refs:worker (Results 1 – 5 of 5) sorted by relevance
| /kernel/ |
| D | kthread.c | 552 void __init_kthread_worker(struct kthread_worker *worker, in __init_kthread_worker() argument
556 spin_lock_init(&worker->lock); in __init_kthread_worker()
557 lockdep_set_class_and_name(&worker->lock, key, name); in __init_kthread_worker()
558 INIT_LIST_HEAD(&worker->work_list); in __init_kthread_worker()
559 worker->task = NULL; in __init_kthread_worker()
580 struct kthread_worker *worker = worker_ptr; in kthread_worker_fn() local
583 WARN_ON(worker->task); in kthread_worker_fn()
584 worker->task = current; in kthread_worker_fn()
590 spin_lock_irq(&worker->lock); in kthread_worker_fn()
591 worker->task = NULL; in kthread_worker_fn()
[all …]
|
| D | workqueue.c | 167 struct worker *manager; /* L: purely informational */
250 struct worker *rescuer; /* I: rescue worker */
389 #define for_each_pool_worker(worker, pool) \ argument
390 list_for_each_entry((worker), &(pool)->workers, node) \
824 static struct worker *first_idle_worker(struct worker_pool *pool) in first_idle_worker()
829 return list_first_entry(&pool->idle_list, struct worker, entry); in first_idle_worker()
843 struct worker *worker = first_idle_worker(pool); in wake_up_worker() local
845 if (likely(worker)) in wake_up_worker()
846 wake_up_process(worker->task); in wake_up_worker()
862 struct worker *worker = kthread_data(task); in wq_worker_waking_up() local
[all …]
|
| D | async.c | 329 struct worker *worker = current_wq_worker(); in current_is_async() local
331 return worker && worker->current_func == async_run_entry_fn; in current_is_async()
|
| D | workqueue_internal.h | 23 struct worker { struct
61 static inline struct worker *current_wq_worker(void) in current_wq_worker()
|
| /kernel/sched/ |
| D | cpufreq_schedutil.c | 56 struct kthread_worker worker; member
436 queue_kthread_work(&sg_policy->worker, &sg_policy->work); in sugov_irq_work()
563 init_kthread_worker(&sg_policy->worker); in sugov_kthread_create()
564 thread = kthread_create(kthread_worker_fn, &sg_policy->worker, in sugov_kthread_create()
595 flush_kthread_worker(&sg_policy->worker); in sugov_kthread_stop()
|