org.apache.zookeeper.data.Stat.setVersion()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(8.8k)|赞(0)|评价(0)|浏览(124)

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

Stat.setVersion介绍

暂无

代码示例

代码示例来源：origin: org.apache.hadoop/hadoop-common

private void addOrUpdateToken(TokenIdent ident,
  DelegationTokenInformation info, boolean isUpdate) throws Exception {
 String nodeCreatePath =
   getNodePath(ZK_DTSM_TOKENS_ROOT, DELEGATION_TOKEN_PREFIX
     + ident.getSequenceNumber());
 try (ByteArrayOutputStream tokenOs = new ByteArrayOutputStream();
    DataOutputStream tokenOut = new DataOutputStream(tokenOs)) {
  ident.write(tokenOut);
  tokenOut.writeLong(info.getRenewDate());
  tokenOut.writeInt(info.getPassword().length);
  tokenOut.write(info.getPassword());
  if (LOG.isDebugEnabled()) {
   LOG.debug((isUpdate ? "Updating " : "Storing ")
     + "ZKDTSMDelegationToken_" +
     ident.getSequenceNumber());
  }
  if (isUpdate) {
   zkClient.setData().forPath(nodeCreatePath, tokenOs.toByteArray())
     .setVersion(-1);
  } else {
   zkClient.create().withMode(CreateMode.PERSISTENT)
     .forPath(nodeCreatePath, tokenOs.toByteArray());
  }
 }
}

代码示例来源：origin: apache/pulsar

@Override
public Stat exists(String path, boolean watch) throws KeeperException, InterruptedException {
  mutex.lock();
  try {
    checkProgrammedFail();
    if (stopped)
      throw new KeeperException.ConnectionLossException();
    if (tree.containsKey(path)) {
      Stat stat = new Stat();
      stat.setVersion(tree.get(path).getRight());
      return stat;
    } else {
      return null;
    }
  } finally {
    mutex.unlock();
  }
}

代码示例来源：origin: apache/pulsar

@Override
public Stat exists(String path, Watcher watcher) throws KeeperException, InterruptedException {
  mutex.lock();
  try {
    checkProgrammedFail();
    if (stopped)
      throw new KeeperException.ConnectionLossException();
    if (watcher != null) {
      watchers.put(path, watcher);
    }
    if (tree.containsKey(path)) {
      Stat stat = new Stat();
      stat.setVersion(tree.get(path).getRight());
      return stat;
    } else {
      return null;
    }
  } finally {
    mutex.unlock();
  }
}

代码示例来源：origin: apache/pulsar

@Override
public byte[] getData(String path, Watcher watcher, Stat stat) throws KeeperException {
  mutex.lock();
  try {
    checkProgrammedFail();
    Pair<byte[], Integer> value = tree.get(path);
    if (value == null) {
      throw new KeeperException.NoNodeException(path);
    } else {
      if (watcher != null) {
        watchers.put(path, watcher);
      }
      if (stat != null) {
        stat.setVersion(value.getRight());
      }
      return value.getLeft();
    }
  } finally {
    mutex.unlock();
  }
}

代码示例来源：origin: apache/zookeeper

ACLCB(ZooKeeper zk, CountDownLatch latch) {
  super(zk, latch);
  stat.setAversion(0);
  stat.setCversion(0);
  stat.setEphemeralOwner(0);
  stat.setVersion(0);
}

代码示例来源：origin: apache/zookeeper

DataCB(ZooKeeper zk, CountDownLatch latch) {
  super(zk, latch);
  stat.setAversion(0);
  stat.setCversion(0);
  stat.setEphemeralOwner(0);
  stat.setVersion(0);
}

代码示例来源：origin: apache/zookeeper

StatCB(ZooKeeper zk, CountDownLatch latch) {
  super(zk, latch);
  stat.setAversion(0);
  stat.setCversion(0);
  stat.setEphemeralOwner(0);
  stat.setVersion(0);
}

代码示例来源：origin: apache/incubator-pinot

