diff options
author | nharmata <nharmata@google.com> | 2017-06-16 00:26:27 +0200 |
---|---|---|
committer | Yun Peng <pcloudy@google.com> | 2017-06-16 09:27:24 +0200 |
commit | bea67e9e7bc5b25dc0569bc429d92434a76b9a84 (patch) | |
tree | d0f71a262248ffe4676fd746a428fc1c1f6ce48e /src/main/java/com/google/devtools/build/skyframe/ParallelEvaluatorContext.java | |
parent | 0bd2102ea33f8c1bc40fbfb2acabcd46895011f3 (diff) |
A bunch of unrelated cleanups:
-Have SkylarkImportLookupFunction include causes in the SkyFunctionExceptions it throws.
-Better transitive skyframe error declarations in ASTFileLookupFunction.
-Have ErrorInfo differentiate between direct and transitive transience.
-Introduce ErrorInfoManager and have ParallelEvaluator/ParallelEvaluatorContext use it.
RELNOTES: None
PiperOrigin-RevId: 159163186
Diffstat (limited to 'src/main/java/com/google/devtools/build/skyframe/ParallelEvaluatorContext.java')
-rw-r--r-- | src/main/java/com/google/devtools/build/skyframe/ParallelEvaluatorContext.java | 15 |
1 files changed, 8 insertions, 7 deletions
diff --git a/src/main/java/com/google/devtools/build/skyframe/ParallelEvaluatorContext.java b/src/main/java/com/google/devtools/build/skyframe/ParallelEvaluatorContext.java index 49782ce513..2f585ff679 100644 --- a/src/main/java/com/google/devtools/build/skyframe/ParallelEvaluatorContext.java +++ b/src/main/java/com/google/devtools/build/skyframe/ParallelEvaluatorContext.java @@ -47,9 +47,10 @@ class ParallelEvaluatorContext { private final ExtendedEventHandler reporter; private final NestedSetVisitor<TaggedEvents> replayingNestedSetEventVisitor; private final boolean keepGoing; - private final boolean storeErrorsAlongsideValues; private final DirtyTrackingProgressReceiver progressReceiver; private final EventFilter storedEventFilter; + private final ErrorInfoManager errorInfoManager; + /** * The visitor managing the thread pool. Used to enqueue parents when an entry is finished, and, * during testing, to block until an exception is thrown if a node builder requests that. @@ -65,9 +66,9 @@ class ParallelEvaluatorContext { ExtendedEventHandler reporter, EmittedEventState emittedEventState, boolean keepGoing, - boolean storeErrorsAlongsideValues, final DirtyTrackingProgressReceiver progressReceiver, EventFilter storedEventFilter, + ErrorInfoManager errorInfoManager, final Function<SkyKey, Runnable> runnableMaker, final int threadCount) { this.graph = graph; @@ -77,9 +78,9 @@ class ParallelEvaluatorContext { this.replayingNestedSetEventVisitor = new NestedSetVisitor<>(new NestedSetEventReceiver(reporter), emittedEventState); this.keepGoing = keepGoing; - this.storeErrorsAlongsideValues = storeErrorsAlongsideValues; this.progressReceiver = Preconditions.checkNotNull(progressReceiver); this.storedEventFilter = storedEventFilter; + this.errorInfoManager = errorInfoManager; visitorSupplier = Suppliers.memoize( new Supplier<NodeEntryVisitor>() { @@ -98,9 +99,9 @@ class ParallelEvaluatorContext { ExtendedEventHandler reporter, EmittedEventState emittedEventState, boolean keepGoing, - boolean storeErrorsAlongsideValues, final DirtyTrackingProgressReceiver progressReceiver, EventFilter storedEventFilter, + ErrorInfoManager errorInfoManager, final Function<SkyKey, Runnable> runnableMaker, final ForkJoinPool forkJoinPool) { this.graph = graph; @@ -110,9 +111,9 @@ class ParallelEvaluatorContext { this.replayingNestedSetEventVisitor = new NestedSetVisitor<>(new NestedSetEventReceiver(reporter), emittedEventState); this.keepGoing = keepGoing; - this.storeErrorsAlongsideValues = storeErrorsAlongsideValues; this.progressReceiver = Preconditions.checkNotNull(progressReceiver); this.storedEventFilter = storedEventFilter; + this.errorInfoManager = errorInfoManager; visitorSupplier = Suppliers.memoize( new Supplier<NodeEntryVisitor>() { @@ -203,8 +204,8 @@ class ParallelEvaluatorContext { return storedEventFilter; } - boolean storeErrorsAlongsideValues() { - return storeErrorsAlongsideValues; + ErrorInfoManager getErrorInfoManager() { + return errorInfoManager; } /** Receives the events from the NestedSet and delegates to the reporter. */ |