public class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractServerChannel
{
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig config;
private final java.util.Queue inboundBuffer;
private final java.lang.Runnable shutdownHook;
private volatile int state;
private volatile org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalAddress localAddress;
private volatile boolean acceptInProgress;
public void <init>()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelConfig v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.PreferHeapByteBufAllocator v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel$1 v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator v;
java.util.ArrayDeque v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractServerChannel: void <init>()>();
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelConfig;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelConfig: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig config> = v;
v = new java.util.ArrayDeque;
specialinvoke v.<java.util.ArrayDeque: void <init>()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: java.util.Queue inboundBuffer> = v;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel$1;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel$1: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: java.lang.Runnable shutdownHook> = v;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig config()>();
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.PreferHeapByteBufAllocator;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig config>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator getAllocator()>();
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.PreferHeapByteBufAllocator: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator)>(v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig setAllocator(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator)>(v);
return;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig config()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig config>;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalAddress localAddress()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel v;
java.net.SocketAddress v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractServerChannel: java.net.SocketAddress localAddress()>();
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalAddress remoteAddress()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel v;
java.net.SocketAddress v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractServerChannel: java.net.SocketAddress remoteAddress()>();
return v;
}
public boolean isOpen()
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: int state>;
if v >= 2 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public boolean isActive()
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: int state>;
if v != 1 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
protected boolean isCompatible(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop;
v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SingleThreadEventLoop;
return v;
}
protected java.net.SocketAddress localAddress0()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalAddress v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalAddress localAddress>;
return v;
}
protected void doRegister() throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel v;
java.lang.Runnable v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop eventLoop()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: java.lang.Runnable shutdownHook>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.SingleThreadEventExecutor: void addShutdownHook(java.lang.Runnable)>(v);
return;
}
protected void doBind(java.net.SocketAddress) throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel v;
java.net.SocketAddress v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalAddress v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel;
v := @parameter: java.net.SocketAddress;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalAddress localAddress>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalChannelRegistry: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalAddress register(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalAddress,java.net.SocketAddress)>(v, v, v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalAddress localAddress> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: int state> = 1;
return;
}
protected void doClose() throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel v;
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalAddress v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: int state>;
if v > 1 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalAddress localAddress>;
if v == null goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalAddress localAddress>;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalChannelRegistry: void unregister(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalAddress)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalAddress localAddress> = null;
label:
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: int state> = 2;
label:
return;
}
protected void doDeregister() throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel v;
java.lang.Runnable v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop eventLoop()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: java.lang.Runnable shutdownHook>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.SingleThreadEventExecutor: void removeShutdownHook(java.lang.Runnable)>(v);
return;
}
protected void doBeginRead() throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel v;
java.util.Queue v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: boolean acceptInProgress>;
if v == 0 goto label;
return;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: java.util.Queue inboundBuffer>;
v = interfaceinvoke v.<java.util.Queue: boolean isEmpty()>();
if v == 0 goto label;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: boolean acceptInProgress> = 1;
return;
label:
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: void readInbound()>();
return;
}
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalChannel serve(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalChannel)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalChannel v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel$2 v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalChannel;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalChannel newLocalChannel(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalChannel)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop eventLoop()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop: boolean inEventLoop()>();
if v == 0 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: void serve0(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalChannel)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop eventLoop()>();
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel$2;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel$2: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalChannel)>(v, v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop: void execute(java.lang.Runnable)>(v);
label:
return v;
}
private void readInbound()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig v;
java.lang.Object v;
java.util.Queue v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.RecvByteBufAllocator$Handle v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: 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.RecvByteBufAllocator$Handle recvBufAllocHandle()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig config()>();
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.RecvByteBufAllocator$Handle: void reset(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline pipeline()>();
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: java.util.Queue inboundBuffer>;
v = interfaceinvoke v.<java.util.Queue: java.lang.Object poll()>();
if v == null goto label;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline fireChannelRead(java.lang.Object)>(v);
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.RecvByteBufAllocator$Handle: boolean continueReading()>();
if v != 0 goto label;
label:
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline fireChannelReadComplete()>();
return;
}
protected org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalChannel newLocalChannel(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalChannel)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalChannel v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalChannel;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalChannel;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalChannel: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalChannel)>(v, v);
return v;
}
private void serve0(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalChannel)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel v;
java.util.Queue v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: java.util.Queue inboundBuffer>;
interfaceinvoke v.<java.util.Queue: boolean add(java.lang.Object)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: boolean acceptInProgress>;
if v == 0 goto label;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: boolean acceptInProgress> = 0;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.local.LocalServerChannel: void readInbound()>();
label:
return;
}
}