class org.apache.zookeeper.server.quorum.Zab1_0Test$10 extends java.lang.Object implements org.apache.zookeeper.server.quorum.Zab1_0Test$LeaderConversation
{
final org.apache.zookeeper.server.quorum.Zab1_0Test this$0;
void <init>(org.apache.zookeeper.server.quorum.Zab1_0Test)
{
org.apache.zookeeper.server.quorum.Zab1_0Test v;
org.apache.zookeeper.server.quorum.Zab1_0Test$10 v;
v := @this: org.apache.zookeeper.server.quorum.Zab1_0Test$10;
v := @parameter: org.apache.zookeeper.server.quorum.Zab1_0Test;
v.<org.apache.zookeeper.server.quorum.Zab1_0Test$10: org.apache.zookeeper.server.quorum.Zab1_0Test this$0> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void converseWithLeader(org.apache.jute.InputArchive, org.apache.jute.OutputArchive, org.apache.zookeeper.server.quorum.Leader) throws java.io.IOException, java.lang.InterruptedException
{
org.apache.zookeeper.server.quorum.QuorumPeer v, v, v;
byte[] v, v;
org.apache.jute.InputArchive v;
long v, v, v;
java.nio.ByteBuffer v, v;
org.apache.zookeeper.server.quorum.QuorumPacket v;
int v, v, v, v, v, v;
org.apache.jute.OutputArchive v;
org.apache.zookeeper.server.quorum.Zab1_0Test$10 v;
org.apache.zookeeper.server.quorum.LearnerInfo v;
org.apache.zookeeper.server.quorum.Leader v;
v := @this: org.apache.zookeeper.server.quorum.Zab1_0Test$10;
v := @parameter: org.apache.jute.InputArchive;
v := @parameter: org.apache.jute.OutputArchive;
v := @parameter: org.apache.zookeeper.server.quorum.Leader;
v = new org.apache.zookeeper.server.quorum.LearnerInfo;
specialinvoke v.<org.apache.zookeeper.server.quorum.LearnerInfo: void <init>(long,int,long)>(1L, 65536, 0L);
v = newarray (byte)[20];
v = staticinvoke <java.nio.ByteBuffer: java.nio.ByteBuffer wrap(byte[])>(v);
staticinvoke <org.apache.zookeeper.server.ByteBufferOutputStream: void record2ByteBuffer(org.apache.jute.Record,java.nio.ByteBuffer)>(v, v);
v = new org.apache.zookeeper.server.quorum.QuorumPacket;
specialinvoke v.<org.apache.zookeeper.server.quorum.QuorumPacket: void <init>(int,long,byte[],java.util.List)>(11, 0L, v, null);
interfaceinvoke v.<org.apache.jute.OutputArchive: void writeRecord(org.apache.jute.Record,java.lang.String)>(v, null);
staticinvoke <org.apache.zookeeper.server.quorum.Zab1_0Test: void readPacketSkippingPing(org.apache.jute.InputArchive,org.apache.zookeeper.server.quorum.QuorumPacket)>(v, v);
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPacket: int getType()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(17, v);
v = staticinvoke <org.apache.zookeeper.server.util.ZxidUtils: long makeZxid(long,long)>(1L, 0L);
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPacket: long getZxid()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(long,long)>(v, v);
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPacket: byte[] getData()>();
v = staticinvoke <java.nio.ByteBuffer: java.nio.ByteBuffer wrap(byte[])>(v);
v = virtualinvoke v.<java.nio.ByteBuffer: int getInt()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, 65536);
v = v.<org.apache.zookeeper.server.quorum.Leader: org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: int getInitLimit()>();
v = v.<org.apache.zookeeper.server.quorum.Leader: org.apache.zookeeper.server.quorum.QuorumPeer self>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.QuorumPeer: int getTickTime()>();
v = v * v;
v = v + 5000;
staticinvoke <java.lang.Thread: void sleep(long)>(v);
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()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(long,long)>(0L, v);
return;
}
}