aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/main/java/com/google/devtools/build/skyframe/ParallelEvaluatorContext.java
diff options
context:
space:
mode:
authorGravatar nharmata <nharmata@google.com>2017-06-16 00:26:27 +0200
committerGravatar Yun Peng <pcloudy@google.com>2017-06-16 09:27:24 +0200
commitbea67e9e7bc5b25dc0569bc429d92434a76b9a84 (patch)
treed0f71a262248ffe4676fd746a428fc1c1f6ce48e /src/main/java/com/google/devtools/build/skyframe/ParallelEvaluatorContext.java
parent0bd2102ea33f8c1bc40fbfb2acabcd46895011f3 (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.java15
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. */