public abstract class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor extends java.util.concurrent.AbstractExecutorService implements org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor
{
private static final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger;
static final long DEFAULT_SHUTDOWN_QUIET_PERIOD;
static final long DEFAULT_SHUTDOWN_TIMEOUT;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup parent;
private final java.util.Collection selfCollection;
protected void <init>()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup)>(null);
return;
}
protected void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup)
{
java.util.Set v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup;
specialinvoke v.<java.util.concurrent.AbstractExecutorService: void <init>()>();
v = staticinvoke <java.util.Collections: java.util.Set singleton(java.lang.Object)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor: java.util.Collection selfCollection> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup parent> = v;
return;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup parent()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup parent>;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor next()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor;
return v;
}
public boolean inEventLoop()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor v;
boolean v;
java.lang.Thread v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor: boolean inEventLoop(java.lang.Thread)>(v);
return v;
}
public java.util.Iterator iterator()
{
java.util.Iterator v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor v;
java.util.Collection v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor: java.util.Collection selfCollection>;
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future shutdownGracefully()
{
java.util.concurrent.TimeUnit v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future shutdownGracefully(long,long,java.util.concurrent.TimeUnit)>(2L, 15L, v);
return v;
}
public abstract void shutdown();
public java.util.List shutdownNow()
{
java.util.List v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor: void shutdown()>();
v = staticinvoke <java.util.Collections: java.util.List emptyList()>();
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Promise newPromise()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.DefaultPromise v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.DefaultPromise;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.DefaultPromise: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.ProgressivePromise newProgressivePromise()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.DefaultProgressivePromise v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.DefaultProgressivePromise;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.DefaultProgressivePromise: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future newSucceededFuture(java.lang.Object)
{
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.SucceededFuture v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor;
v := @parameter: java.lang.Object;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.SucceededFuture;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.SucceededFuture: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor,java.lang.Object)>(v, v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future newFailedFuture(java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.FailedFuture v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor;
v := @parameter: java.lang.Throwable;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.FailedFuture;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.FailedFuture: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor,java.lang.Throwable)>(v, v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future submit(java.lang.Runnable)
{
java.util.concurrent.Future v;
java.lang.Runnable v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor;
v := @parameter: java.lang.Runnable;
v = specialinvoke v.<java.util.concurrent.AbstractExecutorService: java.util.concurrent.Future submit(java.lang.Runnable)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future submit(java.lang.Runnable, java.lang.Object)
{
java.util.concurrent.Future v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor v;
java.lang.Object v;
java.lang.Runnable v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor;
v := @parameter: java.lang.Runnable;
v := @parameter: java.lang.Object;
v = specialinvoke v.<java.util.concurrent.AbstractExecutorService: java.util.concurrent.Future submit(java.lang.Runnable,java.lang.Object)>(v, v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future submit(java.util.concurrent.Callable)
{
java.util.concurrent.Callable v;
java.util.concurrent.Future v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor;
v := @parameter: java.util.concurrent.Callable;
v = specialinvoke v.<java.util.concurrent.AbstractExecutorService: java.util.concurrent.Future submit(java.util.concurrent.Callable)>(v);
return v;
}
protected final java.util.concurrent.RunnableFuture newTaskFor(java.lang.Runnable, java.lang.Object)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor v;
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.PromiseTask v;
java.lang.Runnable v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor;
v := @parameter: java.lang.Runnable;
v := @parameter: java.lang.Object;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.PromiseTask;
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,java.lang.Object)>(v, v, v);
return v;
}
protected final java.util.concurrent.RunnableFuture newTaskFor(java.util.concurrent.Callable)
{
java.util.concurrent.Callable v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.PromiseTask v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor;
v := @parameter: java.util.concurrent.Callable;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.PromiseTask;
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);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.ScheduledFuture schedule(java.lang.Runnable, long, java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v;
java.lang.UnsupportedOperationException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor v;
long v;
java.lang.Runnable v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor;
v := @parameter: java.lang.Runnable;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>()>();
throw v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.ScheduledFuture schedule(java.util.concurrent.Callable, long, java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v;
java.lang.UnsupportedOperationException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor v;
java.util.concurrent.Callable v;
long v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor;
v := @parameter: java.util.concurrent.Callable;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>()>();
throw v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.ScheduledFuture scheduleAtFixedRate(java.lang.Runnable, long, long, java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v;
java.lang.UnsupportedOperationException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor v;
long v, v;
java.lang.Runnable v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor;
v := @parameter: java.lang.Runnable;
v := @parameter: long;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>()>();
throw v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.ScheduledFuture scheduleWithFixedDelay(java.lang.Runnable, long, long, java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v;
java.lang.UnsupportedOperationException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor v;
long v, v;
java.lang.Runnable v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor;
v := @parameter: java.lang.Runnable;
v := @parameter: long;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>()>();
throw v;
}
protected static void safeExecute(java.lang.Runnable)
{
java.lang.Throwable v;
java.lang.Runnable v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger v;
v := @parameter: java.lang.Runnable;
label:
interfaceinvoke v.<java.lang.Runnable: void run()>();
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor: 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.Object,java.lang.Object)>("A task raised an exception. Task: {}", v, v);
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void lazyExecute(java.lang.Runnable)
{
java.lang.Runnable v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor;
v := @parameter: java.lang.Runnable;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor: void execute(java.lang.Runnable)>(v);
return;
}
static void <clinit>()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLoggerFactory: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger getInstance(java.lang.Class)>(class "Lorg/apache/hive/kudu/org/apache/kudu/shaded/io/netty/util/concurrent/AbstractEventExecutor;");
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.AbstractEventExecutor: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger> = v;
return;
}
}