public class org.apache.drill.exec.rpc.ResettableBarrier extends java.lang.Object
{
static final org.slf4j.Logger logger;
private final org.apache.drill.exec.rpc.ResettableBarrier$InternalSynchronizer sync;
public void <init>()
{
org.apache.drill.exec.rpc.ResettableBarrier$InternalSynchronizer v;
org.apache.drill.exec.rpc.ResettableBarrier v;
v := @this: org.apache.drill.exec.rpc.ResettableBarrier;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new org.apache.drill.exec.rpc.ResettableBarrier$InternalSynchronizer;
specialinvoke v.<org.apache.drill.exec.rpc.ResettableBarrier$InternalSynchronizer: void <init>()>();
v.<org.apache.drill.exec.rpc.ResettableBarrier: org.apache.drill.exec.rpc.ResettableBarrier$InternalSynchronizer sync> = v;
return;
}
public void await() throws java.lang.InterruptedException
{
org.apache.drill.exec.rpc.ResettableBarrier$InternalSynchronizer v;
org.apache.drill.exec.rpc.ResettableBarrier v;
v := @this: org.apache.drill.exec.rpc.ResettableBarrier;
v = v.<org.apache.drill.exec.rpc.ResettableBarrier: org.apache.drill.exec.rpc.ResettableBarrier$InternalSynchronizer sync>;
virtualinvoke v.<org.apache.drill.exec.rpc.ResettableBarrier$InternalSynchronizer: void acquireSharedInterruptibly(int)>(1);
return;
}
public boolean await(long, java.util.concurrent.TimeUnit) throws java.lang.InterruptedException
{
java.util.concurrent.TimeUnit v;
org.apache.drill.exec.rpc.ResettableBarrier$InternalSynchronizer v;
org.apache.drill.exec.rpc.ResettableBarrier v;
long v, v;
boolean v;
v := @this: org.apache.drill.exec.rpc.ResettableBarrier;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = v.<org.apache.drill.exec.rpc.ResettableBarrier: org.apache.drill.exec.rpc.ResettableBarrier$InternalSynchronizer sync>;
v = virtualinvoke v.<java.util.concurrent.TimeUnit: long toNanos(long)>(v);
v = virtualinvoke v.<org.apache.drill.exec.rpc.ResettableBarrier$InternalSynchronizer: boolean tryAcquireSharedNanos(int,long)>(1, v);
return v;
}
public void openBarrier()
{
org.apache.drill.exec.rpc.ResettableBarrier$InternalSynchronizer v;
org.apache.drill.exec.rpc.ResettableBarrier v;
v := @this: org.apache.drill.exec.rpc.ResettableBarrier;
v = v.<org.apache.drill.exec.rpc.ResettableBarrier: org.apache.drill.exec.rpc.ResettableBarrier$InternalSynchronizer sync>;
virtualinvoke v.<org.apache.drill.exec.rpc.ResettableBarrier$InternalSynchronizer: boolean releaseShared(int)>(1);
return;
}
public void closeBarrier()
{
org.apache.drill.exec.rpc.ResettableBarrier$InternalSynchronizer v;
org.apache.drill.exec.rpc.ResettableBarrier v;
v := @this: org.apache.drill.exec.rpc.ResettableBarrier;
v = v.<org.apache.drill.exec.rpc.ResettableBarrier: org.apache.drill.exec.rpc.ResettableBarrier$InternalSynchronizer sync>;
virtualinvoke v.<org.apache.drill.exec.rpc.ResettableBarrier$InternalSynchronizer: void reset()>();
return;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/drill/exec/rpc/ResettableBarrier;");
<org.apache.drill.exec.rpc.ResettableBarrier: org.slf4j.Logger logger> = v;
return;
}
}