aboutsummaryrefslogtreecommitdiffstats
path: root/fs/nfs/pnfs.c
diff options
context:
space:
mode:
Diffstat (limited to 'fs/nfs/pnfs.c')
-rw-r--r--fs/nfs/pnfs.c43
1 files changed, 7 insertions, 36 deletions
diff --git a/fs/nfs/pnfs.c b/fs/nfs/pnfs.c
index b96736df98e8..ea83f3c03c65 100644
--- a/fs/nfs/pnfs.c
+++ b/fs/nfs/pnfs.c
@@ -1841,7 +1841,8 @@ void pnfs_ld_write_done(struct nfs_pgio_header *hdr)
1841{ 1841{
1842 trace_nfs4_pnfs_write(hdr, hdr->pnfs_error); 1842 trace_nfs4_pnfs_write(hdr, hdr->pnfs_error);
1843 if (!hdr->pnfs_error) { 1843 if (!hdr->pnfs_error) {
1844 pnfs_set_layoutcommit(hdr); 1844 pnfs_set_layoutcommit(hdr->inode, hdr->lseg,
1845 hdr->mds_offset + hdr->res.count);
1845 hdr->mds_ops->rpc_call_done(&hdr->task, hdr); 1846 hdr->mds_ops->rpc_call_done(&hdr->task, hdr);
1846 } else 1847 } else
1847 pnfs_ld_handle_write_error(hdr); 1848 pnfs_ld_handle_write_error(hdr);
@@ -2099,11 +2100,10 @@ void pnfs_set_lo_fail(struct pnfs_layout_segment *lseg)
2099EXPORT_SYMBOL_GPL(pnfs_set_lo_fail); 2100EXPORT_SYMBOL_GPL(pnfs_set_lo_fail);
2100 2101
2101void 2102void
2102pnfs_set_layoutcommit(struct nfs_pgio_header *hdr) 2103pnfs_set_layoutcommit(struct inode *inode, struct pnfs_layout_segment *lseg,
2104 loff_t end_pos)
2103{ 2105{
2104 struct inode *inode = hdr->inode;
2105 struct nfs_inode *nfsi = NFS_I(inode); 2106 struct nfs_inode *nfsi = NFS_I(inode);
2106 loff_t end_pos = hdr->mds_offset + hdr->res.count;
2107 bool mark_as_dirty = false; 2107 bool mark_as_dirty = false;
2108 2108
2109 spin_lock(&inode->i_lock); 2109 spin_lock(&inode->i_lock);
@@ -2114,13 +2114,13 @@ pnfs_set_layoutcommit(struct nfs_pgio_header *hdr)
2114 __func__, inode->i_ino); 2114 __func__, inode->i_ino);
2115 } else if (end_pos > nfsi->layout->plh_lwb) 2115 } else if (end_pos > nfsi->layout->plh_lwb)
2116 nfsi->layout->plh_lwb = end_pos; 2116 nfsi->layout->plh_lwb = end_pos;
2117 if (!test_and_set_bit(NFS_LSEG_LAYOUTCOMMIT, &hdr->lseg->pls_flags)) { 2117 if (!test_and_set_bit(NFS_LSEG_LAYOUTCOMMIT, &lseg->pls_flags)) {
2118 /* references matched in nfs4_layoutcommit_release */ 2118 /* references matched in nfs4_layoutcommit_release */
2119 pnfs_get_lseg(hdr->lseg); 2119 pnfs_get_lseg(lseg);
2120 } 2120 }
2121 spin_unlock(&inode->i_lock); 2121 spin_unlock(&inode->i_lock);
2122 dprintk("%s: lseg %p end_pos %llu\n", 2122 dprintk("%s: lseg %p end_pos %llu\n",
2123 __func__, hdr->lseg, nfsi->layout->plh_lwb); 2123 __func__, lseg, nfsi->layout->plh_lwb);
2124 2124
2125 /* if pnfs_layoutcommit_inode() runs between inode locks, the next one 2125 /* if pnfs_layoutcommit_inode() runs between inode locks, the next one
2126 * will be a noop because NFS_INO_LAYOUTCOMMIT will not be set */ 2126 * will be a noop because NFS_INO_LAYOUTCOMMIT will not be set */
@@ -2129,35 +2129,6 @@ pnfs_set_layoutcommit(struct nfs_pgio_header *hdr)
2129} 2129}
2130EXPORT_SYMBOL_GPL(pnfs_set_layoutcommit); 2130EXPORT_SYMBOL_GPL(pnfs_set_layoutcommit);
2131 2131
2132void pnfs_commit_set_layoutcommit(struct nfs_commit_data *data)
2133{
2134 struct inode *inode = data->inode;
2135 struct nfs_inode *nfsi = NFS_I(inode);
2136 bool mark_as_dirty = false;
2137
2138 spin_lock(&inode->i_lock);
2139 if (!test_and_set_bit(NFS_INO_LAYOUTCOMMIT, &nfsi->flags)) {
2140 nfsi->layout->plh_lwb = data->lwb;
2141 mark_as_dirty = true;
2142 dprintk("%s: Set layoutcommit for inode %lu ",
2143 __func__, inode->i_ino);
2144 } else if (data->lwb > nfsi->layout->plh_lwb)
2145 nfsi->layout->plh_lwb = data->lwb;
2146 if (!test_and_set_bit(NFS_LSEG_LAYOUTCOMMIT, &data->lseg->pls_flags)) {
2147 /* references matched in nfs4_layoutcommit_release */
2148 pnfs_get_lseg(data->lseg);
2149 }
2150 spin_unlock(&inode->i_lock);
2151 dprintk("%s: lseg %p end_pos %llu\n",
2152 __func__, data->lseg, nfsi->layout->plh_lwb);
2153
2154 /* if pnfs_layoutcommit_inode() runs between inode locks, the next one
2155 * will be a noop because NFS_INO_LAYOUTCOMMIT will not be set */
2156 if (mark_as_dirty)
2157 mark_inode_dirty_sync(inode);
2158}
2159EXPORT_SYMBOL_GPL(pnfs_commit_set_layoutcommit);
2160
2161void pnfs_cleanup_layoutcommit(struct nfs4_layoutcommit_data *data) 2132void pnfs_cleanup_layoutcommit(struct nfs4_layoutcommit_data *data)
2162{ 2133{
2163 struct nfs_server *nfss = NFS_SERVER(data->args.inode); 2134 struct nfs_server *nfss = NFS_SERVER(data->args.inode);