本文整理了Java中com.linecorp.centraldogma.server.internal.replication.ZooKeeperCommandExecutor.pathFromRevision()方法的一些代码示例，展示了ZooKeeperCommandExecutor.pathFromRevision()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZooKeeperCommandExecutor.pathFromRevision()方法的具体详情如下：
包路径：com.linecorp.centraldogma.server.internal.replication.ZooKeeperCommandExecutor
类名称：ZooKeeperCommandExecutor
方法名：pathFromRevision

ZooKeeperCommandExecutor.pathFromRevision介绍

暂无

代码示例

代码示例来源：origin: line/centraldogma

@VisibleForTesting
Optional<ReplicationLog<?>> loadLog(long revision, boolean skipIfSameReplica) {
  try {
    createParentNodes();
    final String logPath = absolutePath(LOG_PATH) + '/' + pathFromRevision(revision);
    final LogMeta logMeta = Jackson.readValue(curator.getData().forPath(logPath), LogMeta.class);
    if (skipIfSameReplica && replicaId() == logMeta.replicaId()) {
      return Optional.empty();
    }
    final byte[] bytes = new byte[logMeta.size()];
    int offset = 0;
    for (long blockId : logMeta.blocks()) {
      final String blockPath = absolutePath(LOG_BLOCK_PATH) + '/' + pathFromRevision(blockId);
      final byte[] b = curator.getData().forPath(blockPath);
      System.arraycopy(b, 0, bytes, offset, b.length);
      offset += b.length;
    }
    assert logMeta.size() == offset;
    final ReplicationLog<?> log = Jackson.readValue(bytes, ReplicationLog.class);
    return Optional.of(log);
  } catch (Exception e) {
    logger.error("Failed to load a log at revision {}; entering read-only mode", revision, e);
    stopLater();
    throw new ReplicationException("failed to load a log at revision " + revision, e);
  }
}

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-server

@VisibleForTesting
Optional<ReplicationLog<?>> loadLog(long revision, boolean skipIfSameReplica) {
  try {
    createParentNodes();
    final String logPath = absolutePath(LOG_PATH) + '/' + pathFromRevision(revision);
    final LogMeta logMeta = Jackson.readValue(curator.getData().forPath(logPath), LogMeta.class);
    if (skipIfSameReplica && replicaId() == logMeta.replicaId()) {
      return Optional.empty();
    }
    final byte[] bytes = new byte[logMeta.size()];
    int offset = 0;
    for (long blockId : logMeta.blocks()) {
      final String blockPath = absolutePath(LOG_BLOCK_PATH) + '/' + pathFromRevision(blockId);
      final byte[] b = curator.getData().forPath(blockPath);
      System.arraycopy(b, 0, bytes, offset, b.length);
      offset += b.length;
    }
    assert logMeta.size() == offset;
    final ReplicationLog<?> log = Jackson.readValue(bytes, ReplicationLog.class);
    return Optional.of(log);
  } catch (Exception e) {
    logger.error("Failed to load a log at revision {}; entering read-only mode", revision, e);
    stopLater();
    throw new ReplicationException("failed to load a log at revision " + revision, e);
  }
}

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-server-shaded

@VisibleForTesting
Optional<ReplicationLog<?>> loadLog(long revision, boolean skipIfSameReplica) {
  try {
    createParentNodes();
    final String logPath = absolutePath(LOG_PATH) + '/' + pathFromRevision(revision);
    final LogMeta logMeta = Jackson.readValue(curator.getData().forPath(logPath), LogMeta.class);
    if (skipIfSameReplica && replicaId() == logMeta.replicaId()) {
      return Optional.empty();
    }
    final byte[] bytes = new byte[logMeta.size()];
    int offset = 0;
    for (long blockId : logMeta.blocks()) {
      final String blockPath = absolutePath(LOG_BLOCK_PATH) + '/' + pathFromRevision(blockId);
      final byte[] b = curator.getData().forPath(blockPath);
      System.arraycopy(b, 0, bytes, offset, b.length);
      offset += b.length;
    }
    assert logMeta.size() == offset;
    final ReplicationLog<?> log = Jackson.readValue(bytes, ReplicationLog.class);
    return Optional.of(log);
  } catch (Exception e) {
    logger.error("Failed to load a log at revision {}; entering read-only mode", revision, e);
    stopLater();
    throw new ReplicationException("failed to load a log at revision " + revision, e);
  }
}