aboutsummaryrefslogtreecommitdiffstats
path: root/fs/nfs/nfs4filelayout.c
diff options
context:
space:
mode:
Diffstat (limited to 'fs/nfs/nfs4filelayout.c')
-rw-r--r--fs/nfs/nfs4filelayout.c34
1 files changed, 17 insertions, 17 deletions
diff --git a/fs/nfs/nfs4filelayout.c b/fs/nfs/nfs4filelayout.c
index b9a35c05b60f..e6936147ad95 100644
--- a/fs/nfs/nfs4filelayout.c
+++ b/fs/nfs/nfs4filelayout.c
@@ -84,7 +84,7 @@ filelayout_get_dserver_offset(struct pnfs_layout_segment *lseg, loff_t offset)
84 BUG(); 84 BUG();
85} 85}
86 86
87static void filelayout_reset_write(struct nfs_write_data *data) 87static void filelayout_reset_write(struct nfs_pgio_data *data)
88{ 88{
89 struct nfs_pgio_header *hdr = data->header; 89 struct nfs_pgio_header *hdr = data->header;
90 struct rpc_task *task = &data->task; 90 struct rpc_task *task = &data->task;
@@ -105,7 +105,7 @@ static void filelayout_reset_write(struct nfs_write_data *data)
105 } 105 }
106} 106}
107 107
108static void filelayout_reset_read(struct nfs_read_data *data) 108static void filelayout_reset_read(struct nfs_pgio_data *data)
109{ 109{
110 struct nfs_pgio_header *hdr = data->header; 110 struct nfs_pgio_header *hdr = data->header;
111 struct rpc_task *task = &data->task; 111 struct rpc_task *task = &data->task;
@@ -243,7 +243,7 @@ wait_on_recovery:
243/* NFS_PROTO call done callback routines */ 243/* NFS_PROTO call done callback routines */
244 244
245static int filelayout_read_done_cb(struct rpc_task *task, 245static int filelayout_read_done_cb(struct rpc_task *task,
246 struct nfs_read_data *data) 246 struct nfs_pgio_data *data)
247{ 247{
248 struct nfs_pgio_header *hdr = data->header; 248 struct nfs_pgio_header *hdr = data->header;
249 int err; 249 int err;
@@ -270,7 +270,7 @@ static int filelayout_read_done_cb(struct rpc_task *task,
270 * rfc5661 is not clear about which credential should be used. 270 * rfc5661 is not clear about which credential should be used.
271 */ 271 */
272static void 272static void
273filelayout_set_layoutcommit(struct nfs_write_data *wdata) 273filelayout_set_layoutcommit(struct nfs_pgio_data *wdata)
274{ 274{
275 struct nfs_pgio_header *hdr = wdata->header; 275 struct nfs_pgio_header *hdr = wdata->header;
276 276
@@ -305,7 +305,7 @@ filelayout_reset_to_mds(struct pnfs_layout_segment *lseg)
305 */ 305 */
306static void filelayout_read_prepare(struct rpc_task *task, void *data) 306static void filelayout_read_prepare(struct rpc_task *task, void *data)
307{ 307{
308 struct nfs_read_data *rdata = data; 308 struct nfs_pgio_data *rdata = data;
309 309
310 if (unlikely(test_bit(NFS_CONTEXT_BAD, &rdata->args.context->flags))) { 310 if (unlikely(test_bit(NFS_CONTEXT_BAD, &rdata->args.context->flags))) {
311 rpc_exit(task, -EIO); 311 rpc_exit(task, -EIO);
@@ -317,7 +317,7 @@ static void filelayout_read_prepare(struct rpc_task *task, void *data)
317 rpc_exit(task, 0); 317 rpc_exit(task, 0);
318 return; 318 return;
319 } 319 }
320 rdata->read_done_cb = filelayout_read_done_cb; 320 rdata->pgio_done_cb = filelayout_read_done_cb;
321 321
322 if (nfs41_setup_sequence(rdata->ds_clp->cl_session, 322 if (nfs41_setup_sequence(rdata->ds_clp->cl_session,
323 &rdata->args.seq_args, 323 &rdata->args.seq_args,
@@ -331,7 +331,7 @@ static void filelayout_read_prepare(struct rpc_task *task, void *data)
331 331
332static void filelayout_read_call_done(struct rpc_task *task, void *data) 332static void filelayout_read_call_done(struct rpc_task *task, void *data)
333{ 333{
334 struct nfs_read_data *rdata = data; 334 struct nfs_pgio_data *rdata = data;
335 335
336 dprintk("--> %s task->tk_status %d\n", __func__, task->tk_status); 336 dprintk("--> %s task->tk_status %d\n", __func__, task->tk_status);
337 337
@@ -347,14 +347,14 @@ static void filelayout_read_call_done(struct rpc_task *task, void *data)
347 347
348static void filelayout_read_count_stats(struct rpc_task *task, void *data) 348static void filelayout_read_count_stats(struct rpc_task *task, void *data)
349{ 349{
350 struct nfs_read_data *rdata = data; 350 struct nfs_pgio_data *rdata = data;
351 351
352 rpc_count_iostats(task, NFS_SERVER(rdata->header->inode)->client->cl_metrics); 352 rpc_count_iostats(task, NFS_SERVER(rdata->header->inode)->client->cl_metrics);
353} 353}
354 354
355static void filelayout_read_release(void *data) 355static void filelayout_read_release(void *data)
356{ 356{
357 struct nfs_read_data *rdata = data; 357 struct nfs_pgio_data *rdata = data;
358 struct pnfs_layout_hdr *lo = rdata->header->lseg->pls_layout; 358 struct pnfs_layout_hdr *lo = rdata->header->lseg->pls_layout;
359 359
360 filelayout_fenceme(lo->plh_inode, lo); 360 filelayout_fenceme(lo->plh_inode, lo);
@@ -363,7 +363,7 @@ static void filelayout_read_release(void *data)
363} 363}
364 364
365static int filelayout_write_done_cb(struct rpc_task *task, 365static int filelayout_write_done_cb(struct rpc_task *task,
366 struct nfs_write_data *data) 366 struct nfs_pgio_data *data)
367{ 367{
368 struct nfs_pgio_header *hdr = data->header; 368 struct nfs_pgio_header *hdr = data->header;
369 int err; 369 int err;
@@ -419,7 +419,7 @@ static int filelayout_commit_done_cb(struct rpc_task *task,
419 419
420static void filelayout_write_prepare(struct rpc_task *task, void *data) 420static void filelayout_write_prepare(struct rpc_task *task, void *data)
421{ 421{
422 struct nfs_write_data *wdata = data; 422 struct nfs_pgio_data *wdata = data;
423 423
424 if (unlikely(test_bit(NFS_CONTEXT_BAD, &wdata->args.context->flags))) { 424 if (unlikely(test_bit(NFS_CONTEXT_BAD, &wdata->args.context->flags))) {
425 rpc_exit(task, -EIO); 425 rpc_exit(task, -EIO);
@@ -443,7 +443,7 @@ static void filelayout_write_prepare(struct rpc_task *task, void *data)
443 443
444static void filelayout_write_call_done(struct rpc_task *task, void *data) 444static void filelayout_write_call_done(struct rpc_task *task, void *data)
445{ 445{
446 struct nfs_write_data *wdata = data; 446 struct nfs_pgio_data *wdata = data;
447 447
448 if (test_bit(NFS_IOHDR_REDO, &wdata->header->flags) && 448 if (test_bit(NFS_IOHDR_REDO, &wdata->header->flags) &&
449 task->tk_status == 0) { 449 task->tk_status == 0) {
@@ -457,14 +457,14 @@ static void filelayout_write_call_done(struct rpc_task *task, void *data)
457 457
458static void filelayout_write_count_stats(struct rpc_task *task, void *data) 458static void filelayout_write_count_stats(struct rpc_task *task, void *data)
459{ 459{
460 struct nfs_write_data *wdata = data; 460 struct nfs_pgio_data *wdata = data;
461 461
462 rpc_count_iostats(task, NFS_SERVER(wdata->header->inode)->client->cl_metrics); 462 rpc_count_iostats(task, NFS_SERVER(wdata->header->inode)->client->cl_metrics);
463} 463}
464 464
465static void filelayout_write_release(void *data) 465static void filelayout_write_release(void *data)
466{ 466{
467 struct nfs_write_data *wdata = data; 467 struct nfs_pgio_data *wdata = data;
468 struct pnfs_layout_hdr *lo = wdata->header->lseg->pls_layout; 468 struct pnfs_layout_hdr *lo = wdata->header->lseg->pls_layout;
469 469
470 filelayout_fenceme(lo->plh_inode, lo); 470 filelayout_fenceme(lo->plh_inode, lo);
@@ -529,7 +529,7 @@ static const struct rpc_call_ops filelayout_commit_call_ops = {
529}; 529};
530 530
531static enum pnfs_try_status 531static enum pnfs_try_status
532filelayout_read_pagelist(struct nfs_read_data *data) 532filelayout_read_pagelist(struct nfs_pgio_data *data)
533{ 533{
534 struct nfs_pgio_header *hdr = data->header; 534 struct nfs_pgio_header *hdr = data->header;
535 struct pnfs_layout_segment *lseg = hdr->lseg; 535 struct pnfs_layout_segment *lseg = hdr->lseg;
@@ -575,7 +575,7 @@ filelayout_read_pagelist(struct nfs_read_data *data)
575 575
576/* Perform async writes. */ 576/* Perform async writes. */
577static enum pnfs_try_status 577static enum pnfs_try_status
578filelayout_write_pagelist(struct nfs_write_data *data, int sync) 578filelayout_write_pagelist(struct nfs_pgio_data *data, int sync)
579{ 579{
580 struct nfs_pgio_header *hdr = data->header; 580 struct nfs_pgio_header *hdr = data->header;
581 struct pnfs_layout_segment *lseg = hdr->lseg; 581 struct pnfs_layout_segment *lseg = hdr->lseg;
@@ -600,7 +600,7 @@ filelayout_write_pagelist(struct nfs_write_data *data, int sync)
600 __func__, hdr->inode->i_ino, sync, (size_t) data->args.count, 600 __func__, hdr->inode->i_ino, sync, (size_t) data->args.count,
601 offset, ds->ds_remotestr, atomic_read(&ds->ds_clp->cl_count)); 601 offset, ds->ds_remotestr, atomic_read(&ds->ds_clp->cl_count));
602 602
603 data->write_done_cb = filelayout_write_done_cb; 603 data->pgio_done_cb = filelayout_write_done_cb;
604 atomic_inc(&ds->ds_clp->cl_count); 604 atomic_inc(&ds->ds_clp->cl_count);
605 data->ds_clp = ds->ds_clp; 605 data->ds_clp = ds->ds_clp;
606 fh = nfs4_fl_select_ds_fh(lseg, j); 606 fh = nfs4_fl_select_ds_fh(lseg, j);