Loading fs/nfs/pnfs_nfs.c +16 −0 Original line number Diff line number Diff line Loading @@ -322,6 +322,20 @@ pnfs_bucket_alloc_ds_commits(struct list_head *list, return nreq; } static unsigned int pnfs_alloc_ds_commits_list(struct list_head *list, struct pnfs_ds_commit_info *fl_cinfo, struct nfs_commit_info *cinfo) { struct pnfs_commit_array *array; unsigned int ret = 0; list_for_each_entry(array, &fl_cinfo->commits, cinfo_list) ret += pnfs_bucket_alloc_ds_commits(list, array->buckets, array->nbuckets, cinfo); return ret; } /* This follows nfs_commit_list pretty closely */ int pnfs_generic_commit_pagelist(struct inode *inode, struct list_head *mds_pages, Loading @@ -345,6 +359,8 @@ pnfs_generic_commit_pagelist(struct inode *inode, struct list_head *mds_pages, nreq += pnfs_bucket_alloc_ds_commits(&list, fl_cinfo->buckets, fl_cinfo->nbuckets, cinfo); nreq += pnfs_alloc_ds_commits_list(&list, fl_cinfo, cinfo); if (nreq == 0) goto out; Loading Loading
fs/nfs/pnfs_nfs.c +16 −0 Original line number Diff line number Diff line Loading @@ -322,6 +322,20 @@ pnfs_bucket_alloc_ds_commits(struct list_head *list, return nreq; } static unsigned int pnfs_alloc_ds_commits_list(struct list_head *list, struct pnfs_ds_commit_info *fl_cinfo, struct nfs_commit_info *cinfo) { struct pnfs_commit_array *array; unsigned int ret = 0; list_for_each_entry(array, &fl_cinfo->commits, cinfo_list) ret += pnfs_bucket_alloc_ds_commits(list, array->buckets, array->nbuckets, cinfo); return ret; } /* This follows nfs_commit_list pretty closely */ int pnfs_generic_commit_pagelist(struct inode *inode, struct list_head *mds_pages, Loading @@ -345,6 +359,8 @@ pnfs_generic_commit_pagelist(struct inode *inode, struct list_head *mds_pages, nreq += pnfs_bucket_alloc_ds_commits(&list, fl_cinfo->buckets, fl_cinfo->nbuckets, cinfo); nreq += pnfs_alloc_ds_commits_list(&list, fl_cinfo, cinfo); if (nreq == 0) goto out; Loading