Lines Matching refs:work_flags
153 static inline unsigned int __io_get_work_hash(unsigned int work_flags) in __io_get_work_hash() argument
155 return work_flags >> IO_WQ_HASH_SHIFT; in __io_get_work_hash()
180 unsigned int work_flags) in io_work_get_acct() argument
182 return io_get_acct(wq, !(work_flags & IO_WQ_WORK_UNBOUND)); in io_work_get_acct()
433 unsigned int hash, work_flags; in io_wq_hash_defer() local
438 work_flags = atomic_read(&work->flags); in io_wq_hash_defer()
439 if (!__io_wq_is_hashed(work_flags)) in io_wq_hash_defer()
446 hash = __io_get_work_hash(work_flags); in io_wq_hash_defer()
448 work_flags = atomic_read(&next->flags); in io_wq_hash_defer()
449 if (!__io_wq_is_hashed(work_flags)) in io_wq_hash_defer()
451 return hash == __io_get_work_hash(work_flags); in io_wq_hash_defer()
531 unsigned int work_flags; in io_get_next_work() local
537 work_flags = atomic_read(&work->flags); in io_get_next_work()
538 if (!__io_wq_is_hashed(work_flags)) { in io_get_next_work()
543 hash = __io_get_work_hash(work_flags); in io_get_next_work()
640 unsigned int work_flags = atomic_read(&work->flags); in io_worker_handle_work() local
641 unsigned int hash = __io_wq_is_hashed(work_flags) in io_worker_handle_work()
642 ? __io_get_work_hash(work_flags) in io_worker_handle_work()
648 (work_flags & IO_WQ_WORK_UNBOUND)) in io_worker_handle_work()
978 struct io_wq_work *work, unsigned int work_flags) in io_wq_insert_work() argument
983 if (!__io_wq_is_hashed(work_flags)) { in io_wq_insert_work()
989 hash = __io_get_work_hash(work_flags); in io_wq_insert_work()
1005 unsigned int work_flags = atomic_read(&work->flags); in io_wq_enqueue() local
1006 struct io_wq_acct *acct = io_work_get_acct(wq, work_flags); in io_wq_enqueue()
1019 (work_flags & IO_WQ_WORK_CANCEL)) { in io_wq_enqueue()
1025 io_wq_insert_work(wq, acct, work, work_flags); in io_wq_enqueue()
1033 if (do_create && ((work_flags & IO_WQ_WORK_CONCURRENT) || in io_wq_enqueue()