abstract class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel 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;
final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket socket;
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;
private volatile java.net.SocketAddress local;
private volatile java.net.SocketAddress remote;
protected int flags;
boolean inputClosedSeenErrorOnRead;
boolean epollInReadyRunnablePending;
protected volatile boolean active;
void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: 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.epoll.LinuxSocket,boolean)>(null, v, 0);
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.epoll.LinuxSocket, boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
java.net.InetSocketAddress v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel v;
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket v;
java.lang.Object v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel;
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.epoll.LinuxSocket;
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 = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: int EPOLLET>;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: int flags> = 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.epoll.AbstractEpollChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket socket> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: boolean active> = v;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket: java.net.InetSocketAddress localAddress()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: java.net.SocketAddress local> = v;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket: java.net.InetSocketAddress remoteAddress()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: 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.epoll.LinuxSocket, java.net.SocketAddress)
{
java.net.SocketAddress v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket v;
java.lang.Object v;
java.net.InetSocketAddress v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel;
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.epoll.LinuxSocket;
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 = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: int EPOLLET>;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: int flags> = 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.epoll.AbstractEpollChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket socket> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: boolean active> = 1;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: java.net.SocketAddress remote> = v;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket: java.net.InetSocketAddress localAddress()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: java.net.SocketAddress local> = v;
return;
}
static boolean isSoErrorZero(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.Socket)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelException v;
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.Socket v;
java.io.IOException v;
boolean v;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.Socket;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.Socket: 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;
}
void setFlag(int) throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel v;
int v, v, v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel;
v := @parameter: int;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: boolean isFlagSet(int)>(v);
if v != 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: int flags>;
v = v | v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: int flags> = v;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: void modifyEvents()>();
label:
return;
}
void clearFlag(int) throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel v;
int v, v, v, v, v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel;
v := @parameter: int;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: boolean isFlagSet(int)>(v);
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: int flags>;
v = (int) -1;
v = v ^ v;
v = v & v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: int flags> = v;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: void modifyEvents()>();
label:
return;
}
boolean isFlagSet(int)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel v;
int v, v, v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel;
v := @parameter: int;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: int flags>;
v = v & v;
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
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.epoll.LinuxSocket v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket socket>;
return v;
}
public abstract org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollChannelConfig config();
public boolean isActive()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: 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.epoll.AbstractEpollChannel 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.epoll.AbstractEpollChannel;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelMetadata METADATA>;
return v;
}
protected void doClose() throws java.lang.Exception
{
java.lang.Throwable v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop v;
java.util.concurrent.ScheduledFuture v;
java.nio.channels.ClosedChannelException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel$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.epoll.AbstractEpollChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket v, v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: boolean active> = 0;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: boolean inputClosedSeenErrorOnRead> = 1;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise connectPromise>;
if v == null goto label;
v = new java.nio.channels.ClosedChannelException;
specialinvoke v.<java.nio.channels.ClosedChannelException: void <init>()>();
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise: boolean tryFailure(java.lang.Throwable)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise connectPromise> = null;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: java.util.concurrent.ScheduledFuture connectTimeoutFuture>;
if v == null goto label;
interfaceinvoke v.<java.util.concurrent.ScheduledFuture: boolean cancel(boolean)>(0);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: java.util.concurrent.ScheduledFuture connectTimeoutFuture> = null;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: boolean isRegistered()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: 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;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: void doDeregister()>();
goto label;
label:
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel$1;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel$1: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel)>(v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop: void execute(java.lang.Runnable)>(v);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket socket>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket: void close()>();
goto label;
label:
v := @caughtexception;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket socket>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket: void close()>();
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
void resetCachedAddresses()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket v, v;
java.net.InetSocketAddress v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket socket>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket: java.net.InetSocketAddress localAddress()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: java.net.SocketAddress local> = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket socket>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket: java.net.InetSocketAddress remoteAddress()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: java.net.SocketAddress remote> = v;
return;
}
protected void doDisconnect() throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: void doClose()>();
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.epoll.AbstractEpollChannel v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel;
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.epoll.EpollEventLoop;
return v;
}
public boolean isOpen()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket socket>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket: 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.epoll.AbstractEpollChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: 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.epoll.EpollEventLoop: void remove(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel)>(v);
return;
}
protected final void doBeginRead() throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel 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.epoll.EpollChannelConfig v;
int v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: 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.epoll.AbstractEpollChannel$AbstractEpollUnsafe: boolean readPending> = 1;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: int EPOLLIN>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: void setFlag(int)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe: boolean maybeMoreDataToRead>;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollChannelConfig config()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe: void executeEpollInReadyRunnable(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig)>(v);
label:
return;
}
final boolean shouldBreakEpollInReady(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket v;
boolean v, v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel;
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.epoll.AbstractEpollChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket socket>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket: boolean isInputShutdown()>();
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: boolean inputClosedSeenErrorOnRead>;
if v != 0 goto label;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: 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.epoll.EpollDomainSocketChannelConfig;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannelConfig: 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 clearEpollIn()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel$2 v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe v;
int v, v, v, v, v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: boolean isRegistered()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: 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.epoll.AbstractEpollChannel: 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.epoll.AbstractEpollChannel$AbstractEpollUnsafe: void clearEpollIn0()>();
goto label;
label:
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel$2;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel$2: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe)>(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 = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: int flags>;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: int EPOLLIN>;
v = (int) -1;
v = v ^ v;
v = v & v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: int flags> = v;
label:
return;
}
private void modifyEvents() throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: boolean isOpen()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: boolean isRegistered()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: 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.epoll.EpollEventLoop: void modify(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel)>(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.epoll.AbstractEpollChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: boolean epollInReadyRunnablePending> = 0;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: 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.epoll.EpollEventLoop: void add(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel)>(v);
return;
}
protected abstract org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe newUnsafe();
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.epoll.AbstractEpollChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel;
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.epoll.AbstractEpollChannel: 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.buffer.ByteBuf v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel 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.epoll.AbstractEpollChannel;
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.epoll.AbstractEpollChannel: 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.epoll.AbstractEpollChannel: 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.epoll.AbstractEpollChannel: 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
{
long v;
java.nio.ByteBuffer 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;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel;
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.epoll.AbstractEpollChannel: 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.epoll.AbstractEpollChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket 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.epoll.LinuxSocket: 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.epoll.AbstractEpollChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket 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.epoll.LinuxSocket: 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
{
long v;
java.nio.ByteBuffer 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;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel;
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.epoll.AbstractEpollChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket 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.epoll.LinuxSocket: 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.epoll.AbstractEpollChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket 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.epoll.LinuxSocket: 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;
}
protected void doBind(java.net.SocketAddress) throws java.lang.Exception
{
java.net.SocketAddress v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket v, v;
java.net.InetSocketAddress v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel;
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.epoll.AbstractEpollChannel: void checkResolvable(java.net.InetSocketAddress)>(v);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket socket>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket: void bind(java.net.SocketAddress)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket socket>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket: java.net.InetSocketAddress localAddress()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: java.net.SocketAddress local> = v;
return;
}
protected boolean doConnect(java.net.SocketAddress, java.net.SocketAddress) throws java.lang.Exception
{
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.epoll.AbstractEpollChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket v, v, v;
boolean v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel;
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.epoll.AbstractEpollChannel: 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.epoll.AbstractEpollChannel: void checkResolvable(java.net.InetSocketAddress)>(v);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: 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.epoll.AbstractEpollChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket socket>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket: void bind(java.net.SocketAddress)>(v);
label:
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: 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.epoll.AbstractEpollChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket socket>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket: 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.epoll.AbstractEpollChannel: java.net.SocketAddress remote> = v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket socket>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket: java.net.InetSocketAddress localAddress()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: java.net.SocketAddress local> = v;
return v;
}
private boolean doConnect0(java.net.SocketAddress) throws java.lang.Exception
{
java.lang.Throwable v;
java.net.SocketAddress v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel v;
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel;
v := @parameter: java.net.SocketAddress;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket socket>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket: boolean connect(java.net.SocketAddress)>(v);
if v != 0 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: int EPOLLOUT>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: void setFlag(int)>(v);
label:
return v;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: void doClose()>();
throw v;
catch java.lang.Throwable from label to label with label;
}
protected java.net.SocketAddress localAddress0()
{
java.net.SocketAddress v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: java.net.SocketAddress local>;
return v;
}
protected java.net.SocketAddress remoteAddress0()
{
java.net.SocketAddress v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: 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.epoll.AbstractEpollChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelMetadata METADATA> = v;
return;
}
}