org.apache.zookeeper.server.ZKDatabase.getEphemerals()方法的使用及代码示例

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

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

ZKDatabase.getEphemerals介绍

[英]the paths for ephemeral session id
[中]临时会话id的路径

代码示例

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

public Map<Long, Set<String>> getEphemerals() {
  return zkDb.getEphemerals();
}

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

public String[] getEphemeralNodes() {
  if(zk.getZKDatabase()  !=null){
    String[] res = zk.getZKDatabase().getEphemerals(sessionId)
      .toArray(new String[0]);
    Arrays.sort(res);
    return res;
  }
  return null;
}

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

public String[] getEphemeralNodes() {
  if(zk.getZKDatabase()  !=null){
    String[] res = zk.getZKDatabase().getEphemerals(sessionId)
      .toArray(new String[0]);
    Arrays.sort(res);
    return res;
  }
  return null;
}

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

LOG.info("Validating ephemeral for session id 0x{}", Long.toHexString(l));
assertTrue("Should have same set of sessions in both servers, did not expect: " + l, sessionsNotRestarted.contains(l));
Set<String> ephemerals = restarted.getEphemerals(l);
Set<String> cleanEphemerals = clean.getEphemerals(l);
for(String o : cleanEphemerals) {
  if(!ephemerals.contains(o)) {
Set<String> leadEphemerals = lead.getEphemerals(l);
for(String o : leadEphemerals) {
  if(!cleanEphemerals.contains(o)) {
assertEquals("Leader should equal follower", lead.getEphemerals(l).size(), cleanEphemerals.size());

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

.getEphemerals(request.sessionId);
synchronized (zks.outstandingChanges) {
  for (ChangeRecord c : zks.outstandingChanges) {

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

.getEphemerals(request.sessionId);
synchronized (zks.outstandingChanges) {
  for (ChangeRecord c : zks.outstandingChanges) {

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

public String[] getEphemeralNodes() {
  if(zk.getZKDatabase()  !=null){
    String[] res= zk.getZKDatabase().getEphemerals(sessionId)
      .toArray(new String[0]);
    Arrays.sort(res);
    return res;
  }
  return null;
}

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

.getEphemerals(request.sessionId);
synchronized (zks.outstandingChanges) {
  for (ChangeRecord c : zks.outstandingChanges) {

相关文章