| /fs/nfs/ |
| D | pnfs_nfs.c | 69 struct nfs_commit_info *cinfo) in pnfs_generic_clear_request_commit() argument
75 cinfo->ds->nwritten--; in pnfs_generic_clear_request_commit()
86 nfs_request_remove_commit_list(req, cinfo); in pnfs_generic_clear_request_commit()
93 struct nfs_commit_info *cinfo, in pnfs_generic_scan_ds_commit_list() argument
100 lockdep_assert_held(&NFS_I(cinfo->inode)->commit_mutex); in pnfs_generic_scan_ds_commit_list()
101 ret = nfs_scan_commit_list(src, dst, cinfo, max); in pnfs_generic_scan_ds_commit_list()
103 cinfo->ds->nwritten -= ret; in pnfs_generic_scan_ds_commit_list()
104 cinfo->ds->ncommitting += ret; in pnfs_generic_scan_ds_commit_list()
118 int pnfs_generic_scan_commit_lists(struct nfs_commit_info *cinfo, in pnfs_generic_scan_commit_lists() argument
123 lockdep_assert_held(&NFS_I(cinfo->inode)->commit_mutex); in pnfs_generic_scan_commit_lists()
[all …]
|
| D | write.c | 62 static void nfs_init_cinfo_from_inode(struct nfs_commit_info *cinfo,
827 struct nfs_commit_info cinfo; in nfs_page_search_commits_for_head_request_locked() local
830 nfs_init_cinfo_from_inode(&cinfo, inode); in nfs_page_search_commits_for_head_request_locked()
833 freq = pnfs_search_commit_reqs(inode, &cinfo, page); in nfs_page_search_commits_for_head_request_locked()
838 list_for_each_entry_safe(freq, t, &cinfo.mds->list, wb_list) { in nfs_page_search_commits_for_head_request_locked()
861 struct nfs_commit_info *cinfo) in nfs_request_add_commit_list_locked() argument
865 atomic_long_inc(&cinfo->mds->ncommit); in nfs_request_add_commit_list_locked()
882 nfs_request_add_commit_list(struct nfs_page *req, struct nfs_commit_info *cinfo) in nfs_request_add_commit_list() argument
884 mutex_lock(&NFS_I(cinfo->inode)->commit_mutex); in nfs_request_add_commit_list()
885 nfs_request_add_commit_list_locked(req, &cinfo->mds->list, cinfo); in nfs_request_add_commit_list()
[all …]
|
| D | pnfs.h | 153 struct nfs_commit_info *cinfo,
156 struct nfs_commit_info *cinfo);
157 int (*scan_commit_lists) (struct nfs_commit_info *cinfo,
160 struct nfs_commit_info *cinfo);
161 struct nfs_page * (*search_commit_reqs)(struct nfs_commit_info *cinfo,
166 struct nfs_commit_info *cinfo);
364 struct nfs_commit_info *cinfo);
369 struct nfs_commit_info *cinfo);
373 struct nfs_commit_info *cinfo,
376 int pnfs_generic_scan_commit_lists(struct nfs_commit_info *cinfo, int max);
[all …]
|
| D | direct.c | 286 void nfs_init_cinfo_from_dreq(struct nfs_commit_info *cinfo, in nfs_init_cinfo_from_dreq() argument
289 cinfo->inode = dreq->inode; in nfs_init_cinfo_from_dreq()
290 cinfo->mds = &dreq->mds_cinfo; in nfs_init_cinfo_from_dreq()
291 cinfo->ds = &dreq->ds_cinfo; in nfs_init_cinfo_from_dreq()
292 cinfo->dreq = dreq; in nfs_init_cinfo_from_dreq()
293 cinfo->completion_ops = &nfs_direct_commit_completion_ops; in nfs_init_cinfo_from_dreq()
610 struct nfs_commit_info *cinfo) in nfs_direct_write_scan_commit_list() argument
612 mutex_lock(&NFS_I(cinfo->inode)->commit_mutex); in nfs_direct_write_scan_commit_list()
614 if (cinfo->ds != NULL && cinfo->ds->nwritten != 0) in nfs_direct_write_scan_commit_list()
615 NFS_SERVER(inode)->pnfs_curr_ld->recover_commit_reqs(list, cinfo); in nfs_direct_write_scan_commit_list()
[all …]
|
| D | internal.h | 481 struct nfs_commit_info *cinfo);
483 struct nfs_commit_info *cinfo, int max);
486 struct nfs_commit_info *cinfo);
489 struct nfs_commit_info *cinfo,
494 int how, struct nfs_commit_info *cinfo);
497 struct nfs_commit_info *cinfo,
501 struct nfs_commit_info *cinfo);
504 struct nfs_commit_info *cinfo);
506 struct nfs_commit_info *cinfo);
507 void nfs_init_cinfo(struct nfs_commit_info *cinfo,
[all …]
|
| D | pagelist.c | 564 int how, struct nfs_commit_info *cinfo) in nfs_pgio_rpcsetup() argument
585 if (nfs_reqs_to_commit(cinfo)) in nfs_pgio_rpcsetup()
767 struct nfs_commit_info cinfo; in nfs_generic_pgio() local
787 nfs_init_cinfo(&cinfo, desc->pg_inode, desc->pg_dreq); in nfs_generic_pgio()
809 (desc->pg_moreio || nfs_reqs_to_commit(&cinfo))) in nfs_generic_pgio()
813 nfs_pgio_rpcsetup(hdr, mirror->pg_count, desc->pg_ioflags, &cinfo); in nfs_generic_pgio()
|
| D | nfs4xdr.c | 4224 static int decode_change_info(struct xdr_stream *xdr, struct nfs4_change_info *cinfo) in decode_change_info() argument
4231 cinfo->atomic = be32_to_cpup(p++); in decode_change_info()
4232 p = xdr_decode_hyper(p, &cinfo->before); in decode_change_info()
4233 xdr_decode_hyper(p, &cinfo->after); in decode_change_info()
4327 static int decode_create(struct xdr_stream *xdr, struct nfs4_change_info *cinfo) in decode_create() argument
4336 if ((status = decode_change_info(xdr, cinfo))) in decode_create()
4891 static int decode_link(struct xdr_stream *xdr, struct nfs4_change_info *cinfo) in decode_link() argument
4898 return decode_change_info(xdr, cinfo); in decode_link()
5098 decode_change_info(xdr, &res->cinfo); in decode_open()
5237 static int decode_remove(struct xdr_stream *xdr, struct nfs4_change_info *cinfo) in decode_remove() argument
[all …]
|
| D | nfs4proc.c | 1148 update_changeattr_locked(struct inode *dir, struct nfs4_change_info *cinfo, in update_changeattr_locked() argument
1157 if (cinfo->atomic && cinfo->before == inode_peek_iversion_raw(dir)) { in update_changeattr_locked()
1162 if (cinfo->before != inode_peek_iversion_raw(dir)) in update_changeattr_locked()
1166 inode_set_iversion_raw(dir, cinfo->after); in update_changeattr_locked()
1174 update_changeattr(struct inode *dir, struct nfs4_change_info *cinfo, in update_changeattr() argument
1178 update_changeattr_locked(dir, cinfo, timestamp, cache_validity); in update_changeattr()
2624 else if (o_res->cinfo.before != o_res->cinfo.after) in _nfs4_proc_open()
2627 inode_peek_iversion_raw(dir) != o_res->cinfo.after) in _nfs4_proc_open()
2628 update_changeattr(dir, &o_res->cinfo, in _nfs4_proc_open()
4482 update_changeattr_locked(dir, &res.cinfo, timestamp, 0); in _nfs4_proc_remove()
[all …]
|
| /fs/nfs/filelayout/ |
| D | filelayout.c | 764 struct nfs_commit_info *cinfo, in filelayout_alloc_commit_info() argument
777 if (cinfo->ds->nbuckets >= size) { in filelayout_alloc_commit_info()
798 spin_lock(&cinfo->inode->i_lock); in filelayout_alloc_commit_info()
799 if (cinfo->ds->nbuckets >= size) in filelayout_alloc_commit_info()
801 for (i = 0; i < cinfo->ds->nbuckets; i++) { in filelayout_alloc_commit_info()
802 list_splice(&cinfo->ds->buckets[i].written, in filelayout_alloc_commit_info()
804 list_splice(&cinfo->ds->buckets[i].committing, in filelayout_alloc_commit_info()
807 cinfo->ds->buckets[i].direct_verf.committed; in filelayout_alloc_commit_info()
808 buckets[i].wlseg = cinfo->ds->buckets[i].wlseg; in filelayout_alloc_commit_info()
809 buckets[i].clseg = cinfo->ds->buckets[i].clseg; in filelayout_alloc_commit_info()
[all …]
|
| /fs/nfsd/ |
| D | xdr4.h | 715 set_change_info(struct nfsd4_change_info *cinfo, struct svc_fh *fhp) in set_change_info() argument
718 cinfo->atomic = (u32)fhp->fh_post_saved; in set_change_info()
719 cinfo->change_supported = IS_I_VERSION(d_inode(fhp->fh_dentry)); in set_change_info()
721 cinfo->before_change = fhp->fh_pre_change; in set_change_info()
722 cinfo->after_change = fhp->fh_post_change; in set_change_info()
723 cinfo->before_ctime_sec = fhp->fh_pre_ctime.tv_sec; in set_change_info()
724 cinfo->before_ctime_nsec = fhp->fh_pre_ctime.tv_nsec; in set_change_info()
725 cinfo->after_ctime_sec = fhp->fh_post_attr.ctime.tv_sec; in set_change_info()
726 cinfo->after_ctime_nsec = fhp->fh_post_attr.ctime.tv_nsec; in set_change_info()
|
| /fs/nfs/flexfilelayout/ |
| D | flexfilelayout.c | 751 struct nfs_commit_info *cinfo, in ff_layout_alloc_commit_info() argument
758 if (cinfo->ds->nbuckets != 0) { in ff_layout_alloc_commit_info()
776 spin_lock(&cinfo->inode->i_lock); in ff_layout_alloc_commit_info()
777 if (cinfo->ds->nbuckets != 0) in ff_layout_alloc_commit_info()
780 cinfo->ds->buckets = buckets; in ff_layout_alloc_commit_info()
781 cinfo->ds->nbuckets = size; in ff_layout_alloc_commit_info()
790 spin_unlock(&cinfo->inode->i_lock); in ff_layout_alloc_commit_info()
956 struct nfs_commit_info cinfo; in ff_layout_pg_init_write() local
981 nfs_init_cinfo(&cinfo, pgio->pg_inode, pgio->pg_dreq); in ff_layout_pg_init_write()
982 status = ff_layout_alloc_commit_info(pgio->pg_lseg, &cinfo, GFP_NOFS); in ff_layout_pg_init_write()
[all …]
|