// Copyright 2018 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.actions; import com.google.common.base.Preconditions; import java.util.Arrays; import javax.annotation.Nullable; /** * Helper for {@link MetadataProvider} implementations. * *
Allows {@link FileArtifactValue} lookups by exec path or {@link ActionInput}. Also * allows {@link ActionInput} to be looked up by exec path. * *
This class is thread-compatible. */ public final class ActionInputMap implements MetadataProvider { /** * {@link ActionInput} keys stored in even indices * *
{@link FileArtifactValue} values stored in odd indices */ private Object[] data; /** Number of contained elements. */ private int size; /** Length of data = 2^(numBits+1) */ private int numBits; /** Mask to use to perform the modulo operation since the table size is a power of 2. */ private int mask; public ActionInputMap(int sizeHint) { this.numBits = 1; while ((1 << numBits) <= sizeHint) { ++numBits; } this.mask = (1 << numBits) - 1; this.data = new Object[1 << (numBits + 1)]; this.size = 0; } @Nullable @Override public FileArtifactValue getMetadata(ActionInput input) { return getMetadata(input.getExecPathString()); } @Nullable public FileArtifactValue getMetadata(String execPathString) { int hashCode = execPathString.hashCode(); int probe = getProbe(hashCode); ActionInput nextKey; while ((nextKey = (ActionInput) data[probe]) != null) { if (hashCode == nextKey.getExecPathString().hashCode() && nextKey.getExecPathString().equals(execPathString)) { return (FileArtifactValue) data[probe + 1]; } probe = incProbe(probe); } return null; } @Nullable @Override public ActionInput getInput(String execPathString) { int hashCode = execPathString.hashCode(); int probe = getProbe(hashCode); ActionInput nextKey; while ((nextKey = (ActionInput) data[probe]) != null) { if (hashCode == nextKey.getExecPathString().hashCode() && nextKey.getExecPathString().equals(execPathString)) { return nextKey; } probe = incProbe(probe); } return null; } /** Count of contained entries. */ public int size() { return size; } /** @return true if an entry was added, false if the map already contains {@code input} */ public boolean put(ActionInput input, FileArtifactValue metadata) { Preconditions.checkNotNull(input); if (size * 4 >= data.length) { resize(); } return putImpl(input, metadata); } public void clear() { Arrays.fill(data, null); size = 0; } private void resize() { Object[] oldData = data; int oldSize = size; data = new Object[data.length * 2]; size = 0; ++numBits; mask = (1 << numBits) - 1; for (int i = 0; i < oldData.length; i += 2) { ActionInput key = (ActionInput) oldData[i]; if (key != null) { FileArtifactValue value = (FileArtifactValue) oldData[i + 1]; putImpl(key, value); } } Preconditions.checkState(size == oldSize, "size = %s, oldSize = %s", size, oldSize); } /** * Unlike the public version, this doesn't resize. * *
REQUIRES: there are free positions in {@link data}. */ private boolean putImpl(ActionInput key, FileArtifactValue value) { int hashCode = key.getExecPathString().hashCode(); int probe = getProbe(hashCode); while (true) { ActionInput next = (ActionInput) data[probe]; if (next == null) { data[probe] = key; data[probe + 1] = value; ++size; return true; } if (hashCode == next.getExecPathString().hashCode() && next.getExecPathString().equals(key.getExecPathString())) { return false; // already present } probe = incProbe(probe); } } private int getProbe(int hashCode) { return (hashCode & mask) << 1; } private int incProbe(int probe) { probe += 2; if (probe >= data.length) { probe -= data.length; } return probe; } }