Searched refs:worker (Results 1 – 5 of 5) sorted by relevance
| /kernel/ |
| D | kthread.c | 768 void __kthread_init_worker(struct kthread_worker *worker, in __kthread_init_worker() argument
772 memset(worker, 0, sizeof(struct kthread_worker)); in __kthread_init_worker()
773 raw_spin_lock_init(&worker->lock); in __kthread_init_worker()
774 lockdep_set_class_and_name(&worker->lock, key, name); in __kthread_init_worker()
775 INIT_LIST_HEAD(&worker->work_list); in __kthread_init_worker()
776 INIT_LIST_HEAD(&worker->delayed_work_list); in __kthread_init_worker()
797 struct kthread_worker *worker = worker_ptr; in kthread_worker_fn() local
804 WARN_ON(worker->task && worker->task != current); in kthread_worker_fn()
805 worker->task = current; in kthread_worker_fn()
807 if (worker->flags & KTW_FREEZABLE) in kthread_worker_fn()
[all …]
|
| D | workqueue.c | 182 struct worker *manager; /* L: purely informational */
274 struct worker *rescuer; /* MD: rescue worker */
434 #define for_each_pool_worker(worker, pool) \ argument
435 list_for_each_entry((worker), &(pool)->workers, node) \
844 static struct worker *first_idle_worker(struct worker_pool *pool) in first_idle_worker()
849 return list_first_entry(&pool->idle_list, struct worker, entry); in first_idle_worker()
863 struct worker *worker = first_idle_worker(pool); in wake_up_worker() local
865 if (likely(worker)) in wake_up_worker()
866 wake_up_process(worker->task); in wake_up_worker()
877 struct worker *worker = kthread_data(task); in wq_worker_running() local
[all …]
|
| D | async.c | 342 struct worker *worker = current_wq_worker(); in current_is_async() local
344 return worker && worker->current_func == async_run_entry_fn; in current_is_async()
|
| D | workqueue_internal.h | 24 struct worker { struct
66 static inline struct worker *current_wq_worker(void) in current_wq_worker()
|
| /kernel/sched/ |
| D | cpufreq_schedutil.c | 34 struct kthread_worker worker; member
502 kthread_queue_work(&sg_policy->worker, &sg_policy->work); in sugov_irq_work()
609 kthread_init_worker(&sg_policy->worker); in sugov_kthread_create()
610 thread = kthread_create(kthread_worker_fn, &sg_policy->worker, in sugov_kthread_create()
641 kthread_flush_worker(&sg_policy->worker); in sugov_kthread_stop()
|