Lines Matching defs:data
22 void pnfs_generic_rw_release(void *data)
24 struct nfs_pgio_header *hdr = data;
27 hdr->mds_ops->rpc_release(data);
31 /* Fake up some data that will cause nfs_commit_release to retry the writes. */
32 void pnfs_generic_prepare_to_resend_writes(struct nfs_commit_data *data)
34 struct nfs_writeverf *verf = data->res.verf;
36 data->task.tk_status = 0;
42 void pnfs_generic_write_commit_done(struct rpc_task *task, void *data)
44 struct nfs_commit_data *wdata = data;
47 wdata->mds_ops->rpc_call_done(task, data);
53 struct nfs_commit_data *data = calldata;
55 data->completion_ops->completion(data);
56 pnfs_put_lseg(data->lseg);
57 nfs_put_client(data->ds_clp);
58 nfs_commitdata_release(data);
422 struct nfs_commit_data *data = nfs_commitdata_alloc();
424 if (!data)
426 data->lseg = pnfs_bucket_get_committing(&data->pages, bucket, cinfo);
427 return data;
457 struct nfs_commit_data *data;
466 data = pnfs_bucket_fetch_commitdata(bucket, cinfo);
467 if (!data)
469 data->ds_commit_index = i;
470 list_add_tail(&data->list, list);
509 int (*initiate_commit)(struct nfs_commit_data *data,
513 struct nfs_commit_data *data, *tmp;
518 data = nfs_commitdata_alloc();
519 if (!data) {
523 data->ds_commit_index = -1;
524 list_splice_init(mds_pages, &data->pages);
525 list_add_tail(&data->list, &list);
533 list_for_each_entry_safe(data, tmp, &list, list) {
534 list_del(&data->list);
535 if (data->ds_commit_index < 0) {
536 nfs_init_commit(data, NULL, NULL, cinfo);
537 nfs_initiate_commit(NFS_CLIENT(inode), data,
538 NFS_PROTO(data->inode),
539 data->mds_ops, how,
542 nfs_init_commit(data, NULL, data->lseg, cinfo);
543 initiate_commit(data, how);
557 * - incremented when a device id maps a data server already in the cache.
793 dprintk("%s add new data server %s\n", __func__,
799 dprintk("%s data server %s found, inc'ed ds_count to %d\n",
941 .data = &xprtdata,
1030 * Create an rpc connection to the nfs4_pnfs_ds data server.