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

QuorumVerifier.toString介绍

暂无

代码示例

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

@Override
public byte[] getQuorumVerifierBytes() {
  return self.getLastSeenQuorumVerifier().toString().getBytes();
}

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

@Override
public String getQuorumSystemInfo() {
  return peer.getQuorumVerifier().toString();
}

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

@Override
public byte[] getQuorumVerifierBytes() {
  return self.getLastSeenQuorumVerifier().toString().getBytes();
}

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

@Override
  public void write(Writer out) throws IOException {
    Properties cfg = new Properties();
    cfg.load( new StringReader(
        qv.toString()));
    List<String> servers = new ArrayList<String>();
    for (Entry<Object, Object> entry : cfg.entrySet()) {
      String key = entry.getKey().toString().trim();
      if ( !needKeepVersion && key.startsWith("version"))
        continue;
      String value = entry.getValue().toString().trim();
      servers.add(key
          .concat("=")
          .concat(value));
    }
    Collections.sort(servers);
    out.write(StringUtils.joinStrings(servers, "\n"));
  }
});

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

/**
 * Send notifications to all peers upon a change in our vote
 */
private void sendNotifications() {
  for (long sid : self.getCurrentAndNextConfigVoters()) {
    QuorumVerifier qv = self.getQuorumVerifier();
    ToSend notmsg = new ToSend(ToSend.mType.notification,
        proposedLeader,
        proposedZxid,
        logicalclock.get(),
        QuorumPeer.ServerState.LOOKING,
        sid,
        proposedEpoch, qv.toString().getBytes());
    if(LOG.isDebugEnabled()){
      LOG.debug("Sending Notification: " + proposedLeader + " (n.leader), 0x"  +
         Long.toHexString(proposedZxid) + " (n.zxid), 0x" + Long.toHexString(logicalclock.get())  +
         " (n.round), " + sid + " (recipient), " + self.getId() +
         " (myid), 0x" + Long.toHexString(proposedEpoch) + " (n.peerEpoch)");
    }
    sendqueue.offer(notmsg);
  }
}

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

@Override
public void dumpConf(PrintWriter pwriter) {
  super.dumpConf(pwriter);
  pwriter.print("initLimit=");
  pwriter.println(self.getInitLimit());
  pwriter.print("syncLimit=");
  pwriter.println(self.getSyncLimit());
  pwriter.print("electionAlg=");
  pwriter.println(self.getElectionType());
  pwriter.print("electionPort=");
  pwriter.println(self.getElectionAddress().getPort());
  pwriter.print("quorumPort=");
  pwriter.println(self.getQuorumAddress().getPort());
  pwriter.print("peerType=");
  pwriter.println(self.getLearnerType().ordinal());
  pwriter.println("membership: ");
  pwriter.print(new String(self.getQuorumVerifier().toString().getBytes()));
}

代码示例来源：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

members = QuorumPeerConfig.parseDynamicConfig(dynamicCfg, 0, true, false).toString();
} catch (Exception e) {
  throw new CliParseException("Error processing " + cl.getOptionValue("file") + e.getMessage());

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

response.sid,
current.getPeerEpoch(),
qv.toString().getBytes());
    response.sid,
    v.getPeerEpoch(),
    qv.toString().getBytes());
sendqueue.offer(notmsg);
    response.sid,
    current.getPeerEpoch(),
    qv.toString().getBytes());
sendqueue.offer(notmsg);

代码示例来源：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

request.setTxn(new SetDataTxn(ZooDefs.CONFIG_NODE, request.qv.toString().getBytes(), -1));
nodeRecord = nodeRecord.duplicate(request.getHdr().getZxid());
nodeRecord.stat.setVersion(-1);

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

rsp = new GetDataResponse(((QuorumZooKeeperServer)zks).self.getQuorumVerifier().toString().getBytes(), rc.stat);
err = Code.get(rc.err);
break;

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

QuorumVerifier newQV = self.configFromString(curQV.toString());
newQV.setVersion(zk.getZxid());
self.setLastSeenQuorumVerifier(newQV, true);