public class oadd.org.apache.drill.common.concurrent.ExtendedLatch extends java.util.concurrent.CountDownLatch
{
private static final org.slf4j.Logger logger;
public void <init>()
{
oadd.org.apache.drill.common.concurrent.ExtendedLatch v;
v := @this: oadd.org.apache.drill.common.concurrent.ExtendedLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
return;
}
public void <init>(int)
{
int v;
oadd.org.apache.drill.common.concurrent.ExtendedLatch v;
v := @this: oadd.org.apache.drill.common.concurrent.ExtendedLatch;
v := @parameter: int;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(v);
return;
}
public boolean awaitUninterruptibly(long)
{
org.slf4j.Logger v;
oadd.org.apache.drill.common.concurrent.ExtendedLatch v;
long v, v, v, v, v, v;
java.util.concurrent.TimeUnit v;
byte v, v;
java.lang.InterruptedException v;
boolean v;
v := @this: oadd.org.apache.drill.common.concurrent.ExtendedLatch;
v := @parameter: long;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v + v;
label:
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v cmp v;
if v >= 0 goto label;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v - v;
v = v cmp 1L;
if v >= 0 goto label;
return 0;
label:
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = virtualinvoke v.<oadd.org.apache.drill.common.concurrent.ExtendedLatch: boolean await(long,java.util.concurrent.TimeUnit)>(v, v);
label:
return v;
label:
v := @caughtexception;
v = <oadd.org.apache.drill.common.concurrent.ExtendedLatch: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>("Interrupted while waiting for event latch.", v);
goto label;
label:
return 0;
catch java.lang.InterruptedException from label to label with label;
}
public void awaitUninterruptibly()
{
org.slf4j.Logger v;
oadd.org.apache.drill.common.concurrent.ExtendedLatch v;
java.lang.InterruptedException v;
v := @this: oadd.org.apache.drill.common.concurrent.ExtendedLatch;
label:
virtualinvoke v.<oadd.org.apache.drill.common.concurrent.ExtendedLatch: void await()>();
label:
return;
label:
v := @caughtexception;
v = <oadd.org.apache.drill.common.concurrent.ExtendedLatch: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>("Interrupted while waiting for event latch.", v);
goto label;
catch java.lang.InterruptedException from label to label with label;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Loadd/org/apache/drill/common/concurrent/ExtendedLatch;");
<oadd.org.apache.drill.common.concurrent.ExtendedLatch: org.slf4j.Logger logger> = v;
return;
}
}