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,  in pnfs_generic_scan_ds_commit_list()  argument
99 	lockdep_assert_held(&NFS_I(cinfo->inode)->commit_mutex);  in pnfs_generic_scan_ds_commit_list()
100 	ret = nfs_scan_commit_list(src, dst, cinfo, max);  in pnfs_generic_scan_ds_commit_list()
102 		cinfo->ds->nwritten -= ret;  in pnfs_generic_scan_ds_commit_list()
103 		cinfo->ds->ncommitting += ret;  in pnfs_generic_scan_ds_commit_list()
117 int pnfs_generic_scan_commit_lists(struct nfs_commit_info *cinfo,  in pnfs_generic_scan_commit_lists()  argument
122 	lockdep_assert_held(&NFS_I(cinfo->inode)->commit_mutex);  in pnfs_generic_scan_commit_lists()
123 	for (i = 0; i < cinfo->ds->nbuckets && max != 0; i++) {  in pnfs_generic_scan_commit_lists()
124 		cnt = pnfs_generic_scan_ds_commit_list(&cinfo->ds->buckets[i],  in pnfs_generic_scan_commit_lists()
125 						       cinfo, max);  in pnfs_generic_scan_commit_lists()
135 				      struct nfs_commit_info *cinfo)  in pnfs_generic_recover_commit_reqs()  argument
142 	lockdep_assert_held(&NFS_I(cinfo->inode)->commit_mutex);  in pnfs_generic_recover_commit_reqs()
144 	for (i = 0, b = cinfo->ds->buckets; i < cinfo->ds->nbuckets; i++, b++) {  in pnfs_generic_recover_commit_reqs()
145 		nwritten = nfs_scan_commit_list(&b->written, dst, cinfo, 0);  in pnfs_generic_recover_commit_reqs()
148 		cinfo->ds->nwritten -= nwritten;  in pnfs_generic_recover_commit_reqs()
159 static void pnfs_generic_retry_commit(struct nfs_commit_info *cinfo, int idx)  in pnfs_generic_retry_commit()  argument
161 	struct pnfs_ds_commit_info *fl_cinfo = cinfo->ds;  in pnfs_generic_retry_commit()
168 	mutex_lock(&NFS_I(cinfo->inode)->commit_mutex);  in pnfs_generic_retry_commit()
176 			cinfo->ds->ncommitting--;  in pnfs_generic_retry_commit()
178 		mutex_unlock(&NFS_I(cinfo->inode)->commit_mutex);  in pnfs_generic_retry_commit()
179 		nfs_retry_commit(&pages, freeme, cinfo, i);  in pnfs_generic_retry_commit()
181 		mutex_lock(&NFS_I(cinfo->inode)->commit_mutex);  in pnfs_generic_retry_commit()
183 	mutex_unlock(&NFS_I(cinfo->inode)->commit_mutex);  in pnfs_generic_retry_commit()
187 pnfs_generic_alloc_ds_commits(struct nfs_commit_info *cinfo,  in pnfs_generic_alloc_ds_commits()  argument
196 	fl_cinfo = cinfo->ds;  in pnfs_generic_alloc_ds_commits()
210 	pnfs_generic_retry_commit(cinfo, i);  in pnfs_generic_alloc_ds_commits()
217 		struct nfs_commit_info *cinfo)  in pnfs_fetch_commit_bucket_list()  argument
222 	bucket = &cinfo->ds->buckets[data->ds_commit_index];  in pnfs_fetch_commit_bucket_list()
223 	mutex_lock(&NFS_I(cinfo->inode)->commit_mutex);  in pnfs_fetch_commit_bucket_list()
225 		cinfo->ds->ncommitting--;  in pnfs_fetch_commit_bucket_list()
229 	mutex_unlock(&NFS_I(cinfo->inode)->commit_mutex);  in pnfs_fetch_commit_bucket_list()
242 					  struct nfs_commit_info *cinfo)  in pnfs_generic_commit_cancel_empty_pagelist()  argument
245 		if (atomic_dec_and_test(&cinfo->mds->rpcs_out))  in pnfs_generic_commit_cancel_empty_pagelist()
246 			wake_up_var(&cinfo->mds->rpcs_out);  in pnfs_generic_commit_cancel_empty_pagelist()
261 			     int how, struct nfs_commit_info *cinfo,  in pnfs_generic_commit_pagelist()  argument
276 	nreq += pnfs_generic_alloc_ds_commits(cinfo, &list);  in pnfs_generic_commit_pagelist()
281 	atomic_add(nreq, &cinfo->mds->rpcs_out);  in pnfs_generic_commit_pagelist()
288 				data, cinfo))  in pnfs_generic_commit_pagelist()
291 			nfs_init_commit(data, mds_pages, NULL, cinfo);  in pnfs_generic_commit_pagelist()
298 			pnfs_fetch_commit_bucket_list(&pages, data, cinfo);  in pnfs_generic_commit_pagelist()
302 				data, cinfo))  in pnfs_generic_commit_pagelist()
305 			nfs_init_commit(data, &pages, data->lseg, cinfo);  in pnfs_generic_commit_pagelist()
924 				struct nfs_commit_info *cinfo,  in pnfs_layout_mark_request_commit()  argument
930 	mutex_lock(&NFS_I(cinfo->inode)->commit_mutex);  in pnfs_layout_mark_request_commit()
931 	buckets = cinfo->ds->buckets;  in pnfs_layout_mark_request_commit()
935 			mutex_unlock(&NFS_I(cinfo->inode)->commit_mutex);  in pnfs_layout_mark_request_commit()
936 			cinfo->completion_ops->resched_write(cinfo, req);  in pnfs_layout_mark_request_commit()
949 	cinfo->ds->nwritten++;  in pnfs_layout_mark_request_commit()
951 	nfs_request_add_commit_list_locked(req, list, cinfo);  in pnfs_layout_mark_request_commit()
952 	mutex_unlock(&NFS_I(cinfo->inode)->commit_mutex);  in pnfs_layout_mark_request_commit()
953 	nfs_mark_page_unstable(req->wb_page, cinfo);  in pnfs_layout_mark_request_commit()