|
@@ -630,14 +630,12 @@ static void __rpc_execute(struct rpc_task *task)
|
|
save_callback = task->tk_callback;
|
|
save_callback = task->tk_callback;
|
|
task->tk_callback = NULL;
|
|
task->tk_callback = NULL;
|
|
save_callback(task);
|
|
save_callback(task);
|
|
- }
|
|
|
|
-
|
|
|
|
- /*
|
|
|
|
- * Perform the next FSM step.
|
|
|
|
- * tk_action may be NULL when the task has been killed
|
|
|
|
- * by someone else.
|
|
|
|
- */
|
|
|
|
- if (!RPC_IS_QUEUED(task)) {
|
|
|
|
|
|
+ } else {
|
|
|
|
+ /*
|
|
|
|
+ * Perform the next FSM step.
|
|
|
|
+ * tk_action may be NULL when the task has been killed
|
|
|
|
+ * by someone else.
|
|
|
|
+ */
|
|
if (task->tk_action == NULL)
|
|
if (task->tk_action == NULL)
|
|
break;
|
|
break;
|
|
task->tk_action(task);
|
|
task->tk_action(task);
|