ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [12/50] [abbrv] incubator-ignite git commit: IGNITE-544 - Fixing tests
Date Wed, 25 Mar 2015 12:05:58 GMT
IGNITE-544 - Fixing tests


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

Branch: refs/heads/ignite-565
Commit: 987a5dc2d8dc1f4bea123f6777db11c93a45f796
Parents: 1424f9d
Author: Valentin Kulichenko <vkulichenko@gridgain.com>
Authored: Tue Mar 24 18:36:35 2015 -0700
Committer: Valentin Kulichenko <vkulichenko@gridgain.com>
Committed: Tue Mar 24 18:36:35 2015 -0700

----------------------------------------------------------------------
 .../cache/distributed/dht/GridDhtAssignmentFetchFuture.java   | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/987a5dc2/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtAssignmentFetchFuture.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtAssignmentFetchFuture.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtAssignmentFetchFuture.java
index 79628cc..303d649 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtAssignmentFetchFuture.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtAssignmentFetchFuture.java
@@ -71,7 +71,12 @@ public class GridDhtAssignmentFetchFuture extends GridFutureAdapter<List<List<Cl
         this.topVer = topVer;
 
         LinkedList<ClusterNode> tmp = new LinkedList<>();
-        tmp.addAll(availableNodes);
+
+        for (ClusterNode node : availableNodes) {
+            if (!node.isLocal())
+                tmp.add(node);
+        }
+
         Collections.sort(tmp, GridNodeOrderComparator.INSTANCE);
 
         this.availableNodes = tmp;


Mime
View raw message