public class org.apache.zookeeper.server.quorum.QuorumCnxManagerSocketConnectionTimeoutTest extends org.apache.zookeeper.ZKTestCase
{
private static final org.slf4j.Logger LOG;
private org.apache.zookeeper.test.QuorumUtil qu;
public void <init>()
{
org.apache.zookeeper.server.quorum.QuorumCnxManagerSocketConnectionTimeoutTest v;
v := @this: org.apache.zookeeper.server.quorum.QuorumCnxManagerSocketConnectionTimeoutTest;
specialinvoke v.<org.apache.zookeeper.ZKTestCase: void <init>()>();
return;
}
public void setUp() throws java.lang.Exception
{
org.apache.zookeeper.test.QuorumUtil v, v;
org.apache.zookeeper.server.quorum.QuorumCnxManagerSocketConnectionTimeoutTest v;
v := @this: org.apache.zookeeper.server.quorum.QuorumCnxManagerSocketConnectionTimeoutTest;
v = new org.apache.zookeeper.test.QuorumUtil;
specialinvoke v.<org.apache.zookeeper.test.QuorumUtil: void <init>(int,int)>(1, 2);
v.<org.apache.zookeeper.server.quorum.QuorumCnxManagerSocketConnectionTimeoutTest: org.apache.zookeeper.test.QuorumUtil qu> = v;
v = v.<org.apache.zookeeper.server.quorum.QuorumCnxManagerSocketConnectionTimeoutTest: org.apache.zookeeper.test.QuorumUtil qu>;
virtualinvoke v.<org.apache.zookeeper.test.QuorumUtil: void startAll()>();
return;
}
public void testSocketConnectionTimeoutDuringConnectingToElectionAddress() throws java.lang.Exception
{
org.apache.zookeeper.server.quorum.QuorumPeer v;
java.util.function.Supplier v;
org.apache.zookeeper.test.QuorumUtil$PeerStruct v;
org.apache.zookeeper.server.quorum.QuorumCnxManagerSocketConnectionTimeoutTest v;
int v, v, v;
org.apache.zookeeper.ZKTestCase$WaitForCondition v;
java.lang.String v;
boolean v;
java.net.InetSocketAddress v;
org.apache.zookeeper.server.quorum.MultipleAddresses v;
org.apache.zookeeper.test.QuorumUtil v, v, v, v;
v := @this: org.apache.zookeeper.server.quorum.QuorumCnxManagerSocketConnectionTimeoutTest;
v = v.<org.apache.zookeeper.server.quorum.QuorumCnxManagerSocketConnectionTimeoutTest: org.apache.zookeeper.test.QuorumUtil qu>;
v = virtualinvoke v.<org.apache.zookeeper.test.QuorumUtil: int getLeaderServer()>();
v = v.<org.apache.zookeeper.server.quorum.QuorumCnxManagerSocketConnectionTimeoutTest: org.apache.zookeeper.test.QuorumUtil qu>;
v = virtualinvoke v.<org.apache.zookeeper.test.QuorumUtil: org.apache.zookeeper.server.quorum.QuorumPeer getLeaderQuorumPeer()>();
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.MultipleAddresses getElectionAddress()>();
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.MultipleAddresses: java.net.InetSocketAddress getOne()>();
v = staticinvoke <org.apache.zookeeper.server.quorum.QuorumCnxManagerSocketConnectionTimeoutTest$lambda_testSocketConnectionTimeoutDuringConnectingToElectionAddress_0__196: java.util.function.Supplier bootstrap$(org.apache.zookeeper.server.quorum.QuorumCnxManagerSocketConnectionTimeoutTest,java.net.InetSocketAddress)>(v, v);
staticinvoke <org.apache.zookeeper.server.quorum.QuorumCnxManager: void setSocketFactory(java.util.function.Supplier)>(v);
v = v.<org.apache.zookeeper.server.quorum.QuorumCnxManagerSocketConnectionTimeoutTest: org.apache.zookeeper.test.QuorumUtil qu>;
virtualinvoke v.<org.apache.zookeeper.test.QuorumUtil: void shutdown(int)>(v);
v = v.<org.apache.zookeeper.server.quorum.QuorumCnxManagerSocketConnectionTimeoutTest: org.apache.zookeeper.test.QuorumUtil qu>;
v = virtualinvoke v.<org.apache.zookeeper.test.QuorumUtil: org.apache.zookeeper.test.QuorumUtil$PeerStruct getPeer(int)>(v);
v = v.<org.apache.zookeeper.test.QuorumUtil$PeerStruct: int clientPort>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("127.0.0.1:\u0001");
v = <org.apache.zookeeper.test.ClientBase: int CONNECTION_TIMEOUT>;
v = staticinvoke <org.apache.zookeeper.test.ClientBase: boolean waitForServerDown(java.lang.String,long)>(v, v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, "Timeout during waiting for current leader to go down");
v = staticinvoke <org.apache.zookeeper.server.quorum.QuorumCnxManagerSocketConnectionTimeoutTest$lambda_testSocketConnectionTimeoutDuringConnectingToElectionAddress_1__197: org.apache.zookeeper.ZKTestCase$WaitForCondition bootstrap$(org.apache.zookeeper.server.quorum.QuorumCnxManagerSocketConnectionTimeoutTest,int)>(v, v);
staticinvoke <org.apache.zookeeper.server.quorum.QuorumCnxManagerSocketConnectionTimeoutTest: void waitFor(java.lang.String,org.apache.zookeeper.ZKTestCase$WaitForCondition,int)>("No new leader was elected", v, 15);
return;
}
public void tearDown() throws java.lang.Exception
{
org.apache.zookeeper.test.QuorumUtil v;
java.util.function.Supplier v;
org.apache.zookeeper.server.quorum.QuorumCnxManagerSocketConnectionTimeoutTest v;
v := @this: org.apache.zookeeper.server.quorum.QuorumCnxManagerSocketConnectionTimeoutTest;
v = v.<org.apache.zookeeper.server.quorum.QuorumCnxManagerSocketConnectionTimeoutTest: org.apache.zookeeper.test.QuorumUtil qu>;
virtualinvoke v.<org.apache.zookeeper.test.QuorumUtil: void shutdownAll()>();
v = <org.apache.zookeeper.server.quorum.QuorumCnxManager: java.util.function.Supplier DEFAULT_SOCKET_FACTORY>;
staticinvoke <org.apache.zookeeper.server.quorum.QuorumCnxManager: void setSocketFactory(java.util.function.Supplier)>(v);
return;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/zookeeper/server/quorum/QuorumCnxManagerSocketConnectionTimeoutTest;");
<org.apache.zookeeper.server.quorum.QuorumCnxManagerSocketConnectionTimeoutTest: org.slf4j.Logger LOG> = v;
return;
}
}