public class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoop extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SingleThreadEventLoop
{
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoopGroup parent;
private org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel ch;
public void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoopGroup)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoop v;
java.util.concurrent.Executor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoopGroup v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoop;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoopGroup;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoopGroup: java.util.concurrent.Executor executor>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SingleThreadEventLoop: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoopGroup,java.util.concurrent.Executor,boolean)>(v, v, 1);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoop: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoopGroup parent> = v;
return;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture register(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoop$1 v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoop v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoop;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SingleThreadEventLoop: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture register(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoop$1;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoop$1: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoop)>(v);
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture addListener(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GenericFutureListener)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture register(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoop$2 v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoop v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoop;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SingleThreadEventLoop: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture register(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoop$2;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoop$2: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoop)>(v);
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture addListener(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GenericFutureListener)>(v);
return v;
}
protected void run()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoop v;
java.lang.Runnable v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe v, v;
boolean v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoop;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoop: java.lang.Runnable takeTask()>();
if v == null goto label;
interfaceinvoke v.<java.lang.Runnable: void run()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoop: void updateLastExecutionTime()>();
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoop: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel ch>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoop: boolean isShuttingDown()>();
if v == 0 goto label;
if v == null goto label;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe unsafe()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe unsafe()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise voidPromise()>();
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe: void close(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v);
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoop: boolean confirmShutdown()>();
if v == 0 goto label;
goto label;
label:
if v == null goto label;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel: boolean isRegistered()>();
if v != 0 goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoop: boolean runAllTasks()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoop: void deregister()>();
goto label;
label:
return;
}
protected void deregister()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoopGroup v, v;
java.util.Set v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoop v;
java.util.Queue v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoop;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoop: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel ch> = null;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoop: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoopGroup parent>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoopGroup: java.util.Set activeChildren>;
interfaceinvoke v.<java.util.Set: boolean remove(java.lang.Object)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoop: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoopGroup parent>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoopGroup: java.util.Queue idleChildren>;
interfaceinvoke v.<java.util.Queue: boolean add(java.lang.Object)>(v);
return;
}
public int registeredChannels()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoop v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ThreadPerChannelEventLoop;
return 1;
}
}