| Index: third_party/cacheinvalidation/src/java/com/google/ipc/invalidation/ticl/proto/AndroidListenerProtocol.java
|
| diff --git a/third_party/cacheinvalidation/src/java/com/google/ipc/invalidation/ticl/proto/AndroidListenerProtocol.java b/third_party/cacheinvalidation/src/java/com/google/ipc/invalidation/ticl/proto/AndroidListenerProtocol.java
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..18443a1d070337bec0634457b4041330fa7895c0
|
| --- /dev/null
|
| +++ b/third_party/cacheinvalidation/src/java/com/google/ipc/invalidation/ticl/proto/AndroidListenerProtocol.java
|
| @@ -0,0 +1,501 @@
|
| +/*
|
| + * Copyright 2011 Google Inc.
|
| + *
|
| + * 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.
|
| + */
|
| +// Generated by j/c/g/ipc/invalidation/common/proto_wrapper_generator
|
| +package com.google.ipc.invalidation.ticl.proto;
|
| +
|
| +import com.google.ipc.invalidation.util.Bytes;
|
| +import com.google.ipc.invalidation.util.ProtoWrapper;
|
| +import com.google.ipc.invalidation.util.ProtoWrapper.ValidationException;
|
| +import com.google.ipc.invalidation.util.TextBuilder;
|
| +import com.google.protobuf.nano.MessageNano;
|
| +import com.google.protobuf.nano.InvalidProtocolBufferNanoException;
|
| +
|
| +import java.util.ArrayList;
|
| +import java.util.Collection;
|
| +import java.util.List;
|
| +
|
| +
|
| +public interface AndroidListenerProtocol {
|
| +
|
| + public static final class AndroidListenerState extends ProtoWrapper {
|
| + public static final class RetryRegistrationState extends ProtoWrapper {
|
| + public static RetryRegistrationState create(com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP objectId,
|
| + com.google.ipc.invalidation.ticl.proto.Client.ExponentialBackoffState exponentialBackoffState) {
|
| + return new RetryRegistrationState(objectId, exponentialBackoffState);
|
| + }
|
| +
|
| + public static final RetryRegistrationState DEFAULT_INSTANCE = new RetryRegistrationState(null, null);
|
| +
|
| + private final long __hazzerBits;
|
| + private final com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP objectId;
|
| + private final com.google.ipc.invalidation.ticl.proto.Client.ExponentialBackoffState exponentialBackoffState;
|
| +
|
| + private RetryRegistrationState(com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP objectId,
|
| + com.google.ipc.invalidation.ticl.proto.Client.ExponentialBackoffState exponentialBackoffState) {
|
| + int hazzerBits = 0;
|
| + this.objectId = objectId;
|
| + if (exponentialBackoffState != null) {
|
| + hazzerBits |= 0x1;
|
| + this.exponentialBackoffState = exponentialBackoffState;
|
| + } else {
|
| + this.exponentialBackoffState = com.google.ipc.invalidation.ticl.proto.Client.ExponentialBackoffState.DEFAULT_INSTANCE;
|
| + }
|
| + this.__hazzerBits = hazzerBits;
|
| + }
|
| +
|
| + public com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP getNullableObjectId() { return objectId; }
|
| +
|
| + public com.google.ipc.invalidation.ticl.proto.Client.ExponentialBackoffState getExponentialBackoffState() { return exponentialBackoffState; }
|
| + public boolean hasExponentialBackoffState() { return (0x1 & __hazzerBits) != 0; }
|
| +
|
| + @Override public final boolean equals(Object obj) {
|
| + if (this == obj) { return true; }
|
| + if (!(obj instanceof RetryRegistrationState)) { return false; }
|
| + RetryRegistrationState other = (RetryRegistrationState) obj;
|
| + return __hazzerBits == other.__hazzerBits
|
| + && equals(objectId, other.objectId)
|
| + && (!hasExponentialBackoffState() || equals(exponentialBackoffState, other.exponentialBackoffState));
|
| + }
|
| +
|
| + @Override protected int computeHashCode() {
|
| + int result = hash(__hazzerBits);
|
| + if (objectId != null) {
|
| + result = result * 31 + objectId.hashCode();
|
| + }
|
| + if (hasExponentialBackoffState()) {
|
| + result = result * 31 + exponentialBackoffState.hashCode();
|
| + }
|
| + return result;
|
| + }
|
| +
|
| + @Override public void toCompactString(TextBuilder builder) {
|
| + builder.append("<RetryRegistrationState:");
|
| + if (objectId != null) {
|
| + builder.append(" object_id=").append(objectId);
|
| + }
|
| + if (hasExponentialBackoffState()) {
|
| + builder.append(" exponential_backoff_state=").append(exponentialBackoffState);
|
| + }
|
| + builder.append('>');
|
| + }
|
| +
|
| + public static RetryRegistrationState parseFrom(byte[] data) throws ValidationException {
|
| + try {
|
| + return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoAndroidListenerProtocol.AndroidListenerState.RetryRegistrationState(), data));
|
| + } catch (InvalidProtocolBufferNanoException exception) {
|
| + throw new ValidationException(exception);
|
| + } catch (ValidationArgumentException exception) {
|
| + throw new ValidationException(exception.getMessage());
|
| + }
|
| + }
|
| +
|
| + static RetryRegistrationState fromMessageNano(com.google.protos.ipc.invalidation.NanoAndroidListenerProtocol.AndroidListenerState.RetryRegistrationState message) {
|
| + if (message == null) { return null; }
|
| + return new RetryRegistrationState(com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP.fromMessageNano(message.objectId),
|
| + com.google.ipc.invalidation.ticl.proto.Client.ExponentialBackoffState.fromMessageNano(message.exponentialBackoffState));
|
| + }
|
| +
|
| + public byte[] toByteArray() {
|
| + return MessageNano.toByteArray(toMessageNano());
|
| + }
|
| +
|
| + com.google.protos.ipc.invalidation.NanoAndroidListenerProtocol.AndroidListenerState.RetryRegistrationState toMessageNano() {
|
| + com.google.protos.ipc.invalidation.NanoAndroidListenerProtocol.AndroidListenerState.RetryRegistrationState msg = new com.google.protos.ipc.invalidation.NanoAndroidListenerProtocol.AndroidListenerState.RetryRegistrationState();
|
| + msg.objectId = this.objectId != null ? objectId.toMessageNano() : null;
|
| + msg.exponentialBackoffState = hasExponentialBackoffState() ? exponentialBackoffState.toMessageNano() : null;
|
| + return msg;
|
| + }
|
| + }
|
| + public static AndroidListenerState create(Collection<com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP> registration,
|
| + Collection<com.google.ipc.invalidation.ticl.proto.AndroidListenerProtocol.AndroidListenerState.RetryRegistrationState> retryRegistrationState,
|
| + Bytes clientId,
|
| + Integer requestCodeSeqNum) {
|
| + return new AndroidListenerState(registration, retryRegistrationState, clientId, requestCodeSeqNum);
|
| + }
|
| +
|
| + public static final AndroidListenerState DEFAULT_INSTANCE = new AndroidListenerState(null, null, null, null);
|
| +
|
| + private final long __hazzerBits;
|
| + private final List<com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP> registration;
|
| + private final List<com.google.ipc.invalidation.ticl.proto.AndroidListenerProtocol.AndroidListenerState.RetryRegistrationState> retryRegistrationState;
|
| + private final Bytes clientId;
|
| + private final int requestCodeSeqNum;
|
| +
|
| + private AndroidListenerState(Collection<com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP> registration,
|
| + Collection<com.google.ipc.invalidation.ticl.proto.AndroidListenerProtocol.AndroidListenerState.RetryRegistrationState> retryRegistrationState,
|
| + Bytes clientId,
|
| + Integer requestCodeSeqNum) {
|
| + int hazzerBits = 0;
|
| + this.registration = optional("registration", registration);
|
| + this.retryRegistrationState = optional("retry_registration_state", retryRegistrationState);
|
| + if (clientId != null) {
|
| + hazzerBits |= 0x1;
|
| + this.clientId = clientId;
|
| + } else {
|
| + this.clientId = Bytes.EMPTY_BYTES;
|
| + }
|
| + if (requestCodeSeqNum != null) {
|
| + hazzerBits |= 0x2;
|
| + this.requestCodeSeqNum = requestCodeSeqNum;
|
| + } else {
|
| + this.requestCodeSeqNum = 0;
|
| + }
|
| + this.__hazzerBits = hazzerBits;
|
| + }
|
| +
|
| + public List<com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP> getRegistration() { return registration; }
|
| +
|
| + public List<com.google.ipc.invalidation.ticl.proto.AndroidListenerProtocol.AndroidListenerState.RetryRegistrationState> getRetryRegistrationState() { return retryRegistrationState; }
|
| +
|
| + public Bytes getClientId() { return clientId; }
|
| + public boolean hasClientId() { return (0x1 & __hazzerBits) != 0; }
|
| +
|
| + public int getRequestCodeSeqNum() { return requestCodeSeqNum; }
|
| + public boolean hasRequestCodeSeqNum() { return (0x2 & __hazzerBits) != 0; }
|
| +
|
| + @Override public final boolean equals(Object obj) {
|
| + if (this == obj) { return true; }
|
| + if (!(obj instanceof AndroidListenerState)) { return false; }
|
| + AndroidListenerState other = (AndroidListenerState) obj;
|
| + return __hazzerBits == other.__hazzerBits
|
| + && equals(registration, other.registration)
|
| + && equals(retryRegistrationState, other.retryRegistrationState)
|
| + && (!hasClientId() || equals(clientId, other.clientId))
|
| + && (!hasRequestCodeSeqNum() || requestCodeSeqNum == other.requestCodeSeqNum);
|
| + }
|
| +
|
| + @Override protected int computeHashCode() {
|
| + int result = hash(__hazzerBits);
|
| + result = result * 31 + registration.hashCode();
|
| + result = result * 31 + retryRegistrationState.hashCode();
|
| + if (hasClientId()) {
|
| + result = result * 31 + clientId.hashCode();
|
| + }
|
| + if (hasRequestCodeSeqNum()) {
|
| + result = result * 31 + hash(requestCodeSeqNum);
|
| + }
|
| + return result;
|
| + }
|
| +
|
| + @Override public void toCompactString(TextBuilder builder) {
|
| + builder.append("<AndroidListenerState:");
|
| + builder.append(" registration=[").append(registration).append(']');
|
| + builder.append(" retry_registration_state=[").append(retryRegistrationState).append(']');
|
| + if (hasClientId()) {
|
| + builder.append(" client_id=").append(clientId);
|
| + }
|
| + if (hasRequestCodeSeqNum()) {
|
| + builder.append(" request_code_seq_num=").append(requestCodeSeqNum);
|
| + }
|
| + builder.append('>');
|
| + }
|
| +
|
| + public static AndroidListenerState parseFrom(byte[] data) throws ValidationException {
|
| + try {
|
| + return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoAndroidListenerProtocol.AndroidListenerState(), data));
|
| + } catch (InvalidProtocolBufferNanoException exception) {
|
| + throw new ValidationException(exception);
|
| + } catch (ValidationArgumentException exception) {
|
| + throw new ValidationException(exception.getMessage());
|
| + }
|
| + }
|
| +
|
| + static AndroidListenerState fromMessageNano(com.google.protos.ipc.invalidation.NanoAndroidListenerProtocol.AndroidListenerState message) {
|
| + if (message == null) { return null; }
|
| + List<com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP> registration = new ArrayList<com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP>(message.registration.length);
|
| + for (int i = 0; i < message.registration.length; i++) {
|
| + registration.add(com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP.fromMessageNano(message.registration[i]));
|
| + }
|
| + List<com.google.ipc.invalidation.ticl.proto.AndroidListenerProtocol.AndroidListenerState.RetryRegistrationState> retryRegistrationState = new ArrayList<com.google.ipc.invalidation.ticl.proto.AndroidListenerProtocol.AndroidListenerState.RetryRegistrationState>(message.retryRegistrationState.length);
|
| + for (int i = 0; i < message.retryRegistrationState.length; i++) {
|
| + retryRegistrationState.add(com.google.ipc.invalidation.ticl.proto.AndroidListenerProtocol.AndroidListenerState.RetryRegistrationState.fromMessageNano(message.retryRegistrationState[i]));
|
| + }
|
| + return new AndroidListenerState(registration,
|
| + retryRegistrationState,
|
| + Bytes.fromByteArray(message.clientId),
|
| + message.requestCodeSeqNum);
|
| + }
|
| +
|
| + public byte[] toByteArray() {
|
| + return MessageNano.toByteArray(toMessageNano());
|
| + }
|
| +
|
| + com.google.protos.ipc.invalidation.NanoAndroidListenerProtocol.AndroidListenerState toMessageNano() {
|
| + com.google.protos.ipc.invalidation.NanoAndroidListenerProtocol.AndroidListenerState msg = new com.google.protos.ipc.invalidation.NanoAndroidListenerProtocol.AndroidListenerState();
|
| + msg.registration = new com.google.protos.ipc.invalidation.NanoClientProtocol.ObjectIdP[registration.size()];
|
| + for (int i = 0; i < msg.registration.length; i++) {
|
| + msg.registration[i] = registration.get(i).toMessageNano();
|
| + }
|
| + msg.retryRegistrationState = new com.google.protos.ipc.invalidation.NanoAndroidListenerProtocol.AndroidListenerState.RetryRegistrationState[retryRegistrationState.size()];
|
| + for (int i = 0; i < msg.retryRegistrationState.length; i++) {
|
| + msg.retryRegistrationState[i] = retryRegistrationState.get(i).toMessageNano();
|
| + }
|
| + msg.clientId = hasClientId() ? clientId.getByteArray() : null;
|
| + msg.requestCodeSeqNum = hasRequestCodeSeqNum() ? requestCodeSeqNum : null;
|
| + return msg;
|
| + }
|
| + }
|
| +
|
| + public static final class RegistrationCommand extends ProtoWrapper {
|
| + public static RegistrationCommand create(Boolean isRegister,
|
| + Collection<com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP> objectId,
|
| + Bytes clientId,
|
| + Boolean isDelayed) {
|
| + return new RegistrationCommand(isRegister, objectId, clientId, isDelayed);
|
| + }
|
| +
|
| + public static final RegistrationCommand DEFAULT_INSTANCE = new RegistrationCommand(null, null, null, null);
|
| +
|
| + private final long __hazzerBits;
|
| + private final boolean isRegister;
|
| + private final List<com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP> objectId;
|
| + private final Bytes clientId;
|
| + private final boolean isDelayed;
|
| +
|
| + private RegistrationCommand(Boolean isRegister,
|
| + Collection<com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP> objectId,
|
| + Bytes clientId,
|
| + Boolean isDelayed) {
|
| + int hazzerBits = 0;
|
| + if (isRegister != null) {
|
| + hazzerBits |= 0x1;
|
| + this.isRegister = isRegister;
|
| + } else {
|
| + this.isRegister = false;
|
| + }
|
| + this.objectId = optional("object_id", objectId);
|
| + if (clientId != null) {
|
| + hazzerBits |= 0x2;
|
| + this.clientId = clientId;
|
| + } else {
|
| + this.clientId = Bytes.EMPTY_BYTES;
|
| + }
|
| + if (isDelayed != null) {
|
| + hazzerBits |= 0x4;
|
| + this.isDelayed = isDelayed;
|
| + } else {
|
| + this.isDelayed = false;
|
| + }
|
| + this.__hazzerBits = hazzerBits;
|
| + }
|
| +
|
| + public boolean getIsRegister() { return isRegister; }
|
| + public boolean hasIsRegister() { return (0x1 & __hazzerBits) != 0; }
|
| +
|
| + public List<com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP> getObjectId() { return objectId; }
|
| +
|
| + public Bytes getClientId() { return clientId; }
|
| + public boolean hasClientId() { return (0x2 & __hazzerBits) != 0; }
|
| +
|
| + public boolean getIsDelayed() { return isDelayed; }
|
| + public boolean hasIsDelayed() { return (0x4 & __hazzerBits) != 0; }
|
| +
|
| + @Override public final boolean equals(Object obj) {
|
| + if (this == obj) { return true; }
|
| + if (!(obj instanceof RegistrationCommand)) { return false; }
|
| + RegistrationCommand other = (RegistrationCommand) obj;
|
| + return __hazzerBits == other.__hazzerBits
|
| + && (!hasIsRegister() || isRegister == other.isRegister)
|
| + && equals(objectId, other.objectId)
|
| + && (!hasClientId() || equals(clientId, other.clientId))
|
| + && (!hasIsDelayed() || isDelayed == other.isDelayed);
|
| + }
|
| +
|
| + @Override protected int computeHashCode() {
|
| + int result = hash(__hazzerBits);
|
| + if (hasIsRegister()) {
|
| + result = result * 31 + hash(isRegister);
|
| + }
|
| + result = result * 31 + objectId.hashCode();
|
| + if (hasClientId()) {
|
| + result = result * 31 + clientId.hashCode();
|
| + }
|
| + if (hasIsDelayed()) {
|
| + result = result * 31 + hash(isDelayed);
|
| + }
|
| + return result;
|
| + }
|
| +
|
| + @Override public void toCompactString(TextBuilder builder) {
|
| + builder.append("<RegistrationCommand:");
|
| + if (hasIsRegister()) {
|
| + builder.append(" is_register=").append(isRegister);
|
| + }
|
| + builder.append(" object_id=[").append(objectId).append(']');
|
| + if (hasClientId()) {
|
| + builder.append(" client_id=").append(clientId);
|
| + }
|
| + if (hasIsDelayed()) {
|
| + builder.append(" is_delayed=").append(isDelayed);
|
| + }
|
| + builder.append('>');
|
| + }
|
| +
|
| + public static RegistrationCommand parseFrom(byte[] data) throws ValidationException {
|
| + try {
|
| + return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoAndroidListenerProtocol.RegistrationCommand(), data));
|
| + } catch (InvalidProtocolBufferNanoException exception) {
|
| + throw new ValidationException(exception);
|
| + } catch (ValidationArgumentException exception) {
|
| + throw new ValidationException(exception.getMessage());
|
| + }
|
| + }
|
| +
|
| + static RegistrationCommand fromMessageNano(com.google.protos.ipc.invalidation.NanoAndroidListenerProtocol.RegistrationCommand message) {
|
| + if (message == null) { return null; }
|
| + List<com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP> objectId = new ArrayList<com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP>(message.objectId.length);
|
| + for (int i = 0; i < message.objectId.length; i++) {
|
| + objectId.add(com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP.fromMessageNano(message.objectId[i]));
|
| + }
|
| + return new RegistrationCommand(message.isRegister,
|
| + objectId,
|
| + Bytes.fromByteArray(message.clientId),
|
| + message.isDelayed);
|
| + }
|
| +
|
| + public byte[] toByteArray() {
|
| + return MessageNano.toByteArray(toMessageNano());
|
| + }
|
| +
|
| + com.google.protos.ipc.invalidation.NanoAndroidListenerProtocol.RegistrationCommand toMessageNano() {
|
| + com.google.protos.ipc.invalidation.NanoAndroidListenerProtocol.RegistrationCommand msg = new com.google.protos.ipc.invalidation.NanoAndroidListenerProtocol.RegistrationCommand();
|
| + msg.isRegister = hasIsRegister() ? isRegister : null;
|
| + msg.objectId = new com.google.protos.ipc.invalidation.NanoClientProtocol.ObjectIdP[objectId.size()];
|
| + for (int i = 0; i < msg.objectId.length; i++) {
|
| + msg.objectId[i] = objectId.get(i).toMessageNano();
|
| + }
|
| + msg.clientId = hasClientId() ? clientId.getByteArray() : null;
|
| + msg.isDelayed = hasIsDelayed() ? isDelayed : null;
|
| + return msg;
|
| + }
|
| + }
|
| +
|
| + public static final class StartCommand extends ProtoWrapper {
|
| + public static StartCommand create(Integer clientType,
|
| + Bytes clientName,
|
| + Boolean allowSuppression) {
|
| + return new StartCommand(clientType, clientName, allowSuppression);
|
| + }
|
| +
|
| + public static final StartCommand DEFAULT_INSTANCE = new StartCommand(null, null, null);
|
| +
|
| + private final long __hazzerBits;
|
| + private final int clientType;
|
| + private final Bytes clientName;
|
| + private final boolean allowSuppression;
|
| +
|
| + private StartCommand(Integer clientType,
|
| + Bytes clientName,
|
| + Boolean allowSuppression) {
|
| + int hazzerBits = 0;
|
| + if (clientType != null) {
|
| + hazzerBits |= 0x1;
|
| + this.clientType = clientType;
|
| + } else {
|
| + this.clientType = 0;
|
| + }
|
| + if (clientName != null) {
|
| + hazzerBits |= 0x2;
|
| + this.clientName = clientName;
|
| + } else {
|
| + this.clientName = Bytes.EMPTY_BYTES;
|
| + }
|
| + if (allowSuppression != null) {
|
| + hazzerBits |= 0x4;
|
| + this.allowSuppression = allowSuppression;
|
| + } else {
|
| + this.allowSuppression = false;
|
| + }
|
| + this.__hazzerBits = hazzerBits;
|
| + }
|
| +
|
| + public int getClientType() { return clientType; }
|
| + public boolean hasClientType() { return (0x1 & __hazzerBits) != 0; }
|
| +
|
| + public Bytes getClientName() { return clientName; }
|
| + public boolean hasClientName() { return (0x2 & __hazzerBits) != 0; }
|
| +
|
| + public boolean getAllowSuppression() { return allowSuppression; }
|
| + public boolean hasAllowSuppression() { return (0x4 & __hazzerBits) != 0; }
|
| +
|
| + @Override public final boolean equals(Object obj) {
|
| + if (this == obj) { return true; }
|
| + if (!(obj instanceof StartCommand)) { return false; }
|
| + StartCommand other = (StartCommand) obj;
|
| + return __hazzerBits == other.__hazzerBits
|
| + && (!hasClientType() || clientType == other.clientType)
|
| + && (!hasClientName() || equals(clientName, other.clientName))
|
| + && (!hasAllowSuppression() || allowSuppression == other.allowSuppression);
|
| + }
|
| +
|
| + @Override protected int computeHashCode() {
|
| + int result = hash(__hazzerBits);
|
| + if (hasClientType()) {
|
| + result = result * 31 + hash(clientType);
|
| + }
|
| + if (hasClientName()) {
|
| + result = result * 31 + clientName.hashCode();
|
| + }
|
| + if (hasAllowSuppression()) {
|
| + result = result * 31 + hash(allowSuppression);
|
| + }
|
| + return result;
|
| + }
|
| +
|
| + @Override public void toCompactString(TextBuilder builder) {
|
| + builder.append("<StartCommand:");
|
| + if (hasClientType()) {
|
| + builder.append(" client_type=").append(clientType);
|
| + }
|
| + if (hasClientName()) {
|
| + builder.append(" client_name=").append(clientName);
|
| + }
|
| + if (hasAllowSuppression()) {
|
| + builder.append(" allow_suppression=").append(allowSuppression);
|
| + }
|
| + builder.append('>');
|
| + }
|
| +
|
| + public static StartCommand parseFrom(byte[] data) throws ValidationException {
|
| + try {
|
| + return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoAndroidListenerProtocol.StartCommand(), data));
|
| + } catch (InvalidProtocolBufferNanoException exception) {
|
| + throw new ValidationException(exception);
|
| + } catch (ValidationArgumentException exception) {
|
| + throw new ValidationException(exception.getMessage());
|
| + }
|
| + }
|
| +
|
| + static StartCommand fromMessageNano(com.google.protos.ipc.invalidation.NanoAndroidListenerProtocol.StartCommand message) {
|
| + if (message == null) { return null; }
|
| + return new StartCommand(message.clientType,
|
| + Bytes.fromByteArray(message.clientName),
|
| + message.allowSuppression);
|
| + }
|
| +
|
| + public byte[] toByteArray() {
|
| + return MessageNano.toByteArray(toMessageNano());
|
| + }
|
| +
|
| + com.google.protos.ipc.invalidation.NanoAndroidListenerProtocol.StartCommand toMessageNano() {
|
| + com.google.protos.ipc.invalidation.NanoAndroidListenerProtocol.StartCommand msg = new com.google.protos.ipc.invalidation.NanoAndroidListenerProtocol.StartCommand();
|
| + msg.clientType = hasClientType() ? clientType : null;
|
| + msg.clientName = hasClientName() ? clientName.getByteArray() : null;
|
| + msg.allowSuppression = hasAllowSuppression() ? allowSuppression : null;
|
| + return msg;
|
| + }
|
| + }
|
| +}
|
|
|