68 				  struct nfs_commit_info *cinfo)  in pnfs_generic_clear_request_commit()  argument
74 	cinfo->ds->nwritten--;  in pnfs_generic_clear_request_commit()
85 	nfs_request_remove_commit_list(req, cinfo);  in pnfs_generic_clear_request_commit()
92 				  struct nfs_commit_info *cinfo, int max)  in pnfs_generic_transfer_commit_list()  argument
101 		if (cond_resched_lock(cinfo->lock))  in pnfs_generic_transfer_commit_list()
103 		nfs_request_remove_commit_list(req, cinfo);  in pnfs_generic_transfer_commit_list()
107 		if ((ret == max) && !cinfo->dreq)  in pnfs_generic_transfer_commit_list()
115 				 struct nfs_commit_info *cinfo,  in pnfs_generic_scan_ds_commit_list()  argument
122 	lockdep_assert_held(cinfo->lock);  in pnfs_generic_scan_ds_commit_list()
123 	ret = pnfs_generic_transfer_commit_list(src, dst, cinfo, max);  in pnfs_generic_scan_ds_commit_list()
125 		cinfo->ds->nwritten -= ret;  in pnfs_generic_scan_ds_commit_list()
126 		cinfo->ds->ncommitting += ret;  in pnfs_generic_scan_ds_commit_list()
140 int pnfs_generic_scan_commit_lists(struct nfs_commit_info *cinfo,  in pnfs_generic_scan_commit_lists()  argument
145 	lockdep_assert_held(cinfo->lock);  in pnfs_generic_scan_commit_lists()
146 	for (i = 0; i < cinfo->ds->nbuckets && max != 0; i++) {  in pnfs_generic_scan_commit_lists()
147 		cnt = pnfs_generic_scan_ds_commit_list(&cinfo->ds->buckets[i],  in pnfs_generic_scan_commit_lists()
148 						       cinfo, max);  in pnfs_generic_scan_commit_lists()
158 				      struct nfs_commit_info *cinfo)  in pnfs_generic_recover_commit_reqs()  argument
164 	lockdep_assert_held(cinfo->lock);  in pnfs_generic_recover_commit_reqs()
166 	for (i = 0, b = cinfo->ds->buckets; i < cinfo->ds->nbuckets; i++, b++) {  in pnfs_generic_recover_commit_reqs()
168 						      cinfo, 0)) {  in pnfs_generic_recover_commit_reqs()
171 			spin_unlock(cinfo->lock);  in pnfs_generic_recover_commit_reqs()
173 			spin_lock(cinfo->lock);  in pnfs_generic_recover_commit_reqs()
177 	cinfo->ds->nwritten = 0;  in pnfs_generic_recover_commit_reqs()
181 static void pnfs_generic_retry_commit(struct nfs_commit_info *cinfo, int idx)  in pnfs_generic_retry_commit()  argument
183 	struct pnfs_ds_commit_info *fl_cinfo = cinfo->ds;  in pnfs_generic_retry_commit()
189 	spin_lock(cinfo->lock);  in pnfs_generic_retry_commit()
197 		spin_unlock(cinfo->lock);  in pnfs_generic_retry_commit()
198 		nfs_retry_commit(&pages, freeme, cinfo, i);  in pnfs_generic_retry_commit()
200 		spin_lock(cinfo->lock);  in pnfs_generic_retry_commit()
202 	spin_unlock(cinfo->lock);  in pnfs_generic_retry_commit()
206 pnfs_generic_alloc_ds_commits(struct nfs_commit_info *cinfo,  in pnfs_generic_alloc_ds_commits()  argument
215 	fl_cinfo = cinfo->ds;  in pnfs_generic_alloc_ds_commits()
229 	pnfs_generic_retry_commit(cinfo, i);  in pnfs_generic_alloc_ds_commits()
236 		struct nfs_commit_info *cinfo)  in pnfs_fetch_commit_bucket_list()  argument
240 	bucket = &cinfo->ds->buckets[data->ds_commit_index];  in pnfs_fetch_commit_bucket_list()
241 	spin_lock(cinfo->lock);  in pnfs_fetch_commit_bucket_list()
245 	spin_unlock(cinfo->lock);  in pnfs_fetch_commit_bucket_list()
252 			     int how, struct nfs_commit_info *cinfo,  in pnfs_generic_commit_pagelist()  argument
267 			nfs_retry_commit(mds_pages, NULL, cinfo, 0);  in pnfs_generic_commit_pagelist()
268 			pnfs_generic_retry_commit(cinfo, 0);  in pnfs_generic_commit_pagelist()
269 			cinfo->completion_ops->error_cleanup(NFS_I(inode));  in pnfs_generic_commit_pagelist()
274 	nreq += pnfs_generic_alloc_ds_commits(cinfo, &list);  in pnfs_generic_commit_pagelist()
277 		cinfo->completion_ops->error_cleanup(NFS_I(inode));  in pnfs_generic_commit_pagelist()
281 	atomic_add(nreq, &cinfo->mds->rpcs_out);  in pnfs_generic_commit_pagelist()
286 			nfs_init_commit(data, mds_pages, NULL, cinfo);  in pnfs_generic_commit_pagelist()
293 			pnfs_fetch_commit_bucket_list(&pages, data, cinfo);  in pnfs_generic_commit_pagelist()
294 			nfs_init_commit(data, &pages, data->lseg, cinfo);  in pnfs_generic_commit_pagelist()
299 	cinfo->ds->ncommitting = 0;  in pnfs_generic_commit_pagelist()
864 				struct nfs_commit_info *cinfo,  in pnfs_layout_mark_request_commit()  argument
870 	spin_lock(cinfo->lock);  in pnfs_layout_mark_request_commit()
871 	buckets = cinfo->ds->buckets;  in pnfs_layout_mark_request_commit()
884 	cinfo->ds->nwritten++;  in pnfs_layout_mark_request_commit()
886 	nfs_request_add_commit_list_locked(req, list, cinfo);  in pnfs_layout_mark_request_commit()
887 	spin_unlock(cinfo->lock);  in pnfs_layout_mark_request_commit()
888 	nfs_mark_page_unstable(req->wb_page, cinfo);  in pnfs_layout_mark_request_commit()