IGNITE-9038 Node join serialization defaults Signed-off-by: Andrey Gura <ag...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/0ee363f5 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/0ee363f5 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/0ee363f5 Branch: refs/heads/ignite-8446 Commit: 0ee363f53e4d5635430ca330ccbf98a4df44f537 Parents: 0553210 Author: dkarachentsev <dkarachent...@gridgain.com> Authored: Wed Jul 25 13:03:42 2018 +0300 Committer: Andrey Gura <ag...@apache.org> Committed: Wed Jul 25 13:03:42 2018 +0300 ---------------------------------------------------------------------- .../cache/CacheJoinNodeDiscoveryData.java | 26 ++++++++++++++++---- 1 file changed, 21 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/0ee363f5/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheJoinNodeDiscoveryData.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheJoinNodeDiscoveryData.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheJoinNodeDiscoveryData.java index a3902de..bb0b59b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheJoinNodeDiscoveryData.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheJoinNodeDiscoveryData.java @@ -17,6 +17,8 @@ package org.apache.ignite.internal.processors.cache; +import java.io.IOException; +import java.io.ObjectInputStream; import java.io.Serializable; import java.util.Map; import org.apache.ignite.internal.util.tostring.GridToStringInclude; @@ -99,21 +101,21 @@ public class CacheJoinNodeDiscoveryData implements Serializable { /** */ @GridToStringInclude - private final StoredCacheData cacheData; + private StoredCacheData cacheData; /** */ @GridToStringInclude - private final CacheType cacheType; + private CacheType cacheType; /** */ @GridToStringInclude - private final boolean sql; + private boolean sql; /** Flags added for future usage. */ - private final long flags; + private long flags; /** Statically configured flag */ - private final boolean staticallyConfigured; + private boolean staticallyConfigured; /** * @param cacheData Cache data. @@ -159,6 +161,20 @@ public class CacheJoinNodeDiscoveryData implements Serializable { return staticallyConfigured; } + /** + * @param ois ObjectInputStream. + */ + private void readObject(ObjectInputStream ois) + throws IOException, ClassNotFoundException { + ObjectInputStream.GetField gf = ois.readFields(); + + cacheData = (StoredCacheData)gf.get("cacheData", null); + cacheType = (CacheType)gf.get("cacheType", null); + sql = gf.get("sql", false); + flags = gf.get("flags", 0L); + staticallyConfigured = gf.get("staticallyConfigured", true); + } + /** {@inheritDoc} */ @Override public String toString() { return S.toString(CacheInfo.class, this);
