| /* |
| * 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 ClientProtocol { |
| |
| public static final class Version extends ProtoWrapper { |
| public static Version create(int majorVersion, |
| int minorVersion) { |
| return new Version(majorVersion, minorVersion); |
| } |
| |
| private final int majorVersion; |
| private final int minorVersion; |
| |
| private Version(Integer majorVersion, |
| Integer minorVersion) throws ValidationArgumentException { |
| required("major_version", majorVersion); |
| nonNegative("major_version", majorVersion); |
| this.majorVersion = majorVersion; |
| required("minor_version", minorVersion); |
| nonNegative("minor_version", minorVersion); |
| this.minorVersion = minorVersion; |
| } |
| |
| public int getMajorVersion() { return majorVersion; } |
| |
| public int getMinorVersion() { return minorVersion; } |
| |
| @Override public final boolean equals(Object obj) { |
| if (this == obj) { return true; } |
| if (!(obj instanceof Version)) { return false; } |
| Version other = (Version) obj; |
| return majorVersion == other.majorVersion |
| && minorVersion == other.minorVersion; |
| } |
| |
| @Override protected int computeHashCode() { |
| int result = 1; |
| result = result * 31 + hash(majorVersion); |
| result = result * 31 + hash(minorVersion); |
| return result; |
| } |
| |
| @Override public void toCompactString(TextBuilder builder) { |
| builder.append("<Version:"); |
| builder.append(" major_version=").append(majorVersion); |
| builder.append(" minor_version=").append(minorVersion); |
| builder.append('>'); |
| } |
| |
| public static Version parseFrom(byte[] data) throws ValidationException { |
| try { |
| return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClientProtocol.Version(), data)); |
| } catch (InvalidProtocolBufferNanoException exception) { |
| throw new ValidationException(exception); |
| } catch (ValidationArgumentException exception) { |
| throw new ValidationException(exception.getMessage()); |
| } |
| } |
| |
| static Version fromMessageNano(com.google.protos.ipc.invalidation.NanoClientProtocol.Version message) { |
| if (message == null) { return null; } |
| return new Version(message.majorVersion, |
| message.minorVersion); |
| } |
| |
| public byte[] toByteArray() { |
| return MessageNano.toByteArray(toMessageNano()); |
| } |
| |
| com.google.protos.ipc.invalidation.NanoClientProtocol.Version toMessageNano() { |
| com.google.protos.ipc.invalidation.NanoClientProtocol.Version msg = new com.google.protos.ipc.invalidation.NanoClientProtocol.Version(); |
| msg.majorVersion = majorVersion; |
| msg.minorVersion = minorVersion; |
| return msg; |
| } |
| } |
| |
| public static final class ProtocolVersion extends ProtoWrapper { |
| public static ProtocolVersion create(com.google.ipc.invalidation.ticl.proto.ClientProtocol.Version version) { |
| return new ProtocolVersion(version); |
| } |
| |
| private final com.google.ipc.invalidation.ticl.proto.ClientProtocol.Version version; |
| |
| private ProtocolVersion(com.google.ipc.invalidation.ticl.proto.ClientProtocol.Version version) throws ValidationArgumentException { |
| required("version", version); |
| this.version = version; |
| } |
| |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.Version getVersion() { return version; } |
| |
| @Override public final boolean equals(Object obj) { |
| if (this == obj) { return true; } |
| if (!(obj instanceof ProtocolVersion)) { return false; } |
| ProtocolVersion other = (ProtocolVersion) obj; |
| return equals(version, other.version); |
| } |
| |
| @Override protected int computeHashCode() { |
| int result = 1; |
| result = result * 31 + version.hashCode(); |
| return result; |
| } |
| |
| @Override public void toCompactString(TextBuilder builder) { |
| builder.append("<ProtocolVersion:"); |
| builder.append(" version=").append(version); |
| builder.append('>'); |
| } |
| |
| public static ProtocolVersion parseFrom(byte[] data) throws ValidationException { |
| try { |
| return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClientProtocol.ProtocolVersion(), data)); |
| } catch (InvalidProtocolBufferNanoException exception) { |
| throw new ValidationException(exception); |
| } catch (ValidationArgumentException exception) { |
| throw new ValidationException(exception.getMessage()); |
| } |
| } |
| |
| static ProtocolVersion fromMessageNano(com.google.protos.ipc.invalidation.NanoClientProtocol.ProtocolVersion message) { |
| if (message == null) { return null; } |
| return new ProtocolVersion(com.google.ipc.invalidation.ticl.proto.ClientProtocol.Version.fromMessageNano(message.version)); |
| } |
| |
| public byte[] toByteArray() { |
| return MessageNano.toByteArray(toMessageNano()); |
| } |
| |
| com.google.protos.ipc.invalidation.NanoClientProtocol.ProtocolVersion toMessageNano() { |
| com.google.protos.ipc.invalidation.NanoClientProtocol.ProtocolVersion msg = new com.google.protos.ipc.invalidation.NanoClientProtocol.ProtocolVersion(); |
| msg.version = version.toMessageNano(); |
| return msg; |
| } |
| } |
| |
| public static final class ClientVersion extends ProtoWrapper { |
| public static ClientVersion create(com.google.ipc.invalidation.ticl.proto.ClientProtocol.Version version, |
| String platform, |
| String language, |
| String applicationInfo) { |
| return new ClientVersion(version, platform, language, applicationInfo); |
| } |
| |
| private final com.google.ipc.invalidation.ticl.proto.ClientProtocol.Version version; |
| private final String platform; |
| private final String language; |
| private final String applicationInfo; |
| |
| private ClientVersion(com.google.ipc.invalidation.ticl.proto.ClientProtocol.Version version, |
| String platform, |
| String language, |
| String applicationInfo) throws ValidationArgumentException { |
| required("version", version); |
| this.version = version; |
| required("platform", platform); |
| this.platform = platform; |
| required("language", language); |
| this.language = language; |
| required("application_info", applicationInfo); |
| this.applicationInfo = applicationInfo; |
| } |
| |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.Version getVersion() { return version; } |
| |
| public String getPlatform() { return platform; } |
| |
| public String getLanguage() { return language; } |
| |
| public String getApplicationInfo() { return applicationInfo; } |
| |
| @Override public final boolean equals(Object obj) { |
| if (this == obj) { return true; } |
| if (!(obj instanceof ClientVersion)) { return false; } |
| ClientVersion other = (ClientVersion) obj; |
| return equals(version, other.version) |
| && equals(platform, other.platform) |
| && equals(language, other.language) |
| && equals(applicationInfo, other.applicationInfo); |
| } |
| |
| @Override protected int computeHashCode() { |
| int result = 1; |
| result = result * 31 + version.hashCode(); |
| result = result * 31 + platform.hashCode(); |
| result = result * 31 + language.hashCode(); |
| result = result * 31 + applicationInfo.hashCode(); |
| return result; |
| } |
| |
| @Override public void toCompactString(TextBuilder builder) { |
| builder.append("<ClientVersion:"); |
| builder.append(" version=").append(version); |
| builder.append(" platform=").append(platform); |
| builder.append(" language=").append(language); |
| builder.append(" application_info=").append(applicationInfo); |
| builder.append('>'); |
| } |
| |
| public static ClientVersion parseFrom(byte[] data) throws ValidationException { |
| try { |
| return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClientProtocol.ClientVersion(), data)); |
| } catch (InvalidProtocolBufferNanoException exception) { |
| throw new ValidationException(exception); |
| } catch (ValidationArgumentException exception) { |
| throw new ValidationException(exception.getMessage()); |
| } |
| } |
| |
| static ClientVersion fromMessageNano(com.google.protos.ipc.invalidation.NanoClientProtocol.ClientVersion message) { |
| if (message == null) { return null; } |
| return new ClientVersion(com.google.ipc.invalidation.ticl.proto.ClientProtocol.Version.fromMessageNano(message.version), |
| message.platform, |
| message.language, |
| message.applicationInfo); |
| } |
| |
| public byte[] toByteArray() { |
| return MessageNano.toByteArray(toMessageNano()); |
| } |
| |
| com.google.protos.ipc.invalidation.NanoClientProtocol.ClientVersion toMessageNano() { |
| com.google.protos.ipc.invalidation.NanoClientProtocol.ClientVersion msg = new com.google.protos.ipc.invalidation.NanoClientProtocol.ClientVersion(); |
| msg.version = version.toMessageNano(); |
| msg.platform = platform; |
| msg.language = language; |
| msg.applicationInfo = applicationInfo; |
| return msg; |
| } |
| } |
| |
| public static final class StatusP extends ProtoWrapper { |
| public interface Code { |
| public static final int SUCCESS = 1; |
| public static final int TRANSIENT_FAILURE = 2; |
| public static final int PERMANENT_FAILURE = 3; |
| } |
| |
| public static StatusP create(int code, |
| String description) { |
| return new StatusP(code, description); |
| } |
| |
| private final long __hazzerBits; |
| private final int code; |
| private final String description; |
| |
| private StatusP(Integer code, |
| String description) throws ValidationArgumentException { |
| int hazzerBits = 0; |
| required("code", code); |
| this.code = code; |
| if (description != null) { |
| hazzerBits |= 0x1; |
| this.description = description; |
| } else { |
| this.description = ""; |
| } |
| this.__hazzerBits = hazzerBits; |
| } |
| |
| public int getCode() { return code; } |
| |
| public String getDescription() { return description; } |
| public boolean hasDescription() { return (0x1 & __hazzerBits) != 0; } |
| |
| @Override public final boolean equals(Object obj) { |
| if (this == obj) { return true; } |
| if (!(obj instanceof StatusP)) { return false; } |
| StatusP other = (StatusP) obj; |
| return __hazzerBits == other.__hazzerBits |
| && code == other.code |
| && (!hasDescription() || equals(description, other.description)); |
| } |
| |
| @Override protected int computeHashCode() { |
| int result = hash(__hazzerBits); |
| result = result * 31 + hash(code); |
| if (hasDescription()) { |
| result = result * 31 + description.hashCode(); |
| } |
| return result; |
| } |
| |
| @Override public void toCompactString(TextBuilder builder) { |
| builder.append("<StatusP:"); |
| builder.append(" code=").append(code); |
| if (hasDescription()) { |
| builder.append(" description=").append(description); |
| } |
| builder.append('>'); |
| } |
| |
| public static StatusP parseFrom(byte[] data) throws ValidationException { |
| try { |
| return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClientProtocol.StatusP(), data)); |
| } catch (InvalidProtocolBufferNanoException exception) { |
| throw new ValidationException(exception); |
| } catch (ValidationArgumentException exception) { |
| throw new ValidationException(exception.getMessage()); |
| } |
| } |
| |
| static StatusP fromMessageNano(com.google.protos.ipc.invalidation.NanoClientProtocol.StatusP message) { |
| if (message == null) { return null; } |
| return new StatusP(message.code, |
| message.description); |
| } |
| |
| public byte[] toByteArray() { |
| return MessageNano.toByteArray(toMessageNano()); |
| } |
| |
| com.google.protos.ipc.invalidation.NanoClientProtocol.StatusP toMessageNano() { |
| com.google.protos.ipc.invalidation.NanoClientProtocol.StatusP msg = new com.google.protos.ipc.invalidation.NanoClientProtocol.StatusP(); |
| msg.code = code; |
| msg.description = hasDescription() ? description : null; |
| return msg; |
| } |
| } |
| |
| public static final class ObjectIdP extends ProtoWrapper { |
| public static ObjectIdP create(int source, |
| Bytes name) { |
| return new ObjectIdP(source, name); |
| } |
| |
| private final int source; |
| private final Bytes name; |
| |
| private ObjectIdP(Integer source, |
| Bytes name) throws ValidationArgumentException { |
| required("source", source); |
| nonNegative("source", source); |
| this.source = source; |
| required("name", name); |
| this.name = name; |
| } |
| |
| public int getSource() { return source; } |
| |
| public Bytes getName() { return name; } |
| |
| @Override public final boolean equals(Object obj) { |
| if (this == obj) { return true; } |
| if (!(obj instanceof ObjectIdP)) { return false; } |
| ObjectIdP other = (ObjectIdP) obj; |
| return source == other.source |
| && equals(name, other.name); |
| } |
| |
| @Override protected int computeHashCode() { |
| int result = 1; |
| result = result * 31 + hash(source); |
| result = result * 31 + name.hashCode(); |
| return result; |
| } |
| |
| @Override public void toCompactString(TextBuilder builder) { |
| builder.append("<ObjectIdP:"); |
| builder.append(" source=").append(source); |
| builder.append(" name=").append(name); |
| builder.append('>'); |
| } |
| |
| public static ObjectIdP parseFrom(byte[] data) throws ValidationException { |
| try { |
| return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClientProtocol.ObjectIdP(), data)); |
| } catch (InvalidProtocolBufferNanoException exception) { |
| throw new ValidationException(exception); |
| } catch (ValidationArgumentException exception) { |
| throw new ValidationException(exception.getMessage()); |
| } |
| } |
| |
| static ObjectIdP fromMessageNano(com.google.protos.ipc.invalidation.NanoClientProtocol.ObjectIdP message) { |
| if (message == null) { return null; } |
| return new ObjectIdP(message.source, |
| Bytes.fromByteArray(message.name)); |
| } |
| |
| public byte[] toByteArray() { |
| return MessageNano.toByteArray(toMessageNano()); |
| } |
| |
| com.google.protos.ipc.invalidation.NanoClientProtocol.ObjectIdP toMessageNano() { |
| com.google.protos.ipc.invalidation.NanoClientProtocol.ObjectIdP msg = new com.google.protos.ipc.invalidation.NanoClientProtocol.ObjectIdP(); |
| msg.source = source; |
| msg.name = name.getByteArray(); |
| return msg; |
| } |
| } |
| |
| public static final class ApplicationClientIdP extends ProtoWrapper { |
| public static ApplicationClientIdP create(Integer clientType, |
| Bytes clientName) { |
| return new ApplicationClientIdP(clientType, clientName); |
| } |
| |
| private final long __hazzerBits; |
| private final int clientType; |
| private final Bytes clientName; |
| |
| private ApplicationClientIdP(Integer clientType, |
| Bytes clientName) throws ValidationArgumentException { |
| int hazzerBits = 0; |
| if (clientType != null) { |
| hazzerBits |= 0x1; |
| this.clientType = clientType; |
| } else { |
| this.clientType = 0; |
| } |
| required("client_name", clientName); |
| nonEmpty("client_name", clientName); |
| this.clientName = clientName; |
| this.__hazzerBits = hazzerBits; |
| } |
| |
| public int getClientType() { return clientType; } |
| public boolean hasClientType() { return (0x1 & __hazzerBits) != 0; } |
| |
| public Bytes getClientName() { return clientName; } |
| |
| @Override public final boolean equals(Object obj) { |
| if (this == obj) { return true; } |
| if (!(obj instanceof ApplicationClientIdP)) { return false; } |
| ApplicationClientIdP other = (ApplicationClientIdP) obj; |
| return __hazzerBits == other.__hazzerBits |
| && (!hasClientType() || clientType == other.clientType) |
| && equals(clientName, other.clientName); |
| } |
| |
| @Override protected int computeHashCode() { |
| int result = hash(__hazzerBits); |
| if (hasClientType()) { |
| result = result * 31 + hash(clientType); |
| } |
| result = result * 31 + clientName.hashCode(); |
| return result; |
| } |
| |
| @Override public void toCompactString(TextBuilder builder) { |
| builder.append("<ApplicationClientIdP:"); |
| if (hasClientType()) { |
| builder.append(" client_type=").append(clientType); |
| } |
| builder.append(" client_name=").append(clientName); |
| builder.append('>'); |
| } |
| |
| public static ApplicationClientIdP parseFrom(byte[] data) throws ValidationException { |
| try { |
| return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClientProtocol.ApplicationClientIdP(), data)); |
| } catch (InvalidProtocolBufferNanoException exception) { |
| throw new ValidationException(exception); |
| } catch (ValidationArgumentException exception) { |
| throw new ValidationException(exception.getMessage()); |
| } |
| } |
| |
| static ApplicationClientIdP fromMessageNano(com.google.protos.ipc.invalidation.NanoClientProtocol.ApplicationClientIdP message) { |
| if (message == null) { return null; } |
| return new ApplicationClientIdP(message.clientType, |
| Bytes.fromByteArray(message.clientName)); |
| } |
| |
| public byte[] toByteArray() { |
| return MessageNano.toByteArray(toMessageNano()); |
| } |
| |
| com.google.protos.ipc.invalidation.NanoClientProtocol.ApplicationClientIdP toMessageNano() { |
| com.google.protos.ipc.invalidation.NanoClientProtocol.ApplicationClientIdP msg = new com.google.protos.ipc.invalidation.NanoClientProtocol.ApplicationClientIdP(); |
| msg.clientType = hasClientType() ? clientType : null; |
| msg.clientName = clientName.getByteArray(); |
| return msg; |
| } |
| } |
| |
| public static final class InvalidationP extends ProtoWrapper { |
| public static final class Builder { |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP objectId; |
| public boolean isKnownVersion; |
| public long version; |
| public Bytes payload; |
| public Long bridgeArrivalTimeMsDeprecated; |
| public Boolean isTrickleRestart; |
| public Builder(com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP objectId, |
| boolean isKnownVersion, |
| long version) { |
| this.objectId = objectId;this.isKnownVersion = isKnownVersion;this.version = version;} |
| |
| public InvalidationP build() { |
| return new InvalidationP(objectId, isKnownVersion, version, payload, bridgeArrivalTimeMsDeprecated, isTrickleRestart); |
| } |
| } |
| |
| public static InvalidationP create(com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP objectId, |
| boolean isKnownVersion, |
| long version, |
| Bytes payload, |
| Long bridgeArrivalTimeMsDeprecated, |
| Boolean isTrickleRestart) { |
| return new InvalidationP(objectId, isKnownVersion, version, payload, bridgeArrivalTimeMsDeprecated, isTrickleRestart); |
| } |
| |
| private final long __hazzerBits; |
| private final com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP objectId; |
| private final boolean isKnownVersion; |
| private final long version; |
| private final Bytes payload; |
| private final long bridgeArrivalTimeMsDeprecated; |
| private final boolean isTrickleRestart; |
| |
| private InvalidationP(com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP objectId, |
| Boolean isKnownVersion, |
| Long version, |
| Bytes payload, |
| Long bridgeArrivalTimeMsDeprecated, |
| Boolean isTrickleRestart) throws ValidationArgumentException { |
| int hazzerBits = 0; |
| required("object_id", objectId); |
| this.objectId = objectId; |
| required("is_known_version", isKnownVersion); |
| this.isKnownVersion = isKnownVersion; |
| required("version", version); |
| nonNegative("version", version); |
| this.version = version; |
| if (payload != null) { |
| hazzerBits |= 0x1; |
| this.payload = payload; |
| } else { |
| this.payload = Bytes.EMPTY_BYTES; |
| } |
| if (bridgeArrivalTimeMsDeprecated != null) { |
| hazzerBits |= 0x2; |
| this.bridgeArrivalTimeMsDeprecated = bridgeArrivalTimeMsDeprecated; |
| } else { |
| this.bridgeArrivalTimeMsDeprecated = 0; |
| } |
| if (isTrickleRestart != null) { |
| hazzerBits |= 0x4; |
| this.isTrickleRestart = isTrickleRestart; |
| } else { |
| this.isTrickleRestart = true; |
| } |
| this.__hazzerBits = hazzerBits; |
| check(isKnownVersion || (isTrickleRestart == null || isTrickleRestart), |
| "is_trickle_restart required if not is_known_version"); |
| } |
| |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP getObjectId() { return objectId; } |
| |
| public boolean getIsKnownVersion() { return isKnownVersion; } |
| |
| public long getVersion() { return version; } |
| |
| public Bytes getPayload() { return payload; } |
| public boolean hasPayload() { return (0x1 & __hazzerBits) != 0; } |
| |
| public long getBridgeArrivalTimeMsDeprecated() { return bridgeArrivalTimeMsDeprecated; } |
| public boolean hasBridgeArrivalTimeMsDeprecated() { return (0x2 & __hazzerBits) != 0; } |
| |
| public boolean getIsTrickleRestart() { return isTrickleRestart; } |
| public boolean hasIsTrickleRestart() { return (0x4 & __hazzerBits) != 0; } |
| |
| public Builder toBuilder() { |
| Builder builder = new Builder(objectId, isKnownVersion, version); |
| if (hasPayload()) { |
| builder.payload = payload; |
| } |
| if (hasBridgeArrivalTimeMsDeprecated()) { |
| builder.bridgeArrivalTimeMsDeprecated = bridgeArrivalTimeMsDeprecated; |
| } |
| if (hasIsTrickleRestart()) { |
| builder.isTrickleRestart = isTrickleRestart; |
| } |
| return builder; |
| } |
| |
| @Override public final boolean equals(Object obj) { |
| if (this == obj) { return true; } |
| if (!(obj instanceof InvalidationP)) { return false; } |
| InvalidationP other = (InvalidationP) obj; |
| return __hazzerBits == other.__hazzerBits |
| && equals(objectId, other.objectId) |
| && isKnownVersion == other.isKnownVersion |
| && version == other.version |
| && (!hasPayload() || equals(payload, other.payload)) |
| && (!hasBridgeArrivalTimeMsDeprecated() || bridgeArrivalTimeMsDeprecated == other.bridgeArrivalTimeMsDeprecated) |
| && (!hasIsTrickleRestart() || isTrickleRestart == other.isTrickleRestart); |
| } |
| |
| @Override protected int computeHashCode() { |
| int result = hash(__hazzerBits); |
| result = result * 31 + objectId.hashCode(); |
| result = result * 31 + hash(isKnownVersion); |
| result = result * 31 + hash(version); |
| if (hasPayload()) { |
| result = result * 31 + payload.hashCode(); |
| } |
| if (hasBridgeArrivalTimeMsDeprecated()) { |
| result = result * 31 + hash(bridgeArrivalTimeMsDeprecated); |
| } |
| if (hasIsTrickleRestart()) { |
| result = result * 31 + hash(isTrickleRestart); |
| } |
| return result; |
| } |
| |
| @Override public void toCompactString(TextBuilder builder) { |
| builder.append("<InvalidationP:"); |
| builder.append(" object_id=").append(objectId); |
| builder.append(" is_known_version=").append(isKnownVersion); |
| builder.append(" version=").append(version); |
| if (hasPayload()) { |
| builder.append(" payload=").append(payload); |
| } |
| if (hasBridgeArrivalTimeMsDeprecated()) { |
| builder.append(" bridge_arrival_time_ms_deprecated=").append(bridgeArrivalTimeMsDeprecated); |
| } |
| if (hasIsTrickleRestart()) { |
| builder.append(" is_trickle_restart=").append(isTrickleRestart); |
| } |
| builder.append('>'); |
| } |
| |
| public static InvalidationP parseFrom(byte[] data) throws ValidationException { |
| try { |
| return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClientProtocol.InvalidationP(), data)); |
| } catch (InvalidProtocolBufferNanoException exception) { |
| throw new ValidationException(exception); |
| } catch (ValidationArgumentException exception) { |
| throw new ValidationException(exception.getMessage()); |
| } |
| } |
| |
| static InvalidationP fromMessageNano(com.google.protos.ipc.invalidation.NanoClientProtocol.InvalidationP message) { |
| if (message == null) { return null; } |
| return new InvalidationP(com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP.fromMessageNano(message.objectId), |
| message.isKnownVersion, |
| message.version, |
| Bytes.fromByteArray(message.payload), |
| message.bridgeArrivalTimeMsDeprecated, |
| message.isTrickleRestart); |
| } |
| |
| public byte[] toByteArray() { |
| return MessageNano.toByteArray(toMessageNano()); |
| } |
| |
| com.google.protos.ipc.invalidation.NanoClientProtocol.InvalidationP toMessageNano() { |
| com.google.protos.ipc.invalidation.NanoClientProtocol.InvalidationP msg = new com.google.protos.ipc.invalidation.NanoClientProtocol.InvalidationP(); |
| msg.objectId = objectId.toMessageNano(); |
| msg.isKnownVersion = isKnownVersion; |
| msg.version = version; |
| msg.payload = hasPayload() ? payload.getByteArray() : null; |
| msg.bridgeArrivalTimeMsDeprecated = hasBridgeArrivalTimeMsDeprecated() ? bridgeArrivalTimeMsDeprecated : null; |
| msg.isTrickleRestart = hasIsTrickleRestart() ? isTrickleRestart : null; |
| return msg; |
| } |
| } |
| |
| public static final class RegistrationP extends ProtoWrapper { |
| public interface OpType { |
| public static final int REGISTER = 1; |
| public static final int UNREGISTER = 2; |
| } |
| |
| public static RegistrationP create(com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP objectId, |
| int opType) { |
| return new RegistrationP(objectId, opType); |
| } |
| |
| private final com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP objectId; |
| private final int opType; |
| |
| private RegistrationP(com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP objectId, |
| Integer opType) throws ValidationArgumentException { |
| required("object_id", objectId); |
| this.objectId = objectId; |
| required("op_type", opType); |
| this.opType = opType; |
| } |
| |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP getObjectId() { return objectId; } |
| |
| public int getOpType() { return opType; } |
| |
| @Override public final boolean equals(Object obj) { |
| if (this == obj) { return true; } |
| if (!(obj instanceof RegistrationP)) { return false; } |
| RegistrationP other = (RegistrationP) obj; |
| return equals(objectId, other.objectId) |
| && opType == other.opType; |
| } |
| |
| @Override protected int computeHashCode() { |
| int result = 1; |
| result = result * 31 + objectId.hashCode(); |
| result = result * 31 + hash(opType); |
| return result; |
| } |
| |
| @Override public void toCompactString(TextBuilder builder) { |
| builder.append("<RegistrationP:"); |
| builder.append(" object_id=").append(objectId); |
| builder.append(" op_type=").append(opType); |
| builder.append('>'); |
| } |
| |
| public static RegistrationP parseFrom(byte[] data) throws ValidationException { |
| try { |
| return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationP(), data)); |
| } catch (InvalidProtocolBufferNanoException exception) { |
| throw new ValidationException(exception); |
| } catch (ValidationArgumentException exception) { |
| throw new ValidationException(exception.getMessage()); |
| } |
| } |
| |
| static RegistrationP fromMessageNano(com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationP message) { |
| if (message == null) { return null; } |
| return new RegistrationP(com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP.fromMessageNano(message.objectId), |
| message.opType); |
| } |
| |
| public byte[] toByteArray() { |
| return MessageNano.toByteArray(toMessageNano()); |
| } |
| |
| com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationP toMessageNano() { |
| com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationP msg = new com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationP(); |
| msg.objectId = objectId.toMessageNano(); |
| msg.opType = opType; |
| return msg; |
| } |
| } |
| |
| public static final class RegistrationSummary extends ProtoWrapper { |
| public static RegistrationSummary create(int numRegistrations, |
| Bytes registrationDigest) { |
| return new RegistrationSummary(numRegistrations, registrationDigest); |
| } |
| |
| private final int numRegistrations; |
| private final Bytes registrationDigest; |
| |
| private RegistrationSummary(Integer numRegistrations, |
| Bytes registrationDigest) throws ValidationArgumentException { |
| required("num_registrations", numRegistrations); |
| nonNegative("num_registrations", numRegistrations); |
| this.numRegistrations = numRegistrations; |
| required("registration_digest", registrationDigest); |
| nonEmpty("registration_digest", registrationDigest); |
| this.registrationDigest = registrationDigest; |
| } |
| |
| public int getNumRegistrations() { return numRegistrations; } |
| |
| public Bytes getRegistrationDigest() { return registrationDigest; } |
| |
| @Override public final boolean equals(Object obj) { |
| if (this == obj) { return true; } |
| if (!(obj instanceof RegistrationSummary)) { return false; } |
| RegistrationSummary other = (RegistrationSummary) obj; |
| return numRegistrations == other.numRegistrations |
| && equals(registrationDigest, other.registrationDigest); |
| } |
| |
| @Override protected int computeHashCode() { |
| int result = 1; |
| result = result * 31 + hash(numRegistrations); |
| result = result * 31 + registrationDigest.hashCode(); |
| return result; |
| } |
| |
| @Override public void toCompactString(TextBuilder builder) { |
| builder.append("<RegistrationSummary:"); |
| builder.append(" num_registrations=").append(numRegistrations); |
| builder.append(" registration_digest=").append(registrationDigest); |
| builder.append('>'); |
| } |
| |
| public static RegistrationSummary parseFrom(byte[] data) throws ValidationException { |
| try { |
| return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationSummary(), data)); |
| } catch (InvalidProtocolBufferNanoException exception) { |
| throw new ValidationException(exception); |
| } catch (ValidationArgumentException exception) { |
| throw new ValidationException(exception.getMessage()); |
| } |
| } |
| |
| static RegistrationSummary fromMessageNano(com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationSummary message) { |
| if (message == null) { return null; } |
| return new RegistrationSummary(message.numRegistrations, |
| Bytes.fromByteArray(message.registrationDigest)); |
| } |
| |
| public byte[] toByteArray() { |
| return MessageNano.toByteArray(toMessageNano()); |
| } |
| |
| com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationSummary toMessageNano() { |
| com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationSummary msg = new com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationSummary(); |
| msg.numRegistrations = numRegistrations; |
| msg.registrationDigest = registrationDigest.getByteArray(); |
| return msg; |
| } |
| } |
| |
| public static final class ClientHeader extends ProtoWrapper { |
| public static ClientHeader create(com.google.ipc.invalidation.ticl.proto.ClientProtocol.ProtocolVersion protocolVersion, |
| Bytes clientToken, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationSummary registrationSummary, |
| long clientTimeMs, |
| long maxKnownServerTimeMs, |
| String messageId, |
| Integer clientType) { |
| return new ClientHeader(protocolVersion, clientToken, registrationSummary, clientTimeMs, maxKnownServerTimeMs, messageId, clientType); |
| } |
| |
| private final long __hazzerBits; |
| private final com.google.ipc.invalidation.ticl.proto.ClientProtocol.ProtocolVersion protocolVersion; |
| private final Bytes clientToken; |
| private final com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationSummary registrationSummary; |
| private final long clientTimeMs; |
| private final long maxKnownServerTimeMs; |
| private final String messageId; |
| private final int clientType; |
| |
| private ClientHeader(com.google.ipc.invalidation.ticl.proto.ClientProtocol.ProtocolVersion protocolVersion, |
| Bytes clientToken, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationSummary registrationSummary, |
| Long clientTimeMs, |
| Long maxKnownServerTimeMs, |
| String messageId, |
| Integer clientType) throws ValidationArgumentException { |
| int hazzerBits = 0; |
| required("protocol_version", protocolVersion); |
| this.protocolVersion = protocolVersion; |
| if (clientToken != null) { |
| hazzerBits |= 0x1; |
| nonEmpty("client_token", clientToken); |
| this.clientToken = clientToken; |
| } else { |
| this.clientToken = Bytes.EMPTY_BYTES; |
| } |
| this.registrationSummary = registrationSummary; |
| required("client_time_ms", clientTimeMs); |
| nonNegative("client_time_ms", clientTimeMs); |
| this.clientTimeMs = clientTimeMs; |
| required("max_known_server_time_ms", maxKnownServerTimeMs); |
| nonNegative("max_known_server_time_ms", maxKnownServerTimeMs); |
| this.maxKnownServerTimeMs = maxKnownServerTimeMs; |
| if (messageId != null) { |
| hazzerBits |= 0x2; |
| nonEmpty("message_id", messageId); |
| this.messageId = messageId; |
| } else { |
| this.messageId = ""; |
| } |
| if (clientType != null) { |
| hazzerBits |= 0x4; |
| this.clientType = clientType; |
| } else { |
| this.clientType = 0; |
| } |
| this.__hazzerBits = hazzerBits; |
| } |
| |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.ProtocolVersion getProtocolVersion() { return protocolVersion; } |
| |
| public Bytes getClientToken() { return clientToken; } |
| public boolean hasClientToken() { return (0x1 & __hazzerBits) != 0; } |
| |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationSummary getNullableRegistrationSummary() { return registrationSummary; } |
| |
| public long getClientTimeMs() { return clientTimeMs; } |
| |
| public long getMaxKnownServerTimeMs() { return maxKnownServerTimeMs; } |
| |
| public String getMessageId() { return messageId; } |
| public boolean hasMessageId() { return (0x2 & __hazzerBits) != 0; } |
| |
| public int getClientType() { return clientType; } |
| public boolean hasClientType() { return (0x4 & __hazzerBits) != 0; } |
| |
| @Override public final boolean equals(Object obj) { |
| if (this == obj) { return true; } |
| if (!(obj instanceof ClientHeader)) { return false; } |
| ClientHeader other = (ClientHeader) obj; |
| return __hazzerBits == other.__hazzerBits |
| && equals(protocolVersion, other.protocolVersion) |
| && (!hasClientToken() || equals(clientToken, other.clientToken)) |
| && equals(registrationSummary, other.registrationSummary) |
| && clientTimeMs == other.clientTimeMs |
| && maxKnownServerTimeMs == other.maxKnownServerTimeMs |
| && (!hasMessageId() || equals(messageId, other.messageId)) |
| && (!hasClientType() || clientType == other.clientType); |
| } |
| |
| @Override protected int computeHashCode() { |
| int result = hash(__hazzerBits); |
| result = result * 31 + protocolVersion.hashCode(); |
| if (hasClientToken()) { |
| result = result * 31 + clientToken.hashCode(); |
| } |
| if (registrationSummary != null) { |
| result = result * 31 + registrationSummary.hashCode(); |
| } |
| result = result * 31 + hash(clientTimeMs); |
| result = result * 31 + hash(maxKnownServerTimeMs); |
| if (hasMessageId()) { |
| result = result * 31 + messageId.hashCode(); |
| } |
| if (hasClientType()) { |
| result = result * 31 + hash(clientType); |
| } |
| return result; |
| } |
| |
| @Override public void toCompactString(TextBuilder builder) { |
| builder.append("<ClientHeader:"); |
| builder.append(" protocol_version=").append(protocolVersion); |
| if (hasClientToken()) { |
| builder.append(" client_token=").append(clientToken); |
| } |
| if (registrationSummary != null) { |
| builder.append(" registration_summary=").append(registrationSummary); |
| } |
| builder.append(" client_time_ms=").append(clientTimeMs); |
| builder.append(" max_known_server_time_ms=").append(maxKnownServerTimeMs); |
| if (hasMessageId()) { |
| builder.append(" message_id=").append(messageId); |
| } |
| if (hasClientType()) { |
| builder.append(" client_type=").append(clientType); |
| } |
| builder.append('>'); |
| } |
| |
| public static ClientHeader parseFrom(byte[] data) throws ValidationException { |
| try { |
| return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClientProtocol.ClientHeader(), data)); |
| } catch (InvalidProtocolBufferNanoException exception) { |
| throw new ValidationException(exception); |
| } catch (ValidationArgumentException exception) { |
| throw new ValidationException(exception.getMessage()); |
| } |
| } |
| |
| static ClientHeader fromMessageNano(com.google.protos.ipc.invalidation.NanoClientProtocol.ClientHeader message) { |
| if (message == null) { return null; } |
| return new ClientHeader(com.google.ipc.invalidation.ticl.proto.ClientProtocol.ProtocolVersion.fromMessageNano(message.protocolVersion), |
| Bytes.fromByteArray(message.clientToken), |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationSummary.fromMessageNano(message.registrationSummary), |
| message.clientTimeMs, |
| message.maxKnownServerTimeMs, |
| message.messageId, |
| message.clientType); |
| } |
| |
| public byte[] toByteArray() { |
| return MessageNano.toByteArray(toMessageNano()); |
| } |
| |
| com.google.protos.ipc.invalidation.NanoClientProtocol.ClientHeader toMessageNano() { |
| com.google.protos.ipc.invalidation.NanoClientProtocol.ClientHeader msg = new com.google.protos.ipc.invalidation.NanoClientProtocol.ClientHeader(); |
| msg.protocolVersion = protocolVersion.toMessageNano(); |
| msg.clientToken = hasClientToken() ? clientToken.getByteArray() : null; |
| msg.registrationSummary = this.registrationSummary != null ? registrationSummary.toMessageNano() : null; |
| msg.clientTimeMs = clientTimeMs; |
| msg.maxKnownServerTimeMs = maxKnownServerTimeMs; |
| msg.messageId = hasMessageId() ? messageId : null; |
| msg.clientType = hasClientType() ? clientType : null; |
| return msg; |
| } |
| } |
| |
| public static final class ClientToServerMessage extends ProtoWrapper { |
| public static ClientToServerMessage create(com.google.ipc.invalidation.ticl.proto.ClientProtocol.ClientHeader header, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.InitializeMessage initializeMessage, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationMessage registrationMessage, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationSyncMessage registrationSyncMessage, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.InvalidationMessage invalidationAckMessage, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.InfoMessage infoMessage) { |
| return new ClientToServerMessage(header, initializeMessage, registrationMessage, registrationSyncMessage, invalidationAckMessage, infoMessage); |
| } |
| |
| private final long __hazzerBits; |
| private final com.google.ipc.invalidation.ticl.proto.ClientProtocol.ClientHeader header; |
| private final com.google.ipc.invalidation.ticl.proto.ClientProtocol.InitializeMessage initializeMessage; |
| private final com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationMessage registrationMessage; |
| private final com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationSyncMessage registrationSyncMessage; |
| private final com.google.ipc.invalidation.ticl.proto.ClientProtocol.InvalidationMessage invalidationAckMessage; |
| private final com.google.ipc.invalidation.ticl.proto.ClientProtocol.InfoMessage infoMessage; |
| |
| private ClientToServerMessage(com.google.ipc.invalidation.ticl.proto.ClientProtocol.ClientHeader header, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.InitializeMessage initializeMessage, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationMessage registrationMessage, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationSyncMessage registrationSyncMessage, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.InvalidationMessage invalidationAckMessage, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.InfoMessage infoMessage) throws ValidationArgumentException { |
| int hazzerBits = 0; |
| required("header", header); |
| this.header = header; |
| this.initializeMessage = initializeMessage; |
| this.registrationMessage = registrationMessage; |
| this.registrationSyncMessage = registrationSyncMessage; |
| this.invalidationAckMessage = invalidationAckMessage; |
| if (infoMessage != null) { |
| hazzerBits |= 0x1; |
| this.infoMessage = infoMessage; |
| } else { |
| this.infoMessage = com.google.ipc.invalidation.ticl.proto.ClientProtocol.InfoMessage.DEFAULT_INSTANCE; |
| } |
| this.__hazzerBits = hazzerBits; |
| check((initializeMessage != null) ^ header.hasClientToken(), |
| "There should either be a client token or an initialization request"); |
| } |
| |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.ClientHeader getHeader() { return header; } |
| |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.InitializeMessage getNullableInitializeMessage() { return initializeMessage; } |
| |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationMessage getNullableRegistrationMessage() { return registrationMessage; } |
| |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationSyncMessage getNullableRegistrationSyncMessage() { return registrationSyncMessage; } |
| |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.InvalidationMessage getNullableInvalidationAckMessage() { return invalidationAckMessage; } |
| |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.InfoMessage getInfoMessage() { return infoMessage; } |
| public boolean hasInfoMessage() { return (0x1 & __hazzerBits) != 0; } |
| |
| @Override public final boolean equals(Object obj) { |
| if (this == obj) { return true; } |
| if (!(obj instanceof ClientToServerMessage)) { return false; } |
| ClientToServerMessage other = (ClientToServerMessage) obj; |
| return __hazzerBits == other.__hazzerBits |
| && equals(header, other.header) |
| && equals(initializeMessage, other.initializeMessage) |
| && equals(registrationMessage, other.registrationMessage) |
| && equals(registrationSyncMessage, other.registrationSyncMessage) |
| && equals(invalidationAckMessage, other.invalidationAckMessage) |
| && (!hasInfoMessage() || equals(infoMessage, other.infoMessage)); |
| } |
| |
| @Override protected int computeHashCode() { |
| int result = hash(__hazzerBits); |
| result = result * 31 + header.hashCode(); |
| if (initializeMessage != null) { |
| result = result * 31 + initializeMessage.hashCode(); |
| } |
| if (registrationMessage != null) { |
| result = result * 31 + registrationMessage.hashCode(); |
| } |
| if (registrationSyncMessage != null) { |
| result = result * 31 + registrationSyncMessage.hashCode(); |
| } |
| if (invalidationAckMessage != null) { |
| result = result * 31 + invalidationAckMessage.hashCode(); |
| } |
| if (hasInfoMessage()) { |
| result = result * 31 + infoMessage.hashCode(); |
| } |
| return result; |
| } |
| |
| @Override public void toCompactString(TextBuilder builder) { |
| builder.append("<ClientToServerMessage:"); |
| builder.append(" header=").append(header); |
| if (initializeMessage != null) { |
| builder.append(" initialize_message=").append(initializeMessage); |
| } |
| if (registrationMessage != null) { |
| builder.append(" registration_message=").append(registrationMessage); |
| } |
| if (registrationSyncMessage != null) { |
| builder.append(" registration_sync_message=").append(registrationSyncMessage); |
| } |
| if (invalidationAckMessage != null) { |
| builder.append(" invalidation_ack_message=").append(invalidationAckMessage); |
| } |
| if (hasInfoMessage()) { |
| builder.append(" info_message=").append(infoMessage); |
| } |
| builder.append('>'); |
| } |
| |
| public static ClientToServerMessage parseFrom(byte[] data) throws ValidationException { |
| try { |
| return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClientProtocol.ClientToServerMessage(), data)); |
| } catch (InvalidProtocolBufferNanoException exception) { |
| throw new ValidationException(exception); |
| } catch (ValidationArgumentException exception) { |
| throw new ValidationException(exception.getMessage()); |
| } |
| } |
| |
| static ClientToServerMessage fromMessageNano(com.google.protos.ipc.invalidation.NanoClientProtocol.ClientToServerMessage message) { |
| if (message == null) { return null; } |
| return new ClientToServerMessage(com.google.ipc.invalidation.ticl.proto.ClientProtocol.ClientHeader.fromMessageNano(message.header), |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.InitializeMessage.fromMessageNano(message.initializeMessage), |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationMessage.fromMessageNano(message.registrationMessage), |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationSyncMessage.fromMessageNano(message.registrationSyncMessage), |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.InvalidationMessage.fromMessageNano(message.invalidationAckMessage), |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.InfoMessage.fromMessageNano(message.infoMessage)); |
| } |
| |
| public byte[] toByteArray() { |
| return MessageNano.toByteArray(toMessageNano()); |
| } |
| |
| com.google.protos.ipc.invalidation.NanoClientProtocol.ClientToServerMessage toMessageNano() { |
| com.google.protos.ipc.invalidation.NanoClientProtocol.ClientToServerMessage msg = new com.google.protos.ipc.invalidation.NanoClientProtocol.ClientToServerMessage(); |
| msg.header = header.toMessageNano(); |
| msg.initializeMessage = this.initializeMessage != null ? initializeMessage.toMessageNano() : null; |
| msg.registrationMessage = this.registrationMessage != null ? registrationMessage.toMessageNano() : null; |
| msg.registrationSyncMessage = this.registrationSyncMessage != null ? registrationSyncMessage.toMessageNano() : null; |
| msg.invalidationAckMessage = this.invalidationAckMessage != null ? invalidationAckMessage.toMessageNano() : null; |
| msg.infoMessage = hasInfoMessage() ? infoMessage.toMessageNano() : null; |
| return msg; |
| } |
| } |
| |
| public static final class InitializeMessage extends ProtoWrapper { |
| public interface DigestSerializationType { |
| public static final int BYTE_BASED = 1; |
| public static final int NUMBER_BASED = 2; |
| } |
| |
| public static InitializeMessage create(int clientType, |
| Bytes nonce, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.ApplicationClientIdP applicationClientId, |
| int digestSerializationType) { |
| return new InitializeMessage(clientType, nonce, applicationClientId, digestSerializationType); |
| } |
| |
| private final int clientType; |
| private final Bytes nonce; |
| private final com.google.ipc.invalidation.ticl.proto.ClientProtocol.ApplicationClientIdP applicationClientId; |
| private final int digestSerializationType; |
| |
| private InitializeMessage(Integer clientType, |
| Bytes nonce, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.ApplicationClientIdP applicationClientId, |
| Integer digestSerializationType) throws ValidationArgumentException { |
| required("client_type", clientType); |
| nonNegative("client_type", clientType); |
| this.clientType = clientType; |
| required("nonce", nonce); |
| this.nonce = nonce; |
| required("application_client_id", applicationClientId); |
| this.applicationClientId = applicationClientId; |
| required("digest_serialization_type", digestSerializationType); |
| this.digestSerializationType = digestSerializationType; |
| } |
| |
| public int getClientType() { return clientType; } |
| |
| public Bytes getNonce() { return nonce; } |
| |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.ApplicationClientIdP getApplicationClientId() { return applicationClientId; } |
| |
| public int getDigestSerializationType() { return digestSerializationType; } |
| |
| @Override public final boolean equals(Object obj) { |
| if (this == obj) { return true; } |
| if (!(obj instanceof InitializeMessage)) { return false; } |
| InitializeMessage other = (InitializeMessage) obj; |
| return clientType == other.clientType |
| && equals(nonce, other.nonce) |
| && equals(applicationClientId, other.applicationClientId) |
| && digestSerializationType == other.digestSerializationType; |
| } |
| |
| @Override protected int computeHashCode() { |
| int result = 1; |
| result = result * 31 + hash(clientType); |
| result = result * 31 + nonce.hashCode(); |
| result = result * 31 + applicationClientId.hashCode(); |
| result = result * 31 + hash(digestSerializationType); |
| return result; |
| } |
| |
| @Override public void toCompactString(TextBuilder builder) { |
| builder.append("<InitializeMessage:"); |
| builder.append(" client_type=").append(clientType); |
| builder.append(" nonce=").append(nonce); |
| builder.append(" application_client_id=").append(applicationClientId); |
| builder.append(" digest_serialization_type=").append(digestSerializationType); |
| builder.append('>'); |
| } |
| |
| public static InitializeMessage parseFrom(byte[] data) throws ValidationException { |
| try { |
| return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClientProtocol.InitializeMessage(), data)); |
| } catch (InvalidProtocolBufferNanoException exception) { |
| throw new ValidationException(exception); |
| } catch (ValidationArgumentException exception) { |
| throw new ValidationException(exception.getMessage()); |
| } |
| } |
| |
| static InitializeMessage fromMessageNano(com.google.protos.ipc.invalidation.NanoClientProtocol.InitializeMessage message) { |
| if (message == null) { return null; } |
| return new InitializeMessage(message.clientType, |
| Bytes.fromByteArray(message.nonce), |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.ApplicationClientIdP.fromMessageNano(message.applicationClientId), |
| message.digestSerializationType); |
| } |
| |
| public byte[] toByteArray() { |
| return MessageNano.toByteArray(toMessageNano()); |
| } |
| |
| com.google.protos.ipc.invalidation.NanoClientProtocol.InitializeMessage toMessageNano() { |
| com.google.protos.ipc.invalidation.NanoClientProtocol.InitializeMessage msg = new com.google.protos.ipc.invalidation.NanoClientProtocol.InitializeMessage(); |
| msg.clientType = clientType; |
| msg.nonce = nonce.getByteArray(); |
| msg.applicationClientId = applicationClientId.toMessageNano(); |
| msg.digestSerializationType = digestSerializationType; |
| return msg; |
| } |
| } |
| |
| public static final class RegistrationMessage extends ProtoWrapper { |
| public static RegistrationMessage create(Collection<com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationP> registration) { |
| return new RegistrationMessage(registration); |
| } |
| |
| private final List<com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationP> registration; |
| |
| private RegistrationMessage(Collection<com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationP> registration) throws ValidationArgumentException { |
| this.registration = required("registration", registration); |
| } |
| |
| public List<com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationP> getRegistration() { return registration; } |
| |
| @Override public final boolean equals(Object obj) { |
| if (this == obj) { return true; } |
| if (!(obj instanceof RegistrationMessage)) { return false; } |
| RegistrationMessage other = (RegistrationMessage) obj; |
| return equals(registration, other.registration); |
| } |
| |
| @Override protected int computeHashCode() { |
| int result = 1; |
| result = result * 31 + registration.hashCode(); |
| return result; |
| } |
| |
| @Override public void toCompactString(TextBuilder builder) { |
| builder.append("<RegistrationMessage:"); |
| builder.append(" registration=[").append(registration).append(']'); |
| builder.append('>'); |
| } |
| |
| public static RegistrationMessage parseFrom(byte[] data) throws ValidationException { |
| try { |
| return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationMessage(), data)); |
| } catch (InvalidProtocolBufferNanoException exception) { |
| throw new ValidationException(exception); |
| } catch (ValidationArgumentException exception) { |
| throw new ValidationException(exception.getMessage()); |
| } |
| } |
| |
| static RegistrationMessage fromMessageNano(com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationMessage message) { |
| if (message == null) { return null; } |
| List<com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationP> registration = new ArrayList<com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationP>(message.registration.length); |
| for (int i = 0; i < message.registration.length; i++) { |
| registration.add(com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationP.fromMessageNano(message.registration[i])); |
| } |
| return new RegistrationMessage(registration); |
| } |
| |
| public byte[] toByteArray() { |
| return MessageNano.toByteArray(toMessageNano()); |
| } |
| |
| com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationMessage toMessageNano() { |
| com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationMessage msg = new com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationMessage(); |
| msg.registration = new com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationP[registration.size()]; |
| for (int i = 0; i < msg.registration.length; i++) { |
| msg.registration[i] = registration.get(i).toMessageNano(); |
| } |
| return msg; |
| } |
| } |
| |
| public static final class RegistrationSyncMessage extends ProtoWrapper { |
| public static RegistrationSyncMessage create(Collection<com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationSubtree> subtree) { |
| return new RegistrationSyncMessage(subtree); |
| } |
| |
| private final List<com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationSubtree> subtree; |
| |
| private RegistrationSyncMessage(Collection<com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationSubtree> subtree) throws ValidationArgumentException { |
| this.subtree = required("subtree", subtree); |
| } |
| |
| public List<com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationSubtree> getSubtree() { return subtree; } |
| |
| @Override public final boolean equals(Object obj) { |
| if (this == obj) { return true; } |
| if (!(obj instanceof RegistrationSyncMessage)) { return false; } |
| RegistrationSyncMessage other = (RegistrationSyncMessage) obj; |
| return equals(subtree, other.subtree); |
| } |
| |
| @Override protected int computeHashCode() { |
| int result = 1; |
| result = result * 31 + subtree.hashCode(); |
| return result; |
| } |
| |
| @Override public void toCompactString(TextBuilder builder) { |
| builder.append("<RegistrationSyncMessage:"); |
| builder.append(" subtree=[").append(subtree).append(']'); |
| builder.append('>'); |
| } |
| |
| public static RegistrationSyncMessage parseFrom(byte[] data) throws ValidationException { |
| try { |
| return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationSyncMessage(), data)); |
| } catch (InvalidProtocolBufferNanoException exception) { |
| throw new ValidationException(exception); |
| } catch (ValidationArgumentException exception) { |
| throw new ValidationException(exception.getMessage()); |
| } |
| } |
| |
| static RegistrationSyncMessage fromMessageNano(com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationSyncMessage message) { |
| if (message == null) { return null; } |
| List<com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationSubtree> subtree = new ArrayList<com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationSubtree>(message.subtree.length); |
| for (int i = 0; i < message.subtree.length; i++) { |
| subtree.add(com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationSubtree.fromMessageNano(message.subtree[i])); |
| } |
| return new RegistrationSyncMessage(subtree); |
| } |
| |
| public byte[] toByteArray() { |
| return MessageNano.toByteArray(toMessageNano()); |
| } |
| |
| com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationSyncMessage toMessageNano() { |
| com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationSyncMessage msg = new com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationSyncMessage(); |
| msg.subtree = new com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationSubtree[subtree.size()]; |
| for (int i = 0; i < msg.subtree.length; i++) { |
| msg.subtree[i] = subtree.get(i).toMessageNano(); |
| } |
| return msg; |
| } |
| } |
| |
| public static final class RegistrationSubtree extends ProtoWrapper { |
| public static RegistrationSubtree create(Collection<com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP> registeredObject) { |
| return new RegistrationSubtree(registeredObject); |
| } |
| |
| public static final RegistrationSubtree DEFAULT_INSTANCE = new RegistrationSubtree(null); |
| |
| private final List<com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP> registeredObject; |
| |
| private RegistrationSubtree(Collection<com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP> registeredObject) { |
| this.registeredObject = optional("registered_object", registeredObject); |
| } |
| |
| public List<com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP> getRegisteredObject() { return registeredObject; } |
| |
| @Override public final boolean equals(Object obj) { |
| if (this == obj) { return true; } |
| if (!(obj instanceof RegistrationSubtree)) { return false; } |
| RegistrationSubtree other = (RegistrationSubtree) obj; |
| return equals(registeredObject, other.registeredObject); |
| } |
| |
| @Override protected int computeHashCode() { |
| int result = 1; |
| result = result * 31 + registeredObject.hashCode(); |
| return result; |
| } |
| |
| @Override public void toCompactString(TextBuilder builder) { |
| builder.append("<RegistrationSubtree:"); |
| builder.append(" registered_object=[").append(registeredObject).append(']'); |
| builder.append('>'); |
| } |
| |
| public static RegistrationSubtree parseFrom(byte[] data) throws ValidationException { |
| try { |
| return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationSubtree(), data)); |
| } catch (InvalidProtocolBufferNanoException exception) { |
| throw new ValidationException(exception); |
| } catch (ValidationArgumentException exception) { |
| throw new ValidationException(exception.getMessage()); |
| } |
| } |
| |
| static RegistrationSubtree fromMessageNano(com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationSubtree message) { |
| if (message == null) { return null; } |
| List<com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP> registeredObject = new ArrayList<com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP>(message.registeredObject.length); |
| for (int i = 0; i < message.registeredObject.length; i++) { |
| registeredObject.add(com.google.ipc.invalidation.ticl.proto.ClientProtocol.ObjectIdP.fromMessageNano(message.registeredObject[i])); |
| } |
| return new RegistrationSubtree(registeredObject); |
| } |
| |
| public byte[] toByteArray() { |
| return MessageNano.toByteArray(toMessageNano()); |
| } |
| |
| com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationSubtree toMessageNano() { |
| com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationSubtree msg = new com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationSubtree(); |
| msg.registeredObject = new com.google.protos.ipc.invalidation.NanoClientProtocol.ObjectIdP[registeredObject.size()]; |
| for (int i = 0; i < msg.registeredObject.length; i++) { |
| msg.registeredObject[i] = registeredObject.get(i).toMessageNano(); |
| } |
| return msg; |
| } |
| } |
| |
| public static final class InfoMessage extends ProtoWrapper { |
| public static InfoMessage create(com.google.ipc.invalidation.ticl.proto.ClientProtocol.ClientVersion clientVersion, |
| Collection<com.google.ipc.invalidation.ticl.proto.ClientProtocol.PropertyRecord> configParameter, |
| Collection<com.google.ipc.invalidation.ticl.proto.ClientProtocol.PropertyRecord> performanceCounter, |
| Boolean serverRegistrationSummaryRequested, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.ClientConfigP clientConfig) { |
| return new InfoMessage(clientVersion, configParameter, performanceCounter, serverRegistrationSummaryRequested, clientConfig); |
| } |
| |
| public static final InfoMessage DEFAULT_INSTANCE = new InfoMessage(null, null, null, null, null); |
| |
| private final long __hazzerBits; |
| private final com.google.ipc.invalidation.ticl.proto.ClientProtocol.ClientVersion clientVersion; |
| private final List<com.google.ipc.invalidation.ticl.proto.ClientProtocol.PropertyRecord> configParameter; |
| private final List<com.google.ipc.invalidation.ticl.proto.ClientProtocol.PropertyRecord> performanceCounter; |
| private final boolean serverRegistrationSummaryRequested; |
| private final com.google.ipc.invalidation.ticl.proto.ClientProtocol.ClientConfigP clientConfig; |
| |
| private InfoMessage(com.google.ipc.invalidation.ticl.proto.ClientProtocol.ClientVersion clientVersion, |
| Collection<com.google.ipc.invalidation.ticl.proto.ClientProtocol.PropertyRecord> configParameter, |
| Collection<com.google.ipc.invalidation.ticl.proto.ClientProtocol.PropertyRecord> performanceCounter, |
| Boolean serverRegistrationSummaryRequested, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.ClientConfigP clientConfig) { |
| int hazzerBits = 0; |
| this.clientVersion = clientVersion; |
| this.configParameter = optional("config_parameter", configParameter); |
| this.performanceCounter = optional("performance_counter", performanceCounter); |
| if (serverRegistrationSummaryRequested != null) { |
| hazzerBits |= 0x1; |
| this.serverRegistrationSummaryRequested = serverRegistrationSummaryRequested; |
| } else { |
| this.serverRegistrationSummaryRequested = false; |
| } |
| this.clientConfig = clientConfig; |
| this.__hazzerBits = hazzerBits; |
| } |
| |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.ClientVersion getNullableClientVersion() { return clientVersion; } |
| |
| public List<com.google.ipc.invalidation.ticl.proto.ClientProtocol.PropertyRecord> getConfigParameter() { return configParameter; } |
| |
| public List<com.google.ipc.invalidation.ticl.proto.ClientProtocol.PropertyRecord> getPerformanceCounter() { return performanceCounter; } |
| |
| public boolean getServerRegistrationSummaryRequested() { return serverRegistrationSummaryRequested; } |
| public boolean hasServerRegistrationSummaryRequested() { return (0x1 & __hazzerBits) != 0; } |
| |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.ClientConfigP getNullableClientConfig() { return clientConfig; } |
| |
| @Override public final boolean equals(Object obj) { |
| if (this == obj) { return true; } |
| if (!(obj instanceof InfoMessage)) { return false; } |
| InfoMessage other = (InfoMessage) obj; |
| return __hazzerBits == other.__hazzerBits |
| && equals(clientVersion, other.clientVersion) |
| && equals(configParameter, other.configParameter) |
| && equals(performanceCounter, other.performanceCounter) |
| && (!hasServerRegistrationSummaryRequested() || serverRegistrationSummaryRequested == other.serverRegistrationSummaryRequested) |
| && equals(clientConfig, other.clientConfig); |
| } |
| |
| @Override protected int computeHashCode() { |
| int result = hash(__hazzerBits); |
| if (clientVersion != null) { |
| result = result * 31 + clientVersion.hashCode(); |
| } |
| result = result * 31 + configParameter.hashCode(); |
| result = result * 31 + performanceCounter.hashCode(); |
| if (hasServerRegistrationSummaryRequested()) { |
| result = result * 31 + hash(serverRegistrationSummaryRequested); |
| } |
| if (clientConfig != null) { |
| result = result * 31 + clientConfig.hashCode(); |
| } |
| return result; |
| } |
| |
| @Override public void toCompactString(TextBuilder builder) { |
| builder.append("<InfoMessage:"); |
| if (clientVersion != null) { |
| builder.append(" client_version=").append(clientVersion); |
| } |
| builder.append(" config_parameter=[").append(configParameter).append(']'); |
| builder.append(" performance_counter=[").append(performanceCounter).append(']'); |
| if (hasServerRegistrationSummaryRequested()) { |
| builder.append(" server_registration_summary_requested=").append(serverRegistrationSummaryRequested); |
| } |
| if (clientConfig != null) { |
| builder.append(" client_config=").append(clientConfig); |
| } |
| builder.append('>'); |
| } |
| |
| public static InfoMessage parseFrom(byte[] data) throws ValidationException { |
| try { |
| return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClientProtocol.InfoMessage(), data)); |
| } catch (InvalidProtocolBufferNanoException exception) { |
| throw new ValidationException(exception); |
| } catch (ValidationArgumentException exception) { |
| throw new ValidationException(exception.getMessage()); |
| } |
| } |
| |
| static InfoMessage fromMessageNano(com.google.protos.ipc.invalidation.NanoClientProtocol.InfoMessage message) { |
| if (message == null) { return null; } |
| List<com.google.ipc.invalidation.ticl.proto.ClientProtocol.PropertyRecord> configParameter = new ArrayList<com.google.ipc.invalidation.ticl.proto.ClientProtocol.PropertyRecord>(message.configParameter.length); |
| for (int i = 0; i < message.configParameter.length; i++) { |
| configParameter.add(com.google.ipc.invalidation.ticl.proto.ClientProtocol.PropertyRecord.fromMessageNano(message.configParameter[i])); |
| } |
| List<com.google.ipc.invalidation.ticl.proto.ClientProtocol.PropertyRecord> performanceCounter = new ArrayList<com.google.ipc.invalidation.ticl.proto.ClientProtocol.PropertyRecord>(message.performanceCounter.length); |
| for (int i = 0; i < message.performanceCounter.length; i++) { |
| performanceCounter.add(com.google.ipc.invalidation.ticl.proto.ClientProtocol.PropertyRecord.fromMessageNano(message.performanceCounter[i])); |
| } |
| return new InfoMessage(com.google.ipc.invalidation.ticl.proto.ClientProtocol.ClientVersion.fromMessageNano(message.clientVersion), |
| configParameter, |
| performanceCounter, |
| message.serverRegistrationSummaryRequested, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.ClientConfigP.fromMessageNano(message.clientConfig)); |
| } |
| |
| public byte[] toByteArray() { |
| return MessageNano.toByteArray(toMessageNano()); |
| } |
| |
| com.google.protos.ipc.invalidation.NanoClientProtocol.InfoMessage toMessageNano() { |
| com.google.protos.ipc.invalidation.NanoClientProtocol.InfoMessage msg = new com.google.protos.ipc.invalidation.NanoClientProtocol.InfoMessage(); |
| msg.clientVersion = this.clientVersion != null ? clientVersion.toMessageNano() : null; |
| msg.configParameter = new com.google.protos.ipc.invalidation.NanoClientProtocol.PropertyRecord[configParameter.size()]; |
| for (int i = 0; i < msg.configParameter.length; i++) { |
| msg.configParameter[i] = configParameter.get(i).toMessageNano(); |
| } |
| msg.performanceCounter = new com.google.protos.ipc.invalidation.NanoClientProtocol.PropertyRecord[performanceCounter.size()]; |
| for (int i = 0; i < msg.performanceCounter.length; i++) { |
| msg.performanceCounter[i] = performanceCounter.get(i).toMessageNano(); |
| } |
| msg.serverRegistrationSummaryRequested = hasServerRegistrationSummaryRequested() ? serverRegistrationSummaryRequested : null; |
| msg.clientConfig = this.clientConfig != null ? clientConfig.toMessageNano() : null; |
| return msg; |
| } |
| } |
| |
| public static final class PropertyRecord extends ProtoWrapper { |
| public static PropertyRecord create(String name, |
| Integer value) { |
| return new PropertyRecord(name, value); |
| } |
| |
| public static final PropertyRecord DEFAULT_INSTANCE = new PropertyRecord(null, null); |
| |
| private final long __hazzerBits; |
| private final String name; |
| private final int value; |
| |
| private PropertyRecord(String name, |
| Integer value) { |
| int hazzerBits = 0; |
| if (name != null) { |
| hazzerBits |= 0x1; |
| this.name = name; |
| } else { |
| this.name = ""; |
| } |
| if (value != null) { |
| hazzerBits |= 0x2; |
| this.value = value; |
| } else { |
| this.value = 0; |
| } |
| this.__hazzerBits = hazzerBits; |
| } |
| |
| public String getName() { return name; } |
| public boolean hasName() { return (0x1 & __hazzerBits) != 0; } |
| |
| public int getValue() { return value; } |
| public boolean hasValue() { return (0x2 & __hazzerBits) != 0; } |
| |
| @Override public final boolean equals(Object obj) { |
| if (this == obj) { return true; } |
| if (!(obj instanceof PropertyRecord)) { return false; } |
| PropertyRecord other = (PropertyRecord) obj; |
| return __hazzerBits == other.__hazzerBits |
| && (!hasName() || equals(name, other.name)) |
| && (!hasValue() || value == other.value); |
| } |
| |
| @Override protected int computeHashCode() { |
| int result = hash(__hazzerBits); |
| if (hasName()) { |
| result = result * 31 + name.hashCode(); |
| } |
| if (hasValue()) { |
| result = result * 31 + hash(value); |
| } |
| return result; |
| } |
| |
| @Override public void toCompactString(TextBuilder builder) { |
| builder.append("<PropertyRecord:"); |
| if (hasName()) { |
| builder.append(" name=").append(name); |
| } |
| if (hasValue()) { |
| builder.append(" value=").append(value); |
| } |
| builder.append('>'); |
| } |
| |
| public static PropertyRecord parseFrom(byte[] data) throws ValidationException { |
| try { |
| return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClientProtocol.PropertyRecord(), data)); |
| } catch (InvalidProtocolBufferNanoException exception) { |
| throw new ValidationException(exception); |
| } catch (ValidationArgumentException exception) { |
| throw new ValidationException(exception.getMessage()); |
| } |
| } |
| |
| static PropertyRecord fromMessageNano(com.google.protos.ipc.invalidation.NanoClientProtocol.PropertyRecord message) { |
| if (message == null) { return null; } |
| return new PropertyRecord(message.name, |
| message.value); |
| } |
| |
| public byte[] toByteArray() { |
| return MessageNano.toByteArray(toMessageNano()); |
| } |
| |
| com.google.protos.ipc.invalidation.NanoClientProtocol.PropertyRecord toMessageNano() { |
| com.google.protos.ipc.invalidation.NanoClientProtocol.PropertyRecord msg = new com.google.protos.ipc.invalidation.NanoClientProtocol.PropertyRecord(); |
| msg.name = hasName() ? name : null; |
| msg.value = hasValue() ? value : null; |
| return msg; |
| } |
| } |
| |
| public static final class ServerHeader extends ProtoWrapper { |
| public static final class Builder { |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.ProtocolVersion protocolVersion; |
| public Bytes clientToken; |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationSummary registrationSummary; |
| public long serverTimeMs; |
| public String messageId; |
| public Builder(com.google.ipc.invalidation.ticl.proto.ClientProtocol.ProtocolVersion protocolVersion, |
| Bytes clientToken, |
| long serverTimeMs) { |
| this.protocolVersion = protocolVersion;this.clientToken = clientToken;this.serverTimeMs = serverTimeMs;} |
| |
| public ServerHeader build() { |
| return new ServerHeader(protocolVersion, clientToken, registrationSummary, serverTimeMs, messageId); |
| } |
| } |
| |
| public static ServerHeader create(com.google.ipc.invalidation.ticl.proto.ClientProtocol.ProtocolVersion protocolVersion, |
| Bytes clientToken, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationSummary registrationSummary, |
| long serverTimeMs, |
| String messageId) { |
| return new ServerHeader(protocolVersion, clientToken, registrationSummary, serverTimeMs, messageId); |
| } |
| |
| private final long __hazzerBits; |
| private final com.google.ipc.invalidation.ticl.proto.ClientProtocol.ProtocolVersion protocolVersion; |
| private final Bytes clientToken; |
| private final com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationSummary registrationSummary; |
| private final long serverTimeMs; |
| private final String messageId; |
| |
| private ServerHeader(com.google.ipc.invalidation.ticl.proto.ClientProtocol.ProtocolVersion protocolVersion, |
| Bytes clientToken, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationSummary registrationSummary, |
| Long serverTimeMs, |
| String messageId) throws ValidationArgumentException { |
| int hazzerBits = 0; |
| required("protocol_version", protocolVersion); |
| this.protocolVersion = protocolVersion; |
| required("client_token", clientToken); |
| nonEmpty("client_token", clientToken); |
| this.clientToken = clientToken; |
| this.registrationSummary = registrationSummary; |
| required("server_time_ms", serverTimeMs); |
| nonNegative("server_time_ms", serverTimeMs); |
| this.serverTimeMs = serverTimeMs; |
| if (messageId != null) { |
| hazzerBits |= 0x1; |
| nonEmpty("message_id", messageId); |
| this.messageId = messageId; |
| } else { |
| this.messageId = ""; |
| } |
| this.__hazzerBits = hazzerBits; |
| } |
| |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.ProtocolVersion getProtocolVersion() { return protocolVersion; } |
| |
| public Bytes getClientToken() { return clientToken; } |
| |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationSummary getNullableRegistrationSummary() { return registrationSummary; } |
| |
| public long getServerTimeMs() { return serverTimeMs; } |
| |
| public String getMessageId() { return messageId; } |
| public boolean hasMessageId() { return (0x1 & __hazzerBits) != 0; } |
| |
| public Builder toBuilder() { |
| Builder builder = new Builder(protocolVersion, clientToken, serverTimeMs); |
| if (this.registrationSummary != null) { |
| builder.registrationSummary = registrationSummary; |
| } |
| if (hasMessageId()) { |
| builder.messageId = messageId; |
| } |
| return builder; |
| } |
| |
| @Override public final boolean equals(Object obj) { |
| if (this == obj) { return true; } |
| if (!(obj instanceof ServerHeader)) { return false; } |
| ServerHeader other = (ServerHeader) obj; |
| return __hazzerBits == other.__hazzerBits |
| && equals(protocolVersion, other.protocolVersion) |
| && equals(clientToken, other.clientToken) |
| && equals(registrationSummary, other.registrationSummary) |
| && serverTimeMs == other.serverTimeMs |
| && (!hasMessageId() || equals(messageId, other.messageId)); |
| } |
| |
| @Override protected int computeHashCode() { |
| int result = hash(__hazzerBits); |
| result = result * 31 + protocolVersion.hashCode(); |
| result = result * 31 + clientToken.hashCode(); |
| if (registrationSummary != null) { |
| result = result * 31 + registrationSummary.hashCode(); |
| } |
| result = result * 31 + hash(serverTimeMs); |
| if (hasMessageId()) { |
| result = result * 31 + messageId.hashCode(); |
| } |
| return result; |
| } |
| |
| @Override public void toCompactString(TextBuilder builder) { |
| builder.append("<ServerHeader:"); |
| builder.append(" protocol_version=").append(protocolVersion); |
| builder.append(" client_token=").append(clientToken); |
| if (registrationSummary != null) { |
| builder.append(" registration_summary=").append(registrationSummary); |
| } |
| builder.append(" server_time_ms=").append(serverTimeMs); |
| if (hasMessageId()) { |
| builder.append(" message_id=").append(messageId); |
| } |
| builder.append('>'); |
| } |
| |
| public static ServerHeader parseFrom(byte[] data) throws ValidationException { |
| try { |
| return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClientProtocol.ServerHeader(), data)); |
| } catch (InvalidProtocolBufferNanoException exception) { |
| throw new ValidationException(exception); |
| } catch (ValidationArgumentException exception) { |
| throw new ValidationException(exception.getMessage()); |
| } |
| } |
| |
| static ServerHeader fromMessageNano(com.google.protos.ipc.invalidation.NanoClientProtocol.ServerHeader message) { |
| if (message == null) { return null; } |
| return new ServerHeader(com.google.ipc.invalidation.ticl.proto.ClientProtocol.ProtocolVersion.fromMessageNano(message.protocolVersion), |
| Bytes.fromByteArray(message.clientToken), |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationSummary.fromMessageNano(message.registrationSummary), |
| message.serverTimeMs, |
| message.messageId); |
| } |
| |
| public byte[] toByteArray() { |
| return MessageNano.toByteArray(toMessageNano()); |
| } |
| |
| com.google.protos.ipc.invalidation.NanoClientProtocol.ServerHeader toMessageNano() { |
| com.google.protos.ipc.invalidation.NanoClientProtocol.ServerHeader msg = new com.google.protos.ipc.invalidation.NanoClientProtocol.ServerHeader(); |
| msg.protocolVersion = protocolVersion.toMessageNano(); |
| msg.clientToken = clientToken.getByteArray(); |
| msg.registrationSummary = this.registrationSummary != null ? registrationSummary.toMessageNano() : null; |
| msg.serverTimeMs = serverTimeMs; |
| msg.messageId = hasMessageId() ? messageId : null; |
| return msg; |
| } |
| } |
| |
| public static final class ServerToClientMessage extends ProtoWrapper { |
| public static final class Builder { |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.ServerHeader header; |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.TokenControlMessage tokenControlMessage; |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.InvalidationMessage invalidationMessage; |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationStatusMessage registrationStatusMessage; |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationSyncRequestMessage registrationSyncRequestMessage; |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.ConfigChangeMessage configChangeMessage; |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.InfoRequestMessage infoRequestMessage; |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.ErrorMessage errorMessage; |
| public Builder(com.google.ipc.invalidation.ticl.proto.ClientProtocol.ServerHeader header) { |
| this.header = header;} |
| |
| public ServerToClientMessage build() { |
| return new ServerToClientMessage(header, tokenControlMessage, invalidationMessage, registrationStatusMessage, registrationSyncRequestMessage, configChangeMessage, infoRequestMessage, errorMessage); |
| } |
| } |
| |
| public static ServerToClientMessage create(com.google.ipc.invalidation.ticl.proto.ClientProtocol.ServerHeader header, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.TokenControlMessage tokenControlMessage, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.InvalidationMessage invalidationMessage, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationStatusMessage registrationStatusMessage, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationSyncRequestMessage registrationSyncRequestMessage, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.ConfigChangeMessage configChangeMessage, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.InfoRequestMessage infoRequestMessage, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.ErrorMessage errorMessage) { |
| return new ServerToClientMessage(header, tokenControlMessage, invalidationMessage, registrationStatusMessage, registrationSyncRequestMessage, configChangeMessage, infoRequestMessage, errorMessage); |
| } |
| |
| private final long __hazzerBits; |
| private final com.google.ipc.invalidation.ticl.proto.ClientProtocol.ServerHeader header; |
| private final com.google.ipc.invalidation.ticl.proto.ClientProtocol.TokenControlMessage tokenControlMessage; |
| private final com.google.ipc.invalidation.ticl.proto.ClientProtocol.InvalidationMessage invalidationMessage; |
| private final com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationStatusMessage registrationStatusMessage; |
| private final com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationSyncRequestMessage registrationSyncRequestMessage; |
| private final com.google.ipc.invalidation.ticl.proto.ClientProtocol.ConfigChangeMessage configChangeMessage; |
| private final com.google.ipc.invalidation.ticl.proto.ClientProtocol.InfoRequestMessage infoRequestMessage; |
| private final com.google.ipc.invalidation.ticl.proto.ClientProtocol.ErrorMessage errorMessage; |
| |
| private ServerToClientMessage(com.google.ipc.invalidation.ticl.proto.ClientProtocol.ServerHeader header, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.TokenControlMessage tokenControlMessage, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.InvalidationMessage invalidationMessage, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationStatusMessage registrationStatusMessage, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationSyncRequestMessage registrationSyncRequestMessage, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.ConfigChangeMessage configChangeMessage, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.InfoRequestMessage infoRequestMessage, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.ErrorMessage errorMessage) throws ValidationArgumentException { |
| int hazzerBits = 0; |
| required("header", header); |
| this.header = header; |
| if (tokenControlMessage != null) { |
| hazzerBits |= 0x1; |
| this.tokenControlMessage = tokenControlMessage; |
| } else { |
| this.tokenControlMessage = com.google.ipc.invalidation.ticl.proto.ClientProtocol.TokenControlMessage.DEFAULT_INSTANCE; |
| } |
| this.invalidationMessage = invalidationMessage; |
| this.registrationStatusMessage = registrationStatusMessage; |
| if (registrationSyncRequestMessage != null) { |
| hazzerBits |= 0x2; |
| this.registrationSyncRequestMessage = registrationSyncRequestMessage; |
| } else { |
| this.registrationSyncRequestMessage = com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationSyncRequestMessage.DEFAULT_INSTANCE; |
| } |
| if (configChangeMessage != null) { |
| hazzerBits |= 0x4; |
| this.configChangeMessage = configChangeMessage; |
| } else { |
| this.configChangeMessage = com.google.ipc.invalidation.ticl.proto.ClientProtocol.ConfigChangeMessage.DEFAULT_INSTANCE; |
| } |
| this.infoRequestMessage = infoRequestMessage; |
| this.errorMessage = errorMessage; |
| this.__hazzerBits = hazzerBits; |
| } |
| |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.ServerHeader getHeader() { return header; } |
| |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.TokenControlMessage getTokenControlMessage() { return tokenControlMessage; } |
| public boolean hasTokenControlMessage() { return (0x1 & __hazzerBits) != 0; } |
| |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.InvalidationMessage getNullableInvalidationMessage() { return invalidationMessage; } |
| |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationStatusMessage getNullableRegistrationStatusMessage() { return registrationStatusMessage; } |
| |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationSyncRequestMessage getRegistrationSyncRequestMessage() { return registrationSyncRequestMessage; } |
| public boolean hasRegistrationSyncRequestMessage() { return (0x2 & __hazzerBits) != 0; } |
| |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.ConfigChangeMessage getConfigChangeMessage() { return configChangeMessage; } |
| public boolean hasConfigChangeMessage() { return (0x4 & __hazzerBits) != 0; } |
| |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.InfoRequestMessage getNullableInfoRequestMessage() { return infoRequestMessage; } |
| |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.ErrorMessage getNullableErrorMessage() { return errorMessage; } |
| |
| public Builder toBuilder() { |
| Builder builder = new Builder(header); |
| if (hasTokenControlMessage()) { |
| builder.tokenControlMessage = tokenControlMessage; |
| } |
| if (this.invalidationMessage != null) { |
| builder.invalidationMessage = invalidationMessage; |
| } |
| if (this.registrationStatusMessage != null) { |
| builder.registrationStatusMessage = registrationStatusMessage; |
| } |
| if (hasRegistrationSyncRequestMessage()) { |
| builder.registrationSyncRequestMessage = registrationSyncRequestMessage; |
| } |
| if (hasConfigChangeMessage()) { |
| builder.configChangeMessage = configChangeMessage; |
| } |
| if (this.infoRequestMessage != null) { |
| builder.infoRequestMessage = infoRequestMessage; |
| } |
| if (this.errorMessage != null) { |
| builder.errorMessage = errorMessage; |
| } |
| return builder; |
| } |
| |
| @Override public final boolean equals(Object obj) { |
| if (this == obj) { return true; } |
| if (!(obj instanceof ServerToClientMessage)) { return false; } |
| ServerToClientMessage other = (ServerToClientMessage) obj; |
| return __hazzerBits == other.__hazzerBits |
| && equals(header, other.header) |
| && (!hasTokenControlMessage() || equals(tokenControlMessage, other.tokenControlMessage)) |
| && equals(invalidationMessage, other.invalidationMessage) |
| && equals(registrationStatusMessage, other.registrationStatusMessage) |
| && (!hasRegistrationSyncRequestMessage() || equals(registrationSyncRequestMessage, other.registrationSyncRequestMessage)) |
| && (!hasConfigChangeMessage() || equals(configChangeMessage, other.configChangeMessage)) |
| && equals(infoRequestMessage, other.infoRequestMessage) |
| && equals(errorMessage, other.errorMessage); |
| } |
| |
| @Override protected int computeHashCode() { |
| int result = hash(__hazzerBits); |
| result = result * 31 + header.hashCode(); |
| if (hasTokenControlMessage()) { |
| result = result * 31 + tokenControlMessage.hashCode(); |
| } |
| if (invalidationMessage != null) { |
| result = result * 31 + invalidationMessage.hashCode(); |
| } |
| if (registrationStatusMessage != null) { |
| result = result * 31 + registrationStatusMessage.hashCode(); |
| } |
| if (hasRegistrationSyncRequestMessage()) { |
| result = result * 31 + registrationSyncRequestMessage.hashCode(); |
| } |
| if (hasConfigChangeMessage()) { |
| result = result * 31 + configChangeMessage.hashCode(); |
| } |
| if (infoRequestMessage != null) { |
| result = result * 31 + infoRequestMessage.hashCode(); |
| } |
| if (errorMessage != null) { |
| result = result * 31 + errorMessage.hashCode(); |
| } |
| return result; |
| } |
| |
| @Override public void toCompactString(TextBuilder builder) { |
| builder.append("<ServerToClientMessage:"); |
| builder.append(" header=").append(header); |
| if (hasTokenControlMessage()) { |
| builder.append(" token_control_message=").append(tokenControlMessage); |
| } |
| if (invalidationMessage != null) { |
| builder.append(" invalidation_message=").append(invalidationMessage); |
| } |
| if (registrationStatusMessage != null) { |
| builder.append(" registration_status_message=").append(registrationStatusMessage); |
| } |
| if (hasRegistrationSyncRequestMessage()) { |
| builder.append(" registration_sync_request_message=").append(registrationSyncRequestMessage); |
| } |
| if (hasConfigChangeMessage()) { |
| builder.append(" config_change_message=").append(configChangeMessage); |
| } |
| if (infoRequestMessage != null) { |
| builder.append(" info_request_message=").append(infoRequestMessage); |
| } |
| if (errorMessage != null) { |
| builder.append(" error_message=").append(errorMessage); |
| } |
| builder.append('>'); |
| } |
| |
| public static ServerToClientMessage parseFrom(byte[] data) throws ValidationException { |
| try { |
| return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClientProtocol.ServerToClientMessage(), data)); |
| } catch (InvalidProtocolBufferNanoException exception) { |
| throw new ValidationException(exception); |
| } catch (ValidationArgumentException exception) { |
| throw new ValidationException(exception.getMessage()); |
| } |
| } |
| |
| static ServerToClientMessage fromMessageNano(com.google.protos.ipc.invalidation.NanoClientProtocol.ServerToClientMessage message) { |
| if (message == null) { return null; } |
| return new ServerToClientMessage(com.google.ipc.invalidation.ticl.proto.ClientProtocol.ServerHeader.fromMessageNano(message.header), |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.TokenControlMessage.fromMessageNano(message.tokenControlMessage), |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.InvalidationMessage.fromMessageNano(message.invalidationMessage), |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationStatusMessage.fromMessageNano(message.registrationStatusMessage), |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationSyncRequestMessage.fromMessageNano(message.registrationSyncRequestMessage), |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.ConfigChangeMessage.fromMessageNano(message.configChangeMessage), |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.InfoRequestMessage.fromMessageNano(message.infoRequestMessage), |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.ErrorMessage.fromMessageNano(message.errorMessage)); |
| } |
| |
| public byte[] toByteArray() { |
| return MessageNano.toByteArray(toMessageNano()); |
| } |
| |
| com.google.protos.ipc.invalidation.NanoClientProtocol.ServerToClientMessage toMessageNano() { |
| com.google.protos.ipc.invalidation.NanoClientProtocol.ServerToClientMessage msg = new com.google.protos.ipc.invalidation.NanoClientProtocol.ServerToClientMessage(); |
| msg.header = header.toMessageNano(); |
| msg.tokenControlMessage = hasTokenControlMessage() ? tokenControlMessage.toMessageNano() : null; |
| msg.invalidationMessage = this.invalidationMessage != null ? invalidationMessage.toMessageNano() : null; |
| msg.registrationStatusMessage = this.registrationStatusMessage != null ? registrationStatusMessage.toMessageNano() : null; |
| msg.registrationSyncRequestMessage = hasRegistrationSyncRequestMessage() ? registrationSyncRequestMessage.toMessageNano() : null; |
| msg.configChangeMessage = hasConfigChangeMessage() ? configChangeMessage.toMessageNano() : null; |
| msg.infoRequestMessage = this.infoRequestMessage != null ? infoRequestMessage.toMessageNano() : null; |
| msg.errorMessage = this.errorMessage != null ? errorMessage.toMessageNano() : null; |
| return msg; |
| } |
| } |
| |
| public static final class TokenControlMessage extends ProtoWrapper { |
| public static TokenControlMessage create(Bytes newToken) { |
| return new TokenControlMessage(newToken); |
| } |
| |
| public static final TokenControlMessage DEFAULT_INSTANCE = new TokenControlMessage(null); |
| |
| private final long __hazzerBits; |
| private final Bytes newToken; |
| |
| private TokenControlMessage(Bytes newToken) { |
| int hazzerBits = 0; |
| if (newToken != null) { |
| hazzerBits |= 0x1; |
| this.newToken = newToken; |
| } else { |
| this.newToken = Bytes.EMPTY_BYTES; |
| } |
| this.__hazzerBits = hazzerBits; |
| } |
| |
| public Bytes getNewToken() { return newToken; } |
| public boolean hasNewToken() { return (0x1 & __hazzerBits) != 0; } |
| |
| @Override public final boolean equals(Object obj) { |
| if (this == obj) { return true; } |
| if (!(obj instanceof TokenControlMessage)) { return false; } |
| TokenControlMessage other = (TokenControlMessage) obj; |
| return __hazzerBits == other.__hazzerBits |
| && (!hasNewToken() || equals(newToken, other.newToken)); |
| } |
| |
| @Override protected int computeHashCode() { |
| int result = hash(__hazzerBits); |
| if (hasNewToken()) { |
| result = result * 31 + newToken.hashCode(); |
| } |
| return result; |
| } |
| |
| @Override public void toCompactString(TextBuilder builder) { |
| builder.append("<TokenControlMessage:"); |
| if (hasNewToken()) { |
| builder.append(" new_token=").append(newToken); |
| } |
| builder.append('>'); |
| } |
| |
| public static TokenControlMessage parseFrom(byte[] data) throws ValidationException { |
| try { |
| return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClientProtocol.TokenControlMessage(), data)); |
| } catch (InvalidProtocolBufferNanoException exception) { |
| throw new ValidationException(exception); |
| } catch (ValidationArgumentException exception) { |
| throw new ValidationException(exception.getMessage()); |
| } |
| } |
| |
| static TokenControlMessage fromMessageNano(com.google.protos.ipc.invalidation.NanoClientProtocol.TokenControlMessage message) { |
| if (message == null) { return null; } |
| return new TokenControlMessage(Bytes.fromByteArray(message.newToken)); |
| } |
| |
| public byte[] toByteArray() { |
| return MessageNano.toByteArray(toMessageNano()); |
| } |
| |
| com.google.protos.ipc.invalidation.NanoClientProtocol.TokenControlMessage toMessageNano() { |
| com.google.protos.ipc.invalidation.NanoClientProtocol.TokenControlMessage msg = new com.google.protos.ipc.invalidation.NanoClientProtocol.TokenControlMessage(); |
| msg.newToken = hasNewToken() ? newToken.getByteArray() : null; |
| return msg; |
| } |
| } |
| |
| public static final class RegistrationStatus extends ProtoWrapper { |
| public static RegistrationStatus create(com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationP registration, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.StatusP status) { |
| return new RegistrationStatus(registration, status); |
| } |
| |
| private final com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationP registration; |
| private final com.google.ipc.invalidation.ticl.proto.ClientProtocol.StatusP status; |
| |
| private RegistrationStatus(com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationP registration, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.StatusP status) throws ValidationArgumentException { |
| required("registration", registration); |
| this.registration = registration; |
| required("status", status); |
| this.status = status; |
| } |
| |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationP getRegistration() { return registration; } |
| |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.StatusP getStatus() { return status; } |
| |
| @Override public final boolean equals(Object obj) { |
| if (this == obj) { return true; } |
| if (!(obj instanceof RegistrationStatus)) { return false; } |
| RegistrationStatus other = (RegistrationStatus) obj; |
| return equals(registration, other.registration) |
| && equals(status, other.status); |
| } |
| |
| @Override protected int computeHashCode() { |
| int result = 1; |
| result = result * 31 + registration.hashCode(); |
| result = result * 31 + status.hashCode(); |
| return result; |
| } |
| |
| @Override public void toCompactString(TextBuilder builder) { |
| builder.append("<RegistrationStatus:"); |
| builder.append(" registration=").append(registration); |
| builder.append(" status=").append(status); |
| builder.append('>'); |
| } |
| |
| public static RegistrationStatus parseFrom(byte[] data) throws ValidationException { |
| try { |
| return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationStatus(), data)); |
| } catch (InvalidProtocolBufferNanoException exception) { |
| throw new ValidationException(exception); |
| } catch (ValidationArgumentException exception) { |
| throw new ValidationException(exception.getMessage()); |
| } |
| } |
| |
| static RegistrationStatus fromMessageNano(com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationStatus message) { |
| if (message == null) { return null; } |
| return new RegistrationStatus(com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationP.fromMessageNano(message.registration), |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.StatusP.fromMessageNano(message.status)); |
| } |
| |
| public byte[] toByteArray() { |
| return MessageNano.toByteArray(toMessageNano()); |
| } |
| |
| com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationStatus toMessageNano() { |
| com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationStatus msg = new com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationStatus(); |
| msg.registration = registration.toMessageNano(); |
| msg.status = status.toMessageNano(); |
| return msg; |
| } |
| } |
| |
| public static final class RegistrationStatusMessage extends ProtoWrapper { |
| public static RegistrationStatusMessage create(Collection<com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationStatus> registrationStatus) { |
| return new RegistrationStatusMessage(registrationStatus); |
| } |
| |
| private final List<com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationStatus> registrationStatus; |
| |
| private RegistrationStatusMessage(Collection<com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationStatus> registrationStatus) throws ValidationArgumentException { |
| this.registrationStatus = required("registration_status", registrationStatus); |
| } |
| |
| public List<com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationStatus> getRegistrationStatus() { return registrationStatus; } |
| |
| @Override public final boolean equals(Object obj) { |
| if (this == obj) { return true; } |
| if (!(obj instanceof RegistrationStatusMessage)) { return false; } |
| RegistrationStatusMessage other = (RegistrationStatusMessage) obj; |
| return equals(registrationStatus, other.registrationStatus); |
| } |
| |
| @Override protected int computeHashCode() { |
| int result = 1; |
| result = result * 31 + registrationStatus.hashCode(); |
| return result; |
| } |
| |
| @Override public void toCompactString(TextBuilder builder) { |
| builder.append("<RegistrationStatusMessage:"); |
| builder.append(" registration_status=[").append(registrationStatus).append(']'); |
| builder.append('>'); |
| } |
| |
| public static RegistrationStatusMessage parseFrom(byte[] data) throws ValidationException { |
| try { |
| return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationStatusMessage(), data)); |
| } catch (InvalidProtocolBufferNanoException exception) { |
| throw new ValidationException(exception); |
| } catch (ValidationArgumentException exception) { |
| throw new ValidationException(exception.getMessage()); |
| } |
| } |
| |
| static RegistrationStatusMessage fromMessageNano(com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationStatusMessage message) { |
| if (message == null) { return null; } |
| List<com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationStatus> registrationStatus = new ArrayList<com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationStatus>(message.registrationStatus.length); |
| for (int i = 0; i < message.registrationStatus.length; i++) { |
| registrationStatus.add(com.google.ipc.invalidation.ticl.proto.ClientProtocol.RegistrationStatus.fromMessageNano(message.registrationStatus[i])); |
| } |
| return new RegistrationStatusMessage(registrationStatus); |
| } |
| |
| public byte[] toByteArray() { |
| return MessageNano.toByteArray(toMessageNano()); |
| } |
| |
| com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationStatusMessage toMessageNano() { |
| com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationStatusMessage msg = new com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationStatusMessage(); |
| msg.registrationStatus = new com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationStatus[registrationStatus.size()]; |
| for (int i = 0; i < msg.registrationStatus.length; i++) { |
| msg.registrationStatus[i] = registrationStatus.get(i).toMessageNano(); |
| } |
| return msg; |
| } |
| } |
| |
| public static final class RegistrationSyncRequestMessage extends ProtoWrapper { |
| public static RegistrationSyncRequestMessage create() { |
| return new RegistrationSyncRequestMessage(); |
| } |
| |
| public static final RegistrationSyncRequestMessage DEFAULT_INSTANCE = new RegistrationSyncRequestMessage(); |
| |
| |
| private RegistrationSyncRequestMessage() { |
| } |
| |
| |
| @Override public final boolean equals(Object obj) { |
| if (this == obj) { return true; } |
| if (!(obj instanceof RegistrationSyncRequestMessage)) { return false; } |
| RegistrationSyncRequestMessage other = (RegistrationSyncRequestMessage) obj; |
| return true; |
| } |
| |
| @Override protected int computeHashCode() { |
| int result = 1; |
| return result; |
| } |
| |
| @Override public void toCompactString(TextBuilder builder) { |
| builder.append("<RegistrationSyncRequestMessage:"); |
| builder.append('>'); |
| } |
| |
| public static RegistrationSyncRequestMessage parseFrom(byte[] data) throws ValidationException { |
| try { |
| return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationSyncRequestMessage(), data)); |
| } catch (InvalidProtocolBufferNanoException exception) { |
| throw new ValidationException(exception); |
| } catch (ValidationArgumentException exception) { |
| throw new ValidationException(exception.getMessage()); |
| } |
| } |
| |
| static RegistrationSyncRequestMessage fromMessageNano(com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationSyncRequestMessage message) { |
| if (message == null) { return null; } |
| return new RegistrationSyncRequestMessage(); |
| } |
| |
| public byte[] toByteArray() { |
| return MessageNano.toByteArray(toMessageNano()); |
| } |
| |
| com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationSyncRequestMessage toMessageNano() { |
| com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationSyncRequestMessage msg = new com.google.protos.ipc.invalidation.NanoClientProtocol.RegistrationSyncRequestMessage(); |
| return msg; |
| } |
| } |
| |
| public static final class InvalidationMessage extends ProtoWrapper { |
| public static InvalidationMessage create(Collection<com.google.ipc.invalidation.ticl.proto.ClientProtocol.InvalidationP> invalidation) { |
| return new InvalidationMessage(invalidation); |
| } |
| |
| private final List<com.google.ipc.invalidation.ticl.proto.ClientProtocol.InvalidationP> invalidation; |
| |
| private InvalidationMessage(Collection<com.google.ipc.invalidation.ticl.proto.ClientProtocol.InvalidationP> invalidation) throws ValidationArgumentException { |
| this.invalidation = required("invalidation", invalidation); |
| } |
| |
| public List<com.google.ipc.invalidation.ticl.proto.ClientProtocol.InvalidationP> getInvalidation() { return invalidation; } |
| |
| @Override public final boolean equals(Object obj) { |
| if (this == obj) { return true; } |
| if (!(obj instanceof InvalidationMessage)) { return false; } |
| InvalidationMessage other = (InvalidationMessage) obj; |
| return equals(invalidation, other.invalidation); |
| } |
| |
| @Override protected int computeHashCode() { |
| int result = 1; |
| result = result * 31 + invalidation.hashCode(); |
| return result; |
| } |
| |
| @Override public void toCompactString(TextBuilder builder) { |
| builder.append("<InvalidationMessage:"); |
| builder.append(" invalidation=[").append(invalidation).append(']'); |
| builder.append('>'); |
| } |
| |
| public static InvalidationMessage parseFrom(byte[] data) throws ValidationException { |
| try { |
| return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClientProtocol.InvalidationMessage(), data)); |
| } catch (InvalidProtocolBufferNanoException exception) { |
| throw new ValidationException(exception); |
| } catch (ValidationArgumentException exception) { |
| throw new ValidationException(exception.getMessage()); |
| } |
| } |
| |
| static InvalidationMessage fromMessageNano(com.google.protos.ipc.invalidation.NanoClientProtocol.InvalidationMessage message) { |
| if (message == null) { return null; } |
| List<com.google.ipc.invalidation.ticl.proto.ClientProtocol.InvalidationP> invalidation = new ArrayList<com.google.ipc.invalidation.ticl.proto.ClientProtocol.InvalidationP>(message.invalidation.length); |
| for (int i = 0; i < message.invalidation.length; i++) { |
| invalidation.add(com.google.ipc.invalidation.ticl.proto.ClientProtocol.InvalidationP.fromMessageNano(message.invalidation[i])); |
| } |
| return new InvalidationMessage(invalidation); |
| } |
| |
| public byte[] toByteArray() { |
| return MessageNano.toByteArray(toMessageNano()); |
| } |
| |
| com.google.protos.ipc.invalidation.NanoClientProtocol.InvalidationMessage toMessageNano() { |
| com.google.protos.ipc.invalidation.NanoClientProtocol.InvalidationMessage msg = new com.google.protos.ipc.invalidation.NanoClientProtocol.InvalidationMessage(); |
| msg.invalidation = new com.google.protos.ipc.invalidation.NanoClientProtocol.InvalidationP[invalidation.size()]; |
| for (int i = 0; i < msg.invalidation.length; i++) { |
| msg.invalidation[i] = invalidation.get(i).toMessageNano(); |
| } |
| return msg; |
| } |
| } |
| |
| public static final class InfoRequestMessage extends ProtoWrapper { |
| public interface InfoType { |
| public static final int GET_PERFORMANCE_COUNTERS = 1; |
| } |
| |
| public static InfoRequestMessage create(Collection<Integer> infoType) { |
| return new InfoRequestMessage(infoType); |
| } |
| |
| private final List<Integer> infoType; |
| |
| private InfoRequestMessage(Collection<Integer> infoType) throws ValidationArgumentException { |
| this.infoType = required("info_type", infoType); |
| } |
| |
| public List<Integer> getInfoType() { return infoType; } |
| |
| @Override public final boolean equals(Object obj) { |
| if (this == obj) { return true; } |
| if (!(obj instanceof InfoRequestMessage)) { return false; } |
| InfoRequestMessage other = (InfoRequestMessage) obj; |
| return equals(infoType, other.infoType); |
| } |
| |
| @Override protected int computeHashCode() { |
| int result = 1; |
| result = result * 31 + infoType.hashCode(); |
| return result; |
| } |
| |
| @Override public void toCompactString(TextBuilder builder) { |
| builder.append("<InfoRequestMessage:"); |
| builder.append(" info_type=[").append(infoType).append(']'); |
| builder.append('>'); |
| } |
| |
| public static InfoRequestMessage parseFrom(byte[] data) throws ValidationException { |
| try { |
| return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClientProtocol.InfoRequestMessage(), data)); |
| } catch (InvalidProtocolBufferNanoException exception) { |
| throw new ValidationException(exception); |
| } catch (ValidationArgumentException exception) { |
| throw new ValidationException(exception.getMessage()); |
| } |
| } |
| |
| static InfoRequestMessage fromMessageNano(com.google.protos.ipc.invalidation.NanoClientProtocol.InfoRequestMessage message) { |
| if (message == null) { return null; } |
| List<Integer> infoType = new ArrayList<Integer>(message.infoType.length); |
| for (int i = 0; i < message.infoType.length; i++) { |
| infoType.add(message.infoType[i]); |
| } |
| return new InfoRequestMessage(infoType); |
| } |
| |
| public byte[] toByteArray() { |
| return MessageNano.toByteArray(toMessageNano()); |
| } |
| |
| com.google.protos.ipc.invalidation.NanoClientProtocol.InfoRequestMessage toMessageNano() { |
| com.google.protos.ipc.invalidation.NanoClientProtocol.InfoRequestMessage msg = new com.google.protos.ipc.invalidation.NanoClientProtocol.InfoRequestMessage(); |
| msg.infoType = new int[infoType.size()]; |
| for (int i = 0; i < msg.infoType.length; i++) { |
| msg.infoType[i] = infoType.get(i); |
| } |
| return msg; |
| } |
| } |
| |
| public static final class RateLimitP extends ProtoWrapper { |
| public static RateLimitP create(int windowMs, |
| int count) { |
| return new RateLimitP(windowMs, count); |
| } |
| |
| private final int windowMs; |
| private final int count; |
| |
| private RateLimitP(Integer windowMs, |
| Integer count) throws ValidationArgumentException { |
| required("window_ms", windowMs); |
| this.windowMs = windowMs; |
| required("count", count); |
| this.count = count; |
| check(windowMs >= 1000 && windowMs > count, "Invalid window_ms and count"); |
| } |
| |
| public int getWindowMs() { return windowMs; } |
| |
| public int getCount() { return count; } |
| |
| @Override public final boolean equals(Object obj) { |
| if (this == obj) { return true; } |
| if (!(obj instanceof RateLimitP)) { return false; } |
| RateLimitP other = (RateLimitP) obj; |
| return windowMs == other.windowMs |
| && count == other.count; |
| } |
| |
| @Override protected int computeHashCode() { |
| int result = 1; |
| result = result * 31 + hash(windowMs); |
| result = result * 31 + hash(count); |
| return result; |
| } |
| |
| @Override public void toCompactString(TextBuilder builder) { |
| builder.append("<RateLimitP:"); |
| builder.append(" window_ms=").append(windowMs); |
| builder.append(" count=").append(count); |
| builder.append('>'); |
| } |
| |
| public static RateLimitP parseFrom(byte[] data) throws ValidationException { |
| try { |
| return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClientProtocol.RateLimitP(), data)); |
| } catch (InvalidProtocolBufferNanoException exception) { |
| throw new ValidationException(exception); |
| } catch (ValidationArgumentException exception) { |
| throw new ValidationException(exception.getMessage()); |
| } |
| } |
| |
| static RateLimitP fromMessageNano(com.google.protos.ipc.invalidation.NanoClientProtocol.RateLimitP message) { |
| if (message == null) { return null; } |
| return new RateLimitP(message.windowMs, |
| message.count); |
| } |
| |
| public byte[] toByteArray() { |
| return MessageNano.toByteArray(toMessageNano()); |
| } |
| |
| com.google.protos.ipc.invalidation.NanoClientProtocol.RateLimitP toMessageNano() { |
| com.google.protos.ipc.invalidation.NanoClientProtocol.RateLimitP msg = new com.google.protos.ipc.invalidation.NanoClientProtocol.RateLimitP(); |
| msg.windowMs = windowMs; |
| msg.count = count; |
| return msg; |
| } |
| } |
| |
| public static final class ProtocolHandlerConfigP extends ProtoWrapper { |
| public static final class Builder { |
| public Integer batchingDelayMs; |
| public Collection<com.google.ipc.invalidation.ticl.proto.ClientProtocol.RateLimitP> rateLimit; |
| public Builder() { |
| } |
| |
| public ProtocolHandlerConfigP build() { |
| return new ProtocolHandlerConfigP(batchingDelayMs, rateLimit); |
| } |
| } |
| |
| public static ProtocolHandlerConfigP create(Integer batchingDelayMs, |
| Collection<com.google.ipc.invalidation.ticl.proto.ClientProtocol.RateLimitP> rateLimit) { |
| return new ProtocolHandlerConfigP(batchingDelayMs, rateLimit); |
| } |
| |
| public static final ProtocolHandlerConfigP DEFAULT_INSTANCE = new ProtocolHandlerConfigP(null, null); |
| |
| private final long __hazzerBits; |
| private final int batchingDelayMs; |
| private final List<com.google.ipc.invalidation.ticl.proto.ClientProtocol.RateLimitP> rateLimit; |
| |
| private ProtocolHandlerConfigP(Integer batchingDelayMs, |
| Collection<com.google.ipc.invalidation.ticl.proto.ClientProtocol.RateLimitP> rateLimit) { |
| int hazzerBits = 0; |
| if (batchingDelayMs != null) { |
| hazzerBits |= 0x1; |
| this.batchingDelayMs = batchingDelayMs; |
| } else { |
| this.batchingDelayMs = 500; |
| } |
| this.rateLimit = optional("rate_limit", rateLimit); |
| this.__hazzerBits = hazzerBits; |
| } |
| |
| public int getBatchingDelayMs() { return batchingDelayMs; } |
| public boolean hasBatchingDelayMs() { return (0x1 & __hazzerBits) != 0; } |
| |
| public List<com.google.ipc.invalidation.ticl.proto.ClientProtocol.RateLimitP> getRateLimit() { return rateLimit; } |
| |
| public Builder toBuilder() { |
| Builder builder = new Builder(); |
| if (hasBatchingDelayMs()) { |
| builder.batchingDelayMs = batchingDelayMs; |
| } |
| if (!this.rateLimit.isEmpty()) { |
| builder.rateLimit = rateLimit; |
| } |
| return builder; |
| } |
| |
| @Override public final boolean equals(Object obj) { |
| if (this == obj) { return true; } |
| if (!(obj instanceof ProtocolHandlerConfigP)) { return false; } |
| ProtocolHandlerConfigP other = (ProtocolHandlerConfigP) obj; |
| return __hazzerBits == other.__hazzerBits |
| && (!hasBatchingDelayMs() || batchingDelayMs == other.batchingDelayMs) |
| && equals(rateLimit, other.rateLimit); |
| } |
| |
| @Override protected int computeHashCode() { |
| int result = hash(__hazzerBits); |
| if (hasBatchingDelayMs()) { |
| result = result * 31 + hash(batchingDelayMs); |
| } |
| result = result * 31 + rateLimit.hashCode(); |
| return result; |
| } |
| |
| @Override public void toCompactString(TextBuilder builder) { |
| builder.append("<ProtocolHandlerConfigP:"); |
| if (hasBatchingDelayMs()) { |
| builder.append(" batching_delay_ms=").append(batchingDelayMs); |
| } |
| builder.append(" rate_limit=[").append(rateLimit).append(']'); |
| builder.append('>'); |
| } |
| |
| public static ProtocolHandlerConfigP parseFrom(byte[] data) throws ValidationException { |
| try { |
| return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClientProtocol.ProtocolHandlerConfigP(), data)); |
| } catch (InvalidProtocolBufferNanoException exception) { |
| throw new ValidationException(exception); |
| } catch (ValidationArgumentException exception) { |
| throw new ValidationException(exception.getMessage()); |
| } |
| } |
| |
| static ProtocolHandlerConfigP fromMessageNano(com.google.protos.ipc.invalidation.NanoClientProtocol.ProtocolHandlerConfigP message) { |
| if (message == null) { return null; } |
| List<com.google.ipc.invalidation.ticl.proto.ClientProtocol.RateLimitP> rateLimit = new ArrayList<com.google.ipc.invalidation.ticl.proto.ClientProtocol.RateLimitP>(message.rateLimit.length); |
| for (int i = 0; i < message.rateLimit.length; i++) { |
| rateLimit.add(com.google.ipc.invalidation.ticl.proto.ClientProtocol.RateLimitP.fromMessageNano(message.rateLimit[i])); |
| } |
| return new ProtocolHandlerConfigP(message.batchingDelayMs, |
| rateLimit); |
| } |
| |
| public byte[] toByteArray() { |
| return MessageNano.toByteArray(toMessageNano()); |
| } |
| |
| com.google.protos.ipc.invalidation.NanoClientProtocol.ProtocolHandlerConfigP toMessageNano() { |
| com.google.protos.ipc.invalidation.NanoClientProtocol.ProtocolHandlerConfigP msg = new com.google.protos.ipc.invalidation.NanoClientProtocol.ProtocolHandlerConfigP(); |
| msg.batchingDelayMs = hasBatchingDelayMs() ? batchingDelayMs : null; |
| msg.rateLimit = new com.google.protos.ipc.invalidation.NanoClientProtocol.RateLimitP[rateLimit.size()]; |
| for (int i = 0; i < msg.rateLimit.length; i++) { |
| msg.rateLimit[i] = rateLimit.get(i).toMessageNano(); |
| } |
| return msg; |
| } |
| } |
| |
| public static final class ClientConfigP extends ProtoWrapper { |
| public static final class Builder { |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.Version version; |
| public Integer networkTimeoutDelayMs; |
| public Integer writeRetryDelayMs; |
| public Integer heartbeatIntervalMs; |
| public Integer perfCounterDelayMs; |
| public Integer maxExponentialBackoffFactor; |
| public Integer smearPercent; |
| public Boolean isTransient; |
| public Integer initialPersistentHeartbeatDelayMs; |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.ProtocolHandlerConfigP protocolHandlerConfig; |
| public Boolean channelSupportsOfflineDelivery; |
| public Integer offlineHeartbeatThresholdMs; |
| public Boolean allowSuppression; |
| public Builder(com.google.ipc.invalidation.ticl.proto.ClientProtocol.Version version, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.ProtocolHandlerConfigP protocolHandlerConfig) { |
| this.version = version;this.protocolHandlerConfig = protocolHandlerConfig;} |
| |
| public ClientConfigP build() { |
| return new ClientConfigP(version, networkTimeoutDelayMs, writeRetryDelayMs, heartbeatIntervalMs, perfCounterDelayMs, maxExponentialBackoffFactor, smearPercent, isTransient, initialPersistentHeartbeatDelayMs, protocolHandlerConfig, channelSupportsOfflineDelivery, offlineHeartbeatThresholdMs, allowSuppression); |
| } |
| } |
| |
| public static ClientConfigP create(com.google.ipc.invalidation.ticl.proto.ClientProtocol.Version version, |
| Integer networkTimeoutDelayMs, |
| Integer writeRetryDelayMs, |
| Integer heartbeatIntervalMs, |
| Integer perfCounterDelayMs, |
| Integer maxExponentialBackoffFactor, |
| Integer smearPercent, |
| Boolean isTransient, |
| Integer initialPersistentHeartbeatDelayMs, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.ProtocolHandlerConfigP protocolHandlerConfig, |
| Boolean channelSupportsOfflineDelivery, |
| Integer offlineHeartbeatThresholdMs, |
| Boolean allowSuppression) { |
| return new ClientConfigP(version, networkTimeoutDelayMs, writeRetryDelayMs, heartbeatIntervalMs, perfCounterDelayMs, maxExponentialBackoffFactor, smearPercent, isTransient, initialPersistentHeartbeatDelayMs, protocolHandlerConfig, channelSupportsOfflineDelivery, offlineHeartbeatThresholdMs, allowSuppression); |
| } |
| |
| private final long __hazzerBits; |
| private final com.google.ipc.invalidation.ticl.proto.ClientProtocol.Version version; |
| private final int networkTimeoutDelayMs; |
| private final int writeRetryDelayMs; |
| private final int heartbeatIntervalMs; |
| private final int perfCounterDelayMs; |
| private final int maxExponentialBackoffFactor; |
| private final int smearPercent; |
| private final boolean isTransient; |
| private final int initialPersistentHeartbeatDelayMs; |
| private final com.google.ipc.invalidation.ticl.proto.ClientProtocol.ProtocolHandlerConfigP protocolHandlerConfig; |
| private final boolean channelSupportsOfflineDelivery; |
| private final int offlineHeartbeatThresholdMs; |
| private final boolean allowSuppression; |
| |
| private ClientConfigP(com.google.ipc.invalidation.ticl.proto.ClientProtocol.Version version, |
| Integer networkTimeoutDelayMs, |
| Integer writeRetryDelayMs, |
| Integer heartbeatIntervalMs, |
| Integer perfCounterDelayMs, |
| Integer maxExponentialBackoffFactor, |
| Integer smearPercent, |
| Boolean isTransient, |
| Integer initialPersistentHeartbeatDelayMs, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.ProtocolHandlerConfigP protocolHandlerConfig, |
| Boolean channelSupportsOfflineDelivery, |
| Integer offlineHeartbeatThresholdMs, |
| Boolean allowSuppression) throws ValidationArgumentException { |
| int hazzerBits = 0; |
| required("version", version); |
| this.version = version; |
| if (networkTimeoutDelayMs != null) { |
| hazzerBits |= 0x1; |
| this.networkTimeoutDelayMs = networkTimeoutDelayMs; |
| } else { |
| this.networkTimeoutDelayMs = 60000; |
| } |
| if (writeRetryDelayMs != null) { |
| hazzerBits |= 0x2; |
| this.writeRetryDelayMs = writeRetryDelayMs; |
| } else { |
| this.writeRetryDelayMs = 10000; |
| } |
| if (heartbeatIntervalMs != null) { |
| hazzerBits |= 0x4; |
| this.heartbeatIntervalMs = heartbeatIntervalMs; |
| } else { |
| this.heartbeatIntervalMs = 1200000; |
| } |
| if (perfCounterDelayMs != null) { |
| hazzerBits |= 0x8; |
| this.perfCounterDelayMs = perfCounterDelayMs; |
| } else { |
| this.perfCounterDelayMs = 21600000; |
| } |
| if (maxExponentialBackoffFactor != null) { |
| hazzerBits |= 0x10; |
| this.maxExponentialBackoffFactor = maxExponentialBackoffFactor; |
| } else { |
| this.maxExponentialBackoffFactor = 500; |
| } |
| if (smearPercent != null) { |
| hazzerBits |= 0x20; |
| this.smearPercent = smearPercent; |
| } else { |
| this.smearPercent = 20; |
| } |
| if (isTransient != null) { |
| hazzerBits |= 0x40; |
| this.isTransient = isTransient; |
| } else { |
| this.isTransient = false; |
| } |
| if (initialPersistentHeartbeatDelayMs != null) { |
| hazzerBits |= 0x80; |
| this.initialPersistentHeartbeatDelayMs = initialPersistentHeartbeatDelayMs; |
| } else { |
| this.initialPersistentHeartbeatDelayMs = 2000; |
| } |
| required("protocol_handler_config", protocolHandlerConfig); |
| this.protocolHandlerConfig = protocolHandlerConfig; |
| if (channelSupportsOfflineDelivery != null) { |
| hazzerBits |= 0x100; |
| this.channelSupportsOfflineDelivery = channelSupportsOfflineDelivery; |
| } else { |
| this.channelSupportsOfflineDelivery = false; |
| } |
| if (offlineHeartbeatThresholdMs != null) { |
| hazzerBits |= 0x200; |
| this.offlineHeartbeatThresholdMs = offlineHeartbeatThresholdMs; |
| } else { |
| this.offlineHeartbeatThresholdMs = 60000; |
| } |
| if (allowSuppression != null) { |
| hazzerBits |= 0x400; |
| this.allowSuppression = allowSuppression; |
| } else { |
| this.allowSuppression = true; |
| } |
| this.__hazzerBits = hazzerBits; |
| } |
| |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.Version getVersion() { return version; } |
| |
| public int getNetworkTimeoutDelayMs() { return networkTimeoutDelayMs; } |
| public boolean hasNetworkTimeoutDelayMs() { return (0x1 & __hazzerBits) != 0; } |
| |
| public int getWriteRetryDelayMs() { return writeRetryDelayMs; } |
| public boolean hasWriteRetryDelayMs() { return (0x2 & __hazzerBits) != 0; } |
| |
| public int getHeartbeatIntervalMs() { return heartbeatIntervalMs; } |
| public boolean hasHeartbeatIntervalMs() { return (0x4 & __hazzerBits) != 0; } |
| |
| public int getPerfCounterDelayMs() { return perfCounterDelayMs; } |
| public boolean hasPerfCounterDelayMs() { return (0x8 & __hazzerBits) != 0; } |
| |
| public int getMaxExponentialBackoffFactor() { return maxExponentialBackoffFactor; } |
| public boolean hasMaxExponentialBackoffFactor() { return (0x10 & __hazzerBits) != 0; } |
| |
| public int getSmearPercent() { return smearPercent; } |
| public boolean hasSmearPercent() { return (0x20 & __hazzerBits) != 0; } |
| |
| public boolean getIsTransient() { return isTransient; } |
| public boolean hasIsTransient() { return (0x40 & __hazzerBits) != 0; } |
| |
| public int getInitialPersistentHeartbeatDelayMs() { return initialPersistentHeartbeatDelayMs; } |
| public boolean hasInitialPersistentHeartbeatDelayMs() { return (0x80 & __hazzerBits) != 0; } |
| |
| public com.google.ipc.invalidation.ticl.proto.ClientProtocol.ProtocolHandlerConfigP getProtocolHandlerConfig() { return protocolHandlerConfig; } |
| |
| public boolean getChannelSupportsOfflineDelivery() { return channelSupportsOfflineDelivery; } |
| public boolean hasChannelSupportsOfflineDelivery() { return (0x100 & __hazzerBits) != 0; } |
| |
| public int getOfflineHeartbeatThresholdMs() { return offlineHeartbeatThresholdMs; } |
| public boolean hasOfflineHeartbeatThresholdMs() { return (0x200 & __hazzerBits) != 0; } |
| |
| public boolean getAllowSuppression() { return allowSuppression; } |
| public boolean hasAllowSuppression() { return (0x400 & __hazzerBits) != 0; } |
| |
| public Builder toBuilder() { |
| Builder builder = new Builder(version, protocolHandlerConfig); |
| if (hasNetworkTimeoutDelayMs()) { |
| builder.networkTimeoutDelayMs = networkTimeoutDelayMs; |
| } |
| if (hasWriteRetryDelayMs()) { |
| builder.writeRetryDelayMs = writeRetryDelayMs; |
| } |
| if (hasHeartbeatIntervalMs()) { |
| builder.heartbeatIntervalMs = heartbeatIntervalMs; |
| } |
| if (hasPerfCounterDelayMs()) { |
| builder.perfCounterDelayMs = perfCounterDelayMs; |
| } |
| if (hasMaxExponentialBackoffFactor()) { |
| builder.maxExponentialBackoffFactor = maxExponentialBackoffFactor; |
| } |
| if (hasSmearPercent()) { |
| builder.smearPercent = smearPercent; |
| } |
| if (hasIsTransient()) { |
| builder.isTransient = isTransient; |
| } |
| if (hasInitialPersistentHeartbeatDelayMs()) { |
| builder.initialPersistentHeartbeatDelayMs = initialPersistentHeartbeatDelayMs; |
| } |
| if (hasChannelSupportsOfflineDelivery()) { |
| builder.channelSupportsOfflineDelivery = channelSupportsOfflineDelivery; |
| } |
| if (hasOfflineHeartbeatThresholdMs()) { |
| builder.offlineHeartbeatThresholdMs = offlineHeartbeatThresholdMs; |
| } |
| if (hasAllowSuppression()) { |
| builder.allowSuppression = allowSuppression; |
| } |
| return builder; |
| } |
| |
| @Override public final boolean equals(Object obj) { |
| if (this == obj) { return true; } |
| if (!(obj instanceof ClientConfigP)) { return false; } |
| ClientConfigP other = (ClientConfigP) obj; |
| return __hazzerBits == other.__hazzerBits |
| && equals(version, other.version) |
| && (!hasNetworkTimeoutDelayMs() || networkTimeoutDelayMs == other.networkTimeoutDelayMs) |
| && (!hasWriteRetryDelayMs() || writeRetryDelayMs == other.writeRetryDelayMs) |
| && (!hasHeartbeatIntervalMs() || heartbeatIntervalMs == other.heartbeatIntervalMs) |
| && (!hasPerfCounterDelayMs() || perfCounterDelayMs == other.perfCounterDelayMs) |
| && (!hasMaxExponentialBackoffFactor() || maxExponentialBackoffFactor == other.maxExponentialBackoffFactor) |
| && (!hasSmearPercent() || smearPercent == other.smearPercent) |
| && (!hasIsTransient() || isTransient == other.isTransient) |
| && (!hasInitialPersistentHeartbeatDelayMs() || initialPersistentHeartbeatDelayMs == other.initialPersistentHeartbeatDelayMs) |
| && equals(protocolHandlerConfig, other.protocolHandlerConfig) |
| && (!hasChannelSupportsOfflineDelivery() || channelSupportsOfflineDelivery == other.channelSupportsOfflineDelivery) |
| && (!hasOfflineHeartbeatThresholdMs() || offlineHeartbeatThresholdMs == other.offlineHeartbeatThresholdMs) |
| && (!hasAllowSuppression() || allowSuppression == other.allowSuppression); |
| } |
| |
| @Override protected int computeHashCode() { |
| int result = hash(__hazzerBits); |
| result = result * 31 + version.hashCode(); |
| if (hasNetworkTimeoutDelayMs()) { |
| result = result * 31 + hash(networkTimeoutDelayMs); |
| } |
| if (hasWriteRetryDelayMs()) { |
| result = result * 31 + hash(writeRetryDelayMs); |
| } |
| if (hasHeartbeatIntervalMs()) { |
| result = result * 31 + hash(heartbeatIntervalMs); |
| } |
| if (hasPerfCounterDelayMs()) { |
| result = result * 31 + hash(perfCounterDelayMs); |
| } |
| if (hasMaxExponentialBackoffFactor()) { |
| result = result * 31 + hash(maxExponentialBackoffFactor); |
| } |
| if (hasSmearPercent()) { |
| result = result * 31 + hash(smearPercent); |
| } |
| if (hasIsTransient()) { |
| result = result * 31 + hash(isTransient); |
| } |
| if (hasInitialPersistentHeartbeatDelayMs()) { |
| result = result * 31 + hash(initialPersistentHeartbeatDelayMs); |
| } |
| result = result * 31 + protocolHandlerConfig.hashCode(); |
| if (hasChannelSupportsOfflineDelivery()) { |
| result = result * 31 + hash(channelSupportsOfflineDelivery); |
| } |
| if (hasOfflineHeartbeatThresholdMs()) { |
| result = result * 31 + hash(offlineHeartbeatThresholdMs); |
| } |
| if (hasAllowSuppression()) { |
| result = result * 31 + hash(allowSuppression); |
| } |
| return result; |
| } |
| |
| @Override public void toCompactString(TextBuilder builder) { |
| builder.append("<ClientConfigP:"); |
| builder.append(" version=").append(version); |
| if (hasNetworkTimeoutDelayMs()) { |
| builder.append(" network_timeout_delay_ms=").append(networkTimeoutDelayMs); |
| } |
| if (hasWriteRetryDelayMs()) { |
| builder.append(" write_retry_delay_ms=").append(writeRetryDelayMs); |
| } |
| if (hasHeartbeatIntervalMs()) { |
| builder.append(" heartbeat_interval_ms=").append(heartbeatIntervalMs); |
| } |
| if (hasPerfCounterDelayMs()) { |
| builder.append(" perf_counter_delay_ms=").append(perfCounterDelayMs); |
| } |
| if (hasMaxExponentialBackoffFactor()) { |
| builder.append(" max_exponential_backoff_factor=").append(maxExponentialBackoffFactor); |
| } |
| if (hasSmearPercent()) { |
| builder.append(" smear_percent=").append(smearPercent); |
| } |
| if (hasIsTransient()) { |
| builder.append(" is_transient=").append(isTransient); |
| } |
| if (hasInitialPersistentHeartbeatDelayMs()) { |
| builder.append(" initial_persistent_heartbeat_delay_ms=").append(initialPersistentHeartbeatDelayMs); |
| } |
| builder.append(" protocol_handler_config=").append(protocolHandlerConfig); |
| if (hasChannelSupportsOfflineDelivery()) { |
| builder.append(" channel_supports_offline_delivery=").append(channelSupportsOfflineDelivery); |
| } |
| if (hasOfflineHeartbeatThresholdMs()) { |
| builder.append(" offline_heartbeat_threshold_ms=").append(offlineHeartbeatThresholdMs); |
| } |
| if (hasAllowSuppression()) { |
| builder.append(" allow_suppression=").append(allowSuppression); |
| } |
| builder.append('>'); |
| } |
| |
| public static ClientConfigP parseFrom(byte[] data) throws ValidationException { |
| try { |
| return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClientProtocol.ClientConfigP(), data)); |
| } catch (InvalidProtocolBufferNanoException exception) { |
| throw new ValidationException(exception); |
| } catch (ValidationArgumentException exception) { |
| throw new ValidationException(exception.getMessage()); |
| } |
| } |
| |
| static ClientConfigP fromMessageNano(com.google.protos.ipc.invalidation.NanoClientProtocol.ClientConfigP message) { |
| if (message == null) { return null; } |
| return new ClientConfigP(com.google.ipc.invalidation.ticl.proto.ClientProtocol.Version.fromMessageNano(message.version), |
| message.networkTimeoutDelayMs, |
| message.writeRetryDelayMs, |
| message.heartbeatIntervalMs, |
| message.perfCounterDelayMs, |
| message.maxExponentialBackoffFactor, |
| message.smearPercent, |
| message.isTransient, |
| message.initialPersistentHeartbeatDelayMs, |
| com.google.ipc.invalidation.ticl.proto.ClientProtocol.ProtocolHandlerConfigP.fromMessageNano(message.protocolHandlerConfig), |
| message.channelSupportsOfflineDelivery, |
| message.offlineHeartbeatThresholdMs, |
| message.allowSuppression); |
| } |
| |
| public byte[] toByteArray() { |
| return MessageNano.toByteArray(toMessageNano()); |
| } |
| |
| com.google.protos.ipc.invalidation.NanoClientProtocol.ClientConfigP toMessageNano() { |
| com.google.protos.ipc.invalidation.NanoClientProtocol.ClientConfigP msg = new com.google.protos.ipc.invalidation.NanoClientProtocol.ClientConfigP(); |
| msg.version = version.toMessageNano(); |
| msg.networkTimeoutDelayMs = hasNetworkTimeoutDelayMs() ? networkTimeoutDelayMs : null; |
| msg.writeRetryDelayMs = hasWriteRetryDelayMs() ? writeRetryDelayMs : null; |
| msg.heartbeatIntervalMs = hasHeartbeatIntervalMs() ? heartbeatIntervalMs : null; |
| msg.perfCounterDelayMs = hasPerfCounterDelayMs() ? perfCounterDelayMs : null; |
| msg.maxExponentialBackoffFactor = hasMaxExponentialBackoffFactor() ? maxExponentialBackoffFactor : null; |
| msg.smearPercent = hasSmearPercent() ? smearPercent : null; |
| msg.isTransient = hasIsTransient() ? isTransient : null; |
| msg.initialPersistentHeartbeatDelayMs = hasInitialPersistentHeartbeatDelayMs() ? initialPersistentHeartbeatDelayMs : null; |
| msg.protocolHandlerConfig = protocolHandlerConfig.toMessageNano(); |
| msg.channelSupportsOfflineDelivery = hasChannelSupportsOfflineDelivery() ? channelSupportsOfflineDelivery : null; |
| msg.offlineHeartbeatThresholdMs = hasOfflineHeartbeatThresholdMs() ? offlineHeartbeatThresholdMs : null; |
| msg.allowSuppression = hasAllowSuppression() ? allowSuppression : null; |
| return msg; |
| } |
| } |
| |
| public static final class ConfigChangeMessage extends ProtoWrapper { |
| public static ConfigChangeMessage create(Long nextMessageDelayMs) { |
| return new ConfigChangeMessage(nextMessageDelayMs); |
| } |
| |
| public static final ConfigChangeMessage DEFAULT_INSTANCE = new ConfigChangeMessage(null); |
| |
| private final long __hazzerBits; |
| private final long nextMessageDelayMs; |
| |
| private ConfigChangeMessage(Long nextMessageDelayMs) throws ValidationArgumentException { |
| int hazzerBits = 0; |
| if (nextMessageDelayMs != null) { |
| hazzerBits |= 0x1; |
| positive("next_message_delay_ms", nextMessageDelayMs); |
| this.nextMessageDelayMs = nextMessageDelayMs; |
| } else { |
| this.nextMessageDelayMs = 0; |
| } |
| this.__hazzerBits = hazzerBits; |
| } |
| |
| public long getNextMessageDelayMs() { return nextMessageDelayMs; } |
| public boolean hasNextMessageDelayMs() { return (0x1 & __hazzerBits) != 0; } |
| |
| @Override public final boolean equals(Object obj) { |
| if (this == obj) { return true; } |
| if (!(obj instanceof ConfigChangeMessage)) { return false; } |
| ConfigChangeMessage other = (ConfigChangeMessage) obj; |
| return __hazzerBits == other.__hazzerBits |
| && (!hasNextMessageDelayMs() || nextMessageDelayMs == other.nextMessageDelayMs); |
| } |
| |
| @Override protected int computeHashCode() { |
| int result = hash(__hazzerBits); |
| if (hasNextMessageDelayMs()) { |
| result = result * 31 + hash(nextMessageDelayMs); |
| } |
| return result; |
| } |
| |
| @Override public void toCompactString(TextBuilder builder) { |
| builder.append("<ConfigChangeMessage:"); |
| if (hasNextMessageDelayMs()) { |
| builder.append(" next_message_delay_ms=").append(nextMessageDelayMs); |
| } |
| builder.append('>'); |
| } |
| |
| public static ConfigChangeMessage parseFrom(byte[] data) throws ValidationException { |
| try { |
| return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClientProtocol.ConfigChangeMessage(), data)); |
| } catch (InvalidProtocolBufferNanoException exception) { |
| throw new ValidationException(exception); |
| } catch (ValidationArgumentException exception) { |
| throw new ValidationException(exception.getMessage()); |
| } |
| } |
| |
| static ConfigChangeMessage fromMessageNano(com.google.protos.ipc.invalidation.NanoClientProtocol.ConfigChangeMessage message) { |
| if (message == null) { return null; } |
| return new ConfigChangeMessage(message.nextMessageDelayMs); |
| } |
| |
| public byte[] toByteArray() { |
| return MessageNano.toByteArray(toMessageNano()); |
| } |
| |
| com.google.protos.ipc.invalidation.NanoClientProtocol.ConfigChangeMessage toMessageNano() { |
| com.google.protos.ipc.invalidation.NanoClientProtocol.ConfigChangeMessage msg = new com.google.protos.ipc.invalidation.NanoClientProtocol.ConfigChangeMessage(); |
| msg.nextMessageDelayMs = hasNextMessageDelayMs() ? nextMessageDelayMs : null; |
| return msg; |
| } |
| } |
| |
| public static final class ErrorMessage extends ProtoWrapper { |
| public interface Code { |
| public static final int AUTH_FAILURE = 1; |
| public static final int UNKNOWN_FAILURE = 10000; |
| } |
| |
| public static ErrorMessage create(int code, |
| String description) { |
| return new ErrorMessage(code, description); |
| } |
| |
| private final int code; |
| private final String description; |
| |
| private ErrorMessage(Integer code, |
| String description) throws ValidationArgumentException { |
| required("code", code); |
| this.code = code; |
| required("description", description); |
| this.description = description; |
| } |
| |
| public int getCode() { return code; } |
| |
| public String getDescription() { return description; } |
| |
| @Override public final boolean equals(Object obj) { |
| if (this == obj) { return true; } |
| if (!(obj instanceof ErrorMessage)) { return false; } |
| ErrorMessage other = (ErrorMessage) obj; |
| return code == other.code |
| && equals(description, other.description); |
| } |
| |
| @Override protected int computeHashCode() { |
| int result = 1; |
| result = result * 31 + hash(code); |
| result = result * 31 + description.hashCode(); |
| return result; |
| } |
| |
| @Override public void toCompactString(TextBuilder builder) { |
| builder.append("<ErrorMessage:"); |
| builder.append(" code=").append(code); |
| builder.append(" description=").append(description); |
| builder.append('>'); |
| } |
| |
| public static ErrorMessage parseFrom(byte[] data) throws ValidationException { |
| try { |
| return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClientProtocol.ErrorMessage(), data)); |
| } catch (InvalidProtocolBufferNanoException exception) { |
| throw new ValidationException(exception); |
| } catch (ValidationArgumentException exception) { |
| throw new ValidationException(exception.getMessage()); |
| } |
| } |
| |
| static ErrorMessage fromMessageNano(com.google.protos.ipc.invalidation.NanoClientProtocol.ErrorMessage message) { |
| if (message == null) { return null; } |
| return new ErrorMessage(message.code, |
| message.description); |
| } |
| |
| public byte[] toByteArray() { |
| return MessageNano.toByteArray(toMessageNano()); |
| } |
| |
| com.google.protos.ipc.invalidation.NanoClientProtocol.ErrorMessage toMessageNano() { |
| com.google.protos.ipc.invalidation.NanoClientProtocol.ErrorMessage msg = new com.google.protos.ipc.invalidation.NanoClientProtocol.ErrorMessage(); |
| msg.code = code; |
| msg.description = description; |
| return msg; |
| } |
| } |
| } |