public class org.apache.zookeeper.server.CreateTTLTest extends org.apache.zookeeper.test.ClientBase
{
private org.apache.zookeeper.TestableZooKeeper zk;
private static final java.util.Collection disabledTests;
public void <init>()
{
org.apache.zookeeper.server.CreateTTLTest v;
v := @this: org.apache.zookeeper.server.CreateTTLTest;
specialinvoke v.<org.apache.zookeeper.test.ClientBase: void <init>()>();
return;
}
public void setUp() throws java.lang.Exception
{
org.apache.zookeeper.server.CreateTTLTest v;
v := @this: org.apache.zookeeper.server.CreateTTLTest;
return;
}
public void setUp(org.junit.jupiter.api.TestInfo) throws java.lang.Exception
{
java.util.Collection v;
org.apache.zookeeper.server.CreateTTLTest v;
org.junit.jupiter.api.TestInfo v;
org.apache.zookeeper.TestableZooKeeper v;
java.util.Optional v;
java.lang.Object v;
java.lang.String v, v;
boolean v;
v := @this: org.apache.zookeeper.server.CreateTTLTest;
v := @parameter: org.junit.jupiter.api.TestInfo;
v = <org.apache.zookeeper.server.CreateTTLTest: java.util.Collection disabledTests>;
v = interfaceinvoke v.<org.junit.jupiter.api.TestInfo: java.util.Optional getTestMethod()>();
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
v = virtualinvoke v.<java.lang.reflect.Method: java.lang.String getName()>();
v = interfaceinvoke v.<java.util.Collection: boolean contains(java.lang.Object)>(v);
if v == 0 goto label;
v = "false";
goto label;
label:
v = "true";
label:
staticinvoke <java.lang.System: java.lang.String setProperty(java.lang.String,java.lang.String)>("zookeeper.extendedTypesEnabled", v);
specialinvoke v.<org.apache.zookeeper.test.ClientBase: void setUpWithServerId(int)>(254);
v = virtualinvoke v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk> = v;
return;
}
public void tearDown() throws java.lang.Exception
{
org.apache.zookeeper.server.CreateTTLTest v;
org.apache.zookeeper.TestableZooKeeper v;
v := @this: org.apache.zookeeper.server.CreateTTLTest;
staticinvoke <java.lang.System: java.lang.String clearProperty(java.lang.String)>("zookeeper.extendedTypesEnabled");
specialinvoke v.<org.apache.zookeeper.test.ClientBase: void tearDown()>();
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: void close()>();
return;
}
public void testCreate() throws org.apache.zookeeper.KeeperException, java.lang.InterruptedException
{
org.apache.zookeeper.CreateMode v;
byte[] v;
org.apache.zookeeper.server.ContainerManager v;
org.apache.zookeeper.server.CreateTTLTest v;
long v;
org.apache.zookeeper.data.Stat v, v, v;
java.util.ArrayList v;
java.util.concurrent.atomic.AtomicLong v;
org.apache.zookeeper.TestableZooKeeper v, v, v;
v := @this: org.apache.zookeeper.server.CreateTTLTest;
v = new org.apache.zookeeper.data.Stat;
specialinvoke v.<org.apache.zookeeper.data.Stat: void <init>()>();
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = newarray (byte)[0];
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode PERSISTENT_WITH_TTL>;
virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: java.lang.String create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode,org.apache.zookeeper.data.Stat,long)>("/foo", v, v, v, v, 100L);
v = virtualinvoke v.<org.apache.zookeeper.data.Stat: long getEphemeralOwner()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(long,long)>(0L, v);
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>(long)>(0L);
v = specialinvoke v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.server.ContainerManager newContainerManager(java.util.concurrent.atomic.AtomicLong)>(v);
virtualinvoke v.<org.apache.zookeeper.server.ContainerManager: void checkContainers()>();
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>("/foo", 0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object,java.lang.String)>(v, "Ttl node should not have been deleted yet");
virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: void set(long)>(1000L);
virtualinvoke v.<org.apache.zookeeper.server.ContainerManager: void checkContainers()>();
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>("/foo", 0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNull(java.lang.Object,java.lang.String)>(v, "Ttl node should have been deleted");
return;
}
public void testBadTTLs() throws java.lang.InterruptedException, org.apache.zookeeper.KeeperException
{
org.apache.zookeeper.CreateMode v, v;
byte[] v, v;
long v, v;
org.apache.zookeeper.data.Stat v, v;
java.util.ArrayList v, v;
org.apache.zookeeper.KeeperException$Code v, v;
int v, v, v, v, v, v;
org.apache.zookeeper.server.CreateTTLTest v;
org.apache.zookeeper.server.EphemeralType v;
org.apache.zookeeper.proto.RequestHeader v;
org.apache.zookeeper.TestableZooKeeper v, v, v, v;
org.apache.zookeeper.proto.ReplyHeader v, v;
org.apache.zookeeper.proto.CreateTTLRequest v, v;
org.apache.zookeeper.proto.CreateResponse v, v;
v := @this: org.apache.zookeeper.server.CreateTTLTest;
v = new org.apache.zookeeper.proto.RequestHeader;
specialinvoke v.<org.apache.zookeeper.proto.RequestHeader: void <init>(int,int)>(1, 21);
v = new org.apache.zookeeper.proto.CreateTTLRequest;
v = newarray (byte)[0];
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode PERSISTENT_WITH_TTL>;
v = virtualinvoke v.<org.apache.zookeeper.CreateMode: int toFlag()>();
specialinvoke v.<org.apache.zookeeper.proto.CreateTTLRequest: void <init>(java.lang.String,byte[],java.util.List,int,long)>("/bad_ttl", v, v, v, -100L);
v = new org.apache.zookeeper.proto.CreateResponse;
specialinvoke v.<org.apache.zookeeper.proto.CreateResponse: void <init>()>();
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.proto.ReplyHeader submitRequest(org.apache.zookeeper.proto.RequestHeader,org.apache.jute.Record,org.apache.jute.Record,org.apache.zookeeper.ZooKeeper$WatchRegistration)>(v, v, v, null);
v = virtualinvoke v.<org.apache.zookeeper.proto.ReplyHeader: int getErr()>();
v = <org.apache.zookeeper.KeeperException$Code: org.apache.zookeeper.KeeperException$Code BADARGUMENTS>;
v = virtualinvoke v.<org.apache.zookeeper.KeeperException$Code: int intValue()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int,java.lang.String)>(v, v, "An invalid CreateTTLRequest should throw BadArguments");
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>("/bad_ttl", 0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNull(java.lang.Object,java.lang.String)>(v, "An invalid CreateTTLRequest should not result in znode creation");
v = new org.apache.zookeeper.proto.CreateTTLRequest;
v = newarray (byte)[0];
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode PERSISTENT_WITH_TTL>;
v = virtualinvoke v.<org.apache.zookeeper.CreateMode: int toFlag()>();
v = <org.apache.zookeeper.server.EphemeralType: org.apache.zookeeper.server.EphemeralType TTL>;
v = virtualinvoke v.<org.apache.zookeeper.server.EphemeralType: long maxValue()>();
v = v + 1L;
specialinvoke v.<org.apache.zookeeper.proto.CreateTTLRequest: void <init>(java.lang.String,byte[],java.util.List,int,long)>("/bad_ttl", v, v, v, v);
v = new org.apache.zookeeper.proto.CreateResponse;
specialinvoke v.<org.apache.zookeeper.proto.CreateResponse: void <init>()>();
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.proto.ReplyHeader submitRequest(org.apache.zookeeper.proto.RequestHeader,org.apache.jute.Record,org.apache.jute.Record,org.apache.zookeeper.ZooKeeper$WatchRegistration)>(v, v, v, null);
v = virtualinvoke v.<org.apache.zookeeper.proto.ReplyHeader: int getErr()>();
v = <org.apache.zookeeper.KeeperException$Code: org.apache.zookeeper.KeeperException$Code BADARGUMENTS>;
v = virtualinvoke v.<org.apache.zookeeper.KeeperException$Code: int intValue()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int,java.lang.String)>(v, v, "An invalid CreateTTLRequest should throw BadArguments");
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>("/bad_ttl", 0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNull(java.lang.Object,java.lang.String)>(v, "An invalid CreateTTLRequest should not result in znode creation");
return;
}
public void testMaxTTLs() throws java.lang.InterruptedException, org.apache.zookeeper.KeeperException
{
org.apache.zookeeper.CreateMode v;
byte[] v;
long v;
org.apache.zookeeper.data.Stat v;
java.util.ArrayList v;
org.apache.zookeeper.KeeperException$Code v;
int v, v, v;
org.apache.zookeeper.server.CreateTTLTest v;
org.apache.zookeeper.server.EphemeralType v;
org.apache.zookeeper.proto.RequestHeader v;
org.apache.zookeeper.TestableZooKeeper v, v;
org.apache.zookeeper.proto.ReplyHeader v;
org.apache.zookeeper.proto.CreateTTLRequest v;
org.apache.zookeeper.proto.CreateResponse v;
v := @this: org.apache.zookeeper.server.CreateTTLTest;
v = new org.apache.zookeeper.proto.RequestHeader;
specialinvoke v.<org.apache.zookeeper.proto.RequestHeader: void <init>(int,int)>(1, 21);
v = new org.apache.zookeeper.proto.CreateTTLRequest;
v = newarray (byte)[0];
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode PERSISTENT_WITH_TTL>;
v = virtualinvoke v.<org.apache.zookeeper.CreateMode: int toFlag()>();
v = <org.apache.zookeeper.server.EphemeralType: org.apache.zookeeper.server.EphemeralType TTL>;
v = virtualinvoke v.<org.apache.zookeeper.server.EphemeralType: long maxValue()>();
specialinvoke v.<org.apache.zookeeper.proto.CreateTTLRequest: void <init>(java.lang.String,byte[],java.util.List,int,long)>("/bad_ttl", v, v, v, v);
v = new org.apache.zookeeper.proto.CreateResponse;
specialinvoke v.<org.apache.zookeeper.proto.CreateResponse: void <init>()>();
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.proto.ReplyHeader submitRequest(org.apache.zookeeper.proto.RequestHeader,org.apache.jute.Record,org.apache.jute.Record,org.apache.zookeeper.ZooKeeper$WatchRegistration)>(v, v, v, null);
v = virtualinvoke v.<org.apache.zookeeper.proto.ReplyHeader: int getErr()>();
v = <org.apache.zookeeper.KeeperException$Code: org.apache.zookeeper.KeeperException$Code OK>;
v = virtualinvoke v.<org.apache.zookeeper.KeeperException$Code: int intValue()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int,java.lang.String)>(v, v, "EphemeralType.getMaxTTL() should succeed");
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>("/bad_ttl", 0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object,java.lang.String)>(v, "Node should exist");
return;
}
public void testCreateSequential() throws org.apache.zookeeper.KeeperException, java.lang.InterruptedException
{
org.apache.zookeeper.CreateMode v;
byte[] v;
org.apache.zookeeper.server.ContainerManager v;
org.apache.zookeeper.server.CreateTTLTest v;
long v;
org.apache.zookeeper.data.Stat v, v, v;
java.util.ArrayList v;
java.util.concurrent.atomic.AtomicLong v;
org.apache.zookeeper.TestableZooKeeper v, v, v;
java.lang.String v;
v := @this: org.apache.zookeeper.server.CreateTTLTest;
v = new org.apache.zookeeper.data.Stat;
specialinvoke v.<org.apache.zookeeper.data.Stat: void <init>()>();
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = newarray (byte)[0];
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode PERSISTENT_SEQUENTIAL_WITH_TTL>;
v = virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: java.lang.String create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode,org.apache.zookeeper.data.Stat,long)>("/foo", v, v, v, v, 100L);
v = virtualinvoke v.<org.apache.zookeeper.data.Stat: long getEphemeralOwner()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(long,long)>(0L, v);
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>(long)>(0L);
v = specialinvoke v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.server.ContainerManager newContainerManager(java.util.concurrent.atomic.AtomicLong)>(v);
virtualinvoke v.<org.apache.zookeeper.server.ContainerManager: void checkContainers()>();
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>(v, 0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object,java.lang.String)>(v, "Ttl node should not have been deleted yet");
virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: void set(long)>(1000L);
virtualinvoke v.<org.apache.zookeeper.server.ContainerManager: void checkContainers()>();
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>(v, 0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNull(java.lang.Object,java.lang.String)>(v, "Ttl node should have been deleted");
return;
}
public void testCreateAsync() throws org.apache.zookeeper.KeeperException, java.lang.InterruptedException
{
org.apache.zookeeper.CreateMode v;
byte[] v;
org.apache.zookeeper.server.ContainerManager v;
org.apache.zookeeper.server.CreateTTLTest v;
org.apache.zookeeper.AsyncCallback$Create2Callback v;
org.apache.zookeeper.data.Stat v, v;
java.util.ArrayList v;
java.util.concurrent.atomic.AtomicLong v;
org.apache.zookeeper.TestableZooKeeper v, v, v;
v := @this: org.apache.zookeeper.server.CreateTTLTest;
v = staticinvoke <org.apache.zookeeper.server.CreateTTLTest$lambda_testCreateAsync_0__150: org.apache.zookeeper.AsyncCallback$Create2Callback bootstrap$()>();
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = newarray (byte)[0];
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode PERSISTENT_WITH_TTL>;
virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: void create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode,org.apache.zookeeper.AsyncCallback$Create2Callback,java.lang.Object,long)>("/foo", v, v, v, v, null, 100L);
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>(long)>(0L);
v = specialinvoke v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.server.ContainerManager newContainerManager(java.util.concurrent.atomic.AtomicLong)>(v);
virtualinvoke v.<org.apache.zookeeper.server.ContainerManager: void checkContainers()>();
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>("/foo", 0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object,java.lang.String)>(v, "Ttl node should not have been deleted yet");
virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: void set(long)>(1000L);
virtualinvoke v.<org.apache.zookeeper.server.ContainerManager: void checkContainers()>();
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>("/foo", 0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNull(java.lang.Object,java.lang.String)>(v, "Ttl node should have been deleted");
return;
}
public void testModifying() throws org.apache.zookeeper.KeeperException, java.lang.InterruptedException
{
org.apache.zookeeper.CreateMode v;
byte[] v, v;
long v;
org.apache.zookeeper.data.Stat v, v, v, v;
java.util.ArrayList v;
int v, v, v;
org.apache.zookeeper.server.ContainerManager v;
org.apache.zookeeper.server.CreateTTLTest v;
java.util.concurrent.atomic.AtomicLong v;
org.apache.zookeeper.TestableZooKeeper v, v, v, v, v;
v := @this: org.apache.zookeeper.server.CreateTTLTest;
v = new org.apache.zookeeper.data.Stat;
specialinvoke v.<org.apache.zookeeper.data.Stat: void <init>()>();
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = newarray (byte)[0];
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode PERSISTENT_WITH_TTL>;
virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: java.lang.String create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode,org.apache.zookeeper.data.Stat,long)>("/foo", v, v, v, v, 100L);
v = virtualinvoke v.<org.apache.zookeeper.data.Stat: long getEphemeralOwner()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(long,long)>(0L, v);
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>(long)>(0L);
v = specialinvoke v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.server.ContainerManager newContainerManager(java.util.concurrent.atomic.AtomicLong)>(v);
virtualinvoke v.<org.apache.zookeeper.server.ContainerManager: void checkContainers()>();
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>("/foo", 0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object,java.lang.String)>(v, "Ttl node should not have been deleted yet");
v = 0;
label:
if v >= 10 goto label;
virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: void set(long)>(50L);
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = v + 1;
v = newarray (byte)[v];
v = (int) -1;
virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.data.Stat setData(java.lang.String,byte[],int)>("/foo", v, v);
virtualinvoke v.<org.apache.zookeeper.server.ContainerManager: void checkContainers()>();
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>("/foo", 0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object,java.lang.String)>(v, "Ttl node should not have been deleted yet");
v = v + 1;
goto label;
label:
virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: void set(long)>(200L);
virtualinvoke v.<org.apache.zookeeper.server.ContainerManager: void checkContainers()>();
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>("/foo", 0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNull(java.lang.Object,java.lang.String)>(v, "Ttl node should have been deleted");
return;
}
public void testMulti() throws org.apache.zookeeper.KeeperException, java.lang.InterruptedException
{
org.apache.zookeeper.CreateMode v, v, v, v, v;
byte[] v, v, v, v, v;
org.apache.zookeeper.CreateOptions v, v;
long v, v;
java.util.ArrayList v, v, v;
java.lang.String v, v;
org.apache.zookeeper.server.CreateTTLTest v;
java.util.concurrent.atomic.AtomicLong v;
org.apache.zookeeper.TestableZooKeeper v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.zookeeper.CreateOptions$Builder v, v, v, v;
org.apache.zookeeper.data.Stat v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.zookeeper.Op v, v, v, v, v;
java.util.List v, v, v, v;
org.apache.zookeeper.Op[] v;
org.apache.zookeeper.server.ContainerManager v;
java.lang.Object v, v;
v := @this: org.apache.zookeeper.server.CreateTTLTest;
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode PERSISTENT_WITH_TTL>;
v = staticinvoke <org.apache.zookeeper.CreateOptions: org.apache.zookeeper.CreateOptions$Builder newBuilder(java.util.List,org.apache.zookeeper.CreateMode)>(v, v);
v = virtualinvoke v.<org.apache.zookeeper.CreateOptions$Builder: org.apache.zookeeper.CreateOptions$Builder withTtl(long)>(100L);
v = virtualinvoke v.<org.apache.zookeeper.CreateOptions$Builder: org.apache.zookeeper.CreateOptions build()>();
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode PERSISTENT_SEQUENTIAL_WITH_TTL>;
v = staticinvoke <org.apache.zookeeper.CreateOptions: org.apache.zookeeper.CreateOptions$Builder newBuilder(java.util.List,org.apache.zookeeper.CreateMode)>(v, v);
v = virtualinvoke v.<org.apache.zookeeper.CreateOptions$Builder: org.apache.zookeeper.CreateOptions$Builder withTtl(long)>(200L);
v = virtualinvoke v.<org.apache.zookeeper.CreateOptions$Builder: org.apache.zookeeper.CreateOptions build()>();
v = newarray (byte)[0];
v = virtualinvoke v.<org.apache.zookeeper.CreateOptions: java.util.List getAcl()>();
v = virtualinvoke v.<org.apache.zookeeper.CreateOptions: org.apache.zookeeper.CreateMode getCreateMode()>();
v = virtualinvoke v.<org.apache.zookeeper.CreateOptions: long getTtl()>();
v = staticinvoke <org.apache.zookeeper.Op: org.apache.zookeeper.Op create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode,long)>("/a", v, v, v, v);
v = newarray (byte)[0];
v = staticinvoke <org.apache.zookeeper.Op: org.apache.zookeeper.Op create(java.lang.String,byte[],org.apache.zookeeper.CreateOptions)>("/a2", v, v);
v = newarray (byte)[0];
v = virtualinvoke v.<org.apache.zookeeper.CreateOptions: java.util.List getAcl()>();
v = virtualinvoke v.<org.apache.zookeeper.CreateOptions: org.apache.zookeeper.CreateMode getCreateMode()>();
v = virtualinvoke v.<org.apache.zookeeper.CreateOptions: long getTtl()>();
v = staticinvoke <org.apache.zookeeper.Op: org.apache.zookeeper.Op create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode,long)>("/b", v, v, v, v);
v = newarray (byte)[0];
v = staticinvoke <org.apache.zookeeper.Op: org.apache.zookeeper.Op create(java.lang.String,byte[],org.apache.zookeeper.CreateOptions)>("/b2", v, v);
v = newarray (byte)[0];
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode PERSISTENT>;
v = staticinvoke <org.apache.zookeeper.Op: org.apache.zookeeper.Op create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode)>("/c", v, v, v);
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = newarray (org.apache.zookeeper.Op)[5];
v[0] = v;
v[1] = v;
v[2] = v;
v[3] = v;
v[4] = v;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
v = virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: java.util.List multi(java.lang.Iterable)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(2);
v = virtualinvoke v.<org.apache.zookeeper.OpResult$CreateResult: java.lang.String getPath()>();
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(3);
v = virtualinvoke v.<org.apache.zookeeper.OpResult$CreateResult: java.lang.String getPath()>();
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>(long)>(0L);
v = specialinvoke v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.server.ContainerManager newContainerManager(java.util.concurrent.atomic.AtomicLong)>(v);
virtualinvoke v.<org.apache.zookeeper.server.ContainerManager: void checkContainers()>();
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>("/a", 0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object,java.lang.String)>(v, "node should not have been deleted yet");
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>("/a2", 0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object,java.lang.String)>(v, "node should not have been deleted yet");
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>(v, 0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object,java.lang.String)>(v, "node should not have been deleted yet");
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>(v, 0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object,java.lang.String)>(v, "node should not have been deleted yet");
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>("/c", 0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object,java.lang.String)>(v, "node should never be deleted");
virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: void set(long)>(110L);
virtualinvoke v.<org.apache.zookeeper.server.ContainerManager: void checkContainers()>();
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>("/a", 0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNull(java.lang.Object,java.lang.String)>(v, "node should have been deleted");
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>("/a2", 0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNull(java.lang.Object,java.lang.String)>(v, "node should have been deleted");
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>(v, 0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object,java.lang.String)>(v, "node should not have been deleted yet");
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>(v, 0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object,java.lang.String)>(v, "node should not have been deleted yet");
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>("/c", 0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object,java.lang.String)>(v, "node should never be deleted");
virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: void set(long)>(210L);
virtualinvoke v.<org.apache.zookeeper.server.ContainerManager: void checkContainers()>();
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>("/a", 0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNull(java.lang.Object,java.lang.String)>(v, "node should have been deleted");
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>("/a2", 0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNull(java.lang.Object,java.lang.String)>(v, "node should have been deleted");
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>(v, 0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNull(java.lang.Object,java.lang.String)>(v, "node should have been deleted");
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>(v, 0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNull(java.lang.Object,java.lang.String)>(v, "node should have been deleted");
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>("/c", 0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object,java.lang.String)>(v, "node should never be deleted");
return;
}
public void testBadUsage() throws org.apache.zookeeper.KeeperException, java.lang.InterruptedException
{
org.apache.zookeeper.CreateMode v, v, v, v;
byte[] v, v, v, v;
org.apache.zookeeper.data.Stat v;
org.apache.zookeeper.CreateMode[] v, v;
boolean v, v;
org.apache.zookeeper.Op v, v;
java.util.Set v, v;
org.apache.zookeeper.AsyncCallback$Create2Callback v;
long v, v;
java.util.ArrayList v, v, v, v;
int v, v, v, v;
org.apache.zookeeper.server.CreateTTLTest v;
java.lang.IllegalArgumentException v, v, v, v;
org.apache.zookeeper.TestableZooKeeper v, v, v, v;
v := @this: org.apache.zookeeper.server.CreateTTLTest;
v = staticinvoke <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode[] values()>();
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
label:
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = newarray (byte)[0];
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = new org.apache.zookeeper.data.Stat;
specialinvoke v.<org.apache.zookeeper.data.Stat: void <init>()>();
v = virtualinvoke v.<org.apache.zookeeper.CreateMode: boolean isTTL()>();
if v == 0 goto label;
v = 0L;
goto label;
label:
v = 100L;
label:
virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: java.lang.String create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode,org.apache.zookeeper.data.Stat,long)>("/foo", v, v, v, v, v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("should have thrown IllegalArgumentException");
label:
goto label;
label:
v := @caughtexception;
label:
v = v + 1;
goto label;
label:
v = staticinvoke <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode[] values()>();
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = staticinvoke <org.apache.zookeeper.server.CreateTTLTest$lambda_testBadUsage_1__151: org.apache.zookeeper.AsyncCallback$Create2Callback bootstrap$()>();
label:
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = newarray (byte)[0];
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = virtualinvoke v.<org.apache.zookeeper.CreateMode: boolean isTTL()>();
if v == 0 goto label;
v = 0L;
goto label;
label:
v = 100L;
label:
virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: void create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode,org.apache.zookeeper.AsyncCallback$Create2Callback,java.lang.Object,long)>("/foo", v, v, v, v, null, v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("should have thrown IllegalArgumentException");
label:
goto label;
label:
v := @caughtexception;
label:
v = v + 1;
goto label;
label:
v = newarray (byte)[0];
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode PERSISTENT_WITH_TTL>;
v = staticinvoke <org.apache.zookeeper.Op: org.apache.zookeeper.Op create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode,long)>("/foo", v, v, v, 0L);
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = staticinvoke <java.util.Collections: java.util.Set singleton(java.lang.Object)>(v);
virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: java.util.List multi(java.lang.Iterable)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("should have thrown IllegalArgumentException");
label:
goto label;
label:
v := @caughtexception;
label:
v = newarray (byte)[0];
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode PERSISTENT_SEQUENTIAL_WITH_TTL>;
v = staticinvoke <org.apache.zookeeper.Op: org.apache.zookeeper.Op create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode,long)>("/foo", v, v, v, 0L);
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.TestableZooKeeper zk>;
v = staticinvoke <java.util.Collections: java.util.Set singleton(java.lang.Object)>(v);
virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper: java.util.List multi(java.lang.Iterable)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("should have thrown IllegalArgumentException");
label:
goto label;
label:
v := @caughtexception;
label:
return;
catch java.lang.IllegalArgumentException from label to label with label;
catch java.lang.IllegalArgumentException from label to label with label;
catch java.lang.IllegalArgumentException from label to label with label;
catch java.lang.IllegalArgumentException from label to label with label;
}
public void testDisabled() throws org.apache.zookeeper.KeeperException, java.lang.InterruptedException
{
org.apache.zookeeper.server.CreateTTLTest v;
org.junit.jupiter.api.function.Executable v;
v := @this: org.apache.zookeeper.server.CreateTTLTest;
v = staticinvoke <org.apache.zookeeper.server.CreateTTLTest$lambda_testDisabled_2__152: org.junit.jupiter.api.function.Executable bootstrap$(org.apache.zookeeper.server.CreateTTLTest)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Lorg/apache/zookeeper/KeeperException$UnimplementedException;", v);
return;
}
private org.apache.zookeeper.server.ContainerManager newContainerManager(java.util.concurrent.atomic.AtomicLong)
{
org.apache.zookeeper.server.ZKDatabase v;
org.apache.zookeeper.server.CreateTTLTest v;
org.apache.zookeeper.server.ServerCnxnFactory v, v;
org.apache.zookeeper.server.CreateTTLTest$1 v;
org.apache.zookeeper.server.ZooKeeperServer v, v;
java.util.concurrent.atomic.AtomicLong v;
org.apache.zookeeper.server.RequestProcessor v;
v := @this: org.apache.zookeeper.server.CreateTTLTest;
v := @parameter: java.util.concurrent.atomic.AtomicLong;
v = new org.apache.zookeeper.server.CreateTTLTest$1;
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.server.ServerCnxnFactory serverFactory>;
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxnFactory: org.apache.zookeeper.server.ZooKeeperServer getZooKeeperServer()>();
v = virtualinvoke v.<org.apache.zookeeper.server.ZooKeeperServer: org.apache.zookeeper.server.ZKDatabase getZKDatabase()>();
v = v.<org.apache.zookeeper.server.CreateTTLTest: org.apache.zookeeper.server.ServerCnxnFactory serverFactory>;
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxnFactory: org.apache.zookeeper.server.ZooKeeperServer getZooKeeperServer()>();
v = v.<org.apache.zookeeper.server.ZooKeeperServer: org.apache.zookeeper.server.RequestProcessor firstProcessor>;
specialinvoke v.<org.apache.zookeeper.server.CreateTTLTest$1: void <init>(org.apache.zookeeper.server.CreateTTLTest,org.apache.zookeeper.server.ZKDatabase,org.apache.zookeeper.server.RequestProcessor,int,int,java.util.concurrent.atomic.AtomicLong)>(v, v, v, 1, 100, v);
return v;
}
static void <clinit>()
{
java.util.Set v;
v = staticinvoke <java.util.Collections: java.util.Set singleton(java.lang.Object)>("testDisabled");
<org.apache.zookeeper.server.CreateTTLTest: java.util.Collection disabledTests> = v;
return;
}
}