FIX: Concurrency problem in locator allNodes.

Author: brido4125

src/main/java/net/spy/memcached/ArcusKetamaNodeLocator.java

@@ -32,6 +32,7 @@
 import java.util.SortedSet;
 import java.util.TreeMap;
 import java.util.TreeSet;
+import java.util.concurrent.CopyOnWriteArrayList;
 import java.util.concurrent.locks.Lock;
 import java.util.concurrent.locks.ReentrantLock;
 
@@ -66,7 +67,7 @@ public ArcusKetamaNodeLocator(List<MemcachedNode> nodes) {
   public ArcusKetamaNodeLocator(List<MemcachedNode> nodes,
                                 ArcusKetamaNodeLocatorConfiguration conf) {
     super();
-    allNodes = nodes;
+    allNodes = new CopyOnWriteArrayList<>(nodes);
     ketamaNodes = new TreeMap<>();
     config = conf;
 
@@ -92,7 +93,7 @@ private ArcusKetamaNodeLocator(TreeMap<Long, SortedSet<MemcachedNode>> smn,
                                  ArcusKetamaNodeLocatorConfiguration conf) {
     super();
     ketamaNodes = smn;
-    allNodes = an;
+    allNodes = new CopyOnWriteArrayList<>(an);
     config = conf;
 
     /* ENABLE_MIGRATION if */

src/main/java/net/spy/memcached/ArcusReplKetamaNodeLocator.java

@@ -32,6 +32,7 @@
 import java.util.SortedSet;
 import java.util.TreeMap;
 import java.util.TreeSet;
+import java.util.concurrent.CopyOnWriteArrayList;
 import java.util.concurrent.locks.Lock;
 import java.util.concurrent.locks.ReentrantLock;
 
@@ -65,7 +66,7 @@ public class ArcusReplKetamaNodeLocator extends SpyObject implements NodeLocator
 
   public ArcusReplKetamaNodeLocator(List<MemcachedNode> nodes) {
     super();
-    allNodes = nodes;
+    allNodes = new CopyOnWriteArrayList<>(nodes);
     ketamaGroups = new TreeMap<>();
     allGroups = new HashMap<>();
 
@@ -108,7 +109,7 @@ private ArcusReplKetamaNodeLocator(TreeMap<Long, SortedSet<MemcachedReplicaGroup
     super();
     ketamaGroups = kg;
     allGroups = ag;
-    allNodes = an;
+    allNodes = new CopyOnWriteArrayList<>(an);
     toDeleteGroups = new HashSet<>();
 
     /* ENABLE_MIGRATION if */