From 1b94e82c58f1cbef1ba9217c11f2ba83bd378c26 Mon Sep 17 00:00:00 2001 From: Radovan Zvoncek Date: Wed, 15 Jul 2015 13:17:04 +0200 Subject: [PATCH] Free repair slot before handling the result --- src/main/java/com/spotify/reaper/service/RepairRunner.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/com/spotify/reaper/service/RepairRunner.java b/src/main/java/com/spotify/reaper/service/RepairRunner.java index 1b9cea56b..6fd516664 100644 --- a/src/main/java/com/spotify/reaper/service/RepairRunner.java +++ b/src/main/java/com/spotify/reaper/service/RepairRunner.java @@ -311,8 +311,8 @@ private void repairSegment(final int rangeIndex, final long segmentId, RingRange Futures.addCallback(segmentResult, new FutureCallback() { @Override public void onSuccess(Object ignored) { - handleResult(segmentId); currentlyRunningSegments.set(rangeIndex, -1); + handleResult(segmentId); } @Override public void onFailure(Throwable t) {