Lines Matching refs:task
33 static void ff_layout_read_record_layoutstats_done(struct rpc_task *task,
693 nfs4_ff_layout_stat_io_end_read(struct rpc_task *task, in nfs4_ff_layout_stat_io_end_read() argument
701 ktime_get(), task->tk_start); in nfs4_ff_layout_stat_io_end_read()
724 nfs4_ff_layout_stat_io_end_write(struct rpc_task *task, in nfs4_ff_layout_stat_io_end_write() argument
735 requested, completed, ktime_get(), task->tk_start); in nfs4_ff_layout_stat_io_end_write()
996 struct rpc_task *task = &hdr->task; in ff_layout_reset_write() local
1003 hdr->task.tk_pid, in ff_layout_reset_write()
1016 hdr->task.tk_pid, in ff_layout_reset_write()
1022 task->tk_status = pnfs_write_done_resend_to_mds(hdr); in ff_layout_reset_write()
1028 struct rpc_task *task = &hdr->task; in ff_layout_reset_read() local
1035 hdr->task.tk_pid, in ff_layout_reset_read()
1041 task->tk_status = pnfs_read_done_resend_to_mds(hdr); in ff_layout_reset_read()
1045 static int ff_layout_async_handle_error_v4(struct rpc_task *task, in ff_layout_async_handle_error_v4() argument
1056 switch (task->tk_status) { in ff_layout_async_handle_error_v4()
1065 "flags 0x%x\n", __func__, task->tk_status, in ff_layout_async_handle_error_v4()
1067 nfs4_schedule_session_recovery(clp->cl_session, task->tk_status); in ff_layout_async_handle_error_v4()
1071 rpc_delay(task, FF_LAYOUT_POLL_RETRY_MAX); in ff_layout_async_handle_error_v4()
1083 task->tk_status); in ff_layout_async_handle_error_v4()
1103 task->tk_status); in ff_layout_async_handle_error_v4()
1113 task->tk_status); in ff_layout_async_handle_error_v4()
1116 task->tk_status = 0; in ff_layout_async_handle_error_v4()
1121 static int ff_layout_async_handle_error_v3(struct rpc_task *task, in ff_layout_async_handle_error_v3() argument
1127 switch (task->tk_status) { in ff_layout_async_handle_error_v3()
1141 task->tk_status); in ff_layout_async_handle_error_v3()
1148 task->tk_status = 0; in ff_layout_async_handle_error_v3()
1149 rpc_restart_call_prepare(task); in ff_layout_async_handle_error_v3()
1150 rpc_delay(task, NFS_JUKEBOX_RETRY_TIME); in ff_layout_async_handle_error_v3()
1154 static int ff_layout_async_handle_error(struct rpc_task *task, in ff_layout_async_handle_error() argument
1162 if (task->tk_status >= 0) in ff_layout_async_handle_error()
1171 return ff_layout_async_handle_error_v3(task, lseg, idx); in ff_layout_async_handle_error()
1173 return ff_layout_async_handle_error_v4(task, state, clp, in ff_layout_async_handle_error()
1231 static int ff_layout_read_done_cb(struct rpc_task *task, in ff_layout_read_done_cb() argument
1236 trace_nfs4_pnfs_read(hdr, task->tk_status); in ff_layout_read_done_cb()
1237 if (task->tk_status < 0) in ff_layout_read_done_cb()
1241 task->tk_status); in ff_layout_read_done_cb()
1242 err = ff_layout_async_handle_error(task, hdr->args.context->state, in ff_layout_read_done_cb()
1252 ff_layout_read_record_layoutstats_done(task, hdr); in ff_layout_read_done_cb()
1254 return task->tk_status; in ff_layout_read_done_cb()
1257 return task->tk_status; in ff_layout_read_done_cb()
1264 rpc_restart_call_prepare(task); in ff_layout_read_done_cb()
1305 static void ff_layout_read_record_layoutstats_start(struct rpc_task *task, in ff_layout_read_record_layoutstats_start() argument
1313 task->tk_start); in ff_layout_read_record_layoutstats_start()
1316 static void ff_layout_read_record_layoutstats_done(struct rpc_task *task, in ff_layout_read_record_layoutstats_done() argument
1321 nfs4_ff_layout_stat_io_end_read(task, in ff_layout_read_record_layoutstats_done()
1327 static int ff_layout_read_prepare_common(struct rpc_task *task, in ff_layout_read_prepare_common() argument
1331 rpc_exit(task, -EIO); in ff_layout_read_prepare_common()
1335 rpc_exit(task, -EHOSTDOWN); in ff_layout_read_prepare_common()
1339 ff_layout_read_record_layoutstats_start(task, hdr); in ff_layout_read_prepare_common()
1348 static void ff_layout_read_prepare_v3(struct rpc_task *task, void *data) in ff_layout_read_prepare_v3() argument
1352 if (ff_layout_read_prepare_common(task, hdr)) in ff_layout_read_prepare_v3()
1355 rpc_call_start(task); in ff_layout_read_prepare_v3()
1358 static void ff_layout_read_prepare_v4(struct rpc_task *task, void *data) in ff_layout_read_prepare_v4() argument
1365 task)) in ff_layout_read_prepare_v4()
1368 ff_layout_read_prepare_common(task, hdr); in ff_layout_read_prepare_v4()
1371 static void ff_layout_read_call_done(struct rpc_task *task, void *data) in ff_layout_read_call_done() argument
1375 dprintk("--> %s task->tk_status %d\n", __func__, task->tk_status); in ff_layout_read_call_done()
1378 task->tk_status == 0) { in ff_layout_read_call_done()
1379 nfs4_sequence_done(task, &hdr->res.seq_res); in ff_layout_read_call_done()
1384 hdr->mds_ops->rpc_call_done(task, hdr); in ff_layout_read_call_done()
1387 static void ff_layout_read_count_stats(struct rpc_task *task, void *data) in ff_layout_read_count_stats() argument
1391 ff_layout_read_record_layoutstats_done(task, hdr); in ff_layout_read_count_stats()
1392 rpc_count_iostats_metrics(task, in ff_layout_read_count_stats()
1400 ff_layout_read_record_layoutstats_done(&hdr->task, hdr); in ff_layout_read_release()
1405 static int ff_layout_write_done_cb(struct rpc_task *task, in ff_layout_write_done_cb() argument
1411 trace_nfs4_pnfs_write(hdr, task->tk_status); in ff_layout_write_done_cb()
1412 if (task->tk_status < 0) in ff_layout_write_done_cb()
1416 task->tk_status); in ff_layout_write_done_cb()
1417 err = ff_layout_async_handle_error(task, hdr->args.context->state, in ff_layout_write_done_cb()
1424 return task->tk_status; in ff_layout_write_done_cb()
1427 return task->tk_status; in ff_layout_write_done_cb()
1441 if (task->tk_status >= 0) in ff_layout_write_done_cb()
1447 static int ff_layout_commit_done_cb(struct rpc_task *task, in ff_layout_commit_done_cb() argument
1452 trace_nfs4_pnfs_commit_ds(data, task->tk_status); in ff_layout_commit_done_cb()
1453 if (task->tk_status < 0) in ff_layout_commit_done_cb()
1457 task->tk_status); in ff_layout_commit_done_cb()
1458 err = ff_layout_async_handle_error(task, NULL, data->ds_clp, in ff_layout_commit_done_cb()
1469 rpc_restart_call_prepare(task); in ff_layout_commit_done_cb()
1478 static void ff_layout_write_record_layoutstats_start(struct rpc_task *task, in ff_layout_write_record_layoutstats_start() argument
1486 task->tk_start); in ff_layout_write_record_layoutstats_start()
1489 static void ff_layout_write_record_layoutstats_done(struct rpc_task *task, in ff_layout_write_record_layoutstats_done() argument
1494 nfs4_ff_layout_stat_io_end_write(task, in ff_layout_write_record_layoutstats_done()
1500 static int ff_layout_write_prepare_common(struct rpc_task *task, in ff_layout_write_prepare_common() argument
1504 rpc_exit(task, -EIO); in ff_layout_write_prepare_common()
1509 rpc_exit(task, -EHOSTDOWN); in ff_layout_write_prepare_common()
1513 ff_layout_write_record_layoutstats_start(task, hdr); in ff_layout_write_prepare_common()
1517 static void ff_layout_write_prepare_v3(struct rpc_task *task, void *data) in ff_layout_write_prepare_v3() argument
1521 if (ff_layout_write_prepare_common(task, hdr)) in ff_layout_write_prepare_v3()
1524 rpc_call_start(task); in ff_layout_write_prepare_v3()
1527 static void ff_layout_write_prepare_v4(struct rpc_task *task, void *data) in ff_layout_write_prepare_v4() argument
1534 task)) in ff_layout_write_prepare_v4()
1537 ff_layout_write_prepare_common(task, hdr); in ff_layout_write_prepare_v4()
1540 static void ff_layout_write_call_done(struct rpc_task *task, void *data) in ff_layout_write_call_done() argument
1545 task->tk_status == 0) { in ff_layout_write_call_done()
1546 nfs4_sequence_done(task, &hdr->res.seq_res); in ff_layout_write_call_done()
1551 hdr->mds_ops->rpc_call_done(task, hdr); in ff_layout_write_call_done()
1554 static void ff_layout_write_count_stats(struct rpc_task *task, void *data) in ff_layout_write_count_stats() argument
1558 ff_layout_write_record_layoutstats_done(task, hdr); in ff_layout_write_count_stats()
1559 rpc_count_iostats_metrics(task, in ff_layout_write_count_stats()
1567 ff_layout_write_record_layoutstats_done(&hdr->task, hdr); in ff_layout_write_release()
1571 static void ff_layout_commit_record_layoutstats_start(struct rpc_task *task, in ff_layout_commit_record_layoutstats_start() argument
1578 0, task->tk_start); in ff_layout_commit_record_layoutstats_start()
1581 static void ff_layout_commit_record_layoutstats_done(struct rpc_task *task, in ff_layout_commit_record_layoutstats_done() argument
1590 if (task->tk_status == 0) { in ff_layout_commit_record_layoutstats_done()
1594 nfs4_ff_layout_stat_io_end_write(task, in ff_layout_commit_record_layoutstats_done()
1599 static void ff_layout_commit_prepare_common(struct rpc_task *task, in ff_layout_commit_prepare_common() argument
1602 ff_layout_commit_record_layoutstats_start(task, cdata); in ff_layout_commit_prepare_common()
1605 static void ff_layout_commit_prepare_v3(struct rpc_task *task, void *data) in ff_layout_commit_prepare_v3() argument
1607 ff_layout_commit_prepare_common(task, data); in ff_layout_commit_prepare_v3()
1608 rpc_call_start(task); in ff_layout_commit_prepare_v3()
1611 static void ff_layout_commit_prepare_v4(struct rpc_task *task, void *data) in ff_layout_commit_prepare_v4() argument
1618 task)) in ff_layout_commit_prepare_v4()
1620 ff_layout_commit_prepare_common(task, data); in ff_layout_commit_prepare_v4()
1623 static void ff_layout_commit_done(struct rpc_task *task, void *data) in ff_layout_commit_done() argument
1625 pnfs_generic_write_commit_done(task, data); in ff_layout_commit_done()
1628 static void ff_layout_commit_count_stats(struct rpc_task *task, void *data) in ff_layout_commit_count_stats() argument
1632 ff_layout_commit_record_layoutstats_done(task, cdata); in ff_layout_commit_count_stats()
1633 rpc_count_iostats_metrics(task, in ff_layout_commit_count_stats()
1641 ff_layout_commit_record_layoutstats_done(&cdata->task, cdata); in ff_layout_commit_release()