public abstract class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel 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.util.internal.logging.InternalLogger logger;
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 java.nio.channels.WritableByteChannel byteChannel;
private final java.lang.Runnable flushTask;
static final boolean $assertionsDisabled;
void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket, boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel$1 v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket;
v := @parameter: boolean;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket,boolean)>(v, v, v);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel$1;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel$1: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel: java.lang.Runnable flushTask> = 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.kqueue.BsdSocket, 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.kqueue.AbstractKQueueStreamChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel$1 v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket;
v := @parameter: java.net.SocketAddress;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket,java.net.SocketAddress)>(v, v, v);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel$1;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel$1: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel: java.lang.Runnable flushTask> = v;
return;
}
void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel: boolean isSoErrorZero(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket)>(v);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket,boolean)>(null, v, v);
return;
}
protected org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel$AbstractKQueueUnsafe newUnsafe()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel$KQueueStreamUnsafe v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel$KQueueStreamUnsafe;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel$KQueueStreamUnsafe: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel)>(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.kqueue.AbstractKQueueStreamChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelMetadata v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelMetadata METADATA>;
return v;
}
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.channel.kqueue.AbstractKQueueStreamChannel 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.kqueue.KQueueChannelConfig v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer v;
int v, v, v, v, v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel;
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.kqueue.AbstractKQueueStreamChannel: 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.kqueue.AbstractKQueueStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig config()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig: long getMaxBytesPerGatheringWrite()>();
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel: 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)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel v;
long v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig v, v;
byte v, v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel;
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.kqueue.AbstractKQueueStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig config()>();
v = v << 1;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig: 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.kqueue.AbstractKQueueStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig config()>();
v = v >>> 1;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig: 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
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel v;
long v, v, v, v;
java.lang.AssertionError v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer v;
byte v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
int 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.kqueue.AbstractKQueueStreamChannel;
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.kqueue.AbstractKQueueStreamChannel: 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.kqueue.AbstractKQueueStreamChannel: 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.kqueue.AbstractKQueueStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket socket>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.IovArray: long memoryAddress(int)>(0);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: 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.kqueue.AbstractKQueueStreamChannel: 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;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel v;
long v, v, v;
java.lang.AssertionError v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer v;
byte v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
int v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel;
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.kqueue.AbstractKQueueStreamChannel: 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.kqueue.AbstractKQueueStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket socket>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: 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.kqueue.AbstractKQueueStreamChannel: 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.kqueue.AbstractKQueueStreamChannel v;
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.ChannelOutboundBuffer v;
byte v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel;
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 count()>();
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()>();
return 0;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket socket>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: long position()>();
v = v - v;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: 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.kqueue.AbstractKQueueStreamChannel: 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;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel v;
long v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel$KQueueSocketWritableByteChannel 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.kqueue.AbstractKQueueStreamChannel;
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.kqueue.AbstractKQueueStreamChannel: java.nio.channels.WritableByteChannel byteChannel>;
if v != null goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel$KQueueSocketWritableByteChannel;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel$KQueueSocketWritableByteChannel: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel: java.nio.channels.WritableByteChannel byteChannel> = v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel: 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;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig v;
java.lang.Runnable v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer v;
int v, v, v, v;
java.lang.Object v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel;
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.kqueue.AbstractKQueueStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig config()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig: 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.kqueue.AbstractKQueueStreamChannel: 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;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel: void writeFilter(boolean)>(0);
return;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel: 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;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel: void writeFilter(boolean)>(0);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel: 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.kqueue.AbstractKQueueStreamChannel: 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:
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel: void writeFilter(boolean)>(1);
label:
return;
}
protected int doWriteSingle(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.kqueue.AbstractKQueueStreamChannel v;
java.lang.Error 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 := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel;
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.kqueue.AbstractKQueueStreamChannel: 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.kqueue.AbstractKQueueStreamChannel: 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.kqueue.AbstractKQueueStreamChannel: 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 = 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;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel v;
long v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer 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.kqueue.AbstractKQueueStreamChannel;
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.kqueue.AbstractKQueueStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig config()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig: long getMaxBytesPerGatheringWrite()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop eventLoop()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.IovArray cleanArray()>();
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.kqueue.AbstractKQueueStreamChannel: 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.channel.kqueue.AbstractKQueueStreamChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
java.lang.Object v;
java.lang.String v, v, v;
boolean v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel;
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.kqueue.AbstractKQueueStreamChannel: 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;
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.kqueue.AbstractKQueueStreamChannel: 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.kqueue.AbstractKQueueStreamChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket socket>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: void shutdown(boolean,boolean)>(0, 1);
return;
}
public boolean isOutputShutdown()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket socket>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: boolean isOutputShutdown()>();
return v;
}
public boolean isInputShutdown()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket socket>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: boolean isInputShutdown()>();
return v;
}
public boolean isShutdown()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket socket>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: boolean 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.kqueue.AbstractKQueueStreamChannel 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.kqueue.AbstractKQueueStreamChannel;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel: 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.kqueue.AbstractKQueueStreamChannel: 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.kqueue.AbstractKQueueStreamChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel$2 v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel;
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.kqueue.AbstractKQueueStreamChannel: 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.kqueue.AbstractKQueueStreamChannel: 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.kqueue.AbstractKQueueStreamChannel$2;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel$2: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel,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.kqueue.AbstractKQueueStreamChannel 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.kqueue.AbstractKQueueStreamChannel;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel: 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.kqueue.AbstractKQueueStreamChannel: 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;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel$3 v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel;
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.kqueue.AbstractKQueueStreamChannel: 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.kqueue.AbstractKQueueStreamChannel: 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.kqueue.AbstractKQueueStreamChannel$3;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel$3: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel,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;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel;
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.kqueue.AbstractKQueueStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket socket>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: void shutdown(boolean,boolean)>(1, 0);
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);
return;
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()>();
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 v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel 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.kqueue.AbstractKQueueStreamChannel;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel: 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.kqueue.AbstractKQueueStreamChannel: 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.ChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel$4 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.kqueue.AbstractKQueueStreamChannel;
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.kqueue.AbstractKQueueStreamChannel: 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.kqueue.AbstractKQueueStreamChannel: 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.kqueue.AbstractKQueueStreamChannel$4;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel$4: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel,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.kqueue.AbstractKQueueStreamChannel 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.kqueue.AbstractKQueueStreamChannel$5 v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel;
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.kqueue.AbstractKQueueStreamChannel: 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.kqueue.AbstractKQueueStreamChannel: 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.kqueue.AbstractKQueueStreamChannel$5;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel$5: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel,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.kqueue.AbstractKQueueStreamChannel: 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;
}
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/kqueue/AbstractKQueueStreamChannel;";
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.kqueue.AbstractKQueueStreamChannel: boolean $assertionsDisabled> = 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/kqueue/AbstractKQueueStreamChannel;");
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger> = 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.kqueue.AbstractKQueueStreamChannel: 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.kqueue.AbstractKQueueStreamChannel: java.lang.String EXPECTED_TYPES> = v;
return;
}
}