|
@@ -849,6 +849,13 @@ public class Dispatcher {
|
|
|
+ ", scheduledSize=" + getScheduledSize()
|
|
|
+ ", srcBlocks#=" + srcBlocks.size());
|
|
|
}
|
|
|
+ // check if time is up or not
|
|
|
+ if (Time.monotonicNow() - startTime > MAX_ITERATION_TIME) {
|
|
|
+ LOG.info("Time up (max time=" + MAX_ITERATION_TIME/1000
|
|
|
+ + " seconds). Skipping " + this);
|
|
|
+ isTimeUp = true;
|
|
|
+ continue;
|
|
|
+ }
|
|
|
final PendingMove p = chooseNextMove();
|
|
|
if (p != null) {
|
|
|
// Reset no pending move counter
|
|
@@ -886,14 +893,6 @@ public class Dispatcher {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- // check if time is up or not
|
|
|
- if (Time.monotonicNow() - startTime > MAX_ITERATION_TIME) {
|
|
|
- LOG.info("Time up (max time=" + MAX_ITERATION_TIME/1000
|
|
|
- + " seconds). Skipping " + this);
|
|
|
- isTimeUp = true;
|
|
|
- continue;
|
|
|
- }
|
|
|
-
|
|
|
// Now we can not schedule any block to move and there are
|
|
|
// no new blocks added to the source block list, so we wait.
|
|
|
try {
|