#ignite-237: add node attributes.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/148ca095 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/148ca095 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/148ca095 Branch: refs/heads/ignite-51 Commit: 148ca09572b336cfe4c55683e059ca13fa8cd238 Parents: d254da4 Author: ivasilinets <ivasilin...@gridgain.com> Authored: Fri Feb 27 15:53:51 2015 +0300 Committer: ivasilinets <ivasilin...@gridgain.com> Committed: Fri Feb 27 15:53:51 2015 +0300 ---------------------------------------------------------------------- .../internal/processors/cache/GridCacheAttributes.java | 8 ++++++++ 1 file changed, 8 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/148ca095/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAttributes.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAttributes.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAttributes.java index 571ae25..8ecd84c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAttributes.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAttributes.java @@ -19,6 +19,7 @@ package org.apache.ignite.internal.processors.cache; import org.apache.ignite.cache.*; import org.apache.ignite.cache.affinity.*; +import org.apache.ignite.cache.affinity.rendezvous.*; import org.apache.ignite.cache.store.*; import org.apache.ignite.configuration.*; import org.apache.ignite.internal.util.typedef.internal.*; @@ -191,6 +192,13 @@ public class GridCacheAttributes implements Externalizable { CacheAffinityFunction aff = cfg.getAffinity(); if (aff != null) { + if (aff instanceof CacheRendezvousAffinityFunction) { + CacheRendezvousAffinityFunction aff0 = (CacheRendezvousAffinityFunction) aff; + + affInclNeighbors = aff0.isExcludeNeighbors(); + affHashIdRslvrClsName = className(aff0.getHashIdResolver()); + } + affPartsCnt = aff.partitions(); affClsName = className(aff); }
