- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中com.linecorp.centraldogma.server.internal.replication.ZooKeeperCommandExecutor.absolutePath()
方法的一些代码示例,展示了ZooKeeperCommandExecutor.absolutePath()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZooKeeperCommandExecutor.absolutePath()
方法的具体详情如下:
包路径:com.linecorp.centraldogma.server.internal.replication.ZooKeeperCommandExecutor
类名称:ZooKeeperCommandExecutor
方法名:absolutePath
暂无
代码示例来源:origin: line/centraldogma
private void createParentNodes() throws Exception {
if (createdParentNodes) {
return;
}
// Create the zkPath if it does not exist.
createZkPathIfMissing(absolutePath());
createZkPathIfMissing(absolutePath(LOG_PATH));
createZkPathIfMissing(absolutePath(LOG_BLOCK_PATH));
createZkPathIfMissing(absolutePath(LOCK_PATH));
createdParentNodes = true;
}
代码示例来源:origin: com.linecorp.centraldogma/centraldogma-server
private void createParentNodes() throws Exception {
if (createdParentNodes) {
return;
}
// Create the zkPath if it does not exist.
createZkPathIfMissing(absolutePath());
createZkPathIfMissing(absolutePath(LOG_PATH));
createZkPathIfMissing(absolutePath(LOG_BLOCK_PATH));
createZkPathIfMissing(absolutePath(LOCK_PATH));
createdParentNodes = true;
}
代码示例来源:origin: com.linecorp.centraldogma/centraldogma-server-shaded
private void createParentNodes() throws Exception {
if (createdParentNodes) {
return;
}
// Create the zkPath if it does not exist.
createZkPathIfMissing(absolutePath());
createZkPathIfMissing(absolutePath(LOG_PATH));
createZkPathIfMissing(absolutePath(LOG_BLOCK_PATH));
createZkPathIfMissing(absolutePath(LOCK_PATH));
createdParentNodes = true;
}
代码示例来源: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
@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
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 long storeLog(ReplicationLog<?> log) {
try {
final byte[] bytes = Jackson.writeValueAsBytes(log);
assert bytes.length > 0;
final LogMeta logMeta = new LogMeta(log.replicaId(), System.currentTimeMillis(), bytes.length);
final int count = (bytes.length + MAX_BYTES - 1) / MAX_BYTES;
for (int i = 0; i < count; ++i) {
final int start = i * MAX_BYTES;
final int end = Math.min((i + 1) * MAX_BYTES, bytes.length);
final byte[] b = Arrays.copyOfRange(bytes, start, end);
final String blockPath = curator.create()
.withMode(CreateMode.PERSISTENT_SEQUENTIAL)
.forPath(absolutePath(LOG_BLOCK_PATH) + '/', b);
final long blockId = revisionFromPath(blockPath);
logMeta.appendBlock(blockId);
}
final String logPath =
curator.create().withMode(CreateMode.PERSISTENT_SEQUENTIAL)
.forPath(absolutePath(LOG_PATH) + '/', Jackson.writeValueAsBytes(logMeta));
return revisionFromPath(logPath);
} catch (Exception e) {
logger.error("Failed to store a log; entering read-only mode: {}", log, e);
stopLater();
throw new ReplicationException("failed to store a log: " + log, e);
}
}
代码示例来源:origin: line/centraldogma
private SafeLock safeLock(String executionPath) {
final InterProcessMutex mtx = mutexMap.computeIfAbsent(
executionPath, k -> new InterProcessMutex(curator, absolutePath(LOCK_PATH, executionPath)));
try {
mtx.acquire();
} catch (Exception e) {
logger.error("Failed to acquire a lock for {}; entering read-only mode", executionPath, e);
stopLater();
throw new ReplicationException("failed to acquire a lock for " + executionPath, e);
}
return () -> {
try {
mtx.release();
} catch (Exception ignored) {
// Ignore.
}
};
}
代码示例来源:origin: com.linecorp.centraldogma/centraldogma-server-shaded
private long storeLog(ReplicationLog<?> log) {
try {
final byte[] bytes = Jackson.writeValueAsBytes(log);
assert bytes.length > 0;
final LogMeta logMeta = new LogMeta(log.replicaId(), System.currentTimeMillis(), bytes.length);
final int count = (bytes.length + MAX_BYTES - 1) / MAX_BYTES;
for (int i = 0; i < count; ++i) {
final int start = i * MAX_BYTES;
final int end = Math.min((i + 1) * MAX_BYTES, bytes.length);
final byte[] b = Arrays.copyOfRange(bytes, start, end);
final String blockPath = curator.create()
.withMode(CreateMode.PERSISTENT_SEQUENTIAL)
.forPath(absolutePath(LOG_BLOCK_PATH) + '/', b);
final long blockId = revisionFromPath(blockPath);
logMeta.appendBlock(blockId);
}
final String logPath =
curator.create().withMode(CreateMode.PERSISTENT_SEQUENTIAL)
.forPath(absolutePath(LOG_PATH) + '/', Jackson.writeValueAsBytes(logMeta));
return revisionFromPath(logPath);
} catch (Exception e) {
logger.error("Failed to store a log; entering read-only mode: {}", log, e);
stopLater();
throw new ReplicationException("failed to store a log: " + log, e);
}
}
代码示例来源:origin: com.linecorp.centraldogma/centraldogma-server
private long storeLog(ReplicationLog<?> log) {
try {
final byte[] bytes = Jackson.writeValueAsBytes(log);
assert bytes.length > 0;
final LogMeta logMeta = new LogMeta(log.replicaId(), System.currentTimeMillis(), bytes.length);
final int count = (bytes.length + MAX_BYTES - 1) / MAX_BYTES;
for (int i = 0; i < count; ++i) {
final int start = i * MAX_BYTES;
final int end = Math.min((i + 1) * MAX_BYTES, bytes.length);
final byte[] b = Arrays.copyOfRange(bytes, start, end);
final String blockPath = curator.create()
.withMode(CreateMode.PERSISTENT_SEQUENTIAL)
.forPath(absolutePath(LOG_BLOCK_PATH) + '/', b);
final long blockId = revisionFromPath(blockPath);
logMeta.appendBlock(blockId);
}
final String logPath =
curator.create().withMode(CreateMode.PERSISTENT_SEQUENTIAL)
.forPath(absolutePath(LOG_PATH) + '/', Jackson.writeValueAsBytes(logMeta));
return revisionFromPath(logPath);
} catch (Exception e) {
logger.error("Failed to store a log; entering read-only mode: {}", log, e);
stopLater();
throw new ReplicationException("failed to store a log: " + log, 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
private SafeLock safeLock(String executionPath) {
final InterProcessMutex mtx = mutexMap.computeIfAbsent(
executionPath, k -> new InterProcessMutex(curator, absolutePath(LOCK_PATH, executionPath)));
try {
mtx.acquire();
} catch (Exception e) {
logger.error("Failed to acquire a lock for {}; entering read-only mode", executionPath, e);
stopLater();
throw new ReplicationException("failed to acquire a lock for " + executionPath, e);
}
return () -> {
try {
mtx.release();
} catch (Exception ignored) {
// Ignore.
}
};
}
代码示例来源:origin: com.linecorp.centraldogma/centraldogma-server-shaded
private SafeLock safeLock(String executionPath) {
final InterProcessMutex mtx = mutexMap.computeIfAbsent(
executionPath, k -> new InterProcessMutex(curator, absolutePath(LOCK_PATH, executionPath)));
try {
mtx.acquire();
} catch (Exception e) {
logger.error("Failed to acquire a lock for {}; entering read-only mode", executionPath, e);
stopLater();
throw new ReplicationException("failed to acquire a lock for " + executionPath, e);
}
return () -> {
try {
mtx.release();
} catch (Exception ignored) {
// Ignore.
}
};
}
代码示例来源: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);
}
}
代码示例来源:origin: line/centraldogma
logWatcher = new PathChildrenCache(curator, absolutePath(LOG_PATH),
true, false, logWatcherExecutor);
logWatcher.getListenable().addListener(this, MoreExecutors.directExecutor());
leaderSelectorExecutor = Executors.newSingleThreadExecutor(
new DefaultThreadFactory("zookeeper-leader-selector", true));
leaderSelector = new LeaderSelector(curator, absolutePath(LEADER_PATH),
leaderSelectorExecutor, oldLogRemover);
leaderSelector.start();
代码示例来源:origin: com.linecorp.centraldogma/centraldogma-server-shaded
logWatcher = new PathChildrenCache(curator, absolutePath(LOG_PATH),
true, false, logWatcherExecutor);
logWatcher.getListenable().addListener(this, MoreExecutors.directExecutor());
leaderSelectorExecutor = Executors.newSingleThreadExecutor(
new DefaultThreadFactory("zookeeper-leader-selector", true));
leaderSelector = new LeaderSelector(curator, absolutePath(LEADER_PATH),
leaderSelectorExecutor, oldLogRemover);
leaderSelector.start();
代码示例来源:origin: com.linecorp.centraldogma/centraldogma-server
logWatcher = new PathChildrenCache(curator, absolutePath(LOG_PATH),
true, false, logWatcherExecutor);
logWatcher.getListenable().addListener(this, MoreExecutors.directExecutor());
leaderSelectorExecutor = Executors.newSingleThreadExecutor(
new DefaultThreadFactory("zookeeper-leader-selector", true));
leaderSelector = new LeaderSelector(curator, absolutePath(LEADER_PATH),
leaderSelectorExecutor, oldLogRemover);
leaderSelector.start();
这个问题在这里已经有了答案: How to make a property protected AND internal in C#? (8 个答案) 关闭 9 年前。 我需要声明一个既受又 内部保
我对在 Kotlin 1.3 中使用 Strings.isNullOrEmpty 导入 jdk.internal.joptsimple.internal.Strings.isNullOrEmpty 的
我有一个项目,实习生单元测试应该位于与被测源代码不同的目录树中。有点像这样: projectRoot projectRoot/src projectRoot/tests projectRoot/tes
如何在功能测试中访问浏览器的主要 JavaScript 范围?例如,我想获取对 Dojo 小部件的引用并检查它的属性。例如,在浏览器 JavaScript 控制台中,我可以运行: dijit.
public class TestClass { protected internal int FieldA; internal protected int FieldB; }
我想创建一个内部自动属性: internal bool IP { get; protected internal set; } 我认为可以使 setter protected 或 protected
java.lang.NoSuchMethodError: okhttp3.internal.Internal.initializeInstanceForTests() When creating a
我正在尝试使用 intern 来测试在 node.js 下运行的 dojo 应用程序 我的 intern.js 配置文件是这样的: define({ loader: {
我在 Raspbian wheezy 上的 nginx 1.2.1-2.2 有点问题。我认为它是在我更改站点可用/默认文件中的索引后开始的。以下是相关文件: nginx.conf user www-d
我在尝试加载 Visual studio 2012 时遇到了此错误,遇到了异常。这可能是由扩展引起的,并且在 C:\Users\~\AppData 中给出了附加信息的位置\Roaming\Micros
我正在将一个项目迁移到 Java9,在我切换到新的 Java 版本后,测试开始失败,看起来 PowerMock 正在尝试访问一些它无法访问的类。 Tests run: 1, Failures: 0,
该触发器用于检测进度中的顺序是否已更新,并有助于更新进度的概览状态和完成时间。 但是当发生内部错误时,它并不总是有效,如下所示: Error: 13 INTERNAL: An internal err
当我尝试将包含一些 JavaScript 的项目导入工作区时(使用 Eclipse 的 Neon.M6 版本),出现此错误: eclipse.buildId=4.6.0.I20160317-0200
我在尝试访问 FullContact API 服务器时收到此错误。我正在使用 okhttp 2.7.5 和 okhttp-urlconnection 2.7.5 以及改造 1.9.0。 Caused
当我试图读取一个以前版本的 pandas 保存的 pickle 文件时,它产生了一个 ImportError。 ImportError: No module named 'pandas.core.in
我正在将一个项目迁移到 Java9,在我切换到新的 Java 版本后测试开始失败,似乎 PowerMock 正在尝试访问它无法访问的一些类。 Tests run: 1, Failures: 0, Er
我正在尝试设置 Lumen - 建立在 Laravel 组件之上的“微框架”。服务器端有 nginx + php-fpm。 这是我的 nginx 配置: server { server_nam
在我们的项目中,我们决定在我们的项目中使用最新的 fmt 版本 (6.2.0) 并主要使用 printf 功能,因为我们在广泛使用 printf 的地方进行日志记录。 我使用 fmt 包中包含的 CM
我正在使用 Mockito jar 为 Groovy 编写 Junit 测试用例,但它给了我以下异常: java.lang.NoSuchMethodError: org.mockito.interna
我们的应用程序使用 Google 集合中的 MapMaker 类,并且我们遇到了以下异常,但仅限于使用 webstart 的 OS X 10.4。从应用程序包启动时以及在 OS X 10.5 和 Wi
我是一名优秀的程序员,十分优秀!