本文整理了Java中org.apache.jackrabbit.oak.spi.state.NodeStore.release()
方法的一些代码示例,展示了NodeStore.release()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。NodeStore.release()
方法的具体详情如下:
包路径:org.apache.jackrabbit.oak.spi.state.NodeStore
类名称:NodeStore
方法名:release
[英]Releases the provided checkpoint. If the provided checkpoint doesn't exist this method should return true.
[中]释放提供的检查点。如果提供的检查点不存在,此方法应返回true。
代码示例来源:origin: org.apache.jackrabbit/oak-core
private void releaseCheckpoint() {
nodeStore.release(indexerInfo.checkpoint);
log.info("Released the referred checkpoint [{}]", indexerInfo.checkpoint);
}
代码示例来源:origin: apache/jackrabbit-oak
private void releaseCheckpoint() {
nodeStore.release(indexerInfo.checkpoint);
log.info("Released the referred checkpoint [{}]", indexerInfo.checkpoint);
}
代码示例来源:origin: org.apache.sling/org.apache.sling.testing.sling-mock-oak
private void releaseCheckpoint() {
nodeStore.release(indexerInfo.checkpoint);
log.info("Released the referred checkpoint [{}]", indexerInfo.checkpoint);
}
代码示例来源:origin: org.apache.jackrabbit/oak-core
@Override
public boolean release(@NotNull String checkpoint) {
if (inheritedCheckpoints.contains(checkpoint)) {
return nodeStore.release(checkpoint);
} else if (checkpointMapping.containsKey(checkpoint)) {
return memoryNodeStore.release(checkpointMapping.remove(checkpoint));
} else {
return false;
}
}
代码示例来源:origin: org.apache.sling/org.apache.sling.testing.sling-mock-oak
@Override
public boolean release(@Nonnull String checkpoint) {
if (inheritedCheckpoints.contains(checkpoint)) {
return nodeStore.release(checkpoint);
} else if (checkpointMapping.containsKey(checkpoint)) {
return memoryNodeStore.release(checkpointMapping.remove(checkpoint));
} else {
return false;
}
}
代码示例来源:origin: apache/jackrabbit-oak
@Override
public boolean release(@NotNull String checkpoint) {
if (inheritedCheckpoints.contains(checkpoint)) {
return nodeStore.release(checkpoint);
} else if (checkpointMapping.containsKey(checkpoint)) {
return memoryNodeStore.release(checkpointMapping.remove(checkpoint));
} else {
return false;
}
}
代码示例来源:origin: org.apache.sling/org.apache.sling.testing.sling-mock-oak
@Override
public boolean release(String checkpoint) {
return getNodeStore().release(checkpoint);
}
代码示例来源:origin: org.apache.sling/org.apache.sling.testing.sling-mock-oak
@Override
public boolean release(@Nonnull String checkpoint) {
return getNodeStore().release(checkpoint);
}
代码示例来源:origin: apache/jackrabbit-oak
@Override public boolean releaseCheckpoint(String id) {
return nodeStore.release(id);
}
}
代码示例来源:origin: apache/jackrabbit-oak
@Override
public boolean release(String checkpoint) {
return getNodeStore().release(checkpoint);
}
代码示例来源:origin: apache/jackrabbit-oak
public Void release() {
while (!cancelled && !nodeStore.release(checkpoint)) {}
return null;
}
代码示例来源:origin: apache/jackrabbit-oak
@Override
public boolean release(@NotNull String checkpoint) {
return getNodeStore().release(checkpoint);
}
代码示例来源:origin: org.apache.jackrabbit/oak-core
@Override
public boolean release(@NotNull String checkpoint) {
return getNodeStore().release(checkpoint);
}
代码示例来源:origin: org.apache.jackrabbit/oak-core
public void dispose() {
for (String cp : nodeStore.checkpoints()) {
if ("copy-on-write".equals(nodeStore.checkpointInfo(cp).get("type"))) {
nodeStore.release(cp);
}
}
}
代码示例来源:origin: org.apache.sling/org.apache.sling.testing.sling-mock-oak
public void dispose() {
for (String cp : nodeStore.checkpoints()) {
if ("copy-on-write".equals(nodeStore.checkpointInfo(cp).get("type"))) {
nodeStore.release(cp);
}
}
}
代码示例来源:origin: apache/jackrabbit-oak
public void dispose() {
for (String cp : nodeStore.checkpoints()) {
if ("copy-on-write".equals(nodeStore.checkpointInfo(cp).get("type"))) {
nodeStore.release(cp);
}
}
}
代码示例来源:origin: org.apache.jackrabbit/oak-core
private void updateTempCheckpoints(NodeBuilder async,
String checkpoint, String afterCheckpoint) {
indexStats.setReferenceCheckpoint(checkpoint);
indexStats.setProcessedCheckpoint(afterCheckpoint);
// try to drop temp cps, add 'currentCp' to the temp cps list
Set<String> temps = newHashSet();
for (String cp : getStrings(async, tempCpName)) {
if (cp.equals(checkpoint)) {
temps.add(cp);
continue;
}
boolean released = store.release(cp);
log.debug("[{}] Releasing temporary checkpoint {}: {}", name, cp, released);
if (!released) {
temps.add(cp);
}
}
temps.add(afterCheckpoint);
async.setProperty(tempCpName, temps, Type.STRINGS);
indexStats.setTempCheckpoints(temps);
}
代码示例来源:origin: apache/jackrabbit-oak
@Override
public boolean release(String checkpoint) {
Map<String, String> props;
boolean result;
if (checkpointExists(ctx.getGlobalStore().getNodeStore(), checkpoint)) {
props = ctx.getGlobalStore().getNodeStore().checkpointInfo(checkpoint);
result = ctx.getGlobalStore().getNodeStore().release(checkpoint);
} else {
props = Collections.emptyMap();
result = true;
}
if (LOG.isDebugEnabled()) {
LOG.debug("Released checkpoint {}. Result: {}. Debug info:\n{}", checkpoint, result, checkpointDebugInfo());
}
return result;
}
代码示例来源:origin: apache/jackrabbit-oak
@Test
public void noContentChangeForCheckpoints() throws Exception{
final AtomicInteger invocationCount = new AtomicInteger();
((Observable)store).addObserver(new Observer() {
@Override
public void contentChanged(@NotNull NodeState root, @NotNull CommitInfo info) {
invocationCount.incrementAndGet();
}
});
invocationCount.set(0);
String cp = store.checkpoint(Long.MAX_VALUE);
assertEquals(0, invocationCount.get());
store.release(cp);
assertEquals(0, invocationCount.get());
}
代码示例来源:origin: apache/jackrabbit-oak
@Test
public void checkpoint() throws CommitFailedException {
String cp = store.checkpoint(Long.MAX_VALUE);
NodeBuilder builder = store.getRoot().builder();
builder.setChildNode("new");
store.merge(builder, EmptyHook.INSTANCE, CommitInfo.EMPTY);
assertFalse(root.equals(store.getRoot()));
assertEquals(root, store.retrieve(cp));
assertTrue(store.release(cp));
assertNull(store.retrieve(cp));
}
内容来源于网络,如有侵权,请联系作者删除!