final class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.UnorderedThreadPoolEventExecutor$RunnableScheduledFutureTask extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.PromiseTask implements java.util.concurrent.RunnableScheduledFuture, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.ScheduledFuture
{
private final java.util.concurrent.RunnableScheduledFuture future;
void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor, java.lang.Runnable, java.util.concurrent.RunnableScheduledFuture)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.UnorderedThreadPoolEventExecutor$RunnableScheduledFutureTask v;
java.util.concurrent.RunnableScheduledFuture v;
java.lang.Runnable v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.UnorderedThreadPoolEventExecutor$RunnableScheduledFutureTask;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor;
v := @parameter: java.lang.Runnable;
v := @parameter: java.util.concurrent.RunnableScheduledFuture;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.PromiseTask: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor,java.lang.Runnable)>(v, v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.UnorderedThreadPoolEventExecutor$RunnableScheduledFutureTask: java.util.concurrent.RunnableScheduledFuture future> = v;
return;
}
void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor, java.util.concurrent.Callable, java.util.concurrent.RunnableScheduledFuture)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.UnorderedThreadPoolEventExecutor$RunnableScheduledFutureTask v;
java.util.concurrent.RunnableScheduledFuture v;
java.util.concurrent.Callable v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.UnorderedThreadPoolEventExecutor$RunnableScheduledFutureTask;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor;
v := @parameter: java.util.concurrent.Callable;
v := @parameter: java.util.concurrent.RunnableScheduledFuture;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.PromiseTask: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor,java.util.concurrent.Callable)>(v, v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.UnorderedThreadPoolEventExecutor$RunnableScheduledFutureTask: java.util.concurrent.RunnableScheduledFuture future> = v;
return;
}
public void run()
{
java.lang.Throwable v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.UnorderedThreadPoolEventExecutor$RunnableScheduledFutureTask v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger v;
boolean v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.UnorderedThreadPoolEventExecutor$RunnableScheduledFutureTask;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.UnorderedThreadPoolEventExecutor$RunnableScheduledFutureTask: boolean isPeriodic()>();
if v != 0 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.PromiseTask: void run()>();
goto label;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.UnorderedThreadPoolEventExecutor$RunnableScheduledFutureTask: boolean isDone()>();
if v != 0 goto label;
label:
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.UnorderedThreadPoolEventExecutor$RunnableScheduledFutureTask: java.lang.Object runTask()>();
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.UnorderedThreadPoolEventExecutor$RunnableScheduledFutureTask: boolean tryFailureInternal(java.lang.Throwable)>(v);
if v != 0 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.UnorderedThreadPoolEventExecutor: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger>;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger: void warn(java.lang.String,java.lang.Throwable)>("Failure during execution of task", v);
label:
return;
catch java.lang.Throwable from label to label with label;
}
public boolean isPeriodic()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.UnorderedThreadPoolEventExecutor$RunnableScheduledFutureTask v;
boolean v;
java.util.concurrent.RunnableScheduledFuture v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.UnorderedThreadPoolEventExecutor$RunnableScheduledFutureTask;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.UnorderedThreadPoolEventExecutor$RunnableScheduledFutureTask: java.util.concurrent.RunnableScheduledFuture future>;
v = interfaceinvoke v.<java.util.concurrent.RunnableScheduledFuture: boolean isPeriodic()>();
return v;
}
public long getDelay(java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.UnorderedThreadPoolEventExecutor$RunnableScheduledFutureTask v;
java.util.concurrent.RunnableScheduledFuture v;
long v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.UnorderedThreadPoolEventExecutor$RunnableScheduledFutureTask;
v := @parameter: java.util.concurrent.TimeUnit;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.UnorderedThreadPoolEventExecutor$RunnableScheduledFutureTask: java.util.concurrent.RunnableScheduledFuture future>;
v = interfaceinvoke v.<java.util.concurrent.RunnableScheduledFuture: long getDelay(java.util.concurrent.TimeUnit)>(v);
return v;
}
public int compareTo(java.util.concurrent.Delayed)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.UnorderedThreadPoolEventExecutor$RunnableScheduledFutureTask v;
java.util.concurrent.RunnableScheduledFuture v;
int v;
java.util.concurrent.Delayed v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.UnorderedThreadPoolEventExecutor$RunnableScheduledFutureTask;
v := @parameter: java.util.concurrent.Delayed;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.UnorderedThreadPoolEventExecutor$RunnableScheduledFutureTask: java.util.concurrent.RunnableScheduledFuture future>;
v = interfaceinvoke v.<java.util.concurrent.RunnableScheduledFuture: int compareTo(java.lang.Object)>(v);
return v;
}
}