Lines Matching refs:task
49 nfs3_async_handle_jukebox(struct rpc_task *task, struct inode *inode) in nfs3_async_handle_jukebox() argument
51 if (task->tk_status != -EJUKEBOX) in nfs3_async_handle_jukebox()
54 task->tk_status = 0; in nfs3_async_handle_jukebox()
55 rpc_restart_call(task); in nfs3_async_handle_jukebox()
56 rpc_delay(task, NFS_JUKEBOX_RETRY_TIME); in nfs3_async_handle_jukebox()
468 static void nfs3_proc_unlink_rpc_prepare(struct rpc_task *task, struct nfs_unlinkdata *data) in nfs3_proc_unlink_rpc_prepare() argument
470 rpc_call_start(task); in nfs3_proc_unlink_rpc_prepare()
474 nfs3_proc_unlink_done(struct rpc_task *task, struct inode *dir) in nfs3_proc_unlink_done() argument
477 if (nfs3_async_handle_jukebox(task, dir)) in nfs3_proc_unlink_done()
479 res = task->tk_msg.rpc_resp; in nfs3_proc_unlink_done()
492 static void nfs3_proc_rename_rpc_prepare(struct rpc_task *task, struct nfs_renamedata *data) in nfs3_proc_rename_rpc_prepare() argument
494 rpc_call_start(task); in nfs3_proc_rename_rpc_prepare()
498 nfs3_proc_rename_done(struct rpc_task *task, struct inode *old_dir, in nfs3_proc_rename_done() argument
503 if (nfs3_async_handle_jukebox(task, old_dir)) in nfs3_proc_rename_done()
505 res = task->tk_msg.rpc_resp; in nfs3_proc_rename_done()
846 static int nfs3_read_done(struct rpc_task *task, struct nfs_pgio_header *hdr) in nfs3_read_done() argument
852 return hdr->pgio_done_cb(task, hdr); in nfs3_read_done()
854 if (nfs3_async_handle_jukebox(task, inode)) in nfs3_read_done()
857 if (task->tk_status >= 0 && !server->read_hdrsize) in nfs3_read_done()
872 static int nfs3_proc_pgio_rpc_prepare(struct rpc_task *task, in nfs3_proc_pgio_rpc_prepare() argument
875 rpc_call_start(task); in nfs3_proc_pgio_rpc_prepare()
879 static int nfs3_write_done(struct rpc_task *task, struct nfs_pgio_header *hdr) in nfs3_write_done() argument
884 return hdr->pgio_done_cb(task, hdr); in nfs3_write_done()
886 if (nfs3_async_handle_jukebox(task, inode)) in nfs3_write_done()
888 if (task->tk_status >= 0) in nfs3_write_done()
900 static void nfs3_proc_commit_rpc_prepare(struct rpc_task *task, struct nfs_commit_data *data) in nfs3_proc_commit_rpc_prepare() argument
902 rpc_call_start(task); in nfs3_proc_commit_rpc_prepare()
905 static int nfs3_commit_done(struct rpc_task *task, struct nfs_commit_data *data) in nfs3_commit_done() argument
908 return data->commit_done_cb(task, data); in nfs3_commit_done()
910 if (nfs3_async_handle_jukebox(task, data->inode)) in nfs3_commit_done()
931 static bool nfs3_nlm_unlock_prepare(struct rpc_task *task, void *data) in nfs3_nlm_unlock_prepare() argument
935 return nfs_async_iocounter_wait(task, l_ctx); in nfs3_nlm_unlock_prepare()