Lines Matching refs:barr
2373 struct wq_barrier *barr = container_of(work, struct wq_barrier, work); in wq_barrier_func() local
2374 complete(&barr->done); in wq_barrier_func()
2402 struct wq_barrier *barr, in insert_wq_barrier() argument
2414 INIT_WORK_ONSTACK(&barr->work, wq_barrier_func); in insert_wq_barrier()
2415 __set_bit(WORK_STRUCT_PENDING_BIT, work_data_bits(&barr->work)); in insert_wq_barrier()
2416 init_completion(&barr->done); in insert_wq_barrier()
2417 barr->task = current; in insert_wq_barrier()
2434 debug_work_activate(&barr->work); in insert_wq_barrier()
2435 insert_work(pwq, &barr->work, head, in insert_wq_barrier()
2718 static bool start_flush_work(struct work_struct *work, struct wq_barrier *barr) in start_flush_work() argument
2746 insert_wq_barrier(pwq, barr, work, worker); in start_flush_work()
2780 struct wq_barrier barr; in flush_work() local
2785 if (start_flush_work(work, &barr)) { in flush_work()
2786 wait_for_completion(&barr.done); in flush_work()
2787 destroy_work_on_stack(&barr.work); in flush_work()
4238 struct wq_barrier *barr; in pr_cont_work() local
4240 barr = container_of(work, struct wq_barrier, work); in pr_cont_work()
4243 task_pid_nr(barr->task)); in pr_cont_work()