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()
124 	for (i = 0; i < cinfo->ds->nbuckets && max != 0; i++) {  in pnfs_generic_scan_commit_lists()
125 		cnt = pnfs_generic_scan_ds_commit_list(&cinfo->ds->buckets[i],  in pnfs_generic_scan_commit_lists()
126 						       cinfo, max);  in pnfs_generic_scan_commit_lists()
136 				      struct nfs_commit_info *cinfo)  in pnfs_generic_recover_commit_reqs()  argument
143 	lockdep_assert_held(&NFS_I(cinfo->inode)->commit_mutex);  in pnfs_generic_recover_commit_reqs()
145 	for (i = 0, b = cinfo->ds->buckets; i < cinfo->ds->nbuckets; i++, b++) {  in pnfs_generic_recover_commit_reqs()
146 		nwritten = nfs_scan_commit_list(&b->written, dst, cinfo, 0);  in pnfs_generic_recover_commit_reqs()
149 		cinfo->ds->nwritten -= nwritten;  in pnfs_generic_recover_commit_reqs()
160 static void pnfs_generic_retry_commit(struct nfs_commit_info *cinfo, int idx)  in pnfs_generic_retry_commit()  argument
162 	struct pnfs_ds_commit_info *fl_cinfo = cinfo->ds;  in pnfs_generic_retry_commit()
169 	mutex_lock(&NFS_I(cinfo->inode)->commit_mutex);  in pnfs_generic_retry_commit()
177 			cinfo->ds->ncommitting--;  in pnfs_generic_retry_commit()
179 		mutex_unlock(&NFS_I(cinfo->inode)->commit_mutex);  in pnfs_generic_retry_commit()
180 		nfs_retry_commit(&pages, freeme, cinfo, i);  in pnfs_generic_retry_commit()
182 		mutex_lock(&NFS_I(cinfo->inode)->commit_mutex);  in pnfs_generic_retry_commit()
184 	mutex_unlock(&NFS_I(cinfo->inode)->commit_mutex);  in pnfs_generic_retry_commit()
188 pnfs_generic_alloc_ds_commits(struct nfs_commit_info *cinfo,  in pnfs_generic_alloc_ds_commits()  argument
197 	fl_cinfo = cinfo->ds;  in pnfs_generic_alloc_ds_commits()
211 	pnfs_generic_retry_commit(cinfo, i);  in pnfs_generic_alloc_ds_commits()
218 		struct nfs_commit_info *cinfo)  in pnfs_fetch_commit_bucket_list()  argument
223 	bucket = &cinfo->ds->buckets[data->ds_commit_index];  in pnfs_fetch_commit_bucket_list()
224 	mutex_lock(&NFS_I(cinfo->inode)->commit_mutex);  in pnfs_fetch_commit_bucket_list()
226 		cinfo->ds->ncommitting--;  in pnfs_fetch_commit_bucket_list()
230 	mutex_unlock(&NFS_I(cinfo->inode)->commit_mutex);  in pnfs_fetch_commit_bucket_list()
243 					  struct nfs_commit_info *cinfo)  in pnfs_generic_commit_cancel_empty_pagelist()  argument
246 		if (atomic_dec_and_test(&cinfo->mds->rpcs_out))  in pnfs_generic_commit_cancel_empty_pagelist()
247 			wake_up_var(&cinfo->mds->rpcs_out);  in pnfs_generic_commit_cancel_empty_pagelist()
262 			     int how, struct nfs_commit_info *cinfo,  in pnfs_generic_commit_pagelist()  argument
277 	nreq += pnfs_generic_alloc_ds_commits(cinfo, &list);  in pnfs_generic_commit_pagelist()
282 	atomic_add(nreq, &cinfo->mds->rpcs_out);  in pnfs_generic_commit_pagelist()
289 				data, cinfo))  in pnfs_generic_commit_pagelist()
292 			nfs_init_commit(data, mds_pages, NULL, cinfo);  in pnfs_generic_commit_pagelist()
299 			pnfs_fetch_commit_bucket_list(&pages, data, cinfo);  in pnfs_generic_commit_pagelist()
303 				data, cinfo))  in pnfs_generic_commit_pagelist()
306 			nfs_init_commit(data, &pages, data->lseg, cinfo);  in pnfs_generic_commit_pagelist()
930 				struct nfs_commit_info *cinfo,  in pnfs_layout_mark_request_commit()  argument
936 	mutex_lock(&NFS_I(cinfo->inode)->commit_mutex);  in pnfs_layout_mark_request_commit()
937 	buckets = cinfo->ds->buckets;  in pnfs_layout_mark_request_commit()
941 			mutex_unlock(&NFS_I(cinfo->inode)->commit_mutex);  in pnfs_layout_mark_request_commit()
942 			cinfo->completion_ops->resched_write(cinfo, req);  in pnfs_layout_mark_request_commit()
955 	cinfo->ds->nwritten++;  in pnfs_layout_mark_request_commit()
957 	nfs_request_add_commit_list_locked(req, list, cinfo);  in pnfs_layout_mark_request_commit()
958 	mutex_unlock(&NFS_I(cinfo->inode)->commit_mutex);  in pnfs_layout_mark_request_commit()
959 	nfs_mark_page_unstable(req->wb_page, cinfo);  in pnfs_layout_mark_request_commit()