public final class org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor extends java.lang.Object
{
private final boolean fair;
private final java.util.concurrent.locks.ReentrantLock lock;
private org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard activeGuards;
public void <init>()
{
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: void <init>(boolean)>(0);
return;
}
public void <init>(boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v;
java.util.concurrent.locks.ReentrantLock v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: boolean;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard activeGuards> = null;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: boolean fair> = v;
v = new java.util.concurrent.locks.ReentrantLock;
specialinvoke v.<java.util.concurrent.locks.ReentrantLock: void <init>(boolean)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: java.util.concurrent.locks.ReentrantLock lock> = v;
return;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard newGuard(java.util.function.BooleanSupplier)
{
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$1 v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v;
java.util.function.BooleanSupplier v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: java.util.function.BooleanSupplier;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object,java.lang.Object)>(v, "isSatisfied");
v = new org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$1;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$1: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor,org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor,java.util.function.BooleanSupplier)>(v, v, v);
return v;
}
public void enter()
{
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v;
java.util.concurrent.locks.ReentrantLock v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void lock()>();
return;
}
public boolean enter(java.time.Duration)
{
java.util.concurrent.TimeUnit v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v;
java.time.Duration v;
long v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: java.time.Duration;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Internal: long toNanosSaturated(java.time.Duration)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit NANOSECONDS>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: boolean enter(long,java.util.concurrent.TimeUnit)>(v, v);
return v;
}
public boolean enter(long, java.util.concurrent.TimeUnit)
{
java.lang.Throwable v;
long v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v;
java.lang.Thread v, v;
boolean v, v, v, v;
java.util.concurrent.locks.ReentrantLock v;
java.util.concurrent.TimeUnit v, v;
java.lang.InterruptedException v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: long toSafeNanos(long,java.util.concurrent.TimeUnit)>(v, v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: java.util.concurrent.locks.ReentrantLock lock>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: boolean fair>;
if v != 0 goto label;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: boolean tryLock()>();
if v == 0 goto label;
return 1;
label:
v = staticinvoke <java.lang.Thread: boolean interrupted()>();
label:
v = staticinvoke <java.lang.System: long nanoTime()>();
v = v;
label:
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit NANOSECONDS>;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: boolean tryLock(long,java.util.concurrent.TimeUnit)>(v, v);
label:
if v == 0 goto label;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
virtualinvoke v.<java.lang.Thread: void interrupt()>();
label:
return v;
label:
v := @caughtexception;
v = 1;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: long remainingNanos(long,long)>(v, v);
goto label;
label:
v := @caughtexception;
if v == 0 goto label;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
virtualinvoke v.<java.lang.Thread: void interrupt()>();
label:
throw v;
catch java.lang.InterruptedException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public void enterInterruptibly() throws java.lang.InterruptedException
{
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v;
java.util.concurrent.locks.ReentrantLock v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void lockInterruptibly()>();
return;
}
public boolean enterInterruptibly(java.time.Duration) throws java.lang.InterruptedException
{
java.util.concurrent.TimeUnit v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v;
java.time.Duration v;
long v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: java.time.Duration;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Internal: long toNanosSaturated(java.time.Duration)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit NANOSECONDS>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: boolean enterInterruptibly(long,java.util.concurrent.TimeUnit)>(v, v);
return v;
}
public boolean enterInterruptibly(long, java.util.concurrent.TimeUnit) throws java.lang.InterruptedException
{
java.util.concurrent.TimeUnit v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v;
java.util.concurrent.locks.ReentrantLock v;
long v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: java.util.concurrent.locks.ReentrantLock lock>;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: boolean tryLock(long,java.util.concurrent.TimeUnit)>(v, v);
return v;
}
public boolean tryEnter()
{
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v;
java.util.concurrent.locks.ReentrantLock v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: java.util.concurrent.locks.ReentrantLock lock>;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: boolean tryLock()>();
return v;
}
public void enterWhen(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard) throws java.lang.InterruptedException
{
java.lang.Throwable v;
java.util.concurrent.locks.ReentrantLock v;
java.lang.IllegalMonitorStateException v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor monitor>;
if v == v goto label;
v = new java.lang.IllegalMonitorStateException;
specialinvoke v.<java.lang.IllegalMonitorStateException: void <init>()>();
throw v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: java.util.concurrent.locks.ReentrantLock lock>;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: boolean isHeldByCurrentThread()>();
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void lockInterruptibly()>();
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: boolean isSatisfied()>();
if v != 0 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: void await(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard,boolean)>(v, v);
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: void leave()>();
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public boolean enterWhen(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard, java.time.Duration) throws java.lang.InterruptedException
{
java.util.concurrent.TimeUnit v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard v;
java.time.Duration v;
long v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard;
v := @parameter: java.time.Duration;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Internal: long toNanosSaturated(java.time.Duration)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit NANOSECONDS>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: boolean enterWhen(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard,long,java.util.concurrent.TimeUnit)>(v, v, v);
return v;
}
public boolean enterWhen(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard, long, java.util.concurrent.TimeUnit) throws java.lang.InterruptedException
{
java.lang.Throwable v, v;
long v, v, v, v;
java.lang.IllegalMonitorStateException v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard v;
byte v;
boolean v, v, v, v, v, v, v, v, v, v;
java.util.concurrent.locks.ReentrantLock v;
java.util.concurrent.TimeUnit v;
java.lang.InterruptedException v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: long toSafeNanos(long,java.util.concurrent.TimeUnit)>(v, v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor monitor>;
if v == v goto label;
v = new java.lang.IllegalMonitorStateException;
specialinvoke v.<java.lang.IllegalMonitorStateException: void <init>()>();
throw v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: java.util.concurrent.locks.ReentrantLock lock>;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: boolean isHeldByCurrentThread()>();
v = 0L;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: boolean fair>;
if v != 0 goto label;
v = staticinvoke <java.lang.Thread: boolean interrupted()>();
if v == 0 goto label;
v = new java.lang.InterruptedException;
specialinvoke v.<java.lang.InterruptedException: void <init>()>();
throw v;
label:
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: boolean tryLock()>();
if v != 0 goto label;
label:
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: long initNanoTime(long)>(v);
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: boolean tryLock(long,java.util.concurrent.TimeUnit)>(v, v);
if v != 0 goto label;
return 0;
label:
v = 0;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: boolean isSatisfied()>();
if v != 0 goto label;
v = v cmp 0L;
if v != 0 goto label;
v = v;
goto label;
label:
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: long remainingNanos(long,long)>(v, v);
label:
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: boolean awaitNanos(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard,long,boolean)>(v, v, v);
if v == 0 goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
v = v;
label:
if v != 0 goto label;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
label:
return v;
label:
v := @caughtexception;
if v != 0 goto label;
label:
if v != 0 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: void signalNextWaiter()>();
label:
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
goto label;
label:
v := @caughtexception;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
throw v;
label:
throw v;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public void enterWhenUninterruptibly(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard)
{
java.lang.Throwable v;
java.util.concurrent.locks.ReentrantLock v;
java.lang.IllegalMonitorStateException v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor monitor>;
if v == v goto label;
v = new java.lang.IllegalMonitorStateException;
specialinvoke v.<java.lang.IllegalMonitorStateException: void <init>()>();
throw v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: java.util.concurrent.locks.ReentrantLock lock>;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: boolean isHeldByCurrentThread()>();
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void lock()>();
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: boolean isSatisfied()>();
if v != 0 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: void awaitUninterruptibly(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard,boolean)>(v, v);
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: void leave()>();
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public boolean enterWhenUninterruptibly(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard, java.time.Duration)
{
java.util.concurrent.TimeUnit v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard v;
java.time.Duration v;
long v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard;
v := @parameter: java.time.Duration;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Internal: long toNanosSaturated(java.time.Duration)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit NANOSECONDS>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: boolean enterWhenUninterruptibly(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard,long,java.util.concurrent.TimeUnit)>(v, v, v);
return v;
}
public boolean enterWhenUninterruptibly(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard, long, java.util.concurrent.TimeUnit)
{
java.lang.Throwable v, v;
long v, v, v, v, v;
java.lang.IllegalMonitorStateException v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard v;
byte v;
java.lang.Thread v, v, v;
boolean v, v, v, v, v, v, v, v;
java.util.concurrent.locks.ReentrantLock v;
java.util.concurrent.TimeUnit v, v;
java.lang.InterruptedException v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: long toSafeNanos(long,java.util.concurrent.TimeUnit)>(v, v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor monitor>;
if v == v goto label;
v = new java.lang.IllegalMonitorStateException;
specialinvoke v.<java.lang.IllegalMonitorStateException: void <init>()>();
throw v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: java.util.concurrent.locks.ReentrantLock lock>;
v = 0L;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: boolean isHeldByCurrentThread()>();
v = staticinvoke <java.lang.Thread: boolean interrupted()>();
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: boolean fair>;
if v != 0 goto label;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: boolean tryLock()>();
if v != 0 goto label;
label:
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: long initNanoTime(long)>(v);
v = v;
label:
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit NANOSECONDS>;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: boolean tryLock(long,java.util.concurrent.TimeUnit)>(v, v);
if v != 0 goto label;
label:
if v == 0 goto label;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
virtualinvoke v.<java.lang.Thread: void interrupt()>();
label:
return 0;
label:
v := @caughtexception;
v = 1;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: long remainingNanos(long,long)>(v, v);
goto label;
label:
v = 0;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: boolean isSatisfied()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = v cmp 0L;
if v != 0 goto label;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: long initNanoTime(long)>(v);
v = v;
goto label;
label:
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: long remainingNanos(long,long)>(v, v);
label:
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: boolean awaitNanos(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard,long,boolean)>(v, v, v);
label:
v = v;
label:
if v != 0 goto label;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
label:
if v == 0 goto label;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
virtualinvoke v.<java.lang.Thread: void interrupt()>();
label:
return v;
label:
v := @caughtexception;
v = 1;
v = 0;
goto label;
label:
v := @caughtexception;
if v != 0 goto label;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
label:
throw v;
label:
v := @caughtexception;
if v == 0 goto label;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
virtualinvoke v.<java.lang.Thread: void interrupt()>();
label:
throw v;
catch java.lang.InterruptedException from label to label with label;
catch java.lang.InterruptedException from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public boolean enterIf(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard)
{
java.lang.Throwable v;
java.lang.IllegalMonitorStateException v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard v;
java.util.concurrent.locks.ReentrantLock v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor monitor>;
if v == v goto label;
v = new java.lang.IllegalMonitorStateException;
specialinvoke v.<java.lang.IllegalMonitorStateException: void <init>()>();
throw v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void lock()>();
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: boolean isSatisfied()>();
label:
if v != 0 goto label;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
label:
return v;
label:
v := @caughtexception;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
throw v;
catch java.lang.Throwable from label to label with label;
}
public boolean enterIf(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard, java.time.Duration)
{
java.util.concurrent.TimeUnit v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard v;
java.time.Duration v;
long v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard;
v := @parameter: java.time.Duration;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Internal: long toNanosSaturated(java.time.Duration)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit NANOSECONDS>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: boolean enterIf(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard,long,java.util.concurrent.TimeUnit)>(v, v, v);
return v;
}
public boolean enterIf(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard, long, java.util.concurrent.TimeUnit)
{
java.lang.Throwable v;
java.util.concurrent.locks.ReentrantLock v, v;
long v;
java.util.concurrent.TimeUnit v;
java.lang.IllegalMonitorStateException v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor monitor>;
if v == v goto label;
v = new java.lang.IllegalMonitorStateException;
specialinvoke v.<java.lang.IllegalMonitorStateException: void <init>()>();
throw v;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: boolean enter(long,java.util.concurrent.TimeUnit)>(v, v);
if v != 0 goto label;
return 0;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: boolean isSatisfied()>();
label:
if v != 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
label:
return v;
label:
v := @caughtexception;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
throw v;
catch java.lang.Throwable from label to label with label;
}
public boolean enterIfInterruptibly(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard) throws java.lang.InterruptedException
{
java.lang.Throwable v;
java.lang.IllegalMonitorStateException v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard v;
java.util.concurrent.locks.ReentrantLock v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor monitor>;
if v == v goto label;
v = new java.lang.IllegalMonitorStateException;
specialinvoke v.<java.lang.IllegalMonitorStateException: void <init>()>();
throw v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void lockInterruptibly()>();
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: boolean isSatisfied()>();
label:
if v != 0 goto label;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
label:
return v;
label:
v := @caughtexception;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
throw v;
catch java.lang.Throwable from label to label with label;
}
public boolean enterIfInterruptibly(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard, java.time.Duration) throws java.lang.InterruptedException
{
java.util.concurrent.TimeUnit v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard v;
java.time.Duration v;
long v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard;
v := @parameter: java.time.Duration;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Internal: long toNanosSaturated(java.time.Duration)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit NANOSECONDS>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: boolean enterIfInterruptibly(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard,long,java.util.concurrent.TimeUnit)>(v, v, v);
return v;
}
public boolean enterIfInterruptibly(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard, long, java.util.concurrent.TimeUnit) throws java.lang.InterruptedException
{
java.lang.Throwable v;
java.util.concurrent.locks.ReentrantLock v;
long v;
java.util.concurrent.TimeUnit v;
java.lang.IllegalMonitorStateException v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor monitor>;
if v == v goto label;
v = new java.lang.IllegalMonitorStateException;
specialinvoke v.<java.lang.IllegalMonitorStateException: void <init>()>();
throw v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: java.util.concurrent.locks.ReentrantLock lock>;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: boolean tryLock(long,java.util.concurrent.TimeUnit)>(v, v);
if v != 0 goto label;
return 0;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: boolean isSatisfied()>();
label:
if v != 0 goto label;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
label:
return v;
label:
v := @caughtexception;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
throw v;
catch java.lang.Throwable from label to label with label;
}
public boolean tryEnterIf(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard)
{
java.lang.Throwable v;
java.util.concurrent.locks.ReentrantLock v;
java.lang.IllegalMonitorStateException v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor monitor>;
if v == v goto label;
v = new java.lang.IllegalMonitorStateException;
specialinvoke v.<java.lang.IllegalMonitorStateException: void <init>()>();
throw v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: java.util.concurrent.locks.ReentrantLock lock>;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: boolean tryLock()>();
if v != 0 goto label;
return 0;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: boolean isSatisfied()>();
label:
if v != 0 goto label;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
label:
return v;
label:
v := @caughtexception;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
throw v;
catch java.lang.Throwable from label to label with label;
}
public void waitFor(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard) throws java.lang.InterruptedException
{
java.util.concurrent.locks.ReentrantLock v;
java.lang.IllegalMonitorStateException v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard v;
boolean v, v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor monitor>;
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: java.util.concurrent.locks.ReentrantLock lock>;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: boolean isHeldByCurrentThread()>();
v = v & v;
if v != 0 goto label;
v = new java.lang.IllegalMonitorStateException;
specialinvoke v.<java.lang.IllegalMonitorStateException: void <init>()>();
throw v;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: boolean isSatisfied()>();
if v != 0 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: void await(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard,boolean)>(v, 1);
label:
return;
}
public boolean waitFor(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard, java.time.Duration) throws java.lang.InterruptedException
{
java.util.concurrent.TimeUnit v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard v;
java.time.Duration v;
long v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard;
v := @parameter: java.time.Duration;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Internal: long toNanosSaturated(java.time.Duration)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit NANOSECONDS>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: boolean waitFor(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard,long,java.util.concurrent.TimeUnit)>(v, v, v);
return v;
}
public boolean waitFor(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard, long, java.util.concurrent.TimeUnit) throws java.lang.InterruptedException
{
java.util.concurrent.locks.ReentrantLock v;
long v, v;
java.util.concurrent.TimeUnit v;
java.lang.IllegalMonitorStateException v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard v;
java.lang.InterruptedException v;
boolean v, v, v, v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: long toSafeNanos(long,java.util.concurrent.TimeUnit)>(v, v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor monitor>;
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: java.util.concurrent.locks.ReentrantLock lock>;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: boolean isHeldByCurrentThread()>();
v = v & v;
if v != 0 goto label;
v = new java.lang.IllegalMonitorStateException;
specialinvoke v.<java.lang.IllegalMonitorStateException: void <init>()>();
throw v;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: boolean isSatisfied()>();
if v == 0 goto label;
return 1;
label:
v = staticinvoke <java.lang.Thread: boolean interrupted()>();
if v == 0 goto label;
v = new java.lang.InterruptedException;
specialinvoke v.<java.lang.InterruptedException: void <init>()>();
throw v;
label:
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: boolean awaitNanos(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard,long,boolean)>(v, v, 1);
return v;
}
public void waitForUninterruptibly(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard)
{
java.util.concurrent.locks.ReentrantLock v;
java.lang.IllegalMonitorStateException v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard v;
boolean v, v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor monitor>;
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: java.util.concurrent.locks.ReentrantLock lock>;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: boolean isHeldByCurrentThread()>();
v = v & v;
if v != 0 goto label;
v = new java.lang.IllegalMonitorStateException;
specialinvoke v.<java.lang.IllegalMonitorStateException: void <init>()>();
throw v;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: boolean isSatisfied()>();
if v != 0 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: void awaitUninterruptibly(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard,boolean)>(v, 1);
label:
return;
}
public boolean waitForUninterruptibly(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard, java.time.Duration)
{
java.util.concurrent.TimeUnit v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard v;
java.time.Duration v;
long v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard;
v := @parameter: java.time.Duration;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Internal: long toNanosSaturated(java.time.Duration)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit NANOSECONDS>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: boolean waitForUninterruptibly(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard,long,java.util.concurrent.TimeUnit)>(v, v, v);
return v;
}
public boolean waitForUninterruptibly(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard, long, java.util.concurrent.TimeUnit)
{
java.lang.Throwable v;
long v, v, v, v;
java.lang.IllegalMonitorStateException v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard v;
java.lang.Thread v, v, v;
boolean v, v, v, v, v, v, v, v;
java.util.concurrent.locks.ReentrantLock v;
java.util.concurrent.TimeUnit v;
java.lang.InterruptedException v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: long toSafeNanos(long,java.util.concurrent.TimeUnit)>(v, v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor monitor>;
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: java.util.concurrent.locks.ReentrantLock lock>;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: boolean isHeldByCurrentThread()>();
v = v & v;
if v != 0 goto label;
v = new java.lang.IllegalMonitorStateException;
specialinvoke v.<java.lang.IllegalMonitorStateException: void <init>()>();
throw v;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: boolean isSatisfied()>();
if v == 0 goto label;
return 1;
label:
v = 1;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: long initNanoTime(long)>(v);
v = staticinvoke <java.lang.Thread: boolean interrupted()>();
label:
v = v;
label:
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: boolean awaitNanos(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard,long,boolean)>(v, v, v);
label:
if v == 0 goto label;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
virtualinvoke v.<java.lang.Thread: void interrupt()>();
label:
return v;
label:
v := @caughtexception;
v = 1;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: boolean isSatisfied()>();
if v == 0 goto label;
label:
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
virtualinvoke v.<java.lang.Thread: void interrupt()>();
return 1;
label:
v = 0;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: long remainingNanos(long,long)>(v, v);
goto label;
label:
v := @caughtexception;
if v == 0 goto label;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
virtualinvoke v.<java.lang.Thread: void interrupt()>();
label:
throw v;
catch java.lang.InterruptedException from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public void leave()
{
java.lang.Throwable v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v;
java.util.concurrent.locks.ReentrantLock v;
int v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: java.util.concurrent.locks.ReentrantLock lock>;
label:
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: int getHoldCount()>();
if v != 1 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: void signalNextWaiter()>();
label:
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
goto label;
label:
v := @caughtexception;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public boolean isFair()
{
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: boolean fair>;
return v;
}
public boolean isOccupied()
{
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v;
java.util.concurrent.locks.ReentrantLock v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: java.util.concurrent.locks.ReentrantLock lock>;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: boolean isLocked()>();
return v;
}
public boolean isOccupiedByCurrentThread()
{
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v;
java.util.concurrent.locks.ReentrantLock v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: java.util.concurrent.locks.ReentrantLock lock>;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: boolean isHeldByCurrentThread()>();
return v;
}
public int getOccupiedDepth()
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v;
java.util.concurrent.locks.ReentrantLock v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: java.util.concurrent.locks.ReentrantLock lock>;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: int getHoldCount()>();
return v;
}
public int getQueueLength()
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v;
java.util.concurrent.locks.ReentrantLock v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: java.util.concurrent.locks.ReentrantLock lock>;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: int getQueueLength()>();
return v;
}
public boolean hasQueuedThreads()
{
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v;
java.util.concurrent.locks.ReentrantLock v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: java.util.concurrent.locks.ReentrantLock lock>;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: boolean hasQueuedThreads()>();
return v;
}
public boolean hasQueuedThread(java.lang.Thread)
{
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v;
java.util.concurrent.locks.ReentrantLock v;
java.lang.Thread v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: java.lang.Thread;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: java.util.concurrent.locks.ReentrantLock lock>;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: boolean hasQueuedThread(java.lang.Thread)>(v);
return v;
}
public boolean hasWaiters(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard)
{
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard v;
int v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: int getWaitQueueLength(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard)>(v);
if v <= 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public int getWaitQueueLength(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard)
{
java.lang.Throwable v;
java.util.concurrent.locks.ReentrantLock v, v, v;
java.lang.IllegalMonitorStateException v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard v;
int v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor monitor>;
if v == v goto label;
v = new java.lang.IllegalMonitorStateException;
specialinvoke v.<java.lang.IllegalMonitorStateException: void <init>()>();
throw v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void lock()>();
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: int waiterCount>;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
return v;
label:
v := @caughtexception;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
throw v;
catch java.lang.Throwable from label to label with label;
}
private static long toSafeNanos(long, java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v;
long v, v, v;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = virtualinvoke v.<java.util.concurrent.TimeUnit: long toNanos(long)>(v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.primitives.Longs: long constrainToRange(long,long,long)>(v, 0L, 6917529027641081853L);
return v;
}
private static long initNanoTime(long)
{
byte v, v;
long v, v, v;
v := @parameter: long;
v = v cmp 0L;
if v > 0 goto label;
return 0L;
label:
v = staticinvoke <java.lang.System: long nanoTime()>();
v = v cmp 0L;
if v != 0 goto label;
v = 1L;
goto label;
label:
v = v;
label:
return v;
}
private static long remainingNanos(long, long)
{
byte v;
long v, v, v, v, v;
v := @parameter: long;
v := @parameter: long;
v = v cmp 0L;
if v > 0 goto label;
v = 0L;
goto label;
label:
v = staticinvoke <java.lang.System: long nanoTime()>();
v = v - v;
v = v - v;
label:
return v;
}
private void signalNextWaiter()
{
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard v;
java.util.concurrent.locks.Condition v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard activeGuards>;
label:
if v == null goto label;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: boolean isSatisfied(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard)>(v);
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: java.util.concurrent.locks.Condition condition>;
interfaceinvoke v.<java.util.concurrent.locks.Condition: void signal()>();
goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard next>;
goto label;
label:
return;
}
private boolean isSatisfied(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard)
{
java.lang.Throwable v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: boolean isSatisfied()>();
label:
return v;
label:
v := @caughtexception;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: void signalAllWaiters()>();
throw v;
catch java.lang.Throwable from label to label with label;
}
private void signalAllWaiters()
{
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard v;
java.util.concurrent.locks.Condition v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard activeGuards>;
label:
if v == null goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: java.util.concurrent.locks.Condition condition>;
interfaceinvoke v.<java.util.concurrent.locks.Condition: void signalAll()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard next>;
goto label;
label:
return;
}
private void beginWaitingFor(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard)
{
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard v, v;
int v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: int waiterCount>;
v = v + 1;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: int waiterCount> = v;
if v != 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard activeGuards>;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard next> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard activeGuards> = v;
label:
return;
}
private void endWaitingFor(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard)
{
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard v, v, v, v, v;
int v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: int waiterCount>;
v = v - 1;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: int waiterCount> = v;
if v != 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard activeGuards>;
v = null;
label:
if v != v goto label;
if v != null goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard next>;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard activeGuards> = v;
goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard next>;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard next> = v;
label:
v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard next> = null;
goto label;
label:
v = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard next>;
goto label;
label:
return;
}
private void await(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard, boolean) throws java.lang.InterruptedException
{
java.lang.Throwable v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard v;
java.util.concurrent.locks.Condition v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard;
v := @parameter: boolean;
if v == 0 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: void signalNextWaiter()>();
label:
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: void beginWaitingFor(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard)>(v);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: java.util.concurrent.locks.Condition condition>;
interfaceinvoke v.<java.util.concurrent.locks.Condition: void await()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: boolean isSatisfied()>();
if v == 0 goto label;
label:
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: void endWaitingFor(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard)>(v);
goto label;
label:
v := @caughtexception;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: void endWaitingFor(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard)>(v);
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
private void awaitUninterruptibly(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard, boolean)
{
java.lang.Throwable v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard v;
java.util.concurrent.locks.Condition v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard;
v := @parameter: boolean;
if v == 0 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: void signalNextWaiter()>();
label:
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: void beginWaitingFor(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard)>(v);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: java.util.concurrent.locks.Condition condition>;
interfaceinvoke v.<java.util.concurrent.locks.Condition: void awaitUninterruptibly()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: boolean isSatisfied()>();
if v == 0 goto label;
label:
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: void endWaitingFor(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard)>(v);
goto label;
label:
v := @caughtexception;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: void endWaitingFor(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard)>(v);
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
private boolean awaitNanos(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard, long, boolean) throws java.lang.InterruptedException
{
java.lang.Throwable v;
long v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard v;
java.util.concurrent.locks.Condition v;
byte v;
boolean v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard;
v := @parameter: long;
v := @parameter: boolean;
v = 1;
label:
v = v cmp 0L;
if v > 0 goto label;
label:
if v != 0 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: void endWaitingFor(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard)>(v);
label:
return 0;
label:
if v == 0 goto label;
if v == 0 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: void signalNextWaiter()>();
label:
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: void beginWaitingFor(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard)>(v);
v = 0;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: java.util.concurrent.locks.Condition condition>;
v = interfaceinvoke v.<java.util.concurrent.locks.Condition: long awaitNanos(long)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard: boolean isSatisfied()>();
if v == 0 goto label;
label:
if v != 0 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: void endWaitingFor(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard)>(v);
label:
return 1;
label:
v := @caughtexception;
if v != 0 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor: void endWaitingFor(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Monitor$Guard)>(v);
label:
throw v;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
}