com.alibaba.wasp.zookeeper.ZKUtil.deleteNodeFailSilent()方法的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(2.1k)|赞(0)|评价(0)|浏览(135)

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

ZKUtil.deleteNodeFailSilent介绍

[英]Deletes the specified node. Fails silent if the node does not exist.
[中]删除指定的节点。如果节点不存在,则失败为静默。

代码示例

代码示例来源:origin: alibaba/wasp

  1. /**
  2. * Deletes the table in zookeeper. Fails silently if the table is not
  3. * currently disabled in zookeeper. Sets no watches.
  4. *
  5. * @param tableName
  6. * @throws org.apache.zookeeper.KeeperException
  7. * unexpected zookeeper exception
  8. */
  9. public void setDeletedTable(final String tableName) throws KeeperException {
  10. synchronized (this.cache) {
  11. if (this.cache.remove(tableName) == null) {
  12. LOG.warn("Moving table " + tableName + " state to deleted but was "
  13. + "already deleted");
  14. }
  15. ZKUtil.deleteNodeFailSilent(this.watcher,
  16. ZKUtil.joinZNode(this.watcher.tableZNode, tableName));
  17. }
  18. }

代码示例来源:origin: alibaba/wasp

  1. /**
  2. * Delete the assignment node regardless of its current state.
  3. * <p>
  4. * Fail silent even if the node does not exist at all.
  5. * @param watcher
  6. * @param entityGroupInfo
  7. * @throws org.apache.zookeeper.KeeperException
  8. */
  9. public static void deleteNodeFailSilent(ZooKeeperWatcher watcher,
  10. EntityGroupInfo entityGroupInfo) throws KeeperException {
  11. String node = getNodeName(watcher, entityGroupInfo.getEncodedName());
  12. ZKUtil.deleteNodeFailSilent(watcher, node);
  13. }

代码示例来源:origin: alibaba/wasp

  1. @Override
  2. EntityGroup openEntityGroup() {
  3. // Open entityGroup first, then remove znode as though it'd been
  4. // hijacked.
  5. EntityGroup entityGroup = super.openEntityGroup();
  6. // Don't actually open entityGroup BUT remove the znode as though it'd
  7. // been hijacked on us.
  8. ZooKeeperWatcher zkw = this.server.getZooKeeper();
  9. String node = ZKAssign.getNodeName(zkw, egi.getEncodedName());
  10. try {
  11. ZKUtil.deleteNodeFailSilent(zkw, node);
  12. } catch (KeeperException e) {
  13. throw new RuntimeException("Ugh failed delete of " + node, e);
  14. }
  15. return entityGroup;
  16. }
  17. };

代码示例来源:origin: alibaba/wasp

  1. LOG.info("Deleting ZNode for " + backupZNode
  2. + " from backup master directory");
  3. ZKUtil.deleteNodeFailSilent(this.watcher, backupZNode);

相关文章