|
@@ -826,8 +826,15 @@ void xprt_connect(struct rpc_task *task)
|
|
|
return;
|
|
|
if (xprt_test_and_set_connecting(xprt))
|
|
|
return;
|
|
|
- xprt->stat.connect_start = jiffies;
|
|
|
- xprt->ops->connect(xprt, task);
|
|
|
+ /* Race breaker */
|
|
|
+ if (!xprt_connected(xprt)) {
|
|
|
+ xprt->stat.connect_start = jiffies;
|
|
|
+ xprt->ops->connect(xprt, task);
|
|
|
+ } else {
|
|
|
+ xprt_clear_connecting(xprt);
|
|
|
+ task->tk_status = 0;
|
|
|
+ rpc_wake_up_queued_task(&xprt->pending, task);
|
|
|
+ }
|
|
|
}
|
|
|
xprt_release_write(xprt, task);
|
|
|
}
|