diff --git a/fs/block_dev.c b/fs/block_dev.c index 450be88cffef3a7e0b9d68973159ac1c2a2b00fc..c546cdce77e6df48ab48df9b84f3cb6c20c4d173 100644 --- a/fs/block_dev.c +++ b/fs/block_dev.c @@ -237,11 +237,9 @@ __blkdev_direct_IO_simple(struct kiocb *iocb, struct iov_iter *iter, qc = submit_bio(&bio); for (;;) { - __set_current_state(TASK_UNINTERRUPTIBLE); - + set_current_state(TASK_UNINTERRUPTIBLE); if (!READ_ONCE(bio.bi_private)) break; - if (!(iocb->ki_flags & IOCB_HIPRI) || !blk_poll(bdev_get_queue(bdev), qc, true)) io_schedule(); @@ -426,8 +424,7 @@ __blkdev_direct_IO(struct kiocb *iocb, struct iov_iter *iter, int nr_pages) return -EIOCBQUEUED; for (;;) { - __set_current_state(TASK_UNINTERRUPTIBLE); - + set_current_state(TASK_UNINTERRUPTIBLE); if (!READ_ONCE(dio->waiter)) break; diff --git a/fs/iomap.c b/fs/iomap.c index 3a0cd557b4cf8edfa0d068acd77f3ad9c88320e4..a3088fae567ba3092735667e4f9ac2595a1814b1 100644 --- a/fs/iomap.c +++ b/fs/iomap.c @@ -1921,8 +1921,7 @@ iomap_dio_rw(struct kiocb *iocb, struct iov_iter *iter, return -EIOCBQUEUED; for (;;) { - __set_current_state(TASK_UNINTERRUPTIBLE); - + set_current_state(TASK_UNINTERRUPTIBLE); if (!READ_ONCE(dio->submit.waiter)) break; diff --git a/mm/page_io.c b/mm/page_io.c index 3475733b19264ea6c0aa76bbcf031c3aafcec456..d975fa3f02aa565c1bd050b0e2a70e6bedc3af2e 100644 --- a/mm/page_io.c +++ b/mm/page_io.c @@ -405,8 +405,7 @@ int swap_readpage(struct page *page, bool synchronous) bio_get(bio); qc = submit_bio(bio); while (synchronous) { - __set_current_state(TASK_UNINTERRUPTIBLE); - + set_current_state(TASK_UNINTERRUPTIBLE); if (!READ_ONCE(bio->bi_private)) break;