Lines Matching refs:barr
3732 struct wq_barrier *barr = container_of(work, struct wq_barrier, work); in wq_barrier_func() local
3733 complete(&barr->done); in wq_barrier_func()
3761 struct wq_barrier *barr, in insert_wq_barrier() argument
3779 INIT_WORK_ONSTACK_KEY(&barr->work, wq_barrier_func, in insert_wq_barrier()
3781 __set_bit(WORK_STRUCT_PENDING_BIT, work_data_bits(&barr->work)); in insert_wq_barrier()
3783 init_completion_map(&barr->done, &target->lockdep_map); in insert_wq_barrier()
3785 barr->task = current; in insert_wq_barrier()
3810 insert_work(pwq, &barr->work, head, work_flags); in insert_wq_barrier()
4142 static bool start_flush_work(struct work_struct *work, struct wq_barrier *barr, in start_flush_work() argument
4173 insert_wq_barrier(pwq, barr, work, worker); in start_flush_work()
4200 struct wq_barrier barr; in __flush_work() local
4208 if (!start_flush_work(work, &barr, from_cancel)) in __flush_work()
4232 while (!try_wait_for_completion(&barr.done)) { in __flush_work()
4244 wait_for_completion(&barr.done); in __flush_work()
4247 destroy_work_on_stack(&barr.work); in __flush_work()
6215 struct wq_barrier *barr; in pr_cont_work() local
6217 barr = container_of(work, struct wq_barrier, work); in pr_cont_work()
6221 task_pid_nr(barr->task)); in pr_cont_work()