22 void pnfs_generic_rw_release(void *data)  in pnfs_generic_rw_release()  argument
24 	struct nfs_pgio_header *hdr = data;  in pnfs_generic_rw_release()
27 	hdr->mds_ops->rpc_release(data);  in pnfs_generic_rw_release()
32 void pnfs_generic_prepare_to_resend_writes(struct nfs_commit_data *data)  in pnfs_generic_prepare_to_resend_writes()  argument
34 	struct nfs_page *first = nfs_list_entry(data->pages.next);  in pnfs_generic_prepare_to_resend_writes()
36 	data->task.tk_status = 0;  in pnfs_generic_prepare_to_resend_writes()
37 	memcpy(&data->verf.verifier, &first->wb_verf,  in pnfs_generic_prepare_to_resend_writes()
38 	       sizeof(data->verf.verifier));  in pnfs_generic_prepare_to_resend_writes()
39 	data->verf.verifier.data[0]++; /* ensure verifier mismatch */  in pnfs_generic_prepare_to_resend_writes()
43 void pnfs_generic_write_commit_done(struct rpc_task *task, void *data)  in pnfs_generic_write_commit_done()  argument
45 	struct nfs_commit_data *wdata = data;  in pnfs_generic_write_commit_done()
48 	wdata->mds_ops->rpc_call_done(task, data);  in pnfs_generic_write_commit_done()
54 	struct nfs_commit_data *data = calldata;  in pnfs_generic_commit_release()  local
56 	data->completion_ops->completion(data);  in pnfs_generic_commit_release()
57 	pnfs_put_lseg(data->lseg);  in pnfs_generic_commit_release()
58 	nfs_put_client(data->ds_clp);  in pnfs_generic_commit_release()
59 	nfs_commitdata_release(data);  in pnfs_generic_commit_release()
193 	struct nfs_commit_data *data;  in pnfs_generic_alloc_ds_commits()  local
202 		data = nfs_commitdata_alloc(false);  in pnfs_generic_alloc_ds_commits()
203 		if (!data)  in pnfs_generic_alloc_ds_commits()
205 		data->ds_commit_index = i;  in pnfs_generic_alloc_ds_commits()
206 		list_add(&data->pages, list);  in pnfs_generic_alloc_ds_commits()
217 		struct nfs_commit_data *data,  in pnfs_fetch_commit_bucket_list()  argument
223 	bucket = &cinfo->ds->buckets[data->ds_commit_index];  in pnfs_fetch_commit_bucket_list()
228 	data->lseg = bucket->clseg;  in pnfs_fetch_commit_bucket_list()
242 					  struct nfs_commit_data *data,  in pnfs_generic_commit_cancel_empty_pagelist()  argument
251 		WARN_ON_ONCE(data->context);  in pnfs_generic_commit_cancel_empty_pagelist()
252 		nfs_commit_free(data);  in pnfs_generic_commit_cancel_empty_pagelist()
263 			     int (*initiate_commit)(struct nfs_commit_data *data,  in pnfs_generic_commit_pagelist()  argument
266 	struct nfs_commit_data *data, *tmp;  in pnfs_generic_commit_pagelist()  local
271 		data = nfs_commitdata_alloc(true);  in pnfs_generic_commit_pagelist()
272 		data->ds_commit_index = -1;  in pnfs_generic_commit_pagelist()
273 		list_add(&data->pages, &list);  in pnfs_generic_commit_pagelist()
284 	list_for_each_entry_safe(data, tmp, &list, pages) {  in pnfs_generic_commit_pagelist()
285 		list_del_init(&data->pages);  in pnfs_generic_commit_pagelist()
286 		if (data->ds_commit_index < 0) {  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()
293 			nfs_initiate_commit(NFS_CLIENT(inode), data,  in pnfs_generic_commit_pagelist()
294 					    NFS_PROTO(data->inode),  in pnfs_generic_commit_pagelist()
295 					    data->mds_ops, how, 0);  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()
307 			initiate_commit(data, how);  in pnfs_generic_commit_pagelist()
684 				.data = &xprtdata,  in _nfs4_pnfs_v4_ds_connect()