public class org.apache.zookeeper.server.quorum.LearnerHandlerTest extends org.apache.zookeeper.ZKTestCase { protected static final org.slf4j.Logger LOG; private org.apache.zookeeper.server.quorum.LearnerHandlerTest$MockLearnerHandler learnerHandler; private java.net.Socket sock; private org.apache.zookeeper.server.quorum.Leader leader; private long currentZxid; private org.apache.zookeeper.server.quorum.LearnerHandlerTest$MockZKDatabase db; public void () { org.apache.zookeeper.server.quorum.LearnerHandlerTest v; v := @this: org.apache.zookeeper.server.quorum.LearnerHandlerTest; specialinvoke v.()>(); return; } public void setUp() throws java.lang.Exception { java.net.Socket v; org.apache.zookeeper.server.ZKDatabase v; long v, v; org.apache.zookeeper.server.quorum.LearnerHandlerTest$MockZKDatabase v, v; org.apache.zookeeper.server.quorum.LearnerHandlerTest v; org.apache.zookeeper.server.quorum.LearnerHandlerTest$1 v; java.lang.Long v; org.mockito.stubbing.OngoingStubbing v, v; org.apache.zookeeper.server.quorum.LearnerHandlerTest$MockLearnerHandler v; org.apache.zookeeper.server.quorum.Leader v, v, v; java.lang.Object v, v, v; v := @this: org.apache.zookeeper.server.quorum.LearnerHandlerTest; v = new org.apache.zookeeper.server.quorum.LearnerHandlerTest$MockZKDatabase; specialinvoke v.(org.apache.zookeeper.server.quorum.LearnerHandlerTest,org.apache.zookeeper.server.persistence.FileTxnSnapLog)>(v, null); v. = v; v = staticinvoke (class "Ljava/net/Socket;"); v. = v; v = staticinvoke (class "Lorg/apache/zookeeper/server/quorum/Leader;"); v. = v; v = v.; v = staticinvoke (class "Lorg/apache/zookeeper/server/quorum/LearnerHandler;"); v = staticinvoke (); v = virtualinvoke v.(v, v); v = staticinvoke (v); v = staticinvoke (v); v = new org.apache.zookeeper.server.quorum.LearnerHandlerTest$1; specialinvoke v.(org.apache.zookeeper.server.quorum.LearnerHandlerTest)>(v); interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = v.; interfaceinvoke v.(v); v = new org.apache.zookeeper.server.quorum.LearnerHandlerTest$MockLearnerHandler; v = v.; v = v.; specialinvoke v.(org.apache.zookeeper.server.quorum.LearnerHandlerTest,java.net.Socket,org.apache.zookeeper.server.quorum.Leader)>(v, v, v); v. = v; return; } org.apache.zookeeper.server.quorum.Leader$Proposal createProposal(long) { org.apache.zookeeper.server.quorum.QuorumPacket v, v, v; org.apache.zookeeper.server.quorum.Leader$Proposal v; long v; org.apache.zookeeper.server.quorum.LearnerHandlerTest v; v := @this: org.apache.zookeeper.server.quorum.LearnerHandlerTest; v := @parameter: long; v = new org.apache.zookeeper.server.quorum.Leader$Proposal; specialinvoke v.()>(); v = new org.apache.zookeeper.server.quorum.QuorumPacket; specialinvoke v.()>(); v. = v; v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(2); return v; } public void queuedPacketMatches(long[]) { java.util.Iterator v; long v, v; org.apache.zookeeper.server.quorum.LearnerHandlerTest$MockLearnerHandler v; org.apache.zookeeper.server.quorum.LearnerHandlerTest v; long[] v; int v, v, v; java.lang.Object v; java.util.Queue v; boolean v; v := @this: org.apache.zookeeper.server.quorum.LearnerHandlerTest; v := @parameter: long[]; v = 0; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); if v != 2 goto label; v = v; v = v + 1; v = v[v]; v = virtualinvoke v.(); virtualinvoke v.(v, v); goto label; label: return; } void reset() { org.apache.zookeeper.server.quorum.LearnerHandlerTest$MockLearnerHandler v, v, v; java.util.Queue v; org.apache.zookeeper.server.quorum.LearnerHandlerTest v; v := @this: org.apache.zookeeper.server.quorum.LearnerHandlerTest; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(); v = v.; v. = 0; v = v.; virtualinvoke v.(1); return; } public void assertOpType(int, long, long) { long v, v, v, v; org.apache.zookeeper.server.quorum.LearnerHandlerTest$MockLearnerHandler v; org.apache.zookeeper.server.quorum.LearnerHandlerTest v; int v, v, v; java.lang.Object v, v; java.util.Queue v; boolean v; v := @this: org.apache.zookeeper.server.quorum.LearnerHandlerTest; v := @parameter: int; v := @parameter: long; v := @parameter: long; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); if v <= 0 goto label; v = 1; goto label; label: v = 0; label: staticinvoke (v); v = interfaceinvoke v.(); v = virtualinvoke v.(); staticinvoke (v, v); v = interfaceinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v, v); v = v.; virtualinvoke v.(v, v); return; } void assertZxidEquals(long, long) { long v, v; java.lang.String v, v, v; org.apache.zookeeper.server.quorum.LearnerHandlerTest v; v := @this: org.apache.zookeeper.server.quorum.LearnerHandlerTest; v := @parameter: long; v := @parameter: long; v = staticinvoke (v); v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Expected 0x\u but was 0x\u0001"); staticinvoke (v, v, v); return; } public void testEmptyCommittedLog() throws java.lang.Exception { org.apache.zookeeper.server.quorum.LearnerHandlerTest$MockZKDatabase v, v, v, v, v, v, v, v, v, v, v; boolean v, v, v; org.apache.zookeeper.server.quorum.LearnerHandlerTest$MockLearnerHandler v, v, v, v, v; java.util.Queue v, v; long v, v, v, v; org.apache.zookeeper.server.quorum.LearnerHandlerTest v; int v, v; java.util.LinkedList v, v, v; org.apache.zookeeper.server.quorum.Leader v, v, v; v := @this: org.apache.zookeeper.server.quorum.LearnerHandlerTest; v = v.; v. = 1L; v = v.; v = v.; virtualinvoke v.(); v = v.; v = v.; v = virtualinvoke v.(3L, v); staticinvoke (v); v = v.; v = v.; v = v.; v = v.; virtualinvoke v.(14, v, v); virtualinvoke v.(); v = v.; v. = 1L; v = v.; v = v.; virtualinvoke v.(); v = v.; v = v.; v = virtualinvoke v.(1L, v); staticinvoke (v); v = v.; v = v.; v = v.; v = v.; virtualinvoke v.(13, v, v); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (1, v); virtualinvoke v.(); v = v.; virtualinvoke v.(-1.0); v = v.; v. = 1L; v = v.; v = v.; virtualinvoke v.(); v = v.; v = v.; v = virtualinvoke v.(0L, v); staticinvoke (v); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (0, v); virtualinvoke v.(); return; } public void testCommittedLog() throws java.lang.Exception { org.apache.zookeeper.server.quorum.LearnerHandlerTest$MockZKDatabase v, v, v, v, v, v, v; boolean v, v, v; org.apache.zookeeper.server.quorum.LearnerHandlerTest$MockLearnerHandler v, v, v, v, v, v; org.apache.zookeeper.server.quorum.Leader$Proposal v, v, v; java.util.Queue v, v, v; long v, v; org.apache.zookeeper.server.quorum.LearnerHandlerTest v; long[] v, v; int v, v, v; java.util.LinkedList v, v, v; org.apache.zookeeper.server.quorum.Leader v, v, v; v := @this: org.apache.zookeeper.server.quorum.LearnerHandlerTest; v = v.; v. = 6L; v = v.; v = v.; v = virtualinvoke v.(2L); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(3L); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(5L); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(4L, v); staticinvoke (v); virtualinvoke v.(14, 3L, 5L); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (3, v); v = newarray (long)[1]; v[0] = 5L; virtualinvoke v.(v); virtualinvoke v.(); v = v.; v = v.; v = virtualinvoke v.(2L, v); staticinvoke (v); v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(13, v, v); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (5, v); v = newarray (long)[2]; v[0] = 3L; v[1] = 5L; virtualinvoke v.(v); virtualinvoke v.(); v = v.; virtualinvoke v.(-1.0); v = v.; v = v.; v = virtualinvoke v.(1L, v); staticinvoke (v); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (0, v); virtualinvoke v.(); return; } public void testTxnLog() throws java.lang.Exception { org.apache.zookeeper.server.quorum.LearnerHandlerTest$MockZKDatabase v, v, v, v, v, v, v, v, v, v, v, v, v, v; boolean v, v; org.apache.zookeeper.server.quorum.LearnerHandlerTest$MockLearnerHandler v, v, v, v; org.apache.zookeeper.server.quorum.Leader$Proposal v, v, v, v, v, v, v, v, v, v; java.util.Queue v, v; long v, v, v; org.apache.zookeeper.server.quorum.LearnerHandlerTest v; long[] v, v; int v, v; java.util.LinkedList v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.server.quorum.Leader v, v; v := @this: org.apache.zookeeper.server.quorum.LearnerHandlerTest; v = v.; v = v.; v = virtualinvoke v.(2L); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(3L); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(5L); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(6L); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(7L); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(8L); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(9L); virtualinvoke v.(v); v = v.; v. = 9L; v = v.; v = v.; v = virtualinvoke v.(6L); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(7L); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(8L); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(4L, v); staticinvoke (v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(14, 3L, v); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (9, v); v = newarray (long)[4]; v[0] = 5L; v[1] = 6L; v[2] = 7L; v[3] = 8L; virtualinvoke v.(v); virtualinvoke v.(); v = v.; v = v.; v = virtualinvoke v.(3L, v); staticinvoke (v); v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(13, v, v); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (9, v); v = newarray (long)[4]; v[0] = 5L; v[1] = 6L; v[2] = 7L; v[3] = 8L; virtualinvoke v.(v); virtualinvoke v.(); return; } public void testTxnLogProposalIteratorClosure() throws java.lang.Exception { org.apache.zookeeper.server.ZKDatabase v; org.apache.zookeeper.server.quorum.LearnerHandlerTest$MockZKDatabase v, v, v, v; org.apache.zookeeper.server.quorum.LearnerHandlerTest v; org.apache.zookeeper.server.quorum.LearnerHandlerTest$2 v; java.util.LinkedList v, v; boolean v; org.mockito.stubbing.OngoingStubbing v; org.apache.zookeeper.server.quorum.LearnerHandlerTest$MockLearnerHandler v; org.apache.zookeeper.server.quorum.Leader v, v; org.apache.zookeeper.server.quorum.Leader$Proposal v, v; v := @this: org.apache.zookeeper.server.quorum.LearnerHandlerTest; v = new org.apache.zookeeper.server.quorum.LearnerHandlerTest$2; specialinvoke v.(org.apache.zookeeper.server.quorum.LearnerHandlerTest,org.apache.zookeeper.server.persistence.FileTxnSnapLog)>(v, null); v. = v; v = v.; v. = 7L; v = v.; v = v.; v = virtualinvoke v.(2L); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(3L); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = v.; interfaceinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(4L, v); staticinvoke (v, "Couldn\'t identify snapshot transfer!"); virtualinvoke v.(); return; } public void testTxnLogOnly() throws java.lang.Exception { org.apache.zookeeper.server.quorum.LearnerHandlerTest$MockZKDatabase v, v, v, v, v, v, v, v, v, v; boolean v, v, v; org.apache.zookeeper.server.quorum.LearnerHandlerTest$MockLearnerHandler v, v, v, v, v, v; org.apache.zookeeper.server.quorum.Leader$Proposal v, v, v, v, v, v; java.util.Queue v, v, v; long v, v, v; org.apache.zookeeper.server.quorum.LearnerHandlerTest v; long[] v, v; int v, v, v; java.util.LinkedList v, v, v, v, v, v; org.apache.zookeeper.server.quorum.Leader v, v, v; v := @this: org.apache.zookeeper.server.quorum.LearnerHandlerTest; v = v.; v. = 7L; v = v.; v = v.; v = virtualinvoke v.(2L); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(3L); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(5L); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(6L); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(7L); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(8L); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(4L, v); staticinvoke (v); v = v.; v = v.; virtualinvoke v.(14, 3L, v); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (7, v); v = newarray (long)[3]; v[0] = 5L; v[1] = 6L; v[2] = 7L; virtualinvoke v.(v); virtualinvoke v.(); v = v.; v = v.; v = virtualinvoke v.(2L, v); staticinvoke (v); v = v.; v = v.; v = v.; v = v.; virtualinvoke v.(13, v, v); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (9, v); v = newarray (long)[4]; v[0] = 3L; v[1] = 5L; v[2] = 6L; v[3] = 7L; virtualinvoke v.(v); virtualinvoke v.(); v = v.; v = v.; v = virtualinvoke v.(1L, v); staticinvoke (v); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (0, v); virtualinvoke v.(); return; } long getZxid(long, long) { long v, v, v; org.apache.zookeeper.server.quorum.LearnerHandlerTest v; v := @this: org.apache.zookeeper.server.quorum.LearnerHandlerTest; v := @parameter: long; v := @parameter: long; v = staticinvoke (v, v); return v; } public void testTxnLogWithNegativeZxid() throws java.lang.Exception { org.apache.zookeeper.server.quorum.LearnerHandlerTest$MockZKDatabase v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.server.quorum.Leader$Proposal v, v, v, v, v, v, v, v, v, v; long 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; org.apache.zookeeper.server.quorum.LearnerHandlerTest v; boolean v, v; org.apache.zookeeper.server.quorum.LearnerHandlerTest$MockLearnerHandler v, v, v, v; java.util.Queue v, v; long[] v, v; int v, v; java.util.LinkedList v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.server.quorum.Leader v, v; v := @this: org.apache.zookeeper.server.quorum.LearnerHandlerTest; v = v.; v = v.; v = virtualinvoke v.(15L, 2L); v = virtualinvoke v.(v); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(15L, 3L); v = virtualinvoke v.(v); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(15L, 5L); v = virtualinvoke v.(v); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(15L, 6L); v = virtualinvoke v.(v); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(15L, 7L); v = virtualinvoke v.(v); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(15L, 8L); v = virtualinvoke v.(v); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(15L, 9L); v = virtualinvoke v.(v); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(15L, 9L); v. = v; v = v.; v = v.; v = virtualinvoke v.(15L, 6L); v = virtualinvoke v.(v); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(15L, 7L); v = virtualinvoke v.(v); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(15L, 8L); v = virtualinvoke v.(v); virtualinvoke v.(v); v = virtualinvoke v.(15L, 4L); v = v.; v = v.; v = virtualinvoke v.(v, v); staticinvoke (v); v = virtualinvoke v.(15L, 3L); v = v.; v = virtualinvoke v.(); virtualinvoke v.(14, v, v); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (9, v); v = newarray (long)[4]; v = virtualinvoke v.(15L, 5L); v[0] = v; v = virtualinvoke v.(15L, 6L); v[1] = v; v = virtualinvoke v.(15L, 7L); v[2] = v; v = virtualinvoke v.(15L, 8L); v[3] = v; virtualinvoke v.(v); virtualinvoke v.(); v = virtualinvoke v.(15L, 3L); v = v.; v = v.; v = virtualinvoke v.(v, v); staticinvoke (v); v = v.; v = virtualinvoke v.(); v = v.