abstract class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel implements org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.UnixChannel
{
private static final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelMetadata METADATA;
private org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise connectPromise;
private java.util.concurrent.ScheduledFuture connectTimeoutFuture;
private java.net.SocketAddress requestedRemoteAddress;
final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket socket;
private boolean readFilterEnabled;
private boolean writeFilterEnabled;
boolean readReadyRunnablePending;
boolean inputClosedSeenErrorOnRead;
protected volatile boolean active;
private volatile java.net.SocketAddress local;
private volatile java.net.SocketAddress remote;
void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket, boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel 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.kqueue.BsdSocket v;
java.lang.Object v;
java.net.InetSocketAddress v, v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel;
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.kqueue.BsdSocket;
v := @parameter: boolean;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel)>(v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "fd");
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket socket> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: boolean active> = v;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: java.net.InetSocketAddress localAddress()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: java.net.SocketAddress local> = v;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: java.net.InetSocketAddress remoteAddress()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: java.net.SocketAddress remote> = v;
label:
return;
}
void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket, java.net.SocketAddress)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel v;
java.net.SocketAddress 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.kqueue.BsdSocket v;
java.lang.Object v;
java.net.InetSocketAddress v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel;
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.kqueue.BsdSocket;
v := @parameter: java.net.SocketAddress;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel)>(v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "fd");
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket socket> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: boolean active> = 1;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: java.net.SocketAddress remote> = v;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: java.net.InetSocketAddress localAddress()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: java.net.SocketAddress local> = v;
return;
}
static boolean isSoErrorZero(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
int v;
java.io.IOException v;
boolean v;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: int getSoError()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
label:
v := @caughtexception;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelException;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelException: void <init>(java.lang.Throwable)>(v);
throw v;
catch java.io.IOException from label to label with label;
}
public final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor fd()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket socket>;
return v;
}
public boolean isActive()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: boolean active>;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelMetadata metadata()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelMetadata v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelMetadata METADATA>;
return v;
}
protected void doClose() throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: boolean active> = 0;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: boolean inputClosedSeenErrorOnRead> = 1;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket socket>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: void close()>();
return;
}
protected void doDisconnect() throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: void doClose()>();
return;
}
void resetCachedAddresses()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v, v;
java.net.InetSocketAddress v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket socket>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: java.net.InetSocketAddress localAddress()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: java.net.SocketAddress local> = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket socket>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: java.net.InetSocketAddress remoteAddress()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: java.net.SocketAddress remote> = v;
return;
}
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.kqueue.AbstractKQueueChannel v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel;
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.kqueue.KQueueEventLoop;
return v;
}
public boolean isOpen()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket socket>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: boolean isOpen()>();
return v;
}
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.kqueue.AbstractKQueueChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop eventLoop()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: void remove(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: boolean readFilterEnabled> = 0;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: boolean writeFilterEnabled> = 0;
return;
}
void unregisterFilters() throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel v;
short v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: void readFilter(boolean)>(0);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: void writeFilter(boolean)>(0);
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EVFILT_SOCK>;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EV_DELETE>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: void evSet0(short,short,int)>(v, v, 0);
return;
}
protected final void doBeginRead() throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel 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.kqueue.KQueueChannelConfig v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe unsafe()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel$AbstractKQueueUnsafe: boolean readPending> = 1;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: void readFilter(boolean)>(1);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel$AbstractKQueueUnsafe: boolean maybeMoreDataToRead>;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig config()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel$AbstractKQueueUnsafe: void executeReadReadyRunnable(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig)>(v);
label:
return;
}
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.kqueue.AbstractKQueueChannel v;
short v, v, v, v, v, v;
int v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: boolean readReadyRunnablePending> = 0;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop eventLoop()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: void add(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: boolean writeFilterEnabled>;
if v == 0 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EVFILT_WRITE>;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EV_ADD_CLEAR_ENABLE>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: void evSet0(short,short)>(v, v);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: boolean readFilterEnabled>;
if v == 0 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EVFILT_READ>;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EV_ADD_CLEAR_ENABLE>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: void evSet0(short,short)>(v, v);
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EVFILT_SOCK>;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EV_ADD>;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: int NOTE_RDHUP>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: void evSet0(short,short,int)>(v, v, v);
return;
}
protected abstract org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel$AbstractKQueueUnsafe newUnsafe();
public abstract org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig config();
protected final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf newDirectBuffer(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf newDirectBuffer(java.lang.Object,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v, v);
return v;
}
protected final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf newDirectBuffer(java.lang.Object, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v, v, v, v, v;
int v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator v;
java.lang.Object v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel;
v := @parameter: java.lang.Object;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readableBytes()>();
if v != 0 goto label;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ReferenceCountUtil: boolean release(java.lang.Object)>(v);
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.Unpooled: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf EMPTY_BUFFER>;
return v;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator alloc()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator: boolean isDirectBufferPooled()>();
if v == 0 goto label;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf newDirectBuffer0(java.lang.Object,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator,int)>(v, v, v, v);
return v;
label:
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufUtil: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf threadLocalDirectBuffer()>();
if v != null goto label;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf newDirectBuffer0(java.lang.Object,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator,int)>(v, v, v, v);
return v;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readerIndex()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf writeBytes(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,int,int)>(v, v, v);
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ReferenceCountUtil: void safeRelease(java.lang.Object)>(v);
return v;
}
private static org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf newDirectBuffer0(java.lang.Object, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator, int)
{
int v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator v;
java.lang.Object v;
v := @parameter: java.lang.Object;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator;
v := @parameter: int;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf directBuffer(int)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readerIndex()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf writeBytes(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,int,int)>(v, v, v);
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ReferenceCountUtil: void safeRelease(java.lang.Object)>(v);
return v;
}
protected static void checkResolvable(java.net.InetSocketAddress)
{
java.nio.channels.UnresolvedAddressException v;
java.net.InetSocketAddress v;
boolean v;
v := @parameter: java.net.InetSocketAddress;
v = virtualinvoke v.<java.net.InetSocketAddress: boolean isUnresolved()>();
if v == 0 goto label;
v = new java.nio.channels.UnresolvedAddressException;
specialinvoke v.<java.nio.channels.UnresolvedAddressException: void <init>()>();
throw v;
label:
return;
}
protected final int doReadBytes(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf) throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel v;
long v;
java.nio.ByteBuffer v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe v;
int v, v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.RecvByteBufAllocator$Handle v;
boolean v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int writerIndex()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: 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.buffer.ByteBuf: int writableBytes()>();
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.RecvByteBufAllocator$Handle: void attemptedBytesRead(int)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: boolean hasMemoryAddress()>();
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket socket>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: long memoryAddress()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int capacity()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: int readAddress(long,int,int)>(v, v, v);
goto label;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int writableBytes()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: java.nio.ByteBuffer internalNioBuffer(int,int)>(v, v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket socket>;
v = virtualinvoke v.<java.nio.ByteBuffer: int position()>();
v = virtualinvoke v.<java.nio.ByteBuffer: int limit()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: int read(java.nio.ByteBuffer,int,int)>(v, v, v);
label:
if v <= 0 goto label;
v = v + v;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf writerIndex(int)>(v);
label:
return v;
}
protected final int doWriteBytes(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf) throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel v;
long v;
java.nio.ByteBuffer v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v, v;
int v, v, v, v, v, v, v, v, v, v, v;
boolean v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: boolean hasMemoryAddress()>();
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket socket>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: long memoryAddress()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readerIndex()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int writerIndex()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: int writeAddress(long,int,int)>(v, v, v);
if v <= 0 goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer: void removeBytes(long)>(v);
return 1;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int nioBufferCount()>();
if v != 1 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readerIndex()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readableBytes()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: java.nio.ByteBuffer internalNioBuffer(int,int)>(v, v);
goto label;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: java.nio.ByteBuffer nioBuffer()>();
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket socket>;
v = virtualinvoke v.<java.nio.ByteBuffer: int position()>();
v = virtualinvoke v.<java.nio.ByteBuffer: int limit()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: int write(java.nio.ByteBuffer,int,int)>(v, v, v);
if v <= 0 goto label;
v = virtualinvoke v.<java.nio.ByteBuffer: int position()>();
v = v + v;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer position(int)>(v);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer: void removeBytes(long)>(v);
return 1;
label:
return 2147483647;
}
final boolean shouldBreakReadReady(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig v;
boolean v, v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel;
v := @parameter: 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.kqueue.AbstractKQueueChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket socket>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: boolean isInputShutdown()>();
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: boolean inputClosedSeenErrorOnRead>;
if v != 0 goto label;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: boolean isAllowHalfClosure(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig)>(v);
if v != 0 goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
private static boolean isAllowHalfClosure(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig v;
boolean v, v, v, v, v;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig;
v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannelConfig;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannelConfig: boolean isAllowHalfClosure()>();
return v;
label:
v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.SocketChannelConfig;
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.SocketChannelConfig: boolean isAllowHalfClosure()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
final void clearReadFilter()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel$1 v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: boolean isRegistered()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop eventLoop()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: 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.EventLoop: boolean inEventLoop()>();
if v == 0 goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel$AbstractKQueueUnsafe: void clearReadFilter0()>();
goto label;
label:
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel$1;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel$1: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel$AbstractKQueueUnsafe)>(v, v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop: void execute(java.lang.Runnable)>(v);
goto label;
label:
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: boolean readFilterEnabled> = 0;
label:
return;
}
void readFilter(boolean) throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel v;
short v, v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel;
v := @parameter: boolean;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: boolean readFilterEnabled>;
if v == v goto label;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: boolean readFilterEnabled> = v;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EVFILT_READ>;
if v == 0 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EV_ADD_CLEAR_ENABLE>;
goto label;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EV_DELETE_DISABLE>;
label:
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: void evSet(short,short)>(v, v);
label:
return;
}
void writeFilter(boolean) throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel v;
short v, v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel;
v := @parameter: boolean;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: boolean writeFilterEnabled>;
if v == v goto label;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: boolean writeFilterEnabled> = v;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EVFILT_WRITE>;
if v == 0 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EV_ADD_CLEAR_ENABLE>;
goto label;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EV_DELETE_DISABLE>;
label:
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: void evSet(short,short)>(v, v);
label:
return;
}
private void evSet(short, short)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel v;
short v, v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel;
v := @parameter: short;
v := @parameter: short;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: boolean isRegistered()>();
if v == 0 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: void evSet0(short,short)>(v, v);
label:
return;
}
private void evSet0(short, short)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel v;
short v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel;
v := @parameter: short;
v := @parameter: short;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: void evSet0(short,short,int)>(v, v, 0);
return;
}
private void evSet0(short, short, int)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel v;
short v, v;
int v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel;
v := @parameter: short;
v := @parameter: short;
v := @parameter: int;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: boolean isOpen()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop eventLoop()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: void evSet(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel,short,short,int)>(v, v, v, v);
label:
return;
}
protected void doBind(java.net.SocketAddress) throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel v;
java.net.SocketAddress v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v, v;
java.net.InetSocketAddress v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel;
v := @parameter: java.net.SocketAddress;
v = v instanceof java.net.InetSocketAddress;
if v == 0 goto label;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: void checkResolvable(java.net.InetSocketAddress)>(v);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket socket>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: void bind(java.net.SocketAddress)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket socket>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: java.net.InetSocketAddress localAddress()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: java.net.SocketAddress local> = v;
return;
}
protected boolean doConnect(java.net.SocketAddress, java.net.SocketAddress) throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel v;
java.net.SocketAddress v, v, v, v;
java.nio.channels.AlreadyConnectedException v;
java.net.InetSocketAddress v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v, v, v;
boolean v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel;
v := @parameter: java.net.SocketAddress;
v := @parameter: java.net.SocketAddress;
v = v instanceof java.net.InetSocketAddress;
if v == 0 goto label;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: void checkResolvable(java.net.InetSocketAddress)>(v);
label:
v = v instanceof java.net.InetSocketAddress;
if v != 0 goto label;
v = null;
label:
v = v;
if v == null goto label;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: void checkResolvable(java.net.InetSocketAddress)>(v);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: java.net.SocketAddress remote>;
if v == null goto label;
v = new java.nio.channels.AlreadyConnectedException;
specialinvoke v.<java.nio.channels.AlreadyConnectedException: void <init>()>();
throw v;
label:
if v == null goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket socket>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: void bind(java.net.SocketAddress)>(v);
label:
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: boolean doConnect0(java.net.SocketAddress)>(v);
if v == 0 goto label;
if v != null goto label;
v = v;
goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket socket>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: java.net.InetSocketAddress remoteAddress()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.UnixChannelUtil: java.net.InetSocketAddress computeRemoteAddr(java.net.InetSocketAddress,java.net.InetSocketAddress)>(v, v);
label:
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: java.net.SocketAddress remote> = v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket socket>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: java.net.InetSocketAddress localAddress()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: java.net.SocketAddress local> = v;
return v;
}
private boolean doConnect0(java.net.SocketAddress) throws java.lang.Exception
{
java.lang.Throwable v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel v;
java.net.SocketAddress v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel;
v := @parameter: java.net.SocketAddress;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket socket>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: boolean connect(java.net.SocketAddress)>(v);
if v != 0 goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: void writeFilter(boolean)>(1);
label:
return v;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: void doClose()>();
throw v;
catch java.lang.Throwable from label to label with label;
}
protected java.net.SocketAddress localAddress0()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel v;
java.net.SocketAddress v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: java.net.SocketAddress local>;
return v;
}
protected java.net.SocketAddress remoteAddress0()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel v;
java.net.SocketAddress v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: java.net.SocketAddress remote>;
return v;
}
static void <clinit>()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelMetadata v;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelMetadata;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelMetadata: void <init>(boolean)>(0);
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelMetadata METADATA> = v;
return;
}
}