public class org.apache.zookeeper.server.quorum.LeaderWithObserverTest extends java.lang.Object
{
org.apache.zookeeper.server.quorum.QuorumPeer peer;
org.apache.zookeeper.server.quorum.Leader leader;
java.io.File tmpDir;
long participantId;
long observerId;
public void <init>()
{
org.apache.zookeeper.server.quorum.LeaderWithObserverTest v;
v := @this: org.apache.zookeeper.server.quorum.LeaderWithObserverTest;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void setUp() throws java.lang.Exception
{
org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v, v;
org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v;
long v, v;
org.apache.zookeeper.server.quorum.LeaderWithObserverTest v;
java.lang.Long v;
org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType v;
java.util.Map v;
int v, v, v, v;
java.net.InetSocketAddress v, v, v;
java.io.File v, v, v;
org.apache.zookeeper.server.quorum.Leader v, v;
org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer v;
v := @this: org.apache.zookeeper.server.quorum.LeaderWithObserverTest;
v = staticinvoke <org.apache.zookeeper.test.ClientBase: java.io.File createTmpDir()>();
v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: java.io.File tmpDir> = v;
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: java.io.File tmpDir>;
v = staticinvoke <org.apache.zookeeper.server.quorum.ZabUtils: org.apache.zookeeper.server.quorum.QuorumPeer createQuorumPeer(java.io.File)>(v);
v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.QuorumPeer peer> = v;
v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: long participantId> = 1L;
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.QuorumPeer peer>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.flexible.QuorumVerifier getQuorumVerifier()>();
v = interfaceinvoke v.<org.apache.zookeeper.server.quorum.flexible.QuorumVerifier: java.util.Map getAllMembers()>();
v = interfaceinvoke v.<java.util.Map: int size()>();
v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: long observerId> = v;
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: java.io.File tmpDir>;
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.QuorumPeer peer>;
v = staticinvoke <org.apache.zookeeper.server.quorum.ZabUtils: org.apache.zookeeper.server.quorum.Leader createLeader(java.io.File,org.apache.zookeeper.server.quorum.QuorumPeer)>(v, v);
v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader> = v;
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.QuorumPeer peer>;
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.Leader leader> = v;
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: long observerId>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = new org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer;
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: long observerId>;
v = new java.net.InetSocketAddress;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>("127.0.0.1", v);
v = new java.net.InetSocketAddress;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>("127.0.0.1", v);
v = new java.net.InetSocketAddress;
v = staticinvoke <org.apache.zookeeper.PortAssignment: int unique()>();
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>("127.0.0.1", v);
v = <org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType: org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType OBSERVER>;
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)>(v, v, v, v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.QuorumPeer peer>;
v.<org.apache.zookeeper.server.quorum.QuorumPeer: int tickTime> = 1;
return;
}
public void tearDown()
{
org.apache.zookeeper.server.quorum.Leader v;
org.apache.zookeeper.server.quorum.LeaderWithObserverTest v;
java.io.File v;
v := @this: org.apache.zookeeper.server.quorum.LeaderWithObserverTest;
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.Leader: void shutdown(java.lang.String)>("end of test");
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: java.io.File tmpDir>;
virtualinvoke v.<java.io.File: boolean delete()>();
return;
}
public void testGetEpochToPropose() throws java.lang.Exception
{
org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v, v;
boolean v, v, v, v;
java.util.Set v, v, v, v;
java.lang.Exception v;
long v, v, v, v, v, v;
org.apache.zookeeper.server.quorum.LeaderWithObserverTest v;
int v, v, v, v;
org.apache.zookeeper.server.quorum.Leader v, v, v, v, v, v, v, v, v, v, v;
java.lang.InterruptedException v, v;
v := @this: org.apache.zookeeper.server.quorum.LeaderWithObserverTest;
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.QuorumPeer peer>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: void setAcceptedEpoch(long)>(5L);
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.Leader: java.util.Set connectingFollowers>;
v = interfaceinvoke v.<java.util.Set: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int,java.lang.String)>(0, v, "Unexpected vote in connectingFollowers");
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.Leader: boolean waitingForNewEpoch>;
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
label:
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.QuorumPeer peer>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: long getMyId()>();
virtualinvoke v.<org.apache.zookeeper.server.quorum.Leader: long getEpochToPropose(long,long)>(v, 5L);
label:
goto label;
label:
v := @caughtexception;
label:
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.Leader: java.util.Set connectingFollowers>;
v = interfaceinvoke v.<java.util.Set: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int,java.lang.String)>(1, v, "Unexpected vote in connectingFollowers");
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.QuorumPeer peer>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: long getAcceptedEpoch()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(long,long,java.lang.String)>(5L, v, "Leader shouldn\'t set new epoch until quorum of participants is in connectingFollowers");
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.Leader: boolean waitingForNewEpoch>;
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
label:
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: long observerId>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.Leader: long getEpochToPropose(long,long)>(v, 5L);
label:
goto label;
label:
v := @caughtexception;
label:
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.Leader: java.util.Set connectingFollowers>;
v = interfaceinvoke v.<java.util.Set: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int,java.lang.String)>(1, v, "Unexpected vote in connectingFollowers");
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.QuorumPeer peer>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: long getAcceptedEpoch()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(long,long,java.lang.String)>(5L, v, "Leader shouldn\'t set new epoch after observer asks for epoch");
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.Leader: boolean waitingForNewEpoch>;
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
label:
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: long participantId>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.Leader: long getEpochToPropose(long,long)>(v, 5L);
label:
goto label;
label:
v := @caughtexception;
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("Timed out in getEpochToPropose");
label:
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.Leader: java.util.Set connectingFollowers>;
v = interfaceinvoke v.<java.util.Set: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int,java.lang.String)>(2, v, "Unexpected vote in connectingFollowers");
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.QuorumPeer peer>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: long getAcceptedEpoch()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(long,long,java.lang.String)>(6L, v, "Leader should record next epoch");
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.Leader: boolean waitingForNewEpoch>;
staticinvoke <org.junit.jupiter.api.Assertions: void assertFalse(boolean)>(v);
return;
catch java.lang.InterruptedException from label to label with label;
catch java.lang.InterruptedException from label to label with label;
catch java.lang.Exception from label to label with label;
}
public void testWaitForEpochAck() throws java.lang.Exception
{
org.apache.zookeeper.server.quorum.QuorumPeer v, v;
boolean v, v, v, v;
org.apache.zookeeper.server.quorum.StateSummary v, v, v, v;
java.util.Set v, v, v, v;
java.lang.Exception v;
long v, v, v, v, v;
org.apache.zookeeper.server.quorum.LeaderWithObserverTest v;
int v, v, v, v;
org.apache.zookeeper.server.quorum.LeaderZooKeeperServer v;
org.apache.zookeeper.server.quorum.Leader v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.InterruptedException v, v;
v := @this: org.apache.zookeeper.server.quorum.LeaderWithObserverTest;
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = new org.apache.zookeeper.server.quorum.StateSummary;
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.Leader: org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: long getCurrentEpoch()>();
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.Leader: org.apache.zookeeper.server.quorum.LeaderZooKeeperServer zk>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.LeaderZooKeeperServer: long getLastProcessedZxid()>();
specialinvoke v.<org.apache.zookeeper.server.quorum.StateSummary: void <init>(long,long)>(v, v);
v.<org.apache.zookeeper.server.quorum.Leader: org.apache.zookeeper.server.quorum.StateSummary leaderStateSummary> = v;
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.Leader: java.util.Set electingFollowers>;
v = interfaceinvoke v.<java.util.Set: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int,java.lang.String)>(0, v, "Unexpected vote in electingFollowers");
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.Leader: boolean electionFinished>;
staticinvoke <org.junit.jupiter.api.Assertions: void assertFalse(boolean)>(v);
label:
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.QuorumPeer peer>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: long getMyId()>();
v = new org.apache.zookeeper.server.quorum.StateSummary;
specialinvoke v.<org.apache.zookeeper.server.quorum.StateSummary: void <init>(long,long)>(0L, 0L);
virtualinvoke v.<org.apache.zookeeper.server.quorum.Leader: void waitForEpochAck(long,org.apache.zookeeper.server.quorum.StateSummary)>(v, v);
label:
goto label;
label:
v := @caughtexception;
label:
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.Leader: java.util.Set electingFollowers>;
v = interfaceinvoke v.<java.util.Set: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int,java.lang.String)>(1, v, "Unexpected vote in electingFollowers");
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.Leader: boolean electionFinished>;
staticinvoke <org.junit.jupiter.api.Assertions: void assertFalse(boolean)>(v);
label:
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: long observerId>;
v = new org.apache.zookeeper.server.quorum.StateSummary;
specialinvoke v.<org.apache.zookeeper.server.quorum.StateSummary: void <init>(long,long)>(0L, 0L);
virtualinvoke v.<org.apache.zookeeper.server.quorum.Leader: void waitForEpochAck(long,org.apache.zookeeper.server.quorum.StateSummary)>(v, v);
label:
goto label;
label:
v := @caughtexception;
label:
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.Leader: java.util.Set electingFollowers>;
v = interfaceinvoke v.<java.util.Set: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int,java.lang.String)>(1, v, "Unexpected vote in electingFollowers");
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.Leader: boolean electionFinished>;
staticinvoke <org.junit.jupiter.api.Assertions: void assertFalse(boolean)>(v);
label:
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: long participantId>;
v = new org.apache.zookeeper.server.quorum.StateSummary;
specialinvoke v.<org.apache.zookeeper.server.quorum.StateSummary: void <init>(long,long)>(0L, 0L);
virtualinvoke v.<org.apache.zookeeper.server.quorum.Leader: void waitForEpochAck(long,org.apache.zookeeper.server.quorum.StateSummary)>(v, v);
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.Leader: java.util.Set electingFollowers>;
v = interfaceinvoke v.<java.util.Set: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int,java.lang.String)>(2, v, "Unexpected vote in electingFollowers");
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.Leader: boolean electionFinished>;
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
label:
goto label;
label:
v := @caughtexception;
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("Timed out in waitForEpochAck");
label:
return;
catch java.lang.InterruptedException from label to label with label;
catch java.lang.InterruptedException from label to label with label;
catch java.lang.Exception from label to label with label;
}
public void testWaitForNewLeaderAck() throws java.lang.Exception
{
org.apache.zookeeper.server.quorum.QuorumPeer v, v;
org.apache.zookeeper.server.quorum.QuorumPacket v;
boolean v, v, v, v;
java.lang.Exception v;
org.apache.zookeeper.server.quorum.Leader$Proposal v, v, v;
org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v;
long v, v, v, v;
org.apache.zookeeper.server.quorum.LeaderWithObserverTest v;
java.util.ArrayList v;
java.util.HashSet v;
int v, v, v, v;
org.apache.zookeeper.server.quorum.LeaderZooKeeperServer v;
org.apache.zookeeper.server.quorum.Leader v, v, v, v, v, v, v, v, v, v, v;
java.lang.InterruptedException v, v;
java.lang.Object v;
v := @this: org.apache.zookeeper.server.quorum.LeaderWithObserverTest;
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.Leader: org.apache.zookeeper.server.quorum.LeaderZooKeeperServer zk>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.LeaderZooKeeperServer: long getZxid()>();
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.Leader: org.apache.zookeeper.server.quorum.Leader$Proposal newLeaderProposal>;
v = new org.apache.zookeeper.server.quorum.QuorumPacket;
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPacket: void <init>(int,long,byte[],java.util.List)>(0, v, null, null);
v.<org.apache.zookeeper.server.quorum.Leader$Proposal: org.apache.zookeeper.server.quorum.QuorumPacket packet> = v;
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.Leader: org.apache.zookeeper.server.quorum.Leader$Proposal newLeaderProposal>;
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.QuorumPeer peer>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: org.apache.zookeeper.server.quorum.flexible.QuorumVerifier getQuorumVerifier()>();
virtualinvoke v.<org.apache.zookeeper.server.quorum.Leader$Proposal: void addQuorumVerifier(org.apache.zookeeper.server.quorum.flexible.QuorumVerifier)>(v);
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.Leader: org.apache.zookeeper.server.quorum.Leader$Proposal newLeaderProposal>;
v = v.<org.apache.zookeeper.server.quorum.Leader$Proposal: java.util.ArrayList qvAcksetPairs>;
v = virtualinvoke v.<java.util.ArrayList: java.lang.Object get(int)>(0);
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.SyncedLearnerTracker$QuorumVerifierAcksetPair: java.util.HashSet getAckset()>();
v = interfaceinvoke v.<java.util.Set: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int,java.lang.String)>(0, v, "Unexpected vote in ackSet");
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.Leader: boolean quorumFormed>;
staticinvoke <org.junit.jupiter.api.Assertions: void assertFalse(boolean)>(v);
label:
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.QuorumPeer peer>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: long getMyId()>();
virtualinvoke v.<org.apache.zookeeper.server.quorum.Leader: void waitForNewLeaderAck(long,long)>(v, v);
label:
goto label;
label:
v := @caughtexception;
label:
v = interfaceinvoke v.<java.util.Set: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int,java.lang.String)>(1, v, "Unexpected vote in ackSet");
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.Leader: boolean quorumFormed>;
staticinvoke <org.junit.jupiter.api.Assertions: void assertFalse(boolean)>(v);
label:
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: long observerId>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.Leader: void waitForNewLeaderAck(long,long)>(v, v);
label:
goto label;
label:
v := @caughtexception;
label:
v = interfaceinvoke v.<java.util.Set: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int,java.lang.String)>(1, v, "Unexpected vote in ackSet");
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.Leader: boolean quorumFormed>;
staticinvoke <org.junit.jupiter.api.Assertions: void assertFalse(boolean)>(v);
label:
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: long participantId>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.Leader: void waitForNewLeaderAck(long,long)>(v, v);
v = interfaceinvoke v.<java.util.Set: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int,java.lang.String)>(2, v, "Unexpected vote in ackSet");
v = v.<org.apache.zookeeper.server.quorum.LeaderWithObserverTest: org.apache.zookeeper.server.quorum.Leader leader>;
v = v.<org.apache.zookeeper.server.quorum.Leader: boolean quorumFormed>;
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
label:
goto label;
label:
v := @caughtexception;
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("Timed out in waitForEpochAck");
label:
return;
catch java.lang.InterruptedException from label to label with label;
catch java.lang.InterruptedException from label to label with label;
catch java.lang.Exception from label to label with label;
}
}