ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject incubator-ignite git commit: ignite-929
Date Thu, 11 Jun 2015 07:11:37 GMT
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 <avinogradov@gridgain.com>
Authored: Thu Jun 11 10:11:15 2015 +0300
Committer: Anton Vinogradov <avinogradov@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();
     }
 
     /**


Mime
View raw message