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()
139 int pnfs_generic_scan_commit_lists(struct nfs_commit_info *cinfo,  in pnfs_generic_scan_commit_lists()  argument
144 	lockdep_assert_held(cinfo->lock);  in pnfs_generic_scan_commit_lists()
145 	for (i = 0; i < cinfo->ds->nbuckets && max != 0; i++) {  in pnfs_generic_scan_commit_lists()
146 		cnt = pnfs_generic_scan_ds_commit_list(&cinfo->ds->buckets[i],  in pnfs_generic_scan_commit_lists()
147 						       cinfo, max);  in pnfs_generic_scan_commit_lists()
157 				      struct nfs_commit_info *cinfo)  in pnfs_generic_recover_commit_reqs()  argument
163 	lockdep_assert_held(cinfo->lock);  in pnfs_generic_recover_commit_reqs()
165 	for (i = 0, b = cinfo->ds->buckets; i < cinfo->ds->nbuckets; i++, b++) {  in pnfs_generic_recover_commit_reqs()
167 						      cinfo, 0)) {  in pnfs_generic_recover_commit_reqs()
170 			spin_unlock(cinfo->lock);  in pnfs_generic_recover_commit_reqs()
172 			spin_lock(cinfo->lock);  in pnfs_generic_recover_commit_reqs()
176 	cinfo->ds->nwritten = 0;  in pnfs_generic_recover_commit_reqs()
180 static void pnfs_generic_retry_commit(struct nfs_commit_info *cinfo, int idx)  in pnfs_generic_retry_commit()  argument
182 	struct pnfs_ds_commit_info *fl_cinfo = cinfo->ds;  in pnfs_generic_retry_commit()
191 		nfs_retry_commit(&bucket->committing, bucket->clseg, cinfo, i);  in pnfs_generic_retry_commit()
192 		spin_lock(cinfo->lock);  in pnfs_generic_retry_commit()
195 		spin_unlock(cinfo->lock);  in pnfs_generic_retry_commit()
201 pnfs_generic_alloc_ds_commits(struct nfs_commit_info *cinfo,  in pnfs_generic_alloc_ds_commits()  argument
210 	fl_cinfo = cinfo->ds;  in pnfs_generic_alloc_ds_commits()
219 		spin_lock(cinfo->lock);  in pnfs_generic_alloc_ds_commits()
222 		spin_unlock(cinfo->lock);  in pnfs_generic_alloc_ds_commits()
228 	pnfs_generic_retry_commit(cinfo, i);  in pnfs_generic_alloc_ds_commits()
235 			     int how, struct nfs_commit_info *cinfo,  in pnfs_generic_commit_pagelist()  argument
250 			nfs_retry_commit(mds_pages, NULL, cinfo, 0);  in pnfs_generic_commit_pagelist()
251 			pnfs_generic_retry_commit(cinfo, 0);  in pnfs_generic_commit_pagelist()
252 			cinfo->completion_ops->error_cleanup(NFS_I(inode));  in pnfs_generic_commit_pagelist()
257 	nreq += pnfs_generic_alloc_ds_commits(cinfo, &list);  in pnfs_generic_commit_pagelist()
260 		cinfo->completion_ops->error_cleanup(NFS_I(inode));  in pnfs_generic_commit_pagelist()
264 	atomic_add(nreq, &cinfo->mds->rpcs_out);  in pnfs_generic_commit_pagelist()
269 			nfs_init_commit(data, mds_pages, NULL, cinfo);  in pnfs_generic_commit_pagelist()
276 			buckets = cinfo->ds->buckets;  in pnfs_generic_commit_pagelist()
280 					cinfo);  in pnfs_generic_commit_pagelist()
285 	cinfo->ds->ncommitting = 0;  in pnfs_generic_commit_pagelist()
850 				struct nfs_commit_info *cinfo,  in pnfs_layout_mark_request_commit()  argument
856 	spin_lock(cinfo->lock);  in pnfs_layout_mark_request_commit()
857 	buckets = cinfo->ds->buckets;  in pnfs_layout_mark_request_commit()
870 	cinfo->ds->nwritten++;  in pnfs_layout_mark_request_commit()
871 	spin_unlock(cinfo->lock);  in pnfs_layout_mark_request_commit()
873 	nfs_request_add_commit_list(req, list, cinfo);  in pnfs_layout_mark_request_commit()