You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by yz...@apache.org on 2017/04/11 09:45:12 UTC
ignite git commit: ignite-4828 - fixed deserialization
Repository: ignite
Updated Branches:
refs/heads/ignite-4828-reviewed 6ccfb4384 -> d0e6173e2
ignite-4828 - fixed deserialization
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/d0e6173e
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/d0e6173e
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/d0e6173e
Branch: refs/heads/ignite-4828-reviewed
Commit: d0e6173e2ca5e22c77f7201e6bba2dbc591c539f
Parents: 6ccfb43
Author: Yakov Zhdanov <yz...@gridgain.com>
Authored: Tue Apr 11 12:45:03 2017 +0300
Committer: Yakov Zhdanov <yz...@gridgain.com>
Committed: Tue Apr 11 12:45:03 2017 +0300
----------------------------------------------------------------------
.../cache/affinity/rendezvous/RendezvousAffinityFunction.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/d0e6173e/modules/core/src/main/java/org/apache/ignite/cache/affinity/rendezvous/RendezvousAffinityFunction.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/cache/affinity/rendezvous/RendezvousAffinityFunction.java b/modules/core/src/main/java/org/apache/ignite/cache/affinity/rendezvous/RendezvousAffinityFunction.java
index 3845715..dcac7d4 100644
--- a/modules/core/src/main/java/org/apache/ignite/cache/affinity/rendezvous/RendezvousAffinityFunction.java
+++ b/modules/core/src/main/java/org/apache/ignite/cache/affinity/rendezvous/RendezvousAffinityFunction.java
@@ -102,7 +102,7 @@ public class RendezvousAffinityFunction implements AffinityFunction, Externaliza
private int parts;
/** Mask to use in calculation when partitions count is power of 2. */
- private int mask = -1;
+ private transient int mask = -1;
/** Exclude neighbors flag. */
private boolean exclNeighbors;
@@ -570,7 +570,8 @@ public class RendezvousAffinityFunction implements AffinityFunction, Externaliza
/** {@inheritDoc} */
@SuppressWarnings("unchecked")
@Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException {
- parts = in.readInt();
+ setPartitions(in.readInt());
+
exclNeighbors = in.readBoolean();
hashIdRslvr = (AffinityNodeHashResolver)in.readObject();
backupFilter = (IgniteBiPredicate<ClusterNode, ClusterNode>)in.readObject();