final class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native extends java.lang.Object
{
private static final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger;
static final short EV_ADD;
static final short EV_ENABLE;
static final short EV_DISABLE;
static final short EV_DELETE;
static final short EV_CLEAR;
static final short EV_ERROR;
static final short EV_EOF;
static final int NOTE_READCLOSED;
static final int NOTE_CONNRESET;
static final int NOTE_DISCONNECTED;
static final int NOTE_RDHUP;
static final short EV_ADD_CLEAR_ENABLE;
static final short EV_DELETE_DISABLE;
static final short EVFILT_READ;
static final short EVFILT_WRITE;
static final short EVFILT_USER;
static final short EVFILT_SOCK;
static org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor newKQueue()
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor v;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: int kqueueCreate()>();
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor: void <init>(int)>(v);
return v;
}
static 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) throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray v, v;
long v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.Errors$NativeIoException v;
int v, v, v, v, v, v;
v := @parameter: int;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray;
v := @parameter: int;
v := @parameter: int;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray: long memoryAddress()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray: int size()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray: long memoryAddress()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueEventArray: int capacity()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: int keventWait(int,long,int,long,int,int,int)>(v, v, v, v, v, v, v);
if v >= 0 goto label;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.Errors: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.Errors$NativeIoException newIOException(java.lang.String,int)>("kevent", v);
throw v;
label:
return v;
}
private static native int kqueueCreate();
private static native int keventWait(int, long, int, long, int, int, int);
static native int keventTriggerUserEvent(int, int);
static native int keventAddUserEvent(int, int);
static native int sizeofKEvent();
static native int offsetofKEventIdent();
static native int offsetofKEventFlags();
static native int offsetofKEventFFlags();
static native int offsetofKEventFilter();
static native int offsetofKeventData();
private static void loadNativeLibrary()
{
java.lang.IllegalStateException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger v;
java.util.Locale v;
java.lang.ClassLoader v;
java.lang.String v, v, v, v, v;
java.lang.UnsatisfiedLinkError v, v;
boolean v, v, v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.SystemPropertyUtil: java.lang.String get(java.lang.String)>("os.name");
v = <java.util.Locale: java.util.Locale UK>;
v = virtualinvoke v.<java.lang.String: java.lang.String toLowerCase(java.util.Locale)>(v);
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("mac");
if v != 0 goto label;
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>("bsd");
if v != 0 goto label;
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("darwin");
if v != 0 goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("Only supported on BSD");
throw v;
label:
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.PlatformDependent: java.lang.String normalizedArch()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>("netty_transport_native_kqueue", 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[])>("\u0001_\u0001");
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.PlatformDependent: java.lang.ClassLoader getClassLoader(java.lang.Class)>(class "Lorg/apache/hive/kudu/org/apache/kudu/shaded/io/netty/channel/kqueue/Native;");
label:
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.NativeLibraryLoader: void load(java.lang.String,java.lang.ClassLoader)>(v, v);
label:
goto label;
label:
v := @caughtexception;
label:
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.NativeLibraryLoader: void load(java.lang.String,java.lang.ClassLoader)>("netty_transport_native_kqueue", v);
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger>;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("Failed to load {}", v, v);
label:
goto label;
label:
v := @caughtexception;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ThrowableUtil: void addSuppressed(java.lang.Throwable,java.lang.Throwable)>(v, v);
throw v;
label:
return;
catch java.lang.UnsatisfiedLinkError from label to label with label;
catch java.lang.UnsatisfiedLinkError from label to label with label;
}
private void <init>()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
static void <clinit>()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger v;
short v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
int v, v, v, v, v;
java.lang.UnsatisfiedLinkError 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/Native;");
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger> = v;
label:
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: int sizeofKEvent()>();
label:
goto label;
label:
v := @caughtexception;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: void loadNativeLibrary()>();
label:
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.Socket: void initialize()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueStaticallyReferencedJniMethods: short evAdd()>();
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EV_ADD> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueStaticallyReferencedJniMethods: short evEnable()>();
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EV_ENABLE> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueStaticallyReferencedJniMethods: short evDisable()>();
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EV_DISABLE> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueStaticallyReferencedJniMethods: short evDelete()>();
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EV_DELETE> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueStaticallyReferencedJniMethods: short evClear()>();
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EV_CLEAR> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueStaticallyReferencedJniMethods: short evError()>();
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EV_ERROR> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueStaticallyReferencedJniMethods: short evEOF()>();
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EV_EOF> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueStaticallyReferencedJniMethods: short noteReadClosed()>();
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: int NOTE_READCLOSED> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueStaticallyReferencedJniMethods: short noteConnReset()>();
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: int NOTE_CONNRESET> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueStaticallyReferencedJniMethods: short noteDisconnected()>();
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: int NOTE_DISCONNECTED> = v;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: int NOTE_READCLOSED>;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: int NOTE_CONNRESET>;
v = v | v;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: int NOTE_DISCONNECTED>;
v = v | v;
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: int NOTE_RDHUP> = v;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EV_ADD>;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EV_CLEAR>;
v = v | v;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EV_ENABLE>;
v = v | v;
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EV_ADD_CLEAR_ENABLE> = v;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EV_DELETE>;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EV_DISABLE>;
v = v | v;
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EV_DELETE_DISABLE> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueStaticallyReferencedJniMethods: short evfiltRead()>();
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EVFILT_READ> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueStaticallyReferencedJniMethods: short evfiltWrite()>();
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EVFILT_WRITE> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueStaticallyReferencedJniMethods: short evfiltUser()>();
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EVFILT_USER> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueStaticallyReferencedJniMethods: short evfiltSock()>();
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.Native: short EVFILT_SOCK> = v;
return;
catch java.lang.UnsatisfiedLinkError from label to label with label;
}
}