Searched refs:worker (Results 1 – 5 of 5) sorted by relevance
| /kernel/ |
| D | kthread.c | 606 void __kthread_init_worker(struct kthread_worker *worker, in __kthread_init_worker() argument
610 memset(worker, 0, sizeof(struct kthread_worker)); in __kthread_init_worker()
611 raw_spin_lock_init(&worker->lock); in __kthread_init_worker()
612 lockdep_set_class_and_name(&worker->lock, key, name); in __kthread_init_worker()
613 INIT_LIST_HEAD(&worker->work_list); in __kthread_init_worker()
614 INIT_LIST_HEAD(&worker->delayed_work_list); in __kthread_init_worker()
635 struct kthread_worker *worker = worker_ptr; in kthread_worker_fn() local
642 WARN_ON(worker->task && worker->task != current); in kthread_worker_fn()
643 worker->task = current; in kthread_worker_fn()
645 if (worker->flags & KTW_FREEZABLE) in kthread_worker_fn()
[all …]
|
| D | workqueue.c | 169 struct worker *manager; /* L: purely informational */
251 struct worker *rescuer; /* I: rescue worker */
410 #define for_each_pool_worker(worker, pool) \ argument
411 list_for_each_entry((worker), &(pool)->workers, node) \
820 static struct worker *first_idle_worker(struct worker_pool *pool) in first_idle_worker()
825 return list_first_entry(&pool->idle_list, struct worker, entry); in first_idle_worker()
839 struct worker *worker = first_idle_worker(pool); in wake_up_worker() local
841 if (likely(worker)) in wake_up_worker()
842 wake_up_process(worker->task); in wake_up_worker()
853 struct worker *worker = kthread_data(task); in wq_worker_running() local
[all …]
|
| D | async.c | 330 struct worker *worker = current_wq_worker(); in current_is_async() local
332 return worker && worker->current_func == async_run_entry_fn; in current_is_async()
|
| D | workqueue_internal.h | 24 struct worker { struct
65 static inline struct worker *current_wq_worker(void) in current_wq_worker()
|
| /kernel/sched/ |
| D | cpufreq_schedutil.c | 39 struct kthread_worker worker; member
581 kthread_queue_work(&sg_policy->worker, &sg_policy->work); in sugov_irq_work()
679 kthread_init_worker(&sg_policy->worker); in sugov_kthread_create()
680 thread = kthread_create(kthread_worker_fn, &sg_policy->worker, in sugov_kthread_create()
711 kthread_flush_worker(&sg_policy->worker); in sugov_kthread_stop()
|