public class oadd.org.apache.zookeeper.server.quorum.Leader extends java.lang.Object { private static final org.slf4j.Logger LOG; private static final boolean nodelay; private static final java.lang.String MAX_CONCURRENT_SNAPSHOTS; private static final int maxConcurrentSnapshots; private static final java.lang.String MAX_CONCURRENT_SNAPSHOT_TIMEOUT; private static final long maxConcurrentSnapshotTimeout; private final oadd.org.apache.zookeeper.server.quorum.LearnerSnapshotThrottler learnerSnapshotThrottler; final oadd.org.apache.zookeeper.server.quorum.LeaderZooKeeperServer zk; final oadd.org.apache.zookeeper.server.quorum.QuorumPeer self; protected boolean quorumFormed; volatile oadd.org.apache.zookeeper.server.quorum.Leader$LearnerCnxAcceptor cnxAcceptor; private final java.util.HashSet learners; private final oadd.org.apache.zookeeper.server.quorum.BufferStats proposalStats; private final java.util.HashSet forwardingFollowers; private final java.util.HashSet observingLearners; private final java.util.HashMap pendingSyncs; final java.util.concurrent.atomic.AtomicLong followerCounter; private final java.net.ServerSocket ss; static final int DIFF; static final int TRUNC; static final int SNAP; static final int OBSERVERINFO; static final int NEWLEADER; static final int FOLLOWERINFO; static final int UPTODATE; public static final int LEADERINFO; public static final int ACKEPOCH; static final int REQUEST; public static final int PROPOSAL; static final int ACK; static final int COMMIT; static final int PING; static final int REVALIDATE; static final int SYNC; static final int INFORM; static final int COMMITANDACTIVATE; static final int INFORMANDACTIVATE; final java.util.concurrent.ConcurrentMap outstandingProposals; private final java.util.concurrent.ConcurrentLinkedQueue toBeApplied; protected final oadd.org.apache.zookeeper.server.quorum.Leader$Proposal newLeaderProposal; oadd.org.apache.zookeeper.server.quorum.StateSummary leaderStateSummary; long epoch; boolean waitingForNewEpoch; boolean allowedToCommit; boolean isShutdown; long lastCommitted; long lastProposed; protected final java.util.Set connectingFollowers; protected final java.util.Set electingFollowers; protected boolean electionFinished; public oadd.org.apache.zookeeper.server.quorum.BufferStats getProposalStats() { oadd.org.apache.zookeeper.server.quorum.Leader v; oadd.org.apache.zookeeper.server.quorum.BufferStats v; v := @this: oadd.org.apache.zookeeper.server.quorum.Leader; v = v.; return v; } public oadd.org.apache.zookeeper.server.quorum.LearnerSnapshotThrottler createLearnerSnapshotThrottler(int, long) { oadd.org.apache.zookeeper.server.quorum.Leader v; int v; long v; oadd.org.apache.zookeeper.server.quorum.LearnerSnapshotThrottler v; v := @this: oadd.org.apache.zookeeper.server.quorum.Leader; v := @parameter: int; v := @parameter: long; v = new oadd.org.apache.zookeeper.server.quorum.LearnerSnapshotThrottler; specialinvoke v.(int,long)>(v, v); return v; } public java.util.List getLearners() { java.lang.Throwable v; java.util.HashSet v, v; oadd.org.apache.zookeeper.server.quorum.Leader v; java.util.ArrayList v; v := @this: oadd.org.apache.zookeeper.server.quorum.Leader; v = v.; entermonitor v; label: v = new java.util.ArrayList; v = v.; specialinvoke v.(java.util.Collection)>(v); exitmonitor v; label: return v; label: v := @caughtexception; exitmonitor v; throw v; catch java.lang.Throwable from label to label with label; } public java.util.List getForwardingFollowers() { java.lang.Throwable v; java.util.HashSet v, v; oadd.org.apache.zookeeper.server.quorum.Leader v; java.util.ArrayList v; v := @this: oadd.org.apache.zookeeper.server.quorum.Leader; v = v.; entermonitor v; label: v = new java.util.ArrayList; v = v.; specialinvoke v.(java.util.Collection)>(v); exitmonitor v; label: return v; label: v := @caughtexception; exitmonitor v; throw v; catch java.lang.Throwable from label to label with label; } private void addForwardingFollower(oadd.org.apache.zookeeper.server.quorum.LearnerHandler) { java.lang.Throwable v; java.util.HashSet v, v; oadd.org.apache.zookeeper.server.quorum.Leader v; oadd.org.apache.zookeeper.server.quorum.LearnerHandler v; v := @this: oadd.org.apache.zookeeper.server.quorum.Leader; v := @parameter: oadd.org.apache.zookeeper.server.quorum.LearnerHandler; v = v.; entermonitor v; label: v = v.; virtualinvoke v.(v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: return; catch java.lang.Throwable from label to label with label; } public java.util.List getObservingLearners() { java.lang.Throwable v; java.util.HashSet v, v; oadd.org.apache.zookeeper.server.quorum.Leader v; java.util.ArrayList v; v := @this: oadd.org.apache.zookeeper.server.quorum.Leader; v = v.; entermonitor v; label: v = new java.util.ArrayList; v = v.; specialinvoke v.(java.util.Collection)>(v); exitmonitor v; label: return v; label: v := @caughtexception; exitmonitor v; throw v; catch java.lang.Throwable from label to label with label; } private void addObserverLearnerHandler(oadd.org.apache.zookeeper.server.quorum.LearnerHandler) { java.lang.Throwable v; java.util.HashSet v, v; oadd.org.apache.zookeeper.server.quorum.Leader v; oadd.org.apache.zookeeper.server.quorum.LearnerHandler v; v := @this: oadd.org.apache.zookeeper.server.quorum.Leader; v := @parameter: oadd.org.apache.zookeeper.server.quorum.LearnerHandler; v = v.; entermonitor v; label: v = v.; virtualinvoke v.(v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: return; catch java.lang.Throwable from label to label with label; } public synchronized int getNumPendingSyncs() { int v; java.util.HashMap v; oadd.org.apache.zookeeper.server.quorum.Leader v; v := @this: oadd.org.apache.zookeeper.server.quorum.Leader; v = v.; v = virtualinvoke v.(); return v; } void addLearnerHandler(oadd.org.apache.zookeeper.server.quorum.LearnerHandler) { java.lang.Throwable v; java.util.HashSet v, v; oadd.org.apache.zookeeper.server.quorum.Leader v; oadd.org.apache.zookeeper.server.quorum.LearnerHandler v; v := @this: oadd.org.apache.zookeeper.server.quorum.Leader; v := @parameter: oadd.org.apache.zookeeper.server.quorum.LearnerHandler; v = v.; entermonitor v; label: v = v.; virtualinvoke v.(v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: return; catch java.lang.Throwable from label to label with label; } void removeLearnerHandler(oadd.org.apache.zookeeper.server.quorum.LearnerHandler) { java.lang.Throwable v, v, v; oadd.org.apache.zookeeper.server.quorum.Leader v; oadd.org.apache.zookeeper.server.quorum.LearnerHandler v; java.util.HashSet v, v, v, v, v, v; v := @this: oadd.org.apache.zookeeper.server.quorum.Leader; v := @parameter: oadd.org.apache.zookeeper.server.quorum.LearnerHandler; v = v.; entermonitor v; label: v = v.; virtualinvoke v.(v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = v.; entermonitor v; label: v = v.; virtualinvoke v.(v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = v.; entermonitor v; label: v = v.; virtualinvoke v.(v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: return; 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; } boolean isLearnerSynced(oadd.org.apache.zookeeper.server.quorum.LearnerHandler) { java.lang.Throwable v; java.util.HashSet v, v; oadd.org.apache.zookeeper.server.quorum.Leader v; oadd.org.apache.zookeeper.server.quorum.LearnerHandler v; boolean v; v := @this: oadd.org.apache.zookeeper.server.quorum.Leader; v := @parameter: oadd.org.apache.zookeeper.server.quorum.LearnerHandler; v = v.; entermonitor v; label: v = v.; v = virtualinvoke v.(v); exitmonitor v; label: return v; label: v := @caughtexception; exitmonitor v; throw v; catch java.lang.Throwable from label to label with label; } public boolean isQuorumSynced(oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier) { java.lang.Throwable v; long v, v, v, v; java.util.HashSet v, v, v; java.lang.Long v, v, v, v; java.util.Map v, v; boolean v, v, v, v, v; java.util.Iterator v; oadd.org.apache.zookeeper.server.quorum.Leader v; oadd.org.apache.zookeeper.server.quorum.QuorumPeer v, v; oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v; java.lang.Object v; v := @this: oadd.org.apache.zookeeper.server.quorum.Leader; v := @parameter: oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier; v = new java.util.HashSet; specialinvoke 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.(); v = staticinvoke (v); virtualinvoke v.(v); label: v = v.; entermonitor v; label: v = v.; v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.(v); goto label; label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = interfaceinvoke v.(v); return v; catch java.lang.Throwable from label to label with label; } void (oadd.org.apache.zookeeper.server.quorum.QuorumPeer, oadd.org.apache.zookeeper.server.quorum.LeaderZooKeeperServer) throws java.io.IOException { java.net.ServerSocket v, v, v, v; oadd.org.apache.zookeeper.common.QuorumX509Util v, v; oadd.org.apache.zookeeper.server.quorum.LearnerSnapshotThrottler v; boolean v, v, v, v, v, v, v; oadd.org.apache.zookeeper.server.quorum.BufferStats v; oadd.org.apache.zookeeper.server.quorum.Leader v; java.util.concurrent.ConcurrentHashMap v; java.net.InetSocketAddress v, v, v, v, v; java.util.concurrent.ConcurrentLinkedQueue v; oadd.org.apache.zookeeper.server.quorum.Leader$Proposal v; oadd.org.apache.zookeeper.server.quorum.LeaderZooKeeperServer v; java.util.HashMap v; long v; java.net.BindException v; java.util.HashSet v, v, v, v, v; int v, v, v, v; java.lang.String v, v; org.slf4j.Logger v, v; oadd.org.apache.zookeeper.server.quorum.UnifiedServerSocket v, v; oadd.org.apache.zookeeper.server.quorum.QuorumPeer v; java.util.concurrent.atomic.AtomicLong v; v := @this: oadd.org.apache.zookeeper.server.quorum.Leader; v := @parameter: oadd.org.apache.zookeeper.server.quorum.QuorumPeer; v := @parameter: oadd.org.apache.zookeeper.server.quorum.LeaderZooKeeperServer; specialinvoke v.()>(); v. = 0; v. = null; v = new java.util.HashSet; specialinvoke v.()>(); v. = v; v = new java.util.HashSet; specialinvoke v.()>(); v. = v; v = new java.util.HashSet; specialinvoke v.()>(); v. = v; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.atomic.AtomicLong; specialinvoke v.(long)>(-1L); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentLinkedQueue; specialinvoke v.()>(); v. = v; v = new oadd.org.apache.zookeeper.server.quorum.Leader$Proposal; specialinvoke v.()>(); v. = v; v. = -1L; v. = 1; v. = 1; v. = -1L; v = new java.util.HashSet; specialinvoke v.()>(); v. = v; v = new java.util.HashSet; specialinvoke v.()>(); v. = v; v. = 0; v. = v; v = new oadd.org.apache.zookeeper.server.quorum.BufferStats; specialinvoke v.()>(); v. = v; label: v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = new oadd.org.apache.zookeeper.server.quorum.UnifiedServerSocket; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(oadd.org.apache.zookeeper.common.X509Util,boolean,int)>(v, v, v); v. = v; goto label; label: v = new oadd.org.apache.zookeeper.server.quorum.UnifiedServerSocket; v = virtualinvoke v.(); specialinvoke v.(oadd.org.apache.zookeeper.common.X509Util,boolean)>(v, v); v. = v; goto label; label: v = virtualinvoke v.(); if v == 0 goto label; v = new java.net.ServerSocket; v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(int)>(v); v. = v; goto label; label: v = new java.net.ServerSocket; specialinvoke v.()>(); v. = v; label: v = v.; virtualinvoke v.(1); v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); if v == 0 goto label; v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Couldn\'t bind to port \u0001"); interfaceinvoke v.(v, v); goto label; label: v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Couldn\'t bind to \u0001"); interfaceinvoke v.(v, v); label: throw v; label: v. = v; v = ; v = ; v = virtualinvoke v.(v, v); v. = v; return; catch java.net.BindException from label to label with label; } void lead() throws java.io.IOException, java.lang.InterruptedException { oadd.org.apache.zookeeper.server.quorum.LeaderBean v; byte v, v, v, v, v, v; java.lang.Long v, v, v, v, v; java.util.Map v; oadd.org.apache.zookeeper.server.quorum.Leader$Proposal 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; java.io.IOException v; java.util.concurrent.atomic.AtomicInteger v, v; oadd.org.apache.zookeeper.server.quorum.SyncedLearnerTracker v; oadd.org.apache.zookeeper.server.quorum.Leader$LearnerCnxAcceptor v, v; oadd.org.apache.zookeeper.server.quorum.LocalPeerBean v; oadd.org.apache.zookeeper.server.quorum.QuorumPacket v, v, v; java.util.HashSet v; int v, v; org.slf4j.Logger v, v, v; java.lang.Object v, v, v, v; oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.Exception v; oadd.org.apache.zookeeper.server.quorum.StateSummary v, v; java.lang.Throwable v, v, v; oadd.org.apache.zookeeper.server.quorum.LeaderZooKeeperServer v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; oadd.org.apache.zookeeper.server.admin.AdminServer v; java.util.ArrayList v; java.lang.String v, v, v, v, v, v, v, v, v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v; oadd.org.apache.zookeeper.server.quorum.Leader v; java.util.List v, v, v; java.util.Iterator v, v, 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; java.lang.InterruptedException v; v := @this: oadd.org.apache.zookeeper.server.quorum.Leader; v = v.; v = staticinvoke (); v. = v; v = v.; v = v.; v = v.; v = v.; v = v - v; v = v.; virtualinvoke v.(v); v = ; v = staticinvoke (v); interfaceinvoke v.("LEADING - LEADER ELECTION TOOK - {} {}", v, "MS"); v = v.; v. = 0L; v = v.; v. = 0L; v = v.; v = new oadd.org.apache.zookeeper.server.quorum.LeaderBean; v = v.; specialinvoke v.(oadd.org.apache.zookeeper.server.quorum.Leader,oadd.org.apache.zookeeper.server.ZooKeeperServer)>(v, v); v = v.; v = v.; virtualinvoke v.(v, v); label: v = v.; v = v.; virtualinvoke v.(0); v = v.; virtualinvoke v.(); v = new oadd.org.apache.zookeeper.server.quorum.StateSummary; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); specialinvoke v.(long,long)>(v, v); v. = v; v = new oadd.org.apache.zookeeper.server.quorum.Leader$LearnerCnxAcceptor; specialinvoke v.(oadd.org.apache.zookeeper.server.quorum.Leader)>(v); v. = v; v = v.; virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); v = v.; v = staticinvoke (v, 0L); virtualinvoke v.(v); entermonitor v; label: v = v.; v = virtualinvoke v.(); v. = v; exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = v.; v = new oadd.org.apache.zookeeper.server.quorum.QuorumPacket; v = v.; v = virtualinvoke v.(); specialinvoke v.(int,long,byte[],java.util.List)>(10, v, null, null); v. = v; v = v.; v = v.; v = virtualinvoke v.(); v = v & 4294967295L; v = v cmp 0L; if v == 0 goto label; v = ; v = v.; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v) ("NEWLEADER proposal has Zxid of \u0001"); interfaceinvoke v.(v); label: v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = v cmp 0L; if v != 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = v cmp v; if v != 0 goto label; label: v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); v = v.; virtualinvoke v.(v, 1); label: goto label; label: v := @caughtexception; v = new java.io.IOException; specialinvoke v.(java.lang.Throwable)>(v); throw v; label: v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); 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 = v.; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = v.; v = virtualinvoke v.(); v = v.; virtualinvoke v.(v, v); v = v.; virtualinvoke v.(v); label: v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Waiting for a quorum of followers, only synced with sids: [ \u ]"); virtualinvoke v.(v); v = new java.util.HashSet; specialinvoke v.()>(); v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.(v); goto label; label: v = 1; v = v.; v = v.; v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v != 0 goto label; v = 0; label: if v == 0 goto label; v = ; interfaceinvoke v.("Enough followers present. Perhaps the initTicks need to be increased."); label: v = v.; virtualinvoke v.(v); return; label: specialinvoke v.(); v = staticinvoke ("zookeeper.testingonly.initialZxid"); if v == null goto label; v = staticinvoke (v); v = v.; v = v.; v = virtualinvoke v.(); v = v & -4294967296L; v = v | v; virtualinvoke v.(v); label: v = staticinvoke ("zookeeper.leaderServes", "yes"); v = virtualinvoke v.("no"); if v != 0 goto label; v = v.; v = v.; virtualinvoke v.(v); label: v = v.; v = v.; v = v.; interfaceinvoke v.(v); v = 1; label: entermonitor v; label: v = staticinvoke (); v = v; v = v.; v = v.; v = v / 2; v = v + v; label: v = v cmp v; if v >= 0 goto label; v = v - v; virtualinvoke v.(v); v = staticinvoke (); goto label; label: if v != 0 goto label; v = v.; v = v.; virtualinvoke v.(); label: v = new oadd.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 = v.; v = virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.(v); v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.(v); goto label; label: v = specialinvoke v.(); if v != 0 goto label; v = "Unexpected internal error"; exitmonitor v; label: goto label; label: if v != 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Not sufficient followers synced, only synced with sids: [ \u ]"); exitmonitor v; label: goto label; label: if v != 0 goto label; v = 1; goto label; label: v = 0; label: v = v; exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(); goto label; label: if v == null goto label; virtualinvoke v.(v); label: v = v.; virtualinvoke v.(v); goto label; label: v := @caughtexception; v = v.; virtualinvoke v.(v); throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Exception from label to label with label; catch java.lang.InterruptedException 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; } void shutdown(java.lang.String) { java.lang.Throwable v; oadd.org.apache.zookeeper.server.quorum.LeaderZooKeeperServer v, v; oadd.org.apache.zookeeper.server.admin.AdminServer v; java.net.ServerSocket v; java.util.HashSet v, v; oadd.org.apache.zookeeper.server.quorum.Leader$LearnerCnxAcceptor v, v; java.lang.String v, v; boolean v, v; org.slf4j.Logger v, v, v; java.util.Iterator v; oadd.org.apache.zookeeper.server.quorum.Leader v; oadd.org.apache.zookeeper.server.quorum.QuorumPeer v, v, v; java.io.IOException v; java.lang.Exception v; java.lang.Object v; v := @this: oadd.org.apache.zookeeper.server.quorum.Leader; v := @parameter: java.lang.String; v = ; interfaceinvoke v.("Shutting down"); v = v.; if v == 0 goto label; return; label: v = ; v = new java.lang.Exception; v = dynamicinvoke "makeConcatWithConstants" (v) ("shutdown Leader! reason: \u0001"); specialinvoke v.(java.lang.String)>(v); interfaceinvoke v.("Shutdown called", v); v = v.; if v == null goto label; v = v.; virtualinvoke v.(); label: v = v.; virtualinvoke v.(null); v = v.; v = v.; interfaceinvoke v.(null); label: v = v.; virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Ignoring unexpected exception during close", v); label: v = v.; virtualinvoke v.(); v = v.; if v == null goto label; v = v.; virtualinvoke v.(); label: v = v.; entermonitor v; label: v = v.; v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); interfaceinvoke v.(); virtualinvoke v.(); goto label; label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v. = 1; return; catch java.io.IOException from label to label with label; catch java.lang.Throwable from label to label with label; } private long getDesignatedLeader(oadd.org.apache.zookeeper.server.quorum.Leader$Proposal, long) { java.lang.Long v, v, v, v, v; java.util.Map v, v; boolean v, v, v, v, v; oadd.org.apache.zookeeper.server.quorum.Leader v; oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v, v; java.net.InetSocketAddress v, v; oadd.org.apache.zookeeper.server.quorum.Leader$Proposal v; long v, v, v, v, v, v, v; java.util.ArrayList v, v, v; java.util.concurrent.ConcurrentMap v, v; java.util.HashSet v, v, v; int v, v, v; java.util.Iterator v, v, v; oadd.org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v, v; java.lang.Object v, v, v, v, v, v; v := @this: oadd.org.apache.zookeeper.server.quorum.Leader; v := @parameter: oadd.org.apache.zookeeper.server.quorum.Leader$Proposal; v := @parameter: long; v = v.; v = v.; v = virtualinvoke v.(); v = v - 1; v = virtualinvoke 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 = virtualinvoke v.(); v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = v.; v = virtualinvoke v.(); return v; label: v = new java.util.HashSet; v = virtualinvoke v.(); specialinvoke v.(java.util.Collection)>(v); v = v.; v = virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.(v); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = v + 1L; v = v.; v = staticinvoke (v); v = interfaceinvoke v.(v); label: if v == null goto label; v = virtualinvoke v.