public class org.apache.zookeeper.server.quorum.CnxManagerTest extends org.apache.zookeeper.ZKTestCase { protected static final org.slf4j.Logger LOG; protected static final int THRESHOLD; int count; java.util.Map peers; java.io.File[] peerTmpdir; int[] peerQuorumPort; int[] peerClientPort; public void () { org.apache.zookeeper.server.quorum.CnxManagerTest v; v := @this: org.apache.zookeeper.server.quorum.CnxManagerTest; specialinvoke v.()>(); return; } public void setUp() throws java.lang.Exception { java.util.HashMap v; int[] v, v, v, v, v, v; java.lang.Long v; org.apache.zookeeper.server.quorum.CnxManagerTest v; java.util.Map v; int v, v, v, v, v, v, v, v, v, v, v; java.net.InetSocketAddress v, v, v; java.io.File v; org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer v; java.io.File[] v, v; v := @this: org.apache.zookeeper.server.quorum.CnxManagerTest; v. = 3; v = new java.util.HashMap; v = v.; specialinvoke v.(int)>(v); v. = v; v = v.; v = newarray (java.io.File)[v]; v. = v; v = v.; v = newarray (int)[v]; v. = v; v = v.; v = newarray (int)[v]; v. = v; v = 0; label: v = v.; if v >= v goto label; v = v.; v = staticinvoke (); v[v] = v; v = v.; v = staticinvoke (); v[v] = v; v = v.; v = staticinvoke (v); v = new org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer; v = new java.net.InetSocketAddress; v = v.; v = v[v]; specialinvoke v.(java.lang.String,int)>("127.0.0.1", v); v = new java.net.InetSocketAddress; v = staticinvoke (); specialinvoke v.(java.lang.String,int)>("127.0.0.1", v); v = new java.net.InetSocketAddress; v = v.; v = v[v]; specialinvoke v.(java.lang.String,int)>("127.0.0.1", v); specialinvoke v.(long,java.net.InetSocketAddress,java.net.InetSocketAddress,java.net.InetSocketAddress)>(v, v, v, v); interfaceinvoke v.(v, v); v = v.; v = staticinvoke (); v[v] = v; v = v + 1; goto label; label: return; } java.nio.ByteBuffer createMsg(int, long, long, long) { byte[] v; org.apache.zookeeper.server.quorum.CnxManagerTest v; int v; long v, v, v; java.nio.ByteBuffer v; v := @this: org.apache.zookeeper.server.quorum.CnxManagerTest; v := @parameter: int; v := @parameter: long; v := @parameter: long; v := @parameter: long; v = newarray (byte)[28]; v = staticinvoke (v); virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(v); return v; } public void testCnxManager() throws java.lang.Exception { org.apache.zookeeper.server.quorum.QuorumPeer v; org.apache.zookeeper.server.quorum.CnxManagerTest$CnxManagerThread v; java.nio.ByteBuffer v; org.apache.zookeeper.server.quorum.QuorumCnxManager$Message v; org.apache.zookeeper.server.quorum.QuorumPeer$ServerState v; int[] v; java.lang.Long v; org.apache.zookeeper.server.quorum.CnxManagerTest v; java.util.Map v; int v, v, v, v; boolean v, v, v, v; org.slf4j.Logger v; org.apache.zookeeper.server.quorum.QuorumCnxManager v; java.io.File v, v; java.util.concurrent.TimeUnit v; org.apache.zookeeper.server.quorum.QuorumCnxManager$Listener v, v; java.io.File[] v, v; v := @this: org.apache.zookeeper.server.quorum.CnxManagerTest; v = new org.apache.zookeeper.server.quorum.CnxManagerTest$CnxManagerThread; specialinvoke v.(org.apache.zookeeper.server.quorum.CnxManagerTest)>(v); virtualinvoke v.(); v = new org.apache.zookeeper.server.quorum.QuorumPeer; v = v.; v = v.; v = v[1]; v = v.; v = v[1]; v = v.; v = v[1]; specialinvoke v.(java.util.Map,java.io.File,java.io.File,int,int,long,int,int,int,int)>(v, v, v, v, 3, 1L, 1000, 2, 2, 2); v = virtualinvoke v.(); v = v.; if v == null goto label; virtualinvoke v.(); goto label; label: v = ; interfaceinvoke v.("Null listener when initializing cnx manager"); label: v = staticinvoke (0L); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v, 1L, -1L, 1L); virtualinvoke v.(v, v); v = null; v = 1; label: if v != null goto label; v = v; v = v + 1; if v > 4 goto label; v = ; v = virtualinvoke v.(3000L, v); if v != null goto label; virtualinvoke v.(); goto label; label: if v > 4 goto label; v = 1; goto label; label: v = 0; label: staticinvoke (v, "Exceeded number of retries"); virtualinvoke v.(5000L); v = virtualinvoke v.(); if v == 0 goto label; staticinvoke ("Thread didn\'t join"); goto label; label: v = v.; if v == 0 goto label; staticinvoke ("Did not receive expected message"); label: virtualinvoke v.(); v = v.; v = virtualinvoke v.(); staticinvoke (v); return; } public void testCnxManagerTimeout() throws java.lang.Exception { org.apache.zookeeper.server.quorum.QuorumPeer v; java.nio.ByteBuffer v; byte v; org.apache.zookeeper.server.quorum.QuorumPeer$ServerState v; int[] v; java.lang.Long v, v; org.apache.zookeeper.server.quorum.CnxManagerTest v; java.util.Map v, v; boolean v; java.net.InetSocketAddress v, v, v; org.apache.zookeeper.server.quorum.QuorumCnxManager v; org.apache.zookeeper.server.quorum.QuorumCnxManager$Listener v, v; org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer v; long v, v, v; java.util.concurrent.ThreadLocalRandom v; int v, v, v, v, v, v; java.lang.String v; org.slf4j.Logger v, v; java.io.File v, v, v; java.io.File[] v, v, v; v := @this: org.apache.zookeeper.server.quorum.CnxManagerTest; v = staticinvoke (); v = virtualinvoke v.(1, 255); v = staticinvoke (); v = dynamicinvoke "makeConcatWithConstants" (v) ("10.1.1.\u0001"); v = ; interfaceinvoke v.("This is the dead address I\'m trying: {}", v); v = v.; v = staticinvoke (2L); v = new org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer; v = new java.net.InetSocketAddress; specialinvoke v.(java.lang.String,int)>(v, v); v = new java.net.InetSocketAddress; v = staticinvoke (); specialinvoke v.(java.lang.String,int)>(v, v); v = new java.net.InetSocketAddress; v = staticinvoke (); specialinvoke v.(java.lang.String,int)>(v, v); specialinvoke v.(long,java.net.InetSocketAddress,java.net.InetSocketAddress,java.net.InetSocketAddress)>(2L, v, v, v); interfaceinvoke v.(v, v); v = v.; v = staticinvoke (); v[2] = v; v = new org.apache.zookeeper.server.quorum.QuorumPeer; v = v.; v = v.; v = v[1]; v = v.; v = v[1]; v = v.; v = v[1]; specialinvoke v.(java.util.Map,java.io.File,java.io.File,int,int,long,int,int,int,int)>(v, v, v, v, 3, 1L, 1000, 2, 2, 2); v = virtualinvoke v.(); v = v.; if v == null goto label; virtualinvoke v.(); goto label; label: v = ; interfaceinvoke v.("Null listener when initializing cnx manager"); label: v = staticinvoke (); v = staticinvoke (2L); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v, 1L, -1L, 1L); virtualinvoke v.(v, v); v = staticinvoke (); v = v - v; v = v cmp 10000L; if v <= 0 goto label; staticinvoke ("Waited more than necessary"); label: virtualinvoke v.(); v = v.; v = virtualinvoke v.(); staticinvoke (v); return; } public void testCnxManagerSpinLock() throws java.lang.Exception { org.apache.zookeeper.server.quorum.QuorumPeer v; byte[] v, v; java.lang.Integer v; java.nio.ByteBuffer v; java.io.DataOutputStream v; java.nio.channels.SocketChannel v; int[] v; java.lang.Long v, v; org.apache.zookeeper.server.quorum.CnxManagerTest v; java.util.Map v, v, v; boolean v; java.net.InetSocketAddress v, v; org.apache.zookeeper.server.quorum.QuorumCnxManager v; java.lang.Exception v; org.apache.zookeeper.server.quorum.QuorumCnxManager$Listener v, v; java.net.Socket v, v; long v; int v, v, v, v, v, v; java.lang.String v, v; java.io.OutputStream v; org.slf4j.Logger v, v, v; java.io.File v, v; org.apache.zookeeper.server.quorum.MultipleAddresses v, v; java.lang.Object v, v; java.io.File[] v, v; v := @this: org.apache.zookeeper.server.quorum.CnxManagerTest; v = new org.apache.zookeeper.server.quorum.QuorumPeer; v = v.; v = v.; v = v[1]; v = v.; v = v[1]; v = v.; v = v[1]; specialinvoke v.(java.util.Map,java.io.File,java.io.File,int,int,long,int,int,int,int)>(v, v, v, v, 3, 1L, 1000, 2, 2, 2); v = virtualinvoke v.(); v = v.; if v == null goto label; virtualinvoke v.(); goto label; label: v = ; interfaceinvoke v.("Null listener when initializing cnx manager"); label: v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("Election port: {}", v); staticinvoke (1000L); v = staticinvoke (); v = virtualinvoke v.(); virtualinvoke v.(v, 5000); v = v.; v = staticinvoke (2L); v = interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); v = new java.io.DataOutputStream; v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.io.OutputStream)>(v); virtualinvoke v.(-65536L); virtualinvoke v.(2L); v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u0001:\u0001"); v = virtualinvoke v.(); v = lengthof v; virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(); v = newarray (byte)[4]; v = staticinvoke (v); v = (int) -20; virtualinvoke v.(v); virtualinvoke v.(0); virtualinvoke v.(v); staticinvoke (1000L); label: v = 0; label: if v >= 100 goto label; virtualinvoke v.(0); virtualinvoke v.(v); v = v + 1; goto label; label: staticinvoke ("Socket has not been closed"); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Socket has been closed as expected"); label: virtualinvoke v.(); virtualinvoke v.(); v = v.; v = virtualinvoke v.(); staticinvoke (v); return; catch java.lang.Exception from label to label with label; } public void testCnxManagerListenerThreadConfigurableRetry() throws java.lang.Exception { org.apache.zookeeper.server.quorum.QuorumPeer v; java.util.concurrent.atomic.AtomicBoolean v; java.util.HashMap v; java.lang.Runnable v; java.lang.Long v; org.apache.zookeeper.server.quorum.CnxManagerTest v; java.lang.String v, v; boolean v, v, v; org.apache.zookeeper.server.quorum.QuorumCnxManager v; java.io.File v, v; org.apache.zookeeper.server.quorum.QuorumCnxManager$Listener v; org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer v; java.lang.Class v; v := @this: org.apache.zookeeper.server.quorum.CnxManagerTest; v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (1L); v = new org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer; specialinvoke v.(long,java.lang.String)>(1L, "unresolvable-domain.org:2182:2183;2181"); interfaceinvoke v.(v, v); v = new org.apache.zookeeper.server.quorum.QuorumPeer; v = staticinvoke (); v = staticinvoke (); specialinvoke v.(java.util.Map,java.io.File,java.io.File,int,int,long,int,int,int,int)>(v, v, v, 2181, 3, 1L, 1000, 2, 2, 2); v = virtualinvoke v.(); v = v.; v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.(boolean)>(0); v = staticinvoke (v); virtualinvoke v.(v); virtualinvoke v.(); virtualinvoke v.(15000L); v = virtualinvoke v.(); staticinvoke (v); v = virtualinvoke v.(); staticinvoke (v); v = virtualinvoke v.(); v = class "Lorg/apache/zookeeper/server/quorum/QuorumPeer;"; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u not stopped after listener thread death"); staticinvoke (v, v); return; } public void testCnxManagerNPE() throws java.lang.Exception { org.apache.zookeeper.server.quorum.QuorumPeer v; byte[] v, v; java.lang.Integer v; java.nio.ByteBuffer v, v; org.apache.zookeeper.server.quorum.QuorumCnxManager$Message v; java.nio.channels.SocketChannel v; int[] v; java.lang.Long v, v; org.apache.zookeeper.server.quorum.CnxManagerTest v; org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType v; java.util.Map v, v, v; boolean v; java.net.InetSocketAddress v; org.apache.zookeeper.server.quorum.QuorumCnxManager v; org.apache.zookeeper.server.quorum.QuorumCnxManager$Listener v, v; java.net.Socket v; long v; int v, v; org.slf4j.Logger v, v; java.io.File v, v; java.util.concurrent.TimeUnit v; org.apache.zookeeper.server.quorum.MultipleAddresses v; java.lang.Object v, v; java.io.File[] v, v; v := @this: org.apache.zookeeper.server.quorum.CnxManagerTest; v = v.; v = staticinvoke (2L); v = interfaceinvoke v.(v); v = ; v. = v; v = new org.apache.zookeeper.server.quorum.QuorumPeer; v = v.; v = v.; v = v[1]; v = v.; v = v[1]; v = v.; v = v[1]; specialinvoke v.(java.util.Map,java.io.File,java.io.File,int,int,long,int,int,int,int)>(v, v, v, v, 3, 1L, 1000, 2, 2, 2); v = virtualinvoke v.(); v = v.; if v == null goto label; virtualinvoke v.(); goto label; label: v = ; interfaceinvoke v.("Null listener when initializing cnx manager"); label: v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("Election port: {}", v); staticinvoke (1000L); v = staticinvoke (); v = virtualinvoke v.(); virtualinvoke v.(v, 5000); v = newarray (byte)[8]; v = staticinvoke (v); virtualinvoke v.(2L); virtualinvoke v.(0); virtualinvoke v.(v); v = newarray (byte)[8]; v = staticinvoke (v); virtualinvoke v.(4); virtualinvoke v.(5); virtualinvoke v.(0); virtualinvoke v.(v); v = ; v = virtualinvoke v.(1000L, v); staticinvoke (v); virtualinvoke v.(); virtualinvoke v.(); v = v.; v = virtualinvoke v.(); staticinvoke (v); return; } public void testSocketTimeout() throws java.lang.Exception { org.apache.zookeeper.server.quorum.QuorumPeer v; java.lang.Integer v; byte v; int[] v; java.lang.Long v; org.apache.zookeeper.server.quorum.CnxManagerTest v; java.util.Map v, v; boolean v; java.net.InetSocketAddress v; org.apache.zookeeper.server.quorum.QuorumCnxManager v; org.apache.zookeeper.server.quorum.QuorumCnxManager$Listener v, v; java.net.Socket v; long v, v, v, v; int v, v, v, v, v, v; org.slf4j.Logger v, v; java.io.File v, v; org.apache.zookeeper.server.quorum.MultipleAddresses v; java.lang.Object v; java.io.File[] v, v; v := @this: org.apache.zookeeper.server.quorum.CnxManagerTest; v = new org.apache.zookeeper.server.quorum.QuorumPeer; v = v.; v = v.; v = v[1]; v = v.; v = v[1]; v = v.; v = v[1]; specialinvoke v.(java.util.Map,java.io.File,java.io.File,int,int,long,int,int,int,int)>(v, v, v, v, 3, 1L, 2000, 2, 2, 2); v = virtualinvoke v.(); v = v.; if v == null goto label; virtualinvoke v.(); goto label; label: v = ; interfaceinvoke v.("Null listener when initializing cnx manager"); label: v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("Election port: {}", v); staticinvoke (1000L); v = new java.net.Socket; specialinvoke v.()>(); virtualinvoke v.(v, 5000); v = staticinvoke (); virtualinvoke v.(v); v = staticinvoke (); v = v - v; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v * v; v = v + 500; v = v cmp v; if v <= 0 goto label; staticinvoke ("Waited more than necessary"); label: virtualinvoke v.(); v = v.; v = virtualinvoke v.(); staticinvoke (v); return; } public void testSSLSocketClosedWhenHandshakeTimeout() throws java.lang.Exception { int[] v; java.lang.Long v; org.apache.zookeeper.server.quorum.CnxManagerTest v; java.util.Map v, v; int v; org.apache.zookeeper.server.quorum.CnxManagerTest$1 v; boolean v; org.apache.zookeeper.server.quorum.CnxManagerTest$2 v; org.apache.zookeeper.server.quorum.QuorumCnxManager v; java.io.File v, v; java.util.concurrent.TimeUnit v; java.util.concurrent.CountDownLatch v; org.apache.zookeeper.server.quorum.MultipleAddresses v; java.lang.Object v; java.io.File[] v, v; v := @this: org.apache.zookeeper.server.quorum.CnxManagerTest; v = new java.util.concurrent.CountDownLatch; specialinvoke v.(int)>(1); v = new org.apache.zookeeper.server.quorum.CnxManagerTest$1; specialinvoke v.(org.apache.zookeeper.server.quorum.CnxManagerTest,java.util.concurrent.CountDownLatch)>(v, v); v = new org.apache.zookeeper.server.quorum.CnxManagerTest$2; v = v.; v = v.; v = v[0]; v = v.; v = v[0]; v = v.; v = v[0]; specialinvoke v.(org.apache.zookeeper.server.quorum.CnxManagerTest,java.util.Map,java.io.File,java.io.File,int,int,long,int,int,int,int,org.apache.zookeeper.common.QuorumX509Util)>(v, v, v, v, v, 3, 0L, 2000, 2, 2, 2, v); virtualinvoke v.(1); v = virtualinvoke v.(); v = v.; v = staticinvoke (1L); v = interfaceinvoke v.(v); v = v.; virtualinvoke v.(1L, v); v = ; v = virtualinvoke v.(1L, v); staticinvoke (v); return; } public void testWorkerThreads() throws java.lang.Exception { org.apache.zookeeper.server.quorum.QuorumPeer v, v; java.lang.Integer v, v; int[] v, v; java.lang.Long v, v, v; org.apache.zookeeper.server.quorum.CnxManagerTest v; java.util.Map v, v; boolean v, v; java.lang.Throwable v; long v, v, v; java.util.ArrayList v; int v, v, v, v, v; java.lang.String v, v, v; org.slf4j.Logger v, v, v; java.util.Iterator v, v; java.io.File v, v, v, v; java.lang.Object v, v, v; java.io.File[] v, v, v, v; v := @this: org.apache.zookeeper.server.quorum.CnxManagerTest; v = new java.util.ArrayList; specialinvoke v.()>(); label: v = 0; label: if v >= 3 goto label; v = new org.apache.zookeeper.server.quorum.QuorumPeer; v = v.; v = v.; v = v[v]; v = v.; v = v[v]; v = v.; v = v[v]; specialinvoke v.(java.util.Map,java.io.File,java.io.File,int,int,long,int,int,int,int)>(v, v, v, v, 3, v, 1000, 2, 2, 2); v = ; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("Starting peer {}", v); virtualinvoke v.(); virtualinvoke v.(v, v); v = v + 1; goto label; label: v = virtualinvoke v.(v, 4L); staticinvoke (v, v); v = 0; label: if v >= 3 goto label; v = 0; label: if v >= 5 goto label; v = virtualinvoke v.(v); v = ; v = staticinvoke (v); v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("Round {}, halting peer {}", v, v); virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(v, 2L); staticinvoke (v, v); v = new org.apache.zookeeper.server.quorum.QuorumPeer; v = v.; v = v.; v = v[v]; v = v.; v = v[v]; v = v.; v = v[v]; specialinvoke v.(java.util.Map,java.io.File,java.io.File,int,int,long,int,int,int,int)>(v, v, v, v, 3, v, 1000, 2, 2, 2); v = ; v = staticinvoke (v); v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("Round {}, restarting peer {}", v, v); virtualinvoke v.(); virtualinvoke v.(v, v); v = virtualinvoke v.(v, 4L); staticinvoke (v, v); v = v + 1; goto label; label: v = v + 1; goto label; label: v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(); goto label; label: v := @caughtexception; v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(); goto label; label: throw v; label: return; catch java.lang.Throwable from label to label with label; } public java.lang.String verifyThreadCount(java.util.ArrayList, long) throws java.lang.InterruptedException { org.apache.zookeeper.server.quorum.CnxManagerTest v; int v; long v; java.lang.String v; java.util.ArrayList v; v := @this: org.apache.zookeeper.server.quorum.CnxManagerTest; v := @parameter: java.util.ArrayList; v := @parameter: long; v = null; v = 0; label: if v >= 480 goto label; staticinvoke (500L); v = virtualinvoke v.(v, v); if v != null goto label; return null; label: v = v + 1; goto label; label: return v; } public java.lang.String _verifyThreadCount(java.util.ArrayList, long) { java.util.Date v; long v, v; org.apache.zookeeper.server.quorum.QuorumCnxManager v; java.util.ArrayList v; byte v; org.apache.zookeeper.server.quorum.CnxManagerTest v; int v, v; java.lang.Object v; java.lang.String v; v := @this: org.apache.zookeeper.server.quorum.CnxManagerTest; v := @parameter: java.util.ArrayList; v := @parameter: long; v = 0; label: v = virtualinvoke v.(); if v >= v goto label; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v cmp v; if v == 0 goto label; v = new java.util.Date; specialinvoke v.()>(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v) ("\u Incorrect number of Worker threads for sid=\u expected \u found \u0001"); return v; label: v = v + 1; goto label; label: return null; } public void testInitialMessage() throws java.lang.Exception { byte[] v, v, v, v, v, v, v, v, v, v; java.io.DataOutputStream v, v, v, v, v; java.lang.Long v, v, v, v, v, v, v, v, v; org.apache.zookeeper.server.quorum.CnxManagerTest v; java.lang.Throwable v, v, v, v, v; java.io.ByteArrayOutputStream v, v, v, v, v; java.lang.String v, v, v, v, v, v, v; java.io.ByteArrayInputStream v, v, v, v, v; org.apache.zookeeper.server.quorum.QuorumCnxManager$InitialMessage v, v; java.net.InetSocketAddress v, v, v, v; java.util.List v, v, v, v; java.net.InetSocketAddress[] v, v; java.io.DataInputStream v, v, v, v, v; int v, v, v, v, v; v := @this: org.apache.zookeeper.server.quorum.CnxManagerTest; label: v = "10.0.0.2:3888"; v = new java.io.ByteArrayOutputStream; specialinvoke v.()>(); v = new java.io.DataOutputStream; specialinvoke v.(java.io.OutputStream)>(v); virtualinvoke v.(5L); v = virtualinvoke v.(); v = lengthof v; virtualinvoke v.(v); virtualinvoke v.("10.0.0.2:3888"); v = new java.io.DataInputStream; v = new java.io.ByteArrayInputStream; v = virtualinvoke v.(); specialinvoke v.(byte[])>(v); specialinvoke v.(java.io.InputStream)>(v); v = staticinvoke (-65530L); staticinvoke (v, v); staticinvoke ("bad protocol version accepted"); label: goto label; label: v := @caughtexception; label: v = specialinvoke v.(1048576); v = new java.io.ByteArrayOutputStream; specialinvoke v.()>(); v = new java.io.DataOutputStream; specialinvoke v.(java.io.OutputStream)>(v); virtualinvoke v.(5L); v = virtualinvoke v.(); v = lengthof v; virtualinvoke v.(v); virtualinvoke v.(v); v = new java.io.DataInputStream; v = new java.io.ByteArrayInputStream; v = virtualinvoke v.(); specialinvoke v.(byte[])>(v); specialinvoke v.(java.io.InputStream)>(v); v = staticinvoke (-65536L); staticinvoke (v, v); staticinvoke ("long message accepted"); label: goto label; label: v := @caughtexception; label: v = "what\'s going on here?"; v = new java.io.ByteArrayOutputStream; specialinvoke v.()>(); v = new java.io.DataOutputStream; specialinvoke v.(java.io.OutputStream)>(v); virtualinvoke v.(5L); v = virtualinvoke v.(); v = lengthof v; virtualinvoke v.(v); virtualinvoke v.("what\'s going on here?"); v = new java.io.DataInputStream; v = new java.io.ByteArrayInputStream; v = virtualinvoke v.(); specialinvoke v.(byte[])>(v); specialinvoke v.(java.io.InputStream)>(v); v = staticinvoke (-65536L); staticinvoke (v, v); staticinvoke ("bad hostport accepted"); label: goto label; label: v := @caughtexception; label: v = "10.0.0.2:3888"; v = new java.io.ByteArrayOutputStream; specialinvoke v.()>(); v = new java.io.DataOutputStream; specialinvoke v.(java.io.OutputStream)>(v); virtualinvoke v.(5L); v = virtualinvoke v.(); v = lengthof v; virtualinvoke v.(v); virtualinvoke v.("10.0.0.2:3888"); v = new java.io.DataInputStream; v = new java.io.ByteArrayInputStream; v = virtualinvoke v.(); specialinvoke v.(byte[])>(v); specialinvoke v.(java.io.InputStream)>(v); v = staticinvoke (-65536L); v = staticinvoke (v, v); v = staticinvoke (5L); v = v.; staticinvoke (v, v); v = newarray (java.net.InetSocketAddress)[1]; v = new java.net.InetSocketAddress; specialinvoke v.(java.lang.String,int)>("10.0.0.2", 3888); v[0] = v; v = staticinvoke (v); v = v.; staticinvoke (v, v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); staticinvoke (v); label: v = "1.1.1.1:9999|2.2.2.2:8888|3.3.3.3:7777"; v = new java.io.ByteArrayOutputStream; specialinvoke v.()>(); v = new java.io.DataOutputStream; specialinvoke v.(java.io.OutputStream)>(v); virtualinvoke v.(5L); v = virtualinvoke v.(); v = lengthof v; virtualinvoke v.(v); virtualinvoke v.("1.1.1.1:9999|2.2.2.2:8888|3.3.3.3:7777"); v = new java.io.DataInputStream; v = new java.io.ByteArrayInputStream; v = virtualinvoke v.(); specialinvoke v.