Lines Matching refs:pool_workqueue

200 struct pool_workqueue {  struct
275 struct pool_workqueue *dfl_pwq; /* PW: only for unbound wqs */
296 struct pool_workqueue __percpu *cpu_pwqs; /* I: per-cpu pwqs */
297 struct pool_workqueue __rcu *numa_pwq_tbl[]; /* PWR: unbound pwqs indexed by node */
377 static void show_pwq(struct pool_workqueue *pwq);
577 static struct pool_workqueue *unbound_pwq_by_node(struct workqueue_struct *wq, in unbound_pwq_by_node()
637 static void set_work_pwq(struct work_struct *work, struct pool_workqueue *pwq, in set_work_pwq()
699 static struct pool_workqueue *get_work_pwq(struct work_struct *work) in get_work_pwq()
732 return ((struct pool_workqueue *) in get_work_pool()
754 return ((struct pool_workqueue *) in get_work_pool_id()
1105 static void get_pwq(struct pool_workqueue *pwq) in get_pwq()
1119 static void put_pwq(struct pool_workqueue *pwq) in put_pwq()
1143 static void put_pwq_unlocked(struct pool_workqueue *pwq) in put_pwq_unlocked()
1158 struct pool_workqueue *pwq = get_work_pwq(work); in pwq_activate_inactive_work()
1168 static void pwq_activate_first_inactive(struct pool_workqueue *pwq) in pwq_activate_first_inactive()
1187 static void pwq_dec_nr_in_flight(struct pool_workqueue *pwq, unsigned long work_data) in pwq_dec_nr_in_flight()
1257 struct pool_workqueue *pwq; in try_to_grab_pending()
1347 static void insert_work(struct pool_workqueue *pwq, struct work_struct *work, in insert_work()
1423 struct pool_workqueue *pwq; in __queue_work()
2040 struct pool_workqueue *pwq = get_work_pwq(work); in send_mayday()
2193 struct pool_workqueue *pwq = get_work_pwq(work); in process_one_work()
2521 struct pool_workqueue *pwq = list_first_entry(&wq->maydays, in rescuer_thread()
2522 struct pool_workqueue, mayday_node); in rescuer_thread()
2679 static void insert_wq_barrier(struct pool_workqueue *pwq, in insert_wq_barrier()
2762 struct pool_workqueue *pwq; in flush_workqueue_prep_pwqs()
2970 struct pool_workqueue *pwq; in drain_workqueue()
3016 struct pool_workqueue *pwq; in start_flush_work()
3696 container_of(rcu, struct pool_workqueue, rcu)); in rcu_free_pwq()
3705 struct pool_workqueue *pwq = container_of(work, struct pool_workqueue, in pwq_unbound_release_workfn()
3749 static void pwq_adjust_max_active(struct pool_workqueue *pwq) in pwq_adjust_max_active()
3797 static void init_pwq(struct pool_workqueue *pwq, struct workqueue_struct *wq, in init_pwq()
3815 static void link_pwq(struct pool_workqueue *pwq) in link_pwq()
3836 static struct pool_workqueue *alloc_unbound_pwq(struct workqueue_struct *wq, in alloc_unbound_pwq()
3840 struct pool_workqueue *pwq; in alloc_unbound_pwq()
3911 static struct pool_workqueue *numa_pwq_tbl_install(struct workqueue_struct *wq, in numa_pwq_tbl_install()
3913 struct pool_workqueue *pwq) in numa_pwq_tbl_install()
3915 struct pool_workqueue *old_pwq; in numa_pwq_tbl_install()
3933 struct pool_workqueue *dfl_pwq;
3934 struct pool_workqueue *pwq_tbl[];
4146 struct pool_workqueue *old_pwq = NULL, *pwq; in wq_update_unbound_numa()
4210 wq->cpu_pwqs = alloc_percpu(struct pool_workqueue); in alloc_and_link_pwqs()
4215 struct pool_workqueue *pwq = in alloc_and_link_pwqs()
4295 struct pool_workqueue *pwq; in alloc_workqueue()
4385 static bool pwq_busy(struct pool_workqueue *pwq) in pwq_busy()
4409 struct pool_workqueue *pwq; in destroy_workqueue()
4506 struct pool_workqueue *pwq; in workqueue_set_max_active()
4577 struct pool_workqueue *pwq; in workqueue_congested()
4674 struct pool_workqueue *pwq = NULL; in print_worker_info()
4727 static void show_pwq(struct pool_workqueue *pwq) in show_pwq()
4817 struct pool_workqueue *pwq; in show_workqueue_state()
5239 struct pool_workqueue *pwq; in freeze_workqueues_begin()
5273 struct pool_workqueue *pwq; in freeze_workqueues_busy()
5314 struct pool_workqueue *pwq; in thaw_workqueues()
5996 BUILD_BUG_ON(__alignof__(struct pool_workqueue) < __alignof__(long long)); in workqueue_init_early()
6001 pwq_cache = KMEM_CACHE(pool_workqueue, SLAB_PANIC); in workqueue_init_early()