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

QuorumVerifier.getVersion介绍

暂无

代码示例

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

@Override
public long getQuorumVerifierVersion() {
  return self.getQuorumVerifier().getVersion();
}

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

private void printNotification(Notification n) {
  LOG.info("Notification: my state:{}; n.sid:{}, n.state:{}, n.leader:{}, n.round:0x{}, " +
          "n.peerEpoch:0x{}, n.zxid:0x{}, message format version:0x{}, n.config version:0x{}",
      self.getPeerState(), n.sid, n.state, n.leader, Long.toHexString(n.electionEpoch),
      Long.toHexString(n.peerEpoch), Long.toHexString(n.zxid), Long.toHexString(n.version),
      (n.qv != null ? (Long.toHexString(n.qv.getVersion())) : "0"));
}

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

@Override
public long getQuorumVerifierVersion() {
  return self.getQuorumVerifier().getVersion();
}

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

public long getConfigVersion(){
  return peer.getQuorumVerifier().getVersion();
}

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

synchronized (outerLockObject) {
  synchronized (QV_LOCK) {
    if (lastSeenQuorumVerifier != null && lastSeenQuorumVerifier.getVersion() > qv.getVersion()) {
      LOG.error("setLastSeenQuorumVerifier called with stale config " + qv.getVersion() +
          ". Current version: " + quorumVerifier.getVersion());
        lastSeenQuorumVerifier.getVersion() == qv.getVersion()) {
      return;

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

public QuorumVerifier setQuorumVerifier(QuorumVerifier qv, boolean writeToDisk){
  synchronized (QV_LOCK) {
    if ((quorumVerifier != null) && (quorumVerifier.getVersion() >= qv.getVersion())) {
      LOG.debug(getId() + " setQuorumVerifier called with known or old config " + qv.getVersion() +
          ". Current version: " + quorumVerifier.getVersion());
      return quorumVerifier;
    if (lastSeenQuorumVerifier == null || (qv.getVersion() > lastSeenQuorumVerifier.getVersion()))
      lastSeenQuorumVerifier = qv;
        try {
          String dynamicConfigFilename = makeDynamicConfigFilename(
              qv.getVersion());
          QuorumPeerConfig.writeDynamicConfig(
              dynamicConfigFilename, qv, false);
    if (qv.getVersion() == lastSeenQuorumVerifier.getVersion()) {
      QuorumPeerConfig.deleteFile(getNextDynamicConfigFilename());

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

public synchronized void initConfigInZKDatabase(QuorumVerifier qv) {
  if (qv == null) return; // only happens during tests
  try {
    if (this.dataTree.getNode(ZooDefs.CONFIG_NODE) == null) {
      // should only happen during upgrade
      LOG.warn("configuration znode missing (should only happen during upgrade), creating the node");
      this.dataTree.addConfigNode();
    }
    this.dataTree.setData(ZooDefs.CONFIG_NODE, qv.toString().getBytes(), -1, qv.getVersion(), Time.currentWallTime());
  } catch (NoNodeException e) {
    System.out.println("configuration node missing - should not happen");
  }
}

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

/**
 * Given a set of votes, return the SyncedLearnerTracker which is used to
 * determines if have sufficient to declare the end of the election round.
 *
 * @param votes
 *            Set of votes
 * @param vote
 *            Identifier of the vote received last
 * @return the SyncedLearnerTracker with vote details
 */
protected SyncedLearnerTracker getVoteTracker(Map<Long, Vote> votes, Vote vote) {
  SyncedLearnerTracker voteSet = new SyncedLearnerTracker();
  voteSet.addQuorumVerifier(self.getQuorumVerifier());
  if (self.getLastSeenQuorumVerifier() != null
      && self.getLastSeenQuorumVerifier().getVersion() > self
          .getQuorumVerifier().getVersion()) {
    voteSet.addQuorumVerifier(self.getLastSeenQuorumVerifier());
  }
  /*
   * First make the views consistent. Sometimes peers will have different
   * zxids for a server depending on timing.
   */
  for (Map.Entry<Long, Vote> entry : votes.entrySet()) {
    if (vote.equals(entry.getValue())) {
      voteSet.addAck(entry.getKey());
    }
  }
  return voteSet;
}

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

rqv = self.configFromString(new String(b));
QuorumVerifier curQV = self.getQuorumVerifier();
if (rqv.getVersion() > curQV.getVersion()) {
  LOG.info("{} Received version: {} my version: {}", self.getId(),
      Long.toHexString(rqv.getVersion()),
      Long.toHexString(self.getQuorumVerifier().getVersion()));
  if (self.getPeerState() == ServerState.LOOKING) {
    LOG.debug("Invoking processReconfig(), state: {}", self.getServerState());
      Long.toHexString(current.getZxid()),
      current.getId(),
      Long.toHexString(self.getQuorumVerifier().getVersion()));

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

if (prevQV.getVersion() < qv.getVersion() && !prevQV.equals(qv)) {
  Map<Long, QuorumServer> newMembers = qv.getAllMembers();
  updateRemotePeerMXBeans(newMembers);

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

if (self.getQuorumVerifier().getVersion()<self.getLastSeenQuorumVerifier().getVersion()) {
  p.addQuorumVerifier(self.getLastSeenQuorumVerifier());

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

LearnerInfo li = new LearnerInfo(self.getId(), 0x10000, self.getQuorumVerifier().getVersion());
ByteArrayOutputStream bsid = new ByteArrayOutputStream();
BinaryOutputArchive boa = BinaryOutputArchive.getArchive(bsid);

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

if (curQV.getVersion() == 0 && curQV.getVersion() == lastSeenQV.getVersion()) {
if (self.getLastSeenQuorumVerifier().getVersion() > self.getQuorumVerifier().getVersion()){
  newLeaderProposal.addQuorumVerifier(self.getLastSeenQuorumVerifier());
    syncedAckSet.addQuorumVerifier(self.getQuorumVerifier());
    if (self.getLastSeenQuorumVerifier() != null
        && self.getLastSeenQuorumVerifier().getVersion() > self
            .getQuorumVerifier().getVersion()) {
      syncedAckSet.addQuorumVerifier(self
          .getLastSeenQuorumVerifier());

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

private void assertLocalPeerMXBeanAttributes(QuorumPeer qp,
    String beanName, Boolean isPartOfEnsemble) throws Exception {
  Assert.assertEquals("Mismatches LearnerType!", qp.getLearnerType()
      .name(), JMXEnv.ensureBeanAttribute(beanName, "LearnerType"));
  Assert.assertEquals("Mismatches ClientAddress!",
      qp.getClientAddress().getHostString() + ":" + qp.getClientAddress().getPort(),
      JMXEnv.ensureBeanAttribute(beanName, "ClientAddress"));
  Assert.assertEquals("Mismatches LearnerType!",
      qp.getElectionAddress().getHostString() + ":" + qp.getElectionAddress().getPort(),
      JMXEnv.ensureBeanAttribute(beanName, "ElectionAddress"));
  Assert.assertEquals("Mismatches PartOfEnsemble!", isPartOfEnsemble,
      JMXEnv.ensureBeanAttribute(beanName, "PartOfEnsemble"));
  Assert.assertEquals("Mismatches ConfigVersion!", qp.getQuorumVerifier()
      .getVersion(), JMXEnv.ensureBeanAttribute(beanName,
      "ConfigVersion"));
  Assert.assertEquals("Mismatches QuorumSystemInfo!", qp
      .getQuorumVerifier().toString(), JMXEnv.ensureBeanAttribute(
      beanName, "QuorumSystemInfo"));
}

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

@Test
public void testInitialConfigHasPositiveVersion() throws Exception {
  qu = new QuorumUtil(1); // create 3 servers
  qu.disableJMXTest = true;
  qu.startAll();
  zkArr = createHandles(qu);
  testNormalOperation(zkArr[1], zkArr[2]);
  for (int i=1; i<4; i++) {
    String configStr = testServerHasConfig(zkArr[i], null, null);
    QuorumVerifier qv = qu.getPeer(i).peer.configFromString(configStr);
    long version = qv.getVersion();
    Assert.assertTrue(version == 0x100000000L);
  }
}

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

long version = qv.getVersion();

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

if (lastSeenQV.getVersion()!=lzks.self.getQuorumVerifier().getVersion()) {
    throw new KeeperException.ReconfigInProgress();
if (configId != -1 && configId!=lzks.self.getLastSeenQuorumVerifier().getVersion()){
  String msg = "Reconfiguration from version " + configId + " failed -- last seen version is " +
      lzks.self.getLastSeenQuorumVerifier().getVersion();
  throw new KeeperException.BadVersionException(msg);