Repository: incubator-ignite Updated Branches: refs/heads/ignite-901 d8d953f0c -> 1654f3615
# ignite-901 Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/1654f361 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/1654f361 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/1654f361 Branch: refs/heads/ignite-901 Commit: 1654f36157b7c3972890fda5fbf65927dee1666d Parents: d8d953f Author: sboikov <sboi...@gridgain.com> Authored: Tue Jul 14 17:29:43 2015 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Tue Jul 14 17:29:43 2015 +0300 ---------------------------------------------------------------------- .../java/org/apache/ignite/internal/IgniteKernal.java | 10 ++++++++++ .../internal/processors/cache/GridCacheGateway.java | 14 ++++++++++++++ 2 files changed, 24 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1654f361/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 90218ef..0d4ce32 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 @@ -2849,6 +2849,16 @@ public class IgniteKernal implements IgniteEx, IgniteMXBean, Externalizable { } } + for (GridCacheContext cctx : ctx.cache().context().cacheContexts()) { + cctx.gate().writeLock(); + + cctx.gate().writeUnlock(); + } + + ctx.gateway().writeLock(); + + ctx.gateway().writeUnlock(); + if (err != null) { reconnectFut.onDone(err); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1654f361/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 263a697..a3c8da6 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 @@ -266,6 +266,20 @@ public class GridCacheGateway<K, V> { } /** + * + */ + public void writeLock(){ + rwLock.writeLock(); + } + + /** + * + */ + public void writeUnlock() { + rwLock.writeUnlock(); + } + + /** * @param stopped Cache stopped flag. */ public void reconnected(boolean stopped) {
