public class org.apache.zookeeper.common.TimeTest extends org.apache.zookeeper.test.ClientBase
{
private static final long mt;
private static final long nt;
private static java.util.concurrent.atomic.AtomicInteger watchCount;
public void <init>()
{
org.apache.zookeeper.common.TimeTest v;
v := @this: org.apache.zookeeper.common.TimeTest;
specialinvoke v.<org.apache.zookeeper.test.ClientBase: void <init>()>();
return;
}
public static void main(java.lang.String[]) throws java.lang.Exception
{
org.apache.zookeeper.CreateMode v;
byte[] v;
java.lang.Object[] v;
java.lang.String[] v;
long v, v, v, v;
org.apache.zookeeper.data.Stat v;
java.util.ArrayList v;
byte v;
java.lang.Long v;
java.util.concurrent.atomic.AtomicInteger v;
org.apache.zookeeper.common.TimeTest v;
int v;
java.lang.Boolean v;
boolean v;
java.io.PrintStream v, v, v;
org.apache.zookeeper.Watcher v;
org.apache.zookeeper.TestableZooKeeper v;
v := @parameter: java.lang.String[];
v = <java.lang.System: java.io.PrintStream out>;
virtualinvoke v.<java.io.PrintStream: void print(java.lang.String)>("Starting\n");
v = new org.apache.zookeeper.common.TimeTest;
specialinvoke v.<org.apache.zookeeper.common.TimeTest: void <init>()>();
v = <java.lang.System: java.io.PrintStream out>;
virtualinvoke v.<java.io.PrintStream: void print(java.lang.String)>("After construct\n");
virtualinvoke v.<org.apache.zookeeper.common.TimeTest: void setUp()>();
v = virtualinvoke v.<org.apache.zookeeper.common.TimeTest: org.apache.zookeeper.TestableZooKeeper createClient()>();
v = newarray (byte)[3];
v[0] = 1;
v[1] = 2;
v[2] = 3;
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode EPHEMERAL>;
virtualinvoke v.<org.apache.zookeeper.ZooKeeper: java.lang.String create(java.lang.String,byte[],java.util.List,org.apache.zookeeper.CreateMode)>("/ephemeral", v, v, v);
label:
v = staticinvoke <org.apache.zookeeper.common.Time: long currentElapsedTime()>();
v = <org.apache.zookeeper.common.TimeTest: long nt0>;
v = v - v;
v = v cmp 100000L;
if v >= 0 goto label;
v = <java.lang.System: java.io.PrintStream out>;
v = newarray (java.lang.Object)[2];
v = staticinvoke <org.apache.zookeeper.common.TimeTest: long discrepancy()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[0] = v;
v = <org.apache.zookeeper.common.TimeTest: java.util.concurrent.atomic.AtomicInteger watchCount>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int get()>();
if v != 0 goto label;
v = staticinvoke <org.apache.zookeeper.common.TimeTest: org.apache.zookeeper.Watcher createWatcher()>();
goto label;
label:
v = null;
label:
v = virtualinvoke v.<org.apache.zookeeper.ZooKeeper: org.apache.zookeeper.data.Stat exists(java.lang.String,org.apache.zookeeper.Watcher)>("/ephemeral", v);
if v == null goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
v[1] = v;
virtualinvoke v.<java.io.PrintStream: java.io.PrintStream printf(java.lang.String,java.lang.Object[])>("%d\t%s\n", v);
staticinvoke <org.apache.zookeeper.common.TimeTest: void waitByYielding(long)>(500L);
goto label;
label:
return;
}
private static org.apache.zookeeper.Watcher createWatcher()
{
java.util.concurrent.atomic.AtomicInteger v;
org.apache.zookeeper.Watcher v;
v = <org.apache.zookeeper.common.TimeTest: java.util.concurrent.atomic.AtomicInteger watchCount>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int incrementAndGet()>();
v = staticinvoke <org.apache.zookeeper.common.TimeTest$lambda_createWatcher_0__131: org.apache.zookeeper.Watcher bootstrap$()>();
return v;
}
private static void waitByYielding(long)
{
byte v;
long v, v, v, v;
v := @parameter: long;
v = staticinvoke <org.apache.zookeeper.common.Time: long currentElapsedTime()>();
label:
v = staticinvoke <org.apache.zookeeper.common.Time: long currentElapsedTime()>();
v = v + v;
v = v cmp v;
if v >= 0 goto label;
staticinvoke <java.lang.Thread: void yield()>();
goto label;
label:
return;
}
private static long discrepancy()
{
long v, v, v, v, v, v, v;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = <org.apache.zookeeper.common.TimeTest: long mt0>;
v = v - v;
v = staticinvoke <org.apache.zookeeper.common.Time: long currentElapsedTime()>();
v = <org.apache.zookeeper.common.TimeTest: long nt0>;
v = v - v;
v = v - v;
return v;
}
public void testElapsedTimeToDate() throws java.lang.Exception
{
java.util.Date v, v;
long v, v;
java.util.Calendar v;
org.apache.zookeeper.common.TimeTest v;
int v, v;
v := @this: org.apache.zookeeper.common.TimeTest;
v = staticinvoke <org.apache.zookeeper.common.Time: long currentWallTime()>();
v = staticinvoke <org.apache.zookeeper.common.Time: long currentElapsedTime()>();
staticinvoke <java.lang.Thread: void sleep(long)>(200L);
v = staticinvoke <java.util.Calendar: java.util.Calendar getInstance()>();
v = staticinvoke <org.apache.zookeeper.common.Time: java.util.Date elapsedTimeToDate(long)>(v);
virtualinvoke v.<java.util.Calendar: void setTime(java.util.Date)>(v);
v = virtualinvoke v.<java.util.Calendar: int get(int)>(11);
v = new java.util.Date;
specialinvoke v.<java.util.Date: void <init>(long)>(v);
virtualinvoke v.<java.util.Calendar: void setTime(java.util.Date)>(v);
v = virtualinvoke v.<java.util.Calendar: int get(int)>(11);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(v, v);
return;
}
static void <clinit>()
{
long v, v;
java.util.concurrent.atomic.AtomicInteger v;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
<org.apache.zookeeper.common.TimeTest: long mt0> = v;
v = staticinvoke <org.apache.zookeeper.common.Time: long currentElapsedTime()>();
<org.apache.zookeeper.common.TimeTest: long nt0> = v;
v = new java.util.concurrent.atomic.AtomicInteger;
specialinvoke v.<java.util.concurrent.atomic.AtomicInteger: void <init>(int)>(0);
<org.apache.zookeeper.common.TimeTest: java.util.concurrent.atomic.AtomicInteger watchCount> = v;
return;
}
}