public abstract class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel implements org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.DuplexChannel
{
private static final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelMetadata METADATA;
private static final java.lang.String EXPECTED_TYPES;
private static final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger;
private final java.lang.Runnable flushTask;
private volatile java.util.Queue spliceQueue;
private org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor pipeIn;
private org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor pipeOut;
private java.nio.channels.WritableByteChannel byteChannel;
static final boolean $assertionsDisabled;
protected void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel, int)
{
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;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel;
v := @parameter: int;
v = new 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.LinuxSocket: void <init>(int)>(v);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: 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)>(v, v);
return;
}
protected void <init>(int)
{
int v;
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.AbstractEpollStreamChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
v := @parameter: int;
v = new 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.LinuxSocket: void <init>(int)>(v);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket)>(v);
return;
}
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;
boolean v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: boolean isSoErrorZero(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.Socket)>(v);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket,boolean)>(v, v);
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)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$1 v;
int v, v, v;
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.AbstractEpollStreamChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
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;
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)>(v, v, 1);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$1;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$1: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: java.lang.Runnable flushTask> = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: int flags>;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: int EPOLLRDHUP>;
v = v | v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: int flags> = v;
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.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$1 v;
int v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
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.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,java.net.SocketAddress)>(v, v, v);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$1;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$1: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: java.lang.Runnable flushTask> = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: int flags>;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: int EPOLLRDHUP>;
v = v | v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: int flags> = v;
return;
}
protected void <init>(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.epoll.AbstractEpollStreamChannel$1 v;
int v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket v;
boolean v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
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.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, v);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$1;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$1: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: java.lang.Runnable flushTask> = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: int flags>;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: int EPOLLRDHUP>;
v = v | v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: int flags> = v;
return;
}
protected org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe newUnsafe()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel)>(v);
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.ChannelMetadata v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelMetadata METADATA>;
return v;
}
public final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture spliceTo(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel, int)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
v := @parameter: int;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: 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.epoll.AbstractEpollStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture spliceTo(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel,int,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v, v);
return v;
}
public final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture spliceTo(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel, int, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)
{
java.lang.IllegalStateException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop v, v;
int v;
java.lang.String v;
boolean v;
java.nio.channels.ClosedChannelException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollMode v, v, v, v, v;
java.lang.IllegalArgumentException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel 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.channel.epoll.AbstractEpollStreamChannel$SpliceInChannelTask v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollChannelConfig v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
v := @parameter: int;
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.epoll.AbstractEpollStreamChannel: 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.AbstractEpollStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop eventLoop()>();
if v == v goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("EventLoops are not the same.");
throw v;
label:
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: int checkPositiveOrZero(int,java.lang.String)>(v, "len");
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollChannelConfig config()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollMode getEpollMode()>();
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollMode: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollMode LEVEL_TRIGGERED>;
if v != v goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollChannelConfig config()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollMode getEpollMode()>();
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollMode: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollMode LEVEL_TRIGGERED>;
if v == v goto label;
label:
v = new java.lang.IllegalStateException;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollMode: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollMode LEVEL_TRIGGERED>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollMode)>(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[])>("spliceTo() supported only when using \u0001");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
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, "promise");
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: boolean isOpen()>();
if v != 0 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);
goto label;
label:
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$SpliceInChannelTask;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$SpliceInChannelTask: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel,int,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v, v, v);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: void addToSpliceQueue(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$SpliceInTask)>(v);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: void failSpliceIfClosed(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v);
label:
return v;
}
public final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture spliceTo(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor, int, int)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
int v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor;
v := @parameter: int;
v := @parameter: int;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: 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.epoll.AbstractEpollStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture spliceTo(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor,int,int,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v, v, v);
return v;
}
public final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture spliceTo(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor, int, int, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)
{
java.lang.IllegalStateException v;
java.nio.channels.ClosedChannelException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollMode v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$SpliceFdTask 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.EpollChannelConfig v;
int v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor v;
java.lang.String v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor;
v := @parameter: int;
v := @parameter: int;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: int checkPositiveOrZero(int,java.lang.String)>(v, "len");
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: int checkPositiveOrZero(int,java.lang.String)>(v, "offset");
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollChannelConfig config()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollMode getEpollMode()>();
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollMode: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollMode LEVEL_TRIGGERED>;
if v == v goto label;
v = new java.lang.IllegalStateException;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollMode: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollMode LEVEL_TRIGGERED>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollMode)>(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[])>("spliceTo() supported only when using \u0001");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
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, "promise");
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: boolean isOpen()>();
if v != 0 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);
goto label;
label:
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$SpliceFdTask;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$SpliceFdTask: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor,int,int,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v, v, v, v);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: void addToSpliceQueue(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$SpliceInTask)>(v);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: void failSpliceIfClosed(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v);
label:
return v;
}
private void failSpliceIfClosed(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.ChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$2 v;
java.nio.channels.ClosedChannelException v;
boolean v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
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.epoll.AbstractEpollStreamChannel: boolean isOpen()>();
if v != 0 goto label;
v = new java.nio.channels.ClosedChannelException;
specialinvoke v.<java.nio.channels.ClosedChannelException: void <init>()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise: boolean tryFailure(java.lang.Throwable)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop eventLoop()>();
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$2;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$2: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel)>(v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop: void execute(java.lang.Runnable)>(v);
label:
return;
}
private int writeBytes(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
{
java.nio.ByteBuffer[] v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
long v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel 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.EpollChannelConfig v;
int v, v, v, v, v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
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: int readableBytes()>();
if v != 0 goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer: boolean remove()>();
return 0;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: boolean hasMemoryAddress()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int nioBufferCount()>();
if v != 1 goto label;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: 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)>(v, v);
return v;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: java.nio.ByteBuffer[] nioBuffers()>();
v = lengthof v;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollChannelConfig config()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollChannelConfig: long getMaxBytesPerGatheringWrite()>();
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: int writeBytesMultiple(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer,java.nio.ByteBuffer[],int,long,long)>(v, v, v, v, v);
return v;
}
private void adjustMaxBytesPerGatheringWrite(long, long, long)
{
long v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel v;
byte v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollChannelConfig v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
v := @parameter: long;
v := @parameter: long;
v := @parameter: long;
v = v cmp v;
if v != 0 goto label;
v = v << 1;
v = v cmp v;
if v <= 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollChannelConfig config()>();
v = v << 1;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollChannelConfig: void setMaxBytesPerGatheringWrite(long)>(v);
goto label;
label:
v = v cmp 4096L;
if v <= 0 goto label;
v = v >>> 1;
v = v cmp v;
if v >= 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollChannelConfig config()>();
v = v >>> 1;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollChannelConfig: void setMaxBytesPerGatheringWrite(long)>(v);
label:
return;
}
private int writeBytesMultiple(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.IovArray) throws java.io.IOException
{
long v, v, v, v;
java.lang.AssertionError v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer v;
byte v, v;
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket v;
boolean v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.IovArray v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
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.channel.unix.IovArray;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.IovArray: long size()>();
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: boolean $assertionsDisabled>;
if v != 0 goto label;
v = v cmp 0L;
if v != 0 goto label;
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>()>();
throw v;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.IovArray: int count()>();
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: boolean $assertionsDisabled>;
if v != 0 goto label;
if v != 0 goto label;
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>()>();
throw v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: 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.unix.IovArray: long memoryAddress(int)>(0);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket: long writevAddresses(long,int)>(v, v);
v = v cmp 0L;
if v <= 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.IovArray: long maxBytes()>();
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: void adjustMaxBytesPerGatheringWrite(long,long,long)>(v, v, v);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer: void removeBytes(long)>(v);
return 1;
label:
return 2147483647;
}
private int writeBytesMultiple(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer, java.nio.ByteBuffer[], int, long, long) throws java.io.IOException
{
java.nio.ByteBuffer[] v;
long v, v, v;
java.lang.AssertionError v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer v;
byte v, v, 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.AbstractEpollStreamChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer;
v := @parameter: java.nio.ByteBuffer[];
v := @parameter: int;
v := @parameter: long;
v := @parameter: long;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: boolean $assertionsDisabled>;
if v != 0 goto label;
v = v cmp 0L;
if v != 0 goto label;
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>()>();
throw v;
label:
v = v cmp v;
if v <= 0 goto label;
v = v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: 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: long writev(java.nio.ByteBuffer[],int,int,long)>(v, 0, v, v);
v = v cmp 0L;
if v <= 0 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: void adjustMaxBytesPerGatheringWrite(long,long,long)>(v, v, v);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer: void removeBytes(long)>(v);
return 1;
label:
return 2147483647;
}
private int writeDefaultFileRegion(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion) throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion v;
long v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer v;
byte v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
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.channel.DefaultFileRegion;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: long transferred()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: long count()>();
v = v cmp v;
if v < 0 goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer: boolean remove()>();
return 0;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: 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.DefaultFileRegion: long position()>();
v = v - v;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket: long sendFile(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion,long,long,long)>(v, v, v, v);
v = v cmp 0L;
if v <= 0 goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer: void progress(long)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: long transferred()>();
v = v cmp v;
if v < 0 goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer: boolean remove()>();
label:
return 1;
label:
v = v cmp 0L;
if v != 0 goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: void validateFileRegion(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion,long)>(v, v);
label:
return 2147483647;
}
private int writeFileRegion(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.FileRegion) throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.FileRegion v;
long v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$EpollSocketWritableByteChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer v;
byte v, v, v;
java.nio.channels.WritableByteChannel v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
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.channel.FileRegion;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.FileRegion: long transferred()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.FileRegion: long count()>();
v = v cmp v;
if v < 0 goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer: boolean remove()>();
return 0;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: java.nio.channels.WritableByteChannel byteChannel>;
if v != null goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$EpollSocketWritableByteChannel;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$EpollSocketWritableByteChannel: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: java.nio.channels.WritableByteChannel byteChannel> = v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: java.nio.channels.WritableByteChannel byteChannel>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.FileRegion: long transferred()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.FileRegion: long transferTo(java.nio.channels.WritableByteChannel,long)>(v, v);
v = v cmp 0L;
if v <= 0 goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer: void progress(long)>(v);
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.FileRegion: long transferred()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.FileRegion: long count()>();
v = v cmp v;
if v < 0 goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer: boolean remove()>();
label:
return 1;
label:
return 2147483647;
}
protected void doWrite(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer) throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop v;
java.lang.Runnable v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel 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.EpollChannelConfig v;
int v, v, v, v, v, v, v;
java.lang.Object v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollChannelConfig config()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollChannelConfig: int getWriteSpinCount()>();
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer: int size()>();
if v <= 1 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer: java.lang.Object current()>();
v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
if v == 0 goto label;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: int doWriteMultiple(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer)>(v);
v = v - v;
goto label;
label:
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.AbstractEpollStreamChannel: void clearFlag(int)>(v);
return;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: int doWriteSingle(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer)>(v);
v = v - v;
label:
if v > 0 goto label;
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.AbstractEpollStreamChannel: void clearFlag(int)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop eventLoop()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: java.lang.Runnable flushTask>;
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.epoll.Native: int EPOLLOUT>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: void setFlag(int)>(v);
label:
return;
}
protected int doWriteSingle(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer) throws java.lang.Exception
{
java.lang.Error v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer v;
int v, v, v;
java.lang.Object v;
boolean v, v, v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer: java.lang.Object current()>();
v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
if v == 0 goto label;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: int writeBytes(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v, v);
return v;
label:
v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion;
if v == 0 goto label;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: int writeDefaultFileRegion(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion)>(v, v);
return v;
label:
v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.FileRegion;
if v == 0 goto label;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: int writeFileRegion(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.FileRegion)>(v, v);
return v;
label:
v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$SpliceOutTask;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$SpliceOutTask: boolean spliceOut()>();
if v != 0 goto label;
return 2147483647;
label:
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer: boolean remove()>();
return 1;
label:
v = new java.lang.Error;
specialinvoke v.<java.lang.Error: void <init>()>();
throw v;
}
private int doWriteMultiple(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer) throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop v;
long v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel 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.EpollChannelConfig v;
int v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.IovArray v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollChannelConfig config()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollChannelConfig: long getMaxBytesPerGatheringWrite()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: 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.EpollEventLoop: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.IovArray cleanIovArray()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.IovArray: void maxBytes(long)>(v);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer: void forEachFlushedMessage(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer$MessageProcessor)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.IovArray: int count()>();
if v < 1 goto label;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: int writeBytesMultiple(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.IovArray)>(v, v);
return v;
label:
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer: void removeBytes(long)>(0L);
return 0;
}
protected java.lang.Object filterOutboundMessage(java.lang.Object)
{
java.lang.UnsupportedOperationException 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.AbstractEpollStreamChannel v;
java.lang.Object v;
java.lang.String v, v, v;
boolean v, v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
v := @parameter: java.lang.Object;
v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
if v == 0 goto label;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.UnixChannelUtil: boolean isBufferCopyNeededForWrite(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: 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)>(v);
goto label;
label:
v = v;
label:
return v;
label:
v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.FileRegion;
if v != 0 goto label;
v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$SpliceOutTask;
if v == 0 goto label;
label:
return v;
label:
v = new java.lang.UnsupportedOperationException;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.StringUtil: java.lang.String simpleClassName(java.lang.Object)>(v);
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: java.lang.String EXPECTED_TYPES>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, 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[])>("unsupported message type: \u0001\u0001");
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>(v);
throw v;
}
protected final void doShutdownOutput() throws java.lang.Exception
{
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.AbstractEpollStreamChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: 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 shutdown(boolean,boolean)>(0, 1);
return;
}
private void shutdownInput0(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.ChannelPromise v;
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.AbstractEpollStreamChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
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.epoll.AbstractEpollStreamChannel: 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 shutdown(boolean,boolean)>(1, 0);
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 boolean isOutputShutdown()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket v;
boolean v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: 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 isOutputShutdown()>();
return v;
}
public boolean isInputShutdown()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket v;
boolean v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: 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()>();
return v;
}
public boolean isShutdown()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket v;
boolean v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: 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 isShutdown()>();
return v;
}
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 v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: 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.epoll.AbstractEpollStreamChannel: 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 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.ChannelPromise 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.AbstractEpollStreamChannel$3 v;
boolean v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
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.epoll.AbstractEpollStreamChannel: 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;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe unsafe()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel$AbstractUnsafe: void shutdownOutput(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.epoll.AbstractEpollStreamChannel$3;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$3: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel,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;
}
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 v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: 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.epoll.AbstractEpollStreamChannel: 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 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;
java.util.concurrent.Executor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$5 v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$4 v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
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.epoll.AbstractEpollStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe unsafe()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe: java.util.concurrent.Executor prepareToClose()>();
if v == null goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$4;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$4: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v);
interfaceinvoke v.<java.util.concurrent.Executor: void execute(java.lang.Runnable)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: 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.epoll.AbstractEpollStreamChannel: 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.epoll.AbstractEpollStreamChannel$5;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$5: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel,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;
}
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 v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: 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.epoll.AbstractEpollStreamChannel: 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;
}
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.epoll.AbstractEpollStreamChannel$6 v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
boolean v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
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.epoll.AbstractEpollStreamChannel: 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.epoll.AbstractEpollStreamChannel: 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.epoll.AbstractEpollStreamChannel$6;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$6: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel,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.ChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$7 v;
boolean v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
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.epoll.AbstractEpollStreamChannel: 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.epoll.AbstractEpollStreamChannel: 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.epoll.AbstractEpollStreamChannel$7;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$7: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel,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.epoll.AbstractEpollStreamChannel: 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;
}
protected void doClose() throws java.lang.Exception
{
java.lang.Throwable v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
label:
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: void doClose()>();
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor pipeIn>;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: void safeClosePipe(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor pipeOut>;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: void safeClosePipe(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor)>(v);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: void clearSpliceQueue()>();
goto label;
label:
v := @caughtexception;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor pipeIn>;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: void safeClosePipe(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor pipeOut>;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: void safeClosePipe(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor)>(v);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: void clearSpliceQueue()>();
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
private void clearSpliceQueue()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
java.nio.channels.ClosedChannelException v, v;
java.lang.Object v;
java.util.Queue v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: java.util.Queue spliceQueue>;
if v != null goto label;
return;
label:
v = null;
label:
v = interfaceinvoke v.<java.util.Queue: java.lang.Object poll()>();
if v == null goto label;
if v != null goto label;
v = new java.nio.channels.ClosedChannelException;
specialinvoke v.<java.nio.channels.ClosedChannelException: void <init>()>();
v = v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$SpliceInTask: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise promise>;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise: boolean tryFailure(java.lang.Throwable)>(v);
goto label;
label:
return;
}
private static void safeClosePipe(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor v;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor;
return;
}
private void addToSpliceQueue(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$SpliceInTask)
{
java.lang.Throwable v;
java.util.Queue v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$SpliceInTask v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel$SpliceInTask;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: java.util.Queue spliceQueue>;
if v != null goto label;
entermonitor v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: java.util.Queue spliceQueue>;
if v != null goto label;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.PlatformDependent: java.util.Queue newMpscQueue()>();
v = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: java.util.Queue spliceQueue> = v;
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
interfaceinvoke v.<java.util.Queue: boolean add(java.lang.Object)>(v);
return;
catch java.lang.Throwable from label to label with label;
}
static void <clinit>()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger v;
java.lang.Class v;
java.lang.String v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelMetadata v;
boolean v, v;
v = class "Lorg/apache/hive/kudu/org/apache/kudu/shaded/io/netty/channel/epoll/AbstractEpollStreamChannel;";
v = virtualinvoke v.<java.lang.Class: boolean desiredAssertionStatus()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: boolean $assertionsDisabled> = 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,int)>(0, 16);
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelMetadata METADATA> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.StringUtil: java.lang.String simpleClassName(java.lang.Class)>(class "Lorg/apache/hive/kudu/org/apache/kudu/shaded/io/netty/buffer/ByteBuf;");
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.StringUtil: java.lang.String simpleClassName(java.lang.Class)>(class "Lorg/apache/hive/kudu/org/apache/kudu/shaded/io/netty/channel/DefaultFileRegion;");
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, 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[])>(" (expected: \u, \u)");
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: java.lang.String EXPECTED_TYPES> = 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/epoll/AbstractEpollStreamChannel;");
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger> = v;
return;
}
}