public class org.apache.zookeeper.server.quorum.QuorumPeerTest extends java.lang.Object
{
private int electionAlg;
private int tickTime;
private int initLimit;
private int syncLimit;
private int connectToLearnerMasterLimit;
public void <init>()
{
org.apache.zookeeper.server.quorum.QuorumPeerTest v;
v := @this: org.apache.zookeeper.server.quorum.QuorumPeerTest;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.zookeeper.server.quorum.QuorumPeerTest: int electionAlg> = 3;
v.<org.apache.zookeeper.server.quorum.QuorumPeerTest: int tickTime> = 2000;
v.<org.apache.zookeeper.server.quorum.QuorumPeerTest: int initLimit> = 3;
v.<org.apache.zookeeper.server.quorum.QuorumPeerTest: int syncLimit> = 3;
v.<org.apache.zookeeper.server.quorum.QuorumPeerTest: int connectToLearnerMasterLimit> = 3;
return;
}
public void testQuorumPeerListendOnSpecifiedClientIP() throws java.io.IOException
{
org.apache.zookeeper.server.quorum.QuorumPeer v, v;
java.net.InetAddress v;
java.lang.Long v, v;
org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType v, v;
java.net.InetSocketAddress v, v, v, v, v, v, v, v;
org.apache.zookeeper.server.quorum.QuorumPeerTest v;
org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer v, v;
java.util.HashMap v;
org.apache.zookeeper.server.ServerCnxnFactory v, v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v;
java.io.File v;
v := @this: org.apache.zookeeper.server.quorum.QuorumPeerTest;
v = staticinvoke <org.apache.zookeeper.test.ClientBase: java.io.File createTmpDir()>();
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = staticinvoke <java.net.InetAddress: java.net.InetAddress getLoopbackAddress()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(1L);
v = new org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer;
v = new java.net.InetSocketAddress;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.net.InetAddress,int)>(v, v);
v = new java.net.InetSocketAddress;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.net.InetAddress,int)>(v, v);
v = new java.net.InetSocketAddress;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.net.InetAddress,int)>(v, v);
v = <org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType PARTICIPANT>;
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: void <init>(long,java.net.InetSocketAddress,java.net.InetSocketAddress,java.net.InetSocketAddress,org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType)>(1L, v, v, v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = new org.apache.zookeeper.server.quorum.QuorumPeer;
v = v.<org.apache.zookeeper.server.quorum.QuorumPeerTest: int electionAlg>;
v = v.<org.apache.zookeeper.server.quorum.QuorumPeerTest: int tickTime>;
v = v.<org.apache.zookeeper.server.quorum.QuorumPeerTest: int initLimit>;
v = v.<org.apache.zookeeper.server.quorum.QuorumPeerTest: int syncLimit>;
v = v.<org.apache.zookeeper.server.quorum.QuorumPeerTest: int connectToLearnerMasterLimit>;
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void <init>(java.util.Map,java.io.File,java.io.File,int,int,long,int,int,int,int)>(v, v, v, v, v, 1L, v, v, v, v);
v = v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.ServerCnxnFactory cnxnFactory>;
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxnFactory: java.net.InetSocketAddress getLocalAddress()>();
v = virtualinvoke v.<java.net.InetSocketAddress: java.lang.String getHostString()>();
v = virtualinvoke v.<java.net.InetAddress: java.lang.String getHostAddress()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void shutdown()>();
interfaceinvoke v.<java.util.Map: void clear()>();
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(1L);
v = new org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer;
v = new java.net.InetSocketAddress;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.net.InetAddress,int)>(v, v);
v = new java.net.InetSocketAddress;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.net.InetAddress,int)>(v, v);
v = new java.net.InetSocketAddress;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.net.InetAddress,int)>(v, v);
v = <org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType PARTICIPANT>;
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer: void <init>(long,java.net.InetSocketAddress,java.net.InetSocketAddress,java.net.InetSocketAddress,org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType)>(1L, v, v, v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = new org.apache.zookeeper.server.quorum.QuorumPeer;
v = v.<org.apache.zookeeper.server.quorum.QuorumPeerTest: int electionAlg>;
v = v.<org.apache.zookeeper.server.quorum.QuorumPeerTest: int tickTime>;
v = v.<org.apache.zookeeper.server.quorum.QuorumPeerTest: int initLimit>;
v = v.<org.apache.zookeeper.server.quorum.QuorumPeerTest: int syncLimit>;
v = v.<org.apache.zookeeper.server.quorum.QuorumPeerTest: int connectToLearnerMasterLimit>;
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void <init>(java.util.Map,java.io.File,java.io.File,int,int,long,int,int,int,int)>(v, v, v, v, v, 1L, v, v, v, v);
v = v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.ServerCnxnFactory cnxnFactory>;
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxnFactory: java.net.InetSocketAddress getLocalAddress()>();
v = virtualinvoke v.<java.net.InetSocketAddress: java.lang.String getHostString()>();
v = virtualinvoke v.<java.net.InetAddress: java.lang.String getHostAddress()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void shutdown()>();
return;
}
public void testLocalPeerIsLeader() throws java.lang.Exception
{
org.apache.zookeeper.server.quorum.QuorumPeer v;
org.apache.zookeeper.server.quorum.Vote v;
org.apache.zookeeper.server.quorum.QuorumPeerTest v;
boolean v;
v := @this: org.apache.zookeeper.server.quorum.QuorumPeerTest;
v = new org.apache.zookeeper.server.quorum.QuorumPeer;
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void <init>()>();
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void setId(long)>(7L);
v = new org.apache.zookeeper.server.quorum.Vote;
specialinvoke v.<org.apache.zookeeper.server.quorum.Vote: void <init>(long,long)>(7L, 0L);
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void setCurrentVote(org.apache.zookeeper.server.quorum.Vote)>(v);
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: boolean isLeader(long)>(7L);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
return;
}
public void testLocalPeerIsNotLeader() throws java.lang.Exception
{
org.apache.zookeeper.server.quorum.QuorumPeer v;
org.apache.zookeeper.server.quorum.Vote v;
org.apache.zookeeper.server.quorum.QuorumPeerTest v;
boolean v;
v := @this: org.apache.zookeeper.server.quorum.QuorumPeerTest;
v = new org.apache.zookeeper.server.quorum.QuorumPeer;
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void <init>()>();
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void setId(long)>(7L);
v = new org.apache.zookeeper.server.quorum.Vote;
specialinvoke v.<org.apache.zookeeper.server.quorum.Vote: void <init>(long,long)>(17L, 0L);
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void setCurrentVote(org.apache.zookeeper.server.quorum.Vote)>(v);
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: boolean isLeader(long)>(7L);
staticinvoke <org.junit.jupiter.api.Assertions: void assertFalse(boolean)>(v);
return;
}
public void testIsNotLeaderBecauseNoVote() throws java.lang.Exception
{
org.apache.zookeeper.server.quorum.QuorumPeer v;
boolean v;
org.apache.zookeeper.server.quorum.QuorumPeerTest v;
v := @this: org.apache.zookeeper.server.quorum.QuorumPeerTest;
v = new org.apache.zookeeper.server.quorum.QuorumPeer;
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void <init>()>();
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void setId(long)>(7L);
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void setCurrentVote(org.apache.zookeeper.server.quorum.Vote)>(null);
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: boolean isLeader(long)>(7L);
staticinvoke <org.junit.jupiter.api.Assertions: void assertFalse(boolean)>(v);
return;
}
}