Lines Matching defs:work_flags
155 static inline unsigned int __io_get_work_hash(unsigned int work_flags)
157 return work_flags >> IO_WQ_HASH_SHIFT;
182 unsigned int work_flags)
184 return io_get_acct(wq, !(work_flags & IO_WQ_WORK_UNBOUND));
435 unsigned int hash, work_flags;
440 work_flags = atomic_read(&work->flags);
441 if (!__io_wq_is_hashed(work_flags))
448 hash = __io_get_work_hash(work_flags);
450 work_flags = atomic_read(&next->flags);
451 if (!__io_wq_is_hashed(work_flags))
453 return hash == __io_get_work_hash(work_flags);
533 unsigned int work_flags;
539 work_flags = atomic_read(&work->flags);
540 if (!__io_wq_is_hashed(work_flags)) {
545 hash = __io_get_work_hash(work_flags);
642 unsigned int work_flags = atomic_read(&work->flags);
643 unsigned int hash = __io_wq_is_hashed(work_flags)
644 ? __io_get_work_hash(work_flags)
650 (work_flags & IO_WQ_WORK_UNBOUND))
1000 struct io_wq_work *work, unsigned int work_flags)
1005 if (!__io_wq_is_hashed(work_flags)) {
1011 hash = __io_get_work_hash(work_flags);
1027 unsigned int work_flags = atomic_read(&work->flags);
1028 struct io_wq_acct *acct = io_work_get_acct(wq, work_flags);
1041 (work_flags & IO_WQ_WORK_CANCEL)) {
1047 io_wq_insert_work(wq, acct, work, work_flags);
1055 if (do_create && ((work_flags & IO_WQ_WORK_CONCURRENT) ||