final class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel$KQueueStreamUnsafe
{
final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel this$0;
private void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel this$0> = v;
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;
}
void readReady(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe v;
java.lang.Error v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.DomainSocketReadMode v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle v;
int[] v;
int v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannelConfig v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel$1: int[] $SwitchMap$io$netty$channel$unix$DomainSocketReadMode>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel this$0>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannelConfig config()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.DomainSocketReadMode getReadMode()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.DomainSocketReadMode: int ordinal()>();
v = v[v];
lookupswitch(v)
{
case 1: goto label;
case 2: goto label;
default: goto label;
};
label:
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel$KQueueStreamUnsafe: void readReady(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle)>(v);
goto label;
label:
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe: void readReadyFd()>();
goto label;
label:
v = new java.lang.Error;
specialinvoke v.<java.lang.Error: void <init>()>();
throw v;
label:
return;
}
private void readReadyFd()
{
java.lang.Throwable v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v, v;
int v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor v;
boolean v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle 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.ChannelPipeline v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannelConfig v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel v, v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket socket>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: boolean isInputShutdown()>();
if v == 0 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel$KQueueStreamUnsafe: void clearReadFilter0()>();
return;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel this$0>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannelConfig config()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle recvBufAllocHandle()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel this$0>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline pipeline()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle: void reset(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig)>(v);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe: void readReadyBefore()>();
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel: 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: int recvFd()>();
lookupswitch(v)
{
case -1: goto label;
case 0: goto label;
default: goto label;
};
label:
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle: void lastBytesRead(int)>(0);
goto label;
label:
v = (int) -1;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle: void lastBytesRead(int)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise voidPromise()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe: void close(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v);
label:
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe: void readReadyFinally(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig)>(v);
return;
label:
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle: void lastBytesRead(int)>(1);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle: void incMessagesRead(int)>(1);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe: boolean readPending> = 0;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor: void <init>(int)>(v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline fireChannelRead(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle: boolean continueReading()>();
if v != 0 goto label;
label:
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle: void readComplete()>();
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline fireChannelReadComplete()>();
label:
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe: void readReadyFinally(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig)>(v);
goto label;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle: void readComplete()>();
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline fireChannelReadComplete()>();
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline fireExceptionCaught(java.lang.Throwable)>(v);
label:
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe: void readReadyFinally(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig)>(v);
goto label;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe: void readReadyFinally(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig)>(v);
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
}