final class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop 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 static final java.util.concurrent.atomic.AtomicIntegerFieldUpdater WAKEN_UP_UPDATER;
private static final int KQUEUE_WAKE_UP_IDENT;
private final boolean allowGrowing;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor kqueueFd;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray changeList;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray eventList;
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.channel.unix.IovArray iovArray;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.IntSupplier selectNowSupplier;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.IntObjectMap channels;
private volatile int wakenUp;
private volatile int ioRatio;
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;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoopTaskQueueFactory v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop$1 v;
int v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor v, v;
java.lang.String 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.concurrent.Executor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoopGroup v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop v;
java.lang.Object v;
java.util.Queue 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.KQueueEventLoop;
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.kqueue.KQueueEventLoop: 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.kqueue.KQueueEventLoop: 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.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.kqueue.KQueueEventLoop: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.IovArray iovArray> = v;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop$1;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop$1: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.IntSupplier selectNowSupplier> = 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.kqueue.KQueueEventLoop: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.IntObjectMap channels> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: 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.kqueue.KQueueEventLoop: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SelectStrategy selectStrategy> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor newKQueue()>();
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.FileDescriptor kqueueFd> = v;
if v != 0 goto label;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: boolean allowGrowing> = 1;
v = 4096;
goto label;
label:
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: boolean allowGrowing> = 0;
label:
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray: void <init>(int)>(v);
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.kqueue.KQueueEventArray changeList> = v;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray: void <init>(int)>(v);
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.kqueue.KQueueEventArray eventList> = v;
v = 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.FileDescriptor kqueueFd>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor: int intValue()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: int keventAddUserEvent(int,int)>(v, 0);
if v >= 0 goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: void cleanup()>();
v = new java.lang.IllegalStateException;
v = neg v;
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[])>("kevent failed to add user event with errno: \u0001");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
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.kqueue.KQueueEventLoop: int DEFAULT_MAX_PENDING_TASKS>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: java.util.Queue newTaskQueue0(int)>(v);
return v;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: 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;
}
void add(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel v;
java.lang.AssertionError v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop v;
int 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.util.collection.IntObjectMap v;
boolean v, v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: boolean $assertionsDisabled>;
if v != 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: 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.kqueue.KQueueEventLoop: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.IntObjectMap channels>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor fd()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor: int intValue()>();
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.kqueue.KQueueEventLoop: 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.kqueue.AbstractKQueueChannel: boolean isOpen()>();
if v == 0 goto label;
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>()>();
throw v;
label:
return;
}
void evSet(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel, short, short, int)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray v;
java.lang.AssertionError v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop v;
short v, v;
int v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel;
v := @parameter: short;
v := @parameter: short;
v := @parameter: int;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: boolean $assertionsDisabled>;
if v != 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: 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.kqueue.KQueueEventLoop: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray changeList>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray: void evSet(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel,short,short,int)>(v, v, v, v);
return;
}
void remove(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel) throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel v;
java.lang.AssertionError v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop v;
int 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.util.collection.IntObjectMap v, v;
boolean v, v, v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: boolean $assertionsDisabled>;
if v != 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: boolean inEventLoop()>();
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.kqueue.AbstractKQueueChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor fd()>();
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.kqueue.KQueueEventLoop: 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.kqueue.KQueueEventLoop: 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.kqueue.KQueueEventLoop: boolean $assertionsDisabled>;
if v != 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: 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.kqueue.AbstractKQueueChannel: boolean isOpen()>();
if v == 0 goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: void unregisterFilters()>();
label:
return;
}
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.IovArray cleanArray()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.IovArray v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop;
v = 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 iovArray>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.IovArray: void clear()>();
v = 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 iovArray>;
return v;
}
protected void wakeup(boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop v;
java.util.concurrent.atomic.AtomicIntegerFieldUpdater v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop;
v := @parameter: boolean;
if v != 0 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: java.util.concurrent.atomic.AtomicIntegerFieldUpdater WAKEN_UP_UPDATER>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicIntegerFieldUpdater: boolean compareAndSet(java.lang.Object,int,int)>(v, 0, 1);
if v == 0 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: void wakeup()>();
label:
return;
}
private void wakeup()
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop;
v = 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.FileDescriptor kqueueFd>;
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.kqueue.Native: int keventTriggerUserEvent(int,int)>(v, 0);
return;
}
private int kqueueWait(boolean) throws java.io.IOException
{
long v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop v;
int v, v, v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop;
v := @parameter: boolean;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: boolean hasTasks()>();
if v == 0 goto label;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: int kqueueWaitNow()>();
return v;
label:
v = staticinvoke <java.lang.System: long nanoTime()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: long delayNanos(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, 2147483647L);
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: int kqueueWait(int,int)>(v, v);
return v;
}
private int kqueueWaitNow() throws java.io.IOException
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: int kqueueWait(int,int)>(0, 0);
return v;
}
private int kqueueWait(int, int) throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop v;
int v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop;
v := @parameter: int;
v := @parameter: int;
v = 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.FileDescriptor kqueueFd>;
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.kqueue.KQueueEventLoop: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray changeList>;
v = 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.kqueue.KQueueEventArray eventList>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: int keventWait(int,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray,int,int)>(v, v, v, v, v);
v = 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.kqueue.KQueueEventArray changeList>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray: void clear()>();
return v;
}
private void processReady(int)
{
java.lang.Integer v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger v;
java.lang.Short v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe v;
boolean v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.IntObjectMap v;
java.lang.Object[] v;
long v;
java.lang.AssertionError v;
short v, v, v, v, v, v, v, v, v, v, v, v, v;
int v, v, v, v, v, v;
java.lang.Object v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop;
v := @parameter: int;
v = 0;
label:
if v >= v goto label;
v = 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.kqueue.KQueueEventArray eventList>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray: short filter(int)>(v);
v = 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.kqueue.KQueueEventArray eventList>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray: short flags(int)>(v);
v = 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.kqueue.KQueueEventArray eventList>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray: int fd(int)>(v);
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EVFILT_USER>;
if v == v goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EV_ERROR>;
v = v & v;
if v == 0 goto label;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: boolean $assertionsDisabled>;
if v != 0 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EVFILT_USER>;
if v != v goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EVFILT_USER>;
if v != v goto label;
if v == 0 goto label;
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.KQueueEventLoop: 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 = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger>;
v = newarray (java.lang.Object)[3];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = 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.kqueue.KQueueEventArray eventList>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray: int fd(int)>(v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = v;
v = staticinvoke <java.lang.Short: java.lang.Short valueOf(short)>(v);
v[2] = v;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger: void warn(java.lang.String,java.lang.Object[])>("events[{}]=[{}, {}] had no channel!", v);
goto label;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel: 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.kqueue.Native: short EVFILT_WRITE>;
if v != v goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel$AbstractKQueueUnsafe: void writeReady()>();
goto label;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EVFILT_READ>;
if v != v goto label;
v = 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.kqueue.KQueueEventArray eventList>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray: long data(int)>(v);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel$AbstractKQueueUnsafe: void readReady(long)>(v);
goto label;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EVFILT_SOCK>;
if v != v goto label;
v = 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.kqueue.KQueueEventArray eventList>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray: short fflags(int)>(v);
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: int NOTE_RDHUP>;
v = v & v;
if v == 0 goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel$AbstractKQueueUnsafe: void readEOF()>();
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EV_EOF>;
v = v & v;
if v == 0 goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel$AbstractKQueueUnsafe: void readEOF()>();
label:
v = v + 1;
goto label;
label:
return;
}
protected void run()
{
java.lang.Throwable v, v, v, v;
java.util.concurrent.atomic.AtomicIntegerFieldUpdater v;
long v, v, v, v, v, v, v, v, v;
int v, 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;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.IntSupplier v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop;
label:
v = 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.SelectStrategy selectStrategy>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: 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.kqueue.KQueueEventLoop: 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 = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: java.util.concurrent.atomic.AtomicIntegerFieldUpdater WAKEN_UP_UPDATER>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicIntegerFieldUpdater: int getAndSet(java.lang.Object,int)>(v, 0);
if v != 1 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: int kqueueWait(boolean)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: int wakenUp>;
if v != 1 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: void wakeup()>();
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: int ioRatio>;
if v != 100 goto label;
label:
if v <= 0 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: void processReady(int)>(v);
label:
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: boolean runAllTasks()>();
goto label;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: boolean runAllTasks()>();
throw v;
label:
v = staticinvoke <java.lang.System: long nanoTime()>();
label:
if v <= 0 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: void processReady(int)>(v);
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.kqueue.KQueueEventLoop: 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.kqueue.KQueueEventLoop: boolean runAllTasks(long)>(v);
throw v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: boolean allowGrowing>;
if v == 0 goto label;
v = 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.kqueue.KQueueEventArray eventList>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray: int capacity()>();
if v != v goto label;
v = 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.kqueue.KQueueEventArray eventList>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray: void realloc(boolean)>(0);
label:
goto label;
label:
v := @caughtexception;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: void handleLoopException(java.lang.Throwable)>(v);
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: boolean isShuttingDown()>();
if v == 0 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: void closeAll()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: boolean confirmShutdown()>();
if v != 0 goto label;
label:
goto label;
label:
v := @caughtexception;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: 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;
}
protected java.util.Queue newTaskQueue(int)
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop v;
java.util.Queue v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop;
v := @parameter: int;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: 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.kqueue.KQueueEventLoop v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: int ioRatio>;
return v;
}
public void setIoRatio(int)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop v;
int v;
java.lang.String v;
java.lang.IllegalArgumentException v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop;
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.kqueue.KQueueEventLoop: int ioRatio> = v;
return;
}
public int registeredChannels()
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop 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.kqueue.KQueueEventLoop;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: 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;
}
protected void cleanup()
{
java.lang.Throwable v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray v, v, v, v;
java.io.IOException 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.kqueue.KQueueEventLoop v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop;
label:
v = 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.FileDescriptor kqueueFd>;
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.kqueue.KQueueEventLoop: 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 kqueue fd.", v);
label:
v = 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.kqueue.KQueueEventArray changeList>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray: void free()>();
v = 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.kqueue.KQueueEventArray eventList>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray: void free()>();
goto label;
label:
v := @caughtexception;
v = 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.kqueue.KQueueEventArray changeList>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray: void free()>();
v = 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.kqueue.KQueueEventArray eventList>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray: void free()>();
throw v;
label:
return;
catch java.io.IOException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
private void closeAll()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel v;
java.lang.Object[] v;
java.util.Collection v;
java.io.IOException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel[] v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe v, v;
int v, 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.kqueue.KQueueEventLoop;
label:
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: int kqueueWaitNow()>();
label:
goto label;
label:
v := @caughtexception;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: 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.kqueue.AbstractKQueueChannel)[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.kqueue.AbstractKQueueChannel: 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.kqueue.AbstractKQueueChannel: 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;
catch java.io.IOException from label to label with label;
}
private static void handleLoopException(java.lang.Throwable)
{
java.lang.Throwable v;
java.lang.InterruptedException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger v;
v := @parameter: java.lang.Throwable;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: 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;
}
static void <clinit>()
{
java.util.concurrent.atomic.AtomicIntegerFieldUpdater v;
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/kqueue/KQueueEventLoop;";
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.KQueueEventLoop: 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/KQueueEventLoop;");
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger> = v;
v = staticinvoke <java.util.concurrent.atomic.AtomicIntegerFieldUpdater: java.util.concurrent.atomic.AtomicIntegerFieldUpdater newUpdater(java.lang.Class,java.lang.String)>(class "Lorg/apache/hive/kudu/org/apache/kudu/shaded/io/netty/channel/kqueue/KQueueEventLoop;", "wakenUp");
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventLoop: java.util.concurrent.atomic.AtomicIntegerFieldUpdater WAKEN_UP_UPDATER> = v;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueue: void ensureAvailability()>();
return;
}
}