@Override
 public LLCRealtimeSegmentZKMetadata getRealtimeSegmentZKMetadata(String realtimeTableName, String segmentName,
   Stat stat) {
  LLCRealtimeSegmentZKMetadata metadata = super.getRealtimeSegmentZKMetadata(realtimeTableName, segmentName, stat);
  switch (_scenario) {
   case SCENARIO_1_ZK_VERSION_NUM_HAS_CHANGE:
    // Mock another controller has already updated the segment metadata, which makes the version number self increase.
    stat.setVersion(_version + 1);
    break;
   case SCENARIO_2_METADATA_STATUS_HAS_CHANGE:
    // Mock another controller has updated the status of the old segment metadata.
    metadata.setStatus(CommonConstants.Segment.Realtime.Status.DONE);
    break;
  }
  return metadata;
 }
}

代码示例来源：origin: apache/pulsar

stat.setVersion(newVersion);
return stat;

代码示例来源：origin: apache/pulsar

@Override
public void getData(final String path, final Watcher watcher, final DataCallback cb, final Object ctx) {
  executor.execute(() -> {
    checkReadOpDelay();
    mutex.lock();
    if (getProgrammedFailStatus()) {
      mutex.unlock();
      cb.processResult(failReturnCode.intValue(), path, ctx, null, null);
      return;
    } else if (stopped) {
      mutex.unlock();
      cb.processResult(KeeperException.Code.CONNECTIONLOSS.intValue(), path, ctx, null, null);
      return;
    }
    Pair<byte[], Integer> value = tree.get(path);
    if (value == null) {
      mutex.unlock();
      cb.processResult(KeeperException.Code.NONODE.intValue(), path, ctx, null, null);
    } else {
      if (watcher != null) {
        watchers.put(path, watcher);
      }
      Stat stat = new Stat();
      stat.setVersion(value.getRight());
      mutex.unlock();
      cb.processResult(0, path, ctx, value.getLeft(), stat);
    }
  });
}

代码示例来源：origin: apache/zookeeper

public void verifySetData() {
  stat.setVersion(1);
  new StringCB(zk).verifyCreate();
  setData();
  verify();
}

代码示例来源：origin: apache/pulsar

@Override
public void getData(final String path, boolean watch, final DataCallback cb, final Object ctx) {
  executor.execute(() -> {
    checkReadOpDelay();
    if (getProgrammedFailStatus()) {
      cb.processResult(failReturnCode.intValue(), path, ctx, null, null);
      return;
    } else if (stopped) {
      cb.processResult(KeeperException.Code.ConnectionLoss, path, ctx, null, null);
      return;
    }
    Pair<byte[], Integer> value;
    mutex.lock();
    try {
      value = tree.get(path);
    } finally {
      mutex.unlock();
    }
    if (value == null) {
      cb.processResult(KeeperException.Code.NoNode, path, ctx, null, null);
    } else {
      Stat stat = new Stat();
      stat.setVersion(value.getRight());
      cb.processResult(0, path, ctx, value.getLeft(), stat);
    }
  });
}

代码示例来源：origin: apache/pulsar

tree.put(path, Pair.of(data, newVersion));
Stat stat = new Stat();
stat.setVersion(newVersion);

代码示例来源：origin: org.apache.zookeeper/zookeeper

public void copyStat(Stat to) {
  to.setAversion(stat.getAversion());
  to.setCtime(stat.getCtime());
  to.setCversion(stat.getCversion());
  to.setCzxid(stat.getCzxid());
  to.setMtime(stat.getMtime());
  to.setMzxid(stat.getMzxid());
  to.setVersion(stat.getVersion());
  to.setEphemeralOwner(stat.getEphemeralOwner());
  to.setDataLength(data.length);
  to.setNumChildren(children.size());
}

代码示例来源：origin: apache/zookeeper

