Apache
/
lucene
mirror of https://github.com/apache/lucene.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

be a little less aggressive in how fast we retry failed recoveries 

git-svn-id: https://svn.apache.org/repos/asf/lucene/dev/trunk@1365607 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Mark Robert Miller 2012-07-25 14:47:41 +00:00
parent f7b94431d5
commit e3af5988e7
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
solr/core/src/java/org/apache/solr/cloud/RecoveryStrategy.java
View File

@ -58,7 +58,7 @@ import org.slf4j.LoggerFactory;
public class RecoveryStrategy extends Thread implements SafeStopThread {
private static final int MAX_RETRIES = 500;
private static final int INTERRUPTED = MAX_RETRIES + 1;
private static final int START_TIMEOUT = 100;
private static final int STARTING_RECOVERY_DELAY = 1000;
private static final String REPLICATION_HANDLER = "/replication";
@ -409,10 +409,11 @@ public class RecoveryStrategy extends Thread implements SafeStopThread {
}
try {
// if (!isClosed()) Thread.sleep(Math.min(START_TIMEOUT * retries, 60000));
for (int i = 0; i<Math.min(retries, 600); i++) {
// start at 1 sec and work up to a couple min
double loopCount = Math.min(Math.pow(2, retries), 600);
for (int i = 0; i < loopCount; i++) {
if (isClosed()) break; // check if someone closed us
Thread.sleep(START_TIMEOUT);
Thread.sleep(STARTING_RECOVERY_DELAY);
}
} catch (InterruptedException e) {
Thread.currentThread().interrupt();