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/AbstractParallelEvaluator.java | |
| parent | 1c75cf386eca4f4f7e6409312ac76b9a1082958d (diff) | |
Store cycle detectors directly in AbstractParallelEvaluator.
PiperOrigin-RevId: 186617412
Diffstat (limited to 'src/main/java/com/google/devtools/build/skyframe/AbstractParallelEvaluator.java')
| -rw-r--r-- | src/main/java/com/google/devtools/build/skyframe/AbstractParallelEvaluator.java | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/src/main/java/com/google/devtools/build/skyframe/AbstractParallelEvaluator.java b/src/main/java/com/google/devtools/build/skyframe/AbstractParallelEvaluator.java index a103f53457..a8c9747c90 100644 --- a/src/main/java/com/google/devtools/build/skyframe/AbstractParallelEvaluator.java +++ b/src/main/java/com/google/devtools/build/skyframe/AbstractParallelEvaluator.java @@ -54,6 +54,7 @@ public abstract class AbstractParallelEvaluator { final ProcessableGraph graph; final ParallelEvaluatorContext evaluatorContext; + protected final CycleDetector cycleDetector; AbstractParallelEvaluator( ProcessableGraph graph, @@ -65,8 +66,10 @@ public abstract class AbstractParallelEvaluator { ErrorInfoManager errorInfoManager, boolean keepGoing, int threadCount, - DirtyTrackingProgressReceiver progressReceiver) { + DirtyTrackingProgressReceiver progressReceiver, + CycleDetector cycleDetector) { this.graph = graph; + this.cycleDetector = cycleDetector; evaluatorContext = new ParallelEvaluatorContext( graph, @@ -92,8 +95,10 @@ public abstract class AbstractParallelEvaluator { ErrorInfoManager errorInfoManager, boolean keepGoing, DirtyTrackingProgressReceiver progressReceiver, - ForkJoinPool forkJoinPool) { + ForkJoinPool forkJoinPool, + CycleDetector cycleDetector) { this.graph = graph; + this.cycleDetector = cycleDetector; evaluatorContext = new ParallelEvaluatorContext( graph, |