Pull cacheinvalidations code directory into chromium repo.

third_party/cacheinvalidation/src/java/com/google/ipc/invalidation/ticl/proto/Client.java

Index: third_party/cacheinvalidation/src/java/com/google/ipc/invalidation/ticl/proto/Client.java
diff --git a/third_party/cacheinvalidation/src/java/com/google/ipc/invalidation/ticl/proto/Client.java b/third_party/cacheinvalidation/src/java/com/google/ipc/invalidation/ticl/proto/Client.java
new file mode 100644
index 0000000000000000000000000000000000000000..c8e21968fac2eb6750306c79d83260782aad38f4
--- /dev/null
+++ b/third_party/cacheinvalidation/src/java/com/google/ipc/invalidation/ticl/proto/Client.java
@@ -0,0 +1,483 @@
+/*
+ * 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 Client {
+
+  public static final class AckHandleP extends ProtoWrapper {
+    public static AckHandleP create(com.google.ipc.invalidation.ticl.proto.ClientProtocol.InvalidationP invalidation) {
+      return new AckHandleP(invalidation);
+    }
+
+    public static final AckHandleP DEFAULT_INSTANCE = new AckHandleP(null);
+
+    private final com.google.ipc.invalidation.ticl.proto.ClientProtocol.InvalidationP invalidation;
+
+    private AckHandleP(com.google.ipc.invalidation.ticl.proto.ClientProtocol.InvalidationP invalidation) {
+      this.invalidation = invalidation;
+    }
+
+    public com.google.ipc.invalidation.ticl.proto.ClientProtocol.InvalidationP getNullableInvalidation() { return invalidation; }
+
+    @Override public final boolean equals(Object obj) {
+      if (this == obj) { return true; }
+      if (!(obj instanceof AckHandleP)) { return false; }
+      AckHandleP other = (AckHandleP) obj;
+      return equals(invalidation, other.invalidation);
+    }
+
+    @Override protected int computeHashCode() {
+      int result = 1;
+      if (invalidation != null) {
+        result = result * 31 + invalidation.hashCode();
+      }
+      return result;
+    }
+
+    @Override public void toCompactString(TextBuilder builder) {
+      builder.append("<AckHandleP:");
+      if (invalidation != null) {
+        builder.append(" invalidation=").append(invalidation);
+      }
+      builder.append('>');
+    }
+
+    public static AckHandleP parseFrom(byte[] data) throws ValidationException {
+      try {
+        return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClient.AckHandleP(), data));
+      } catch (InvalidProtocolBufferNanoException exception) {
+        throw new ValidationException(exception);
+      } catch (ValidationArgumentException exception) {
+        throw new ValidationException(exception.getMessage());
+      }
+    }
+
+    static AckHandleP fromMessageNano(com.google.protos.ipc.invalidation.NanoClient.AckHandleP message) {
+      if (message == null) { return null; }
+      return new AckHandleP(com.google.ipc.invalidation.ticl.proto.ClientProtocol.InvalidationP.fromMessageNano(message.invalidation));
+    }
+
+    public byte[] toByteArray() {
+      return MessageNano.toByteArray(toMessageNano());
+    }
+
+    com.google.protos.ipc.invalidation.NanoClient.AckHandleP toMessageNano() {
+      com.google.protos.ipc.invalidation.NanoClient.AckHandleP msg = new com.google.protos.ipc.invalidation.NanoClient.AckHandleP();
+      msg.invalidation = this.invalidation != null ? invalidation.toMessageNano() : null;
+      return msg;
+    }
+  }
+
+  public static final class PersistentTiclState extends ProtoWrapper {
+    public static final class Builder {
+      public Bytes clientToken;
+      public Long lastMessageSendTimeMs;
+      public Builder() {
+      }
+
+      public PersistentTiclState build() {
+        return new PersistentTiclState(clientToken, lastMessageSendTimeMs);
+      }
+    }
+
+    public static PersistentTiclState create(Bytes clientToken,
+        Long lastMessageSendTimeMs) {
+      return new PersistentTiclState(clientToken, lastMessageSendTimeMs);
+    }
+
+    public static final PersistentTiclState DEFAULT_INSTANCE = new PersistentTiclState(null, null);
+
+    private final long __hazzerBits;
+    private final Bytes clientToken;
+    private final long lastMessageSendTimeMs;
+
+    private PersistentTiclState(Bytes clientToken,
+        Long lastMessageSendTimeMs) {
+      int hazzerBits = 0;
+      if (clientToken != null) {
+        hazzerBits |= 0x1;
+        this.clientToken = clientToken;
+      } else {
+        this.clientToken = Bytes.EMPTY_BYTES;
+      }
+      if (lastMessageSendTimeMs != null) {
+        hazzerBits |= 0x2;
+        this.lastMessageSendTimeMs = lastMessageSendTimeMs;
+      } else {
+        this.lastMessageSendTimeMs = 0;
+      }
+      this.__hazzerBits = hazzerBits;
+    }
+
+    public Bytes getClientToken() { return clientToken; }
+    public boolean hasClientToken() { return (0x1 & __hazzerBits) != 0; }
+
+    public long getLastMessageSendTimeMs() { return lastMessageSendTimeMs; }
+    public boolean hasLastMessageSendTimeMs() { return (0x2 & __hazzerBits) != 0; }
+
+    public Builder toBuilder() {
+      Builder builder = new Builder();
+      if (hasClientToken()) {
+        builder.clientToken = clientToken;
+      }
+      if (hasLastMessageSendTimeMs()) {
+        builder.lastMessageSendTimeMs = lastMessageSendTimeMs;
+      }
+      return builder;
+    }
+
+    @Override public final boolean equals(Object obj) {
+      if (this == obj) { return true; }
+      if (!(obj instanceof PersistentTiclState)) { return false; }
+      PersistentTiclState other = (PersistentTiclState) obj;
+      return __hazzerBits == other.__hazzerBits
+          && (!hasClientToken() || equals(clientToken, other.clientToken))
+          && (!hasLastMessageSendTimeMs() || lastMessageSendTimeMs == other.lastMessageSendTimeMs);
+    }
+
+    @Override protected int computeHashCode() {
+      int result = hash(__hazzerBits);
+      if (hasClientToken()) {
+        result = result * 31 + clientToken.hashCode();
+      }
+      if (hasLastMessageSendTimeMs()) {
+        result = result * 31 + hash(lastMessageSendTimeMs);
+      }
+      return result;
+    }
+
+    @Override public void toCompactString(TextBuilder builder) {
+      builder.append("<PersistentTiclState:");
+      if (hasClientToken()) {
+        builder.append(" client_token=").append(clientToken);
+      }
+      if (hasLastMessageSendTimeMs()) {
+        builder.append(" last_message_send_time_ms=").append(lastMessageSendTimeMs);
+      }
+      builder.append('>');
+    }
+
+    public static PersistentTiclState parseFrom(byte[] data) throws ValidationException {
+      try {
+        return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClient.PersistentTiclState(), data));
+      } catch (InvalidProtocolBufferNanoException exception) {
+        throw new ValidationException(exception);
+      } catch (ValidationArgumentException exception) {
+        throw new ValidationException(exception.getMessage());
+      }
+    }
+
+    static PersistentTiclState fromMessageNano(com.google.protos.ipc.invalidation.NanoClient.PersistentTiclState message) {
+      if (message == null) { return null; }
+      return new PersistentTiclState(Bytes.fromByteArray(message.clientToken),
+          message.lastMessageSendTimeMs);
+    }
+
+    public byte[] toByteArray() {
+      return MessageNano.toByteArray(toMessageNano());
+    }
+
+    com.google.protos.ipc.invalidation.NanoClient.PersistentTiclState toMessageNano() {
+      com.google.protos.ipc.invalidation.NanoClient.PersistentTiclState msg = new com.google.protos.ipc.invalidation.NanoClient.PersistentTiclState();
+      msg.clientToken = hasClientToken() ? clientToken.getByteArray() : null;
+      msg.lastMessageSendTimeMs = hasLastMessageSendTimeMs() ? lastMessageSendTimeMs : null;
+      return msg;
+    }
+  }
+
+  public static final class PersistentStateBlob extends ProtoWrapper {
+    public static PersistentStateBlob create(com.google.ipc.invalidation.ticl.proto.Client.PersistentTiclState ticlState,
+        Bytes authenticationCode) {
+      return new PersistentStateBlob(ticlState, authenticationCode);
+    }
+
+    public static final PersistentStateBlob DEFAULT_INSTANCE = new PersistentStateBlob(null, null);
+
+    private final long __hazzerBits;
+    private final com.google.ipc.invalidation.ticl.proto.Client.PersistentTiclState ticlState;
+    private final Bytes authenticationCode;
+
+    private PersistentStateBlob(com.google.ipc.invalidation.ticl.proto.Client.PersistentTiclState ticlState,
+        Bytes authenticationCode) {
+      int hazzerBits = 0;
+      if (ticlState != null) {
+        hazzerBits |= 0x1;
+        this.ticlState = ticlState;
+      } else {
+        this.ticlState = com.google.ipc.invalidation.ticl.proto.Client.PersistentTiclState.DEFAULT_INSTANCE;
+      }
+      if (authenticationCode != null) {
+        hazzerBits |= 0x2;
+        this.authenticationCode = authenticationCode;
+      } else {
+        this.authenticationCode = Bytes.EMPTY_BYTES;
+      }
+      this.__hazzerBits = hazzerBits;
+    }
+
+    public com.google.ipc.invalidation.ticl.proto.Client.PersistentTiclState getTiclState() { return ticlState; }
+    public boolean hasTiclState() { return (0x1 & __hazzerBits) != 0; }
+
+    public Bytes getAuthenticationCode() { return authenticationCode; }
+    public boolean hasAuthenticationCode() { return (0x2 & __hazzerBits) != 0; }
+
+    @Override public final boolean equals(Object obj) {
+      if (this == obj) { return true; }
+      if (!(obj instanceof PersistentStateBlob)) { return false; }
+      PersistentStateBlob other = (PersistentStateBlob) obj;
+      return __hazzerBits == other.__hazzerBits
+          && (!hasTiclState() || equals(ticlState, other.ticlState))
+          && (!hasAuthenticationCode() || equals(authenticationCode, other.authenticationCode));
+    }
+
+    @Override protected int computeHashCode() {
+      int result = hash(__hazzerBits);
+      if (hasTiclState()) {
+        result = result * 31 + ticlState.hashCode();
+      }
+      if (hasAuthenticationCode()) {
+        result = result * 31 + authenticationCode.hashCode();
+      }
+      return result;
+    }
+
+    @Override public void toCompactString(TextBuilder builder) {
+      builder.append("<PersistentStateBlob:");
+      if (hasTiclState()) {
+        builder.append(" ticl_state=").append(ticlState);
+      }
+      if (hasAuthenticationCode()) {
+        builder.append(" authentication_code=").append(authenticationCode);
+      }
+      builder.append('>');
+    }
+
+    public static PersistentStateBlob parseFrom(byte[] data) throws ValidationException {
+      try {
+        return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClient.PersistentStateBlob(), data));
+      } catch (InvalidProtocolBufferNanoException exception) {
+        throw new ValidationException(exception);
+      } catch (ValidationArgumentException exception) {
+        throw new ValidationException(exception.getMessage());
+      }
+    }
+
+    static PersistentStateBlob fromMessageNano(com.google.protos.ipc.invalidation.NanoClient.PersistentStateBlob message) {
+      if (message == null) { return null; }
+      return new PersistentStateBlob(com.google.ipc.invalidation.ticl.proto.Client.PersistentTiclState.fromMessageNano(message.ticlState),
+          Bytes.fromByteArray(message.authenticationCode));
+    }
+
+    public byte[] toByteArray() {
+      return MessageNano.toByteArray(toMessageNano());
+    }
+
+    com.google.protos.ipc.invalidation.NanoClient.PersistentStateBlob toMessageNano() {
+      com.google.protos.ipc.invalidation.NanoClient.PersistentStateBlob msg = new com.google.protos.ipc.invalidation.NanoClient.PersistentStateBlob();
+      msg.ticlState = hasTiclState() ? ticlState.toMessageNano() : null;
+      msg.authenticationCode = hasAuthenticationCode() ? authenticationCode.getByteArray() : null;
+      return msg;
+    }
+  }
+
+  public static final class RunStateP extends ProtoWrapper {
+    public interface State {
+      public static final int NOT_STARTED = 1;
+      public static final int STARTED = 2;
+      public static final int STOPPED = 3;
+    }
+
+    public static RunStateP create(Integer state) {
+      return new RunStateP(state);
+    }
+
+    public static final RunStateP DEFAULT_INSTANCE = new RunStateP(null);
+
+    private final long __hazzerBits;
+    private final int state;
+
+    private RunStateP(Integer state) {
+      int hazzerBits = 0;
+      if (state != null) {
+        hazzerBits |= 0x1;
+        this.state = state;
+      } else {
+        this.state = 1;
+      }
+      this.__hazzerBits = hazzerBits;
+    }
+
+    public int getState() { return state; }
+    public boolean hasState() { return (0x1 & __hazzerBits) != 0; }
+
+    @Override public final boolean equals(Object obj) {
+      if (this == obj) { return true; }
+      if (!(obj instanceof RunStateP)) { return false; }
+      RunStateP other = (RunStateP) obj;
+      return __hazzerBits == other.__hazzerBits
+          && (!hasState() || state == other.state);
+    }
+
+    @Override protected int computeHashCode() {
+      int result = hash(__hazzerBits);
+      if (hasState()) {
+        result = result * 31 + hash(state);
+      }
+      return result;
+    }
+
+    @Override public void toCompactString(TextBuilder builder) {
+      builder.append("<RunStateP:");
+      if (hasState()) {
+        builder.append(" state=").append(state);
+      }
+      builder.append('>');
+    }
+
+    public static RunStateP parseFrom(byte[] data) throws ValidationException {
+      try {
+        return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClient.RunStateP(), data));
+      } catch (InvalidProtocolBufferNanoException exception) {
+        throw new ValidationException(exception);
+      } catch (ValidationArgumentException exception) {
+        throw new ValidationException(exception.getMessage());
+      }
+    }
+
+    static RunStateP fromMessageNano(com.google.protos.ipc.invalidation.NanoClient.RunStateP message) {
+      if (message == null) { return null; }
+      return new RunStateP(message.state);
+    }
+
+    public byte[] toByteArray() {
+      return MessageNano.toByteArray(toMessageNano());
+    }
+
+    com.google.protos.ipc.invalidation.NanoClient.RunStateP toMessageNano() {
+      com.google.protos.ipc.invalidation.NanoClient.RunStateP msg = new com.google.protos.ipc.invalidation.NanoClient.RunStateP();
+      msg.state = hasState() ? state : null;
+      return msg;
+    }
+  }
+
+  public static final class ExponentialBackoffState extends ProtoWrapper {
+    public static ExponentialBackoffState create(Integer currentMaxDelay,
+        Boolean inRetryMode) {
+      return new ExponentialBackoffState(currentMaxDelay, inRetryMode);
+    }
+
+    public static final ExponentialBackoffState DEFAULT_INSTANCE = new ExponentialBackoffState(null, null);
+
+    private final long __hazzerBits;
+    private final int currentMaxDelay;
+    private final boolean inRetryMode;
+
+    private ExponentialBackoffState(Integer currentMaxDelay,
+        Boolean inRetryMode) {
+      int hazzerBits = 0;
+      if (currentMaxDelay != null) {
+        hazzerBits |= 0x1;
+        this.currentMaxDelay = currentMaxDelay;
+      } else {
+        this.currentMaxDelay = 0;
+      }
+      if (inRetryMode != null) {
+        hazzerBits |= 0x2;
+        this.inRetryMode = inRetryMode;
+      } else {
+        this.inRetryMode = false;
+      }
+      this.__hazzerBits = hazzerBits;
+    }
+
+    public int getCurrentMaxDelay() { return currentMaxDelay; }
+    public boolean hasCurrentMaxDelay() { return (0x1 & __hazzerBits) != 0; }
+
+    public boolean getInRetryMode() { return inRetryMode; }
+    public boolean hasInRetryMode() { return (0x2 & __hazzerBits) != 0; }
+
+    @Override public final boolean equals(Object obj) {
+      if (this == obj) { return true; }
+      if (!(obj instanceof ExponentialBackoffState)) { return false; }
+      ExponentialBackoffState other = (ExponentialBackoffState) obj;
+      return __hazzerBits == other.__hazzerBits
+          && (!hasCurrentMaxDelay() || currentMaxDelay == other.currentMaxDelay)
+          && (!hasInRetryMode() || inRetryMode == other.inRetryMode);
+    }
+
+    @Override protected int computeHashCode() {
+      int result = hash(__hazzerBits);
+      if (hasCurrentMaxDelay()) {
+        result = result * 31 + hash(currentMaxDelay);
+      }
+      if (hasInRetryMode()) {
+        result = result * 31 + hash(inRetryMode);
+      }
+      return result;
+    }
+
+    @Override public void toCompactString(TextBuilder builder) {
+      builder.append("<ExponentialBackoffState:");
+      if (hasCurrentMaxDelay()) {
+        builder.append(" current_max_delay=").append(currentMaxDelay);
+      }
+      if (hasInRetryMode()) {
+        builder.append(" in_retry_mode=").append(inRetryMode);
+      }
+      builder.append('>');
+    }
+
+    public static ExponentialBackoffState parseFrom(byte[] data) throws ValidationException {
+      try {
+        return fromMessageNano(MessageNano.mergeFrom(new com.google.protos.ipc.invalidation.NanoClient.ExponentialBackoffState(), data));
+      } catch (InvalidProtocolBufferNanoException exception) {
+        throw new ValidationException(exception);
+      } catch (ValidationArgumentException exception) {
+        throw new ValidationException(exception.getMessage());
+      }
+    }
+
+    static ExponentialBackoffState fromMessageNano(com.google.protos.ipc.invalidation.NanoClient.ExponentialBackoffState message) {
+      if (message == null) { return null; }
+      return new ExponentialBackoffState(message.currentMaxDelay,
+          message.inRetryMode);
+    }
+
+    public byte[] toByteArray() {
+      return MessageNano.toByteArray(toMessageNano());
+    }
+
+    com.google.protos.ipc.invalidation.NanoClient.ExponentialBackoffState toMessageNano() {
+      com.google.protos.ipc.invalidation.NanoClient.ExponentialBackoffState msg = new com.google.protos.ipc.invalidation.NanoClient.ExponentialBackoffState();
+      msg.currentMaxDelay = hasCurrentMaxDelay() ? currentMaxDelay : null;
+      msg.inRetryMode = hasInRetryMode() ? inRetryMode : null;
+      return msg;
+    }
+  }
+}