diff options
Diffstat (limited to 'fs/nfs/write.c')
| -rw-r--r-- | fs/nfs/write.c | 20 |
1 files changed, 16 insertions, 4 deletions
diff --git a/fs/nfs/write.c b/fs/nfs/write.c index 3aea3ca98ab7..91679e2631ee 100644 --- a/fs/nfs/write.c +++ b/fs/nfs/write.c | |||
| @@ -1386,7 +1386,7 @@ static int nfs_commit_inode(struct inode *inode, int how) | |||
| 1386 | int res = 0; | 1386 | int res = 0; |
| 1387 | 1387 | ||
| 1388 | if (!nfs_commit_set_lock(NFS_I(inode), may_wait)) | 1388 | if (!nfs_commit_set_lock(NFS_I(inode), may_wait)) |
| 1389 | goto out; | 1389 | goto out_mark_dirty; |
| 1390 | spin_lock(&inode->i_lock); | 1390 | spin_lock(&inode->i_lock); |
| 1391 | res = nfs_scan_commit(inode, &head, 0, 0); | 1391 | res = nfs_scan_commit(inode, &head, 0, 0); |
| 1392 | spin_unlock(&inode->i_lock); | 1392 | spin_unlock(&inode->i_lock); |
| @@ -1398,9 +1398,18 @@ static int nfs_commit_inode(struct inode *inode, int how) | |||
| 1398 | wait_on_bit(&NFS_I(inode)->flags, NFS_INO_COMMIT, | 1398 | wait_on_bit(&NFS_I(inode)->flags, NFS_INO_COMMIT, |
| 1399 | nfs_wait_bit_killable, | 1399 | nfs_wait_bit_killable, |
| 1400 | TASK_KILLABLE); | 1400 | TASK_KILLABLE); |
| 1401 | else | ||
| 1402 | goto out_mark_dirty; | ||
| 1401 | } else | 1403 | } else |
| 1402 | nfs_commit_clear_lock(NFS_I(inode)); | 1404 | nfs_commit_clear_lock(NFS_I(inode)); |
| 1403 | out: | 1405 | return res; |
| 1406 | /* Note: If we exit without ensuring that the commit is complete, | ||
| 1407 | * we must mark the inode as dirty. Otherwise, future calls to | ||
| 1408 | * sync_inode() with the WB_SYNC_ALL flag set will fail to ensure | ||
| 1409 | * that the data is on the disk. | ||
| 1410 | */ | ||
| 1411 | out_mark_dirty: | ||
| 1412 | __mark_inode_dirty(inode, I_DIRTY_DATASYNC); | ||
| 1404 | return res; | 1413 | return res; |
| 1405 | } | 1414 | } |
| 1406 | 1415 | ||
| @@ -1509,14 +1518,17 @@ int nfs_wb_page(struct inode *inode, struct page *page) | |||
| 1509 | }; | 1518 | }; |
| 1510 | int ret; | 1519 | int ret; |
| 1511 | 1520 | ||
| 1512 | while(PagePrivate(page)) { | 1521 | for (;;) { |
| 1513 | wait_on_page_writeback(page); | 1522 | wait_on_page_writeback(page); |
| 1514 | if (clear_page_dirty_for_io(page)) { | 1523 | if (clear_page_dirty_for_io(page)) { |
| 1515 | ret = nfs_writepage_locked(page, &wbc); | 1524 | ret = nfs_writepage_locked(page, &wbc); |
| 1516 | if (ret < 0) | 1525 | if (ret < 0) |
| 1517 | goto out_error; | 1526 | goto out_error; |
| 1527 | continue; | ||
| 1518 | } | 1528 | } |
| 1519 | ret = sync_inode(inode, &wbc); | 1529 | if (!PagePrivate(page)) |
| 1530 | break; | ||
| 1531 | ret = nfs_commit_inode(inode, FLUSH_SYNC); | ||
| 1520 | if (ret < 0) | 1532 | if (ret < 0) |
| 1521 | goto out_error; | 1533 | goto out_error; |
| 1522 | } | 1534 | } |
