Lines Matching refs:task
805 static void nfsd4_cb_probe_done(struct rpc_task *task, void *calldata) in nfsd4_cb_probe_done() argument
809 if (task->tk_status) in nfsd4_cb_probe_done()
810 nfsd4_mark_cb_down(clp, task->tk_status); in nfsd4_cb_probe_done()
853 static bool nfsd41_cb_get_slot(struct nfs4_client *clp, struct rpc_task *task) in nfsd41_cb_get_slot() argument
856 rpc_sleep_on(&clp->cl_cb_waitq, task, NULL); in nfsd41_cb_get_slot()
862 rpc_wake_up_queued_task(&clp->cl_cb_waitq, task); in nfsd41_cb_get_slot()
871 static void nfsd4_cb_prepare(struct rpc_task *task, void *calldata) in nfsd4_cb_prepare() argument
879 if (!nfsd41_cb_get_slot(clp, task)) in nfsd4_cb_prepare()
882 rpc_call_start(task); in nfsd4_cb_prepare()
885 static void nfsd4_cb_done(struct rpc_task *task, void *calldata) in nfsd4_cb_done() argument
895 if (!task->tk_status) in nfsd4_cb_done()
912 if (task->tk_flags & RPC_TASK_KILLED) { in nfsd4_cb_done()
913 task->tk_status = 0; in nfsd4_cb_done()
919 WARN_ON_ONCE(task->tk_status); in nfsd4_cb_done()
920 task->tk_status = cb->cb_status; in nfsd4_cb_done()
923 switch (cb->cb_ops->done(cb, task)) { in nfsd4_cb_done()
925 task->tk_status = 0; in nfsd4_cb_done()
926 rpc_restart_call_prepare(task); in nfsd4_cb_done()
932 nfsd4_mark_cb_down(clp, task->tk_status); in nfsd4_cb_done()