You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2015/09/15 13:15:34 UTC
ignite git commit: Fixed RendezvousAffinityFunction.hashIdResolver
compatibility.
Repository: ignite
Updated Branches:
refs/heads/ignite-gg-10722 [created] 5843be72b
Fixed RendezvousAffinityFunction.hashIdResolver compatibility.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/5843be72
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/5843be72
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/5843be72
Branch: refs/heads/ignite-gg-10722
Commit: 5843be72b30cb3df178165aecd7f43ef373b7342
Parents: f977613
Author: sboikov <sb...@gridgain.com>
Authored: Tue Sep 15 14:10:07 2015 +0300
Committer: sboikov <sb...@gridgain.com>
Committed: Tue Sep 15 14:10:07 2015 +0300
----------------------------------------------------------------------
.../internal/processors/cache/GridCacheProcessor.java | 10 ++++------
1 file changed, 4 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/5843be72/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java
index 59bb5f7..4453e0b 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java
@@ -232,16 +232,14 @@ public class GridCacheProcessor extends GridProcessorAdapter {
if (cfg.getCacheMode() == PARTITIONED) {
RendezvousAffinityFunction aff = new RendezvousAffinityFunction();
- if (internalCache)
- aff.setHashIdResolver(new AffinityNodeAddressHashResolver());
+ aff.setHashIdResolver(new AffinityNodeAddressHashResolver());
cfg.setAffinity(aff);
}
else if (cfg.getCacheMode() == REPLICATED) {
RendezvousAffinityFunction aff = new RendezvousAffinityFunction(false, 512);
- if (internalCache)
- aff.setHashIdResolver(new AffinityNodeAddressHashResolver());
+ aff.setHashIdResolver(new AffinityNodeAddressHashResolver());
cfg.setAffinity(aff);
@@ -251,11 +249,11 @@ public class GridCacheProcessor extends GridProcessorAdapter {
cfg.setAffinity(new LocalAffinityFunction());
}
else {
- if (cfg.getCacheMode() == PARTITIONED) {
+ if (cfg.getCacheMode() != LOCAL) {
if (cfg.getAffinity() instanceof RendezvousAffinityFunction) {
RendezvousAffinityFunction aff = (RendezvousAffinityFunction)cfg.getAffinity();
- if (internalCache && aff.getHashIdResolver() == null)
+ if (aff.getHashIdResolver() == null)
aff.setHashIdResolver(new AffinityNodeAddressHashResolver());
}
}