Lines Matching defs:task

36 static void ff_layout_read_record_layoutstats_done(struct rpc_task *task,
670 nfs4_ff_layout_stat_io_end_read(struct rpc_task *task,
678 ktime_get(), task->tk_start);
701 nfs4_ff_layout_stat_io_end_write(struct rpc_task *task,
712 requested, completed, ktime_get(), task->tk_start);
1020 struct rpc_task *task = &hdr->task;
1025 dprintk("%s Reset task %5u for i/o through pNFS "
1027 hdr->task.tk_pid,
1038 dprintk("%s Reset task %5u for i/o through MDS "
1040 hdr->task.tk_pid,
1050 task->tk_status = pnfs_write_done_resend_to_mds(hdr);
1068 struct rpc_task *task = &hdr->task;
1074 dprintk("%s Reset task %5u for i/o through MDS "
1076 hdr->task.tk_pid,
1086 task->tk_status = pnfs_read_done_resend_to_mds(hdr);
1090 static int ff_layout_async_handle_error_v4(struct rpc_task *task,
1101 switch (task->tk_status) {
1110 "flags 0x%x\n", __func__, task->tk_status,
1112 nfs4_schedule_session_recovery(clp->cl_session, task->tk_status);
1116 rpc_delay(task, FF_LAYOUT_POLL_RETRY_MAX);
1128 task->tk_status);
1148 task->tk_status);
1158 task->tk_status);
1161 task->tk_status = 0;
1166 static int ff_layout_async_handle_error_v3(struct rpc_task *task,
1172 switch (task->tk_status) {
1186 task->tk_status);
1193 task->tk_status = 0;
1194 rpc_restart_call_prepare(task);
1195 rpc_delay(task, NFS_JUKEBOX_RETRY_TIME);
1199 static int ff_layout_async_handle_error(struct rpc_task *task,
1207 if (task->tk_status >= 0) {
1218 return ff_layout_async_handle_error_v3(task, lseg, idx);
1220 return ff_layout_async_handle_error_v4(task, state, clp,
1290 static int ff_layout_read_done_cb(struct rpc_task *task,
1295 if (task->tk_status < 0) {
1299 task->tk_status);
1303 err = ff_layout_async_handle_error(task, hdr->args.context->state,
1313 return task->tk_status;
1316 return task->tk_status;
1323 rpc_restart_call_prepare(task);
1355 static void ff_layout_read_record_layoutstats_start(struct rpc_task *task,
1363 task->tk_start);
1366 static void ff_layout_read_record_layoutstats_done(struct rpc_task *task,
1371 nfs4_ff_layout_stat_io_end_read(task,
1378 static int ff_layout_read_prepare_common(struct rpc_task *task,
1382 rpc_exit(task, -EIO);
1386 ff_layout_read_record_layoutstats_start(task, hdr);
1395 static void ff_layout_read_prepare_v3(struct rpc_task *task, void *data)
1399 if (ff_layout_read_prepare_common(task, hdr))
1402 rpc_call_start(task);
1405 static void ff_layout_read_prepare_v4(struct rpc_task *task, void *data)
1412 task))
1415 ff_layout_read_prepare_common(task, hdr);
1418 static void ff_layout_read_call_done(struct rpc_task *task, void *data)
1422 dprintk("--> %s task->tk_status %d\n", __func__, task->tk_status);
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);
1568 ff_layout_write_record_layoutstats_start(task, hdr);
1572 static void ff_layout_write_prepare_v3(struct rpc_task *task, void *data)
1576 if (ff_layout_write_prepare_common(task, hdr))
1579 rpc_call_start(task);
1582 static void ff_layout_write_prepare_v4(struct rpc_task *task, void *data)
1589 task))
1592 ff_layout_write_prepare_common(task, hdr);
1595 static void ff_layout_write_call_done(struct rpc_task *task, void *data)
1600 task->tk_status == 0) {
1601 nfs4_sequence_done(task, &hdr->res.seq_res);
1606 hdr->mds_ops->rpc_call_done(task, hdr);
1609 static void ff_layout_write_count_stats(struct rpc_task *task, void *data)
1613 ff_layout_write_record_layoutstats_done(task, hdr);
1614 rpc_count_iostats_metrics(task,
1622 ff_layout_write_record_layoutstats_done(&hdr->task, hdr);
1631 static void ff_layout_commit_record_layoutstats_start(struct rpc_task *task,
1638 0, task->tk_start);
1641 static void ff_layout_commit_record_layoutstats_done(struct rpc_task *task,
1650 if (task->tk_status == 0) {
1654 nfs4_ff_layout_stat_io_end_write(task,
1660 static void ff_layout_commit_prepare_common(struct rpc_task *task,
1663 ff_layout_commit_record_layoutstats_start(task, cdata);
1666 static void ff_layout_commit_prepare_v3(struct rpc_task *task, void *data)
1668 ff_layout_commit_prepare_common(task, data);
1669 rpc_call_start(task);
1672 static void ff_layout_commit_prepare_v4(struct rpc_task *task, void *data)
1679 task))
1681 ff_layout_commit_prepare_common(task, data);
1684 static void ff_layout_commit_done(struct rpc_task *task, void *data)
1686 pnfs_generic_write_commit_done(task, data);
1689 static void ff_layout_commit_count_stats(struct rpc_task *task, void *data)
1693 ff_layout_commit_record_layoutstats_done(task, cdata);
1694 rpc_count_iostats_metrics(task,
1702 ff_layout_commit_record_layoutstats_done(&cdata->task, cdata);