You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ag...@apache.org on 2018/01/23 14:01:44 UTC
[2/9] ignite git commit: GG-13361 Compilation
GG-13361 Compilation
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/3f346afa
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/3f346afa
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/3f346afa
Branch: refs/heads/ignite-7505
Commit: 3f346afa31ab6cc5da3769b51ddc8eedc89e47c9
Parents: 1a4ceae
Author: Alexey Goncharuk <al...@gmail.com>
Authored: Tue Jan 23 11:33:50 2018 +0300
Committer: Alexey Goncharuk <al...@gmail.com>
Committed: Tue Jan 23 11:33:50 2018 +0300
----------------------------------------------------------------------
.../processors/affinity/GridAffinityAssignmentCache.java | 9 +++++++++
1 file changed, 9 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/3f346afa/modules/core/src/main/java/org/apache/ignite/internal/processors/affinity/GridAffinityAssignmentCache.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/affinity/GridAffinityAssignmentCache.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/affinity/GridAffinityAssignmentCache.java
index dd46246..47f5612 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/affinity/GridAffinityAssignmentCache.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/affinity/GridAffinityAssignmentCache.java
@@ -194,6 +194,15 @@ public class GridAffinityAssignmentCache {
assert topVer.compareTo(lastVersion()) >= 0 : "[topVer = " + topVer + ", last=" + lastVersion() + ']';
assert idealAssignment != null;
+ DiscoCache discoCache = ctx.discovery().discoCache(topVer);
+
+ if (ctx.cache().cacheGroup(grpId).persistenceEnabled()) {
+ for (List<ClusterNode> pNodes : affAssignment) {
+ for (ClusterNode pNode : pNodes)
+ assert discoCache.baselineNode(pNode.id());
+ }
+ }
+
GridAffinityAssignment assignment = new GridAffinityAssignment(topVer, affAssignment, idealAssignment);
affCache.put(topVer, new HistoryAffinityAssignment(assignment));