public class org.apache.zookeeper.server.quorum.QuorumServerTest extends org.apache.zookeeper.ZKTestCase
{
private java.lang.String ipv6n;
private java.lang.String ipv6n;
private java.lang.String ipv4config;
public void <init>()
{
org.apache.zookeeper.server.quorum.QuorumServerTest v;
v := @this: org.apache.zookeeper.server.quorum.QuorumServerTest;
specialinvoke v.<org.apache.zookeeper.ZKTestCase: void <init>()>();
v.<org.apache.zookeeper.server.quorum.QuorumServerTest: java.lang.String ipv6n1> = "[2500:0:0:0:0:0:1:0]";
v.<org.apache.zookeeper.server.quorum.QuorumServerTest: java.lang.String ipv6n2> = "[2600:0:0:0:0:0:1:0]";
v.<org.apache.zookeeper.server.quorum.QuorumServerTest: java.lang.String ipv4config> = "127.0.0.1:1234:1236";
return;
}
public void tearDown()
{
org.apache.zookeeper.server.quorum.QuorumServerTest v;
v := @this: org.apache.zookeeper.server.quorum.QuorumServerTest;
staticinvoke <java.lang.System: java.lang.String clearProperty(java.lang.String)>("zookeeper.multiAddress.enabled");
return;
}
public void testToString() throws org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException
{
org.apache.zookeeper.server.quorum.QuorumServerTest v;
org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer 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 := @this: org.apache.zookeeper.server.quorum.QuorumServerTest;
v = v.<org.apache.zookeeper.server.quorum.QuorumServerTest: java.lang.String ipv4config>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u0001:participant;0.0.0.0:1237");
v = v.<org.apache.zookeeper.server.quorum.QuorumServerTest: java.lang.String ipv4config>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u0001:participant;0.0.0.0:1237");
v = new org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer;
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: void <init>(long,java.lang.String)>(0L, v);
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: java.lang.String toString()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(v, v, "Use IP address");
v = v.<org.apache.zookeeper.server.quorum.QuorumServerTest: java.lang.String ipv4config>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u;0.0.0.0:1237");
v = v.<org.apache.zookeeper.server.quorum.QuorumServerTest: java.lang.String ipv4config>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u0001:participant;0.0.0.0:1237");
v = new org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer;
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: void <init>(long,java.lang.String)>(0L, v);
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: java.lang.String toString()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(v, v, "Type unspecified");
v = v.<org.apache.zookeeper.server.quorum.QuorumServerTest: java.lang.String ipv4config>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u0001:observer;0.0.0.0:1237");
v = v.<org.apache.zookeeper.server.quorum.QuorumServerTest: java.lang.String ipv4config>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u0001:observer;0.0.0.0:1237");
v = new org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer;
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: void <init>(long,java.lang.String)>(0L, v);
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: java.lang.String toString()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(v, v, "Observer type");
v = v.<org.apache.zookeeper.server.quorum.QuorumServerTest: java.lang.String ipv4config>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u0001:participant;1237");
v = v.<org.apache.zookeeper.server.quorum.QuorumServerTest: java.lang.String ipv4config>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u0001:participant;0.0.0.0:1237");
v = new org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer;
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: void <init>(long,java.lang.String)>(0L, v);
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: java.lang.String toString()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(v, v, "Client address unspecified");
v = v.<org.apache.zookeeper.server.quorum.QuorumServerTest: java.lang.String ipv4config>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u0001:participant;1.2.3.4:1237");
v = v.<org.apache.zookeeper.server.quorum.QuorumServerTest: java.lang.String ipv4config>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u0001:participant;1.2.3.4:1237");
v = new org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer;
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: void <init>(long,java.lang.String)>(0L, v);
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: java.lang.String toString()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(v, v, "Client address specified");
v = new org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer;
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: void <init>(long,java.lang.String)>(0L, "example.com:1234:1236:participant;1237");
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: java.lang.String toString()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>("example.com:1234:1236:participant;0.0.0.0:1237", v, "Use hostname");
return;
}
public void constructionUnderstandsIpv6LiteralsInServerConfig() throws org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException
{
org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer v;
java.lang.String v;
org.apache.zookeeper.server.quorum.QuorumServerTest v;
v := @this: org.apache.zookeeper.server.quorum.QuorumServerTest;
v = new org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer;
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: void <init>(long,java.lang.String)>(0L, "[::1]:1234:1236:participant");
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: java.lang.String toString()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("[0:0:0:0:0:0:0:1]:1234:1236:participant", v);
return;
}
public void constructionUnderstandsIpv6LiteralsInClientConfig() throws org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException
{
org.apache.zookeeper.server.quorum.QuorumServerTest v;
org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer v;
java.lang.String v, v, v, v, v;
v := @this: org.apache.zookeeper.server.quorum.QuorumServerTest;
v = v.<org.apache.zookeeper.server.quorum.QuorumServerTest: java.lang.String ipv4config>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u0001:participant;[::1]:1237");
v = new org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer;
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: void <init>(long,java.lang.String)>(0L, v);
v = v.<org.apache.zookeeper.server.quorum.QuorumServerTest: java.lang.String ipv4config>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u0001:participant;[0:0:0:0:0:0:0:1]:1237");
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: java.lang.String toString()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
return;
}
public void unbalancedIpv6LiteralsInServerConfigFailToBeParsed()
{
org.apache.zookeeper.server.quorum.QuorumServerTest v;
org.junit.jupiter.api.function.Executable v;
v := @this: org.apache.zookeeper.server.quorum.QuorumServerTest;
v = staticinvoke <org.apache.zookeeper.server.quorum.QuorumServerTest$lambda_unbalancedIpv6LiteralsInServerConfigFailToBeParsed_0__203: org.junit.jupiter.api.function.Executable bootstrap$()>();
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Lorg/apache/zookeeper/server/quorum/QuorumPeerConfig$ConfigException;", v);
return;
}
public void unbalancedIpv6LiteralsInClientConfigFailToBeParsed()
{
org.apache.zookeeper.server.quorum.QuorumServerTest v;
org.junit.jupiter.api.function.Executable v;
v := @this: org.apache.zookeeper.server.quorum.QuorumServerTest;
v = staticinvoke <org.apache.zookeeper.server.quorum.QuorumServerTest$lambda_unbalancedIpv6LiteralsInClientConfigFailToBeParsed_1__204: org.junit.jupiter.api.function.Executable bootstrap$(org.apache.zookeeper.server.quorum.QuorumServerTest)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Lorg/apache/zookeeper/server/quorum/QuorumPeerConfig$ConfigException;", v);
return;
}
public void shouldNotAllowMultipleAddressesWhenMultiAddressFeatureIsDisabled()
{
org.apache.zookeeper.server.quorum.QuorumServerTest v;
org.junit.jupiter.api.function.Executable v;
v := @this: org.apache.zookeeper.server.quorum.QuorumServerTest;
v = staticinvoke <org.apache.zookeeper.server.quorum.QuorumServerTest$lambda_shouldNotAllowMultipleAddressesWhenMultiAddressFeatureIsDisabled_2__205: org.junit.jupiter.api.function.Executable bootstrap$()>();
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Lorg/apache/zookeeper/server/quorum/QuorumPeerConfig$ConfigException;", v);
return;
}
public void shouldAllowMultipleAddressesWhenMultiAddressFeatureIsEnabled() throws org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException
{
org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer v;
java.lang.String v;
org.apache.zookeeper.server.quorum.QuorumServerTest v;
v := @this: org.apache.zookeeper.server.quorum.QuorumServerTest;
staticinvoke <java.lang.System: java.lang.String setProperty(java.lang.String,java.lang.String)>("zookeeper.multiAddress.enabled", "true");
v = new org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer;
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: void <init>(long,java.lang.String)>(0L, "127.0.0.1:1234:1236|127.0.0.1:2234:2236");
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: java.lang.String toString()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>("127.0.0.1:1234:1236|127.0.0.1:2234:2236:participant", v, "MultiAddress parse error");
return;
}
public void testWildcard() throws org.apache.zookeeper.KeeperException$BadArgumentsException
{
java.lang.String[] v;
org.apache.zookeeper.server.quorum.QuorumServerTest v;
int v, v, v, v;
java.lang.String v, v, v, v, v, v;
java.net.InetSocketAddress v, v, v, v, v, v;
org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer v, v;
v := @this: org.apache.zookeeper.server.quorum.QuorumServerTest;
v = newarray (java.lang.String)[4];
v[0] = "127.0.0.1";
v[1] = "[0:0:0:0:0:0:0:1]";
v[2] = "0.0.0.0";
v[3] = "[::]";
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = v;
label:
v = lengthof v;
if v >= v goto label;
v = new org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer;
v = new java.net.InetSocketAddress;
v = v.<org.apache.zookeeper.server.quorum.QuorumServerTest: java.lang.String ipv6n1>;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>(v, 1234);
v = new java.net.InetSocketAddress;
v = v.<org.apache.zookeeper.server.quorum.QuorumServerTest: java.lang.String ipv6n1>;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>(v, 1236);
v = new java.net.InetSocketAddress;
v = v[v];
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>(v, 1237);
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: void <init>(long,java.net.InetSocketAddress,java.net.InetSocketAddress,java.net.InetSocketAddress)>(1L, v, v, v);
v = new org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer;
v = new java.net.InetSocketAddress;
v = v.<org.apache.zookeeper.server.quorum.QuorumServerTest: java.lang.String ipv6n2>;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>(v, 1234);
v = new java.net.InetSocketAddress;
v = v.<org.apache.zookeeper.server.quorum.QuorumServerTest: java.lang.String ipv6n2>;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>(v, 1236);
v = new java.net.InetSocketAddress;
v = v[v];
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>(v, 1237);
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: void <init>(long,java.net.InetSocketAddress,java.net.InetSocketAddress,java.net.InetSocketAddress)>(2L, v, v, v);
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: void checkAddressDuplicate(org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer)>(v);
v = v + 1;
goto label;
label:
v = v + 1;
goto label;
label:
return;
}
public void testDuplicate()
{
org.apache.zookeeper.server.quorum.QuorumServerTest v;
org.junit.jupiter.api.function.Executable v;
v := @this: org.apache.zookeeper.server.quorum.QuorumServerTest;
v = staticinvoke <org.apache.zookeeper.server.quorum.QuorumServerTest$lambda_testDuplicate_3__206: org.junit.jupiter.api.function.Executable bootstrap$(org.apache.zookeeper.server.quorum.QuorumServerTest)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Lorg/apache/zookeeper/KeeperException$BadArgumentsException;", v);
return;
}
}