Fixed "IGNITE-6184 Add checkClusterState() call to destroyCachesAsync() and 
getOrCreateCaches()". This closes #2526.

Signed-off-by: nikolay_tikhonov <[email protected]>


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

Branch: refs/heads/ignite-3478
Commit: adbf0680f8378448ae2f520ed8237bd6baaf7334
Parents: 2929ace
Author: Ilya Kasnacheev <[email protected]>
Authored: Wed Sep 27 13:46:37 2017 +0300
Committer: nikolay_tikhonov <[email protected]>
Committed: Wed Sep 27 13:46:37 2017 +0300

----------------------------------------------------------------------
 .../src/main/java/org/apache/ignite/internal/IgniteKernal.java   | 4 ++++
 1 file changed, 4 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/adbf0680/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java
----------------------------------------------------------------------
diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java 
b/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java
index 67f76e1..f5d736a 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java
@@ -2921,6 +2921,8 @@ public class IgniteKernal implements IgniteEx, 
IgniteMXBean, Externalizable {
         guard();
 
         try {
+            checkClusterState();
+
             ctx.cache().dynamicStartCaches(cacheCfgs,
                 false,
                 true).get();
@@ -3166,6 +3168,8 @@ public class IgniteKernal implements IgniteEx, 
IgniteMXBean, Externalizable {
         guard();
 
         try {
+            checkClusterState();
+
             return ctx.cache().dynamicDestroyCaches(cacheNames, checkThreadTx, 
false);
         }
         finally {

Reply via email to