final class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.Socket
{
private static final int APPLE_SND_LOW_AT_MAX;
private static final int FREEBSD_SND_LOW_AT_MAX;
static final int BSD_SND_LOW_AT_MAX;
void <init>(int)
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket;
v := @parameter: int;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.Socket: void <init>(int)>(v);
return;
}
void setAcceptFilter(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AcceptFilter) throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
int v;
java.lang.String v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AcceptFilter v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AcceptFilter;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: int intValue()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AcceptFilter: java.lang.String filterName()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AcceptFilter: java.lang.String filterArgs()>();
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: void setAcceptFilter(int,java.lang.String,java.lang.String)>(v, v, v);
return;
}
void setTcpNoPush(boolean) throws java.io.IOException
{
byte v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
int v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket;
v := @parameter: boolean;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: int intValue()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: void setTcpNoPush(int,int)>(v, v);
return;
}
void setSndLowAt(int) throws java.io.IOException
{
int v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket;
v := @parameter: int;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: int intValue()>();
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: void setSndLowAt(int,int)>(v, v);
return;
}
boolean isTcpNoPush() throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
int v, v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: int intValue()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: int getTcpNoPush(int)>(v);
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
int getSndLowAt() throws java.io.IOException
{
int v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: int intValue()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: int getSndLowAt(int)>(v);
return v;
}
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AcceptFilter getAcceptFilter() throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
int v;
java.lang.String[] v;
java.lang.String v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AcceptFilter v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: int intValue()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: java.lang.String[] getAcceptFilter(int)>(v);
if v != null goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AcceptFilter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AcceptFilter PLATFORM_UNSUPPORTED>;
goto label;
label:
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AcceptFilter;
v = v[0];
v = v[1];
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AcceptFilter: void <init>(java.lang.String,java.lang.String)>(v, v);
label:
return v;
}
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.PeerCredentials getPeerCredentials() throws java.io.IOException
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.PeerCredentials v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: int intValue()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.PeerCredentials getPeerCredentials(int)>(v);
return v;
}
long sendFile(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion, long, long, long) throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion v;
long v, v, v, v;
byte v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
int v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion;
v := @parameter: long;
v := @parameter: long;
v := @parameter: long;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: void open()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: int intValue()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: long sendFile(int,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion,long,long,long)>(v, v, v, v, v);
v = v cmp 0L;
if v < 0 goto label;
return v;
label:
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.Errors: int ioResult(java.lang.String,int)>("sendfile", v);
return v;
}
public static org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket newSocketStream()
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: int newSocketStream0()>();
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: void <init>(int)>(v);
return v;
}
public static org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket newSocketDgram()
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: int newSocketDgram0()>();
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: void <init>(int)>(v);
return v;
}
public static org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket newSocketDomain()
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: int newSocketDomain0()>();
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: void <init>(int)>(v);
return v;
}
private static native long sendFile(int, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion, long, long, long) throws java.io.IOException;
private static native java.lang.String[] getAcceptFilter(int) throws java.io.IOException;
private static native int getTcpNoPush(int) throws java.io.IOException;
private static native int getSndLowAt(int) throws java.io.IOException;
private static native org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.PeerCredentials getPeerCredentials(int) throws java.io.IOException;
private static native void setAcceptFilter(int, java.lang.String, java.lang.String) throws java.io.IOException;
private static native void setTcpNoPush(int, int) throws java.io.IOException;
private static native void setSndLowAt(int, int) throws java.io.IOException;
static void <clinit>()
{
int v, v;
v = (int) 32768;
v = staticinvoke <java.lang.Math: int min(int,int)>(131072, v);
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: int BSD_SND_LOW_AT_MAX> = v;
return;
}
}