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

ZKDatabase.getSessions介绍

[英]return the sessions in the datatree
[中]返回数据树中的会话

代码示例

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

for (Long session : zkDb.getSessions()) {
  if (zkDb.getSessionWithTimeOuts().get(session) == null) {
    deadSessions.add(session);

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

for (Long session : zkDb.getSessions()) {
  if (zkDb.getSessionWithTimeOuts().get(session) == null) {
    deadSessions.add(session);

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

"Current epoch: " + epochF, epochF == epochL);
int leaderIndex = (index == 1) ? 2 : 1;
Collection<Long> sessionsRestarted = qu.getPeer(index).peer.getActiveServer().getZKDatabase().getSessions();
Collection<Long> sessionsNotRestarted = qu.getPeer(leaderIndex).peer.getActiveServer().getZKDatabase().getSessions();

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

zkDb2.loadDataBase();
LOG.info("zkdb2 sessions:" + zkDb2.getSessions());
LOG.info("zkdb2 with timeouts:" + zkDb2.getSessionWithTimeOuts());
Assert.assertNotNull(zkDb2.getSessionWithTimeOuts().get(4L));

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

/**
 *  Restore sessions and data
 */
public void loadData() throws IOException, InterruptedException {
  zkDb.loadDataBase();
  setZxid(zkDb.loadDataBase());
  // Clean up dead sessions
  LinkedList<Long> deadSessions = new LinkedList<Long>();
  for (long session : zkDb.getSessions()) {
    sessionsWithTimeouts = zkDb.getSessionWithTimeOuts();
    if (sessionsWithTimeouts.get(session) == null) {
      deadSessions.add(session);
    }
  }
  zkDb.setDataTreeInit(true);
  for (long session : deadSessions) {
    // XXX: Is lastProcessedZxid really the best thing to use?
    killSession(session, zkDb.getDataTreeLastProcessedZxid());
  }
  // Make a clean snapshot
  takeSnapshot();
}