Lines Matching defs:task
964 static void nfsd4_cb_probe_done(struct rpc_task *task, void *calldata)
968 trace_nfsd_cb_done(clp, task->tk_status);
969 if (task->tk_status)
970 nfsd4_mark_cb_down(clp, task->tk_status);
1024 static bool nfsd41_cb_get_slot(struct nfsd4_callback *cb, struct rpc_task *task)
1030 rpc_sleep_on(&clp->cl_cb_waitq, task, NULL);
1036 rpc_wake_up_queued_task(&clp->cl_cb_waitq, task);
1067 static void nfsd4_cb_prepare(struct rpc_task *task, void *calldata)
1079 if (minorversion && !nfsd41_cb_get_slot(cb, task))
1081 rpc_call_start(task);
1084 static bool nfsd4_cb_sequence_done(struct rpc_task *task, struct nfsd4_callback *cb)
1093 * task was queued, we need to resubmit it after setting up
1100 if (RPC_SIGNALLED(task))
1129 if (!rpc_restart_call(task))
1132 rpc_delay(task, 2 * HZ);
1152 if (RPC_SIGNALLED(task))
1157 if (rpc_restart_call_prepare(task))
1162 task->tk_status = 0;
1168 static void nfsd4_cb_done(struct rpc_task *task, void *calldata)
1173 trace_nfsd_cb_done(clp, task->tk_status);
1175 if (!nfsd4_cb_sequence_done(task, cb))
1179 WARN_ON_ONCE(task->tk_status);
1180 task->tk_status = cb->cb_status;
1183 switch (cb->cb_ops->done(cb, task)) {
1185 task->tk_status = 0;
1186 rpc_restart_call_prepare(task);
1189 switch (task->tk_status) {
1193 nfsd4_mark_cb_down(clp, task->tk_status);