Java TiclExponentialBackoffDelayGenerator类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中com.google.ipc.invalidation.ticl.TiclExponentialBackoffDelayGenerator类的典型用法代码示例。如果您正苦于以下问题：Java TiclExponentialBackoffDelayGenerator类的具体用法？Java TiclExponentialBackoffDelayGenerator怎么用？Java TiclExponentialBackoffDelayGenerator使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

TiclExponentialBackoffDelayGenerator类属于com.google.ipc.invalidation.ticl包，在下文中一共展示了TiclExponentialBackoffDelayGenerator类的8个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: AndroidListenerState

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;
}

开发者ID:mogoweb，项目名称:365browser，代码行数:26，代码来源:AndroidListenerState.java

示例2: AndroidListenerState

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;
}

开发者ID:morristech，项目名称:android-chromium，代码行数:19，代码来源:AndroidListenerState.java

示例3: newAndroidListenerState

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();
}

开发者ID:morristech，项目名称:android-chromium，代码行数:17，代码来源:AndroidListenerProtos.java

示例4: equals

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;
}

开发者ID:mogoweb，项目名称:365browser，代码行数:16，代码来源:AndroidListenerState.java

示例5: newAndroidListenerState

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);
}

开发者ID:mogoweb，项目名称:365browser，代码行数:16，代码来源:AndroidListenerProtos.java

示例6: equals

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;
}

开发者ID:morristech，项目名称:android-chromium，代码行数:16，代码来源:AndroidListenerState.java

示例7: newRetryRegistrationState

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();
}

开发者ID:morristech，项目名称:android-chromium，代码行数:9，代码来源:AndroidListenerProtos.java

示例8: newRetryRegistrationState

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());
}

开发者ID:mogoweb，项目名称:365browser，代码行数:7，代码来源:AndroidListenerProtos.java

注：本文中的com.google.ipc.invalidation.ticl.TiclExponentialBackoffDelayGenerator类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。