ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject [08/13] ignite git commit: IGNITE-2263: Removed retain for GridDiscoveryManager.
Date Sat, 02 Jan 2016 09:21:47 GMT
IGNITE-2263: Removed retain for GridDiscoveryManager.


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/1f7ce262
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/1f7ce262
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/1f7ce262

Branch: refs/heads/ignite-2263
Commit: 1f7ce262a4f2d09c95823ed8b942bea39e81537d
Parents: 980adb1
Author: thatcoach <ppozerov@list.ru>
Authored: Sat Jan 2 11:57:29 2016 +0300
Committer: thatcoach <ppozerov@list.ru>
Committed: Sat Jan 2 11:57:29 2016 +0300

----------------------------------------------------------------------
 .../internal/managers/discovery/GridDiscoveryManager.java | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/1f7ce262/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java
b/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java
index b978057..d6bd8cd 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java
@@ -1084,9 +1084,15 @@ public class GridDiscoveryManager extends GridManagerAdapter<DiscoverySpi>
{
 
         Collection<ClusterNode> rmtNodes = discoCache.remoteNodes();
 
-        Collection<ClusterNode> srvNodes = F.retain(discoCache.allNodes(), true, F.not(clientFilter));
+        Collection<ClusterNode> srvNodes = new ArrayList<>();
+        Collection<ClusterNode> clientNodes = new ArrayList<>();
 
-        Collection<ClusterNode> clientNodes = F.retain(discoCache.allNodes(), true,
clientFilter);
+        for (ClusterNode node : discoCache.allNodes()) {
+            if (clientFilter.apply(node))
+                clientNodes.add(node);
+            else
+                srvNodes.add(node);
+        }
 
         ClusterNode locNode = discoCache.localNode();
 


Mime
View raw message