| /fs/nfs/ |
| D | pnfs_nfs.c | 79 struct nfs_commit_info *cinfo) in pnfs_generic_clear_request_commit() argument
85 cinfo->ds->nwritten--; in pnfs_generic_clear_request_commit()
90 nfs_request_remove_commit_list(req, cinfo); in pnfs_generic_clear_request_commit()
242 struct nfs_commit_info *cinfo, in pnfs_bucket_scan_ds_commit_list() argument
249 lockdep_assert_held(&NFS_I(cinfo->inode)->commit_mutex); in pnfs_bucket_scan_ds_commit_list()
250 ret = nfs_scan_commit_list(src, dst, cinfo, max); in pnfs_bucket_scan_ds_commit_list()
252 cinfo->ds->nwritten -= ret; in pnfs_bucket_scan_ds_commit_list()
253 cinfo->ds->ncommitting += ret; in pnfs_bucket_scan_ds_commit_list()
258 static int pnfs_bucket_scan_array(struct nfs_commit_info *cinfo, in pnfs_bucket_scan_array() argument
267 cnt = pnfs_bucket_scan_ds_commit_list(&buckets[i], cinfo, max); in pnfs_bucket_scan_array()
[all …]
|
| D | write.c | 62 static void nfs_init_cinfo_from_inode(struct nfs_commit_info *cinfo,
830 struct nfs_commit_info cinfo; in nfs_page_search_commits_for_head_request_locked() local
833 nfs_init_cinfo_from_inode(&cinfo, inode); in nfs_page_search_commits_for_head_request_locked()
836 freq = pnfs_search_commit_reqs(inode, &cinfo, page); in nfs_page_search_commits_for_head_request_locked()
841 list_for_each_entry_safe(freq, t, &cinfo.mds->list, wb_list) { in nfs_page_search_commits_for_head_request_locked()
864 struct nfs_commit_info *cinfo) in nfs_request_add_commit_list_locked() argument
868 atomic_long_inc(&cinfo->mds->ncommit); in nfs_request_add_commit_list_locked()
885 nfs_request_add_commit_list(struct nfs_page *req, struct nfs_commit_info *cinfo) in nfs_request_add_commit_list() argument
887 mutex_lock(&NFS_I(cinfo->inode)->commit_mutex); in nfs_request_add_commit_list()
888 nfs_request_add_commit_list_locked(req, &cinfo->mds->list, cinfo); in nfs_request_add_commit_list()
[all …]
|
| D | pnfs.h | 184 struct nfs_commit_info *cinfo);
187 struct nfs_commit_info *cinfo,
190 struct nfs_commit_info *cinfo);
191 int (*scan_commit_lists) (struct nfs_commit_info *cinfo,
194 struct nfs_commit_info *cinfo);
195 struct nfs_page * (*search_commit_reqs)(struct nfs_commit_info *cinfo,
391 struct nfs_commit_info *cinfo);
396 struct nfs_commit_info *cinfo);
397 struct nfs_page *pnfs_generic_search_commit_reqs(struct nfs_commit_info *cinfo,
402 struct nfs_commit_info *cinfo,
[all …]
|
| D | direct.c | 152 void nfs_init_cinfo_from_dreq(struct nfs_commit_info *cinfo, in nfs_init_cinfo_from_dreq() argument
155 cinfo->inode = dreq->inode; in nfs_init_cinfo_from_dreq()
156 cinfo->mds = &dreq->mds_cinfo; in nfs_init_cinfo_from_dreq()
157 cinfo->ds = &dreq->ds_cinfo; in nfs_init_cinfo_from_dreq()
158 cinfo->dreq = dreq; in nfs_init_cinfo_from_dreq()
159 cinfo->completion_ops = &nfs_direct_commit_completion_ops; in nfs_init_cinfo_from_dreq()
523 struct nfs_commit_info *cinfo) in nfs_direct_write_scan_commit_list() argument
525 mutex_lock(&NFS_I(cinfo->inode)->commit_mutex); in nfs_direct_write_scan_commit_list()
526 pnfs_recover_commit_reqs(list, cinfo); in nfs_direct_write_scan_commit_list()
527 nfs_scan_commit_list(&cinfo->mds->list, list, cinfo, 0); in nfs_direct_write_scan_commit_list()
[all …]
|
| D | internal.h | 515 struct nfs_commit_info *cinfo);
517 struct nfs_commit_info *cinfo, int max);
520 struct nfs_commit_info *cinfo);
523 struct nfs_commit_info *cinfo,
528 int how, struct nfs_commit_info *cinfo);
531 struct nfs_commit_info *cinfo,
535 struct nfs_commit_info *cinfo);
538 struct nfs_commit_info *cinfo);
540 struct nfs_commit_info *cinfo);
541 void nfs_init_cinfo(struct nfs_commit_info *cinfo,
[all …]
|
| D | pagelist.c | 701 int how, struct nfs_commit_info *cinfo) in nfs_pgio_rpcsetup() argument
722 if (nfs_reqs_to_commit(cinfo)) in nfs_pgio_rpcsetup()
895 struct nfs_commit_info cinfo; in nfs_generic_pgio() local
915 nfs_init_cinfo(&cinfo, desc->pg_inode, desc->pg_dreq); in nfs_generic_pgio()
937 (desc->pg_moreio || nfs_reqs_to_commit(&cinfo))) in nfs_generic_pgio()
941 nfs_pgio_rpcsetup(hdr, mirror->pg_count, desc->pg_ioflags, &cinfo); in nfs_generic_pgio()
|
| D | nfs42xdr.c | 462 struct nfs4_change_info *cinfo) in decode_setxattr() argument
469 status = decode_change_info(xdr, cinfo); in decode_setxattr()
528 struct nfs4_change_info *cinfo) in decode_removexattr() argument
536 status = decode_change_info(xdr, cinfo); in decode_removexattr()
1522 status = decode_setxattr(xdr, &res->cinfo); in nfs4_xdr_dec_setxattr()
1644 status = decode_removexattr(xdr, &res->cinfo); in nfs4_xdr_dec_removexattr()
|
| D | nfs4xdr.c | 4314 static int decode_change_info(struct xdr_stream *xdr, struct nfs4_change_info *cinfo) in decode_change_info() argument
4321 cinfo->atomic = be32_to_cpup(p++); in decode_change_info()
4322 p = xdr_decode_hyper(p, &cinfo->before); in decode_change_info()
4323 xdr_decode_hyper(p, &cinfo->after); in decode_change_info()
4420 static int decode_create(struct xdr_stream *xdr, struct nfs4_change_info *cinfo) in decode_create() argument
4429 if ((status = decode_change_info(xdr, cinfo))) in decode_create()
5016 static int decode_link(struct xdr_stream *xdr, struct nfs4_change_info *cinfo) in decode_link() argument
5023 return decode_change_info(xdr, cinfo); in decode_link()
5223 decode_change_info(xdr, &res->cinfo); in decode_open()
5362 static int decode_remove(struct xdr_stream *xdr, struct nfs4_change_info *cinfo) in decode_remove() argument
[all …]
|
| D | nfs4proc.c | 1217 struct nfs4_change_info *cinfo, in nfs4_update_changeattr_locked() argument
1229 if (cinfo->after == change_attr) in nfs4_update_changeattr_locked()
1233 if ((s64)(change_attr - cinfo->after) >= 0) in nfs4_update_changeattr_locked()
1237 inode_set_iversion_raw(inode, cinfo->after); in nfs4_update_changeattr_locked()
1238 if (!cinfo->atomic || cinfo->before != change_attr) { in nfs4_update_changeattr_locked()
1259 nfs4_update_changeattr(struct inode *dir, struct nfs4_change_info *cinfo, in nfs4_update_changeattr() argument
1263 nfs4_update_changeattr_locked(dir, cinfo, timestamp, cache_validity); in nfs4_update_changeattr()
2697 else if (o_res->cinfo.before != o_res->cinfo.after) in _nfs4_proc_open()
2700 inode_peek_iversion_raw(dir) != o_res->cinfo.after) in _nfs4_proc_open()
2701 nfs4_update_changeattr(dir, &o_res->cinfo, in _nfs4_proc_open()
[all …]
|
| D | nfs4_fs.h | 334 struct nfs4_change_info *cinfo,
|
| D | nfs42proc.c | 1185 nfs4_update_changeattr(inode, &res.cinfo, timestamp, 0); in _nfs42_proc_removexattr()
1229 nfs4_update_changeattr(inode, &res.cinfo, timestamp, 0); in _nfs42_proc_setxattr()
|
| /fs/nfsd/ |
| D | xdr4.h | 778 set_change_info(struct nfsd4_change_info *cinfo, struct svc_fh *fhp) in set_change_info() argument
781 cinfo->atomic = (u32)(fhp->fh_post_saved && !fhp->fh_no_atomic_attr); in set_change_info()
783 cinfo->before_change = fhp->fh_pre_change; in set_change_info()
784 cinfo->after_change = fhp->fh_post_change; in set_change_info()
|
| /fs/nfs/filelayout/ |
| D | filelayout.c | 946 struct nfs_commit_info *cinfo, in filelayout_mark_request_commit() argument
954 nfs_request_add_commit_list(req, cinfo); in filelayout_mark_request_commit()
964 pnfs_layout_mark_request_commit(req, lseg, cinfo, i); in filelayout_mark_request_commit()
1029 int how, struct nfs_commit_info *cinfo) in filelayout_commit_pagelist() argument
1031 return pnfs_generic_commit_pagelist(inode, mds_pages, how, cinfo, in filelayout_commit_pagelist()
|
| /fs/nfs/flexfilelayout/ |
| D | flexfilelayout.c | 1971 int how, struct nfs_commit_info *cinfo) in ff_layout_commit_pagelist() argument
1973 return pnfs_generic_commit_pagelist(inode, mds_pages, how, cinfo, in ff_layout_commit_pagelist()
|