aboutsummaryrefslogtreecommitdiffstats
path: root/fs
diff options
context:
space:
mode:
authorNeilBrown <neilb@suse.de>2014-09-23 21:28:32 -0400
committerTrond Myklebust <trond.myklebust@primarydata.com>2014-09-25 08:25:38 -0400
commit353db7966288a2f18da22438aeec2b4862c0b241 (patch)
tree959b0fe5a246747af6db55bb7652d4d35b738ba8 /fs
parent9590544694becc64f4874963dbfc4b4d391024b7 (diff)
NFS: avoid waiting at all in nfs_release_page when congested.
If nfs_release_page() is called on a sequence of pages which are all in the same file which is blocked on COMMIT, each page could contribute a 1 second delay which could be come excessive. I have seen delays of as much as 208 seconds. To keep the delay to one second, mark the bdi as write-congested if the commit didn't finished. Once it does finish, the write-congested flag will be cleared by nfs_commit_release_pages(). With this, the longest total delay in try_to_free_pages that I have seen is under 3 seconds. With no waiting in nfs_release_page at all I have seen delays of nearly 1.5 seconds. Signed-off-by: NeilBrown <neilb@suse.de> Acked-by: Jeff Layton <jlayton@primarydata.com> Signed-off-by: Trond Myklebust <trond.myklebust@primarydata.com>
Diffstat (limited to 'fs')
-rw-r--r--fs/nfs/file.c9
-rw-r--r--fs/nfs/write.c5
2 files changed, 12 insertions, 2 deletions
diff --git a/fs/nfs/file.c b/fs/nfs/file.c
index 325df0aeab05..24832d040eb8 100644
--- a/fs/nfs/file.c
+++ b/fs/nfs/file.c
@@ -477,7 +477,8 @@ static int nfs_release_page(struct page *page, gfp_t gfp)
477 477
478 /* Always try to initiate a 'commit' if relevant, but only 478 /* Always try to initiate a 'commit' if relevant, but only
479 * wait for it if __GFP_WAIT is set and the calling process is 479 * wait for it if __GFP_WAIT is set and the calling process is
480 * allowed to block. Even then, only wait 1 second. 480 * allowed to block. Even then, only wait 1 second and only
481 * if the 'bdi' is not congested.
481 * Waiting indefinitely can cause deadlocks when the NFS 482 * Waiting indefinitely can cause deadlocks when the NFS
482 * server is on this machine, and there is no particular need 483 * server is on this machine, and there is no particular need
483 * to wait extensively here. A short wait has the benefit 484 * to wait extensively here. A short wait has the benefit
@@ -488,9 +489,13 @@ static int nfs_release_page(struct page *page, gfp_t gfp)
488 nfs_commit_inode(mapping->host, 0); 489 nfs_commit_inode(mapping->host, 0);
489 if ((gfp & __GFP_WAIT) && 490 if ((gfp & __GFP_WAIT) &&
490 !current_is_kswapd() && 491 !current_is_kswapd() &&
491 !(current->flags & PF_FSTRANS)) { 492 !(current->flags & PF_FSTRANS) &&
493 !bdi_write_congested(&nfss->backing_dev_info)) {
492 wait_on_page_bit_killable_timeout(page, PG_private, 494 wait_on_page_bit_killable_timeout(page, PG_private,
493 HZ); 495 HZ);
496 if (PagePrivate(page))
497 set_bdi_congested(&nfss->backing_dev_info,
498 BLK_RW_ASYNC);
494 } 499 }
495 } 500 }
496 /* If PagePrivate() is set, then the page is not freeable */ 501 /* If PagePrivate() is set, then the page is not freeable */
diff --git a/fs/nfs/write.c b/fs/nfs/write.c
index c063a4e70354..12493846a2d3 100644
--- a/fs/nfs/write.c
+++ b/fs/nfs/write.c
@@ -1611,6 +1611,7 @@ static void nfs_commit_release_pages(struct nfs_commit_data *data)
1611 struct nfs_page *req; 1611 struct nfs_page *req;
1612 int status = data->task.tk_status; 1612 int status = data->task.tk_status;
1613 struct nfs_commit_info cinfo; 1613 struct nfs_commit_info cinfo;
1614 struct nfs_server *nfss;
1614 1615
1615 while (!list_empty(&data->pages)) { 1616 while (!list_empty(&data->pages)) {
1616 req = nfs_list_entry(data->pages.next); 1617 req = nfs_list_entry(data->pages.next);
@@ -1644,6 +1645,10 @@ static void nfs_commit_release_pages(struct nfs_commit_data *data)
1644 next: 1645 next:
1645 nfs_unlock_and_release_request(req); 1646 nfs_unlock_and_release_request(req);
1646 } 1647 }
1648 nfss = NFS_SERVER(data->inode);
1649 if (atomic_long_read(&nfss->writeback) < NFS_CONGESTION_OFF_THRESH)
1650 clear_bdi_congested(&nfss->backing_dev_info, BLK_RW_ASYNC);
1651
1647 nfs_init_cinfo(&cinfo, data->inode, data->dreq); 1652 nfs_init_cinfo(&cinfo, data->inode, data->dreq);
1648 if (atomic_dec_and_test(&cinfo.mds->rpcs_out)) 1653 if (atomic_dec_and_test(&cinfo.mds->rpcs_out))
1649 nfs_commit_clear_lock(NFS_I(data->inode)); 1654 nfs_commit_clear_lock(NFS_I(data->inode));