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

QuorumPacket.getAuthinfo介绍

暂无

代码示例

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

boolean revalidateLearnerSession(QuorumPacket qp) throws IOException {
  ByteArrayInputStream bis = new ByteArrayInputStream(qp.getData());
  DataInputStream dis = new DataInputStream(bis);
  long id = dis.readLong();
  boolean valid = dis.readBoolean();
  Iterator<Revalidation> itr = pendingRevalidations.iterator();
  if (!itr.hasNext()) {
    // not a learner session, handle locally
    return false;
  }
  Revalidation revalidation = itr.next();
  if (revalidation.sessionId != id) {
    // not a learner session, handle locally
    return false;
  }
  itr.remove();
  LearnerHandler learnerHandler = revalidation.handler;
  // create a copy here as the qp object is reused by the Follower and may be mutated
  QuorumPacket deepCopy = new QuorumPacket(qp.getType(), qp.getZxid(),
      Arrays.copyOf(qp.getData(), qp.getData().length),
      qp.getAuthinfo() == null ? null : new ArrayList<>(qp.getAuthinfo()));
  learnerHandler.queuePacket(deepCopy);
  // To keep consistent as leader, touch the session when it's
  // revalidating the session, only update if it's a valid session.
  if (valid) {
    touch(revalidation.sessionId, revalidation.timeout);
  }
  return true;
}

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

Request si;
if(type == OpCode.sync){
  si = new LearnerSyncRequest(this, sessionId, cxid, type, bb, qp.getAuthinfo());
} else {
  si = new Request(null, sessionId, cxid, type, bb, qp.getAuthinfo());

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

Request si;
if(type == OpCode.sync){
  si = new LearnerSyncRequest(this, sessionId, cxid, type, bb, qp.getAuthinfo());
} else {
  si = new Request(null, sessionId, cxid, type, bb, qp.getAuthinfo());

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

if(type == OpCode.sync){
   leader.zk.submitRequest(new LearnerSyncRequest(this, sessionId, cxid, type, bb,
      qp.getAuthinfo()));
} else {
  Request si = new Request(null, sessionId, cxid, type, bb, qp.getAuthinfo());
  si.setOwner(this);
  leader.zk.submitRequest(si);