Lines Matching defs:task
41 static void ff_layout_read_record_layoutstats_done(struct rpc_task *task,
676 nfs4_ff_layout_stat_io_end_read(struct rpc_task *task,
684 ktime_get(), task->tk_start);
707 nfs4_ff_layout_stat_io_end_write(struct rpc_task *task,
718 requested, completed, ktime_get(), task->tk_start);
1013 struct rpc_task *task = &hdr->task;
1018 dprintk("%s Reset task %5u for i/o through pNFS "
1020 hdr->task.tk_pid,
1031 dprintk("%s Reset task %5u for i/o through MDS "
1033 hdr->task.tk_pid,
1043 task->tk_status = pnfs_write_done_resend_to_mds(hdr);
1061 struct rpc_task *task = &hdr->task;
1067 dprintk("%s Reset task %5u for i/o through MDS "
1069 hdr->task.tk_pid,
1079 task->tk_status = pnfs_read_done_resend_to_mds(hdr);
1083 static int ff_layout_async_handle_error_v4(struct rpc_task *task,
1094 switch (task->tk_status) {
1103 "flags 0x%x\n", __func__, task->tk_status,
1105 nfs4_schedule_session_recovery(clp->cl_session, task->tk_status);
1109 rpc_delay(task, FF_LAYOUT_POLL_RETRY_MAX);
1121 task->tk_status);
1143 task->tk_status);
1153 task->tk_status);
1156 task->tk_status = 0;
1161 static int ff_layout_async_handle_error_v3(struct rpc_task *task,
1167 switch (task->tk_status) {
1181 task->tk_status);
1188 task->tk_status = 0;
1189 rpc_restart_call_prepare(task);
1190 rpc_delay(task, NFS_JUKEBOX_RETRY_TIME);
1194 static int ff_layout_async_handle_error(struct rpc_task *task,
1202 if (task->tk_status >= 0) {
1213 return ff_layout_async_handle_error_v3(task, lseg, idx);
1215 return ff_layout_async_handle_error_v4(task, state, clp,
1287 static int ff_layout_read_done_cb(struct rpc_task *task,
1292 if (task->tk_status < 0) {
1296 task->tk_status);
1300 err = ff_layout_async_handle_error(task, hdr->args.context->state,
1310 return task->tk_status;
1313 return task->tk_status;
1320 rpc_restart_call_prepare(task);
1352 static void ff_layout_read_record_layoutstats_start(struct rpc_task *task,
1360 task->tk_start);
1363 static void ff_layout_read_record_layoutstats_done(struct rpc_task *task,
1368 nfs4_ff_layout_stat_io_end_read(task,
1375 static int ff_layout_read_prepare_common(struct rpc_task *task,
1379 rpc_exit(task, -EIO);
1384 rpc_exit(task, -EAGAIN);
1388 ff_layout_read_record_layoutstats_start(task, hdr);
1397 static void ff_layout_read_prepare_v3(struct rpc_task *task, void *data)
1401 if (ff_layout_read_prepare_common(task, hdr))
1404 rpc_call_start(task);
1407 static void ff_layout_read_prepare_v4(struct rpc_task *task, void *data)
1414 task))
1417 ff_layout_read_prepare_common(task, hdr);
1420 static void ff_layout_read_call_done(struct rpc_task *task, void *data)
1425 task->tk_status == 0) {
1426 nfs4_sequence_done(task, &hdr->res.seq_res);
1431 hdr->mds_ops->rpc_call_done(task, hdr);
1434 static void ff_layout_read_count_stats(struct rpc_task *task, void *data)
1438 ff_layout_read_record_layoutstats_done(task, hdr);
1439 rpc_count_iostats_metrics(task,
1447 ff_layout_read_record_layoutstats_done(&hdr->task, hdr);
1456 static int ff_layout_write_done_cb(struct rpc_task *task,
1462 if (task->tk_status < 0) {
1466 task->tk_status);
1470 err = ff_layout_async_handle_error(task, hdr->args.context->state,
1480 return task->tk_status;
1483 return task->tk_status;
1497 if (task->tk_status >= 0)
1503 static int ff_layout_commit_done_cb(struct rpc_task *task,
1508 if (task->tk_status < 0) {
1512 task->tk_status);
1516 err = ff_layout_async_handle_error(task, NULL, data->ds_clp,
1528 rpc_restart_call_prepare(task);
1537 static void ff_layout_write_record_layoutstats_start(struct rpc_task *task,
1545 task->tk_start);
1548 static void ff_layout_write_record_layoutstats_done(struct rpc_task *task,
1553 nfs4_ff_layout_stat_io_end_write(task,
1560 static int ff_layout_write_prepare_common(struct rpc_task *task,
1564 rpc_exit(task, -EIO);
1569 rpc_exit(task, -EAGAIN);
1573 ff_layout_write_record_layoutstats_start(task, hdr);
1577 static void ff_layout_write_prepare_v3(struct rpc_task *task, void *data)
1581 if (ff_layout_write_prepare_common(task, hdr))
1584 rpc_call_start(task);
1587 static void ff_layout_write_prepare_v4(struct rpc_task *task, void *data)
1594 task))
1597 ff_layout_write_prepare_common(task, hdr);
1600 static void ff_layout_write_call_done(struct rpc_task *task, void *data)
1605 task->tk_status == 0) {
1606 nfs4_sequence_done(task, &hdr->res.seq_res);
1611 hdr->mds_ops->rpc_call_done(task, hdr);
1614 static void ff_layout_write_count_stats(struct rpc_task *task, void *data)
1618 ff_layout_write_record_layoutstats_done(task, hdr);
1619 rpc_count_iostats_metrics(task,
1627 ff_layout_write_record_layoutstats_done(&hdr->task, hdr);
1636 static void ff_layout_commit_record_layoutstats_start(struct rpc_task *task,
1643 0, task->tk_start);
1646 static void ff_layout_commit_record_layoutstats_done(struct rpc_task *task,
1655 if (task->tk_status == 0) {
1659 nfs4_ff_layout_stat_io_end_write(task,
1665 static int ff_layout_commit_prepare_common(struct rpc_task *task,
1669 rpc_exit(task, -EAGAIN);
1673 ff_layout_commit_record_layoutstats_start(task, cdata);
1677 static void ff_layout_commit_prepare_v3(struct rpc_task *task, void *data)
1679 if (ff_layout_commit_prepare_common(task, data))
1682 rpc_call_start(task);
1685 static void ff_layout_commit_prepare_v4(struct rpc_task *task, void *data)
1692 task))
1694 ff_layout_commit_prepare_common(task, data);
1697 static void ff_layout_commit_done(struct rpc_task *task, void *data)
1699 pnfs_generic_write_commit_done(task, data);
1702 static void ff_layout_commit_count_stats(struct rpc_task *task, void *data)
1706 ff_layout_commit_record_layoutstats_done(task, cdata);
1707 rpc_count_iostats_metrics(task,
1715 ff_layout_commit_record_layoutstats_done(&cdata->task, cdata);
1977 static bool ff_layout_match_rw(const struct rpc_task *task,
1984 static bool ff_layout_match_commit(const struct rpc_task *task,
1991 static bool ff_layout_match_io(const struct rpc_task *task, const void *data)
1993 const struct rpc_call_ops *ops = task->tk_ops;
1999 return ff_layout_match_rw(task, task->tk_calldata, data);
2002 return ff_layout_match_commit(task, task->tk_calldata, data);