public class org.apache.zookeeper.test.FollowerResyncConcurrencyTest extends org.apache.zookeeper.ZKTestCase { private static final org.slf4j.Logger LOG; public static final long CONNECTION_TIMEOUT; private java.util.concurrent.atomic.AtomicInteger counter; private java.util.concurrent.atomic.AtomicInteger errors; private java.util.concurrent.atomic.AtomicInteger pending; public void () { java.util.concurrent.atomic.AtomicInteger v, v, v; org.apache.zookeeper.test.FollowerResyncConcurrencyTest v; v := @this: org.apache.zookeeper.test.FollowerResyncConcurrencyTest; specialinvoke v.()>(); v = new java.util.concurrent.atomic.AtomicInteger; specialinvoke v.(int)>(0); v. = v; v = new java.util.concurrent.atomic.AtomicInteger; specialinvoke v.(int)>(0); v. = v; v = new java.util.concurrent.atomic.AtomicInteger; specialinvoke v.(int)>(0); v. = v; return; } public void setUp() throws java.lang.Exception { java.util.concurrent.atomic.AtomicInteger v, v, v; org.apache.zookeeper.test.FollowerResyncConcurrencyTest v; v := @this: org.apache.zookeeper.test.FollowerResyncConcurrencyTest; v = v.; virtualinvoke v.(0); v = v.; virtualinvoke v.(0); v = v.; virtualinvoke v.(0); return; } public void tearDown() throws java.lang.Exception { org.slf4j.Logger v; java.util.concurrent.atomic.AtomicInteger v; int v; java.lang.Integer v; org.apache.zookeeper.test.FollowerResyncConcurrencyTest v; v := @this: org.apache.zookeeper.test.FollowerResyncConcurrencyTest; v = ; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("Error count {}", v); return; } public void testLaggingFollowerResyncsUnderNewEpoch() throws java.lang.Exception { org.apache.zookeeper.CreateMode v; org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v; org.apache.zookeeper.test.QuorumUtil$PeerStruct v, v, v, v, v, v, v, v, v, v, v; long v, v, v, v; org.apache.zookeeper.test.ClientBase$CountdownWatcher v, v, v; java.util.ArrayList v; org.apache.zookeeper.test.FollowerResyncConcurrencyTest v; java.lang.String v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.test.DisconnectableZooKeeper v, v, v, v; org.apache.zookeeper.data.Stat v, v, v; boolean v, v, v, v, v, v, v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.slf4j.Logger v, v, v, v; org.apache.zookeeper.test.QuorumUtil v; v := @this: org.apache.zookeeper.test.FollowerResyncConcurrencyTest; v = new org.apache.zookeeper.test.ClientBase$CountdownWatcher; specialinvoke v.()>(); v = new org.apache.zookeeper.test.ClientBase$CountdownWatcher; specialinvoke v.()>(); v = new org.apache.zookeeper.test.ClientBase$CountdownWatcher; specialinvoke v.()>(); v = new org.apache.zookeeper.test.QuorumUtil; specialinvoke v.(int)>(1); virtualinvoke v.(); virtualinvoke v.(1); virtualinvoke v.(2); v = virtualinvoke v.(1); v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("127.0.0.1:\u0001"); v = ; v = staticinvoke (v, v); staticinvoke (v, "Waiting for server up"); v = virtualinvoke v.(2); v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("127.0.0.1:\u0001"); v = ; v = staticinvoke (v, v); staticinvoke (v, "Waiting for server up"); v = virtualinvoke v.(1); v = v.; v = virtualinvoke v.(); v = staticinvoke (v, v); v = ; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("zk has session id 0x{}", v); v = ; v = ; virtualinvoke v.("/resyncundernewepoch", null, v, v); virtualinvoke v.(); virtualinvoke v.(1); virtualinvoke v.(2); v = virtualinvoke v.(1); v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("127.0.0.1:\u0001"); v = ; v = staticinvoke (v, v); staticinvoke (v, "Waiting for server down"); v = virtualinvoke v.(2); v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("127.0.0.1:\u0001"); v = ; v = staticinvoke (v, v); staticinvoke (v, "Waiting for server down"); virtualinvoke v.(1); virtualinvoke v.(2); v = virtualinvoke v.(1); v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("127.0.0.1:\u0001"); v = ; v = staticinvoke (v, v); staticinvoke (v, "Waiting for server up"); v = virtualinvoke v.(2); v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("127.0.0.1:\u0001"); v = ; v = staticinvoke (v, v); staticinvoke (v, "Waiting for server up"); virtualinvoke v.(3); v = virtualinvoke v.(3); v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("127.0.0.1:\u0001"); v = ; v = staticinvoke (v, v); staticinvoke (v, "Waiting for server up"); v = virtualinvoke v.(1); v = v.; v = virtualinvoke v.(); v = staticinvoke (v, v); v = ; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("zk has session id 0x{}", v); v = virtualinvoke v.("/resyncundernewepoch", 0); staticinvoke (v, "zk has data"); v = virtualinvoke v.(2); v = v.; v = virtualinvoke v.(); v = staticinvoke (v, v); v = ; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("zk has session id 0x{}", v); v = virtualinvoke v.("/resyncundernewepoch", 0); staticinvoke (v, "zk has data"); v = virtualinvoke v.(3); v = v.; v = virtualinvoke v.(); v = staticinvoke (v, v); v = ; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("zk has session id 0x{}", v); v = virtualinvoke v.("/resyncundernewepoch", 0); staticinvoke (v, "zk has data"); virtualinvoke v.(); virtualinvoke v.(); virtualinvoke v.(); virtualinvoke v.(); return; } public void testResyncBySnapThenDiffAfterFollowerCrashes() throws java.lang.Throwable { org.apache.zookeeper.test.FollowerResyncConcurrencyTest v; v := @this: org.apache.zookeeper.test.FollowerResyncConcurrencyTest; virtualinvoke v.(0); return; } public void testResyncByTxnlogThenDiffAfterFollowerCrashes() throws java.lang.Throwable { org.apache.zookeeper.test.FollowerResyncConcurrencyTest v; v := @this: org.apache.zookeeper.test.FollowerResyncConcurrencyTest; virtualinvoke v.(1); return; } public void followerResyncCrashTest(boolean) throws java.lang.Throwable { org.apache.zookeeper.CreateMode v, v, v, v; org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v, v, v, v; byte[] v; java.lang.Integer v, v, v, v, v; org.apache.zookeeper.test.QuorumUtil$PeerStruct v, v, v, v, v, v, v; byte v, v; java.lang.Thread v; org.apache.zookeeper.server.ZKDatabase v, v; long v, v, v; org.apache.zookeeper.test.ClientBase$CountdownWatcher v, v, v; java.util.ArrayList v, v, v, v; org.apache.zookeeper.test.FollowerResyncConcurrencyTest v; java.lang.String v, v, v; org.apache.zookeeper.test.DisconnectableZooKeeper v, v, v; org.apache.zookeeper.server.ZooKeeperServer v, v; org.apache.zookeeper.test.FollowerResyncConcurrencyTest$1 v; java.util.concurrent.atomic.AtomicInteger v, v; boolean v, v, v, v, v; int v, v, v, v, v, v, v, v, v; org.slf4j.Logger v, v, v, v, v, v, v, v, v, v, v; java.util.concurrent.Semaphore v; org.apache.zookeeper.AsyncCallback$StringCallback v, v; java.util.concurrent.TimeUnit v; org.apache.zookeeper.server.quorum.Leader v, v; org.apache.zookeeper.test.QuorumUtil v; v := @this: org.apache.zookeeper.test.FollowerResyncConcurrencyTest; v := @parameter: boolean; v = new java.util.concurrent.Semaphore; specialinvoke v.(int)>(0); v = new org.apache.zookeeper.test.QuorumUtil; specialinvoke v.(int)>(1); virtualinvoke v.(); v = new org.apache.zookeeper.test.ClientBase$CountdownWatcher; specialinvoke v.()>(); v = new org.apache.zookeeper.test.ClientBase$CountdownWatcher; specialinvoke v.()>(); v = new org.apache.zookeeper.test.ClientBase$CountdownWatcher; specialinvoke v.()>(); v = 1; label: v = virtualinvoke v.(v); v = v.; v = v.; if v != null goto label; v = v + 1; goto label; label: v = virtualinvoke v.(v); v = v.; v = v.; staticinvoke (v); if v == 0 goto label; v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(1000.0); goto label; label: v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(-1.0); label: if v != 1 goto label; v = 2; goto label; label: v = 1; label: v = v; v = ; v = staticinvoke (v); interfaceinvoke v.("Connecting to follower: {}", v); virtualinvoke v.(v); v = virtualinvoke v.(3); v = v.; v = virtualinvoke v.(); v = staticinvoke (v, v); v = ; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("zk has session id 0x{}", v); v = ; v = ; virtualinvoke v.("/mybar", null, v, v); virtualinvoke v.(v); v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = staticinvoke (v, v); v = ; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("zk has session id 0x{}", v); v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = staticinvoke (v, v); v = ; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("zk has session id 0x{}", v); v = newarray (byte)[0]; v = ; v = ; virtualinvoke v.("/first", v, v, v); v = new java.lang.Thread; v = new org.apache.zookeeper.test.FollowerResyncConcurrencyTest$1; specialinvoke v.(org.apache.zookeeper.test.FollowerResyncConcurrencyTest,org.apache.zookeeper.ZooKeeper,java.util.concurrent.Semaphore)>(v, v, v); specialinvoke v.(java.lang.Runnable)>(v); v = 0; label: if v >= 13000 goto label; v = ; v = ; v = staticinvoke (v, v); virtualinvoke v.("/mybar", null, v, v, v, null); v = v.; virtualinvoke v.(); if v != 5000 goto label; virtualinvoke v.(v); v = ; interfaceinvoke v.("Shutting down s1"); label: if v != 12000 goto label; virtualinvoke v.(); v = ; v = staticinvoke (v); interfaceinvoke v.("Restarting follower: {}", v); virtualinvoke v.(v); staticinvoke (300L); v = ; v = staticinvoke (v); interfaceinvoke v.("Shutdown follower: {}", v); virtualinvoke v.(v); staticinvoke (300L); v = ; v = staticinvoke (v); interfaceinvoke v.("Restarting follower: {}", v); virtualinvoke v.(v); v = ; v = staticinvoke (v); interfaceinvoke v.("Setting up server: {}", v); label: v = v % 1000; if v != 0 goto label; staticinvoke (1000L); label: v = v % 50; if v != 0 goto label; v = ; v = ; v = staticinvoke (v, v); virtualinvoke v.("/newbaz", null, v, v, v, null); v = v.; virtualinvoke v.(); label: v = v + 1; goto label; label: v = ; v = ; v = virtualinvoke v.(v, v); if v != 0 goto label; v = ; interfaceinvoke v.("Did not aquire semaphore fast enough"); label: v = ; virtualinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = ; interfaceinvoke v.("mytestfooThread is still alive"); label: v = specialinvoke v.(60); staticinvoke (v); v = specialinvoke v.(v, v, 10); staticinvoke (v); specialinvoke v.(v, v, v); virtualinvoke v.(); virtualinvoke v.(); virtualinvoke v.(); virtualinvoke v.(); return; } public void testResyncByDiffAfterFollowerCrashes() throws java.io.IOException, java.lang.InterruptedException, org.apache.zookeeper.KeeperException, java.lang.Throwable { org.apache.zookeeper.CreateMode v, v, v, v; org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v, v; byte[] v; java.lang.Integer v, v; org.apache.zookeeper.test.QuorumUtil$PeerStruct v, v, v, v, v; byte v, v; java.lang.Thread v; long v, v, v; org.apache.zookeeper.test.ClientBase$CountdownWatcher v, v, v; java.util.ArrayList v, v, v, v; org.apache.zookeeper.test.FollowerResyncConcurrencyTest v; java.lang.String v, v, v; org.apache.zookeeper.test.DisconnectableZooKeeper v, v, v; org.apache.zookeeper.test.FollowerResyncConcurrencyTest$2 v; java.util.concurrent.atomic.AtomicInteger v, v; boolean v, v, v, v; java.util.concurrent.atomic.AtomicBoolean v; int v, v, v, v, v, v, v, v; org.slf4j.Logger v, v, v, v, v, v, v, v; java.util.concurrent.Semaphore v; org.apache.zookeeper.AsyncCallback$StringCallback v, v; java.util.concurrent.TimeUnit v; org.apache.zookeeper.server.quorum.Leader v, v; org.apache.zookeeper.test.QuorumUtil v; v := @this: org.apache.zookeeper.test.FollowerResyncConcurrencyTest; v = new java.util.concurrent.Semaphore; specialinvoke v.(int)>(0); v = new org.apache.zookeeper.test.QuorumUtil; specialinvoke v.(int)>(1); virtualinvoke v.(); v = new org.apache.zookeeper.test.ClientBase$CountdownWatcher; specialinvoke v.()>(); v = new org.apache.zookeeper.test.ClientBase$CountdownWatcher; specialinvoke v.()>(); v = new org.apache.zookeeper.test.ClientBase$CountdownWatcher; specialinvoke v.()>(); v = 1; label: v = virtualinvoke v.(v); v = v.; v = v.; if v != null goto label; v = v + 1; goto label; label: v = virtualinvoke v.(v); v = v.; v = v.; staticinvoke (v); if v != 1 goto label; v = 2; goto label; label: v = 1; label: v = v; v = ; v = staticinvoke (v); interfaceinvoke v.("Connecting to follower: {}", v); v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = staticinvoke (v, v); v = ; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("zk has session id 0x{}", v); v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = staticinvoke (v, v); v = ; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("zk has session id 0x{}", v); v = virtualinvoke v.(3); v = v.; v = virtualinvoke v.(); v = staticinvoke (v, v); v = ; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("zk has session id 0x{}", v); v = newarray (byte)[0]; v = ; v = ; virtualinvoke v.("/first", v, v, v); v = ; v = ; virtualinvoke v.("/mybar", null, v, v); v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.(boolean)>(0); v = new java.lang.Thread; v = new org.apache.zookeeper.test.FollowerResyncConcurrencyTest$2; specialinvoke v.(org.apache.zookeeper.test.FollowerResyncConcurrencyTest,java.util.concurrent.atomic.AtomicBoolean,org.apache.zookeeper.ZooKeeper,java.util.concurrent.Semaphore)>(v, v, v, v); specialinvoke v.(java.lang.Runnable)>(v); virtualinvoke v.(); v = 0; label: if v >= 5000 goto label; v = ; v = ; v = staticinvoke (v, v); virtualinvoke v.("/mybar", null, v, v, v, null); v = v.; virtualinvoke v.(); if v != 1000 goto label; virtualinvoke v.(v); staticinvoke (1100L); v = ; interfaceinvoke v.("Shutting down s1"); label: if v == 1100 goto label; if v == 1150 goto label; if v != 1200 goto label; label: staticinvoke (1000L); if v != 1200 goto label; virtualinvoke v.(v); virtualinvoke v.(1); virtualinvoke v.(v); v = ; v = staticinvoke (v); interfaceinvoke v.("Setting up server: {}", v); label: if v < 1000 goto label; v = v % 2; if v != 0 goto label; v = ; v = ; v = staticinvoke (v, v); virtualinvoke v.("/newbaz", null, v, v, v, null); v = v.; virtualinvoke v.(); label: if v == 1050 goto label; if v == 1100 goto label; if v != 1150 goto label; label: staticinvoke (1000L); label: v = v + 1; goto label; label: v = ; v = ; v = virtualinvoke v.(v, v); if v != 0 goto label; v = ; interfaceinvoke v.("Did not aquire semaphore fast enough"); label: v = ; virtualinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = ; interfaceinvoke v.("mytestfooThread is still alive"); label: v = specialinvoke v.(60); staticinvoke (v); v = specialinvoke v.(v, v, 10); staticinvoke (v); specialinvoke v.(v, v, v); virtualinvoke v.(); virtualinvoke v.(); virtualinvoke v.(); virtualinvoke v.(); return; } private static org.apache.zookeeper.test.DisconnectableZooKeeper createClient(int, org.apache.zookeeper.test.ClientBase$CountdownWatcher) throws java.io.IOException, java.util.concurrent.TimeoutException, java.lang.InterruptedException { org.apache.zookeeper.test.DisconnectableZooKeeper v; int v, v; long v; java.lang.String v; org.apache.zookeeper.test.ClientBase$CountdownWatcher v; v := @parameter: int; v := @parameter: org.apache.zookeeper.test.ClientBase$CountdownWatcher; v = new org.apache.zookeeper.test.DisconnectableZooKeeper; v = dynamicinvoke "makeConcatWithConstants" (v) ("127.0.0.1:\u0001"); v = ; specialinvoke v.(java.lang.String,int,org.apache.zookeeper.Watcher)>(v, v, v); v = ; virtualinvoke v.(v); return v; } private boolean waitForPendingRequests(int) throws java.lang.InterruptedException { org.slf4j.Logger v, v; java.lang.Integer v, v; org.apache.zookeeper.test.FollowerResyncConcurrencyTest v; java.util.concurrent.atomic.AtomicInteger v, v, v; int v, v, v, v, v; v := @this: org.apache.zookeeper.test.FollowerResyncConcurrencyTest; v := @parameter: int; v = ; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("Wait for pending requests: {}", v); v = 0; label: if v >= v goto label; staticinvoke (1000L); v = v.; v = virtualinvoke v.(); if v != 0 goto label; return 1; label: v = v + 1; goto label; label: v = ; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("Timeout waiting for pending requests: {}", v); return 0; } private boolean waitForSync(org.apache.zookeeper.test.QuorumUtil, int, int) throws java.lang.InterruptedException { org.apache.zookeeper.server.quorum.QuorumPeer v, v, v; java.lang.Object[] v; org.apache.zookeeper.server.ZKDatabase v, v, v; long v, v, v; org.apache.zookeeper.test.FollowerResyncConcurrencyTest v; org.apache.zookeeper.test.QuorumUtil$PeerStruct v, v, v; byte v, v, v; int v, v, v; java.lang.String v, v, v; org.slf4j.Logger v, v; org.apache.zookeeper.server.ZooKeeperServer v, v, v; org.apache.zookeeper.test.QuorumUtil v; v := @this: org.apache.zookeeper.test.FollowerResyncConcurrencyTest; v := @parameter: org.apache.zookeeper.test.QuorumUtil; v := @parameter: int; v := @parameter: int; v = ; interfaceinvoke v.("Wait for server to sync"); if v != 1 goto label; v = 2; goto label; label: v = 1; label: v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(3); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = 0L; v = 0L; v = 0L; v = 0; label: if v >= v goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v cmp v; if v != 0 goto label; v = v cmp v; if v != 0 goto label; return 1; label: staticinvoke (1000L); v = v + 1; goto label; label: v = ; v = newarray (java.lang.Object)[3]; v = staticinvoke (v); v[0] = v; v = staticinvoke (v); v[1] = v; v = staticinvoke (v); v[2] = v; interfaceinvoke v.("Timeout waiting for zxid to sync: leader 0x{} clean 0x{} restarted 0x{}", v); return 0; } private static org.apache.zookeeper.TestableZooKeeper createTestableClient(java.lang.String) throws java.io.IOException, java.util.concurrent.TimeoutException, java.lang.InterruptedException { java.lang.String v; org.apache.zookeeper.TestableZooKeeper v; org.apache.zookeeper.test.ClientBase$CountdownWatcher v; v := @parameter: java.lang.String; v = new org.apache.zookeeper.test.ClientBase$CountdownWatcher; specialinvoke v.()>(); v = staticinvoke (v, v); return v; } private static org.apache.zookeeper.TestableZooKeeper createTestableClient(org.apache.zookeeper.test.ClientBase$CountdownWatcher, java.lang.String) throws java.io.IOException, java.util.concurrent.TimeoutException, java.lang.InterruptedException { org.apache.zookeeper.TestableZooKeeper v; int v; long v; java.lang.String v; org.apache.zookeeper.test.ClientBase$CountdownWatcher v; v := @parameter: org.apache.zookeeper.test.ClientBase$CountdownWatcher; v := @parameter: java.lang.String; v = new org.apache.zookeeper.TestableZooKeeper; v = ; specialinvoke v.(java.lang.String,int,org.apache.zookeeper.Watcher)>(v, v, v); v = ; virtualinvoke v.(v); return v; } private void verifyState(org.apache.zookeeper.test.QuorumUtil, int, org.apache.zookeeper.server.quorum.Leader) { org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v, v, v, v, v; org.apache.zookeeper.test.QuorumUtil$PeerStruct v, v, v, v, v, v, v, v; byte v, v, v; java.util.Set v, v, v, v; org.apache.zookeeper.server.quorum.Follower v; org.apache.zookeeper.server.ZKDatabase v, v, v, v, v, v; long v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.test.FollowerResyncConcurrencyTest v; org.apache.zookeeper.data.StatPersisted v, v, v, v; java.lang.String v, v, v, v, v, v, v, v; org.apache.zookeeper.server.ZooKeeperServer v, v, v, v, v, v, v; org.apache.zookeeper.server.DataTree v, v, v, v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.server.DataNode v, v, v, v; java.util.Collection v, v; int v, v, v, v, v, v, v; org.slf4j.Logger v, v, v, v, v, v; java.util.Iterator v, v, v, v, v, v; org.apache.zookeeper.server.quorum.Leader v; java.lang.Object v, v, v, v, v, v; org.apache.zookeeper.test.QuorumUtil v; v := @this: org.apache.zookeeper.test.FollowerResyncConcurrencyTest; v := @parameter: org.apache.zookeeper.test.QuorumUtil; v := @parameter: int; v := @parameter: org.apache.zookeeper.server.quorum.Leader; v = ; interfaceinvoke v.("Verifying state"); v = virtualinvoke v.(v); v = v.; v = v.; if v == null goto label; v = 1; goto label; label: v = 0; label: staticinvoke (v, "Not following"); v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v >> 32; v = virtualinvoke v.(); v = v >> 32; v = v cmp v; if v != 0 goto label; v = 1; goto label; label: v = 0; label: v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Zxid: \u0001Current epoch: \u0001"); staticinvoke