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

ZooKeeperServer.takeSnapshot介绍

暂无

代码示例

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

public void takeSnapshot() {
  takeSnapshot(false);
}

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

public void run() {
    try {
      zks.takeSnapshot();
    } catch(Exception e) {
      LOG.warn("Unexpected exception", e);
    }
  }
};

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

public void run() {
    try {
      zks.takeSnapshot();
    } catch(Exception e) {
      LOG.warn("Unexpected exception", e);
    }
  }
};

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

@Override
  public void process(String path) {
    LOG.info("Take a snapshot");
    zkServer.takeSnapshot(true);
  }
});

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

@Override
  public void process(long sessionId) {
    LOG.info("Take snapshot");
    if (shouldTakeSnapshot.getAndSet(false)) {
      zkServer.takeSnapshot(true);
    }
  }
});

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

takeSnapshot();

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

/**
 * It's possible during taking fuzzy snapshot, the parent is serialized
 * before the child get deleted in the fuzzy range.
 *
 * In which case, we need to make sure the pzxid get correctly updated
 * when replaying the txns.
 */
@Test
public void testPZxidUpdatedWhenLoadingSnapshot() throws Exception {
  final String parent = "/testPZxidUpdatedDuringTakingSnapshot";
  final String child = parent + "/child";
  createEmptyNode(zk[followerA], parent);
  createEmptyNode(zk[followerA], child);
  LOG.info("Set up ZKDatabase to catch the node serializing in DataTree");
  addSerializeListener(followerA, parent, child);
  LOG.info("Take snapshot on follower A");
  ZooKeeperServer zkServer = mt[followerA].main.quorumPeer.getActiveServer();
  zkServer.takeSnapshot(true);
  LOG.info("Restarting follower A to load snapshot");
  mt[followerA].shutdown();
  QuorumPeerMainTest.waitForOne(zk[followerA], States.CONNECTING);
  mt[followerA].start();
  QuorumPeerMainTest.waitForOne(zk[followerA], States.CONNECTED);
  LOG.info("Check and make sure the pzxid of the parent is the same " +
      "on leader and follower A");
  compareStat(parent, leaderId, followerA);
}

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

/**
   * ZOOKEEPER-1573: test restoring a snapshot with deleted txns ahead of the
   * snapshot file's zxid.
   */
  @Test
  public void testReloadSnapshotWithMissingParent() throws Exception {
    // create transactions to create the snapshot with create/delete pattern
    ZooKeeper zk = createZKClient(hostPort);
    zk.create("/a", "".getBytes(), Ids.OPEN_ACL_UNSAFE,
        CreateMode.PERSISTENT);
    Stat stat = zk.exists("/a", false);
    long createZxId = stat.getMzxid();
    zk.create("/a/b", "".getBytes(), Ids.OPEN_ACL_UNSAFE,
        CreateMode.PERSISTENT);
    zk.delete("/a/b", -1);
    zk.delete("/a", -1);
    // force the zxid to be behind the content
    ZooKeeperServer zks = getServer(serverFactory);
    zks.getZKDatabase().setlastProcessedZxid(createZxId);
    LOG.info("Set lastProcessedZxid to {}", zks.getZKDatabase()
        .getDataTreeLastProcessedZxid());
    // Force snapshot and restore
    zks.takeSnapshot();
    zks.shutdown();
    stopServer();

    startServer();
  }
}

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

+ zks.getZKDatabase().getDataTreeLastProcessedZxid());
zks.takeSnapshot();
zks.shutdown();
stopServer();

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

zks.takeSnapshot();
zks.shutdown();
stopServer();

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

CreateMode.PERSISTENT);
zks.takeSnapshot();

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

public void run() {
    try {
      zks.takeSnapshot();
    } catch(Exception e) {
      LOG.warn("Unexpected exception", e);
    }
  }
};

代码示例来源：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();
}