cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From yu...@apache.org
Subject git commit: Move prepareLatch to local scope
Date Fri, 14 Feb 2014 03:02:01 GMT
Updated Branches:
  refs/heads/trunk ee477cc4d -> 5b0eb01c9


Move prepareLatch to local scope


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/5b0eb01c
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/5b0eb01c
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/5b0eb01c

Branch: refs/heads/trunk
Commit: 5b0eb01c9da6a2c27e419e19210f0bfebf5ac216
Parents: ee477cc
Author: Yuki Morishita <yukim@apache.org>
Authored: Thu Feb 13 21:01:40 2014 -0600
Committer: Yuki Morishita <yukim@apache.org>
Committed: Thu Feb 13 21:01:40 2014 -0600

----------------------------------------------------------------------
 src/java/org/apache/cassandra/service/ActiveRepairService.java | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/5b0eb01c/src/java/org/apache/cassandra/service/ActiveRepairService.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/service/ActiveRepairService.java b/src/java/org/apache/cassandra/service/ActiveRepairService.java
index dc4c66a..232974d 100644
--- a/src/java/org/apache/cassandra/service/ActiveRepairService.java
+++ b/src/java/org/apache/cassandra/service/ActiveRepairService.java
@@ -100,7 +100,6 @@ public class ActiveRepairService
 
     private final ConcurrentMap<UUID, ParentRepairSession> parentRepairSessions;
 
-    private CountDownLatch prepareLatch = null;
     /**
      * Protected constructor. Use ActiveRepairService.instance.
      */
@@ -217,13 +216,13 @@ public class ActiveRepairService
     {
         UUID parentRepairSession = UUIDGen.getTimeUUID();
         registerParentRepairSession(parentRepairSession, columnFamilyStores, ranges);
-        prepareLatch = new CountDownLatch(endpoints.size());
+        final CountDownLatch prepareLatch = new CountDownLatch(endpoints.size());
         IAsyncCallback callback = new IAsyncCallback()
         {
             @Override
             public void response(MessageIn msg)
             {
-                ActiveRepairService.this.prepareLatch.countDown();
+                prepareLatch.countDown();
             }
 
             @Override


Mime
View raw message