Skip to content

Commit eed25cd

Browse files
Mike Christieaxboe
authored andcommitted
mpage: use bio op accessors
Separate the op from the rq_flag_bits and have the mpage code set/get the bio using bio_set_op_attrs/bio_op. Signed-off-by: Mike Christie <[email protected]> Reviewed-by: Christoph Hellwig <[email protected]> Reviewed-by: Hannes Reinecke <[email protected]> Signed-off-by: Jens Axboe <[email protected]>
1 parent 67ed259 commit eed25cd

File tree

1 file changed

+20
-20
lines changed

1 file changed

+20
-20
lines changed

fs/mpage.c

Lines changed: 20 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -56,11 +56,11 @@ static void mpage_end_io(struct bio *bio)
5656
bio_put(bio);
5757
}
5858

59-
static struct bio *mpage_bio_submit(int rw, struct bio *bio)
59+
static struct bio *mpage_bio_submit(int op, int op_flags, struct bio *bio)
6060
{
6161
bio->bi_end_io = mpage_end_io;
62-
bio->bi_rw = rw;
63-
guard_bio_eod(rw, bio);
62+
bio_set_op_attrs(bio, op, op_flags);
63+
guard_bio_eod(op, bio);
6464
submit_bio(bio);
6565
return NULL;
6666
}
@@ -270,7 +270,7 @@ do_mpage_readpage(struct bio *bio, struct page *page, unsigned nr_pages,
270270
* This page will go to BIO. Do we need to send this BIO off first?
271271
*/
272272
if (bio && (*last_block_in_bio != blocks[0] - 1))
273-
bio = mpage_bio_submit(READ, bio);
273+
bio = mpage_bio_submit(REQ_OP_READ, 0, bio);
274274

275275
alloc_new:
276276
if (bio == NULL) {
@@ -287,23 +287,23 @@ do_mpage_readpage(struct bio *bio, struct page *page, unsigned nr_pages,
287287

288288
length = first_hole << blkbits;
289289
if (bio_add_page(bio, page, length, 0) < length) {
290-
bio = mpage_bio_submit(READ, bio);
290+
bio = mpage_bio_submit(REQ_OP_READ, 0, bio);
291291
goto alloc_new;
292292
}
293293

294294
relative_block = block_in_file - *first_logical_block;
295295
nblocks = map_bh->b_size >> blkbits;
296296
if ((buffer_boundary(map_bh) && relative_block == nblocks) ||
297297
(first_hole != blocks_per_page))
298-
bio = mpage_bio_submit(READ, bio);
298+
bio = mpage_bio_submit(REQ_OP_READ, 0, bio);
299299
else
300300
*last_block_in_bio = blocks[blocks_per_page - 1];
301301
out:
302302
return bio;
303303

304304
confused:
305305
if (bio)
306-
bio = mpage_bio_submit(READ, bio);
306+
bio = mpage_bio_submit(REQ_OP_READ, 0, bio);
307307
if (!PageUptodate(page))
308308
block_read_full_page(page, get_block);
309309
else
@@ -385,7 +385,7 @@ mpage_readpages(struct address_space *mapping, struct list_head *pages,
385385
}
386386
BUG_ON(!list_empty(pages));
387387
if (bio)
388-
mpage_bio_submit(READ, bio);
388+
mpage_bio_submit(REQ_OP_READ, 0, bio);
389389
return 0;
390390
}
391391
EXPORT_SYMBOL(mpage_readpages);
@@ -406,7 +406,7 @@ int mpage_readpage(struct page *page, get_block_t get_block)
406406
bio = do_mpage_readpage(bio, page, 1, &last_block_in_bio,
407407
&map_bh, &first_logical_block, get_block, gfp);
408408
if (bio)
409-
mpage_bio_submit(READ, bio);
409+
mpage_bio_submit(REQ_OP_READ, 0, bio);
410410
return 0;
411411
}
412412
EXPORT_SYMBOL(mpage_readpage);
@@ -487,7 +487,7 @@ static int __mpage_writepage(struct page *page, struct writeback_control *wbc,
487487
struct buffer_head map_bh;
488488
loff_t i_size = i_size_read(inode);
489489
int ret = 0;
490-
int wr = (wbc->sync_mode == WB_SYNC_ALL ? WRITE_SYNC : WRITE);
490+
int op_flags = (wbc->sync_mode == WB_SYNC_ALL ? WRITE_SYNC : 0);
491491

492492
if (page_has_buffers(page)) {
493493
struct buffer_head *head = page_buffers(page);
@@ -596,7 +596,7 @@ static int __mpage_writepage(struct page *page, struct writeback_control *wbc,
596596
* This page will go to BIO. Do we need to send this BIO off first?
597597
*/
598598
if (bio && mpd->last_block_in_bio != blocks[0] - 1)
599-
bio = mpage_bio_submit(wr, bio);
599+
bio = mpage_bio_submit(REQ_OP_WRITE, op_flags, bio);
600600

601601
alloc_new:
602602
if (bio == NULL) {
@@ -623,7 +623,7 @@ static int __mpage_writepage(struct page *page, struct writeback_control *wbc,
623623
wbc_account_io(wbc, page, PAGE_SIZE);
624624
length = first_unmapped << blkbits;
625625
if (bio_add_page(bio, page, length, 0) < length) {
626-
bio = mpage_bio_submit(wr, bio);
626+
bio = mpage_bio_submit(REQ_OP_WRITE, op_flags, bio);
627627
goto alloc_new;
628628
}
629629

@@ -633,7 +633,7 @@ static int __mpage_writepage(struct page *page, struct writeback_control *wbc,
633633
set_page_writeback(page);
634634
unlock_page(page);
635635
if (boundary || (first_unmapped != blocks_per_page)) {
636-
bio = mpage_bio_submit(wr, bio);
636+
bio = mpage_bio_submit(REQ_OP_WRITE, op_flags, bio);
637637
if (boundary_block) {
638638
write_boundary_block(boundary_bdev,
639639
boundary_block, 1 << blkbits);
@@ -645,7 +645,7 @@ static int __mpage_writepage(struct page *page, struct writeback_control *wbc,
645645

646646
confused:
647647
if (bio)
648-
bio = mpage_bio_submit(wr, bio);
648+
bio = mpage_bio_submit(REQ_OP_WRITE, op_flags, bio);
649649

650650
if (mpd->use_writepage) {
651651
ret = mapping->a_ops->writepage(page, wbc);
@@ -702,9 +702,9 @@ mpage_writepages(struct address_space *mapping,
702702

703703
ret = write_cache_pages(mapping, wbc, __mpage_writepage, &mpd);
704704
if (mpd.bio) {
705-
int wr = (wbc->sync_mode == WB_SYNC_ALL ?
706-
WRITE_SYNC : WRITE);
707-
mpage_bio_submit(wr, mpd.bio);
705+
int op_flags = (wbc->sync_mode == WB_SYNC_ALL ?
706+
WRITE_SYNC : 0);
707+
mpage_bio_submit(REQ_OP_WRITE, op_flags, mpd.bio);
708708
}
709709
}
710710
blk_finish_plug(&plug);
@@ -723,9 +723,9 @@ int mpage_writepage(struct page *page, get_block_t get_block,
723723
};
724724
int ret = __mpage_writepage(page, wbc, &mpd);
725725
if (mpd.bio) {
726-
int wr = (wbc->sync_mode == WB_SYNC_ALL ?
727-
WRITE_SYNC : WRITE);
728-
mpage_bio_submit(wr, mpd.bio);
726+
int op_flags = (wbc->sync_mode == WB_SYNC_ALL ?
727+
WRITE_SYNC : 0);
728+
mpage_bio_submit(REQ_OP_WRITE, op_flags, mpd.bio);
729729
}
730730
return ret;
731731
}

0 commit comments

Comments
 (0)