public class oadd.org.apache.zookeeper.server.quorum.FastLeaderElection extends java.lang.Object implements oadd.org.apache.zookeeper.server.quorum.Election
{
private static final org.slf4j.Logger LOG;
static final int finalizeWait;
static final int maxNotificationInterval;
oadd.org.apache.zookeeper.server.quorum.QuorumCnxManager manager;
static byte[] dummyData;
java.util.concurrent.LinkedBlockingQueue sendqueue;
java.util.concurrent.LinkedBlockingQueue recvqueue;
oadd.org.apache.zookeeper.server.quorum.QuorumPeer self;
oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Messenger messenger;
java.util.concurrent.atomic.AtomicLong logicalclock;
long proposedLeader;
long proposedZxid;
long proposedEpoch;
volatile boolean stop;
public long getLogicalClock()
{
oadd.org.apache.zookeeper.server.quorum.FastLeaderElection v;
java.util.concurrent.atomic.AtomicLong v;
long v;
v := @this: oadd.org.apache.zookeeper.server.quorum.FastLeaderElection;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: java.util.concurrent.atomic.AtomicLong logicalclock>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long get()>();
return v;
}
static java.nio.ByteBuffer buildMsg(int, long, long, long, long)
{
byte[] v;
int v;
long v, v, v, v;
java.nio.ByteBuffer v;
v := @parameter: int;
v := @parameter: long;
v := @parameter: long;
v := @parameter: long;
v := @parameter: long;
v = newarray (byte)[40];
v = staticinvoke <java.nio.ByteBuffer: java.nio.ByteBuffer wrap(byte[])>(v);
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer clear()>();
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer putInt(int)>(v);
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer putLong(long)>(v);
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer putLong(long)>(v);
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer putLong(long)>(v);
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer putLong(long)>(v);
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer putInt(int)>(1);
return v;
}
static java.nio.ByteBuffer buildMsg(int, long, long, long, long, byte[])
{
byte[] v, v;
long v, v, v, v;
java.nio.ByteBuffer v;
int v, v, v, v;
v := @parameter: int;
v := @parameter: long;
v := @parameter: long;
v := @parameter: long;
v := @parameter: long;
v := @parameter: byte[];
v = lengthof v;
v = 44 + v;
v = newarray (byte)[v];
v = staticinvoke <java.nio.ByteBuffer: java.nio.ByteBuffer wrap(byte[])>(v);
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer clear()>();
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer putInt(int)>(v);
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer putLong(long)>(v);
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer putLong(long)>(v);
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer putLong(long)>(v);
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer putLong(long)>(v);
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer putInt(int)>(2);
v = lengthof v;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer putInt(int)>(v);
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer put(byte[])>(v);
return v;
}
public void <init>(oadd.org.apache.zookeeper.server.quorum.QuorumPeer, oadd.org.apache.zookeeper.server.quorum.QuorumCnxManager)
{
oadd.org.apache.zookeeper.server.quorum.FastLeaderElection v;
oadd.org.apache.zookeeper.server.quorum.QuorumCnxManager v;
java.util.concurrent.atomic.AtomicLong v;
oadd.org.apache.zookeeper.server.quorum.QuorumPeer v;
v := @this: oadd.org.apache.zookeeper.server.quorum.FastLeaderElection;
v := @parameter: oadd.org.apache.zookeeper.server.quorum.QuorumPeer;
v := @parameter: oadd.org.apache.zookeeper.server.quorum.QuorumCnxManager;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>()>();
v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: java.util.concurrent.atomic.AtomicLong logicalclock> = v;
v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: boolean stop> = 0;
v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumCnxManager manager> = v;
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: void starter(oadd.org.apache.zookeeper.server.quorum.QuorumPeer,oadd.org.apache.zookeeper.server.quorum.QuorumCnxManager)>(v, v);
return;
}
private void starter(oadd.org.apache.zookeeper.server.quorum.QuorumPeer, oadd.org.apache.zookeeper.server.quorum.QuorumCnxManager)
{
oadd.org.apache.zookeeper.server.quorum.FastLeaderElection v;
oadd.org.apache.zookeeper.server.quorum.QuorumCnxManager v;
oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Messenger v;
oadd.org.apache.zookeeper.server.quorum.QuorumPeer v;
java.util.concurrent.LinkedBlockingQueue v, v;
v := @this: oadd.org.apache.zookeeper.server.quorum.FastLeaderElection;
v := @parameter: oadd.org.apache.zookeeper.server.quorum.QuorumPeer;
v := @parameter: oadd.org.apache.zookeeper.server.quorum.QuorumCnxManager;
v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self> = v;
v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long proposedLeader> = -1L;
v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long proposedZxid> = -1L;
v = new java.util.concurrent.LinkedBlockingQueue;
specialinvoke v.<java.util.concurrent.LinkedBlockingQueue: void <init>()>();
v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: java.util.concurrent.LinkedBlockingQueue sendqueue> = v;
v = new java.util.concurrent.LinkedBlockingQueue;
specialinvoke v.<java.util.concurrent.LinkedBlockingQueue: void <init>()>();
v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: java.util.concurrent.LinkedBlockingQueue recvqueue> = v;
v = new oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Messenger;
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Messenger: void <init>(oadd.org.apache.zookeeper.server.quorum.FastLeaderElection,oadd.org.apache.zookeeper.server.quorum.QuorumCnxManager)>(v, v);
v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Messenger messenger> = v;
return;
}
public void start()
{
oadd.org.apache.zookeeper.server.quorum.FastLeaderElection v;
oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Messenger v;
v := @this: oadd.org.apache.zookeeper.server.quorum.FastLeaderElection;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Messenger messenger>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Messenger: void start()>();
return;
}
private void leaveInstance(oadd.org.apache.zookeeper.server.quorum.Vote)
{
oadd.org.apache.zookeeper.server.quorum.FastLeaderElection v;
java.lang.Object[] v;
long v, v, v;
java.lang.Long v, v;
java.lang.String v;
boolean v;
oadd.org.apache.zookeeper.server.quorum.Vote v;
org.slf4j.Logger v, v;
oadd.org.apache.zookeeper.server.quorum.QuorumPeer v, v;
java.util.concurrent.LinkedBlockingQueue v;
oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState v;
v := @this: oadd.org.apache.zookeeper.server.quorum.FastLeaderElection;
v := @parameter: oadd.org.apache.zookeeper.server.quorum.Vote;
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
v = newarray (java.lang.Object)[4];
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.Vote: long getId()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[0] = v;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.Vote: long getZxid()>();
v = staticinvoke <java.lang.Long: java.lang.String toHexString(long)>(v);
v[1] = v;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: long getId()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[2] = v;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState getPeerState()>();
v[3] = v;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object[])>("About to leave FLE instance: leader={}, zxid=0x{}, my id={}, my state={}", v);
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: java.util.concurrent.LinkedBlockingQueue recvqueue>;
virtualinvoke v.<java.util.concurrent.LinkedBlockingQueue: void clear()>();
return;
}
public oadd.org.apache.zookeeper.server.quorum.QuorumCnxManager getCnxManager()
{
oadd.org.apache.zookeeper.server.quorum.FastLeaderElection v;
oadd.org.apache.zookeeper.server.quorum.QuorumCnxManager v;
v := @this: oadd.org.apache.zookeeper.server.quorum.FastLeaderElection;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumCnxManager manager>;
return v;
}
public void shutdown()
{
oadd.org.apache.zookeeper.server.quorum.FastLeaderElection v;
oadd.org.apache.zookeeper.server.quorum.QuorumCnxManager v;
org.slf4j.Logger v, v, v;
oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Messenger v;
v := @this: oadd.org.apache.zookeeper.server.quorum.FastLeaderElection;
v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: boolean stop> = 1;
v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long proposedLeader> = -1L;
v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long proposedZxid> = -1L;
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Shutting down connection manager");
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumCnxManager manager>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumCnxManager: void halt()>();
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Shutting down messenger");
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Messenger messenger>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Messenger: void halt()>();
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("FLE is down");
return;
}
private void sendNotifications()
{
byte[] v;
boolean v, v;
java.util.Set v;
oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v;
java.util.concurrent.LinkedBlockingQueue v;
oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState v;
oadd.org.apache.zookeeper.server.quorum.FastLeaderElection v;
long v, v, v, v, v, v, v, v, v, v;
oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$ToSend$mType v;
java.lang.String v, v, v, v, v;
org.slf4j.Logger v, v;
java.util.Iterator v;
oadd.org.apache.zookeeper.server.quorum.QuorumPeer v, v, v;
oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$ToSend v;
java.util.concurrent.atomic.AtomicLong v, v;
java.lang.Object v;
v := @this: oadd.org.apache.zookeeper.server.quorum.FastLeaderElection;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: java.util.Set getCurrentAndNextConfigVoters()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier getQuorumVerifier()>();
v = new oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$ToSend;
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$ToSend$mType: oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$ToSend$mType notification>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long proposedLeader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long proposedZxid>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: java.util.concurrent.atomic.AtomicLong logicalclock>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long get()>();
v = <oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState: oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState LOOKING>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long proposedEpoch>;
v = interfaceinvoke v.<oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier: java.lang.String toString()>();
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$ToSend: void <init>(oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$ToSend$mType,long,long,long,oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState,long,long,byte[])>(v, v, v, v, v, v, v, v);
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long proposedLeader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long proposedZxid>;
v = staticinvoke <java.lang.Long: java.lang.String toHexString(long)>(v);
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: java.util.concurrent.atomic.AtomicLong logicalclock>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long get()>();
v = staticinvoke <java.lang.Long: java.lang.String toHexString(long)>(v);
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: long getId()>();
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long proposedEpoch>;
v = staticinvoke <java.lang.Long: java.lang.String toHexString(long)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long,java.lang.String,java.lang.String,long,long,java.lang.String)>(v, v, v, v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Sending Notification: \u (n.leader), 0x\u (n.zxid), 0x\u (n.round), \u (recipient), \u (myid), 0x\u (n.peerEpoch)");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: java.util.concurrent.LinkedBlockingQueue sendqueue>;
virtualinvoke v.<java.util.concurrent.LinkedBlockingQueue: boolean offer(java.lang.Object)>(v);
goto label;
label:
return;
}
private void printNotification(oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification)
{
oadd.org.apache.zookeeper.server.quorum.FastLeaderElection v;
long v, v, v, v, v, v;
oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification v;
int v;
java.lang.String v, v, v, v, v, v, v;
org.slf4j.Logger v;
oadd.org.apache.zookeeper.server.quorum.QuorumPeer v;
oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v, v;
oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState v, v;
v := @this: oadd.org.apache.zookeeper.server.quorum.FastLeaderElection;
v := @parameter: oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification;
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: int version>;
v = staticinvoke <java.lang.Long: java.lang.String toHexString(long)>(v);
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long leader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long zxid>;
v = staticinvoke <java.lang.Long: java.lang.String toHexString(long)>(v);
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long electionEpoch>;
v = staticinvoke <java.lang.Long: java.lang.String toHexString(long)>(v);
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState state>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long sid>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long peerEpoch>;
v = staticinvoke <java.lang.Long: java.lang.String toHexString(long)>(v);
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState getPeerState()>();
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier qv>;
if v == null goto label;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier qv>;
v = interfaceinvoke v.<oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier: long getVersion()>();
v = staticinvoke <java.lang.Long: java.lang.String toHexString(long)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u (n.config version)");
goto label;
label:
v = "";
label:
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,long,java.lang.String,java.lang.String,oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState,long,java.lang.String,oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState,java.lang.String)>(v, v, v, v, v, v, v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Notification: \u (message format version), \u (n.leader), 0x\u (n.zxid), 0x\u (n.round), \u (n.state), \u (n.sid), 0x\u (n.peerEPoch), \u (my state)\u0001");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
return;
}
protected boolean totalOrderPredicate(long, long, long, long, long, long)
{
oadd.org.apache.zookeeper.server.quorum.FastLeaderElection v;
long v, v, v, v, v, v, v;
byte v, v, v, v, v, v;
java.lang.String v, v, v;
boolean v;
org.slf4j.Logger v;
oadd.org.apache.zookeeper.server.quorum.QuorumPeer v;
oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v;
v := @this: oadd.org.apache.zookeeper.server.quorum.FastLeaderElection;
v := @parameter: long;
v := @parameter: long;
v := @parameter: long;
v := @parameter: long;
v := @parameter: long;
v := @parameter: long;
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
v = staticinvoke <java.lang.Long: java.lang.String toHexString(long)>(v);
v = staticinvoke <java.lang.Long: java.lang.String toHexString(long)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long,long,java.lang.String,java.lang.String)>(v, v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("id: \u, proposed id: \u, zxid: 0x\u, proposed zxid: 0x\u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier getQuorumVerifier()>();
v = interfaceinvoke v.<oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier: long getWeight(long)>(v);
v = v cmp 0L;
if v != 0 goto label;
return 0;
label:
v = v cmp v;
if v > 0 goto label;
v = v cmp v;
if v != 0 goto label;
v = v cmp v;
if v > 0 goto label;
v = v cmp v;
if v != 0 goto label;
v = v cmp v;
if v <= 0 goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
protected boolean termPredicate(java.util.Map, oadd.org.apache.zookeeper.server.quorum.Vote)
{
oadd.org.apache.zookeeper.server.quorum.FastLeaderElection v;
long v, v;
byte v;
java.util.Map v;
oadd.org.apache.zookeeper.server.quorum.SyncedLearnerTracker v;
boolean v, v, v;
oadd.org.apache.zookeeper.server.quorum.Vote v;
java.util.Iterator v;
oadd.org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v, v;
java.util.Set v;
oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v, v, v, v, v;
java.lang.Object v, v, v;
v := @this: oadd.org.apache.zookeeper.server.quorum.FastLeaderElection;
v := @parameter: java.util.Map;
v := @parameter: oadd.org.apache.zookeeper.server.quorum.Vote;
v = new oadd.org.apache.zookeeper.server.quorum.SyncedLearnerTracker;
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.SyncedLearnerTracker: void <init>()>();
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier getQuorumVerifier()>();
virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.SyncedLearnerTracker: void addQuorumVerifier(oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier)>(v);
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier getLastSeenQuorumVerifier()>();
if v == null goto label;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier getLastSeenQuorumVerifier()>();
v = interfaceinvoke v.<oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier: long getVersion()>();
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier getQuorumVerifier()>();
v = interfaceinvoke v.<oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier: long getVersion()>();
v = v cmp v;
if v <= 0 goto label;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier getLastSeenQuorumVerifier()>();
virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.SyncedLearnerTracker: void addQuorumVerifier(oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier)>(v);
label:
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.Vote: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.SyncedLearnerTracker: boolean addAck(java.lang.Long)>(v);
goto label;
label:
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.SyncedLearnerTracker: boolean hasAllQuorums()>();
return v;
}
protected boolean checkLeader(java.util.Map, long, long)
{
oadd.org.apache.zookeeper.server.quorum.FastLeaderElection v;
long v, v, v, v;
byte v, v;
java.lang.Long v, v;
java.util.Map v;
boolean v;
oadd.org.apache.zookeeper.server.quorum.QuorumPeer v;
java.util.concurrent.atomic.AtomicLong v;
java.lang.Object v, v;
oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState v, v;
v := @this: oadd.org.apache.zookeeper.server.quorum.FastLeaderElection;
v := @parameter: java.util.Map;
v := @parameter: long;
v := @parameter: long;
v = 1;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: long getId()>();
v = v cmp v;
if v == 0 goto label;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = 0;
goto label;
label:
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.Vote: oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState getState()>();
v = <oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState: oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState LEADING>;
if v == v goto label;
v = 0;
goto label;
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: java.util.concurrent.atomic.AtomicLong logicalclock>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long get()>();
v = v cmp v;
if v == 0 goto label;
v = 0;
label:
return v;
}
synchronized void updateProposal(long, long, long)
{
oadd.org.apache.zookeeper.server.quorum.FastLeaderElection v;
org.slf4j.Logger v, v;
long v, v, v, v, v;
java.lang.String v, v, v;
boolean v;
v := @this: oadd.org.apache.zookeeper.server.quorum.FastLeaderElection;
v := @parameter: long;
v := @parameter: long;
v := @parameter: long;
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
v = staticinvoke <java.lang.Long: java.lang.String toHexString(long)>(v);
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long proposedLeader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long proposedZxid>;
v = staticinvoke <java.lang.Long: java.lang.String toHexString(long)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long,java.lang.String,long,java.lang.String)>(v, v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Updating proposal: \u (newleader), 0x\u (newzxid), \u (oldleader), 0x\u (oldzxid)");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
label:
v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long proposedLeader> = v;
v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long proposedZxid> = v;
v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long proposedEpoch> = v;
return;
}
public synchronized oadd.org.apache.zookeeper.server.quorum.Vote getVote()
{
oadd.org.apache.zookeeper.server.quorum.FastLeaderElection v;
oadd.org.apache.zookeeper.server.quorum.Vote v;
long v, v, v;
v := @this: oadd.org.apache.zookeeper.server.quorum.FastLeaderElection;
v = new oadd.org.apache.zookeeper.server.quorum.Vote;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long proposedLeader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long proposedZxid>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long proposedEpoch>;
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.Vote: void <init>(long,long,long)>(v, v, v);
return v;
}
private oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState learningState()
{
oadd.org.apache.zookeeper.server.quorum.FastLeaderElection v;
org.slf4j.Logger v, v;
oadd.org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType v, v;
oadd.org.apache.zookeeper.server.quorum.QuorumPeer v, v, v;
long v, v;
java.lang.String v, v;
oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState v, v;
v := @this: oadd.org.apache.zookeeper.server.quorum.FastLeaderElection;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: oadd.org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType getLearnerType()>();
v = <oadd.org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: oadd.org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType PARTICIPANT>;
if v != v goto label;
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: long getId()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("I\'m a participant: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
v = <oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState: oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState FOLLOWING>;
return v;
label:
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: long getId()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("I\'m an observer: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
v = <oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState: oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState OBSERVING>;
return v;
}
private long getInitId()
{
oadd.org.apache.zookeeper.server.quorum.FastLeaderElection v;
oadd.org.apache.zookeeper.server.quorum.QuorumPeer v, v, v;
oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v;
long v, v;
java.lang.Long v;
java.util.Map v;
boolean v;
v := @this: oadd.org.apache.zookeeper.server.quorum.FastLeaderElection;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier getQuorumVerifier()>();
v = interfaceinvoke v.<oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier: java.util.Map getVotingMembers()>();
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: long getId()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>(v);
if v == 0 goto label;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: long getId()>();
return v;
label:
return -9223372036854775808L;
}
private long getInitLastLoggedZxid()
{
oadd.org.apache.zookeeper.server.quorum.FastLeaderElection v;
oadd.org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType v, v;
oadd.org.apache.zookeeper.server.quorum.QuorumPeer v, v;
long v;
v := @this: oadd.org.apache.zookeeper.server.quorum.FastLeaderElection;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: oadd.org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType getLearnerType()>();
v = <oadd.org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: oadd.org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType PARTICIPANT>;
if v != v goto label;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: long getLastLoggedZxid()>();
return v;
label:
return -9223372036854775808L;
}
private long getPeerEpoch()
{
oadd.org.apache.zookeeper.server.quorum.FastLeaderElection v;
oadd.org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType v, v;
oadd.org.apache.zookeeper.server.quorum.QuorumPeer v, v;
java.io.IOException v;
long v;
java.lang.RuntimeException v;
java.lang.StackTraceElement[] v;
java.lang.String v;
v := @this: oadd.org.apache.zookeeper.server.quorum.FastLeaderElection;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: oadd.org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType getLearnerType()>();
v = <oadd.org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: oadd.org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType PARTICIPANT>;
if v != v goto label;
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: long getCurrentEpoch()>();
label:
return v;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
v = virtualinvoke v.<java.io.IOException: java.lang.String getMessage()>();
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<java.io.IOException: java.lang.StackTraceElement[] getStackTrace()>();
virtualinvoke v.<java.lang.RuntimeException: void setStackTrace(java.lang.StackTraceElement[])>(v);
throw v;
label:
return -9223372036854775808L;
catch java.io.IOException from label to label with label;
}
public oadd.org.apache.zookeeper.server.quorum.Vote lookForLeader() throws java.lang.InterruptedException
{
oadd.org.apache.zookeeper.server.quorum.LeaderElectionBean v, v, v, v, v, v, v, v, v, v, v, v;
int[] v;
int v, v, v, v, v, v, v, v, v, v;
java.lang.Exception v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v;
boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
oadd.org.apache.zookeeper.server.quorum.QuorumCnxManager v, v, v, v, v, v, v;
java.util.concurrent.TimeUnit v, v;
byte v, v, v, v, v, v, v;
java.lang.Long v, v, v, v, v, v, v, v, v, v, v, v;
long v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.concurrent.atomic.AtomicLong v, v, v, v, v, v, v, v, v;
oadd.org.apache.zookeeper.jmx.MBeanRegistry v, v, v, v, v, v;
oadd.org.apache.zookeeper.server.quorum.LocalPeerBean v;
oadd.org.apache.zookeeper.server.quorum.Vote v, v, v, v, v, v, v, v, v;
org.slf4j.Logger v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Object v, v;
oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState v, v, v, v, v, v, v, v, v, v;
java.lang.Throwable v, v, v;
oadd.org.apache.zookeeper.server.quorum.FastLeaderElection v;
java.util.concurrent.LinkedBlockingQueue v, v, v;
java.util.HashMap v, v;
oadd.org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
v := @this: oadd.org.apache.zookeeper.server.quorum.FastLeaderElection;
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = new oadd.org.apache.zookeeper.server.quorum.LeaderElectionBean;
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.LeaderElectionBean: void <init>()>();
v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: oadd.org.apache.zookeeper.server.quorum.LeaderElectionBean jmxLeaderElectionBean> = v;
v = staticinvoke <oadd.org.apache.zookeeper.jmx.MBeanRegistry: oadd.org.apache.zookeeper.jmx.MBeanRegistry getInstance()>();
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: oadd.org.apache.zookeeper.server.quorum.LeaderElectionBean jmxLeaderElectionBean>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: oadd.org.apache.zookeeper.server.quorum.LocalPeerBean jmxLocalPeerBean>;
virtualinvoke v.<oadd.org.apache.zookeeper.jmx.MBeanRegistry: void register(oadd.org.apache.zookeeper.jmx.ZKMBeanInfo,oadd.org.apache.zookeeper.jmx.ZKMBeanInfo)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>("Failed to register with JMX", v);
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: oadd.org.apache.zookeeper.server.quorum.LeaderElectionBean jmxLeaderElectionBean> = null;
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: long start_fle>;
v = v cmp 0L;
if v != 0 goto label;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = staticinvoke <oadd.org.apache.zookeeper.common.Time: long currentElapsedTime()>();
v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: long start_fle> = v;
label:
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = 200;
entermonitor v;
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: java.util.concurrent.atomic.AtomicLong logicalclock>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long incrementAndGet()>();
v = specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long getInitId()>();
v = specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long getInitLastLoggedZxid()>();
v = specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long getPeerEpoch()>();
virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: void updateProposal(long,long,long)>(v, v, v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: long getId()>();
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long proposedZxid>;
v = staticinvoke <java.lang.Long: java.lang.String toHexString(long)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("New election. My id =  \u, proposed zxid=0x\u0001");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: void sendNotifications()>();
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState getPeerState()>();
v = <oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState: oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState LOOKING>;
if v != v goto label;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: boolean stop>;
if v != 0 goto label;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: java.util.concurrent.LinkedBlockingQueue recvqueue>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = virtualinvoke v.<java.util.concurrent.LinkedBlockingQueue: java.lang.Object poll(long,java.util.concurrent.TimeUnit)>(v, v);
if v != null goto label;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumCnxManager manager>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumCnxManager: boolean haveDelivered()>();
if v == 0 goto label;
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: void sendNotifications()>();
goto label;
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumCnxManager manager>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumCnxManager: void connectAll()>();
label:
v = v * 2;
v = (int) 60000;
if v >= v goto label;
v = v;
goto label;
label:
v = (int) 60000;
v = v;
label:
v = v;
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Notification time out: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
goto label;
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long sid>;
v = specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: boolean validVoter(long)>(v);
if v == 0 goto label;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long leader>;
v = specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: boolean validVoter(long)>(v);
if v == 0 goto label;
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$1: int[] $SwitchMap$org$apache$zookeeper$server$quorum$QuorumPeer$ServerState>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState state>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
default: goto label;
};
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long electionEpoch>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: java.util.concurrent.atomic.AtomicLong logicalclock>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long get()>();
v = v cmp v;
if v <= 0 goto label;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: java.util.concurrent.atomic.AtomicLong logicalclock>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long electionEpoch>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: void set(long)>(v);
virtualinvoke v.<java.util.HashMap: void clear()>();
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long leader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long zxid>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long peerEpoch>;
v = specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long getInitId()>();
v = specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long getInitLastLoggedZxid()>();
v = specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long getPeerEpoch()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: boolean totalOrderPredicate(long,long,long,long,long,long)>(v, v, v, v, v, v);
if v == 0 goto label;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long leader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long zxid>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long peerEpoch>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: void updateProposal(long,long,long)>(v, v, v);
goto label;
label:
v = specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long getInitId()>();
v = specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long getInitLastLoggedZxid()>();
v = specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long getPeerEpoch()>();
virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: void updateProposal(long,long,long)>(v, v, v);
label:
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: void sendNotifications()>();
goto label;
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long electionEpoch>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: java.util.concurrent.atomic.AtomicLong logicalclock>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long get()>();
v = v cmp v;
if v >= 0 goto label;
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long electionEpoch>;
v = staticinvoke <java.lang.Long: java.lang.String toHexString(long)>(v);
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: java.util.concurrent.atomic.AtomicLong logicalclock>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long get()>();
v = staticinvoke <java.lang.Long: java.lang.String toHexString(long)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Notification election epoch is smaller than logicalclock. n.electionEpoch = 0x\u, logicalclock=0x\u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
goto label;
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long leader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long zxid>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long peerEpoch>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long proposedLeader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long proposedZxid>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long proposedEpoch>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: boolean totalOrderPredicate(long,long,long,long,long,long)>(v, v, v, v, v, v);
if v == 0 goto label;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long leader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long zxid>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long peerEpoch>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: void updateProposal(long,long,long)>(v, v, v);
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: void sendNotifications()>();
label:
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long sid>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long leader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long zxid>;
v = staticinvoke <java.lang.Long: java.lang.String toHexString(long)>(v);
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long electionEpoch>;
v = staticinvoke <java.lang.Long: java.lang.String toHexString(long)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long,long,java.lang.String,java.lang.String)>(v, v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Adding vote: from=\u, proposed leader=\u, proposed zxid=0x\u, proposed election epoch=0x\u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long sid>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = new oadd.org.apache.zookeeper.server.quorum.Vote;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long leader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long zxid>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long electionEpoch>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long peerEpoch>;
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.Vote: void <init>(long,long,long,long)>(v, v, v, v);
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = new oadd.org.apache.zookeeper.server.quorum.Vote;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long proposedLeader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long proposedZxid>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: java.util.concurrent.atomic.AtomicLong logicalclock>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long get()>();
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long proposedEpoch>;
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.Vote: void <init>(long,long,long,long)>(v, v, v, v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: boolean termPredicate(java.util.Map,oadd.org.apache.zookeeper.server.quorum.Vote)>(v, v);
if v == 0 goto label;
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: java.util.concurrent.LinkedBlockingQueue recvqueue>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = virtualinvoke v.<java.util.concurrent.LinkedBlockingQueue: java.lang.Object poll(long,java.util.concurrent.TimeUnit)>(200L, v);
if v == null goto label;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long leader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long zxid>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long peerEpoch>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long proposedLeader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long proposedZxid>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long proposedEpoch>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: boolean totalOrderPredicate(long,long,long,long,long,long)>(v, v, v, v, v, v);
if v == 0 goto label;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: java.util.concurrent.LinkedBlockingQueue recvqueue>;
virtualinvoke v.<java.util.concurrent.LinkedBlockingQueue: void put(java.lang.Object)>(v);
label:
if v != null goto label;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long proposedLeader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: long getId()>();
v = v cmp v;
if v != 0 goto label;
v = <oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState: oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState LEADING>;
goto label;
label:
v = specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState learningState()>();
label:
virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: void setPeerState(oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState)>(v);
v = new oadd.org.apache.zookeeper.server.quorum.Vote;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long proposedLeader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long proposedZxid>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: java.util.concurrent.atomic.AtomicLong logicalclock>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long get()>();
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: long proposedEpoch>;
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.Vote: void <init>(long,long,long,long)>(v, v, v, v);
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: void leaveInstance(oadd.org.apache.zookeeper.server.quorum.Vote)>(v);
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: oadd.org.apache.zookeeper.server.quorum.LeaderElectionBean jmxLeaderElectionBean>;
if v == null goto label;
v = staticinvoke <oadd.org.apache.zookeeper.jmx.MBeanRegistry: oadd.org.apache.zookeeper.jmx.MBeanRegistry getInstance()>();
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: oadd.org.apache.zookeeper.server.quorum.LeaderElectionBean jmxLeaderElectionBean>;
virtualinvoke v.<oadd.org.apache.zookeeper.jmx.MBeanRegistry: void unregister(oadd.org.apache.zookeeper.jmx.ZKMBeanInfo)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>("Failed to unregister with JMX", v);
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: oadd.org.apache.zookeeper.server.quorum.LeaderElectionBean jmxLeaderElectionBean> = null;
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumCnxManager manager>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumCnxManager: long getConnectionThreadCount()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Number of connection processing threads: {}", v);
return v;
label:
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long sid>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Notification from observer: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
goto label;
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long electionEpoch>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: java.util.concurrent.atomic.AtomicLong logicalclock>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long get()>();
v = v cmp v;
if v != 0 goto label;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long sid>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = new oadd.org.apache.zookeeper.server.quorum.Vote;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long leader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long zxid>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long electionEpoch>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long peerEpoch>;
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.Vote: void <init>(long,long,long,long)>(v, v, v, v);
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = new oadd.org.apache.zookeeper.server.quorum.Vote;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: int version>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long leader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long zxid>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long electionEpoch>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long peerEpoch>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState state>;
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.Vote: void <init>(int,long,long,long,long,oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState)>(v, v, v, v, v, v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: boolean termPredicate(java.util.Map,oadd.org.apache.zookeeper.server.quorum.Vote)>(v, v);
if v == 0 goto label;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long leader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long electionEpoch>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: boolean checkLeader(java.util.Map,long,long)>(v, v, v);
if v == 0 goto label;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long leader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: long getId()>();
v = v cmp v;
if v != 0 goto label;
v = <oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState: oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState LEADING>;
goto label;
label:
v = specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState learningState()>();
label:
virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: void setPeerState(oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState)>(v);
v = new oadd.org.apache.zookeeper.server.quorum.Vote;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long leader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long zxid>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long electionEpoch>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long peerEpoch>;
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.Vote: void <init>(long,long,long,long)>(v, v, v, v);
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: void leaveInstance(oadd.org.apache.zookeeper.server.quorum.Vote)>(v);
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: oadd.org.apache.zookeeper.server.quorum.LeaderElectionBean jmxLeaderElectionBean>;
if v == null goto label;
v = staticinvoke <oadd.org.apache.zookeeper.jmx.MBeanRegistry: oadd.org.apache.zookeeper.jmx.MBeanRegistry getInstance()>();
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: oadd.org.apache.zookeeper.server.quorum.LeaderElectionBean jmxLeaderElectionBean>;
virtualinvoke v.<oadd.org.apache.zookeeper.jmx.MBeanRegistry: void unregister(oadd.org.apache.zookeeper.jmx.ZKMBeanInfo)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>("Failed to unregister with JMX", v);
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: oadd.org.apache.zookeeper.server.quorum.LeaderElectionBean jmxLeaderElectionBean> = null;
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumCnxManager manager>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumCnxManager: long getConnectionThreadCount()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Number of connection processing threads: {}", v);
return v;
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long sid>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = new oadd.org.apache.zookeeper.server.quorum.Vote;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: int version>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long leader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long zxid>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long electionEpoch>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long peerEpoch>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState state>;
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.Vote: void <init>(int,long,long,long,long,oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState)>(v, v, v, v, v, v);
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = new oadd.org.apache.zookeeper.server.quorum.Vote;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: int version>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long leader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long zxid>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long electionEpoch>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long peerEpoch>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState state>;
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.Vote: void <init>(int,long,long,long,long,oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState)>(v, v, v, v, v, v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: boolean termPredicate(java.util.Map,oadd.org.apache.zookeeper.server.quorum.Vote)>(v, v);
if v == 0 goto label;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long leader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long electionEpoch>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: boolean checkLeader(java.util.Map,long,long)>(v, v, v);
if v == 0 goto label;
entermonitor v;
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: java.util.concurrent.atomic.AtomicLong logicalclock>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long electionEpoch>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: void set(long)>(v);
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long leader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: long getId()>();
v = v cmp v;
if v != 0 goto label;
v = <oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState: oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState LEADING>;
goto label;
label:
v = specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState learningState()>();
label:
virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: void setPeerState(oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState)>(v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = new oadd.org.apache.zookeeper.server.quorum.Vote;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long leader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long zxid>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long electionEpoch>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long peerEpoch>;
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.Vote: void <init>(long,long,long,long)>(v, v, v, v);
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: void leaveInstance(oadd.org.apache.zookeeper.server.quorum.Vote)>(v);
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: oadd.org.apache.zookeeper.server.quorum.LeaderElectionBean jmxLeaderElectionBean>;
if v == null goto label;
v = staticinvoke <oadd.org.apache.zookeeper.jmx.MBeanRegistry: oadd.org.apache.zookeeper.jmx.MBeanRegistry getInstance()>();
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: oadd.org.apache.zookeeper.server.quorum.LeaderElectionBean jmxLeaderElectionBean>;
virtualinvoke v.<oadd.org.apache.zookeeper.jmx.MBeanRegistry: void unregister(oadd.org.apache.zookeeper.jmx.ZKMBeanInfo)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>("Failed to unregister with JMX", v);
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: oadd.org.apache.zookeeper.server.quorum.LeaderElectionBean jmxLeaderElectionBean> = null;
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumCnxManager manager>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumCnxManager: long getConnectionThreadCount()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Number of connection processing threads: {}", v);
return v;
label:
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState state>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long sid>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState,long)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Notification state unrecoginized: \u (n.state), \u (n.sid)");
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>(v);
goto label;
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long leader>;
v = specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: boolean validVoter(long)>(v);
if v != 0 goto label;
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long leader>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long sid>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object,java.lang.Object)>("Ignoring notification for non-cluster member sid {} from sid {}", v, v);
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long sid>;
v = specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: boolean validVoter(long)>(v);
if v != 0 goto label;
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long leader>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection$Notification: long sid>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object,java.lang.Object)>("Ignoring notification for sid {} from non-quorum member sid {}", v, v);
goto label;
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: oadd.org.apache.zookeeper.server.quorum.LeaderElectionBean jmxLeaderElectionBean>;
if v == null goto label;
v = staticinvoke <oadd.org.apache.zookeeper.jmx.MBeanRegistry: oadd.org.apache.zookeeper.jmx.MBeanRegistry getInstance()>();
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: oadd.org.apache.zookeeper.server.quorum.LeaderElectionBean jmxLeaderElectionBean>;
virtualinvoke v.<oadd.org.apache.zookeeper.jmx.MBeanRegistry: void unregister(oadd.org.apache.zookeeper.jmx.ZKMBeanInfo)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>("Failed to unregister with JMX", v);
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: oadd.org.apache.zookeeper.server.quorum.LeaderElectionBean jmxLeaderElectionBean> = null;
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumCnxManager manager>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumCnxManager: long getConnectionThreadCount()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Number of connection processing threads: {}", v);
return null;
label:
v := @caughtexception;
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: oadd.org.apache.zookeeper.server.quorum.LeaderElectionBean jmxLeaderElectionBean>;
if v == null goto label;
v = staticinvoke <oadd.org.apache.zookeeper.jmx.MBeanRegistry: oadd.org.apache.zookeeper.jmx.MBeanRegistry getInstance()>();
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: oadd.org.apache.zookeeper.server.quorum.LeaderElectionBean jmxLeaderElectionBean>;
virtualinvoke v.<oadd.org.apache.zookeeper.jmx.MBeanRegistry: void unregister(oadd.org.apache.zookeeper.jmx.ZKMBeanInfo)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>("Failed to unregister with JMX", v);
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: oadd.org.apache.zookeeper.server.quorum.LeaderElectionBean jmxLeaderElectionBean> = null;
v = <oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG>;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumCnxManager manager>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumCnxManager: long getConnectionThreadCount()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Number of connection processing threads: {}", v);
throw v;
catch java.lang.Exception from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Exception from label to label with label;
}
private boolean validVoter(long)
{
oadd.org.apache.zookeeper.server.quorum.FastLeaderElection v;
java.lang.Long v;
oadd.org.apache.zookeeper.server.quorum.QuorumPeer v;
java.util.Set v;
long v;
boolean v;
v := @this: oadd.org.apache.zookeeper.server.quorum.FastLeaderElection;
v := @parameter: long;
v = v.<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: java.util.Set getCurrentAndNextConfigVoters()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = interfaceinvoke v.<java.util.Set: boolean contains(java.lang.Object)>(v);
return v;
}
static void <clinit>()
{
byte[] v;
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Loadd/org/apache/zookeeper/server/quorum/FastLeaderElection;");
<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: org.slf4j.Logger LOG> = v;
v = newarray (byte)[0];
<oadd.org.apache.zookeeper.server.quorum.FastLeaderElection: byte[] dummyData> = v;
return;
}
}