89 	struct rpc_task *task = &data->task;  in filelayout_reset_write()  local
94 			data->task.tk_pid,  in filelayout_reset_write()
100 		task->tk_status = pnfs_write_done_resend_to_mds(hdr->inode,  in filelayout_reset_write()
110 	struct rpc_task *task = &data->task;  in filelayout_reset_read()  local
115 			data->task.tk_pid,  in filelayout_reset_read()
121 		task->tk_status = pnfs_read_done_resend_to_mds(hdr->inode,  in filelayout_reset_read()
135 static int filelayout_async_handle_error(struct rpc_task *task,  in filelayout_async_handle_error()  argument
147 	if (task->tk_status >= 0)  in filelayout_async_handle_error()
150 	switch (task->tk_status) {  in filelayout_async_handle_error()
180 			"flags 0x%x\n", __func__, task->tk_status,  in filelayout_async_handle_error()
182 		nfs4_schedule_session_recovery(clp->cl_session, task->tk_status);  in filelayout_async_handle_error()
186 		rpc_delay(task, FILELAYOUT_POLL_RETRY_MAX);  in filelayout_async_handle_error()
198 			task->tk_status);  in filelayout_async_handle_error()
218 			task->tk_status);  in filelayout_async_handle_error()
226 			task->tk_status);  in filelayout_async_handle_error()
230 	task->tk_status = 0;  in filelayout_async_handle_error()
233 	task->tk_status = -EIO;  in filelayout_async_handle_error()
236 	rpc_sleep_on(&mds_client->cl_rpcwaitq, task, NULL);  in filelayout_async_handle_error()
238 		rpc_wake_up_queued_task(&mds_client->cl_rpcwaitq, task);  in filelayout_async_handle_error()
244 static int filelayout_read_done_cb(struct rpc_task *task,  in filelayout_read_done_cb()  argument
250 	err = filelayout_async_handle_error(task, data->args.context->state,  in filelayout_read_done_cb()
256 		return task->tk_status;  in filelayout_read_done_cb()
258 		rpc_restart_call_prepare(task);  in filelayout_read_done_cb()
304 static void filelayout_read_prepare(struct rpc_task *task, void *data)  in filelayout_read_prepare()  argument
309 		rpc_exit(task, -EIO);  in filelayout_read_prepare()
313 		dprintk("%s task %u reset io to MDS\n", __func__, task->tk_pid);  in filelayout_read_prepare()
315 		rpc_exit(task, 0);  in filelayout_read_prepare()
323 			task))  in filelayout_read_prepare()
329 static void filelayout_read_call_done(struct rpc_task *task, void *data)  in filelayout_read_call_done()  argument
333 	dprintk("--> %s task->tk_status %d\n", __func__, task->tk_status);  in filelayout_read_call_done()
336 	    task->tk_status == 0)  in filelayout_read_call_done()
340 	rdata->header->mds_ops->rpc_call_done(task, data);  in filelayout_read_call_done()
343 static void filelayout_read_count_stats(struct rpc_task *task, void *data)  in filelayout_read_count_stats()  argument
347 	rpc_count_iostats(task, NFS_SERVER(rdata->header->inode)->client->cl_metrics);  in filelayout_read_count_stats()
360 static int filelayout_write_done_cb(struct rpc_task *task,  in filelayout_write_done_cb()  argument
366 	err = filelayout_async_handle_error(task, data->args.context->state,  in filelayout_write_done_cb()
372 		return task->tk_status;  in filelayout_write_done_cb()
374 		rpc_restart_call_prepare(task);  in filelayout_write_done_cb()
387 	data->task.tk_status = 0;  in prepare_to_resend_writes()
393 static int filelayout_commit_done_cb(struct rpc_task *task,  in filelayout_commit_done_cb()  argument
398 	err = filelayout_async_handle_error(task, NULL, data->ds_clp,  in filelayout_commit_done_cb()
406 		rpc_restart_call_prepare(task);  in filelayout_commit_done_cb()
413 static void filelayout_write_prepare(struct rpc_task *task, void *data)  in filelayout_write_prepare()  argument
418 		rpc_exit(task, -EIO);  in filelayout_write_prepare()
422 		dprintk("%s task %u reset io to MDS\n", __func__, task->tk_pid);  in filelayout_write_prepare()
424 		rpc_exit(task, 0);  in filelayout_write_prepare()
430 			task))  in filelayout_write_prepare()
436 static void filelayout_write_call_done(struct rpc_task *task, void *data)  in filelayout_write_call_done()  argument
441 	    task->tk_status == 0)  in filelayout_write_call_done()
445 	wdata->header->mds_ops->rpc_call_done(task, data);  in filelayout_write_call_done()
448 static void filelayout_write_count_stats(struct rpc_task *task, void *data)  in filelayout_write_count_stats()  argument
452 	rpc_count_iostats(task, NFS_SERVER(wdata->header->inode)->client->cl_metrics);  in filelayout_write_count_stats()
465 static void filelayout_commit_prepare(struct rpc_task *task, void *data)  in filelayout_commit_prepare()  argument
472 			task);  in filelayout_commit_prepare()
475 static void filelayout_write_commit_done(struct rpc_task *task, void *data)  in filelayout_write_commit_done()  argument
480 	wdata->mds_ops->rpc_call_done(task, data);  in filelayout_write_commit_done()
483 static void filelayout_commit_count_stats(struct rpc_task *task, void *data)  in filelayout_commit_count_stats()  argument
487 	rpc_count_iostats(task, NFS_SERVER(cdata->inode)->client->cl_metrics);  in filelayout_commit_count_stats()