synchronized public void copyStat(Stat to) {
  to.setAversion(stat.getAversion());
  to.setCtime(stat.getCtime());
  to.setCzxid(stat.getCzxid());
  to.setMtime(stat.getMtime());
  to.setMzxid(stat.getMzxid());
  to.setPzxid(stat.getPzxid());
  to.setVersion(stat.getVersion());
  to.setEphemeralOwner(getClientEphemeralOwner(stat));
  to.setDataLength(data == null ? 0 : data.length);
  int numChildren = 0;
  if (this.children != null) {
    numChildren = children.size();
  }
  // when we do the Cversion we need to translate from the count of the creates
  // to the count of the changes (v3 semantics)
  // for every create there is a delete except for the children still present
  to.setCversion(stat.getCversion()*2 - numChildren);
  to.setNumChildren(numChildren);
}

代码示例来源：origin: apache/zookeeper

/**
 * Create a new Stat, fill in dummy values trying to catch Assert.failure
 * to copy in client or server code.
 *
 * @return a new stat with dummy values
 */
private Stat newStat() {
  Stat stat = new Stat();
  stat.setAversion(100);
  stat.setCtime(100);
  stat.setCversion(100);
  stat.setCzxid(100);
  stat.setDataLength(100);
  stat.setEphemeralOwner(100);
  stat.setMtime(100);
  stat.setMzxid(100);
  stat.setNumChildren(100);
  stat.setPzxid(100);
  stat.setVersion(100);
  return stat;
}

代码示例来源：origin: apache/zookeeper

static public void copyStat(Stat from, Stat to) {
  to.setAversion(from.getAversion());
  to.setCtime(from.getCtime());
  to.setCversion(from.getCversion());
  to.setCzxid(from.getCzxid());
  to.setMtime(from.getMtime());
  to.setMzxid(from.getMzxid());
  to.setPzxid(from.getPzxid());
  to.setVersion(from.getVersion());
  to.setEphemeralOwner(from.getEphemeralOwner());
  to.setDataLength(from.getDataLength());
  to.setNumChildren(from.getNumChildren());
}

代码示例来源：origin: org.apache.zookeeper/zookeeper

synchronized public void copyStat(Stat to) {
  to.setAversion(stat.getAversion());
  to.setCtime(stat.getCtime());
  to.setCzxid(stat.getCzxid());
  to.setMtime(stat.getMtime());
  to.setMzxid(stat.getMzxid());
  to.setPzxid(stat.getPzxid());
  to.setVersion(stat.getVersion());
  to.setEphemeralOwner(stat.getEphemeralOwner());
  to.setDataLength(data == null ? 0 : data.length);
  int numChildren = 0;
  if (this.children != null) {
    numChildren = children.size();
  }
  // when we do the Cversion we need to translate from the count of the creates
  // to the count of the changes (v3 semantics)
  // for every create there is a delete except for the children still present
  to.setCversion(stat.getCversion()*2 - numChildren);
  to.setNumChildren(numChildren);
}

代码示例来源：origin: org.apache.zookeeper/zookeeper

static public void copyStat(Stat from, Stat to) {
  to.setAversion(from.getAversion());
  to.setCtime(from.getCtime());
  to.setCversion(from.getCversion());
  to.setCzxid(from.getCzxid());
  to.setMtime(from.getMtime());
  to.setMzxid(from.getMzxid());
  to.setVersion(from.getVersion());
  to.setEphemeralOwner(from.getEphemeralOwner());
  to.setDataLength(from.getDataLength());
  to.setNumChildren(from.getNumChildren());
}

代码示例来源：origin: org.apache.zookeeper/zookeeper

static public void copyStat(Stat from, Stat to) {
  to.setAversion(from.getAversion());
  to.setCtime(from.getCtime());
  to.setCversion(from.getCversion());
  to.setCzxid(from.getCzxid());
  to.setMtime(from.getMtime());
  to.setMzxid(from.getMzxid());
  to.setPzxid(from.getPzxid());
  to.setVersion(from.getVersion());
  to.setEphemeralOwner(from.getEphemeralOwner());
  to.setDataLength(from.getDataLength());
  to.setNumChildren(from.getNumChildren());
}

内容来源于网络，如有侵权，请联系作者删除！

stat

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com