Loading fs/io-wq.c +2 −3 Original line number Original line Diff line number Diff line Loading @@ -405,8 +405,7 @@ static void io_wqe_dec_running(struct io_worker *worker) * Worker will start processing some work. Move it to the busy list, if * Worker will start processing some work. Move it to the busy list, if * it's currently on the freelist * it's currently on the freelist */ */ static void __io_worker_busy(struct io_wqe *wqe, struct io_worker *worker, static void __io_worker_busy(struct io_wqe *wqe, struct io_worker *worker) struct io_wq_work *work) __must_hold(wqe->lock) __must_hold(wqe->lock) { { if (worker->flags & IO_WORKER_F_FREE) { if (worker->flags & IO_WORKER_F_FREE) { Loading Loading @@ -556,7 +555,7 @@ static void io_worker_handle_work(struct io_worker *worker) */ */ work = io_get_next_work(acct, worker); work = io_get_next_work(acct, worker); if (work) if (work) __io_worker_busy(wqe, worker, work); __io_worker_busy(wqe, worker); raw_spin_unlock(&wqe->lock); raw_spin_unlock(&wqe->lock); if (!work) if (!work) Loading Loading
fs/io-wq.c +2 −3 Original line number Original line Diff line number Diff line Loading @@ -405,8 +405,7 @@ static void io_wqe_dec_running(struct io_worker *worker) * Worker will start processing some work. Move it to the busy list, if * Worker will start processing some work. Move it to the busy list, if * it's currently on the freelist * it's currently on the freelist */ */ static void __io_worker_busy(struct io_wqe *wqe, struct io_worker *worker, static void __io_worker_busy(struct io_wqe *wqe, struct io_worker *worker) struct io_wq_work *work) __must_hold(wqe->lock) __must_hold(wqe->lock) { { if (worker->flags & IO_WORKER_F_FREE) { if (worker->flags & IO_WORKER_F_FREE) { Loading Loading @@ -556,7 +555,7 @@ static void io_worker_handle_work(struct io_worker *worker) */ */ work = io_get_next_work(acct, worker); work = io_get_next_work(acct, worker); if (work) if (work) __io_worker_busy(wqe, worker, work); __io_worker_busy(wqe, worker); raw_spin_unlock(&wqe->lock); raw_spin_unlock(&wqe->lock); if (!work) if (!work) Loading