Lines Matching refs:io_wq_work
49 struct io_wq_work *cur_work;
102 struct io_wq_work *hash_tail[IO_WQ_NR_HASH_BUCKETS];
163 struct io_wq_work *work) in io_work_get_acct()
409 struct io_wq_work *work) in __io_worker_busy()
434 static inline unsigned int io_get_work_hash(struct io_wq_work *work) in io_get_work_hash()
457 static struct io_wq_work *io_get_next_work(struct io_wqe_acct *acct, in io_get_next_work()
462 struct io_wq_work *work, *tail; in io_get_next_work()
469 work = container_of(node, struct io_wq_work, list); in io_get_next_work()
525 struct io_wq_work *work) in io_assign_current_work()
537 static void io_wqe_enqueue(struct io_wqe *wqe, struct io_wq_work *work);
548 struct io_wq_work *work; in io_worker_handle_work()
569 struct io_wq_work *next_hashed, *linked; in io_worker_handle_work()
720 static bool io_wq_work_match_all(struct io_wq_work *work, void *data) in io_wq_work_match_all()
867 static void io_run_cancel(struct io_wq_work *work, struct io_wqe *wqe) in io_run_cancel()
878 static void io_wqe_insert_work(struct io_wqe *wqe, struct io_wq_work *work) in io_wqe_insert_work()
882 struct io_wq_work *tail; in io_wqe_insert_work()
899 static bool io_wq_work_match_item(struct io_wq_work *work, void *data) in io_wq_work_match_item()
904 static void io_wqe_enqueue(struct io_wqe *wqe, struct io_wq_work *work) in io_wqe_enqueue()
954 void io_wq_enqueue(struct io_wq *wq, struct io_wq_work *work) in io_wq_enqueue()
965 void io_wq_hash_work(struct io_wq_work *work, void *val) in io_wq_hash_work()
993 struct io_wq_work *work, in io_wqe_remove_pending()
998 struct io_wq_work *prev_work = NULL; in io_wqe_remove_pending()
1002 prev_work = container_of(prev, struct io_wq_work, list); in io_wqe_remove_pending()
1017 struct io_wq_work *work; in io_acct_cancel_pending_work()
1020 work = container_of(node, struct io_wq_work, list); in io_acct_cancel_pending_work()