ignite-gg-12138 fix activate/deactivate process for new snapshot pool
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/cf1ffede Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/cf1ffede Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/cf1ffede Branch: refs/heads/ignite-5398 Commit: cf1ffede8f70f3d798c0660547ef4d64161333d3 Parents: 84edcfe Author: Dmitriy Govorukhin <[email protected]> Authored: Thu May 25 16:38:38 2017 +0300 Committer: Dmitriy Govorukhin <[email protected]> Committed: Thu May 25 16:38:38 2017 +0300 ---------------------------------------------------------------------- .../processors/cluster/GridClusterStateProcessor.java | 12 +++++------- 1 file changed, 5 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/cf1ffede/modules/core/src/main/java/org/apache/ignite/internal/processors/cluster/GridClusterStateProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cluster/GridClusterStateProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cluster/GridClusterStateProcessor.java index db05e90..b73d30b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cluster/GridClusterStateProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cluster/GridClusterStateProcessor.java @@ -387,15 +387,13 @@ public class GridClusterStateProcessor extends GridProcessorAdapter { sharedCtx.affinity().removeAllCacheInfo(); - if (!ctx.clientNode()) { - sharedCtx.database().onDeActivate(ctx); + sharedCtx.database().onDeActivate(ctx); - if (sharedCtx.pageStore() != null) - sharedCtx.pageStore().onDeActivate(ctx); + if (sharedCtx.pageStore() != null) + sharedCtx.pageStore().onDeActivate(ctx); - if (sharedCtx.wal() != null) - sharedCtx.wal().onDeActivate(ctx); - } + if (sharedCtx.wal() != null) + sharedCtx.wal().onDeActivate(ctx); } catch (Exception e) { for (Map.Entry<UUID, Exception> entry : exs.entrySet())
