diff options
Diffstat (limited to 'fs/f2fs/node.c')
| -rw-r--r-- | fs/f2fs/node.c | 73 |
1 files changed, 27 insertions, 46 deletions
diff --git a/fs/f2fs/node.c b/fs/f2fs/node.c index fca87835a1da..b33dac9592ca 100644 --- a/fs/f2fs/node.c +++ b/fs/f2fs/node.c | |||
| @@ -1277,21 +1277,17 @@ release_page: | |||
| 1277 | 1277 | ||
| 1278 | static struct page *last_fsync_dnode(struct f2fs_sb_info *sbi, nid_t ino) | 1278 | static struct page *last_fsync_dnode(struct f2fs_sb_info *sbi, nid_t ino) |
| 1279 | { | 1279 | { |
| 1280 | pgoff_t index, end; | 1280 | pgoff_t index; |
| 1281 | struct pagevec pvec; | 1281 | struct pagevec pvec; |
| 1282 | struct page *last_page = NULL; | 1282 | struct page *last_page = NULL; |
| 1283 | int nr_pages; | ||
| 1283 | 1284 | ||
| 1284 | pagevec_init(&pvec, 0); | 1285 | pagevec_init(&pvec); |
| 1285 | index = 0; | 1286 | index = 0; |
| 1286 | end = ULONG_MAX; | 1287 | |
| 1287 | 1288 | while ((nr_pages = pagevec_lookup_tag(&pvec, NODE_MAPPING(sbi), &index, | |
| 1288 | while (index <= end) { | 1289 | PAGECACHE_TAG_DIRTY))) { |
| 1289 | int i, nr_pages; | 1290 | int i; |
| 1290 | nr_pages = pagevec_lookup_tag(&pvec, NODE_MAPPING(sbi), &index, | ||
| 1291 | PAGECACHE_TAG_DIRTY, | ||
| 1292 | min(end - index, (pgoff_t)PAGEVEC_SIZE-1) + 1); | ||
| 1293 | if (nr_pages == 0) | ||
| 1294 | break; | ||
| 1295 | 1291 | ||
| 1296 | for (i = 0; i < nr_pages; i++) { | 1292 | for (i = 0; i < nr_pages; i++) { |
| 1297 | struct page *page = pvec.pages[i]; | 1293 | struct page *page = pvec.pages[i]; |
| @@ -1425,13 +1421,14 @@ static int f2fs_write_node_page(struct page *page, | |||
| 1425 | int fsync_node_pages(struct f2fs_sb_info *sbi, struct inode *inode, | 1421 | int fsync_node_pages(struct f2fs_sb_info *sbi, struct inode *inode, |
| 1426 | struct writeback_control *wbc, bool atomic) | 1422 | struct writeback_control *wbc, bool atomic) |
| 1427 | { | 1423 | { |
| 1428 | pgoff_t index, end; | 1424 | pgoff_t index; |
| 1429 | pgoff_t last_idx = ULONG_MAX; | 1425 | pgoff_t last_idx = ULONG_MAX; |
| 1430 | struct pagevec pvec; | 1426 | struct pagevec pvec; |
| 1431 | int ret = 0; | 1427 | int ret = 0; |
| 1432 | struct page *last_page = NULL; | 1428 | struct page *last_page = NULL; |
| 1433 | bool marked = false; | 1429 | bool marked = false; |
| 1434 | nid_t ino = inode->i_ino; | 1430 | nid_t ino = inode->i_ino; |
| 1431 | int nr_pages; | ||
| 1435 | 1432 | ||
| 1436 | if (atomic) { | 1433 | if (atomic) { |
| 1437 | last_page = last_fsync_dnode(sbi, ino); | 1434 | last_page = last_fsync_dnode(sbi, ino); |
| @@ -1439,17 +1436,12 @@ int fsync_node_pages(struct f2fs_sb_info *sbi, struct inode *inode, | |||
| 1439 | return PTR_ERR_OR_ZERO(last_page); | 1436 | return PTR_ERR_OR_ZERO(last_page); |
| 1440 | } | 1437 | } |
| 1441 | retry: | 1438 | retry: |
| 1442 | pagevec_init(&pvec, 0); | 1439 | pagevec_init(&pvec); |
| 1443 | index = 0; | 1440 | index = 0; |
| 1444 | end = ULONG_MAX; | 1441 | |
| 1445 | 1442 | while ((nr_pages = pagevec_lookup_tag(&pvec, NODE_MAPPING(sbi), &index, | |
| 1446 | while (index <= end) { | 1443 | PAGECACHE_TAG_DIRTY))) { |
| 1447 | int i, nr_pages; | 1444 | int i; |
| 1448 | nr_pages = pagevec_lookup_tag(&pvec, NODE_MAPPING(sbi), &index, | ||
| 1449 | PAGECACHE_TAG_DIRTY, | ||
| 1450 | min(end - index, (pgoff_t)PAGEVEC_SIZE-1) + 1); | ||
| 1451 | if (nr_pages == 0) | ||
| 1452 | break; | ||
| 1453 | 1445 | ||
| 1454 | for (i = 0; i < nr_pages; i++) { | 1446 | for (i = 0; i < nr_pages; i++) { |
| 1455 | struct page *page = pvec.pages[i]; | 1447 | struct page *page = pvec.pages[i]; |
| @@ -1548,25 +1540,21 @@ out: | |||
| 1548 | int sync_node_pages(struct f2fs_sb_info *sbi, struct writeback_control *wbc, | 1540 | int sync_node_pages(struct f2fs_sb_info *sbi, struct writeback_control *wbc, |
| 1549 | bool do_balance, enum iostat_type io_type) | 1541 | bool do_balance, enum iostat_type io_type) |
| 1550 | { | 1542 | { |
| 1551 | pgoff_t index, end; | 1543 | pgoff_t index; |
| 1552 | struct pagevec pvec; | 1544 | struct pagevec pvec; |
| 1553 | int step = 0; | 1545 | int step = 0; |
| 1554 | int nwritten = 0; | 1546 | int nwritten = 0; |
| 1555 | int ret = 0; | 1547 | int ret = 0; |
| 1548 | int nr_pages; | ||
| 1556 | 1549 | ||
| 1557 | pagevec_init(&pvec, 0); | 1550 | pagevec_init(&pvec); |
| 1558 | 1551 | ||
| 1559 | next_step: | 1552 | next_step: |
| 1560 | index = 0; | 1553 | index = 0; |
| 1561 | end = ULONG_MAX; | 1554 | |
| 1562 | 1555 | while ((nr_pages = pagevec_lookup_tag(&pvec, NODE_MAPPING(sbi), &index, | |
| 1563 | while (index <= end) { | 1556 | PAGECACHE_TAG_DIRTY))) { |
| 1564 | int i, nr_pages; | 1557 | int i; |
| 1565 | nr_pages = pagevec_lookup_tag(&pvec, NODE_MAPPING(sbi), &index, | ||
| 1566 | PAGECACHE_TAG_DIRTY, | ||
| 1567 | min(end - index, (pgoff_t)PAGEVEC_SIZE-1) + 1); | ||
| 1568 | if (nr_pages == 0) | ||
| 1569 | break; | ||
| 1570 | 1558 | ||
| 1571 | for (i = 0; i < nr_pages; i++) { | 1559 | for (i = 0; i < nr_pages; i++) { |
| 1572 | struct page *page = pvec.pages[i]; | 1560 | struct page *page = pvec.pages[i]; |
| @@ -1655,27 +1643,20 @@ out: | |||
| 1655 | 1643 | ||
| 1656 | int wait_on_node_pages_writeback(struct f2fs_sb_info *sbi, nid_t ino) | 1644 | int wait_on_node_pages_writeback(struct f2fs_sb_info *sbi, nid_t ino) |
| 1657 | { | 1645 | { |
| 1658 | pgoff_t index = 0, end = ULONG_MAX; | 1646 | pgoff_t index = 0; |
| 1659 | struct pagevec pvec; | 1647 | struct pagevec pvec; |
| 1660 | int ret2, ret = 0; | 1648 | int ret2, ret = 0; |
| 1649 | int nr_pages; | ||
| 1661 | 1650 | ||
| 1662 | pagevec_init(&pvec, 0); | 1651 | pagevec_init(&pvec); |
| 1663 | 1652 | ||
| 1664 | while (index <= end) { | 1653 | while ((nr_pages = pagevec_lookup_tag(&pvec, NODE_MAPPING(sbi), &index, |
| 1665 | int i, nr_pages; | 1654 | PAGECACHE_TAG_WRITEBACK))) { |
| 1666 | nr_pages = pagevec_lookup_tag(&pvec, NODE_MAPPING(sbi), &index, | 1655 | int i; |
| 1667 | PAGECACHE_TAG_WRITEBACK, | ||
| 1668 | min(end - index, (pgoff_t)PAGEVEC_SIZE-1) + 1); | ||
| 1669 | if (nr_pages == 0) | ||
| 1670 | break; | ||
| 1671 | 1656 | ||
| 1672 | for (i = 0; i < nr_pages; i++) { | 1657 | for (i = 0; i < nr_pages; i++) { |
| 1673 | struct page *page = pvec.pages[i]; | 1658 | struct page *page = pvec.pages[i]; |
| 1674 | 1659 | ||
| 1675 | /* until radix tree lookup accepts end_index */ | ||
| 1676 | if (unlikely(page->index > end)) | ||
| 1677 | continue; | ||
| 1678 | |||
| 1679 | if (ino && ino_of_node(page) == ino) { | 1660 | if (ino && ino_of_node(page) == ino) { |
| 1680 | f2fs_wait_on_page_writeback(page, NODE, true); | 1661 | f2fs_wait_on_page_writeback(page, NODE, true); |
| 1681 | if (TestClearPageError(page)) | 1662 | if (TestClearPageError(page)) |
