| // Copyright 2014 The Bazel Authors. All rights reserved. |
| // |
| // Licensed under the Apache License, Version 2.0 (the "License"); |
| // you may not use this file except in compliance with the License. |
| // You may obtain a copy of the License at |
| // |
| // http://www.apache.org/licenses/LICENSE-2.0 |
| // |
| // Unless required by applicable law or agreed to in writing, software |
| // distributed under the License is distributed on an "AS IS" BASIS, |
| // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| // See the License for the specific language governing permissions and |
| // limitations under the License. |
| package com.google.devtools.build.lib.skyframe; |
| |
| import static com.google.common.collect.ImmutableList.toImmutableList; |
| import static com.google.common.collect.ImmutableMap.toImmutableMap; |
| import static com.google.common.collect.ImmutableSet.toImmutableSet; |
| |
| import com.google.common.annotations.VisibleForTesting; |
| import com.google.common.base.Joiner; |
| import com.google.common.base.Preconditions; |
| import com.google.common.base.Stopwatch; |
| import com.google.common.collect.ImmutableList; |
| import com.google.common.collect.ImmutableMap; |
| import com.google.common.collect.ImmutableSet; |
| import com.google.common.collect.Iterables; |
| import com.google.common.collect.Sets; |
| import com.google.common.collect.Streams; |
| import com.google.common.eventbus.EventBus; |
| import com.google.devtools.build.lib.actions.ActionAnalysisMetadata; |
| import com.google.devtools.build.lib.actions.ActionKeyContext; |
| import com.google.devtools.build.lib.actions.ActionLookupKey; |
| import com.google.devtools.build.lib.actions.ActionLookupValue; |
| import com.google.devtools.build.lib.actions.AnalysisGraphStatsEvent; |
| import com.google.devtools.build.lib.actions.Artifact; |
| import com.google.devtools.build.lib.actions.ArtifactFactory; |
| import com.google.devtools.build.lib.actions.ArtifactPrefixConflictException; |
| import com.google.devtools.build.lib.actions.BuildFailedException; |
| import com.google.devtools.build.lib.actions.MutableActionGraph.ActionConflictException; |
| import com.google.devtools.build.lib.actions.PackageRoots; |
| import com.google.devtools.build.lib.actions.ResourceManager; |
| import com.google.devtools.build.lib.actions.TestExecException; |
| import com.google.devtools.build.lib.actions.TotalAndConfiguredTargetOnlyMetric; |
| import com.google.devtools.build.lib.analysis.AnalysisFailureEvent; |
| import com.google.devtools.build.lib.analysis.AnalysisOperationWatcher; |
| import com.google.devtools.build.lib.analysis.AnalysisPhaseCompleteEvent; |
| import com.google.devtools.build.lib.analysis.AspectValue; |
| import com.google.devtools.build.lib.analysis.CachingAnalysisEnvironment; |
| import com.google.devtools.build.lib.analysis.ConfiguredAspect; |
| import com.google.devtools.build.lib.analysis.ConfiguredRuleClassProvider; |
| import com.google.devtools.build.lib.analysis.ConfiguredTarget; |
| import com.google.devtools.build.lib.analysis.ConfiguredTargetFactory; |
| import com.google.devtools.build.lib.analysis.ConfiguredTargetValue; |
| import com.google.devtools.build.lib.analysis.DependencyKind; |
| import com.google.devtools.build.lib.analysis.ExecGroupCollection; |
| import com.google.devtools.build.lib.analysis.ExecGroupCollection.InvalidExecGroupException; |
| import com.google.devtools.build.lib.analysis.ResolvedToolchainContext; |
| import com.google.devtools.build.lib.analysis.ToolchainCollection; |
| import com.google.devtools.build.lib.analysis.TopLevelArtifactContext; |
| import com.google.devtools.build.lib.analysis.ViewCreationFailedException; |
| import com.google.devtools.build.lib.analysis.config.BuildConfigurationValue; |
| import com.google.devtools.build.lib.analysis.config.BuildOptions; |
| import com.google.devtools.build.lib.analysis.config.BuildOptions.OptionsDiff; |
| import com.google.devtools.build.lib.analysis.config.ConfigConditions; |
| import com.google.devtools.build.lib.analysis.config.StarlarkTransitionCache; |
| import com.google.devtools.build.lib.analysis.test.AnalysisFailurePropagationException; |
| import com.google.devtools.build.lib.bugreport.BugReport; |
| import com.google.devtools.build.lib.bugreport.BugReporter; |
| import com.google.devtools.build.lib.buildeventstream.BuildEventStreamProtos.BuildMetrics.BuildGraphMetrics; |
| import com.google.devtools.build.lib.causes.AnalysisFailedCause; |
| import com.google.devtools.build.lib.cmdline.Label; |
| import com.google.devtools.build.lib.collect.nestedset.NestedSet; |
| import com.google.devtools.build.lib.collect.nestedset.NestedSetBuilder; |
| import com.google.devtools.build.lib.collect.nestedset.Order; |
| import com.google.devtools.build.lib.concurrent.MultiThreadPoolsQuiescingExecutor; |
| import com.google.devtools.build.lib.concurrent.QuiescingExecutors; |
| import com.google.devtools.build.lib.events.Event; |
| import com.google.devtools.build.lib.events.EventHandler; |
| import com.google.devtools.build.lib.events.ExtendedEventHandler; |
| import com.google.devtools.build.lib.packages.Package; |
| import com.google.devtools.build.lib.packages.Rule; |
| import com.google.devtools.build.lib.packages.Target; |
| import com.google.devtools.build.lib.packages.TargetUtils; |
| import com.google.devtools.build.lib.profiler.Profiler; |
| import com.google.devtools.build.lib.profiler.SilentCloseable; |
| import com.google.devtools.build.lib.skyframe.ArtifactConflictFinder.ConflictException; |
| import com.google.devtools.build.lib.skyframe.AspectKeyCreator.AspectKey; |
| import com.google.devtools.build.lib.skyframe.AspectKeyCreator.TopLevelAspectsKey; |
| import com.google.devtools.build.lib.skyframe.BuildDriverKey.TestType; |
| import com.google.devtools.build.lib.skyframe.SkyframeErrorProcessor.ErrorProcessingResult; |
| import com.google.devtools.build.lib.skyframe.SkyframeExecutor.ConfigureTargetsResult; |
| import com.google.devtools.build.lib.skyframe.SkyframeExecutor.FailureToRetrieveIntrospectedValueException; |
| import com.google.devtools.build.lib.skyframe.SkyframeExecutor.TopLevelActionConflictReport; |
| import com.google.devtools.build.lib.util.DetailedExitCode; |
| import com.google.devtools.build.lib.util.DetailedExitCode.DetailedExitCodeComparator; |
| import com.google.devtools.build.lib.util.OrderedSetMultimap; |
| import com.google.devtools.build.skyframe.ErrorInfo; |
| import com.google.devtools.build.skyframe.EvaluationProgressReceiver; |
| import com.google.devtools.build.skyframe.EvaluationResult; |
| import com.google.devtools.build.skyframe.GroupedDeps; |
| import com.google.devtools.build.skyframe.SkyFunction.Environment; |
| import com.google.devtools.build.skyframe.SkyKey; |
| import com.google.devtools.build.skyframe.SkyValue; |
| import com.google.devtools.common.options.OptionDefinition; |
| import java.util.ArrayList; |
| import java.util.Collection; |
| import java.util.Collections; |
| import java.util.HashSet; |
| import java.util.List; |
| import java.util.Map; |
| import java.util.Map.Entry; |
| import java.util.Optional; |
| import java.util.Set; |
| import java.util.concurrent.atomic.AtomicInteger; |
| import java.util.function.Supplier; |
| import javax.annotation.Nullable; |
| |
| /** |
| * Skyframe-based driver of analysis. |
| * |
| * <p>Covers enough functionality to work as a substitute for {@code BuildView#configureTargets}. |
| */ |
| public final class SkyframeBuildView { |
| private final ConfiguredTargetFactory factory; |
| private final ArtifactFactory artifactFactory; |
| private final SkyframeExecutor skyframeExecutor; |
| private final ActionKeyContext actionKeyContext; |
| private boolean enableAnalysis = false; |
| |
| // This hack allows us to see when an action lookup node has been invalidated, and thus when the |
| // set of artifact conflicts needs to be recomputed (whenever an action lookup node has been |
| // invalidated or newly evaluated). |
| private final ActionLookupValueProgressReceiver progressReceiver = |
| new ActionLookupValueProgressReceiver(); |
| // Used to see if checks of graph consistency need to be done after analysis. |
| private volatile boolean someActionLookupValueEvaluated = false; |
| |
| // We keep the set of invalidated action lookup nodes so that we can know if something has been |
| // invalidated after graph pruning has been executed. |
| private Set<ActionLookupKey> dirtiedActionLookupKeys = Sets.newConcurrentHashSet(); |
| |
| private final ConfiguredRuleClassProvider ruleClassProvider; |
| |
| private BuildConfigurationValue configuration; |
| |
| /** |
| * If the last build was executed with {@code Options#discard_analysis_cache} and we are not |
| * running Skyframe full, we should clear the legacy data since it is out-of-sync. |
| */ |
| private boolean skyframeAnalysisWasDiscarded; |
| |
| private ImmutableSet<SkyKey> largestTopLevelKeySetCheckedForConflicts = ImmutableSet.of(); |
| private boolean foundActionConflictInLatestCheck; |
| |
| private final StarlarkTransitionCache starlarkTransitionCache = new StarlarkTransitionCache(); |
| |
| public SkyframeBuildView( |
| ArtifactFactory artifactFactory, |
| SkyframeExecutor skyframeExecutor, |
| ConfiguredRuleClassProvider ruleClassProvider, |
| ActionKeyContext actionKeyContext) { |
| this.actionKeyContext = actionKeyContext; |
| this.factory = new ConfiguredTargetFactory(ruleClassProvider); |
| this.artifactFactory = artifactFactory; |
| this.skyframeExecutor = skyframeExecutor; |
| this.ruleClassProvider = ruleClassProvider; |
| } |
| |
| public void resetProgressReceiver() { |
| progressReceiver.reset(); |
| } |
| |
| public TotalAndConfiguredTargetOnlyMetric getEvaluatedCounts() { |
| return TotalAndConfiguredTargetOnlyMetric.create( |
| progressReceiver.configuredObjectCount.get(), progressReceiver.configuredTargetCount.get()); |
| } |
| |
| ConfiguredTargetFactory getConfiguredTargetFactory() { |
| return factory; |
| } |
| |
| public TotalAndConfiguredTargetOnlyMetric getEvaluatedActionCounts() { |
| return TotalAndConfiguredTargetOnlyMetric.create( |
| progressReceiver.actionCount.get(), progressReceiver.configuredTargetActionCount.get()); |
| } |
| |
| /** |
| * Returns a description of the analysis-cache affecting changes between the current configuration |
| * and the incoming one. |
| * |
| * @param maxDifferencesToShow the maximum number of change-affecting options to include in the |
| * returned description |
| * @return a description or {@code null} if the configuration has not changed in a way that |
| * requires the analysis cache to be invalidated |
| */ |
| @Nullable |
| private String describeConfigurationDifference( |
| BuildConfigurationValue configuration, int maxDifferencesToShow) { |
| if (this.configuration == null) { |
| return null; |
| } |
| if (configuration.equals(this.configuration)) { |
| return null; |
| } |
| |
| OptionsDiff diff = |
| BuildOptions.diff(this.configuration.getOptions(), configuration.getOptions()); |
| |
| ImmutableSet<OptionDefinition> nativeCacheInvalidatingDifferences = |
| getNativeCacheInvalidatingDifferences(configuration, diff); |
| if (nativeCacheInvalidatingDifferences.isEmpty() |
| && diff.getChangedStarlarkOptions().isEmpty()) { |
| // The configuration may have changed, but none of the changes required a cache reset. For |
| // example, test trimming was turned on and a test option changed. In this case, nothing needs |
| // to be done. |
| return null; |
| } |
| |
| if (maxDifferencesToShow == 0) { |
| return "Build options have changed"; |
| } |
| |
| ImmutableList<String> relevantDifferences = |
| Streams.concat( |
| diff.getChangedStarlarkOptions().stream().map(Label::getCanonicalForm), |
| nativeCacheInvalidatingDifferences.stream().map(OptionDefinition::getOptionName)) |
| .map(s -> "--" + s) |
| // Sorting the list to ensure that (if truncated through maxDifferencesToShow) the |
| // options in the message remain stable. |
| .sorted() |
| .collect(toImmutableList()); |
| |
| if (maxDifferencesToShow > 0 && relevantDifferences.size() > maxDifferencesToShow) { |
| return String.format( |
| "Build options %s%s and %d more have changed", |
| Joiner.on(", ").join(relevantDifferences.subList(0, maxDifferencesToShow)), |
| maxDifferencesToShow == 1 ? "" : ",", |
| relevantDifferences.size() - maxDifferencesToShow); |
| } else if (relevantDifferences.size() == 1) { |
| return String.format( |
| "Build option %s has changed", Iterables.getOnlyElement(relevantDifferences)); |
| } else if (relevantDifferences.size() == 2) { |
| return String.format( |
| "Build options %s have changed", Joiner.on(" and ").join(relevantDifferences)); |
| } else { |
| return String.format( |
| "Build options %s, and %s have changed", |
| Joiner.on(", ").join(relevantDifferences.subList(0, relevantDifferences.size() - 1)), |
| Iterables.getLast(relevantDifferences)); |
| } |
| } |
| |
| // TODO(schmitt): This method assumes that the only option that can cause multiple target |
| // configurations is --cpu which (with the presence of split transitions) is no longer true. |
| private ImmutableSet<OptionDefinition> getNativeCacheInvalidatingDifferences( |
| BuildConfigurationValue newConfig, |
| OptionsDiff diff) { |
| return diff.getFirst().keySet().stream() |
| .filter( |
| (definition) -> |
| ruleClassProvider.shouldInvalidateCacheForOptionDiff( |
| newConfig.getOptions(), |
| definition, |
| diff.getFirst().get(definition), |
| Iterables.getOnlyElement(diff.getSecond().get(definition)))) |
| .collect(toImmutableSet()); |
| } |
| |
| /** Sets the configuration. Not thread-safe. DO NOT CALL except from tests! */ |
| @VisibleForTesting |
| public void setConfiguration( |
| EventHandler eventHandler, BuildConfigurationValue configuration, int maxDifferencesToShow) { |
| if (skyframeAnalysisWasDiscarded) { |
| eventHandler.handle( |
| Event.warn( |
| "--discard_analysis_cache was used in the previous build, " |
| + "discarding analysis cache.")); |
| skyframeExecutor.handleAnalysisInvalidatingChange(); |
| } else { |
| String diff = describeConfigurationDifference(configuration, maxDifferencesToShow); |
| if (diff != null) { |
| eventHandler.handle( |
| Event.warn(diff + ", discarding analysis cache (this can be expensive).")); |
| // Note that clearing the analysis cache is currently required for correctness. It is also |
| // helpful to save memory. |
| // |
| // If we had more memory, fixing the correctness issue (see also b/144932999) would allow us |
| // to not invalidate the cache, leading to potentially better performance on incremental |
| // builds. |
| skyframeExecutor.handleAnalysisInvalidatingChange(); |
| } |
| } |
| |
| skyframeAnalysisWasDiscarded = false; |
| this.configuration = configuration; |
| skyframeExecutor.setTopLevelConfiguration(configuration); |
| } |
| |
| @VisibleForTesting |
| public BuildConfigurationValue getBuildConfiguration() { |
| return configuration; |
| } |
| |
| /** |
| * Drops the analysis cache. If building with Skyframe, targets in {@code topLevelTargets} may |
| * remain in the cache for use during the execution phase. |
| * |
| * @see com.google.devtools.build.lib.analysis.AnalysisOptions#discardAnalysisCache |
| */ |
| public void clearAnalysisCache( |
| ImmutableSet<ConfiguredTarget> topLevelTargets, ImmutableSet<AspectKey> topLevelAspects) { |
| // TODO(bazel-team): Consider clearing packages too to save more memory. |
| skyframeAnalysisWasDiscarded = true; |
| try (SilentCloseable c = Profiler.instance().profile("skyframeExecutor.clearAnalysisCache")) { |
| skyframeExecutor.clearAnalysisCache(topLevelTargets, topLevelAspects); |
| } |
| starlarkTransitionCache.clear(); |
| } |
| |
| /** |
| * Analyzes the specified targets using Skyframe as the driving framework. |
| * |
| * @return the configured targets that should be built along with a WalkableGraph of the analysis. |
| */ |
| public SkyframeAnalysisResult configureTargets( |
| ExtendedEventHandler eventHandler, |
| ImmutableList<ConfiguredTargetKey> ctKeys, |
| ImmutableList<TopLevelAspectsKey> topLevelAspectsKeys, |
| Supplier<Map<BuildConfigurationKey, BuildConfigurationValue>> configurationLookupSupplier, |
| TopLevelArtifactContext topLevelArtifactContextForConflictPruning, |
| EventBus eventBus, |
| BugReporter bugReporter, |
| boolean keepGoing, |
| QuiescingExecutors executors, |
| boolean strictConflictChecks, |
| boolean checkForActionConflicts) |
| throws InterruptedException, ViewCreationFailedException { |
| enableAnalysis(true); |
| ConfigureTargetsResult result; |
| try (SilentCloseable c = Profiler.instance().profile("skyframeExecutor.configureTargets")) { |
| result = |
| skyframeExecutor.configureTargets( |
| eventHandler, ctKeys, topLevelAspectsKeys, keepGoing, executors); |
| } finally { |
| enableAnalysis(false); |
| } |
| |
| ImmutableSet<ConfiguredTarget> cts = result.configuredTargets(); |
| ImmutableMap<AspectKey, ConfiguredAspect> aspects = result.aspects(); |
| ImmutableSet<AspectKey> aspectKeys = aspects.keySet(); |
| PackageRoots packageRoots = result.packageRoots(); |
| EvaluationResult<ActionLookupValue> evaluationResult = result.evaluationResult(); |
| |
| ImmutableMap<ActionAnalysisMetadata, ConflictException> actionConflicts = ImmutableMap.of(); |
| try (SilentCloseable c = |
| Profiler.instance().profile("skyframeExecutor.findArtifactConflicts")) { |
| ImmutableSet<SkyKey> newKeys = |
| ImmutableSet.<SkyKey>builderWithExpectedSize(ctKeys.size() + aspectKeys.size()) |
| .addAll(ctKeys) |
| .addAll(aspectKeys) |
| .build(); |
| if (shouldCheckForConflicts(checkForActionConflicts, newKeys)) { |
| largestTopLevelKeySetCheckedForConflicts = newKeys; |
| // This operation is somewhat expensive, so we only do it if the graph might have changed in |
| // some way -- either we analyzed a new target or we invalidated an old one or are building |
| // targets together that haven't been built before. |
| ActionLookupValuesTraversal analysisTraversalResult = |
| skyframeExecutor.collectActionLookupValuesInBuild(ctKeys, aspectKeys); |
| ArtifactConflictFinder.ActionConflictsAndStats conflictsAndStats = |
| ArtifactConflictFinder.findAndStoreArtifactConflicts( |
| analysisTraversalResult.getActionLookupValueShards(), |
| analysisTraversalResult.getActionCount(), |
| strictConflictChecks, |
| actionKeyContext); |
| BuildGraphMetrics buildGraphMetrics = |
| analysisTraversalResult |
| .getMetrics() |
| .setOutputArtifactCount(conflictsAndStats.getOutputArtifactCount()) |
| .build(); |
| eventBus.post(new AnalysisGraphStatsEvent(buildGraphMetrics)); |
| actionConflicts = conflictsAndStats.getConflicts(); |
| someActionLookupValueEvaluated = false; |
| } |
| } |
| foundActionConflictInLatestCheck = !actionConflicts.isEmpty(); |
| |
| if (!evaluationResult.hasError() && !foundActionConflictInLatestCheck) { |
| return new SkyframeAnalysisResult( |
| /* hasLoadingError= */ false, |
| /* hasAnalysisError= */ false, |
| foundActionConflictInLatestCheck, |
| cts, |
| evaluationResult.getWalkableGraph(), |
| aspects, |
| packageRoots); |
| } |
| |
| ErrorProcessingResult errorProcessingResult = |
| SkyframeErrorProcessor.processAnalysisErrors( |
| evaluationResult, |
| configurationLookupSupplier, |
| skyframeExecutor.getCyclesReporter(), |
| eventHandler, |
| keepGoing, |
| eventBus, |
| bugReporter); |
| |
| ViewCreationFailedException noKeepGoingExceptionDueToConflict = null; |
| // Sometimes there are action conflicts, but the actions aren't actually required to run by the |
| // build. In such cases, the conflict should still be reported to the user. |
| // See OutputArtifactConflictTest#unusedActionsStillConflict. |
| Collection<Exception> reportedExceptions = Sets.newHashSet(); |
| for (Entry<ActionAnalysisMetadata, ConflictException> bad : actionConflicts.entrySet()) { |
| ConflictException ex = bad.getValue(); |
| DetailedExitCode detailedExitCode; |
| try { |
| throw ex.rethrowTyped(); |
| } catch (ActionConflictException ace) { |
| detailedExitCode = ace.getDetailedExitCode(); |
| ace.reportTo(eventHandler); |
| if (keepGoing) { |
| eventHandler.handle( |
| Event.warn( |
| "errors encountered while analyzing target '" |
| + bad.getKey().getOwner().getLabel() |
| + "': it will not be built")); |
| } |
| } catch (ArtifactPrefixConflictException apce) { |
| detailedExitCode = apce.getDetailedExitCode(); |
| if (reportedExceptions.add(apce)) { |
| eventHandler.handle(Event.error(apce.getMessage())); |
| } |
| } |
| if (!keepGoing) { |
| noKeepGoingExceptionDueToConflict = |
| new ViewCreationFailedException(detailedExitCode.getFailureDetail(), ex); |
| } |
| } |
| |
| if (foundActionConflictInLatestCheck) { |
| // In order to determine the set of configured targets transitively error free from action |
| // conflict issues, we run a post-processing update() that uses the bad action map. |
| TopLevelActionConflictReport topLevelActionConflictReport; |
| enableAnalysis(true); |
| try { |
| topLevelActionConflictReport = |
| skyframeExecutor.filterActionConflictsForConfiguredTargetsAndAspects( |
| eventHandler, |
| Iterables.concat(ctKeys, aspectKeys), |
| actionConflicts, |
| topLevelArtifactContextForConflictPruning); |
| } finally { |
| enableAnalysis(false); |
| } |
| // Report an AnalysisFailureEvent to BEP for the top-level targets with discoverable action |
| // conflicts, then finally throw if evaluation is --nokeep_going. |
| for (ActionLookupKey ctKey : Iterables.concat(ctKeys, aspectKeys)) { |
| if (!topLevelActionConflictReport.isErrorFree(ctKey)) { |
| Optional<ConflictException> e = topLevelActionConflictReport.getConflictException(ctKey); |
| if (e.isEmpty()) { |
| continue; |
| } |
| AnalysisFailedCause failedCause = |
| makeArtifactConflictAnalysisFailedCause(configurationLookupSupplier, e.get()); |
| BuildConfigurationKey configKey = ctKey.getConfigurationKey(); |
| eventBus.post( |
| new AnalysisFailureEvent( |
| ctKey, |
| configurationLookupSupplier.get().get(configKey).toBuildEvent().getEventId(), |
| NestedSetBuilder.create(Order.STABLE_ORDER, failedCause))); |
| if (!keepGoing) { |
| noKeepGoingExceptionDueToConflict = |
| new ViewCreationFailedException( |
| failedCause.getDetailedExitCode().getFailureDetail(), e.get()); |
| } |
| } |
| } |
| |
| // If we're here and we're --nokeep_going, then there was a conflict due to actions not |
| // discoverable by TopLevelActionLookupConflictFindingFunction. This includes extra actions, |
| // coverage artifacts, and artifacts produced by aspects in output groups not present in |
| // --output_groups. Throw the exception produced by the ArtifactConflictFinder which cannot |
| // identify root-cause top-level keys but does catch all possible conflicts. |
| if (!keepGoing) { |
| skyframeExecutor.resetActionConflictsStoredInSkyframe(); |
| throw Preconditions.checkNotNull(noKeepGoingExceptionDueToConflict); |
| } |
| |
| // Filter cts and aspects to only error-free keys. Note that any analysis failure - not just |
| // action conflicts - will be observed here and lead to a key's exclusion. |
| cts = |
| ctKeys.stream() |
| .filter(topLevelActionConflictReport::isErrorFree) |
| .map( |
| k -> |
| Preconditions.checkNotNull((ConfiguredTargetValue) evaluationResult.get(k), k) |
| .getConfiguredTarget()) |
| .collect(toImmutableSet()); |
| |
| aspects = |
| aspects.entrySet().stream() |
| .filter(e -> topLevelActionConflictReport.isErrorFree(e.getKey())) |
| .collect(toImmutableMap(Map.Entry::getKey, Map.Entry::getValue)); |
| } |
| |
| return new SkyframeAnalysisResult( |
| errorProcessingResult.hasLoadingError(), |
| evaluationResult.hasError() || foundActionConflictInLatestCheck, |
| foundActionConflictInLatestCheck, |
| cts, |
| evaluationResult.getWalkableGraph(), |
| aspects, |
| packageRoots); |
| } |
| |
| /** |
| * Performs analysis & execution of the CTs and aspects with Skyframe. |
| * |
| * <p>In case of error: --nokeep_going will eventually throw a ViewCreationFailedException, |
| * whereas --keep_going will return a SkyframeAnalysisAndExecutionResult which contains the |
| * failure details. |
| * |
| * <p>TODO(b/199053098) Have a more appropriate return type. |
| */ |
| public SkyframeAnalysisResult analyzeAndExecuteTargets( |
| ExtendedEventHandler eventHandler, |
| List<ConfiguredTargetKey> ctKeys, |
| ImmutableList<TopLevelAspectsKey> topLevelAspectsKeys, |
| @Nullable ImmutableSet<Label> testsToRun, |
| ImmutableMap<Label, Target> labelTargetMap, |
| Supplier<Map<BuildConfigurationKey, BuildConfigurationValue>> configurationLookupSupplier, |
| TopLevelArtifactContext topLevelArtifactContext, |
| ImmutableSet<Label> explicitTargetPatterns, |
| EventBus eventBus, |
| BugReporter bugReporter, |
| ResourceManager resourceManager, |
| BuildResultListener buildResultListener, |
| CoverageReportActionsWrapperSupplier coverageReportActionsWrapperSupplier, |
| boolean keepGoing, |
| boolean skipIncompatibleExplicitTargets, |
| boolean strictConflictCheck, |
| boolean checkForActionConflicts, |
| QuiescingExecutors executors, |
| boolean shouldDiscardAnalysisCache, |
| BuildDriverKeyTestContext buildDriverKeyTestContext, |
| int skymeldAnalysisOverlapPercentage) |
| throws InterruptedException, |
| ViewCreationFailedException, |
| BuildFailedException, |
| TestExecException { |
| Stopwatch analysisWorkTimer = Stopwatch.createStarted(); |
| EvaluationResult<BuildDriverValue> evaluationResult; |
| |
| ImmutableSet<SkyKey> newKeys = |
| ImmutableSet.<SkyKey>builderWithExpectedSize(ctKeys.size() + topLevelAspectsKeys.size()) |
| .addAll(ctKeys) |
| .addAll(topLevelAspectsKeys) |
| .build(); |
| |
| ImmutableList<Artifact> workspaceStatusArtifacts = |
| skyframeExecutor.getWorkspaceStatusArtifacts(eventHandler); |
| |
| ImmutableSet<BuildDriverKey> buildDriverCTKeys = |
| ctKeys.stream() |
| .map( |
| ctKey -> |
| BuildDriverKey.ofConfiguredTarget( |
| ctKey, |
| topLevelArtifactContext, |
| strictConflictCheck, |
| /* explicitlyRequested= */ explicitTargetPatterns.contains( |
| ctKey.getLabel()), |
| skipIncompatibleExplicitTargets, |
| determineTestType( |
| testsToRun, |
| labelTargetMap, |
| ctKey.getLabel(), |
| buildDriverKeyTestContext, |
| eventHandler))) |
| .collect(ImmutableSet.toImmutableSet()); |
| |
| ImmutableSet<BuildDriverKey> buildDriverAspectKeys = |
| topLevelAspectsKeys.stream() |
| .map( |
| k -> |
| BuildDriverKey.ofTopLevelAspect( |
| k, |
| topLevelArtifactContext, |
| strictConflictCheck, |
| /* explicitlyRequested= */ explicitTargetPatterns.contains(k.getLabel()), |
| skipIncompatibleExplicitTargets)) |
| .collect(ImmutableSet.toImmutableSet()); |
| List<DetailedExitCode> detailedExitCodes = new ArrayList<>(); |
| MultiThreadPoolsQuiescingExecutor executor = |
| (MultiThreadPoolsQuiescingExecutor) executors.getMergedAnalysisAndExecutionExecutor(); |
| Set<SkyKey> topLevelKeys = |
| Sets.newConcurrentHashSet(Sets.union(buildDriverCTKeys, buildDriverAspectKeys)); |
| |
| try (AnalysisOperationWatcher autoCloseableWatcher = |
| AnalysisOperationWatcher.createAndRegisterWithEventBus( |
| topLevelKeys, |
| eventBus, |
| /* lowerThresholdToSignalForExecution= */ (float) |
| (topLevelKeys.size() * skymeldAnalysisOverlapPercentage / 100.0), |
| /* finisher= */ () -> |
| analysisFinishedCallback( |
| eventBus, |
| buildResultListener, |
| skyframeExecutor, |
| ctKeys, |
| shouldDiscardAnalysisCache, |
| /* measuredAnalysisTime= */ analysisWorkTimer.stop().elapsed().toMillis(), |
| /* shouldPublishBuildGraphMetrics= */ () -> |
| shouldCheckForConflicts(checkForActionConflicts, newKeys)), |
| /* executionGoAheadCallback= */ executor::launchQueuedUpExecutionPhaseTasks)) { |
| |
| try { |
| resourceManager.resetResourceUsage(); |
| EvaluationResult<SkyValue> additionalArtifactsResult; |
| try (SilentCloseable c = |
| Profiler.instance().profile("skyframeExecutor.evaluateBuildDriverKeys")) { |
| // Will be disabled later by the AnalysisOperationWatcher upon conclusion of analysis. |
| enableAnalysis(true); |
| evaluationResult = |
| skyframeExecutor.evaluateBuildDriverKeys( |
| eventHandler, |
| buildDriverCTKeys, |
| buildDriverAspectKeys, |
| keepGoing, |
| executors.executionParallelism(), |
| executor, |
| () -> shouldCheckForConflicts(checkForActionConflicts, newKeys)); |
| } finally { |
| // Required for incremental correctness. |
| // We unconditionally reset the states here instead of in #analysisFinishedCallback since |
| // in case of --nokeep_going & analysis error, the analysis phase is never finished. |
| skyframeExecutor.resetIncrementalArtifactConflictFindingStates(); |
| skyframeExecutor.resetBuildDriverFunction(); |
| |
| Set<Artifact> additionalArtifacts = new HashSet<>(); |
| |
| // Unconditionally create build-info.txt and build-changelist.txt. |
| // No action conflict expected here. |
| additionalArtifacts.addAll(workspaceStatusArtifacts); |
| // Coverage. |
| additionalArtifacts.addAll( |
| coverageReportActionsWrapperSupplier.getCoverageArtifacts( |
| buildResultListener.getAnalyzedTargets(), |
| buildResultListener.getAnalyzedTests())); |
| // This evaluation involves action executions, and hence has to be done after the first |
| // SomeExecutionStartedEvent (which is posted from BuildDriverFunction). The most |
| // straightforward solution is to perform this here, after |
| // SkyframeExecutor#evaluateBuildDriverKeys. |
| additionalArtifactsResult = |
| skyframeExecutor.evaluateSkyKeys( |
| eventHandler, Artifact.keys(additionalArtifacts), keepGoing); |
| if (additionalArtifactsResult.hasError()) { |
| detailedExitCodes.add( |
| SkyframeErrorProcessor.processErrors( |
| additionalArtifactsResult, |
| configurationLookupSupplier, |
| skyframeExecutor.getCyclesReporter(), |
| eventHandler, |
| keepGoing, |
| eventBus, |
| bugReporter, |
| /* includeExecutionPhase= */ true) |
| .executionDetailedExitCode()); |
| } |
| // These attributes affect whether conflict checking will be done during the next build. |
| if (shouldCheckForConflicts(checkForActionConflicts, newKeys)) { |
| largestTopLevelKeySetCheckedForConflicts = newKeys; |
| } |
| someActionLookupValueEvaluated = false; |
| } |
| |
| // The exclusive tests whose analysis succeeded i.e. those that can be run. |
| ImmutableSet<ConfiguredTarget> exclusiveTestsToRun = getExclusiveTests(evaluationResult); |
| boolean continueWithExclusiveTests = |
| (!evaluationResult.hasError() && !additionalArtifactsResult.hasError()) || keepGoing; |
| |
| if (continueWithExclusiveTests && !exclusiveTestsToRun.isEmpty()) { |
| // Run exclusive tests sequentially. |
| Iterable<SkyKey> testCompletionKeys = |
| TestCompletionValue.keys( |
| exclusiveTestsToRun, topLevelArtifactContext, /*exclusiveTesting=*/ true); |
| for (SkyKey testCompletionKey : testCompletionKeys) { |
| EvaluationResult<SkyValue> testRunResult = |
| skyframeExecutor.evaluateSkyKeys( |
| eventHandler, ImmutableSet.of(testCompletionKey), keepGoing); |
| if (testRunResult.hasError()) { |
| detailedExitCodes.add( |
| SkyframeErrorProcessor.processErrors( |
| testRunResult, |
| configurationLookupSupplier, |
| skyframeExecutor.getCyclesReporter(), |
| eventHandler, |
| keepGoing, |
| eventBus, |
| bugReporter, |
| /*includeExecutionPhase=*/ true) |
| .executionDetailedExitCode()); |
| } |
| } |
| } |
| } finally { |
| // No more action execution beyond this point. |
| skyframeExecutor.clearExecutionStates(eventHandler); |
| // Also releases thread locks. |
| resourceManager.resetResourceUsage(); |
| } |
| |
| if (!evaluationResult.hasError() && detailedExitCodes.isEmpty()) { |
| ImmutableMap<AspectKey, ConfiguredAspect> successfulAspects = |
| getSuccessfulAspectMap( |
| topLevelAspectsKeys.size(), |
| evaluationResult, |
| buildDriverAspectKeys, |
| /*topLevelActionConflictReport=*/ null); |
| ImmutableSet<ConfiguredTarget> successfulConfiguredTargets = |
| getSuccessfulConfiguredTargets( |
| ctKeys.size(), |
| evaluationResult, |
| buildDriverCTKeys, |
| /*topLevelActionConflictReport=*/ null); |
| |
| return SkyframeAnalysisAndExecutionResult.success( |
| successfulConfiguredTargets, |
| evaluationResult.getWalkableGraph(), |
| successfulAspects, |
| /*packageRoots=*/ null); |
| } |
| |
| ErrorProcessingResult errorProcessingResult = |
| SkyframeErrorProcessor.processErrors( |
| evaluationResult, |
| configurationLookupSupplier, |
| skyframeExecutor.getCyclesReporter(), |
| eventHandler, |
| keepGoing, |
| eventBus, |
| bugReporter, |
| /*includeExecutionPhase=*/ true); |
| detailedExitCodes.add(errorProcessingResult.executionDetailedExitCode()); |
| |
| foundActionConflictInLatestCheck = !errorProcessingResult.actionConflicts().isEmpty(); |
| TopLevelActionConflictReport topLevelActionConflictReport = |
| foundActionConflictInLatestCheck |
| ? handleActionConflicts( |
| eventHandler, |
| ctKeys, |
| topLevelAspectsKeys, |
| configurationLookupSupplier, |
| topLevelArtifactContext, |
| eventBus, |
| keepGoing, |
| errorProcessingResult) |
| : null; |
| |
| ImmutableMap<AspectKey, ConfiguredAspect> successfulAspects = |
| getSuccessfulAspectMap( |
| topLevelAspectsKeys.size(), |
| evaluationResult, |
| buildDriverAspectKeys, |
| topLevelActionConflictReport); |
| ImmutableSet<ConfiguredTarget> successfulConfiguredTargets = |
| getSuccessfulConfiguredTargets( |
| ctKeys.size(), evaluationResult, buildDriverCTKeys, topLevelActionConflictReport); |
| |
| return SkyframeAnalysisAndExecutionResult.withErrors( |
| /*hasLoadingError=*/ errorProcessingResult.hasLoadingError(), |
| /*hasAnalysisError=*/ errorProcessingResult.hasAnalysisError(), |
| /*hasActionConflicts=*/ foundActionConflictInLatestCheck, |
| successfulConfiguredTargets, |
| evaluationResult.getWalkableGraph(), |
| successfulAspects, |
| /*packageRoots=*/ null, |
| Collections.max(detailedExitCodes, DetailedExitCodeComparator.INSTANCE)); |
| } |
| } |
| |
| /** Handles the required steps after all analysis work in this build is done. */ |
| private void analysisFinishedCallback( |
| EventBus eventBus, |
| BuildResultListener buildResultListener, |
| SkyframeExecutor skyframeExecutor, |
| List<ConfiguredTargetKey> configuredTargetKeys, |
| boolean shouldDiscardAnalysisCache, |
| long measuredAnalysisTime, |
| Supplier<Boolean> shouldPublishBuildGraphMetrics) |
| throws InterruptedException { |
| |
| if (shouldPublishBuildGraphMetrics.get()) { |
| // Now that we have the full picture, it's time to collect the metrics of the whole graph. |
| BuildGraphMetrics buildGraphMetrics = |
| skyframeExecutor |
| .collectActionLookupValuesInBuild( |
| configuredTargetKeys, buildResultListener.getAnalyzedAspects().keySet()) |
| .getMetrics() |
| .setOutputArtifactCount(skyframeExecutor.getOutputArtifactCount()) |
| .build(); |
| eventBus.post(new AnalysisGraphStatsEvent(buildGraphMetrics)); |
| } |
| |
| if (shouldDiscardAnalysisCache) { |
| clearAnalysisCache( |
| buildResultListener.getAnalyzedTargets(), |
| buildResultListener.getAnalyzedAspects().keySet()); |
| } |
| |
| // At this point, it's safe to clear objects related to action conflict checking. |
| // Clearing the states here is a performance optimization (reduce peak heap size) and isn't |
| // required for correctness. |
| skyframeExecutor.resetIncrementalArtifactConflictFindingStates(); |
| |
| // Clearing the syscall cache here to free up some heap space. |
| // TODO(b/273225564) Would this incur more CPU cost for the execution phase cache misses? |
| skyframeExecutor.clearSyscallCache(); |
| |
| enableAnalysis(false); |
| |
| eventBus.post( |
| AnalysisPhaseCompleteEvent.fromSkymeld( |
| buildResultListener.getAnalyzedTargets(), |
| getEvaluatedCounts(), |
| getEvaluatedActionCounts(), |
| measuredAnalysisTime, |
| skyframeExecutor.getPackageManager().getAndClearStatistics(), |
| skyframeExecutor.wasAnalysisCacheInvalidatedAndResetBit())); |
| } |
| |
| /** |
| * Report the appropriate conflicts and return a TopLevelActionConflictReport. |
| * |
| * <p>The TopLevelActionConflictReport is used to determine the set of top level targets that |
| * depend on conflicted actions. |
| */ |
| private TopLevelActionConflictReport handleActionConflicts( |
| ExtendedEventHandler eventHandler, |
| List<ConfiguredTargetKey> ctKeys, |
| ImmutableList<TopLevelAspectsKey> topLevelAspectsKeys, |
| Supplier<Map<BuildConfigurationKey, BuildConfigurationValue>> configurationLookupSupplier, |
| TopLevelArtifactContext topLevelArtifactContextForConflictPruning, |
| EventBus eventBus, |
| boolean keepGoing, |
| ErrorProcessingResult errorProcessingResult) |
| throws InterruptedException, ViewCreationFailedException { |
| |
| try { |
| // Here we already have the <TopLevelAspectKey, error> mapping, but what we need to fit into |
| // the existing AnalysisFailureEvent is <AspectKey, error>. An extra Skyframe evaluation is |
| // required. |
| Iterable<ActionLookupKey> effectiveTopLevelKeysForConflictReporting = |
| Iterables.concat(ctKeys, getDerivedAspectKeysForConflictReporting(topLevelAspectsKeys)); |
| TopLevelActionConflictReport topLevelActionConflictReport; |
| enableAnalysis(true); |
| // In order to determine the set of configured targets transitively error free from action |
| // conflict issues, we run a post-processing update() that uses the bad action map. |
| try { |
| topLevelActionConflictReport = |
| skyframeExecutor.filterActionConflictsForConfiguredTargetsAndAspects( |
| eventHandler, |
| effectiveTopLevelKeysForConflictReporting, |
| errorProcessingResult.actionConflicts(), |
| topLevelArtifactContextForConflictPruning); |
| } finally { |
| enableAnalysis(false); |
| } |
| reportActionConflictErrors( |
| topLevelActionConflictReport, |
| effectiveTopLevelKeysForConflictReporting, |
| eventHandler, |
| eventBus, |
| configurationLookupSupplier, |
| keepGoing); |
| return topLevelActionConflictReport; |
| } finally { |
| skyframeExecutor.resetActionConflictsStoredInSkyframe(); |
| } |
| } |
| |
| /** |
| * From the {@code topLevelActionConflictReport}, report the action conflict errors. |
| * |
| * <p>Throw a ViewCreationFailedException in case of --nokeep_going. |
| */ |
| private static void reportActionConflictErrors( |
| TopLevelActionConflictReport topLevelActionConflictReport, |
| Iterable<ActionLookupKey> effectiveTopLevelKeysForConflictReporting, |
| ExtendedEventHandler eventHandler, |
| EventBus eventBus, |
| Supplier<Map<BuildConfigurationKey, BuildConfigurationValue>> configurationLookupSupplier, |
| boolean keepGoing) |
| throws ViewCreationFailedException { |
| |
| // ArtifactPrefixConflictExceptions come in pairs, and only one should be reported. |
| Set<ArtifactPrefixConflictException> reportedExceptions = Sets.newHashSet(); |
| |
| // Report an AnalysisFailureEvent to BEP for the top-level targets with discoverable action |
| // conflicts, then finally throw. |
| for (ActionLookupKey actionLookupKey : effectiveTopLevelKeysForConflictReporting) { |
| if (topLevelActionConflictReport.isErrorFree(actionLookupKey)) { |
| continue; |
| } |
| Optional<ConflictException> e = |
| topLevelActionConflictReport.getConflictException(actionLookupKey); |
| if (e.isEmpty()) { |
| continue; |
| } |
| |
| ConflictException conflictException = e.get(); |
| try { |
| conflictException.rethrowTyped(); |
| } catch (ActionConflictException ace) { |
| ace.reportTo(eventHandler); |
| } catch (ArtifactPrefixConflictException apce) { |
| if (reportedExceptions.add(apce)) { |
| eventHandler.handle(Event.error(apce.getMessage())); |
| } |
| } |
| |
| AnalysisFailedCause failedCause = |
| makeArtifactConflictAnalysisFailedCause(configurationLookupSupplier, conflictException); |
| eventHandler.handle( |
| Event.warn( |
| String.format( |
| "errors encountered while building target '%s'", actionLookupKey.getLabel()))); |
| BuildConfigurationKey configKey = actionLookupKey.getConfigurationKey(); |
| // TODO(b/210710338) Replace with a more appropriate event. |
| eventBus.post( |
| new AnalysisFailureEvent( |
| actionLookupKey, |
| configurationLookupSupplier.get().get(configKey).toBuildEvent().getEventId(), |
| NestedSetBuilder.create(Order.STABLE_ORDER, failedCause))); |
| if (!keepGoing) { |
| throw new ViewCreationFailedException( |
| failedCause.getDetailedExitCode().getFailureDetail(), conflictException); |
| } |
| } |
| } |
| |
| private static ImmutableSet<ConfiguredTarget> getExclusiveTests( |
| EvaluationResult<BuildDriverValue> evaluationResult) { |
| ImmutableSet.Builder<ConfiguredTarget> exclusiveTests = ImmutableSet.builder(); |
| for (BuildDriverValue value : evaluationResult.values()) { |
| if (value instanceof ExclusiveTestBuildDriverValue) { |
| exclusiveTests.add( |
| ((ExclusiveTestBuildDriverValue) value).getExclusiveTestConfiguredTarget()); |
| } |
| } |
| return exclusiveTests.build(); |
| } |
| |
| private static TestType determineTestType( |
| ImmutableSet<Label> testsToRun, |
| ImmutableMap<Label, Target> labelTargetMap, |
| Label label, |
| BuildDriverKeyTestContext buildDriverKeyTestContext, |
| ExtendedEventHandler eventHandler) { |
| if (testsToRun == null || !testsToRun.contains(label)) { |
| return TestType.NOT_TEST; |
| } |
| Target target = labelTargetMap.get(label); |
| |
| if (!(target instanceof Rule)) { |
| return TestType.NOT_TEST; |
| } |
| |
| TestType fromExplicitFlagOrTag; |
| if (buildDriverKeyTestContext.getTestStrategy().equals("exclusive") |
| || TargetUtils.isExclusiveTestRule((Rule) target)) { |
| fromExplicitFlagOrTag = TestType.EXCLUSIVE; |
| } else if (TargetUtils.isExclusiveIfLocalTestRule((Rule) target)) { |
| fromExplicitFlagOrTag = TestType.EXCLUSIVE_IF_LOCAL; |
| } else { |
| fromExplicitFlagOrTag = TestType.PARALLEL; |
| } |
| |
| if ((fromExplicitFlagOrTag == TestType.EXCLUSIVE |
| && buildDriverKeyTestContext.forceExclusiveTestsInParallel()) |
| || (fromExplicitFlagOrTag == TestType.EXCLUSIVE_IF_LOCAL |
| && buildDriverKeyTestContext.forceExclusiveIfLocalTestsInParallel())) { |
| eventHandler.handle( |
| Event.warn( |
| label |
| + " is tagged " |
| + fromExplicitFlagOrTag.getMsg() |
| + ", but --test_strategy=" |
| + buildDriverKeyTestContext.getTestStrategy() |
| + " forces parallel test execution.")); |
| return TestType.PARALLEL; |
| } |
| return fromExplicitFlagOrTag; |
| } |
| |
| // When we check for action conflicts that occur with a TopLevelAspectKey, a reference to the |
| // lower-level AspectKeys is required: it could happen that only some AspectKeys, but not |
| // all, that derived from a TopLevelAspectKey has a conflicting action. |
| private ImmutableSet<AspectKey> getDerivedAspectKeysForConflictReporting( |
| ImmutableList<TopLevelAspectsKey> topLevelAspectsKeys) { |
| ImmutableSet.Builder<AspectKey> aspectKeysBuilder = ImmutableSet.builder(); |
| for (TopLevelAspectsKey topLevelAspectsKey : topLevelAspectsKeys) { |
| try { |
| TopLevelAspectsValue topLevelAspectsValue = |
| (TopLevelAspectsValue) |
| skyframeExecutor.getDoneSkyValueForIntrospection(topLevelAspectsKey); |
| topLevelAspectsValue |
| .getTopLevelAspectsValues() |
| .forEach(aspectValue -> aspectKeysBuilder.add(aspectValue.getKey())); |
| } catch (FailureToRetrieveIntrospectedValueException e) { |
| // It could happen that the analysis of TopLevelAspectKey wasn't complete: either its own |
| // analysis failed, or another error was raise in --nokeep_going mode. In that case, it |
| // couldn't be involved in the conflict exception anyway, and we just move on. |
| // Unless it's an unexpected interrupt that caused the exception. |
| if (e.getCause() instanceof InterruptedException) { |
| BugReport.sendBugReport(e); |
| } |
| } |
| } |
| return aspectKeysBuilder.build(); |
| } |
| |
| private static ImmutableSet<ConfiguredTarget> getSuccessfulConfiguredTargets( |
| int expectedSize, |
| EvaluationResult<BuildDriverValue> evaluationResult, |
| Set<BuildDriverKey> buildDriverCTKeys, |
| @Nullable TopLevelActionConflictReport topLevelActionConflictReport) { |
| ImmutableSet.Builder<ConfiguredTarget> cts = ImmutableSet.builderWithExpectedSize(expectedSize); |
| for (BuildDriverKey bdCTKey : buildDriverCTKeys) { |
| if (topLevelActionConflictReport != null |
| && !topLevelActionConflictReport.isErrorFree(bdCTKey.getActionLookupKey())) { |
| continue; |
| } |
| BuildDriverValue value = evaluationResult.get(bdCTKey); |
| if (value == null) { |
| continue; |
| } |
| ConfiguredTargetValue ctValue = (ConfiguredTargetValue) value.getWrappedSkyValue(); |
| |
| cts.add(ctValue.getConfiguredTarget()); |
| } |
| return cts.build(); |
| } |
| |
| private static ImmutableMap<AspectKey, ConfiguredAspect> getSuccessfulAspectMap( |
| int expectedSize, |
| EvaluationResult<BuildDriverValue> evaluationResult, |
| Set<BuildDriverKey> buildDriverAspectKeys, |
| @Nullable TopLevelActionConflictReport topLevelActionConflictReport) { |
| // There can't be duplicate Aspects after resolving --aspects, so this is safe. |
| ImmutableMap.Builder<AspectKey, ConfiguredAspect> aspects = |
| ImmutableMap.builderWithExpectedSize(expectedSize); |
| for (BuildDriverKey bdAspectKey : buildDriverAspectKeys) { |
| if (topLevelActionConflictReport != null |
| && !topLevelActionConflictReport.isErrorFree(bdAspectKey.getActionLookupKey())) { |
| continue; |
| } |
| BuildDriverValue value = evaluationResult.get(bdAspectKey); |
| if (value == null) { |
| // Skip aspects that couldn't be applied to targets. |
| continue; |
| } |
| TopLevelAspectsValue topLevelAspectsValue = (TopLevelAspectsValue) value.getWrappedSkyValue(); |
| for (AspectValue aspectValue : topLevelAspectsValue.getTopLevelAspectsValues()) { |
| aspects.put(aspectValue.getKey(), aspectValue.getConfiguredAspect()); |
| } |
| } |
| return aspects.buildOrThrow(); |
| } |
| |
| private static AnalysisFailedCause makeArtifactConflictAnalysisFailedCause( |
| Supplier<Map<BuildConfigurationKey, BuildConfigurationValue>> configurationLookupSupplier, |
| ConflictException e) { |
| try { |
| throw e.rethrowTyped(); |
| } catch (ActionConflictException ace) { |
| return makeArtifactConflictAnalysisFailedCause(configurationLookupSupplier, ace); |
| } catch (ArtifactPrefixConflictException apce) { |
| return new AnalysisFailedCause(apce.getFirstOwner(), null, apce.getDetailedExitCode()); |
| } |
| } |
| |
| private static AnalysisFailedCause makeArtifactConflictAnalysisFailedCause( |
| Supplier<Map<BuildConfigurationKey, BuildConfigurationValue>> configurationLookupSupplier, |
| ActionConflictException ace) { |
| DetailedExitCode detailedExitCode = ace.getDetailedExitCode(); |
| Label causeLabel = ace.getArtifact().getArtifactOwner().getLabel(); |
| BuildConfigurationKey causeConfigKey = null; |
| if (ace.getArtifact().getArtifactOwner() instanceof ConfiguredTargetKey) { |
| causeConfigKey = |
| ((ConfiguredTargetKey) ace.getArtifact().getArtifactOwner()).getConfigurationKey(); |
| } |
| BuildConfigurationValue causeConfig = |
| causeConfigKey == null ? null : configurationLookupSupplier.get().get(causeConfigKey); |
| return new AnalysisFailedCause( |
| causeLabel, |
| causeConfig == null ? null : causeConfig.toBuildEvent().getEventId().getConfiguration(), |
| detailedExitCode); |
| } |
| |
| private boolean shouldCheckForConflicts( |
| boolean specifiedValueInRequest, ImmutableSet<SkyKey> newKeys) { |
| if (!specifiedValueInRequest) { |
| // A build request by default enables action conflict checking, except for some cases e.g. |
| // cquery. |
| return false; |
| } |
| |
| if (someActionLookupValueEvaluated) { |
| // A top-level target was added and may introduce a conflict, or a top-level target was |
| // recomputed and may introduce or resolve a conflict. |
| return true; |
| } |
| |
| if (!dirtiedActionLookupKeys.isEmpty()) { |
| // No target was (re)computed but at least one was dirtied. |
| // Example: (//:x //foo:y) are built, and in conflict (//:x creates foo/C and //foo:y |
| // creates C). Then y is removed from foo/BUILD and only //:x is built, so //foo:y is |
| // dirtied but not recomputed, and no other nodes are recomputed (and none are deleted). |
| // Still we must do the conflict checking because previously there was a conflict but now |
| // there isn't. |
| return true; |
| } |
| |
| if (foundActionConflictInLatestCheck) { |
| // Example sequence: |
| // 1. Build (x y z), and there is a conflict. We store (x y z) as the largest checked key |
| // set, and record the fact that there were bad actions. |
| // 2. Null-build (x z), so we don't evaluate or dirty anything, but because we know there was |
| // some conflict last time but don't know exactly which targets conflicted, it could have |
| // been (x z), so we now check again. The value of foundActionConflictInLatestCheck would |
| // then be updated for the next build, based on the result of this check. |
| return true; |
| } |
| |
| if (!largestTopLevelKeySetCheckedForConflicts.containsAll(newKeys)) { |
| // Example sequence: |
| // 1. Build (x y z), and there is a conflict. We store (x y z) as the largest checked key |
| // set, and record the fact that there were bad actions. |
| // 2. Null-build (x z), so we don't evaluate or dirty anything, but we check again for |
| // conflict because foundActionConflictInLatestCheck is true, and store (x z) as the |
| // largest checked key set. |
| // 3. Null-build (y z), so again we don't evaluate or dirty anything, and the previous build |
| // had no conflicts, so no other condition is true. But because (y z) is not a subset of |
| // (x z) and we only keep the most recent largest checked key set, we don't know if (y z) |
| // are conflict free, so we check. |
| return true; |
| } |
| |
| // We believe the conditions above are correct in the sense that we always check for conflicts |
| // when we have to. But they are incomplete, so we sometimes check for conflicts even if we |
| // wouldn't have to. For example: |
| // - if no target was evaluated nor dirtied and build sequence is (x y) [no conflict], (z), |
| // where z is in the transitive closure of (x y), then we shouldn't check. |
| // - if no target was evaluated nor dirtied and build sequence is (x y) [no conflict], (w), (x), |
| // then the last build shouldn't conflict-check because (x y) was checked earlier. But it |
| // does, because after the second build we store (w) as the largest checked set, and (x) is |
| // not a subset of that. |
| |
| // Case when we DON'T need to re-check: |
| // - a configured target is deleted. Deletion can only resolve conflicts, not introduce any, and |
| // if the previous build had a conflict then foundActionConflictInLatestCheck would be true, |
| // and if the previous build had no conflict then deleting a CT won't change that. |
| // Example that triggers this scenario: |
| // 1. genrule(name='x', srcs=['A'], ...) |
| // genrule(name='y', outs=['A'], ...) |
| // 2. Build (x y) |
| // 3. Rename 'x' to 'y', and 'y' to 'z' |
| // 4. Build (y z) |
| // 5. Null-build (y z) again |
| // We only delete the old 'x' value in (5), and we don't evaluate nor dirty anything, nor was |
| // (4) bad. So there's no reason to re-check just because we deleted something. |
| return false; |
| } |
| |
| public ArtifactFactory getArtifactFactory() { |
| return artifactFactory; |
| } |
| |
| CachingAnalysisEnvironment createAnalysisEnvironment( |
| ActionLookupKey owner, |
| ExtendedEventHandler eventHandler, |
| Environment env, |
| BuildConfigurationValue config, |
| StarlarkBuiltinsValue starlarkBuiltinsValue) { |
| boolean extendedSanityChecks = config != null && config.extendedSanityChecks(); |
| boolean allowAnalysisFailures = config != null && config.allowAnalysisFailures(); |
| return new CachingAnalysisEnvironment( |
| artifactFactory, |
| skyframeExecutor.getActionKeyContext(), |
| owner, |
| extendedSanityChecks, |
| allowAnalysisFailures, |
| eventHandler, |
| env, |
| starlarkBuiltinsValue); |
| } |
| |
| /** |
| * Invokes the appropriate constructor to create a {@link ConfiguredTarget} instance. |
| * |
| * <p>For use in {@code ConfiguredTargetFunction}. |
| * |
| * <p>Returns null if Skyframe deps are missing or upon certain errors. |
| */ |
| @Nullable |
| ConfiguredTarget createConfiguredTarget( |
| Target target, |
| BuildConfigurationValue configuration, |
| CachingAnalysisEnvironment analysisEnvironment, |
| ConfiguredTargetKey configuredTargetKey, |
| OrderedSetMultimap<DependencyKind, ConfiguredTargetAndData> prerequisiteMap, |
| ConfigConditions configConditions, |
| @Nullable ToolchainCollection<ResolvedToolchainContext> toolchainContexts, |
| @Nullable NestedSet<Package> transitivePackages, |
| ExecGroupCollection.Builder execGroupCollectionBuilder) |
| throws InterruptedException, ActionConflictException, InvalidExecGroupException, |
| AnalysisFailurePropagationException { |
| Preconditions.checkState( |
| enableAnalysis, "Already in execution phase %s %s", target, configuration); |
| Preconditions.checkNotNull(analysisEnvironment); |
| Preconditions.checkNotNull(target); |
| Preconditions.checkNotNull(prerequisiteMap); |
| return factory.createConfiguredTarget( |
| analysisEnvironment, |
| artifactFactory, |
| target, |
| configuration, |
| configuredTargetKey, |
| prerequisiteMap, |
| configConditions, |
| toolchainContexts, |
| transitivePackages, |
| execGroupCollectionBuilder); |
| } |
| |
| /** |
| * Workaround to clear all legacy data, like the artifact factory. We need to clear them to avoid |
| * conflicts. TODO(bazel-team): Remove this workaround. [skyframe-execution] |
| */ |
| void clearLegacyData() { |
| artifactFactory.clear(); |
| starlarkTransitionCache.clear(); |
| } |
| |
| /** |
| * Clears any data cached in this BuildView. To be called when the attached SkyframeExecutor is |
| * reset. |
| */ |
| void reset() { |
| configuration = null; |
| skyframeAnalysisWasDiscarded = false; |
| clearLegacyData(); |
| } |
| |
| /** |
| * Hack to invalidate actions in legacy action graph when their values are invalidated in |
| * skyframe. |
| */ |
| EvaluationProgressReceiver getProgressReceiver() { |
| return progressReceiver; |
| } |
| |
| /** Clear the invalidated action lookup nodes detected during loading and analysis phases. */ |
| public void clearInvalidatedActionLookupKeys() { |
| dirtiedActionLookupKeys = Sets.newConcurrentHashSet(); |
| } |
| |
| /** |
| * {@link #createConfiguredTarget} will only create configured targets if this is set to true. It |
| * should be set to true before any Skyframe update call that might call into {@link |
| * #createConfiguredTarget}, and false immediately after the call. Use it to fail-fast in the case |
| * that a target is requested for analysis not during the analysis phase. |
| */ |
| public void enableAnalysis(boolean enable) { |
| this.enableAnalysis = enable; |
| } |
| |
| public ActionKeyContext getActionKeyContext() { |
| return skyframeExecutor.getActionKeyContext(); |
| } |
| |
| public StarlarkTransitionCache getStarlarkTransitionCache() { |
| return starlarkTransitionCache; |
| } |
| |
| private final class ActionLookupValueProgressReceiver implements EvaluationProgressReceiver { |
| private final AtomicInteger configuredObjectCount = new AtomicInteger(); |
| private final AtomicInteger actionCount = new AtomicInteger(); |
| private final AtomicInteger configuredTargetCount = new AtomicInteger(); |
| private final AtomicInteger configuredTargetActionCount = new AtomicInteger(); |
| |
| @Override |
| public void invalidated(SkyKey skyKey, InvalidationState state) { |
| if (skyKey instanceof ActionLookupKey && state != InvalidationState.DELETED) { |
| // If the value was just dirtied and not deleted, then it may not be truly invalid, since |
| // it may later get re-validated. Therefore adding the key to dirtiedConfiguredTargetKeys |
| // is provisional--if the key is later evaluated and the value found to be clean, then we |
| // remove it from the set. |
| dirtiedActionLookupKeys.add((ActionLookupKey) skyKey); |
| } |
| } |
| |
| @Override |
| public void evaluated( |
| SkyKey skyKey, |
| @Nullable SkyValue newValue, |
| @Nullable ErrorInfo newError, |
| Supplier<EvaluationSuccessState> evaluationSuccessState, |
| EvaluationState state, |
| @Nullable GroupedDeps directDeps) { |
| // We tolerate any action lookup keys here, although we only expect configured targets, |
| // aspects, and the workspace status value. |
| if (!(skyKey instanceof ActionLookupKey)) { |
| return; |
| } |
| switch (state) { |
| case BUILT: |
| if (!evaluationSuccessState.get().succeeded()) { |
| return; |
| } |
| configuredObjectCount.incrementAndGet(); |
| boolean isConfiguredTarget = skyKey.functionName().equals(SkyFunctions.CONFIGURED_TARGET); |
| if (isConfiguredTarget) { |
| configuredTargetCount.incrementAndGet(); |
| } |
| if (newValue instanceof ActionLookupValue) { |
| // During multithreaded operation, this is only set to true, so no concurrency issues. |
| someActionLookupValueEvaluated = true; |
| int numActions = ((ActionLookupValue) newValue).getNumActions(); |
| actionCount.addAndGet(numActions); |
| if (isConfiguredTarget) { |
| configuredTargetActionCount.addAndGet(numActions); |
| } |
| } |
| break; |
| case CLEAN: |
| // If the action lookup value did not need to be rebuilt, then it wasn't truly invalid. |
| dirtiedActionLookupKeys.remove(skyKey); |
| break; |
| } |
| } |
| |
| public void reset() { |
| configuredObjectCount.set(0); |
| actionCount.set(0); |
| configuredTargetCount.set(0); |
| configuredTargetActionCount.set(0); |
| } |
| } |
| |
| /** Provides the list of coverage artifacts to be built. */ |
| @FunctionalInterface |
| public interface CoverageReportActionsWrapperSupplier { |
| ImmutableSet<Artifact> getCoverageArtifacts( |
| Set<ConfiguredTarget> configuredTargets, Set<ConfiguredTarget> allTargetsToTest) |
| throws InterruptedException; |
| } |
| |
| /** Encapsulates the context required to construct a test BuildDriverKey. */ |
| public interface BuildDriverKeyTestContext { |
| String getTestStrategy(); |
| |
| boolean forceExclusiveTestsInParallel(); |
| |
| boolean forceExclusiveIfLocalTestsInParallel(); |
| } |
| } |
