public class org.apache.zookeeper.test.QuorumQuotaTest extends org.apache.zookeeper.test.QuorumBase
{
public void <init>()
{
org.apache.zookeeper.test.QuorumQuotaTest v;
v := @this: org.apache.zookeeper.test.QuorumQuotaTest;
specialinvoke v.<org.apache.zookeeper.test.QuorumBase: void <init>()>();
return;
}
public void testQuotaWithQuorum() throws java.lang.Exception
{
org.apache.zookeeper.CreateMode v, v, v;
byte[] v, v, v, v, v, v;
org.apache.zookeeper.data.Stat v, v;
byte v, v, v, v;
boolean v, v, v, v;
org.apache.zookeeper.test.QuorumQuotaTest v;
long v, v, v, v;
java.util.ArrayList v, v, v;
int v, v, v;
java.lang.String v, v, v, v, v, v, v;
org.apache.zookeeper.StatsTrack v, v, v;
org.apache.zookeeper.TestableZooKeeper v;
v := @this: org.apache.zookeeper.test.QuorumQuotaTest;
v = virtualinvoke v.<org.apache.zookeeper.test.QuorumQuotaTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = "some";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v = (int) -1;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat setData(java.lang.String,byte[],int)>("/", v, v);
v = "some";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode PERSISTENT>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.lang.String create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode)>("/a", v, v, v);
v = 0;
label:
if v >= 300 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("/a/\u0001");
v = "some";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode PERSISTENT>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.lang.String create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode)>(v, v, v, v);
v = v + 1;
goto label;
label:
v = new org.apache.zookeeper.StatsTrack;
specialinvoke v.<org.apache.zookeeper.StatsTrack: void <init>()>();
virtualinvoke v.<org.apache.zookeeper.StatsTrack: void setCount(long)>(1000L);
virtualinvoke v.<org.apache.zookeeper.StatsTrack: void setBytes(long)>(5000L);
staticinvoke <org.apache.zookeeper.cli.SetQuotaCommand: boolean createQuota(org.apache.zookeeper.ZooKeeper,java.lang.String,org.apache.zookeeper.StatsTrack)>(v, "/a", v);
v = staticinvoke <org.apache.zookeeper.Quotas: java.lang.String statPath(java.lang.String)>("/a");
v = new org.apache.zookeeper.data.Stat;
specialinvoke v.<org.apache.zookeeper.data.Stat: void <init>()>();
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: byte[] getData(java.lang.String,boolean,org.apache.zookeeper.data.Stat)>(v, 0, v);
v = new org.apache.zookeeper.StatsTrack;
specialinvoke v.<org.apache.zookeeper.StatsTrack: void <init>(byte[])>(v);
v = virtualinvoke v.<org.apache.zookeeper.StatsTrack: long getBytes()>();
v = v cmp 1204L;
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, "bytes are set");
v = virtualinvoke v.<org.apache.zookeeper.StatsTrack: long getCount()>();
v = v cmp 301L;
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, "num count is set");
v = 300;
label:
if v >= 600 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("/a/\u0001");
v = "some";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode PERSISTENT>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.lang.String create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode)>(v, v, v, v);
v = v + 1;
goto label;
label:
v = new org.apache.zookeeper.data.Stat;
specialinvoke v.<org.apache.zookeeper.data.Stat: void <init>()>();
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: byte[] getData(java.lang.String,boolean,org.apache.zookeeper.data.Stat)>(v, 0, v);
v = new org.apache.zookeeper.StatsTrack;
specialinvoke v.<org.apache.zookeeper.StatsTrack: void <init>(byte[])>(v);
v = virtualinvoke v.<org.apache.zookeeper.StatsTrack: long getBytes()>();
v = v cmp 2404L;
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, "bytes are set");
v = virtualinvoke v.<org.apache.zookeeper.StatsTrack: long getCount()>();
v = v cmp 601L;
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, "num count is set");
return;
}
}