org.apache.jackrabbit.oak.spi.state.NodeStore.release()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(5.7k)|赞(0)|评价(0)|浏览(70)

本文整理了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

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

相关文章