|
@@ -133,7 +133,9 @@ static void __rpc_add_wait_queue(struct rpc_wait_queue *queue,
|
|
|
struct rpc_task *task,
|
|
|
unsigned char queue_priority)
|
|
|
{
|
|
|
- BUG_ON (RPC_IS_QUEUED(task));
|
|
|
+ WARN_ON_ONCE(RPC_IS_QUEUED(task));
|
|
|
+ if (RPC_IS_QUEUED(task))
|
|
|
+ return;
|
|
|
|
|
|
if (RPC_IS_PRIORITY(queue))
|
|
|
__rpc_add_wait_queue_priority(queue, task, queue_priority);
|
|
@@ -707,7 +709,9 @@ static void __rpc_execute(struct rpc_task *task)
|
|
|
dprintk("RPC: %5u __rpc_execute flags=0x%x\n",
|
|
|
task->tk_pid, task->tk_flags);
|
|
|
|
|
|
- BUG_ON(RPC_IS_QUEUED(task));
|
|
|
+ WARN_ON_ONCE(RPC_IS_QUEUED(task));
|
|
|
+ if (RPC_IS_QUEUED(task))
|
|
|
+ return;
|
|
|
|
|
|
for (;;) {
|
|
|
void (*do_action)(struct rpc_task *);
|