Lines Matching refs:worker_pool
184 struct worker_pool { struct
257 struct worker_pool *pool; /* I: the associated pool */
483 static DEFINE_PER_CPU_SHARED_ALIGNED(struct worker_pool [NR_STD_WORKER_POOLS], bh_worker_pools);
486 static DEFINE_PER_CPU_SHARED_ALIGNED(struct worker_pool [NR_STD_WORKER_POOLS], cpu_worker_pools);
528 static void show_one_worker_pool(struct worker_pool *pool);
706 static int worker_pool_assign_id(struct worker_pool *pool) in worker_pool_assign_id()
767 static unsigned long pool_offq_flags(struct worker_pool *pool) in pool_offq_flags()
879 static struct worker_pool *get_work_pool(struct work_struct *work) in get_work_pool()
932 static bool need_more_worker(struct worker_pool *pool) in need_more_worker()
938 static bool may_start_working(struct worker_pool *pool) in may_start_working()
944 static bool keep_working(struct worker_pool *pool) in keep_working()
950 static bool need_to_create_worker(struct worker_pool *pool) in need_to_create_worker()
956 static bool too_many_workers(struct worker_pool *pool) in too_many_workers()
974 struct worker_pool *pool = worker->pool; in worker_set_flags()
996 struct worker_pool *pool = worker->pool; in worker_clr_flags()
1014 static struct worker *first_idle_worker(struct worker_pool *pool) in first_idle_worker()
1034 struct worker_pool *pool = worker->pool; in worker_enter_idle()
1067 struct worker_pool *pool = worker->pool; in worker_leave_idle()
1109 static struct worker *find_worker_executing_work(struct worker_pool *pool, in find_worker_executing_work()
1180 struct worker_pool *pool = worker->pool; in assign_work()
1203 static struct irq_work *bh_pool_irq_work(struct worker_pool *pool) in bh_pool_irq_work()
1210 static void kick_bh_pool(struct worker_pool *pool) in kick_bh_pool()
1233 static bool kick_pool(struct worker_pool *pool) in kick_pool()
1422 struct worker_pool *pool; in wq_worker_sleeping()
1469 struct worker_pool *pool = worker->pool; in wq_worker_tick()
1713 struct worker_pool *pool = pwq->pool; in pwq_tryinc_nr_active()
1851 struct worker_pool *caller_pool) in node_activate_pending_pwq()
1853 struct worker_pool *locked_pool = caller_pool; in node_activate_pending_pwq()
1932 struct worker_pool *pool = pwq->pool; in pwq_dec_nr_active()
2050 struct worker_pool *pool; in try_to_grab_pending()
2239 struct worker_pool *last_pool, *pool; in __queue_work()
2649 static cpumask_t *pool_allowed_cpus(struct worker_pool *pool) in pool_allowed_cpus()
2667 struct worker_pool *pool) in worker_attach_to_pool()
2722 struct worker_pool *pool = worker->pool; in worker_detach_from_pool()
2737 struct worker_pool *pool) in format_worker_id()
2768 static struct worker *create_worker(struct worker_pool *pool) in create_worker()
2869 struct worker_pool *pool = worker->pool; in set_worker_dying()
2903 struct worker_pool *pool = from_timer(pool, t, idle_timer); in idle_worker_timeout()
2942 struct worker_pool *pool = container_of(work, struct worker_pool, idle_cull_work); in idle_cull_fn()
3002 struct worker_pool *pool = from_timer(pool, t, mayday_timer); in pool_mayday_timeout()
3043 static void maybe_create_worker(struct worker_pool *pool) in maybe_create_worker()
3098 struct worker_pool *pool = worker->pool; in manage_workers()
3133 struct worker_pool *pool = worker->pool; in process_one_work()
3339 struct worker_pool *pool = worker->pool; in worker_thread()
3463 struct worker_pool *pool = pwq->pool; in rescuer_thread()
3547 struct worker_pool *pool = worker->pool; in bh_worker()
3594 struct worker_pool *pool = in workqueue_softirq_action()
3602 struct worker_pool *pool;
3610 struct worker_pool *pool = dead_work->pool; in drain_dead_softirq_workfn()
3659 struct worker_pool *pool = &per_cpu(bh_worker_pools, cpu)[i]; in workqueue_softirq_dead()
3843 struct worker_pool *pool = pwq->pool; in flush_workqueue_prep_pwqs()
4119 struct worker_pool *pool; in start_flush_work()
4736 static int init_worker_pool(struct worker_pool *pool) in init_worker_pool()
4882 struct worker_pool *pool = container_of(rcu, struct worker_pool, rcu); in rcu_free_pool()
4900 static void put_unbound_pool(struct worker_pool *pool) in put_unbound_pool()
4982 static struct worker_pool *get_unbound_pool(const struct workqueue_attrs *attrs) in get_unbound_pool()
4986 struct worker_pool *pool; in get_unbound_pool()
5042 struct worker_pool *pool = pwq->pool; in pwq_release_workfn()
5092 struct worker_pool *pool) in init_pwq()
5131 struct worker_pool *pool; in alloc_unbound_pwq()
5456 struct worker_pool __percpu *pools; in alloc_and_link_pwqs()
5465 struct worker_pool *pool; in alloc_and_link_pwqs()
6039 struct worker_pool *pool; in work_busy()
6132 static void pr_cont_pool_info(struct worker_pool *pool) in pr_cont_pool_info()
6147 struct worker_pool *pool = worker->pool; in pr_cont_worker_id()
6204 struct worker_pool *pool = pwq->pool; in show_pwq()
6324 static void show_one_worker_pool(struct worker_pool *pool) in show_one_worker_pool()
6377 struct worker_pool *pool; in show_all_workqueues()
6424 struct worker_pool *pool = worker->pool; in wq_worker_comm()
6472 struct worker_pool *pool; in unbind_workers()
6524 static void rebind_workers(struct worker_pool *pool) in rebind_workers()
6584 static void restore_unbound_workers_cpumask(struct worker_pool *pool, int cpu) in restore_unbound_workers_cpumask()
6604 struct worker_pool *pool; in workqueue_prepare_cpu()
6617 struct worker_pool *pool; in workqueue_online_cpu()
7459 static void show_cpu_pool_hog(struct worker_pool *pool) in show_cpu_pool_hog()
7488 struct worker_pool *pool; in show_cpu_pools_hogs()
7529 struct worker_pool *pool; in wq_watchdog_timer_fn()
7680 static void __init init_cpu_worker_pool(struct worker_pool *pool, int cpu, int nice) in init_cpu_worker_pool()
7757 struct worker_pool *pool; in workqueue_init_early()
7863 struct worker_pool *pool; in workqueue_init()