| Index: third_party/cacheinvalidation/src/java/com/google/ipc/invalidation/ticl/proto/ClientProtocol.java
|
| diff --git a/third_party/cacheinvalidation/src/java/com/google/ipc/invalidation/ticl/proto/ClientProtocol.java b/third_party/cacheinvalidation/src/java/com/google/ipc/invalidation/ticl/proto/ClientProtocol.java
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..501e580cc3e5e11e0413dd7889f77b6505687fb5
|
| --- /dev/null
|
| +++ b/third_party/cacheinvalidation/src/java/com/google/ipc/invalidation/ticl/proto/ClientProtocol.java
|
| @@ -0,0 +1,3171 @@
|
| +/*
|
| + * 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;
|
| + }
|
| + }
|
| +}
|
|
|
Chromium Code Reviews
Issue 1162033004:
Pull cacheinvalidations code directory into chromium repo. (Closed)
Base URL: https://chromium.googlesource.com/chromium/src.git@master