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

Browse Source
This commit is contained in:
wentch
2015-12-23 16:12:05 +08:00
parent 33944bd01c
commit 789a547f6b
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -67,7 +67,7 @@ public abstract class WebSocketNode {
Set<String> engineids = localNodes.get(groupid); Set<String> engineids = localNodes.get(groupid);
if (engineids == null) { if (engineids == null) {
engineids = new CopyOnWriteArraySet<>(); engineids = new CopyOnWriteArraySet<>();
localNodes.put(groupid, engineids); localNodes.putIfAbsent(groupid, engineids);
} }
if (localSncpAddress != null && engineids.isEmpty()) connect(groupid, localSncpAddress); if (localSncpAddress != null && engineids.isEmpty()) connect(groupid, localSncpAddress);
engineids.add(engineid); engineids.add(engineid);