diff options
author | 2017-12-21 08:10:15 -0800 | |
---|---|---|
committer | 2017-12-21 08:12:45 -0800 | |
commit | 57f228ab6fc8c871648e2f48bf97824566985f29 (patch) | |
tree | ff841e5f40a62e6e887204569c4885788d17d11f /src/main/java | |
parent | 2384b98ac6e193bac30454f39e8949739e441982 (diff) |
Refactor WalkableGraph and BuildDriver interfaces
Remove WalkableGraph#isUpToDate and BuildDriver#alreadyEvaluated and delegate the
work to implementation.
RELNOTES: None
PiperOrigin-RevId: 179815374
Diffstat (limited to 'src/main/java')
5 files changed, 9 insertions, 36 deletions
diff --git a/src/main/java/com/google/devtools/build/lib/query2/SkyQueryEnvironment.java b/src/main/java/com/google/devtools/build/lib/query2/SkyQueryEnvironment.java index f3bdc78760..883047e1a6 100644 --- a/src/main/java/com/google/devtools/build/lib/query2/SkyQueryEnvironment.java +++ b/src/main/java/com/google/devtools/build/lib/query2/SkyQueryEnvironment.java @@ -248,24 +248,21 @@ public class SkyQueryEnvironment extends AbstractBlazeQueryEnvironment<Target> private void beforeEvaluateQuery(QueryExpression expr) throws QueryException, InterruptedException { Set<SkyKey> roots = getGraphRootsFromExpression(expr); - if (graph == null || !graphFactory.isUpToDate(roots)) { - // If this environment is uninitialized or the graph factory needs to evaluate, do so. We - // assume here that this environment cannot be initialized-but-stale if the factory is up - // to date. - EvaluationResult<SkyValue> result; - try (AutoProfiler p = AutoProfiler.logged("evaluation and walkable graph", logger)) { - result = graphFactory.prepareAndGet(roots, loadingPhaseThreads, universeEvalEventHandler); - } - checkEvaluationResult(roots, result); + EvaluationResult<SkyValue> result; + try (AutoProfiler p = AutoProfiler.logged("evaluation and walkable graph", logger)) { + result = graphFactory.prepareAndGet(roots, loadingPhaseThreads, universeEvalEventHandler); + } + if (graph == null || graph != result.getWalkableGraph()) { + checkEvaluationResult(roots, result); packageSemaphore = makeFreshPackageMultisetSemaphore(); graph = result.getWalkableGraph(); blacklistPatternsSupplier = InterruptibleSupplier.Memoize.of(new BlacklistSupplier(graph)); - graphBackedRecursivePackageProvider = new GraphBackedRecursivePackageProvider(graph, universeTargetPatternKeys, pkgPath); } + if (executor == null) { executor = MoreExecutors.listeningDecorator( new ThreadPoolExecutor( diff --git a/src/main/java/com/google/devtools/build/lib/skyframe/SkyframeExecutor.java b/src/main/java/com/google/devtools/build/lib/skyframe/SkyframeExecutor.java index 96fbd0b5e2..3c450d3462 100644 --- a/src/main/java/com/google/devtools/build/lib/skyframe/SkyframeExecutor.java +++ b/src/main/java/com/google/devtools/build/lib/skyframe/SkyframeExecutor.java @@ -1717,11 +1717,6 @@ public abstract class SkyframeExecutor implements WalkableGraphFactory { return evaluationResult; } - @Override - public boolean isUpToDate(Set<SkyKey> roots) { - return buildDriver.alreadyEvaluated(roots); - } - /** * Get metadata related to the prepareAndGet() lookup. Resulting data is specific to the * underlying evaluation implementation. diff --git a/src/main/java/com/google/devtools/build/skyframe/BuildDriver.java b/src/main/java/com/google/devtools/build/skyframe/BuildDriver.java index 78c24793c6..d1f942e0c7 100644 --- a/src/main/java/com/google/devtools/build/skyframe/BuildDriver.java +++ b/src/main/java/com/google/devtools/build/skyframe/BuildDriver.java @@ -37,13 +37,6 @@ public interface BuildDriver { String meta(Iterable<SkyKey> roots, OptionsClassProvider options) throws AbruptExitException, InterruptedException; - /** - * Returns true if this {@link BuildDriver} instance has already been used to {@link #evaluate} - * the given {@code roots} at the Version that would be passed along to the next call to {@link - * MemoizingEvaluator#evaluate} in {@link #evaluate}. - */ - boolean alreadyEvaluated(Iterable<SkyKey> roots); - MemoizingEvaluator getGraphForTesting(); @Nullable diff --git a/src/main/java/com/google/devtools/build/skyframe/SequentialBuildDriver.java b/src/main/java/com/google/devtools/build/skyframe/SequentialBuildDriver.java index 76ae66cb22..51724cdc05 100644 --- a/src/main/java/com/google/devtools/build/skyframe/SequentialBuildDriver.java +++ b/src/main/java/com/google/devtools/build/skyframe/SequentialBuildDriver.java @@ -42,14 +42,9 @@ public class SequentialBuildDriver implements BuildDriver { } } - @Override - public String meta(Iterable<SkyKey> of, OptionsClassProvider options) { - return ""; - } - @Override - public boolean alreadyEvaluated(Iterable<SkyKey> roots) { - return false; + public String meta(Iterable<SkyKey> of, OptionsClassProvider options) { + return ""; } @Override diff --git a/src/main/java/com/google/devtools/build/skyframe/WalkableGraph.java b/src/main/java/com/google/devtools/build/skyframe/WalkableGraph.java index b5b744f6af..a55bbc5415 100644 --- a/src/main/java/com/google/devtools/build/skyframe/WalkableGraph.java +++ b/src/main/java/com/google/devtools/build/skyframe/WalkableGraph.java @@ -103,13 +103,6 @@ public interface WalkableGraph { Set<SkyKey> roots, int numThreads, ExtendedEventHandler eventHandler) throws InterruptedException; - /** - * Returns true if this instance has already been used to {@link #prepareAndGet} {@code roots}. - * If so, cached results from {@link #prepareAndGet} can be re-used safely, potentially saving - * some processing time. - */ - boolean isUpToDate(Set<SkyKey> roots); - /** Returns the {@link SkyKey} that defines this universe. */ SkyKey getUniverseKey(Collection<String> roots, String offset); } |