public class org.apache.zookeeper.server.quorum.Leader extends org.apache.zookeeper.server.quorum.LearnerMaster { private static final org.slf4j.Logger LOG; private static final boolean nodelay; private static final java.lang.String ACK_LOGGING_FREQUENCY; private static int ackLoggingFrequency; final org.apache.zookeeper.server.quorum.LeaderZooKeeperServer zk; final org.apache.zookeeper.server.quorum.QuorumPeer self; protected boolean quorumFormed; volatile org.apache.zookeeper.server.quorum.Leader$LearnerCnxAcceptor cnxAcceptor; private final java.util.HashSet learners; private final org.apache.zookeeper.server.quorum.BufferStats proposalStats; private final java.util.concurrent.ConcurrentHashMap connectionBeans; private final java.util.HashSet forwardingFollowers; private final java.util.HashSet observingLearners; private final java.util.Map pendingSyncs; final java.util.concurrent.atomic.AtomicLong followerCounter; private final java.util.List serverSockets; 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 org.apache.zookeeper.server.quorum.Leader$Proposal newLeaderProposal; org.apache.zookeeper.server.quorum.StateSummary leaderStateSummary; long epoch; boolean waitingForNewEpoch; boolean allowedToCommit; private long leaderStartTime; boolean isShutdown; long lastCommitted; long lastProposed; protected final java.util.Set connectingFollowers; private volatile boolean quitWaitForEpoch; private volatile long timeStartWaitForEpoch; private volatile org.apache.zookeeper.server.quorum.SyncedLearnerTracker voteSet; public static final java.lang.String MAX_TIME_TO_WAIT_FOR_EPOCH; private static int maxTimeToWaitForEpoch; protected final java.util.Set electingFollowers; protected boolean electionFinished; public static void setAckLoggingFrequency(int) { int v; v := @parameter: int; = v; return; } public static int getAckLoggingFrequency() { int v; v = ; return v; } public org.apache.zookeeper.server.quorum.BufferStats getProposalStats() { org.apache.zookeeper.server.quorum.Leader v; org.apache.zookeeper.server.quorum.BufferStats v; v := @this: org.apache.zookeeper.server.quorum.Leader; v = v.; return v; } public java.util.List getLearners() { java.lang.Throwable v; java.util.HashSet v, v; org.apache.zookeeper.server.quorum.Leader v; java.util.ArrayList v; v := @this: 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; org.apache.zookeeper.server.quorum.Leader v; java.util.ArrayList v; v := @this: 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 getNonVotingFollowers() { java.lang.Throwable v; java.util.Iterator v; long v; java.util.ArrayList v; java.util.HashSet v, v; org.apache.zookeeper.server.quorum.Leader v; java.lang.Object v; boolean v, v; v := @this: org.apache.zookeeper.server.quorum.Leader; v = new java.util.ArrayList; specialinvoke v.()>(); 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.(); v = specialinvoke v.(v); if v != 0 goto label; interfaceinvoke v.(v); goto label; label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: return v; catch java.lang.Throwable from label to label with label; } void addForwardingFollower(org.apache.zookeeper.server.quorum.LearnerHandler) { java.lang.Throwable v; org.apache.zookeeper.server.quorum.QuorumPeer v; org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v; java.util.ArrayList v; java.util.HashSet v, v, v; org.apache.zookeeper.server.quorum.LearnerHandler v; org.apache.zookeeper.server.quorum.Leader v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: org.apache.zookeeper.server.quorum.LearnerHandler; v = v.; entermonitor v; label: v = v.; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = new java.util.ArrayList; v = v.; specialinvoke v.(java.util.Collection)>(v); interfaceinvoke 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; org.apache.zookeeper.server.quorum.Leader v; java.util.ArrayList v; v := @this: 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(org.apache.zookeeper.server.quorum.LearnerHandler) { java.lang.Throwable v; java.util.HashSet v, v; org.apache.zookeeper.server.quorum.LearnerHandler v; org.apache.zookeeper.server.quorum.Leader v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: 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.lang.Iterable getObservingLearnersInfo() { java.lang.Throwable v; java.util.Iterator v; java.util.HashSet v, v, v; org.apache.zookeeper.server.quorum.Leader v; java.util.Map v; java.lang.Object v; boolean v; v := @this: org.apache.zookeeper.server.quorum.Leader; v = new java.util.HashSet; specialinvoke v.()>(); 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.(); interfaceinvoke v.(v); goto label; label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: return v; catch java.lang.Throwable from label to label with label; } public void resetObserverConnectionStats() { java.lang.Throwable v; java.util.HashSet v, v; org.apache.zookeeper.server.quorum.Leader v; java.util.Iterator v; java.lang.Object v; boolean v; v := @this: org.apache.zookeeper.server.quorum.Leader; v = v.; entermonitor v; label: v = v.; v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(); goto label; label: 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; org.apache.zookeeper.server.quorum.Leader v; java.util.Map v; v := @this: org.apache.zookeeper.server.quorum.Leader; v = v.; v = interfaceinvoke v.(); return v; } public void addLearnerHandler(org.apache.zookeeper.server.quorum.LearnerHandler) { java.lang.Throwable v; java.util.HashSet v, v; org.apache.zookeeper.server.quorum.LearnerHandler v; org.apache.zookeeper.server.quorum.Leader v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: 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 void removeLearnerHandler(org.apache.zookeeper.server.quorum.LearnerHandler) { java.lang.Throwable v, v, v; java.util.HashSet v, v, v, v, v, v; org.apache.zookeeper.server.quorum.LearnerHandler v; org.apache.zookeeper.server.quorum.Leader v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: 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(org.apache.zookeeper.server.quorum.LearnerHandler) { java.lang.Throwable v; java.util.HashSet v, v; org.apache.zookeeper.server.quorum.LearnerHandler v; org.apache.zookeeper.server.quorum.Leader v; boolean v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: 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(org.apache.zookeeper.server.quorum.flexible.QuorumVerifier) { java.lang.Throwable v; org.apache.zookeeper.server.quorum.QuorumPeer v, v; org.apache.zookeeper.server.quorum.flexible.QuorumVerifier 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; org.apache.zookeeper.server.quorum.Leader v; java.lang.Object v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: 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; } public void (org.apache.zookeeper.server.quorum.QuorumPeer, org.apache.zookeeper.server.quorum.LeaderZooKeeperServer) throws java.io.IOException { org.apache.zookeeper.server.quorum.QuorumPeer v; org.apache.zookeeper.server.quorum.BufferStats v; boolean v, v; java.util.function.Predicate v; java.util.concurrent.ConcurrentHashMap v, v; java.util.Set v; java.util.List v, v; java.util.stream.Stream v, v, v, v; org.apache.zookeeper.server.quorum.Leader$Proposal v; java.util.concurrent.ConcurrentLinkedQueue v; java.util.HashMap v; java.util.function.Function v, v; java.util.HashSet v, v, v, v, v; java.lang.String v; java.util.LinkedList v; java.io.IOException v; java.util.function.Consumer v; java.util.concurrent.atomic.AtomicLong v; org.apache.zookeeper.server.quorum.LeaderZooKeeperServer v; org.apache.zookeeper.server.quorum.Leader v; org.apache.zookeeper.server.quorum.MultipleAddresses v, v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: org.apache.zookeeper.server.quorum.QuorumPeer; v := @parameter: 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.concurrent.ConcurrentHashMap; 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.LinkedList; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentLinkedQueue; specialinvoke v.()>(); v. = v; v = new 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. = 0; v. = -1L; v = new java.util.HashSet; specialinvoke v.()>(); v. = v; v. = 0; v. = v; v = new org.apache.zookeeper.server.quorum.BufferStats; specialinvoke v.()>(); v. = v; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(); label: v = interfaceinvoke v.(); v = staticinvoke (v, v); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = v.; virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v); v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = new java.io.IOException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Leader failed to initialize any of the following sockets: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v. = v; return; } java.util.Optional createServerSocket(java.net.InetSocketAddress, boolean, boolean) { org.apache.zookeeper.server.quorum.QuorumPeer v; org.slf4j.Logger v; java.io.IOException v; java.net.InetSocketAddress v; java.net.ServerSocket v, v; org.apache.zookeeper.server.quorum.Leader v; java.util.Optional v, v; org.apache.zookeeper.common.QuorumX509Util v; java.lang.String v; org.apache.zookeeper.server.quorum.UnifiedServerSocket v; boolean v, v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: java.net.InetSocketAddress; v := @parameter: boolean; v := @parameter: boolean; label: if v != 0 goto label; if v == 0 goto label; label: v = new org.apache.zookeeper.server.quorum.UnifiedServerSocket; v = v.; v = virtualinvoke v.(); specialinvoke v.(org.apache.zookeeper.common.X509Util,boolean)>(v, v); v = v; goto label; label: v = new java.net.ServerSocket; specialinvoke v.()>(); v = v; label: virtualinvoke v.(1); virtualinvoke v.(v); v = staticinvoke (v); label: return v; label: v := @caughtexception; v = ; v = virtualinvoke v.(); interfaceinvoke v.("Couldn\'t bind to {}", v, v); v = staticinvoke (); return v; catch java.io.IOException from label to label with label; } public long getUptime() { org.apache.zookeeper.server.quorum.Leader v; byte v; long v, v, v, v; v := @this: org.apache.zookeeper.server.quorum.Leader; v = v.; v = v cmp 0L; if v <= 0 goto label; v = staticinvoke (); v = v.; v = v - v; return v; label: return 0L; } void lead() throws java.io.IOException, java.lang.InterruptedException { byte v, v, v, v, v, v; java.lang.Long v, v, v, v, v; java.util.Map v; org.apache.zookeeper.server.admin.AdminServer v; org.apache.zookeeper.server.quorum.StateSummary v, v; java.lang.Object[] v; org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v, v, 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; java.io.IOException v; org.apache.zookeeper.server.quorum.MultipleAddresses v; java.util.concurrent.atomic.AtomicInteger v, v; java.util.Collection v; java.util.concurrent.ConcurrentMap v; java.util.HashSet v; int v, v; org.slf4j.Logger v, v, v, v; org.apache.zookeeper.server.quorum.LeaderZooKeeperServer v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.server.quorum.Leader v; java.lang.Object v, v, 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, 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.QuorumPacket v, v, v; org.apache.zookeeper.server.quorum.LeaderBean v; java.lang.Exception v; org.apache.zookeeper.server.quorum.Leader$Proposal v, v, v, v, v, v, v; org.apache.zookeeper.server.quorum.QuorumPeer$ZabState v, v, v; java.lang.Throwable v, v, v; java.util.ArrayList v, v; org.apache.zookeeper.server.ServerMetrics v; java.lang.String v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.server.quorum.Leader$LearnerCnxAcceptor v, v; org.apache.zookeeper.metrics.Summary v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.List v, v, v, v; org.apache.zookeeper.server.quorum.SyncedLearnerTracker v; java.util.Iterator v, v, v, v; java.lang.InterruptedException v; v := @this: 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 = staticinvoke (); v = v.; interfaceinvoke 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 org.apache.zookeeper.server.quorum.LeaderBean; v = v.; specialinvoke v.(org.apache.zookeeper.server.quorum.Leader,org.apache.zookeeper.server.ZooKeeperServer)>(v, v); v = v.; v = v.; virtualinvoke v.(v, v); label: v = v.; v = ; virtualinvoke v.(v); v = v.; v = v.; virtualinvoke v.(0); v = v.; virtualinvoke v.(); v = new 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 org.apache.zookeeper.server.quorum.Leader$LearnerCnxAcceptor; specialinvoke v.(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 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); interfaceinvoke v.("NEWLEADER proposal has Zxid of {}", 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 = newarray (java.lang.Object)[1]; v = interfaceinvoke v.(); v[0] = v; v = staticinvoke ("set lastSeenQuorumVerifier to currentQuorumVerifier (%s)", v); interfaceinvoke v.(v); 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); v = v.; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(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 = ; virtualinvoke v.(v); 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 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 = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = new java.util.ArrayList; v = v.; v = interfaceinvoke v.(); specialinvoke v.(java.util.Collection)>(v); v = v.; v = interfaceinvoke v.(v, v, v); if v != 0 goto label; 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; org.apache.zookeeper.server.quorum.QuorumPeer v, v, v; java.util.HashSet v, v; java.lang.String v; org.apache.zookeeper.server.quorum.Leader$LearnerCnxAcceptor v, v; boolean v, v; org.apache.zookeeper.server.admin.AdminServer v; org.slf4j.Logger v, v; java.util.Iterator v; org.apache.zookeeper.server.quorum.LeaderZooKeeperServer v, v; org.apache.zookeeper.server.quorum.Leader v; java.lang.Object v; v := @this: 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 = ; interfaceinvoke v.("Shutdown called. For the reason {}", v); v = v.; if v == null goto label; v = v.; virtualinvoke v.(); goto label; label: virtualinvoke v.(); label: v = v.; virtualinvoke v.(null); v = v.; v = v.; interfaceinvoke v.(null); 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.lang.Throwable from label to label with label; } synchronized void closeSockets() { java.util.List v; org.apache.zookeeper.server.quorum.Leader v; java.util.Iterator v; java.lang.Object v; boolean v, v; v := @this: org.apache.zookeeper.server.quorum.Leader; v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(); goto label; label: return; } private long getDesignatedLeader(org.apache.zookeeper.server.quorum.Leader$Proposal, long) { org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v, v; java.lang.Long v, v, v, v, v; java.util.Map v, v; boolean v, v, v, v, v; org.apache.zookeeper.server.quorum.Leader$Proposal v; org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v, 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; org.apache.zookeeper.server.quorum.Leader v; org.apache.zookeeper.server.quorum.MultipleAddresses v, v; java.lang.Object v, v, v, v, v, v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: 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.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; return v; label: v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 1 goto label; return v; label: v = v + 1L; v = v.; v = staticinvoke (v); interfaceinvoke v.(v); goto label; label: return v; } public synchronized boolean tryToCommit(org.apache.zookeeper.server.quorum.Leader$Proposal, long, java.net.SocketAddress) { org.apache.zookeeper.server.quorum.QuorumPeer v, v, v; java.lang.Integer v; byte v, v; java.lang.Long v, v, v, v, v, v; java.util.Map v, v; org.apache.zookeeper.server.quorum.Leader$Proposal v; java.lang.Object[] v; org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v; long v, v, v, v, v, v, v, v, v, v, v, v; java.util.ArrayList v, v; org.apache.zookeeper.server.ServerMetrics v; java.lang.String v, v, v; org.apache.zookeeper.txn.TxnHeader v; java.net.SocketAddress v; org.apache.zookeeper.metrics.Summary v; org.apache.zookeeper.server.quorum.CommitProcessor v; boolean v, v, v, v, v; org.apache.zookeeper.server.Request v, v, v, v, v; java.util.concurrent.ConcurrentLinkedQueue v; java.util.concurrent.ConcurrentMap v, v, v; int v, v, v, v; java.lang.Boolean v; org.slf4j.Logger v, v, v, v, v; java.util.Iterator v; org.apache.zookeeper.server.quorum.LeaderZooKeeperServer v, v; org.apache.zookeeper.server.quorum.Leader v; java.lang.Object v, v, v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: org.apache.zookeeper.server.quorum.Leader$Proposal; v := @parameter: long; v := @parameter: java.net.SocketAddress; v = v.; v = v - 1L; v = staticinvoke (v); v = interfaceinvoke v.(v); if v == 0 goto label; return 0; label: v = virtualinvoke v.(); if v != 0 goto label; return 0; label: v = v.; v = v + 1L; v = v cmp v; if v == 0 goto label; v = ; v = staticinvoke (v); interfaceinvoke v.("Commiting zxid 0x{} from {} not first!", v, v); v = ; v = v.; v = v + 1L; v = staticinvoke (v); interfaceinvoke v.("First is 0x{}", v); label: v = v.; v = staticinvoke (v); interfaceinvoke v.(v); v = v.; if v == null goto label; v = v.; virtualinvoke v.(v); label: v = v.; if v != null goto label; v = ; interfaceinvoke v.("Going to commit null: {}", v); goto label; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 16 goto label; v = ; v = v.; v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("Committing a reconfiguration! {}", v); v = specialinvoke v.(v, v); v = staticinvoke (v); v = v.; v = v.; v = virtualinvoke v.(); v = v - 1; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = v.; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.(v, v, v, 1); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = v cmp v; if v == 0 goto label; v = ; v = newarray (java.lang.Object)[1]; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v[0] = v; v = staticinvoke ("Committing a reconfiguration (reconfigEnabled=%s); this leader is not the designated leader anymore, setting allowedToCommit=false", v); interfaceinvoke v.(v); v. = 0; label: v = virtualinvoke v.(); virtualinvoke v.(v, v); v = virtualinvoke v.(); virtualinvoke v.(v, v); goto label; label: v = v.; v = staticinvoke (); v = v.; virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(v); label: v = v.; v = v.; v = v.; virtualinvoke v.(v); v = v.; v = staticinvoke (v); v = interfaceinvoke v.(v); if v == 0 goto label; v = v.; v = staticinvoke (v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(v); goto label; label: return 1; } public synchronized void processAck(long, long, java.net.SocketAddress) { java.net.SocketAddress v; org.apache.zookeeper.metrics.SummarySet v; org.apache.zookeeper.server.quorum.QuorumPacket v; byte v, v, v; java.lang.Long v, v, v; boolean v, v, v, v, v; java.util.Collection v; org.apache.zookeeper.server.Request v, v, v; long v, v, v, v, v, v, v, v; java.util.concurrent.ConcurrentMap v, v, v, v; org.apache.zookeeper.server.ServerMetrics v; int v, v, v, v; java.lang.String v, v, v, v, v, v; org.slf4j.Logger v, v, v, v, v, v, v; java.util.Iterator v; org.apache.zookeeper.txn.TxnHeader v; org.apache.zookeeper.server.quorum.Leader v; java.lang.Object v, v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: long; v := @parameter: long; v := @parameter: java.net.SocketAddress; v = v.; if v != 0 goto label; return; label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = staticinvoke (v); interfaceinvoke v.("Ack zxid: 0x{}", v); v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); v = ; v = staticinvoke (v); interfaceinvoke v.("outstanding proposal: 0x{}", v); goto label; label: v = ; interfaceinvoke v.("outstanding proposals all"); label: v = v & 4294967295L; v = v cmp 0L; if v != 0 goto label; return; label: v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = ; interfaceinvoke v.("outstanding is 0"); return; label: v = v.; v = v cmp v; if v < 0 goto label; v = ; v = v.; v = staticinvoke (v); v = staticinvoke (v); interfaceinvoke v.("proposal has already been committed, pzxid: 0x{} zxid: 0x{}", v, v); return; label: v = v.; v = staticinvoke (v); v = interfaceinvoke v.(v); if v != null goto label; v = ; v = staticinvoke (v); interfaceinvoke v.("Trying to commit future proposal: zxid 0x{} from {}", v, v); return; label: v = ; if v <= 0 goto label; v = ; v = v % v; v = v cmp 0L; if v != 0 goto label; v = v.; v = staticinvoke (); v = v.; v = staticinvoke (v); virtualinvoke v.(v, v); label: v = staticinvoke (v); virtualinvoke v.(v); v = virtualinvoke v.(v, v, v); if v == 0 goto label; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 16 goto label; v = v; label: v = v.; if v == 0 goto label; if v == 0 goto label; v = v + 1L; v = v.; v = staticinvoke (v); interfaceinvoke v.(v); v = virtualinvoke v.(v, v, null); goto label; label: return; } void sendPacket(org.apache.zookeeper.server.quorum.QuorumPacket) { java.lang.Throwable v; java.util.Iterator v; java.util.HashSet v, v; org.apache.zookeeper.server.quorum.QuorumPacket v; org.apache.zookeeper.server.quorum.Leader v; java.lang.Object v; boolean v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: org.apache.zookeeper.server.quorum.QuorumPacket; v = v.; entermonitor v; label: v = v.; v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(v); goto label; label: 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 sendObserverPacket(org.apache.zookeeper.server.quorum.QuorumPacket) { org.apache.zookeeper.server.quorum.QuorumPacket v; java.util.List v; org.apache.zookeeper.server.quorum.Leader v; java.util.Iterator v; java.lang.Object v; boolean v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: org.apache.zookeeper.server.quorum.QuorumPacket; v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(v); goto label; label: return; } public void commit(long) { java.lang.Throwable v; org.apache.zookeeper.server.quorum.QuorumPacket v; org.apache.zookeeper.server.quorum.Leader v; org.apache.zookeeper.metrics.Counter v; org.apache.zookeeper.server.ServerMetrics v; long v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: long; entermonitor v; label: v. = v; exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = new org.apache.zookeeper.server.quorum.QuorumPacket; specialinvoke v.(int,long,byte[],java.util.List)>(4, v, null, null); virtualinvoke v.(v); v = staticinvoke (); v = v.; interfaceinvoke v.(1L); return; catch java.lang.Throwable from label to label with label; } public void commitAndActivate(long, long) { java.lang.Throwable v; org.apache.zookeeper.server.quorum.QuorumPacket v; byte[] v; org.apache.zookeeper.server.quorum.Leader v; long v, v; java.nio.ByteBuffer v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: long; v := @parameter: long; entermonitor v; label: v. = v; exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = newarray (byte)[8]; v = staticinvoke (v); virtualinvoke v.(v); v = new org.apache.zookeeper.server.quorum.QuorumPacket; specialinvoke v.(int,long,byte[],java.util.List)>(9, v, v, null); virtualinvoke v.(v); return; catch java.lang.Throwable from label to label with label; } public void inform(org.apache.zookeeper.server.quorum.Leader$Proposal) { org.apache.zookeeper.server.Request v; org.apache.zookeeper.server.quorum.QuorumPacket v, v; byte[] v; org.apache.zookeeper.server.quorum.Leader v; org.apache.zookeeper.server.quorum.Leader$Proposal v; long v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: org.apache.zookeeper.server.quorum.Leader$Proposal; v = new org.apache.zookeeper.server.quorum.QuorumPacket; v = v.; v = v.; v = v.; v = virtualinvoke v.(); specialinvoke v.(int,long,byte[],java.util.List)>(8, v, v, null); virtualinvoke v.(v); return; } public static org.apache.zookeeper.server.quorum.QuorumPacket buildInformAndActivePacket(long, long, byte[]) { byte[] v, v; long v, v; java.nio.ByteBuffer v; org.apache.zookeeper.server.quorum.QuorumPacket v; int v, v; v := @parameter: long; v := @parameter: long; v := @parameter: byte[]; v = lengthof v; v = v + 8; v = newarray (byte)[v]; v = staticinvoke (v); virtualinvoke v.(v); virtualinvoke v.(v); v = new org.apache.zookeeper.server.quorum.QuorumPacket; specialinvoke v.(int,long,byte[],java.util.List)>(19, v, v, null); return v; } public void informAndActivate(org.apache.zookeeper.server.quorum.Leader$Proposal, long) { byte[] v; long v, v; org.apache.zookeeper.server.Request v; org.apache.zookeeper.server.quorum.QuorumPacket v, v; org.apache.zookeeper.server.quorum.Leader v; org.apache.zookeeper.server.quorum.Leader$Proposal v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: org.apache.zookeeper.server.quorum.Leader$Proposal; v := @parameter: long; v = v.; v = v.; v = v.; v = virtualinvoke v.(); v = staticinvoke (v, v, v); virtualinvoke v.(v); return; } public synchronized long getLastProposed() { long v; org.apache.zookeeper.server.quorum.Leader v; v := @this: org.apache.zookeeper.server.quorum.Leader; v = v.; return v; } public long getEpoch() { long v, v; org.apache.zookeeper.server.quorum.Leader v; v := @this: org.apache.zookeeper.server.quorum.Leader; v = v.; v = staticinvoke (v); return v; } public org.apache.zookeeper.server.quorum.Leader$Proposal propose(org.apache.zookeeper.server.Request) throws org.apache.zookeeper.server.quorum.Leader$XidRolloverException { org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v, v; byte[] v; org.apache.zookeeper.metrics.Counter v; org.apache.zookeeper.server.quorum.BufferStats v; org.apache.zookeeper.server.quorum.QuorumPacket v, v; byte v, v; org.apache.zookeeper.server.quorum.Leader$XidRolloverException v; java.lang.Long v; boolean v; org.apache.zookeeper.server.Request v; org.apache.zookeeper.server.quorum.Leader$Proposal v; java.lang.Throwable v; org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v, v, v, v, v; long v, v, v, v, v, v, v; java.util.concurrent.ConcurrentMap v; org.apache.zookeeper.server.ServerMetrics v; int v, v, v; org.slf4j.Logger v, v; org.apache.zookeeper.txn.TxnHeader v; org.apache.zookeeper.server.ExitCode v; org.apache.zookeeper.server.quorum.Leader v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: org.apache.zookeeper.server.Request; v = virtualinvoke v.(); if v == 0 goto label; v = ; interfaceinvoke v.("Throttled request send as proposal: {}. Exiting.", v); v = ; v = virtualinvoke v.(); staticinvoke (v); label: v = v.; v = v & 4294967295L; v = v cmp 4294967295L; if v != 0 goto label; virtualinvoke v.("zxid lower 32 bits have rolled over, forcing re-election, and therefore new epoch start"); v = new org.apache.zookeeper.server.quorum.Leader$XidRolloverException; specialinvoke v.(java.lang.String)>("zxid lower 32 bits have rolled over, forcing re-election, and therefore new epoch start"); throw v; label: v = virtualinvoke v.(); v = v.; v = lengthof v; virtualinvoke v.(v); v = new org.apache.zookeeper.server.quorum.QuorumPacket; v = v.; specialinvoke v.(int,long,byte[],java.util.List)>(2, v, v, null); v = new org.apache.zookeeper.server.quorum.Leader$Proposal; specialinvoke v.()>(); v. = v; v. = v; entermonitor v; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 16 goto label; v = v.; v = v.; virtualinvoke v.(v, 1); 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.("Proposing:: {}", v); v = v.; v = virtualinvoke v.(); v. = v; v = v.; v = v.; v = staticinvoke (v); interfaceinvoke v.(v, v); virtualinvoke v.(v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = staticinvoke (); v = v.; interfaceinvoke v.(1L); return v; catch java.lang.Throwable from label to label with label; } public synchronized void processSync(org.apache.zookeeper.server.quorum.LearnerSyncRequest) { org.apache.zookeeper.server.quorum.LearnerSyncRequest v; long v; java.util.function.Function v; java.util.concurrent.ConcurrentMap v; org.apache.zookeeper.server.quorum.Leader v; java.lang.Long v; java.util.Map v; java.lang.Object v; boolean v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: org.apache.zookeeper.server.quorum.LearnerSyncRequest; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; virtualinvoke v.(v); goto label; label: v = v.; v = v.; v = staticinvoke (v); v = staticinvoke (); v = interfaceinvoke v.(v, v); interfaceinvoke v.(v); label: return; } public void sendSync(org.apache.zookeeper.server.quorum.LearnerSyncRequest) { org.apache.zookeeper.server.quorum.LearnerHandler v; org.apache.zookeeper.server.quorum.QuorumPacket v; org.apache.zookeeper.server.quorum.Leader v; org.apache.zookeeper.server.quorum.LearnerSyncRequest v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: org.apache.zookeeper.server.quorum.LearnerSyncRequest; v = new org.apache.zookeeper.server.quorum.QuorumPacket; specialinvoke v.(int,long,byte[],java.util.List)>(7, 0L, null, null); v = v.; virtualinvoke v.(v); return; } public synchronized long startForwarding(org.apache.zookeeper.server.quorum.LearnerHandler, long) { org.apache.zookeeper.server.quorum.QuorumPacket v, v, v, v, v; byte v, v, v; org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType v, v, v, v; boolean v, v; java.util.Set v; org.apache.zookeeper.server.quorum.LearnerHandler v; java.util.concurrent.ConcurrentLinkedQueue v; long v, v, v, v, v, v; java.util.ArrayList v; java.util.concurrent.ConcurrentMap v, v; java.util.Iterator v, v; org.apache.zookeeper.server.quorum.Leader v; java.lang.Object v, v, v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: org.apache.zookeeper.server.quorum.LearnerHandler; v := @parameter: long; v = v.; v = v cmp v; if v <= 0 goto label; v = v.; v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); v = v cmp v; if v <= 0 goto label; v = v.; virtualinvoke v.(v); v = new org.apache.zookeeper.server.quorum.QuorumPacket; v = v.; v = virtualinvoke v.(); specialinvoke v.(int,long,byte[],java.util.List)>(4, v, null, null); virtualinvoke v.(v); goto label; label: v = virtualinvoke v.(); v = ; if v != v goto label; v = new java.util.ArrayList; v = v.; v = interfaceinvoke v.(); specialinvoke v.(java.util.Collection)>(v); staticinvoke (v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = v cmp v; if v <= 0 goto label; v = v.; v = interfaceinvoke v.(v); v = v.; virtualinvoke v.(v); goto label; label: v = virtualinvoke v.(); v = ; if v != v goto label; virtualinvoke v.(v); goto label; label: specialinvoke v.(v); label: v = v.; return v; } public void waitForStartup() throws java.lang.InterruptedException { java.lang.Throwable v; org.apache.zookeeper.server.quorum.LeaderZooKeeperServer v, v, v; org.apache.zookeeper.server.quorum.Leader v; java.lang.Thread v; boolean v, v; v := @this: org.apache.zookeeper.server.quorum.Leader; v = v.; entermonitor v; label: v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = staticinvoke (); v = virtualinvoke v.(); if v != 0 goto label; v = v.; virtualinvoke v.(20L); goto label; label: 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 static void setMaxTimeToWaitForEpoch(int) { org.slf4j.Logger v; int v, v; java.lang.Integer v; v := @parameter: int; = v; v = ; v = ; v = staticinvoke (v); interfaceinvoke v.("Set {} to {}ms", "zookeeper.leader.maxTimeToWaitForEpoch", v); return; } private void quitLeading() { java.lang.Throwable v; org.apache.zookeeper.server.quorum.Leader v; org.slf4j.Logger v; org.apache.zookeeper.metrics.Counter v; org.apache.zookeeper.server.ServerMetrics v; java.util.Set v, v; v := @this: org.apache.zookeeper.server.quorum.Leader; v = v.; entermonitor v; label: v. = 1; v = v.; virtualinvoke v.(); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = staticinvoke (); v = v.; interfaceinvoke v.(1L); v = ; interfaceinvoke v.("Quit leading due to voter changed mind."); return; catch java.lang.Throwable from label to label with label; } public void setLeadingVoteSet(org.apache.zookeeper.server.quorum.SyncedLearnerTracker) { org.apache.zookeeper.server.quorum.SyncedLearnerTracker v; org.apache.zookeeper.server.quorum.Leader v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: org.apache.zookeeper.server.quorum.SyncedLearnerTracker; v. = v; return; } public void reportLookingSid(long) { org.apache.zookeeper.server.quorum.SyncedLearnerTracker v, v; long v, v, v, v, v; org.apache.zookeeper.server.quorum.Leader v; byte v, v; int v, v; boolean v, v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: long; v = ; if v < 0 goto label; v = v.; v = v cmp 0L; if v < 0 goto label; v = v.; if v != 0 goto label; label: return; label: v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(v); if v != 0 goto label; label: return; label: v = staticinvoke (); v = v.; v = v - v; v = ; v = v cmp v; if v <= 0 goto label; specialinvoke v.(); label: return; } public long getEpochToPropose(long, long) throws java.lang.InterruptedException, java.io.IOException { org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v, v, v; byte v, v, v; java.lang.Long v, v; boolean v, v, v, v, v, v, v; java.util.Set v, v, v, v, v, v; java.lang.Throwable v; org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v; long v, v, v, v, v, v, v, v, v, v, v, v, v; int v, v, v; org.apache.zookeeper.server.quorum.Leader v; java.lang.InterruptedException v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: long; v := @parameter: long; v = v.; entermonitor v; label: v = v.; if v != 0 goto label; v = v.; exitmonitor v; label: return v; label: v = v.; v = v cmp v; if v < 0 goto label; v = v + 1L; v. = v; label: v = specialinvoke v.(v); if v == 0 goto label; v = v.; v = staticinvoke (v); interfaceinvoke v.(v); label: v = v.; v = virtualinvoke v.(); v = v.; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); if v == 0 goto label; v = v.; v = interfaceinvoke v.(v); if v == 0 goto label; v. = 0; v = v.; v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(); goto label; label: v = staticinvoke (); v = v.; v = virtualinvoke v.(); v = v cmp v; if v != 0 goto label; v. = v; label: v = v; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = v * v; v = v + v; label: v = v.; if v == 0 goto label; v = v cmp v; if v >= 0 goto label; v = v.; if v != 0 goto label; v = v.; v = v - v; virtualinvoke v.(v); v = staticinvoke (); goto label; label: v = v.; if v == 0 goto label; v = new java.lang.InterruptedException; specialinvoke v.(java.lang.String)>("Timeout while waiting for epoch from quorum"); throw v; label: v = v.; exitmonitor v; label: return v; label: v := @caughtexception; exitmonitor v; throw v; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public org.apache.zookeeper.server.ZKDatabase getZKDatabase() { org.apache.zookeeper.server.quorum.LeaderZooKeeperServer v; org.apache.zookeeper.server.quorum.Leader v; org.apache.zookeeper.server.ZKDatabase v; v := @this: org.apache.zookeeper.server.quorum.Leader; v = v.; v = virtualinvoke v.(); return v; } public void waitForEpochAck(long, org.apache.zookeeper.server.quorum.StateSummary) throws java.io.IOException, java.lang.InterruptedException { org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v; byte v, v, v; java.lang.Long v, v; boolean v, v, v, v, v, v, v; org.apache.zookeeper.server.quorum.StateSummary v, v, v, v; java.util.Set v, v, v, v, v, v; java.lang.Throwable v; org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v; long v, v, v, v, v, v, v, v, v, v; int v, v, v; java.lang.String v; java.io.IOException v; org.apache.zookeeper.server.quorum.Leader v; java.lang.InterruptedException v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: long; v := @parameter: org.apache.zookeeper.server.quorum.StateSummary; v = v.; entermonitor v; label: v = v.; if v == 0 goto label; exitmonitor v; label: return; label: v = virtualinvoke v.(); v = v cmp -1L; if v == 0 goto label; v = v.; v = virtualinvoke v.(v); if v == 0 goto label; v = new java.io.IOException; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Follower is ahead of the leader, leader summary: \u (current epoch), \u (last zxid)"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); v = v cmp -1L; if v == 0 goto label; v = specialinvoke v.(v); if v == 0 goto label; v = v.; v = staticinvoke (v); interfaceinvoke v.(v); label: v = v.; v = virtualinvoke v.(); v = v.; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); if v == 0 goto label; v = v.; v = interfaceinvoke v.(v); if v == 0 goto label; v. = 1; v = v.; virtualinvoke v.(); goto label; label: v = staticinvoke (); v = v; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = v * v; v = v + v; label: v = v.; if v != 0 goto label; v = v cmp v; if v >= 0 goto label; v = v.; v = v - v; virtualinvoke v.(v); v = staticinvoke (); goto label; label: v = v.; if v != 0 goto label; v = new java.lang.InterruptedException; specialinvoke v.(java.lang.String)>("Timeout while waiting for epoch to be acked by quorum"); throw v; label: 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; } private java.lang.String getSidSetString(java.util.Set) { java.util.Iterator v; java.util.Set v; org.apache.zookeeper.server.quorum.Leader v; java.lang.Object v; java.lang.StringBuilder v; java.lang.String v; boolean v, v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: java.util.Set; v = new java.lang.StringBuilder; specialinvoke v.()>(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(v); v = interfaceinvoke v.(); if v == 0 goto label; virtualinvoke v.(","); goto label; label: v = virtualinvoke v.(); return v; } private synchronized void startZkServer() { org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v, v; byte v; java.lang.Long v, v; boolean v; org.apache.zookeeper.server.quorum.Leader$Proposal v, v; org.apache.zookeeper.server.ZKDatabase v; org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v; long v, v, v, v, v, v, v, v, v, v; java.lang.String v, v; org.slf4j.Logger v, v, v; org.apache.zookeeper.server.quorum.LeaderZooKeeperServer v, v, v, v, v, v, v; org.apache.zookeeper.server.quorum.Leader v; v := @this: org.apache.zookeeper.server.quorum.Leader; v = v.; v = virtualinvoke v.(); v. = v; v = ; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("Have quorum of supporters, sids: [{}]; starting up and setting last processed zxid: 0x{}", v, v); v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = v.; v = v.; v = virtualinvoke v.(); v = specialinvoke v.(v, v); v = staticinvoke (v); v = v.; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.(v, v, v, 1); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = v cmp v; if v == 0 goto label; v = ; interfaceinvoke v.("This leader is not the designated leader, it will be initialized with allowedToCommit = false"); v. = 0; goto label; label: v = ; interfaceinvoke v.("Dynamic reconfig feature is disabled, skip designatedLeader calculation and reconfig processing."); label: v = staticinvoke (); v. = v; v = v.; virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); return; } public void waitForNewLeaderAck(long, long) throws java.lang.InterruptedException { org.apache.zookeeper.server.quorum.QuorumPeer v, v; org.apache.zookeeper.server.quorum.QuorumPacket v; byte v, v; java.lang.Long v, v; boolean v, v, v, v; org.apache.zookeeper.server.quorum.Leader$Proposal v, v, v, v, v, v; java.lang.Throwable v; java.lang.Object[] v; long v, v, v, v, v, v, v; java.util.ArrayList v, v, v; int v, v, v; java.lang.String v, v; org.slf4j.Logger v; org.apache.zookeeper.server.quorum.Leader v; java.lang.InterruptedException v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: long; v := @parameter: long; v = v.; v = v.; entermonitor v; label: v = v.; if v == 0 goto label; exitmonitor v; label: return; label: v = v.; v = v.; v = virtualinvoke v.(); v = v cmp v; if v == 0 goto label; v = ; v = newarray (java.lang.Object)[3]; v = staticinvoke (v); v[0] = v; v = staticinvoke (v); v[1] = v; v = staticinvoke (v); v[2] = v; interfaceinvoke v.("NEWLEADER ACK from sid: {} is from a different epoch - current 0x{} received 0x{}", v); exitmonitor v; label: return; label: v = v.; v = staticinvoke (v); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); if v == 0 goto label; v. = 1; v = v.; v = v.; virtualinvoke v.(); goto label; label: v = staticinvoke (); v = v; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = v * v; v = v + v; label: v = v.; if v != 0 goto label; v = v cmp v; if v >= 0 goto label; v = v.; v = v.; v = v - v; virtualinvoke v.(v); v = staticinvoke (); goto label; label: v = v.; if v != 0 goto label; v = new java.lang.InterruptedException; specialinvoke v.(java.lang.String)>("Timeout while waiting for NEWLEADER to be acked by quorum"); throw v; label: 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; } public static java.lang.String getPacketType(int) { int v; v := @parameter: int; tableswitch(v) { case 1: goto label; case 2: goto label; case 3: goto label; case 4: goto label; case 5: goto label; case 6: goto label; case 7: goto label; case 8: goto label; case 9: goto label; case 10: goto label; case 11: goto label; case 12: goto label; case 13: goto label; case 14: goto label; case 15: goto label; case 16: goto label; case 17: goto label; case 18: goto label; case 19: goto label; default: goto label; }; label: return "DIFF"; label: return "TRUNC"; label: return "SNAP"; label: return "OBSERVERINFO"; label: return "NEWLEADER"; label: return "FOLLOWERINFO"; label: return "UPTODATE"; label: return "LEADERINFO"; label: return "ACKEPOCH"; label: return "REQUEST"; label: return "PROPOSAL"; label: return "ACK"; label: return "COMMIT"; label: return "COMMITANDACTIVATE"; label: return "PING"; label: return "REVALIDATE"; label: return "SYNC"; label: return "INFORM"; label: return "INFORMANDACTIVATE"; label: return "UNKNOWN"; } private boolean isRunning() { org.apache.zookeeper.server.quorum.QuorumPeer v; org.apache.zookeeper.server.quorum.LeaderZooKeeperServer v; org.apache.zookeeper.server.quorum.Leader v; boolean v, v, v; v := @this: org.apache.zookeeper.server.quorum.Leader; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = 1; goto label; label: v = 0; label: return v; } private boolean isParticipant(long) { org.apache.zookeeper.server.quorum.QuorumPeer v; org.apache.zookeeper.server.quorum.Leader v; java.lang.Long v; java.util.Map v; org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v; long v; boolean v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: long; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); return v; } public int getCurrentTick() { org.apache.zookeeper.server.quorum.QuorumPeer v; org.apache.zookeeper.server.quorum.Leader v; java.util.concurrent.atomic.AtomicInteger v; int v; v := @this: org.apache.zookeeper.server.quorum.Leader; v = v.; v = v.; v = virtualinvoke v.(); return v; } public int syncTimeout() { org.apache.zookeeper.server.quorum.QuorumPeer v, v; org.apache.zookeeper.server.quorum.Leader v; int v, v, v; v := @this: org.apache.zookeeper.server.quorum.Leader; v = v.; v = v.; v = v.; v = v.; v = v * v; return v; } public int getTickOfNextAckDeadline() { org.apache.zookeeper.server.quorum.QuorumPeer v, v; org.apache.zookeeper.server.quorum.Leader v; java.util.concurrent.atomic.AtomicInteger v; int v, v, v; v := @this: org.apache.zookeeper.server.quorum.Leader; v = v.; v = v.; v = virtualinvoke v.(); v = v.; v = v.; v = v + v; return v; } public int getTickOfInitialAckDeadline() { org.apache.zookeeper.server.quorum.QuorumPeer v, v, v; org.apache.zookeeper.server.quorum.Leader v; java.util.concurrent.atomic.AtomicInteger v; int v, v, v, v, v; v := @this: org.apache.zookeeper.server.quorum.Leader; v = v.; v = v.; v = virtualinvoke v.(); v = v.; v = v.; v = v + v; v = v.; v = v.; v = v + v; return v; } public long getAndDecrementFollowerCounter() { java.util.concurrent.atomic.AtomicLong v; long v; org.apache.zookeeper.server.quorum.Leader v; v := @this: org.apache.zookeeper.server.quorum.Leader; v = v.; v = virtualinvoke v.(); return v; } public void touch(long, int) { org.apache.zookeeper.server.quorum.LeaderZooKeeperServer v; org.apache.zookeeper.server.quorum.Leader v; int v; long v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: long; v := @parameter: int; v = v.; virtualinvoke v.(v, v); return; } public void submitLearnerRequest(org.apache.zookeeper.server.Request) { org.apache.zookeeper.server.Request v; org.apache.zookeeper.server.quorum.LeaderZooKeeperServer v; org.apache.zookeeper.server.quorum.Leader v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: org.apache.zookeeper.server.Request; v = v.; virtualinvoke v.(v); return; } public long getQuorumVerifierVersion() { org.apache.zookeeper.server.quorum.QuorumPeer v; org.apache.zookeeper.server.quorum.Leader v; org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v; long v; v := @this: org.apache.zookeeper.server.quorum.Leader; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); return v; } public java.lang.String getPeerInfo(long) { org.apache.zookeeper.server.quorum.QuorumPeer v; org.apache.zookeeper.server.quorum.Leader v; java.lang.Long v; java.util.Map v; java.lang.Object v; long v; java.lang.String v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: long; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); if v != null goto label; v = ""; goto label; label: v = virtualinvoke v.(); label: return v; } public byte[] getQuorumVerifierBytes() { org.apache.zookeeper.server.quorum.QuorumPeer v; byte[] v; org.apache.zookeeper.server.quorum.Leader v; java.nio.charset.Charset v; org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v; java.lang.String v; v := @this: org.apache.zookeeper.server.quorum.Leader; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = ; v = virtualinvoke v.(v); return v; } public org.apache.zookeeper.server.quorum.auth.QuorumAuthServer getQuorumAuthServer() { org.apache.zookeeper.server.quorum.QuorumPeer v, v; org.apache.zookeeper.server.quorum.Leader v; org.apache.zookeeper.server.quorum.auth.QuorumAuthServer v; v := @this: org.apache.zookeeper.server.quorum.Leader; v = v.; if v != null goto label; v = null; goto label; label: v = v.; v = v.; label: return v; } public void revalidateSession(org.apache.zookeeper.server.quorum.QuorumPacket, org.apache.zookeeper.server.quorum.LearnerHandler) throws java.io.IOException { byte[] v, v; java.io.DataInputStream v; java.io.ByteArrayOutputStream v; long v; org.apache.zookeeper.server.quorum.QuorumPacket v; java.io.ByteArrayInputStream v; java.io.DataOutputStream v; int v; java.lang.String v, v, v; boolean v, v; org.slf4j.Logger v, v, v; org.apache.zookeeper.KeeperException$SessionExpiredException v; org.apache.zookeeper.server.quorum.LearnerHandler v; org.apache.zookeeper.server.quorum.LeaderZooKeeperServer v, v; org.apache.zookeeper.server.quorum.Leader v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: org.apache.zookeeper.server.quorum.QuorumPacket; v := @parameter: org.apache.zookeeper.server.quorum.LearnerHandler; v = new java.io.ByteArrayInputStream; v = virtualinvoke v.(); specialinvoke v.(byte[])>(v); v = new java.io.DataInputStream; specialinvoke v.(java.io.InputStream)>(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = new java.io.ByteArrayOutputStream; specialinvoke v.()>(); v = new java.io.DataOutputStream; specialinvoke v.(java.io.OutputStream)>(v); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(v, v); if v == 0 goto label; label: v = v.; virtualinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = ; v = staticinvoke (v); interfaceinvoke v.("Somehow session 0x{} expired right after being renewed! (impossible)", v, v); label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Session 0x\u is valid: \u0001"); staticinvoke (v, 32L, v); label: virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(v); return; catch org.apache.zookeeper.KeeperException$SessionExpiredException from label to label with label; } public void registerLearnerHandlerBean(org.apache.zookeeper.server.quorum.LearnerHandler, java.net.Socket) { org.apache.zookeeper.server.quorum.LearnerHandler v; org.apache.zookeeper.server.quorum.LeaderZooKeeperServer v; java.net.Socket v; org.apache.zookeeper.server.quorum.Leader v; org.apache.zookeeper.server.quorum.LearnerHandlerBean v; java.util.concurrent.ConcurrentHashMap v; boolean v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: org.apache.zookeeper.server.quorum.LearnerHandler; v := @parameter: java.net.Socket; v = new org.apache.zookeeper.server.quorum.LearnerHandlerBean; specialinvoke v.(org.apache.zookeeper.server.quorum.LearnerHandler,java.net.Socket)>(v, v); v = v.; v = virtualinvoke v.(v); if v == 0 goto label; v = v.; virtualinvoke v.(v, v); label: return; } public void unregisterLearnerHandlerBean(org.apache.zookeeper.server.quorum.LearnerHandler) { org.apache.zookeeper.server.quorum.LearnerHandler v; org.apache.zookeeper.server.quorum.Leader v; org.apache.zookeeper.jmx.MBeanRegistry v; java.util.concurrent.ConcurrentHashMap v; java.lang.Object v; v := @this: org.apache.zookeeper.server.quorum.Leader; v := @parameter: org.apache.zookeeper.server.quorum.LearnerHandler; v = v.; v = virtualinvoke v.(v); if v == null goto label; v = staticinvoke (); virtualinvoke v.(v); label: return; } static void () { java.lang.Integer v, v, v, v; int v, v, v, v, v; java.lang.Boolean v; java.lang.String v; boolean v, v; org.slf4j.Logger v, v, v, v; v = staticinvoke (class "Lorg/apache/zookeeper/server/quorum/Leader;"); = v; v = staticinvoke ("leader.nodelay", "true"); v = virtualinvoke v.("true"); = v; v = ; v = ; v = staticinvoke (v); interfaceinvoke v.("TCP NoDelay set to: {}", v); v = staticinvoke ("zookeeper.leader.ackLoggingFrequency", 1000); v = virtualinvoke v.(); = v; v = ; v = ; v = staticinvoke (v); interfaceinvoke v.("{} = {}", "zookeeper.leader.ackLoggingFrequency", v); v = (int) -1; v = staticinvoke ("zookeeper.leader.maxTimeToWaitForEpoch", v); v = virtualinvoke v.(); = v; v = ; v = ; v = staticinvoke (v); interfaceinvoke v.("{} = {}ms", "zookeeper.leader.maxTimeToWaitForEpoch", v); return; } }