Lines Matching refs:task
42 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()
1037 struct rpc_task *task = &hdr->task; in ff_layout_reset_write() local
1044 hdr->task.tk_pid, in ff_layout_reset_write()
1057 hdr->task.tk_pid, in ff_layout_reset_write()
1067 task->tk_status = pnfs_write_done_resend_to_mds(hdr); in ff_layout_reset_write()
1085 struct rpc_task *task = &hdr->task; in ff_layout_reset_read() local
1093 hdr->task.tk_pid, in ff_layout_reset_read()
1103 task->tk_status = pnfs_read_done_resend_to_mds(hdr); in ff_layout_reset_read()
1107 static int ff_layout_async_handle_error_v4(struct rpc_task *task, in ff_layout_async_handle_error_v4() argument
1124 if (!task->tk_xprt) in ff_layout_async_handle_error_v4()
1126 xprt_force_disconnect(task->tk_xprt); in ff_layout_async_handle_error_v4()
1136 "flags 0x%x\n", __func__, task->tk_status, in ff_layout_async_handle_error_v4()
1138 nfs4_schedule_session_recovery(clp->cl_session, task->tk_status); in ff_layout_async_handle_error_v4()
1144 rpc_delay(task, FF_LAYOUT_POLL_RETRY_MAX); in ff_layout_async_handle_error_v4()
1156 task->tk_status); in ff_layout_async_handle_error_v4()
1171 switch (task->tk_status) { in ff_layout_async_handle_error_v4()
1187 task->tk_status); in ff_layout_async_handle_error_v4()
1200 task->tk_status); in ff_layout_async_handle_error_v4()
1204 task->tk_status = 0; in ff_layout_async_handle_error_v4()
1209 static int ff_layout_async_handle_error_v3(struct rpc_task *task, in ff_layout_async_handle_error_v3() argument
1222 if (!task->tk_xprt) in ff_layout_async_handle_error_v3()
1224 xprt_force_disconnect(task->tk_xprt); in ff_layout_async_handle_error_v3()
1241 switch (task->tk_status) { in ff_layout_async_handle_error_v3()
1260 task->tk_status); in ff_layout_async_handle_error_v3()
1268 task->tk_status = 0; in ff_layout_async_handle_error_v3()
1269 rpc_restart_call_prepare(task); in ff_layout_async_handle_error_v3()
1270 rpc_delay(task, NFS_JUKEBOX_RETRY_TIME); in ff_layout_async_handle_error_v3()
1274 static int ff_layout_async_handle_error(struct rpc_task *task, in ff_layout_async_handle_error() argument
1283 if (task->tk_status >= 0) { in ff_layout_async_handle_error()
1294 return ff_layout_async_handle_error_v3(task, op_status, clp, in ff_layout_async_handle_error()
1297 return ff_layout_async_handle_error_v4(task, op_status, state, in ff_layout_async_handle_error()
1371 static int ff_layout_read_done_cb(struct rpc_task *task, in ff_layout_read_done_cb() argument
1376 if (task->tk_status < 0) { in ff_layout_read_done_cb()
1380 task->tk_status); in ff_layout_read_done_cb()
1381 trace_ff_layout_read_error(hdr, task->tk_status); in ff_layout_read_done_cb()
1384 err = ff_layout_async_handle_error(task, hdr->res.op_status, in ff_layout_read_done_cb()
1395 return task->tk_status; in ff_layout_read_done_cb()
1398 return task->tk_status; in ff_layout_read_done_cb()
1402 task->tk_status = -EIO; in ff_layout_read_done_cb()
1408 rpc_restart_call_prepare(task); in ff_layout_read_done_cb()
1440 static void ff_layout_read_record_layoutstats_start(struct rpc_task *task, in ff_layout_read_record_layoutstats_start() argument
1448 task->tk_start); in ff_layout_read_record_layoutstats_start()
1451 static void ff_layout_read_record_layoutstats_done(struct rpc_task *task, in ff_layout_read_record_layoutstats_done() argument
1456 nfs4_ff_layout_stat_io_end_read(task, in ff_layout_read_record_layoutstats_done()
1463 static int ff_layout_read_prepare_common(struct rpc_task *task, in ff_layout_read_prepare_common() argument
1467 rpc_exit(task, -EIO); in ff_layout_read_prepare_common()
1472 rpc_exit(task, -EAGAIN); in ff_layout_read_prepare_common()
1476 ff_layout_read_record_layoutstats_start(task, hdr); in ff_layout_read_prepare_common()
1485 static void ff_layout_read_prepare_v3(struct rpc_task *task, void *data) in ff_layout_read_prepare_v3() argument
1489 if (ff_layout_read_prepare_common(task, hdr)) in ff_layout_read_prepare_v3()
1492 rpc_call_start(task); in ff_layout_read_prepare_v3()
1495 static void ff_layout_read_prepare_v4(struct rpc_task *task, void *data) in ff_layout_read_prepare_v4() argument
1502 task)) in ff_layout_read_prepare_v4()
1505 ff_layout_read_prepare_common(task, hdr); in ff_layout_read_prepare_v4()
1508 static void ff_layout_read_call_done(struct rpc_task *task, void *data) in ff_layout_read_call_done() argument
1513 task->tk_status == 0) { in ff_layout_read_call_done()
1514 nfs4_sequence_done(task, &hdr->res.seq_res); in ff_layout_read_call_done()
1519 hdr->mds_ops->rpc_call_done(task, hdr); in ff_layout_read_call_done()
1522 static void ff_layout_read_count_stats(struct rpc_task *task, void *data) in ff_layout_read_count_stats() argument
1526 ff_layout_read_record_layoutstats_done(task, hdr); in ff_layout_read_count_stats()
1527 rpc_count_iostats_metrics(task, in ff_layout_read_count_stats()
1535 ff_layout_read_record_layoutstats_done(&hdr->task, hdr); in ff_layout_read_release()
1544 static int ff_layout_write_done_cb(struct rpc_task *task, in ff_layout_write_done_cb() argument
1550 if (task->tk_status < 0) { in ff_layout_write_done_cb()
1554 task->tk_status); in ff_layout_write_done_cb()
1555 trace_ff_layout_write_error(hdr, task->tk_status); in ff_layout_write_done_cb()
1558 err = ff_layout_async_handle_error(task, hdr->res.op_status, in ff_layout_write_done_cb()
1569 return task->tk_status; in ff_layout_write_done_cb()
1572 return task->tk_status; in ff_layout_write_done_cb()
1576 task->tk_status = -EIO; in ff_layout_write_done_cb()
1589 if (task->tk_status >= 0) in ff_layout_write_done_cb()
1595 static int ff_layout_commit_done_cb(struct rpc_task *task, in ff_layout_commit_done_cb() argument
1600 if (task->tk_status < 0) { in ff_layout_commit_done_cb()
1604 task->tk_status); in ff_layout_commit_done_cb()
1605 trace_ff_layout_commit_error(data, task->tk_status); in ff_layout_commit_done_cb()
1608 err = ff_layout_async_handle_error(task, data->res.op_status, in ff_layout_commit_done_cb()
1621 rpc_restart_call_prepare(task); in ff_layout_commit_done_cb()
1624 task->tk_status = -EIO; in ff_layout_commit_done_cb()
1633 static void ff_layout_write_record_layoutstats_start(struct rpc_task *task, in ff_layout_write_record_layoutstats_start() argument
1641 task->tk_start); in ff_layout_write_record_layoutstats_start()
1644 static void ff_layout_write_record_layoutstats_done(struct rpc_task *task, in ff_layout_write_record_layoutstats_done() argument
1649 nfs4_ff_layout_stat_io_end_write(task, in ff_layout_write_record_layoutstats_done()
1656 static int ff_layout_write_prepare_common(struct rpc_task *task, in ff_layout_write_prepare_common() argument
1660 rpc_exit(task, -EIO); in ff_layout_write_prepare_common()
1665 rpc_exit(task, -EAGAIN); in ff_layout_write_prepare_common()
1669 ff_layout_write_record_layoutstats_start(task, hdr); in ff_layout_write_prepare_common()
1673 static void ff_layout_write_prepare_v3(struct rpc_task *task, void *data) in ff_layout_write_prepare_v3() argument
1677 if (ff_layout_write_prepare_common(task, hdr)) in ff_layout_write_prepare_v3()
1680 rpc_call_start(task); in ff_layout_write_prepare_v3()
1683 static void ff_layout_write_prepare_v4(struct rpc_task *task, void *data) in ff_layout_write_prepare_v4() argument
1690 task)) in ff_layout_write_prepare_v4()
1693 ff_layout_write_prepare_common(task, hdr); in ff_layout_write_prepare_v4()
1696 static void ff_layout_write_call_done(struct rpc_task *task, void *data) in ff_layout_write_call_done() argument
1701 task->tk_status == 0) { in ff_layout_write_call_done()
1702 nfs4_sequence_done(task, &hdr->res.seq_res); in ff_layout_write_call_done()
1707 hdr->mds_ops->rpc_call_done(task, hdr); in ff_layout_write_call_done()
1710 static void ff_layout_write_count_stats(struct rpc_task *task, void *data) in ff_layout_write_count_stats() argument
1714 ff_layout_write_record_layoutstats_done(task, hdr); in ff_layout_write_count_stats()
1715 rpc_count_iostats_metrics(task, in ff_layout_write_count_stats()
1723 ff_layout_write_record_layoutstats_done(&hdr->task, hdr); in ff_layout_write_release()
1732 static void ff_layout_commit_record_layoutstats_start(struct rpc_task *task, in ff_layout_commit_record_layoutstats_start() argument
1739 0, task->tk_start); in ff_layout_commit_record_layoutstats_start()
1742 static void ff_layout_commit_record_layoutstats_done(struct rpc_task *task, in ff_layout_commit_record_layoutstats_done() argument
1751 if (task->tk_status == 0) { in ff_layout_commit_record_layoutstats_done()
1755 nfs4_ff_layout_stat_io_end_write(task, in ff_layout_commit_record_layoutstats_done()
1761 static int ff_layout_commit_prepare_common(struct rpc_task *task, in ff_layout_commit_prepare_common() argument
1765 rpc_exit(task, -EAGAIN); in ff_layout_commit_prepare_common()
1769 ff_layout_commit_record_layoutstats_start(task, cdata); in ff_layout_commit_prepare_common()
1773 static void ff_layout_commit_prepare_v3(struct rpc_task *task, void *data) in ff_layout_commit_prepare_v3() argument
1775 if (ff_layout_commit_prepare_common(task, data)) in ff_layout_commit_prepare_v3()
1778 rpc_call_start(task); in ff_layout_commit_prepare_v3()
1781 static void ff_layout_commit_prepare_v4(struct rpc_task *task, void *data) in ff_layout_commit_prepare_v4() argument
1788 task)) in ff_layout_commit_prepare_v4()
1790 ff_layout_commit_prepare_common(task, data); in ff_layout_commit_prepare_v4()
1793 static void ff_layout_commit_done(struct rpc_task *task, void *data) in ff_layout_commit_done() argument
1795 pnfs_generic_write_commit_done(task, data); in ff_layout_commit_done()
1798 static void ff_layout_commit_count_stats(struct rpc_task *task, void *data) in ff_layout_commit_count_stats() argument
1802 ff_layout_commit_record_layoutstats_done(task, cdata); in ff_layout_commit_count_stats()
1803 rpc_count_iostats_metrics(task, in ff_layout_commit_count_stats()
1811 ff_layout_commit_record_layoutstats_done(&cdata->task, cdata); in ff_layout_commit_release()
1916 hdr->task.tk_start = ktime_get(); in ff_layout_read_pagelist()
1917 ff_layout_read_record_layoutstats_start(&hdr->task, hdr); in ff_layout_read_pagelist()
1996 hdr->task.tk_start = ktime_get(); in ff_layout_write_pagelist()
1997 ff_layout_write_record_layoutstats_start(&hdr->task, hdr); in ff_layout_write_pagelist()
2081 data->task.tk_start = ktime_get(); in ff_layout_initiate_commit()
2082 ff_layout_commit_record_layoutstats_start(&data->task, data); in ff_layout_initiate_commit()
2105 static bool ff_layout_match_rw(const struct rpc_task *task, in ff_layout_match_rw() argument
2112 static bool ff_layout_match_commit(const struct rpc_task *task, in ff_layout_match_commit() argument
2119 static bool ff_layout_match_io(const struct rpc_task *task, const void *data) in ff_layout_match_io() argument
2121 const struct rpc_call_ops *ops = task->tk_ops; in ff_layout_match_io()
2127 return ff_layout_match_rw(task, task->tk_calldata, data); in ff_layout_match_io()
2130 return ff_layout_match_commit(task, task->tk_calldata, data); in ff_layout_match_io()