// Copyright 2015 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 com.google.common.base.Preconditions; import com.google.common.collect.ImmutableSortedSet; import com.google.common.collect.Interner; import com.google.devtools.build.lib.analysis.config.BuildConfiguration; import com.google.devtools.build.lib.analysis.config.BuildConfiguration.Fragment; import com.google.devtools.build.lib.analysis.config.BuildOptions; import com.google.devtools.build.lib.concurrent.BlazeInterners; import com.google.devtools.build.lib.concurrent.ThreadSafety.ThreadSafe; import com.google.devtools.build.lib.skyframe.serialization.InjectingObjectCodec; import com.google.devtools.build.lib.skyframe.serialization.ObjectCodec; import com.google.devtools.build.lib.skyframe.serialization.SerializationException; import com.google.devtools.build.lib.skyframe.serialization.autocodec.AutoCodec; import com.google.devtools.build.lib.skyframe.serialization.strings.StringCodecs; import com.google.devtools.build.lib.vfs.FileSystemProvider; import com.google.devtools.build.skyframe.SkyFunctionName; import com.google.devtools.build.skyframe.SkyKey; import com.google.devtools.build.skyframe.SkyValue; import com.google.protobuf.CodedInputStream; import com.google.protobuf.CodedOutputStream; import java.io.IOException; import java.io.Serializable; import java.util.Objects; import java.util.Set; /** A Skyframe value representing a {@link BuildConfiguration}. */ // TODO(bazel-team): mark this immutable when BuildConfiguration is immutable. // @Immutable @AutoCodec(dependency = FileSystemProvider.class) @ThreadSafe public class BuildConfigurationValue implements SkyValue { public static final InjectingObjectCodec CODEC = new BuildConfigurationValue_AutoCodec(); private static final Interner keyInterner = BlazeInterners.newWeakInterner(); private final BuildConfiguration configuration; BuildConfigurationValue(BuildConfiguration configuration) { this.configuration = configuration; } public BuildConfiguration getConfiguration() { return configuration; } /** * Returns the key for a requested configuration. * * @param fragments the fragments the configuration should contain * @param buildOptions the build options the fragments should be built from */ @ThreadSafe public static Key key( Set> fragments, BuildOptions buildOptions) { return keyInterner.intern( new Key( ImmutableSortedSet.copyOf(BuildConfiguration.lexicalFragmentSorter, fragments), buildOptions)); } static final class Key implements SkyKey, Serializable { static final ObjectCodec CODEC = new Codec(); private final ImmutableSortedSet> fragments; private final BuildOptions buildOptions; // If hashCode really is -1, we'll recompute it from scratch each time. Oh well. private volatile int hashCode = -1; private Key( ImmutableSortedSet> fragments, BuildOptions buildOptions) { this.fragments = fragments; this.buildOptions = Preconditions.checkNotNull(buildOptions); } ImmutableSortedSet> getFragments() { return fragments; } BuildOptions getBuildOptions() { return buildOptions; } @Override public SkyFunctionName functionName() { return SkyFunctions.BUILD_CONFIGURATION; } @Override public boolean equals(Object o) { if (this == o) { return true; } if (!(o instanceof Key)) { return false; } Key otherConfig = (Key) o; return buildOptions.equals(otherConfig.buildOptions) && Objects.equals(fragments, otherConfig.fragments); } @Override public int hashCode() { if (hashCode == -1) { hashCode = Objects.hash(fragments, buildOptions); } return hashCode; } private static class Codec implements ObjectCodec { @Override public Class getEncodedClass() { return Key.class; } @Override public void serialize(Key obj, CodedOutputStream codedOut) throws SerializationException, IOException { BuildOptions.CODEC.serialize(obj.buildOptions, codedOut); codedOut.writeInt32NoTag(obj.fragments.size()); for (Class fragment : obj.fragments) { StringCodecs.asciiOptimized().serialize(fragment.getName(), codedOut); } } @Override @SuppressWarnings("unchecked") // Class cast public Key deserialize(CodedInputStream codedIn) throws SerializationException, IOException { BuildOptions buildOptions = BuildOptions.CODEC.deserialize(codedIn); int fragmentsSize = codedIn.readInt32(); ImmutableSortedSet.Builder> fragmentsBuilder = ImmutableSortedSet.orderedBy(BuildConfiguration.lexicalFragmentSorter); for (int i = 0; i < fragmentsSize; i++) { try { fragmentsBuilder.add( (Class) Class.forName(StringCodecs.asciiOptimized().deserialize(codedIn))); } catch (ClassNotFoundException e) { throw new SerializationException( "Couldn't deserialize BuildConfigurationValue$Key fragment class", e); } } return key(fragmentsBuilder.build(), buildOptions); } } } }