| Index: third_party/protobuf/java/src/main/java/com/google/protobuf/ByteString.java
|
| diff --git a/third_party/protobuf/java/src/main/java/com/google/protobuf/ByteString.java b/third_party/protobuf/java/src/main/java/com/google/protobuf/ByteString.java
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..913563573e023e549bc53de866ba0ed183e7fb9a
|
| --- /dev/null
|
| +++ b/third_party/protobuf/java/src/main/java/com/google/protobuf/ByteString.java
|
| @@ -0,0 +1,403 @@
|
| +// Protocol Buffers - Google's data interchange format
|
| +// Copyright 2008 Google Inc. All rights reserved.
|
| +// http://code.google.com/p/protobuf/
|
| +//
|
| +// Redistribution and use in source and binary forms, with or without
|
| +// modification, are permitted provided that the following conditions are
|
| +// met:
|
| +//
|
| +// * Redistributions of source code must retain the above copyright
|
| +// notice, this list of conditions and the following disclaimer.
|
| +// * Redistributions in binary form must reproduce the above
|
| +// copyright notice, this list of conditions and the following disclaimer
|
| +// in the documentation and/or other materials provided with the
|
| +// distribution.
|
| +// * Neither the name of Google Inc. nor the names of its
|
| +// contributors may be used to endorse or promote products derived from
|
| +// this software without specific prior written permission.
|
| +//
|
| +// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
|
| +// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
|
| +// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
|
| +// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
|
| +// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
|
| +// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
|
| +// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
|
| +// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
|
| +// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
|
| +// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
|
| +// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
| +
|
| +package com.google.protobuf;
|
| +
|
| +import java.io.InputStream;
|
| +import java.io.ByteArrayInputStream;
|
| +import java.io.ByteArrayOutputStream;
|
| +import java.io.FilterOutputStream;
|
| +import java.io.UnsupportedEncodingException;
|
| +import java.nio.ByteBuffer;
|
| +import java.util.List;
|
| +
|
| +/**
|
| + * Immutable array of bytes.
|
| + *
|
| + * @author crazybob@google.com Bob Lee
|
| + * @author kenton@google.com Kenton Varda
|
| + */
|
| +public final class ByteString {
|
| + private final byte[] bytes;
|
| +
|
| + private ByteString(final byte[] bytes) {
|
| + this.bytes = bytes;
|
| + }
|
| +
|
| + /**
|
| + * Gets the byte at the given index.
|
| + *
|
| + * @throws ArrayIndexOutOfBoundsException {@code index} is < 0 or >= size
|
| + */
|
| + public byte byteAt(final int index) {
|
| + return bytes[index];
|
| + }
|
| +
|
| + /**
|
| + * Gets the number of bytes.
|
| + */
|
| + public int size() {
|
| + return bytes.length;
|
| + }
|
| +
|
| + /**
|
| + * Returns {@code true} if the size is {@code 0}, {@code false} otherwise.
|
| + */
|
| + public boolean isEmpty() {
|
| + return bytes.length == 0;
|
| + }
|
| +
|
| + // =================================================================
|
| + // byte[] -> ByteString
|
| +
|
| + /**
|
| + * Empty ByteString.
|
| + */
|
| + public static final ByteString EMPTY = new ByteString(new byte[0]);
|
| +
|
| + /**
|
| + * Copies the given bytes into a {@code ByteString}.
|
| + */
|
| + public static ByteString copyFrom(final byte[] bytes, final int offset,
|
| + final int size) {
|
| + final byte[] copy = new byte[size];
|
| + System.arraycopy(bytes, offset, copy, 0, size);
|
| + return new ByteString(copy);
|
| + }
|
| +
|
| + /**
|
| + * Copies the given bytes into a {@code ByteString}.
|
| + */
|
| + public static ByteString copyFrom(final byte[] bytes) {
|
| + return copyFrom(bytes, 0, bytes.length);
|
| + }
|
| +
|
| + /**
|
| + * Copies {@code size} bytes from a {@code java.nio.ByteBuffer} into
|
| + * a {@code ByteString}.
|
| + */
|
| + public static ByteString copyFrom(final ByteBuffer bytes, final int size) {
|
| + final byte[] copy = new byte[size];
|
| + bytes.get(copy);
|
| + return new ByteString(copy);
|
| + }
|
| +
|
| + /**
|
| + * Copies the remaining bytes from a {@code java.nio.ByteBuffer} into
|
| + * a {@code ByteString}.
|
| + */
|
| + public static ByteString copyFrom(final ByteBuffer bytes) {
|
| + return copyFrom(bytes, bytes.remaining());
|
| + }
|
| +
|
| + /**
|
| + * Encodes {@code text} into a sequence of bytes using the named charset
|
| + * and returns the result as a {@code ByteString}.
|
| + */
|
| + public static ByteString copyFrom(final String text, final String charsetName)
|
| + throws UnsupportedEncodingException {
|
| + return new ByteString(text.getBytes(charsetName));
|
| + }
|
| +
|
| + /**
|
| + * Encodes {@code text} into a sequence of UTF-8 bytes and returns the
|
| + * result as a {@code ByteString}.
|
| + */
|
| + public static ByteString copyFromUtf8(final String text) {
|
| + try {
|
| + return new ByteString(text.getBytes("UTF-8"));
|
| + } catch (UnsupportedEncodingException e) {
|
| + throw new RuntimeException("UTF-8 not supported?", e);
|
| + }
|
| + }
|
| +
|
| + /**
|
| + * Concatenates all byte strings in the list and returns the result.
|
| + *
|
| + * <p>The returned {@code ByteString} is not necessarily a unique object.
|
| + * If the list is empty, the returned object is the singleton empty
|
| + * {@code ByteString}. If the list has only one element, that
|
| + * {@code ByteString} will be returned without copying.
|
| + */
|
| + public static ByteString copyFrom(List<ByteString> list) {
|
| + if (list.size() == 0) {
|
| + return EMPTY;
|
| + } else if (list.size() == 1) {
|
| + return list.get(0);
|
| + }
|
| +
|
| + int size = 0;
|
| + for (ByteString str : list) {
|
| + size += str.size();
|
| + }
|
| + byte[] bytes = new byte[size];
|
| + int pos = 0;
|
| + for (ByteString str : list) {
|
| + System.arraycopy(str.bytes, 0, bytes, pos, str.size());
|
| + pos += str.size();
|
| + }
|
| + return new ByteString(bytes);
|
| + }
|
| +
|
| + // =================================================================
|
| + // ByteString -> byte[]
|
| +
|
| + /**
|
| + * Copies bytes into a buffer at the given offset.
|
| + *
|
| + * @param target buffer to copy into
|
| + * @param offset in the target buffer
|
| + */
|
| + public void copyTo(final byte[] target, final int offset) {
|
| + System.arraycopy(bytes, 0, target, offset, bytes.length);
|
| + }
|
| +
|
| + /**
|
| + * Copies bytes into a buffer.
|
| + *
|
| + * @param target buffer to copy into
|
| + * @param sourceOffset offset within these bytes
|
| + * @param targetOffset offset within the target buffer
|
| + * @param size number of bytes to copy
|
| + */
|
| + public void copyTo(final byte[] target, final int sourceOffset,
|
| + final int targetOffset,
|
| + final int size) {
|
| + System.arraycopy(bytes, sourceOffset, target, targetOffset, size);
|
| + }
|
| +
|
| + /**
|
| + * Copies bytes into a ByteBuffer.
|
| + *
|
| + * @param target ByteBuffer to copy into.
|
| + * @throws ReadOnlyBufferException if the {@code target} is read-only
|
| + * @throws BufferOverflowException if the {@code target}'s remaining()
|
| + * space is not large enough to hold the data.
|
| + */
|
| + public void copyTo(ByteBuffer target) {
|
| + target.put(bytes, 0, bytes.length);
|
| + }
|
| +
|
| + /**
|
| + * Copies bytes to a {@code byte[]}.
|
| + */
|
| + public byte[] toByteArray() {
|
| + final int size = bytes.length;
|
| + final byte[] copy = new byte[size];
|
| + System.arraycopy(bytes, 0, copy, 0, size);
|
| + return copy;
|
| + }
|
| +
|
| + /**
|
| + * Constructs a new read-only {@code java.nio.ByteBuffer} with the
|
| + * same backing byte array.
|
| + */
|
| + public ByteBuffer asReadOnlyByteBuffer() {
|
| + final ByteBuffer byteBuffer = ByteBuffer.wrap(bytes);
|
| + return byteBuffer.asReadOnlyBuffer();
|
| + }
|
| +
|
| + /**
|
| + * Constructs a new {@code String} by decoding the bytes using the
|
| + * specified charset.
|
| + */
|
| + public String toString(final String charsetName)
|
| + throws UnsupportedEncodingException {
|
| + return new String(bytes, charsetName);
|
| + }
|
| +
|
| + /**
|
| + * Constructs a new {@code String} by decoding the bytes as UTF-8.
|
| + */
|
| + public String toStringUtf8() {
|
| + try {
|
| + return new String(bytes, "UTF-8");
|
| + } catch (UnsupportedEncodingException e) {
|
| + throw new RuntimeException("UTF-8 not supported?", e);
|
| + }
|
| + }
|
| +
|
| + // =================================================================
|
| + // equals() and hashCode()
|
| +
|
| + @Override
|
| + public boolean equals(final Object o) {
|
| + if (o == this) {
|
| + return true;
|
| + }
|
| +
|
| + if (!(o instanceof ByteString)) {
|
| + return false;
|
| + }
|
| +
|
| + final ByteString other = (ByteString) o;
|
| + final int size = bytes.length;
|
| + if (size != other.bytes.length) {
|
| + return false;
|
| + }
|
| +
|
| + final byte[] thisBytes = bytes;
|
| + final byte[] otherBytes = other.bytes;
|
| + for (int i = 0; i < size; i++) {
|
| + if (thisBytes[i] != otherBytes[i]) {
|
| + return false;
|
| + }
|
| + }
|
| +
|
| + return true;
|
| + }
|
| +
|
| + private volatile int hash = 0;
|
| +
|
| + @Override
|
| + public int hashCode() {
|
| + int h = hash;
|
| +
|
| + if (h == 0) {
|
| + final byte[] thisBytes = bytes;
|
| + final int size = bytes.length;
|
| +
|
| + h = size;
|
| + for (int i = 0; i < size; i++) {
|
| + h = h * 31 + thisBytes[i];
|
| + }
|
| + if (h == 0) {
|
| + h = 1;
|
| + }
|
| +
|
| + hash = h;
|
| + }
|
| +
|
| + return h;
|
| + }
|
| +
|
| + // =================================================================
|
| + // Input stream
|
| +
|
| + /**
|
| + * Creates an {@code InputStream} which can be used to read the bytes.
|
| + */
|
| + public InputStream newInput() {
|
| + return new ByteArrayInputStream(bytes);
|
| + }
|
| +
|
| + /**
|
| + * Creates a {@link CodedInputStream} which can be used to read the bytes.
|
| + * Using this is more efficient than creating a {@link CodedInputStream}
|
| + * wrapping the result of {@link #newInput()}.
|
| + */
|
| + public CodedInputStream newCodedInput() {
|
| + // We trust CodedInputStream not to modify the bytes, or to give anyone
|
| + // else access to them.
|
| + return CodedInputStream.newInstance(bytes);
|
| + }
|
| +
|
| + // =================================================================
|
| + // Output stream
|
| +
|
| + /**
|
| + * Creates a new {@link Output} with the given initial capacity.
|
| + */
|
| + public static Output newOutput(final int initialCapacity) {
|
| + return new Output(new ByteArrayOutputStream(initialCapacity));
|
| + }
|
| +
|
| + /**
|
| + * Creates a new {@link Output}.
|
| + */
|
| + public static Output newOutput() {
|
| + return newOutput(32);
|
| + }
|
| +
|
| + /**
|
| + * Outputs to a {@code ByteString} instance. Call {@link #toByteString()} to
|
| + * create the {@code ByteString} instance.
|
| + */
|
| + public static final class Output extends FilterOutputStream {
|
| + private final ByteArrayOutputStream bout;
|
| +
|
| + /**
|
| + * Constructs a new output with the given initial capacity.
|
| + */
|
| + private Output(final ByteArrayOutputStream bout) {
|
| + super(bout);
|
| + this.bout = bout;
|
| + }
|
| +
|
| + /**
|
| + * Creates a {@code ByteString} instance from this {@code Output}.
|
| + */
|
| + public ByteString toByteString() {
|
| + final byte[] byteArray = bout.toByteArray();
|
| + return new ByteString(byteArray);
|
| + }
|
| + }
|
| +
|
| + /**
|
| + * Constructs a new ByteString builder, which allows you to efficiently
|
| + * construct a {@code ByteString} by writing to a {@link CodedOutputStream}.
|
| + * Using this is much more efficient than calling {@code newOutput()} and
|
| + * wrapping that in a {@code CodedOutputStream}.
|
| + *
|
| + * <p>This is package-private because it's a somewhat confusing interface.
|
| + * Users can call {@link Message#toByteString()} instead of calling this
|
| + * directly.
|
| + *
|
| + * @param size The target byte size of the {@code ByteString}. You must
|
| + * write exactly this many bytes before building the result.
|
| + */
|
| + static CodedBuilder newCodedBuilder(final int size) {
|
| + return new CodedBuilder(size);
|
| + }
|
| +
|
| + /** See {@link ByteString#newCodedBuilder(int)}. */
|
| + static final class CodedBuilder {
|
| + private final CodedOutputStream output;
|
| + private final byte[] buffer;
|
| +
|
| + private CodedBuilder(final int size) {
|
| + buffer = new byte[size];
|
| + output = CodedOutputStream.newInstance(buffer);
|
| + }
|
| +
|
| + public ByteString build() {
|
| + output.checkNoSpaceLeft();
|
| +
|
| + // We can be confident that the CodedOutputStream will not modify the
|
| + // underlying bytes anymore because it already wrote all of them. So,
|
| + // no need to make a copy.
|
| + return new ByteString(buffer);
|
| + }
|
| +
|
| + public CodedOutputStream getCodedOutput() {
|
| + return output;
|
| + }
|
| + }
|
| +}
|
|
|