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 <[email protected]> Authored: Thu Feb 13 21:01:40 2014 -0600 Committer: Yuki Morishita <[email protected]> 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
