public class org.apache.zookeeper.server.quorum.FastLeaderElection extends java.lang.Object implements org.apache.zookeeper.server.quorum.Election { private static final org.slf4j.Logger LOG; static final int finalizeWait; private static int maxNotificationInterval; private static int minNotificationInterval; public static final java.lang.String MIN_NOTIFICATION_INTERVAL; public static final java.lang.String MAX_NOTIFICATION_INTERVAL; org.apache.zookeeper.server.quorum.QuorumCnxManager manager; private org.apache.zookeeper.server.quorum.SyncedLearnerTracker leadingVoteSet; static byte[] dummyData; java.util.concurrent.LinkedBlockingQueue sendqueue; java.util.concurrent.LinkedBlockingQueue recvqueue; org.apache.zookeeper.server.quorum.QuorumPeer self; 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() { java.util.concurrent.atomic.AtomicLong v; long v; org.apache.zookeeper.server.quorum.FastLeaderElection v; v := @this: org.apache.zookeeper.server.quorum.FastLeaderElection; v = v.; v = virtualinvoke v.(); 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 (v); virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(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 (v); virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(2); v = lengthof v; virtualinvoke v.(v); virtualinvoke v.(v); return v; } public void (org.apache.zookeeper.server.quorum.QuorumPeer, org.apache.zookeeper.server.quorum.QuorumCnxManager) { org.apache.zookeeper.server.quorum.QuorumPeer v; java.util.concurrent.atomic.AtomicLong v; org.apache.zookeeper.server.quorum.FastLeaderElection v; org.apache.zookeeper.server.quorum.QuorumCnxManager v; v := @this: org.apache.zookeeper.server.quorum.FastLeaderElection; v := @parameter: org.apache.zookeeper.server.quorum.QuorumPeer; v := @parameter: org.apache.zookeeper.server.quorum.QuorumCnxManager; specialinvoke v.()>(); v = new java.util.concurrent.atomic.AtomicLong; specialinvoke v.()>(); v. = v; v. = 0; v. = v; specialinvoke v.(v, v); return; } private void starter(org.apache.zookeeper.server.quorum.QuorumPeer, org.apache.zookeeper.server.quorum.QuorumCnxManager) { org.apache.zookeeper.server.quorum.QuorumPeer v; org.apache.zookeeper.server.quorum.FastLeaderElection$Messenger v; org.apache.zookeeper.server.quorum.FastLeaderElection v; java.util.concurrent.LinkedBlockingQueue v, v; org.apache.zookeeper.server.quorum.QuorumCnxManager v; v := @this: org.apache.zookeeper.server.quorum.FastLeaderElection; v := @parameter: org.apache.zookeeper.server.quorum.QuorumPeer; v := @parameter: org.apache.zookeeper.server.quorum.QuorumCnxManager; v. = v; v. = -1L; v. = -1L; v = new java.util.concurrent.LinkedBlockingQueue; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.LinkedBlockingQueue; specialinvoke v.()>(); v. = v; v = new org.apache.zookeeper.server.quorum.FastLeaderElection$Messenger; specialinvoke v.(org.apache.zookeeper.server.quorum.FastLeaderElection,org.apache.zookeeper.server.quorum.QuorumCnxManager)>(v, v); v. = v; return; } public void start() { org.apache.zookeeper.server.quorum.FastLeaderElection$Messenger v; org.apache.zookeeper.server.quorum.FastLeaderElection v; v := @this: org.apache.zookeeper.server.quorum.FastLeaderElection; v = v.; virtualinvoke v.(); return; } private void leaveInstance(org.apache.zookeeper.server.quorum.Vote) { org.apache.zookeeper.server.quorum.QuorumPeer v, v; java.lang.Object[] v; org.slf4j.Logger v; org.apache.zookeeper.server.quorum.Vote v; org.apache.zookeeper.server.quorum.FastLeaderElection v; long v, v, v; java.util.concurrent.LinkedBlockingQueue v; org.apache.zookeeper.server.quorum.QuorumPeer$ServerState v; java.lang.Long v, v; java.lang.String v; v := @this: org.apache.zookeeper.server.quorum.FastLeaderElection; v := @parameter: org.apache.zookeeper.server.quorum.Vote; v = ; v = newarray (java.lang.Object)[4]; v = virtualinvoke v.(); v = staticinvoke (v); v[0] = v; v = virtualinvoke v.(); v = staticinvoke (v); v[1] = v; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v[2] = v; v = v.; v = virtualinvoke v.(); v[3] = v; interfaceinvoke v.("About to leave FLE instance: leader={}, zxid=0x{}, my id={}, my state={}", v); v = v.; virtualinvoke v.(); return; } public org.apache.zookeeper.server.quorum.QuorumCnxManager getCnxManager() { org.apache.zookeeper.server.quorum.FastLeaderElection v; org.apache.zookeeper.server.quorum.QuorumCnxManager v; v := @this: org.apache.zookeeper.server.quorum.FastLeaderElection; v = v.; return v; } public void shutdown() { org.slf4j.Logger v, v, v; org.apache.zookeeper.server.quorum.FastLeaderElection$Messenger v; org.apache.zookeeper.server.quorum.FastLeaderElection v; org.apache.zookeeper.server.quorum.QuorumCnxManager v; v := @this: org.apache.zookeeper.server.quorum.FastLeaderElection; v. = 1; v. = -1L; v. = -1L; v. = null; v = ; interfaceinvoke v.("Shutting down connection manager"); v = v.; virtualinvoke v.(); v = ; interfaceinvoke v.("Shutting down messenger"); v = v.; virtualinvoke v.(); v = ; interfaceinvoke v.("FLE is down"); return; } private void sendNotifications() { org.apache.zookeeper.server.quorum.QuorumPeer v, v, v; byte[] v; org.apache.zookeeper.server.quorum.QuorumPeer$ServerState v; java.lang.Long v, v, v; boolean v; org.apache.zookeeper.server.quorum.FastLeaderElection v; java.util.Set v; java.util.concurrent.LinkedBlockingQueue v; java.lang.Object[] v; org.apache.zookeeper.server.quorum.FastLeaderElection$ToSend$mType v; org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v; long v, v, v, v, v, v, v, v, v, v; java.nio.charset.Charset v; java.lang.String v, v, v, v; org.slf4j.Logger v; java.util.Iterator v; org.apache.zookeeper.server.quorum.FastLeaderElection$ToSend v; java.util.concurrent.atomic.AtomicLong v, v; java.lang.Object v; v := @this: org.apache.zookeeper.server.quorum.FastLeaderElection; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = new org.apache.zookeeper.server.quorum.FastLeaderElection$ToSend; v = ; v = v.; v = v.; v = v.; v = virtualinvoke v.(); v = ; v = v.; v = interfaceinvoke v.(); v = ; v = virtualinvoke v.(v); specialinvoke v.(org.apache.zookeeper.server.quorum.FastLeaderElection$ToSend$mType,long,long,long,org.apache.zookeeper.server.quorum.QuorumPeer$ServerState,long,long,byte[])>(v, v, v, v, v, v, v, v); v = ; v = newarray (java.lang.Object)[6]; v = v.; v = staticinvoke (v); v[0] = v; v = v.; v = staticinvoke (v); v[1] = v; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v[2] = v; v = staticinvoke (v); v[3] = v; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v[4] = v; v = v.; v = staticinvoke (v); v[5] = v; interfaceinvoke v.("Sending Notification: {} (n.leader), 0x{} (n.zxid), 0x{} (n.round), {} (recipient), {} (myid), 0x{} (n.peerEpoch) ", v); v = v.; virtualinvoke v.(v); goto label; label: return; } protected boolean totalOrderPredicate(long, long, long, long, long, long) { org.apache.zookeeper.server.quorum.QuorumPeer v; java.lang.Object[] v; org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v; long v, v, v, v, v, v, v; byte v, v, v, v, v, v; java.lang.Long v, v; java.lang.String v, v; boolean v; org.slf4j.Logger v; org.apache.zookeeper.server.quorum.FastLeaderElection v; v := @this: 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 = ; v = newarray (java.lang.Object)[4]; v = staticinvoke (v); v[0] = v; v = staticinvoke (v); v[1] = v; v = staticinvoke (v); v[2] = v; v = staticinvoke (v); v[3] = v; interfaceinvoke v.("id: {}, proposed id: {}, zxid: 0x{}, proposed zxid: 0x{}", v); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(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 org.apache.zookeeper.server.quorum.SyncedLearnerTracker getVoteTracker(java.util.Map, org.apache.zookeeper.server.quorum.Vote) { org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v, v; org.apache.zookeeper.server.quorum.SyncedLearnerTracker v; org.apache.zookeeper.server.quorum.Vote v; org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v, v, v, v, v; long v, v; byte v; java.util.Map v; boolean v, v; java.util.Iterator v; org.apache.zookeeper.server.quorum.FastLeaderElection v; java.util.Set v; java.lang.Object v, v, v; v := @this: org.apache.zookeeper.server.quorum.FastLeaderElection; v := @parameter: java.util.Map; v := @parameter: org.apache.zookeeper.server.quorum.Vote; v = new org.apache.zookeeper.server.quorum.SyncedLearnerTracker; specialinvoke v.()>(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); if v == null goto label; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = v cmp v; if v <= 0 goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(v); goto label; label: return v; } protected boolean checkLeader(java.util.Map, long, long) { org.apache.zookeeper.server.quorum.QuorumPeer v; long v, v, v, v; byte v, v; org.apache.zookeeper.server.quorum.QuorumPeer$ServerState v, v; java.lang.Long v, v; java.util.Map v; boolean v; org.apache.zookeeper.server.quorum.FastLeaderElection v; java.util.concurrent.atomic.AtomicLong v; java.lang.Object v, v; v := @this: org.apache.zookeeper.server.quorum.FastLeaderElection; v := @parameter: java.util.Map; v := @parameter: long; v := @parameter: long; v = 1; v = v.; v = virtualinvoke v.(); v = v cmp v; if v == 0 goto label; v = staticinvoke (v); v = interfaceinvoke v.(v); if v != null goto label; v = 0; goto label; label: v = staticinvoke (v); v = interfaceinvoke v.(v); v = virtualinvoke v.(); v = ; if v == v goto label; v = 0; goto label; label: v = v.; v = virtualinvoke v.(); v = v cmp v; if v == 0 goto label; v = 0; label: return v; } synchronized void updateProposal(long, long, long) { java.lang.Object[] v; org.slf4j.Logger v; org.apache.zookeeper.server.quorum.FastLeaderElection v; long v, v, v, v, v; java.lang.Long v, v; java.lang.String v, v; v := @this: org.apache.zookeeper.server.quorum.FastLeaderElection; v := @parameter: long; v := @parameter: long; v := @parameter: long; v = ; v = newarray (java.lang.Object)[4]; v = staticinvoke (v); v[0] = v; v = staticinvoke (v); v[1] = v; v = v.; v = staticinvoke (v); v[2] = v; v = v.; v = staticinvoke (v); v[3] = v; interfaceinvoke v.("Updating proposal: {} (newleader), 0x{} (newzxid), {} (oldleader), 0x{} (oldzxid)", v); v. = v; v. = v; v. = v; return; } public synchronized org.apache.zookeeper.server.quorum.Vote getVote() { org.apache.zookeeper.server.quorum.Vote v; org.apache.zookeeper.server.quorum.FastLeaderElection v; long v, v, v; v := @this: org.apache.zookeeper.server.quorum.FastLeaderElection; v = new org.apache.zookeeper.server.quorum.Vote; v = v.; v = v.; v = v.; specialinvoke v.(long,long,long)>(v, v, v); return v; } private org.apache.zookeeper.server.quorum.QuorumPeer$ServerState learningState() { org.apache.zookeeper.server.quorum.QuorumPeer v, v, v; org.slf4j.Logger v, v; org.apache.zookeeper.server.quorum.FastLeaderElection v; long v, v; org.apache.zookeeper.server.quorum.QuorumPeer$ServerState v, v; java.lang.Long v, v; org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType v, v; v := @this: org.apache.zookeeper.server.quorum.FastLeaderElection; v = v.; v = virtualinvoke v.(); v = ; if v != v goto label; v = ; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("I am a participant: {}", v); v = ; return v; label: v = ; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("I am an observer: {}", v); v = ; return v; } private long getInitId() { org.apache.zookeeper.server.quorum.QuorumPeer v, v, v; org.apache.zookeeper.server.quorum.FastLeaderElection v; org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v; long v, v; java.lang.Long v; java.util.Map v; boolean v; v := @this: org.apache.zookeeper.server.quorum.FastLeaderElection; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); if v == 0 goto label; v = v.; v = virtualinvoke v.(); return v; label: return -9223372036854775808L; } private long getInitLastLoggedZxid() { org.apache.zookeeper.server.quorum.QuorumPeer v, v; org.apache.zookeeper.server.quorum.FastLeaderElection v; org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType v, v; long v; v := @this: org.apache.zookeeper.server.quorum.FastLeaderElection; v = v.; v = virtualinvoke v.(); v = ; if v != v goto label; v = v.; v = virtualinvoke v.(); return v; label: return -9223372036854775808L; } private long getPeerEpoch() { org.apache.zookeeper.server.quorum.QuorumPeer v, v; org.apache.zookeeper.server.quorum.FastLeaderElection v; java.io.IOException v; long v; java.lang.RuntimeException v; java.lang.StackTraceElement[] v; org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType v, v; java.lang.String v; v := @this: org.apache.zookeeper.server.quorum.FastLeaderElection; v = v.; v = virtualinvoke v.(); v = ; if v != v goto label; label: v = v.; v = virtualinvoke v.(); label: return v; label: v := @caughtexception; v = new java.lang.RuntimeException; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(); virtualinvoke v.(v); throw v; label: return -9223372036854775808L; catch java.io.IOException from label to label with label; } private void setPeerState(long, org.apache.zookeeper.server.quorum.SyncedLearnerTracker) { org.apache.zookeeper.server.quorum.QuorumPeer v, v; org.apache.zookeeper.server.quorum.SyncedLearnerTracker v; org.apache.zookeeper.server.quorum.FastLeaderElection v; long v, v; byte v; org.apache.zookeeper.server.quorum.QuorumPeer$ServerState v, v; v := @this: org.apache.zookeeper.server.quorum.FastLeaderElection; v := @parameter: long; v := @parameter: org.apache.zookeeper.server.quorum.SyncedLearnerTracker; v = v.; v = virtualinvoke v.(); v = v cmp v; if v != 0 goto label; v = ; goto label; label: v = specialinvoke v.(); label: v = v.; virtualinvoke v.(v); v = ; if v != v goto label; v. = v; label: return; } public org.apache.zookeeper.server.quorum.Vote lookForLeader() throws java.lang.InterruptedException { java.lang.Integer v; byte v, v, v, v; java.lang.Long v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.server.quorum.QuorumCnxManager v, v, v, v, v, v, v, v; java.lang.Object[] v; org.apache.zookeeper.server.quorum.flexible.QuorumVerifier 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; java.util.concurrent.atomic.AtomicLong v, v, v, v, v, v, v, v; org.apache.zookeeper.server.quorum.LeaderElectionBean v, v, v, v, v, v, v, v, v, v, v, v, v, v; int[] v; int 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, v, v; java.lang.Object v, v; 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; org.apache.zookeeper.server.quorum.LocalPeerBean v; org.apache.zookeeper.server.quorum.QuorumPeer$ServerState v, v, v, v; org.apache.zookeeper.server.quorum.FastLeaderElection v; java.lang.Exception v, v, v, v, v, v, v; java.lang.Throwable v, v; org.apache.zookeeper.server.quorum.Vote v, v, v, v, v, v; java.lang.String v, v, v, v, v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.concurrent.LinkedBlockingQueue v, v, v; org.apache.zookeeper.server.quorum.SyncedLearnerTracker v, v; java.util.HashMap v, v; org.apache.zookeeper.jmx.MBeanRegistry v, v, v, v, v, v, v; java.util.concurrent.TimeUnit v, v; v := @this: org.apache.zookeeper.server.quorum.FastLeaderElection; label: v = v.; v = new org.apache.zookeeper.server.quorum.LeaderElectionBean; specialinvoke v.()>(); v. = v; v = staticinvoke (); v = v.; v = v.; v = v.; v = v.; virtualinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to register with JMX", v); v = v.; v. = null; label: v = v.; v = staticinvoke (); v. = v; label: v = new java.util.HashMap; specialinvoke v.()>(); v = new java.util.HashMap; specialinvoke v.()>(); v = ; entermonitor v; label: v = v.; virtualinvoke v.(); v = specialinvoke v.(); v = specialinvoke v.(); v = specialinvoke v.(); virtualinvoke v.(v, v, v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = ; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = v.; v = staticinvoke (v); interfaceinvoke v.("New election. My id = {}, proposed zxid=0x{}", v, v); specialinvoke v.(); v = null; label: v = v.; v = virtualinvoke v.(); v = ; if v != v goto label; v = v.; if v != 0 goto label; v = v.; v = ; v = virtualinvoke v.(v, v); if v != null goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; specialinvoke v.(); goto label; label: v = v.; virtualinvoke v.(); label: v = v << 1; v = ; v = staticinvoke (v, v); v = v.; v = virtualinvoke v.(); v = v instanceof org.apache.zookeeper.server.quorum.flexible.QuorumOracleMaj; if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = v; v = ; if v == v goto label; v = 1; goto label; label: v = 0; label: v = interfaceinvoke v.(v, v); if v == 0 goto label; v = v.; specialinvoke v.(v, v); v = new org.apache.zookeeper.server.quorum.Vote; v = v.; v = v.; v = v.; v = virtualinvoke v.(); v = v.; specialinvoke v.(long,long,long,long)>(v, v, v, v); specialinvoke v.(v); label: v = v.; v = v.; if v == null goto label; v = staticinvoke (); v = v.; v = v.; virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to unregister with JMX", v); label: v = v.; v. = null; v = ; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("Number of connection processing threads: {}", v); return v; label: v = ; v = staticinvoke (v); interfaceinvoke v.("Notification time out: {} ms", v); goto label; label: v = v.; v = specialinvoke v.(v); if v == 0 goto label; v = v.; v = specialinvoke v.(v); if v == 0 goto label; v = ; v = v.; v = virtualinvoke v.(); 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 = specialinvoke v.(); v = v cmp -1L; if v != 0 goto label; v = ; interfaceinvoke v.("Ignoring notification as our zxid is -1"); goto label; label: v = v.; v = v cmp -1L; if v != 0 goto label; v = ; v = v.; v = staticinvoke (v); interfaceinvoke v.("Ignoring notification from member with -1 zxid {}", v); goto label; label: v = v.; v = v.; v = virtualinvoke v.(); v = v cmp v; if v <= 0 goto label; v = v.; v = v.; virtualinvoke v.(v); interfaceinvoke v.(); v = v.; v = v.; v = v.; v = specialinvoke v.(); v = specialinvoke v.(); v = specialinvoke v.(); v = virtualinvoke v.(v, v, v, v, v, v); if v == 0 goto label; v = v.; v = v.; v = v.; virtualinvoke v.(v, v, v); goto label; label: v = specialinvoke v.(); v = specialinvoke v.(); v = specialinvoke v.(); virtualinvoke v.(v, v, v); label: specialinvoke v.(); goto label; label: v = v.; v = v.; v = virtualinvoke v.(); v = v cmp v; if v >= 0 goto label; v = ; v = v.; v = staticinvoke (v); v = v.; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("Notification election epoch is smaller than logicalclock. n.electionEpoch = 0x{}, logicalclock=0x{}", v, v); goto label; label: v = v.; v = v.; v = v.; v = v.; v = v.; v = v.; v = virtualinvoke v.(v, v, v, v, v, v); if v == 0 goto label; v = v.; v = v.; v = v.; virtualinvoke v.(v, v, v); specialinvoke v.(); label: v = ; v = newarray (java.lang.Object)[4]; v = v.; v = staticinvoke (v); v[0] = v; v = v.; v = staticinvoke (v); v[1] = v; v = v.; v = staticinvoke (v); v[2] = v; v = v.; v = staticinvoke (v); v[3] = v; interfaceinvoke v.("Adding vote: from={}, proposed leader={}, proposed zxid=0x{}, proposed election epoch=0x{}", v); v = v.; v = staticinvoke (v); v = new org.apache.zookeeper.server.quorum.Vote; v = v.; v = v.; v = v.; v = v.; specialinvoke v.(long,long,long,long)>(v, v, v, v); interfaceinvoke v.(v, v); v = new org.apache.zookeeper.server.quorum.Vote; v = v.; v = v.; v = v.; v = virtualinvoke v.(); v = v.; specialinvoke v.(long,long,long,long)>(v, v, v, v); v = virtualinvoke v.(v, v); v = virtualinvoke v.(); if v == 0 goto label; label: v = v.; v = ; v = virtualinvoke v.(200L, v); if v == null goto label; v = v.; v = v.; v = v.; v = v.; v = v.; v = v.; v = virtualinvoke v.(v, v, v, v, v, v); if v == 0 goto label; v = v.; virtualinvoke v.(v); label: if v != null goto label; v = v.; specialinvoke v.(v, v); v = new org.apache.zookeeper.server.quorum.Vote; v = v.; v = v.; v = v.; v = virtualinvoke v.(); v = v.; specialinvoke v.(long,long,long,long)>(v, v, v, v); specialinvoke v.(v); label: v = v.; v = v.; if v == null goto label; v = staticinvoke (); v = v.; v = v.; virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to unregister with JMX", v); label: v = v.