lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
Redkale
2019-08-30 10:50:24 +08:00
parent 2a14f39495
commit 543ecc071a
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/org/redkale/net/http/WebSocketNode.java
View File

@@ -265,6 +265,7 @@ public abstract class WebSocketNode {
if (addrs == null) addrs = new ArrayList<>(); if (addrs == null) addrs = new ArrayList<>();
addrs.add(userAddress.sncpAddress()); addrs.add(userAddress.sncpAddress());
} }
if (addrs == null || addrs.isEmpty()) return CompletableFuture.completedFuture(false);
CompletableFuture<Boolean> future = null; CompletableFuture<Boolean> future = null;
for (InetSocketAddress addr : addrs) { for (InetSocketAddress addr : addrs) {
if (addr == null || addr.equals(localSncpAddress)) continue; if (addr == null || addr.equals(localSncpAddress)) continue;
@@ -319,6 +320,7 @@ public abstract class WebSocketNode {
if (addrs == null) addrs = new ArrayList<>(); if (addrs == null) addrs = new ArrayList<>();
addrs.add(userAddress.sncpAddress()); addrs.add(userAddress.sncpAddress());
} }
if (addrs == null || addrs.isEmpty()) return CompletableFuture.completedFuture(0);
addrsFuture = CompletableFuture.completedFuture(addrs); addrsFuture = CompletableFuture.completedFuture(addrs);
} }
CompletableFuture<Integer> remoteFuture = addrsFuture.thenCompose((Collection<InetSocketAddress> addrs) -> { CompletableFuture<Integer> remoteFuture = addrsFuture.thenCompose((Collection<InetSocketAddress> addrs) -> {