| /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 | 61 static void nfs_clear_request_commit(struct nfs_commit_info *cinfo,
63 static void nfs_init_cinfo_from_inode(struct nfs_commit_info *cinfo,
504 void nfs_join_page_group(struct nfs_page *head, struct nfs_commit_info *cinfo, in nfs_join_page_group() argument
535 nfs_clear_request_commit(cinfo, subreq); in nfs_join_page_group()
569 struct nfs_commit_info cinfo; in nfs_lock_and_join_requests() local
572 nfs_init_cinfo_from_inode(&cinfo, inode); in nfs_lock_and_join_requests()
589 nfs_join_page_group(head, &cinfo, inode); in nfs_lock_and_join_requests()
821 struct nfs_commit_info cinfo; in nfs_page_search_commits_for_head_request_locked() local
824 nfs_init_cinfo_from_inode(&cinfo, inode); in nfs_page_search_commits_for_head_request_locked()
827 freq = pnfs_search_commit_reqs(inode, &cinfo, page); in nfs_page_search_commits_for_head_request_locked()
[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 | 186 void nfs_init_cinfo_from_dreq(struct nfs_commit_info *cinfo, in nfs_init_cinfo_from_dreq() argument
189 cinfo->inode = dreq->inode; in nfs_init_cinfo_from_dreq()
190 cinfo->mds = &dreq->mds_cinfo; in nfs_init_cinfo_from_dreq()
191 cinfo->ds = &dreq->ds_cinfo; in nfs_init_cinfo_from_dreq()
192 cinfo->dreq = dreq; in nfs_init_cinfo_from_dreq()
193 cinfo->completion_ops = &nfs_direct_commit_completion_ops; in nfs_init_cinfo_from_dreq()
529 struct nfs_commit_info *cinfo, in nfs_direct_join_group() argument
552 nfs_join_page_group(req, cinfo, inode); in nfs_direct_join_group()
559 struct nfs_commit_info *cinfo) in nfs_direct_write_scan_commit_list() argument
561 mutex_lock(&NFS_I(cinfo->inode)->commit_mutex); in nfs_direct_write_scan_commit_list()
[all …]
|
| D | internal.h | 507 struct nfs_commit_info *cinfo);
509 struct nfs_commit_info *cinfo, int max);
512 struct nfs_commit_info *cinfo);
515 struct nfs_commit_info *cinfo,
520 int how, struct nfs_commit_info *cinfo);
523 struct nfs_commit_info *cinfo,
527 struct nfs_commit_info *cinfo);
530 struct nfs_commit_info *cinfo);
532 struct nfs_commit_info *cinfo);
533 void nfs_init_cinfo(struct nfs_commit_info *cinfo,
[all …]
|
| D | pagelist.c | 707 int how, struct nfs_commit_info *cinfo) in nfs_pgio_rpcsetup() argument
728 if (nfs_reqs_to_commit(cinfo)) in nfs_pgio_rpcsetup()
901 struct nfs_commit_info cinfo; in nfs_generic_pgio() local
921 nfs_init_cinfo(&cinfo, desc->pg_inode, desc->pg_dreq); in nfs_generic_pgio()
943 (desc->pg_moreio || nfs_reqs_to_commit(&cinfo))) in nfs_generic_pgio()
947 nfs_pgio_rpcsetup(hdr, mirror->pg_count, desc->pg_ioflags, &cinfo); in nfs_generic_pgio()
|
| D | nfs42xdr.c | 455 struct nfs4_change_info *cinfo) in decode_setxattr() argument
462 status = decode_change_info(xdr, cinfo); in decode_setxattr()
515 struct nfs4_change_info *cinfo) in decode_removexattr() argument
523 status = decode_change_info(xdr, cinfo); in decode_removexattr()
1464 status = decode_setxattr(xdr, &res->cinfo); in nfs4_xdr_dec_setxattr()
1587 status = decode_removexattr(xdr, &res->cinfo); in nfs4_xdr_dec_removexattr()
|
| D | nfs4xdr.c | 4246 static int decode_change_info(struct xdr_stream *xdr, struct nfs4_change_info *cinfo) in decode_change_info() argument
4253 cinfo->atomic = be32_to_cpup(p++); in decode_change_info()
4254 p = xdr_decode_hyper(p, &cinfo->before); in decode_change_info()
4255 xdr_decode_hyper(p, &cinfo->after); in decode_change_info()
4352 static int decode_create(struct xdr_stream *xdr, struct nfs4_change_info *cinfo) in decode_create() argument
4361 if ((status = decode_change_info(xdr, cinfo))) in decode_create()
4921 static int decode_link(struct xdr_stream *xdr, struct nfs4_change_info *cinfo) in decode_link() argument
4928 return decode_change_info(xdr, cinfo); in decode_link()
5128 decode_change_info(xdr, &res->cinfo); in decode_open()
5267 static int decode_remove(struct xdr_stream *xdr, struct nfs4_change_info *cinfo) in decode_remove() argument
[all …]
|
| D | nfs4proc.c | 1206 struct nfs4_change_info *cinfo, in nfs4_update_changeattr_locked() argument
1215 if (cinfo->atomic && cinfo->before == inode_peek_iversion_raw(inode)) { in nfs4_update_changeattr_locked()
1228 if (cinfo->before != inode_peek_iversion_raw(inode)) in nfs4_update_changeattr_locked()
1233 inode_set_iversion_raw(inode, cinfo->after); in nfs4_update_changeattr_locked()
1243 nfs4_update_changeattr(struct inode *dir, struct nfs4_change_info *cinfo, in nfs4_update_changeattr() argument
1247 nfs4_update_changeattr_locked(dir, cinfo, timestamp, cache_validity); in nfs4_update_changeattr()
2685 else if (o_res->cinfo.before != o_res->cinfo.after) in _nfs4_proc_open()
2688 inode_peek_iversion_raw(dir) != o_res->cinfo.after) in _nfs4_proc_open()
2689 nfs4_update_changeattr(dir, &o_res->cinfo, in _nfs4_proc_open()
4618 nfs4_update_changeattr_locked(dir, &res.cinfo, timestamp, in _nfs4_proc_remove()
[all …]
|
| D | nfs4_fs.h | 332 struct nfs4_change_info *cinfo,
|
| D | nfs42proc.c | 1143 nfs4_update_changeattr(inode, &res.cinfo, timestamp, 0); in _nfs42_proc_removexattr()
1186 nfs4_update_changeattr(inode, &res.cinfo, timestamp, 0); in _nfs42_proc_setxattr()
|
| /fs/nfsd/ |
| D | xdr4.h | 767 set_change_info(struct nfsd4_change_info *cinfo, struct svc_fh *fhp) in set_change_info() argument
770 cinfo->atomic = (u32)fhp->fh_post_saved; in set_change_info()
771 cinfo->change_supported = IS_I_VERSION(d_inode(fhp->fh_dentry)); in set_change_info()
773 cinfo->before_change = fhp->fh_pre_change; in set_change_info()
774 cinfo->after_change = fhp->fh_post_change; in set_change_info()
775 cinfo->before_ctime_sec = fhp->fh_pre_ctime.tv_sec; in set_change_info()
776 cinfo->before_ctime_nsec = fhp->fh_pre_ctime.tv_nsec; in set_change_info()
777 cinfo->after_ctime_sec = fhp->fh_post_attr.ctime.tv_sec; in set_change_info()
778 cinfo->after_ctime_nsec = fhp->fh_post_attr.ctime.tv_nsec; in set_change_info()
|
| /fs/nfs/filelayout/ |
| D | filelayout.c | 941 struct nfs_commit_info *cinfo, in filelayout_mark_request_commit() argument
949 nfs_request_add_commit_list(req, cinfo); in filelayout_mark_request_commit()
959 pnfs_layout_mark_request_commit(req, lseg, cinfo, i); in filelayout_mark_request_commit()
1024 int how, struct nfs_commit_info *cinfo) in filelayout_commit_pagelist() argument
1026 return pnfs_generic_commit_pagelist(inode, mds_pages, how, cinfo, in filelayout_commit_pagelist()
|
| /fs/nfs/flexfilelayout/ |
| D | flexfilelayout.c | 1958 int how, struct nfs_commit_info *cinfo) in ff_layout_commit_pagelist() argument
1960 return pnfs_generic_commit_pagelist(inode, mds_pages, how, cinfo, in ff_layout_commit_pagelist()
|