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

ZooKeeperCommandExecutor.replayLogs介绍

暂无

代码示例

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

private <T> T blockingExecute(Command<T> command) throws Exception {
  createParentNodes();
  try (SafeLock ignored = safeLock(command.executionPath())) {
    // NB: We are sure no other replicas will append the conflicting logs (the commands with the
    //     same execution path) while we hold the lock for the command's execution path.
    //
    //     Other replicas may still append the logs with different execution paths, because, by design,
    //     two commands never conflict with each other if they have different execution paths.
    final List<String> recentRevisions = curator.getChildren().forPath(absolutePath(LOG_PATH));
    if (!recentRevisions.isEmpty()) {
      final long lastRevision = recentRevisions.stream().mapToLong(Long::parseLong).max().getAsLong();
      replayLogs(lastRevision);
    }
    final T result = delegate.execute(command).get();
    final ReplicationLog<T> log = new ReplicationLog<>(replicaId(), command, result);
    // Store the command execution log to ZooKeeper.
    final long revision = storeLog(log);
    logger.debug("logging OK. revision = {}, log = {}", revision, log);
    return result;
  }
}

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

private <T> T blockingExecute(Command<T> command) throws Exception {
  createParentNodes();
  try (SafeLock ignored = safeLock(command.executionPath())) {
    // NB: We are sure no other replicas will append the conflicting logs (the commands with the
    //     same execution path) while we hold the lock for the command's execution path.
    //
    //     Other replicas may still append the logs with different execution paths, because, by design,
    //     two commands never conflict with each other if they have different execution paths.
    final List<String> recentRevisions = curator.getChildren().forPath(absolutePath(LOG_PATH));
    if (!recentRevisions.isEmpty()) {
      final long lastRevision = recentRevisions.stream().mapToLong(Long::parseLong).max().getAsLong();
      replayLogs(lastRevision);
    }
    final T result = delegate.execute(command).get();
    final ReplicationLog<T> log = new ReplicationLog<>(replicaId(), command, result);
    // Store the command execution log to ZooKeeper.
    final long revision = storeLog(log);
    logger.debug("logging OK. revision = {}, log = {}", revision, log);
    return result;
  }
}

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

private <T> T blockingExecute(int replicaId, Command<T> command) throws Exception {
  createParentNodes();
  try (SafeLock ignored = safeLock(command.executionPath())) {
    // NB: We are sure no other replicas will append the conflicting logs (the commands with the
    //     same execution path) while we hold the lock for the command's execution path.
    //
    //     Other replicas may still append the logs with different execution paths, because, by design,
    //     two commands never conflict with each other if they have different execution paths.
    final List<String> recentRevisions = curator.getChildren().forPath(absolutePath(LOG_PATH));
    if (!recentRevisions.isEmpty()) {
      final long lastRevision = recentRevisions.stream().mapToLong(Long::parseLong).max().getAsLong();
      replayLogs(lastRevision);
    }
    final T result = delegate.execute(replicaId, command).get();
    final ReplicationLog<T> log = new ReplicationLog<>(replicaId(), command, result);
    // Store the command execution log to ZooKeeper.
    final long revision = storeLog(log);
    logger.debug("logging OK. revision = {}, log = {}", revision, log);
    return result;
  }
}

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

@Override
public void childEvent(CuratorFramework unused, PathChildrenCacheEvent event) throws Exception {
  if (event.getType() != PathChildrenCacheEvent.Type.CHILD_ADDED) {
    return;
  }
  final long lastKnownRevision = revisionFromPath(event.getData().getPath());
  try {
    replayLogs(lastKnownRevision);
  } catch (ReplicationException ignored) {
    // replayLogs() logs and handles the exception already, so we just bail out here.
    return;
  }
  oldLogRemover.touch();
}

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

@Override
public void childEvent(CuratorFramework unused, PathChildrenCacheEvent event) throws Exception {
  if (event.getType() != PathChildrenCacheEvent.Type.CHILD_ADDED) {
    return;
  }
  final long lastKnownRevision = revisionFromPath(event.getData().getPath());
  try {
    replayLogs(lastKnownRevision);
  } catch (ReplicationException ignored) {
    // replayLogs() logs and handles the exception already, so we just bail out here.
    return;
  }
  oldLogRemover.touch();
}

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

@Override
public void childEvent(CuratorFramework unused, PathChildrenCacheEvent event) throws Exception {
  if (event.getType() != PathChildrenCacheEvent.Type.CHILD_ADDED) {
    return;
  }
  final long lastKnownRevision = revisionFromPath(event.getData().getPath());
  try {
    replayLogs(lastKnownRevision);
  } catch (ReplicationException ignored) {
    // replayLogs() logs and handles the exception already, so we just bail out here.
    return;
  }
  oldLogRemover.touch();
}