Repository: ignite Updated Branches: refs/heads/master 3785cc4c5 -> 8a7e8f07f
IGNITE-8323 Fixed discovery event listener calls - Fixes #3890. Signed-off-by: Alexey Goncharuk <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/8a7e8f07 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/8a7e8f07 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/8a7e8f07 Branch: refs/heads/master Commit: 8a7e8f07fccebb9d5786e5624e353af730d4d039 Parents: 3785cc4 Author: Ilya Lantukh <[email protected]> Authored: Mon Apr 23 17:39:57 2018 +0300 Committer: Alexey Goncharuk <[email protected]> Committed: Mon Apr 23 17:39:57 2018 +0300 ---------------------------------------------------------------------- .../internal/managers/discovery/GridDiscoveryManager.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/8a7e8f07/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java index 6af3293..e9b6cfe 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java @@ -687,11 +687,15 @@ public class GridDiscoveryManager extends GridManagerAdapter<DiscoverySpi> { } nextTopVer = new AffinityTopologyVersion(topVer, minorTopVer); + + if (incMinorTopVer) + ctx.cache().onDiscoveryEvent(type, customMsg, node, nextTopVer, ctx.state().clusterState()); } - else + else { nextTopVer = new AffinityTopologyVersion(topVer, minorTopVer); - ctx.cache().onDiscoveryEvent(type, customMsg, node, nextTopVer, ctx.state().clusterState()); + ctx.cache().onDiscoveryEvent(type, customMsg, node, nextTopVer, ctx.state().clusterState()); + } if (type == EVT_DISCOVERY_CUSTOM_EVT) { for (Class cls = customMsg.getClass(); cls != null; cls = cls.getSuperclass()) {
