class oadd.org.apache.zookeeper.ClientCnxn$SendThread extends oadd.org.apache.zookeeper.server.ZooKeeperThread { private long lastPingSentNs; private final oadd.org.apache.zookeeper.ClientCnxnSocket clientCnxnSocket; private java.util.Random r; private boolean isFirstConnect; private java.net.InetSocketAddress rwServerAddress; private static final int minPingRwTimeout; private static final int maxPingRwTimeout; private int pingRwTimeout; private boolean saslLoginFailed; private static final java.lang.String RETRY_CONN_MSG; final oadd.org.apache.zookeeper.ClientCnxn this$0; void readResponse(java.nio.ByteBuffer) throws java.io.IOException { byte[] v; oadd.org.apache.zookeeper.ClientCnxn$SendThread v; byte v; oadd.org.apache.jute.BinaryInputArchive v; oadd.org.apache.zookeeper.server.ByteBufferInputStream v; long v, v, v, v, v, v, v, v, v, v, v, v; java.io.IOException v, v; oadd.org.apache.zookeeper.client.ZooKeeperSaslClient v; oadd.org.apache.zookeeper.ZooKeeper$States v; oadd.org.apache.zookeeper.proto.WatcherEvent v; oadd.org.apache.zookeeper.KeeperException$Code v, v; oadd.org.apache.zookeeper.ClientCnxn v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, 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; java.util.LinkedList v, v, v; org.slf4j.Logger v, v, v, v, v, v, v, v, v, v, v; oadd.org.apache.zookeeper.proto.RequestHeader v, v; java.lang.Object v; oadd.org.apache.zookeeper.proto.ReplyHeader v, v, v, v, v; java.lang.Throwable v, v; oadd.org.apache.zookeeper.WatchedEvent v, v; oadd.org.apache.zookeeper.Watcher$Event$KeeperState 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; java.nio.ByteBuffer v; boolean v, v, v, v, v, v; oadd.org.apache.jute.Record v, v; oadd.org.apache.zookeeper.proto.GetSASLRequest v; oadd.org.apache.zookeeper.Watcher$Event$EventType v; oadd.org.apache.zookeeper.ClientCnxn$EventThread v, v, v; v := @this: oadd.org.apache.zookeeper.ClientCnxn$SendThread; v := @parameter: java.nio.ByteBuffer; v = new oadd.org.apache.zookeeper.server.ByteBufferInputStream; specialinvoke v.(java.nio.ByteBuffer)>(v); v = staticinvoke (v); v = new oadd.org.apache.zookeeper.proto.ReplyHeader; specialinvoke v.()>(); virtualinvoke v.(v, "header"); v = virtualinvoke v.(); v = (int) -2; if v != v goto label; v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = v.; v = v.; v = staticinvoke (v); v = staticinvoke (); v = v.; v = v - v; v = v / 1000000L; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Got ping response for sessionid: 0x\u after \u0001ms"); interfaceinvoke v.(v); label: return; label: v = virtualinvoke v.(); v = (int) -4; if v != v goto label; v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); if v != v goto label; v = v.; v = ; v. = v; v = v.; v = v.; v = new oadd.org.apache.zookeeper.WatchedEvent; v = ; v = ; specialinvoke v.(oadd.org.apache.zookeeper.Watcher$Event$EventType,oadd.org.apache.zookeeper.Watcher$Event$KeeperState,java.lang.String)>(v, v, null); virtualinvoke v.(v); v = v.; v = v.; virtualinvoke v.(); label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = v.; v = v.; v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v) ("Got auth sessionid:0x\u0001"); interfaceinvoke v.(v); label: return; label: v = virtualinvoke v.(); v = (int) -1; if v != v goto label; v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = v.; v = v.; v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v) ("Got notification sessionid:0x\u0001"); interfaceinvoke v.(v); label: v = new oadd.org.apache.zookeeper.proto.WatcherEvent; specialinvoke v.()>(); virtualinvoke v.(v, "response"); v = v.; v = v.; if v == null goto label; v = virtualinvoke v.(); v = v.; v = v.; v = virtualinvoke v.(v); if v != 0 goto label; virtualinvoke v.("/"); goto label; label: v = virtualinvoke v.(); v = v.; v = v.; v = virtualinvoke v.(); if v <= v goto label; v = v.; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); virtualinvoke v.(v); goto label; label: v = ; v = virtualinvoke v.(); v = v.; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Got server path \u which is too short for chroot path \u0001"); interfaceinvoke v.(v); label: v = new oadd.org.apache.zookeeper.WatchedEvent; specialinvoke v.(oadd.org.apache.zookeeper.proto.WatcherEvent)>(v); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = v.; v = v.; v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Got \u for sessionid 0x\u0001"); interfaceinvoke v.(v); label: v = v.; v = v.; virtualinvoke v.(v); return; label: v = virtualinvoke v.(); if v == 0 goto label; v = new oadd.org.apache.zookeeper.proto.GetSASLRequest; specialinvoke v.()>(); virtualinvoke v.(v, "token"); v = v.; v = v.; v = virtualinvoke v.(); v = v.; virtualinvoke v.(v, v); return; label: v = v.; v = v.; entermonitor v; label: v = v.; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = new java.io.IOException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Nothing in the queue, but got \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; v = v.; v = virtualinvoke v.(); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == v goto label; v = v.; v = ; v = virtualinvoke v.(); virtualinvoke v.(v); v = new java.io.IOException; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v) ("Xid out of order. Got Xid \u with err \u expected Xid \u for a packet with details: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); v = v cmp 0L; if v <= 0 goto label; v = v.; v = virtualinvoke v.(); v. = v; label: v = v.; if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = v.; interfaceinvoke v.(v, "response"); label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = v.; v = v.; v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Reading reply sessionid:0x\u, packet:: \u0001"); interfaceinvoke 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.Throwable from label to label with label; } void (oadd.org.apache.zookeeper.ClientCnxn, oadd.org.apache.zookeeper.ClientCnxnSocket) { oadd.org.apache.zookeeper.ClientCnxn$SendThread v; oadd.org.apache.zookeeper.ZooKeeper$States v; oadd.org.apache.zookeeper.ClientCnxn v; java.util.Random v; java.lang.String v; oadd.org.apache.zookeeper.ClientCnxnSocket v; v := @this: oadd.org.apache.zookeeper.ClientCnxn$SendThread; v := @parameter: oadd.org.apache.zookeeper.ClientCnxn; v := @parameter: oadd.org.apache.zookeeper.ClientCnxnSocket; v. = v; v = staticinvoke ("-SendThread()"); specialinvoke v.(java.lang.String)>(v); v = new java.util.Random; specialinvoke v.()>(); v. = v; v. = 1; v. = null; v. = 100; v. = 0; v = ; v. = v; v. = v; virtualinvoke v.(1); return; } oadd.org.apache.zookeeper.ZooKeeper$States getZkState() { oadd.org.apache.zookeeper.ClientCnxn$SendThread v; oadd.org.apache.zookeeper.ZooKeeper$States v; oadd.org.apache.zookeeper.ClientCnxn v; v := @this: oadd.org.apache.zookeeper.ClientCnxn$SendThread; v = v.; v = v.; return v; } oadd.org.apache.zookeeper.ClientCnxnSocket getClientCnxnSocket() { oadd.org.apache.zookeeper.ClientCnxn$SendThread v; oadd.org.apache.zookeeper.ClientCnxnSocket v; v := @this: oadd.org.apache.zookeeper.ClientCnxn$SendThread; v = v.; return v; } void primeConnection() throws java.io.IOException { byte[] v, v; oadd.org.apache.zookeeper.ClientCnxn$SendThread v; oadd.org.apache.zookeeper.proto.ConnectRequest v; java.util.concurrent.CopyOnWriteArraySet v; long v, v, v; java.util.ArrayList v, v, v; java.lang.String v, v; oadd.org.apache.zookeeper.proto.AuthPacket v; java.util.concurrent.LinkedBlockingDeque v, v, v; java.net.SocketAddress v, v, v; oadd.org.apache.zookeeper.ClientCnxnSocket v, v, v, v; oadd.org.apache.zookeeper.ZooKeeper v, v, v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.List v, v, v, v, v, v; oadd.org.apache.zookeeper.proto.SetWatches v; oadd.org.apache.zookeeper.ClientCnxn v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; int v, v, v, v, v; oadd.org.apache.zookeeper.client.ZKClientConfig v; org.slf4j.Logger v, v, v; java.util.Iterator v, v, v, v; oadd.org.apache.zookeeper.ClientCnxn$Packet v, v, v; oadd.org.apache.zookeeper.proto.RequestHeader v, v; java.lang.Object v, v; oadd.org.apache.zookeeper.proto.ReplyHeader v; v := @this: oadd.org.apache.zookeeper.ClientCnxn$SendThread; v = ; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); interfaceinvoke v.("Socket connection established, initiating session, client: {}, server: {}", v, v); v. = 0; v = v.; v = v.; if v == 0 goto label; v = v.; v = v.; goto label; label: v = 0L; label: v = new oadd.org.apache.zookeeper.proto.ConnectRequest; v = v.; v = v.; v = v.; v = v.; v = v.; v = v.; specialinvoke v.(int,long,int,long,byte[])>(0, v, v, v, v); v = v.; v = v.; v = virtualinvoke v.("zookeeper.disableAutoWatchReset"); if v != 0 goto label; v = v.; v = v.; v = virtualinvoke v.(); v = v.; v = v.; v = virtualinvoke v.(); v = v.; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); if v != 0 goto label; label: v = specialinvoke v.(v); v = interfaceinvoke v.(); v = specialinvoke v.(v); v = interfaceinvoke v.(); v = specialinvoke v.(v); v = interfaceinvoke v.(); v = v.; v = v.; label: v = interfaceinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(); if v == 0 goto label; label: v = new java.util.ArrayList; specialinvoke v.()>(); v = new java.util.ArrayList; specialinvoke v.()>(); v = new java.util.ArrayList; specialinvoke v.()>(); v = 0; label: if v >= 131072 goto label; v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); interfaceinvoke v.(v); goto label; label: v = interfaceinvoke v.(); if v == 0 goto label; interfaceinvoke v.(); interfaceinvoke v.(v); goto label; label: v = interfaceinvoke v.(); if v == 0 goto label; interfaceinvoke v.(); interfaceinvoke v.(v); label: v = virtualinvoke v.(); v = v + v; goto label; label: v = new oadd.org.apache.zookeeper.proto.SetWatches; specialinvoke v.(long,java.util.List,java.util.List,java.util.List)>(v, v, v, v); v = new oadd.org.apache.zookeeper.proto.RequestHeader; v = (int) -8; specialinvoke v.(int,int)>(v, 101); v = new oadd.org.apache.zookeeper.ClientCnxn$Packet; v = new oadd.org.apache.zookeeper.proto.ReplyHeader; specialinvoke v.()>(); specialinvoke v.(oadd.org.apache.zookeeper.proto.RequestHeader,oadd.org.apache.zookeeper.proto.ReplyHeader,oadd.org.apache.jute.Record,oadd.org.apache.jute.Record,oadd.org.apache.zookeeper.ZooKeeper$WatchRegistration)>(v, v, v, null, null); v = v.; v = v.; virtualinvoke v.(v); goto label; label: v = v.; v = v.; v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = v.; v = new oadd.org.apache.zookeeper.ClientCnxn$Packet; v = new oadd.org.apache.zookeeper.proto.RequestHeader; v = (int) -4; specialinvoke v.(int,int)>(v, 100); v = new oadd.org.apache.zookeeper.proto.AuthPacket; v = v.; v = v.; specialinvoke v.(int,java.lang.String,byte[])>(0, v, v); specialinvoke v.(oadd.org.apache.zookeeper.proto.RequestHeader,oadd.org.apache.zookeeper.proto.ReplyHeader,oadd.org.apache.jute.Record,oadd.org.apache.jute.Record,oadd.org.apache.zookeeper.ZooKeeper$WatchRegistration)>(v, null, v, null, null); virtualinvoke v.(v); goto label; label: v = v.; v = v.; v = new oadd.org.apache.zookeeper.ClientCnxn$Packet; v = v.; v = v.; specialinvoke v.(oadd.org.apache.zookeeper.proto.RequestHeader,oadd.org.apache.zookeeper.proto.ReplyHeader,oadd.org.apache.jute.Record,oadd.org.apache.jute.Record,oadd.org.apache.zookeeper.ZooKeeper$WatchRegistration,boolean)>(null, null, v, null, null, v); virtualinvoke v.(v); v = v.; virtualinvoke v.(); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Session establishment request sent on \u0001"); interfaceinvoke v.(v); label: return; } private java.util.List prependChroot(java.util.List) { oadd.org.apache.zookeeper.ClientCnxn$SendThread v; oadd.org.apache.zookeeper.ClientCnxn v, v, v; java.util.List v; int v, v, v; java.lang.Object v; java.lang.String v, v, v; boolean v; v := @this: oadd.org.apache.zookeeper.ClientCnxn$SendThread; v := @parameter: java.util.List; v = v.; v = v.; if v == null goto label; v = interfaceinvoke v.(); if v != 0 goto label; v = 0; label: v = interfaceinvoke v.(); if v >= v goto label; v = interfaceinvoke v.(v); v = virtualinvoke v.(); if v != 1 goto label; v = v.; v = v.; goto label; label: v = v.; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u0001\u0001"); label: interfaceinvoke v.(v, v); v = v + 1; goto label; label: return v; } private void sendPing() { oadd.org.apache.zookeeper.ClientCnxn$SendThread v; oadd.org.apache.zookeeper.ClientCnxn v; int v; long v; oadd.org.apache.zookeeper.proto.RequestHeader v; v := @this: oadd.org.apache.zookeeper.ClientCnxn$SendThread; v = staticinvoke (); v. = v; v = new oadd.org.apache.zookeeper.proto.RequestHeader; v = (int) -2; specialinvoke v.(int,int)>(v, 11); v = v.; virtualinvoke v.(v, null, null, null, null, null, null, null, null); return; } private void startConnect(java.net.InetSocketAddress) throws java.io.IOException { javax.security.auth.login.LoginException v; oadd.org.apache.zookeeper.ClientCnxn$SendThread v; java.util.Random v; oadd.org.apache.zookeeper.ClientCnxnSocket v; oadd.org.apache.zookeeper.client.ZooKeeperSaslClient v, v, v; boolean v, v; oadd.org.apache.zookeeper.ZooKeeper$States v; java.net.InetSocketAddress v; oadd.org.apache.zookeeper.ClientCnxn v, v, v, v, v, v, v, v; oadd.org.apache.zookeeper.WatchedEvent v; int v, v; oadd.org.apache.zookeeper.Watcher$Event$KeeperState v; oadd.org.apache.zookeeper.client.ZKClientConfig v, v, v; java.lang.String v, v, v, v, v, v, v; oadd.org.apache.zookeeper.Watcher$Event$EventType v; org.slf4j.Logger v, v; java.lang.InterruptedException v; oadd.org.apache.zookeeper.ClientCnxn$EventThread v; v := @this: oadd.org.apache.zookeeper.ClientCnxn$SendThread; v := @parameter: java.net.InetSocketAddress; v. = 0; v = v.; if v != 0 goto label; label: v = v.; v = virtualinvoke v.(1000); staticinvoke (v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Unexpected exception", v); label: v = v.; v = ; v. = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u0001:\u0001"); staticinvoke ("myid", v); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("(\u)"); v = virtualinvoke v.("\$.*\$", v); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(); if v == 0 goto label; label: v = v.; v = v.; if v == null goto label; v = v.; v = v.; virtualinvoke v.(); label: v = v.; v = new oadd.org.apache.zookeeper.client.ZooKeeperSaslClient; v = v.; v = v.; v = staticinvoke (v, v); v = v.; v = v.; specialinvoke v.(java.lang.String,oadd.org.apache.zookeeper.client.ZKClientConfig)>(v, v); v. = v; label: goto label; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("SASL configuration failed: \u Will continue connection to Zookeeper server without SASL authentication, if Zookeeper server allows it."); interfaceinvoke v.(v); v = v.; v = v.; v = new oadd.org.apache.zookeeper.WatchedEvent; v = ; v = ; specialinvoke v.(oadd.org.apache.zookeeper.Watcher$Event$EventType,oadd.org.apache.zookeeper.Watcher$Event$KeeperState,java.lang.String)>(v, v, null); virtualinvoke v.(v); v. = 1; label: specialinvoke v.(v); v = v.; virtualinvoke v.(v); return; catch java.lang.InterruptedException from label to label with label; catch javax.security.auth.login.LoginException from label to label with label; } private void logStartConnect(java.net.InetSocketAddress) { oadd.org.apache.zookeeper.ClientCnxn$SendThread v; org.slf4j.Logger v; oadd.org.apache.zookeeper.ClientCnxn v, v; java.net.InetSocketAddress v; oadd.org.apache.zookeeper.client.ZooKeeperSaslClient v, v; java.lang.String v, v; v := @this: oadd.org.apache.zookeeper.ClientCnxn$SendThread; v := @parameter: java.net.InetSocketAddress; v = dynamicinvoke "makeConcatWithConstants" (v) ("Opening socket connection to server \u0001"); v = v.; v = v.; if v == null goto label; v = v.; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u. \u0001"); label: v = ; interfaceinvoke v.(v); return; } public void run() { oadd.org.apache.zookeeper.ClientCnxn$SendThread v; javax.security.sasl.SaslException v; java.lang.Object[] v; long v, v, v, v, v, v, v, v, v; short v; oadd.org.apache.zookeeper.ClientCnxnSocket v, v, v, v, v, v, v, v, v, v, v, v, v, v; oadd.org.apache.zookeeper.client.ZooKeeperSaslClient v, v, v, v; oadd.org.apache.zookeeper.ZooKeeper$States v, v, v, v, v, v, v, v, v, v, v; oadd.org.apache.zookeeper.ClientCnxn 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; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.LinkedList v; org.slf4j.Logger v, v, v, v, v, v, v, v, v, v, v; oadd.org.apache.zookeeper.ClientCnxn$SessionTimeoutException v; oadd.org.apache.zookeeper.client.ZooKeeperSaslClient$SaslState v, v; java.lang.Throwable v, v; oadd.org.apache.zookeeper.WatchedEvent v, v, v; oadd.org.apache.zookeeper.Watcher$Event$KeeperState 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; java.util.concurrent.LinkedBlockingDeque v; oadd.org.apache.zookeeper.client.HostProvider v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.net.InetSocketAddress v, v; oadd.org.apache.zookeeper.Watcher$Event$EventType v, v, v; oadd.org.apache.zookeeper.ClientCnxn$EventThread v, v, v, v; v := @this: oadd.org.apache.zookeeper.ClientCnxn$SendThread; v = v.; v = v.; v = v.; v = v.; v = v.; virtualinvoke v.(v, v, v); v = v.; virtualinvoke v.(); v = v.; virtualinvoke v.(); v = staticinvoke (); v = null; label: v = v.; v = v.; v = virtualinvoke v.(); if v == 0 goto label; label: v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = v.; if v != 0 goto label; label: v = v.; if v == null goto label; v = v.; v. = null; goto label; label: v = v.; v = v.; v = interfaceinvoke v.(1000L); label: specialinvoke v.(v); v = v.; virtualinvoke v.(); label: v = v.; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = v.; if v == null goto label; v = 0; v = v.; v = v.; v = virtualinvoke v.(); v = ; if v != v goto label; label: v = v.; v = v.; v = v.; virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("SASL authentication with Zookeeper Quorum member failed: \u0001"); interfaceinvoke v.(v); v = v.; v = ; v. = v; v = 1; label: v = v.; v = v.; v = virtualinvoke v.(); if v == null goto label; v = ; if v != v goto label; v = v.; v = ; v. = v; v = 1; goto label; label: v = ; if v != v goto label; v = 1; label: if v == 0 goto label; v = v.; v = v.; v = new oadd.org.apache.zookeeper.WatchedEvent; v = ; specialinvoke v.