You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by av...@apache.org on 2015/07/03 16:57:30 UTC
[50/50] incubator-ignite git commit: ignite-929
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 <av...@gridgain.com>
Authored: Fri Jul 3 17:55:38 2015 +0300
Committer: Anton <av...@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);