本文整理了Java中org.apache.zookeeper.server.ZKDatabase.getEphemerals()
方法的一些代码示例,展示了ZKDatabase.getEphemerals()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZKDatabase.getEphemerals()
方法的具体详情如下:
包路径:org.apache.zookeeper.server.ZKDatabase
类名称: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) {
内容来源于网络,如有侵权,请联系作者删除!