Index: third_party/protobuf/java/src/main/java/com/google/protobuf/DynamicMessage.java |
diff --git a/third_party/protobuf/java/src/main/java/com/google/protobuf/DynamicMessage.java b/third_party/protobuf/java/src/main/java/com/google/protobuf/DynamicMessage.java |
new file mode 100644 |
index 0000000000000000000000000000000000000000..c106b662ba769cf20c4bdcb42b3bbc51a0c31130 |
--- /dev/null |
+++ b/third_party/protobuf/java/src/main/java/com/google/protobuf/DynamicMessage.java |
@@ -0,0 +1,438 @@ |
+// 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 com.google.protobuf.Descriptors.Descriptor; |
+import com.google.protobuf.Descriptors.FieldDescriptor; |
+ |
+import java.io.InputStream; |
+import java.io.IOException; |
+import java.util.Map; |
+ |
+/** |
+ * An implementation of {@link Message} that can represent arbitrary types, |
+ * given a {@link Descriptors.Descriptor}. |
+ * |
+ * @author kenton@google.com Kenton Varda |
+ */ |
+public final class DynamicMessage extends AbstractMessage { |
+ private final Descriptor type; |
+ private final FieldSet<FieldDescriptor> fields; |
+ private final UnknownFieldSet unknownFields; |
+ private int memoizedSize = -1; |
+ |
+ /** |
+ * Construct a {@code DynamicMessage} using the given {@code FieldSet}. |
+ */ |
+ private DynamicMessage(Descriptor type, FieldSet<FieldDescriptor> fields, |
+ UnknownFieldSet unknownFields) { |
+ this.type = type; |
+ this.fields = fields; |
+ this.unknownFields = unknownFields; |
+ } |
+ |
+ /** |
+ * Get a {@code DynamicMessage} representing the default instance of the |
+ * given type. |
+ */ |
+ public static DynamicMessage getDefaultInstance(Descriptor type) { |
+ return new DynamicMessage(type, FieldSet.<FieldDescriptor>emptySet(), |
+ UnknownFieldSet.getDefaultInstance()); |
+ } |
+ |
+ /** Parse a message of the given type from the given input stream. */ |
+ public static DynamicMessage parseFrom(Descriptor type, |
+ CodedInputStream input) |
+ throws IOException { |
+ return newBuilder(type).mergeFrom(input).buildParsed(); |
+ } |
+ |
+ /** Parse a message of the given type from the given input stream. */ |
+ public static DynamicMessage parseFrom( |
+ Descriptor type, |
+ CodedInputStream input, |
+ ExtensionRegistry extensionRegistry) |
+ throws IOException { |
+ return newBuilder(type).mergeFrom(input, extensionRegistry).buildParsed(); |
+ } |
+ |
+ /** Parse {@code data} as a message of the given type and return it. */ |
+ public static DynamicMessage parseFrom(Descriptor type, ByteString data) |
+ throws InvalidProtocolBufferException { |
+ return newBuilder(type).mergeFrom(data).buildParsed(); |
+ } |
+ |
+ /** Parse {@code data} as a message of the given type and return it. */ |
+ public static DynamicMessage parseFrom(Descriptor type, ByteString data, |
+ ExtensionRegistry extensionRegistry) |
+ throws InvalidProtocolBufferException { |
+ return newBuilder(type).mergeFrom(data, extensionRegistry).buildParsed(); |
+ } |
+ |
+ /** Parse {@code data} as a message of the given type and return it. */ |
+ public static DynamicMessage parseFrom(Descriptor type, byte[] data) |
+ throws InvalidProtocolBufferException { |
+ return newBuilder(type).mergeFrom(data).buildParsed(); |
+ } |
+ |
+ /** Parse {@code data} as a message of the given type and return it. */ |
+ public static DynamicMessage parseFrom(Descriptor type, byte[] data, |
+ ExtensionRegistry extensionRegistry) |
+ throws InvalidProtocolBufferException { |
+ return newBuilder(type).mergeFrom(data, extensionRegistry).buildParsed(); |
+ } |
+ |
+ /** Parse a message of the given type from {@code input} and return it. */ |
+ public static DynamicMessage parseFrom(Descriptor type, InputStream input) |
+ throws IOException { |
+ return newBuilder(type).mergeFrom(input).buildParsed(); |
+ } |
+ |
+ /** Parse a message of the given type from {@code input} and return it. */ |
+ public static DynamicMessage parseFrom(Descriptor type, InputStream input, |
+ ExtensionRegistry extensionRegistry) |
+ throws IOException { |
+ return newBuilder(type).mergeFrom(input, extensionRegistry).buildParsed(); |
+ } |
+ |
+ /** Construct a {@link Message.Builder} for the given type. */ |
+ public static Builder newBuilder(Descriptor type) { |
+ return new Builder(type); |
+ } |
+ |
+ /** |
+ * Construct a {@link Message.Builder} for a message of the same type as |
+ * {@code prototype}, and initialize it with {@code prototype}'s contents. |
+ */ |
+ public static Builder newBuilder(Message prototype) { |
+ return new Builder(prototype.getDescriptorForType()).mergeFrom(prototype); |
+ } |
+ |
+ // ----------------------------------------------------------------- |
+ // Implementation of Message interface. |
+ |
+ public Descriptor getDescriptorForType() { |
+ return type; |
+ } |
+ |
+ public DynamicMessage getDefaultInstanceForType() { |
+ return getDefaultInstance(type); |
+ } |
+ |
+ public Map<FieldDescriptor, Object> getAllFields() { |
+ return fields.getAllFields(); |
+ } |
+ |
+ public boolean hasField(FieldDescriptor field) { |
+ verifyContainingType(field); |
+ return fields.hasField(field); |
+ } |
+ |
+ public Object getField(FieldDescriptor field) { |
+ verifyContainingType(field); |
+ Object result = fields.getField(field); |
+ if (result == null) { |
+ if (field.getJavaType() == FieldDescriptor.JavaType.MESSAGE) { |
+ result = getDefaultInstance(field.getMessageType()); |
+ } else { |
+ result = field.getDefaultValue(); |
+ } |
+ } |
+ return result; |
+ } |
+ |
+ public int getRepeatedFieldCount(FieldDescriptor field) { |
+ verifyContainingType(field); |
+ return fields.getRepeatedFieldCount(field); |
+ } |
+ |
+ public Object getRepeatedField(FieldDescriptor field, int index) { |
+ verifyContainingType(field); |
+ return fields.getRepeatedField(field, index); |
+ } |
+ |
+ public UnknownFieldSet getUnknownFields() { |
+ return unknownFields; |
+ } |
+ |
+ private static boolean isInitialized(Descriptor type, |
+ FieldSet<FieldDescriptor> fields) { |
+ // Check that all required fields are present. |
+ for (final FieldDescriptor field : type.getFields()) { |
+ if (field.isRequired()) { |
+ if (!fields.hasField(field)) { |
+ return false; |
+ } |
+ } |
+ } |
+ |
+ // Check that embedded messages are initialized. |
+ return fields.isInitialized(); |
+ } |
+ |
+ public boolean isInitialized() { |
+ return isInitialized(type, fields); |
+ } |
+ |
+ public void writeTo(CodedOutputStream output) throws IOException { |
+ if (type.getOptions().getMessageSetWireFormat()) { |
+ fields.writeMessageSetTo(output); |
+ unknownFields.writeAsMessageSetTo(output); |
+ } else { |
+ fields.writeTo(output); |
+ unknownFields.writeTo(output); |
+ } |
+ } |
+ |
+ public int getSerializedSize() { |
+ int size = memoizedSize; |
+ if (size != -1) return size; |
+ |
+ if (type.getOptions().getMessageSetWireFormat()) { |
+ size = fields.getMessageSetSerializedSize(); |
+ size += unknownFields.getSerializedSizeAsMessageSet(); |
+ } else { |
+ size = fields.getSerializedSize(); |
+ size += unknownFields.getSerializedSize(); |
+ } |
+ |
+ memoizedSize = size; |
+ return size; |
+ } |
+ |
+ public Builder newBuilderForType() { |
+ return new Builder(type); |
+ } |
+ |
+ public Builder toBuilder() { |
+ return newBuilderForType().mergeFrom(this); |
+ } |
+ |
+ /** Verifies that the field is a field of this message. */ |
+ private void verifyContainingType(FieldDescriptor field) { |
+ if (field.getContainingType() != type) { |
+ throw new IllegalArgumentException( |
+ "FieldDescriptor does not match message type."); |
+ } |
+ } |
+ |
+ // ================================================================= |
+ |
+ /** |
+ * Builder for {@link DynamicMessage}s. |
+ */ |
+ public static final class Builder extends AbstractMessage.Builder<Builder> { |
+ private final Descriptor type; |
+ private FieldSet<FieldDescriptor> fields; |
+ private UnknownFieldSet unknownFields; |
+ |
+ /** Construct a {@code Builder} for the given type. */ |
+ private Builder(Descriptor type) { |
+ this.type = type; |
+ this.fields = FieldSet.newFieldSet(); |
+ this.unknownFields = UnknownFieldSet.getDefaultInstance(); |
+ } |
+ |
+ // --------------------------------------------------------------- |
+ // Implementation of Message.Builder interface. |
+ |
+ public Builder clear() { |
+ if (fields == null) { |
+ throw new IllegalStateException("Cannot call clear() after build()."); |
+ } |
+ fields.clear(); |
+ return this; |
+ } |
+ |
+ public Builder mergeFrom(Message other) { |
+ if (other instanceof DynamicMessage) { |
+ // This should be somewhat faster than calling super.mergeFrom(). |
+ DynamicMessage otherDynamicMessage = (DynamicMessage) other; |
+ if (otherDynamicMessage.type != type) { |
+ throw new IllegalArgumentException( |
+ "mergeFrom(Message) can only merge messages of the same type."); |
+ } |
+ fields.mergeFrom(otherDynamicMessage.fields); |
+ mergeUnknownFields(otherDynamicMessage.unknownFields); |
+ return this; |
+ } else { |
+ return super.mergeFrom(other); |
+ } |
+ } |
+ |
+ public DynamicMessage build() { |
+ // If fields == null, we'll throw an appropriate exception later. |
+ if (fields != null && !isInitialized()) { |
+ throw newUninitializedMessageException( |
+ new DynamicMessage(type, fields, unknownFields)); |
+ } |
+ return buildPartial(); |
+ } |
+ |
+ /** |
+ * Helper for DynamicMessage.parseFrom() methods to call. Throws |
+ * {@link InvalidProtocolBufferException} instead of |
+ * {@link UninitializedMessageException}. |
+ */ |
+ private DynamicMessage buildParsed() throws InvalidProtocolBufferException { |
+ if (!isInitialized()) { |
+ throw newUninitializedMessageException( |
+ new DynamicMessage(type, fields, unknownFields)) |
+ .asInvalidProtocolBufferException(); |
+ } |
+ return buildPartial(); |
+ } |
+ |
+ public DynamicMessage buildPartial() { |
+ if (fields == null) { |
+ throw new IllegalStateException( |
+ "build() has already been called on this Builder."); |
+ } |
+ fields.makeImmutable(); |
+ DynamicMessage result = |
+ new DynamicMessage(type, fields, unknownFields); |
+ fields = null; |
+ unknownFields = null; |
+ return result; |
+ } |
+ |
+ public Builder clone() { |
+ Builder result = new Builder(type); |
+ result.fields.mergeFrom(fields); |
+ return result; |
+ } |
+ |
+ public boolean isInitialized() { |
+ return DynamicMessage.isInitialized(type, fields); |
+ } |
+ |
+ public Descriptor getDescriptorForType() { |
+ return type; |
+ } |
+ |
+ public DynamicMessage getDefaultInstanceForType() { |
+ return getDefaultInstance(type); |
+ } |
+ |
+ public Map<FieldDescriptor, Object> getAllFields() { |
+ return fields.getAllFields(); |
+ } |
+ |
+ public Builder newBuilderForField(FieldDescriptor field) { |
+ verifyContainingType(field); |
+ |
+ if (field.getJavaType() != FieldDescriptor.JavaType.MESSAGE) { |
+ throw new IllegalArgumentException( |
+ "newBuilderForField is only valid for fields with message type."); |
+ } |
+ |
+ return new Builder(field.getMessageType()); |
+ } |
+ |
+ public boolean hasField(FieldDescriptor field) { |
+ verifyContainingType(field); |
+ return fields.hasField(field); |
+ } |
+ |
+ public Object getField(FieldDescriptor field) { |
+ verifyContainingType(field); |
+ Object result = fields.getField(field); |
+ if (result == null) { |
+ if (field.getJavaType() == FieldDescriptor.JavaType.MESSAGE) { |
+ result = getDefaultInstance(field.getMessageType()); |
+ } else { |
+ result = field.getDefaultValue(); |
+ } |
+ } |
+ return result; |
+ } |
+ |
+ public Builder setField(FieldDescriptor field, Object value) { |
+ verifyContainingType(field); |
+ fields.setField(field, value); |
+ return this; |
+ } |
+ |
+ public Builder clearField(FieldDescriptor field) { |
+ verifyContainingType(field); |
+ fields.clearField(field); |
+ return this; |
+ } |
+ |
+ public int getRepeatedFieldCount(FieldDescriptor field) { |
+ verifyContainingType(field); |
+ return fields.getRepeatedFieldCount(field); |
+ } |
+ |
+ public Object getRepeatedField(FieldDescriptor field, int index) { |
+ verifyContainingType(field); |
+ return fields.getRepeatedField(field, index); |
+ } |
+ |
+ public Builder setRepeatedField(FieldDescriptor field, |
+ int index, Object value) { |
+ verifyContainingType(field); |
+ fields.setRepeatedField(field, index, value); |
+ return this; |
+ } |
+ |
+ public Builder addRepeatedField(FieldDescriptor field, Object value) { |
+ verifyContainingType(field); |
+ fields.addRepeatedField(field, value); |
+ return this; |
+ } |
+ |
+ public UnknownFieldSet getUnknownFields() { |
+ return unknownFields; |
+ } |
+ |
+ public Builder setUnknownFields(UnknownFieldSet unknownFields) { |
+ this.unknownFields = unknownFields; |
+ return this; |
+ } |
+ |
+ public Builder mergeUnknownFields(UnknownFieldSet unknownFields) { |
+ this.unknownFields = |
+ UnknownFieldSet.newBuilder(this.unknownFields) |
+ .mergeFrom(unknownFields) |
+ .build(); |
+ return this; |
+ } |
+ |
+ /** Verifies that the field is a field of this message. */ |
+ private void verifyContainingType(FieldDescriptor field) { |
+ if (field.getContainingType() != type) { |
+ throw new IllegalArgumentException( |
+ "FieldDescriptor does not match message type."); |
+ } |
+ } |
+ } |
+} |