ignite-929
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/ed789f9d Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/ed789f9d Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/ed789f9d Branch: refs/heads/ignite-929 Commit: ed789f9db66c810e46880ebca73e51bc932c2159 Parents: fdf2ce9 Author: Anton <avinogra...@gridgain.com> Authored: Fri Jul 3 17:55:38 2015 +0300 Committer: Anton <avinogra...@gridgain.com> Committed: Fri Jul 3 17:55:38 2015 +0300 ---------------------------------------------------------------------- .../ignite/internal/processors/cache/GridCacheGateway.java | 6 +++--- .../ignite/internal/processors/cache/GridCacheProcessor.java | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ed789f9d/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheGateway.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheGateway.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheGateway.java index ed6ed9c..df450d0 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheGateway.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheGateway.java @@ -153,7 +153,7 @@ public class GridCacheGateway<K, V> { throw new IllegalStateException("Cache has been stopped: " + ctx.name()); } - if (closed.get() != null && closed.get()) { + if (closed.get() != null) { rwLock.readUnlock(); throw new IllegalStateException("Cache has been closed: " + ctx.name()); @@ -246,14 +246,14 @@ public class GridCacheGateway<K, V> { * */ public void open() { - closed.set(false); + closed.remove(); } /** * */ public void close() { - closed.set(true); + closed.set(Boolean.TRUE); } /** http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ed789f9d/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java index 2c3be1f..8a0514c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java @@ -2018,7 +2018,7 @@ public class GridCacheProcessor extends GridProcessorAdapter { public IgniteInternalFuture<?> dynamicDestroyCache(String cacheName) { checkEmptyTransactions(); - DynamicCacheChangeRequest t = new DynamicCacheChangeRequest(cacheName, ctx.localNodeId(), true); + DynamicCacheChangeRequest t = new DynamicCacheChangeRequest(cacheName, ctx.localNodeId()); t.stop(true);
