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

QuorumPacket.setZxid介绍

暂无

代码示例

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

Proposal createProposal(long zxid) {
  Proposal p = new Proposal();
  p.packet = new QuorumPacket();
  p.packet.setZxid(zxid);
  p.packet.setType(Leader.PROPOSAL);
  return p;
}

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

private void proposeSetData(QuorumPacket qp, long zxid, String data, int version) throws IOException {
    qp.setType(Leader.PROPOSAL);
    qp.setZxid(zxid);
    TxnHeader hdr = new TxnHeader(4, 1414, qp.getZxid(), 55, ZooDefs.OpCode.setData);
    SetDataTxn sdt = new SetDataTxn("/foo", data.getBytes(), version);
    ByteArrayOutputStream baos = new ByteArrayOutputStream();
    OutputArchive boa = BinaryOutputArchive.getArchive(baos);
    boa.writeRecord(hdr, null);
    boa.writeRecord(sdt, null);
    qp.setData(baos.toByteArray());
  }
});

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

private void proposeSetData(QuorumPacket qp, String path,
      long zxid, String data, int version) throws IOException {
    qp.setType(Leader.PROPOSAL);
    qp.setZxid(zxid);
    TxnHeader hdr = new TxnHeader(4, 1414, qp.getZxid(), 55,
        ZooDefs.OpCode.setData);
    SetDataTxn sdt = new SetDataTxn(path, data.getBytes(), version);
    ByteArrayOutputStream baos = new ByteArrayOutputStream();
    OutputArchive boa = BinaryOutputArchive.getArchive(baos);
    boa.writeRecord(hdr, null);
    boa.writeRecord(sdt, null);
    qp.setData(baos.toByteArray());
  }
});

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

private void proposeNewSession(QuorumPacket qp, long zxid, long sessionId) throws IOException {
    qp.setType(Leader.PROPOSAL);
    qp.setZxid(zxid);
    TxnHeader hdr = new TxnHeader(4, 1414, qp.getZxid(), 55, ZooDefs.OpCode.createSession);
    CreateSessionTxn cst = new CreateSessionTxn(30000);
    ByteArrayOutputStream baos = new ByteArrayOutputStream();
    OutputArchive boa = BinaryOutputArchive.getArchive(baos);
    boa.writeRecord(hdr, null);
    boa.writeRecord(cst, null);
    qp.setData(baos.toByteArray());
  }
});

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

QuorumPacket qp = new QuorumPacket();                
qp.setType(pktType);
qp.setZxid(ZxidUtils.makeZxid(self.getAcceptedEpoch(), 0));

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

ack.setZxid(ZxidUtils.makeZxid(newEpoch, 0));
writePacket(ack, true);
sock.setSoTimeout(self.tickTime * self.syncLimit);

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

QuorumPacket qp = new QuorumPacket();                
qp.setType(pktType);
qp.setZxid(ZxidUtils.makeZxid(self.getAcceptedEpoch(), 0));

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

ack.setZxid(ZxidUtils.makeZxid(newEpoch, 0));
writePacket(ack, true);
sock.setSoTimeout(self.tickTime * self.syncLimit);

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

qp.setZxid(ZxidUtils.makeZxid(1, 0));
byte protoBytes[] = new byte[4];
ByteBuffer.wrap(protoBytes).putInt(0x10000);
qp.setZxid(zkDb.getDataTreeLastProcessedZxid());
oa.writeRecord(qp, null);
final long createSessionZxid = ZxidUtils.makeZxid(1, 2);
oa.writeRecord(qp, null);
qp.setType(Leader.COMMIT);
qp.setZxid(createSessionZxid);
oa.writeRecord(qp, null);
qp.setType(Leader.NEWLEADER);
qp.setZxid(ZxidUtils.makeZxid(1, 0));
qp.setData(null);
oa.writeRecord(qp, null);
qp.setType(Leader.UPTODATE);
qp.setZxid(0);
oa.writeRecord(qp, null);

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

qp.setZxid(ZxidUtils.makeZxid(1, 0));
byte protoBytes[] = new byte[4];
ByteBuffer.wrap(protoBytes).putInt(0x10000);
qp.setZxid(zkDb.getDataTreeLastProcessedZxid());
oa.writeRecord(qp, null);
zkDb.serializeSnapshot(oa);
qp.setZxid(ZxidUtils.makeZxid(1, 0));
oa.writeRecord(qp, null);
qp.setZxid(proposalZxid);
oa.writeRecord(qp, null);
qp.setZxid(0);
oa.writeRecord(qp, null);

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

qp.setZxid(ZxidUtils.makeZxid(1, 0));
byte protoBytes[] = new byte[4];
ByteBuffer.wrap(protoBytes).putInt(0x10000);
qp.setZxid(zkDb.getDataTreeLastProcessedZxid());
oa.writeRecord(qp, null);
zkDb.serializeSnapshot(oa);
oa.writeString("BenWasHere", null);
qp.setType(Leader.NEWLEADER);
qp.setZxid(ZxidUtils.makeZxid(1, 0));
oa.writeRecord(qp, null);
qp.setZxid(proposalZxid);
oa.writeRecord(qp, null);
qp.setZxid(0);
oa.writeRecord(qp, null);

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

qp.setType(pktType);
long sentLastZxid = self.getLastLoggedZxid();
qp.setZxid(sentLastZxid);

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

ack.setZxid(newLeaderZxid & ~0xffffffffL);
writePacket(ack, true);
sock.setSoTimeout(self.tickTime * self.syncLimit);