start new incremental fetch immediately
@@ -174,9 +174,11 @@ public class Mirror implements IMirror {
if (requestDone) {
handleUpdate();
requestDone = false;
- return;
+ }
+ startFetchRequest();
}
+ private void startFetchRequest() {
if (target != null && ! slobroks.contains(currSlobrok)) {
log.log(Level.INFO, "location broker "+currSlobrok+" removed, will disconnect and use one of: "+slobroks);
target.close();
@@ -215,8 +217,7 @@ public class Mirror implements IMirror {
" (error code " + req.errorCode() + ")");
}
target.close();
- target = null;
- updateTask.scheduleNow(); // try next slobrok
+ target = null; // try next slobrok
return;
}
Values answer = req.returnValues();
@@ -235,7 +236,6 @@ public class Mirror implements IMirror {
Entry[] newSpecs;
if (diffFromGeneration == 0) {
newSpecs = new Entry[numNames];
-
for (int idx = 0; idx < numNames; idx++) {
newSpecs[idx] = new Entry(n[idx], s[idx]);
}
@@ -270,7 +270,6 @@ public class Mirror implements IMirror {
updates = u;
}
backOff.reset();
- updateTask.schedule(0.1); // be nice
}
/**
