import com.google.ipc.invalidation.ticl.TiclExponentialBackoffDelayGenerator; //导入依赖的package包/类
/** Initializes state from proto. */
AndroidListenerState(int initialMaxDelayMs, int maxDelayFactor,
    AndroidListenerProtocol.AndroidListenerState state) {
  desiredRegistrations = new HashSet<ObjectId>();
  for (ObjectIdP objectIdProto : state.getRegistration()) {
    desiredRegistrations.add(ProtoWrapperConverter.convertFromObjectIdProto(objectIdProto));
  }
  for (RetryRegistrationState retryState : state.getRetryRegistrationState()) {
    ObjectIdP objectIdP = retryState.getNullableObjectId();
    if (objectIdP == null) {
      continue;
    }
    ObjectId objectId = ProtoWrapperConverter.convertFromObjectIdProto(objectIdP);
    delayGenerators.put(objectId, new TiclExponentialBackoffDelayGenerator(random,
        initialMaxDelayMs, maxDelayFactor, retryState.getExponentialBackoffState()));
  }
  for (ScheduledRegistrationRetry registrationRetry : state.getRegistrationRetry()) {
    registrationRetries.put(registrationRetry.getExecuteTimeMs(), registrationRetry.getCommand());
  }
  clientId = state.getClientId();
  requestCodeSeqNum = state.getRequestCodeSeqNum();
  isDirty = false;
  this.initialMaxDelayMs = initialMaxDelayMs;
  this.maxDelayFactor = maxDelayFactor;
}
 

import com.google.ipc.invalidation.ticl.TiclExponentialBackoffDelayGenerator; //导入依赖的package包/类
/** Initializes state from proto. */
AndroidListenerState(int initialMaxDelayMs, int maxDelayFactor,
    AndroidListenerProtocol.AndroidListenerState state) {
  desiredRegistrations = new HashSet<ObjectId>();
  for (ObjectIdP objectIdProto : state.getRegistrationList()) {
    desiredRegistrations.add(ProtoConverter.convertFromObjectIdProto(objectIdProto));
  }
  for (RetryRegistrationState retryState : state.getRetryRegistrationStateList()) {
    ObjectId objectId = ProtoConverter.convertFromObjectIdProto(retryState.getObjectId());
    delayGenerators.put(objectId, new TiclExponentialBackoffDelayGenerator(random,
        initialMaxDelayMs, maxDelayFactor, retryState.getExponentialBackoffState()));
  }
  clientId = state.getClientId();
  requestCodeSeqNum = state.getRequestCodeSeqNum();
  isDirty = false;
  this.initialMaxDelayMs = initialMaxDelayMs;
  this.maxDelayFactor = maxDelayFactor;
}
 

import com.google.ipc.invalidation.ticl.TiclExponentialBackoffDelayGenerator; //导入依赖的package包/类
/** Creates proto for {@link AndroidListener} state. */
static AndroidListenerState newAndroidListenerState(ByteString clientId, int requestCodeSeqNum,
    Map<ObjectId, TiclExponentialBackoffDelayGenerator> delayGenerators,
    Iterable<ObjectId> desiredRegistrations) {
  AndroidListenerState.Builder builder = AndroidListenerState.newBuilder()
      .setClientId(clientId)
      .setRequestCodeSeqNum(requestCodeSeqNum);
  for (ObjectId objectId : desiredRegistrations) {
    builder.addRegistration(ProtoConverter.convertToObjectIdProto(objectId));
  }
  for (Entry<ObjectId, TiclExponentialBackoffDelayGenerator> entry : delayGenerators.entrySet()) {
    builder.addRetryRegistrationState(
        newRetryRegistrationState(entry.getKey(), entry.getValue()));
  }
  return builder.build();
}
 

import com.google.ipc.invalidation.ticl.TiclExponentialBackoffDelayGenerator; //导入依赖的package包/类
/** Compares the contents of two {@link #delayGenerators} maps. */
private static boolean equals(Map<ObjectId, TiclExponentialBackoffDelayGenerator> x,
    Map<ObjectId, TiclExponentialBackoffDelayGenerator> y) {
  if (x.size() != y.size()) {
    return false;
  }
  for (Entry<ObjectId, TiclExponentialBackoffDelayGenerator> xEntry : x.entrySet()) {
    TiclExponentialBackoffDelayGenerator yGenerator = y.get(xEntry.getKey());
    if ((yGenerator == null) || !TypedUtil.<ExponentialBackoffState>equals(
        xEntry.getValue().marshal(), yGenerator.marshal())) {
      return false;
    }
  }
  return true;
}
 

import com.google.ipc.invalidation.ticl.TiclExponentialBackoffDelayGenerator; //导入依赖的package包/类
/** Creates proto for {@link AndroidListener} state. */
static AndroidListenerState newAndroidListenerState(Bytes clientId, int requestCodeSeqNum,
    Map<ObjectId, TiclExponentialBackoffDelayGenerator> delayGenerators,
    Collection<ObjectId> desiredRegistrations,
    Collection<ScheduledRegistrationRetry> registrationRetries) {
  ArrayList<RetryRegistrationState> retryRegistrationState =
      new ArrayList<RetryRegistrationState>(delayGenerators.size());
  for (Entry<ObjectId, TiclExponentialBackoffDelayGenerator> entry : delayGenerators.entrySet()) {
    retryRegistrationState.add(
        newRetryRegistrationState(entry.getKey(), entry.getValue()));
  }
  return AndroidListenerState.create(
      ProtoWrapperConverter.convertToObjectIdProtoCollection(desiredRegistrations),
      retryRegistrationState, clientId, requestCodeSeqNum, registrationRetries);
}
 

import com.google.ipc.invalidation.ticl.TiclExponentialBackoffDelayGenerator; //导入依赖的package包/类
/** Compares the contents of two {@link #delayGenerators} maps. */
private static boolean equals(Map<ObjectId, TiclExponentialBackoffDelayGenerator> x,
    Map<ObjectId, TiclExponentialBackoffDelayGenerator> y) {
  if (x.size() != y.size()) {
    return false;
  }
  for (Entry<ObjectId, TiclExponentialBackoffDelayGenerator> xEntry : x.entrySet()) {
    TiclExponentialBackoffDelayGenerator yGenerator = y.get(xEntry.getKey());
    if ((yGenerator == null) || !xEntry.getValue().marshal().toByteString().equals(
        yGenerator.marshal().toByteString())) {
      return false;
    }
  }
  return true;
}
 

import com.google.ipc.invalidation.ticl.TiclExponentialBackoffDelayGenerator; //导入依赖的package包/类
/** Creates proto for retry registration state. */
static RetryRegistrationState newRetryRegistrationState(ObjectId objectId,
    TiclExponentialBackoffDelayGenerator delayGenerator) {
  return RetryRegistrationState.newBuilder()
      .setObjectId(ProtoConverter.convertToObjectIdProto(objectId))
      .setExponentialBackoffState(delayGenerator.marshal())
      .build();
}
 

import com.google.ipc.invalidation.ticl.TiclExponentialBackoffDelayGenerator; //导入依赖的package包/类
/** Creates proto for retry registration state. */
static RetryRegistrationState newRetryRegistrationState(ObjectId objectId,
    TiclExponentialBackoffDelayGenerator delayGenerator) {
  return RetryRegistrationState.create(ProtoWrapperConverter.convertToObjectIdProto(objectId),
      delayGenerator.marshal());
}