public class oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection extends java.lang.Object implements oadd.org.apache.zookeeper.server.quorum.Election
{
private static final org.slf4j.Logger LOG;
static int sequencer;
static int maxTag;
static int finalizeWait;
static int challengeCounter;
private boolean authEnabled;
java.util.concurrent.LinkedBlockingQueue sendqueue;
java.util.concurrent.LinkedBlockingQueue recvqueue;
oadd.org.apache.zookeeper.server.quorum.QuorumPeer self;
int port;
java.util.concurrent.atomic.AtomicLong logicalclock;
java.net.DatagramSocket mySocket;
long proposedLeader;
long proposedZxid;
public void <init>(oadd.org.apache.zookeeper.server.quorum.QuorumPeer, boolean)
{
java.util.concurrent.atomic.AtomicLong v;
oadd.org.apache.zookeeper.server.quorum.QuorumPeer v;
oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection v;
boolean v;
v := @this: oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection;
v := @parameter: oadd.org.apache.zookeeper.server.quorum.QuorumPeer;
v := @parameter: boolean;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: boolean authEnabled> = 0;
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>()>();
v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: java.util.concurrent.atomic.AtomicLong logicalclock> = v;
v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: boolean authEnabled> = v;
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: void starter(oadd.org.apache.zookeeper.server.quorum.QuorumPeer)>(v);
return;
}
public void <init>(oadd.org.apache.zookeeper.server.quorum.QuorumPeer)
{
oadd.org.apache.zookeeper.server.quorum.QuorumPeer v;
java.util.concurrent.atomic.AtomicLong v;
oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection v;
v := @this: oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection;
v := @parameter: oadd.org.apache.zookeeper.server.quorum.QuorumPeer;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: boolean authEnabled> = 0;
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>()>();
v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: java.util.concurrent.atomic.AtomicLong logicalclock> = v;
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: void starter(oadd.org.apache.zookeeper.server.quorum.QuorumPeer)>(v);
return;
}
private void starter(oadd.org.apache.zookeeper.server.quorum.QuorumPeer)
{
oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$Messenger v;
long v;
java.net.DatagramSocket v, v;
java.net.SocketException v;
java.lang.Long v;
java.util.Map v, v, v, v;
int v, v, v, v, v, v, v, v;
oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection v;
oadd.org.apache.zookeeper.server.quorum.QuorumPeer v;
java.lang.RuntimeException v;
java.net.InetSocketAddress v;
java.util.concurrent.LinkedBlockingQueue v, v;
java.lang.Object v;
v := @this: oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection;
v := @parameter: oadd.org.apache.zookeeper.server.quorum.QuorumPeer;
v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self> = v;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: java.util.Map getVotingView()>();
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: java.lang.Object get(java.lang.Object)>(v);
v = v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: java.net.InetSocketAddress electionAddr>;
v = virtualinvoke v.<java.net.InetSocketAddress: int getPort()>();
v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: int port> = v;
v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: long proposedLeader> = -1L;
v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: long proposedZxid> = -1L;
label:
v = new java.net.DatagramSocket;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: int port>;
specialinvoke v.<java.net.DatagramSocket: void <init>(int)>(v);
v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: java.net.DatagramSocket mySocket> = v;
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<java.net.SocketException: void printStackTrace()>();
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>()>();
throw v;
label:
v = new java.util.concurrent.LinkedBlockingQueue;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: java.util.Map getVotingView()>();
v = interfaceinvoke v.<java.util.Map: int size()>();
v = 2 * v;
specialinvoke v.<java.util.concurrent.LinkedBlockingQueue: void <init>(int)>(v);
v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: java.util.concurrent.LinkedBlockingQueue sendqueue> = v;
v = new java.util.concurrent.LinkedBlockingQueue;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: java.util.Map getVotingView()>();
v = interfaceinvoke v.<java.util.Map: int size()>();
v = 2 * v;
specialinvoke v.<java.util.concurrent.LinkedBlockingQueue: void <init>(int)>(v);
v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: java.util.concurrent.LinkedBlockingQueue recvqueue> = v;
v = new oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$Messenger;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: java.util.Map getVotingView()>();
v = interfaceinvoke v.<java.util.Map: int size()>();
v = v * 2;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: java.net.DatagramSocket mySocket>;
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$Messenger: void <init>(oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection,int,java.net.DatagramSocket)>(v, v, v);
return;
catch java.net.SocketException from label to label with label;
}
private void leaveInstance()
{
java.util.concurrent.atomic.AtomicLong v;
oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection v;
v := @this: oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: java.util.concurrent.atomic.AtomicLong logicalclock>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long incrementAndGet()>();
return;
}
private void sendNotifications()
{
long v, v, v, v;
java.lang.Long v;
java.util.Map v, v;
int v, v;
oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection v;
boolean v;
oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$ToSend v;
java.util.Iterator v;
java.util.Collection v;
oadd.org.apache.zookeeper.server.quorum.QuorumPeer v, v;
java.net.InetSocketAddress v;
java.util.concurrent.LinkedBlockingQueue v;
java.util.concurrent.atomic.AtomicLong v;
java.lang.Object v, v;
oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$ToSend$mType v;
oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState v;
v := @this: oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: java.util.Map getView()>();
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
v = interfaceinvoke v.<java.util.Collection: 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 = new oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$ToSend;
v = <oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$ToSend$mType: oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$ToSend$mType notification>;
v = <oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: int sequencer>;
v = v + 1;
<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: int sequencer> = v;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: long proposedLeader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: long proposedZxid>;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: 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.AuthFastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: java.util.Map getView()>();
v = v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: long id>;
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 = v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: java.net.InetSocketAddress electionAddr>;
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$ToSend: void <init>(oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$ToSend$mType,long,long,long,long,oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState,java.net.InetSocketAddress)>(v, v, v, v, v, v, v);
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: java.util.concurrent.LinkedBlockingQueue sendqueue>;
virtualinvoke v.<java.util.concurrent.LinkedBlockingQueue: boolean offer(java.lang.Object)>(v);
goto label;
label:
return;
}
private boolean totalOrderPredicate(long, long)
{
long v, v, v, v, v;
byte v, v, v;
oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection v;
v := @this: oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection;
v := @parameter: long;
v := @parameter: long;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: long proposedZxid>;
v = v cmp v;
if v > 0 goto label;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: long proposedZxid>;
v = v cmp v;
if v != 0 goto label;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: long proposedLeader>;
v = v cmp v;
if v <= 0 goto label;
label:
return 1;
label:
return 0;
}
private boolean termPredicate(java.util.HashMap, long, long)
{
java.util.HashMap v;
long v, v, v, v;
byte v, v;
java.util.Map v;
int v, v, v;
oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection v;
boolean v;
java.util.Iterator v;
java.util.Collection v;
oadd.org.apache.zookeeper.server.quorum.QuorumPeer v;
java.lang.Object v;
v := @this: oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection;
v := @parameter: java.util.HashMap;
v := @parameter: long;
v := @parameter: long;
v = virtualinvoke v.<java.util.HashMap: java.util.Collection values()>();
v = 0;
v = interfaceinvoke v.<java.util.Collection: 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.<oadd.org.apache.zookeeper.server.quorum.Vote: long getId()>();
v = v cmp v;
if v != 0 goto label;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.Vote: long getZxid()>();
v = v cmp v;
if v != 0 goto label;
v = v + 1;
goto label;
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: java.util.Map getVotingView()>();
v = interfaceinvoke v.<java.util.Map: int size()>();
v = v / 2;
if v <= v goto label;
return 1;
label:
return 0;
}
public void shutdown()
{
oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection v;
v := @this: oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection;
return;
}
public oadd.org.apache.zookeeper.server.quorum.Vote lookForLeader() throws java.lang.InterruptedException
{
byte v, v, v, v, v, v;
java.util.Map v;
oadd.org.apache.zookeeper.server.quorum.LeaderElectionBean v, v, 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;
java.util.concurrent.atomic.AtomicLong v, v, v, v;
int[] v;
oadd.org.apache.zookeeper.jmx.MBeanRegistry v, v, v, v, v, v, v;
oadd.org.apache.zookeeper.server.quorum.LocalPeerBean v;
int v, v, v, v, v, v, v, v;
oadd.org.apache.zookeeper.server.quorum.Vote v, v, v, v, v, v, v;
org.slf4j.Logger v, v, v, v, v, v, v, v, v;
java.lang.Object v, v, v;
java.lang.Exception v, v, v, v, v, v, v;
oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState v, v, v, v, v, v, v;
java.lang.Throwable v;
oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection v;
boolean v, v, v, v, v, v, v, v, v;
java.net.InetSocketAddress v, v, v;
java.util.concurrent.LinkedBlockingQueue v, v, v, 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, v, v, v, v;
java.util.concurrent.TimeUnit v;
v := @this: oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection;
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: 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.AuthFastLeaderElection: 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.AuthFastLeaderElection: 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.AuthFastLeaderElection: 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.AuthFastLeaderElection: 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 = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: java.util.concurrent.atomic.AtomicLong logicalclock>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long incrementAndGet()>();
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: long getId()>();
v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: long proposedLeader> = v;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: long getLastLoggedZxid()>();
v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: long proposedZxid> = v;
v = <oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Election tally");
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: void sendNotifications()>();
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: 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.AuthFastLeaderElection: java.util.concurrent.LinkedBlockingQueue recvqueue>;
v = <oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: int finalizeWait>;
v = 2 * v;
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 = virtualinvoke v.<java.util.HashMap: boolean isEmpty()>();
if v == 0 goto label;
v = virtualinvoke v.<java.util.HashMap: int size()>();
if v <= 1 goto label;
label:
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: void sendNotifications()>();
goto label;
label:
v = <oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$1: int[] $SwitchMap$org$apache$zookeeper$server$quorum$QuorumPeer$ServerState>;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$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;
default: goto label;
};
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$Notification: long epoch>;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: 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.AuthFastLeaderElection: java.util.concurrent.atomic.AtomicLong logicalclock>;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$Notification: long epoch>;
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.AuthFastLeaderElection$Notification: long leader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$Notification: long zxid>;
v = specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: boolean totalOrderPredicate(long,long)>(v, v);
if v == 0 goto label;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$Notification: long leader>;
v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: long proposedLeader> = v;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$Notification: long zxid>;
v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: long proposedZxid> = v;
label:
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: void sendNotifications()>();
goto label;
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$Notification: long epoch>;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: 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.AuthFastLeaderElection$Notification: long leader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$Notification: long zxid>;
v = specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: boolean totalOrderPredicate(long,long)>(v, v);
if v == 0 goto label;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$Notification: long leader>;
v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: long proposedLeader> = v;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$Notification: long zxid>;
v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: long proposedZxid> = v;
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: void sendNotifications()>();
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$Notification: java.net.InetSocketAddress addr>;
v = new oadd.org.apache.zookeeper.server.quorum.Vote;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$Notification: long leader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$Notification: long zxid>;
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.Vote: void <init>(long,long)>(v, v);
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: java.util.Map getVotingView()>();
v = interfaceinvoke v.<java.util.Map: int size()>();
v = virtualinvoke v.<java.util.HashMap: int size()>();
if v != v goto label;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: long proposedLeader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: 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 = <oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState: oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState FOLLOWING>;
label:
virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: void setPeerState(oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState)>(v);
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: void leaveInstance()>();
v = new oadd.org.apache.zookeeper.server.quorum.Vote;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: long proposedLeader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: long proposedZxid>;
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.Vote: void <init>(long,long)>(v, v);
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: 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.AuthFastLeaderElection: 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.AuthFastLeaderElection: 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.AuthFastLeaderElection: 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;
return v;
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: long proposedLeader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: long proposedZxid>;
v = specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: boolean termPredicate(java.util.HashMap,long,long)>(v, v, v);
if v == 0 goto label;
v = <oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Passed predicate");
v = <oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: int finalizeWait>;
staticinvoke <java.lang.Thread: void sleep(long)>(v);
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: java.util.concurrent.LinkedBlockingQueue recvqueue>;
v = virtualinvoke v.<java.util.concurrent.LinkedBlockingQueue: boolean isEmpty()>();
if v != 0 goto label;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: java.util.concurrent.LinkedBlockingQueue recvqueue>;
v = virtualinvoke v.<java.util.concurrent.LinkedBlockingQueue: java.lang.Object peek()>();
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$Notification: long leader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: java.util.concurrent.LinkedBlockingQueue recvqueue>;
v = virtualinvoke v.<java.util.concurrent.LinkedBlockingQueue: java.lang.Object peek()>();
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$Notification: long zxid>;
v = specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: boolean totalOrderPredicate(long,long)>(v, v);
if v != 0 goto label;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: java.util.concurrent.LinkedBlockingQueue recvqueue>;
virtualinvoke v.<java.util.concurrent.LinkedBlockingQueue: java.lang.Object poll()>();
goto label;
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: java.util.concurrent.LinkedBlockingQueue recvqueue>;
v = virtualinvoke v.<java.util.concurrent.LinkedBlockingQueue: boolean isEmpty()>();
if v == 0 goto label;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: long proposedLeader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: 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 = <oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState: oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState FOLLOWING>;
label:
virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: void setPeerState(oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState)>(v);
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: void leaveInstance()>();
v = new oadd.org.apache.zookeeper.server.quorum.Vote;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: long proposedLeader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: long proposedZxid>;
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.Vote: void <init>(long,long)>(v, v);
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: 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.AuthFastLeaderElection: 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.AuthFastLeaderElection: 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.AuthFastLeaderElection: 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;
return v;
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$Notification: java.net.InetSocketAddress addr>;
v = new oadd.org.apache.zookeeper.server.quorum.Vote;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$Notification: long leader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$Notification: long zxid>;
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.Vote: void <init>(long,long)>(v, v);
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$Notification: long leader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$Notification: long zxid>;
v = specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: boolean termPredicate(java.util.HashMap,long,long)>(v, v, v);
if v == 0 goto label;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$Notification: long leader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: 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 = <oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState: oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState FOLLOWING>;
label:
virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: void setPeerState(oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState)>(v);
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: void leaveInstance()>();
v = new oadd.org.apache.zookeeper.server.quorum.Vote;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$Notification: long leader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$Notification: long zxid>;
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.Vote: void <init>(long,long)>(v, v);
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: 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.AuthFastLeaderElection: 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.AuthFastLeaderElection: 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.AuthFastLeaderElection: 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;
return v;
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$Notification: java.net.InetSocketAddress addr>;
v = new oadd.org.apache.zookeeper.server.quorum.Vote;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$Notification: long leader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$Notification: long zxid>;
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.Vote: void <init>(long,long)>(v, v);
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$Notification: long leader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$Notification: long zxid>;
v = specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: boolean termPredicate(java.util.HashMap,long,long)>(v, v, v);
if v == 0 goto label;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: oadd.org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$Notification: long leader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: 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 = <oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState: oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState FOLLOWING>;
label:
virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPeer: void setPeerState(oadd.org.apache.zookeeper.server.quorum.QuorumPeer$ServerState)>(v);
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: void leaveInstance()>();
v = new oadd.org.apache.zookeeper.server.quorum.Vote;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$Notification: long leader>;
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection$Notification: long zxid>;
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.Vote: void <init>(long,long)>(v, v);
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: 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.AuthFastLeaderElection: 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.AuthFastLeaderElection: 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.AuthFastLeaderElection: 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;
return v;
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: 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.AuthFastLeaderElection: 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.AuthFastLeaderElection: 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.AuthFastLeaderElection: 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;
return null;
label:
v := @caughtexception;
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: 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.AuthFastLeaderElection: 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.AuthFastLeaderElection: 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.AuthFastLeaderElection: 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;
throw v;
catch java.lang.Exception 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.Exception 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.Throwable from label to label with label;
catch java.lang.Exception from label to label with label;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Loadd/org/apache/zookeeper/server/quorum/AuthFastLeaderElection;");
<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: org.slf4j.Logger LOG> = v;
<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: int sequencer> = 0;
<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: int maxTag> = 0;
<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: int finalizeWait> = 100;
<oadd.org.apache.zookeeper.server.quorum.AuthFastLeaderElection: int challengeCounter> = 0;
return;
}
}