public class oadd.org.apache.zookeeper.server.quorum.LearnerHandler extends oadd.org.apache.zookeeper.server.ZooKeeperThread { private static final org.slf4j.Logger LOG; protected final java.net.Socket sock; final oadd.org.apache.zookeeper.server.quorum.Leader leader; volatile long tickOfNextAckDeadline; protected long sid; protected int version; final java.util.concurrent.LinkedBlockingQueue queuedPackets; private oadd.org.apache.zookeeper.server.quorum.LearnerHandler$SyncLimitCheck syncLimitCheck; private oadd.org.apache.jute.BinaryInputArchive ia; private oadd.org.apache.jute.BinaryOutputArchive oa; private final java.io.BufferedInputStream bufferedInput; private java.io.BufferedOutputStream bufferedOutput; private volatile boolean sendingThreadStarted; public static final java.lang.String FORCE_SNAP_SYNC; private boolean forceSnapSync; private boolean needOpPacket; private long leaderLastZxid; final oadd.org.apache.zookeeper.server.quorum.QuorumPacket proposalOfDeath; private oadd.org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType learnerType; public java.net.Socket getSocket() { java.net.Socket v; oadd.org.apache.zookeeper.server.quorum.LearnerHandler v; v := @this: oadd.org.apache.zookeeper.server.quorum.LearnerHandler; v = v.; return v; } long getSid() { long v; oadd.org.apache.zookeeper.server.quorum.LearnerHandler v; v := @this: oadd.org.apache.zookeeper.server.quorum.LearnerHandler; v = v.; return v; } int getVersion() { int v; oadd.org.apache.zookeeper.server.quorum.LearnerHandler v; v := @this: oadd.org.apache.zookeeper.server.quorum.LearnerHandler; v = v.; return v; } void (java.net.Socket, java.io.BufferedInputStream, oadd.org.apache.zookeeper.server.quorum.Leader) throws java.io.IOException { java.io.DataInputStream v; java.net.Socket v; java.io.BufferedInputStream v; java.net.SocketAddress v, v; oadd.org.apache.zookeeper.server.quorum.QuorumPacket v; oadd.org.apache.zookeeper.server.quorum.LearnerHandler v; javax.security.sasl.SaslException v; oadd.org.apache.zookeeper.server.quorum.LearnerHandler$SyncLimitCheck v; java.lang.String v, v, v; boolean v; org.slf4j.Logger v, v; oadd.org.apache.zookeeper.server.quorum.Leader v; oadd.org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType v; oadd.org.apache.zookeeper.server.quorum.QuorumPeer v, v; java.io.IOException v; java.util.concurrent.LinkedBlockingQueue v; oadd.org.apache.zookeeper.server.quorum.auth.QuorumAuthServer v; v := @this: oadd.org.apache.zookeeper.server.quorum.LearnerHandler; v := @parameter: java.net.Socket; v := @parameter: java.io.BufferedInputStream; v := @parameter: oadd.org.apache.zookeeper.server.quorum.Leader; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("LearnerHandler-\u0001"); specialinvoke v.(java.lang.String)>(v); v. = 0L; v. = 1; v = new java.util.concurrent.LinkedBlockingQueue; specialinvoke v.()>(); v. = v; v = new oadd.org.apache.zookeeper.server.quorum.LearnerHandler$SyncLimitCheck; specialinvoke v.(oadd.org.apache.zookeeper.server.quorum.LearnerHandler)>(v); v. = v; v. = 0; v. = 0; v. = 1; v = new oadd.org.apache.zookeeper.server.quorum.QuorumPacket; specialinvoke v.()>(); v. = v; v = ; v. = v; v. = v; v. = v; v. = v; v = staticinvoke ("zookeeper.forceSnapshotSync"); if v == 0 goto label; v. = 1; v = ; interfaceinvoke v.("Forcing snapshot sync is enabled"); label: v = v.; if v == null goto label; v = v.; v = v.; v = new java.io.DataInputStream; specialinvoke v.(java.io.InputStream)>(v); interfaceinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = ; v = virtualinvoke v.(); interfaceinvoke v.("Server failed to authenticate quorum learner, addr: {}, closing connection", v, v); v = new javax.security.sasl.SaslException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Authentication failure: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: return; catch java.io.IOException from label to label with label; } public java.lang.String toString() { java.net.Socket v; oadd.org.apache.zookeeper.server.quorum.LearnerHandler v; long v; java.util.concurrent.LinkedBlockingQueue v; int v; java.lang.StringBuilder v, v, v, v, v; java.lang.String v; boolean v; v := @this: oadd.org.apache.zookeeper.server.quorum.LearnerHandler; v = new java.lang.StringBuilder; specialinvoke v.()>(); v = virtualinvoke v.("LearnerHandler "); v = v.; virtualinvoke v.(v); v = virtualinvoke v.(" tickOfNextAckDeadline:"); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(" synced?:"); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(" queuedPacketLength:"); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public oadd.org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType getLearnerType() { oadd.org.apache.zookeeper.server.quorum.LearnerHandler v; oadd.org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType v; v := @this: oadd.org.apache.zookeeper.server.quorum.LearnerHandler; v = v.; return v; } private void sendPackets() throws java.lang.InterruptedException { java.net.Socket v, v; oadd.org.apache.zookeeper.server.quorum.QuorumPacket v; oadd.org.apache.zookeeper.server.quorum.LearnerHandler v; long v, v, v; java.io.BufferedOutputStream v; oadd.org.apache.zookeeper.server.quorum.LearnerHandler$SyncLimitCheck v; int v, v; java.lang.String v, v; boolean v, v; org.slf4j.Logger v, v, v, v; oadd.org.apache.jute.BinaryOutputArchive v; java.io.IOException v, v; java.util.concurrent.LinkedBlockingQueue v, v; java.lang.Object v; v := @this: oadd.org.apache.zookeeper.server.quorum.LearnerHandler; v = 16L; label: v = v.; v = virtualinvoke v.(); if v != null goto label; v = v.; virtualinvoke v.(); v = v.; virtualinvoke v.(); label: v = v.; if v == v goto label; label: v = virtualinvoke v.(); if v != 5 goto label; v = 128L; label: v = virtualinvoke v.(); if v != 2 goto label; v = v.; v = virtualinvoke v.(); v = staticinvoke (); virtualinvoke v.(v, v); label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; staticinvoke (v, v, 111, v); label: v = v.; virtualinvoke v.(v, "packet"); label: goto label; label: v := @caughtexception; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Unexpected exception at \u0001"); interfaceinvoke v.(v, v); label: v = v.; virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Error closing socket for handler \u0001"); interfaceinvoke v.(v, v); label: return; catch java.io.IOException from label to label with label; catch java.io.IOException from label to label with label; catch java.io.IOException from label to label with label; } public static java.lang.String packetToString(oadd.org.apache.zookeeper.server.quorum.QuorumPacket) { byte[] v, v; java.io.DataInputStream v; oadd.org.apache.zookeeper.server.quorum.QuorumPacket v; long v, v; java.io.ByteArrayInputStream v; int v, v; java.lang.String v, v, v, v; org.slf4j.Logger v, v; java.io.IOException v, v; oadd.org.apache.zookeeper.txn.TxnHeader v; v := @parameter: oadd.org.apache.zookeeper.server.quorum.QuorumPacket; v = null; v = virtualinvoke v.(); 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: v = "ACK"; goto label; label: v = "COMMIT"; goto label; label: v = "FOLLOWERINFO"; goto label; label: v = "NEWLEADER"; goto label; label: v = "PING"; goto label; label: v = "PROPOSAL"; v = new oadd.org.apache.zookeeper.txn.TxnHeader; specialinvoke v.()>(); label: v = virtualinvoke v.(); staticinvoke (v, v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Unexpected exception", v); goto label; label: v = "REQUEST"; goto label; label: v = "REVALIDATE"; v = new java.io.ByteArrayInputStream; v = virtualinvoke v.(); specialinvoke v.(byte[])>(v); v = new java.io.DataInputStream; specialinvoke v.(java.io.InputStream)>(v); label: v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) (" sessionid = \u0001"); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Unexpected exception", v); goto label; label: v = "UPTODATE"; goto label; label: v = "DIFF"; goto label; label: v = "TRUNC"; goto label; label: v = "SNAP"; goto label; label: v = "ACKEPOCH"; goto label; label: v = "SYNC"; goto label; label: v = "INFORM"; goto label; label: v = "COMMITANDACTIVATE"; goto label; label: v = "INFORMANDACTIVATE"; goto label; label: v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("UNKNOWN\u0001"); label: v = null; if v == null goto label; v = virtualinvoke v.(); v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("\u \u \u0001"); label: return v; catch java.io.IOException from label to label with label; catch java.io.IOException from label to label with label; } public void run() { java.io.BufferedInputStream v; java.lang.Integer v; oadd.org.apache.jute.BinaryInputArchive v, v, v, v, v; java.io.Serializable v, v, v, v, v, v, v; oadd.org.apache.zookeeper.server.quorum.SnapshotThrottleException v; java.io.ByteArrayOutputStream v; java.io.ByteArrayInputStream v, v; java.util.concurrent.atomic.AtomicInteger v, v; oadd.org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType v, v, v, v, v; java.io.DataInputStream v, v; int 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; oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v, v, v; oadd.org.apache.zookeeper.server.quorum.LeaderZooKeeperServer v, v, v, v, v, v, 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, v, v, v, v, v, v, v, v, v, v, v, v, v; java.net.SocketAddress v; oadd.org.apache.zookeeper.server.quorum.LearnerSnapshotThrottler v; boolean v, v, v, v, v, v, v, v, v, v, v, v; oadd.org.apache.zookeeper.server.quorum.Leader v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.List v, v; oadd.org.apache.zookeeper.KeeperException$SessionExpiredException v; java.io.OutputStream v; byte[] v, v, v, v, v, v, v, v; byte v; java.lang.Long v, v; java.util.Map v, v; oadd.org.apache.zookeeper.server.Request v, v; java.lang.Object[] 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; oadd.org.apache.zookeeper.server.quorum.LearnerSyncRequest v; java.io.IOException v, v, v; java.util.concurrent.atomic.AtomicLong v; oadd.org.apache.zookeeper.server.ZKDatabase v, v, v; oadd.org.apache.zookeeper.server.quorum.QuorumPacket v, v, v, v, v, v, v, v, v; oadd.org.apache.zookeeper.server.quorum.LearnerHandler$SyncLimitCheck v, v; org.slf4j.Logger v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; oadd.org.apache.jute.BinaryOutputArchive v, v, v, v, v, v; java.lang.Object v; java.io.DataOutputStream v; oadd.org.apache.zookeeper.server.quorum.StateSummary v, v, v; java.lang.Throwable v, v, v; java.io.BufferedOutputStream v, v, v, v, v, v; oadd.org.apache.zookeeper.server.quorum.LearnerHandler v; java.nio.ByteBuffer v, v, v, v, v; java.util.concurrent.LinkedBlockingQueue v, v, v; java.net.Socket v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; oadd.org.apache.zookeeper.server.quorum.LearnerSnapshot v; oadd.org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v, v, v, v, v, v, v, v, v; java.lang.InterruptedException v; v := @this: oadd.org.apache.zookeeper.server.quorum.LearnerHandler; label: v = v.; virtualinvoke v.(v); v = v.; v = v.; v = v.; v = virtualinvoke v.(); v = v.; v = v.; v = v.; v = v + v; v = v.; v = v.; v = v.; v = v + v; v. = v; v = 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 = new oadd.org.apache.zookeeper.server.quorum.QuorumPacket; specialinvoke v.()>(); v = v.; virtualinvoke v.(v, "packet"); v = virtualinvoke v.(); if v == 11 goto label; v = virtualinvoke v.(); if v == 16 goto label; v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("First packet \u is not FOLLOWERINFO or OBSERVERINFO!"); interfaceinvoke v.(v); label: v = ; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); goto label; label: v = ""; label: v = dynamicinvoke "makeConcatWithConstants" (v) ("******* GOODBYE \u ********"); interfaceinvoke v.(v); virtualinvoke v.(); return; label: v = virtualinvoke v.(); if v == null goto label; v = staticinvoke (v); v = lengthof v; if v < 8 goto label; v = virtualinvoke v.(); v. = v; label: v = lengthof v; if v < 12 goto label; v = virtualinvoke v.(); v. = v; label: v = lengthof v; if v < 20 goto label; v = virtualinvoke v.(); v = v.; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = v cmp v; if v <= 0 goto label; v = new java.io.IOException; specialinvoke v.(java.lang.String)>("Follower is ahead of the leader (has a later activated configuration)"); throw v; label: v = v.; v = v.; v = virtualinvoke v.(); v. = v; label: v = v.; v = v.; v = virtualinvoke v.(); v = v.; v = staticinvoke (v); v = interfaceinvoke v.(v); if v == 0 goto label; v = ; v = v.; v = v.; v = v.; v = virtualinvoke v.(); v = v.; v = staticinvoke (v); v = interfaceinvoke v.(v); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Follower sid: \u : info : \u0001"); interfaceinvoke v.(v); goto label; label: v = ; v = v.; v = v.; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Follower sid: \u not in the current config \u0001"); interfaceinvoke v.(v); label: v = virtualinvoke v.(); if v != 16 goto label; v = ; v. = v; label: v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); v = staticinvoke (v, 0L); v = virtualinvoke v.(); if v >= 65536 goto label; v = staticinvoke (v); v = new oadd.org.apache.zookeeper.server.quorum.StateSummary; specialinvoke v.(long,long)>(v, v); v = v; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v); goto label; label: v = newarray (byte)[4]; v = staticinvoke (v); virtualinvoke v.(65536); v = new oadd.org.apache.zookeeper.server.quorum.QuorumPacket; specialinvoke v.(int,long,byte[],java.util.List)>(17, v, v, null); v = v.; virtualinvoke v.(v, "packet"); v = v.; virtualinvoke v.(); v = new oadd.org.apache.zookeeper.server.quorum.QuorumPacket; specialinvoke v.()>(); v = v.; virtualinvoke v.(v, "packet"); v = virtualinvoke v.(); if v == 18 goto label; v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u is not ACKEPOCH"); interfaceinvoke v.(v); label: v = ; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); goto label; label: v = ""; label: v = dynamicinvoke "makeConcatWithConstants" (v) ("******* GOODBYE \u ********"); interfaceinvoke v.(v); virtualinvoke v.(); return; label: v = virtualinvoke v.(); v = staticinvoke (v); v = new oadd.org.apache.zookeeper.server.quorum.StateSummary; v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(long,long)>(v, v); v = v; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v); label: v = virtualinvoke v.(); v = v.; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(v, v, v); if v == 0 goto label; v = virtualinvoke v.(); v = ; if v == v goto label; v = 1; goto label; label: v = 0; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); label: v = v.; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = new oadd.org.apache.zookeeper.server.quorum.QuorumPacket; specialinvoke v.(int,long,byte[],java.util.List)>(15, v, null, null); virtualinvoke v.(v, "packet"); v = v.; virtualinvoke v.(); v = ; v = newarray (java.lang.Object)[5]; v = staticinvoke (v); v[0] = v; v = v.; v = staticinvoke (v); v[1] = v; v = staticinvoke (v); v[2] = v; v = virtualinvoke v.(); v = staticinvoke (v); v[3] = v; v = virtualinvoke v.(); if v == 0 goto label; v = "exempt"; goto label; label: v = "not exempt"; label: v[4] = v; interfaceinvoke v.("Sending snapshot last zxid of peer is 0x{}, zxid of leader is 0x{}, send zxid of db as 0x{}, {} concurrent snapshots, snapshot was {} from throttle", v); v = v.; v = v.; v = virtualinvoke v.(); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.("BenWasHere", "signature"); v = v.; virtualinvoke v.(); label: virtualinvoke v.(); goto label; label: v := @caughtexception; virtualinvoke v.(); throw v; label: v = ; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Sending NEWLEADER message to \u0001"); interfaceinvoke v.(v); v = virtualinvoke v.(); if v >= 65536 goto label; v = new oadd.org.apache.zookeeper.server.quorum.QuorumPacket; specialinvoke v.(int,long,byte[],java.util.List)>(10, v, null, null); v = v.; virtualinvoke v.(v, "packet"); goto label; label: v = new oadd.org.apache.zookeeper.server.quorum.QuorumPacket; v = v.; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(int,long,byte[],java.util.List)>(10, v, v, null); v = v.; virtualinvoke v.(v); label: v = v.; virtualinvoke v.(); virtualinvoke v.(); v = new oadd.org.apache.zookeeper.server.quorum.QuorumPacket; specialinvoke v.()>(); v = v.; virtualinvoke v.(v, "packet"); v = virtualinvoke v.(); if v == 3 goto label; v = ; v = staticinvoke (v); interfaceinvoke v.("Next packet was supposed to be an ACK, but received packet: {}", v); label: v = ; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); goto label; label: v = ""; label: v = dynamicinvoke "makeConcatWithConstants" (v) ("******* GOODBYE \u ********"); interfaceinvoke v.(v); virtualinvoke v.(); return; label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Received NEWLEADER-ACK message from \u0001"); interfaceinvoke v.(v); label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v, v); v = v.; virtualinvoke v.(); v = v.; v = v.; v = v.; v = v.; v = v.; v = v.; v = v.; v = v * v; virtualinvoke v.(v); v = v.; v = v.; entermonitor v; label: v = v.; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = v.; virtualinvoke v.(20L); goto label; label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = ; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Sending UPTODATE message to \u0001"); interfaceinvoke v.(v); v = v.; v = new oadd.org.apache.zookeeper.server.quorum.QuorumPacket; specialinvoke v.(int,long,byte[],java.util.List)>(12, -1L, null, null); virtualinvoke v.(v); label: v = new oadd.org.apache.zookeeper.server.quorum.QuorumPacket; specialinvoke v.()>(); v = v.; virtualinvoke v.(v, "packet"); v = 16L; v = virtualinvoke v.(); if v != 5 goto label; v = 128L; label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; staticinvoke (v, v, 105, v); label: v = v.; v = v.; v = v.; v = virtualinvoke v.(); v = v.; v = v.; v = v.; v = v + v; v. = v; v = virtualinvoke v.(); 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; default: goto label; }; label: v = v.; v = ; if v != v goto label; v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Received ACK from Observer \u0001"); interfaceinvoke v.(v); label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v, v); goto label; label: v = new java.io.ByteArrayInputStream; v = virtualinvoke v.(); specialinvoke v.(byte[])>(v); v = new java.io.DataInputStream; specialinvoke v.(java.io.InputStream)>(v); label: v = virtualinvoke v.(); if v <= 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = v.; virtualinvoke v.