本文整理了Java中org.apache.zookeeper.server.util.ZxidUtils.getEpochFromZxid()
方法的一些代码示例,展示了ZxidUtils.getEpochFromZxid()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZxidUtils.getEpochFromZxid()
方法的具体详情如下:
包路径:org.apache.zookeeper.server.util.ZxidUtils
类名称:ZxidUtils
方法名:getEpochFromZxid
暂无
代码示例来源:origin: apache/zookeeper
/**
* Returns the current epoch of the leader.
*
* @return
*/
public long getEpoch(){
return ZxidUtils.getEpochFromZxid(lastProposed);
}
代码示例来源:origin: org.apache.zookeeper/zookeeper
/**
* Returns the current epoch of the leader.
*
* @return
*/
public long getEpoch(){
return ZxidUtils.getEpochFromZxid(lastProposed);
}
代码示例来源:origin: apache/zookeeper
long epochOfZxid = ZxidUtils.getEpochFromZxid(lastProcessedZxid);
try {
currentEpoch = readLongFromFile(CURRENT_EPOCH_FILENAME);
代码示例来源:origin: apache/zookeeper
long txnEpoch = ZxidUtils.getEpochFromZxid(txnZxid);
long txnCounter = ZxidUtils.getCounterFromZxid(txnZxid);
long previousEpoch = ZxidUtils.getEpochFromZxid(previousZxid);
if (txnEpoch == previousEpoch) {
System.out.println(
代码示例来源:origin: apache/zookeeper
if (ZxidUtils.getEpochFromZxid(packetZxid) !=
ZxidUtils.getEpochFromZxid(peerLastZxid)) {
代码示例来源:origin: org.apache.zookeeper/zookeeper
long epochOfZxid = ZxidUtils.getEpochFromZxid(lastProcessedZxid);
try {
currentEpoch = readLongFromFile(CURRENT_EPOCH_FILENAME);
代码示例来源:origin: apache/zookeeper
rpeerepoch = ZxidUtils.getEpochFromZxid(rzxid);
代码示例来源:origin: org.apache.zookeeper/zookeeper
long newEpoch = ZxidUtils.getEpochFromZxid(newEpochZxid);
if (newEpoch < self.getAcceptedEpoch()) {
LOG.error("Proposed leader epoch " + ZxidUtils.zxidToString(newEpochZxid)
代码示例来源:origin: org.apache.zookeeper/zookeeper
LOG.info("Backward compatibility mode, server id=" + n.sid);
n.peerEpoch = ZxidUtils.getEpochFromZxid(n.zxid);
代码示例来源:origin: apache/zookeeper
long lastAcceptedEpoch = ZxidUtils.getEpochFromZxid(qp.getZxid());
long epoch = ZxidUtils.getEpochFromZxid(zxid);
ss = new StateSummary(epoch, zxid);
代码示例来源:origin: apache/zookeeper
final long newEpoch = ZxidUtils.getEpochFromZxid(qp.getZxid());
if (qp.getType() == Leader.LEADERINFO) {
代码示例来源:origin: apache/zookeeper
long newEpoch = ZxidUtils.getEpochFromZxid(newEpochZxid);
if (newEpoch < self.getAcceptedEpoch()) {
LOG.error("Proposed leader epoch " + ZxidUtils.zxidToString(newEpochZxid)
代码示例来源:origin: org.apache.zookeeper/zookeeper
long lastAcceptedEpoch = ZxidUtils.getEpochFromZxid(qp.getZxid());
long epoch = ZxidUtils.getEpochFromZxid(zxid);
ss = new StateSummary(epoch, zxid);
代码示例来源:origin: apache/zookeeper
QuorumPacket ack = new QuorumPacket(Leader.ACK, 0, null, null);
QuorumPacket qp = new QuorumPacket();
long newEpoch = ZxidUtils.getEpochFromZxid(newLeaderZxid);
代码示例来源:origin: org.apache.zookeeper/zookeeper
final long newEpoch = ZxidUtils.getEpochFromZxid(qp.getZxid());
if (qp.getType() == Leader.LEADERINFO) {
代码示例来源:origin: org.apache.zookeeper/zookeeper
QuorumPacket ack = new QuorumPacket(Leader.ACK, 0, null, null);
QuorumPacket qp = new QuorumPacket();
long newEpoch = ZxidUtils.getEpochFromZxid(newLeaderZxid);
代码示例来源:origin: jboss-fuse/fabric8
long epochOfZxid = ZxidUtils.getEpochFromZxid(lastProcessedZxid);
try {
currentEpoch = readLongFromFile(CURRENT_EPOCH_FILENAME);
内容来源于网络,如有侵权,请联系作者删除!