You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by yu...@apache.org on 2014/02/14 04:02:01 UTC
git commit: Move prepareLatch to local scope
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 <yu...@apache.org>
Authored: Thu Feb 13 21:01:40 2014 -0600
Committer: Yuki Morishita <yu...@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