diff options
Diffstat (limited to 'fs/nfs/nfs4filelayout.c')
-rw-r--r-- | fs/nfs/nfs4filelayout.c | 34 |
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 | ||
87 | static void filelayout_reset_write(struct nfs_write_data *data) | 87 | static 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 | ||
108 | static void filelayout_reset_read(struct nfs_read_data *data) | 108 | static 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 | ||
245 | static int filelayout_read_done_cb(struct rpc_task *task, | 245 | static 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 | */ |
272 | static void | 272 | static void |
273 | filelayout_set_layoutcommit(struct nfs_write_data *wdata) | 273 | filelayout_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 | */ |
306 | static void filelayout_read_prepare(struct rpc_task *task, void *data) | 306 | static 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 | ||
332 | static void filelayout_read_call_done(struct rpc_task *task, void *data) | 332 | static 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 | ||
348 | static void filelayout_read_count_stats(struct rpc_task *task, void *data) | 348 | static 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 | ||
355 | static void filelayout_read_release(void *data) | 355 | static 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 | ||
365 | static int filelayout_write_done_cb(struct rpc_task *task, | 365 | static 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 | ||
420 | static void filelayout_write_prepare(struct rpc_task *task, void *data) | 420 | static 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 | ||
444 | static void filelayout_write_call_done(struct rpc_task *task, void *data) | 444 | static 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 | ||
458 | static void filelayout_write_count_stats(struct rpc_task *task, void *data) | 458 | static 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 | ||
465 | static void filelayout_write_release(void *data) | 465 | static 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 | ||
531 | static enum pnfs_try_status | 531 | static enum pnfs_try_status |
532 | filelayout_read_pagelist(struct nfs_read_data *data) | 532 | filelayout_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. */ |
577 | static enum pnfs_try_status | 577 | static enum pnfs_try_status |
578 | filelayout_write_pagelist(struct nfs_write_data *data, int sync) | 578 | filelayout_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); |