Repository: incubator-ignite Updated Branches: refs/heads/ignite-929 a91171558 -> bb3f4b535
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/bb3f4b53 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/bb3f4b53 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/bb3f4b53 Branch: refs/heads/ignite-929 Commit: bb3f4b535bdb50344722a39b86e0bb5eeb803154 Parents: a911715 Author: Anton Vinogradov <avinogra...@gridgain.com> Authored: Thu Jun 11 10:11:15 2015 +0300 Committer: Anton Vinogradov <avinogra...@gridgain.com> Committed: Thu Jun 11 10:11:15 2015 +0300 ---------------------------------------------------------------------- .../ignite/internal/processors/cache/GridCacheGateway.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bb3f4b53/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 713a159..5170c6d 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 @@ -40,7 +40,7 @@ public class GridCacheGateway<K, V> { private volatile boolean stopped; /** Client counter. */ - private volatile AtomicInteger clients; + private final AtomicInteger clients = new AtomicInteger(0); /** */ private GridSpinReadWriteLock rwLock = new GridSpinReadWriteLock(); @@ -52,8 +52,6 @@ public class GridCacheGateway<K, V> { assert ctx != null; this.ctx = ctx; - - clients = new AtomicInteger(0); } /** @@ -246,6 +244,8 @@ public class GridCacheGateway<K, V> { */ public void block() { stopped = true; + + clients.decrementAndGet(); } /**
