| Index: third_party/protobuf/java/src/main/java/com/google/protobuf/AbstractMessage.java
|
| diff --git a/third_party/protobuf/java/src/main/java/com/google/protobuf/AbstractMessage.java b/third_party/protobuf/java/src/main/java/com/google/protobuf/AbstractMessage.java
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..cc89173ab95b01908abfe2d12cf488fa89f0cc9c
|
| --- /dev/null
|
| +++ b/third_party/protobuf/java/src/main/java/com/google/protobuf/AbstractMessage.java
|
| @@ -0,0 +1,524 @@
|
| +// Protocol Buffers - Google's data interchange format
|
| +// Copyright 2008 Google Inc. All rights reserved.
|
| +// https://developers.google.com/protocol-buffers/
|
| +//
|
| +// 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 com.google.protobuf.Descriptors.FieldDescriptor;
|
| +import com.google.protobuf.Descriptors.OneofDescriptor;
|
| +import com.google.protobuf.Internal.EnumLite;
|
| +
|
| +import java.io.IOException;
|
| +import java.io.InputStream;
|
| +import java.util.Arrays;
|
| +import java.util.Collections;
|
| +import java.util.HashMap;
|
| +import java.util.Iterator;
|
| +import java.util.List;
|
| +import java.util.Map;
|
| +
|
| +/**
|
| + * A partial implementation of the {@link Message} interface which implements
|
| + * as many methods of that interface as possible in terms of other methods.
|
| + *
|
| + * @author kenton@google.com Kenton Varda
|
| + */
|
| +public abstract class AbstractMessage extends AbstractMessageLite
|
| + implements Message {
|
| + public boolean isInitialized() {
|
| + return MessageReflection.isInitialized(this);
|
| + }
|
| +
|
| +
|
| + public List<String> findInitializationErrors() {
|
| + return MessageReflection.findMissingFields(this);
|
| + }
|
| +
|
| + public String getInitializationErrorString() {
|
| + return MessageReflection.delimitWithCommas(findInitializationErrors());
|
| + }
|
| +
|
| + /** TODO(jieluo): Clear it when all subclasses have implemented this method. */
|
| + @Override
|
| + public boolean hasOneof(OneofDescriptor oneof) {
|
| + throw new UnsupportedOperationException("hasOneof() is not implemented.");
|
| + }
|
| +
|
| + /** TODO(jieluo): Clear it when all subclasses have implemented this method. */
|
| + @Override
|
| + public FieldDescriptor getOneofFieldDescriptor(OneofDescriptor oneof) {
|
| + throw new UnsupportedOperationException(
|
| + "getOneofFieldDescriptor() is not implemented.");
|
| + }
|
| +
|
| + @Override
|
| + public final String toString() {
|
| + return TextFormat.printToString(this);
|
| + }
|
| +
|
| + public void writeTo(final CodedOutputStream output) throws IOException {
|
| + MessageReflection.writeMessageTo(this, getAllFields(), output, false);
|
| + }
|
| +
|
| + protected int memoizedSize = -1;
|
| +
|
| + public int getSerializedSize() {
|
| + int size = memoizedSize;
|
| + if (size != -1) {
|
| + return size;
|
| + }
|
| +
|
| + memoizedSize = MessageReflection.getSerializedSize(this, getAllFields());
|
| + return memoizedSize;
|
| + }
|
| +
|
| + @Override
|
| + public boolean equals(final Object other) {
|
| + if (other == this) {
|
| + return true;
|
| + }
|
| + if (!(other instanceof Message)) {
|
| + return false;
|
| + }
|
| + final Message otherMessage = (Message) other;
|
| + if (getDescriptorForType() != otherMessage.getDescriptorForType()) {
|
| + return false;
|
| + }
|
| + return compareFields(getAllFields(), otherMessage.getAllFields()) &&
|
| + getUnknownFields().equals(otherMessage.getUnknownFields());
|
| + }
|
| +
|
| + @Override
|
| + public int hashCode() {
|
| + int hash = memoizedHashCode;
|
| + if (hash == 0) {
|
| + hash = 41;
|
| + hash = (19 * hash) + getDescriptorForType().hashCode();
|
| + hash = hashFields(hash, getAllFields());
|
| + hash = (29 * hash) + getUnknownFields().hashCode();
|
| + memoizedHashCode = hash;
|
| + }
|
| + return hash;
|
| + }
|
| +
|
| + private static ByteString toByteString(Object value) {
|
| + if (value instanceof byte[]) {
|
| + return ByteString.copyFrom((byte[]) value);
|
| + } else {
|
| + return (ByteString) value;
|
| + }
|
| + }
|
| +
|
| + /**
|
| + * Compares two bytes fields. The parameters must be either a byte array or a
|
| + * ByteString object. They can be of different type though.
|
| + */
|
| + private static boolean compareBytes(Object a, Object b) {
|
| + if (a instanceof byte[] && b instanceof byte[]) {
|
| + return Arrays.equals((byte[])a, (byte[])b);
|
| + }
|
| + return toByteString(a).equals(toByteString(b));
|
| + }
|
| +
|
| + /**
|
| + * Converts a list of MapEntry messages into a Map used for equals() and
|
| + * hashCode().
|
| + */
|
| + @SuppressWarnings({"rawtypes", "unchecked"})
|
| + private static Map convertMapEntryListToMap(List list) {
|
| + if (list.isEmpty()) {
|
| + return Collections.emptyMap();
|
| + }
|
| + Map result = new HashMap();
|
| + Iterator iterator = list.iterator();
|
| + Message entry = (Message) iterator.next();
|
| + Descriptors.Descriptor descriptor = entry.getDescriptorForType();
|
| + Descriptors.FieldDescriptor key = descriptor.findFieldByName("key");
|
| + Descriptors.FieldDescriptor value = descriptor.findFieldByName("value");
|
| + result.put(entry.getField(key), entry.getField(value));
|
| + while (iterator.hasNext()) {
|
| + entry = (Message) iterator.next();
|
| + result.put(entry.getField(key), entry.getField(value));
|
| + }
|
| + return result;
|
| + }
|
| +
|
| + /**
|
| + * Compares two map fields. The parameters must be a list of MapEntry
|
| + * messages.
|
| + */
|
| + @SuppressWarnings({"rawtypes", "unchecked"})
|
| + private static boolean compareMapField(Object a, Object b) {
|
| + Map ma = convertMapEntryListToMap((List) a);
|
| + Map mb = convertMapEntryListToMap((List) b);
|
| + return MapFieldLite.equals(ma, mb);
|
| + }
|
| +
|
| + /**
|
| + * Compares two set of fields.
|
| + * This method is used to implement {@link AbstractMessage#equals(Object)}
|
| + * and {@link AbstractMutableMessage#equals(Object)}. It takes special care
|
| + * of bytes fields because immutable messages and mutable messages use
|
| + * different Java type to reprensent a bytes field and this method should be
|
| + * able to compare immutable messages, mutable messages and also an immutable
|
| + * message to a mutable message.
|
| + */
|
| + static boolean compareFields(Map<FieldDescriptor, Object> a,
|
| + Map<FieldDescriptor, Object> b) {
|
| + if (a.size() != b.size()) {
|
| + return false;
|
| + }
|
| + for (FieldDescriptor descriptor : a.keySet()) {
|
| + if (!b.containsKey(descriptor)) {
|
| + return false;
|
| + }
|
| + Object value1 = a.get(descriptor);
|
| + Object value2 = b.get(descriptor);
|
| + if (descriptor.getType() == FieldDescriptor.Type.BYTES) {
|
| + if (descriptor.isRepeated()) {
|
| + List list1 = (List) value1;
|
| + List list2 = (List) value2;
|
| + if (list1.size() != list2.size()) {
|
| + return false;
|
| + }
|
| + for (int i = 0; i < list1.size(); i++) {
|
| + if (!compareBytes(list1.get(i), list2.get(i))) {
|
| + return false;
|
| + }
|
| + }
|
| + } else {
|
| + // Compares a singular bytes field.
|
| + if (!compareBytes(value1, value2)) {
|
| + return false;
|
| + }
|
| + }
|
| + } else if (descriptor.isMapField()) {
|
| + if (!compareMapField(value1, value2)) {
|
| + return false;
|
| + }
|
| + } else {
|
| + // Compare non-bytes fields.
|
| + if (!value1.equals(value2)) {
|
| + return false;
|
| + }
|
| + }
|
| + }
|
| + return true;
|
| + }
|
| +
|
| + /**
|
| + * Calculates the hash code of a map field. {@code value} must be a list of
|
| + * MapEntry messages.
|
| + */
|
| + @SuppressWarnings("unchecked")
|
| + private static int hashMapField(Object value) {
|
| + return MapFieldLite.calculateHashCodeForMap(convertMapEntryListToMap((List) value));
|
| + }
|
| +
|
| + /** Get a hash code for given fields and values, using the given seed. */
|
| + @SuppressWarnings("unchecked")
|
| + protected static int hashFields(int hash, Map<FieldDescriptor, Object> map) {
|
| + for (Map.Entry<FieldDescriptor, Object> entry : map.entrySet()) {
|
| + FieldDescriptor field = entry.getKey();
|
| + Object value = entry.getValue();
|
| + hash = (37 * hash) + field.getNumber();
|
| + if (field.isMapField()) {
|
| + hash = (53 * hash) + hashMapField(value);
|
| + } else if (field.getType() != FieldDescriptor.Type.ENUM){
|
| + hash = (53 * hash) + value.hashCode();
|
| + } else if (field.isRepeated()) {
|
| + List<? extends EnumLite> list = (List<? extends EnumLite>) value;
|
| + hash = (53 * hash) + Internal.hashEnumList(list);
|
| + } else {
|
| + hash = (53 * hash) + Internal.hashEnum((EnumLite) value);
|
| + }
|
| + }
|
| + return hash;
|
| + }
|
| +
|
| + /**
|
| + * Package private helper method for AbstractParser to create
|
| + * UninitializedMessageException with missing field information.
|
| + */
|
| + @Override
|
| + UninitializedMessageException newUninitializedMessageException() {
|
| + return Builder.newUninitializedMessageException(this);
|
| + }
|
| +
|
| + // =================================================================
|
| +
|
| + /**
|
| + * A partial implementation of the {@link Message.Builder} interface which
|
| + * implements as many methods of that interface as possible in terms of
|
| + * other methods.
|
| + */
|
| + @SuppressWarnings("unchecked")
|
| + public static abstract class Builder<BuilderType extends Builder>
|
| + extends AbstractMessageLite.Builder<BuilderType>
|
| + implements Message.Builder {
|
| + // The compiler produces an error if this is not declared explicitly.
|
| + @Override
|
| + public abstract BuilderType clone();
|
| +
|
| + /** TODO(jieluo): Clear it when all subclasses have implemented this method. */
|
| + @Override
|
| + public boolean hasOneof(OneofDescriptor oneof) {
|
| + throw new UnsupportedOperationException("hasOneof() is not implemented.");
|
| + }
|
| +
|
| + /** TODO(jieluo): Clear it when all subclasses have implemented this method. */
|
| + @Override
|
| + public FieldDescriptor getOneofFieldDescriptor(OneofDescriptor oneof) {
|
| + throw new UnsupportedOperationException(
|
| + "getOneofFieldDescriptor() is not implemented.");
|
| + }
|
| +
|
| + /** TODO(jieluo): Clear it when all subclasses have implemented this method. */
|
| + @Override
|
| + public BuilderType clearOneof(OneofDescriptor oneof) {
|
| + throw new UnsupportedOperationException("clearOneof() is not implemented.");
|
| + }
|
| +
|
| + public BuilderType clear() {
|
| + for (final Map.Entry<FieldDescriptor, Object> entry :
|
| + getAllFields().entrySet()) {
|
| + clearField(entry.getKey());
|
| + }
|
| + return (BuilderType) this;
|
| + }
|
| +
|
| + public List<String> findInitializationErrors() {
|
| + return MessageReflection.findMissingFields(this);
|
| + }
|
| +
|
| + public String getInitializationErrorString() {
|
| + return MessageReflection.delimitWithCommas(findInitializationErrors());
|
| + }
|
| +
|
| + public BuilderType mergeFrom(final Message other) {
|
| + if (other.getDescriptorForType() != getDescriptorForType()) {
|
| + throw new IllegalArgumentException(
|
| + "mergeFrom(Message) can only merge messages of the same type.");
|
| + }
|
| +
|
| + // Note: We don't attempt to verify that other's fields have valid
|
| + // types. Doing so would be a losing battle. We'd have to verify
|
| + // all sub-messages as well, and we'd have to make copies of all of
|
| + // them to insure that they don't change after verification (since
|
| + // the Message interface itself cannot enforce immutability of
|
| + // implementations).
|
| + // TODO(kenton): Provide a function somewhere called makeDeepCopy()
|
| + // which allows people to make secure deep copies of messages.
|
| +
|
| + for (final Map.Entry<FieldDescriptor, Object> entry :
|
| + other.getAllFields().entrySet()) {
|
| + final FieldDescriptor field = entry.getKey();
|
| + if (field.isRepeated()) {
|
| + for (final Object element : (List)entry.getValue()) {
|
| + addRepeatedField(field, element);
|
| + }
|
| + } else if (field.getJavaType() == FieldDescriptor.JavaType.MESSAGE) {
|
| + final Message existingValue = (Message)getField(field);
|
| + if (existingValue == existingValue.getDefaultInstanceForType()) {
|
| + setField(field, entry.getValue());
|
| + } else {
|
| + setField(field,
|
| + existingValue.newBuilderForType()
|
| + .mergeFrom(existingValue)
|
| + .mergeFrom((Message)entry.getValue())
|
| + .build());
|
| + }
|
| + } else {
|
| + setField(field, entry.getValue());
|
| + }
|
| + }
|
| +
|
| + mergeUnknownFields(other.getUnknownFields());
|
| +
|
| + return (BuilderType) this;
|
| + }
|
| +
|
| + @Override
|
| + public BuilderType mergeFrom(final CodedInputStream input)
|
| + throws IOException {
|
| + return mergeFrom(input, ExtensionRegistry.getEmptyRegistry());
|
| + }
|
| +
|
| + @Override
|
| + public BuilderType mergeFrom(
|
| + final CodedInputStream input,
|
| + final ExtensionRegistryLite extensionRegistry)
|
| + throws IOException {
|
| + final UnknownFieldSet.Builder unknownFields =
|
| + UnknownFieldSet.newBuilder(getUnknownFields());
|
| + while (true) {
|
| + final int tag = input.readTag();
|
| + if (tag == 0) {
|
| + break;
|
| + }
|
| +
|
| + MessageReflection.BuilderAdapter builderAdapter =
|
| + new MessageReflection.BuilderAdapter(this);
|
| + if (!MessageReflection.mergeFieldFrom(input, unknownFields,
|
| + extensionRegistry,
|
| + getDescriptorForType(),
|
| + builderAdapter,
|
| + tag)) {
|
| + // end group tag
|
| + break;
|
| + }
|
| + }
|
| + setUnknownFields(unknownFields.build());
|
| + return (BuilderType) this;
|
| + }
|
| +
|
| + public BuilderType mergeUnknownFields(final UnknownFieldSet unknownFields) {
|
| + setUnknownFields(
|
| + UnknownFieldSet.newBuilder(getUnknownFields())
|
| + .mergeFrom(unknownFields)
|
| + .build());
|
| + return (BuilderType) this;
|
| + }
|
| +
|
| + public Message.Builder getFieldBuilder(final FieldDescriptor field) {
|
| + throw new UnsupportedOperationException(
|
| + "getFieldBuilder() called on an unsupported message type.");
|
| + }
|
| +
|
| + public Message.Builder getRepeatedFieldBuilder(final FieldDescriptor field,
|
| + int index) {
|
| + throw new UnsupportedOperationException(
|
| + "getRepeatedFieldBuilder() called on an unsupported message type.");
|
| + }
|
| +
|
| + public String toString() {
|
| + return TextFormat.printToString(this);
|
| + }
|
| +
|
| + /**
|
| + * Construct an UninitializedMessageException reporting missing fields in
|
| + * the given message.
|
| + */
|
| + protected static UninitializedMessageException
|
| + newUninitializedMessageException(Message message) {
|
| + return new UninitializedMessageException(
|
| + MessageReflection.findMissingFields(message));
|
| + }
|
| +
|
| + // ===============================================================
|
| + // The following definitions seem to be required in order to make javac
|
| + // not produce weird errors like:
|
| + //
|
| + // java/com/google/protobuf/DynamicMessage.java:203: types
|
| + // com.google.protobuf.AbstractMessage.Builder<
|
| + // com.google.protobuf.DynamicMessage.Builder> and
|
| + // com.google.protobuf.AbstractMessage.Builder<
|
| + // com.google.protobuf.DynamicMessage.Builder> are incompatible; both
|
| + // define mergeFrom(com.google.protobuf.ByteString), but with unrelated
|
| + // return types.
|
| + //
|
| + // Strangely, these lines are only needed if javac is invoked separately
|
| + // on AbstractMessage.java and AbstractMessageLite.java. If javac is
|
| + // invoked on both simultaneously, it works. (Or maybe the important
|
| + // point is whether or not DynamicMessage.java is compiled together with
|
| + // AbstractMessageLite.java -- not sure.) I suspect this is a compiler
|
| + // bug.
|
| +
|
| + @Override
|
| + public BuilderType mergeFrom(final ByteString data)
|
| + throws InvalidProtocolBufferException {
|
| + return super.mergeFrom(data);
|
| + }
|
| +
|
| + @Override
|
| + public BuilderType mergeFrom(
|
| + final ByteString data,
|
| + final ExtensionRegistryLite extensionRegistry)
|
| + throws InvalidProtocolBufferException {
|
| + return super.mergeFrom(data, extensionRegistry);
|
| + }
|
| +
|
| + @Override
|
| + public BuilderType mergeFrom(final byte[] data)
|
| + throws InvalidProtocolBufferException {
|
| + return super.mergeFrom(data);
|
| + }
|
| +
|
| + @Override
|
| + public BuilderType mergeFrom(
|
| + final byte[] data, final int off, final int len)
|
| + throws InvalidProtocolBufferException {
|
| + return super.mergeFrom(data, off, len);
|
| + }
|
| +
|
| + @Override
|
| + public BuilderType mergeFrom(
|
| + final byte[] data,
|
| + final ExtensionRegistryLite extensionRegistry)
|
| + throws InvalidProtocolBufferException {
|
| + return super.mergeFrom(data, extensionRegistry);
|
| + }
|
| +
|
| + @Override
|
| + public BuilderType mergeFrom(
|
| + final byte[] data, final int off, final int len,
|
| + final ExtensionRegistryLite extensionRegistry)
|
| + throws InvalidProtocolBufferException {
|
| + return super.mergeFrom(data, off, len, extensionRegistry);
|
| + }
|
| +
|
| + @Override
|
| + public BuilderType mergeFrom(final InputStream input)
|
| + throws IOException {
|
| + return super.mergeFrom(input);
|
| + }
|
| +
|
| + @Override
|
| + public BuilderType mergeFrom(
|
| + final InputStream input,
|
| + final ExtensionRegistryLite extensionRegistry)
|
| + throws IOException {
|
| + return super.mergeFrom(input, extensionRegistry);
|
| + }
|
| +
|
| + @Override
|
| + public boolean mergeDelimitedFrom(final InputStream input)
|
| + throws IOException {
|
| + return super.mergeDelimitedFrom(input);
|
| + }
|
| +
|
| + @Override
|
| + public boolean mergeDelimitedFrom(
|
| + final InputStream input,
|
| + final ExtensionRegistryLite extensionRegistry)
|
| + throws IOException {
|
| + return super.mergeDelimitedFrom(input, extensionRegistry);
|
| + }
|
| + }
|
| +}
|
|
|