public class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.oio.OioByteStreamChannel implements org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.SocketChannel
{
private static final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger;
private final java.net.Socket socket;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannelConfig config;
public void <init>()
{
java.net.Socket v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel;
v = new java.net.Socket;
specialinvoke v.<java.net.Socket: void <init>()>();
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: void <init>(java.net.Socket)>(v);
return;
}
public void <init>(java.net.Socket)
{
java.net.Socket v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel;
v := @parameter: java.net.Socket;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel,java.net.Socket)>(null, v);
return;
}
public void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel, java.net.Socket)
{
java.io.OutputStream v;
java.lang.Throwable v;
java.net.Socket v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
java.lang.Exception v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.DefaultOioSocketChannelConfig v;
boolean v;
java.io.InputStream v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel;
v := @parameter: java.net.Socket;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.oio.OioByteStreamChannel: 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.socket.oio.OioSocketChannel: java.net.Socket socket> = v;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.DefaultOioSocketChannelConfig;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.DefaultOioSocketChannelConfig: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel,java.net.Socket)>(v, v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannelConfig config> = v;
label:
v = virtualinvoke v.<java.net.Socket: boolean isConnected()>();
if v == 0 goto label;
v = virtualinvoke v.<java.net.Socket: java.io.InputStream getInputStream()>();
v = virtualinvoke v.<java.net.Socket: java.io.OutputStream getOutputStream()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: void activate(java.io.InputStream,java.io.OutputStream)>(v, v);
label:
virtualinvoke v.<java.net.Socket: void setSoTimeout(int)>(1000);
label:
goto label;
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.String,java.lang.Throwable)>("failed to initialize a socket", v);
throw v;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Exception from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.ServerSocketChannel parent()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.oio.OioByteStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel parent()>();
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannelConfig config()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannelConfig v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannelConfig config>;
return v;
}
public boolean isOpen()
{
java.net.Socket v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: java.net.Socket socket>;
v = virtualinvoke v.<java.net.Socket: boolean isClosed()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public boolean isActive()
{
java.net.Socket v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel v;
boolean v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: java.net.Socket socket>;
v = virtualinvoke v.<java.net.Socket: boolean isClosed()>();
if v != 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: java.net.Socket socket>;
v = virtualinvoke v.<java.net.Socket: boolean isConnected()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public boolean isOutputShutdown()
{
java.net.Socket v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel v;
boolean v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: java.net.Socket socket>;
v = virtualinvoke v.<java.net.Socket: boolean isOutputShutdown()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: boolean isActive()>();
if v != 0 goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public boolean isInputShutdown()
{
java.net.Socket v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel v;
boolean v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: java.net.Socket socket>;
v = virtualinvoke v.<java.net.Socket: boolean isInputShutdown()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: boolean isActive()>();
if v != 0 goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public boolean isShutdown()
{
java.net.Socket v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel v;
boolean v, v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: java.net.Socket socket>;
v = virtualinvoke v.<java.net.Socket: boolean isInputShutdown()>();
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: java.net.Socket socket>;
v = virtualinvoke v.<java.net.Socket: boolean isOutputShutdown()>();
if v != 0 goto label;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: boolean isActive()>();
if v != 0 goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
protected final void doShutdownOutput() throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: void shutdownOutput0()>();
return;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture shutdownOutput()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel 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.ChannelFuture v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise newPromise()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture shutdownOutput(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture shutdownInput()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel 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.ChannelFuture v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise newPromise()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture shutdownInput(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture shutdown()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel 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.ChannelFuture v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise newPromise()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture shutdown(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v);
return v;
}
protected int doReadBytes(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf) throws java.lang.Exception
{
java.net.Socket v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel v;
java.net.SocketTimeoutException v;
int v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel;
v := @parameter: 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.socket.oio.OioSocketChannel: java.net.Socket socket>;
v = virtualinvoke v.<java.net.Socket: boolean isClosed()>();
if v == 0 goto label;
v = (int) -1;
return v;
label:
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.oio.OioByteStreamChannel: int doReadBytes(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v);
label:
return v;
label:
v := @caughtexception;
return 0;
catch java.net.SocketTimeoutException from label to label with label;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture shutdownOutput(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel 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.socket.oio.OioSocketChannel$1 v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: 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.socket.oio.OioSocketChannel: void shutdownOutput0(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v);
goto label;
label:
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel$1;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel$1: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(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 shutdownOutput0(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)
{
java.lang.Throwable v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise;
label:
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: void shutdownOutput0()>();
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise setSuccess()>();
label:
goto label;
label:
v := @caughtexception;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise setFailure(java.lang.Throwable)>(v);
label:
return;
catch java.lang.Throwable from label to label with label;
}
private void shutdownOutput0() throws java.io.IOException
{
java.net.Socket v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: java.net.Socket socket>;
virtualinvoke v.<java.net.Socket: void shutdownOutput()>();
return;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture shutdownInput(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel 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.socket.oio.OioSocketChannel$2 v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: 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.socket.oio.OioSocketChannel: void shutdownInput0(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v);
goto label;
label:
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel$2;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel$2: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(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 shutdownInput0(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)
{
java.lang.Throwable v;
java.net.Socket v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: java.net.Socket socket>;
virtualinvoke v.<java.net.Socket: void shutdownInput()>();
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise setSuccess()>();
label:
goto label;
label:
v := @caughtexception;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise setFailure(java.lang.Throwable)>(v);
label:
return;
catch java.lang.Throwable from label to label with label;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture shutdown(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel 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.socket.oio.OioSocketChannel$3 v;
boolean v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture shutdownOutput()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture: boolean isDone()>();
if v == 0 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: void shutdownOutputDone(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v);
goto label;
label:
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel$3;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel$3: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture addListener(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GenericFutureListener)>(v);
label:
return v;
}
private void shutdownOutputDone(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel 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.socket.oio.OioSocketChannel$4 v;
boolean v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture shutdownInput()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture: boolean isDone()>();
if v == 0 goto label;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: void shutdownDone(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v, v);
goto label;
label:
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel$4;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel$4: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v, v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture addListener(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GenericFutureListener)>(v);
label:
return;
}
private static void shutdownDone(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)
{
java.lang.Throwable v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v, v;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture: java.lang.Throwable cause()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture: java.lang.Throwable cause()>();
if v == null goto label;
if v == null goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger>;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger: void debug(java.lang.String,java.lang.Throwable)>("Exception suppressed because a previous exception occurred.", v);
label:
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise setFailure(java.lang.Throwable)>(v);
goto label;
label:
if v == null goto label;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise setFailure(java.lang.Throwable)>(v);
goto label;
label:
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise setSuccess()>();
label:
return;
}
public java.net.InetSocketAddress localAddress()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel v;
java.net.SocketAddress v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.oio.OioByteStreamChannel: java.net.SocketAddress localAddress()>();
return v;
}
public java.net.InetSocketAddress remoteAddress()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel v;
java.net.SocketAddress v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.oio.OioByteStreamChannel: java.net.SocketAddress remoteAddress()>();
return v;
}
protected java.net.SocketAddress localAddress0()
{
java.net.Socket v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel v;
java.net.SocketAddress v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: java.net.Socket socket>;
v = virtualinvoke v.<java.net.Socket: java.net.SocketAddress getLocalSocketAddress()>();
return v;
}
protected java.net.SocketAddress remoteAddress0()
{
java.net.Socket v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel v;
java.net.SocketAddress v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: java.net.Socket socket>;
v = virtualinvoke v.<java.net.Socket: java.net.SocketAddress getRemoteSocketAddress()>();
return v;
}
protected void doBind(java.net.SocketAddress) throws java.lang.Exception
{
java.net.Socket v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel v;
java.net.SocketAddress v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel;
v := @parameter: java.net.SocketAddress;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: java.net.Socket socket>;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.SocketUtils: void bind(java.net.Socket,java.net.SocketAddress)>(v, v);
return;
}
protected void doConnect(java.net.SocketAddress, java.net.SocketAddress) throws java.lang.Exception
{
java.lang.Throwable v;
java.net.Socket v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel v;
java.net.SocketAddress v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannelConfig v;
java.net.SocketTimeoutException v;
int v;
java.lang.String v;
java.io.OutputStream v;
java.lang.StackTraceElement[] v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ConnectTimeoutException v;
java.io.InputStream v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel;
v := @parameter: java.net.SocketAddress;
v := @parameter: java.net.SocketAddress;
if v == null goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: java.net.Socket socket>;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.SocketUtils: void bind(java.net.Socket,java.net.SocketAddress)>(v, v);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: java.net.Socket socket>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannelConfig config()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannelConfig: int getConnectTimeoutMillis()>();
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.SocketUtils: void connect(java.net.Socket,java.net.SocketAddress,int)>(v, v, v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: java.net.Socket socket>;
v = virtualinvoke v.<java.net.Socket: java.io.InputStream getInputStream()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: java.net.Socket socket>;
v = virtualinvoke v.<java.net.Socket: java.io.OutputStream getOutputStream()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: void activate(java.io.InputStream,java.io.OutputStream)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ConnectTimeoutException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.net.SocketAddress)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("connection timed out: \u0001");
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ConnectTimeoutException: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<java.net.SocketTimeoutException: java.lang.StackTraceElement[] getStackTrace()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ConnectTimeoutException: void setStackTrace(java.lang.StackTraceElement[])>(v);
throw v;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: void doClose()>();
throw v;
label:
return;
catch java.net.SocketTimeoutException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
protected void doDisconnect() throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: void doClose()>();
return;
}
protected void doClose() throws java.lang.Exception
{
java.net.Socket v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: java.net.Socket socket>;
virtualinvoke v.<java.net.Socket: void close()>();
return;
}
protected boolean checkInputShutdown()
{
java.lang.Throwable v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannelConfig v;
int v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: boolean isInputShutdown()>();
if v == 0 goto label;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannelConfig config()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannelConfig: int getSoTimeout()>();
staticinvoke <java.lang.Thread: void sleep(long)>(v);
label:
goto label;
label:
v := @caughtexception;
label:
return 1;
label:
return 0;
catch java.lang.Throwable from label to label with label;
}
protected void setReadPending(boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel;
v := @parameter: boolean;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.oio.OioByteStreamChannel: void setReadPending(boolean)>(v);
return;
}
final void clearReadPending0()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: void clearReadPending()>();
return;
}
static void <clinit>()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLoggerFactory: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger getInstance(java.lang.Class)>(class "Lorg/apache/hive/kudu/org/apache/kudu/shaded/io/netty/channel/socket/oio/OioSocketChannel;");
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.oio.OioSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger> = v;
return;
}
}