public class org.apache.zookeeper.server.quorum.Learner extends java.lang.Object { org.apache.zookeeper.server.quorum.QuorumPeer self; org.apache.zookeeper.server.quorum.LearnerZooKeeperServer zk; protected java.io.BufferedOutputStream bufferedOutput; protected java.net.Socket sock; protected org.apache.zookeeper.server.quorum.MultipleAddresses leaderAddr; protected java.util.concurrent.atomic.AtomicBoolean sockBeingClosed; org.apache.zookeeper.server.quorum.LearnerSender sender; protected org.apache.jute.InputArchive leaderIs; protected org.apache.jute.OutputArchive leaderOs; protected int leaderProtocolVersion; private static final int BUFFERED_MESSAGE_SIZE; protected final org.apache.zookeeper.server.util.MessageTracker messageTracker; protected static final org.slf4j.Logger LOG; private static final int leaderConnectDelayDuringRetryMs; private static final boolean nodelay; public static final java.lang.String LEARNER_ASYNC_SENDING; private static boolean asyncSending; public static final java.lang.String LEARNER_CLOSE_SOCKET_ASYNC; public static final boolean closeSocketAsync; final java.util.concurrent.ConcurrentHashMap pendingRevalidations; public void () { java.util.concurrent.ConcurrentHashMap v; java.util.concurrent.atomic.AtomicBoolean v; org.apache.zookeeper.server.util.MessageTracker v; org.apache.zookeeper.server.quorum.Learner v; v := @this: org.apache.zookeeper.server.quorum.Learner; specialinvoke v.()>(); v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.(boolean)>(0); v. = v; v. = null; v. = 1; v = new org.apache.zookeeper.server.util.MessageTracker; specialinvoke v.(int)>(10); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; return; } public java.net.Socket getSocket() { java.net.Socket v; org.apache.zookeeper.server.quorum.Learner v; v := @this: org.apache.zookeeper.server.quorum.Learner; v = v.; return v; } public int getPendingRevalidationsCount() { int v; java.util.concurrent.ConcurrentHashMap v; org.apache.zookeeper.server.quorum.Learner v; v := @this: org.apache.zookeeper.server.quorum.Learner; v = v.; v = virtualinvoke v.(); return v; } protected static void setAsyncSending(boolean) { org.slf4j.Logger v; java.lang.Boolean v; boolean v, v; v := @parameter: boolean; = v; v = ; v = ; v = staticinvoke (v); interfaceinvoke v.("{} = {}", "zookeeper.learner.asyncSending", v); return; } protected static boolean getAsyncSending() { boolean v; v = ; return v; } void validateSession(org.apache.zookeeper.server.ServerCnxn, long, int) throws java.io.IOException { byte[] v; java.io.ByteArrayOutputStream v; long v; org.apache.zookeeper.server.quorum.QuorumPacket v; java.io.DataOutputStream v; java.lang.Long v; int v; org.apache.zookeeper.server.ServerCnxn v; java.lang.String v, v, v; boolean v; org.slf4j.Logger v, v, v; java.util.concurrent.ConcurrentHashMap v; org.apache.zookeeper.server.quorum.Learner v; v := @this: org.apache.zookeeper.server.quorum.Learner; v := @parameter: org.apache.zookeeper.server.ServerCnxn; v := @parameter: long; v := @parameter: int; v = ; v = staticinvoke (v); interfaceinvoke v.("Revalidating client: 0x{}", v); v = new java.io.ByteArrayOutputStream; specialinvoke v.()>(); v = new java.io.DataOutputStream; specialinvoke v.(java.io.OutputStream)>(v); virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(); v = new org.apache.zookeeper.server.quorum.QuorumPacket; v = virtualinvoke v.(); specialinvoke v.(int,long,byte[],java.util.List)>(6, -1L, v, null); v = v.; v = staticinvoke (v); virtualinvoke v.(v, v); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v) ("To validate session 0x\u0001"); staticinvoke (v, 32L, v); label: virtualinvoke v.(v, 1); return; } void writePacket(org.apache.zookeeper.server.quorum.QuorumPacket, boolean) throws java.io.IOException { org.apache.zookeeper.server.quorum.QuorumPacket v; org.apache.zookeeper.server.quorum.LearnerSender v; org.apache.zookeeper.server.quorum.Learner v; boolean v, v; v := @this: org.apache.zookeeper.server.quorum.Learner; v := @parameter: org.apache.zookeeper.server.quorum.QuorumPacket; v := @parameter: boolean; v = ; if v == 0 goto label; v = v.; virtualinvoke v.(v); goto label; label: virtualinvoke v.(v, v); label: return; } void writePacketNow(org.apache.zookeeper.server.quorum.QuorumPacket, boolean) throws java.io.IOException { java.lang.Throwable v; org.apache.zookeeper.server.util.MessageTracker v; java.io.BufferedOutputStream v; org.apache.zookeeper.server.quorum.QuorumPacket v; int v; org.apache.jute.OutputArchive v, v; org.apache.zookeeper.server.quorum.Learner v; boolean v; v := @this: org.apache.zookeeper.server.quorum.Learner; v := @parameter: org.apache.zookeeper.server.quorum.QuorumPacket; v := @parameter: boolean; v = v.; entermonitor v; label: if v == null goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(v, "packet"); label: if v == 0 goto label; v = v.; virtualinvoke 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; } protected void startSendingThread() { org.apache.zookeeper.server.quorum.LearnerSender v, v; org.apache.zookeeper.server.quorum.Learner v; v := @this: org.apache.zookeeper.server.quorum.Learner; v = new org.apache.zookeeper.server.quorum.LearnerSender; specialinvoke v.(org.apache.zookeeper.server.quorum.Learner)>(v); v. = v; v = v.; virtualinvoke v.(); return; } void readPacket(org.apache.zookeeper.server.quorum.QuorumPacket) throws java.io.IOException { java.lang.Throwable v; org.slf4j.Logger v, v; org.apache.jute.InputArchive v, v; long v; org.apache.zookeeper.server.util.MessageTracker v; org.apache.zookeeper.server.quorum.QuorumPacket v; int v, v; org.apache.zookeeper.server.quorum.Learner v; boolean v; v := @this: org.apache.zookeeper.server.quorum.Learner; v := @parameter: org.apache.zookeeper.server.quorum.QuorumPacket; v = v.; entermonitor v; label: v = v.; interfaceinvoke v.(v, "packet"); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v != 5 goto label; v = 128L; goto label; label: v = 16L; label: v = ; staticinvoke (v, v, 105, v); label: return; catch java.lang.Throwable from label to label with label; } void request(org.apache.zookeeper.server.Request) throws java.io.IOException { byte[] v, v; org.slf4j.Logger v; java.io.ByteArrayOutputStream v; long v; org.apache.zookeeper.server.ExitCode v; org.apache.zookeeper.server.Request v; org.apache.zookeeper.server.quorum.QuorumPacket v; java.util.List v; java.io.DataOutputStream v; int v, v, v; org.apache.zookeeper.server.quorum.Learner v; boolean v; v := @this: org.apache.zookeeper.server.quorum.Learner; v := @parameter: org.apache.zookeeper.server.Request; v = virtualinvoke v.(); if v == 0 goto label; v = ; interfaceinvoke v.("Throttled request sent to leader: {}. Exiting", v); v = ; v = virtualinvoke v.(); staticinvoke (v); label: v = new java.io.ByteArrayOutputStream; specialinvoke v.()>(); v = new java.io.DataOutputStream; specialinvoke v.(java.io.OutputStream)>(v); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = virtualinvoke v.(); if v == null goto label; virtualinvoke v.(v); label: virtualinvoke v.(); v = new org.apache.zookeeper.server.quorum.QuorumPacket; v = virtualinvoke v.(); v = v.; specialinvoke v.(int,long,byte[],java.util.List)>(1, -1L, v, v); virtualinvoke v.(v, 1); return; } protected org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer findLeader() { org.apache.zookeeper.server.quorum.QuorumPeer v, v; org.apache.zookeeper.server.quorum.Vote v; long v, v, v; byte v; java.lang.Long v; java.util.Map v; boolean v; org.slf4j.Logger v; java.util.Iterator v; java.util.Collection v; org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer v; java.lang.Object v; org.apache.zookeeper.server.quorum.Learner v; v := @this: org.apache.zookeeper.server.quorum.Learner; v = null; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke 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 cmp v; if v != 0 goto label; virtualinvoke v.(); v = v; label: if v != null goto label; v = ; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("Couldn\'t find the leader with id = {}", v); label: return v; } protected long nanoTime() { long v; org.apache.zookeeper.server.quorum.Learner v; v := @this: org.apache.zookeeper.server.quorum.Learner; v = staticinvoke (); return v; } protected void sockConnect(java.net.Socket, java.net.InetSocketAddress, int) throws java.io.IOException { java.net.Socket v; int v; java.net.InetSocketAddress v; org.apache.zookeeper.server.quorum.Learner v; v := @this: org.apache.zookeeper.server.quorum.Learner; v := @parameter: java.net.Socket; v := @parameter: java.net.InetSocketAddress; v := @parameter: int; virtualinvoke v.(v, v); return; } protected void connectToLeader(org.apache.zookeeper.server.quorum.MultipleAddresses, java.lang.String) throws java.io.IOException { org.apache.zookeeper.server.quorum.QuorumPeer v, v; org.apache.jute.BinaryOutputArchive v; java.io.BufferedInputStream v; boolean v, v, v, v, v; java.util.Set v; java.util.concurrent.CountDownLatch v; java.util.stream.Stream v, v; java.lang.Throwable v; java.net.Socket v, v, v; java.util.concurrent.atomic.AtomicBoolean v; java.util.concurrent.atomic.AtomicReference v; java.util.function.Function v; java.io.BufferedOutputStream v, v; int v, v; java.lang.String v, v; java.util.concurrent.ExecutorService v; java.io.OutputStream v; org.slf4j.Logger v, v, v, v, v, v, v; java.io.IOException v; org.apache.jute.BinaryInputArchive v; java.util.concurrent.TimeUnit v, v, v; java.util.function.Consumer v; org.apache.zookeeper.server.quorum.MultipleAddresses v; java.lang.InterruptedException v, v, v, v; org.apache.zookeeper.server.quorum.auth.QuorumAuthLearner v; java.lang.Object v, v; org.apache.zookeeper.server.quorum.Learner v; java.io.InputStream v; v := @this: org.apache.zookeeper.server.quorum.Learner; v := @parameter: org.apache.zookeeper.server.quorum.MultipleAddresses; v := @parameter: java.lang.String; v. = v; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); goto label; label: v = virtualinvoke v.(); label: v = interfaceinvoke v.(); v = staticinvoke (v); v = new java.util.concurrent.CountDownLatch; v = interfaceinvoke v.(); specialinvoke v.(int)>(v); v = new java.util.concurrent.atomic.AtomicReference; specialinvoke v.(java.lang.Object)>(null); v = interfaceinvoke v.(); v = staticinvoke (v, v, v); v = interfaceinvoke v.(v); virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v); label: virtualinvoke v.(); label: interfaceinvoke v.(); label: v = ; v = interfaceinvoke v.(1L, v); if v != 0 goto label; v = ; interfaceinvoke v.("not all the LeaderConnector terminated properly"); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Interrupted while terminating LeaderConnector executor.", v); goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Interrupted while trying to connect to Leader", v); label: interfaceinvoke v.(); label: v = ; v = interfaceinvoke v.(1L, v); if v != 0 goto label; v = ; interfaceinvoke v.("not all the LeaderConnector terminated properly"); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Interrupted while terminating LeaderConnector executor.", v); goto label; label: v := @caughtexception; interfaceinvoke v.(); label: v = ; v = interfaceinvoke v.(1L, v); if v != 0 goto label; v = ; interfaceinvoke v.("not all the LeaderConnector terminated properly"); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Interrupted while terminating LeaderConnector executor.", v); label: throw v; label: v = virtualinvoke v.(); if v != null goto label; v = new java.io.IOException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed connect to \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); v. = v; v = v.; virtualinvoke v.(0); v = v.; v = v.; v = v.; interfaceinvoke v.(v, v); v = new java.io.BufferedInputStream; v = v.; v = virtualinvoke v.(); specialinvoke v.(java.io.InputStream)>(v); v = staticinvoke (v); v. = v; v = new java.io.BufferedOutputStream; v = v.; v = virtualinvoke v.(); specialinvoke v.(java.io.OutputStream)>(v); v. = v; v = v.; v = staticinvoke (v); v. = v; v = ; if v == 0 goto label; virtualinvoke v.(); label: return; catch java.lang.InterruptedException from label to label with label; catch java.lang.InterruptedException 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.InterruptedException from label to label with label; } protected java.net.Socket createSocket() throws org.apache.zookeeper.common.X509Exception, java.io.IOException { org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v; java.net.Socket v, v; int v, v, v; org.apache.zookeeper.common.QuorumX509Util v; org.apache.zookeeper.server.quorum.Learner v; boolean v; v := @this: org.apache.zookeeper.server.quorum.Learner; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); goto label; label: v = new java.net.Socket; specialinvoke v.()>(); v = v; label: v = v.; v = v.; v = v.; v = v.; v = v * v; virtualinvoke v.(v); return v; } protected long registerWithLeader(int) throws java.io.IOException { org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v, v, v, v, v, v, v, v; byte[] v, v, v; org.apache.jute.BinaryOutputArchive v; java.nio.ByteBuffer v, v; org.apache.zookeeper.server.quorum.QuorumPacket v, v; byte v, v, v; java.io.ByteArrayOutputStream v; org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v; long v, v, v, v, v, v, v, v, v, v, v, v, v, v; int v, v, v, v, v; java.lang.String v; org.slf4j.Logger v; org.apache.zookeeper.server.quorum.LearnerInfo v; java.io.IOException v, v; org.apache.zookeeper.server.quorum.Learner v; v := @this: org.apache.zookeeper.server.quorum.Learner; v := @parameter: int; v = v.; v = virtualinvoke v.(); v = new org.apache.zookeeper.server.quorum.QuorumPacket; specialinvoke v.()>(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = staticinvoke (v, 0L); virtualinvoke v.(v); v = new org.apache.zookeeper.server.quorum.LearnerInfo; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); specialinvoke v.(long,int,long)>(v, 65536, v); v = new java.io.ByteArrayOutputStream; specialinvoke v.()>(); v = staticinvoke (v); virtualinvoke v.(v, "LearnerInfo"); v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(v, 1); virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(); if v != 17 goto label; v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(); v. = v; v = newarray (byte)[4]; v = staticinvoke (v); v = v.; v = virtualinvoke v.(); v = v cmp v; if v <= 0 goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(v); goto label; label: v = v.; v = virtualinvoke v.(); v = v cmp v; if v != 0 goto label; v = (int) -1; virtualinvoke v.(v); goto label; label: v = new java.io.IOException; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Leaders epoch, \u is less than accepted epoch, \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = new org.apache.zookeeper.server.quorum.QuorumPacket; specialinvoke v.(int,long,byte[],java.util.List)>(18, v, v, null); virtualinvoke v.(v, 1); v = staticinvoke (v, 0L); return v; label: v = v.; v = virtualinvoke v.(); v = v cmp v; if v <= 0 goto label; v = v.; virtualinvoke v.(v); label: v = virtualinvoke v.(); if v == 10 goto label; v = ; interfaceinvoke v.("First packet should have been NEWLEADER"); v = new java.io.IOException; specialinvoke v.(java.lang.String)>("First packet should have been NEWLEADER"); throw v; label: v = virtualinvoke v.(); return v; } protected void syncWithLeader(long) throws java.lang.Exception { org.apache.zookeeper.server.admin.AdminServer v; org.apache.jute.Record v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.server.quorum.Learner v; org.apache.zookeeper.server.quorum.LearnerZooKeeperServer v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.nio.charset.Charset v, v, v, v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.server.quorum.QuorumPeer$SyncMode v, v, v, v; java.lang.Exception v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.txn.TxnHeader 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.ArrayDeque v, v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.server.Request v; org.apache.zookeeper.txn.TxnDigest v, v, v, v, v, v; byte[] v, v, v, v, v, v, v, v, v, v, v; byte v, v, v, v, v; java.lang.Long v, v, v, v, v, v; org.apache.zookeeper.server.quorum.flexible.QuorumVerifier 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; java.io.IOException v; org.apache.zookeeper.server.TxnLogEntry v, v, v; org.slf4j.Logger v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.server.ExitCode v, v; java.lang.Object v, v, 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; org.apache.jute.InputArchive v, v; org.apache.zookeeper.server.quorum.QuorumPacket v, v, v; org.apache.zookeeper.server.quorum.Learner$PacketInFlight v, v; java.lang.Throwable v; org.apache.zookeeper.server.ZKDatabase v, v, v, v, v, v; java.lang.UnsupportedOperationException v; java.nio.ByteBuffer v, v; java.net.Socket v; java.util.Iterator v, v, v, v; v := @this: org.apache.zookeeper.server.quorum.Learner; v := @parameter: long; v = new org.apache.zookeeper.server.quorum.QuorumPacket; specialinvoke v.(int,long,byte[],java.util.List)>(3, 0L, null, null); v = new org.apache.zookeeper.server.quorum.QuorumPacket; specialinvoke v.()>(); v = staticinvoke (v); v = null; v = 1; v = 0; virtualinvoke v.(v); v = new java.util.ArrayDeque; specialinvoke v.()>(); v = new java.util.ArrayDeque; specialinvoke v.()>(); v = v.; entermonitor v; label: v = virtualinvoke v.(); if v != 13 goto label; v = ; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("Getting a diff from the leader 0x{}", v); v = v.; v = ; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = ; interfaceinvoke v.("Forcing a snapshot write as part of upgrading from an older Zookeeper. This should only happen while upgrading."); v = 1; v = 1; goto label; label: v = 0; goto label; label: v = virtualinvoke v.(); if v != 15 goto label; v = v.; v = ; virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("Getting a snapshot from leader 0x{}", v); v = v.; v = virtualinvoke v.(); v = v.; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = ; interfaceinvoke v.("Reset config node content from local config after deserialization of snapshot."); v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = v.; v = interfaceinvoke v.("signature"); v = virtualinvoke v.("BenWasHere"); if v != 0 goto label; v = ; interfaceinvoke v.("Missing signature. Got {}", v); v = new java.io.IOException; specialinvoke v.(java.lang.String)>("Missing signature"); throw v; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); v = 1; goto label; label: v = virtualinvoke v.(); if v != 14 goto label; v = v.; v = ; virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("Truncating log to get in sync with the leader 0x{}", v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v != 0 goto label; v = ; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("Not able to truncate the log 0x{}", v); v = ; v = virtualinvoke v.(); staticinvoke (v); label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: v = ; v = staticinvoke (v); interfaceinvoke v.("Got unexpected packet from leader: {}, exiting ... ", v); v = ; v = virtualinvoke v.(); staticinvoke (v); label: v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(); v = 0L; v = 1; if v != 0 goto label; v = 1; goto label; label: v = 0; label: v = v; label: v = v.; v = virtualinvoke v.(); if v == 0 goto label; virtualinvoke v.(v); v = virtualinvoke v.(); tableswitch(v) { 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: v = new org.apache.zookeeper.server.quorum.Learner$PacketInFlight; specialinvoke v.()>(); v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(); v. = v; v = virtualinvoke v.(); v. = v; v = virtualinvoke v.(); v. = v; v = v.; v = virtualinvoke v.(); v = v + 1L; v = v cmp v; if v == 0 goto label; v = ; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = v + 1L; v = staticinvoke (v); interfaceinvoke v.("Got zxid 0x{} expected 0x{}", v, v); label: v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); if v != 16 goto label; v = v.; v = v.; v = new java.lang.String; v = virtualinvoke v.(); v = ; specialinvoke v.(byte[],java.nio.charset.Charset)>(v, v); v = virtualinvoke v.(v); v = v.; virtualinvoke v.(v, 1); label: interfaceinvoke v.(v); goto label; label: v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v cmp v; if v != 0 goto label; v = virtualinvoke v.(); if v != 9 goto label; v = v.; v = new java.lang.String; v = v.; v = virtualinvoke v.(); v = ; specialinvoke v.(byte[],java.nio.charset.Charset)>(v, v); v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(v, v, v, 1); if v == 0 goto label; v = new java.lang.Exception; specialinvoke v.(java.lang.String)>("changes proposed in reconfig"); throw v; label: if v != 0 goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v cmp v; if v == 0 goto label; v = ; v = virtualinvoke v.(); v = staticinvoke (v); v = v.; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("Committing 0x{}, but next proposal is 0x{}", v, v); goto label; label: v = v.; v = v.; v = v.; virtualinvoke v.(v, v); interfaceinvoke v.(); goto label; label: v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v); goto label; label: v = new org.apache.zookeeper.server.quorum.Learner$PacketInFlight; specialinvoke v.()>(); v = virtualinvoke v.(); if v != 19 goto label; v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.