ignite-gg-12138 fix activate/deactivate process for new snapshot pool update


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/6bacfdc7
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/6bacfdc7
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/6bacfdc7

Branch: refs/heads/ignite-5398
Commit: 6bacfdc7fee2b0063a2a2ba8680cd01efcfd4855
Parents: cf1ffed
Author: Dmitriy Govorukhin <[email protected]>
Authored: Thu May 25 17:33:09 2017 +0300
Committer: Dmitriy Govorukhin <[email protected]>
Committed: Thu May 25 17:33:09 2017 +0300

----------------------------------------------------------------------
 .../cluster/GridClusterStateProcessor.java      | 20 +++++++++++---------
 1 file changed, 11 insertions(+), 9 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/6bacfdc7/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 b73d30b..a7c5cb8 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
@@ -453,16 +453,18 @@ public class GridClusterStateProcessor extends 
GridProcessorAdapter {
 
             sharedCtx.database().initDataBase();
 
-            for (CacheConfiguration cfg : cfgs) {
-                if (CU.isSystemCache(cfg.getName()))
-                    if (pageStore != null)
-                        pageStore.initializeForCache(cfg);
-            }
+            if (!client){
+                for (CacheConfiguration cfg : cfgs) {
+                    if (CU.isSystemCache(cfg.getName()))
+                        if (pageStore != null)
+                            pageStore.initializeForCache(cfg);
+                }
 
-            for (CacheConfiguration cfg : cfgs) {
-                if (!CU.isSystemCache(cfg.getName()))
-                    if (pageStore != null)
-                        pageStore.initializeForCache(cfg);
+                for (CacheConfiguration cfg : cfgs) {
+                    if (!CU.isSystemCache(cfg.getName()))
+                        if (pageStore != null)
+                            pageStore.initializeForCache(cfg);
+                }
             }
 
             sharedCtx.database().onActivate(ctx);

Reply via email to