diff options
| author |  shreyax <shreyax@google.com> | 2018-02-22 07:59:17 -0800 |
|---|---|---|
| committer |  Copybara-Service <copybara-piper@google.com> | 2018-02-22 08:01:52 -0800 |
| commit | 0af09b770672a6a6645a4e542fa1082cc586a5da (patch) | |
| tree | 4c383b7a0ea37e60f2513d31c255d38293aaaeff /src/main/java/com/google/devtools/build/skyframe/AbstractExceptionalParallelEvaluator.java | |
| parent | 1c75cf386eca4f4f7e6409312ac76b9a1082958d (diff) | |
Store cycle detectors directly in AbstractParallelEvaluator.
PiperOrigin-RevId: 186617412
Diffstat (limited to 'src/main/java/com/google/devtools/build/skyframe/AbstractExceptionalParallelEvaluator.java')
| -rw-r--r-- | src/main/java/com/google/devtools/build/skyframe/AbstractExceptionalParallelEvaluator.java | 10 |
1 files changed, 4 insertions, 6 deletions
diff --git a/src/main/java/com/google/devtools/build/skyframe/AbstractExceptionalParallelEvaluator.java b/src/main/java/com/google/devtools/build/skyframe/AbstractExceptionalParallelEvaluator.java index bb9a7621f2..6fe3adc25a 100644 --- a/src/main/java/com/google/devtools/build/skyframe/AbstractExceptionalParallelEvaluator.java +++ b/src/main/java/com/google/devtools/build/skyframe/AbstractExceptionalParallelEvaluator.java @@ -76,8 +76,6 @@ import javax.annotation.Nullable; public abstract class AbstractExceptionalParallelEvaluator<E extends Exception> extends AbstractParallelEvaluator { - private final CycleDetector cycleDetector; - AbstractExceptionalParallelEvaluator( ProcessableGraph graph, Version graphVersion, @@ -99,8 +97,8 @@ public abstract class AbstractExceptionalParallelEvaluator<E extends Exception> errorInfoManager, keepGoing, threadCount, - progressReceiver); - cycleDetector = new SimpleCycleDetector(); + progressReceiver, + new SimpleCycleDetector()); } AbstractExceptionalParallelEvaluator( @@ -125,8 +123,8 @@ public abstract class AbstractExceptionalParallelEvaluator<E extends Exception> errorInfoManager, keepGoing, progressReceiver, - forkJoinPool); - this.cycleDetector = cycleDetector; + forkJoinPool, + cycleDetector); } private void informProgressReceiverThatValueIsDone(SkyKey key, NodeEntry entry) |