only connect to hosts not already in progress
This commit is contained in:
@@ -78,8 +78,8 @@ class ConnectionEstablisher {
|
|||||||
}
|
}
|
||||||
if (toTry == null)
|
if (toTry == null)
|
||||||
return
|
return
|
||||||
inProgress.add(toTry)
|
if (inProgress.add(toTry))
|
||||||
executor.execute({connect(toTry)} as Runnable)
|
executor.execute({connect(toTry)} as Runnable)
|
||||||
}
|
}
|
||||||
|
|
||||||
private void connect(Destination toTry) {
|
private void connect(Destination toTry) {
|
||||||
|
|||||||
Reference in New Issue
Block a user