class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SingleThreadEventLoop
{
private static final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor epollFd;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor eventFd;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor timerFd;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.IntObjectMap channels;
private final boolean allowGrowing;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventArray events;
private org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.IovArray iovArray;
private org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.NativeDatagramPacketArray datagramPacketArray;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SelectStrategy selectStrategy;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.IntSupplier selectNowSupplier;
private static final long AWAKE;
private static final long NONE;
private final java.util.concurrent.atomic.AtomicLong nextWakeupNanos;
private boolean pendingWakeup;
private volatile int ioRatio;
private static final long MAX_SCHEDULED_TIMERFD_NS;
static final boolean $assertionsDisabled;
void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoopGroup, java.util.concurrent.Executor, int, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SelectStrategy, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.RejectedExecutionHandler, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoopTaskQueueFactory)
{
java.lang.IllegalStateException v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SelectStrategy v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.IntObjectHashMap v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.RejectedExecutionHandler v;
java.util.Queue v, v;
java.lang.Throwable v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoopTaskQueueFactory v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop$1 v;
int v, v, v, v, v, v, v, v, v, v, v;
java.util.concurrent.Executor v;
java.io.IOException v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoopGroup v;
java.util.concurrent.atomic.AtomicLong v;
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventArray v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoopGroup;
v := @parameter: java.util.concurrent.Executor;
v := @parameter: int;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SelectStrategy;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.RejectedExecutionHandler;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoopTaskQueueFactory;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: java.util.Queue newTaskQueue(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoopTaskQueueFactory)>(v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: java.util.Queue newTaskQueue(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoopTaskQueueFactory)>(v);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SingleThreadEventLoop: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoopGroup,java.util.concurrent.Executor,boolean,java.util.Queue,java.util.Queue,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.RejectedExecutionHandler)>(v, v, 0, v, v, v);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.IntObjectHashMap;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.IntObjectHashMap: void <init>(int)>(4096);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.IntObjectMap channels> = v;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop$1;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop$1: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.IntSupplier selectNowSupplier> = v;
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>(long)>(-1L);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: java.util.concurrent.atomic.AtomicLong nextWakeupNanos> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: int ioRatio> = 50;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "strategy");
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.SelectStrategy selectStrategy> = v;
if v != 0 goto label;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: boolean allowGrowing> = 1;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventArray;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventArray: void <init>(int)>(4096);
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.epoll.EpollEventArray events> = v;
goto label;
label:
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: boolean allowGrowing> = 0;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventArray;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventArray: void <init>(int)>(v);
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.epoll.EpollEventArray events> = v;
label:
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor newEpollCreate()>();
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.FileDescriptor epollFd> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor newEventFd()>();
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.FileDescriptor eventFd> = v;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor: int intValue()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor: int intValue()>();
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: int EPOLLIN>;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: int EPOLLET>;
v = v | v;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: void epollCtlAdd(int,int,int)>(v, v, v);
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String,java.lang.Throwable)>("Unable to add eventFd filedescriptor to epoll", v);
throw v;
label:
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor newTimerFd()>();
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.FileDescriptor timerFd> = v;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor: int intValue()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor: int intValue()>();
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: int EPOLLIN>;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: int EPOLLET>;
v = v | v;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: void epollCtlAdd(int,int,int)>(v, v, v);
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String,java.lang.Throwable)>("Unable to add timerFd filedescriptor to epoll", v);
throw v;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
private static java.util.Queue newTaskQueue(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoopTaskQueueFactory)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoopTaskQueueFactory v;
int v, v;
java.util.Queue v, v;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoopTaskQueueFactory;
if v != null goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: int DEFAULT_MAX_PENDING_TASKS>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: java.util.Queue newTaskQueue0(int)>(v);
return v;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: int DEFAULT_MAX_PENDING_TASKS>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoopTaskQueueFactory: java.util.Queue newTaskQueue(int)>(v);
return v;
}
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.IovArray cleanIovArray()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.IovArray v, v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop;
v = 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 iovArray>;
if v != null goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.IovArray;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.IovArray: void <init>()>();
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 iovArray> = v;
goto label;
label:
v = 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 iovArray>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.IovArray: void clear()>();
label:
v = 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 iovArray>;
return v;
}
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.NativeDatagramPacketArray cleanDatagramPacketArray()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.NativeDatagramPacketArray v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop;
v = 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.epoll.NativeDatagramPacketArray datagramPacketArray>;
if v != null goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.NativeDatagramPacketArray;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.NativeDatagramPacketArray: void <init>()>();
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.epoll.NativeDatagramPacketArray datagramPacketArray> = v;
goto label;
label:
v = 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.epoll.NativeDatagramPacketArray datagramPacketArray>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.NativeDatagramPacketArray: void clear()>();
label:
v = 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.epoll.NativeDatagramPacketArray datagramPacketArray>;
return v;
}
protected void wakeup(boolean)
{
java.util.concurrent.atomic.AtomicLong v;
byte v;
int v;
long 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.epoll.EpollEventLoop v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop;
v := @parameter: boolean;
if v != 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: java.util.concurrent.atomic.AtomicLong nextWakeupNanos>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long getAndSet(long)>(-1L);
v = v cmp -1L;
if v == 0 goto label;
v = 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.FileDescriptor eventFd>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor: int intValue()>();
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: void eventFdWrite(int,long)>(v, 1L);
label:
return;
}
protected boolean beforeScheduledTaskSubmitted(long)
{
java.util.concurrent.atomic.AtomicLong v;
byte v;
long v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop;
v := @parameter: long;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: java.util.concurrent.atomic.AtomicLong nextWakeupNanos>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long get()>();
v = v cmp v;
if v >= 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
protected boolean afterScheduledTaskSubmitted(long)
{
java.util.concurrent.atomic.AtomicLong v;
byte v;
long v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop;
v := @parameter: long;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: java.util.concurrent.atomic.AtomicLong nextWakeupNanos>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long get()>();
v = v cmp v;
if v >= 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
void add(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel) throws java.io.IOException
{
java.lang.AssertionError v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel v;
int v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket v;
java.lang.Object 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.epoll.EpollEventLoop v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.IntObjectMap v;
boolean v, v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: boolean $assertionsDisabled>;
if v != 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: boolean inEventLoop()>();
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.AbstractEpollChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket socket>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket: int intValue()>();
v = 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.FileDescriptor epollFd>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor: int intValue()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: int flags>;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: void epollCtlAdd(int,int,int)>(v, v, v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.IntObjectMap channels>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.IntObjectMap: java.lang.Object put(int,java.lang.Object)>(v, v);
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: boolean $assertionsDisabled>;
if v != 0 goto label;
if v == null goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: boolean isOpen()>();
if v == 0 goto label;
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>()>();
throw v;
label:
return;
}
void modify(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel) throws java.io.IOException
{
java.lang.AssertionError v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel 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.unix.FileDescriptor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: boolean $assertionsDisabled>;
if v != 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: boolean inEventLoop()>();
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.EpollEventLoop: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor epollFd>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor: int intValue()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket socket>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket: int intValue()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: int flags>;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: void epollCtlMod(int,int,int)>(v, v, v);
return;
}
void remove(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel) throws java.io.IOException
{
java.lang.AssertionError v, v;
int v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor v;
boolean v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket v;
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.IntObjectMap v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: boolean $assertionsDisabled>;
if v != 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: boolean inEventLoop()>();
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.AbstractEpollChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket socket>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket: int intValue()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.IntObjectMap channels>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.IntObjectMap: java.lang.Object remove(int)>(v);
if v == null goto label;
if v == v goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.IntObjectMap channels>;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.IntObjectMap: java.lang.Object put(int,java.lang.Object)>(v, v);
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: boolean $assertionsDisabled>;
if v != 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: boolean isOpen()>();
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.epoll.AbstractEpollChannel: boolean isOpen()>();
if v == 0 goto label;
v = 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.FileDescriptor epollFd>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor: int intValue()>();
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: void epollCtlDel(int,int)>(v, v);
label:
return;
}
protected java.util.Queue newTaskQueue(int)
{
int v;
java.util.Queue v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop;
v := @parameter: int;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: java.util.Queue newTaskQueue0(int)>(v);
return v;
}
private static java.util.Queue newTaskQueue0(int)
{
int v;
java.util.Queue v;
v := @parameter: int;
if v != 2147483647 goto label;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.PlatformDependent: java.util.Queue newMpscQueue()>();
goto label;
label:
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.PlatformDependent: java.util.Queue newMpscQueue(int)>(v);
label:
return v;
}
public int getIoRatio()
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: int ioRatio>;
return v;
}
public void setIoRatio(int)
{
int v;
java.lang.String v;
java.lang.IllegalArgumentException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop;
v := @parameter: int;
if v <= 0 goto label;
if v <= 100 goto label;
label:
v = new java.lang.IllegalArgumentException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(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[])>("ioRatio: \u (expected: 0 < ioRatio <= 100)");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: int ioRatio> = v;
return;
}
public int registeredChannels()
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.IntObjectMap v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.IntObjectMap channels>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.IntObjectMap: int size()>();
return v;
}
private int epollWait(long) throws java.io.IOException
{
long v, v, v, v, v, v, v;
byte v;
int v, v, 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.EpollEventArray v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop;
v := @parameter: long;
v = v cmp 9223372036854775807L;
if v != 0 goto label;
v = 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.FileDescriptor epollFd>;
v = 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.epoll.EpollEventArray events>;
v = 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.FileDescriptor timerFd>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: int epollWait(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventArray,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor,int,int)>(v, v, v, 2147483647, 0);
return v;
label:
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: long deadlineToDelayNanos(long)>(v);
v = v / 1000000000L;
v = staticinvoke <java.lang.Math: long min(long,long)>(v, 2147483647L);
v = v * 1000000000L;
v = v - v;
v = staticinvoke <java.lang.Math: long min(long,long)>(v, 999999999L);
v = 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.FileDescriptor epollFd>;
v = 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.epoll.EpollEventArray events>;
v = 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.FileDescriptor timerFd>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: int epollWait(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventArray,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor,int,int)>(v, v, v, v, v);
return v;
}
private int epollWaitNoTimerChange() throws java.io.IOException
{
int 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.epoll.EpollEventArray v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop;
v = 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.FileDescriptor epollFd>;
v = 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.epoll.EpollEventArray events>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: int epollWait(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventArray,boolean)>(v, v, 0);
return v;
}
private int epollWaitNow() throws java.io.IOException
{
int 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.epoll.EpollEventArray v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop;
v = 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.FileDescriptor epollFd>;
v = 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.epoll.EpollEventArray events>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: int epollWait(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventArray,boolean)>(v, v, 1);
return v;
}
private int epollBusyWait() throws java.io.IOException
{
int 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.epoll.EpollEventArray v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop;
v = 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.FileDescriptor epollFd>;
v = 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.epoll.EpollEventArray events>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: int epollBusyWait(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventArray)>(v, v);
return v;
}
private int epollWaitTimeboxed() throws java.io.IOException
{
int 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.epoll.EpollEventArray v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop;
v = 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.FileDescriptor epollFd>;
v = 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.epoll.EpollEventArray events>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: int epollWait(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventArray,int)>(v, v, 1000);
return v;
}
protected void run()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger v;
byte v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SelectStrategy v;
boolean v, v, v, v, v, v, v, v, v;
java.lang.Throwable v, v, v, v, v;
long v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
int v, v, v, v, v;
java.util.concurrent.atomic.AtomicLong v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.IntSupplier v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventArray v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop;
v = 9223372036854775807L;
label:
v = 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.SelectStrategy selectStrategy>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.IntSupplier selectNowSupplier>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: boolean hasTasks()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SelectStrategy: int calculateStrategy(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.IntSupplier,boolean)>(v, v);
tableswitch(v)
{
case -3: goto label;
case -2: goto label;
case -1: goto label;
default: goto label;
};
label:
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: int epollBusyWait()>();
goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: boolean pendingWakeup>;
if v == 0 goto label;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: int epollWaitTimeboxed()>();
if v != 0 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: 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 warn(java.lang.String)>("Missed eventfd write (not seen after > 1 second)");
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: boolean pendingWakeup> = 0;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: boolean hasTasks()>();
if v != 0 goto label;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: long nextScheduledTaskDeadlineNanos()>();
v = v cmp -1L;
if v != 0 goto label;
v = 9223372036854775807L;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: java.util.concurrent.atomic.AtomicLong nextWakeupNanos>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: void set(long)>(v);
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: boolean hasTasks()>();
if v != 0 goto label;
v = v cmp v;
if v != 0 goto label;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: int epollWaitNoTimerChange()>();
goto label;
label:
v = v;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: int epollWait(long)>(v);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: java.util.concurrent.atomic.AtomicLong nextWakeupNanos>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long get()>();
v = v cmp -1L;
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: java.util.concurrent.atomic.AtomicLong nextWakeupNanos>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long getAndSet(long)>(-1L);
v = v cmp -1L;
if v != 0 goto label;
label:
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: boolean pendingWakeup> = 1;
goto label;
label:
v := @caughtexception;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: java.util.concurrent.atomic.AtomicLong nextWakeupNanos>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long get()>();
v = v cmp -1L;
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: java.util.concurrent.atomic.AtomicLong nextWakeupNanos>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long getAndSet(long)>(-1L);
v = v cmp -1L;
if v != 0 goto label;
label:
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: boolean pendingWakeup> = 1;
label:
throw v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: int ioRatio>;
if v != 100 goto label;
label:
if v <= 0 goto label;
v = 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.epoll.EpollEventArray events>;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: boolean processReady(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventArray,int)>(v, v);
if v == 0 goto label;
v = 9223372036854775807L;
label:
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: boolean runAllTasks()>();
goto label;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: boolean runAllTasks()>();
throw v;
label:
if v <= 0 goto label;
v = staticinvoke <java.lang.System: long nanoTime()>();
label:
v = 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.epoll.EpollEventArray events>;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: boolean processReady(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventArray,int)>(v, v);
if v == 0 goto label;
v = 9223372036854775807L;
label:
v = staticinvoke <java.lang.System: long nanoTime()>();
v = v - v;
v = 100 - v;
v = v * v;
v = v / v;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: boolean runAllTasks(long)>(v);
goto label;
label:
v := @caughtexception;
v = staticinvoke <java.lang.System: long nanoTime()>();
v = v - v;
v = 100 - v;
v = v * v;
v = v / v;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: boolean runAllTasks(long)>(v);
throw v;
label:
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: boolean runAllTasks(long)>(0L);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: boolean allowGrowing>;
if v == 0 goto label;
v = 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.epoll.EpollEventArray events>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventArray: int length()>();
if v != v goto label;
v = 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.epoll.EpollEventArray events>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventArray: void increase()>();
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: void handleLoopException(java.lang.Throwable)>(v);
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: boolean isShuttingDown()>();
if v == 0 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: void closeAll()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: boolean confirmShutdown()>();
if v != 0 goto label;
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: void handleLoopException(java.lang.Throwable)>(v);
goto label;
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;
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;
}
void handleLoopException(java.lang.Throwable)
{
java.lang.Throwable v;
java.lang.InterruptedException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop;
v := @parameter: java.lang.Throwable;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: 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 warn(java.lang.String,java.lang.Throwable)>("Unexpected exception in the selector loop.", v);
label:
staticinvoke <java.lang.Thread: void sleep(long)>(1000L);
label:
goto label;
label:
v := @caughtexception;
label:
return;
catch java.lang.InterruptedException from label to label with label;
}
private void closeAll()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel[] v;
java.lang.Object[] v;
java.util.Collection v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe v, v;
int v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.IntObjectMap v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.IntObjectMap channels>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.IntObjectMap: java.util.Collection values()>();
v = newarray (org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel)[0];
v = interfaceinvoke v.<java.util.Collection: java.lang.Object[] toArray(java.lang.Object[])>(v);
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe unsafe()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe unsafe()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise voidPromise()>();
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe: void close(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v);
v = v + 1;
goto label;
label:
return;
}
private boolean processReady(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventArray, int)
{
long v, v, v;
byte v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor v, v, v;
boolean v;
java.io.IOException v;
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventArray v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.IntObjectMap v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventArray;
v := @parameter: int;
v = 0;
v = 0;
label:
if v >= v goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventArray: int fd(int)>(v);
v = 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.FileDescriptor eventFd>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor: int intValue()>();
if v != v goto label;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: boolean pendingWakeup> = 0;
goto label;
label:
v = 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.FileDescriptor timerFd>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor: int intValue()>();
if v != v goto label;
v = 1;
goto label;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventArray: int events(int)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.IntObjectMap channels>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.IntObjectMap: java.lang.Object get(int)>(v);
if v == null goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe unsafe()>();
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: int EPOLLERR>;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: int EPOLLOUT>;
v = v | 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.epoll.AbstractEpollChannel$AbstractEpollUnsafe: void epollOutReady()>();
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: int EPOLLERR>;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: int EPOLLIN>;
v = v | 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.epoll.AbstractEpollChannel$AbstractEpollUnsafe: void epollInReady()>();
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: int EPOLLRDHUP>;
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.epoll.AbstractEpollChannel$AbstractEpollUnsafe: void epollRdHupReady()>();
goto label;
label:
v = 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.FileDescriptor epollFd>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor: int intValue()>();
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: void epollCtlDel(int,int)>(v, v);
label:
goto label;
label:
v := @caughtexception;
label:
v = v + 1;
goto label;
label:
return v;
catch java.io.IOException from label to label with label;
}
protected void cleanup()
{
java.lang.Throwable v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.NativeDatagramPacketArray v, v, v, v;
int v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor v, v, v, v;
boolean v;
java.io.IOException v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventArray v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.IovArray v, v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: boolean pendingWakeup>;
if v == 0 goto label;
label:
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: int epollWaitTimeboxed()>();
if v == 0 goto label;
label:
v = 0;
label:
if v >= v goto label;
v = 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.epoll.EpollEventArray events>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventArray: int fd(int)>(v);
v = 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.FileDescriptor eventFd>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor: int intValue()>();
if v != v goto label;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: boolean pendingWakeup> = 0;
goto label;
label:
v = v + 1;
goto label;
label:
v := @caughtexception;
goto label;
label:
v = 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.FileDescriptor eventFd>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor: void close()>();
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: 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 warn(java.lang.String,java.lang.Throwable)>("Failed to close the event fd.", v);
label:
v = 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.FileDescriptor timerFd>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor: void close()>();
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: 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 warn(java.lang.String,java.lang.Throwable)>("Failed to close the timer fd.", v);
label:
v = 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.FileDescriptor epollFd>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor: void close()>();
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: 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 warn(java.lang.String,java.lang.Throwable)>("Failed to close the epoll fd.", v);
label:
v = 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 iovArray>;
if v == null goto label;
v = 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 iovArray>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.IovArray: void release()>();
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 iovArray> = null;
label:
v = 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.epoll.NativeDatagramPacketArray datagramPacketArray>;
if v == null goto label;
v = 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.epoll.NativeDatagramPacketArray datagramPacketArray>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.NativeDatagramPacketArray: void release()>();
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.epoll.NativeDatagramPacketArray datagramPacketArray> = null;
label:
v = 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.epoll.EpollEventArray events>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventArray: void free()>();
goto label;
label:
v := @caughtexception;
v = 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 iovArray>;
if v == null goto label;
v = 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 iovArray>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.IovArray: void release()>();
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 iovArray> = null;
label:
v = 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.epoll.NativeDatagramPacketArray datagramPacketArray>;
if v == null goto label;
v = 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.epoll.NativeDatagramPacketArray datagramPacketArray>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.NativeDatagramPacketArray: void release()>();
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.epoll.NativeDatagramPacketArray datagramPacketArray> = null;
label:
v = 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.epoll.EpollEventArray events>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventArray: void free()>();
throw v;
label:
return;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
static void <clinit>()
{
java.lang.Class v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger v;
boolean v, v;
v = class "Lorg/apache/hive/kudu/org/apache/kudu/shaded/io/netty/channel/epoll/EpollEventLoop;";
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.EpollEventLoop: 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/epoll/EpollEventLoop;");
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger> = v;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Epoll: void ensureAvailability()>();
return;
}
}